ACE/examples/APG/Timers/CB.cpp

   1 #include "ace/Log_Msg.h"
   2 #include "CB.h"
   3 #include "TimerDispatcher.h"
   4
   5 CB::CB () : count_(0)
   6 {
   7   ACE_TRACE ("CB::CB");
   8 }
   9
  10 // Listing 1 code/ch20
  11 int CB::handle_timeout (const ACE_Time_Value &,
  12                         const void *arg)
  13 {
  14   ACE_TRACE ("CB::handle_timeout");
  15
  16   const int *val = static_cast<const int*> (arg);
  17   ACE_ASSERT ((*val) == timerID_);
  18
  19   ACE_UNUSED_ARG (val);
  20
  21   if (count_ == 5)
  22     {
  23       ACE_DEBUG ((LM_DEBUG,
  24                   ACE_TEXT ("Reseting interval for timer %d\n"),
  25                   timerID_));
  26
  27       // New interval is 10 ms.
  28       ACE_Time_Value interval (0L, 1000L);
  29       int status = Timer::instance ()->reset_interval
  30                                          (timerID_, interval);
  31 #if defined (ACE_NDEBUG)
  32       ACE_UNUSED_ARG (status);
  33 #else
  34       ACE_ASSERT (status != -1);
  35 #endif
  36     }
  37
  38   if (count_++ == 10)
  39     {
  40       ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Canceling %d\n"),
  41                   timerID_));
  42       ACE_ASSERT ((Timer::instance ()->cancel (this)) != 0);
  43     }
  44
  45   return 0;
  46 }
  47 // Listing 1
  48
  49 void
  50 CB::setID (long timerID)
  51 {
  52   ACE_TRACE ("CB::setID");
  53   timerID_ = timerID;
  54 }
  55
  56 long
  57 CB::getID ()
  58 {
  59   ACE_TRACE ("CB::getID");
  60   return timerID_;
  61 }
  62
  63 int
  64 CB::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
  65 {
  66   ACE_TRACE ("CB::handle_close");
  67   return 0;
  68 }