ACE/examples/Service_Configurator/IPC-tests/server/Handle_Timeout.inl

   1 /* -*- C++ -*- */
   2 #include "ace/Service_Config.h"
   3 #include "ace/Get_Opt.h"
   4 #include "ace/OS_NS_stdio.h"
   5 #include "ace/OS_NS_string.h"
   6 #include "ace/Truncate.h"
   7
   8 ACE_INLINE
   9 Handle_Timeout::Handle_Timeout () : count (0)
  10 {
  11 }
  12
  13 ACE_INLINE int
  14 Handle_Timeout::info (ACE_TCHAR **strp, size_t length) const
  15 {
  16   ACE_TCHAR buf[BUFSIZ];
  17
  18   ACE_OS::strcpy (buf, ACE_TEXT("# tests timeout facility\n"));
  19
  20   if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0)
  21     {
  22       return -1;
  23     }
  24   else
  25     {
  26       ACE_OS::strncpy (*strp, buf, length);
  27     }
  28
  29   return ACE_Utils::truncate_cast<int> (ACE_OS::strlen (buf));
  30 }
  31
  32 ACE_INLINE int
  33 Handle_Timeout::init (int argc, ACE_TCHAR *argv[])
  34 {
  35   ACE_Time_Value delta (10);
  36   ACE_Time_Value interval (1);
  37   ACE_Get_Opt    get_opt (argc, argv, ACE_TEXT("a:d:i:"), 0);
  38   intptr_t       arg = 0;
  39
  40   for (int c; (c = get_opt ()) != -1; )
  41      switch (c)
  42        {
  43        case 'd':
  44          delta.sec (ACE_OS::atoi (get_opt.opt_arg ()));
  45          break;
  46        case 'i':
  47          interval.sec (ACE_OS::atoi (get_opt.opt_arg ()));
  48          break;
  49        case 'a':
  50          arg = ACE_OS::atoi (get_opt.opt_arg ());
  51          break;
  52        default:
  53          break;
  54        }
  55
  56   if (ACE_Reactor::instance ()->schedule_timer (this,
  57                                                 reinterpret_cast<void *> (arg),
  58                                                 delta,
  59                                                 interval) == -1)
  60     return -1;
  61   else
  62     return 0;
  63 }
  64
  65 ACE_INLINE int
  66 Handle_Timeout::fini ()
  67 {
  68   return 0;
  69 }
  70
  71 ACE_INLINE ACE_HANDLE
  72 Handle_Timeout::get_handle () const
  73 {
  74   return ACE_INVALID_HANDLE;
  75 }
  76
  77 ACE_INLINE int
  78 Handle_Timeout::handle_timeout (const ACE_Time_Value &tv,
  79                                 const void *arg)
  80 {
  81   if (this->count++ >= 10)
  82     return -1; // Automatically cancel periodic timer...
  83
  84   // Cast arg to a long, first, because a pointer is the same
  85   // size as a long on all current ACE platforms.
  86   ACE_DEBUG ((LM_INFO,
  87               ACE_TEXT ("time for this(%u) expired at (%d, %d) with arg = %d\n"),
  88               this,
  89               tv.sec (),
  90               tv.usec (),
  91               (int) (ptrdiff_t) arg));
  92   return 0;
  93 }