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/src/qpid/broker/Queue.cpp | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) (limited to 'cpp/src/qpid/broker/Queue.cpp') diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index 2fe5de2dc9..4fae1086d5 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -15,9 +15,10 @@ * limitations under the License. * */ -#include "qpid/broker/Queue.h" -#include "qpid/broker/MessageStore.h" -#include "qpid/sys/Monitor.h" +#include +#include +#include +#include #include using namespace qpid::broker; @@ -38,7 +39,7 @@ Queue::Queue(const string& _name, u_int32_t _autodelete, exclusive(0), persistenceId(0) { - if(autodelete) lastUsed = getTimeMsecs(); + if(autodelete) lastUsed = Time::now().msecs(); } Queue::~Queue(){ @@ -133,7 +134,7 @@ void Queue::consume(Consumer* c, bool requestExclusive){ void Queue::cancel(Consumer* c){ Mutex::ScopedLock locker(lock); consumers.erase(find(consumers.begin(), consumers.end(), c)); - if(autodelete && consumers.empty()) lastUsed = getTimeMsecs(); + if(autodelete && consumers.empty()) lastUsed = Time::now().msecs(); if(exclusive == c) exclusive = 0; } @@ -166,7 +167,7 @@ u_int32_t Queue::getConsumerCount() const{ bool Queue::canAutoDelete() const{ Mutex::ScopedLock locker(lock); - return lastUsed && (getTimeMsecs() - lastUsed > autodelete); + return lastUsed && (Time::now().msecs() - lastUsed > autodelete); } void Queue::enqueue(TransactionContext* ctxt, Message::shared_ptr& msg, const string * const xid) -- cgit v1.2.1