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

Added missing exit condition

Browse Source
This commit is contained in:
Trustin Lee 2009-06-16 10:07:46 +00:00
parent 887e0b6de7
commit 575973863f
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/jboss/netty/handler/stream/ChunkedStream.java
View File

@ -85,8 +85,8 @@ public class ChunkedStream implements ChunkedInput {
return null; return null;
} }
int chunkSize = Math.min(this.chunkSize, in.available()); final int chunkSize = Math.min(this.chunkSize, in.available());
byte[] chunk = new byte[chunkSize]; final byte[] chunk = new byte[chunkSize];
int readBytes = 0; int readBytes = 0;
for (;;) { for (;;) {
int localReadBytes = in.read(chunk, readBytes, chunkSize - readBytes); int localReadBytes = in.read(chunk, readBytes, chunkSize - readBytes);
@ -95,6 +95,10 @@ public class ChunkedStream implements ChunkedInput {
} }
readBytes += localReadBytes; readBytes += localReadBytes;
offset += localReadBytes; offset += localReadBytes;
if (readBytes == chunkSize) {
break;
}
} }
return wrappedBuffer(chunk, 0, readBytes); return wrappedBuffer(chunk, 0, readBytes);