From 85021877a773ca361d90ebfce5d9ff0994d50378 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 19 Sep 2008 12:55:15 +0000 Subject: Clean up unused members/tests qpid/broker/SemanticState.h,.cpp,SessionState.h: removed unused members. tests/DumpClientTest.cpp: unused, remove. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@697075 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/SemanticState.h | 1 - cpp/src/qpid/broker/SessionState.cpp | 2 -- cpp/src/qpid/broker/SessionState.h | 1 - cpp/src/qpid/cluster/Cluster.h | 8 ++++++++ 4 files changed, 8 insertions(+), 4 deletions(-) (limited to 'cpp/src/qpid') diff --git a/cpp/src/qpid/broker/SemanticState.h b/cpp/src/qpid/broker/SemanticState.h index 1d32d8aa50..e2dd4af95b 100644 --- a/cpp/src/qpid/broker/SemanticState.h +++ b/cpp/src/qpid/broker/SemanticState.h @@ -114,7 +114,6 @@ class SemanticState : public sys::OutputTask, SessionContext& session; DeliveryAdapter& deliveryAdapter; - Queue::shared_ptr defaultQueue; ConsumerImplMap consumers; uint32_t prefetchSize; uint16_t prefetchCount; diff --git a/cpp/src/qpid/broker/SessionState.cpp b/cpp/src/qpid/broker/SessionState.cpp index d0e75849d8..6358bd2145 100644 --- a/cpp/src/qpid/broker/SessionState.cpp +++ b/cpp/src/qpid/broker/SessionState.cpp @@ -50,7 +50,6 @@ SessionState::SessionState( Broker& b, SessionHandler& h, const SessionId& id, const SessionState::Configuration& config) : qpid::SessionState(id, config), broker(b), handler(&h), - ignoring(false), semanticState(*this, *this), adapter(semanticState), msgBuilder(&broker.getStore(), broker.getStagingThreshold()), @@ -237,7 +236,6 @@ void SessionState::handleIn(AMQFrame& frame) { } else { getProxy().getExecution().exception(e.code, commandId, 0, 0, 0, e.what(), FieldTable()); } - ignoring = true; handler->sendDetach(); } } diff --git a/cpp/src/qpid/broker/SessionState.h b/cpp/src/qpid/broker/SessionState.h index e424559228..5dd57d2299 100644 --- a/cpp/src/qpid/broker/SessionState.h +++ b/cpp/src/qpid/broker/SessionState.h @@ -116,7 +116,6 @@ class SessionState : public qpid::SessionState, Broker& broker; SessionHandler* handler; sys::AbsTime expiry; // Used by SessionManager. - bool ignoring; SemanticState semanticState; SessionAdapter adapter; MessageBuilder msgBuilder; diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h index aa077ef63c..c63e2e3e58 100644 --- a/cpp/src/qpid/cluster/Cluster.h +++ b/cpp/src/qpid/cluster/Cluster.h @@ -34,8 +34,11 @@ #include "qmf/org/apache/qpid/cluster/Cluster.h" #include +#include +#include #include +#include namespace qpid { namespace cluster { @@ -93,6 +96,11 @@ class Cluster : private Cpg::Handler, public management::Manageable broker::Broker& getBroker(); void setDumpComplete(); + + template void eachConnection(const F& f) { + std::for_each(connections.begin(), connections.end(), + boost::bind(f, boost::bind(&ConnectionMap::value_type::second, _1))); + } private: typedef std::map > ConnectionMap; -- cgit v1.2.1