Skip to content

Commit

Permalink
perform repair even for small entropy differences. patch by Stu Hood;…
Browse files Browse the repository at this point in the history
… reviewed by jbellis for CASSANDRA-924

git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.6@930961 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
jbellis committed Apr 5, 2010
1 parent 45c6d33 commit 80b538e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 16 deletions.
1 change: 1 addition & 0 deletions CHANGES.txt
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
* fix race condition that could trigger a false-positive assertion
during post-flush discard of old commitlog segments (CASSANDRA-936)
* fix neighbor calculation for anti-entropy repair (CASSANDRA-924)
* perform repair even for small entropy differences (CASSANDRA-924)


0.6.0-RC1
Expand Down
18 changes: 2 additions & 16 deletions src/java/org/apache/cassandra/service/AntiEntropyService.java
Original file line number Diff line number Diff line change
Expand Up @@ -589,11 +589,8 @@ public void run()
logger.debug("Endpoints " + local + " and " + remote + " are consistent for " + cf);
return;
}

if (difference < 0.05)
performRangeRepair();
else
performStreamingRepair();

performStreamingRepair();
}
catch(IOException e)
{
Expand All @@ -613,17 +610,6 @@ float differenceFraction()
return (float)fraction;
}

/**
* Sends our list of differences to the remote endpoint using read
* repairs via the query API.
*/
void performRangeRepair() throws IOException
{
logger.info("Performing range read repair of " + differences.size() + " ranges for " + cf);
// FIXME
logger.debug("Finished range read repair for " + cf);
}

/**
* Sends our list of differences to the remote endpoint using the
* Streaming API.
Expand Down

0 comments on commit 80b538e

Please sign in to comment.