This is an automated email from the ASF dual-hosted git repository. aweisberg pushed a change to branch cep-15-accord in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 329a6a85d4 Use pinned Harry version add 3ef381e7e8 Several simulator fixes not yet merged to cep-15-accord new 153bc914d8 Accord support for live migration new 5ac890b023 Accord/non-Accord interoperability 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 | 2 +- build.xml | 12 +- ide/idea/workspace.xml | 2 +- modules/accord | 2 +- .../cassandra/auth/CassandraRoleManager.java | 39 +- .../cassandra/auth/PasswordSaltSupplier.java | 62 ++ .../org/apache/cassandra/concurrent/Stage.java | 1 + .../cassandra/concurrent/SyncFutureTask.java | 6 +- .../config/CassandraRelevantProperties.java | 13 +- src/java/org/apache/cassandra/config/Config.java | 113 ++- .../cassandra/config/DatabaseDescriptor.java | 94 ++- src/java/org/apache/cassandra/cql3/Lists.java | 66 +- .../apache/cassandra/cql3/UpdateParameters.java | 37 +- .../cassandra/cql3/statements/BatchStatement.java | 2 +- .../cql3/statements/BatchUpdatesCollector.java | 16 +- .../cassandra/cql3/statements/CQL3CasRequest.java | 54 +- .../cql3/statements/ModificationStatement.java | 37 +- .../cql3/statements/TransactionStatement.java | 67 +- .../cassandra/db/AbstractMutationVerbHandler.java | 6 +- .../org/apache/cassandra/db/ColumnFamilyStore.java | 5 + src/java/org/apache/cassandra/db/IMutation.java | 5 + src/java/org/apache/cassandra/db/Mutation.java | 70 +- .../cassandra/db/PartitionRangeReadCommand.java | 18 +- src/java/org/apache/cassandra/db/ReadCommand.java | 103 ++- .../cassandra/db/ReadCommandVerbHandler.java | 37 +- .../apache/cassandra/db/ReadRepairVerbHandler.java | 7 +- .../cassandra/db/SinglePartitionReadCommand.java | 16 +- .../org/apache/cassandra/db/SystemKeyspace.java | 59 +- .../db/partitions/AbstractBTreePartition.java | 34 +- .../db/partitions/AtomicBTreePartition.java | 17 +- .../cassandra/db/partitions/FilteredPartition.java | 11 +- .../cassandra/db/partitions/PartitionUpdate.java | 38 +- .../org/apache/cassandra/db/rows/AbstractCell.java | 14 +- .../org/apache/cassandra/db/rows/BTreeRow.java | 16 +- .../org/apache/cassandra/db/rows/ColumnData.java | 21 +- .../cassandra/db/rows/ComplexColumnData.java | 17 +- src/java/org/apache/cassandra/db/rows/Row.java | 21 +- .../db/streaming/CassandraOutgoingFile.java | 8 + .../db/streaming/CassandraStreamManager.java | 19 +- .../db/streaming/CassandraStreamReceiver.java | 19 +- .../cassandra/db/virtual/LocalRepairTables.java | 9 +- .../org/apache/cassandra/dht/AccordSplitter.java | 2 +- .../cassandra/dht/ByteOrderedPartitioner.java | 39 +- .../org/apache/cassandra/dht/LocalPartitioner.java | 18 +- .../apache/cassandra/dht/Murmur3Partitioner.java | 21 +- .../cassandra/dht/OrderPreservingPartitioner.java | 10 +- .../apache/cassandra/dht/RandomPartitioner.java | 19 +- src/java/org/apache/cassandra/dht/Range.java | 291 ++++++- .../apache/cassandra/locator/ReplicaLayout.java | 14 +- .../org/apache/cassandra/locator/ReplicaPlans.java | 53 +- .../metrics/AccordClientRequestMetrics.java | 20 + .../cassandra/metrics/CASClientRequestMetrics.java | 12 + .../metrics/ClientRequestsMetricsHolder.java | 2 + .../apache/cassandra/metrics/KeyspaceMetrics.java | 10 + .../org/apache/cassandra/metrics/TableMetrics.java | 13 + src/java/org/apache/cassandra/net/Message.java | 6 + src/java/org/apache/cassandra/net/MessageFlag.java | 5 +- .../apache/cassandra/net/ResponseVerbHandler.java | 6 +- src/java/org/apache/cassandra/net/Verb.java | 79 +- .../apache/cassandra/repair/AbstractRepairJob.java | 66 ++ .../cassandra/repair/AbstractRepairTask.java | 9 +- .../apache/cassandra/repair/AccordRepairJob.java | 173 ++++ .../{RepairJob.java => CassandraRepairJob.java} | 61 +- .../cassandra/repair/IncrementalRepairTask.java | 22 +- .../apache/cassandra/repair/NormalRepairTask.java | 17 +- .../apache/cassandra/repair/PreviewRepairTask.java | 12 +- .../apache/cassandra/repair/RepairCoordinator.java | 144 ++-- .../cassandra/repair/RepairMessageVerbHandler.java | 19 +- .../org/apache/cassandra/repair/RepairResult.java | 6 +- .../org/apache/cassandra/repair/RepairSession.java | 32 +- .../cassandra/repair/messages/RepairOption.java | 51 +- .../cassandra/repair/messages/SyncResponse.java | 5 +- .../cassandra/repair/state/CoordinatorState.java | 4 +- .../schema/SystemDistributedKeyspace.java | 6 +- src/java/org/apache/cassandra/schema/TableId.java | 47 ++ .../org/apache/cassandra/schema/TableMetadata.java | 9 +- .../cassandra/service/ActiveRepairService.java | 7 +- .../org/apache/cassandra/service/CASRequest.java | 10 +- .../service/FileSystemOwnershipCheck.java | 5 +- .../org/apache/cassandra/service/StorageProxy.java | 250 ++++-- .../apache/cassandra/service/StorageService.java | 101 ++- .../cassandra/service/StorageServiceMBean.java | 19 + .../service/accord/AccordCachingState.java | 24 +- .../service/accord/AccordCommandStore.java | 8 +- .../service/accord/AccordFetchCoordinator.java | 6 +- .../cassandra/service/accord/AccordJournal.java | 143 +++- .../cassandra/service/accord/AccordKeyspace.java | 4 +- .../service/accord/AccordMessageSink.java | 162 +++- .../service/accord/AccordObjectSizes.java | 10 +- .../service/accord/AccordSafeCommand.java | 5 +- .../service/accord/AccordSafeCommandStore.java | 29 +- .../service/accord/AccordSerializers.java | 25 + .../cassandra/service/accord/AccordService.java | 185 ++++- .../service/accord/AccordTopologyUtils.java | 15 +- .../cassandra/service/accord/IAccordService.java | 69 +- .../cassandra/service/accord/api/AccordAgent.java | 20 +- .../cassandra/service/accord/api/PartitionKey.java | 6 + .../service/accord/interop/AccordInteropApply.java | 269 ++++++ .../accord/interop/AccordInteropCommit.java | 73 ++ .../accord/interop/AccordInteropExecution.java | 412 ++++++++++ .../accord/interop/AccordInteropPersist.java | 167 ++++ .../service/accord/interop/AccordInteropRead.java | 209 +++++ .../accord/interop/AccordInteropReadCallback.java | 88 ++ .../accord/interop/AccordInteropReadRepair.java | 182 +++++ .../accord/serializers/ApplySerializers.java | 43 +- .../accord/serializers/CheckStatusSerializers.java | 2 +- .../accord/serializers/CommandSerializers.java | 4 +- .../accord/serializers/CommitSerializers.java | 53 +- .../serializers/InformHomeDurableSerializers.java | 1 - .../service/accord/serializers/KeySerializers.java | 2 +- .../accord/serializers/ReadDataSerializers.java | 139 +++- .../accord/serializers/SetDurableSerializers.java | 18 +- .../cassandra/service/accord/txn/AccordUpdate.java | 126 +++ .../service/accord/txn/AccordUpdateParameters.java | 20 +- .../accord/txn/RetryWithNewProtocolResult.java | 75 ++ .../cassandra/service/accord/txn/TxnCondition.java | 5 +- .../cassandra/service/accord/txn/TxnData.java | 38 +- .../cassandra/service/accord/txn/TxnDataName.java | 11 +- .../cassandra/service/accord/txn/TxnNamedRead.java | 18 +- .../cassandra/service/accord/txn/TxnQuery.java | 101 ++- .../cassandra/service/accord/txn/TxnRead.java | 78 +- .../cassandra/service/accord/txn/TxnResult.java | 88 ++ .../cassandra/service/accord/txn/TxnUpdate.java | 54 +- .../cassandra/service/accord/txn/TxnWrite.java | 38 +- .../accord/txn/UnrecoverableRepairUpdate.java | 206 +++++ .../migration/ConsensusKeyMigrationState.java | 364 +++++++++ .../migration/ConsensusRequestRouter.java | 247 ++++++ .../migration/ConsensusTableMigrationState.java | 907 +++++++++++++++++++++ .../service/paxos/AbstractPaxosRepair.java | 26 +- .../org/apache/cassandra/service/paxos/Paxos.java | 159 ++-- .../service/paxos/PaxosCommitAndPrepare.java | 20 +- .../cassandra/service/paxos/PaxosPrepare.java | 107 ++- .../cassandra/service/paxos/PaxosPropose.java | 155 ++-- .../cassandra/service/paxos/PaxosRepair.java | 35 +- .../service/paxos/PaxosRequestCallback.java | 28 + .../apache/cassandra/service/paxos/PaxosState.java | 69 +- .../paxos/cleanup/PaxosStartPrepareCleanup.java | 2 + .../service/reads/AbstractReadExecutor.java | 48 +- .../cassandra/service/reads/DataResolver.java | 17 +- .../cassandra/service/reads/DigestResolver.java | 8 +- .../cassandra/service/reads/ReadCoordinator.java | 78 ++ .../service/reads/ReplicaFilteringProtection.java | 9 +- .../cassandra/service/reads/ResponseResolver.java | 4 +- .../reads/ShortReadPartitionsProtection.java | 23 +- .../service/reads/ShortReadProtection.java | 3 +- .../service/reads/range/RangeCommandIterator.java | 5 +- .../service/reads/repair/AbstractReadRepair.java | 19 +- .../reads/repair/BlockingPartitionRepair.java | 52 +- .../service/reads/repair/BlockingReadRepair.java | 170 +++- .../service/reads/repair/NoopReadRepair.java | 9 + .../service/reads/repair/ReadOnlyReadRepair.java | 12 +- .../cassandra/service/reads/repair/ReadRepair.java | 18 +- .../service/reads/repair/ReadRepairStrategy.java | 9 +- .../apache/cassandra/streaming/OutgoingStream.java | 4 + .../apache/cassandra/streaming/SessionSummary.java | 11 +- .../streaming/StreamDeserializingTask.java | 3 +- .../cassandra/streaming/StreamOperation.java | 26 +- .../cassandra/streaming/StreamReceiveTask.java | 18 +- .../apache/cassandra/streaming/StreamSession.java | 23 +- .../apache/cassandra/streaming/StreamSummary.java | 33 +- .../org/apache/cassandra/streaming/StreamTask.java | 8 +- .../cassandra/streaming/StreamTransferTask.java | 14 + .../cassandra/streaming/TableStreamManager.java | 5 +- .../management/StreamSummaryCompositeData.java | 10 +- .../streaming/messages/CompleteMessage.java | 5 +- .../streaming/messages/IncomingStreamMessage.java | 8 +- .../streaming/messages/KeepAliveMessage.java | 5 +- .../streaming/messages/OutgoingStreamMessage.java | 5 +- .../streaming/messages/PrepareAckMessage.java | 5 +- .../streaming/messages/PrepareSynAckMessage.java | 7 +- .../streaming/messages/PrepareSynMessage.java | 9 +- .../streaming/messages/ReceivedMessage.java | 7 +- .../streaming/messages/SessionFailedMessage.java | 5 +- .../streaming/messages/StreamInitMessage.java | 9 +- .../streaming/messages/StreamMessage.java | 9 +- .../org/apache/cassandra/tcm/ClusterMetadata.java | 66 +- src/java/org/apache/cassandra/tcm/Epoch.java | 5 + .../org/apache/cassandra/tcm/MetadataKeys.java | 4 +- .../org/apache/cassandra/tcm/Transformation.java | 25 +- .../cassandra/tcm/compatibility/GossipHelper.java | 5 +- .../apache/cassandra/tcm/ownership/TokenMap.java | 13 +- .../cassandra/tcm/transformations/AlterSchema.java | 31 +- .../BeginConsensusMigrationForTableAndRange.java | 134 +++ ...beFinishConsensusMigrationForTableAndRange.java | 162 ++++ .../SetConsensusMigrationTargetProtocol.java | 131 +++ src/java/org/apache/cassandra/tools/NodeProbe.java | 35 +- src/java/org/apache/cassandra/tools/NodeTool.java | 48 +- .../org/apache/cassandra/tools/RepairRunner.java | 16 +- .../tools/nodetool/ConsensusMigrationAdmin.java | 146 ++++ .../apache/cassandra/tools/nodetool/Repair.java | 9 +- ...MultiValMap.java => AbstractBiMultiValMap.java} | 84 +- .../org/apache/cassandra/utils/BiMultiValMap.java | 103 +-- .../cassandra/utils/CollectionSerializers.java | 192 ++++- .../org/apache/cassandra/utils/PojoToString.java | 182 +++++ .../apache/cassandra/utils/RangesSerializer.java | 16 +- .../cassandra/utils/SortedBiMultiValMap.java | 27 +- src/java/org/apache/cassandra/utils/TimeUUID.java | 5 + .../serialization/5.0/service.SyncComplete.bin | Bin 256 -> 258 bytes .../5.0/service.ValidationComplete.bin | Bin 597 -> 597 bytes .../distributed/impl/AbstractCluster.java | 2 +- .../impl/DirectStreamingConnectionFactory.java | 6 + .../test/OptimiseStreamsRepairTest.java | 14 +- .../cassandra/distributed/test/ReadRepairTest.java | 34 +- .../distributed/test/SSTableIdGenerationTest.java | 9 +- .../distributed/test/ShortReadProtectionTest.java | 37 +- .../distributed/test/accord/AccordCQLTest.java | 227 +++++- .../test/accord/AccordFeatureFlagTest.java | 5 +- .../test/accord/AccordIntegrationTest.java | 22 +- .../test/accord/AccordInteropReadTest.java | 94 +++ .../test/accord/AccordInteroperabilityTest.java | 66 ++ .../distributed/test/accord/AccordMetricsTest.java | 2 +- .../test/accord/AccordMigrationTest.java | 654 +++++++++++++++ .../distributed/test/accord/AccordTestBase.java | 197 ++++- .../distributed/test/accord/NewSchemaTest.java | 10 + .../GuardrailCollectionSizeOnSSTableWriteTest.java | 44 +- .../test/log/ClusterMetadataTestHelper.java | 13 +- .../Murmur3ReplicationAwareTokenAllocatorTest.java | 4 +- .../NoReplicationTokenAllocatorTest.java | 10 +- .../RandomReplicationAwareTokenAllocatorTest.java | 4 +- .../test/microbench/ZeroCopyStreamingBench.java | 7 +- .../btree/AtomicBTreePartitionUpdateBench.java | 4 +- .../cassandra/simulator/asm/ClassTransformer.java | 1 + .../simulator/asm/DeterministicChanceSupplier.java | 18 +- .../cassandra/simulator/asm/InterceptClasses.java | 38 +- .../cassandra/simulator/ClusterSimulation.java | 68 +- .../cassandra/simulator/SimulationRunner.java | 32 +- .../apache/cassandra/simulator/SimulatorUtils.java | 37 + .../simulator/asm/InterceptAsClassTransformer.java | 7 +- .../simulator/cluster/ClusterActions.java | 29 +- .../simulator/cluster/KeyspaceActions.java | 72 +- .../cluster/OnClusterMigrateConsensus.java | 87 ++ .../cluster/OnClusterMigrateConsensusOneRange.java | 50 ++ .../simulator/cluster/OnInstanceRepair.java | 2 +- .../cluster/OnInstanceStartConsensusMigration.java | 53 ++ .../cassandra/simulator/debug/Reconcile.java | 2 +- .../cassandra/simulator/debug/SelfReconcile.java | 26 +- .../AbstractPairOfSequencesPaxosSimulation.java | 8 +- .../paxos/PairOfSequencesPaxosSimulation.java | 4 + .../simulator/paxos/PaxosClusterSimulation.java | 7 +- .../simulator/paxos/PaxosSimulationRunner.java | 24 +- .../simulator/systems/InterceptingMonitors.java | 5 +- .../systems/SimulatedFailureDetector.java | 10 +- .../test/AccordJournalSimulationTest.java | 2 +- .../simulator/test/ShortPaxosSimulationTest.java | 16 +- .../simulator/test/SimulationTestBase.java | 2 +- .../org/apache/cassandra/CassandraTestBase.java | 257 ++++++ test/unit/org/apache/cassandra/Util.java | 29 +- .../cassandra/auth/CassandraAuthorizerTest.java | 1 + .../cassandra/auth/PasswordAuthenticatorTest.java | 2 +- .../cassandra/batchlog/BatchlogManagerTest.java | 21 +- .../config/DatabaseDescriptorRefTest.java | 3 +- .../cassandra/cql3/statements/TxnDataNameTest.java | 4 +- .../apache/cassandra/db/CleanupTransientTest.java | 12 +- .../db/ReadCommandVerbHandlerOutOfRangeTest.java | 2 + .../cassandra/db/ReadCommandVerbHandlerTest.java | 1 + .../org/apache/cassandra/db/ReadResponseTest.java | 1 + .../compaction/CompactionStrategyManagerTest.java | 23 +- .../db/compaction/PartialCompactionsTest.java | 4 +- .../cassandra/db/filter/ColumnFilterTest.java | 3 +- .../CassandraEntireSSTableStreamWriterTest.java | 7 +- .../db/streaming/CassandraStreamManagerTest.java | 8 +- ...TableStreamConcurrentComponentMutationTest.java | 7 +- .../apache/cassandra/db/view/ViewUtilsTest.java | 20 +- .../db/virtual/StreamingVirtualTableTest.java | 13 +- .../org/apache/cassandra/dht/BootStrapperTest.java | 14 +- .../org/apache/cassandra/dht/KeyCollisionTest.java | 28 +- .../apache/cassandra/dht/LengthPartitioner.java | 2 + test/unit/org/apache/cassandra/dht/RangeTest.java | 167 +++- .../org/apache/cassandra/dht/SplitterTest.java | 24 +- .../apache/cassandra/dht/StreamStateStoreTest.java | 8 +- .../dht/tokenallocator/TokenAllocationTest.java | 24 +- .../apache/cassandra/gms/FailureDetectorTest.java | 2 +- .../cassandra/io/sstable/CQLSSTableWriterTest.java | 114 +-- .../org/apache/cassandra/io/sstable/ScrubTest.java | 2 +- .../io/sstable/format/bti/PartitionIndexTest.java | 2 +- .../io/sstable/indexsummary/IndexSummaryTest.java | 2 +- .../locator/AssureSufficientLiveNodesTest.java | 22 +- .../locator/NetworkTopologyStrategyTest.java | 125 +-- .../cassandra/locator/PropertyFileSnitchTest.java | 17 +- .../cassandra/locator/SimpleStrategyTest.java | 63 +- .../org/apache/cassandra/repair/RepairJobTest.java | 79 +- .../apache/cassandra/repair/RepairSessionTest.java | 4 +- .../messages/RepairMessageSerializationsTest.java | 29 +- .../apache/cassandra/schema/ValidationTest.java | 7 +- .../AbstractFilesystemOwnershipCheckTest.java | 84 +- .../cassandra/service/BootstrapTransientTest.java | 7 +- .../org/apache/cassandra/service/RemoveTest.java | 26 +- .../cassandra/service/SerializationsTest.java | 21 +- .../service/StorageServiceServerTest.java | 139 ++-- .../cassandra/service/StorageServiceTest.java | 8 +- .../service/accord/AccordReadRepairTest.java | 117 +++ .../cassandra/service/accord/AccordTestUtils.java | 4 +- .../{TxnUpdateTest.java => AccordUpdateTest.java} | 10 +- .../service/paxos/AbstractPaxosRepairTest.java | 2 +- .../paxos/cleanup/PaxosTableRepairsTest.java | 2 +- .../paxos/uncommitted/PaxosBallotTrackerTest.java | 19 +- .../paxos/uncommitted/PaxosUncommittedTests.java | 17 +- .../PaxosUncommittedTrackerIntegrationTest.java | 11 +- .../service/reads/AbstractReadResponseTest.java | 12 +- .../cassandra/service/reads/DataResolverTest.java | 43 +- .../service/reads/DigestResolverTest.java | 12 +- .../cassandra/service/reads/ReadExecutorTest.java | 12 +- .../reads/repair/AbstractReadRepairTest.java | 3 +- .../reads/repair/BlockingReadRepairTest.java | 5 +- .../repair/DiagEventsBlockingReadRepairTest.java | 5 +- .../reads/repair/ReadOnlyReadRepairTest.java | 3 +- .../service/reads/repair/ReadRepairTest.java | 3 +- .../reads/repair/RepairedDataVerifierTest.java | 1 + .../service/reads/repair/TestableReadRepair.java | 9 +- .../cassandra/streaming/SessionInfoTest.java | 6 +- .../cassandra/streaming/StreamReaderTest.java | 7 +- .../async/StreamingInboundHandlerTest.java | 6 +- .../tcm/ClusterMetadataTransformationTest.java | 3 + .../cassandra/tools/nodetool/NetStatsTest.java | 3 +- .../apache/cassandra/utils/BloomFilterTest.java | 2 +- .../apache/cassandra/utils/SerializationsTest.java | 2 +- 316 files changed, 11975 insertions(+), 2239 deletions(-) create mode 100644 src/java/org/apache/cassandra/auth/PasswordSaltSupplier.java create mode 100644 src/java/org/apache/cassandra/repair/AbstractRepairJob.java create mode 100644 src/java/org/apache/cassandra/repair/AccordRepairJob.java rename src/java/org/apache/cassandra/repair/{RepairJob.java => CassandraRepairJob.java} (95%) create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropApply.java create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropCommit.java create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropExecution.java create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropPersist.java create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropRead.java create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropReadCallback.java create mode 100644 src/java/org/apache/cassandra/service/accord/interop/AccordInteropReadRepair.java create mode 100644 src/java/org/apache/cassandra/service/accord/txn/AccordUpdate.java create mode 100644 src/java/org/apache/cassandra/service/accord/txn/RetryWithNewProtocolResult.java create mode 100644 src/java/org/apache/cassandra/service/accord/txn/TxnResult.java create mode 100644 src/java/org/apache/cassandra/service/accord/txn/UnrecoverableRepairUpdate.java create mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusKeyMigrationState.java create mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusRequestRouter.java create mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusTableMigrationState.java create mode 100644 src/java/org/apache/cassandra/service/reads/ReadCoordinator.java create mode 100644 src/java/org/apache/cassandra/tcm/transformations/BeginConsensusMigrationForTableAndRange.java create mode 100644 src/java/org/apache/cassandra/tcm/transformations/MaybeFinishConsensusMigrationForTableAndRange.java create mode 100644 src/java/org/apache/cassandra/tcm/transformations/SetConsensusMigrationTargetProtocol.java create mode 100644 src/java/org/apache/cassandra/tools/nodetool/ConsensusMigrationAdmin.java copy src/java/org/apache/cassandra/utils/{BiMultiValMap.java => AbstractBiMultiValMap.java} (51%) create mode 100644 src/java/org/apache/cassandra/utils/PojoToString.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/accord/AccordInteropReadTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/accord/AccordInteroperabilityTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/accord/AccordMigrationTest.java copy src/java/org/apache/cassandra/repair/RepairResult.java => test/simulator/asm/org/apache/cassandra/simulator/asm/DeterministicChanceSupplier.java (71%) create mode 100644 test/simulator/main/org/apache/cassandra/simulator/cluster/OnClusterMigrateConsensus.java create mode 100644 test/simulator/main/org/apache/cassandra/simulator/cluster/OnClusterMigrateConsensusOneRange.java create mode 100644 test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceStartConsensusMigration.java create mode 100644 test/unit/org/apache/cassandra/CassandraTestBase.java create mode 100644 test/unit/org/apache/cassandra/service/accord/AccordReadRepairTest.java rename test/unit/org/apache/cassandra/service/accord/txn/{TxnUpdateTest.java => AccordUpdateTest.java} (91%) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org