diff options
Diffstat (limited to 'TAO/examples/Quoter/client.cpp')
-rw-r--r-- | TAO/examples/Quoter/client.cpp | 404 |
1 files changed, 404 insertions, 0 deletions
diff --git a/TAO/examples/Quoter/client.cpp b/TAO/examples/Quoter/client.cpp new file mode 100644 index 00000000000..7dec1d90a22 --- /dev/null +++ b/TAO/examples/Quoter/client.cpp @@ -0,0 +1,404 @@ +// $Id$ + +#include "ace/Read_Buffer.h" + +#include "orbsvcs/CosNamingC.h" + +#include "client.h" + +ACE_RCSID (Quoter, + client, + "$Id$") + +Quoter_Task::Quoter_Task (int argc, char **argv) + : argc_ (argc), argv_ (argv) +{ + // Nothing +} + +int +Quoter_Task::svc (void) +{ + if (this->quoter_client.init (this->argc_, this->argv_) == -1) + return 1; + else + return this->quoter_client.run (); +} + +// Constructor. +Quoter_Client::Quoter_Client (void) + : quoter_factory_key_ (0), + quoter_key_ (ACE_OS::strdup ("key0")), + shutdown_ (0), + quoter_var_ (Stock::Quoter::_nil ()), + useLifeCycleService_(0), // use the Generic Factory + debug_level_ (1) +{ + // Nothing +} + +// Parses the command line arguments and returns an error status. + +int +Quoter_Client::parse_args (void) +{ + ACE_Get_Opt get_opts (argc_, argv_, "n:d:lx"); + int opt; + int exit_code = 0; + + while ((opt = get_opts ()) != -1) + switch (opt) + { + case 'n': // multiple threads + // ignore it, it was handled already + break; + case 'd': // debug flag. + this->debug_level_ = ACE_OS::atoi (get_opts.opt_arg ()); + break; + case 'l': + this->useLifeCycleService_ = 1; + break; + case 'x': + this->shutdown_ = 1; + break; + default: + exit_code = 1; + ACE_ERROR ((LM_ERROR, + "%s: unknown arg, -%c\n", + this->argv_[0], char(opt))); + case '?': + ACE_DEBUG ((LM_DEBUG, + "usage: %s" + " [-m]" + " [-d] <debug level> - Set the debug level\n" + " [-l] - use the lifecycle service instead of the generic factory" + " [-x]" + "\n", + this->argv_ [0])); + ACE_OS::exit (exit_code); + } + + // Indicates successful parsing of command line. + return 0; +} + +int +Quoter_Client::run (void) +{ + if (this->debug_level_ >= 1) + ACE_DEBUG ((LM_DEBUG, + "\nQuoter Example: Quoter_Client is running\n")); + + const char *exception_message = "Null Message"; + ACE_TRY_NEW_ENV + { + exception_message = "While using get_quote ()"; + CORBA::Long q = this->quoter_var_->get_quote ("ACE Hardware" ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (this->debug_level_ >= 1) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: ACE Hardware = %i\n", q)); + + // Copy the Quoter + + CosLifeCycle::Criteria criteria; + exception_message = "While copying the quoter"; + CORBA::Object_var quoterObj_var = + this->quoter_var_->copy (factory_Finder_var_.in (), + criteria + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (CORBA::is_nil (quoterObj_var.in())) + ACE_ERROR_RETURN ((LM_ERROR, + "Quoter_Client::run: Copied Object pointer is nil!"), + -1); + + // Narrow it to the actual Quoter interface + exception_message = "While narrowing the quoter"; + Stock::Quoter_var copied_quoter_var = + Stock::Quoter::_narrow (quoterObj_var.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (CORBA::is_nil (copied_quoter_var.in())) + ACE_ERROR_RETURN ((LM_ERROR, + "Quoter_Client::run: Copied Quoter is nil!"), + -1); + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Copied object.\n")); + + exception_message = "While using get_quote () on copied object"; + q = copied_quoter_var->get_quote ("ACE Hardware" ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (this->debug_level_ >= 1) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Copied object: ACE Hardware = %i\n", q)); + + } + ACE_CATCHANY + { + ACE_ERROR ((LM_ERROR, "Quoter_Client::run - %s\n", exception_message)); + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Quoter_Client::run"); + return -1; + } + ACE_ENDTRY; + + return 0; +} + +Quoter_Client::~Quoter_Client (void) +{ + // Free resources + // Close the ior files + if (this->quoter_factory_key_ != 0) + ACE_OS::free (this->quoter_factory_key_); + if (this->quoter_key_ != 0) + ACE_OS::free (this->quoter_key_); +} + +int +Quoter_Client::init_naming_service (void) +{ + const char *exception_message = "Null Message"; + + ACE_TRY_NEW_ENV + { + // Resolve the Naming Service + CORBA::Object_var naming_obj = + orb_->resolve_initial_references ("NameService" ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (CORBA::is_nil (naming_obj.in ())) + ACE_ERROR_RETURN ((LM_ERROR, + "Unable to resolve the Name Service.\n"), + -1); + + exception_message = "While narrowing the naming context"; + CosNaming::NamingContext_var naming_context = + CosNaming::NamingContext::_narrow (naming_obj.in () ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Have a proper reference to the Naming Service.\n")); + + CosNaming::Name quoterFactoryFinderName (2); + quoterFactoryFinderName.length (2); + quoterFactoryFinderName[0].id = CORBA::string_dup ("IDL_Quoter"); + quoterFactoryFinderName[1].id = CORBA::string_dup ("Quoter_Factory_Finder"); + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Trying to resolve the Quoter Factory Finder!\n")); + + exception_message = "While resolving the factory finder"; + CORBA::Object_var factory_obj = + naming_context->resolve (quoterFactoryFinderName + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Resolved the Quoter Factory Finder!\n")); + + exception_message = "While narrowing the factory finder"; + factory_Finder_var_ = + Stock::Quoter_Factory_Finder::_narrow (factory_obj.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (CORBA::is_nil (factory_Finder_var_.in ())) + ACE_ERROR_RETURN ((LM_ERROR, + " could not resolve quoter factory in Naming service <%s>\n"), + -1); + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Have a proper reference to the Quoter Factory Finder.\n")); + + // The name of the Quoter Generic Factory + CosLifeCycle::Key factoryName (2); // max = 2 + + if (this->useLifeCycleService_ == 1) + { + // use the LifeCycle Service + factoryName.length(1); + factoryName[0].id = CORBA::string_dup ("Life_Cycle_Service"); + } + else + { + // use a Generic Factory + factoryName.length(2); + factoryName[0].id = CORBA::string_dup ("IDL_Quoter"); + factoryName[1].id = CORBA::string_dup ("Quoter_Generic_Factory"); + } + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Trying to get a reference of a factory.\n")); + + // Find an appropriate factory over there. + exception_message = "While finding factories"; + CosLifeCycle::Factories *factories_ptr = + factory_Finder_var_->find_factories (factoryName ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (factories_ptr == 0) + ACE_ERROR_RETURN ((LM_ERROR, + "Did not get a Generic Quoter Factory.\n"), + -1); + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Got a proper reference of a factory.\n")); + + + // Get the first object reference to a factory. + CORBA::Object_var quoter_FactoryObj_var; + + if (factories_ptr->length () >= 1) + { + // everything is ok, at least one factory is there + CosLifeCycle::Factory_ptr factory = (*factories_ptr)[0]; + quoter_FactoryObj_var = factory; + } + else + ACE_ERROR_RETURN ((LM_ERROR, + "No Factory received.\n"), + -1); + + // Narrow it to a Quoter Generic Factory + exception_message = "While narrowing the factory"; + generic_Factory_var_ = + CosLifeCycle::GenericFactory::_narrow (quoter_FactoryObj_var.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (CORBA::is_nil (this->generic_Factory_var_.in ())) + ACE_ERROR_RETURN ((LM_ERROR, + "Factory received is not valid.\n"), + -1); + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Have a proper reference to the Quoter Factory.\n")); + } + ACE_CATCH (CosLifeCycle::NoFactory, excpt) + { + ACE_ERROR ((LM_ERROR, "Quoter_Client::run - %s\n", exception_message)); + ACE_PRINT_EXCEPTION (excpt, "Quoter::init_naming_service: No Factory available!"); + } + ACE_CATCHANY + { + ACE_ERROR ((LM_ERROR, "Quoter_Client::init_naming_service - %s\n", exception_message)); + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Quoter::init_naming_service"); + return -1; + } + ACE_ENDTRY; + + return 0; +} + +int +Quoter_Client::init (int argc, char **argv) +{ + this->argc_ = argc; + int i; + + // Make a copy of argv since ORB_init will change it. + this->argv_ = new char *[argc]; + + for (i = 0; i < argc; i++) + this->argv_[i] = argv[i]; + + ACE_TRY_NEW_ENV + { + // Retrieve the ORB. + this->orb_ = CORBA::ORB_init (this->argc_, + this->argv_, + "internet" + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Parse command line and verify parameters. + if (this->parse_args () == -1) + return -1; + + int naming_result = this->init_naming_service (); + if (naming_result == -1) + return naming_result; + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Factory received OK\n")); + + // using the Quoter Generic Factory + CosLifeCycle::Key genericFactoryName (1); // max = 1 + genericFactoryName.length(1); + genericFactoryName[0].id = CORBA::string_dup ("Quoter_Factory"); + + // The final factory + + CosLifeCycle::Criteria criteria(1); + criteria.length (1); + criteria[0].name = CORBA::string_dup ("filter"); + criteria[0].value <<= CORBA::string_dup ("name=='Quoter_Generic_Factory'"); + // used to find the last generic factory in the chain + + CORBA::Object_var quoterObject_var = + this->generic_Factory_var_->create_object (genericFactoryName, + criteria + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + this->quoter_var_ = Stock::Quoter::_narrow (quoterObject_var.in() ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (this->debug_level_ >= 2) + ACE_DEBUG ((LM_DEBUG, "Quoter Client: Quoter Created\n")); + + if (CORBA::is_nil (this->quoter_var_.in())) + { + ACE_ERROR_RETURN ((LM_ERROR, + "null quoter objref returned by factory\n"), + -1); + } + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Quoter::init"); + return -1; + } + ACE_ENDTRY; + + return 0; +} + + +// This function runs the test. + +int +main (int argc, char **argv) +{ + ACE_Thread_Manager thr_mgr; + + int i; + int threads = 1; + + for (i = 0; i < argc; i++) + if (ACE_OS::strcmp (argv[i], "-n") == 0) + threads = ACE_OS::atoi(argv[i + 1]); + + Quoter_Task **clients = new Quoter_Task*[threads]; + + for (i = 0; i < threads; i++) + clients[i] = new Quoter_Task (argc, argv); + + + for (i = 0; i < threads; i++) + clients[i]->activate (THR_BOUND | THR_SCHED_FIFO, 1, 0, + ACE_DEFAULT_THREAD_PRIORITY); + + int result = ACE_Thread_Manager::instance ()->wait (); + + for (i = 0; i < threads; i++) + delete clients[i]; + + delete [] clients; + + return result; +} |