src/java/org/apache/cassandra/service/AntiEntropyService.java
/**
             * Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback
             * that will be called out of band once the streams complete.
             */
Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback
that will be called out of band once the streams complete.
Starts sending / receiving our list of differences to / from the remote endpoint : creates a callback that will be called out of band once the streams complete .
void performStreamingRepair()
            {
                Runnable callback = new Runnable()
                {
                    public void run()
                    {
                        completed(Differencer.this);
                    }
                };
                StreamingRepairTask task = StreamingRepairTask.create(r1.endpoint, r2.endpoint, tablename, cfname, differences, callback);
                if (task.isLocalTask() || Gossiper.instance.getVersion(task.dst) >= MessagingService.VERSION_10)
                    task.run();
            }
void performStreamingRepair ( ) { Runnable callback = new Runnable ( ) { public void run ( ) { completed ( Differencer . this ) ; } } ; StreamingRepairTask task = StreamingRepairTask . create ( r1 . endpoint , r2 . endpoint , tablename , cfname , differences , callback ) ; if ( task . isLocalTask ( ) || Gossiper . instance . getVersion ( task . dst ) >= MessagingService . VERSION_10 ) task . run ( ) ; }
Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback
 that will be called out of band once the streams complete.
Starts sending / receiving our list of differences to / from the remote endpoint : creates a callback that will be called out of band once the streams complete .
// Pre 1.0, nodes don't know how to handle forwarded streaming task so don't bother