src/java/org/apache/cassandra/service/AntiEntropyService.java
/**
             * Submit differencers for running.
             * All tree *must* have been received before this is called.
             */
Submit differencers for running.
All tree *must* have been received before this is called.
Submit differencers for running . All tree * must * have been received before this is called .
public void submitDifferencers()
            {
                assert remainingEndpoints.isEmpty();
                for (int i = 0; i < trees.size() - 1; ++i)
                {
                    TreeResponse r1 = trees.get(i);
                    for (int j = i + 1; j < trees.size(); ++j)
                    {
                        TreeResponse r2 = trees.get(j);
                        Differencer differencer = new Differencer(cfname, r1, r2);
                        logger.debug("Queueing comparison {}", differencer);
                        remainingDifferencers.add(differencer);
                        StageManager.getStage(Stage.ANTI_ENTROPY).execute(differencer);
                    }
                }
                trees.clear(); 
            }
public void submitDifferencers ( ) { assert remainingEndpoints . isEmpty ( ) ; for ( int i = 0 ; i < trees . size ( ) - 1 ; ++ i ) { TreeResponse r1 = trees . get ( i ) ; for ( int j = i + 1 ; j < trees . size ( ) ; ++ j ) { TreeResponse r2 = trees . get ( j ) ; Differencer differencer = new Differencer ( cfname , r1 , r2 ) ; logger . debug ( "Queueing comparison {}" , differencer ) ; remainingDifferencers . add ( differencer ) ; StageManager . getStage ( Stage . ANTI_ENTROPY ) . execute ( differencer ) ; } } trees . clear ( ) ; }
Submit differencers for running.
Submit differencers for running .
// We need to difference all trees one against another // allows gc to do its thing