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 <[email protected]>
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;