src/java/org/apache/cassandra/service/AntiEntropyService.java
/**
             * Send merkle tree request to every involved neighbor.
             */
Send merkle tree request to every involved neighbor.
Send merkle tree request to every involved neighbor .
public void sendTreeRequests()
            {
                remainingEndpoints.addAll(endpoints);
                remainingEndpoints.add(FBUtilities.getBroadcastAddress());
                for (InetAddress endpoint : remainingEndpoints)
                    AntiEntropyService.instance.request(getName(), endpoint, range, tablename, cfname);
                logger.info(String.format("[repair #%s] requests for merkle tree sent for %s (to %s)", getName(), cfname, remainingEndpoints));
                requestsSent.signalAll();
            }
public void sendTreeRequests ( ) { remainingEndpoints . addAll ( endpoints ) ; remainingEndpoints . add ( FBUtilities . getBroadcastAddress ( ) ) ; for ( InetAddress endpoint : remainingEndpoints ) AntiEntropyService . instance . request ( getName ( ) , endpoint , range , tablename , cfname ) ; logger . info ( String . format ( "[repair #%s] requests for merkle tree sent for %s (to %s)" , getName ( ) , cfname , remainingEndpoints ) ) ; requestsSent . signalAll ( ) ; }
Send merkle tree request to every involved neighbor.
Send merkle tree request to every involved neighbor .
// send requests to all nodes