From 7cdb9a9ab688988e596d9fce116a0998decd0972 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Tue, 2 Dec 2008 20:41:49 +0000 Subject: Cluster: handle CPG flow-control conditions. PollableQueue: allow dispatch functions to refuse dispatch. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722614 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/Cluster.h | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/cluster/Cluster.h') diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h index 81feef4919..94f0c6a95f 100644 --- a/cpp/src/qpid/cluster/Cluster.h +++ b/cpp/src/qpid/cluster/Cluster.h @@ -118,6 +118,8 @@ class Cluster : private Cpg::Handler, public management::Manageable { void leave(Lock&); std::vector getUrls(Lock&) const; + bool sendMcast(const Event& e); + // Called via CPG, deliverQueue or DumpClient threads. void tryMakeOffer(const MemberId&, Lock&); @@ -133,7 +135,7 @@ class Cluster : private Cpg::Handler, public management::Manageable { void ready(const MemberId&, const std::string&, Lock&); void configChange(const MemberId&, const std::string& addresses, Lock& l); void shutdown(const MemberId&, Lock&); - void delivered(const Event&); // deliverQueue callback + bool delivered(const Event&); // deliverQueue callback void delivered(const Event&, Lock&); // unlocked version // CPG callbacks, called in CPG IO thread. @@ -183,7 +185,7 @@ class Cluster : private Cpg::Handler, public management::Manageable { broker::Broker& broker; boost::shared_ptr poller; Cpg cpg; - const Cpg::Name name; + const std::string name; const Url myUrl; const MemberId myId; -- cgit v1.2.1