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 56b7710a Accord: Compute Dependencies Incrementally
add f114529f Improve Rebootstrap: - Distinguish corrupt/incomplete cases;
latter case only refuses uncertain data - Ensures fresh quorum durability
before marking own log faulty - Refuse unsafe operations more selectively once
log marked faulty - Simplify and merge logic with standard bootstrap, using
DurabilityService Also Improve: - Maintain multiple stale timestamp
reservations to allow us to issue stale timestamps closer to any conflicting
transaction - Maintain richer Acco [...]
No new revisions were added by this update.
Summary of changes:
accord-core/src/main/java/accord/api/Agent.java | 5 +
.../src/main/java/accord/api/AsyncExecutor.java | 3 +
.../src/main/java/accord/api/DataStore.java | 19 +-
.../src/main/java/accord/api/LocalListeners.java | 4 +-
.../main/java/accord/api/ProtocolModifiers.java | 7 +
.../src/main/java/accord/api/TopologySorter.java | 42 +-
.../accord/coordinate/AbstractCoordination.java | 68 ++-
.../java/accord/coordinate/AsynchronousAwait.java | 2 +-
.../java/accord/coordinate/CollectLatestDeps.java | 2 +-
.../accord/coordinate/CoordinateEphemeralRead.java | 2 +-
.../accord/coordinate/CoordinateMaxConflict.java | 2 +-
.../accord/coordinate/CoordinatePreAccept.java | 4 +-
.../accord/coordinate/CoordinationAdapter.java | 23 +-
.../accord/coordinate/ExecuteEphemeralRead.java | 2 +-
.../java/accord/coordinate/ExecuteSyncPoint.java | 53 ++-
.../main/java/accord/coordinate/ExecuteTxn.java | 18 +-
.../java/accord/coordinate/FailureAccumulator.java | 10 +-
.../java/accord/coordinate/FetchCoordinator.java | 24 +-
.../src/main/java/accord/coordinate/FetchData.java | 2 +-
.../java/accord/coordinate/FetchDurableBefore.java | 5 +-
.../main/java/accord/coordinate/Invalidate.java | 2 +-
.../src/main/java/accord/coordinate/Persist.java | 11 +-
.../src/main/java/accord/coordinate/Propose.java | 4 +-
.../src/main/java/accord/coordinate/Recover.java | 2 +-
.../src/main/java/accord/coordinate/Stabilise.java | 21 +-
.../java/accord/coordinate/SynchronousAwait.java | 2 +-
.../coordinate/tracking/AbstractTracker.java | 17 +-
.../coordinate/tracking/DurabilityTracker.java | 65 ++-
.../accord/coordinate/tracking/ReadTracker.java | 5 +-
.../java/accord/impl/AbstractFetchCoordinator.java | 95 ++---
.../main/java/accord/impl/AbstractReplayer.java | 6 +-
.../java/accord/impl/AbstractSafeCommandStore.java | 1 +
.../src/main/java/accord/impl/CommandChange.java | 7 +-
.../java/accord/impl/DefaultLocalListeners.java | 57 ++-
.../java/accord/impl/SizeOfIntersectionSorter.java | 4 +-
.../impl/progresslog/DefaultProgressLog.java | 69 ++-
.../java/accord/impl/progresslog/TxnState.java | 38 +-
.../java/accord/impl/progresslog/WaitingState.java | 50 ++-
.../src/main/java/accord/local/Bootstrap.java | 316 ++++++++++----
.../main/java/accord/local/BootstrapReason.java | 56 +++
.../src/main/java/accord/local/Catchup.java | 249 +++++------
.../src/main/java/accord/local/CatchupHard.java | 176 --------
.../src/main/java/accord/local/Cleanup.java | 146 +++++--
.../src/main/java/accord/local/Command.java | 64 +--
.../src/main/java/accord/local/CommandStore.java | 422 ++++++++++---------
.../src/main/java/accord/local/CommandStores.java | 82 ++--
.../src/main/java/accord/local/Commands.java | 26 +-
.../main/java/accord/local/ExecutionContext.java | 10 +-
.../src/main/java/accord/local/FetchAttempt.java | 5 +-
...ilableException.java => LogFaultException.java} | 15 +-
.../java/accord/local/MapReduceCommandStores.java | 71 +++-
.../src/main/java/accord/local/MaxConflicts.java | 8 +-
.../src/main/java/accord/local/MaxDecidedRX.java | 3 +
accord-core/src/main/java/accord/local/Node.java | 33 +-
.../java/accord/local/NodeCommandStoreService.java | 15 +
.../main/java/accord/local/RedundantBefore.java | 81 +++-
.../main/java/accord/local/RedundantStatus.java | 20 +-
.../main/java/accord/local/SafeCommandStore.java | 166 +++++---
.../main/java/accord/local/UniqueTimeService.java | 332 +++++++++++++++
.../main/java/accord/local/cfk/CommandsForKey.java | 10 +-
.../src/main/java/accord/local/cfk/NotifySink.java | 10 +-
.../main/java/accord/local/cfk/PostProcess.java | 41 +-
.../src/main/java/accord/local/cfk/Serialize.java | 1 -
.../src/main/java/accord/local/cfk/Updating.java | 25 +-
.../src/main/java/accord/local/cfk/Utils.java | 42 +-
.../accord/local/durability/DurabilityLevel.java | 74 ++--
.../accord/local/durability/DurabilityQueue.java | 2 +-
.../accord/local/durability/DurabilityRequest.java | 88 +++-
.../accord/local/durability/DurabilityResult.java | 56 ++-
.../accord/local/durability/DurabilityResults.java | 149 +++++++
.../accord/local/durability/DurabilityService.java | 92 ++--
.../accord/local/durability/ShardDurability.java | 25 +-
.../src/main/java/accord/messages/Accept.java | 48 ++-
.../accord/messages/ApplyThenWaitUntilApplied.java | 9 +-
.../src/main/java/accord/messages/Await.java | 2 +-
.../main/java/accord/messages/BeginRecovery.java | 60 +--
.../src/main/java/accord/messages/CheckStatus.java | 38 +-
.../src/main/java/accord/messages/Commit.java | 10 +-
.../java/accord/messages/GetEphemeralReadDeps.java | 6 +
.../main/java/accord/messages/GetLatestDeps.java | 16 +-
.../main/java/accord/messages/GetMaxConflict.java | 4 +-
.../main/java/accord/messages/InformDurable.java | 5 +-
.../main/java/accord/messages/NoWaitRequest.java | 12 +-
.../java/accord/messages/ParticipantsRequest.java | 1 +
.../src/main/java/accord/messages/PreAccept.java | 5 +
.../src/main/java/accord/messages/ReadData.java | 45 +-
.../main/java/accord/messages/RouteRequest.java | 1 +
.../main/java/accord/messages/StableThenRead.java | 4 +-
.../java/accord/primitives/AbstractRanges.java | 3 +-
.../src/main/java/accord/primitives/KnownMap.java | 3 +
.../src/main/java/accord/primitives/RangeDeps.java | 5 +-
.../src/main/java/accord/primitives/Timestamp.java | 5 +
.../src/main/java/accord/topology/EpochReady.java | 64 ++-
.../src/main/java/accord/topology/Topologies.java | 8 +-
.../src/main/java/accord/topology/Topology.java | 4 +-
.../main/java/accord/topology/TopologyManager.java | 5 +
.../src/main/java/accord/utils/Invariants.java | 15 +-
.../src/main/java/accord/utils/LogGroupTimers.java | 24 ++
.../java/accord/utils/ReducingIntervalMap.java | 2 +-
.../main/java/accord/utils/ReducingRangeMap.java | 21 +-
.../main/java/accord/utils/RelationMultiMap.java | 31 +-
.../src/main/java/accord/utils/Rethrowable.java | 7 +
.../src/main/java/accord/utils/SortedArrays.java | 36 ++
.../src/main/java/accord/utils/SortedListSet.java | 18 +-
.../accord/coordinate/CoordinateSyncPointTest.java | 9 +-
.../src/test/java/accord/impl/basic/Cluster.java | 27 +-
.../java/accord/impl/basic/InMemoryJournal.java | 19 +-
.../src/test/java/accord/impl/list/ListAgent.java | 2 +-
.../accord/impl/list/ListFetchCoordinator.java | 40 +-
.../src/test/java/accord/impl/list/ListStore.java | 60 +--
.../src/test/java/accord/impl/mock/MockStore.java | 9 +-
.../accord/local/AbstractDurableBeforeTest.java | 3 +
.../local/AtomicUniqueAutoStaleTimesTest.java | 309 ++++++++++++++
.../src/test/java/accord/local/CleanupTest.java | 170 ++++++++
.../java/accord/local/ImmutableCommandTest.java | 4 +-
.../java/accord/local/MaybeExecuteAdapterTest.java | 2 +-
.../accord/local/RedundantBoundWaiterTest.java | 270 ++++++++++++
.../local/cfk/CommandsForKeyImmutabilityTest.java | 363 ++++++++++++++++
.../cfk/CommandsForKeyRedundantBeforeFuzzTest.java | 171 ++++++++
.../java/accord/local/cfk/CommandsForKeyTest.java | 4 +-
.../local/cfk/CommandsForKeyUnreadyTest.java | 465 +++++++++++++++++++++
.../local/durability/DurabilityQueueTest.java | 9 +-
.../java/accord/topology/TopologyRandomizer.java | 5 +-
.../main/java/accord/maelstrom/MaelstromStore.java | 5 +-
124 files changed, 4688 insertions(+), 1439 deletions(-)
create mode 100644 accord-core/src/main/java/accord/local/BootstrapReason.java
delete mode 100644 accord-core/src/main/java/accord/local/CatchupHard.java
rename accord-core/src/main/java/accord/local/{LogUnavailableException.java =>
LogFaultException.java} (72%)
create mode 100644
accord-core/src/main/java/accord/local/durability/DurabilityResults.java
create mode 100644
accord-core/src/test/java/accord/local/AtomicUniqueAutoStaleTimesTest.java
create mode 100644 accord-core/src/test/java/accord/local/CleanupTest.java
create mode 100644
accord-core/src/test/java/accord/local/RedundantBoundWaiterTest.java
create mode 100644
accord-core/src/test/java/accord/local/cfk/CommandsForKeyImmutabilityTest.java
create mode 100644
accord-core/src/test/java/accord/local/cfk/CommandsForKeyRedundantBeforeFuzzTest.java
create mode 100644
accord-core/src/test/java/accord/local/cfk/CommandsForKeyUnreadyTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
