summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Connection.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-04-29 20:29:53 +0000
committerAlan Conway <aconway@apache.org>2009-04-29 20:29:53 +0000
commitbf70c3a435b5198e48cd83f692796bd47e253df1 (patch)
tree1f67175547e8f847220f9f01ca9993e0b45ff592 /cpp/src/qpid/cluster/Connection.cpp
parent0ea393c49936c4647547199859961c4203a25cb3 (diff)
downloadqpid-python-bf70c3a435b5198e48cd83f692796bd47e253df1.tar.gz
Improved & simplified cluster output algorithm.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@769914 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.cpp')
-rw-r--r--cpp/src/qpid/cluster/Connection.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp
index 97cafbabaa..c107552905 100644
--- a/cpp/src/qpid/cluster/Connection.cpp
+++ b/cpp/src/qpid/cluster/Connection.cpp
@@ -89,7 +89,7 @@ void Connection::init() {
if (isLocalClient()) {
connection.setClusterOrderOutput(mcastFrameHandler); // Actively send cluster-order frames from local node
cluster.addLocalConnection(this);
- giveReadCredit(cluster.getReadMax());
+ giveReadCredit(cluster.getSettings().readMax);
}
else { // Shadow or catch-up connection
connection.setClusterOrderOutput(nullFrameHandler); // Passive, discard cluster-order frames
@@ -100,7 +100,7 @@ void Connection::init() {
}
void Connection::giveReadCredit(int credit) {
- if (cluster.getReadMax() && credit)
+ if (cluster.getSettings().readMax && credit)
output.giveReadCredit(credit);
}