diff options
Diffstat (limited to 'cpp/test')
| -rw-r--r-- | cpp/test/client/topic_publisher.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
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){ |