#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 8 of file CEC_Reactive_Pulling_Strategy.i.
00010 : consumer_admin_ (consumer_admin), 00011 supplier_control_ (control) 00012 { 00013 } |
|
Implements TAO_ESF_Worker< TAO_CEC_ProxyPullConsumer >. Definition at line 178 of file CEC_Reactive_Pulling_Strategy.cpp. References ACE_CATCHANY, ACE_CHECK, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_TRY, ACE_TRY_CHECK, and TAO_CEC_ConsumerAdmin::push().
00180 { 00181 CORBA::Boolean has_event = 0; 00182 CORBA::Any_var any; 00183 00184 ACE_TRY 00185 { 00186 any = consumer->try_pull_from_supplier (has_event 00187 ACE_ENV_ARG_PARAMETER); 00188 ACE_TRY_CHECK; 00189 } 00190 ACE_CATCHANY 00191 { 00192 // Ignore all exceptions 00193 return; 00194 } 00195 ACE_ENDTRY; 00196 00197 if (has_event) 00198 { 00199 this->consumer_admin_->push (any.in () ACE_ENV_ARG_PARAMETER); 00200 ACE_CHECK; 00201 } 00202 } |
|
Used to propagate the events.
Definition at line 137 of file CEC_Reactive_Pulling_Strategy.h. |
|
To report failed or dead suppliers.
Definition at line 140 of file CEC_Reactive_Pulling_Strategy.h. |