From 295145d247a7523affdf43f8d870912b1a303caf Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Thu, 9 Nov 2006 01:29:59 +0000 Subject: More separation of concerns with APR, client side complete. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472732 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/test/client/topic_publisher.cpp | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'cpp/test') diff --git a/cpp/test/client/topic_publisher.cpp b/cpp/test/client/topic_publisher.cpp index 22c36ea9e3..1e1a91dfff 100644 --- a/cpp/test/client/topic_publisher.cpp +++ b/cpp/test/client/topic_publisher.cpp @@ -114,7 +114,7 @@ int main(int argc, char** argv){ if(!max || time > max) max = time; if(!min || time < min) min = time; sum += time; - std::cout << "Completed " << (i+1) << " of " << batchSize << " in " << nsecsToMsecs(time) << "ms" << std::endl; + std::cout << "Completed " << (i+1) << " of " << batchSize << " in " << time << "ms" << std::endl; } publisher.terminate(); int64_t avg = sum / batchSize; @@ -133,13 +133,12 @@ int main(int argc, char** argv){ Publisher::Publisher(Channel* _channel, const std::string& _controlTopic, bool tx) : channel(_channel), controlTopic(_controlTopic), transactional(tx){} -void Publisher::received(Message& msg){ +void Publisher::received(Message& ){ //count responses and when all are received end the current batch Monitor::ScopedLock l(monitor); if(--count == 0){ monitor.notify(); } - std::cout << "Received report: " << msg.getData() << " (" << count << " remaining)." << std::endl; } void Publisher::waitForCompletion(int msgs){ -- cgit v1.2.1