TAO/tests/AMI_Timeouts/timeout_i.cpp

   1 //=============================================================================
   2 /**
   3  *  @file    timeout_i.cpp
   4  *
   5  *  Implements the timeout CORBA Object and its reply handler.
   6  *
   7  *  @author Michael Kircher <Michael.Kircher@mchp.siemens.de>
   8  */
   9 //=============================================================================
  10
  11 #include "timeout_i.h"
  12 #include "ace/OS_NS_unistd.h"
  13
  14 Timeout_i::Timeout_i (CORBA::ORB_ptr orb)
  15 {
  16   orb_ = CORBA::ORB::_duplicate (orb);
  17 }
  18
  19 void
  20 Timeout_i::sendTimeToWait (CORBA::Long msec)
  21 {
  22   //ACE_DEBUG ((LM_DEBUG,
  23   //            "Timeout_i::sendTimeToWait: invoked with msec = %d\n\n",
  24   //            msec));
  25
  26   if (msec != 0)
  27     {
  28       // ACE_DEBUG ((LM_DEBUG,
  29       //            "Timeout_i::sendTimeToWait: sleeping\n\n"));
  30
  31       ACE_Time_Value tv (0, msec * 1000);
  32             ACE_OS::sleep (tv);
  33     }
  34 }
  35
  36 void
  37 Timeout_i::shutdown ()
  38 {
  39   orb_->shutdown ();
  40   //ACE_DEBUG ((LM_DEBUG,
  41   //            "Timeout_i::shutdown: shut down ORB\n\n"));
  42 }
  43
  44 // Reply Handler implementation
  45
  46 TimeoutHandler_i::TimeoutHandler_i ()
  47 : reply_counter_ (0)
  48 , reply_excep_counter_ (0)
  49 {
  50   timer_.reset ();
  51   timer_.start ();
  52   timer_.stop ();
  53 }
  54
  55 void
  56 TimeoutHandler_i::sendTimeToWait ()
  57 {
  58   ACE_DEBUG ((LM_DEBUG,
  59               "reply"));
  60   ++reply_counter_;
  61   timer_.stop ();
  62 }
  63
  64 void
  65 TimeoutHandler_i::sendTimeToWait_excep (::Messaging::ExceptionHolder *excep_holder)
  66 {
  67   timer_.stop ();
  68
  69   try
  70     {
  71       excep_holder->raise_exception ();
  72     }
  73   catch (const CORBA::TIMEOUT& )
  74     {
  75       ACE_DEBUG ((LM_DEBUG,
  76                   "timeout"));
  77       ++reply_excep_counter_;
  78     }
  79   catch (...)
  80     {
  81       ACE_DEBUG ((LM_DEBUG,
  82                   "Error: Unexpected exception"));
  83     }
  84 }
  85
  86 void
  87 TimeoutHandler_i::reset_reply_counter ()
  88 {
  89   reply_counter_ = 0;
  90 }
  91
  92 void
  93 TimeoutHandler_i::reset_reply_excep_counter ()
  94 {
  95   reply_excep_counter_ = 0;
  96 }
  97
  98 unsigned short
  99 TimeoutHandler_i::reply_counter ()
 100 {
 101   return reply_counter_;
 102 }
 103
 104 unsigned short
 105 TimeoutHandler_i::reply_excep_counter ()
 106 {
 107   return reply_excep_counter_;
 108 }
 109
 110 void
 111 TimeoutHandler_i::start ()
 112 {
 113   timer_.reset ();
 114   timer_.start ();
 115 }
 116
 117 ACE_Time_Value &
 118 TimeoutHandler_i::elapsed_time ()
 119 {
 120   timer_.elapsed_time (elapsed_time_);
 121   return elapsed_time_;
 122 }