diff options
Diffstat (limited to 'TAO/tao/Transport_Mux_Strategy.cpp')
| -rw-r--r-- | TAO/tao/Transport_Mux_Strategy.cpp | 324 |
1 files changed, 0 insertions, 324 deletions
diff --git a/TAO/tao/Transport_Mux_Strategy.cpp b/TAO/tao/Transport_Mux_Strategy.cpp deleted file mode 100644 index e5d3492cebf..00000000000 --- a/TAO/tao/Transport_Mux_Strategy.cpp +++ /dev/null @@ -1,324 +0,0 @@ -// $Id$ - -#include "tao/Transport_Mux_Strategy.h" -#include "tao/Reply_Dispatcher.h" -#include "tao/debug.h" -#include "tao/Pluggable.h" - -TAO_Transport_Mux_Strategy::TAO_Transport_Mux_Strategy (void) -{ -} - -TAO_Transport_Mux_Strategy::~TAO_Transport_Mux_Strategy (void) -{ -} - -// ********************************************************************* - -TAO_Exclusive_TMS::TAO_Exclusive_TMS (TAO_ORB_Core *orb_core) - : request_id_generator_ (0), - request_id_ (0), - rd_ (0), - message_state_ (orb_core) -{ -} - -TAO_Exclusive_TMS::~TAO_Exclusive_TMS (void) -{ -} - -// Generate and return an unique request id for the current -// invocation. We can actually return a predecided ULong, since we -// allow only one invocation over this connection at a time. -CORBA::ULong -TAO_Exclusive_TMS::request_id (void) -{ - return this->request_id_generator_++; -} - -// Bind the handler with the request id. -int -TAO_Exclusive_TMS::bind_dispatcher (CORBA::ULong request_id, - TAO_Reply_Dispatcher *rd) -{ - this->request_id_ = request_id; - this->rd_ = rd; - - // @@ Carlos: This method marks the <start> of an invocation. This - // should be the correct place to <reset> the message state. Do I - // make sense? (Alex). - - // If there was a previous reply, cleanup its state first. - if (this->message_state_.message_size != 0) - this->message_state_.reset (); - - return 0; -} - -int -TAO_Exclusive_TMS::dispatch_reply (CORBA::ULong request_id, - CORBA::ULong reply_status, - const TAO_GIOP_Version& version, - TAO_GIOP_ServiceContextList& reply_ctx, - TAO_GIOP_Message_State* message_state) -{ - // There can be only one message state possible. Just do a sanity - // check here. - ACE_ASSERT (message_state == &(this->message_state_)); - - // Check the ids. - if (this->request_id_ != request_id) - { - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "TAO_Exclusive_TMS::dispatch_reply - <%d != %d>\n", - this->request_id_, request_id)); - return -1; - } - - TAO_Reply_Dispatcher *rd = this->rd_; - this->request_id_ = 0xdeadbeef; // @@ What is a good value??? - this->rd_ = 0; - - return rd->dispatch_reply (reply_status, - version, - reply_ctx, - message_state); -} - -TAO_GIOP_Message_State * -TAO_Exclusive_TMS::get_message_state (void) -{ - if (this->rd_ == 0) - return 0; - - return &(this->message_state_); -} - -void -TAO_Exclusive_TMS::destroy_message_state (TAO_GIOP_Message_State *) -{ - // No Op. -} - -int -TAO_Exclusive_TMS::idle_after_send (TAO_Transport *) -{ - // No op. - return 0; -} - -int -TAO_Exclusive_TMS::idle_after_reply (TAO_Transport *transport) -{ - if (transport != 0) - return transport->idle (); - - return 0; -} - -int -TAO_Exclusive_TMS::reply_received (const CORBA::ULong request_id) -{ - if (this->rd_ == 0) - { - // Reply should have been dispatched already. - return 1; - } - else if (this->request_id_ == request_id) - { - // Reply dispatcher is still here. - return 0; - } - else - { - // Error. Request id is not matching. - - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, - "(%P | %t):TAO_Exclusive_TMS::reply_received:" - "Invalid request_id \n")); - } - return -1; - } -} - -// ********************************************************************* - -TAO_Muxed_TMS::TAO_Muxed_TMS (TAO_ORB_Core *orb_core) - : request_id_generator_ (0), - orb_core_ (orb_core), - message_state_ (0) -{ -} - -TAO_Muxed_TMS::~TAO_Muxed_TMS (void) -{ -} - -// Generate and return an unique request id for the current -// invocation. -CORBA::ULong -TAO_Muxed_TMS::request_id (void) -{ - // @@ What is a good error return value? - ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, ace_mon, - this->request_id_lock_, 0); - return this->request_id_generator_++; -} - -// Bind the dispatcher with the request id. -int -TAO_Muxed_TMS::bind_dispatcher (CORBA::ULong request_id, - TAO_Reply_Dispatcher *rd) -{ - int result = this->dispatcher_table_.bind (request_id, rd); - - if (result != 0) - { - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "(%P | %t):TAO_Muxed_TMS::bind_dispatcher: " - "bind dispatcher failed: result = %d\n", - result)); - - return -1; - } - return 0; -} - -int -TAO_Muxed_TMS::dispatch_reply (CORBA::ULong request_id, - CORBA::ULong reply_status, - const TAO_GIOP_Version &version, - TAO_GIOP_ServiceContextList &reply_ctx, - TAO_GIOP_Message_State *message_state) -{ - // This message state should be the same as the one we have here, - // which we gave to the Transport to read the message. Just a sanity - // check here. - ACE_ASSERT (message_state == this->message_state_); - - int result = 0; - TAO_Reply_Dispatcher *rd = 0; - - // Grab the reply dispatcher for this id. - result = this->dispatcher_table_.unbind (request_id, rd); - - if (result != 0) - { - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "(%P | %t):TAO_Muxed_TMS::dispatch_reply: " - "unbind dispatcher failed: result = %d\n", - result)); - - return -1; - } - - // @@ Carlos : We could save the <messagee_state> somehow and then - // signal some other thread to go ahead read the incoming message - // if any. Is this what you were telling me before? (Alex). - - // Dispatch the reply. - return rd->dispatch_reply (reply_status, - version, - reply_ctx, - message_state); -} - -TAO_GIOP_Message_State * -TAO_Muxed_TMS::get_message_state (void) -{ - if (this->message_state_ == 0) - { - // Create the next message state. - ACE_NEW_RETURN (this->message_state_, - TAO_GIOP_Message_State (this->orb_core_), - 0); - } - - return this->message_state_; -} - -void -TAO_Muxed_TMS::destroy_message_state (TAO_GIOP_Message_State *) -{ - delete this->message_state_; - this->message_state_ = 0; -} - -int -TAO_Muxed_TMS::idle_after_send (TAO_Transport *transport) -{ - if (transport != 0) - return transport->idle (); - - return 0; -} - -int -TAO_Muxed_TMS::idle_after_reply (TAO_Transport *) -{ - return 0; -} - -int -TAO_Muxed_TMS::reply_received (const CORBA::ULong request_id) -{ - if (this->dispatcher_table_.find (request_id) == -1) - { - // Reply should have been dispatched already. - return 1; - } - else - { - // Reply dispatcher is still here. - return 0; - } -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Hash_Map_Manager_Ex <CORBA::ULong, - TAO_Reply_Dispatcher *, - ACE_Hash <CORBA::ULong>, - ACE_Equal_To <CORBA::ULong>, - ACE_SYNCH_MUTEX>; - -template class ACE_Hash_Map_Entry<CORBA::ULong, - TAO_Reply_Dispatcher *>; - -template class ACE_Hash_Map_Iterator_Base_Ex<CORBA::ULong, - TAO_Reply_Dispatcher *, - ACE_Hash<unsigned int>, - ACE_Equal_To<unsigned int>, - ACE_SYNCH_MUTEX>; - -template class ACE_Hash_Map_Iterator_Ex<CORBA::ULong, - TAO_Reply_Dispatcher*, - ACE_Hash<CORBA::ULong>, - ACE_Equal_To<CORBA::ULong>, - ACE_SYNCH_MUTEX>; - -template class ACE_Hash_Map_Reverse_Iterator_Ex<CORBA::ULong, - TAO_Reply_Dispatcher*, - ACE_Hash<CORBA::ULong>, - ACE_Equal_To<CORBA::ULong>, - ACE_SYNCH_MUTEX>; -template class ACE_Equal_To <CORBA::ULong>; - -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Hash_Map_Manager_Ex <CORBA::ULong, TAO_Reply_Dispatcher *, ACE_Hash <CORBA::ULong>, ACE_Equal_To <CORBA::ULong>, ACE_SYNCH_MUTEX> - -#pragma instantiate ACE_Hash_Map_Entry<CORBA::ULong, TAO_Reply_Dispatcher *> - -#pragma instantiate ACE_Hash_Map_Iterator_Base_Ex<unsigned int, TAO_Reply_Dispatcher *, ACE_Hash<unsigned int>, ACE_Equal_To<unsigned int>, ACE_SYNCH_MUTEX> - -#pragma instantiate ACE_Hash_Map_Iterator_Ex<CORBA::ULong, TAO_Reply_Dispatcher*, ACE_Hash<CORBA::ULong>, ACE_Equal_To<CORBA::ULong>, ACE_SYNCH_MUTEX> - -#pragma instantiate ACE_Hash_Map_Reverse_Iterator_Ex<CORBA::ULong, TAO_Reply_Dispatcher*, ACE_Hash<CORBA::ULong>, ACE_Equal_To<CORBA::ULong>, ACE_SYNCH_MUTEX> - -#pragma instantiate ACE_Equal_To <CORBA::ULong> - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |