summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp49
1 files changed, 27 insertions, 22 deletions
diff --git a/TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp b/TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp
index 5fad414b4a6..bca0c50df4e 100644
--- a/TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp
+++ b/TAO/orbsvcs/orbsvcs/SSLIOP/SSLIOP_Transport.cpp
@@ -42,6 +42,7 @@ TAO_SSLIOP_Transport::~TAO_SSLIOP_Transport (void)
delete this->messaging_object_;
}
+#if 0
TAO_SSL_SVC_HANDLER *
TAO_SSLIOP_Transport::service_handler (void)
{
@@ -53,17 +54,18 @@ TAO_SSLIOP_Transport::handle (void)
{
return this->connection_handler_->get_handle ();
}
+#endif
ACE_Event_Handler *
-TAO_SSLIOP_Transport::event_handler (void)
+TAO_SSLIOP_Transport::event_handler_i (void)
{
return this->connection_handler_;
}
ssize_t
-TAO_SSLIOP_Transport::send (const ACE_Message_Block *message_block,
- const ACE_Time_Value *max_wait_time,
- size_t *bt)
+TAO_SSLIOP_Transport::send_i (const ACE_Message_Block *message_block,
+ const ACE_Time_Value *max_wait_time,
+ size_t *bt)
{
// @@ This code should be refactored into ACE.cpp or something
// similar!
@@ -98,12 +100,12 @@ TAO_SSLIOP_Transport::send (const ACE_Message_Block *message_block,
if (iovcnt == IOV_MAX)
{
if (max_wait_time == 0)
- n = this->service_handler ()->peer ().sendv_n (iov,
- iovcnt);
+ n = this->connection_handler_->peer ().sendv_n (iov,
+ iovcnt);
else
// @@ No timeouts!!!
- n = this->service_handler ()->peer ().sendv_n (iov,
- iovcnt /*,
+ n = this->connection_handler_->peer ().sendv_n (iov,
+ iovcnt /*,
max_wait_time */);
if (n == 0 ||
@@ -119,8 +121,8 @@ TAO_SSLIOP_Transport::send (const ACE_Message_Block *message_block,
// Check for remaining buffers to be sent!
if (iovcnt != 0)
{
- n = this->service_handler ()->peer ().sendv_n (iov,
- iovcnt);
+ n = this->connection_handler_->peer ().sendv_n (iov,
+ iovcnt);
if (n == 0 ||
n == -1)
return n;
@@ -132,13 +134,13 @@ TAO_SSLIOP_Transport::send (const ACE_Message_Block *message_block,
}
ssize_t
-TAO_SSLIOP_Transport::recv (char *buf,
- size_t len,
- const ACE_Time_Value * /*max_wait_time*/)
+TAO_SSLIOP_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*/);
}
@@ -178,7 +180,7 @@ TAO_SSLIOP_Transport::read_process_message (ACE_Time_Value *max_wait_time,
int
-TAO_SSLIOP_Transport::register_handler (void)
+TAO_SSLIOP_Transport::register_handler_i (void)
{
// @@ It seems like this method should go away, the right reactor is
// picked at object creation time.
@@ -242,8 +244,8 @@ TAO_SSLIOP_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;
@@ -255,8 +257,8 @@ TAO_SSLIOP_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;
}
@@ -599,13 +601,16 @@ TAO_SSLIOP_Transport::get_listen_point (
}
void
-TAO_SSLIOP_Transport::transition_handler_state (void)
+TAO_SSLIOP_Transport::transition_handler_state_i (void)
{
connection_handler_ = 0;
}
+#if 0
TAO_Connection_Handler*
TAO_SSLIOP_Transport::connection_handler (void) const
{
return connection_handler_;
}
+#endif
+