natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge eecf5e6464 into bdbdf8d710

This commit is contained in:
maoling 2026-07-29 13:36:32 +08:00 committed by GitHub
parent bdbdf8d710 eecf5e6464
commit 15eea4f51c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/java/org/apache/cassandra/gms/Gossiper.java
View File

@ -925,9 +925,13 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean,
if (cms.contains(getBroadcastAddressAndPort()))
return;
double probability = cms.size() / (double) (liveEndpoints.size() + unreachableEndpoints.size());
int totalEndpoints = liveEndpoints.size() + unreachableEndpoints.size();
if (totalEndpoints == 0)
return;
double probability = cms.size() / (double) totalEndpoints;
double randDbl = random.nextDouble();
if (randDbl <= probability)
if (randDbl < probability)
{
logger.trace("Sending GossipDigestSyn to the CMS {}", cms);
sendGossip(message, cms);