From 3097509ae43d93c1832638f80ba2ad5810fbef44 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 21 Apr 2008 18:59:31 +0000 Subject: Better workaround for boost::ptr_map incompatibility between boost 1.33 and 1.34, based on public properties of ptr::map types rather than version numbers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@650221 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/Connection.cpp | 6 +++--- cpp/src/qpid/broker/DtxManager.cpp | 8 ++++---- cpp/src/qpid/broker/PreviewConnection.cpp | 6 +++--- cpp/src/qpid/broker/SemanticState.cpp | 12 ++++++------ 4 files changed, 16 insertions(+), 16 deletions(-) (limited to 'cpp/src/qpid/broker') diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp index ef1100a2ec..cfa722e130 100644 --- a/cpp/src/qpid/broker/Connection.cpp +++ b/cpp/src/qpid/broker/Connection.cpp @@ -40,7 +40,7 @@ using namespace boost; using namespace qpid::sys; using namespace qpid::framing; using namespace qpid::sys; -using namespace qpid::ptr_map; +using qpid::ptr_map_ptr; using qpid::management::ManagementAgent; using qpid::management::ManagementObject; using qpid::management::Manageable; @@ -143,7 +143,7 @@ void Connection::idleIn(){} void Connection::closed(){ // Physically closed, suspend open sessions. try { for (ChannelMap::iterator i = channels.begin(); i != channels.end(); ++i) - get_pointer(i)->localSuspend(); + ptr_map_ptr(i)->localSuspend(); while (!exclusiveQueues.empty()) { Queue::shared_ptr q(exclusiveQueues.front()); q->releaseExclusiveOwnership(); @@ -186,7 +186,7 @@ SessionHandler& Connection::getChannel(ChannelId id) { if (i == channels.end()) { i = channels.insert(id, new SessionHandler(*this, id)).first; } - return *get_pointer(i); + return *ptr_map_ptr(i); } ManagementObject::shared_ptr Connection::GetManagementObject (void) const diff --git a/cpp/src/qpid/broker/DtxManager.cpp b/cpp/src/qpid/broker/DtxManager.cpp index fb6b3f019e..47f389a57d 100644 --- a/cpp/src/qpid/broker/DtxManager.cpp +++ b/cpp/src/qpid/broker/DtxManager.cpp @@ -29,7 +29,7 @@ using boost::intrusive_ptr; using qpid::sys::Mutex; -using namespace qpid::ptr_map; +using qpid::ptr_map_ptr; using namespace qpid::broker; using namespace qpid::framing; @@ -95,7 +95,7 @@ DtxWorkRecord* DtxManager::getWork(const std::string& xid) if (i == work.end()) { throw InvalidArgumentException(QPID_MSG("Unrecognised xid " << xid)); } - return get_pointer(i); + return ptr_map_ptr(i); } void DtxManager::remove(const std::string& xid) @@ -116,7 +116,7 @@ DtxWorkRecord* DtxManager::createWork(std::string xid) if (i != work.end()) { throw CommandInvalidException(QPID_MSG("Xid " << xid << " is already known (use 'join' to add work to an existing xid)")); } else { - return get_pointer(work.insert(xid, new DtxWorkRecord(xid, store)).first); + return ptr_map_ptr(work.insert(xid, new DtxWorkRecord(xid, store)).first); } } @@ -147,7 +147,7 @@ void DtxManager::timedout(const std::string& xid) if (i == work.end()) { QPID_LOG(warning, "Transaction timeout failed: no record for xid"); } else { - get_pointer(i)->timedout(); + ptr_map_ptr(i)->timedout(); //TODO: do we want to have a timed task to cleanup, or can we rely on an explicit completion? //timer.add(intrusive_ptr(new DtxCleanup(60*30/*30 mins*/, *this, xid))); } diff --git a/cpp/src/qpid/broker/PreviewConnection.cpp b/cpp/src/qpid/broker/PreviewConnection.cpp index ad4497b24e..2643c85824 100644 --- a/cpp/src/qpid/broker/PreviewConnection.cpp +++ b/cpp/src/qpid/broker/PreviewConnection.cpp @@ -40,7 +40,7 @@ using namespace boost; using namespace qpid::sys; using namespace qpid::framing; using namespace qpid::sys; -using namespace qpid::ptr_map; +using qpid::ptr_map_ptr; using qpid::management::ManagementAgent; using qpid::management::ManagementObject; using qpid::management::Manageable; @@ -139,7 +139,7 @@ void PreviewConnection::idleIn(){} void PreviewConnection::closed(){ // Physically closed, suspend open sessions. try { for (ChannelMap::iterator i = channels.begin(); i != channels.end(); ++i) - get_pointer(i)->localSuspend(); + ptr_map_ptr(i)->localSuspend(); while (!exclusiveQueues.empty()) { Queue::shared_ptr q(exclusiveQueues.front()); q->releaseExclusiveOwnership(); @@ -183,7 +183,7 @@ PreviewSessionHandler& PreviewConnection::getChannel(ChannelId id) { if (i == channels.end()) { i = channels.insert(id, new PreviewSessionHandler(*this, id)).first; } - return *get_pointer(i); + return *ptr_map_ptr(i); } ManagementObject::shared_ptr PreviewConnection::GetManagementObject (void) const diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp index c2f6e3c307..2c2d099fb1 100644 --- a/cpp/src/qpid/broker/SemanticState.cpp +++ b/cpp/src/qpid/broker/SemanticState.cpp @@ -58,7 +58,7 @@ using boost::intrusive_ptr; using namespace qpid::broker; using namespace qpid::framing; using namespace qpid::sys; -using namespace qpid::ptr_map; +using qpid::ptr_map_ptr; SemanticState::SemanticState(DeliveryAdapter& da, SessionContext& ss) : session(ss), @@ -77,7 +77,7 @@ SemanticState::SemanticState(DeliveryAdapter& da, SessionContext& ss) SemanticState::~SemanticState() { //cancel all consumers for (ConsumerImplMap::iterator i = consumers.begin(); i != consumers.end(); i++) { - cancel(*get_pointer(i)); + cancel(*ptr_map_ptr(i)); } if (dtxBuffer.get()) { @@ -105,7 +105,7 @@ void SemanticState::consume(DeliveryToken::shared_ptr token, string& tagInOut, void SemanticState::cancel(const string& tag){ ConsumerImplMap::iterator i = consumers.find(tag); if (i != consumers.end()) { - cancel(*get_pointer(i)); + cancel(*ptr_map_ptr(i)); consumers.erase(i); //should cancel all unacked messages for this consumer so that //they are not redelivered on recovery @@ -429,7 +429,7 @@ void SemanticState::ack(DeliveryId first, DeliveryId last, bool cumulative) void SemanticState::requestDispatch() { for (ConsumerImplMap::iterator i = consumers.begin(); i != consumers.end(); i++) { - requestDispatch(*get_pointer(i)); + requestDispatch(*ptr_map_ptr(i)); } } @@ -445,7 +445,7 @@ void SemanticState::complete(DeliveryRecord& delivery) delivery.subtractFrom(outstanding); ConsumerImplMap::iterator i = consumers.find(delivery.getTag()); if (i != consumers.end()) { - get_pointer(i)->complete(delivery); + ptr_map_ptr(i)->complete(delivery); } } @@ -514,7 +514,7 @@ SemanticState::ConsumerImpl& SemanticState::find(const std::string& destination) if (i == consumers.end()) { throw NotFoundException(QPID_MSG("Unknown destination " << destination)); } else { - return *get_pointer(i); + return *ptr_map_ptr(i); } } -- cgit v1.2.1