Fixed a couple bugs in IdleStateHandler, caused by blind copy and paste
This commit is contained in:
parent
c153fd5bd0
commit
5f2f072d69
@ -237,7 +237,7 @@ public class IdleStateHandler extends SimpleChannelUpstreamHandler
|
|||||||
writerIdleTimeout =
|
writerIdleTimeout =
|
||||||
timer.newTimeout(this, writerIdleTimeMillis, TimeUnit.MILLISECONDS);
|
timer.newTimeout(this, writerIdleTimeMillis, TimeUnit.MILLISECONDS);
|
||||||
try {
|
try {
|
||||||
channelIdle(ctx, IdleState.WRITER_IDLE, lastReadTime);
|
channelIdle(ctx, IdleState.WRITER_IDLE, lastWriteTime);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
fireExceptionCaught(ctx, t);
|
fireExceptionCaught(ctx, t);
|
||||||
}
|
}
|
||||||
@ -271,7 +271,7 @@ public class IdleStateHandler extends SimpleChannelUpstreamHandler
|
|||||||
allIdleTimeout =
|
allIdleTimeout =
|
||||||
timer.newTimeout(this, allIdleTimeMillis, TimeUnit.MILLISECONDS);
|
timer.newTimeout(this, allIdleTimeMillis, TimeUnit.MILLISECONDS);
|
||||||
try {
|
try {
|
||||||
channelIdle(ctx, IdleState.ALL_IDLE, lastReadTime);
|
channelIdle(ctx, IdleState.ALL_IDLE, lastIoTime);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
fireExceptionCaught(ctx, t);
|
fireExceptionCaught(ctx, t);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user