TAO/orbsvcs/tests/CosEvent/Timeout/TestEventConsumer_i.cpp

   1 #include "TestEventConsumer_i.h"
   2
   3 #include "ace/Log_Msg.h"
   4
   5 TestEventConsumer_i::TestEventConsumer_i (CORBA::ORB_ptr orb, bool hang)
   6   : orb_ (CORBA::ORB::_duplicate (orb)),
   7     hang_ (hang),
   8     count_ (0),
   9     orbtask_ (orb),
  10     cond_ (this->mtx_),
  11     shutdown_ (false)
  12 {
  13 }
  14
  15 void
  16 TestEventConsumer_i::activate ()
  17 {
  18   this->orbtask_.activate ();
  19 }
  20
  21 int
  22 TestEventConsumer_i::ORB_task::svc ()
  23 {
  24   ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i ORB_task starting\n")));
  25   try
  26     {
  27       this->orb_->run ();
  28       ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i ORB_task exiting\n")));
  29     }
  30   catch (const CORBA::SystemException &e)
  31     {
  32       e._tao_print_exception (
  33         ACE_TEXT (
  34           "TestEventConsumer_i ORB_task: Caught CORBA::Exception:"));
  35     }
  36   return 0;
  37 }
  38
  39 void
  40 TestEventConsumer_i::push (const CORBA::Any & data)
  41 {
  42   // Extract event data from the any.
  43   const char *eventData;
  44   if (data >>= eventData)
  45     {
  46       ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i::push(): Received ")
  47                             ACE_TEXT ("event containing %d bytes.\n"),
  48                                       ACE_OS::strlen (eventData)));
  49       if (this->hang_ && ++this->count_ == 10)
  50         {
  51           ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i::push(): ")
  52                                 ACE_TEXT ("Simulating hung consumer\n")));
  53           {
  54             ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->mtx_);
  55             while (!this->shutdown_)
  56               this->cond_.wait ();
  57           }
  58           ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i::push Done\n")
  59                       ));
  60         }
  61     }
  62 }
  63
  64 void
  65 TestEventConsumer_i::disconnect_push_consumer ()
  66 {
  67   ACE_DEBUG ((LM_DEBUG,
  68               ACE_TEXT ("TestEventConsumer_i::disconnect_push_consumer()\n")));
  69   this->orb_->shutdown ();
  70   this->shutdown_ = true;
  71   this->cond_.signal ();
  72 }