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

1 files changed, 4 insertions, 1 deletions

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*/