A queue of the messages in the incoming data path. More...
#include <Incoming_Message_Queue.h>
Public Member Functions | |
| TAO_Incoming_Message_Queue (TAO_ORB_Core *orb_core) | |
| Constructor. | |
| ~TAO_Incoming_Message_Queue () | |
| Destructor. | |
| TAO_Queued_Data * | dequeue_head () |
| Adding and deleting a node from the queue. | |
| TAO_Queued_Data * | dequeue_tail () |
| int | enqueue_tail (TAO_Queued_Data *nd) |
| CORBA::ULong | queue_length () const |
| Return the length of the queue.. | |
Private Attributes | |
| TAO_Queued_Data * | last_added_ |
| A circular linked list of messages awaiting processing. | |
| CORBA::ULong | size_ |
| The size of the queue. | |
| TAO_ORB_Core * | orb_core_ |
| Copy of our ORB Core. | |
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_Incoming_Message_Queue | ( | TAO_ORB_Core * | orb_core | ) |
Constructor.
◆ ~TAO_Incoming_Message_Queue()
| TAO_Incoming_Message_Queue::~TAO_Incoming_Message_Queue | ( | ) |
Destructor.
Member Function Documentation
◆ dequeue_head()
| TAO_Queued_Data * TAO_Incoming_Message_Queue::dequeue_head | ( | ) |
Adding and deleting a node from the queue.
◆ dequeue_tail()
| TAO_Queued_Data * TAO_Incoming_Message_Queue::dequeue_tail | ( | ) |
◆ enqueue_tail()
| int TAO_Incoming_Message_Queue::enqueue_tail | ( | TAO_Queued_Data * | nd | ) |
◆ queue_length()
| CORBA::ULong TAO_Incoming_Message_Queue::queue_length | ( | ) | const |
Return the length of the queue..
Friends And Related Symbol Documentation
◆ TAO_Transport
|
friend |
Member Data Documentation
◆ 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_.
◆ orb_core_
|
private |
Copy of our ORB Core.
◆ size_
|
private |
The size of the queue.
The documentation for this class was generated from the following files:
