summaryrefslogtreecommitdiff
path: root/TAO/tao/Strategies/UIOP_Transport.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Strategies/UIOP_Transport.cpp')
-rw-r--r--TAO/tao/Strategies/UIOP_Transport.cpp62
1 files changed, 22 insertions, 40 deletions
diff --git a/TAO/tao/Strategies/UIOP_Transport.cpp b/TAO/tao/Strategies/UIOP_Transport.cpp
index 29f67574369..5a438d9f994 100644
--- a/TAO/tao/Strategies/UIOP_Transport.cpp
+++ b/TAO/tao/Strategies/UIOP_Transport.cpp
@@ -32,9 +32,9 @@ TAO_UIOP_Transport::TAO_UIOP_Transport (TAO_UIOP_Connection_Handler *handler,
TAO_ORB_Core *orb_core,
CORBA::Boolean flag)
: TAO_Transport (TAO_TAG_UIOP_PROFILE,
- orb_core),
- connection_handler_ (handler),
- messaging_object_ (0)
+ orb_core)
+ , connection_handler_ (handler)
+ , messaging_object_ (0)
{
if (flag)
{
@@ -55,43 +55,31 @@ TAO_UIOP_Transport::~TAO_UIOP_Transport (void)
delete this->messaging_object_;
}
-TAO_UIOP_SVC_HANDLER *
-TAO_UIOP_Transport::service_handler (void)
-{
- return this->connection_handler_;
-}
-
-ACE_HANDLE
-TAO_UIOP_Transport::handle (void)
-{
- return this->connection_handler_->get_handle ();
-}
-
ACE_Event_Handler *
-TAO_UIOP_Transport::event_handler (void)
+TAO_UIOP_Transport::event_handler_i (void)
{
return this->connection_handler_;
}
ssize_t
-TAO_UIOP_Transport::send (const ACE_Message_Block *message_block,
- const ACE_Time_Value *max_wait_time,
- size_t *bytes_transferred)
+TAO_UIOP_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_UIOP_Transport::recv (char *buf,
- size_t len,
- const ACE_Time_Value *max_wait_time)
+TAO_UIOP_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);
}
int
@@ -130,7 +118,7 @@ TAO_UIOP_Transport::read_process_message (ACE_Time_Value *max_wait_time,
int
-TAO_UIOP_Transport::register_handler (void)
+TAO_UIOP_Transport::register_handler_i (void)
{
// @@ It seems like this method should go away, the right reactor is
// picked at object creation time.
@@ -194,8 +182,8 @@ TAO_UIOP_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;
@@ -207,8 +195,8 @@ TAO_UIOP_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;
}
@@ -350,8 +338,8 @@ TAO_UIOP_Transport::process_message (void)
{
if (TAO_debug_level > 0)
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("TAO (%P|%t) : UIOP_Client_Transport::")
- ACE_TEXT ("handle_client_input - ")
+ ACE_TEXT ("TAO (%P|%t) : UIOP_Transport::")
+ ACE_TEXT ("process_message - ")
ACE_TEXT ("dispatch reply failed\n")));
this->messaging_object_->reset ();
this->tms_->connection_closed ();
@@ -387,15 +375,9 @@ TAO_UIOP_Transport::process_message (void)
}
void
-TAO_UIOP_Transport::transition_handler_state (void)
+TAO_UIOP_Transport::transition_handler_state_i (void)
{
connection_handler_ = 0;
}
-TAO_Connection_Handler*
-TAO_UIOP_Transport::connection_handler (void) const
-{
- return connection_handler_;
-}
-
#endif /* TAO_HAS_UIOP */