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 c524b6d Pre-requisite changes for CASSANDRA-18888 (#74)
new 29164d4 Various fixes
new 751d840 wip: introduce deps stability
new 34ea651 wip
new e72e4e7 fix compilation
new 509cbd7 serializer support
new f85795c serializer support
new 09b212a serializer support
new 113ed2e fix rebase
new 86e533f fixup
new deb8f02 fixup
new da4450e fixes
new 16cf1eb address NPE
new 4232d02 extra validation
The 13 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:
.../main/java/accord/api/ConfigurationService.java | 2 +-
.../src/main/java/accord/api/EventsListener.java | 4 +
.../src/main/java/accord/api/ProgressLog.java | 8 +-
.../src/main/java/accord/coordinate/Barrier.java | 3 +-
.../main/java/accord/coordinate/BlockOnDeps.java | 16 +-
.../main/java/accord/coordinate/CheckShards.java | 4 +-
.../main/java/accord/coordinate/CollectDeps.java | 2 +-
.../java/accord/coordinate/CoordinateNoOp.java | 2 +-
.../accord/coordinate/CoordinateShardDurable.java | 4 +-
.../accord/coordinate/CoordinateSyncPoint.java | 10 +-
.../accord/coordinate/CoordinateTransaction.java | 3 +-
.../src/main/java/accord/coordinate/Execute.java | 15 +-
.../{TxnExecute.java => ExecuteTxn.java} | 50 ++-
.../java/accord/coordinate/FetchCoordinator.java | 3 +-
.../src/main/java/accord/coordinate/Infer.java | 9 +-
.../java/accord/coordinate/InformHomeOfTxn.java | 1 -
.../main/java/accord/coordinate/Invalidate.java | 4 +-
.../main/java/accord/coordinate/MaybeRecover.java | 8 +
.../src/main/java/accord/coordinate/Persist.java | 20 +-
.../{TxnPersist.java => PersistTxn.java} | 6 +-
.../java/accord/coordinate/ProposeAndExecute.java | 8 +-
.../java/accord/coordinate/ProposeSyncPoint.java | 10 +-
.../src/main/java/accord/coordinate/Recover.java | 124 +++---
.../java/accord/coordinate/RecoverWithRoute.java | 11 +-
.../accord/coordinate/RecoverWithSomeRoute.java | 3 +-
.../src/main/java/accord/coordinate/Stabilise.java | 179 +++++++++
.../{TxnPersist.java => StabiliseTxn.java} | 17 +-
.../coordinate/tracking/AbstractTracker.java | 2 +-
.../accord/coordinate/tracking/ReadTracker.java | 6 +-
.../java/accord/impl/AbstractFetchCoordinator.java | 9 +-
.../java/accord/impl/AbstractSafeCommandStore.java | 5 +-
.../main/java/accord/impl/CommandTimeseries.java | 11 +-
.../src/main/java/accord/impl/CommandsForKeys.java | 1 +
.../main/java/accord/impl/ErasedSafeCommand.java | 8 +-
.../java/accord/impl/InMemoryCommandStore.java | 35 +-
.../main/java/accord/impl/InMemorySafeCommand.java | 4 +-
.../main/java/accord/impl/SimpleProgressLog.java | 56 ++-
.../java/accord/impl/SizeOfIntersectionSorter.java | 1 -
.../src/main/java/accord/local/Bootstrap.java | 7 +-
.../src/main/java/accord/local/Command.java | 120 +++---
.../src/main/java/accord/local/CommandStore.java | 159 +++++---
.../src/main/java/accord/local/CommandStores.java | 5 +-
.../src/main/java/accord/local/Commands.java | 114 +++---
.../src/main/java/accord/local/DurableBefore.java | 2 +-
accord-core/src/main/java/accord/local/Node.java | 7 +-
.../main/java/accord/local/RedundantBefore.java | 37 +-
.../main/java/accord/local/RedundantStatus.java | 3 +-
.../src/main/java/accord/local/SafeCommand.java | 9 +-
.../main/java/accord/local/SafeCommandStore.java | 7 +-
.../src/main/java/accord/local/SaveStatus.java | 51 ++-
.../main/java/accord/local/SerializerSupport.java | 243 +++++-------
accord-core/src/main/java/accord/local/Status.java | 121 ++++--
.../main/java/accord/messages/AbstractExecute.java | 20 +-
.../src/main/java/accord/messages/Accept.java | 3 +-
.../src/main/java/accord/messages/Apply.java | 10 +-
.../accord/messages/ApplyThenWaitUntilApplied.java | 8 +-
.../java/accord/messages/BeginInvalidation.java | 2 +-
.../main/java/accord/messages/BeginRecovery.java | 51 +--
.../src/main/java/accord/messages/CheckStatus.java | 137 ++++---
.../src/main/java/accord/messages/Commit.java | 168 +++++---
.../src/main/java/accord/messages/MessageType.java | 7 +-
.../src/main/java/accord/messages/PreAccept.java | 15 +-
.../src/main/java/accord/messages/Propagate.java | 94 ++---
.../src/main/java/accord/messages/ReadData.java | 36 +-
.../main/java/accord/messages/WaitOnCommit.java | 2 +
.../java/accord/messages/WaitUntilApplied.java | 20 +-
.../main/java/accord/primitives/AbstractKeys.java | 16 +-
.../accord/primitives/AbstractUnseekableKeys.java | 2 +-
.../src/main/java/accord/primitives/KeyDeps.java | 114 ++++--
.../src/main/java/accord/primitives/Keys.java | 10 +
.../main/java/accord/primitives/LatestDeps.java | 429 +++++++++++++++++++++
.../main/java/accord/primitives/PartialDeps.java | 2 +
.../main/java/accord/primitives/PartialTxn.java | 6 +-
.../src/main/java/accord/primitives/Range.java | 3 +-
.../src/main/java/accord/primitives/RangeDeps.java | 32 +-
.../src/main/java/accord/primitives/Seekables.java | 1 +
.../src/main/java/accord/primitives/Txn.java | 12 -
.../src/main/java/accord/primitives/TxnId.java | 8 +-
.../src/main/java/accord/topology/Topologies.java | 7 +-
.../src/main/java/accord/topology/Topology.java | 3 +-
.../main/java/accord/topology/TopologyManager.java | 3 +-
.../src/main/java/accord/utils/ArrayBuffers.java | 4 +-
.../accord/utils/{SortedList.java => Faults.java} | 10 +-
.../src/main/java/accord/utils/Invariants.java | 6 +-
.../java/accord/utils/ReducingIntervalMap.java | 181 ++++++++-
.../main/java/accord/utils/ReducingRangeMap.java | 6 +-
.../main/java/accord/utils/RelationMultiMap.java | 39 +-
.../src/main/java/accord/utils/SortedArrays.java | 7 +-
.../java/accord/utils/ThreadPoolScheduler.java | 4 +-
.../main/java/accord/utils/async/AsyncChains.java | 6 +-
.../main/java/accord/utils/async/AsyncResult.java | 6 +-
.../main/java/accord/utils/async/AsyncResults.java | 8 +-
accord-core/src/test/java/accord/Utils.java | 6 +-
.../accord/burn/random/FrequentLargeRange.java | 6 +-
.../coordinate/CoordinateTransactionTest.java | 4 +-
.../src/test/java/accord/impl/basic/Cluster.java | 11 +-
.../src/test/java/accord/impl/basic/NodeSink.java | 1 +
.../src/test/java/accord/impl/list/ListAgent.java | 3 +-
.../test/java/accord/impl/list/ListRequest.java | 7 +-
.../src/test/java/accord/impl/list/ListStore.java | 8 +-
.../test/java/accord/impl/mock/MockCluster.java | 11 +-
.../test/java/accord/local/CheckedCommands.java | 14 +-
.../java/accord/local/ImmutableCommandTest.java | 8 +-
.../test/java/accord/messages/ReadDataTest.java | 17 +-
.../java/accord/utils/ReducingRangeMapTest.java | 40 +-
.../java/accord/utils/async/AsyncChainsTest.java | 9 +-
.../src/test/java/accord/verify/ElleVerifier.java | 3 +
.../accord/verify/SerializabilityVerifier.java | 6 +-
.../verify/StrictSerializabilityVerifier.java | 6 +-
.../src/main/java/accord/maelstrom/Body.java | 3 +-
.../src/main/java/accord/maelstrom/Cluster.java | 11 +-
.../src/main/java/accord/maelstrom/Json.java | 4 +-
.../main/java/accord/maelstrom/MaelstromReply.java | 4 +-
.../java/accord/maelstrom/MaelstromRequest.java | 4 +-
.../java/accord/maelstrom/MaelstromResult.java | 4 +-
.../src/main/java/accord/maelstrom/Main.java | 6 +-
.../src/main/java/accord/maelstrom/Packet.java | 6 +-
117 files changed, 2238 insertions(+), 1011 deletions(-)
rename accord-core/src/main/java/accord/coordinate/{TxnExecute.java =>
ExecuteTxn.java} (62%)
copy accord-core/src/main/java/accord/coordinate/{TxnPersist.java =>
PersistTxn.java} (90%)
create mode 100644 accord-core/src/main/java/accord/coordinate/Stabilise.java
rename accord-core/src/main/java/accord/coordinate/{TxnPersist.java =>
StabiliseTxn.java} (66%)
create mode 100644 accord-core/src/main/java/accord/primitives/LatestDeps.java
copy accord-core/src/main/java/accord/utils/{SortedList.java => Faults.java}
(74%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
