diff options
Diffstat (limited to 'TAO/tao/IIOP_Transport.cpp')
-rw-r--r-- | TAO/tao/IIOP_Transport.cpp | 52 |
1 files changed, 27 insertions, 25 deletions
diff --git a/TAO/tao/IIOP_Transport.cpp b/TAO/tao/IIOP_Transport.cpp index a86c84819b4..9605f6618ef 100644 --- a/TAO/tao/IIOP_Transport.cpp +++ b/TAO/tao/IIOP_Transport.cpp @@ -32,6 +32,10 @@ TAO_IIOP_Transport::TAO_IIOP_Transport (TAO_IIOP_Connection_Handler *handler, , connection_handler_ (handler) , messaging_object_ (0) { + // We'll set the id_ (from TAO_Transport) to the handle from our connection + if (connection_handler_ != 0) + this->id_ = ACE_static_cast (int, this->connection_handler_->get_handle ()); + if (flag) { // Use the lite version of the protocol @@ -51,43 +55,39 @@ TAO_IIOP_Transport::~TAO_IIOP_Transport (void) delete this->messaging_object_; } -TAO_IIOP_SVC_HANDLER * -TAO_IIOP_Transport::service_handler (void) -{ - return this->connection_handler_; -} - +#if 0 ACE_HANDLE TAO_IIOP_Transport::handle (void) { return this->connection_handler_->get_handle (); } +#endif ACE_Event_Handler * -TAO_IIOP_Transport::event_handler (void) +TAO_IIOP_Transport::event_handler_i (void) { return this->connection_handler_; } ssize_t -TAO_IIOP_Transport::send (const ACE_Message_Block *message_block, - const ACE_Time_Value *max_wait_time, - size_t *bytes_transferred) +TAO_IIOP_Transport::send_i (const ACE_Message_Block *message_block, + const ACE_Time_Value *max_wait_time, + size_t *bytes_transferred) { - return ACE::send_n (this->handle (), + return ACE::send_n (this->connection_handler_->get_handle (), message_block, max_wait_time, bytes_transferred); } ssize_t -TAO_IIOP_Transport::recv (char *buf, - size_t len, - const ACE_Time_Value *max_wait_time) +TAO_IIOP_Transport::recv_i (char *buf, + size_t len, + const ACE_Time_Value *max_wait_time) { - return this->service_handler ()->peer ().recv (buf, - len, - max_wait_time); + return this->connection_handler_->peer ().recv (buf, + len, + max_wait_time); } @@ -127,7 +127,7 @@ TAO_IIOP_Transport::read_process_message (ACE_Time_Value *max_wait_time, int -TAO_IIOP_Transport::register_handler (void) +TAO_IIOP_Transport::register_handler_i (void) { // @@ It seems like this method should go away, the right reactor is // picked at object creation time. @@ -191,8 +191,8 @@ TAO_IIOP_Transport::send_message (TAO_OutputCDR &stream, { if (TAO_debug_level) ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("TAO: (%P|%t|%N|%l) closing conn %d after fault %p\n"), - this->handle (), + ACE_TEXT ("TAO: (%P|%t|%N|%l) closing transport %d after fault %p\n"), + this->id (), ACE_TEXT ("send_message ()\n"))); return -1; @@ -204,8 +204,8 @@ TAO_IIOP_Transport::send_message (TAO_OutputCDR &stream, if (TAO_debug_level) ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TAO: (%P|%t|%N|%l) send_message () \n") - ACE_TEXT ("EOF, closing conn %d\n"), - this->handle())); + ACE_TEXT ("EOF, closing transport %d\n"), + this->id ())); return -1; } @@ -389,8 +389,8 @@ TAO_IIOP_Transport::process_message (void) // every reply on this connection. if (TAO_debug_level > 0) ACE_ERROR ((LM_ERROR, - ACE_TEXT ("TAO (%P|%t) : IIOP_Client_Transport::") - ACE_TEXT ("handle_client_input - ") + ACE_TEXT ("TAO (%P|%t) : IIOP_Transport::") + ACE_TEXT ("process_message - ") ACE_TEXT ("dispatch reply failed\n"))); this->messaging_object_->reset (); @@ -562,13 +562,15 @@ TAO_IIOP_Transport::get_listen_point ( } void -TAO_IIOP_Transport::transition_handler_state (void) +TAO_IIOP_Transport::transition_handler_state_i (void) { connection_handler_ = 0; } +#if 0 TAO_Connection_Handler* TAO_IIOP_Transport::connection_handler (void) const { return connection_handler_; } +#endif |