From c33f3d8550b9b4455ad6ca8a2327a7bd9d6f7db1 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Thu, 9 Nov 2006 21:55:34 +0000 Subject: Added POSIX equivalents to APR classes used by clients, inlined trivial calls. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473087 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/test/client/topic_publisher.cpp | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) (limited to 'cpp/test/client/topic_publisher.cpp') diff --git a/cpp/test/client/topic_publisher.cpp b/cpp/test/client/topic_publisher.cpp index 1e1a91dfff..24393fac86 100644 --- a/cpp/test/client/topic_publisher.cpp +++ b/cpp/test/client/topic_publisher.cpp @@ -15,13 +15,13 @@ * limitations under the License. * */ -#include "qpid/QpidError.h" -#include "qpid/client/Channel.h" -#include "qpid/client/Connection.h" -#include "qpid/client/Exchange.h" -#include "qpid/client/MessageListener.h" -#include "qpid/client/Queue.h" -#include "qpid/sys/Monitor.h" +#include +#include +#include +#include +#include +#include +#include #include "unistd.h" #include #include @@ -149,7 +149,7 @@ void Publisher::waitForCompletion(int msgs){ int64_t Publisher::publish(int msgs, int listeners, int size){ Message msg; msg.setData(generateData(size)); - int64_t start = getTimeMsecs(); + int64_t start = Time::now().msecs(); { Monitor::ScopedLock l(monitor); for(int i = 0; i < msgs; i++){ @@ -166,7 +166,7 @@ int64_t Publisher::publish(int msgs, int listeners, int size){ waitForCompletion(listeners); } - int64_t finish(getTimeMsecs()); + int64_t finish(Time::now().msecs()); return finish - start; } -- cgit v1.2.1