[prev in list] [next in list] [prev in thread] [next in thread] 

List:       mina-commits
Subject:    (mina) branch bugfix/DIRMINA-1173 updated: found one place where the UNACK was calculated wrong
From:       johnnyv () apache ! org
Date:       2024-02-20 13:31:37
Message-ID: 170843589726.1091719.16698506581974467545 () gitbox2-he-fi ! apache ! org
[Download RAW message or body]

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.valliere@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);
             }


[prev in list] [next in list] [prev in thread] [next in thread]