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 cb670fb57e Fix empty LatestDepsSerializer
     add dc11953a61 Follow-up to CASSANDRA-20228:  - Fix waiting state callback 
computes different route to initiator  - Invariants.checkX -> 
Invariants.requireX (to allow complementary Invariants.expectX as appropriate)

No new revisions were added by this update.

Summary of changes:
 modules/accord                                     |  2 +-
 .../org/apache/cassandra/config/AccordSpec.java    |  2 +-
 .../db/compaction/CompactionIterator.java          |  6 ++--
 .../cassandra/db/marshal/ByteArrayAccessor.java    |  2 +-
 .../apache/cassandra/db/marshal/CompositeType.java |  4 +--
 .../cassandra/db/virtual/AccordDebugKeyspace.java  |  2 +-
 .../apache/cassandra/dht/AccordBytesSplitter.java  | 12 ++++----
 .../dht/LocalCompositePrefixPartitioner.java       |  6 ++--
 .../cassandra/dht/OrderPreservingPartitioner.java  |  6 ++--
 .../apache/cassandra/journal/EntrySerializer.java  |  8 ++---
 src/java/org/apache/cassandra/journal/Flusher.java |  4 +--
 src/java/org/apache/cassandra/journal/Journal.java | 12 ++++----
 .../org/apache/cassandra/journal/OnDiskIndex.java  |  2 +-
 src/java/org/apache/cassandra/journal/Segment.java | 10 +++---
 .../org/apache/cassandra/journal/Segments.java     | 12 ++++----
 src/java/org/apache/cassandra/schema/TableId.java  |  4 +--
 .../org/apache/cassandra/schema/TableMetadata.java |  4 +--
 .../cassandra/service/accord/AccordCache.java      | 36 +++++++++++-----------
 .../cassandra/service/accord/AccordCacheEntry.java | 36 +++++++++++-----------
 .../service/accord/AccordCommandStore.java         | 12 ++++----
 .../service/accord/AccordConfigurationService.java |  4 +--
 .../cassandra/service/accord/AccordDataStore.java  |  6 ++--
 .../cassandra/service/accord/AccordExecutor.java   | 32 +++++++++----------
 .../accord/AccordExecutorInfiniteLoops.java        |  2 +-
 .../service/accord/AccordExecutorSimple.java       |  2 +-
 .../service/accord/AccordFastPathCoordinator.java  |  2 +-
 .../service/accord/AccordFetchCoordinator.java     | 22 ++++++-------
 .../cassandra/service/accord/AccordJournal.java    | 24 +++++++--------
 .../service/accord/AccordJournalTable.java         |  4 +--
 .../accord/AccordJournalValueSerializers.java      |  4 +--
 .../cassandra/service/accord/AccordKeyspace.java   | 22 ++++++-------
 .../service/accord/AccordSegmentCompactor.java     |  8 ++---
 .../cassandra/service/accord/AccordService.java    | 10 +++---
 .../service/accord/AccordSyncPropagator.java       |  2 +-
 .../cassandra/service/accord/AccordTask.java       | 30 +++++++++---------
 .../cassandra/service/accord/AccordTopology.java   |  6 ++--
 .../service/accord/CommandsForRanges.java          |  2 +-
 .../cassandra/service/accord/EndpointMapping.java  |  8 ++---
 .../cassandra/service/accord/JournalKey.java       |  4 +--
 .../cassandra/service/accord/TokenRange.java       |  2 +-
 .../cassandra/service/accord/api/AccordAgent.java  |  2 +-
 .../fastpath/ParameterizedFastPathStrategy.java    |  4 +--
 .../accord/fastpath/SimpleFastPathStrategy.java    |  2 +-
 .../service/accord/interop/AccordInteropApply.java |  4 +--
 .../accord/interop/AccordInteropExecution.java     |  8 ++---
 .../accord/interop/AccordInteropPersist.java       |  4 +--
 .../accord/interop/AccordInteropReadCallback.java  |  2 +-
 .../accord/serializers/AcceptSerializers.java      |  2 +-
 .../accord/serializers/ApplySerializers.java       |  2 +-
 .../accord/serializers/AwaitSerializer.java        |  4 +--
 .../accord/serializers/CommandSerializers.java     |  6 ++--
 .../serializers/CommandStoreSerializers.java       |  2 +-
 .../accord/serializers/SmallEnumSerializer.java    |  2 +-
 .../accord/serializers/WaitingOnSerializer.java    | 10 +++---
 .../cassandra/service/accord/txn/TxnData.java      |  6 ++--
 .../cassandra/service/accord/txn/TxnUpdate.java    |  4 +--
 .../cassandra/tcm/AtomicLongBackedProcessor.java   |  2 +-
 src/java/org/apache/cassandra/tcm/Processor.java   |  2 +-
 .../org/apache/cassandra/tcm/log/LogReader.java    |  2 +-
 .../org/apache/cassandra/tcm/log/LogState.java     |  2 +-
 .../apache/cassandra/tcm/membership/Directory.java |  2 +-
 .../org/apache/cassandra/utils/MergeIterator.java  |  2 +-
 .../org/apache/cassandra/utils/btree/BTree.java    |  4 +--
 .../utils/concurrent/LockWithAsyncSignal.java      |  4 +--
 .../cassandra/distributed/impl/Coordinator.java    |  2 +-
 .../distributed/test/IntegrationTestBase.java      |  2 +-
 .../fuzz/topology/TopologyMixupTestBase.java       |  4 +--
 .../harry/dsl/SingleOperationVisitBuilder.java     |  6 ++--
 .../harry/execution/CQLTesterVisitExecutor.java    |  4 +--
 .../harry/execution/CQLVisitExecutor.java          |  4 +--
 .../cassandra/harry/execution/DataTracker.java     |  4 +--
 .../harry/execution/InJvmDTestVisitExecutor.java   |  4 +--
 .../execution/QueryBuildingVisitExecutor.java      |  4 +--
 .../RingAwareInJvmDTestVisitExecutor.java          |  2 +-
 .../org/apache/cassandra/harry/gen/Generators.java |  2 +-
 .../cassandra/harry/gen/InvertibleGenerator.java   | 18 +++++------
 .../cassandra/harry/model/QuiescentChecker.java    |  2 +-
 .../org/apache/cassandra/harry/op/Operations.java  |  2 +-
 .../cassandra/harry/test/SimpleBijectionTest.java  |  2 +-
 .../simulator/logging/RunStartDefiner.java         |  2 +-
 .../simulator/test/HarrySimulatorTest.java         |  2 +-
 .../simulator/test/HarryValidatingQuery.java       |  4 +--
 .../cassandra/concurrent/ManualExecutor.java       |  2 +-
 .../org/apache/cassandra/cql3/ast/Conditional.java |  2 +-
 .../org/apache/cassandra/cql3/ast/Visitor.java     |  2 +-
 .../org/apache/cassandra/journal/IndexTest.java    |  2 +-
 .../cassandra/service/accord/EpochSyncTest.java    | 18 +++++------
 .../service/accord/MockDiskStateManager.java       |  2 +-
 .../SimulatedAccordCommandStoreTestBase.java       |  2 +-
 .../cassandra/utils/SimulatedMiniCluster.java      |  2 +-
 90 files changed, 282 insertions(+), 282 deletions(-)


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to