[mina] 06/15: Fixes bug in TailFilter which triggers the connect future on created instead of opened.

[johnnyv]

This is an automated email from the ASF dual-hosted git repository.

johnnyv pushed a commit to branch bugfix/DIRMINA1132
in repository https://gitbox.apache.org/repos/asf/mina.git

commit b817f0282ded3046ae9c3cc886800df88a2583be
Author: Jonathan Valliere <jon.valli...@emoten.com>
AuthorDate: Sat Jul 24 11:59:02 2021 -0400

    Fixes bug in TailFilter which triggers the connect future on created
    instead of opened.
---
 .../core/filterchain/DefaultIoFilterChain.java     | 34 +++++++++++-----------
 1 file changed, 17 insertions(+), 17 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 ddaf36c..45bc877 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
@@ -930,23 +930,23 @@ public class DefaultIoFilterChain implements 
IoFilterChain {
 
     private static class TailFilter extends IoFilterAdapter {
         @Override
-        public void sessionCreated(NextFilter nextFilter, IoSession session) 
throws Exception {
-            try {
-                session.getHandler().sessionCreated(session);
-            } finally {
-                // Notify the related future.
-                ConnectFuture future = (ConnectFuture) 
session.removeAttribute(SESSION_CREATED_FUTURE);
-
-                if (future != null) {
-                    future.setSession(session);
-                }
-            }
-        }
-
-        @Override
-        public void sessionOpened(NextFilter nextFilter, IoSession session) 
throws Exception {
-            session.getHandler().sessionOpened(session);
-        }
+               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().sessionOpened(session);
+                       } finally {
+                               // Notify the related future.
+                               ConnectFuture future = (ConnectFuture) 
session.removeAttribute(SESSION_CREATED_FUTURE);
+
+                               if (future != null) {
+                                       future.setSession(session);
+                               }
+                       }
+               }
 
         @Override
         public void sessionClosed(NextFilter nextFilter, IoSession session) 
throws Exception {