TAO_Asynch_Reply_Dispatcher_Base Class Reference
Base class for TAO_Asynch_Reply_Dispatcher and TAO_DII_Deferred_Reply_Dispatcher. More...
#include <Asynch_Reply_Dispatcher_Base.h>
Public Member Functions | |
| TAO_Asynch_Reply_Dispatcher_Base (TAO_ORB_Core *orb_core, ACE_Allocator *allocator=0) | |
| Default constructor. | |
| void | transport (TAO_Transport *t) |
| Sets the transport for this invocation. | |
| virtual long | schedule_timer (CORBA::ULong, const ACE_Time_Value &)=0 |
| Install the timeout handler. | |
| bool | try_dispatch_reply (void) |
| A helper method that can be used by the subclasses. | |
Mutators for refcount | |
| void | incr_refcount (void) |
| void | decr_refcount (void) |
Protected Member Functions | |
| virtual | ~TAO_Asynch_Reply_Dispatcher_Base (void) |
| Destructor. | |
Protected Attributes | |
| IOP::ServiceContextList | reply_service_info_ |
| The service context list. | |
| char | buf_ [ACE_CDR::DEFAULT_BUFSIZE] |
| The buffer that is used to initialise the data block. | |
| ACE_Data_Block | db_ |
| TAO_InputCDR | reply_cdr_ |
| TAO_Transport * | transport_ |
| This invocation is using this transport, may change... | |
Private Attributes | |
| ACE_Lock * | lock_ |
Lock to protect refcount and is_reply_dispatched_ flag. | |
| CORBA::ULong | refcount_ |
| Refcount paraphernalia for this class. | |
| bool | is_reply_dispatched_ |
| Has the reply been dispatched? | |
| ACE_Allocator * | allocator_ |
Detailed Description
Base class for TAO_Asynch_Reply_Dispatcher and TAO_DII_Deferred_Reply_Dispatcher.Constructor & Destructor Documentation
| TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Asynch_Reply_Dispatcher_Base::TAO_Asynch_Reply_Dispatcher_Base | ( | TAO_ORB_Core * | orb_core, | |
| ACE_Allocator * | allocator = 0 | |||
| ) |
Default constructor.
| TAO_Asynch_Reply_Dispatcher_Base::~TAO_Asynch_Reply_Dispatcher_Base | ( | void | ) | [protected, virtual] |
Destructor.
Member Function Documentation
| void TAO_Asynch_Reply_Dispatcher_Base::transport | ( | TAO_Transport * | t | ) |
Sets the transport for this invocation.
| virtual long TAO_Asynch_Reply_Dispatcher_Base::schedule_timer | ( | CORBA::ULong | , | |
| const ACE_Time_Value & | ||||
| ) | [pure virtual] |
Install the timeout handler.
| void TAO_Asynch_Reply_Dispatcher_Base::incr_refcount | ( | void | ) |
| void TAO_Asynch_Reply_Dispatcher_Base::decr_refcount | ( | void | ) |
| bool TAO_Asynch_Reply_Dispatcher_Base::try_dispatch_reply | ( | void | ) |
A helper method that can be used by the subclasses.
The semantics of this helper method needs careful attention. A call to this method will do the following
- If the reply has already been dispatched, the return value will be false to signify not to try.
- If the reply has not been dispatched, this method will set the flag to be true and return a true value to signify that the caller thread can go ahead and dispatch reply.
Why are we clumping everything in one method. Answer is we need atomicity?
Member Data Documentation
IOP::ServiceContextList TAO_Asynch_Reply_Dispatcher_Base::reply_service_info_ [protected] |
The service context list.
Note, that this is not a reference as in the synchronous case. We own the reply_service_info because our TAO_Asynch_Invocation or TAO_DII_Deferred_Invocation will go out of scope before we are done.
char TAO_Asynch_Reply_Dispatcher_Base::buf_[ACE_CDR::DEFAULT_BUFSIZE] [protected] |
The buffer that is used to initialise the data block.
ACE_Data_Block TAO_Asynch_Reply_Dispatcher_Base::db_ [protected] |
Datablock that is created on the stack to initialise the CDR stream underneath.
CDR stream which has the reply information that needs to be demarshalled by the stubs
This invocation is using this transport, may change...
ACE_Lock* TAO_Asynch_Reply_Dispatcher_Base::lock_ [private] |
Lock to protect refcount and is_reply_dispatched_ flag.
Refcount paraphernalia for this class.
bool TAO_Asynch_Reply_Dispatcher_Base::is_reply_dispatched_ [private] |
Has the reply been dispatched?
Allocator that was used to allocate this reply dispatcher. In case of zero we come from the heap.
The documentation for this class was generated from the following files:
