TAO/orbsvcs/ImplRepo_Service/Activator_NT_Service.cpp

   1 //=============================================================================
   2 /**
   3  *  @file   Activator_NT_Service.cpp
   4  *
   5  *  @author Darrell Brunsch <brunsch@cs.wustl.edu>
   6  *  @author Jeff Parsons <parsons@cs.wustl.edu>
   7  *  @author John Tucker <jtucker@infoglide.com>
   8  *  @author Mike Vitalo <mvitalo@infoglide.com>
   9  */
  10 //=============================================================================
  11
  12 #include "Activator_NT_Service.h"
  13
  14 #if defined (ACE_WIN32) && !defined (ACE_LACKS_WIN32_SERVICES)
  15
  16 #include "ImR_Activator_i.h"
  17 #include "Activator_Options.h"
  18
  19 #include "tao/ORB_Core.h"
  20
  21 #include "ace/Reactor.h"
  22
  23 const ACE_TCHAR * IMR_ACTIVATOR_SERVICE_NAME =
  24   ACE_TEXT("TAOImRActivator");
  25 const ACE_TCHAR * IMR_ACTIVATOR_DISPLAY_NAME =
  26   ACE_TEXT("TAO Implementation Repository Activator");
  27 const ACE_TCHAR * IMR_ACTIVATOR_DESCRIPTION =
  28   ACE_TEXT("Implementation Repository Activator service for TAO");
  29
  30 /**
  31  * Handles the SERVICE_CONTROL_SHUTDOWN and SERVICE_CONTROL_STOP commands
  32  * by shutting down the ORB.  Otherwise ACE_NT_Service::handle_control
  33  * handles the command.
  34  */
  35 void
  36 Activator_NT_Service::handle_control (DWORD control_code)
  37 {
  38   if (control_code == SERVICE_CONTROL_SHUTDOWN
  39       || control_code == SERVICE_CONTROL_STOP)
  40     {
  41       report_status (SERVICE_STOP_PENDING);
  42       TAO_ORB_Core_instance ()->reactor ()->end_reactor_event_loop ();
  43       TAO_ORB_Core_instance ()->orb ()->shutdown (1);
  44     }
  45   else
  46     {
  47       ACE_NT_Service::handle_control (control_code);
  48     }
  49 }
  50
  51
  52 int
  53 Activator_NT_Service::handle_exception (ACE_HANDLE)
  54 {
  55   return 0;
  56 }
  57
  58
  59 /**
  60  * We do almost the same thing as we do in run_standalone () except that
  61  * we update the report_status after init.
  62  */
  63 int
  64 Activator_NT_Service::svc ()
  65 {
  66   ImR_Activator_i server;
  67   Activator_Options opts;
  68
  69   if (opts.init_from_registry() != 0)
  70     {
  71       report_status (SERVICE_STOPPED);
  72       return -1;
  73     }
  74
  75   try
  76     {
  77       int status = server.init (opts);
  78
  79       if (status == -1)
  80         {
  81           report_status (SERVICE_STOPPED);
  82           return -1;
  83         }
  84       else
  85         {
  86           report_status (SERVICE_RUNNING);
  87           server.run ();
  88
  89           status = server.fini ();
  90
  91           report_status (SERVICE_STOPPED);
  92         }
  93         if (status != -1)
  94             return 0;
  95     }
  96   catch (const CORBA::SystemException& sysex)
  97     {
  98       sysex._tao_print_exception (IMR_ACTIVATOR_DISPLAY_NAME);
  99     }
 100   catch (const CORBA::UserException& userex)
 101     {
 102       userex._tao_print_exception (IMR_ACTIVATOR_DISPLAY_NAME);
 103     }
 104   catch (const CORBA::Exception& ex)
 105     {
 106       ex._tao_print_exception (IMR_ACTIVATOR_DISPLAY_NAME);
 107     }
 108
 109   report_status (SERVICE_STOPPED);
 110   return -1;
 111 }
 112
 113 #endif /* ACE_WIN32 && !ACE_LACKS_WIN32_SERVICES */