ACE/examples/APG/Timers/PCB.cpp

   1 #include "ace/Log_Msg.h"
   2 #include "PCB.h"
   3 #include "PTimerDispatcher.h"
   4
   5 PCB::PCB() : count_(0)
   6 {
   7   ACE_TRACE ("PCB::PCB");
   8 }
   9
  10 PCB::~PCB()
  11 {
  12 }
  13
  14 int PCB::handleEvent (const void *arg)
  15 {
  16   ACE_TRACE ("PCB::handleEvent");
  17
  18   const int *val = static_cast<const int*> (arg);
  19   ACE_ASSERT ((*val) == timerID_);
  20
  21   ACE_UNUSED_ARG (val);
  22
  23   ACE_DEBUG ((LM_DEBUG,
  24               ACE_TEXT("Timer %d expiry handled by thread %t\n"),
  25               timerID_));
  26   if (count_ == 5)
  27     {
  28       ACE_DEBUG ((LM_DEBUG,
  29                   ACE_TEXT ("Reseting interval for timer %d\n"),
  30                   timerID_));
  31
  32       // New interval is 10 ms.
  33       ACE_Time_Value interval (0L, 1000L);
  34       if (PTimer::instance ()->reset_interval (timerID_, interval) != -1)
  35         ACE_ERROR_RETURN ((LM_ERROR,
  36                            ACE_TEXT ("%p\n"),
  37                            ACE_TEXT ("reset_interval")),
  38                           -1);
  39     }
  40
  41   if (count_++ == 10)
  42     {
  43       ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Canceling %d\n"),
  44                   timerID_));
  45       PTimer::instance ()->cancel (this);
  46     }
  47
  48   return 0;
  49 }
  50
  51 void
  52 PCB::setID (long timerID)
  53 {
  54   ACE_TRACE ("PCB::setID");
  55   timerID_ = timerID;
  56 }
  57
  58 long
  59 PCB::getID () const
  60 {
  61   ACE_TRACE ("PCB::getID");
  62   return timerID_;
  63 }
  64
  65 int
  66 PCB::handleClose ()
  67 {
  68   ACE_TRACE ("PCB::handleClose");
  69   return 0;
  70 }
  71
  72 int
  73 PCB::handleCancel ()
  74 {
  75   ACE_TRACE ("PCB::handleCancel");
  76   return 0;
  77 }