src/java/org/apache/cassandra/service/AntiEntropyService.java
/**
     * Responds to the node that requested the given valid tree.
     * @param validator A locally generated validator
     * @param local localhost (parameterized for testing)
     */
Responds to the node that requested the given valid tree.
@param validator A locally generated validator
@param local localhost (parameterized for testing)
Responds to the node that requested the given valid tree . @param validator A locally generated validator @param local localhost ( parameterized for testing )
void respond(Validator validator, InetAddress local)
    {
        MessagingService ms = MessagingService.instance();
        try
        {
            Message message = TreeResponseVerbHandler.makeVerb(local, validator);
            if (!validator.request.endpoint.equals(FBUtilities.getBroadcastAddress()))
                logger.info(String.format("[repair #%s] Sending completed merkle tree to %s for %s", validator.request.sessionid, validator.request.endpoint, validator.request.cf));
            ms.sendOneWay(message, validator.request.endpoint);
        }
        catch (Exception e)
        {
            logger.error(String.format("[repair #%s] Error sending completed merkle tree to %s for %s ", validator.request.sessionid, validator.request.endpoint, validator.request.cf), e);
        }
    }
void respond ( Validator validator , InetAddress local ) { MessagingService ms = MessagingService . instance ( ) ; try { Message message = TreeResponseVerbHandler . makeVerb ( local , validator ) ; if ( ! validator . request . endpoint . equals ( FBUtilities . getBroadcastAddress ( ) ) ) logger . info ( String . format ( "[repair #%s] Sending completed merkle tree to %s for %s" , validator . request . sessionid , validator . request . endpoint , validator . request . cf ) ) ; ms . sendOneWay ( message , validator . request . endpoint ) ; } catch ( Exception e ) { logger . error ( String . format ( "[repair #%s] Error sending completed merkle tree to %s for %s " , validator . request . sessionid , validator . request . endpoint , validator . request . cf ) , e ) ; } }
Responds to the node that requested the given valid tree.
Responds to the node that requested the given valid tree .