diff options
Diffstat (limited to 'TAO/tests/CSD_Strategy_Tests/TP_Common/OrbTask.cpp')
-rw-r--r-- | TAO/tests/CSD_Strategy_Tests/TP_Common/OrbTask.cpp | 99 |
1 files changed, 0 insertions, 99 deletions
diff --git a/TAO/tests/CSD_Strategy_Tests/TP_Common/OrbTask.cpp b/TAO/tests/CSD_Strategy_Tests/TP_Common/OrbTask.cpp deleted file mode 100644 index ff6ad717898..00000000000 --- a/TAO/tests/CSD_Strategy_Tests/TP_Common/OrbTask.cpp +++ /dev/null @@ -1,99 +0,0 @@ -// This may look like C, but it's really -*- C++ -*- - -//============================================================================= -/** - * @file OrbTask.cpp - * - * $Id$ - * - * @author Tim Bradley <bradley_t@ociweb.com> - */ -//============================================================================= - -#include "OrbTask.h" -#include "ace/CORBA_macros.h" - -namespace { enum { MAX_ORB_TASK_WORKER_THREADS = 20 }; } - - -OrbTask::OrbTask(CORBA::ORB_ptr orb, unsigned num_threads) - : orb_(CORBA::ORB::_duplicate(orb)), - num_threads_(num_threads) -{ -} - - -OrbTask::~OrbTask() -{ -} - - -int -OrbTask::open(void*) -{ - if (this->num_threads_ < 1) - { - ACE_ERROR_RETURN((LM_ERROR, - "(%P|%t) OrbTask failed to open. " - "num_threads_ (%d) is less-than 1.\n", - this->num_threads_), - -1); - } - - if (this->num_threads_ > MAX_ORB_TASK_WORKER_THREADS) - { - ACE_ERROR_RETURN((LM_ERROR, - "(%P|%t) OrbTask failed to open. " - "num_threads_ (%d) is too large. Max is %d.\n", - this->num_threads_, MAX_ORB_TASK_WORKER_THREADS), - -1); - } - - if (CORBA::is_nil(this->orb_.in())) - { - ACE_ERROR_RETURN((LM_ERROR, - "(%P|%t) OrbTask failed to open. " - "ORB object reference is nil.\n"), - -1); - } - - if (this->activate(THR_NEW_LWP | THR_JOINABLE, this->num_threads_) != 0) - { - // Assumes that when activate returns non-zero return code that - // no threads were activated. - ACE_ERROR_RETURN((LM_ERROR, - "(%P|%t) OrbTask failed to activate " - "(%d) worker threads.\n", - this->num_threads_), - -1); - } - - return 0; -} - - -int -OrbTask::svc() -{ - ACE_TRY_NEW_ENV - { - this->orb_->run(ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHALL - { - ACE_ERROR((LM_ERROR, - "(%P|%t) Exception raised by ORB::run() method. " - "OrbTask is stopping.\n")); - } - ACE_ENDTRY; - - return 0; -} - - -int -OrbTask::close(u_long) -{ - return 0; -} |