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:20 UTC

[10/10] mina git commit: Call closeNow() instead of close(true)

Call closeNow() instead of close(true)

Project: http://git-wip-us.apache.org/repos/asf/mina/repo
Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/5be12d6b
Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/5be12d6b
Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/5be12d6b

Branch: refs/heads/2.0
Commit: 5be12d6b67bd53bfc08b876edff48b9a9092da6d
Parents: 0aefa80
Author: Emmanuel L�charny <el...@symas.com>
Authored: Thu Aug 11 17:27:52 2016 +0200
Committer: Emmanuel L�charny <el...@symas.com>
Committed: Thu Aug 11 17:27:52 2016 +0200

----------------------------------------------------------------------
 .../org/apache/mina/core/polling/AbstractPollingIoProcessor.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mina/blob/5be12d6b/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 48604c8..c0f7ba8 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
@@ -767,7 +767,7 @@ public abstract class AbstractPollingIoProcessor<S extends AbstractIoSession> im
                         }
                     } catch (Exception e) {
                         scheduleRemove(session);
-                        session.close(true);
+                        session.closeNow();
                         IoFilterChain filterChain = session.getFilterChain();
                         filterChain.fireExceptionCaught(e);
                     }