svn commit: r1157466 - /cassandra/trunk/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java

[jbellis]

Author: jbellis
Date: Sun Aug 14 05:01:23 2011
New Revision: 1157466

URL: http://svn.apache.org/viewvc?rev=1157466&view=rev
Log:
fix read->readFully bug
patch by Dave Brosius and jbellis for CASSANDRA-3033

Modified:
    
cassandra/trunk/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java

Modified: 
cassandra/trunk/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java?rev=1157466&r1=1157465&r2=1157466&view=diff
==============================================================================
--- 
cassandra/trunk/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
 (original)
+++ 
cassandra/trunk/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
 Sun Aug 14 05:01:23 2011
@@ -139,7 +139,7 @@ public class CompressedSequentialWriter 
         int chunkSize = (int) 
(metadataWriter.chunkOffsetBy(realMark.nextChunkIndex) - chunkOffset - 4);
 
         out.seek(chunkOffset);
-        out.read(compressed, 0, chunkSize);
+        out.readFully(compressed, 0, chunkSize);
 
         // decompress data chunk and store its length
         int validBytes = Snappy.rawUncompress(compressed, 0, chunkSize, 
buffer, 0);