TAO/examples/Quoter/server.cpp

   1 //=============================================================================
   2 /**
   3  *  @file    server.cpp
   4  *
   5  *  The Server for the Quoter Factory
   6  *
   7  *  @author Darrell Brunsch (brunsch@cs.wustl.edu) Michael Kircher (mk1@cs.wustl.edu)
   8  */
   9 //=============================================================================
  10
  11
  12 #include "server.h"
  13 #include "tao/ORB_Core.h"
  14
  15 Quoter_Server::Quoter_Server ()
  16   : num_of_objs_ (1),
  17     quoter_Factory_i_ptr_ (0),
  18     debug_level_ (1)
  19 {
  20 }
  21
  22 int
  23 Quoter_Server::parse_args ()
  24 {
  25   ACE_Get_Opt get_opts (argc_, argv_, ACE_TEXT("d:n:"));
  26   int c;
  27
  28   while ((c = get_opts ()) != -1)
  29     switch (c)
  30       {
  31       case 'd':  // debug flag.
  32         this->debug_level_ = ACE_OS::atoi (get_opts.opt_arg ());
  33         break;
  34       case 'n': // number of Quoter objects we export
  35         this->num_of_objs_ = ACE_OS::atoi (get_opts.opt_arg ());
  36         break;
  37       case '?':
  38       default:
  39         ACE_ERROR_RETURN ((LM_ERROR,
  40                            "usage:  %s"
  41                            " [-d] <debug level>"
  42                            " [-n] <num of Quoter objects>"
  43                            "\n",
  44                            argv_ [0]),
  45                           1);
  46       }
  47
  48
  49   // Indicates successful parsing of command line.
  50   return 0;
  51 }
  52
  53
  54 //Initialize the Quoter Server
  55
  56 int
  57 Quoter_Server::init (int argc,
  58                     ACE_TCHAR* argv[])
  59 {
  60   const char *exception_message = "Null Message";
  61   try
  62     {
  63       exception_message = "While ORB Manager init";
  64       int result = this->orb_manager_.init (argc, argv);
  65
  66       if (result == -1)
  67         ACE_ERROR_RETURN ((LM_ERROR,
  68                            "%p\n",
  69                            "init"),
  70                           -1);
  71
  72       // Copy them, because parse_args expects them there.
  73       this->argc_ = argc;
  74       int i;
  75
  76       // Make a copy of argv since ORB_init will change it.
  77       this->argv_ = new ACE_TCHAR *[argc];
  78
  79       for (i = 0; i < argc; i++)
  80         this->argv_[i] = argv[i];
  81
  82       this->parse_args ();
  83
  84       // Obtain the RootPOA.
  85       CORBA::Object_var obj =
  86         this->orb_manager_.orb()->resolve_initial_references ("RootPOA");
  87
  88       // Get the POA_var object from Object_var.
  89       exception_message = "While narrowing the root pos";
  90       PortableServer::POA_var root_poa =
  91         PortableServer::POA::_narrow (obj.in ());
  92
  93       // Get the POAManager of the RootPOA.
  94       exception_message = "While getting the POA Manager";
  95       PortableServer::POAManager_var poa_manager =
  96         root_poa->the_POAManager ();
  97
  98       ACE_NEW_RETURN (quoter_Factory_i_ptr_,
  99                       Quoter_Factory_i(this->num_of_objs_,
 100                                        root_poa.in()),
 101                       0);
 102
 103       exception_message = "While initing the quoter factory";
 104       quoter_Factory_i_ptr_->init ();
 105
 106       PortableServer::ObjectId_var quoter_Factory_oid =
 107         PortableServer::string_to_ObjectId ("Quoter_Factory");
 108
 109       exception_message = "While activating quoter factory";
 110       root_poa->activate_object_with_id (quoter_Factory_oid.in (),
 111                                          quoter_Factory_i_ptr_);
 112
 113       // Get Object reference for first_foo_impl object.
 114       exception_message = "While quoter_Factor::_this";
 115       Stock::Quoter_Factory_var quoter_Factory_var = quoter_Factory_i_ptr_->_this ();
 116
 117       // Stringify the object reference and print it out.
 118       exception_message = "While object_to_string";
 119       CORBA::String_var quoter_Factory_ior =
 120         this->orb_manager_.orb()->object_to_string (quoter_Factory_var.in ());
 121
 122       exception_message = "While activating the POA Manager";
 123       poa_manager->activate ();
 124
 125       // Print the IOR.
 126       if (this->debug_level_ >= 2)
 127         ACE_DEBUG ((LM_DEBUG, "Quoter Server: IOR is: <%C>\n", quoter_Factory_ior.in ()));
 128     }
 129   catch (const CORBA::Exception& ex)
 130     {
 131       ACE_ERROR ((LM_ERROR, "Quote_Server::init - %C\n", exception_message));
 132       ex._tao_print_exception ("Exception");
 133       throw;
 134     }
 135
 136   return this->init_naming_service ();
 137 }
 138
 139
 140 // Initialization of Naming Service and register IDL_Quoter Context
 141 // and Quoter_factory object.
 142
 143 int
 144 Quoter_Server::init_naming_service ()
 145 {
 146   const char *exception_message = "Null Message";
 147   try
 148     {
 149       CORBA::ORB_ptr orb_ptr = TAO_ORB_Core_instance()->orb();
 150
 151       CORBA::Object_var naming_obj =
 152         orb_ptr->resolve_initial_references ("NameService");
 153
 154       if (CORBA::is_nil (naming_obj.in ()))
 155         ACE_ERROR_RETURN ((LM_ERROR,
 156                                        " (%P|%t) Unable to resolve the Name Service.\n"),
 157                           -1);
 158
 159       exception_message = "While narrowing naming context";
 160       namingContext_var_ =
 161         CosNaming::NamingContext::_narrow (naming_obj.in ());
 162
 163       CosNaming::Name quoterContextName (1);
 164       quoterContextName.length (1);
 165       quoterContextName[0].id = CORBA::string_dup ("IDL_Quoter");
 166
 167       exception_message = "While binding a new context";
 168       CosNaming::NamingContext_var quoterNameContext =
 169         namingContext_var_->bind_new_context (quoterContextName);
 170
 171       //Register the quoter_factory name with the IDL_quoter Naming
 172       //Context...
 173       CosNaming::Name quoterFactoryContextName (1);
 174       quoterFactoryContextName.length (1);
 175       quoterFactoryContextName[0].id = CORBA::string_dup ("Quoter_Factory");
 176
 177       exception_message = "While using factory _this";
 178       Stock::Quoter_Factory_var quoter_factory_var = quoter_Factory_i_ptr_->_this ();
 179
 180       exception_message = "While binding factory";
 181       quoterNameContext->bind (quoterFactoryContextName,
 182                                quoter_factory_var.in ());
 183     }
 184   catch (const CORBA::Exception& ex)
 185     {
 186       ACE_ERROR ((LM_ERROR, "Quote_Server::init_naming_service - %C", exception_message));
 187       ex._tao_print_exception ("Exception");
 188       return -1;
 189     }
 190
 191   return 0;
 192 }
 193
 194 int
 195 Quoter_Server::run ()
 196 {
 197   if (this->debug_level_ >= 1)
 198     ACE_DEBUG ((LM_DEBUG,
 199                 "\nQuoter Example: Quoter_Server is running\n"));
 200
 201   orb_manager_.orb()->run ();
 202
 203   return 0;
 204 }
 205
 206 Quoter_Server::~Quoter_Server ()
 207 {
 208   try
 209     {
 210       // Unbind quoter factory context and name.
 211       CosNaming::Name factory_name (2);
 212       factory_name.length (2);
 213       factory_name[0].id = CORBA::string_dup ("IDL_Quoter");
 214       factory_name[1].id = CORBA::string_dup ("Quoter_Factory");
 215       if (!CORBA::is_nil (this->namingContext_var_.in ()))
 216         this->namingContext_var_->unbind (factory_name);
 217
 218       factory_name.length (1);
 219       if (!CORBA::is_nil (this->namingContext_var_.in ()))
 220         this->namingContext_var_->unbind (factory_name);
 221     }
 222   catch (const CORBA::Exception& ex)
 223     {
 224       ACE_ERROR ((LM_ERROR,
 225                   "Could not unbind Quoter Server from the Name Service\n"));
 226       ex._tao_print_exception ("~Quoter_Server");
 227     }
 228
 229   delete [] this->argv_;
 230 }
 231
 232 int
 233 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
 234 {
 235   Quoter_Server quoter_server;
 236
 237   try
 238     {
 239       int result = quoter_server.init (argc, argv);
 240
 241       if (result == -1)
 242         return 1;
 243
 244       quoter_server.run ();
 245     }
 246   catch (const CORBA::SystemException& sysex)
 247     {
 248       sysex._tao_print_exception ("System Exception");
 249       return -1;
 250     }
 251   catch (const CORBA::UserException& userex)
 252     {
 253       userex._tao_print_exception ("User Exception");
 254       return -1;
 255     }
 256   return 0;
 257 }