diff options
Diffstat (limited to 'TAO/tao/Request_Mux_Strategy.cpp')
| -rw-r--r-- | TAO/tao/Request_Mux_Strategy.cpp | 46 |
1 files changed, 23 insertions, 23 deletions
diff --git a/TAO/tao/Request_Mux_Strategy.cpp b/TAO/tao/Request_Mux_Strategy.cpp index 4e42cd5df01..52a00fe8877 100644 --- a/TAO/tao/Request_Mux_Strategy.cpp +++ b/TAO/tao/Request_Mux_Strategy.cpp @@ -1,6 +1,6 @@ // $Id$ -#include "tao/IIOP_RMS.h" +#include "tao/Request_Mux_Strategy.h" // @@ Alex: there is another aspect that is controlled by this // strategy: the demuxed version must idle() the transport @@ -10,28 +10,28 @@ // to guarantee that nobody else is using it. // We may need to add a couple of methods to implement that. -TAO_IIOP_Request_Multiplexing_Strategy::TAO_IIOP_Request_Multiplexing_Strategy (void) +TAO_Request_Mux_Strategy::TAO_Request_Mux_Strategy (void) : cdr_ (0) { } -TAO_IIOP_Request_Multiplexing_Strategy::~TAO_IIOP_Request_Multiplexing_Strategy (void) +TAO_Request_Mux_Strategy::~TAO_Request_Mux_Strategy (void) { } TAO_InputCDR * -TAO_IIOP_Request_Multiplexing_Strategy::get_cdr_stream (void) +TAO_Request_Mux_Strategy::get_cdr_stream (void) { return cdr_; } // ********************************************************************* -TAO_IIOP_Muxed_RMS::TAO_IIOP_Muxed_RMS (void) +TAO_Muxed_RMS::TAO_Muxed_RMS (void) { } -TAO_IIOP_Muxed_RMS::~TAO_IIOP_Muxed_RMS (void) +TAO_Muxed_RMS::~TAO_Muxed_RMS (void) { // @@ delete ??? } @@ -39,7 +39,7 @@ TAO_IIOP_Muxed_RMS::~TAO_IIOP_Muxed_RMS (void) // Generate and return an unique request id for the current // invocation. CORBA::ULong -TAO_IIOP_Muxed_RMS::request_id (void) +TAO_Muxed_RMS::request_id (void) { // @@ return 0; @@ -47,30 +47,30 @@ TAO_IIOP_Muxed_RMS::request_id (void) // Bind the dispatcher with the request id. int -TAO_IIOP_Muxed_RMS::bind_dispatcher (CORBA::ULong request_id, - TAO_IIOP_Reply_Dispatcher *rh) +TAO_Muxed_RMS::bind_dispatcher (CORBA::ULong request_id, + TAO_Reply_Dispatcher *rh) { // @@ return 0; } // Find the Reply Dispatcher. -TAO_IIOP_Reply_Dispatcher* -TAO_IIOP_Muxed_RMS::find_dispatcher (CORBA::ULong request_id) +TAO_Reply_Dispatcher* +TAO_Muxed_RMS::find_dispatcher (CORBA::ULong request_id) { // @@ return 0; } void -TAO_IIOP_Muxed_RMS::set_cdr_stream (TAO_InputCDR *Cdr) +TAO_Muxed_RMS::set_cdr_stream (TAO_InputCDR *Cdr) { // @@ } void -TAO_IIOP_Muxed_RMS::destroy_cdr_stream (void) +TAO_Muxed_RMS::destroy_cdr_stream (void) { // @@ Implement. // delete cdr; @@ -79,13 +79,13 @@ TAO_IIOP_Muxed_RMS::destroy_cdr_stream (void) // ********************************************************************* -TAO_IIOP_Exclusive_RMS::TAO_IIOP_Exclusive_RMS (void) +TAO_Exclusive_RMS::TAO_Exclusive_RMS (void) : request_id_ (931232), // @@ Hardcoding. rd_ (0) { } -TAO_IIOP_Exclusive_RMS::~TAO_IIOP_Exclusive_RMS (void) +TAO_Exclusive_RMS::~TAO_Exclusive_RMS (void) { } @@ -93,15 +93,15 @@ TAO_IIOP_Exclusive_RMS::~TAO_IIOP_Exclusive_RMS (void) // invocation. We can actually return a predecided ULong, since we // allow only one invocation over this connection at a time. CORBA::ULong -TAO_IIOP_Exclusive_RMS::request_id (void) +TAO_Exclusive_RMS::request_id (void) { return this->request_id_; } // Bind the handler with the request id. int -TAO_IIOP_Exclusive_RMS::bind_dispatcher (CORBA::ULong request_id, - TAO_IIOP_Reply_Dispatcher *rd) +TAO_Exclusive_RMS::bind_dispatcher (CORBA::ULong request_id, + TAO_Reply_Dispatcher *rd) { this->request_id_ = request_id; this->rd_ = rd; @@ -109,12 +109,12 @@ TAO_IIOP_Exclusive_RMS::bind_dispatcher (CORBA::ULong request_id, } // Find the Reply Handler. -TAO_IIOP_Reply_Dispatcher * -TAO_IIOP_Exclusive_RMS::find_dispatcher (CORBA::ULong request_id) +TAO_Reply_Dispatcher * +TAO_Exclusive_RMS::find_dispatcher (CORBA::ULong request_id) { if (this->request_id_ != request_id) ACE_ERROR_RETURN ((LM_ERROR, - "%N:%l:TAO_IIOP_Exclusive_RMS::find_handler: ", + "%N:%l:TAO_Exclusive_RMS::find_handler: ", "Failed to find the handler\n"), 0); @@ -124,13 +124,13 @@ TAO_IIOP_Exclusive_RMS::find_dispatcher (CORBA::ULong request_id) // Set the CDR stream. void -TAO_IIOP_Exclusive_RMS::set_cdr_stream (TAO_InputCDR *cdr) +TAO_Exclusive_RMS::set_cdr_stream (TAO_InputCDR *cdr) { this->cdr_ = cdr; } // NOOP function. void -TAO_IIOP_Exclusive_RMS::destroy_cdr_stream (void) +TAO_Exclusive_RMS::destroy_cdr_stream (void) { } |