This is an automated email from the ASF dual-hosted git repository.
dcapwell pushed a change to branch CASSANDRA-21077
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
omit 11b9b078 feedback
omit 67820204 done
omit 63dd2225 unify logic
omit 3f5a56ca added remaining interface to tests
omit 313f4ad8 rename setRange to show inclusive/exclusive and fixed a bug
with small bit set where to=64 would no-op
add 6bae51f6 Fix: - DefaultLocalListeners.ComplexListeners iterator
IndexOutOfBoundsException - Race condition initialising empty ActiveEpochs,
when minimum pending epoch can move backwards - SyncPoints must be declared in
an epoch containing the ranges, and PENDING_REMOVAL ranges will reject
non-syncpoint transactions - AccordExecutorMetrics is now registered on
startup - getRecentValues for non-cumulative histogram should not subtract
prior values Improve: - Report ephemeral [...]
add f6b0a699 Updated so txn.execute is always called before txn.result,
which enables Cassandra to pass around rejections found while creating the
mutations.
add f09a12da Improve - Iterate LocalListeners in order, so can query more
effectively on node - Refine AbstractReplay.minReplay/shouldReplay
add 0e22a2f4 rename setRange to show inclusive/exclusive and fixed a bug
with small bit set where to=64 would no-op
add 87e746a3 added remaining interface to tests
add 77537e27 unify logic
add 1bf18786 done
add 633d937f feedback
add a7d0de7d feedback
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 (11b9b078)
\
N -- N -- N refs/heads/CASSANDRA-21077 (a7d0de7d)
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:
accord-core/src/main/java/accord/api/Agent.java | 5 +
.../src/main/java/accord/api/LocalListeners.java | 4 +-
...ecutorFactory.java => SystemEventListener.java} | 12 +-
.../coordinate/AbstractCoordinatePreAccept.java | 12 +-
.../main/java/accord/coordinate/CheckShards.java | 4 +-
.../accord/coordinate/CoordinateEphemeralRead.java | 9 +-
.../accord/coordinate/CoordinateMaxConflict.java | 11 +-
.../accord/coordinate/CoordinatePreAccept.java | 2 +-
.../accord/coordinate/CoordinateSyncPoint.java | 8 +-
.../accord/coordinate/CoordinateTransaction.java | 6 +-
.../accord/coordinate/CoordinationAdapter.java | 63 +++++----
.../accord/coordinate/ExecuteEphemeralRead.java | 8 +-
.../main/java/accord/coordinate/ExecutePath.java | 2 +-
.../java/accord/coordinate/ExecuteSyncPoint.java | 6 +-
.../main/java/accord/coordinate/ExecuteTxn.java | 11 +-
.../java/accord/coordinate/FetchCoordinator.java | 4 +-
.../main/java/accord/coordinate/Invalidate.java | 4 +-
.../main/java/accord/coordinate/KeyBarriers.java | 2 -
.../main/java/accord/coordinate/MaybeRecover.java | 1 -
.../src/main/java/accord/coordinate/Persist.java | 4 +-
.../java/accord/coordinate/PrepareRecovery.java | 13 +-
.../src/main/java/accord/coordinate/Propose.java | 4 +-
.../src/main/java/accord/coordinate/Recover.java | 18 ++-
.../src/main/java/accord/coordinate/Stabilise.java | 4 +-
.../java/accord/coordinate/SynchronousAwait.java | 4 +-
.../main/java/accord/impl/AbstractReplayer.java | 30 ++---
.../java/accord/impl/AbstractSafeCommandStore.java | 2 +
.../java/accord/impl/DefaultLocalListeners.java | 27 ++--
.../java/accord/impl/InMemoryCommandStore.java | 3 +-
.../accord/impl/progresslog/PackedKeyTracker.java | 2 +-
.../java/accord/impl/progresslog/WaitingState.java | 4 +-
.../src/main/java/accord/local/Command.java | 10 +-
.../src/main/java/accord/local/CommandStore.java | 5 +-
.../src/main/java/accord/local/CommandStores.java | 18 ++-
.../main/java/accord/local/CommandSummaries.java | 3 +-
.../src/main/java/accord/local/Commands.java | 16 ++-
accord-core/src/main/java/accord/local/Node.java | 14 +-
.../main/java/accord/local/RedundantBefore.java | 22 ++-
.../main/java/accord/local/SafeCommandStore.java | 1 -
.../main/java/accord/local/cfk/CommandsForKey.java | 49 +++----
.../src/main/java/accord/local/cfk/Pruning.java | 12 +-
.../java/accord/local/cfk/SafeCommandsForKey.java | 2 +-
.../accord/local/durability/DurabilityService.java | 7 +-
.../src/main/java/accord/messages/Commit.java | 4 +-
.../main/java/accord/primitives/LatestDeps.java | 15 +--
.../src/main/java/accord/primitives/Ranges.java | 7 +-
.../src/main/java/accord/primitives/TxnId.java | 6 +
.../src/main/java/accord/topology/ActiveEpoch.java | 67 ++++++----
.../main/java/accord/topology/ActiveEpochs.java | 147 +++++++++------------
.../main/java/accord/topology/PendingEpoch.java | 41 +++++-
.../main/java/accord/topology/PendingEpochs.java | 1 +
.../{SelectTopology.java => SelectShards.java} | 14 +-
.../main/java/accord/topology/SelectTopology.java | 2 +-
.../src/main/java/accord/topology/Topologies.java | 65 +--------
.../src/main/java/accord/topology/Topology.java | 83 ++++++++----
.../java/accord/topology/TopologyCollector.java | 83 +++++++++---
.../main/java/accord/topology/TopologyManager.java | 82 ++++++------
.../java/accord/topology/TopologyMismatch.java | 36 ++---
.../src/main/java/accord/utils/LargeBitSet.java | 27 ++--
.../src/main/java/accord/utils/RandomSource.java | 8 ++
.../java/accord/utils/ReducingIntervalMap.java | 11 ++
.../main/java/accord/utils/ReducingRangeMap.java | 10 ++
.../src/main/java/accord/utils/SmallBitSet.java | 26 ++--
.../java/accord/burn/BurnTestTopologyService.java | 5 +-
.../src/test/java/accord/burn/TopologyUpdates.java | 1 -
.../accord/coordinate/CoordinateSyncPointTest.java | 3 +-
.../src/test/java/accord/impl/list/ListStore.java | 1 -
.../local/durability/DurabilityQueueTest.java | 5 +-
.../test/java/accord/messages/PreAcceptTest.java | 4 +-
.../java/accord/topology/TopologyManagerTest.java | 33 +++--
.../java/accord/topology/TopologyRandomizer.java | 2 +
.../test/java/accord/topology/TopologyTest.java | 23 ++--
accord-core/src/test/java/accord/utils/Gens.java | 3 +
.../src/test/java/accord/utils/Property.java | 36 +++--
.../test/java/accord/utils/SimpleBitSetTest.java | 51 ++++---
gradle.properties | 4 +
gradle/wrapper/gradle-wrapper.properties | 3 +-
77 files changed, 753 insertions(+), 604 deletions(-)
copy accord-core/src/main/java/accord/api/{AsyncExecutorFactory.java =>
SystemEventListener.java} (79%)
copy accord-core/src/main/java/accord/topology/{SelectTopology.java =>
SelectShards.java} (75%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
