summaryrefslogtreecommitdiff
path: root/TAO/performance-tests/Demux/demux_test_client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/performance-tests/Demux/demux_test_client.cpp')
-rw-r--r--TAO/performance-tests/Demux/demux_test_client.cpp512
1 files changed, 0 insertions, 512 deletions
diff --git a/TAO/performance-tests/Demux/demux_test_client.cpp b/TAO/performance-tests/Demux/demux_test_client.cpp
deleted file mode 100644
index 328fbdae5b1..00000000000
--- a/TAO/performance-tests/Demux/demux_test_client.cpp
+++ /dev/null
@@ -1,512 +0,0 @@
-// $Id$
-// ============================================================================
-//
-// = LIBRARY
-// TAO/performance-tests/Demux
-//
-// = FILENAME
-// demux_test_client.cpp
-//
-// = AUTHOR
-//
-// Aniruddha Gokhale
-//
-// ============================================================================
-
-#include "demux_test_client.h"
-
-// Constructor
-Demux_Test_Client::Demux_Test_Client (void)
- : argc_ (0),
- argv_ (0),
- is_ (Demux_Test_Client::LINEAR),
- num_POAs_ (1),
- // default number of child POAs is 1 and each one will always have 1 object
- num_objs_ (1),
- num_ops_ (1),
- loop_count_ (1),
- ior_fp_ (0),
- result_fp_ (0)
-{
-}
-
-// destructor
-Demux_Test_Client::~Demux_Test_Client (void)
-{
- ACE_OS::fclose (this->ior_fp_);
- ACE_OS::fclose (this->result_fp_);
-}
-
-//
-// initialize the Demux_Test_Client
-//
-
-int
-Demux_Test_Client::init (int argc, char *argv [], CORBA::Environment &env)
-{
- this->argc_ = argc;
- this->argv_ = argv;
-
- // Grab the ORB
- TAO_TRY_EX (GET_ORB)
- {
- char *orb_name = "internet"; // unused by TAO
-
- // get the underlying ORB
- this->orb_ = CORBA::ORB_init (argc, argv, orb_name, TAO_TRY_ENV);
- TAO_CHECK_ENV_EX (GET_ORB);
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("ORB_init");
- env.exception (TAO_TRY_ENV.exception ());
- return -1;
- }
- TAO_ENDTRY;
-
- // now parse the rest of the arguments to determine the POA depth, the number
- // of objects with each POA and other info
-
- if (this->parse_args () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%N:%l) Demux_Test_Client::init - "
- "parse_args failed\n"),
- -1);
-
- if (this->init_operation_db () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%N:%l) Demux_Test_Client::init - "
- "init_operation_db failed\n"),
- -1);
-
- // now read all the IORS
- CORBA::ULong i, j;
-
- for (i = 0; i < this->num_POAs_; ++i)
- for (j = 0; j < this->num_objs_; ++j)
- {
- char str [1028];
- ACE_OS::memset (str, 0, 1028);
-
- if (fscanf (this->ior_fp_, "%s", str) == EOF)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "IOR database has less entries than required\n"),
- -1);
- }
-
- // Get the IOR and output it to the file
- TAO_TRY_EX (IOR)
- {
- CORBA::Object_var objref = this->orb_->string_to_object (str,
- TAO_TRY_ENV);
- TAO_CHECK_ENV_EX (IOR);
-
- // now narrow to Demux_Test object
-
- this->demux_test_[i][j] = Demux_Test::_narrow (objref.in (),
- TAO_TRY_ENV);
-
- TAO_CHECK_ENV_EX (IOR);
-
- if (CORBA::is_nil (this->demux_test_[i][j].in ()))
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "ObjRef for IOR %s (POA %d, OBJ %d) is NULL\n",
- str, i, j),
- -1);
- }
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("object_to_string");
- env.exception (TAO_TRY_ENV.exception ());
- return -1;
- }
- TAO_ENDTRY;
- } // j and i loop
-
- ACE_OS::fclose (this->ior_fp_);
-
- // success
- return 0;
-
-}
-
-// parse command line arguments (if any).
-int
-Demux_Test_Client::parse_args (void)
-{
-
- ACE_Get_Opt get_opts (this->argc_, this->argv_, "df:m:n:o:p:i:");
- int c;
-
- while ((c = get_opts ()) != -1)
- switch (c)
- {
- case 'd': // debug flag
- TAO_debug_level++;
- break;
- case 'f':
- this->ior_fp_ = ACE_OS::fopen (get_opts.optarg, "w");
- if (this->ior_fp_ == 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Unable to open %s for writing: %p\n",
- get_opts.optarg), -1);
- break;
- case 'm':
- this->num_ops_ = ACE_OS::atoi (get_opts.optarg);
- if (this->num_ops_ > TAO_DEMUX_TEST_MAX_OPS)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "%d exceeds the maximum of "
- "%d objects per POA\n",
- this->num_objs_,
- TAO_DEMUX_TEST_MAX_OPS),
- -1);
- }
- break;
- case 'n':
- this->loop_count_ = ACE_OS::atoi (get_opts.optarg);
- break;
- case 'o':
- this->num_objs_ = ACE_OS::atoi (get_opts.optarg);
- if (this->num_objs_ > TAO_DEMUX_TEST_MAX_OBJS)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "%d exceeds the maximum of "
- "%d objects per POA\n",
- this->num_objs_,
- TAO_DEMUX_TEST_MAX_OBJS),
- -1);
- }
- break;
- case 'p':
- this->num_POAs_ = ACE_OS::atoi (get_opts.optarg);
- if (this->num_POAs_ > TAO_DEMUX_TEST_MAX_POAS)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "%d exceeds the maximum of "
- "%d POAs\n",
- this->num_objs_,
- TAO_DEMUX_TEST_MAX_POAS),
- -1);
- }
- break;
- case 'i':
- switch (*get_opts.optarg)
- {
- case 'L':
- this->is_ = Demux_Test_Client::LINEAR;
- break;
- case 'R':
- this->is_ = Demux_Test_Client::RANDOM;
- break;
- case 'B':
- this->is_ = Demux_Test_Client::BEST;
- break;
- case 'W':
- this->is_ = Demux_Test_Client::WORST;
- break;
- }
- break;
- case '?':
- default:
- ACE_ERROR_RETURN ((LM_ERROR,
- "usage: %s"
- " [-d]"
- " [-m <num ops>]"
- " [-o <num objs>]"
- " [-p <num POAs]"
- " [-i <invoke strategy>"
- " [-f <IOR file>]"
- " [-n <loop count>]"
- "\n"
- "Invocation Strategy: L(linear), R(random)"
- "B(best), W(worst)\n",
- this->argv_ [0]),
- -1);
- }
-
- if (!this->ior_fp_)
- {
- // open default IOR file
- this->ior_fp_ = ACE_OS::fopen ("ior.dat", "r");
- if (this->ior_fp_ == 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Unable to open file ior.dat for reading\n"), -1);
- }
- return 0;
-}
-
-// The main program for Demux_Test
-int
-Demux_Test_Client::run (CORBA::Environment &env)
-{
- // open a temporary results file
- if ((this->result_fp_ = ACE_OS::fopen ("results.dat", "w")) == 0)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "Demux_Test_Client::run - "
- "Failed to open the results file for writing\n"),
- -1);
- }
- TAO_TRY_EX (RUN)
- {
- switch (this->is_)
- {
- case Demux_Test_Client::LINEAR:
- (void) this->run_linear_test (TAO_TRY_ENV);
- break;
- case Demux_Test_Client::RANDOM:
- (void) this->run_random_test (TAO_TRY_ENV);
- break;
- case Demux_Test_Client::BEST:
- (void) this->run_best_test (TAO_TRY_ENV);
- break;
- case Demux_Test_Client::WORST:
- (void) this->run_worst_test (TAO_TRY_ENV);
- break;
- }
- TAO_CHECK_ENV_EX (RUN);
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("run failed");
- env.exception (TAO_TRY_ENV.exception ());
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%N:%l) Demux_Test_Client::run - "
- "Error running the Client\n"),
- -1);
- }
- TAO_ENDTRY;
-
- ACE_OS::fclose (this->result_fp_);
-
- TAO_TRY_EX (SHUTDOWN)
- {
- // call the shutdown method one the first object
- this->demux_test_[0][0]->shutdown (TAO_TRY_ENV);
- TAO_CHECK_ENV_EX (SHUTDOWN);
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("shutdown failed");
- env.exception (TAO_TRY_ENV.exception ());
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%N:%l) Demux_Test_Client::run - "
- "Error running the Client\n"),
- -1);
- }
- TAO_ENDTRY;
-
- // now print the results
- if (this->print_results () == -1)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "Demux_Test_Client::run - "
- "Print results failed\n"),
- -1);
- }
-
- return 0;
-}
-
-int
-Demux_Test_Client::run_linear_test (CORBA::Environment &env)
-{
- CORBA::ULong i, j, k, l, m;
- ACE_hrtime_t start, end;
-
- m = 0;
- for (i = 0; i < this->loop_count_; ++i)
- for (j = 0; j < this->num_POAs_; ++j)
- for (k = 0; k < this->num_objs_; ++k)
- for (l = 0; l < this->num_ops_; ++l)
- {
- start = ACE_OS::gethrtime ();
-
- // invoke the method
- this->op_db_[l].op_ (this->demux_test_[j][k].in (), env);
-
- end = ACE_OS::gethrtime ();
-
- m++;
- ACE_OS::fprintf (this->result_fp_, "%d %f\n", m,
- 1.0 * ACE_UINT64_DBLCAST_ADAPTER (end - start));
- }
-
- return 0;
-}
-
-int
-Demux_Test_Client::run_random_test (CORBA::Environment &env)
-{
- CORBA::ULong i, j, k, l, m;
- ACE_hrtime_t start, end;
- long p, q, r;
-
- m = 0;
- // set the random number generator seed
- ACE_OS::srand (ACE_OS::time ());
- for (i = 0; i < this->loop_count_; ++i)
- for (j = 0; j < this->num_POAs_; ++j)
- for (k = 0; k < this->num_objs_; ++k)
- for (l = 0; l < this->num_ops_; ++l)
- {
- p = ACE_OS::rand () % this->num_POAs_;
- q = ACE_OS::rand () % this->num_objs_;
- r = ACE_OS::rand () % this->num_ops_;
- start = ACE_OS::gethrtime ();
-
- // invoke the method
- this->op_db_[r].op_ (this->demux_test_[p][q].in (), env);
-
- end = ACE_OS::gethrtime ();
- m++;
- ACE_OS::fprintf (this->result_fp_, "%d %f\n", m,
- 1.0 * ACE_UINT64_DBLCAST_ADAPTER (end - start));
- }
-
- return 0;
-}
-
-int
-Demux_Test_Client::run_best_test (CORBA::Environment &env)
-{
- CORBA::ULong i, j, k, l, m;
- ACE_hrtime_t start, end;
-
- m = 0;
- for (i = 0; i < this->loop_count_; ++i)
- for (j = 0; j < this->num_POAs_; ++j)
- for (k = 0; k < this->num_objs_; ++k)
- for (l = 0; l < this->num_ops_; ++l)
- {
- start = ACE_OS::gethrtime ();
-
- // invoke the method
- this->op_db_[0].op_ (this->demux_test_[0][0].in (), env);
-
- end = ACE_OS::gethrtime ();
- m++;
- ACE_OS::fprintf (this->result_fp_, "%d %f\n", m,
- 1.0 * ACE_UINT64_DBLCAST_ADAPTER (end - start));
- }
-
- return 0;
-}
-
-int
-Demux_Test_Client::run_worst_test (CORBA::Environment &env)
-{
- CORBA::ULong i, j, k, l, m;
- ACE_hrtime_t start, end;
-
- m = 0;
- for (i = 0; i < this->loop_count_; ++i)
- for (j = 0; j < this->num_POAs_; ++j)
- for (k = 0; k < this->num_objs_; ++k)
- for (l = 0; l < this->num_ops_; ++l)
- {
- start = ACE_OS::gethrtime ();
-
- // invoke the method
- this->op_db_[this->num_ops_ - 1].op_
- (this->demux_test_[this->num_POAs_ - 1][this->num_objs_ - 1].in
- (), env);
-
- end = ACE_OS::gethrtime ();
- m++;
- ACE_OS::fprintf (this->result_fp_, "%d %f\n", m,
- 1.0 * ACE_UINT64_DBLCAST_ADAPTER (end - start));
- }
-
- return 0;
-}
-
-int
-Demux_Test_Client::print_results (void)
-{
- ACE_DEBUG ((LM_DEBUG,
- "******** "));
- switch (this->is_)
- {
- case Demux_Test_Client::LINEAR:
- ACE_DEBUG ((LM_DEBUG,
- "Linear Strategy ******\n"));
- break;
- case Demux_Test_Client::RANDOM:
- ACE_DEBUG ((LM_DEBUG,
- "Random Strategy ******\n"));
- break;
- case Demux_Test_Client::BEST:
- ACE_DEBUG ((LM_DEBUG,
- "Best Strategy ******\n"));
- break;
- case Demux_Test_Client::WORST:
- ACE_DEBUG ((LM_DEBUG,
- "Worst Strategy ******\n"));
- break;
- }
-
- CORBA::ULong i, items;
- double temp, mean, sum, deviation, std_deviation;
-
- if ((this->result_fp_ = ACE_OS::fopen ("results.dat", "r")) == 0)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "Demux_Test_Client::print_results - "
- "Failed to open the results file for reading\n"),
- -1);
- }
-
- sum = 0;
- items = 0;
- while (fscanf (this->result_fp_, "%d %lf", &i, &temp) != EOF)
- {
- sum += temp;
- ++items;
- }
-
- ACE_OS::fclose (this->result_fp_);
-
- mean = sum/items;
-
- // now compute standard deviation
-
- if ((this->result_fp_ = ACE_OS::fopen ("results.dat", "r")) == 0)
- {
- ACE_ERROR_RETURN ((LM_ERROR,
- "Demux_Test_Client::print_results - "
- "Failed to open the results file for reading\n"),
- -1);
- }
-
- sum = 0;
- while (fscanf (this->result_fp_, "%d %lf", &i, &temp) != EOF)
- {
- deviation = temp - mean;
- sum += deviation * deviation;
- }
-
- if (items == 1)
- std_deviation = 0;
- else
- std_deviation = sqrt (sum/(items - 1));
-
- ACE_OS::fclose (this->result_fp_);
-
- ACE_OS::unlink ("results.dat");
-
- ACE_DEBUG ((LM_DEBUG,
- "Average response time = %f millisec\n"
- "Standard Deviation = %f millisec\n",
- (mean * 1e-06),
- (std_deviation * 1e-06)));
-
- return 0;
-}
-
-// include the generated code
-#include "demux_test_client.i"
View Lorry Controller Status