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
