diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.inl')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.inl | 205 |
1 files changed, 205 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.inl b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.inl new file mode 100644 index 00000000000..23f8e906f7c --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.inl @@ -0,0 +1,205 @@ +// -*- C++ -*- +// +// $Id$ + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +ACE_INLINE +TAO_CEC_EventChannel_Attributes:: +TAO_CEC_EventChannel_Attributes (PortableServer::POA_ptr s_poa, + PortableServer::POA_ptr c_poa) + : consumer_reconnect (TAO_CEC_DEFAULT_CONSUMER_RECONNECT), + supplier_reconnect (TAO_CEC_DEFAULT_SUPPLIER_RECONNECT), + disconnect_callbacks (TAO_CEC_DEFAULT_DISCONNECT_CALLBACKS), + supplier_poa (s_poa), + consumer_poa (c_poa) +{ +} + +ACE_INLINE TAO_CEC_Dispatching* +TAO_CEC_EventChannel::dispatching (void) const +{ + return this->dispatching_; +} + +ACE_INLINE TAO_CEC_ConsumerAdmin* +TAO_CEC_EventChannel::consumer_admin (void) const +{ + return this->consumer_admin_; +} + +ACE_INLINE TAO_CEC_SupplierAdmin* +TAO_CEC_EventChannel::supplier_admin (void) const +{ + return this->supplier_admin_; +} + +ACE_INLINE TAO_CEC_ConsumerControl* +TAO_CEC_EventChannel::consumer_control (void) const +{ + return this->consumer_control_; +} + +ACE_INLINE TAO_CEC_SupplierControl* +TAO_CEC_EventChannel::supplier_control (void) const +{ + return this->supplier_control_; +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPushSupplier* &x) +{ + x = this->factory_->create_proxy_push_supplier (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPushSupplier* supplier) +{ + this->factory_->destroy_proxy_push_supplier (supplier); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPullSupplier* &x) +{ + x = this->factory_->create_proxy_pull_supplier (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPullSupplier* supplier) +{ + this->factory_->destroy_proxy_pull_supplier (supplier); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPushConsumer* &x) +{ + x = this->factory_->create_proxy_push_consumer (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPushConsumer* consumer) +{ + this->factory_->destroy_proxy_push_consumer (consumer); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPullConsumer* &x) +{ + x = this->factory_->create_proxy_pull_consumer (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPullConsumer* consumer) +{ + this->factory_->destroy_proxy_pull_consumer (consumer); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPushConsumer_Collection* &x) +{ + x = this->factory_->create_proxy_push_consumer_collection (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPushConsumer_Collection* x) +{ + this->factory_->destroy_proxy_push_consumer_collection (x); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPullConsumer_Collection* &x) +{ + x = this->factory_->create_proxy_pull_consumer_collection (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPullConsumer_Collection* x) +{ + this->factory_->destroy_proxy_pull_consumer_collection (x); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection* &x) +{ + x = this->factory_->create_proxy_push_supplier_collection (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection* x) +{ + this->factory_->destroy_proxy_push_supplier_collection (x); +} + +ACE_INLINE void +TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPullSupplier_Collection* &x) +{ + x = this->factory_->create_proxy_pull_supplier_collection (this); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPullSupplier_Collection* x) +{ + this->factory_->destroy_proxy_pull_supplier_collection (x); +} + +ACE_INLINE PortableServer::POA_ptr +TAO_CEC_EventChannel::supplier_poa (void) +{ + return PortableServer::POA::_duplicate (this->supplier_poa_.in ()); +} + +ACE_INLINE PortableServer::POA_ptr +TAO_CEC_EventChannel::consumer_poa (void) +{ + return PortableServer::POA::_duplicate (this->consumer_poa_.in ()); +} + +ACE_INLINE ACE_Lock* +TAO_CEC_EventChannel::create_consumer_lock (void) +{ + return this->factory_->create_consumer_lock (); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_consumer_lock (ACE_Lock* x) +{ + this->factory_->destroy_consumer_lock (x); +} + +ACE_INLINE ACE_Lock* +TAO_CEC_EventChannel::create_supplier_lock (void) +{ + return this->factory_->create_supplier_lock (); +} + +ACE_INLINE void +TAO_CEC_EventChannel::destroy_supplier_lock (ACE_Lock* x) +{ + this->factory_->destroy_supplier_lock (x); +} + +ACE_INLINE int +TAO_CEC_EventChannel::consumer_reconnect (void) const +{ + return this->consumer_reconnect_; +} + +ACE_INLINE int +TAO_CEC_EventChannel::supplier_reconnect (void) const +{ + return this->supplier_reconnect_; +} + +ACE_INLINE int +TAO_CEC_EventChannel::disconnect_callbacks (void) const +{ + return this->disconnect_callbacks_; +} + +ACE_INLINE TAO_CEC_EventChannel::ServantRetryMap& +TAO_CEC_EventChannel::get_servant_retry_map (void) +{ + return this->retry_map_; +} + +TAO_END_VERSIONED_NAMESPACE_DECL |