//============================================================================= /** * @file client.cpp * * This is a simple client implementation. * * @author Irfan Pyarali */ //============================================================================= #include "ace/streams.h" #include "ace/Get_Opt.h" #include "ace/Profile_Timer.h" #include "testC.h" #include "ace/OS_NS_string.h" static ACE_TCHAR *IOR[7] = { 0, 0, 0, 0, 0, 0, 0 }; static int iterations = 1; static int parse_args (int argc, ACE_TCHAR **argv) { ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("a:b:c:d:e:f:i:")); int c; while ((c = get_opts ()) != -1) switch (c) { case 'a': IOR[1] = ACE_OS::strdup (get_opts.opt_arg ()); break; case 'b': IOR[2] = ACE_OS::strdup (get_opts.opt_arg ()); break; case 'c': IOR[3] = ACE_OS::strdup (get_opts.opt_arg ()); break; case 'd': IOR[4] = ACE_OS::strdup (get_opts.opt_arg ()); break; case 'e': IOR[5] = ACE_OS::strdup (get_opts.opt_arg ()); break; case 'f': IOR[6] = ACE_OS::strdup (get_opts.opt_arg ()); break; case 'i': iterations = ACE_OS::atoi (get_opts.opt_arg ()); break; case '?': default: ACE_ERROR_RETURN ((LM_ERROR, "usage: %s " "-a IOR 1 " "-b IOR 2 " "-c IOR 3 " "-d IOR 4 " "-e IOR 5 " "-f IOR 6 " "\n", argv [0]), -1); } // Indicates successful parsing of command line. return 0; } void print_stats (ACE_Profile_Timer::ACE_Elapsed_Time &elapsed_time, int iterations) { if (iterations > 0) { elapsed_time.real_time *= ACE_ONE_SECOND_IN_MSECS; elapsed_time.user_time *= ACE_ONE_SECOND_IN_MSECS; elapsed_time.system_time *= ACE_ONE_SECOND_IN_MSECS; elapsed_time.real_time /= iterations; elapsed_time.user_time /= iterations; elapsed_time.system_time /= iterations; double tmp = 1000 / elapsed_time.real_time; ACE_DEBUG ((LM_DEBUG, "\treal_time\t = %0.06f ms,\n" "\tuser_time\t = %0.06f ms,\n" "\tsystem_time\t = %0.06f ms,\n" "\t%0.00f calls/second\n", elapsed_time.real_time < 0.0 ? 0.0 : elapsed_time.real_time, elapsed_time.user_time < 0.0 ? 0.0 : elapsed_time.user_time, elapsed_time.system_time < 0.0 ? 0.0 : elapsed_time.system_time, tmp < 0.0 ? 0.0 : tmp)); } else ACE_ERROR ((LM_ERROR, "\tNo time stats printed. Zero iterations or error occurred.\n")); } template class Test { public: static void run (CORBA::ORB_ptr orb, ACE_TCHAR *IOR) { if (IOR != 0) { // Get an object reference from the argument string. CORBA::Object_var object = orb->string_to_object (IOR); // Try to narrow the object reference to a reference. T_var test = T::_narrow (object.in ()); ACE_Profile_Timer timer; ACE_Profile_Timer::ACE_Elapsed_Time elapsed_time; // We start an ACE_Profile_Timer here... timer.start (); CORBA::Long result = 0; int i = 0; for (i = 0; i < iterations ; i++) { // Invoke the doit() method on the reference. result = test->doit (); } // stop the timer. timer.stop (); timer.elapsed_time (elapsed_time); // compute average time. print_stats (elapsed_time, i); // Print the result of doit () method on the reference. ACE_DEBUG ((LM_DEBUG, "%d\n", result)); } } }; int ACE_TMAIN(int argc, ACE_TCHAR *argv[]) { try { // Initialize the ORB CORBA::ORB_var orb = CORBA::ORB_init (argc, argv); // Initialize options based on command-line arguments. int parse_args_result = parse_args (argc, argv); if (parse_args_result != 0) return parse_args_result; int i = 1; Test::run (orb.in (), IOR[i++]); Test::run (orb.in (), IOR[i++]); Test::run (orb.in (), IOR[i++]); Test::run (orb.in (), IOR[i++]); Test::run (orb.in (), IOR[i++]); Test::run (orb.in (), IOR[i++]); orb->destroy (); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ("Exception Caught in main"); return -1; } return 0; }