diff options
Diffstat (limited to 'TAO/examples/Quoter/client.cpp')
-rw-r--r-- | TAO/examples/Quoter/client.cpp | 414 |
1 files changed, 0 insertions, 414 deletions
diff --git a/TAO/examples/Quoter/client.cpp b/TAO/examples/Quoter/client.cpp deleted file mode 100644 index 95938a200cf..00000000000 --- a/TAO/examples/Quoter/client.cpp +++ /dev/null @@ -1,414 +0,0 @@ -// $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.optarg); - 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_TRY_ENV); - 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_TRY_ENV); - 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_TRY_ENV); - 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_TRY_ENV); - ACE_TRY_CHECK; - - if (this->debug_level_ >= 1) - ACE_DEBUG ((LM_DEBUG, "Quoter Client: Copied object: ACE Hardware = %i\n", q)); - - // Move the Quoter - - exception_message = "While moving the quoter"; - this->quoter_var_->move (factory_Finder_var_.in (), - criteria, - ACE_TRY_ENV); - ACE_TRY_CHECK; - - // Caution, the object reference stays the same - - if (this->debug_level_ >= 2) - ACE_DEBUG ((LM_DEBUG, "Quoter Client: Moved object\n")); - - exception_message = "While using get_quote () on moved object"; - q = this->quoter_var_->get_quote ("ACE Hardware", ACE_TRY_ENV); - ACE_TRY_CHECK; - - if (this->debug_level_ >= 1) - ACE_DEBUG ((LM_DEBUG, "Quoter Client: Moved 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"); - - 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_TRY_ENV); - 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_TRY_ENV); - 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_TRY_ENV); - 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_ptr factories_ptr = - factory_Finder_var_->find_factories (factoryName, ACE_TRY_ENV); - 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) - quoter_FactoryObj_var = (*factories_ptr)[0]; // everything is ok, at least one factory is there - 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_TRY_ENV); - 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_TRY_ENV); - 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_TRY_ENV); - ACE_TRY_CHECK; - - this->quoter_var_ = Stock::Quoter::_narrow (quoterObject_var.in(), ACE_TRY_ENV); - 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; -} |