1 files changed, 0 insertions, 190 deletions
diff --git a/apps/JAWS/PROTOTYPE/JAWS/Server.cpp b/apps/JAWS/PROTOTYPE/JAWS/Server.cpp
deleted file mode 100644
index 629bd00d1f4..00000000000
--- a/apps/JAWS/PROTOTYPE/JAWS/Server.cpp
+++ /dev/null
@@ -1,190 +0,0 @@
-// $Id$
-
-#include "ace/Get_Opt.h"
-
-#if (ACE_NTRACE != 1)
-#include "ace/Trace.h"
-#endif /* (ACE_NTRACE != 1) */
-
-#include "JAWS/Server.h"
-#include "JAWS/Data_Block.h"
-#include "JAWS/Concurrency.h"
-#include "JAWS/IO.h"
-#include "JAWS/IO_Handler.h"
-#include "JAWS/IO_Acceptor.h"
-#include "JAWS/Pipeline_Tasks.h"
-
-ACE_RCSID(JAWS, Server, "$Id$")
-
-JAWS_Server::JAWS_Server (void)
-  : port_ (5432),
-    concurrency_ (0),
-    dispatch_ (0),
-    nthreads_ (5),
-    maxthreads_ (20),
-    flags_ (THR_NEW_LWP)
-{
-}
-
-JAWS_Server::JAWS_Server (int argc, char *argv[])
-  : ratio_ (1),
-    port_ (5432),
-    concurrency_ (0),
-    dispatch_ (0),
-    nthreads_ (5),
-    maxthreads_ (20),
-    flags_ (THR_NEW_LWP)
-{
-  this->init (argc, argv);
-}
-
-void
-JAWS_Server::init (int argc, char *argv[])
-{
-  this->parse_args (argc, argv);
-
-  this->policy_.ratio (this->ratio_);
-
-  if (this->concurrency_ == 1)
-    {
-      JAWS_Thread_Per_Singleton::instance ()->make (this->flags_,
-                                                    this->maxthreads_);
-      this->policy_.concurrency (JAWS_Thread_Per_Singleton::instance ());
-    }
-  else
-    {
-      JAWS_Thread_Pool_Singleton::instance ()->make (this->flags_,
-                                                     this->nthreads_,
-                                                     this->maxthreads_);
-      this->policy_.concurrency (JAWS_Thread_Pool_Singleton::instance ());
-    }
-
-#if !(defined (ACE_WIN32) || defined (ACE_HAS_AIO_CALLS))
-  this->dispatch_ = 0;
-#endif /* !defined (ACE_WIN32) */
-
-  if (this->dispatch_ == 1)
-    {
-#if defined (ACE_WIN32) || defined (ACE_HAS_AIO_CALLS)
-      this->policy_.io (JAWS_Asynch_IO_Singleton::instance ());
-      this->policy_.ioh_factory
-        (JAWS_Asynch_IO_Handler_Factory_Singleton::instance ());
-      this->policy_.acceptor (JAWS_IO_Asynch_Acceptor_Singleton::instance ());
-#endif /* defined (ACE_WIN32) */
-    }
-  else
-    {
-      this->policy_.io (JAWS_Synch_IO_Singleton::instance ());
-      this->policy_.ioh_factory
-        (JAWS_Synch_IO_Handler_Factory_Singleton::instance ());
-      this->policy_.acceptor (JAWS_IO_Synch_Acceptor_Singleton::instance ());
-    }
-
-  ACE_INET_Addr inet_addr (this->port_);
-  this->policy_.acceptor ()->open (inet_addr);
-}
-
-int
-JAWS_Server::open (JAWS_Pipeline_Handler *protocol,
-                   JAWS_Dispatch_Policy *policy)
-{
-  if (policy == 0)
-    policy = &this->policy_;
-
-  JAWS_Data_Block *db = new JAWS_Data_Block;
-  if (db == 0)
-    {
-      ACE_DEBUG ((LM_DEBUG,
-                  "(%t) JAWS_Server::open, could not create Data_Block\n"));
-      return -1;
-    }
-
-  // initialize data block
-
-  db->task (JAWS_Pipeline_Accept_Task_Singleton::instance ());
-  db->policy (policy);
-  db->io_handler (0);
-
-  db->task ()->next (protocol);
-
-  // prime the acceptor if appropriate
-  if (this->dispatch_ == 1)
-    {
-#if defined (ACE_WIN32) || defined (ACE_HAS_AIO_CALLS)
-
-      int n = this->nthreads_;
-      if (this->concurrency_ == 1)
-        n = 1;
-
-      for (int i = 0; i < n * this->ratio_ - n; i++)
-        db->task ()->put (db);
-
-#endif /* defined (ACE_WIN32) */
-    }
-
-  // The message block should contain an INET_Addr, and call the
-  // io->accept (INET_Addr) method!
-
-  policy->concurrency ()->put (db);
-
-  ACE_Thread_Manager::instance ()->wait ();
-
-  db->release ();
-
-  return 0;
-}
-
-void
-JAWS_Server::parse_args (int argc, char *argv[])
-{
-  int c;
-  int t = 0;
-
-  ACE_Get_Opt getopt (argc, argv, "t" "p:c:d:n:m:f:r:");
-  while ((c = getopt ()) != -1)
-    switch (c)
-      {
-      case 't':
-        t = !t;
-        break;
-      case 'p':
-        this->port_ = ACE_OS::atoi (getopt.optarg);
-        break;
-      case 'c':
-        if (ACE_OS::strcmp (getopt.optarg, "PER_REQUEST") == 0)
-          this->concurrency_ = 1;
-        else this->concurrency_ = 0;
-        break;
-      case 'd':
-        if (ACE_OS::strcmp (getopt.optarg, "ASYNCH") == 0)
-          this->dispatch_ = 1;
-        else this->dispatch_ = 0;
-        break;
-      case 'n':
-        this->nthreads_ = ACE_OS::atoi (getopt.optarg);
-        break;
-      case 'm':
-        this->maxthreads_ = ACE_OS::atoi (getopt.optarg);
-        break;
-      case 'f':
-        if (ACE_OS::strcmp (getopt.optarg, "THR_BOUND") == 0)
-          this->flags_ |= THR_BOUND;
-        else if (ACE_OS::strcmp (getopt.optarg, "THR_DAEMON") == 0)
-          this->flags_ |= THR_DAEMON;
-        else if (ACE_OS::strcmp (getopt.optarg, "THR_DETACHED") == 0)
-          this->flags_ |= THR_DETACHED;
-        break;
-      case 'r':
-        this->ratio_ = ACE_OS::atoi (getopt.optarg);
-        break;
-      }
-
-  if (t)
-    ACE_Trace::start_tracing ();
-  else
-    ACE_Trace::stop_tracing ();
-
-  if (this->port_ == 0) this->port_ = 5432;
-  if (this->nthreads_ == 0) this->nthreads_ = 5;
-  if (this->maxthreads_ == 0) this->maxthreads_ = 20;
-}