summaryrefslogtreecommitdiff
path: root/TAO/tao/Block_Flushing_Strategy.cpp
diff options
context:
space:
mode:
authorjohnc <johnc@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2008-02-11 22:14:39 +0000
committerjohnc <johnc@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2008-02-11 22:14:39 +0000
commit8e39e6bc40af6f0f4257ef4f39b20d57915c9aa0 (patch)
tree1bc7d70bcc2ef12241e11a893c394acc17f8640a /TAO/tao/Block_Flushing_Strategy.cpp
parentdfd658c5f37c16e273f3f47a0d9fbdaaea23de3b (diff)
downloadATCD-8e39e6bc40af6f0f4257ef4f39b20d57915c9aa0.tar.gz
ChangeLogTag: Mon Feb 11 20:51:59 UTC 2008 Ciju John <johnc at ociweb dot com>
Diffstat (limited to 'TAO/tao/Block_Flushing_Strategy.cpp')
-rw-r--r--TAO/tao/Block_Flushing_Strategy.cpp9
1 files changed, 5 insertions, 4 deletions
diff --git a/TAO/tao/Block_Flushing_Strategy.cpp b/TAO/tao/Block_Flushing_Strategy.cpp
index 87082f19819..f6ef164b948 100644
--- a/TAO/tao/Block_Flushing_Strategy.cpp
+++ b/TAO/tao/Block_Flushing_Strategy.cpp
@@ -23,22 +23,23 @@ TAO_Block_Flushing_Strategy::cancel_output (TAO_Transport *)
int
TAO_Block_Flushing_Strategy::flush_message (TAO_Transport *transport,
TAO_Queued_Message *msg,
- ACE_Time_Value *)
+ ACE_Time_Value *max_wait_time)
{
while (!msg->all_data_sent ())
{
- if (transport->handle_output () == -1)
+ if (transport->handle_output (max_wait_time) == -1)
return -1;
}
return 0;
}
int
-TAO_Block_Flushing_Strategy::flush_transport (TAO_Transport *transport)
+TAO_Block_Flushing_Strategy::flush_transport (TAO_Transport *transport
+ , ACE_Time_Value *max_wait_time)
{
while (!transport->queue_is_empty ())
{
- if (transport->handle_output () == -1)
+ if (transport->handle_output (max_wait_time) == -1)
return -1;
}
return 0;