Repository: mina
Updated Branches:
  refs/heads/2.0 6585bf997 -> 7696c3410


Propagated the inputClose() event through SslFilter, destroying the SslHandler


Project: http://git-wip-us.apache.org/repos/asf/mina/repo
Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/4c628312
Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/4c628312
Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/4c628312

Branch: refs/heads/2.0
Commit: 4c628312b6d769ae96b5f391c904ef195d8d6aae
Parents: 6585bf9
Author: Emmanuel Lécharny <[email protected]>
Authored: Fri May 25 20:54:00 2018 +0200
Committer: Emmanuel Lécharny <[email protected]>
Committed: Fri May 25 20:54:00 2018 +0200

----------------------------------------------------------------------
 .../java/org/apache/mina/filter/ssl/SslFilter.java | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mina/blob/4c628312/mina-core/src/main/java/org/apache/mina/filter/ssl/SslFilter.java
----------------------------------------------------------------------
diff --git a/mina-core/src/main/java/org/apache/mina/filter/ssl/SslFilter.java 
b/mina-core/src/main/java/org/apache/mina/filter/ssl/SslFilter.java
index 060ccc0..b2f8ac8 100644
--- a/mina-core/src/main/java/org/apache/mina/filter/ssl/SslFilter.java
+++ b/mina-core/src/main/java/org/apache/mina/filter/ssl/SslFilter.java
@@ -488,6 +488,23 @@ public class SslFilter extends IoFilterAdapter {
             nextFilter.sessionClosed(session);
         }
     }
+    
+    
+    @Override
+    public void inputClosed(NextFilter nextFilter, IoSession session) throws 
Exception {
+        SslHandler sslHandler = getSslSessionHandler(session);
+
+        try {
+            synchronized (sslHandler) {
+                // release resources
+                sslHandler.destroy();
+            }
+        } finally {
+            // notify closed session
+            nextFilter.inputClosed(session);
+        }
+    }
+
 
     @Override
     public void messageReceived(NextFilter nextFilter, IoSession session, 
Object message) throws SSLException {

Reply via email to