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 0a10cd05 Safely regain ranges and delete retired command stores
new 2cdda7f9 (BTree)?ReducingRangeMap fixes and improvements Fix: -
(BTree)?ReducingRangeMapTest - BTree: bad invariant check, latent foldl bug
Improve: - Implement efficient unconstrained fold
new 66cab49f Expunged records may be resurrected:
CommandChanges.shouldCleanup short-circuits to NO if there is no data, but this
is incorrect as Cleanup.EXPUNGE may have dropped the data and the record must
receive cleanup EXPUNGE and be reported as ERASED. Also Fix: -
ActiveEpochs.withNewEpochs should handle transition from 0 -> more than 1 -
RedundantBefore.minGcBefore should be NONE if empty - Update RangesForEpoch
directly, so that we cannot have race conditions where the o [...]
The 2 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:
.../accord/coordinate/AbstractCoordination.java | 9 +-
.../main/java/accord/coordinate/ExecuteTxn.java | 16 +-
.../java/accord/coordinate/ReadCoordinator.java | 45 ++-
.../accord/coordinate/SynchronousRecoverAwait.java | 4 +-
.../java/accord/impl/AbstractFetchCoordinator.java | 2 +-
.../src/main/java/accord/impl/CommandChange.java | 27 +-
.../java/accord/impl/DefaultLocalListeners.java | 133 ++++---
.../java/accord/impl/InMemoryCommandStore.java | 21 +-
.../src/main/java/accord/local/CommandBuilder.java | 2 +
.../src/main/java/accord/local/CommandStore.java | 97 +----
.../src/main/java/accord/local/CommandStores.java | 66 ++--
.../src/main/java/accord/local/Commands.java | 4 +-
.../main/java/accord/local/RedundantBefore.java | 15 +-
.../src/main/java/accord/messages/Callback.java | 46 ++-
.../main/java/accord/topology/ActiveEpochs.java | 9 +-
.../java/accord/utils/BTreeReducingRangeMap.java | 25 +-
.../java/accord/utils/IntrusivePriorityHeap.java | 23 +-
.../java/accord/utils/ReducingIntervalMap.java | 1 +
.../main/java/accord/utils/ReducingRangeMap.java | 5 +
.../src/main/java/accord/utils/btree/BTree.java | 28 ++
.../java/accord/utils/btree/ReducingBTree.java | 17 +-
.../test/java/accord/impl/RemoteListenersTest.java | 2 +-
.../src/test/java/accord/impl/basic/Cluster.java | 16 +-
.../accord/impl/basic/DelayedCommandStores.java | 30 +-
.../java/accord/impl/basic/InMemoryJournal.java | 35 +-
.../java/accord/local/MaybeExecuteAdapterTest.java | 408 +++++++++++++++++++++
.../java/accord/local/cfk/CommandsForKeyTest.java | 5 +-
.../src/test/java/accord/utils/AccordGens.java | 5 +-
.../accord/utils/BTreeReducingRangeMapTest.java | 40 +-
.../java/accord/utils/ReducingRangeMapTest.java | 14 +-
30 files changed, 803 insertions(+), 347 deletions(-)
create mode 100644
accord-core/src/test/java/accord/local/MaybeExecuteAdapterTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
