From 0c4e91133e5012cd480d5fa2115bcef4ce0635dd Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Fri, 13 Jun 2008 12:24:10 +0000
Subject: QPID-901: flush after every 64K commands issued

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@667501 13f79535-47bb-0310-9956-ffa450edef68
---
 .../common/src/main/java/org/apache/qpidity/transport/Session.java | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'qpid/java')

diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
index 7c6b7daf85..e0bdcf789e 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
+++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
@@ -270,6 +270,13 @@ public class Session extends Invoker
                 {
                     sync();
                 }
+
+                // flush every 64K commands to avoid ambiguity on
+                // wraparound
+                if ((next % 65536) == 0)
+                {
+                    sessionFlush(COMPLETED);
+                }
             }
         }
         else
-- 
cgit v1.2.1