cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject git commit: remove decompression code in CompressedSequentialWriter patch by dbrosius reviewed by jbellis for cassandra-6176
Date Wed, 09 Oct 2013 21:25:03 GMT
Updated Branches:
  refs/heads/cassandra-2.0 6fae7a650 -> 9644f0989


remove decompression code in CompressedSequentialWriter
patch by dbrosius reviewed by jbellis for cassandra-6176


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9644f098
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9644f098
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9644f098

Branch: refs/heads/cassandra-2.0
Commit: 9644f098967d6ba9154725148a383b3502ef62c2
Parents: 6fae7a6
Author: Dave Brosius <dbrosius@mebigfatguy.com>
Authored: Wed Oct 9 17:24:17 2013 -0400
Committer: Dave Brosius <dbrosius@mebigfatguy.com>
Committed: Wed Oct 9 17:24:17 2013 -0400

----------------------------------------------------------------------
 .../io/compress/CompressedSequentialWriter.java        | 13 -------------
 1 file changed, 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/9644f098/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java b/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
index 386eca5..da4307e 100644
--- a/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
+++ b/src/java/org/apache/cassandra/io/compress/CompressedSequentialWriter.java
@@ -21,7 +21,6 @@ import java.io.EOFException;
 import java.io.File;
 import java.io.IOException;
 import java.util.zip.Adler32;
-import java.util.zip.CRC32;
 import java.util.zip.Checksum;
 
 import org.apache.cassandra.io.FSReadError;
@@ -193,18 +192,6 @@ public class CompressedSequentialWriter extends SequentialWriter
         {
             out.seek(chunkOffset);
             out.readFully(compressed.buffer, 0, chunkSize);
-
-            int validBytes;
-            try
-            {
-                // decompress data chunk and store its length
-                validBytes = compressor.uncompress(compressed.buffer, 0, chunkSize, buffer,
0);
-            }
-            catch (IOException e)
-            {
-                throw new CorruptBlockException(getPath(), chunkOffset, chunkSize);
-            }
-
             checksum.update(compressed.buffer, 0, chunkSize);
 
             if (out.readInt() != (int) checksum.getValue())


Mime
View raw message