ACE/apps/JAWS3/small/SS_Service_Handler.cpp

   1 #define ACE_BUILD_SVC_DLL
   2
   3 #include "ace/Get_Opt.h"
   4
   5 #include "jaws3/Concurrency.h"
   6
   7 #include "SS_Service_Handler.h"
   8 #include "SS_State_READ.h"
   9 #include "SS_Data.h"
  10
  11 TeraSS_Service_Handler::TeraSS_Service_Handler ()
  12   : JAWS_Protocol_Handler (TeraSS_State_READ::instance (), & this->data_)
  13   , data_ (this)
  14 {
  15 }
  16
  17 int
  18 TeraSS_Service_Handler::open (void *)
  19 {
  20   int result = JAWS_Concurrency::instance ()->putq (this);
  21   if (result < 0)
  22     return -1;
  23
  24   return 0;
  25 }
  26
  27 int
  28 TeraSS_Service_Handler::close (unsigned long)
  29 {
  30   delete this;
  31   return 0;
  32 }
  33
  34 int
  35 TeraSS_Acceptor::init (int argc, ACE_TCHAR *argv[])
  36 {
  37   ACE_Get_Opt opt (argc, argv, ACE_TEXT("p:"));
  38
  39   unsigned short p = 0;
  40
  41   int c;
  42   while ((c = opt ()) != -1)
  43     switch (c)
  44       {
  45       case 'p':
  46         p = (unsigned short) ACE_OS::atoi (opt.optarg);
  47         break;
  48       default:
  49         break;
  50       }
  51
  52   if (p == 0)
  53     p = 5555;
  54
  55   if (this->open (ACE_INET_Addr (p)) == -1)
  56     {
  57       ACE_DEBUG ((LM_DEBUG, "%p\n", "ACE_Acceptor::open"));
  58       return -1;
  59     }
  60
  61   return 0;
  62 }
  63
  64 ACE_SVC_FACTORY_DEFINE (TeraSS_Acceptor)