This is an automated email from the ASF dual-hosted git repository.
benedict pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
from 05b2f241 Fix CFK restore after replay: - Remove from CFK any
unapplied transactions we know cannot apply - Force notification of waiting
commands in CFK on replay Also fix: - Don't truncateWithOutcome if pre
bootstrap or stale - Fix RangeDeps.without(RangeDeps) - Fix
InMemoryCommandStore replay bug with clearing DefaultLocalListeners - Ensure
SaveStatus and executeAt are updated together to prevent corruption via expunge
Improve: - Inform home shard that command is decided [...]
new 916ff8eb - Handle another truncateWithOutcome edge case
new 204e48df Improve ProgressLog: - Schedule a fallback timeout for
active requests to ensure progress with lost callbacks - Clear active task for
a txnId when new RunInvoker is registered - Consult DurableBefore prior to
invoking recovery - Support user invoked reset of a command, clearing any
active work and requeueing it - (Testing): Treat progress log for RX as
recurring tasks for burn test termination
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/java/accord/coordinate/FetchData.java | 25 ++-
.../main/java/accord/coordinate/FetchRoute.java | 10 +-
.../main/java/accord/coordinate/MaybeRecover.java | 8 +-
.../accord/impl/progresslog/CallbackInvoker.java | 49 +++--
.../impl/progresslog/DefaultProgressLog.java | 216 +++++++++++++--------
.../java/accord/impl/progresslog/HomeState.java | 20 +-
.../java/accord/impl/progresslog/TxnState.java | 14 +-
.../java/accord/impl/progresslog/WaitingState.java | 23 ++-
.../src/main/java/accord/local/Cleanup.java | 9 +-
accord-core/src/main/java/accord/local/Node.java | 10 +-
.../accord/local/durability/DurabilityQueue.java | 5 +-
.../src/test/java/accord/impl/basic/Cluster.java | 4 +-
.../src/test/java/accord/impl/basic/Pending.java | 5 +
.../java/accord/impl/basic/TestProgressLogs.java | 29 ++-
14 files changed, 264 insertions(+), 163 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
