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

avoid anti-entropy checks on the System table. patch by Stu Hood; reviewed by jbellis for CASSANDRA-616 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@888710 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2009-12-09 06:32:37 +00:00
parent d267cf77bd
commit 5b86c3dc00
1 changed files with 3 additions and 2 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

@ -273,12 +273,13 @@ public class AntiEntropyService
* *
* @param table The table name containing the column family. * @param table The table name containing the column family.
* @param cf The column family name. * @param cf The column family name.
* @param initiator Endpoint that initially triggered this validation, or null. * @param initiator Endpoint that initially triggered this validation, or null if
* the validation will not see all of the data contained in the column family.
* @return A Validator. * @return A Validator.
*/ */
public IValidator getValidator(String table, String cf, InetAddress initiator) public IValidator getValidator(String table, String cf, InetAddress initiator)
{ {
if (initiator == null) if (initiator == null || table.equals(Table.SYSTEM_TABLE))
return new NoopValidator(); return new NoopValidator();
else if (StorageService.instance().getTokenMetadata().sortedTokens().size() < 1) else if (StorageService.instance().getTokenMetadata().sortedTokens().size() < 1)
// gossiper isn't started // gossiper isn't started