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 | 402ac40145f2d35f9f9bfd34d499336faeb65c2e (patch) | |
| tree | 49084b4dcb4ba2a1b7c846dc90e997ac6582656f /qpid/cpp/test/client/topic_publisher.cpp | |
| parent | 75e9bad6c3eb3a7bb207a10ec6719e859170396b (diff) | |
| download | qpid-python-402ac40145f2d35f9f9bfd34d499336faeb65c2e.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@473087 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/test/client/topic_publisher.cpp')
| -rw-r--r-- | qpid/cpp/test/client/topic_publisher.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/qpid/cpp/test/client/topic_publisher.cpp b/qpid/cpp/test/client/topic_publisher.cpp index 1e1a91dfff..24393fac86 100644 --- a/qpid/cpp/test/client/topic_publisher.cpp +++ b/qpid/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; } |