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