00001 // -*- C++ -*- 00002 // 00003 // CEC_EventChannel.i,v 1.6 2005/11/10 06:47:23 ossama Exp 00004 00005 TAO_BEGIN_VERSIONED_NAMESPACE_DECL 00006 00007 ACE_INLINE 00008 TAO_CEC_EventChannel_Attributes:: 00009 TAO_CEC_EventChannel_Attributes (PortableServer::POA_ptr s_poa, 00010 PortableServer::POA_ptr c_poa) 00011 : consumer_reconnect (TAO_CEC_DEFAULT_CONSUMER_RECONNECT), 00012 supplier_reconnect (TAO_CEC_DEFAULT_SUPPLIER_RECONNECT), 00013 disconnect_callbacks (TAO_CEC_DEFAULT_DISCONNECT_CALLBACKS), 00014 supplier_poa (s_poa), 00015 consumer_poa (c_poa) 00016 { 00017 } 00018 00019 ACE_INLINE TAO_CEC_Dispatching* 00020 TAO_CEC_EventChannel::dispatching (void) const 00021 { 00022 return this->dispatching_; 00023 } 00024 00025 ACE_INLINE TAO_CEC_ConsumerAdmin* 00026 TAO_CEC_EventChannel::consumer_admin (void) const 00027 { 00028 return this->consumer_admin_; 00029 } 00030 00031 ACE_INLINE TAO_CEC_SupplierAdmin* 00032 TAO_CEC_EventChannel::supplier_admin (void) const 00033 { 00034 return this->supplier_admin_; 00035 } 00036 00037 ACE_INLINE TAO_CEC_ConsumerControl* 00038 TAO_CEC_EventChannel::consumer_control (void) const 00039 { 00040 return this->consumer_control_; 00041 } 00042 00043 ACE_INLINE TAO_CEC_SupplierControl* 00044 TAO_CEC_EventChannel::supplier_control (void) const 00045 { 00046 return this->supplier_control_; 00047 } 00048 00049 ACE_INLINE void 00050 TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPushSupplier* &x) 00051 { 00052 x = this->factory_->create_proxy_push_supplier (this); 00053 } 00054 00055 ACE_INLINE void 00056 TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPushSupplier* supplier) 00057 { 00058 this->factory_->destroy_proxy_push_supplier (supplier); 00059 } 00060 00061 ACE_INLINE void 00062 TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPullSupplier* &x) 00063 { 00064 x = this->factory_->create_proxy_pull_supplier (this); 00065 } 00066 00067 ACE_INLINE void 00068 TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPullSupplier* supplier) 00069 { 00070 this->factory_->destroy_proxy_pull_supplier (supplier); 00071 } 00072 00073 ACE_INLINE void 00074 TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPushConsumer* &x) 00075 { 00076 x = this->factory_->create_proxy_push_consumer (this); 00077 } 00078 00079 ACE_INLINE void 00080 TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPushConsumer* consumer) 00081 { 00082 this->factory_->destroy_proxy_push_consumer (consumer); 00083 } 00084 00085 ACE_INLINE void 00086 TAO_CEC_EventChannel::create_proxy (TAO_CEC_ProxyPullConsumer* &x) 00087 { 00088 x = this->factory_->create_proxy_pull_consumer (this); 00089 } 00090 00091 ACE_INLINE void 00092 TAO_CEC_EventChannel::destroy_proxy (TAO_CEC_ProxyPullConsumer* consumer) 00093 { 00094 this->factory_->destroy_proxy_pull_consumer (consumer); 00095 } 00096 00097 ACE_INLINE void 00098 TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPushConsumer_Collection* &x) 00099 { 00100 x = this->factory_->create_proxy_push_consumer_collection (this); 00101 } 00102 00103 ACE_INLINE void 00104 TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPushConsumer_Collection* x) 00105 { 00106 this->factory_->destroy_proxy_push_consumer_collection (x); 00107 } 00108 00109 ACE_INLINE void 00110 TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPullConsumer_Collection* &x) 00111 { 00112 x = this->factory_->create_proxy_pull_consumer_collection (this); 00113 } 00114 00115 ACE_INLINE void 00116 TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPullConsumer_Collection* x) 00117 { 00118 this->factory_->destroy_proxy_pull_consumer_collection (x); 00119 } 00120 00121 ACE_INLINE void 00122 TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection* &x) 00123 { 00124 x = this->factory_->create_proxy_push_supplier_collection (this); 00125 } 00126 00127 ACE_INLINE void 00128 TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection* x) 00129 { 00130 this->factory_->destroy_proxy_push_supplier_collection (x); 00131 } 00132 00133 ACE_INLINE void 00134 TAO_CEC_EventChannel::create_proxy_collection (TAO_CEC_ProxyPullSupplier_Collection* &x) 00135 { 00136 x = this->factory_->create_proxy_pull_supplier_collection (this); 00137 } 00138 00139 ACE_INLINE void 00140 TAO_CEC_EventChannel::destroy_proxy_collection (TAO_CEC_ProxyPullSupplier_Collection* x) 00141 { 00142 this->factory_->destroy_proxy_pull_supplier_collection (x); 00143 } 00144 00145 ACE_INLINE PortableServer::POA_ptr 00146 TAO_CEC_EventChannel::supplier_poa (void) 00147 { 00148 return PortableServer::POA::_duplicate (this->supplier_poa_.in ()); 00149 } 00150 00151 ACE_INLINE PortableServer::POA_ptr 00152 TAO_CEC_EventChannel::consumer_poa (void) 00153 { 00154 return PortableServer::POA::_duplicate (this->consumer_poa_.in ()); 00155 } 00156 00157 ACE_INLINE ACE_Lock* 00158 TAO_CEC_EventChannel::create_consumer_lock (void) 00159 { 00160 return this->factory_->create_consumer_lock (); 00161 } 00162 00163 ACE_INLINE void 00164 TAO_CEC_EventChannel::destroy_consumer_lock (ACE_Lock* x) 00165 { 00166 this->factory_->destroy_consumer_lock (x); 00167 } 00168 00169 ACE_INLINE ACE_Lock* 00170 TAO_CEC_EventChannel::create_supplier_lock (void) 00171 { 00172 return this->factory_->create_supplier_lock (); 00173 } 00174 00175 ACE_INLINE void 00176 TAO_CEC_EventChannel::destroy_supplier_lock (ACE_Lock* x) 00177 { 00178 this->factory_->destroy_supplier_lock (x); 00179 } 00180 00181 ACE_INLINE int 00182 TAO_CEC_EventChannel::consumer_reconnect (void) const 00183 { 00184 return this->consumer_reconnect_; 00185 } 00186 00187 ACE_INLINE int 00188 TAO_CEC_EventChannel::supplier_reconnect (void) const 00189 { 00190 return this->supplier_reconnect_; 00191 } 00192 00193 ACE_INLINE int 00194 TAO_CEC_EventChannel::disconnect_callbacks (void) const 00195 { 00196 return this->disconnect_callbacks_; 00197 } 00198 00199 ACE_INLINE TAO_CEC_EventChannel::ServantRetryMap& 00200 TAO_CEC_EventChannel::get_servant_retry_map (void) 00201 { 00202 return this->retry_map_; 00203 } 00204 00205 TAO_END_VERSIONED_NAMESPACE_DECL