diff options
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/Cluster.h')
-rw-r--r-- | qpid/cpp/src/qpid/cluster/Cluster.h | 10 |
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); |