ACE/examples/APG/Streams/RecordingDevice_Text.h

   1 /* -*- C++ -*- */
   2 /*
   3  * A RecordingDevice that listens to a socket and collects text.
   4  */
   5
   6 #ifndef RECORDING_DEVICE_TEXT_H
   7 #define RECORDING_DEVICE_TEXT_H
   8
   9 #include "ace/FILE_IO.h"
  10 #include "ace/FILE_Connector.h"
  11 #include "ace/SOCK_Stream.h"
  12 #include "ace/SOCK_Acceptor.h"
  13
  14 #include "CommandStream.h"
  15 #include "MessageInfo.h"
  16 #include "RecordingDevice.h"
  17
  18 class TextListenerAcceptor :
  19       public ACE_Event_Handler,
  20       public RecordingDevice
  21 {
  22 public:
  23   TextListenerAcceptor ();
  24
  25   // ACE_Event_Handler interface
  26
  27   int open (ACE_INET_Addr &addr);
  28
  29   ACE_HANDLE get_handle () const;
  30
  31   int handle_input (ACE_HANDLE);
  32
  33   int accept (ACE_SOCK_Stream &peer);
  34
  35   // RecordingDevice interface
  36
  37   // Open a listening socket on the port specified by argv.
  38   int init (int argc, ACE_TCHAR *argv[]);
  39
  40   ACE_Event_Handler *get_handler () const;
  41
  42   virtual RecordingDevice *wait_for_activity ();
  43
  44   virtual int answer_call ();
  45
  46   virtual CallerId *retrieve_callerId ();
  47
  48   virtual int play_message (ACE_FILE_Addr &addr);
  49
  50   virtual MessageType *record_message (ACE_FILE_Addr &addr);
  51
  52 private:
  53   ACE_SOCK_Acceptor acceptor_;
  54 };
  55
  56 // Listing 01 code/ch18
  57 class TextListener : public RecordingDevice
  58 {
  59 public:
  60   TextListener (TextListenerAcceptor *acceptor);
  61
  62   virtual const ACE_TCHAR *get_name () const;
  63
  64   int answer_call ();
  65
  66   CallerId *retrieve_callerId ();
  67
  68   int play_message (ACE_FILE_Addr &addr);
  69
  70   MessageType *record_message (ACE_FILE_Addr &addr);
  71
  72   virtual void release ();
  73   // Listing 01
  74   // Listing 02 code/ch18
  75 private:
  76   CommandStream *command_stream_;
  77   TextListenerAcceptor *acceptor_;
  78   ACE_SOCK_Stream peer_;
  79 };
  80 // Listing 02
  81
  82 #endif /* RECORDING_DEVICE_TEXT_H */