summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp')
-rw-r--r--TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.cpp18
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