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;