diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Event/Performance/Connect.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/Event/Performance/Connect.cpp | 59 |
1 files changed, 39 insertions, 20 deletions
diff --git a/TAO/orbsvcs/tests/Event/Performance/Connect.cpp b/TAO/orbsvcs/tests/Event/Performance/Connect.cpp index b2d18032e20..d9cba9424f4 100644 --- a/TAO/orbsvcs/tests/Event/Performance/Connect.cpp +++ b/TAO/orbsvcs/tests/Event/Performance/Connect.cpp @@ -5,6 +5,7 @@ #include "Supplier.h" #include "orbsvcs/Event/EC_Event_Channel.h" #include "ace/Arg_Shifter.h" +#include "ace/High_Res_Timer.h" ACE_RCSID(EC_Tests_Performance, Connect, "$Id$") @@ -96,9 +97,10 @@ EC_Connect::print_args (void) const void EC_Connect::dump_results (void) { + ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); ACE_DEBUG ((LM_DEBUG, "\nConnect time:\n")); - this->consumer_connect_.dump_results ("Consumer", "connect"); - this->supplier_connect_.dump_results ("Supplier", "connect"); + this->consumer_connect_.dump_results ("Consumer/connect", gsf); + this->supplier_connect_.dump_results ("Supplier/connect", gsf); ACE_DEBUG ((LM_DEBUG, "\nDisconnect time:\n")); } @@ -114,7 +116,8 @@ EC_Connect::connect_consumer ( i, ACE_TRY_ENV); ACE_hrtime_t now = ACE_OS::gethrtime (); - this->consumer_connect_.sample (now - start); + this->consumer_connect_.sample (now - this->start_time_, + now - start); } void @@ -128,7 +131,8 @@ EC_Connect::connect_supplier ( i, ACE_TRY_ENV); ACE_hrtime_t now = ACE_OS::gethrtime (); - this->supplier_connect_.sample (now - start); + this->supplier_connect_.sample (now - this->start_time_, + now - start); } EC_Consumer* @@ -146,6 +150,7 @@ EC_Connect::allocate_supplier (int i) void EC_Connect::connect_clients (CORBA::Environment &ACE_TRY_ENV) { + this->start_time_ = ACE_OS::gethrtime (); switch (this->order_) { default: @@ -231,6 +236,7 @@ EC_Connect::disconnect_clients (CORBA::Environment &ACE_TRY_ENV) this->event_channel_->for_suppliers (ACE_TRY_ENV); ACE_CHECK; + ACE_hrtime_t start_time = ACE_OS::gethrtime (); for (int i = 0; i != max; ++i) { if (i < this->n_suppliers_) @@ -241,7 +247,8 @@ EC_Connect::disconnect_clients (CORBA::Environment &ACE_TRY_ENV) ACE_CHECK; ACE_hrtime_t now = ACE_OS::gethrtime (); - this->supplier_disconnect_.sample (now - start); + this->supplier_disconnect_.sample (now - start_time, + now - start); } if (i < this->n_consumers_) { @@ -251,16 +258,19 @@ EC_Connect::disconnect_clients (CORBA::Environment &ACE_TRY_ENV) ACE_CHECK; ACE_hrtime_t now = ACE_OS::gethrtime (); - this->consumer_disconnect_.sample (now - start); + this->consumer_disconnect_.sample (now - start_time, + now - start); } } - this->consumer_disconnect_.dump_results ("Consumer", "disconnect"); - this->supplier_disconnect_.dump_results ("Supplier", "disconnect"); + ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); + this->consumer_disconnect_.dump_results ("Consumer/disconnect", gsf); + this->supplier_disconnect_.dump_results ("Supplier/disconnect", gsf); } void EC_Connect::disconnect_consumers (CORBA::Environment &ACE_TRY_ENV) { + ACE_hrtime_t start_time = ACE_OS::gethrtime (); for (int i = 0; i < this->n_consumers_; ++i) { ACE_hrtime_t start = ACE_OS::gethrtime (); @@ -269,9 +279,12 @@ EC_Connect::disconnect_consumers (CORBA::Environment &ACE_TRY_ENV) ACE_CHECK; ACE_hrtime_t now = ACE_OS::gethrtime (); - this->consumer_disconnect_.sample (now - start); + this->consumer_disconnect_.sample (now - start_time, + now - start); } - this->consumer_disconnect_.dump_results ("Consumer", "disconnect"); + ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); + this->consumer_disconnect_.dump_results ("Consumer/disconnect", + gsf); if (this->verbose ()) ACE_DEBUG ((LM_DEBUG, "EC_Connect (%P|%t) consumers disconnected\n")); } @@ -279,6 +292,7 @@ EC_Connect::disconnect_consumers (CORBA::Environment &ACE_TRY_ENV) void EC_Connect::disconnect_suppliers (CORBA::Environment &ACE_TRY_ENV) { + ACE_hrtime_t start_time = ACE_OS::gethrtime (); for (int i = 0; i < this->n_suppliers_; ++i) { ACE_hrtime_t start = ACE_OS::gethrtime (); @@ -287,9 +301,12 @@ EC_Connect::disconnect_suppliers (CORBA::Environment &ACE_TRY_ENV) ACE_CHECK; ACE_hrtime_t now = ACE_OS::gethrtime (); - this->supplier_disconnect_.sample (now - start); + this->supplier_disconnect_.sample (now - start_time, + now - start); } - this->supplier_disconnect_.dump_results ("Supplier", "disconnect"); + ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); + this->supplier_disconnect_.dump_results ("Supplier/disconnect", + gsf); if (this->verbose ()) ACE_DEBUG ((LM_DEBUG, "EC_Connect (%P|%t) suppliers disconnected\n")); } @@ -326,14 +343,15 @@ ECC_Consumer::connect ( shutdown_event_type, ACE_TRY_ENV); ACE_hrtime_t now = ACE_OS::gethrtime (); - this->connect_time_.sample (now - start); + this->connect_time_.sample (now, now - start); } void -ECC_Consumer::dump_results (const char* name) +ECC_Consumer::dump_results (const char* name, + ACE_UINT32 gsf) { - this->connect_time_.dump_results ("EC_Consumers/connect", name); - this->EC_Consumer::dump_results (name); + this->connect_time_.dump_results (name, gsf); + this->EC_Consumer::dump_results (name, gsf); } // **************************************************************** @@ -367,14 +385,15 @@ ECC_Supplier::connect ( shutdown_event_type, ACE_TRY_ENV); ACE_hrtime_t now = ACE_OS::gethrtime (); - this->connect_time_.sample (now - start); + this->connect_time_.sample (now, now - start); } void -ECC_Supplier::dump_results (const char* name) +ECC_Supplier::dump_results (const char* name, + ACE_UINT32 gsf) { - this->connect_time_.dump_results ("EC_Suppliers/connect", name); - this->EC_Supplier::dump_results (name); + this->connect_time_.dump_results (name, gsf); + this->EC_Supplier::dump_results (name, gsf); } |