found one place where the UNACK was calculated wrong

apache · Feb 20, 2024 · d393ad7 · d393ad7
1 parent ec93bb7
commit d393ad7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mina-core/src/main/java/org/apache/mina/filter/ssl/SSLHandlerG1.java b/mina-core/src/main/java/org/apache/mina/filter/ssl/SSLHandlerG1.java
@@ -651,7 +651,7 @@ synchronized protected void flush_start(NextFilter next) throws SSLException {
 
         WriteRequest current = null;
 
-        while ((mAckQueue.size() < MAX_UNACK_MESSAGES) && (current = mEncodeQueue.poll()) != null) {
+        while ((mWriteQueue.size() + mAckQueue.size() < MAX_UNACK_MESSAGES) && (current = mEncodeQueue.poll()) != null) {
             if (LOGGER.isDebugEnabled()) {
                 LOGGER.debug("{} flush() - {}", toString(), current);
             }