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