diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp | 95 |
1 files changed, 0 insertions, 95 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp deleted file mode 100644 index 7fee17d7d68..00000000000 --- a/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp +++ /dev/null @@ -1,95 +0,0 @@ -// $Id$ - -#include "EC_Dispatching_Task.h" -#include "EC_ProxySupplier.h" - -#if ! defined (__ACE_INLINE__) -#include "EC_Dispatching_Task.i" -#endif /* __ACE_INLINE__ */ - -ACE_RCSID(Event, EC_Dispatching, "$Id$") - -int -TAO_EC_Dispatching_Task::svc (void) -{ - int done = 0; - while (!done) - { - ACE_TRY_NEW_ENV - { - ACE_Message_Block *mb; - if (this->getq (mb) == -1) - if (ACE_OS::last_error () == ESHUTDOWN) - return 0; - else - ACE_ERROR ((LM_ERROR, - "EC (%P|%t) getq error in Dispatching Queue\n")); - - TAO_EC_Dispatch_Command *command = - ACE_dynamic_cast(TAO_EC_Dispatch_Command*, mb); - - if (command == 0) - { - ACE_Message_Block::release (mb); - continue; - } - - int result = command->execute (ACE_TRY_ENV); - ACE_TRY_CHECK; - - ACE_Message_Block::release (mb); - - if (result == -1) - done = 1; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - "EC (%P|%t) exception in dispatching queue"); - } - ACE_ENDTRY; - } - return 0; -} - -void -TAO_EC_Dispatching_Task::push (TAO_EC_ProxyPushSupplier *proxy, - RtecEventComm::EventSet& event, - CORBA::Environment &ACE_TRY_ENV) -{ - void* buf = this->allocator_->malloc (sizeof (TAO_EC_Push_Command)); - - if (buf == 0) - ACE_THROW (CORBA::NO_MEMORY (TAO_DEFAULT_MINOR_CODE, - CORBA::COMPLETED_NO)); - - ACE_Message_Block *mb = - new (buf) TAO_EC_Push_Command (proxy, - event, - this->data_block_.duplicate (), - this->allocator_); - this->putq (mb); -} - -// **************************************************************** - -TAO_EC_Dispatch_Command::~TAO_EC_Dispatch_Command (void) -{ -} - -// **************************************************************** - -int -TAO_EC_Shutdown_Command::execute (CORBA::Environment&) -{ - return -1; -} - -// **************************************************************** - -int -TAO_EC_Push_Command::execute (CORBA::Environment& ACE_TRY_ENV) -{ - this->proxy_->push_to_consumer (this->event_, ACE_TRY_ENV); - return 0; -} |