You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jo...@apache.org on 2021/08/02 03:40:51 UTC
[mina] 06/15: Fixes bug in TailFilter which triggers the connect
future on created instead of opened.
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 <jo...@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 {