This is an automated email from the ASF dual-hosted git repository.
aweisberg pushed a change to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 942fa5a3f3 Fix CoordinatorLogOffsetsLifecycleTest
add 2403bfcaac Initial witness non-serial single partition read/write path
No new revisions were added by this update.
Summary of changes:
.../statements/schema/CreateTableStatement.java | 12 +-
.../db/AbstractReadCommandVerbHandler.java | 10 +-
.../org/apache/cassandra/db/ColumnFamilyStore.java | 13 +-
src/java/org/apache/cassandra/db/Keyspace.java | 36 +++
.../cassandra/db/PartitionRangeReadCommand.java | 40 +--
src/java/org/apache/cassandra/db/ReadCommand.java | 50 +--
.../org/apache/cassandra/db/SSTableImporter.java | 3 +-
.../cassandra/db/SinglePartitionReadCommand.java | 41 +--
.../db/compaction/AbstractCompactionStrategy.java | 2 -
.../db/compaction/AbstractStrategyHolder.java | 5 +-
.../cassandra/db/compaction/CompactionManager.java | 24 +-
.../db/compaction/CompactionStrategyHolder.java | 5 +-
.../db/compaction/CompactionStrategyManager.java | 45 +--
.../cassandra/db/compaction/CompactionTask.java | 17 -
.../db/compaction/PendingRepairHolder.java | 12 +-
.../db/compaction/PendingRepairManager.java | 35 +-
.../db/compaction/UnifiedCompactionStrategy.java | 2 -
.../apache/cassandra/db/compaction/Upgrader.java | 1 -
.../db/compaction/unified/ShardedMultiWriter.java | 4 -
.../compaction/writers/CompactionAwareWriter.java | 3 -
.../org/apache/cassandra/db/memtable/Flushing.java | 1 -
.../CassandraEntireSSTableStreamReader.java | 2 +-
.../db/streaming/CassandraStreamReader.java | 2 +-
.../dht/tokenallocator/TokenAllocation.java | 3 +-
.../io/sstable/AbstractSSTableSimpleWriter.java | 1 -
.../io/sstable/RangeAwareSSTableWriter.java | 8 +-
.../org/apache/cassandra/io/sstable/SSTable.java | 4 +-
.../cassandra/io/sstable/SSTableTxnWriter.java | 9 +-
.../io/sstable/SimpleSSTableMultiWriter.java | 2 -
.../cassandra/io/sstable/format/SSTableReader.java | 9 +-
.../cassandra/io/sstable/format/SSTableWriter.java | 17 +-
.../io/sstable/format/SortedTableScrubber.java | 4 +-
.../io/sstable/format/SortedTableVerifier.java | 2 +-
.../io/sstable/metadata/IMetadataSerializer.java | 2 +-
.../io/sstable/metadata/MetadataCollector.java | 3 +-
.../io/sstable/metadata/MetadataSerializer.java | 4 +-
.../io/sstable/metadata/StatsMetadata.java | 12 +-
.../locator/AbstractReplicationStrategy.java | 59 +++-
.../apache/cassandra/locator/LocalStrategy.java | 5 +-
.../org/apache/cassandra/locator/MetaStrategy.java | 5 +-
.../cassandra/locator/NetworkTopologyStrategy.java | 5 +-
.../org/apache/cassandra/locator/ReplicaPlans.java | 61 ++++
.../apache/cassandra/locator/SimpleStrategy.java | 5 +-
.../apache/cassandra/locator/SystemStrategy.java | 5 +-
.../cassandra/replication/TrackedWriteRequest.java | 2 +-
.../apache/cassandra/schema/KeyspaceMetadata.java | 4 +-
.../apache/cassandra/schema/KeyspaceParams.java | 7 +-
.../apache/cassandra/schema/ReplicationParams.java | 4 +-
.../org/apache/cassandra/service/StorageProxy.java | 4 +-
.../apache/cassandra/service/StorageService.java | 6 +-
.../service/accord/AccordSegmentCompactor.java | 2 +-
.../accord/interop/AccordInteropExecution.java | 4 +-
.../service/reads/AbstractReadExecutor.java | 18 +-
.../cassandra/service/reads/ReadCoordinator.java | 2 +-
.../service/reads/ReplicaFilteringProtection.java | 13 +-
.../reads/ShortReadPartitionsProtection.java | 5 +-
.../service/reads/range/RangeCommandIterator.java | 2 +-
.../service/reads/repair/AbstractReadRepair.java | 12 +-
.../cassandra/tools/SSTableMetadataViewer.java | 3 +-
.../cassandra/tools/SSTableRepairedAtSetter.java | 4 +-
.../test/PreviewRepairSnapshotTest.java | 3 +-
.../distributed/test/RepairDigestTrackingTest.java | 2 +-
.../distributed/test/SharedClusterTestBase.java | 145 +++++++++
.../test/WitnessAlwaysReadsFullReplicaTest.java | 171 ++++++++++
...va => MultiNodeTableWalkWithWitnessesTest.java} | 43 +--
.../distributed/test/cql3/StatefulASTBase.java | 11 +-
.../test/tracking/MutationTrackingTest.java | 357 ++++++++++++++++++++-
.../io/sstable/format/ForwardingSSTableReader.java | 10 +-
.../accord/NemesisAccordSegmentCompactor.java | 2 +-
test/unit/org/apache/cassandra/SchemaLoader.java | 5 +-
test/unit/org/apache/cassandra/db/CleanupTest.java | 2 +-
.../apache/cassandra/db/CleanupTransientTest.java | 2 +-
test/unit/org/apache/cassandra/db/ImportTest.java | 2 +-
.../db/MutationVerbHandlerOutOfRangeTest.java | 1 +
.../org/apache/cassandra/db/ReadCommandTest.java | 48 +--
.../db/ReadCommandVerbHandlerOutOfRangeTest.java | 2 -
.../cassandra/db/ReadCommandVerbHandlerTest.java | 1 -
.../org/apache/cassandra/db/ReadResponseTest.java | 1 -
.../cassandra/db/RepairedDataTombstonesTest.java | 2 +-
.../db/compaction/AbstractPendingRepairTest.java | 14 +-
.../db/compaction/AntiCompactionTest.java | 11 +-
...CompactionStrategyManagerPendingRepairTest.java | 106 +-----
.../compaction/CompactionStrategyManagerTest.java | 40 +--
.../db/compaction/CompactionTaskTest.java | 10 +-
.../compaction/LeveledCompactionStrategyTest.java | 2 +-
.../db/compaction/PendingRepairManagerTest.java | 30 +-
.../cassandra/db/lifecycle/LogTransactionTest.java | 4 +-
...pactionManagerGetSSTablesForValidationTest.java | 4 +-
.../db/repair/PendingAntiCompactionTest.java | 8 +-
.../db/streaming/CassandraStreamManagerTest.java | 10 +-
...TableStreamConcurrentComponentMutationTest.java | 4 +-
.../cassandra/index/IndexStatusManagerTest.java | 12 +-
.../cassandra/io/sstable/LegacySSTableTest.java | 9 +-
.../io/sstable/RangeAwareSSTableWriterTest.java | 1 -
.../cassandra/io/sstable/SSTableRewriterTest.java | 2 +-
.../apache/cassandra/io/sstable/SSTableUtils.java | 2 +-
.../cassandra/io/sstable/SSTableWriterTest.java | 20 +-
.../io/sstable/SSTableWriterTestBase.java | 5 +-
.../io/sstable/SSTableWriterTransactionTest.java | 2 +-
.../org/apache/cassandra/io/sstable/ScrubTest.java | 1 -
.../apache/cassandra/io/sstable/VerifyTest.java | 4 +-
.../sstable/metadata/MetadataSerializerTest.java | 2 +-
.../locator/AssureSufficientLiveNodesTest.java | 12 +-
.../locator/NetworkTopologyStrategyTest.java | 14 +-
.../cassandra/locator/PendingRangesTest.java | 4 +-
.../apache/cassandra/locator/ReplicaPlansTest.java | 7 +-
.../cassandra/locator/SimpleStrategyTest.java | 10 +-
.../org/apache/cassandra/repair/FuzzTestBase.java | 5 +-
.../org/apache/cassandra/schema/MockSchema.java | 3 +-
.../cassandra/service/BootstrapTransientTest.java | 3 +-
.../service/WriteResponseHandlerTransientTest.java | 2 +-
.../service/accord/AccordTopologyUtils.java | 3 +-
.../cassandra/service/reads/ReadExecutorTest.java | 2 +-
.../reads/repair/RepairedDataVerifierTest.java | 1 -
.../cassandra/utils/CassandraGenerators.java | 20 +-
115 files changed, 1136 insertions(+), 745 deletions(-)
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/SharedClusterTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/WitnessAlwaysReadsFullReplicaTest.java
copy
test/distributed/org/apache/cassandra/distributed/test/cql3/{AccordInteropMultiNodeTokenConflictBase.java
=> MultiNodeTableWalkWithWitnessesTest.java} (55%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
