TAO/orbsvcs/tests/Bug_2709_Regression/Server_Task.cpp

   1 #include "ace/OS_NS_unistd.h"
   2 #include "TestImpl.h"
   3 #include "Server_Task.h"
   4
   5 //////////////////////////////////////////////////////////////////////////
   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_(sorb)
  15 {
  16 }
  17
  18 int
  19 Server_Task::svc (void)
  20 {
  21   try
  22     {
  23       CORBA::Object_var poa_object =
  24         sorb_->resolve_initial_references ("RootPOA");
  25
  26       if (CORBA::is_nil (poa_object.in ()))
  27         ACE_ERROR_RETURN ((LM_ERROR, " (%P|%t) Unable to initialize the POA.\n"), 1);
  28
  29       PortableServer::POA_var root_poa =
  30         PortableServer::POA::_narrow (poa_object.in ());
  31
  32       PortableServer::POAManager_var poa_manager =
  33         root_poa->the_POAManager ();
  34
  35       poa_manager->activate ();
  36
  37       TestImpl * server_impl = 0;
  38       ACE_NEW_RETURN (server_impl, TestImpl (sorb_.in ()), 1);
  39
  40       PortableServer::ObjectId_var id =
  41         root_poa->activate_object (server_impl);
  42
  43       CORBA::Object_var test_obj =
  44         root_poa->id_to_reference (id.in ());
  45
  46       Test_var server = Test::_narrow (test_obj.in ());
  47
  48       CORBA::String_var ior =
  49         sorb_->object_to_string (test_obj.in ());
  50
  51       // Output the IOR to the <ior_output_file>
  52       FILE *output_file= ACE_OS::fopen (output_, "w");
  53       if (output_file != 0)
  54         {
  55           ACE_OS::fprintf (output_file, "%s", ior.in ());
  56           ACE_OS::fclose (output_file);
  57
  58           ACE_DEBUG ((LM_ERROR, "(%P): Server's IOR was written to file: %s.\n", output_) );
  59         }
  60
  61       // Signal the main thread before we call orb->run ();
  62       this->me_.signal ();
  63
  64       this->sorb_->run ();
  65
  66       ACE_DEBUG ((LM_DEBUG, "event loop finished\n"));
  67
  68       root_poa->destroy (1, 1);
  69     }
  70   catch (const CORBA::Exception& ex)
  71     {
  72       ex._tao_print_exception ("Exception caught in server task:");
  73       return 1;
  74     }
  75
  76   return 0;
  77 }