diff options
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp b/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp index 60caa15d755..f6d58ede385 100644 --- a/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp +++ b/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp @@ -471,29 +471,31 @@ ECT_Throughput::disconnect_consumers (CORBA::Environment &ACE_TRY_ENV) void ECT_Throughput::dump_results (void) { - ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); - - ACE_Throughput_Stats consumers; + ECT_Driver::Throughput_Stats consumers; + ECT_Driver::Latency_Stats latency; for (int j = 0; j < this->n_consumers_; ++j) { char buf[BUFSIZ]; ACE_OS::sprintf (buf, "consumer_%02.2d", j); - this->consumers_[j]->dump_results (buf, gsf); + this->consumers_[j]->dump_results (buf); this->consumers_[j]->accumulate (consumers); + this->consumers_[j]->accumulate (latency); } - consumers.dump_results ("ECT_Consumer/totals", gsf); + consumers.dump_results ("ECT_Consumer", "throughput"); + latency.dump_results ("ECT_Consumer", "latency"); - ACE_Throughput_Stats suppliers; + ECT_Driver::Throughput_Stats suppliers; for (int i = 0; i < this->n_suppliers_; ++i) { char buf[BUFSIZ]; ACE_OS::sprintf (buf, "supplier_%02.2d", i); - this->suppliers_[i]->dump_results (buf, gsf); + this->suppliers_[i]->dump_results (buf); this->suppliers_[i]->accumulate (suppliers); } - suppliers.dump_results ("ECT_Supplier/totals", gsf); + suppliers.dump_results ("ECT_Supplier", "accumulated"); + this->dump_latency_results ("Latency"); } int |