diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp | 109 |
1 files changed, 0 insertions, 109 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp deleted file mode 100644 index 97e9c83ecbc..00000000000 --- a/TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp +++ /dev/null @@ -1,109 +0,0 @@ -// $Id$ - -#include "EC_ProxyConsumer.h" -#include "EC_Event_Channel.h" -#include "EC_SupplierFiltering.h" - -#if ! defined (__ACE_INLINE__) -#include "EC_ProxyConsumer.i" -#endif /* __ACE_INLINE__ */ - -ACE_RCSID(Event, EC_ProxyConsumer, "$Id$") - -TAO_EC_ProxyPushConsumer:: - TAO_EC_ProxyPushConsumer (TAO_EC_Event_Channel* ec, - TAO_EC_SupplierFiltering* filtering) - : event_channel_ (ec), - supplier_filtering_ (filtering) -{ - this->supplier_filtering_->bind (this); -} - -TAO_EC_ProxyPushConsumer::~TAO_EC_ProxyPushConsumer (void) -{ -} - -void -TAO_EC_ProxyPushConsumer::set_default_POA (PortableServer::POA_ptr poa) -{ - this->default_POA_ = - PortableServer::POA::_duplicate (poa); -} - -PortableServer::POA_ptr -TAO_EC_ProxyPushConsumer::_default_POA (CORBA::Environment&) -{ - return PortableServer::POA::_duplicate (this->default_POA_); -} - -void -TAO_EC_ProxyPushConsumer::connected (TAO_EC_ProxyPushSupplier* supplier, - CORBA::Environment &ACE_TRY_ENV) -{ - this->supplier_filtering_->connected (supplier, ACE_TRY_ENV); -} - -void -TAO_EC_ProxyPushConsumer::disconnected (TAO_EC_ProxyPushSupplier* supplier, - CORBA::Environment &ACE_TRY_ENV) -{ - this->supplier_filtering_->disconnected (supplier, ACE_TRY_ENV); -} - -void -TAO_EC_ProxyPushConsumer::connected (TAO_EC_ProxyPushConsumer*, - CORBA::Environment &) -{ -} - -void -TAO_EC_ProxyPushConsumer::disconnected (TAO_EC_ProxyPushConsumer*, - CORBA::Environment &) -{ -} - -void -TAO_EC_ProxyPushConsumer::connect_push_supplier ( - RtecEventComm::PushSupplier_ptr push_supplier, - const RtecEventChannelAdmin::SupplierQOS& qos, - CORBA::Environment &ACE_TRY_ENV) -{ - if (this->is_connected ()) - ACE_THROW (RtecEventChannelAdmin::AlreadyConnected ()); - - this->supplier_ = - RtecEventComm::PushSupplier::_duplicate (push_supplier); - this->qos_ = qos; - - // Notify the event channel... - this->event_channel_->connected (this, ACE_TRY_ENV); -} - -void -TAO_EC_ProxyPushConsumer::push (const RtecEventComm::EventSet& event, - CORBA::Environment &ACE_TRY_ENV) -{ - this->supplier_filtering_->push (event, ACE_TRY_ENV); -} - -void -TAO_EC_ProxyPushConsumer::disconnect_push_consumer ( - CORBA::Environment &ACE_TRY_ENV) -{ - this->supplier_ = - RtecEventComm::PushSupplier::_nil (); - - PortableServer::POA_var poa = - this->_default_POA (ACE_TRY_ENV); - ACE_CHECK; - PortableServer::ObjectId_var id = - poa->servant_to_id (this, ACE_TRY_ENV); - ACE_CHECK; - poa->deactivate_object (id.in (), ACE_TRY_ENV); - ACE_CHECK; - - this->supplier_filtering_->unbind (this); - this->supplier_filtering_ = 0; - - this->event_channel_->destroy_proxy_push_consumer (this); -} |