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 2015/12/04 23:42:53 UTC
[3/5] mina git commit: Close the session when an exception is caught
while flushing the session.
Close the session when an exception is caught while flushing the
session.
Project: http://git-wip-us.apache.org/repos/asf/mina/repo
Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/40634db1
Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/40634db1
Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/40634db1
Branch: refs/heads/2.0
Commit: 40634db13455f4dffa781875285455004ff343a4
Parents: 1407818
Author: Emmanuel Lécharny <el...@symas.com>
Authored: Fri Dec 4 23:06:08 2015 +0100
Committer: Emmanuel Lécharny <el...@symas.com>
Committed: Fri Dec 4 23:06:08 2015 +0100
----------------------------------------------------------------------
.../org/apache/mina/core/polling/AbstractPollingIoProcessor.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mina/blob/40634db1/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
----------------------------------------------------------------------
diff --git a/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java b/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
index ad9ae5d..e6b141c 100644
--- a/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
+++ b/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
@@ -788,6 +788,7 @@ public abstract class AbstractPollingIoProcessor<S extends AbstractIoSession> im
}
} catch (Exception e) {
scheduleRemove(session);
+ session.close(true);
IoFilterChain filterChain = session.getFilterChain();
filterChain.fireExceptionCaught(e);
}