You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by el...@apache.org on 2016/08/11 15:28:12 UTC
[02/10] mina git commit: No need to call session.closeNow() if the
session is currently being closed
No need to call session.closeNow() if the session is currently being closed
Project: http://git-wip-us.apache.org/repos/asf/mina/repo
Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/3b6c4464
Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/3b6c4464
Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/3b6c4464
Branch: refs/heads/2.0
Commit: 3b6c44642bdd07b2fb6b40015b62d7c6b5450dea
Parents: f119ff1
Author: Emmanuel L�charny <el...@symas.com>
Authored: Sun Jul 24 21:30:18 2016 +0200
Committer: Emmanuel L�charny <el...@symas.com>
Committed: Sun Jul 24 21:30:18 2016 +0200
----------------------------------------------------------------------
.../org/apache/mina/core/filterchain/DefaultIoFilterChain.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mina/blob/3b6c4464/mina-core/src/main/java/org/apache/mina/core/filterchain/DefaultIoFilterChain.java
----------------------------------------------------------------------
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 2d301c5..a843a74 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
@@ -594,7 +594,11 @@ public class DefaultIoFilterChain implements IoFilterChain {
} else {
// Please note that this place is not the only place that
// calls ConnectFuture.setException().
- session.close(true);
+ if (!session.isClosing()) {
+ // Call the closeNow method only if needed
+ session.closeNow();
+ }
+
future.setException(cause);
}
}