TAO/orbsvcs/performance-tests/RTEvent/lib/Peer_Base.cpp

   1 /**
   2  * @file Peer_Base.cpp
   3  *
   4  * @author Carlos O'Ryan <coryan@uci.edu>
   5  */
   6
   7 #include "Peer_Base.h"
   8 #include "RTServer_Setup.h"
   9 #include "RIR_Narrow.h"
  10 #include "Servant_var.h"
  11 #include "RTEC_Initializer.h"
  12 #include "EC_Destroyer.h"
  13 #include "Auto_Disconnect.h"
  14 #include "Loopback.h"
  15
  16 #include "orbsvcs/Event/EC_Event_Channel.h"
  17 #include "orbsvcs/Event/EC_Gateway_IIOP.h"
  18
  19 Peer_Base::Peer_Base (CORBA::ORB_ptr orb,
  20                       RTServer_Setup &rtserver_setup)
  21   : orb_ (CORBA::ORB::_duplicate (orb))
  22   , poa_ (rtserver_setup.poa ())
  23 {
  24   Servant_var<TAO_EC_Event_Channel> ec_impl (
  25       RTEC_Initializer::create (this->poa_.in (),
  26                                 this->poa_.in (),
  27                                 rtserver_setup.rtcorba_setup ())
  28       );
  29
  30   ec_impl->activate ();
  31
  32   PortableServer::ObjectId_var ec_id =
  33     this->poa_->activate_object (ec_impl.in ());
  34   CORBA::Object_var ec_object =
  35     this->poa_->id_to_reference (ec_id.in ());
  36
  37   this->event_channel_ =
  38     RtecEventChannelAdmin::EventChannel::_narrow (ec_object.in ());
  39 }
  40
  41 Peer_Base::~Peer_Base (void)
  42 {
  43 }
  44
  45 void
  46 Peer_Base::shutdown (void)
  47 {
  48   {
  49     EC_Destroyer ec_destroyer (this->event_channel_.in ());
  50     this->event_channel_ =
  51       RtecEventChannelAdmin::EventChannel::_nil ();
  52   }
  53
  54   this->orb_->shutdown (0);
  55 }
  56
  57 CORBA::Object_ptr
  58 Peer_Base::channel (void)
  59 {
  60   return CORBA::Object::_duplicate (this->event_channel_.in ());
  61 }
  62
  63 void
  64 Peer_Base::connect (Federated_Test::Peer_ptr remote_peer)
  65 {
  66   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Connecting....\n"));
  67   CORBA::Object_var remote_ec_object =
  68     remote_peer->channel ();
  69
  70   RtecEventChannelAdmin::EventChannel_var remote_ec =
  71     RtecEventChannelAdmin::EventChannel::_narrow (remote_ec_object.in ());
  72
  73   Servant_var<TAO_EC_Gateway_IIOP> gateway (new TAO_EC_Gateway_IIOP);
  74   gateway->init (remote_ec.in (),
  75                  this->event_channel_.in ());
  76
  77   RtecEventChannelAdmin::Observer_var observer =
  78     gateway->_this ();
  79
  80   RtecEventChannelAdmin::Observer_Handle h =
  81     this->event_channel_->append_observer (observer.in ());
  82
  83   gateway->observer_handle (h);
  84 }
  85
  86 Federated_Test::Loopback_ptr
  87 Peer_Base::setup_loopback (CORBA::Long experiment_id,
  88                            CORBA::Long base_event_type)
  89 {
  90   Servant_var<Loopback> loopback (
  91       new Loopback (experiment_id,
  92                     base_event_type,
  93                     this->poa_.in (),
  94                     this->poa_.in (),
  95                     this->event_channel_.in ()));
  96
  97   Auto_Disconnect<Loopback> disconnect (loopback);
  98
  99   Federated_Test::Loopback_var lb =
 100     loopback->_this ();
 101
 102   disconnect.release ();
 103
 104   return lb._retn ();
 105 }
 106
 107 PortableServer::POA_ptr
 108 Peer_Base::_default_POA (void)
 109 {
 110   return PortableServer::POA::_duplicate (this->poa_.in ());
 111 }