TAO/tests/Collocated_NoColl/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 (const ACE_TCHAR *output,
   8                           CORBA::ORB_ptr sorb,
   9                           ACE_Manual_Event &me,
  10                           ACE_Thread_Manager *thr_mgr)
  11   : ACE_Task_Base (thr_mgr)
  12     , output_ (output)
  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;
  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      PortableServer::ObjectId_var id =
  46        root_poa->activate_object (hello_impl);
  47
  48      CORBA::Object_var object = root_poa->id_to_reference (id.in ());
  49
  50      Test::Hello_var hello =
  51        Test::Hello::_narrow (object.in ());
  52
  53      CORBA::String_var ior =
  54        this->sorb_->object_to_string (hello.in ());
  55
  56      // Output the IOR to the <this->output_>
  57      FILE *output_file= ACE_OS::fopen (this->output_,
  58                                        "w");
  59      if (output_file == 0)
  60        ACE_ERROR_RETURN ((LM_ERROR,
  61                           "Cannot open output file for writing IOR: %s",
  62                           this->output_),
  63                          1);
  64
  65      ACE_OS::fprintf (output_file, "%s", ior.in ());
  66      ACE_OS::fclose (output_file);
  67
  68      poa_manager->activate ();
  69
  70      // Signal the main thread before we call orb->run ();
  71      this->me_.signal ();
  72
  73      this->sorb_->run ();
  74
  75      ACE_DEBUG ((LM_DEBUG, "(%P|%t) server - event loop finished\n"));
  76    }
  77  catch (const CORBA::Exception& ex)
  78    {
  79      ex._tao_print_exception ("Exception caught:");
  80      return 1;
  81    }
  82
  83  return 0;
  84 }