summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/EC_ProxyConsumer.cpp109
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 9c29b480614..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_.in ());
-}
-
-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);
-}