This is an automated email from the ASF dual-hosted git repository.
dcapwell pushed a change to branch CASSANDRA-21061
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
omit 52c9b240 pulled in changes from CASSANDRA-20828
omit c86acdfe CASSANDRA-21061: always call Writes before Result
add e7e49ea4 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 d94c03ac CASSANDRA-21061: always call Writes before Result
add ad3dc75d pulled in changes from CASSANDRA-20828
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 (52c9b240)
\
N -- N -- N refs/heads/CASSANDRA-21061 (ad3dc75d)
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 +
...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 | 4 +-
.../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 +-
.../java/accord/impl/DefaultLocalListeners.java | 6 +-
.../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/CommandStores.java | 15 ++-
.../main/java/accord/local/CommandSummaries.java | 3 +-
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 ++---
.../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 ++--
61 files changed, 576 insertions(+), 511 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]
