import org.apache.cassandra.repair.messages.ValidationComplete; //导入依赖的package包/类
public void handleMessage(InetAddress endpoint, RepairMessage message)
{
    RepairJobDesc desc = message.desc;
    RepairSession session = sessions.get(desc.sessionId);
    if (session == null)
        return;
    switch (message.messageType)
    {
        case VALIDATION_COMPLETE:
            ValidationComplete validation = (ValidationComplete) message;
            session.validationComplete(desc, endpoint, validation.tree);
            break;
        case SYNC_COMPLETE:
            // one of replica is synced.
            SyncComplete sync = (SyncComplete) message;
            session.syncComplete(desc, sync.nodes, sync.success);
            break;
        default:
            break;
    }
}
 

import org.apache.cassandra.repair.messages.ValidationComplete; //导入依赖的package包/类
/**
 * Called when some error during the validation happened.
 * This sends RepairStatus to inform the initiator that the validation has failed.
 * The actual reason for failure should be looked up in the log of the host calling this function.
 */
public void fail()
{
    logger.error("Failed creating a merkle tree for {}, {} (see log for details)", desc, initiator);
    // send fail message only to nodes >= version 2.0
    MessagingService.instance().sendOneWay(new ValidationComplete(desc).createMessage(), initiator);
}
 

import org.apache.cassandra.repair.messages.ValidationComplete; //导入依赖的package包/类
/**
 * Called after the validation lifecycle to respond with the now valid tree. Runs in Stage.ANTIENTROPY.
 */
public void run()
{
    // respond to the request that triggered this validation
    if (!initiator.equals(FBUtilities.getBroadcastAddress()))
        logger.info(String.format("[repair #%s] Sending completed merkle tree to %s for %s/%s", desc.sessionId, initiator, desc.keyspace, desc.columnFamily));
    MessagingService.instance().sendOneWay(new ValidationComplete(desc, tree).createMessage(), initiator);
}
 

import org.apache.cassandra.repair.messages.ValidationComplete; //导入依赖的package包/类
/**
 * Called when some error during the validation happened.
 * This sends RepairStatus to inform the initiator that the validation has failed.
 * The actual reason for failure should be looked up in the log of the host calling this function.
 */
public void fail()
{
    logger.error("Failed creating a merkle tree for " + desc + ", " + initiator + " (see log for details)");
    // send fail message only to nodes >= version 2.0
    MessagingService.instance().sendOneWay(new ValidationComplete(desc).createMessage(), initiator);
}
 

import org.apache.cassandra.repair.messages.ValidationComplete; //导入依赖的package包/类
/**
 * Called after the validation lifecycle to respond with the now valid tree. Runs in Stage.ANTIENTROPY.
 */
public void run()
{
    // respond to the request that triggered this validation
    if (!initiator.equals(FBUtilities.getBroadcastAddress()))
    {
        logger.info(String.format("[repair #%s] Sending completed merkle tree to %s for %s.%s", desc.sessionId, initiator, desc.keyspace, desc.columnFamily));
        Tracing.traceRepair("Sending completed merkle tree to {} for {}.{}", initiator, desc.keyspace, desc.columnFamily);
    }
    MessagingService.instance().sendOneWay(new ValidationComplete(desc, trees).createMessage(), initiator);
}