tyler.durden/snappy-java
1
0
Fork 0
mirror of https://github.com/xerial/snappy-java.git synced 2025-07-01 19:24:32 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fixes issue 23

Browse Source
This commit is contained in:
Taro L. Saito 2011-07-04 09:26:30 +09:00
parent 36f0208eb1
commit c675bf4280
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/xerial/snappy/SnappyInputStream.java
View File

@ -170,7 +170,13 @@ public class SnappyInputStream extends InputStream
if (compressed == null || chunkSize > compressed.length) { if (compressed == null || chunkSize > compressed.length) {
compressed = new byte[chunkSize]; compressed = new byte[chunkSize];
} }
int readBytes = in.read(compressed, 0, chunkSize); int readBytes = 0;
while (readBytes < chunkSize) {
int ret = in.read(compressed, readBytes, chunkSize - readBytes);
if (ret == -1)
break;
readBytes += ret;
}
if (readBytes < chunkSize) { if (readBytes < chunkSize) {
throw new IOException("failed to read chunk"); throw new IOException("failed to read chunk");
} }