1 files changed, 0 insertions, 127 deletions
diff --git a/apps/JAWS/server/PROTOTYPE/JAWS/Concurrency.cpp b/apps/JAWS/server/PROTOTYPE/JAWS/Concurrency.cpp
deleted file mode 100644
index 1b46d54929e..00000000000
--- a/apps/JAWS/server/PROTOTYPE/JAWS/Concurrency.cpp
+++ /dev/null
@@ -1,127 +0,0 @@
-// $Id$
-
-#include "JAWS/Concurrency.h"
-#include "JAWS/Pipeline.h"
-#include "JAWS/Policy.h"
-#include "JAWS/Data_Block.h"
-
-JAWS_Concurrency_Base::JAWS_Concurrency_Base (void)
-{
-}
-
-int
-JAWS_Concurrency_Base::put (ACE_Message_Block *mb, ACE_Time_Value *tv)
-{
-  return this->putq (mb, tv);
-}
-
-int
-JAWS_Concurrency_Base::svc (void)
-{
-  int result = 0;
-
-  for (;;)
-    {
-      ACE_Message_Block *mb;
-
-      // At this point we could set a timeout value so that the
-      // threading strategy can delete a thread if there is nothing to
-      // do.  Carefully think how to implement it so you don't leave
-      // yourself with 0 threads.
-
-      result = this->getq (mb);
-
-      // Use a NULL message block to indicate that the thread should shut
-      // itself down
-      if (result == -1 || mb == 0)
-        break;
-
-      do
-        {
-          JAWS_Data_Block *db;
-          JAWS_IO_Handler *ioh;
-          JAWS_Pipeline_Task *task;
-
-          db = ACE_dynamic_cast (JAWS_Data_Block *, mb->data_block ());
-          task = db->task ();
-
-          // Use a NULL task to make the thread recycle now
-          if (task == 0)
-            break;
-
-          result = task->put (mb);
-          if (result == -1)
-            ACE_ERROR ((LM_ERROR, "%p\n", "JAWS_Concurrency_Base::svc"));
-        }
-      while (result == 0);
-    }
-  return 0;
-}
-
-JAWS_Dispatcher::JAWS_Dispatcher (void)
-  : policy_(0)
-{
-}
-
-int
-JAWS_Dispatcher::dispatch (ACE_Message_Block *mb)
-{
-  return this->policy ()->concurrency ()->put (mb);
-}
-
-JAWS_Dispatch_Policy *
-JAWS_Dispatcher::policy (void)
-{
-  return this->policy_;
-}
-
-JAWS_Dispatch_Policy *
-JAWS_Dispatcher::policy (JAWS_Dispatch_Policy *p)
-{
-  this->policy_ = p;
-  return this->policy_;
-}
-
-int
-JAWS_Thread_Pool_Task::open (long flags, int nthreads, int maxthreads)
-{
-  this->nthreads_ = nthreads;
-  this->maxthreads_ = maxthreads;
-
-  if (this->activate (flags, nthreads) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "JAWS_Thread_Pool_Task::activate"),
-                      -1);
-}
-
-int
-JAWS_Thread_Per_Task::open (long flags, int maxthreads)
-{
-  this->flags_ = flags;
-  this->maxthreads_ = maxthreads;
-  return 0;
-}
-
-int
-JAWS_Thread_Per_Task::put (ACE_Message_Block *mb, ACE_Time_Value *tv)
-{
-  const int force_active = 1;
-  const int nthreads = 1;
-
-  if (this->activate (this->flags_, nthreads, force_active) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "JAWS_Thread_Pool_Task::activate"),
-                      -1);
-
-  this->putq (mb, tv);
-
-  return 0;
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class ACE_Singleton<JAWS_Dispatcher, ACE_SYNCH_MUTEX>;
-template class ACE_Singleton<JAWS_Thread_Pool_Task, ACE_SYNCH_MUTEX>;
-template class ACE_Singleton<JAWS_Thread_Per_Task, ACE_SYNCH_MUTEX>;
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate  ACE_Singleton<JAWS_Dispatcher, ACE_SYNCH_MUTEX>
-#pragma instantiate  ACE_Singleton<JAWS_Thread_Pool_Task, ACE_SYNCH_MUTEX>
-#pragma instantiate  ACE_Singleton<JAWS_Thread_Per_Task, ACE_SYNCH_MUTEX>
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */