#include <Muxed_TMS.h>

Inheritance diagram for TAO_Muxed_TMS:

Collaboration diagram for TAO_Muxed_TMS:

Public Member Functions
	TAO_Muxed_TMS (TAO_Transport *transport)
	Constructor.
virtual	~TAO_Muxed_TMS (void)
	Destructor.
virtual CORBA::ULong	request_id (void)
virtual int	bind_dispatcher (CORBA::ULong request_id, ACE_Intrusive_Auto_Ptr< TAO_Reply_Dispatcher > rd)
	Bind the dispatcher with the request id.
virtual int	unbind_dispatcher (CORBA::ULong request_id)
virtual int	dispatch_reply (TAO_Pluggable_Reply_Params &params)
virtual int	reply_timed_out (CORBA::ULong request_id)
virtual bool	idle_after_send (void)
virtual bool	idle_after_reply (void)
virtual void	connection_closed (void)
virtual bool	has_request (void)
	Do we have a request pending.
Private Types
typedef ACE_Hash_Map_Manager_Ex < CORBA::ULong, ACE_Intrusive_Auto_Ptr < TAO_Reply_Dispatcher > , ACE_Hash< CORBA::ULong > , ACE_Equal_To< CORBA::ULong > , ACE_Null_Mutex >	REQUEST_DISPATCHER_TABLE
Private Member Functions
void	operator= (const TAO_Muxed_TMS &)
	TAO_Muxed_TMS (const TAO_Muxed_TMS &)
int	clear_cache_i (void)
Private Attributes
ACE_Lock *	lock_
	Lock to protect the state of the object.
CORBA::ULong	request_id_generator_
TAO_ORB_Core *const	orb_core_
REQUEST_DISPATCHER_TABLE	dispatcher_table_
	Table of <Request ID, Reply Dispatcher> pairs.

Detailed Description

Using this strategy a single connection can have multiple outstanding requests. @ Can the performance of the demuxer be made more predictable, for example, using the request id as an active demux key?

Note:: Check the OMG resolutions about bidirectional connections, it is possible that the request ids can only assume even or odd values.

Member Typedef Documentation

typedef ACE_Hash_Map_Manager_Ex<CORBA::ULong, ACE_Intrusive_Auto_Ptr<TAO_Reply_Dispatcher>, ACE_Hash <CORBA::ULong>, ACE_Equal_To <CORBA::ULong>, ACE_Null_Mutex> TAO_Muxed_TMS::REQUEST_DISPATCHER_TABLE [private]

Constructor & Destructor Documentation

TAO_Muxed_TMS::TAO_Muxed_TMS ( TAO_Transport * transport )

Constructor.

TAO_Muxed_TMS::~TAO_Muxed_TMS ( void ) [virtual]

Destructor.

TAO_Muxed_TMS::TAO_Muxed_TMS ( const TAO_Muxed_TMS & ) [private]

Member Function Documentation

int TAO_Muxed_TMS::bind_dispatcher	(	CORBA::ULong	request_id,
		ACE_Intrusive_Auto_Ptr< TAO_Reply_Dispatcher >	rd
	)		`[virtual]`

Bind the dispatcher with the request id.

Implements TAO_Transport_Mux_Strategy.

int TAO_Muxed_TMS::clear_cache_i ( void ) [private]

void TAO_Muxed_TMS::connection_closed ( void ) [virtual]

The transport object has closed the connection, inform all Reply dispatchers and waiting strategies.

Implements TAO_Transport_Mux_Strategy.

int TAO_Muxed_TMS::dispatch_reply ( TAO_Pluggable_Reply_Params & params ) [virtual]

Dispatch the reply for request_id, cleanup any resources allocated for that request.

Implements TAO_Transport_Mux_Strategy.

bool TAO_Muxed_TMS::has_request ( void ) [virtual]

Do we have a request pending.

Implements TAO_Transport_Mux_Strategy.

bool TAO_Muxed_TMS::idle_after_reply ( void ) [virtual]

Request is sent and the reply is received. Idle the transport now. The return value indicates whether idling was successful or not.

Implements TAO_Transport_Mux_Strategy.

bool TAO_Muxed_TMS::idle_after_send ( void ) [virtual]

Request has been just sent, but the reply is not received. Idle the transport now. The return value indicates whether idling was successful or not.

Implements TAO_Transport_Mux_Strategy.

void TAO_Muxed_TMS::operator= ( const TAO_Muxed_TMS & ) [private]

int TAO_Muxed_TMS::reply_timed_out ( CORBA::ULong request_id ) [virtual]

Dispatch a reply timeout for request request_id

Implements TAO_Transport_Mux_Strategy.

CORBA::ULong TAO_Muxed_TMS::request_id ( void ) [virtual]

Generate and return an unique request id for the current invocation.

Implements TAO_Transport_Mux_Strategy.

int TAO_Muxed_TMS::unbind_dispatcher ( CORBA::ULong request_id ) [virtual]

Unbind the dispatcher, the client is no longer waiting for the request, for example, because the request timed out. The strategy can (must) cleanup any resources associated with the request. A later reply for that request should be ignored.

Implements TAO_Transport_Mux_Strategy.