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 2010/11/01 23:37:58 UTC
svn commit: r1029870 -
/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AntiEntropyService.java
Author: jbellis
Date: Mon Nov 1 22:37:57 2010
New Revision: 1029870
URL: http://svn.apache.org/viewvc?rev=1029870&view=rev
Log:
make RF=1 repair a no-op. patch by Stu Hood; reviewed by jbellis for CASSANDRA-1691
Modified:
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AntiEntropyService.java
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AntiEntropyService.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AntiEntropyService.java?rev=1029870&r1=1029869&r2=1029870&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AntiEntropyService.java (original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AntiEntropyService.java Mon Nov 1 22:37:57 2010
@@ -778,13 +778,19 @@ public class AntiEntropyService
@Override
public void run()
{
+ Set<InetAddress> endpoints = AntiEntropyService.getNeighbors(tablename);
+ if (endpoints.isEmpty())
+ {
+ logger.info("No neighbors to repair with: " + getName() + " completed.");
+ return;
+ }
+
// begin a repair session
Callback callback = new Callback();
AntiEntropyService.this.sessions.put(getName(), callback);
try
{
// request that all relevant endpoints generate trees
- Set<InetAddress> endpoints = AntiEntropyService.getNeighbors(tablename);
for (String cfname : cfnames)
{
// send requests to remote nodes and record them