ACE/examples/Timer_Queue/Custom_Handler.cpp

   1 //=============================================================================
   2 /**
   3  *  @file    Custom_Handler.cpp
   4  *
   5  *  This is a custom event handler to be used with the thread timer queue
   6  *  adapter, and its appropriate upcall.
   7  *
   8  *  @author Alon Diamant <diamant.alon@gmail.com
   9  */
  10 //=============================================================================
  11
  12
  13 #include "Custom_Handler.h"
  14 #include "ace/OS_NS_stdio.h"
  15
  16 Custom_Handler::Custom_Handler(const ACE_Time_Value &expiration_time)
  17   :  expires_ (expiration_time),
  18      id_ (0)
  19 {
  20 }
  21
  22 Custom_Handler::~Custom_Handler ()
  23 {
  24 }
  25
  26 void
  27 Custom_Handler::set_id (int id)
  28 {
  29   this->id_ = id;
  30 }
  31
  32 // This is the method invoked when the Timer expires.
  33 int
  34 Custom_Handler::on_timeout (const ACE_Time_Value &current_time,
  35                             const void *)
  36 {
  37   ACE_Time_Value delay = current_time - this->expires_;
  38
  39   // No need to protect this printf is always called from a Async safe
  40   // point.
  41   ACE_OS::printf ("\nexpiring timer %d at %lu.%7.7lu secs\n"
  42                   "\tthere was a %lu.%7.7lu secs delay\n",
  43                   this->id_,
  44                   static_cast<unsigned long> (current_time.sec ()),
  45                   static_cast<unsigned long> (current_time.usec ()),
  46                   static_cast<unsigned long> (delay.sec ()),
  47                   static_cast<unsigned long> (delay.usec ()));
  48
  49   // Notice this delete is protected.
  50   delete this;
  51
  52   return 0;
  53 }
  54
  55 int Custom_Handler_Upcall::registration(TTimerQueue& , Custom_Handler* , const void* )
  56 {
  57     ACE_TRACE("registration");
  58
  59     return 0;
  60 }
  61
  62 int Custom_Handler_Upcall::preinvoke(TTimerQueue& , Custom_Handler* , const void* , int , const ACE_Time_Value& , const void*& )
  63 {
  64     ACE_TRACE("preinvoke");
  65
  66     return 0;
  67 }
  68
  69 int Custom_Handler_Upcall::timeout(TTimerQueue& , Custom_Handler* handler, const void* arg, int , const ACE_Time_Value& cur_time)
  70 {
  71     ACE_TRACE("timeout");
  72
  73     // Do the actual timer call
  74     handler->on_timeout(cur_time, arg);
  75
  76     return 0;
  77 }
  78
  79 int Custom_Handler_Upcall::postinvoke(TTimerQueue& , Custom_Handler* , const void* , int , const ACE_Time_Value& , const void* )
  80 {
  81     ACE_TRACE("postinvoke");
  82
  83     return 0;
  84 }
  85
  86 int Custom_Handler_Upcall::cancel_type(TTimerQueue& , Custom_Handler* , int , int& )
  87 {
  88     ACE_TRACE("cancel_type");
  89
  90     return 0;
  91 }
  92
  93 int Custom_Handler_Upcall::cancel_timer(TTimerQueue& , Custom_Handler* handler, int , int )
  94 {
  95     ACE_TRACE("cancel_timer");
  96     delete handler;
  97     return 0;
  98 }
  99
 100 int Custom_Handler_Upcall::deletion(TTimerQueue& , Custom_Handler* handler, const void* )
 101 {
 102     ACE_TRACE("deletion");
 103     delete handler;
 104     return 0;
 105 }
 106