6b8bef48e5780aefda6bd1ff29a6290e56ede438 - cassandra-accord

commit	6b8bef48e5780aefda6bd1ff29a6290e56ede438	[log] [tgz]
author	Benedict Elliott Smith <benedict@apache.org>	Wed Feb 14 15:31:38 2024 +0000
committer	Benedict Elliott Smith <benedict@apache.org>	Wed Feb 28 14:26:48 2024 +0000
tree	8f8e863bd307ee468933b97c55f9e87fc19f13cd
parent	62bd2c6c8cc98946ee9d41c2136339f68b12930d [diff]

Refactor CommandsForKey for efficiency, and to support transitive dependency elision

patch by Benedict; reviewed by Aleksey Yeshchenko for CASSANDRA-19310

accord-core/src/main/java/accord/coordinate/AbstractCoordinatePreAccept.java[diff]
accord-core/src/main/java/accord/coordinate/Barrier.java[diff]
accord-core/src/main/java/accord/coordinate/BlockOnDeps.java[Deleted - diff]
accord-core/src/main/java/accord/coordinate/CoordinateEphemeralRead.java[diff]
accord-core/src/main/java/accord/coordinate/CoordinateGloballyDurable.java[diff]
accord-core/src/main/java/accord/coordinate/CoordinateNoOp.java[Deleted - diff]
accord-core/src/main/java/accord/coordinate/CoordinatePreAccept.java[diff]
accord-core/src/main/java/accord/coordinate/CoordinateShardDurable.java[diff]
accord-core/src/main/java/accord/coordinate/CoordinateSyncPoint.java[diff]
accord-core/src/main/java/accord/coordinate/CoordinateTransaction.java[diff]
accord-core/src/main/java/accord/coordinate/CoordinationAdapter.java[Added - diff]
accord-core/src/main/java/accord/coordinate/Execute.java[Deleted - diff]
accord-core/src/main/java/accord/coordinate/ExecuteEphemeralRead.java[diff]
accord-core/src/main/java/accord/coordinate/ExecutePath.java[Renamed from accord-core/src/main/java/accord/impl/DomainTimestamps.java - diff]
accord-core/src/main/java/accord/coordinate/ExecuteSyncPoint.java[Added - diff]
accord-core/src/main/java/accord/coordinate/ExecuteTxn.java[diff]
accord-core/src/main/java/accord/coordinate/FetchData.java[diff]
accord-core/src/main/java/accord/coordinate/FetchMaxConflict.java[Added - diff]
accord-core/src/main/java/accord/coordinate/Infer.java[diff]
accord-core/src/main/java/accord/coordinate/Invalidate.java[diff]
accord-core/src/main/java/accord/coordinate/Persist.java[diff]
accord-core/src/main/java/accord/coordinate/PersistTxn.java[diff]
accord-core/src/main/java/accord/coordinate/Propose.java[diff]
accord-core/src/main/java/accord/coordinate/ProposeAndExecute.java[Deleted - diff]
accord-core/src/main/java/accord/coordinate/ProposeSyncPoint.java[diff]
accord-core/src/main/java/accord/coordinate/ProposeTxn.java[Added - diff]
accord-core/src/main/java/accord/coordinate/Recover.java[diff]
accord-core/src/main/java/accord/coordinate/RecoverWithRoute.java[diff]
accord-core/src/main/java/accord/coordinate/Stabilise.java[diff]
accord-core/src/main/java/accord/coordinate/StabiliseSyncPoint.java[Added - diff]
accord-core/src/main/java/accord/coordinate/StabiliseTxn.java[diff]
accord-core/src/main/java/accord/coordinate/TopologyMismatch.java[diff]
accord-core/src/main/java/accord/coordinate/tracking/AbstractSimpleTracker.java[Added - diff]
accord-core/src/main/java/accord/coordinate/tracking/AppliedTracker.java[diff]
accord-core/src/main/java/accord/coordinate/tracking/QuorumTracker.java[diff]
accord-core/src/main/java/accord/impl/AbstractConfigurationService.java[diff]
accord-core/src/main/java/accord/impl/AbstractFetchCoordinator.java[diff]
accord-core/src/main/java/accord/impl/AbstractSafeCommandStore.java[diff]
accord-core/src/main/java/accord/impl/CommandTimeseries.java[Deleted - diff]
accord-core/src/main/java/accord/impl/CommandsForKey.java[diff]
accord-core/src/main/java/accord/impl/CommandsForKeyGroupUpdater.java[Deleted - diff]
accord-core/src/main/java/accord/impl/CommandsForKeyUpdater.java[Deleted - diff]
accord-core/src/main/java/accord/impl/CommandsForKeys.java[diff]
accord-core/src/main/java/accord/impl/CommandsSummary.java[Added - diff]
accord-core/src/main/java/accord/impl/CoordinateDurabilityScheduling.java[diff]
accord-core/src/main/java/accord/impl/DepsBuilder.java[Deleted - diff]
accord-core/src/main/java/accord/impl/DomainCommands.java[Deleted - diff]
accord-core/src/main/java/accord/impl/InMemoryCommandStore.java[diff]
accord-core/src/main/java/accord/impl/InMemorySafeCommandsForKeyUpdate.java[Deleted - diff]
accord-core/src/main/java/accord/impl/SafeCommandsForKey.java[diff]
accord-core/src/main/java/accord/impl/SafeTimestampsForKey.java[diff]
accord-core/src/main/java/accord/impl/TimestampsForKey.java[diff]
accord-core/src/main/java/accord/local/Bootstrap.java[diff]
accord-core/src/main/java/accord/local/Cleanup.java[diff]
accord-core/src/main/java/accord/local/Command.java[diff]
accord-core/src/main/java/accord/local/CommandStore.java[diff]
accord-core/src/main/java/accord/local/Commands.java[diff]
accord-core/src/main/java/accord/local/DurableBefore.java[diff]
accord-core/src/main/java/accord/local/KeyHistory.java[diff]
accord-core/src/main/java/accord/local/Listeners.java[diff]
accord-core/src/main/java/accord/local/MaxConflicts.java[Added - diff]
accord-core/src/main/java/accord/local/Node.java[diff]
accord-core/src/main/java/accord/local/PreLoadContext.java[diff]
accord-core/src/main/java/accord/local/RedundantBefore.java[diff]
accord-core/src/main/java/accord/local/SafeCommand.java[diff]
accord-core/src/main/java/accord/local/SafeCommandStore.java[diff]
accord-core/src/main/java/accord/local/Status.java[diff]
accord-core/src/main/java/accord/messages/Accept.java[diff]
accord-core/src/main/java/accord/messages/Apply.java[diff]
accord-core/src/main/java/accord/messages/ApplyThenWaitUntilApplied.java[diff]
accord-core/src/main/java/accord/messages/BeginRecovery.java[diff]
accord-core/src/main/java/accord/messages/CheckStatus.java[diff]
accord-core/src/main/java/accord/messages/Commit.java[diff]
accord-core/src/main/java/accord/messages/GetDeps.java[diff]
accord-core/src/main/java/accord/messages/GetEphemeralReadDeps.java[diff]
accord-core/src/main/java/accord/messages/GetMaxConflict.java[Added - diff]
accord-core/src/main/java/accord/messages/PreAccept.java[diff]
accord-core/src/main/java/accord/messages/Propagate.java[diff]
accord-core/src/main/java/accord/messages/ReadData.java[diff]
accord-core/src/main/java/accord/messages/ReadEphemeralTxnData.java[diff]
accord-core/src/main/java/accord/messages/SetGloballyDurable.java[diff]
accord-core/src/main/java/accord/messages/TxnRequest.java[diff]
accord-core/src/main/java/accord/messages/WaitUntilApplied.java[diff]
accord-core/src/main/java/accord/primitives/AbstractKeys.java[diff]
accord-core/src/main/java/accord/primitives/KeyDeps.java[diff]
accord-core/src/main/java/accord/primitives/PartialDeps.java[diff]
accord-core/src/main/java/accord/primitives/RangeDeps.java[diff]
accord-core/src/main/java/accord/primitives/Ranges.java[diff]
accord-core/src/main/java/accord/primitives/SyncPoint.java[diff]
accord-core/src/main/java/accord/primitives/Timestamp.java[diff]
accord-core/src/main/java/accord/primitives/Txn.java[diff]
accord-core/src/main/java/accord/primitives/TxnId.java[diff]
accord-core/src/main/java/accord/utils/ArrayBuffers.java[diff]
accord-core/src/main/java/accord/utils/Invariants.java[diff]
accord-core/src/main/java/accord/utils/ReducingIntervalMap.java[diff]
accord-core/src/main/java/accord/utils/ReducingRangeMap.java[diff]
accord-core/src/test/java/accord/Utils.java[diff]
accord-core/src/test/java/accord/burn/BurnTest.java[diff]
accord-core/src/test/java/accord/coordinate/CoordinateTransactionTest.java[diff]
accord-core/src/test/java/accord/impl/CommandsForKeyGroupUpdaterTest.java[Deleted - diff]
accord-core/src/test/java/accord/impl/PrefixedIntHashKey.java[diff]
accord-core/src/test/java/accord/impl/basic/Cluster.java[diff]
accord-core/src/test/java/accord/impl/list/ListAgent.java[diff]
accord-core/src/test/java/accord/impl/list/ListFetchCoordinator.java[diff]
accord-core/src/test/java/accord/impl/list/ListRequest.java[diff]
accord-core/src/test/java/accord/impl/list/ListStore.java[diff]
accord-core/src/test/java/accord/impl/list/ListWrite.java[diff]
accord-core/src/test/java/accord/impl/mock/MockCluster.java[diff]
accord-core/src/test/java/accord/local/ImmutableCommandTest.java[diff]
accord-core/src/test/java/accord/messages/PreAcceptTest.java[diff]
accord-core/src/test/java/accord/messages/ReadDataTest.java[diff]
accord-core/src/test/java/accord/primitives/DepsBuilderTest.java[Deleted - diff]
accord-core/src/test/java/accord/topology/TopologyRandomizer.java[diff]
accord-core/src/test/java/accord/utils/AccordGens.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java[diff]
accord-maelstrom/src/main/java/accord/maelstrom/Main.java[diff]

116 files changed

tree: 8f8e863bd307ee468933b97c55f9e87fc19f13cd

.build/
.circleci/
accord-core/
accord-maelstrom/
buildSrc/
gradle/
.gitignore
build.gradle
gradle.properties
gradlew
gradlew.bat
settings.gradle