This is an automated email from the ASF dual-hosted git repository.
benedict pushed a change to branch cep-15-accord
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 8834ec8df2 Revert "Ninja: When starting up AccordService set the
instance before startup to avoid an edge case when doing node restart and
replying topology history"
new d4648ac969 visit journal backwards to save time parsing don't load
range commands that are redundant, and load least possible use MISC verb
handler for maintenance tasks
new 312a70372a Fix condition on where we shut down accord; move scheduled
executor shutdown until after MS.
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:
.gitmodules | 4 +-
modules/accord | 2 +-
.../db/compaction/CompactionIterator.java | 20 +-
src/java/org/apache/cassandra/dht/Token.java | 8 +
.../cassandra/index/accord/RoutesSearcher.java | 20 +-
src/java/org/apache/cassandra/journal/Flusher.java | 8 +-
.../apache/cassandra/journal/InMemoryIndex.java | 27 +-
src/java/org/apache/cassandra/journal/Index.java | 2 +-
src/java/org/apache/cassandra/journal/Journal.java | 47 ++-
.../org/apache/cassandra/journal/OnDiskIndex.java | 69 +---
.../apache/cassandra/journal/RecordConsumer.java | 1 -
src/java/org/apache/cassandra/journal/Segment.java | 10 +-
.../org/apache/cassandra/journal/Segments.java | 5 +-
.../apache/cassandra/journal/StaticSegment.java | 4 +-
src/java/org/apache/cassandra/net/Verb.java | 8 +-
src/java/org/apache/cassandra/schema/TableId.java | 7 +-
.../apache/cassandra/service/StorageService.java | 12 +-
.../service/accord/AccordCommandStore.java | 5 +
.../service/accord/AccordCommandStores.java | 38 +++
.../cassandra/service/accord/AccordJournal.java | 52 ++-
.../service/accord/AccordJournalTable.java | 13 +-
.../accord/AccordJournalValueSerializers.java | 4 +
.../cassandra/service/accord/AccordKeyspace.java | 20 +-
.../service/accord/AccordSafeCommandStore.java | 3 +-
.../service/accord/AccordSegmentCompactor.java | 23 +-
.../cassandra/service/accord/AccordService.java | 7 +-
.../service/accord/AccordVerbHandler.java | 6 +
.../service/accord/CommandsForRanges.java | 7 +-
.../service/accord/CommandsForRangesLoader.java | 105 +++---
.../cassandra/service/accord/SavedCommand.java | 372 ++++++++++++---------
.../cassandra/service/accord/TokenRange.java | 11 +-
.../service/accord/api/AccordRoutableKey.java | 8 +
.../service/accord/api/AccordRoutingKey.java | 38 ++-
.../cassandra/service/accord/api/PartitionKey.java | 10 +-
.../service/accord/async/AsyncLoader.java | 16 +-
.../service/accord/async/AsyncOperation.java | 2 +-
.../accord/serializers/CommandSerializers.java | 12 +
.../service/accord/serializers/KeySerializers.java | 49 ++-
.../org/apache/cassandra/utils/ExecutorUtils.java | 28 ++
.../accord/AccordJournalCompactionTest.java | 29 +-
.../test/AccordJournalSimulationTest.java | 2 +-
.../index/accord/AccordIndexStressTest.java | 25 +-
.../cassandra/index/accord/RouteIndexTest.java | 3 +-
.../org/apache/cassandra/journal/IndexTest.java | 25 +-
.../org/apache/cassandra/journal/JournalTest.java | 16 +-
.../org/apache/cassandra/journal/SegmentTest.java | 16 +-
.../service/accord/CommandsForRangesTest.java | 2 +-
.../service/accord/async/AsyncLoaderTest.java | 24 +-
.../accord/async/SimulatedAsyncOperationTest.java | 2 +-
49 files changed, 773 insertions(+), 454 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
