summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp')
-rw-r--r--TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp18
1 files changed, 14 insertions, 4 deletions
diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp
index 6e1ffafb619..1ed8649ac7d 100644
--- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp
+++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/Worker/Client_Timer_Handler.cpp
@@ -69,6 +69,14 @@ Client_Timer_Handler::handle_timeout (const ACE_Time_Value &,
timer_.stop ();
+ ++invocations_;
+
+ ACE_DEBUG ((LM_EMERGENCY, "m(%s,%d,%d,%d) ",
+ logfile_.c_str (),
+ max_iterations_,
+ log_start_,
+ invocations_));
+
if (logging_ && (invocations_ >= log_start_))
{
ACE_Time_Value rt;
@@ -79,9 +87,9 @@ Client_Timer_Handler::handle_timeout (const ACE_Time_Value &,
}
catch (CORBA::SystemException & ex)
{
- ACE_DEBUG ((LM_WARNING,
- ACE_TEXT ("Client_Timer_Handler::handle_timeout () -"
- "caught: %s"), ex._info ().c_str ()));
+ ACE_DEBUG ((LM_EMERGENCY,
+ ACE_TEXT ("Client_Timer_Handler::handle_timeout () -"
+ "caught: %s"), ex._info ().c_str ()));
orb_->shutdown ();
@@ -90,7 +98,7 @@ Client_Timer_Handler::handle_timeout (const ACE_Time_Value &,
try
{
- if ((max_iterations_ > 0) && (++invocations_ >= max_iterations_))
+ if ((max_iterations_ > 0) && (invocations_ >= max_iterations_))
{
worker_->stop ();
@@ -112,6 +120,8 @@ Client_Timer_Handler::handle_timeout (const ACE_Time_Value &,
int
Client_Timer_Handler::handle_signal (int, siginfo_t *, ucontext_t *)
{
+ orb_->orb_core ()->reactor ()->cancel_timer (this);
+
orb_->shutdown ();
return 0;