You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2010/11/10 22:50:21 UTC
svn commit: r1033739 - /qpid/trunk/qpid/cpp/src/tests/qpid-receive.cpp
Author: aconway
Date: Wed Nov 10 21:50:20 2010
New Revision: 1033739
URL: http://svn.apache.org/viewvc?rev=1033739&view=rev
Log:
qpid-recieve --receive-rate: fixed calculation for duplicate messages.
Modified:
qpid/trunk/qpid/cpp/src/tests/qpid-receive.cpp
Modified: qpid/trunk/qpid/cpp/src/tests/qpid-receive.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/qpid-receive.cpp?rev=1033739&r1=1033738&r2=1033739&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/qpid-receive.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/qpid-receive.cpp Wed Nov 10 21:50:20 2010
@@ -185,14 +185,13 @@ int main(int argc, char ** argv)
Reporter<ThroughputAndLatency> reporter(std::cout, opts.reportEvery, opts.reportHeader);
if (!opts.readyAddress.empty())
session.createSender(opts.readyAddress).send(msg);
-
- uint received = 0;
+
+ // For receive rate calculation
qpid::sys::AbsTime start = qpid::sys::now();
int64_t interval = 0;
if (opts.receiveRate) interval = qpid::sys::TIME_SEC/opts.receiveRate;
while (!done && receiver.fetch(msg, timeout)) {
- ++received;
reporter.message(msg);
if (!opts.ignoreDuplicates || !sequenceTracker.isDuplicate(msg)) {
if (msg.getContent() == EOS) {
@@ -225,7 +224,7 @@ int main(int argc, char ** argv)
session.acknowledge();
}
if (opts.receiveRate) {
- qpid::sys::AbsTime waitTill(start, received*interval);
+ qpid::sys::AbsTime waitTill(start, count*interval);
int64_t delay = qpid::sys::Duration(qpid::sys::now(), waitTill);
if (delay > 0) qpid::sys::usleep(delay/qpid::sys::TIME_USEC);
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org