TAO/tests/POA/Generic_Servant/client.cpp

   1 #include "ace/Get_Opt.h"
   2 #include "ace/Argv_Type_Converter.h"
   3 #include "ace/Profile_Timer.h"
   4 #include "ace/Read_Buffer.h"
   5 #include "testC.h"
   6
   7 static ACE_TCHAR *IOR = 0;
   8 static int iterations = 1;
   9 static int oneway = 0;
  10 static int shutdown_server = 0;
  11 static CORBA::ULong timeout = 5;
  12 static int timed_method = 0;
  13
  14 static int
  15 parse_args (int argc, ACE_TCHAR **argv)
  16 {
  17   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("f:k:i:T:otx"));
  18   int c;
  19
  20   while ((c = get_opts ()) != -1)
  21     switch (c)
  22       {
  23       case 'k':
  24         IOR = get_opts.opt_arg ();
  25         break;
  26
  27       case 'o':
  28         oneway = 1;
  29         break;
  30
  31       case 't':
  32         timed_method = 1;
  33         break;
  34
  35       case 'i':
  36         iterations = ACE_OS::atoi (get_opts.opt_arg ());
  37         break;
  38
  39       case 'T':
  40         timeout = static_cast<CORBA::ULong> (ACE_OS::atoi (get_opts.opt_arg ()));
  41         break;
  42
  43       case 'x':
  44         shutdown_server = 1;
  45         break;
  46
  47       case '?':
  48       default:
  49         ACE_ERROR_RETURN ((LM_ERROR,
  50                            "usage:  %s "
  51                            "-k IOR "
  52                            "-o oneway "
  53                            "-t timed operations "
  54                            "-T timeout for timed operations "
  55                            "-i iterations "
  56                            "-x shutdown server "
  57                            "\n",
  58                            argv [0]),
  59                           -1);
  60       }
  61
  62   if (IOR == 0)
  63     ACE_ERROR_RETURN ((LM_ERROR,
  64                        "Please specify the IOR for the servant\n"), -1);
  65
  66   // Indicates successful parsing of command line.
  67   return 0;
  68 }
  69
  70 void
  71 print_stats (ACE_Profile_Timer::ACE_Elapsed_Time &elapsed_time,
  72              int iterations)
  73 {
  74   if (iterations > 0)
  75     {
  76       elapsed_time.real_time *= ACE_ONE_SECOND_IN_MSECS;
  77       elapsed_time.user_time *= ACE_ONE_SECOND_IN_MSECS;
  78       elapsed_time.system_time *= ACE_ONE_SECOND_IN_MSECS;
  79
  80       elapsed_time.real_time /= iterations;
  81       elapsed_time.user_time /= iterations;
  82       elapsed_time.system_time /= iterations;
  83
  84       double tmp = 1000 / elapsed_time.real_time;
  85
  86       ACE_DEBUG ((LM_DEBUG,
  87                   "\titerations\t = %d,\n"
  88                   "\treal_time\t = %0.06f ms,\n"
  89                   "\tuser_time\t = %0.06f ms,\n"
  90                   "\tsystem_time\t = %0.06f ms,\n"
  91                   "\t%0.00f calls/second\n",
  92                   iterations,
  93                   elapsed_time.real_time   < 0.0 ? 0.0 : elapsed_time.real_time,
  94                   elapsed_time.user_time   < 0.0 ? 0.0 : elapsed_time.user_time,
  95                   elapsed_time.system_time < 0.0 ? 0.0 : elapsed_time.system_time,
  96                   tmp < 0.0 ? 0.0 : tmp));
  97     }
  98   else
  99     ACE_ERROR ((LM_ERROR,
 100                 "\tNo time stats printed.  Zero iterations or error occurred.\n"));
 101 }
 102
 103 int
 104 ACE_TMAIN (int argc, ACE_TCHAR *argv[])
 105 {
 106
 107   try
 108     {
 109       // Initialize the ORB
 110       CORBA::ORB_var orb =
 111         CORBA::ORB_init (argc, argv);
 112
 113       // Initialize options based on command-line arguments.
 114       int parse_args_result =
 115         parse_args (argc, argv);
 116       if (parse_args_result != 0)
 117         return parse_args_result;
 118
 119       // Get an object reference from the argument string.
 120       CORBA::Object_var object =
 121         orb->string_to_object (IOR);
 122
 123       // Try to narrow the object reference to a test reference.
 124       test_var test = test::_narrow (object.in ());
 125
 126       CORBA::String_var ior =
 127         orb->object_to_string (test.in ());
 128
 129       ACE_DEBUG ((LM_DEBUG,
 130                   "\nConnecting to: %C\n\n",
 131                   ior.in ()));
 132
 133       ACE_Profile_Timer timer;
 134       ACE_Profile_Timer::ACE_Elapsed_Time elapsed_time;
 135
 136       // We start an ACE_Profile_Timer here...
 137       timer.start ();
 138
 139       int i = 0;
 140
 141       for (i = 0; i < iterations; i++)
 142         {
 143           if (oneway && timed_method)
 144             {
 145               test->timed_oneway_method (timeout);
 146             }
 147           else if (oneway)
 148             {
 149               test->oneway_method ();
 150             }
 151           else if (!oneway && timed_method)
 152             {
 153               test->timed_method (timeout);
 154             }
 155           else
 156             {
 157               test->method ();
 158             }
 159         }
 160
 161       // stop the timer.
 162       timer.stop ();
 163       timer.elapsed_time (elapsed_time);
 164
 165       // compute average time.
 166       print_stats (elapsed_time, i);
 167
 168       if (shutdown_server)
 169         {
 170           test->shutdown ();
 171         }
 172
 173       orb->destroy ();
 174     }
 175   catch (const CORBA::Exception& ex)
 176     {
 177       ex._tao_print_exception ("Error!");
 178       return -1;
 179     }
 180
 181   return 0;
 182 }