diff options
Diffstat (limited to 'TAO/IIOP/tests/Cubit/Orbix/tpool/tpool.cpp')
-rw-r--r-- | TAO/IIOP/tests/Cubit/Orbix/tpool/tpool.cpp | 46 |
1 files changed, 0 insertions, 46 deletions
diff --git a/TAO/IIOP/tests/Cubit/Orbix/tpool/tpool.cpp b/TAO/IIOP/tests/Cubit/Orbix/tpool/tpool.cpp deleted file mode 100644 index 008f777cb22..00000000000 --- a/TAO/IIOP/tests/Cubit/Orbix/tpool/tpool.cpp +++ /dev/null @@ -1,46 +0,0 @@ -// $Id$ - -#include "tpool.h" - -ACE_RCSID(tpool, tpool, "$Id$") - -Thread_Pool::Thread_Pool (int n_threads) - : ACE_Task<ACE_MT_SYNCH> (ACE_Thread_Manager::instance ()) -{ - if (this->activate (THR_DETACHED | THR_NEW_LWP, n_threads) == -1) - ACE_ERROR ((LM_ERROR, "%p\n", "activate failed")); -} - -int -Thread_Pool::svc (void) -{ - cout << "Pool thread activated" << endl; - while (1) - { - // Dequeue message - ACE_Message_Block *mb; - this->msg_queue ()->dequeue_head (mb); - CORBA::Request *vp = (CORBA::Request *) mb->base (); - mb->release (); - // Hand it off to Orbix - CORBA::Orbix.continueThreadDispatch (*vp); - } - return -1; -} - - -int -Thread_Pool::inRequestPreMarshal(CORBA::Request &r, CORBA::Environment&) -{ -// thread_t tid; -// thr_create(NULL, 0, worker, (void *)&r, THR_DETACHED, &tid); - - // Enqueue the request - ACE_Message_Block *mb = new ACE_Message_Block ( (char *) (&r)); - this->msg_queue ()->enqueue (mb); - // Done - return -1; -} - - - |