src/java/org/apache/cassandra/service/AntiEntropyService.java
/**
             * Add a new received tree and return the number of remaining tree to
             * be received for the job to be complete.
             *
             * Callers may assume exactly one addTree call will result in zero remaining endpoints.
             */
Add a new received tree and return the number of remaining tree to
be received for the job to be complete.

Callers may assume exactly one addTree call will result in zero remaining endpoints.
Add a new received tree and return the number of remaining tree to be received for the job to be complete . Callers may assume exactly one addTree call will result in zero remaining endpoints .
public synchronized int addTree(TreeRequest request, MerkleTree tree)
            {
                try
                {
                    requestsSent.await();
                }
                catch (InterruptedException e)
                {
                    throw new AssertionError("Interrupted while waiting for requests to be sent");
                }
                assert request.cf.right.equals(cfname);
                trees.add(new TreeResponse(request.endpoint, tree));
                remainingEndpoints.remove(request.endpoint);
                return remainingEndpoints.size();
            }
public synchronized int addTree ( TreeRequest request , MerkleTree tree ) { try { requestsSent . await ( ) ; } catch ( InterruptedException e ) { throw new AssertionError ( "Interrupted while waiting for requests to be sent" ) ; } assert request . cf . right . equals ( cfname ) ; trees . add ( new TreeResponse ( request . endpoint , tree ) ) ; remainingEndpoints . remove ( request . endpoint ) ; return remainingEndpoints . size ( ) ; }
Add a new received tree and return the number of remaining tree to
 be received for the job to be complete.
Add a new received tree and return the number of remaining tree to be received for the job to be complete .
// Wait for all request to have been performed (see #3400)