TAO/examples/AMH/Sink_Server/MT_AMH_Server.cpp

   1
   2 #include "MT_AMH_Server.h"
   3 #include "tao/Strategies/advanced_resource.h"
   4
   5 #include "ace/Task.h"
   6 #include "ace/Get_Opt.h"
   7
   8 MT_AMH_Server::MT_AMH_Server (int &argc, ACE_TCHAR **argv)
   9   : Base_Server (argc, argv)
  10 {
  11 }
  12
  13 MT_AMH_Server::~MT_AMH_Server ()
  14 {
  15 }
  16
  17 void
  18 MT_AMH_Server::usage (const char *message)
  19 {
  20   static const char * usage =
  21     "invoke as: mt_server -o <ior_output_file>\n"
  22     " -n <num_threads>\n"
  23     "-s <sleep_time (in microseconds)>\n";
  24
  25   // @@ Mayur, why don't you just place the usage message directly in
  26   //    the below ACE_ERROR macro?  It's not a big deal.  It's just
  27   //    something we normally do.
  28   //
  29   // Mayur: Seems cleaner to me this way.
  30   ACE_ERROR ((LM_ERROR, "%C : %C", message, usage));
  31 }
  32
  33
  34 int
  35 MT_AMH_Server::parse_args ()
  36 {
  37   // Let the base server parse it's argumrents first
  38   if (Base_Server::parse_args () != 1)
  39     {
  40       this->usage ("");
  41       ACE_OS::exit (1);
  42     }
  43
  44   ACE_Get_Opt get_opts (this->argc_, this->argv_, ACE_TEXT("n:"));
  45   int c;
  46   int count_argv = 0;
  47
  48   while ((c = get_opts ()) != -1)
  49     {
  50       ++count_argv;
  51       switch (c)
  52         {
  53         case 'n':
  54           {
  55             this->nthreads_ = ACE_OS::atoi (get_opts.opt_arg ());
  56
  57             {
  58               // Added unneeded '{ & }' just to satisfy Win32
  59               for (int i = count_argv; i <= this->argc_; ++i)
  60                 this->argv_ [i] = this->argv_ [i+2];
  61             }
  62
  63             // Decrement the value of this->argc_ to reflect the removal
  64             // of '-n' option.
  65             this->argc_ = this->argc_ - 2;
  66             return 1;
  67           }
  68
  69         case '?':
  70         default:
  71           // Don't do anything.
  72           break;
  73         }
  74     }
  75   return 0;
  76 }
  77
  78 void
  79 MT_AMH_Server::start_threads ()
  80 {
  81   // Each of this thread runs the event loop
  82   this->activate (THR_NEW_LWP | THR_JOINABLE, this->nthreads_, 1);
  83   this->thr_mgr ()->wait ();
  84 }
  85
  86 int
  87 MT_AMH_Server::svc ()
  88 {
  89   run_event_loop ();
  90   return 1;
  91 }