diff options
| author | Alan Conway <aconway@apache.org> | 2006-11-09 21:55:34 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2006-11-09 21:55:34 +0000 |
| commit | c33f3d8550b9b4455ad6ca8a2327a7bd9d6f7db1 (patch) | |
| tree | bb5d68281986eb1664c227d15f303664a65d5e03 /cpp/test/client/topic_publisher.cpp | |
| parent | 76fb78a8495b6cd48c633e8b6219b29761133d82 (diff) | |
| download | qpid-python-c33f3d8550b9b4455ad6ca8a2327a7bd9d6f7db1.tar.gz | |
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
Diffstat (limited to 'cpp/test/client/topic_publisher.cpp')
| -rw-r--r-- | cpp/test/client/topic_publisher.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
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 <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 "unistd.h" #include <qpid/sys/Time.h> #include <cstdlib> @@ -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; } |