#include <Reactive_Task.h>
Inheritance diagram for TAO_Notify_Reactive_Task:
Public Member Functions | |
TAO_Notify_Reactive_Task (void) | |
Constuctor. | |
virtual | ~TAO_Notify_Reactive_Task () |
Destructor. | |
void | init () |
Init the reactive task. | |
virtual void | shutdown (void) |
Shutdown task. | |
virtual void | execute (TAO_Notify_Method_Request &method_request) |
Exec the request. | |
virtual TAO_Notify_Timer * | timer (void) |
The object used by clients to register timers. This method returns a Reactor based Timer. | |
virtual TAO_Notify_Buffering_Strategy * | buffering_strategy (void) |
Returns NULL. | |
Private Member Functions | |
virtual void | release (void) |
Release. | |
Private Attributes | |
TAO_Notify_Timer_Reactor::Ptr | timer_ |
The timer. |
Definition at line 35 of file Reactive_Task.h.
|
Constuctor.
Definition at line 15 of file Reactive_Task.cpp.
00016 :timer_ (0) 00017 { 00018 } |
|
Destructor.
Definition at line 20 of file Reactive_Task.cpp.
00021 { 00022 } |
|
Returns NULL.
Definition at line 8 of file Reactive_Task.inl.
00009 {
00010 return 0;
00011 }
|
|
Exec the request.
Implements TAO_Notify_Worker_Task. Definition at line 48 of file Reactive_Task.cpp. References ACE_ENV_SINGLE_ARG_PARAMETER.
00049 { 00050 method_request.execute (ACE_ENV_SINGLE_ARG_PARAMETER); 00051 } |
|
Init the reactive task.
Definition at line 25 of file Reactive_Task.cpp. References ACE_ASSERT, and ACE_NEW_THROW_EX. Referenced by TAO_Notify_Builder::apply_reactive_concurrency().
00026 { 00027 ACE_ASSERT (this->timer_.get() == 0); 00028 00029 TAO_Notify_Timer_Reactor* timer = 0; 00030 ACE_NEW_THROW_EX (timer, 00031 TAO_Notify_Timer_Reactor (), 00032 CORBA::NO_MEMORY ()); 00033 this->timer_.reset (timer); 00034 } |
|
Release.
Implements TAO_Notify_Refcountable. Definition at line 37 of file Reactive_Task.cpp.
00038 { 00039 delete this; //TODO: Release via factory. 00040 } |
|
Shutdown task.
Implements TAO_Notify_Worker_Task. Definition at line 43 of file Reactive_Task.cpp.
00044 { 00045 } |
|
The object used by clients to register timers. This method returns a Reactor based Timer.
Implements TAO_Notify_Worker_Task. Definition at line 54 of file Reactive_Task.cpp.
00055 { 00056 return this->timer_.get(); 00057 } |
|
The timer.
Definition at line 62 of file Reactive_Task.h. |