TAO/orbsvcs/Time_Service/Server_i.cpp

   1 #include "orbsvcs/Log_Macros.h"
   2 #include "Server_i.h"
   3 #include "tao/debug.h"
   4 #include "ace/Get_Opt.h"
   5 #include "ace/Argv_Type_Converter.h"
   6 #include "ace/OS_NS_stdio.h"
   7 #include "ace/OS_NS_unistd.h"
   8 #include "ace/OS_NS_string.h"
   9 #include "ace/os_include/os_netdb.h"
  10
  11 // Constructor.
  12 Server_i::Server_i ()
  13   : ior_output_file_ (0)
  14 {
  15 }
  16
  17 // Destructor.
  18 Server_i::~Server_i ()
  19 {
  20 }
  21
  22 // Parse the command-line arguments and set options.
  23 int
  24 Server_i::parse_args (int argc,
  25                       ACE_TCHAR* argv[])
  26 {
  27   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("do:"));
  28   int c;
  29
  30   while ((c = get_opts ()) != -1)
  31     switch (c)
  32       {
  33       case 'd':  // debug flag.
  34         TAO_debug_level++;
  35         break;
  36       case 'o':  // output the IOR to a file.
  37         this->ior_output_file_ =
  38           ACE_OS::fopen (get_opts.opt_arg (), ACE_TEXT("a"));
  39
  40         if (this->ior_output_file_ == 0)
  41           ORBSVCS_ERROR_RETURN ((LM_ERROR,
  42                              ACE_TEXT("[SERVER] Process/Thread Id : (%P/%t)Unable to open %s for writing: %p\n"),
  43                              get_opts.opt_arg ()), -1);
  44         break;
  45       case '?':  // display help for use of the server.
  46       default:
  47         ORBSVCS_ERROR_RETURN ((LM_ERROR,
  48                            ACE_TEXT("[SERVER] Process/Thread Id : (%P/%t)")
  49                            ACE_TEXT("usage:  %s")
  50                            ACE_TEXT(" [-d]")
  51                            ACE_TEXT(" [-o] <ior_output_file>")
  52                            ACE_TEXT("\n"),
  53                            argv[0]),
  54                           1);
  55       }
  56
  57   // Indicates successful parsing of command line.
  58   return 0;
  59 }
  60
  61 // Initialise the Naming Service and register the TimeService Object
  62 // with it.
  63
  64 int
  65 Server_i::init_naming_service ()
  66 {
  67   // Initialize the Naming Client.
  68   return (this->naming_client_.init (this->orb_.in ()));
  69 }
  70
  71 // Create a new time server object and register it with the child POA.
  72 // Print the IOR of the registered server on the console and in a file.
  73
  74 int
  75 Server_i::create_server ()
  76 {
  77   try
  78     {
  79       // Create a new server object.
  80       ACE_NEW_RETURN (this->time_service_server_impl_,
  81                       TAO_Time_Service_Server,
  82                       0);
  83
  84       // Register a servant with the child poa.
  85       CORBA::String_var server_str =
  86         this->orb_manager_.activate_under_child_poa ("server",
  87                                                      this->time_service_server_impl_);
  88
  89       PortableServer::ObjectId_var id =
  90         PortableServer::string_to_ObjectId ("server");
  91
  92       CORBA::Object_var server_ref =
  93         this->orb_manager_.child_poa ()->id_to_reference (id.in ());
  94
  95       this->time_service_server_ = CosTime::TimeService::_narrow (server_ref.in ());
  96
  97       // All this !! just to register a servant with the child poa.
  98       // Instead of using _this ().
  99
 100       //Convert the server reference to a string.
 101
 102       CORBA::String_var objref_server =
 103         this->orb_->object_to_string (server_ref.in ());
 104
 105       // Print the server IOR on the console.
 106       ORBSVCS_DEBUG ((LM_DEBUG,
 107                   ACE_TEXT("[SERVER] Process/Thread Id : (%P/%t) The Time Service ")
 108                   ACE_TEXT("SERVER IOR: <%C>\n"),
 109                   objref_server.in ()));
 110
 111       // Print the IOR to a file.
 112
 113       if (this->ior_output_file_)
 114         {
 115           // Write the IOR to the file.
 116           ACE_OS::fprintf (this->ior_output_file_,
 117                            "%s\n",
 118                            objref_server.in ());
 119           ACE_OS::fclose (this->ior_output_file_);
 120         }
 121     }
 122   catch (const CORBA::Exception& ex)
 123     {
 124       ex._tao_print_exception (
 125         ACE_TEXT ("Exception in Server_i::create_server ()"));
 126       return -1;
 127     }
 128   return 0;
 129 }
 130
 131
 132 // Bind the Server in the context 'ServerContext' with the name
 133 // 'Server:<hostname>'.
 134
 135 int
 136 Server_i::register_server ()
 137 {
 138   try
 139     {
 140       CosNaming::Name server_context_name;
 141       server_context_name.length (1);
 142       server_context_name[0].id = CORBA::string_dup ("ServerContext");
 143
 144       try
 145         {
 146           CosNaming::NamingContext_var server_context =
 147             this->naming_client_->bind_new_context(server_context_name);
 148         }
 149       catch (const CosNaming::NamingContext::AlreadyBound& )
 150         {
 151           // OK, naming context already exists.
 152         }
 153
 154       char host_name[MAXHOSTNAMELEN];
 155       char server_mc_name[MAXHOSTNAMELEN];
 156       ACE_OS::hostname (host_name,MAXHOSTNAMELEN);
 157
 158       CosNaming::Name server_name (server_context_name);
 159
 160       server_name.length (2);
 161       ACE_OS::strcpy (server_mc_name, "Server:");
 162       ACE_OS::strcat (server_mc_name, host_name);
 163       server_name[1].id = CORBA::string_dup (server_mc_name);
 164
 165       // Bind the compound name (ServerContext(Server:<hostname>))
 166       // to the Naming Server.
 167
 168       this->naming_client_->rebind (server_name,
 169                                     this->time_service_server_.in ());
 170
 171       ORBSVCS_DEBUG ((LM_DEBUG,
 172                   ACE_TEXT("Binding ServerContext -> %C\n"),
 173                   server_name[1].id.in ()));
 174     }
 175   catch (const CORBA::Exception& ex)
 176     {
 177       ex._tao_print_exception (
 178         ACE_TEXT ("(%P|%t) Exception from Register Server ()\n"));
 179       return -1;
 180     }
 181
 182   return 0;
 183 }
 184
 185 // Initialize the server. If a filename is specified with the -f
 186 // commandline option, the server writes its IOR to the file besides
 187 // binding itself with the Naming Service.
 188
 189 int
 190 Server_i::init (int argc,
 191                 ACE_TCHAR *argv[])
 192 {
 193   try
 194     {
 195       // Make a copy of command line parameter.
 196       ACE_Argv_Type_Converter command(argc, argv);
 197
 198       // Call the init of <TAO_ORB_Manager> to initialize the ORB and
 199       // create a child POA under the root POA.
 200
 201       int retval = this->orb_manager_.init_child_poa (
 202                       command.get_argc(),
 203                       command.get_TCHAR_argv(),
 204                       "time_server");
 205
 206       if (retval == -1)
 207         ORBSVCS_ERROR_RETURN ((LM_ERROR,
 208                            ACE_TEXT("%p\n"),
 209                            ACE_TEXT("init_child_poa")),
 210                            -1);
 211
 212       // Activate the POA Manager.
 213       this->orb_manager_.activate_poa_manager ();
 214
 215       int result = this->parse_args (command.get_argc(), command.get_TCHAR_argv());
 216
 217       if (result != 0)
 218         return result;
 219
 220       // Get the orb.
 221       this->orb_ = this->orb_manager_.orb ();
 222
 223       // Initialize Naming Service.
 224       this->init_naming_service ();
 225
 226       // Create the server object.
 227       this->create_server ();
 228
 229       // Register the server object with the Naming Service.
 230       this->register_server ();
 231     }
 232   catch (const CORBA::Exception& ex)
 233     {
 234       ex._tao_print_exception (ACE_TEXT("Exception:"));
 235       return -1;
 236     }
 237
 238   return 0;
 239 }
 240
 241
 242 // Run the event loop for ORB.
 243
 244 int
 245 Server_i::run ()
 246 {
 247   int retval = this->orb_manager_.run ();
 248
 249   if (retval == -1)
 250     ORBSVCS_ERROR_RETURN ((LM_ERROR,
 251                        ACE_TEXT("[SERVER] Process/Thread Id : (%P/%t) Server_i::run")),
 252                       -1);
 253   return 0;
 254 }