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

Fix infinite loop, and notify progress log of sync point durability while waiting to apply 

patch by Benedict; reviewed by David Capwell for CASSANDRA-20125
This commit is contained in:
Benedict Elliott Smith 2024-12-02 17:44:27 +00:00 committed by David Capwell
parent 74817bc83e
commit a5dc44ad57
2 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/accord

@ -1 +1 @@
Subproject commit bd0761c567d153995a3db8da686ffdc940247200
Subproject commit 1401e93490de57c65a12020d85830fbba8ef8c26

8
src/java/org/apache/cassandra/service/accord/repair/RepairSyncPointAdapter.java
View File

@ -61,17 +61,11 @@ public class RepairSyncPointAdapter<U extends Unseekable> extends CoordinationAd
public void execute(Node node, Topologies all, FullRoute<?> route, ExecutePath path, TxnId txnId, Txn txn, Timestamp executeAt, Deps deps, BiConsumer<? super SyncPoint<U>, Throwable> callback)
{
RequiredResponseTracker tracker = new RequiredResponseTracker(requiredResponses, all);
ExecuteSyncPoint.ExecuteBlocking<U> execute = new ExecuteSyncPoint.ExecuteBlocking<>(node, new SyncPoint<>(txnId, deps, (FullRoute<U>) route), tracker, executeAt);
ExecuteSyncPoint.ExecuteInclusive<U> execute = new ExecuteSyncPoint.ExecuteInclusive<>(node, new SyncPoint<>(txnId, deps, (FullRoute<U>) route), tracker, executeAt);
execute.addCallback(callback);
execute.start();
}
@Override
protected void addOrExecuteCallback(ExecuteSyncPoint.ExecuteBlocking<U> execute, BiConsumer<? super SyncPoint<U>, Throwable> callback)
{
execute.addCallback(callback);
}
@Override
public void persist(Node node, Topologies all, FullRoute<?> route, TxnId txnId, Txn txn, Timestamp executeAt, Deps deps, Writes writes, Result result, BiConsumer<? super SyncPoint<U>, Throwable> callback)
{