ACE/examples/Reactor/Multicast/Log_Wrapper.h

   1 /* -*- C++ -*- */
   2 // log_wrapper.h
   3
   4 #include "ace/Profile_Timer.h"
   5
   6 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   7 # pragma once
   8 #endif /* ACE_LACKS_PRAGMA_ONCE */
   9
  10 #include "ace/INET_Addr.h"
  11 #include "ace/SOCK_Dgram_Mcast.h"
  12
  13 #ifndef _LOG_WRAPPER_H
  14 #define _LOG_WRAPPER_H
  15
  16 class Log_Wrapper
  17   // = TITLE
  18   //      Provide a wrapper around sending log messages via IP
  19   //      multicast.
  20 {
  21 public:
  22   Log_Wrapper ();
  23   ~Log_Wrapper ();
  24
  25   // = Types of logging messages.
  26   enum Log_Priority
  27   {
  28     LM_MESSAGE,
  29     LM_DEBUG,
  30     LM_WARNING,
  31     LM_ERROR,
  32     LM_EMERG
  33   };
  34
  35   int open (const int port, const char* mcast_addr);
  36   // Subscribe to a given UDP multicast group
  37
  38   int log_message (Log_Priority type, char *message);
  39   // send a string to the logger
  40
  41   // = Format of the logging record.
  42   struct Log_Record
  43   {
  44     u_long sequence_number;
  45     Log_Priority type;
  46     long  host;
  47     long  time;
  48     long  app_id;
  49     long  msg_length;
  50   };
  51
  52 private:
  53   ACE_INET_Addr server_;
  54   // Server address where records are logged.
  55
  56   u_long sequence_number_;
  57   // Keep track of the sequence.
  58
  59   Log_Record log_msg_;
  60   // One record used for many log messages.
  61
  62   ACE_SOCK_Dgram_Mcast logger_;
  63   // A logger object.
  64 };
  65
  66 #endif /* _LOG_WRAPPER_H */