#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. |
1.3.6