andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed a bug where AsynchronousCloseException causes IndexOutOfBoundsException during write

Browse Source
This commit is contained in:
Trustin Lee 2009-09-01 08:41:36 +00:00
parent 94a1633ec9
commit e0bef12e2c
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramWorker.java
View File

@ -539,7 +539,9 @@ class NioDatagramWorker implements Runnable {
} }
} catch (final AsynchronousCloseException e) { } catch (final AsynchronousCloseException e) {
// Doesn't need a user attention - ignore. // Doesn't need a user attention - ignore.
channel.currentWriteEvent = evt;
} catch (final Throwable t) { } catch (final Throwable t) {
channel.currentWriteEvent = null;
evt.getFuture().setFailure(t); evt.getFuture().setFailure(t);
evt = null; evt = null;
fireExceptionCaught(channel, t); fireExceptionCaught(channel, t);

4
src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java
View File

@ -454,13 +454,17 @@ class NioWorker implements Runnable {
} }
} catch (AsynchronousCloseException e) { } catch (AsynchronousCloseException e) {
// Doesn't need a user attention - ignore. // Doesn't need a user attention - ignore.
channel.currentWriteEvent = evt;
channel.currentWriteIndex = bufIdx;
} catch (Throwable t) { } catch (Throwable t) {
channel.currentWriteEvent = null;
evt.getFuture().setFailure(t); evt.getFuture().setFailure(t);
evt = null; evt = null;
fireExceptionCaught(channel, t); fireExceptionCaught(channel, t);
if (t instanceof IOException) { if (t instanceof IOException) {
open = false; open = false;
close(channel, succeededFuture(channel)); close(channel, succeededFuture(channel));
break;
} }
} }
} }