natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add assert that repair keys arrive in-order 

patch by jbellis; reviewed by stuhood for CASSANDRA-2316

git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@1094809 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2011-04-18 22:57:57 +00:00
parent d951f52538
commit f5b030a657
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/java/org/apache/cassandra/service/AntiEntropyService.java
View File

@ -272,6 +272,7 @@ public class AntiEntropyService
private transient long validated;
private transient MerkleTree.TreeRange range;
private transient MerkleTree.TreeRangeIterator ranges;
private transient DecoratedKey lastKey;
public final static MerkleTree.RowHash EMPTY_ROW = new MerkleTree.RowHash(null, new byte[0]);
@ -342,6 +343,10 @@ public class AntiEntropyService
*/
public void add(AbstractCompactedRow row)
{
assert lastKey == null || lastKey.compareTo(row.key) < 0
: "row " + row.key + " received out of order wrt " + lastKey;
lastKey = row.key;
if (mintoken != null)
{
assert ranges != null : "Validator was not prepared()";