ACE/examples/APG/Reactor/Timer_Cancel.cpp

   1 /**
   2  * Changing the interval and canceling
   3  */
   4
   5 #include "ace/OS_NS_time.h"
   6 #include "ace/Log_Msg.h"
   7 #include "ace/Reactor.h"
   8 #include "ace/Event_Handler.h"
   9
  10 class MyTimerHandler : public ACE_Event_Handler
  11 {
  12 public:
  13   int handle_timeout (const ACE_Time_Value &current_time,
  14                       const void * = 0)
  15   {
  16     time_t epoch = ((timespec_t)current_time).tv_sec;
  17     ACE_DEBUG ((LM_INFO,
  18                 ACE_TEXT ("handle_timeout: %s"),
  19                 ACE_OS::ctime(&epoch)));
  20     return 0;
  21   }
  22 };
  23
  24 #if !defined (ACE_LACKS_UNIX_SIGNALS)
  25
  26 // Listing 1 code/ch07
  27 class SignalHandler : public ACE_Event_Handler
  28 {
  29 public:
  30   SignalHandler (long timerId, int currentInterval)
  31     : ACE_Event_Handler(),
  32       timerId_(timerId),
  33       currentInterval_(currentInterval)
  34   {
  35   }
  36
  37   int handle_signal (int sig, siginfo_t * = 0, ucontext_t * = 0)
  38   {
  39     if (sig == SIGINT)
  40       {
  41         ACE_DEBUG ((LM_INFO,
  42                     ACE_TEXT ("Resetting interval of timer ")
  43                     ACE_TEXT ("%d to %d\n"),
  44                     this->timerId_,
  45                     ++this->currentInterval_));
  46         ACE_Time_Value newInterval (this->currentInterval_);
  47         ACE_Reactor::instance ()->
  48           reset_timer_interval (this->timerId_, newInterval);
  49       }
  50     else if (sig == SIGTSTP)
  51       {
  52         ACE_DEBUG ((LM_INFO,
  53                     ACE_TEXT ("Canceling timer %d\n"),
  54                     this->timerId_));
  55         ACE_Reactor::instance ()->cancel_timer (this->timerId_);
  56       }
  57
  58     return 0;
  59   }
  60
  61 private:
  62   long timerId_;
  63   int currentInterval_;
  64 };
  65 // Listing 1
  66
  67 #endif /* ACE_LACKS_UNIX_SIGNALS */
  68
  69
  70 int ACE_TMAIN (int, ACE_TCHAR *[])
  71 {
  72   ACE_Time_Value initialDelay (3);
  73   ACE_Time_Value interval (5);
  74
  75   // Listing 2 code/ch07
  76   MyTimerHandler *handler = new MyTimerHandler ();
  77   long timerId =
  78     ACE_Reactor::instance ()->schedule_timer (handler,
  79                                               0,
  80                                               initialDelay,
  81                                               interval);
  82   // Listing 2
  83
  84 #if !defined (ACE_LACKS_UNIX_SIGNALS)
  85
  86   // Listing 3 code/ch07
  87   SignalHandler *mutateTimer =
  88     new SignalHandler (timerId, 5);
  89   ACE_Reactor::instance ()->register_handler (SIGINT,
  90                                               mutateTimer);
  91   ACE_Reactor::instance ()->register_handler (SIGTSTP,
  92                                               mutateTimer);
  93   // Listing 3
  94
  95 #else
  96    ACE_UNUSED_ARG (timerId);
  97 #endif /* ACE_LACKS_UNIX_SIGNALS */
  98
  99   ACE_Reactor::instance ()->run_reactor_event_loop ();
 100   return 0;
 101 }