TAO_Incoming_Message_Queue Class Reference

A queue of the messages in the incoming data path. More...

#include <Incoming_Message_Queue.h>

Collaboration diagram for TAO_Incoming_Message_Queue:

Public Member Functions
	TAO_Incoming_Message_Queue (TAO_ORB_Core *orb_core)
	Constructor. More...
	~TAO_Incoming_Message_Queue (void)
	Destructor. More...
TAO_Queued_Data *	dequeue_head (void)
	Adding and deleting a node from the queue. More...
TAO_Queued_Data *	dequeue_tail (void)
int	enqueue_tail (TAO_Queued_Data *nd)
CORBA::ULong	queue_length (void) const
	Return the length of the queue.. More...

Private Attributes
TAO_Queued_Data *	last_added_
	A circular linked list of messages awaiting processing. More...
CORBA::ULong	size_
	The size of the queue. More...
TAO_ORB_Core *	orb_core_
	Copy of our ORB Core. More...

Friends
class	TAO_Transport

Detailed Description

A queue of the messages in the incoming data path.

Please read the documentation in the TAO_Transport class to find out more about the design of the incoming data path.

Under certain conditions TAO may have to maintain a queue per-connection. This queue is drained by the pluggable protocols framework, normally under control of the ACE_Reactor, but other configurations are conceivable.

The memory that is allocated for holding the messages comes from the global pool for the following reasons

• the thread that reads a part of the message would not be the same thread that reads and fills the rest of the message
• the thread that actually processes the message can be totally different.

Constructor & Destructor Documentation

TAO_Incoming_Message_Queue::TAO_Incoming_Message_Queue

(

TAO_ORB_Core *

orb_core

)

Constructor.

TAO_Incoming_Message_Queue::~TAO_Incoming_Message_Queue

(

void

)

Destructor.

Member Function Documentation

TAO_Queued_Data * TAO_Incoming_Message_Queue::dequeue_head

(

void

)

Adding and deleting a node from the queue.

TAO_Queued_Data * TAO_Incoming_Message_Queue::dequeue_tail

(

void

)

int TAO_Incoming_Message_Queue::enqueue_tail

(

TAO_Queued_Data *

nd

)

CORBA::ULong TAO_Incoming_Message_Queue::queue_length

(

void

)

const

Return the length of the queue..

Friends And Related Function Documentation

friend class TAO_Transport

friend

Member Data Documentation

TAO_Queued_Data* TAO_Incoming_Message_Queue::last_added_

private

A circular linked list of messages awaiting processing.

last_message_added_ points to the most recent message added to the list. The earliest addition can be easily accessed via last_message_added_->next_.

TAO_ORB_Core* TAO_Incoming_Message_Queue::orb_core_

private

Copy of our ORB Core.

CORBA::ULong TAO_Incoming_Message_Queue::size_

private

The size of the queue.

---

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

• Incoming_Message_Queue.h
• Incoming_Message_Queue.cpp
• Incoming_Message_Queue.inl