From f6f6916d3a631240f08f9d9fedf5c3b5f71883aa Mon Sep 17 00:00:00 2001
From: Alan Conway <aconway@apache.org>
Date: Tue, 10 Feb 2009 21:42:10 +0000
Subject: Fix cluster flow control bug: hang with large messages (>frame-max)
 and low --cluster-read-max.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743114 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/cluster/Decoder.h | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'cpp/src/qpid/cluster/Decoder.h')

diff --git a/cpp/src/qpid/cluster/Decoder.h b/cpp/src/qpid/cluster/Decoder.h
index dffd6c8f75..50f6afa491 100644
--- a/cpp/src/qpid/cluster/Decoder.h
+++ b/cpp/src/qpid/cluster/Decoder.h
@@ -30,6 +30,7 @@ namespace qpid {
 namespace cluster {
 
 class EventHeader;
+class ConnectionMap;
 
 /**
  * Holds a map of ConnectionDecoders. Decodes Events into EventFrames
@@ -42,7 +43,7 @@ class Decoder
   public:
     typedef boost::function<void(const EventFrame&)> Handler;
 
-    Decoder(const Handler& h);
+    Decoder(const Handler& h, ConnectionMap&);
 
     /** Takes EventHeader + data rather than Event so that the caller can
      * pass a pointer to connection data or a CPG buffer directly without copy.
@@ -56,7 +57,9 @@ class Decoder
     typedef boost::ptr_map<ConnectionId, ConnectionDecoder> Map;
     Handler handler;
     Map map;
+    ConnectionMap& connections;
 };
+
 }} // namespace qpid::cluster
 
 #endif  /*!QPID_CLUSTER_DECODER_H*/
-- 
cgit v1.2.1