src/java/org/apache/cassandra/gms/Gossiper.java
/* Sends a Gossip message to an unreachable member */
Sends a Gossip message to an unreachable member
Sends a Gossip message to an unreachable member
private void doGossipToUnreachableMember(MessageProducer prod)
    {
        double liveEndpointCount = liveEndpoints.size();
        double unreachableEndpointCount = unreachableEndpoints.size();
        if ( unreachableEndpointCount > 0 )
        {
            /* based on some probability */
            double prob = unreachableEndpointCount / (liveEndpointCount + 1);
            double randDbl = random.nextDouble();
            if ( randDbl < prob )
                sendGossip(prod, unreachableEndpoints.keySet());
        }
    }
private void doGossipToUnreachableMember ( MessageProducer prod ) { double liveEndpointCount = liveEndpoints . size ( ) ; double unreachableEndpointCount = unreachableEndpoints . size ( ) ; if ( unreachableEndpointCount > 0 ) { /* based on some probability */ double prob = unreachableEndpointCount / ( liveEndpointCount + 1 ) ; double randDbl = random . nextDouble ( ) ; if ( randDbl < prob ) sendGossip ( prod , unreachableEndpoints . keySet ( ) ) ; } }
Sends a Gossip message to an unreachable member
Sends a Gossip message to an unreachable member