TAO/orbsvcs/tests/COIOP_Naming_Test/Server_Task.cpp

   1 #include "Server_Task.h"
   2 #include "TestS.h"
   3 #include "Hello.h"
   4
   5 #include "ace/Manual_Event.h"
   6
   7 Server_Task::Server_Task (CosNaming::NamingContext_ptr root_context,
   8                           CORBA::ORB_ptr sorb,
   9                           ACE_Manual_Event &me,
  10                           ACE_Thread_Manager *thr_mgr)
  11   : ACE_Task_Base (thr_mgr)
  12     , root_context_ (CosNaming::NamingContext::_duplicate (root_context))
  13     , me_ (me)
  14     , sorb_ (CORBA::ORB::_duplicate (sorb))
  15 {
  16 }
  17
  18 int
  19 Server_Task::svc (void)
  20 {
  21  try
  22    {
  23      CORBA::Object_var poa_object =
  24        this->sorb_->resolve_initial_references("RootPOA");
  25
  26      PortableServer::POA_var root_poa =
  27        PortableServer::POA::_narrow (poa_object.in ());
  28
  29      if (CORBA::is_nil (root_poa.in ()))
  30        ACE_ERROR_RETURN ((LM_ERROR,
  31                           " (%P|%t) Panic: nil RootPOA\n"),
  32                          1);
  33
  34      PortableServer::POAManager_var poa_manager =
  35        root_poa->the_POAManager ();
  36
  37      Hello *hello_impl = 0;
  38      ACE_NEW_RETURN (hello_impl,
  39                      Hello (this->sorb_.in (),
  40                             ACE_Thread::self ()),
  41                      1);
  42
  43      PortableServer::ServantBase_var owner_transfer(hello_impl);
  44
  45      Test::Hello_var hello =
  46        hello_impl->_this ();
  47
  48      CosNaming::NamingContext_var example_nc;
  49      CosNaming::Name name;
  50      name.length(1);
  51      name[0].id = CORBA::string_dup("Hello");
  52      root_context_->rebind(name, hello.in());
  53
  54      poa_manager->activate ();
  55
  56      // Signal the main thread before we call orb->run ();
  57      this->me_.signal ();
  58
  59      ACE_Time_Value runtime (10);
  60      this->sorb_->run (runtime);
  61
  62      ACE_DEBUG ((LM_DEBUG, "(%P|%t) server - event loop finished\n"));
  63    }
  64  catch (const CORBA::Exception& ex)
  65    {
  66      ex._tao_print_exception ("Exception caught:");
  67      return 1;
  68    }
  69
  70  return 0;
  71 }