You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2012/12/07 22:44:14 UTC

[12/14] git commit: ninja relocate crc_check_chance removal from options list

ninja relocate crc_check_chance removal from options list


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

Branch: refs/heads/trunk
Commit: b49ca58b2a7fb272e21dd2acd00996483a36ddcc
Parents: 0934bff
Author: Jake Luciani <jl...@bluemountaincapital.com>
Authored: Fri Dec 7 12:50:49 2012 -0500
Committer: Jake Luciani <jl...@bluemountaincapital.com>
Committed: Fri Dec 7 12:57:33 2012 -0500

----------------------------------------------------------------------
 .../io/compress/CompressionParameters.java         |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/b49ca58b/src/java/org/apache/cassandra/io/compress/CompressionParameters.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/compress/CompressionParameters.java b/src/java/org/apache/cassandra/io/compress/CompressionParameters.java
index df077ac..93e150f 100644
--- a/src/java/org/apache/cassandra/io/compress/CompressionParameters.java
+++ b/src/java/org/apache/cassandra/io/compress/CompressionParameters.java
@@ -56,7 +56,6 @@ public class CompressionParameters
         String chunkLength = options.get(CHUNK_LENGTH_KB);
         options.remove(SSTABLE_COMPRESSION);
         options.remove(CHUNK_LENGTH_KB);
-        options.remove(CRC_CHECK_CHANCE);
         CompressionParameters cp = new CompressionParameters(sstableCompressionClass, parseChunkLength(chunkLength), options);
         cp.validate();
         return cp;
@@ -78,6 +77,7 @@ public class CompressionParameters
         this.chunkLength = chunkLength;
         this.otherOptions = otherOptions;
         String chance = otherOptions.get(CRC_CHECK_CHANCE);
+        otherOptions.remove(CRC_CHECK_CHANCE);
         this.crcChance = (chance == null) ? DEFAULT_CRC_CHECK_CHANCE : Double.parseDouble(chance);
     }