ACE_Stream_Head< ACE_SYNCH_DECL > Class Template Reference
Standard task that acts as reader or writer at the head of an ACE_Stream. More...
#include <Stream_Modules.h>
Public Member Functions | |
| ACE_Stream_Head (void) | |
| Construction. | |
| ~ACE_Stream_Head (void) | |
| Destruction. | |
| virtual int | open (void *a=0) |
| virtual int | close (u_long flags=0) |
| virtual int | put (ACE_Message_Block *msg, ACE_Time_Value *=0) |
| virtual int | svc (void) |
| Run by a daemon thread to handle deferred processing. | |
| virtual int | init (int argc, ACE_TCHAR *argv[]) |
| Initializes object when dynamic linking occurs. | |
| virtual int | info (ACE_TCHAR **info_string, size_t length) const |
| Returns information on a service object. | |
| virtual int | fini (void) |
| Terminates object when dynamic unlinking occurs. | |
| void | dump (void) const |
| Dump the state of an object. | |
Public Attributes | |
| ACE_ALLOC_HOOK_DECLARE | |
| Declare the dynamic allocation hooks. | |
Private Member Functions | |
| int | control (ACE_Message_Block *) |
| Performs canonical flushing at the ACE_Stream Head. | |
| int | canonical_flush (ACE_Message_Block *) |
Detailed Description
template<ACE_SYNCH_DECL>
class ACE_Stream_Head< ACE_SYNCH_DECL >
Standard task that acts as reader or writer at the head of an ACE_Stream.
A ACE_Message_Block sent to this task (via its put() hook) triggers actions depending on the block type and whether the task is acting as a reader or a writer. If the block is of type ACE_Message_Block::MB_IOCTL, the block's is assumed to contain (beginning at its rd_ptr()) an ACE_IO_Cntl_Msg object and is processed accordingly. This is usually used to set the task's message queue high water and/or low water marks.
When the block is not ACE_Message_Block::MB_IOCTL, processing depends on the ACE_Stream_Head's role in the module:
- Reader: If the block is of type ACE_Message_Block::MB_FLUSH, the canonical_flush() method is called. (
- See also:
- ACE_Stream::canonical_flush().) If the block is any other type, it is queued on this task's message queue. It would thus be available to caller's reading blocks from the containing stream.
- Writer: The block is passed to the next module in the stream.
Constructor & Destructor Documentation
| ACE_BEGIN_VERSIONED_NAMESPACE_DECL ACE_Stream_Head< ACE_SYNCH_DECL >::ACE_Stream_Head | ( | void | ) | [inline] |
Construction.
| ACE_Stream_Head< ACE_SYNCH_DECL >::~ACE_Stream_Head | ( | void | ) | [inline] |
Destruction.
Member Function Documentation
| int ACE_Stream_Head< ACE_SYNCH_DECL >::open | ( | void * | args = 0 |
) | [inline, virtual] |
Hook called to initialize a task and prepare it for execution. args can be used to pass arbitrary information into <open>.
Reimplemented from ACE_Task_Base.
| int ACE_Stream_Head< ACE_SYNCH_DECL >::close | ( | u_long | flags = 0 |
) | [inline, virtual] |
Hook called from ACE_Thread_Exit when during thread exit and from the default implementation of <module_closed>. In general, this method shouldn't be called directly by an application, particularly if the <Task> is running as an Active Object. Instead, a special message should be passed into the <Task> via the <put> method defined below, and the <svc> method should interpret this as a flag to shut down the <Task>.
Reimplemented from ACE_Task_Base.
| int ACE_Stream_Head< ACE_SYNCH_DECL >::put | ( | ACE_Message_Block * | , | |
| ACE_Time_Value * | = 0 | |||
| ) | [inline, virtual] |
A hook method that can be used to pass a message to a task, where it can be processed immediately or queued for subsequent processing in the <svc> hook method.
Reimplemented from ACE_Task_Base.
| int ACE_Stream_Head< ACE_SYNCH_DECL >::svc | ( | void | ) | [inline, virtual] |
| int ACE_Stream_Head< ACE_SYNCH_DECL >::init | ( | int | argc, | |
| ACE_TCHAR * | argv[] | |||
| ) | [inline, virtual] |
| int ACE_Stream_Head< ACE_SYNCH_DECL >::info | ( | ACE_TCHAR ** | info_string, | |
| size_t | length | |||
| ) | const [inline, virtual] |
| int ACE_Stream_Head< ACE_SYNCH_DECL >::fini | ( | void | ) | [inline, virtual] |
| void ACE_Stream_Head< ACE_SYNCH_DECL >::dump | ( | void | ) | const [inline] |
| int ACE_Stream_Head< ACE_SYNCH_DECL >::control | ( | ACE_Message_Block * | mb | ) | [inline, private] |
Performs canonical flushing at the ACE_Stream Head.
| int ACE_Stream_Head< ACE_SYNCH_DECL >::canonical_flush | ( | ACE_Message_Block * | mb | ) | [inline, private] |
Member Data Documentation
| ACE_Stream_Head< ACE_SYNCH_DECL >::ACE_ALLOC_HOOK_DECLARE |
The documentation for this class was generated from the following files:
