TAO/orbsvcs/ImplRepo_Service/Locator_Loader.cpp

   1 #include "orbsvcs/Log_Macros.h"
   2 #include "Locator_Loader.h"
   3 #include "ace/Dynamic_Service.h"
   4 #include "ace/Task.h"
   5
   6 class ImR_Locator_ORB_Runner : public ACE_Task_Base
   7 {
   8 public:
   9   ImR_Locator_ORB_Runner (ImR_Locator_Loader& service)
  10     : service_ (service)
  11   {
  12   }
  13   virtual int svc ()
  14   {
  15     // Block until service_.fini () calls orb->destroy ()
  16     this->service_.run ();
  17     return 0;
  18   }
  19 private:
  20   ImR_Locator_Loader& service_;
  21 };
  22
  23 ImR_Locator_Loader::ImR_Locator_Loader()
  24 {
  25 }
  26
  27 int
  28 ImR_Locator_Loader::init (int argc, ACE_TCHAR *argv[])
  29 {
  30   try
  31     {
  32       int err = this->opts_.init (argc, argv);
  33       if (err != 0)
  34         return -1;
  35
  36       err = this->service_.init (this->opts_);
  37       if (err != 0)
  38         return -1;
  39
  40       // Create a thread in which to run the service
  41       ACE_ASSERT(this->runner_.get () == 0);
  42       this->runner_.reset(new ImR_Locator_ORB_Runner (*this));
  43       this->runner_->activate ();
  44     }
  45   catch (const CORBA::Exception&)
  46     {
  47       return -1;
  48     }
  49   return 0;
  50 }
  51
  52 int
  53 ImR_Locator_Loader::fini ()
  54 {
  55   ACE_ASSERT(this->runner_.get () != 0);
  56   try
  57     {
  58       int ret = this->service_.fini ();
  59
  60       this->runner_->wait ();
  61       this->runner_.reset (0);
  62       return ret;
  63     }
  64   catch (const CORBA::Exception&)
  65     {
  66     }
  67   return -1;
  68 }
  69
  70 CORBA::Object_ptr
  71 ImR_Locator_Loader::create_object (CORBA::ORB_ptr,
  72                                   int,
  73                                   ACE_TCHAR**)
  74 {
  75   throw CORBA::NO_IMPLEMENT();
  76 }
  77
  78 int
  79 ImR_Locator_Loader::run()
  80 {
  81   try
  82     {
  83       return this->service_.run ();
  84     }
  85   catch (...)
  86     {
  87       ORBSVCS_ERROR((LM_ERROR, "Exception in ImR_Locator_ORB_Runner ()\n"));
  88       return -1;
  89     }
  90 }
  91
  92
  93 ACE_FACTORY_DEFINE (Locator, ImR_Locator_Loader)