ACE/examples/ASX/UPIPE_Event_Server/Event_Analyzer.cpp

   1 #include "ace/OS_NS_string.h"
   2 #include "ace/Truncate.h"
   3 #include "Event_Analyzer.h"
   4
   5
   6 #if defined (ACE_HAS_THREADS)
   7
   8 int
   9 Event_Analyzer::open (void *)
  10 {
  11   return 0;
  12 }
  13
  14 int
  15 Event_Analyzer::close (u_long)
  16 {
  17   return 0;
  18 }
  19
  20 int
  21 Event_Analyzer::control (ACE_Message_Block *mb)
  22 {
  23   ACE_IO_Cntl_Msg *ioc = (ACE_IO_Cntl_Msg *) mb->rd_ptr ();
  24   ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds cmd;
  25
  26   switch (cmd = ioc->cmd ())
  27     {
  28     case ACE_IO_Cntl_Msg::SET_LWM:
  29     case ACE_IO_Cntl_Msg::SET_HWM:
  30       this->water_marks (cmd, *(size_t *) mb->cont ()->rd_ptr ());
  31       break;
  32     default:
  33       break;
  34     }
  35   return 0;
  36 }
  37
  38 int
  39 Event_Analyzer::put (ACE_Message_Block *mb, ACE_Time_Value *)
  40 {
  41   if (mb->msg_type () == ACE_Message_Block::MB_IOCTL)
  42     this->control (mb);
  43
  44   return this->put_next (mb);
  45 }
  46
  47 int
  48 Event_Analyzer::init (int, ACE_TCHAR *[])
  49 {
  50   return 0;
  51 }
  52
  53 int
  54 Event_Analyzer::fini ()
  55 {
  56   return 0;
  57 }
  58
  59 int
  60 Event_Analyzer::info (ACE_TCHAR **strp, size_t length) const
  61 {
  62   const ACE_TCHAR *module_name = this->name ();
  63
  64   if (*strp == 0 && (*strp = ACE_OS::strdup (module_name)) == 0)
  65     return -1;
  66   else
  67     ACE_OS::strncpy (*strp, module_name, length);
  68
  69   return ACE_Utils::truncate_cast<int> (ACE_OS::strlen (module_name));
  70 }
  71
  72 #endif /* ACE_HAS_THREADS */