This is an automated email from the ASF dual-hosted git repository.
belliottsmith pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
from cf802f81 Fix failing tests for TrackerReconcilerTest (#288)
add ffb19843 Support C* executor improvements * Refactor SafeState, and
PreLoadContext -> ExecutionContext * ExecutionContext introduces, to allow for
QoS/task splitting: * ExecutionKind (PreAccept/Accept/Commit/Stable/Apply)
* ExecutionSequence (UNSEQUENCED/BY_PRIORITY/ATOMIC) * isIdempotent to
ensure incremental tasks can be retried on failure *
continuationChain/executeContinuation introduced to declare tasks that
logically continue the initiating task. * Add Proto [...]
No new revisions were added by this update.
Summary of changes:
.../src/main/java/accord/api/AsyncExecutor.java | 28 ++-
.../main/java/accord/api/AsyncExecutorFactory.java | 4 +-
.../ExclusiveAsyncExecutor.java} | 6 +-
.../main/java/accord/api/ProtocolModifiers.java | 22 +-
.../coordinate/AbstractCoordinatePreAccept.java | 4 +-
.../accord/coordinate/AbstractCoordination.java | 68 ++++---
.../coordinate/AbstractSimpleCoordination.java | 8 +-
.../java/accord/coordinate/AsynchronousAwait.java | 8 +-
.../main/java/accord/coordinate/CheckShards.java | 6 +-
.../java/accord/coordinate/CollectLatestDeps.java | 2 +-
.../accord/coordinate/CoordinateEphemeralRead.java | 6 +-
.../accord/coordinate/CoordinateMaxConflict.java | 6 +-
.../accord/coordinate/CoordinatePreAccept.java | 6 +-
.../accord/coordinate/CoordinateSyncPoint.java | 6 +-
.../accord/coordinate/CoordinateTransaction.java | 11 +-
.../main/java/accord/coordinate/Coordination.java | 4 +-
.../accord/coordinate/CoordinationAdapter.java | 44 ++--
.../accord/coordinate/ExecuteEphemeralRead.java | 9 +-
.../java/accord/coordinate/ExecuteSyncPoint.java | 12 +-
.../main/java/accord/coordinate/ExecuteTxn.java | 6 +-
.../java/accord/coordinate/FetchCoordinator.java | 4 +-
.../src/main/java/accord/coordinate/FetchData.java | 10 +-
.../java/accord/coordinate/FetchDurableBefore.java | 2 +-
.../main/java/accord/coordinate/FetchRoute.java | 2 +-
.../main/java/accord/coordinate/Invalidate.java | 5 +-
.../main/java/accord/coordinate/KeyBarriers.java | 8 +-
.../main/java/accord/coordinate/MaybeRecover.java | 6 +-
.../src/main/java/accord/coordinate/Persist.java | 6 +-
.../java/accord/coordinate/PersistSyncPoint.java | 4 +-
.../main/java/accord/coordinate/PersistTxn.java | 4 +-
.../java/accord/coordinate/PrepareRecovery.java | 6 +-
.../src/main/java/accord/coordinate/Propose.java | 12 +-
.../main/java/accord/coordinate/ProposeOnly.java | 4 +-
.../java/accord/coordinate/ProposeSyncPoint.java | 4 +-
.../main/java/accord/coordinate/ProposeTxn.java | 4 +-
.../java/accord/coordinate/ReadCoordinator.java | 8 +-
.../src/main/java/accord/coordinate/Recover.java | 23 ++-
.../src/main/java/accord/coordinate/Stabilise.java | 4 +-
.../main/java/accord/coordinate/StabiliseOnly.java | 4 +-
.../java/accord/coordinate/StabiliseSyncPoint.java | 4 +-
.../main/java/accord/coordinate/StabiliseTxn.java | 4 +-
.../java/accord/coordinate/SynchronousAwait.java | 6 +-
.../accord/coordinate/SynchronousRecoverAwait.java | 11 +-
.../java/accord/impl/AbstractAsyncExecutor.java | 24 +++
.../java/accord/impl/AbstractFetchCoordinator.java | 5 +-
.../main/java/accord/impl/AbstractReplayer.java | 2 +-
.../java/accord/impl/AbstractSafeCommandStore.java | 28 +--
.../src/main/java/accord/impl/CommandChange.java | 2 +-
.../java/accord/impl/DefaultLocalListeners.java | 29 ++-
.../java/accord/impl/InMemoryCommandStore.java | 226 +++++++++++----------
.../main/java/accord/impl/InMemorySafeCommand.java | 90 +++-----
.../accord/impl/InMemorySafeCommandsForKey.java | 40 ++--
.../main/java/accord/impl/RequestCallbacks.java | 2 -
.../src/main/java/accord/impl/SafeState.java | 32 ---
.../accord/impl/progresslog/CallbackInvoker.java | 4 +-
.../impl/progresslog/DefaultProgressLog.java | 12 +-
.../java/accord/impl/progresslog/HomeState.java | 1 -
.../java/accord/impl/progresslog/TxnState.java | 4 +-
.../src/main/java/accord/local/Bootstrap.java | 10 +-
.../src/main/java/accord/local/Catchup.java | 4 +-
.../src/main/java/accord/local/CatchupHard.java | 4 +-
.../src/main/java/accord/local/Command.java | 7 +-
.../src/main/java/accord/local/CommandStore.java | 68 +++++--
.../src/main/java/accord/local/CommandStores.java | 7 +-
.../main/java/accord/local/CommandSummaries.java | 4 +-
.../src/main/java/accord/local/Commands.java | 54 +++--
.../{PreLoadContext.java => ExecutionContext.java} | 192 +++++++++++------
.../src/main/java/accord/local/LoadKeys.java | 5 +-
.../java/accord/local/MapReduceCommandStores.java | 2 +-
accord-core/src/main/java/accord/local/Node.java | 9 +-
.../main/java/accord/local/RedundantBefore.java | 2 -
.../src/main/java/accord/local/SafeCommand.java | 35 +---
.../main/java/accord/local/SafeCommandStore.java | 134 +++++++++---
.../src/main/java/accord/local/SafeState.java | 145 +++++++++++++
.../main/java/accord/local/cfk/CommandsForKey.java | 9 +
.../java/accord/local/cfk/ExecuteTxnBacklog.java | 6 +-
.../src/main/java/accord/local/cfk/NotifySink.java | 10 +-
.../main/java/accord/local/cfk/PostProcess.java | 6 +-
.../java/accord/local/cfk/SafeCommandsForKey.java | 24 ++-
.../src/main/java/accord/local/cfk/Updating.java | 6 +-
.../accord/local/durability/DurabilityQueue.java | 9 +-
.../main/java/accord/messages/AbstractRequest.java | 4 +-
.../src/main/java/accord/messages/Accept.java | 5 +
.../src/main/java/accord/messages/Apply.java | 20 +-
.../accord/messages/ApplyThenWaitUntilApplied.java | 5 +
.../java/accord/messages/BeginInvalidation.java | 2 +-
.../main/java/accord/messages/BeginRecovery.java | 6 +
.../src/main/java/accord/messages/Callback.java | 4 +-
.../src/main/java/accord/messages/CheckStatus.java | 4 +-
.../src/main/java/accord/messages/Commit.java | 9 +-
.../java/accord/messages/GetDurableBefore.java | 4 +-
.../main/java/accord/messages/InformDurable.java | 4 +-
.../src/main/java/accord/messages/PreAccept.java | 6 +
.../src/main/java/accord/messages/ReadData.java | 7 +-
.../java/accord/messages/ReadEphemeralTxnData.java | 4 +-
.../java/accord/messages/SetGloballyDurable.java | 4 +-
.../main/java/accord/messages/StableThenRead.java | 3 +-
.../src/main/java/accord/primitives/KeyDeps.java | 3 +-
.../main/java/accord/primitives/LatestDeps.java | 10 +-
.../src/main/java/accord/primitives/Routables.java | 32 ++-
.../src/main/java/accord/utils/ArrayBuffers.java | 7 +
.../java/accord/utils/BTreeReducingRangeMap.java | 1 -
.../src/main/java/accord/utils/Functions.java | 40 ++++
.../java/accord/utils/IntrusiveHeapNode.java} | 20 +-
.../java/accord/utils/IntrusivePriorityHeap.java | 121 ++++++-----
.../src/main/java/accord/utils/Invariants.java | 20 +-
.../src/main/java/accord/utils/LogGroupTimers.java | 17 +-
.../src/main/java/accord/utils/TinyEnumSet.java | 6 +-
.../src/main/java/accord/utils/UnhandledEnum.java | 10 +
.../java/accord/utils/async/AsyncCallbacks.java | 54 +++--
.../main/java/accord/utils/async/AsyncChains.java | 18 +-
.../test/java/accord/impl/LocalListenersTest.java | 16 --
.../src/test/java/accord/impl/MessageListener.java | 6 +-
.../test/java/accord/impl/RemoteListenersTest.java | 13 +-
.../src/test/java/accord/impl/basic/Cluster.java | 9 +-
.../accord/impl/basic/DelayedCommandStores.java | 24 ++-
.../java/accord/impl/basic/RandomDelayQueue.java | 9 +-
.../basic/SimulatedDelayedExecutorService.java | 9 +-
.../src/test/java/accord/impl/list/ListAgent.java | 2 +-
.../accord/impl/list/ListFetchCoordinator.java | 6 +-
.../test/java/accord/impl/list/ListRequest.java | 2 +-
.../src/test/java/accord/impl/list/ListStore.java | 4 +-
.../src/test/java/accord/impl/mock/MockStore.java | 4 +-
.../java/accord/local/ImmutableCommandTest.java | 6 +-
.../java/accord/local/MaybeExecuteAdapterTest.java | 2 +-
.../java/accord/local/cfk/CommandsForKeyTest.java | 58 ++----
.../local/durability/DurabilityQueueTest.java | 7 +-
.../test/java/accord/messages/PreAcceptTest.java | 8 +-
.../test/java/accord/messages/ReadDataTest.java | 12 +-
.../main/java/accord/maelstrom/MaelstromStore.java | 4 +-
130 files changed, 1416 insertions(+), 899 deletions(-)
copy accord-core/src/main/java/accord/{local/SequentialAsyncExecutor.java =>
api/ExclusiveAsyncExecutor.java} (87%)
delete mode 100644 accord-core/src/main/java/accord/impl/SafeState.java
rename accord-core/src/main/java/accord/local/{PreLoadContext.java =>
ExecutionContext.java} (56%)
create mode 100644 accord-core/src/main/java/accord/local/SafeState.java
copy accord-core/src/{test/java/accord/utils/LazyToString.java =>
main/java/accord/utils/IntrusiveHeapNode.java} (75%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
