TAO/tests/Param_Test/server.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    server.cpp
   5  *
   6  *  @author Aniruddha Gokhale
   7  */
   8 //=============================================================================
   9
  10
  11 #include "param_test_i.h"
  12 #include "tao/Codeset/Codeset.h"
  13 #include "tao/debug.h"
  14 #include "ace/Get_Opt.h"
  15 #include "ace/Log_Msg.h"
  16 #include "ace/OS_NS_stdio.h"
  17
  18 // Parses the command line arguments and returns an error status.
  19 static FILE *ior_output_file = 0;
  20 static const ACE_TCHAR *ior_output_filename = ACE_TEXT("test.ior");
  21
  22 static int
  23 parse_args (int argc, ACE_TCHAR *argv[])
  24 {
  25   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("do:"));
  26   int c;
  27
  28   while ((c = get_opts ()) != -1)
  29     switch (c)
  30       {
  31       case 'd':  // debug flag
  32         TAO_debug_level++;
  33         break;
  34       case 'o':
  35         ior_output_filename = get_opts.opt_arg ();
  36         break;
  37       case '?':
  38       default:
  39         ACE_ERROR_RETURN ((LM_ERROR,
  40                            "usage:  %s"
  41                            " [-d]"
  42                            "\n", argv [0]), 1);
  43       }
  44
  45   return 0;  // Indicates successful parsing of command line
  46 }
  47
  48 // Standard command line parsing utilities used.
  49
  50 int
  51 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  52 {
  53   Param_Test_i *param_test = 0;
  54
  55   try
  56     {
  57       const char *orb_name = "";
  58       CORBA::ORB_var orb_ptr =
  59         CORBA::ORB_init (argc, argv, orb_name);
  60
  61       CORBA::Object_var temp; // holder for the myriad of times we get
  62                               // an object which we then have to narrow.
  63
  64       // Get the Root POA
  65       temp = orb_ptr->resolve_initial_references ("RootPOA");
  66
  67       if (CORBA::is_nil (temp.in()))
  68         ACE_ERROR_RETURN ((LM_ERROR,
  69                            "(%P|%t) Unable to get root poa reference.\n"),
  70                           1);
  71
  72       PortableServer::POA_var oa_ptr = PortableServer::POA::_narrow (temp.in());
  73
  74       PortableServer::POAManager_var poa_manager =
  75         oa_ptr->the_POAManager ();
  76
  77       CORBA::PolicyList policies (2);
  78       policies.length (2);
  79       policies[0] =
  80         oa_ptr->create_id_assignment_policy (PortableServer::USER_ID);
  81
  82       policies[1] =
  83         oa_ptr->create_lifespan_policy (PortableServer::PERSISTENT);
  84
  85       // We use a different POA, otherwise the user would have to
  86       // change the object key each time it invokes the server.
  87       PortableServer::POA_var good_poa =
  88         oa_ptr->create_POA ("child_poa",
  89                             poa_manager.in (),
  90                             policies);
  91
  92       // Parse remaining command line and verify parameters.
  93       parse_args (argc, argv);
  94
  95       // initialize a param_test target object and register it with the object
  96       // adapter
  97
  98       // Create the implementation object
  99       ACE_NEW_RETURN (param_test,
 100                       Param_Test_i ("unknown",
 101                                     orb_ptr.in ()), 1);
 102
 103       // Register with GoodPOA with a specific name
 104       PortableServer::ObjectId_var id =
 105         PortableServer::string_to_ObjectId ("param_test");
 106       good_poa->activate_object_with_id (id.in (),
 107                                          param_test);
 108
 109       // Stringify the objref we'll be implementing, and print it to
 110       // stdout.  Someone will take that string and give it to a
 111       // client.  Then release the object.
 112
 113       temp = good_poa->id_to_reference (id.in ());
 114
 115       CORBA::String_var str =
 116         orb_ptr->object_to_string (temp.in ());
 117
 118       if (TAO_debug_level > 0)
 119         {
 120           ACE_DEBUG ((LM_DEBUG,
 121                       "(%P|%t) The IOR is <%s>\n",
 122                       str.in ()));
 123         }
 124
 125       ior_output_file = ACE_OS::fopen (ior_output_filename, "w");
 126
 127       if (ior_output_file == 0)
 128         {
 129           ACE_ERROR_RETURN ((LM_ERROR,
 130                              "Unable to open %s for writing: %p\n",
 131                              ior_output_filename),
 132                             -1);
 133         }
 134
 135       ACE_OS::fprintf (ior_output_file,
 136                        "%s",
 137                        str.in ());
 138       ACE_OS::fclose (ior_output_file);
 139
 140
 141       // Make the POAs controlled by this manager active
 142       poa_manager->activate ();
 143
 144       orb_ptr->run ();
 145
 146       good_poa->destroy (true, true);
 147
 148       oa_ptr->destroy (1, 1);
 149     }
 150   catch (const CORBA::SystemException& sysex)
 151     {
 152       sysex._tao_print_exception ("System Exception");
 153       return -1;
 154     }
 155   catch (const CORBA::UserException& userex)
 156     {
 157       userex._tao_print_exception ("User Exception");
 158       return -1;
 159     }
 160   // Free resources
 161   delete param_test;
 162
 163   return 0;
 164 }