This is an automated email from the ASF dual-hosted git repository.

johnnyv pushed a commit to branch bugfix/DIRMINA-1173
in repository https://gitbox.apache.org/repos/asf/mina.git


The following commit(s) were added to refs/heads/bugfix/DIRMINA-1173 by this 
push:
     new d393ad730 found one place where the UNACK was calculated wrong
d393ad730 is described below

commit d393ad730ab383a59251a1e0f4d229f744afeb95
Author: Jonathan Valliere <jon.valli...@emoten.com>
AuthorDate: Tue Feb 20 08:31:29 2024 -0500

    found one place where the UNACK was calculated wrong
---
 mina-core/src/main/java/org/apache/mina/filter/ssl/SSLHandlerG1.java | 2 +-
 1 file changed, 1 insertion(+), 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
index 80f52752b..7e2f9f6e9 100644
--- 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 @@ import java.util.concurrent.Executor;
 
         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);
             }

Reply via email to