TAO/orbsvcs/tests/Notify/lib/Peer_T.cpp

   1 #ifndef TAO_Notify_Tests_Peer_T_CPP
   2 #define TAO_Notify_Tests_Peer_T_CPP
   3
   4 #include "Peer_T.h"
   5
   6 #include "ace/Arg_Shifter.h"
   7 #include "Name.h"
   8 #include "LookupManager.h"
   9 #include "Options_Parser.h"
  10 #include "orbsvcs/NotifyExtC.h"
  11
  12 template <class Peer_Traits>
  13 TAO_Notify_Tests_Peer_T<Peer_Traits>::TAO_Notify_Tests_Peer_T ()
  14   : proxy_id_ (0)
  15 {
  16 }
  17
  18 template <class Peer_Traits>
  19 TAO_Notify_Tests_Peer_T<Peer_Traits>::~TAO_Notify_Tests_Peer_T ()
  20 {
  21 }
  22
  23 template <class Peer_Traits>
  24 typename TAO_Notify_Tests_Peer_T<Peer_Traits>::Proxy_Traits_PTR
  25 TAO_Notify_Tests_Peer_T<Peer_Traits>::get_proxy ()
  26 {
  27   return proxy_.in ();
  28 }
  29
  30 template <class Peer_Traits>
  31 typename TAO_Notify_Tests_Peer_T<Peer_Traits>::Peer_Traits_PTR
  32 TAO_Notify_Tests_Peer_T<Peer_Traits>::activate ()
  33 {
  34   return this->_this ();
  35 }
  36
  37 template <class Peer_Traits>
  38 void
  39 TAO_Notify_Tests_Peer_T<Peer_Traits>::connect (Proxy_Traits_PTR proxy,
  40                                                Proxy_Traits_ID proxy_id)
  41 {
  42   // This will decr the ref count on exit.
  43   // Clients of this class should use raw pointers, not vars.
  44   PortableServer::ServantBase_var servant_var (this);
  45
  46   typename Peer_Traits::VAR peer_var =
  47     this->activate ();
  48
  49   this->connect_to_peer (proxy, peer_var.in ());
  50
  51   // save the proxy
  52   this->proxy_ = Proxy_Traits_INTERFACE::_duplicate (proxy);
  53   this->proxy_id_ = proxy_id;
  54
  55   // Register the proxy.
  56   if (this->proxy_name_.length () != 0)
  57     {
  58       LOOKUP_MANAGER->_register (this->proxy_.in (),
  59                                  this->proxy_name_.c_str ());
  60     }
  61 }
  62
  63 template <class Peer_Traits>
  64 void
  65 TAO_Notify_Tests_Peer_T<Peer_Traits>::connect (Admin_Traits_PTR admin_ptr)
  66 {
  67   typename Proxy_Traits::VAR proxy_var =
  68     this->obtain_proxy (admin_ptr);
  69
  70   ACE_ASSERT (!CORBA::is_nil (proxy_var.in ()));
  71
  72   this->connect (proxy_var.in (),
  73                  this->proxy_id_);
  74 }
  75
  76
  77 template <class Peer_Traits>
  78 void
  79 TAO_Notify_Tests_Peer_T<Peer_Traits>::connect ()
  80 {
  81   // Get the POA
  82   PortableServer::POA_var poa;
  83   LOOKUP_MANAGER->resolve (poa,
  84                            this->poa_name_.c_str ());
  85
  86   // set the POA
  87   this->set_poa (poa.in ());
  88
  89   // Resolve the admin
  90   typename Admin_Traits::VAR admin_var;
  91
  92   LOOKUP_MANAGER->resolve (admin_var,
  93                            this->admin_name_.c_str ());
  94
  95   typename Admin_Ext_Traits::VAR admin_ext_var =
  96     Admin_Ext_Traits_INTERFACE::_narrow (admin_var.in ());
  97
  98   typename Proxy_Traits::VAR proxy_var =
  99     this->obtain_proxy (admin_ext_var.in (),
 100                         this->qos_);
 101
 102   ACE_ASSERT (!CORBA::is_nil (proxy_var.in ()));
 103
 104   // connect supplier to proxy,
 105   // also activates the servant as CORBA object in the POA specified.
 106   this->connect (proxy_var.in (),
 107                  this->proxy_id_);
 108 }
 109
 110 template <class Peer_Traits>
 111 void
 112 TAO_Notify_Tests_Peer_T<Peer_Traits>::set_qos (
 113     CosNotification::QoSProperties& qos
 114   )
 115 {
 116   this->get_proxy ()->set_qos (qos);
 117 }
 118
 119 template <class Peer_Traits>
 120 void
 121 TAO_Notify_Tests_Peer_T<Peer_Traits>::status ()
 122 {
 123 #if (TAO_HAS_MINIMUM_CORBA == 0)
 124   try
 125     {
 126       CORBA::Boolean not_exist =
 127         this->get_proxy ()->_non_existent ();
 128
 129       if (not_exist == 1)
 130         {
 131           ACE_DEBUG ((LM_DEBUG,
 132                       "Peer %s, Proxy does not exist\n",
 133                       this->name_.c_str ()));
 134         }
 135       else
 136         {
 137           ACE_DEBUG ((LM_DEBUG,
 138                       "Peer %s, Proxy exists\n",
 139                       this->name_.c_str ()));
 140         }
 141     }
 142   catch (const CORBA::TRANSIENT& ex)
 143     {
 144       ex._tao_print_exception ("Error: ");
 145       ACE_DEBUG ((LM_DEBUG,
 146                   "Peer %s is_equivalent transient exception.",
 147                   this->name_.c_str ()));
 148     }
 149   catch (const CORBA::Exception& ex)
 150     {
 151       ex._tao_print_exception ("Error: ");
 152       ACE_DEBUG ((LM_DEBUG,
 153                   "Peer %s is_equivanent other exception.",
 154                   this->name_.c_str ()));
 155     }
 156 #endif /* TAO_HAS_MINIMUM_CORBA */
 157 }
 158
 159 template <class Peer_Traits>
 160 void
 161 TAO_Notify_Tests_Peer_T<Peer_Traits>::disconnect ()
 162 {
 163   ACE_ASSERT (!CORBA::is_nil (this->proxy_.in ()));
 164
 165   try
 166     {
 167       this->disconnect_from_proxy ();
 168     }
 169   catch (const CORBA::Exception&)
 170     {
 171       ACE_DEBUG ((LM_DEBUG,
 172                   "Peer %s failed to disconnect from proxy.",
 173                   this->name_.c_str ()));
 174     }
 175
 176   try
 177     {
 178       this->deactivate ();
 179     }
 180   catch (const CORBA::Exception&)
 181     {
 182       ACE_DEBUG ((LM_DEBUG,
 183                   "Peer %s failed to deactivate.",
 184                   this->name_.c_str ()));
 185     }
 186 }
 187
 188 template <class Peer_Traits>
 189 PortableServer::POA_ptr
 190 TAO_Notify_Tests_Peer_T<Peer_Traits>::_default_POA (
 191   )
 192 {
 193   return PortableServer::POA::_duplicate (this->default_POA_.in ());
 194 }
 195
 196 template <class Peer_Traits>
 197 void
 198 TAO_Notify_Tests_Peer_T<Peer_Traits>::deactivate ()
 199 {
 200   PortableServer::POA_var poa = this->_default_POA ();
 201
 202   PortableServer::ObjectId_var id =
 203     poa->servant_to_id (this);
 204
 205   poa->deactivate_object (id.in ());
 206 }
 207
 208 #endif /* TAO_Notify_Tests_Peer_T_CPP */