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
