You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2009/12/09 07:32:38 UTC
svn commit: r888710 -
/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/AntiEntropyService.java
Author: jbellis
Date: Wed Dec 9 06:32:37 2009
New Revision: 888710
URL: http://svn.apache.org/viewvc?rev=888710&view=rev
Log:
avoid anti-entropy checks on the System table. patch by Stu Hood; reviewed by jbellis for CASSANDRA-616
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/AntiEntropyService.java
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/service/AntiEntropyService.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/AntiEntropyService.java?rev=888710&r1=888709&r2=888710&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/service/AntiEntropyService.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/service/AntiEntropyService.java Wed Dec 9 06:32:37 2009
@@ -273,12 +273,13 @@
*
* @param table The table name containing the column family.
* @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.
*/
public IValidator getValidator(String table, String cf, InetAddress initiator)
{
- if (initiator == null)
+ if (initiator == null || table.equals(Table.SYSTEM_TABLE))
return new NoopValidator();
else if (StorageService.instance().getTokenMetadata().sortedTokens().size() < 1)
// gossiper isn't started