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 e407aa9  Backported a fix for 2.1 (Fixes bug in TailFilter which 
triggers the connect future on created)
e407aa9 is described below

commit e407aa94427d9bf34c547850527eb07a632e8056
Author: emmanuel lecharny <elecha...@apache.org>
AuthorDate: Tue Feb 8 18:41:25 2022 +0100

    Backported a fix for 2.1 (Fixes bug in TailFilter which triggers the
    connect future on created)
---
 .../apache/mina/core/filterchain/DefaultIoFilterChain.java   | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/mina-core/src/main/java/org/apache/mina/core/filterchain/DefaultIoFilterChain.java
 
b/mina-core/src/main/java/org/apache/mina/core/filterchain/DefaultIoFilterChain.java
index ee17646..f2f665f 100644
--- 
a/mina-core/src/main/java/org/apache/mina/core/filterchain/DefaultIoFilterChain.java
+++ 
b/mina-core/src/main/java/org/apache/mina/core/filterchain/DefaultIoFilterChain.java
@@ -913,8 +913,13 @@ public void fireFilterWrite(WriteRequest writeRequest) {
     private static class TailFilter extends IoFilterAdapter {
         @Override
         public void sessionCreated(NextFilter nextFilter, IoSession session) 
throws Exception {
+            session.getHandler().sessionCreated(session);
+        }
+
+        @Override
+        public void sessionOpened(NextFilter nextFilter, IoSession session) 
throws Exception {
             try {
-                session.getHandler().sessionCreated(session);
+                session.getHandler().sessionOpened(session);
             } finally {
                 // Notify the related future.
                 ConnectFuture future = (ConnectFuture) 
session.removeAttribute(SESSION_CREATED_FUTURE);
@@ -926,11 +931,6 @@ public void fireFilterWrite(WriteRequest writeRequest) {
         }
 
         @Override
-        public void sessionOpened(NextFilter nextFilter, IoSession session) 
throws Exception {
-            session.getHandler().sessionOpened(session);
-        }
-
-        @Override
         public void sessionClosed(NextFilter nextFilter, IoSession session) 
throws Exception {
             AbstractIoSession s = (AbstractIoSession) session;
 

Reply via email to