summaryrefslogtreecommitdiff
path: root/TAO/tao/Reactive_Flushing_Strategy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Reactive_Flushing_Strategy.cpp')
-rw-r--r--TAO/tao/Reactive_Flushing_Strategy.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/TAO/tao/Reactive_Flushing_Strategy.cpp b/TAO/tao/Reactive_Flushing_Strategy.cpp
index ef3d1521924..ed2cdd1da84 100644
--- a/TAO/tao/Reactive_Flushing_Strategy.cpp
+++ b/TAO/tao/Reactive_Flushing_Strategy.cpp
@@ -23,7 +23,8 @@ TAO_Reactive_Flushing_Strategy::cancel_output (TAO_Transport *transport)
int
TAO_Reactive_Flushing_Strategy::flush_message (TAO_Transport *transport,
- TAO_Queued_Message *msg)
+ TAO_Queued_Message *msg,
+ ACE_Time_Value *max_wait_time)
{
int result = 0;
@@ -35,7 +36,7 @@ TAO_Reactive_Flushing_Strategy::flush_message (TAO_Transport *transport,
while (!msg->all_data_sent () && result >= 0)
{
- result = orb_core->run (0, 1, ACE_TRY_ENV);
+ result = orb_core->run (max_wait_time, 1, ACE_TRY_ENV);
ACE_TRY_CHECK;
}
}