ACE/apps/JAWS3/jaws3/Task_Timer.cpp

   1 #ifndef JAWS_BUILD_DLL
   2 #define JAWS_BUILD_DLL
   3 #endif
   4
   5 #include "ace/OS_NS_sys_time.h"
   6
   7 #include "jaws3/Task_Timer.h"
   8 #include "jaws3/Timer_Helpers.h"
   9
  10
  11 JAWS_Task_Timer::JAWS_Task_Timer ()
  12 {
  13   this->timer_queue_.activate ();
  14 }
  15
  16
  17 void
  18 JAWS_Task_Timer::schedule_timer ( long *timer_id
  19                                 , const ACE_Time_Value &delta
  20                                 , JAWS_Event_Completer *completer
  21                                 , void *act
  22                                 )
  23 {
  24   JAWS_Timer_EH *eh = new JAWS_Timer_EH (completer, act);
  25   if (eh == 0
  26       || (*timer_id =
  27             this->timer_queue_.schedule ( eh
  28                                         , 0
  29                                         , delta + ACE_OS::gettimeofday ()))
  30          == -1)
  31     {
  32       JAWS_Event_Result timer_result ( 0
  33                                      , JAWS_Event_Result::JE_ERROR
  34                                      , JAWS_Event_Result::JE_TIMER_FAIL
  35                                      );
  36
  37       if (completer)
  38         completer->timer_complete (timer_result, act);
  39
  40       delete eh;
  41     }
  42 }
  43
  44
  45 void
  46 JAWS_Task_Timer::schedule_absolute_timer ( long *timer_id
  47                                          , const ACE_Time_Value &tv
  48                                          , JAWS_Event_Completer *completer
  49                                          , void *act
  50                                          )
  51 {
  52   JAWS_Timer_EH *eh = new JAWS_Timer_EH (completer, act);
  53   if (eh == 0
  54       || (*timer_id = this->timer_queue_.schedule (eh, 0, tv)) == -1)
  55     {
  56       JAWS_Event_Result timer_result ( 0
  57                                      , JAWS_Event_Result::JE_ERROR
  58                                      , JAWS_Event_Result::JE_TIMER_FAIL
  59                                      );
  60
  61       if (completer)
  62         completer->timer_complete (timer_result, act);
  63
  64       delete eh;
  65     }
  66 }
  67
  68
  69 void
  70 JAWS_Task_Timer::schedule_interval_timer ( long *timer_id
  71                                          , const ACE_Time_Value &interval
  72                                          , JAWS_Event_Completer *completer
  73                                          , void *act
  74                                          )
  75 {
  76   JAWS_Timer_EH *eh = new JAWS_Timer_EH (completer, act);
  77   if (eh == 0
  78       || (*timer_id =
  79             this->timer_queue_.schedule ( eh
  80                                         , 0
  81                                         , interval + ACE_OS::gettimeofday ()
  82                                         , interval
  83                                         ))
  84           == -1)
  85     {
  86       JAWS_Event_Result timer_result ( 0
  87                                      , JAWS_Event_Result::JE_ERROR
  88                                      , JAWS_Event_Result::JE_TIMER_FAIL
  89                                      );
  90
  91       if (completer)
  92         completer->timer_complete (timer_result, act);
  93
  94       delete eh;
  95     }
  96 }
  97
  98
  99 void
 100 JAWS_Task_Timer::cancel_timer (long timer_id)
 101 {
 102   this->timer_queue_.cancel (timer_id);
 103 }
 104