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); }