diff options
Diffstat (limited to 'TAO/orbsvcs/tests/CosEvent/Timeout/TestEventConsumer_i.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Timeout/TestEventConsumer_i.cpp | 78 |
1 files changed, 0 insertions, 78 deletions
diff --git a/TAO/orbsvcs/tests/CosEvent/Timeout/TestEventConsumer_i.cpp b/TAO/orbsvcs/tests/CosEvent/Timeout/TestEventConsumer_i.cpp deleted file mode 100644 index d143251cf90..00000000000 --- a/TAO/orbsvcs/tests/CosEvent/Timeout/TestEventConsumer_i.cpp +++ /dev/null @@ -1,78 +0,0 @@ -// $Id$ - -#include "TestEventConsumer_i.h" - -#include "ace/Log_Msg.h" - - -TestEventConsumer_i::TestEventConsumer_i (CORBA::ORB_ptr orb, bool hang) - : orb_ (CORBA::ORB::_duplicate (orb)), - hang_ (hang), - count_ (0), - orbtask_ (orb), - cond_ (this->mtx_), - shutdown_ (false) -{ -} - -void -TestEventConsumer_i::activate () -{ - this->orbtask_.activate (); -} - -int -TestEventConsumer_i::ORB_task::svc () -{ - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i ORB_task starting\n"))); - try - { - this->orb_->run (); - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i ORB_task " - "exiting\n"))); - } - catch (CORBA::SystemException &e) - { - ACE_PRINT_EXCEPTION (e, ACE_TEXT ("TestEventConsumer_i ORB_task: " - "Caught CORBA::Exception:")); - } - return 0; -} - - -void -TestEventConsumer_i::push (const CORBA::Any & data) - throw (CORBA::SystemException, CosEventComm::Disconnected) -{ - // Extract event data from the any. - const char *eventData; - if (data >>= eventData) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i::push(): Received " - "event containing %d bytes.\n"), - ACE_OS::strlen (eventData))); - if (this->hang_ && ++this->count_ == 10) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i::push(): " - "Simulating hung consumer\n"))); - { - ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->mtx_); - while (!this->shutdown_) - this->cond_.wait (); - } - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TestEventConsumer_i::push Done\n") - )); - } - } -} - -void -TestEventConsumer_i::disconnect_push_consumer () - throw (CORBA::SystemException) -{ - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("TestEventConsumer_i::disconnect_push_consumer()\n"))); - this->orb_->shutdown (); - this->shutdown_ = true; - this->cond_.signal (); -} |