TAO  2.2.5
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Static Public Member Functions | Static Private Member Functions | Private Attributes | List of all members
TAO_Queued_Data Class Reference

Represents a node in the queue of incoming messages. More...

#include <Queued_Data.h>

Collaboration diagram for TAO_Queued_Data:
Collaboration graph

Public Member Functions

 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...
 
int consolidate (void)
 
size_t missing_data (void) const
 Get missing data. More...
 
void missing_data (size_t data)
 Set missing data. More...
 
TAO_GIOP_Message_Version const & giop_version (void) const
 Get the GIOP version. More...
 
CORBA::Octet byte_order (void) const
 Get byte_order. More...
 
CORBA::Boolean more_fragments (void) const
 Get more fragments. More...
 
GIOP::MsgType msg_type (void) const
 Get message type. More...
 
TAO_Queued_Datanext (void) const
 Get next. More...
 
void next (TAO_Queued_Data *qd)
 Set next. More...
 
ACE_Message_Blockmsg_block (void) const
 Get message block. More...
 
void msg_block (ACE_Message_Block *mb)
 Set message block. More...
 
void state (const TAO_GIOP_Message_State &state)
 Set the state. More...
 
const TAO_GIOP_Message_Statestate (void) const
 Get the state. More...
 

Static Public Member Functions

static TAO_Queued_Datamake_queued_data (ACE_Allocator *message_buffer_alloc=0, ACE_Allocator *input_cdr_alloc=0, ACE_Data_Block *db=0)
 Creation of a node in the queue. More...
 
static void release (TAO_Queued_Data *qd)
 Deletion of a node from the queue. More...
 
static TAO_Queued_Dataduplicate (TAO_Queued_Data &qd)
 

Static Private Member Functions

static void replace_data_block (ACE_Message_Block &mb)
 

Private Attributes

ACE_Message_Blockmsg_block_
 The message block that contains the message. More...
 
TAO_GIOP_Message_State state_
 State of this queued data. More...
 
TAO_Queued_Datanext_
 Pounter to the next element in the queue. More...
 
ACE_Allocatorallocator_
 The allocator used to allocate this class. More...
 
Missing Data details

The missing_data_ member contains the number of bytes of data missing from msg_block_.

size_t missing_data_
 

Detailed Description

Represents a node in the queue of incoming messages.

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.

The ACE_Message_Block contained within this class may contain a chain of message blocks (usually when GIOP fragments are involved). In that case consolidate () needs to be called prior to being sent to higher layers of the ORB when the GIOP fragment chain is complete.

Constructor & Destructor Documentation

TAO_Queued_Data::TAO_Queued_Data ( ACE_Allocator alloc = 0)

Default Constructor.

TAO_Queued_Data::TAO_Queued_Data ( ACE_Message_Block mb,
ACE_Allocator alloc = 0 
)

Constructor.

TAO_Queued_Data::TAO_Queued_Data ( const TAO_Queued_Data qd)

Copy constructor.

Member Function Documentation

CORBA::Octet TAO_Queued_Data::byte_order ( void  ) const

Get byte_order.

int TAO_Queued_Data::consolidate ( void  )

Consolidate this fragments chained message blocks into one.

Returns
-1 if consolidation failed, eg out or memory, otherwise 0
TAO_Queued_Data * TAO_Queued_Data::duplicate ( TAO_Queued_Data qd)
static

Duplicate ourselves. This creates a copy of ourselves on the heap and returns a pointer to the duplicated node.

TAO_GIOP_Message_Version const & TAO_Queued_Data::giop_version ( void  ) const

Get the GIOP version.

TAO_Queued_Data * TAO_Queued_Data::make_queued_data ( ACE_Allocator message_buffer_alloc = 0,
ACE_Allocator input_cdr_alloc = 0,
ACE_Data_Block db = 0 
)
static

Creation of a node in the queue.

size_t TAO_Queued_Data::missing_data ( void  ) const

Get missing data.

void TAO_Queued_Data::missing_data ( size_t  data)

Set missing data.

CORBA::Boolean TAO_Queued_Data::more_fragments ( void  ) const

Get more fragments.

ACE_Message_Block * TAO_Queued_Data::msg_block ( void  ) const

Get message block.

void TAO_Queued_Data::msg_block ( ACE_Message_Block mb)

Set message block.

GIOP::MsgType TAO_Queued_Data::msg_type ( void  ) const

Get message type.

TAO_Queued_Data * TAO_Queued_Data::next ( void  ) const

Get next.

void TAO_Queued_Data::next ( TAO_Queued_Data qd)

Set next.

void TAO_Queued_Data::release ( TAO_Queued_Data qd)
static

Deletion of a node from the queue.

void TAO_Queued_Data::replace_data_block ( ACE_Message_Block mb)
staticprivate

Replace the datablock with a one allocated on the heap or allocator

void TAO_Queued_Data::state ( const TAO_GIOP_Message_State state)

Set the state.

const TAO_GIOP_Message_State & TAO_Queued_Data::state ( void  ) const

Get the state.

Member Data Documentation

ACE_Allocator* TAO_Queued_Data::allocator_
private

The allocator used to allocate this class.

size_t TAO_Queued_Data::missing_data_
private

Data missing in the above message that hasn't been read or processed yet, the value TAO_MISSING_DATA_UNDEFINED indicates it hasn't been processed yet, otherwise greater or equal zero.

ACE_Message_Block* TAO_Queued_Data::msg_block_
private

The message block that contains the message.

TAO_Queued_Data* TAO_Queued_Data::next_
private

Pounter to the next element in the queue.

TAO_GIOP_Message_State TAO_Queued_Data::state_
private

State of this queued data.


The documentation for this class was generated from the following files: