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

feedback

This commit is contained in:
Blake Eggleston 2026-06-18 14:19:27 -07:00
parent 9bd69f2fec
commit 6dcf3e56c8
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/java/org/apache/cassandra/locator/SatelliteReplicationStrategy.java
View File

@ -587,7 +587,6 @@ public class SatelliteReplicationStrategy extends AbstractReplicationStrategy
// Paxos consensus operates entirely within the primary DC
Predicate<Replica> inPrimaryDC = rp -> metadata.locator.location(rp.endpoint()).datacenter.equals(primaryDC);
ReplicaLayout.ForTokenWrite primaryAll = fullLayout.filter(inPrimaryDC);
ReplicaLayout.ForTokenWrite primaryElectorate = primaryAll;
// Satellite/secondary DC endpoints for reads during prepare and writes during commit.
// Only include the primary DC's satellite and other full DCs — not satellites of other DCs.
@ -604,14 +603,13 @@ public class SatelliteReplicationStrategy extends AbstractReplicationStrategy
EndpointsForToken live = fullLayout.all().filter(isReplicaAlive);
Token actualToken = token;
return new SatellitePaxosParticipants(metadata.epoch,
Keyspace.open(table.keyspace),
consistencyForConsensus,
primaryAll,
primaryElectorate,
primaryAll, // DC filtering happens earlier
live,
(cm) -> Paxos.Participants.get(cm, table, actualToken, consistencyForConsensus),
(cm) -> Paxos.Participants.get(cm, table, token, consistencyForConsensus),
satelliteEndpoints);
}
@ -694,7 +692,7 @@ public class SatelliteReplicationStrategy extends AbstractReplicationStrategy
for (String dc : strategy.fullDCs.keySet())
{
if (dc.equals(primary) || dc.equals(satellite) || strategy.disabledDCs.contains(dc))
if (dc.equals(primary) || strategy.disabledDCs.contains(dc))
continue;
results.add(dc);
}
@ -774,9 +772,7 @@ public class SatelliteReplicationStrategy extends AbstractReplicationStrategy
super(metadata, keyspace, cl, strategy, primary, fullLayout);
this.selector = selector;
if (ADDL_CHECKS_ENABLED)
{
Preconditions.checkState(!strategy.disabledDCs.contains(primary));
}
}
@Override