TAO/tests/DSI_AMI_Gateway/server.cpp

   1 #include "test_i.h"
   2 #include "ace/Get_Opt.h"
   3 #include "ace/Task.h"
   4
   5 const ACE_TCHAR *ior_output_file = ACE_TEXT("server.ior");
   6
   7 int nthreads = 4;
   8
   9 int
  10 parse_args (int argc, ACE_TCHAR *argv[])
  11 {
  12   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("o:n:"));
  13   int c;
  14
  15   while ((c = get_opts ()) != -1)
  16     switch (c)
  17       {
  18       case 'o':
  19         ior_output_file = get_opts.opt_arg ();
  20         break;
  21
  22       case 'n':
  23         nthreads = ACE_OS::atoi (get_opts.opt_arg ());
  24         break;
  25
  26       case '?':
  27       default:
  28         ACE_ERROR_RETURN ((LM_ERROR,
  29                            "usage:  %s "
  30                            "-o <iorfile>"
  31                            "\n",
  32                            argv [0]),
  33                           -1);
  34       }
  35   // Indicates successful parsing of the command line
  36   return 0;
  37 }
  38
  39 int
  40 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  41 {
  42   try
  43     {
  44       CORBA::ORB_var orb =
  45         CORBA::ORB_init (argc, argv);
  46
  47       CORBA::Object_var poa_object =
  48         orb->resolve_initial_references("RootPOA");
  49
  50       if (CORBA::is_nil (poa_object.in ()))
  51         {
  52           ACE_ERROR_RETURN ((LM_ERROR,
  53                              " (%P|%t) Unable to initialize the POA.\n"),
  54                             1);
  55         }
  56
  57       PortableServer::POA_var root_poa =
  58         PortableServer::POA::_narrow (poa_object.in ());
  59
  60       PortableServer::POAManager_var poa_manager =
  61         root_poa->the_POAManager ();
  62
  63       if (parse_args (argc, argv) != 0)
  64         {
  65           return 1;
  66         }
  67
  68       Simple_Server_i server_impl (orb.in ());
  69
  70       PortableServer::ObjectId_var id =
  71         root_poa->activate_object (&server_impl);
  72
  73       CORBA::Object_var object = root_poa->id_to_reference (id.in ());
  74
  75       Simple_Server_var server =
  76         Simple_Server::_narrow (object.in ());
  77
  78       CORBA::String_var ior =
  79               orb->object_to_string (server.in ());
  80
  81       ACE_DEBUG ((LM_DEBUG, "Activated as <%C>\n", ior.in ()));
  82
  83       // If the ior_output_file exists, output the ior to it
  84       if (ior_output_file != 0)
  85               {
  86                 FILE *output_file= ACE_OS::fopen (ior_output_file, "w");
  87
  88                 if (output_file == 0)
  89             {
  90                     ACE_ERROR_RETURN ((LM_ERROR,
  91                                        "Cannot open output file for writing IOR: %s",
  92                                        ior_output_file),
  93                                       1);
  94             }
  95
  96                 ACE_OS::fprintf (output_file, "%s", ior.in ());
  97                 ACE_OS::fclose (output_file);
  98               }
  99
 100       poa_manager->activate ();
 101
 102       orb->run ();
 103
 104       ACE_DEBUG ((LM_DEBUG, "event loop finished\n"));
 105     }
 106   catch (const CORBA::Exception& ex)
 107     {
 108       ex._tao_print_exception ("Server: exception caught - ");
 109       return 1;
 110     }
 111
 112   return 0;
 113 }