ACE/examples/APG/Streams/RecordingDevice_Text.cpp

   1 /*
   2  * A RecordingDevice that listens to a socket and collects text.
   3  */
   4
   5 #include "MessageInfo.h"
   6 #include "RecordingDevice.h"
   7 #include "RecordingDevice_Text.h"
   8 #include "Util.h"
   9
  10 TextListenerAcceptor::TextListenerAcceptor ()
  11   : ACE_Event_Handler(), RecordingDevice()
  12 { }
  13
  14 // ACE_Event_Handler interface
  15
  16 int TextListenerAcceptor::open (ACE_INET_Addr &addr)
  17 {
  18   if (this->acceptor_.open (addr, 1) == -1)
  19     ACE_ERROR_RETURN ((LM_ERROR,
  20                        ACE_TEXT ("%p\n"),
  21                        ACE_TEXT ("acceptor open")),
  22                       -1);
  23   return 0;
  24 }
  25
  26 ACE_HANDLE TextListenerAcceptor::get_handle () const
  27 {
  28   return this->acceptor_.get_handle ();
  29 }
  30
  31 int TextListenerAcceptor::handle_input (ACE_HANDLE)
  32 {
  33   ACE_DEBUG ((LM_INFO,
  34               ACE_TEXT ("TextListenerAcceptor - connection request\n" )));
  35   return 0;
  36 }
  37
  38 int TextListenerAcceptor::accept (ACE_SOCK_Stream &peer)
  39 {
  40   return this->acceptor_.accept (peer);
  41 }
  42
  43 // RecordingDevice interface
  44
  45 // Open a listening socket on the port specified by argv.
  46 int TextListenerAcceptor::init (int argc, ACE_TCHAR *argv[])
  47 {
  48   ACE_UNUSED_ARG(argc);
  49
  50   ACE_INET_Addr addr (argv[1]);
  51
  52   if (this->open (addr) < 0)
  53     ACE_ERROR_RETURN ((LM_ERROR,
  54                        ACE_TEXT ("%p\n"),
  55                        ACE_TEXT ("TextListener - open")),
  56                       -1);
  57   return 0;
  58 }
  59
  60 ACE_Event_Handler *TextListenerAcceptor::get_handler () const
  61 {
  62   return (ACE_Event_Handler *)this;
  63 }
  64
  65 RecordingDevice *TextListenerAcceptor::wait_for_activity ()
  66 {
  67   this->RecordingDevice::wait_for_activity ();
  68   return new TextListener (this);
  69 }
  70
  71 int TextListenerAcceptor::answer_call ()
  72 {
  73   return -1;
  74 }
  75
  76 CallerId *TextListenerAcceptor::retrieve_callerId ()
  77 {
  78   return 0;
  79 }
  80
  81 int TextListenerAcceptor::play_message (ACE_FILE_Addr &addr)
  82 {
  83   ACE_UNUSED_ARG(addr);
  84   return 0;
  85 }
  86
  87 MessageType *TextListenerAcceptor::record_message (ACE_FILE_Addr &addr)
  88 {
  89   ACE_UNUSED_ARG(addr);
  90   return 0;
  91 }
  92
  93
  94 // Listing 01 code/ch18
  95 TextListener::TextListener (TextListenerAcceptor *acceptor)
  96   : acceptor_(acceptor)
  97 {
  98   ACE_TRACE ("TextListener ctor");
  99
 100   ACE_NEW (this->command_stream_, CommandStream (&(this->peer_)));
 101   this->command_stream_->open (0);
 102 }
 103 // Listing 01
 104
 105 const ACE_TCHAR *TextListener::get_name () const
 106 {
 107   return ACE_TEXT ("TextListener");
 108 }
 109
 110 // Listing 02 code/ch18
 111 int TextListener::answer_call ()
 112 {
 113   ACE_DEBUG ((LM_DEBUG,
 114               ACE_TEXT ("TextListener::answer_call()\n")));
 115
 116   Command *c = new Command ();
 117   c->command_ = Command::CMD_ANSWER_CALL;
 118   c->extra_data_ = this->acceptor_;
 119
 120   c = this->command_stream_->execute (c);
 121
 122   ACE_DEBUG ((LM_DEBUG,
 123               ACE_TEXT ("TextListener::answer_call() ")
 124               ACE_TEXT ("result is %d\n"),
 125               c->numeric_result_));
 126
 127   return c->numeric_result_;
 128 }
 129 // Listing 02
 130
 131 // Listing 03 code/ch18
 132 CallerId *TextListener::retrieve_callerId ()
 133 {
 134   ACE_DEBUG ((LM_DEBUG,
 135               ACE_TEXT ("TextListener::retrieve_callerId()\n")));
 136
 137   Command *c = new Command ();
 138   c->command_ = Command::CMD_RETRIEVE_CALLER_ID;
 139
 140   c = this->command_stream_->execute (c);
 141
 142   CallerId *caller_id = new CallerId (c->result_);
 143   return caller_id;
 144 }
 145 // Listing 03
 146
 147 // Listing 04 code/ch18
 148 int TextListener::play_message (ACE_FILE_Addr &addr)
 149 {
 150   MessageType *type = Util::identify_message (addr);
 151   if (type->is_text ())
 152     {
 153       Command *c = new Command ();
 154       c->command_ = Command::CMD_PLAY_MESSAGE;
 155       c->extra_data_ = &addr;
 156       c = this->command_stream_->execute (c);
 157       return c->numeric_result_;
 158     }
 159
 160   ACE_FILE_Addr temp (ACE_TEXT ("/tmp/outgoing_message.text"));
 161   ACE_FILE_IO *file;
 162   if (type->is_audio ())
 163     file = Util::audio_to_text (addr, temp);
 164   else if (type->is_video ())
 165     file = Util::video_to_text (addr, temp);
 166   else
 167     ACE_ERROR_RETURN
 168       ((LM_ERROR, ACE_TEXT ("Invalid message type %d\n"),
 169         type->get_codec ()), -1);
 170   int rval = this->play_message (temp);
 171   file->remove ();
 172   return rval;
 173 }
 174 // Listing 04
 175
 176 // Listing 05 code/ch18
 177 MessageType *TextListener::record_message (ACE_FILE_Addr &addr)
 178 {
 179   Command *c = new Command ();
 180   c->command_ = Command::CMD_RECORD_MESSAGE;
 181   c->extra_data_ = &addr;
 182   c = this->command_stream_->execute (c);
 183   if (c->numeric_result_ == -1)
 184     return 0;
 185
 186   return new MessageType (MessageType::RAWTEXT, addr);
 187 }
 188 // Listing 05
 189
 190 // Listing 06 code/ch18
 191 void TextListener::release ()
 192 {
 193   delete this;
 194 }
 195 // Listing 06