TAO
2.3.1
|
Reply dispatcher for Synchronous Method Invocation (SMI)s. More...
#include <Synch_Reply_Dispatcher.h>
Public Member Functions | |
TAO_Synch_Reply_Dispatcher (TAO_ORB_Core *orb_core, IOP::ServiceContextList &sc) | |
Constructor. More... | |
virtual | ~TAO_Synch_Reply_Dispatcher (void) |
Destructor. More... | |
TAO_InputCDR & | reply_cdr (void) |
Return the reply CDR. More... | |
virtual int | dispatch_reply (TAO_Pluggable_Reply_Params ¶ms) |
virtual void | connection_closed (void) |
virtual void | reply_timed_out (void) |
Inform that the reply timed out. More... | |
![]() | |
TAO_Reply_Dispatcher (ACE_Allocator *allocator=0) | |
Constructor. More... | |
virtual | ~TAO_Reply_Dispatcher (void) |
Destructor. More... | |
GIOP::LocateStatusType | locate_reply_status (void) const |
Get the locate reply status. More... | |
GIOP::ReplyStatusType | reply_status (void) const |
![]() | |
TAO_LF_Invocation_Event (void) | |
Constructor. More... | |
virtual | ~TAO_LF_Invocation_Event (void) |
Destructor. More... | |
int | successful (void) const |
int | error_detected (void) const |
![]() | |
TAO_LF_Event (void) | |
Constructor. More... | |
virtual | ~TAO_LF_Event (void) |
Destructor. More... | |
virtual int | bind (TAO_LF_Follower *follower) |
Bind a follower. More... | |
virtual int | unbind (TAO_LF_Follower *follower) |
Unbind the follower. More... | |
void | reset_state (int new_state) |
Reset the state, irrespective of the previous states. More... | |
void | state_changed (int new_state, TAO_Leader_Follower &lf) |
int | keep_waiting (void) |
Check if we should keep waiting. More... | |
Protected Attributes | |
IOP::ServiceContextList & | reply_service_info_ |
The service context list. More... | |
![]() | |
GIOP::LocateStatusType | locate_reply_status_ |
LocateReply status. More... | |
GIOP::ReplyStatusType | reply_status_ |
![]() | |
int | state_ |
The current state. More... | |
TAO_LF_Follower * | follower_ |
The bounded follower. More... | |
Private Attributes | |
TAO_ORB_Core * | orb_core_ |
Cache the ORB Core pointer. More... | |
char | buf_ [ACE_CDR::DEFAULT_BUFSIZE] |
The buffer that is used to initialise the data block. More... | |
ACE_Data_Block | db_ |
TAO_InputCDR | reply_cdr_ |
Additional Inherited Members | |
![]() | |
enum | { LFS_IDLE = 0, LFS_ACTIVE, LFS_CONNECTION_WAIT, LFS_SUCCESS, LFS_FAILURE, LFS_TIMEOUT, LFS_CONNECTION_CLOSED } |
![]() | |
static void | intrusive_add_ref (TAO_Reply_Dispatcher *) |
static void | intrusive_remove_ref (TAO_Reply_Dispatcher *) |
![]() | |
static const char * | state_name (int st) |
![]() | |
virtual void | state_changed_i (int new_state) |
Validate and perform the state change. More... | |
Reply dispatcher for Synchronous Method Invocation (SMI)s.
TAO_Synch_Reply_Dispatcher::TAO_Synch_Reply_Dispatcher | ( | TAO_ORB_Core * | orb_core, |
IOP::ServiceContextList & | sc | ||
) |
Constructor.
|
virtual |
Destructor.
|
virtual |
The used for the pending reply has been closed. No reply is expected.
Implements TAO_Reply_Dispatcher.
|
virtual |
Dispatch the reply. Return 1 on sucess, -1 on error.
Implements TAO_Reply_Dispatcher.
TAO_InputCDR & TAO_Synch_Reply_Dispatcher::reply_cdr | ( | void | ) |
Return the reply CDR.
|
virtual |
Inform that the reply timed out.
Implements TAO_Reply_Dispatcher.
|
private |
The buffer that is used to initialise the data block.
|
private |
Datablock that is created on the stack to initialise the CDR stream underneath.
|
private |
Cache the ORB Core pointer.
|
private |
CDR stream which has the reply information that needs to be demarshalled by the stubs
|
protected |
The service context list.