#include <CEC_Reactive_Pulling_Strategy.h>
Inheritance diagram for TAO_CEC_Pull_Event:
Public Member Functions | |
TAO_CEC_Pull_Event (TAO_CEC_ConsumerAdmin *consumer_admin, TAO_CEC_SupplierControl *control) | |
virtual void | work (TAO_CEC_ProxyPullConsumer *consumer) |
Private Attributes | |
TAO_CEC_ConsumerAdmin * | consumer_admin_ |
Used to propagate the events. | |
TAO_CEC_SupplierControl * | supplier_control_ |
To report failed or dead suppliers. |
Definition at line 126 of file CEC_Reactive_Pulling_Strategy.h.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE TAO_CEC_Pull_Event::TAO_CEC_Pull_Event | ( | TAO_CEC_ConsumerAdmin * | consumer_admin, | |
TAO_CEC_SupplierControl * | control | |||
) |
Definition at line 8 of file CEC_Reactive_Pulling_Strategy.inl.
00010 : consumer_admin_ (consumer_admin), 00011 supplier_control_ (control) 00012 { 00013 }
void TAO_CEC_Pull_Event::work | ( | TAO_CEC_ProxyPullConsumer * | consumer | ) | [virtual] |
Implements TAO_ESF_Worker< TAO_CEC_ProxyPullConsumer >.
Definition at line 160 of file CEC_Reactive_Pulling_Strategy.cpp.
References consumer_admin_, TAO_CEC_ConsumerAdmin::push(), and TAO_CEC_ProxyPullConsumer::try_pull_from_supplier().
00161 { 00162 CORBA::Boolean has_event = 0; 00163 CORBA::Any_var any; 00164 00165 try 00166 { 00167 any = consumer->try_pull_from_supplier (has_event); 00168 } 00169 catch (const CORBA::Exception&) 00170 { 00171 // Ignore all exceptions 00172 return; 00173 } 00174 00175 if (has_event) 00176 { 00177 this->consumer_admin_->push (any.in ()); 00178 } 00179 }
Used to propagate the events.
Definition at line 136 of file CEC_Reactive_Pulling_Strategy.h.
Referenced by work().