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 25ed39fe6b Fix CoordinatorReadLatencyMetricTest
add 559732ea6b Fix ForceSnapshotTest
new 954a6e1af8 Protocol optimisations: - Privileged coordinator. If the
coordinator is a replica we can reduce our quorum sizes by including the
coordinator's vote. - with deps: if we include coordinator's preaccept deps
we can reliably reduce quorum size by 1, at the expense of recovery sometimes
requiring additional phases and waiting for future txns - with only vote: if
we only include the vote we can avoid any additional recovery phases or waiting
for future txns, but can [...]
The 1 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:
modules/accord | 2 +-
.../db/compaction/CompactionIterator.java | 2 +-
src/java/org/apache/cassandra/net/Verb.java | 7 +-
.../cassandra/service/accord/AccordJournal.java | 4 +-
.../service/accord/AccordMessageSink.java | 29 ++--
.../service/accord/AccordObjectSizes.java | 79 ++++++---
.../cassandra/service/accord/AccordService.java | 9 +-
.../cassandra/service/accord/AccordTopology.java | 17 +-
.../service/accord/CommandsForRanges.java | 4 +-
.../cassandra/service/accord/api/AccordAgent.java | 9 +
.../fastpath/ParameterizedFastPathStrategy.java | 8 +-
.../accord/fastpath/SimpleFastPathStrategy.java | 2 +-
.../service/accord/interop/AccordInteropApply.java | 15 +-
.../accord/interop/AccordInteropCommit.java | 74 ---------
.../accord/interop/AccordInteropExecution.java | 15 +-
.../accord/interop/AccordInteropPersist.java | 20 ++-
.../service/accord/interop/AccordInteropRead.java | 20 +--
.../accord/interop/AccordInteropReadCallback.java | 3 +-
.../accord/interop/AccordInteropReadRepair.java | 16 +-
.../interop/AccordInteropStableThenRead.java | 181 +++++++++++++++++++++
.../accord/serializers/AcceptSerializers.java | 34 ++--
.../accord/serializers/ApplySerializers.java | 10 +-
.../accord/serializers/AwaitSerializer.java | 8 +-
.../accord/serializers/CheckStatusSerializers.java | 2 +-
.../accord/serializers/CommandSerializers.java | 18 +-
.../accord/serializers/CommitSerializers.java | 46 ++----
.../accord/serializers/FetchSerializers.java | 4 +-
.../accord/serializers/PreacceptSerializers.java | 36 ++--
.../accord/serializers/ReadDataSerializers.java | 90 ++++++++--
.../accord/serializers/RecoverySerializers.java | 10 +-
.../accord/serializers/TopologySerializers.java | 19 ++-
.../tcm/transformations/AccordMarkStale.java | 2 +-
.../test/accord/AccordInteroperabilityTest.java | 2 +-
.../test/accord/AccordSimpleFastPathTest.java | 2 +-
.../distributed/test/log/ForceSnapshotTest.java | 2 +
.../simulator/test/AccordHarrySimulationTest.java | 2 +-
.../db/virtual/AccordDebugKeyspaceTest.java | 9 +
.../service/accord/AccordCommandStoreTest.java | 12 +-
.../service/accord/AccordCommandTest.java | 17 +-
.../accord/AccordFastPathCoordinatorTest.java | 12 +-
.../service/accord/AccordJournalOrderTest.java | 6 +-
.../service/accord/AccordKeyspaceTest.java | 11 +-
.../cassandra/service/accord/AccordTestUtils.java | 49 ++----
.../service/accord/AccordTopologyTest.java | 12 +-
.../accord/SimulatedAccordCommandStore.java | 13 +-
.../SimulatedAccordCommandStoreTestBase.java | 2 +-
.../service/accord/SimulatedAccordTaskTest.java | 2 +-
.../serializers/CommandsForKeySerializerTest.java | 93 +++++++----
.../apache/cassandra/utils/AccordGenerators.java | 84 +++++++---
49 files changed, 700 insertions(+), 425 deletions(-)
delete mode 100644
src/java/org/apache/cassandra/service/accord/interop/AccordInteropCommit.java
create mode 100644
src/java/org/apache/cassandra/service/accord/interop/AccordInteropStableThenRead.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
