You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by el...@apache.org on 2022/02/08 01:29:23 UTC
[mina] branch 2.0.X updated: Backorted JonV patch
This is an automated email from the ASF dual-hosted git repository.
elecharny pushed a commit to branch 2.0.X
in repository https://gitbox.apache.org/repos/asf/mina.git
The following commit(s) were added to refs/heads/2.0.X by this push:
new 4256b47 Backorted JonV patch
4256b47 is described below
commit 4256b47a14de5b38342a5ab9612ecc760c38b817
Author: emmanuel lecharny <el...@apache.org>
AuthorDate: Tue Feb 8 02:29:13 2022 +0100
Backorted JonV patch
---
.../src/main/java/org/apache/mina/filter/ssl/SslHandler.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/mina-core/src/main/java/org/apache/mina/filter/ssl/SslHandler.java b/mina-core/src/main/java/org/apache/mina/filter/ssl/SslHandler.java
index 1eaac9e..82ba849 100644
--- a/mina-core/src/main/java/org/apache/mina/filter/ssl/SslHandler.java
+++ b/mina-core/src/main/java/org/apache/mina/filter/ssl/SslHandler.java
@@ -41,6 +41,7 @@ import org.apache.mina.core.session.IoEventType;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.core.write.DefaultWriteRequest;
import org.apache.mina.core.write.WriteRequest;
+import org.apache.mina.core.write.WriteRequestQueue;
import org.apache.mina.filter.ssl.SslFilter.EncryptedWriteRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -525,9 +526,11 @@ class SslHandler {
}
// Empty the session queue
- while (!session.getWriteRequestQueue().isEmpty(session)) {
- WriteRequest writeRequest = session.getWriteRequestQueue().poll( session );
- WriteFuture writeFuture = writeRequest.getFuture();
+ WriteRequestQueue queue = session.getWriteRequestQueue();
+ WriteRequest request = null;
+
+ while ((request = queue.poll(session)) != null) {
+ WriteFuture writeFuture = request.getFuture();
writeFuture.setException(exception);
writeFuture.notifyAll();
}