This is an automated email from the ASF dual-hosted git repository.
ifesdjeen pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
The following commit(s) were added to refs/heads/trunk by this push:
new b268e9a7 Accord: fix durability scheduling order, initialize them
_after_ nodes are created
b268e9a7 is described below
commit b268e9a7e80ed7454da7ec9df6f1a48d68a94ec1
Author: Alex Petrov <[email protected]>
AuthorDate: Wed Aug 13 08:48:53 2025 +0200
Accord: fix durability scheduling order, initialize them _after_ nodes are
created
Patch by Alex Petrov; reviewed by Benedict Elliott Smith for CASSANDRA-20831
---
accord-core/src/test/java/accord/impl/basic/Cluster.java | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/accord-core/src/test/java/accord/impl/basic/Cluster.java
b/accord-core/src/test/java/accord/impl/basic/Cluster.java
index e8bfcd1a..8a005c37 100644
--- a/accord-core/src/test/java/accord/impl/basic/Cluster.java
+++ b/accord-core/src/test/java/accord/impl/basic/Cluster.java
@@ -635,11 +635,6 @@ public class Cluster
{
RandomSource random = randomSupplier.get();
Cluster sinks = new Cluster(randomSupplier.get(), messageListener,
queueSupplier, checkFailures, nodeMap::get, journalMap::get, () ->
topologyFactory.rf, responseSink);
- for (Node node : nodeMap.values())
- {
- node.configService().registerListener((ListStore)
node.commandStores().dataStore());
- node.configService().registerListener(node.durability());
- }
TopologyUpdates topologyUpdates = new
TopologyUpdates(executorMap::get);
TopologyRandomizer.Listener schemaApply = t -> {
for (Node node : nodeMap.values())
@@ -705,6 +700,12 @@ public class Cluster
durabilityServices.add(new DurabilityService(node));
}
+ for (Node node : nodeMap.values())
+ {
+ node.configService().registerListener((ListStore)
node.commandStores().dataStore());
+ node.configService().registerListener(node.durability());
+ }
+
Runnable updateDurabilityRate;
{
IntSupplier targetSplits =
random.biasedUniformIntsSupplier(1, 16, 2, 4, 4, 16).get();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
