#include <Incoming_Message_Queue.h>
Collaboration diagram for TAO_Queued_Data:

Public Methods | |
| TAO_Queued_Data (ACE_Allocator *alloc=0) | |
| Default Constructor. More... | |
| TAO_Queued_Data (ACE_Message_Block *mb, ACE_Allocator *alloc=0) | |
| Constructor. More... | |
| TAO_Queued_Data (const TAO_Queued_Data &qd) | |
| Copy constructor. More... | |
Static Public Methods | |
| TAO_Queued_Data * | get_queued_data (ACE_Allocator *alloc=0) |
| Creation and deletion of a node in the queue. More... | |
| void | release (TAO_Queued_Data *qd) |
| TAO_Queued_Data * | duplicate (TAO_Queued_Data &qd) |
| Duplicate ourselves. This creates a copy of ourselves on the heap and returns a pointer to the duplicated node. More... | |
Public Attributes | |
| ACE_Message_Block * | msg_block_ |
| The message block that contains the message. More... | |
| CORBA::Long | missing_data_ |
| Data missing in the above message that hasn't been read or processed yet. More... | |
| CORBA::Octet | byte_order_ |
| The byte order of the message that is stored in the node.. More... | |
| CORBA::Octet | major_version_ |
| Many protocols like GIOP have a major and minor version information that would be needed to read and decipher the message. More... | |
| CORBA::Octet | minor_version_ |
| CORBA::Octet | more_fragments_ |
| Some messages can be fragmented by the protocol (this is an ORB level fragmentation on top of the TCP/IP fragmentation. This member indicates whether the message that we have recd. and queue already has more fragments that is missing.. More... | |
| TAO_Pluggable_Message_Type | msg_type_ |
| The message type of the message. More... | |
| TAO_Queued_Data * | next_ |
| Pounter to the next element in the queue. More... | |
Static Private Methods | |
| void | replace_data_block (ACE_Message_Block &mb) |
| Replace the datablock with a one allocated on the heap or allocator. More... | |
Private Attributes | |
| ACE_Allocator * | allocator_ |
| The allocator used to allocate this class. More... | |
This class contains necessary information about a message that is stored in the queue. Such a node can be used by the incoming thread from the reactor to dequeue and process the message by sending it to the higher layers of the ORB.
|
|
Default Constructor.
|
|
||||||||||||
|
Constructor.
|
|
|
Copy constructor.
|
|
|
Duplicate ourselves. This creates a copy of ourselves on the heap and returns a pointer to the duplicated node.
|
|
|
Creation and deletion of a node in the queue.
|
|
|
|
|
|
Replace the datablock with a one allocated on the heap or allocator.
|
|
|
The allocator used to allocate this class.
|
|
|
The byte order of the message that is stored in the node..
|
|
|
Many protocols like GIOP have a major and minor version information that would be needed to read and decipher the message.
|
|
|
|
|
|
Data missing in the above message that hasn't been read or processed yet.
|
|
|
Some messages can be fragmented by the protocol (this is an ORB level fragmentation on top of the TCP/IP fragmentation. This member indicates whether the message that we have recd. and queue already has more fragments that is missing..
|
|
|
The message block that contains the message.
|
|
|
The message type of the message.
|
|
|
Pounter to the next element in the queue.
|
1.2.13.1 written by Dimitri van Heesch,
© 1997-2001