TAO/tests/AMI_Timeouts/timeout_i.cpp

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