ASF Git Repos - cassandra-accord.git/commit

projects / cassandra-accord.git / commit

author	Benedict Elliott Smith <benedict@apache.org>
	Wed, 17 Aug 2022 08:50:36 +0000 (09:50 +0100)
committer	Benedict Elliott Smith <benedict@apache.org>
	Wed, 17 Aug 2022 08:57:32 +0000 (09:57 +0100)
commit	bb52de784b3a3de5ec473d3e935d4f76c6258c13
tree	5eabeb58905eb6bbcfe28f610725b2b14b1d7359	tree \| snapshot
parent	119ed545c2532c830d8dcb682741f0f8819a6c30	commit \| diff

Efficient Dependencies (CASSANDRA-17111)

Transaction dependencies must include only the TxnId of the dependent transactions, and the key they conflict on

patch by Benedict; reviewed by David Capwell for CASSANDRA-17111

131 files changed:

accord-core/build.gradle		diff \| blob \| history
accord-core/src/main/java/accord/api/Agent.java		diff \| blob \| history
accord-core/src/main/java/accord/api/Key.java		diff \| blob \| history
accord-core/src/main/java/accord/api/ProgressLog.java		diff \| blob \| history
accord-core/src/main/java/accord/api/Query.java		diff \| blob \| history
accord-core/src/main/java/accord/api/Read.java		diff \| blob \| history
accord-core/src/main/java/accord/api/Update.java		diff \| blob \| history
accord-core/src/main/java/accord/api/Write.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/CheckOnCommitted.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/CheckOnUncommitted.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/CheckShardStatus.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Coordinate.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/CoordinateFailed.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Execute.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/InformHomeOfTxn.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Invalidate.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/MaybeRecover.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Persist.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Preempted.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Propose.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Recover.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/Timeout.java		diff \| blob \| history
accord-core/src/main/java/accord/coordinate/tracking/ReadTracker.java		diff \| blob \| history
accord-core/src/main/java/accord/impl/SimpleProgressLog.java		diff \| blob \| history
accord-core/src/main/java/accord/local/Command.java		diff \| blob \| history
accord-core/src/main/java/accord/local/CommandStore.java		diff \| blob \| history
accord-core/src/main/java/accord/local/CommandStores.java		diff \| blob \| history
accord-core/src/main/java/accord/local/CommandsForKey.java		diff \| blob \| history
accord-core/src/main/java/accord/local/Node.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/Accept.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/Apply.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/BeginInvalidate.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/BeginRecovery.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/Callback.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/CheckStatus.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/Commit.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/InformOfPersistence.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/InformOfTxn.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/PreAccept.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/ReadData.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/TxnRequest.java		diff \| blob \| history
accord-core/src/main/java/accord/messages/WaitOnCommit.java		diff \| blob \| history
accord-core/src/main/java/accord/primitives/Ballot.java	[moved from accord-core/src/main/java/accord/txn/Ballot.java with 92% similarity]	diff \| blob \| history
accord-core/src/main/java/accord/primitives/Deps.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/primitives/KeyRange.java	[moved from accord-core/src/main/java/accord/topology/KeyRange.java with 51% similarity]	diff \| blob \| history
accord-core/src/main/java/accord/primitives/KeyRanges.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/primitives/Keys.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/primitives/Timestamp.java	[moved from accord-core/src/main/java/accord/txn/Timestamp.java with 98% similarity]	diff \| blob \| history
accord-core/src/main/java/accord/primitives/TxnId.java	[moved from accord-core/src/main/java/accord/txn/TxnId.java with 93% similarity]	diff \| blob \| history
accord-core/src/main/java/accord/topology/KeyRanges.java	[deleted file]	blob \| history
accord-core/src/main/java/accord/topology/Shard.java		diff \| blob \| history
accord-core/src/main/java/accord/topology/Topology.java		diff \| blob \| history
accord-core/src/main/java/accord/topology/TopologyManager.java		diff \| blob \| history
accord-core/src/main/java/accord/txn/Dependencies.java	[deleted file]	blob \| history
accord-core/src/main/java/accord/txn/Keys.java	[deleted file]	blob \| history
accord-core/src/main/java/accord/txn/Txn.java		diff \| blob \| history
accord-core/src/main/java/accord/txn/Writes.java		diff \| blob \| history
accord-core/src/main/java/accord/utils/ArrayBuffers.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/AsymmetricComparator.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/IndexedFold.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/IndexedFoldIntersectToLong.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/IndexedFoldToLong.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/IndexedRangeFoldToLong.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/IntrusiveLinkedList.java	[deleted file]	blob \| history
accord-core/src/main/java/accord/utils/IntrusiveLinkedListNode.java	[deleted file]	blob \| history
accord-core/src/main/java/accord/utils/MergeIterator.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/SortedArrays.java	[new file with mode: 0644]	blob
accord-core/src/main/java/accord/utils/Timestamped.java		diff \| blob \| history
accord-core/src/main/java/org/apache/cassandra/concurrent/ImmediateExecutor.java		diff \| blob \| history
accord-core/src/test/java/accord/KeysTest.java		diff \| blob \| history
accord-core/src/test/java/accord/Utils.java		diff \| blob \| history
accord-core/src/test/java/accord/burn/BurnTest.java		diff \| blob \| history
accord-core/src/test/java/accord/burn/BurnTestConfigurationService.java		diff \| blob \| history
accord-core/src/test/java/accord/burn/TopologyUpdate.java		diff \| blob \| history
accord-core/src/test/java/accord/coordinate/CoordinateTest.java		diff \| blob \| history
accord-core/src/test/java/accord/coordinate/PreAcceptTrackerTest.java		diff \| blob \| history
accord-core/src/test/java/accord/coordinate/RecoverTest.java		diff \| blob \| history
accord-core/src/test/java/accord/coordinate/TopologyChangeTest.java		diff \| blob \| history
accord-core/src/test/java/accord/coordinate/tracking/QuorumTrackerTest.java		diff \| blob \| history
accord-core/src/test/java/accord/coordinate/tracking/ReadTrackerTest.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/IntHashKey.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/IntKey.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/TestAgent.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/TopologyFactory.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/TopologyUtils.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/basic/Cluster.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/basic/NodeSink.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/basic/RandomDelayQueue.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/basic/RecurringPendingRunnable.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListAgent.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListQuery.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListRead.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListRequest.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListResult.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListUpdate.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/list/ListWrite.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/mock/EpochSync.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/mock/MockCluster.java		diff \| blob \| history
accord-core/src/test/java/accord/impl/mock/MockStore.java		diff \| blob \| history
accord-core/src/test/java/accord/local/CommandTest.java		diff \| blob \| history
accord-core/src/test/java/accord/local/NodeTest.java		diff \| blob \| history
accord-core/src/test/java/accord/messages/PreAcceptTest.java		diff \| blob \| history
accord-core/src/test/java/accord/messages/TxnRequestScopeTest.java		diff \| blob \| history
accord-core/src/test/java/accord/topology/TopologyManagerTest.java		diff \| blob \| history
accord-core/src/test/java/accord/topology/TopologyRandomizer.java		diff \| blob \| history
accord-core/src/test/java/accord/topology/TopologyTest.java		diff \| blob \| history
accord-core/src/test/java/accord/txn/DepsTest.java	[new file with mode: 0644]	blob
accord-core/src/test/java/accord/utils/Gen.java	[new file with mode: 0644]	blob
accord-core/src/test/java/accord/utils/GenTest.java	[new file with mode: 0644]	blob
accord-core/src/test/java/accord/utils/Gens.java	[new file with mode: 0644]	blob
accord-core/src/test/java/accord/utils/KeyRangeTest.java		diff \| blob \| history
accord-core/src/test/java/accord/utils/KeyRangesTest.java		diff \| blob \| history
accord-core/src/test/java/accord/utils/MessageTask.java		diff \| blob \| history
accord-core/src/test/java/accord/utils/Property.java	[new file with mode: 0644]	blob
accord-core/src/test/java/accord/utils/SortedArraysTest.java	[new file with mode: 0644]	blob
accord-core/src/test/resources/burn-logback-trace-rolling.xml	[new file with mode: 0644]	blob
accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/Datum.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/Json.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromAgent.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromKey.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromQuery.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromRead.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromReply.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromRequest.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromResult.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromUpdate.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/MaelstromWrite.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/Main.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/Packet.java		diff \| blob \| history
accord-maelstrom/src/main/java/accord/maelstrom/TopologyFactory.java		diff \| blob \| history

Accord Distributed Consensus Protocol for Apache Cassandra

RSS Atom