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

For an unknown reason a different exception is raised in NioWorker.read()

Browse Source
This commit is contained in:
Trustin Lee 2010-01-28 03:24:09 +00:00
parent e9b8f6b2d7
commit c8d5f1ab4a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -313,7 +313,7 @@ class NioWorker implements Runnable {
ChannelBuffer buffer = ChannelBuffer buffer =
bufferFactory.getBuffer(predictor.nextReceiveBufferSize()); bufferFactory.getBuffer(predictor.nextReceiveBufferSize());
final ByteBuffer directBuffer; final ByteBuffer directBuffer;
final boolean fromPool; final boolean fromPool;
if (buffer.isDirect()) { if (buffer.isDirect()) {
@ -323,7 +323,7 @@ class NioWorker implements Runnable {
directBuffer = directBufferPool.acquire(buffer.writableBytes()); directBuffer = directBufferPool.acquire(buffer.writableBytes());
fromPool = true; fromPool = true;
} }
int ret = 0; int ret = 0;
int readBytes = 0; int readBytes = 0;
boolean failure = true; boolean failure = true;
@ -337,7 +337,7 @@ class NioWorker implements Runnable {
directBuffer.flip(); directBuffer.flip();
buffer.writeBytes(directBuffer); buffer.writeBytes(directBuffer);
failure = false; failure = false;
} catch (AsynchronousCloseException e) { } catch (ClosedChannelException e) {
// Can happen, and does not need a user attention. // Can happen, and does not need a user attention.
} catch (Throwable t) { } catch (Throwable t) {
fireExceptionCaught(channel, t); fireExceptionCaught(channel, t);