summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Cluster.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-12-08 17:16:37 +0000
committerAlan Conway <aconway@apache.org>2008-12-08 17:16:37 +0000
commitaa2cd60dd1a77bfe34dc8bc71a609eb263d260f5 (patch)
treed331508d61d23aea745589d643fac7c1099c5252 /cpp/src/qpid/cluster/Cluster.h
parentf921058bfebf0ab27d6cfc18f9aea5b06ce80c22 (diff)
downloadqpid-python-aa2cd60dd1a77bfe34dc8bc71a609eb263d260f5.tar.gz
Cluster: reduced scope of mcast locks.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724413 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.h')
-rw-r--r--cpp/src/qpid/cluster/Cluster.h9
1 files changed, 3 insertions, 6 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h
index 14df4db905..2ab2da6fa8 100644
--- a/cpp/src/qpid/cluster/Cluster.h
+++ b/cpp/src/qpid/cluster/Cluster.h
@@ -79,7 +79,6 @@ class Cluster : private Cpg::Handler, public management::Manageable {
// Send to the cluster
void mcastControl(const framing::AMQBody& controlBody, const ConnectionId&, uint32_t id);
void mcastBuffer(const char*, size_t, const ConnectionId&, uint32_t id);
- void mcast(const Event& e);
// URLs of current cluster members.
std::vector<Url> getUrls() const;
@@ -110,11 +109,9 @@ class Cluster : private Cpg::Handler, public management::Manageable {
// The parameter makes it hard to forget since you have to have an instance of
// a Lock to call the unlocked functions.
- // Unlocked versions of public functions
- void mcastControl(const framing::AMQBody& controlBody, const ConnectionId&, uint32_t, Lock&);
- void mcastControl(const framing::AMQBody& controlBody, Lock&);
- void mcastBuffer(const char*, size_t, const ConnectionId&, uint32_t id, Lock&);
- void mcast(const Event& e, Lock&);
+ void mcastControl(const framing::AMQBody& controlBody);
+ void mcast(const Event& e);
+
void leave(Lock&);
std::vector<Url> getUrls(Lock&) const;