TAO/orbsvcs/tests/InterfaceRepo/Latency_Test/Latency_Query_Client.cpp

   1 // -*- C++ -*-
   2 #include "Latency_Query_Client.h"
   3 #include "ace/Get_Opt.h"
   4 #include "ace/High_Res_Timer.h"
   5 #include "ace/Stats.h"
   6 #include "ace/Throughput_Stats.h"
   7 #include "ace/Sample_History.h"
   8
   9 const CORBA::ULong DEFAULT_NUMCALLS = 20000;
  10
  11 Latency_Query_Client::Latency_Query_Client ()
  12   : debug_ (false),
  13     do_dump_history_ (0),
  14     iterations_ (DEFAULT_NUMCALLS)
  15 {
  16 }
  17
  18 Latency_Query_Client::~Latency_Query_Client ()
  19 {
  20 }
  21
  22 int
  23 Latency_Query_Client::init (int argc,
  24                             ACE_TCHAR *argv[])
  25 {
  26   try
  27     {
  28       this->orb_ = CORBA::ORB_init (argc, argv);
  29
  30       int retval = this->parse_args (argc, argv);
  31
  32       if (retval != 0)
  33         {
  34           return retval;
  35         }
  36
  37       CORBA::Object_var object =
  38         this->orb_->resolve_initial_references ("InterfaceRepository");
  39
  40       if (CORBA::is_nil (object.in ()))
  41         {
  42           ACE_ERROR_RETURN ((
  43               LM_ERROR,
  44               "Null objref from resolve_initial_references\n"
  45             ), -1);
  46         }
  47
  48       this->repo_ =
  49         CORBA::Repository::_narrow (object.in ());
  50
  51       if (CORBA::is_nil (this->repo_.in ()))
  52         {
  53           ACE_ERROR_RETURN ((LM_ERROR,
  54                              "CORBA::Repository::_narrow failed\n"),
  55                             -1);
  56         }
  57
  58       retval = this->populate_ifr ();
  59
  60       if (retval != 0)
  61         {
  62           return retval;
  63         }
  64     }
  65   catch (const CORBA::Exception& ex)
  66     {
  67       ex._tao_print_exception ("Latency_Query_Client::init:");
  68       return -1;
  69     }
  70
  71   return 0;
  72 }
  73
  74 int
  75 Latency_Query_Client::run ()
  76 {
  77 //  CORBA::DefinitionKind dk;
  78   CORBA::AttributeMode am;
  79
  80   try
  81     {
  82       for (int j = 0; j < 100; ++j)
  83         {
  84           am = this->attr_->mode ();
  85
  86           if (am != CORBA::ATTR_NORMAL)
  87             {
  88               return -1;
  89             }
  90         }
  91
  92       ACE_Sample_History history (this->iterations_);
  93       ACE_hrtime_t test_start = ACE_OS::gethrtime ();
  94
  95       for (CORBA::ULong i = 0; i < this->iterations_; ++i)
  96         {
  97           ACE_hrtime_t start = ACE_OS::gethrtime ();
  98
  99           am = this->attr_->mode ();
 100
 101           ACE_hrtime_t now = ACE_OS::gethrtime ();
 102           history.sample (now - start);
 103         }
 104
 105       ACE_hrtime_t test_end = ACE_OS::gethrtime ();
 106
 107       if (this->debug_)
 108         {
 109           ACE_DEBUG ((LM_DEBUG,
 110                       "test finished\n"));
 111           ACE_DEBUG ((LM_DEBUG,
 112                       "High resolution timer calibration...."));
 113           ACE_High_Res_Timer::global_scale_factor_type gsf =
 114             ACE_High_Res_Timer::global_scale_factor ();
 115           ACE_DEBUG ((LM_DEBUG,
 116                       "done\n"));
 117
 118           if (this->do_dump_history_)
 119             {
 120               history.dump_samples (ACE_TEXT("HISTORY"), gsf);
 121             }
 122
 123           ACE_Basic_Stats stats;
 124           history.collect_basic_stats (stats);
 125           stats.dump_results (ACE_TEXT("Total"), gsf);
 126
 127           ACE_Throughput_Stats::dump_throughput (ACE_TEXT("Total"),
 128                                                  gsf,
 129                                                  test_end - test_start,
 130                                                  stats.samples_count ());
 131         }
 132     }
 133   catch (const CORBA::Exception& ex)
 134     {
 135       ex._tao_print_exception ("Latency_Query_Client::run:");
 136       return -1;
 137     }
 138
 139   return 0;
 140 }
 141
 142 int
 143 Latency_Query_Client::parse_args (int argc,
 144                                   ACE_TCHAR *argv[])
 145 {
 146   ACE_Get_Opt opts (argc, argv, ACE_TEXT("dhi:"));
 147   int c;
 148   int result = 0;
 149
 150   while ((c = opts ()) != -1)
 151     {
 152       switch (c)
 153         {
 154         case 'd':
 155           this->debug_ = true;
 156           break;
 157         case 'h':
 158           this->do_dump_history_ = true;
 159           break;
 160         case 'i':
 161           result = ACE_OS::atoi (opts.opt_arg ());
 162
 163           if (result > 0)
 164             {
 165               this->iterations_ = result;
 166             }
 167
 168           break;
 169         case '?':
 170         default:
 171           ACE_ERROR_RETURN ((LM_ERROR,
 172                             "usage: %s"
 173                             " [-d]"
 174                             " [-i iterations]"
 175                             "\n",
 176                             argv [0]),
 177                             -1);
 178         }
 179     }
 180
 181   return 0;
 182 }
 183
 184 int
 185 Latency_Query_Client::populate_ifr ()
 186 {
 187   CORBA::Contained_var irobj = this->repo_->lookup_id ("IDL:dummy/attr:1.0");
 188
 189   if (! CORBA::is_nil (irobj.in ()))
 190     {
 191       this->attr_ = CORBA::AttributeDef::_narrow (irobj.in ());
 192
 193       if (CORBA::is_nil (this->attr_.in ()))
 194         {
 195           ACE_ERROR_RETURN ((LM_ERROR,
 196                              "Latency_Query_Client::populate_ifr - "
 197                              "AttributeDef::_narrow returned null\n"),
 198                             -1);
 199         }
 200
 201       return 0;
 202     }
 203
 204   CORBA::InterfaceDefSeq in_bases (0);
 205   in_bases.length (0);
 206
 207   CORBA::InterfaceDef_var iface =
 208     this->repo_->create_interface ("IDL:dummy:1.0",
 209                                    "dummy",
 210                                    "1.0",
 211                                    in_bases);
 212
 213   CORBA::PrimitiveDef_var p_long =
 214     this->repo_->get_primitive (CORBA::pk_long);
 215
 216   this->attr_ =
 217     iface->create_attribute ("IDL:dummt/attr:1.0",
 218                              "attr",
 219                              "1.0",
 220                              p_long.in (),
 221                              CORBA::ATTR_NORMAL);
 222
 223   return 0;
 224 }