TAO/tests/Param_Test/client.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    client.cpp
   5  *
   6  *  This file contains the implementation of the client-side of the
   7  *  Param_Test application.
   8  *
   9  *  @author   Aniruddha Gokhale
  10  */
  11 //=============================================================================
  12
  13
  14 #ifndef CLIENT_CPP
  15 #define CLIENT_CPP
  16
  17 #include "options.h"
  18 #include "results.h"
  19 #include "client.h"
  20
  21 // Constructor.
  22 template <class T>
  23 Param_Test_Client<T>::Param_Test_Client (CORBA::ORB_ptr orb,
  24                                          Param_Test_ptr objref,
  25                                          T *t)
  26   : orb_ (orb),
  27     param_test_ (objref),
  28     test_object_ (t)
  29 {
  30 }
  31
  32 // destructor
  33 template <class T>
  34 Param_Test_Client<T>::~Param_Test_Client ()
  35 {
  36   delete this->test_object_;
  37 }
  38
  39 // All the individual tests.
  40 template <class T> int
  41 Param_Test_Client<T>::run_sii_test ()
  42 {
  43   CORBA::ULong i = 0;  // loop index
  44   Options *opt = OPTIONS::instance (); // get the options
  45   const char *opname = this->test_object_->opname (); // operation
  46
  47   if (opt->debug ())
  48     ACE_DEBUG ((LM_DEBUG,
  49                 "********** %C SII *********\n",
  50                 opname));
  51
  52   // Initialize call count and error count.
  53   this->results_.call_count (0);
  54   this->results_.error_count (0);
  55   this->results_.iterations (opt->loop_count ());
  56
  57   // Declare the Env
  58   // Initialize parameters for the test.
  59   int check = this->test_object_->init_parameters (this->param_test_);
  60
  61   if (check == -1)
  62     {
  63       ACE_ERROR_RETURN ((LM_ERROR,
  64                          "(%N:%l) client.cpp - run_sii_test:"
  65                          "init_parameters failed for opname - %C",
  66                          opname),
  67                         -1);
  68     }
  69
  70
  71   // Make the calls in a loop.
  72   for (i = 0; i < opt->loop_count (); i++)
  73     {
  74       try
  75         {
  76           this->results_.call_count (this->results_.call_count () + 1);
  77           if (opt->debug ())
  78             {
  79               ACE_DEBUG ((LM_DEBUG, "\n****** Before call values *****\n"));
  80               this->test_object_->print_values ();
  81             }
  82
  83           // start the timing
  84           this->results_.start_timer ();
  85
  86           // make the call
  87           this->test_object_->run_sii_test (this->param_test_);
  88
  89           // stop the timer.
  90           this->results_.stop_timer ();
  91
  92           // now check if the values returned are as expected
  93           if (opt->debug ())
  94             {
  95               ACE_DEBUG ((LM_DEBUG, "\n****** After call values *****\n"));
  96               this->test_object_->print_values ();
  97             }
  98         }
  99       catch (const CORBA::Exception& ex)
 100         {
 101           this->results_.error_count (this->results_.error_count () + 1);
 102           ex._tao_print_exception (opname);
 103           ACE_ERROR ((LM_ERROR,
 104                       "(%N:%l) client.cpp - run_sii_test:"
 105                       "run_sii_test exception in iteration %d",
 106                       i));
 107           goto loop_around;
 108         }
 109
 110       if (!this->test_object_->check_validity ())
 111         {
 112           this->results_.error_count (this->results_.error_count () + 1);
 113           ACE_ERROR ((LM_ERROR,
 114                       "(%N:%l) client.cpp - run_sii_test: "
 115                       "Invalid results in iteration %d\n",
 116                       i));
 117           continue;
 118         }
 119       // reset parameters for the test.
 120       if (this->test_object_->reset_parameters () == -1)
 121         ACE_ERROR_RETURN ((LM_ERROR,
 122                            "(%N:%l) client.cpp - run_sii_test:"
 123                            "init_parameters failed for opname - %C",
 124                            opname), -1);
 125     loop_around: continue;
 126     }
 127
 128   // print statistics
 129   this->results_.print_stats ();
 130   if (this->results_.error_count () != 0)
 131     {
 132       ACE_DEBUG ((LM_DEBUG,
 133                   "********** Error running %C SII *********\n",
 134                   opname));
 135     }
 136   else if (opt->debug ())
 137     {
 138       ACE_DEBUG ((LM_DEBUG,
 139                   "********** Finished running %C SII *********\n",
 140                   opname));
 141     }
 142   return this->results_.error_count ()? -1:0;
 143 }
 144
 145 // use DII
 146 template <class T> int
 147 Param_Test_Client<T>::run_dii_test ()
 148 {
 149   const char *opname = this->test_object_->opname ();
 150   Options *opt = OPTIONS::instance ();
 151
 152   if (opt->debug ())
 153     ACE_DEBUG ((LM_DEBUG,
 154                 "********** %C DII *********\n",
 155                 opname));
 156
 157   // initialize call count and error count
 158   this->results_.call_count (0);
 159   this->results_.error_count (0);
 160   this->results_.iterations (opt->loop_count ());
 161
 162   // Environment variable
 163   // initialize parameters for the test
 164   int check = this->test_object_->init_parameters (this->param_test_);
 165
 166   if (check == -1)
 167     {
 168       ACE_ERROR_RETURN ((LM_ERROR,
 169                          "(%N:%l) client.cpp - run_dii_test:"
 170                          "init_parameters failed for opname - %C",
 171                          opname),
 172                         -1);
 173     }
 174
 175       // Make the calls in a loop.
 176   for (CORBA::ULong i = 0; i < opt->loop_count (); i++)
 177     {
 178       this->results_.call_count (this->results_.call_count () + 1);
 179
 180       // start the timing. We measure the entire overhead of DII, including the
 181       // time required to create and populate the NVList
 182       this->results_.start_timer ();
 183
 184       // create the request
 185       CORBA::Request_var req;
 186
 187       try
 188         {
 189           req = this->param_test_->_request (opname);
 190
 191           if (opt->debug ())
 192             {
 193               ACE_DEBUG ((LM_DEBUG, "\n****** Before call values *****\n"));
 194               this->test_object_->print_values ();
 195             }
 196
 197           // Make the invocation, verify the result.
 198           this->test_object_->dii_req_invoke (req.in ());
 199         }
 200       catch (const CORBA::Exception& ex)
 201         {
 202           this->results_.error_count (this->results_.error_count () + 1);
 203
 204           ex._tao_print_exception (opname);
 205           goto loop_around;
 206         }
 207
 208       if (opt->debug ())
 209         {
 210           ACE_DEBUG ((LM_DEBUG, "\n****** After call values *****\n"));
 211           this->test_object_->print_values ();
 212         }
 213       // now check if the values returned are as expected
 214       if (!this->test_object_->check_validity (req.in ()))
 215         {
 216           this->results_.error_count (this->results_.error_count () + 1);
 217           ACE_ERROR ((LM_ERROR,
 218                       "(%N:%l) client.cpp - "
 219                       "Invalid results in run_dii_test in iteration %d\n",
 220                       i));
 221
 222           continue;
 223         }
 224
 225       // stop the this->results_.
 226       this->results_.stop_timer ();
 227
 228       // reset parameters for the test
 229       this->test_object_->reset_parameters ();
 230
 231     loop_around:continue;
 232     } // for loop
 233
 234   // print statistics
 235   this->results_.print_stats ();
 236   if (this->results_.error_count () != 0)
 237     {
 238       ACE_DEBUG ((LM_DEBUG,
 239                   "********** Error running %C DII *********\n",
 240                   opname));
 241     }
 242   else if (opt->debug ())
 243     {
 244       ACE_DEBUG ((LM_DEBUG,
 245                   "********** Finished running %C DII *********\n",
 246                   opname));
 247     }
 248   return this->results_.error_count () ? -1 : 0;
 249 }
 250
 251
 252 #endif /* CLIENT_CPP */