diff options
Diffstat (limited to 'TAO/examples/Load_Balancing_persistent/Identity_Client.cpp')
| -rwxr-xr-x | TAO/examples/Load_Balancing_persistent/Identity_Client.cpp | 272 |
1 files changed, 0 insertions, 272 deletions
diff --git a/TAO/examples/Load_Balancing_persistent/Identity_Client.cpp b/TAO/examples/Load_Balancing_persistent/Identity_Client.cpp deleted file mode 100755 index f3dce3d9712..00000000000 --- a/TAO/examples/Load_Balancing_persistent/Identity_Client.cpp +++ /dev/null @@ -1,272 +0,0 @@ -// $Id$ -// ============================================================================ -// -// = LIBRARY -// TAO/examples/Load_Balancing -// -// = FILENAME -// Identity_Client.cpp -// -// = AUTHOR -// Marina Spivak <marina@cs.wustl.edu> -// -// ============================================================================ - -#include "ace/Get_Opt.h" -#include "Identity_Client.h" -#include "IdentityC.h" -#include "Load_BalancerC.h" -#include "ace/High_Res_Timer.h" -#include "ace/Stats.h" - -Identity_Client::Identity_Client (void) - : group_factory_ior_ (0), - number_of_invocations_ (5), - use_random_ (0), - iterations_ (0) -{ -} - -int -Identity_Client::parse_args (int argc, char *argv[]) -{ - ACE_Get_Opt get_opts (argc, argv, "di:n:k:r"); - int c; - - while ((c = get_opts ()) != -1) - switch (c) - { - case 'd': // debug flag. - TAO_debug_level++; - break; - case 'i': // ior of the <Object_Group_Factory> object. - this->group_factory_ior_ = get_opts.optarg; - break; - case 'n': // number of times to make invocation on an <Identity> object. - this->number_of_invocations_ = ACE_OS::atoi (get_opts.optarg); - break; - case 'k': - this->iterations_ = ACE_OS::atoi (get_opts.optarg); - break; - case 'r': // flag signifying to obtain references to <Identity> - // objects from the random <Object_Group> rather than - // from the round robin one. - this->use_random_ = 1; - break; - case '?': - default: - ACE_ERROR_RETURN ((LM_ERROR, - "usage: %s" - " [-d]" - " [-i] <Object_Group_Factory_ior>" - " [-n] <number_of_invocations>" - " [-r]" - "\n", - argv [0]), - -1); - } - - // Indicates successful parsing of command line. - return 0; -} - -int -Identity_Client::init (int argc, - char* argv[]) -{ - int result; - - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY - { - result = this->orb_manager_.init (argc, - argv, - ACE_TRY_ENV); - ACE_TRY_CHECK; - if (result == -1) - return result; - - // Check the non-ORB arguments. - result = this->parse_args (argc, argv); - if (result < 0) - return result; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Identity_Client::init"); - return -1; - } - ACE_ENDTRY; - ACE_CHECK_RETURN (-1); - - return 0; -} - -int -Identity_Client::run (CORBA::Environment &ACE_TRY_ENV) -{ - // Contact the <Object_Group_Factory> to obtain an <Object_Group>. - CORBA::ORB_var orb = orb_manager_.orb (); - CORBA::Object_var obj = - orb->string_to_object (this->group_factory_ior_, - ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - - if (obj.in () == 0) - ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("(%N|%l) <ERROR> [Identity_Client::run] \n"), - ASYS_TEXT ("factory_resolve \n")), - -1); - - Load_Balancer::Object_Group_Factory_var factory = - Load_Balancer::Object_Group_Factory::_narrow (obj.in (), - ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - - if (CORBA::is_nil (factory.in ())) - ACE_ERROR_RETURN ((LM_ERROR, - "Identity_Client: problems using the factory ior\n"), - -1); - - const char *group_name; - if (this->use_random_) - group_name = "Random group"; - else - group_name = "Round Robin group"; - - Load_Balancer::Object_Group_var object_group; - - // We have this for the measurement that was done. -#if defined (DOORS_MEASURE_STATS) - - // Performance measurements start here - ACE_High_Res_Timer::calibrate (); - - ACE_hrtime_t throughput_base = ACE_OS::gethrtime (); - - ACE_Throughput_Stats throughput; - ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); - - for (int i = 0; i < this->iterations_; i++) - { - // Record current time. - ACE_hrtime_t latency_base = ACE_OS::gethrtime (); - -#endif /*TAO_MEASURE_STATS*/ - // Remote call - object_group = - factory->resolve (group_name, - ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - - CORBA::String_var iorstring = orb->object_to_string (object_group); - - ACE_DEBUG ((LM_DEBUG, - "The ior string is %s \n", iorstring.in ())); -#if defined (DOORS_MEASURE_STATS) - // Grab timestamp again. - ACE_hrtime_t now = ACE_OS::gethrtime (); - - // Record statistics. - throughput.sample (now - throughput_base, - now - latency_base); - - } - - ACE_OS::printf ("*=*=*=*=Aggregated result *=*=*=*=*= \n"); - throughput.dump_results ("Aggregated", gsf); -#endif /*TAO_MEASURE_STATS */ - - if (CORBA::is_nil (object_group.in ())) - { - ACE_ERROR_RETURN ((LM_ERROR, - "(%l|%d)The narrowed object is NUL:"), - -1); - } - - // List <Object_Group>'s id. - CORBA::String_var id = object_group->id (ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - ACE_DEBUG ((LM_DEBUG, "Object Group's id is: %s\n\n", id.in ())); - - // List all <Object_Group>s members. - Load_Balancer::Member_ID_List_var id_list = - object_group->members (ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - ACE_DEBUG ((LM_DEBUG, - "The group contains %d members:\n", - id_list->length ())); - for (CORBA::ULong i = 0; i < id_list->length (); ++i) - ACE_DEBUG ((LM_DEBUG, "%s\n", (id_list[i]).in ())); - - // Perform <number_of_invocations_> method calls on <Identity> - // objects, which are members of the <Object_Group>. Before each - // invocations, we get an <Identity> reference to use for that - // invocation from our <Object_Group>. - Identity_var identity_object; - CORBA::String_var identity; - CORBA_String_var objref; - - for (size_t ind = 0; ind < this->number_of_invocations_; ++ind) - { - objref = object_group->resolve (ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - - obj = orb->string_to_object (objref, - ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - - identity_object = Identity::_narrow (obj.in (), - ACE_TRY_ENV); - ACE_CHECK_RETURN (-1); - - if (CORBA::is_nil (identity_object.in ())) - ACE_ERROR_RETURN ((LM_ERROR, - "Identity_Client: cannot narrow an object received from" - "<Object_Group::resolve> to <Identity>\n"), - -1); - identity_object->get_name (identity.out ()); - ACE_CHECK_RETURN (-1); - - ACE_DEBUG ((LM_DEBUG, - "Invocation %s\n", - identity.in ())); - ACE_CHECK_RETURN (-1); - - } - - return 0; -} - -Identity_Client::~Identity_Client (void) -{ -} - -int -main (int argc, char *argv[]) -{ - int result = 0; - Identity_Client client; - - if (client.init (argc, argv) == -1) - return 1; - - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY - { - result = client.run (ACE_TRY_ENV); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Identity_Client"); - return 1; - } - ACE_ENDTRY; - ACE_CHECK_RETURN (1); - - if (result == -1) - return 1; - else - return 0; -} |