TAO/examples/Event_Comm/Supplier_Input_Handler.cpp

   1 #include "Event_Comm_i.h"
   2 #include "Notifier_Handler.h"
   3 #include "Supplier_Input_Handler.h"
   4 #include "tao/ORB_Core.h"
   5
   6 Supplier_Input_Handler::Supplier_Input_Handler ()
   7   : notifier_ (0)
   8 {
   9   // No-Op.
  10 }
  11
  12 Supplier_Input_Handler::~Supplier_Input_Handler (void)
  13 {
  14   ACE_DEBUG ((LM_DEBUG,
  15               "closing down Supplier_Input_Handler::~Supplier_Input_Handler\n"));
  16 }
  17
  18 int
  19 Supplier_Input_Handler::close (void)
  20 {
  21   ACE_DEBUG ((LM_DEBUG,
  22               "closing down Supplier::Supplier_Input_Handler\n"));
  23
  24   // Make sure to cleanup the STDIN handler.
  25    if (ACE_Event_Handler::remove_stdin_handler
  26       (
  27        TAO_ORB_Core_instance ()->reactor (),
  28        TAO_ORB_Core_instance ()->thr_mgr ()) == -1)
  29      ACE_ERROR ((LM_ERROR,
  30                  "%p\n",
  31                  "remove_stdin_handler"));
  32    return 0;
  33 }
  34
  35 int
  36 Supplier_Input_Handler::initialize (Notifier_Handler *notifier)
  37 {
  38   notifier_ = notifier;
  39   // Register our <Input_Handler> to handle STDIN events, which will
  40   // trigger the <handle_input> method to process these events.
  41
  42   if (ACE_Event_Handler::register_stdin_handler
  43       (this,
  44        TAO_ORB_Core_instance ()->reactor (),
  45        TAO_ORB_Core_instance ()->thr_mgr ()) == -1)
  46     ACE_ERROR_RETURN ((LM_ERROR,
  47                        "%p\n",
  48                        "register_stdin_handler"),
  49                       -1);
  50
  51
  52   return 0;
  53 }
  54
  55 // Frame input events and notify <Consumers>.
  56
  57 int
  58 Supplier_Input_Handler::handle_input (ACE_HANDLE)
  59 {
  60   char buf[BUFSIZ];
  61
  62   // Read up to BUFSIZ worth of data from ACE_HANDLE h.
  63
  64   if (ACE_OS::fgets (buf,
  65                      sizeof buf - 1,
  66                      stdin) == 0)
  67     {
  68       ACE_DEBUG ((LM_DEBUG,
  69                   "shutting down Supplier_Input_Handler\n"));
  70       return 0;
  71     }
  72   else
  73     {
  74       size_t n = ACE_OS::strlen (buf);
  75
  76       // Null terminate the buffer, replacing the '\n' with '\0'.
  77       if (buf[n - 1] == '\n')
  78         buf[n - 1] = '\0';
  79       else
  80         buf[n] = '\0';
  81       ACE_DEBUG ((LM_DEBUG,
  82                   "notifying for event %s\n",
  83                   buf));
  84     }
  85
  86
  87
  88   if (ACE_OS::strncmp (buf, "quit", 4) == 0)
  89     // Tell the main event loop to shutdown.
  90     this->notifier_->shutdown ();
  91   else
  92     {
  93       Event_Comm::Notifier *notifier = this->notifier_->notifier ();
  94       ACE_ASSERT (notifier != 0);
  95
  96       // Use the notifier to notify Consumers.
  97       try
  98         {
  99           Event_Comm::Event event;
 100
 101           // Pass the buf over in the tag field.
 102           event.tag_ = ACE_OS::strdup (buf);
 103
 104           // This is where the "any" value goes or the object
 105           // reference...  event.value_ = ...
 106
 107           // Forward <Event> to all <Consumers>.
 108           notifier->push (event);
 109         }
 110       catch (const CORBA::Exception& ex)
 111         {
 112           ex._tao_print_exception ("Unexpected Error\n");
 113         }
 114     }
 115   return 0;
 116 }