TAO/tests/Bug_1269_Regression/Server_Timer.cpp

   1 /**
   2  * @file Server_Timer.cpp
   3  *
   4  * @author Carlos O'Ryan <coryan@atdesk.com>
   5  */
   6 #include "Server_Timer.h"
   7 #include "ace/Reactor.h"
   8 #include "ace/OS_NS_string.h"
   9
  10 Server_Timer::Server_Timer(Test::Echo_ptr echo,
  11                            ACE_Reactor * reactor)
  12   : ACE_Event_Handler (reactor)
  13   , echo_(Test::Echo::_duplicate(echo))
  14 {
  15 }
  16
  17 void
  18 Server_Timer::activate ()
  19 {
  20   ACE_Time_Value tv (0, 20000);
  21   this->reactor()->schedule_timer (this, 0, tv);
  22 }
  23
  24 int
  25 Server_Timer::handle_timeout (ACE_Time_Value const &, void const *)
  26 {
  27   Test::Payload pload(1024);
  28   pload.length(1024);
  29
  30   ACE_OS::memset(pload.get_buffer(), 0, pload.length());
  31
  32   try
  33   {
  34     Test::Echo_var echo =
  35       Test::Echo::_duplicate (this->echo_.in());
  36
  37     if(CORBA::is_nil (echo.in()))
  38       return 0;
  39
  40     echo->echo_payload (pload);
  41
  42     ACE_Time_Value tv (0, 20000);
  43     this->reactor()->schedule_timer (this, 0, tv);
  44   }
  45   catch (const CORBA::Exception&)
  46   {
  47     this->echo_ = Test::Echo::_nil ();
  48
  49     this->reactor()->cancel_timer(this);
  50
  51     return -1;
  52   }
  53
  54   return 0;
  55 }
  56
  57 int
  58 Server_Timer::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
  59 {
  60   delete this;
  61   return 0;
  62 }