TAO/tests/Bug_1495_Regression/Server_Task.cpp

   1 /**
   2  * @file Server_Task.cpp
   3  * @author Will Otte <wotte@dre.vanderbilt.edu>
   4  *
   5  * Implements the Server_Task class which acts as the process colocated
   6  * corba server for Bug_1495_Regression test.
   7  */
   8
   9 #include "Server_Task.h"
  10 #include "ace/OS_NS_unistd.h"
  11 #include "test_i.h"
  12
  13 #include "ace/Manual_Event.h"
  14
  15
  16 Server_Task::Server_Task (const ACE_TCHAR *output,
  17                           CORBA::ORB_ptr sorb,
  18                           ACE_Manual_Event &me,
  19                           ACE_Thread_Manager *thr_mgr)
  20   : ACE_Task_Base (thr_mgr),
  21     output_ (output),
  22     me_ (me),
  23     sorb_ (CORBA::ORB::_duplicate (sorb))
  24 {
  25 }
  26
  27
  28 int
  29 Server_Task::svc ()
  30 {
  31   try
  32     {
  33       CORBA::Object_var poa_object =
  34         sorb_->resolve_initial_references ("RootPOA");
  35
  36       if (CORBA::is_nil (poa_object.in ()))
  37         {
  38           ACE_ERROR ((LM_ERROR,
  39                       " (%P|%t) Unable to initialize the POA\n"));
  40           return 1;
  41         }
  42
  43       PortableServer::POA_var root_poa =
  44         PortableServer::POA::_narrow (poa_object.in ());
  45
  46       PortableServer::POAManager_var poa_manager =
  47         root_poa->the_POAManager ();
  48
  49       poa_manager->activate ();
  50
  51       Bug1495_i *server_impl = 0;
  52       ACE_NEW_RETURN (server_impl,
  53                       Bug1495_i (sorb_.in ()),
  54                       0);
  55       PortableServer::ServantBase_var owner_transfer (server_impl);
  56
  57       PortableServer::ObjectId_var id =
  58         root_poa->activate_object (server_impl);
  59
  60       CORBA::Object_var object = root_poa->id_to_reference (id.in ());
  61
  62       Bug1495_Regression::Bug1495_var bug1495 =
  63         Bug1495_Regression::Bug1495::_narrow (object.in ());
  64
  65       CORBA::String_var ior = sorb_->object_to_string (bug1495.in ());
  66
  67       if (output_ != 0)
  68         {
  69           FILE *output_file = ACE_OS::fopen (output_, "w");
  70
  71           if (output_file == 0)
  72             {
  73               ACE_ERROR ((LM_ERROR,
  74                           "Cannot open output file for writing the "
  75                           "thread server IOR: %s", output_));
  76               return 1;
  77             }
  78
  79           ACE_OS::fprintf (output_file, "%s", ior.in ());
  80           ACE_OS::fclose (output_file);
  81         }
  82
  83       // sleep for a few seconds and hope the remote server picks up the
  84       // ior.
  85       ACE_OS::sleep (5);
  86
  87       // Signal the manual event to wake the main thread up.
  88       me_.signal ();
  89
  90       // The ORB will run for 15 seconds and shut down.
  91       ACE_Time_Value tv (15, 0);
  92       sorb_->run (tv);
  93
  94       ACE_DEBUG ((LM_DEBUG,
  95                    "Event loop finished for the thread server.\n"));
  96
  97       root_poa->destroy (true, true);
  98
  99       sorb_->destroy ();
 100     }
 101   catch (const CORBA::Exception& ex)
 102     {
 103       ex._tao_print_exception ("Caught an exception in server task: ");
 104       return 1;
 105     }
 106
 107   return 0;
 108 }
 109
 110