diff options
Diffstat (limited to 'qpid/cpp/src/tests/latencytest.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/latencytest.cpp | 38 |
1 files changed, 25 insertions, 13 deletions
diff --git a/qpid/cpp/src/tests/latencytest.cpp b/qpid/cpp/src/tests/latencytest.cpp index eef9d72312..e1c47eab05 100644 --- a/qpid/cpp/src/tests/latencytest.cpp +++ b/qpid/cpp/src/tests/latencytest.cpp @@ -281,27 +281,39 @@ void Stats::print() double aux_avg = (totalLatency / count); if (!opts.cumulative) { if (!opts.csv) { - std::cout << "Latency(ms): min=" << minLatency << ", max=" << + if (count) { + std::cout << "Latency(ms): min=" << minLatency << ", max=" << maxLatency << ", avg=" << aux_avg; + } else { + std::cout << "Stalled: no samples for interval"; + } } else { - std::cout << value << "," << minLatency << "," << maxLatency << + if (count) { + std::cout << value << "," << minLatency << "," << maxLatency << "," << aux_avg; + } else { + std::cout << value << "," << minLatency << "," << maxLatency << + ", Stalled"; + } } } else { - if (already_have_stats) { - c_avg = (c_min + aux_avg) / 2; - if (c_min > minLatency) c_min = minLatency; - if (c_max < maxLatency) c_max = maxLatency; + if (count) { + if (already_have_stats) { + c_avg = (c_min + aux_avg) / 2; + if (c_min > minLatency) c_min = minLatency; + if (c_max < maxLatency) c_max = maxLatency; + } else { + c_avg = aux_avg; + c_min = minLatency; + c_max = maxLatency; + already_have_stats = true; + } + std::cout << value << "," << c_min << "," << c_max << + "," << c_avg; } else { - c_avg = aux_avg; - c_min = minLatency; - c_max = maxLatency; - already_have_stats = true; + std::cout << "Stalled: no samples for interval"; } - std::cout << value << "," << c_min << "," << c_max << - "," << c_avg; } - } void Stats::reset() |