summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/cluster/Cluster.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/Cluster.h')
-rw-r--r--qpid/cpp/src/qpid/cluster/Cluster.h10
1 files changed, 4 insertions, 6 deletions
diff --git a/qpid/cpp/src/qpid/cluster/Cluster.h b/qpid/cpp/src/qpid/cluster/Cluster.h
index eaa91202dc..0b56540f9a 100644
--- a/qpid/cpp/src/qpid/cluster/Cluster.h
+++ b/qpid/cpp/src/qpid/cluster/Cluster.h
@@ -62,10 +62,10 @@ class Cluster : private Cpg::Handler, public management::Manageable
virtual ~Cluster();
- void insert(const boost::intrusive_ptr<Connection>&); // Insert a local connection
- void erase(ConnectionId); // Erase a connection.
-
- void catchUpClosed(const boost::intrusive_ptr<Connection>&); // Insert a local connection
+ // FIXME aconway 2008-09-26: thread safety
+ void insert(const boost::intrusive_ptr<Connection>&);
+ void erase(ConnectionId);
+ void dumpComplete();
/** Get the URLs of current cluster members. */
std::vector<Url> getUrls() const;
@@ -94,8 +94,6 @@ class Cluster : private Cpg::Handler, public management::Manageable
broker::Broker& getBroker();
- void setDumpComplete();
-
template <class F> void eachConnection(const F& f) {
for (ConnectionMap::const_iterator i = connections.begin(); i != connections.end(); ++i)
f(i->second);