TAO_RTEvent
2.1.8
|
Implement the dispatching queues for FIFO and Priority dispatching. More...
#include <EC_Dispatching_Task.h>
Public Member Functions | |
TAO_EC_Dispatching_Task (ACE_Thread_Manager *thr_manager=0, TAO_EC_Queue_Full_Service_Object *queue_full_service_object=0) | |
Constructor. More... | |
virtual int | svc (void) |
Process the events in the queue. More... | |
virtual void | push (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, RtecEventComm::EventSet &event) |
![]() | |
ACE_Task (ACE_Thread_Manager *thr_mgr=0, ACE_Message_Queue< ACE_SYNCH_USE, TIME_POLICY > *mq=0) | |
virtual | ~ACE_Task (void) |
ACE_Message_Queue < ACE_SYNCH_USE, TIME_POLICY > * | msg_queue (void) |
void | msg_queue (ACE_Message_Queue< ACE_SYNCH_USE, TIME_POLICY > *) |
ACE_Time_Value_T< TIME_POLICY > | gettimeofday (void) const |
void | set_time_policy (TIME_POLICY const &time_policy) |
int | putq (ACE_Message_Block *, ACE_Time_Value *timeout=0) |
int | getq (ACE_Message_Block *&mb, ACE_Time_Value *timeout=0) |
int | ungetq (ACE_Message_Block *, ACE_Time_Value *timeout=0) |
int | reply (ACE_Message_Block *mb, ACE_Time_Value *tv=0) |
int | put_next (ACE_Message_Block *msg, ACE_Time_Value *timeout=0) |
const ACE_TCHAR * | name (void) const |
ACE_Task< ACE_SYNCH_USE, TIME_POLICY > * | next (void) |
void | next (ACE_Task< ACE_SYNCH_USE, TIME_POLICY > *) |
ACE_Task< ACE_SYNCH_USE, TIME_POLICY > * | sibling (void) |
ACE_Module< ACE_SYNCH_USE, TIME_POLICY > * | module (void) const |
int | flush (u_long flag=ACE_Task_Flags::ACE_FLUSHALL) |
void | water_marks (ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds, size_t) |
void | dump (void) const |
Private Attributes | |
ACE_Allocator * | allocator_ |
An per-task allocator. More... | |
ACE_Locked_Data_Block < ACE_Lock_Adapter < TAO_SYNCH_MUTEX > > | data_block_ |
Helper data structure to minimize memory allocations... More... | |
TAO_EC_Queue | the_queue_ |
The queue. More... | |
TAO_EC_Queue_Full_Service_Object * | queue_full_service_object_ |
Additional Inherited Members | |
![]() | |
ACE_Message_Queue < ACE_SYNCH_USE, TIME_POLICY > * | msg_queue_ |
bool | delete_msg_queue_ |
ACE_Module< ACE_SYNCH_USE, TIME_POLICY > * | mod_ |
ACE_Task< ACE_SYNCH_USE, TIME_POLICY > * | next_ |
ACE_ALLOC_HOOK_DECLARE | |
![]() | |
size_t | thr_count_ |
ACE_Thread_Manager * | thr_mgr_ |
u_long | flags_ |
int | grp_id_ |
ACE_thread_t | last_thread_id_ |
Implement the dispatching queues for FIFO and Priority dispatching.
TAO_EC_Dispatching_Task::TAO_EC_Dispatching_Task | ( | ACE_Thread_Manager * | thr_manager = 0 , |
TAO_EC_Queue_Full_Service_Object * | queue_full_service_object = 0 |
||
) |
Constructor.
|
virtual |
|
virtual |
Process the events in the queue.
|
private |
An per-task allocator.
|
private |
Helper data structure to minimize memory allocations...
|
private |
|
private |
The queue.