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 2019/02/22 09:54:26 UTC
[mina] 02/03: Ported some more 2.0.20 changes
This is an automated email from the ASF dual-hosted git repository.
elecharny pushed a commit to branch 2.1.0
in repository https://gitbox.apache.org/repos/asf/mina.git
commit 724dfd497fd8ca07b368133bdca6d8ed8acac0c2
Author: emmanuel lecharny <el...@apache.org>
AuthorDate: Fri Feb 22 10:33:25 2019 +0100
Ported some more 2.0.20 changes
---
.../java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 78807ee..5fe4ca1 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
@@ -1157,7 +1157,6 @@ public abstract class AbstractPollingIoProcessor<S extends AbstractIoSession> im
filterChain.fireExceptionCaught(e);
} finally {
try {
- clearWriteRequestQueue(session);
((AbstractIoService) session.getService()).getListeners().fireSessionDestroyed(session);
} catch (Exception e) {
// The session was either destroyed or not at this point.
@@ -1166,6 +1165,8 @@ public abstract class AbstractPollingIoProcessor<S extends AbstractIoSession> im
// the return value by bubbling up.
IoFilterChain filterChain = session.getFilterChain();
filterChain.fireExceptionCaught(e);
+ } finally {
+ clearWriteRequestQueue(session);
}
}