diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/ProxySupplier.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/ProxySupplier.cpp | 71 |
1 files changed, 71 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier.cpp b/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier.cpp new file mode 100644 index 00000000000..e964dff0d62 --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier.cpp @@ -0,0 +1,71 @@ +// $Id$ + +#include "ProxySupplier.h" +#include "Event_Manager.h" + +#if ! defined (__ACE_INLINE__) +#include "ProxySupplier.inl" +#endif /* __ACE_INLINE__ */ + +ACE_RCSID(RT_Notify, TAO_NS_ProxySupplier, "$Id$") + +TAO_NS_ProxySupplier::TAO_NS_ProxySupplier (void) + :consumer_ (0) +{ +} + +TAO_NS_ProxySupplier::~TAO_NS_ProxySupplier () +{ + this->consumer_->_decr_refcnt (); +} + +void +TAO_NS_ProxySupplier::init_ps (ACE_ENV_SINGLE_ARG_DECL) +{ +} + +void +TAO_NS_ProxySupplier::connect (TAO_NS_Consumer *consumer ACE_ENV_ARG_DECL) + ACE_THROW_SPEC (( + CORBA::SystemException + , CosEventChannelAdmin::AlreadyConnected + )) +{ + ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_, + CORBA::INTERNAL ()); + ACE_CHECK; + + if (this->is_connected ()) + ACE_THROW (CosEventChannelAdmin::AlreadyConnected ()); + else + { + consumer_ = consumer; + + event_manager_->subscribe (this, this->subscribed_types_ ACE_ENV_ARG_PARAMETER); + } +} + +void +TAO_NS_ProxySupplier::disconnect (ACE_ENV_SINGLE_ARG_DECL) +{ + event_manager_->un_subscribe (this, this->subscribed_types_ ACE_ENV_ARG_PARAMETER); +} + +void +TAO_NS_ProxySupplier::shutdown (ACE_ENV_SINGLE_ARG_DECL) +{ + this->disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); + + this->inherited::shutdown (ACE_ENV_ARG_PARAMETER); + + //@@ inform the consumer that its disconnected? +} + +void +TAO_NS_ProxySupplier::push (TAO_NS_Event_var &event) +{ + TAO_NS_Method_Request_Dispatch request (event, this); + + this->worker_task ()->exec (request); +} + |