You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by be...@apache.org on 2025/09/18 14:58:23 UTC
(cassandra-accord) branch trunk-tmp2 updated (0d7ff279 -> 5b35a301)
This is an automated email from the ASF dual-hosted git repository.
benedict pushed a change to branch trunk-tmp2
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
discard 0d7ff279 Startup sequence improvements
discard 16e1551d Minor tracing and progress log improvements: Fix - FetchData tracing parameter was not being propagated - Progress log waiting state could infinite loop without making progress Improve: - Progress log waiting state tracing - Simplify progress log run counters
omit 5fff5240 ConcurrentModificationException with CommandStore.waitingOnSync
omit 748344e6 Bootstrap must first wait for a quorum to apply the sync point to ensure the DurableBefore Majority condition holds transitively, since later quorums may include the bootstrapping node which does not participate in the durability of preceding transactions Also Improve: - Apply MaxDecidedRX filtering to CommandsForKey RX dependencies - Optimise AbstractRanges.sliceMinimal (burn test hotspot) - Don't start shard schedulers on topology changes if not already started - O [...]
omit 98ad4f0e Improve ProgressLog: - Schedule a fallback timeout for active requests to ensure progress with lost callbacks - Clear active task for a txnId when new RunInvoker is registered - Consult DurableBefore prior to invoking recovery - Support user invoked reset of a command, clearing any active work and requeueing it - (Testing): Treat progress log for RX as recurring tasks for burn test termination Also fix: - Handle another truncateWithOutcome edge case
omit 0f846434 Fix CFK restore after replay: - Remove from CFK any unapplied transactions we know cannot apply - Force notification of waiting commands in CFK on replay Also fix: - Don't truncateWithOutcome if pre bootstrap or stale - Fix RangeDeps.without(RangeDeps) - Fix InMemoryCommandStore replay bug with clearing DefaultLocalListeners - Ensure SaveStatus and executeAt are updated together to prevent corruption via expunge Improve: - Inform home shard that command is decided [...]
add 2f287b6c Journal.TopologyUpdate should not store the local topology as it can be inferred from the global on (#229)
add 05b2f241 Fix CFK restore after replay: - Remove from CFK any unapplied transactions we know cannot apply - Force notification of waiting commands in CFK on replay Also fix: - Don't truncateWithOutcome if pre bootstrap or stale - Fix RangeDeps.without(RangeDeps) - Fix InMemoryCommandStore replay bug with clearing DefaultLocalListeners - Ensure SaveStatus and executeAt are updated together to prevent corruption via expunge Improve: - Inform home shard that command is decided [...]
add 20df7e5e Improve ProgressLog: - Schedule a fallback timeout for active requests to ensure progress with lost callbacks - Clear active task for a txnId when new RunInvoker is registered - Consult DurableBefore prior to invoking recovery - Support user invoked reset of a command, clearing any active work and requeueing it - (Testing): Treat progress log for RX as recurring tasks for burn test termination Also fix: - Handle another truncateWithOutcome edge case
add d5de79b5 Bootstrap must first wait for a quorum to apply the sync point to ensure the DurableBefore Majority condition holds transitively, since later quorums may include the bootstrapping node which does not participate in the durability of preceding transactions Also Improve: - Apply MaxDecidedRX filtering to CommandsForKey RX dependencies - Optimise AbstractRanges.sliceMinimal (burn test hotspot) - Don't start shard schedulers on topology changes if not already started - O [...]
add 12da4693 ConcurrentModificationException with CommandStore.waitingOnSync
add 0c3c7bf7 Minor tracing and progress log improvements: Fix - FetchData tracing parameter was not being propagated - Progress log waiting state could infinite loop without making progress Improve: - Progress log waiting state tracing - Simplify progress log run counters
add b268e9a7 Accord: fix durability scheduling order, initialize them _after_ nodes are created
add b86550c1 Enrich Durability with each phase, so we can both prune unapplied dependencies to mitigate replicas that are behind causing Deps growth, and more reliably avoid initialising recovery progress log state of transactions that cannot yet make progress Also fix: - Infer invalid in MaybeRecover and FetchData - MaybeRecover sometimes aborts before home shard knows outcome - Epoch sync with VisibilitySyncPoint - Retired implies synced Also improve: - Add Topology.removedNod [...]
add a8916a18 Startup sequence improvements
add 5cbe8d62 Accord fixes: - Fix erroneous call to registerWithDelay with absolute deadline - ExecuteSyncPoint should discount votes from unbootstrapped replicas - Bootstrap no longer needs to first ensure durability (now ExecuteSyncPoint discounts votes from unbootstrapped replicas) - Progress stall with home shard stopping before Stable is propagated to all shards - Only upgrade Durability.HasPhase if we have queried all shards - Incorrectly inferring Durability in CheckStatu [...]
add 48061a52 Improve Observability: - Track all active Coordinations - Refactor Replica/Coordinator metrics and report Coordinator exhausted/preempted/timeout - DurabilityQueue metrics and visibility Also Fix: - WaitingState can get cause distributed stall when asked to wait for CanApply if not yet PreCommitted; track separate querying state and advance this to the next achievable state rather than the desired final state - Stalled coordinators should not prevent recovery - Edg [...]
add c3a62d77 All pending topology notifications must be propagated to a newly published epoch, not only the pending notification for that epoch Also Fix: - removeRedundantMissing could erroneously remove missing dependencies occurring after the new appliedBeforeIndex - Invariant failure for some propagate calls supplying 'wrong' addRoute - Disambiguate nextTxnId and nextTxnIdWithDefaultFlags - Journal.replayTopologies to return List for consistency of integration and semi-integra [...]
add 875937c8 CASSANDRA-20883: bitset changes to support cassandra serializers
add 9c7f856c RegisteredCallback should remove itself from callback map when cancelled Also Fix: - Do not throw CancellationException when processing requests that have been aborted, as may be caused by a successful meaningful reply that can be overridden Also Improve: - Violation information reported - Sort CommandStore shards by id
add 27aec780 Strict Serializability Verifier may incorrectly handle blind writes when witnessed before the writing operation ACKs
add 78b84b08 Split AsyncChain and AsyncResult; normalise AsyncResult with C* Future
add 520818a0 Follow-up to CASSANDRA-20906: Fix Simulator
add 5b35a301 Rebootstrap Also Refine: - Introduce MapReduceConsumeCommandStore for enforcing message refusal comprehensively - Refactor to RedundantStatus: - use int rather than short to prepare to support more statuses - merge PreBootstrap and Unready (into Unready) Also Fix: - Propagate Erase to no longer participating replica - RecoverAwait to original coordinator was not correctly notifying - Cancel messages if we encounter an exception so we do not attempt to process [...]
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0d7ff279)
\
N -- N -- N refs/heads/trunk-tmp2 (5b35a301)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitignore | 7 +
accord-core/src/main/java/accord/api/Agent.java | 29 +-
.../src/main/java/accord/api/AsyncExecutor.java | 29 +-
.../main/java/accord/api/ConfigurationService.java | 9 +-
.../java/accord/api/CoordinatorEventListener.java | 48 +-
.../src/main/java/accord/api/DataStore.java | 10 +-
accord-core/src/main/java/accord/api/Journal.java | 33 +-
.../src/main/java/accord/api/MessageSink.java | 7 +-
...ionHandler.java => OwnershipEventListener.java} | 28 +-
.../src/main/java/accord/api/ProgressLog.java | 80 +-
.../main/java/accord/api/ProtocolModifiers.java | 13 +-
.../src/main/java/accord/api/RemoteListeners.java | 6 +-
...ventListener.java => ReplicaEventListener.java} | 74 +-
.../src/main/java/accord/api/Scheduler.java | 1 +
accord-core/src/main/java/accord/api/Timeouts.java | 2 +-
accord-core/src/main/java/accord/api/Tracing.java | 43 +-
.../src/main/java/accord/api/ViolationHandler.java | 48 +-
.../coordinate/{Preempted.java => Aborted.java} | 23 +-
.../coordinate/AbstractCoordinatePreAccept.java | 83 +--
.../accord/coordinate/AbstractCoordination.java | 347 +++++++++
.../coordinate/AbstractSimpleCoordination.java | 117 +++
.../java/accord/coordinate/AsynchronousAwait.java | 67 +-
.../main/java/accord/coordinate/CheckShards.java | 44 +-
.../java/accord/coordinate/CollectLatestDeps.java | 95 ++-
.../accord/coordinate/CoordinateEphemeralRead.java | 59 +-
.../accord/coordinate/CoordinateMaxConflict.java | 72 +-
.../accord/coordinate/CoordinatePreAccept.java | 52 +-
.../accord/coordinate/CoordinateSyncPoint.java | 96 +--
.../accord/coordinate/CoordinateTransaction.java | 107 +--
.../main/java/accord/coordinate/Coordination.java | 79 ++
.../accord/coordinate/CoordinationAdapter.java | 125 +++-
.../java/accord/coordinate/CoordinationFailed.java | 9 -
.../main/java/accord/coordinate/Coordinations.java | 157 ++++
.../main/java/accord/coordinate/EpochTimeout.java | 9 +-
.../accord/coordinate/ExecuteEphemeralRead.java | 70 +-
.../java/accord/coordinate/ExecuteSyncPoint.java | 205 +++---
.../main/java/accord/coordinate/ExecuteTxn.java | 339 ++++++---
.../src/main/java/accord/coordinate/Exhausted.java | 13 +-
.../java/accord/coordinate/FailureAccumulator.java | 50 +-
.../java/accord/coordinate/FetchCoordinator.java | 72 +-
.../src/main/java/accord/coordinate/FetchData.java | 29 +-
.../main/java/accord/coordinate/FetchRoute.java | 39 +-
.../src/main/java/accord/coordinate/FindRoute.java | 82 ---
.../src/main/java/accord/coordinate/Infer.java | 32 +-
.../main/java/accord/coordinate/Invalidate.java | 203 +++---
.../main/java/accord/coordinate/Invalidated.java | 9 +-
.../main/java/accord/coordinate/KeyBarriers.java | 75 +-
.../main/java/accord/coordinate/MaybeRecover.java | 66 +-
.../src/main/java/accord/coordinate/Persist.java | 81 ++-
.../java/accord/coordinate/PersistSyncPoint.java | 26 +-
.../main/java/accord/coordinate/PersistTxn.java | 4 +-
.../src/main/java/accord/coordinate/Preempted.java | 11 +-
...{RecoverWithRoute.java => PrepareRecovery.java} | 58 +-
.../src/main/java/accord/coordinate/Propose.java | 229 +++---
.../main/java/accord/coordinate/ProposeOnly.java | 2 +-
.../java/accord/coordinate/ReadCoordinator.java | 199 +++--
.../src/main/java/accord/coordinate/Recover.java | 370 +++++-----
.../src/main/java/accord/coordinate/Redundant.java | 2 +-
.../src/main/java/accord/coordinate/Stabilise.java | 121 +--
.../main/java/accord/coordinate/StabiliseOnly.java | 2 +-
.../java/accord/coordinate/SynchronousAwait.java | 70 +-
.../accord/coordinate/SynchronousRecoverAwait.java | 65 +-
.../src/main/java/accord/coordinate/Timeout.java | 16 +-
.../coordinate/tracking/AbstractTracker.java | 23 +
.../accord/coordinate/tracking/AllTracker.java | 6 +
.../accord/coordinate/tracking/AwaitTracker.java | 6 +
.../coordinate/tracking/DurabilityTracker.java | 11 +-
.../coordinate/tracking/FastPathTracker.java | 6 +
.../coordinate/tracking/InvalidationTracker.java | 6 +
.../coordinate/tracking/QuorumIdTracker.java | 6 +
.../accord/coordinate/tracking/QuorumTracker.java | 6 +
.../accord/coordinate/tracking/ReadTracker.java | 22 +-
.../accord/coordinate/tracking/ShardTracker.java | 2 +
.../AbstractAsyncExecutor.java} | 28 +-
.../accord/impl/AbstractConfigurationService.java | 131 ++--
.../java/accord/impl/AbstractFetchCoordinator.java | 13 +-
.../main/java/accord/impl/AbstractReplayer.java | 2 +-
.../main/java/accord/impl/AbstractTimeouts.java | 58 +-
.../src/main/java/accord/impl/CommandChange.java | 139 ++--
.../java/accord/impl/DefaultLocalListeners.java | 2 +-
.../java/accord/impl/DefaultRemoteListeners.java | 19 +-
.../java/accord/impl/InMemoryCommandStore.java | 139 ++--
.../main/java/accord/impl/RequestCallbacks.java | 45 +-
.../impl/progresslog/DefaultProgressLog.java | 152 ++--
.../java/accord/impl/progresslog/HomeState.java | 35 +-
.../accord/impl/progresslog/PackedKeyTracker.java | 5 +-
.../impl/progresslog/SavedProgressToken.java | 2 +-
.../java/accord/impl/progresslog/WaitingState.java | 267 ++++---
.../src/main/java/accord/local/Bootstrap.java | 75 +-
.../src/main/java/accord/local/Cleanup.java | 88 ++-
.../src/main/java/accord/local/Command.java | 108 +--
.../src/main/java/accord/local/CommandStore.java | 372 +++++++---
.../src/main/java/accord/local/CommandStores.java | 341 ++++-----
.../main/java/accord/local/CommandSummaries.java | 102 ++-
.../src/main/java/accord/local/Commands.java | 265 ++++---
.../src/main/java/accord/local/DepsCalculator.java | 18 +-
.../src/main/java/accord/local/DurableBefore.java | 80 +-
.../accord/local/LogUnavailableException.java} | 15 +-
.../java/accord/local/MapReduceCommandStores.java | 68 ++
.../local/MapReduceConsumeCommandStores.java | 95 +++
.../src/main/java/accord/local/MaxDecidedRX.java | 159 ++--
accord-core/src/main/java/accord/local/Node.java | 283 +++----
.../java/accord/local/NodeCommandStoreService.java | 4 +-
.../main/java/accord/local/RedundantBefore.java | 314 ++++----
.../main/java/accord/local/RedundantStatus.java | 244 ++++---
.../src/main/java/accord/local/SafeCommand.java | 2 +-
.../main/java/accord/local/SafeCommandStore.java | 46 +-
.../main/java/accord/local/StoreParticipants.java | 36 +-
.../main/java/accord/local/cfk/CommandsForKey.java | 349 +++++----
.../main/java/accord/local/cfk/PostProcess.java | 36 +-
.../src/main/java/accord/local/cfk/Pruning.java | 48 +-
.../java/accord/local/cfk/SafeCommandsForKey.java | 5 +-
.../src/main/java/accord/local/cfk/Serialize.java | 64 +-
.../src/main/java/accord/local/cfk/Updating.java | 56 +-
.../src/main/java/accord/local/cfk/Utils.java | 81 ++-
.../local/durability/ConcurrencyControl.java | 2 +-
.../accord/local/durability/DurabilityQueue.java | 33 +-
.../accord/local/durability/DurabilityRequest.java | 16 +-
.../accord/local/durability/DurabilityService.java | 33 +-
.../accord/local/durability/GlobalDurability.java | 6 +-
.../accord/local/durability/ShardDurability.java | 23 +-
.../src/main/java/accord/messages/Accept.java | 36 +-
.../src/main/java/accord/messages/Apply.java | 108 ++-
.../accord/messages/ApplyThenWaitUntilApplied.java | 17 +-
.../src/main/java/accord/messages/Await.java | 232 +++++-
.../java/accord/messages/BeginInvalidation.java | 33 +-
.../main/java/accord/messages/BeginRecovery.java | 42 +-
.../src/main/java/accord/messages/Callback.java | 5 +-
.../src/main/java/accord/messages/CheckStatus.java | 150 ++--
.../src/main/java/accord/messages/Commit.java | 187 +++--
.../java/accord/messages/GetEphemeralReadDeps.java | 6 +-
.../main/java/accord/messages/GetLatestDeps.java | 6 +-
.../main/java/accord/messages/GetMaxConflict.java | 6 +-
.../main/java/accord/messages/InformDecided.java | 93 ---
.../main/java/accord/messages/InformDurable.java | 12 +-
.../src/main/java/accord/messages/MessageType.java | 1 -
.../{AbstractRequest.java => NoWaitRequest.java} | 41 +-
.../{TxnRequest.java => ParticipantsRequest.java} | 74 +-
.../src/main/java/accord/messages/PreAccept.java | 6 +-
.../src/main/java/accord/messages/Propagate.java | 109 +--
.../src/main/java/accord/messages/ReadData.java | 188 +++--
.../java/accord/messages/ReadEphemeralTxnData.java | 25 +-
.../src/main/java/accord/messages/ReadTxnData.java | 6 +
.../main/java/accord/messages/RecoverAwait.java | 20 +-
.../src/main/java/accord/messages/Reply.java | 6 +
.../main/java/accord/messages/RouteRequest.java | 78 ++
.../main/java/accord/messages/SafeCallback.java | 29 +-
.../main/java/accord/messages/SetShardDurable.java | 32 +-
.../main/java/accord/messages/StableThenRead.java | 22 +-
.../main/java/accord/primitives/AbstractKeys.java | 15 +-
.../src/main/java/accord/primitives/KeyDeps.java | 149 ++--
.../src/main/java/accord/primitives/Known.java | 11 +-
.../src/main/java/accord/primitives/KnownMap.java | 163 +++--
.../main/java/accord/primitives/LatestDeps.java | 2 +-
.../main/java/accord/primitives/ProgressToken.java | 49 +-
.../src/main/java/accord/primitives/RangeDeps.java | 176 +++--
.../src/main/java/accord/primitives/Ranges.java | 20 +-
.../src/main/java/accord/primitives/Status.java | 478 ++++++++++--
.../src/main/java/accord/primitives/Timestamp.java | 42 +-
.../src/main/java/accord/primitives/Txn.java | 83 +--
.../src/main/java/accord/primitives/TxnId.java | 8 +-
.../src/main/java/accord/primitives/Writes.java | 5 +-
.../src/main/java/accord/topology/Topologies.java | 11 +-
.../src/main/java/accord/topology/Topology.java | 51 +-
.../main/java/accord/topology/TopologyManager.java | 116 +--
.../src/main/java/accord/utils/BitUtils.java | 13 +-
.../DebugMap.java} | 24 +-
.../main/java/accord/utils/DeterministicSet.java | 6 +
.../main/java/accord/utils/ImmutableBitSet.java | 6 +-
.../java/accord/utils/IntrusivePriorityHeap.java | 6 +
.../src/main/java/accord/utils/Invariants.java | 32 +-
.../utils/{SimpleBitSet.java => LargeBitSet.java} | 37 +-
.../main/java/accord/utils/MapReduceConsume.java | 11 +-
.../java/accord/utils/ReducingIntervalMap.java | 11 +-
.../main/java/accord/utils/ReducingRangeMap.java | 8 +-
.../main/java/accord/utils/RelationMultiMap.java | 6 +-
.../src/main/java/accord/utils/SimpleBitSet.java | 480 +-----------
.../{DefaultRandom.java => SimpleBitSets.java} | 22 +-
.../src/main/java/accord/utils/SmallBitSet.java | 97 +++
.../src/main/java/accord/utils/SortedArrays.java | 257 ++++++-
.../src/main/java/accord/utils/SortedList.java | 12 +-
.../src/main/java/accord/utils/SortedListMap.java | 92 ++-
.../src/main/java/accord/utils/SortedListSet.java | 35 +-
accord-core/src/main/java/accord/utils/Utils.java | 6 +-
.../java/accord/utils/async/AsyncCallbacks.java | 195 ++++-
.../main/java/accord/utils/async/AsyncChain.java | 121 +--
.../main/java/accord/utils/async/AsyncChains.java | 810 ++++++++-------------
...{AsyncChainCombiner.java => AsyncCombiner.java} | 55 +-
.../main/java/accord/utils/async/AsyncResult.java | 121 ++-
.../main/java/accord/utils/async/AsyncResults.java | 145 ++--
.../main/java/accord/utils/async/Observable.java | 160 ----
accord-core/src/test/java/accord/Utils.java | 6 +-
.../src/test/java/accord/burn/BurnTest.java | 24 +-
.../src/test/java/accord/burn/BurnTestBase.java | 265 +++++--
.../accord/burn/BurnTestConfigurationService.java | 13 +-
.../src/test/java/accord/burn/TopologyUpdates.java | 26 -
.../accord/coordinate/CoordinateSyncPointTest.java | 26 +-
.../coordinate/CoordinateTransactionTest.java | 14 +-
.../accord/coordinate/FailureAccumulatorTest.java | 20 +-
.../java/accord/coordinate/TopologyChangeTest.java | 32 +-
.../impl/AbstractConfigurationServiceTest.java | 6 +-
....java => AbstractTestConfigurationService.java} | 47 +-
.../test/java/accord/impl/LocalListenersTest.java | 2 +-
.../src/test/java/accord/impl/MessageListener.java | 6 +-
.../test/java/accord/impl/RemoteListenersTest.java | 30 +-
.../src/test/java/accord/impl/TestAgent.java | 43 +-
.../src/test/java/accord/impl/basic/Cluster.java | 241 +++---
.../accord/impl/basic/DelayedCommandStores.java | 69 +-
.../java/accord/impl/basic/InMemoryJournal.java | 88 +--
.../java/accord/impl/basic/LoggingJournal.java | 18 +-
.../src/test/java/accord/impl/basic/NodeSink.java | 6 +-
.../java/accord/impl/basic/RandomDelayQueue.java | 181 ++++-
.../impl/basic/RecurringPendingRunnable.java | 10 +-
.../basic/SimulatedDelayedExecutorService.java | 20 +
.../accord/impl/basic/TaskExecutorService.java | 19 -
.../src/test/java/accord/impl/list/ListAgent.java | 57 +-
.../src/test/java/accord/impl/list/ListData.java | 3 +-
.../accord/impl/list/ListFetchCoordinator.java | 8 +-
.../src/test/java/accord/impl/list/ListRead.java | 4 +-
.../test/java/accord/impl/list/ListRequest.java | 16 +-
.../src/test/java/accord/impl/list/ListStore.java | 4 +-
.../src/test/java/accord/impl/list/ListWrite.java | 2 +-
.../test/java/accord/impl/list/Snapshotter.java | 2 +-
.../test/java/accord/impl/mock/MockCluster.java | 14 +-
.../accord/impl/mock/MockConfigurationService.java | 7 +-
.../src/test/java/accord/impl/mock/MockStore.java | 5 +-
.../src/test/java/accord/impl/mock/Network.java | 6 +-
.../accord/impl/mock/RecordingMessageSink.java | 5 +-
.../java/accord/impl/mock/SimpleMessageSink.java | 5 +-
.../src/test/java/accord/local/CommandsTest.java | 2 +-
.../java/accord/local/ImmutableCommandTest.java | 14 +-
.../java/accord/local/RedundantBeforeTest.java | 17 +-
.../java/accord/local/cfk/CommandsForKeyTest.java | 49 +-
.../test/java/accord/messages/PreAcceptTest.java | 4 +-
.../test/java/accord/messages/ReadDataTest.java | 20 +-
...stScopeTest.java => RouteRequestScopeTest.java} | 22 +-
.../java/accord/primitives/AbstractRangesTest.java | 2 +-
.../java/accord/topology/TopologyManagerTest.java | 13 +-
.../java/accord/topology/TopologyRandomizer.java | 131 +++-
.../test/java/accord/topology/TopologyUtils.java | 2 +-
.../src/test/java/accord/utils/AccordGens.java | 3 +-
.../test/java/accord/utils/ExtendedAssertions.java | 4 +-
...{SimpleBitSetTest.java => LargeBitSetTest.java} | 10 +-
.../test/java/accord/utils/SimpleBitSetTest.java | 263 ++++---
.../test/java/accord/utils/SortedArraysTest.java | 2 +-
.../java/accord/utils/async/AsyncChainUtils.java | 206 ++++++
.../java/accord/utils/async/AsyncChainsTest.java | 78 +-
.../java/accord/utils/async/AsyncResultTest.java | 387 ++++++++++
.../test/java/accord/utils/async/TimeoutUtils.java | 2 +-
.../verify/StrictSerializabilityVerifier.java | 9 +-
.../src/main/java/accord/maelstrom/Cluster.java | 14 +-
.../main/java/accord/maelstrom/MaelstromAgent.java | 18 +-
.../main/java/accord/maelstrom/MaelstromStore.java | 2 +-
.../main/java/accord/maelstrom/MaelstromWrite.java | 4 +-
.../src/main/java/accord/maelstrom/Main.java | 15 +-
.../java/accord/maelstrom/SimpleConfigService.java | 3 +-
.../java/accord/maelstrom/TopologyFactory.java | 3 +-
257 files changed, 10763 insertions(+), 6749 deletions(-)
copy accord-core/src/main/java/accord/api/{ViolationHandler.java => OwnershipEventListener.java} (52%)
rename accord-core/src/main/java/accord/api/{LocalEventListener.java => ReplicaEventListener.java} (76%)
copy accord-core/src/main/java/accord/coordinate/{Preempted.java => Aborted.java} (64%)
create mode 100644 accord-core/src/main/java/accord/coordinate/AbstractCoordination.java
create mode 100644 accord-core/src/main/java/accord/coordinate/AbstractSimpleCoordination.java
create mode 100644 accord-core/src/main/java/accord/coordinate/Coordination.java
create mode 100644 accord-core/src/main/java/accord/coordinate/Coordinations.java
delete mode 100644 accord-core/src/main/java/accord/coordinate/FindRoute.java
rename accord-core/src/main/java/accord/coordinate/{RecoverWithRoute.java => PrepareRecovery.java} (83%)
copy accord-core/src/main/java/accord/{utils/async/RunnableWithResult.java => impl/AbstractAsyncExecutor.java} (58%)
copy accord-core/src/{test/java/accord/impl/basic/SimulatedFault.java => main/java/accord/local/LogUnavailableException.java} (70%)
create mode 100644 accord-core/src/main/java/accord/local/MapReduceCommandStores.java
create mode 100644 accord-core/src/main/java/accord/local/MapReduceConsumeCommandStores.java
delete mode 100644 accord-core/src/main/java/accord/messages/InformDecided.java
rename accord-core/src/main/java/accord/messages/{AbstractRequest.java => NoWaitRequest.java} (82%)
rename accord-core/src/main/java/accord/messages/{TxnRequest.java => ParticipantsRequest.java} (68%)
create mode 100644 accord-core/src/main/java/accord/messages/RouteRequest.java
copy accord-core/src/main/java/accord/{impl/progresslog/DefaultProgressLogs.java => utils/DebugMap.java} (59%)
copy accord-core/src/main/java/accord/utils/{SimpleBitSet.java => LargeBitSet.java} (93%)
copy accord-core/src/main/java/accord/utils/{DefaultRandom.java => SimpleBitSets.java} (71%)
create mode 100644 accord-core/src/main/java/accord/utils/SmallBitSet.java
rename accord-core/src/main/java/accord/utils/async/{AsyncChainCombiner.java => AsyncCombiner.java} (65%)
delete mode 100644 accord-core/src/main/java/accord/utils/async/Observable.java
copy accord-core/src/test/java/accord/impl/{TopologyFactory.java => AbstractTestConfigurationService.java} (50%)
rename accord-core/src/test/java/accord/messages/{TxnRequestScopeTest.java => RouteRequestScopeTest.java} (73%)
copy accord-core/src/test/java/accord/utils/{SimpleBitSetTest.java => LargeBitSetTest.java} (96%)
create mode 100644 accord-core/src/test/java/accord/utils/async/AsyncChainUtils.java
create mode 100644 accord-core/src/test/java/accord/utils/async/AsyncResultTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org