This is an automated email from the ASF dual-hosted git repository. mck pushed a change to branch cassandra-5.0 in repository https://gitbox.apache.org/repos/asf/cassandra.git
omit 08c46d0963 Merge branch 'cassandra-5.0' into trunk omit 85a0b9b5dc Merge branch 'cassandra-5.0' into trunk omit afa86df27d Merge branch 'cassandra-5.0' into trunk omit 901786ec27 Avoid race inserting new data in compaction_history during truncation in SystemKeyspaceMigrator41Test.testMigrateCompactionHistory omit c069a0ffb6 Merge branch 'cassandra-5.0' into trunk omit 8f759e01d5 Merge branch 'cassandra-5.0' into trunk omit 1a46e96890 Don't start MessagingService unnecessarily to speed up tests and to avoid memory leak omit 1df9148ed1 Fix FetchLogFromPeersTest with vnodes omit b470117733 Fix potential for unintended address clash in test case omit 28630ccbbf Update expected error message which is too specific omit 8d6d1774e4 Avoid NPEs when initializing CFSs from local keyspaces before ClusterMetadata is available omit a75814c8f4 Merge branch 'cassandra-5.0' into trunk omit ea1f9e4504 Merge branch 'cassandra-5.0' into trunk omit ad86c9d201 Merge branch 'cassandra-5.0' into trunk omit c5a2781b22 Enable bytebuddy rule after starting nodes to fix DecommissionAvoidWriteTimeoutsTest omit 3ed0903131 In in-jvm dtests, don't mark internode messaging as started until it actually is omit e0766e95bc Fix rejectSubsequentInProgressSequence test: cap message sizes for commit failures omit f4c969adfc Merge branch 'cassandra-5.0' into trunk omit 7204bc45b6 Revert "Revert "Upgrade jackson to 2.15.3 and snakeyaml to 2.1"" omit d91997cb04 Merge branch 'cassandra-5.0' into trunk omit 8cd0690c0b Revert "Upgrade jackson to 2.15.3 and snakeyaml to 2.1" omit f74c07d2d3 Lower the number of tables and repairs to avoid timeouts in ClearSnapshotTest omit 11358bd3a8 Rewrite RegisterTest to verify serialization version ceiling omit bd25c05d52 Test failure: materialized_views_test.TestMaterializedViewsConsistency.test_multi_partition_consistent_reads_after_write omit 390d8da961 Merge branch 'cassandra-5.0' into trunk omit 98fd6fc5a9 Merge branch 'cassandra-5.0' into trunk omit 64cdebdb69 Merge branch 'cassandra-5.0' into trunk omit 500b845003 ninja-fix add addtocmstool tool to bin directory in rpm noboolean package omit 2a807fc81b ninja-fix add addtocmstool tool to bin directory in deb/rpm packages omit f36a518208 Fix test Failure: MixedModeFrom3LoggedBatchTest.testSimpleStrategy omit e182744cd0 Introduce 5.1 messaging format that brings in Epoch omit a98a5a1d9d Reduce time the tests run to avoid timeouts omit 179711eab6 Improve the situation with timeouts of all fuzz tests. omit 5f0359b229 Fix ConsistentMoveTest: nodes were getting stuck in assertGossipStatus, since we would log the message, but never change the actual gossip status. omit ac201d2f04 Make nodetool tablestats use number of significant digits for time and average values consistently omit b45a0e0145 Remove dependency on bundled Harry jar omit 5613d0a4fe Test failure: org.apache.cassandra.distributed.test.ring.DecommissionTest.test*Version* omit da868ab607 Test Failure: org.apache.cassandra.distributed.upgrade.ClusterMetadataUpgradeTest.upgradeWithHintsTest omit 5f2ff4f932 Merge branch 'cassandra-5.0' into trunk omit cbabfd39b1 Merge branch 'cassandra-5.0' into trunk omit 01d8cbdd1e Merge branch 'cassandra-5.0' into trunk omit 64ae866095 Upgrade jackson to 2.15.3 and snakeyaml to 2.1 omit d40c9d1abf Merge branch 'cassandra-5.0' into trunk omit 97bee6abc1 Merge branch 'cassandra-5.0' into trunk omit 30ed828c87 [CEP-21] Add log message for backwards compatibility omit de1766a2f8 [CEP-21] Don't log unknown endpoint errors unnecessarily omit 7b7f79253d Merge branch 'cassandra-5.0' into trunk omit f41ca379dd Merge branch 'cassandra-5.0' into trunk omit 008c1b397b Merge branch 'cassandra-5.0' into trunk omit 3b47b5e473 Merge branch 'cassandra-5.0' into trunk omit 9167d599f3 Test Failure: org.apache.cassandra.db.compaction.writers.CompactionAwareWriterTest.test*CompactionWriter-trie omit db52bef03a Test failure: org.apache.cassandra.db.CorruptPrimaryIndexTest.bigPrimaryIndexDoesNotDetectDiskCorruption omit f6ea362d71 Test failure: org.apache.cassandra.tools.JMXCompatabilityTest omit 31a3ff1768 Test failure: org.apache.cassandra.db.RepairedDataInfoTest omit 58d2132afc Merge branch 'cassandra-5.0' into trunk omit 85b94c561d Merge branch 'cassandra-5.0' into trunk omit 87ce597ad0 Merge branch 'cassandra-5.0' into trunk omit d464c206e1 Revert bad dtest repo in circleci conf omit ae0842372f Implementation of Transactional Cluster Metadata as described in CEP-21 omit 360128b3eb Merge branch 'cassandra-5.0' into trunk omit 06dabb8b3a Merge branch 'cassandra-5.0' into trunk omit 1793c3fd36 Merge branch 'cassandra-5.0' into trunk omit 316a239c7c Merge branch 'cassandra-5.0' into trunk omit 1b7e895f56 Merge branch 'cassandra-5.0' into trunk omit 1463fabac3 Merge branch 'cassandra-5.0' into trunk omit a106f75af5 Merge branch 'cassandra-5.0' into trunk omit 4083166870 Merge branch 'cassandra-5.0' into trunk omit ed5a224283 Merge branch 'cassandra-5.0' into trunk omit ac0347bfa0 Merge branch 'cassandra-5.0' into trunk omit 4f32cdbf7c Merge branch 'cassandra-5.0' into trunk omit 046b2e8465 Merge branch 'cassandra-5.0' into trunk omit ad66fd6547 Merge branch 'cassandra-5.0' into trunk omit 337aa5ce33 Merge branch 'cassandra-5.0' into trunk omit 6a3bcc83d2 Merge branch 'cassandra-5.0' into trunk omit a77951ec0c Merge branch 'cassandra-5.0' into trunk omit c6cb8523b3 Merge branch 'cassandra-5.0' into trunk omit c0e0ea1bc6 Merge branch 'cassandra-5.0' into trunk omit dc62e1dba1 Merge branch 'cassandra-5.0' into trunk omit 0a09c12975 Merge branch 'cassandra-5.0' into trunk omit 30e0b55f93 Merge branch 'cassandra-5.0' into trunk omit c62de1b248 Merge branch 'cassandra-5.0' into trunk omit 753f81d53a Merge branch 'cassandra-5.0' into trunk omit 7b891db36d Merge branch 'cassandra-5.0' into trunk omit 37d2ef11d6 Merge branch 'cassandra-5.0' into trunk omit 10d031bda4 Merge branch 'cassandra-5.0' into trunk omit 537ab03f58 Merge branch 'cassandra-5.0' into trunk omit e5d235dd4d Merge branch 'cassandra-5.0' into trunk omit 5850996ab1 Merge branch 'cassandra-5.0' into trunk omit 53c25f8faa Merge branch 'cassandra-5.0' into trunk omit bb686fc27d Merge branch 'cassandra-5.0' into trunk omit 7377d5501d Merge branch 'cassandra-5.0' into trunk omit b9240d0004 Merge branch 'cassandra-5.0' into trunk omit 2d982a0e52 Merge branch 'cassandra-5.0' into trunk omit b363568c0f Merge branch 'cassandra-5.0' into trunk omit 4cabe486e1 Merge branch 'cassandra-5.0' into trunk omit d6159cfe15 Merge branch 'cassandra-5.0' into trunk omit 59eb8ba043 Merge branch 'cassandra-5.0' into trunk omit 70259c50ff Merge branch 'cassandra-5.0' into trunk omit a8d0584936 Merge branch 'cassandra-5.0' into trunk omit f8c240147c Merge branch 'cassandra-5.0' into trunk omit f5fba9b702 Merge branch 'cassandra-5.0' into trunk omit 45c6352938 Merge branch 'cassandra-5.0' into trunk omit e8c5fe31a2 Merge branch 'cassandra-5.0' into trunk omit 3d022d3c5f Merge branch 'cassandra-5.0' into trunk omit b094303ac2 Merge branch 'cassandra-5.0' into trunk omit afde441448 Merge branch 'cassandra-5.0' into trunk omit bf321d7951 Merge branch 'cassandra-5.0' into trunk omit 06202c9ff3 Merge branch 'cassandra-5.0' into trunk omit 088f3ea3e9 Merge branch 'cassandra-5.0' into trunk omit c2c20ab843 Merge branch 'cassandra-5.0' into trunk omit 7d3a8d5312 Merge branch 'cassandra-5.0' into trunk omit 6c18a6c4f4 Merge branch 'cassandra-5.0' into trunk omit 2feeb39d5a Merge branch 'cassandra-5.0' into trunk omit 3d15be1d5e Merge branch 'cassandra-5.0' into trunk omit 302b272b14 Merge branch 'cassandra-5.0' into trunk omit a9a09c1e6b Merge branch 'cassandra-5.0' into trunk omit 91f5562241 Merge branch 'cassandra-5.0' into trunk omit a0b4cee198 Merge branch 'cassandra-5.0' into trunk omit b8b17dc5db Merge branch 'cassandra-5.0' into trunk omit 31729b8f92 Merge branch 'cassandra-5.0' into trunk omit 4b84c4332c Merge branch 'cassandra-5.0' into trunk omit c40e0778b3 Merge branch 'cassandra-5.0' into trunk omit e63d3bfc4b Merge branch 'cassandra-5.0' into trunk omit 865d7c30e4 Merge branch 'cassandra-5.0' into trunk omit 91406a6c73 Merge branch 'cassandra-5.0' into trunk omit 2e600017ee Merge branch 'cassandra-5.0' into trunk omit b8f36f0cba Merge branch 'cassandra-5.0' into trunk omit 90e0ef27e4 Merge branch 'cassandra-5.0' into trunk omit a1de444331 Merge branch 'cassandra-5.0' into trunk omit 210a59b194 Merge branch 'cassandra-5.0' into trunk omit 16b43e4d4b Merge branch 'cassandra-5.0' into trunk omit c60b2ca65f Merge branch 'cassandra-5.0' into trunk omit 8cc2b48192 Merge branch 'cassandra-5.0' into trunk omit fdbb975188 Merge branch 'cassandra-5.0' into trunk omit fbf6508940 ninja fix for CASSANDRA-18827 omit d1158bfd8e Merge branch 'cassandra-5.0' into trunk omit c96185f188 Merge branch 'cassandra-5.0' into trunk omit a0eecdb996 Merge branch 'cassandra-5.0' into trunk omit 60314f2d6a Resolve deprecations in pylib omit 07fcac4547 Merge branch 'cassandra-5.0' into trunk omit 32cf1ea33d Add ELAPSED command to cqlsh omit e8907eba15 Merge branch 'cassandra-5.0' into trunk omit f2f2ef3f23 Merge branch 'cassandra-5.0' into trunk omit 1dd3440ccb Merge branch 'cassandra-5.0' into trunk omit cfe48de019 Merge branch 'cassandra-5.0' into trunk omit 77912be753 Merge branch 'cassandra-5.0' into trunk omit 02cdaf5b92 Merge branch 'cassandra-5.0' into trunk omit b3879ccb51 Merge branch 'cassandra-5.0' into trunk omit 9aa2109803 Javadoc BigFormat omit c5bb672543 Merge branch 'cassandra-5.0' into trunk omit 970ec2d1db Merge branch 'cassandra-5.0' into trunk omit e1fc195558 Fix invalid unit test check for CreateTableValidationTest omit e76b63d081 Merge branch 'cassandra-5.0' into trunk omit 20d80118ac Add the ability to disable bulk loading of SSTables omit 9f0f1f7c47 Merge branch 'cassandra-5.0' into trunk omit c2a4caa730 Merge branch 'cassandra-5.0' into trunk omit 3ebd09262b Merge branch 'cassandra-5.0' into trunk omit 1087d88303 Merge branch 'cassandra-5.0' into trunk omit f7472774f4 Merge branch 'cassandra-5.0' into trunk omit 188df44c8c Merge branch 'cassandra-5.0' into trunk omit 89065ffa21 Merge branch 'cassandra-5.0' into trunk omit 830f88d4ab Merge branch 'cassandra-5.0' into trunk omit 1959502d8b Merge branch 'cassandra-5.0' into trunk omit 759f2b2932 Merge branch 'cassandra-5.0' into trunk omit a67f4904f7 Merge branch 'cassandra-5.0' into trunk omit 2a5e1b77c9 Merge branch 'cassandra-5.0' into trunk omit e1ddc34f58 Merge branch 'cassandra-5.0' into trunk omit 1ba458c900 Merge branch 'cassandra-5.0' into trunk omit f8d5a1aa16 Merge branch 'cassandra-5.0' into trunk omit 7ecac39570 Merge branch 'cassandra-5.0' into trunk omit d1a1c439f0 Merge branch 'cassandra-5.0' into trunk omit df94834b19 Merge branch 'cassandra-5.0' into trunk omit b966f6af11 Merge branch 'cassandra-5.0' into trunk omit 9bacdc5bdb Merge branch 'cassandra-5.0' into trunk omit bd7dc322d8 Merge branch 'cassandra-5.0' into trunk omit abe09cff34 Clean up obsolete functions and simplify cql_version handling in cqlsh omit 5aa7da5ebd Merge branch 'cassandra-5.0' into trunk omit 1c3c5008f9 Merge branch 'cassandra-5.0' into trunk omit 1f1ec5f503 Merge branch 'cassandra-5.0' into trunk omit 999d263a5d Merge branch 'cassandra-5.0' into trunk omit 4621ec7782 Merge branch 'cassandra-5.0' into trunk omit e9b9f9a35f Merge branch 'cassandra-5.0' into trunk omit 16dc2a2393 Merge branch 'cassandra-5.0' into trunk omit 70766c7ae9 Merge branch 'cassandra-5.0' into trunk omit 7750a9430b Merge branch 'cassandra-5.0' into trunk omit b04c2aeddc Merge branch 'cassandra-5.0' into trunk omit 269c04474f Merge branch 'cassandra-5.0' into trunk omit 052a264741 Merge branch 'cassandra-5.0' into trunk omit 9e90ccc90f Merge branch 'cassandra-5.0' into trunk omit 6fb82b75d5 Merge branch 'cassandra-5.0' into trunk omit cbaef9094e Merge branch 'cassandra-5.0' into trunk omit 4226cbbec6 Merge branch 'cassandra-5.0' into trunk omit 77cf2185b6 Add jmh microbenchmarks to eclipse IDE omit 9c7e1adb1d Merge branch 'cassandra-5.0' into trunk omit 2df8875502 Merge branch 'cassandra-5.0' into trunk omit 825ff89c70 Merge branch 'cassandra-5.0' into trunk omit d6534e5c4f Merge branch 'cassandra-5.0' into trunk omit f8baabd95a Merge branch 'cassandra-5.0' into trunk omit 02f751077f Merge branch 'cassandra-5.0' into trunk omit 119668f2b3 Merge branch 'cassandra-5.0' into trunk omit 49e04e8df2 Merge branch 'cassandra-5.0' into trunk omit 1e19887f72 Merge branch 'cassandra-5.0' into trunk omit 3884eaf47e Merge branch 'cassandra-5.0' into trunk omit 14f6e7898f Merge branch 'cassandra-5.0' into trunk omit cdeb199f78 Merge branch 'cassandra-5.0' into trunk omit 91d40b2780 Merge branch 'cassandra-5.0' into trunk omit 94c3cf74ef Merge branch 'cassandra-5.0' into trunk omit 56f351ec2e Merge branch 'cassandra-5.0' into trunk omit 555dec50c2 Merge branch 'cassandra-5.0' into trunk omit 64f553bf97 Merge branch 'cassandra-5.0' into trunk omit f713a6618f Merge branch 'cassandra-5.0' into trunk omit d058194354 Merge branch 'cassandra-5.0' into trunk omit 8a764dedcd Merge branch 'cassandra-5.0' into trunk omit c834427852 Merge branch 'cassandra-5.0' into trunk omit fb60ee2960 Merge branch 'cassandra-5.0' into trunk omit 724c616f58 Merge branch 'cassandra-5.0' into trunk omit d3a7387836 Merge branch 'cassandra-5.0' into trunk omit 9f2005cd57 Merge branch 'cassandra-5.0' into trunk omit 8f3c8e721e Merge branch 'cassandra-5.0' into trunk omit 5ade7a6cd8 Merge branch 'cassandra-5.0' into trunk omit 7022d1a5e6 Merge branch 'cassandra-5.0' into trunk omit 798edb3edd Merge branch 'cassandra-5.0' into trunk omit b774385b40 Merge branch 'cassandra-5.0' into trunk omit 881bb56be7 Merge branch 'cassandra-5.0' into trunk omit d707bb98b4 Merge branch 'cassandra-5.0' into trunk omit de0a556c5d Merge branch 'cassandra-5.0' into trunk omit ab40d85cd1 Merge branch 'cassandra-5.0' into trunk omit 5a9b79bb83 Merge branch 'cassandra-5.0' into trunk omit d24baecac9 Simplify pylib/cqlshlib/helptopics.py using associative array This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/cassandra-5.0 (2fc2be54ca) \ O -- O -- O (08c46d0963) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .build/build-resolver.xml | 2 +- .build/cassandra-build-deps-template.xml | 4 - .build/parent-pom-template.xml | 19 +- .build/run-tests.sh | 3 +- .circleci/config.yml | 2 +- .circleci/config.yml.FREE | 2 +- .circleci/config.yml.PAID | 2 +- .circleci/config_template.yml | 2 +- .circleci/config_template.yml.PAID.patch | 4 +- .circleci/generate.sh | 2 +- .gitignore | 1 - CHANGES.txt | 55 +- NEWS.txt | 76 +- build.xml | 8 +- ci/harry_simulation.sh | 96 - conf/cassandra.yaml | 17 +- conf/cqlshrc.sample | 7 + conf/harry-example.yaml | 95 - debian/cassandra-tools.install | 1 - debian/changelog | 10 +- doc/antora.yml | 4 +- .../pages/managing/operating/security.adoc | 69 + .../cassandra/pages/managing/operating/snitch.adoc | 82 +- .../cassandra/pages/managing/tools/cqlsh.adoc | 29 - doc/modules/cassandra/pages/new/index.adoc | 8 - ide/idea-iml-file.xml | 1 - pylib/cassandra-cqlsh-tests.sh | 18 +- pylib/cqlshlib/copyutil.py | 2 +- pylib/cqlshlib/cql3handling.py | 6 +- pylib/cqlshlib/cqlshhandling.py | 8 - pylib/cqlshlib/cqlshmain.py | 130 +- pylib/cqlshlib/formatting.py | 19 +- pylib/cqlshlib/helptopics.py | 244 +- pylib/cqlshlib/test/cassconnect.py | 6 +- pylib/cqlshlib/test/test_cqlsh_completion.py | 15 +- pylib/cqlshlib/test/test_cqlsh_output.py | 46 +- pylib/cqlshlib/test/test_unicode.py | 14 +- pylib/cqlshlib/util.py | 22 + pylib/setup.py | 1 - redhat/cassandra.spec | 1 - redhat/noboolean/cassandra.spec | 1 - .../org/apache/cassandra/auth/AuthKeyspace.java | 91 +- .../cassandra/auth/CIDRGroupsMappingLoader.java | 2 +- .../cassandra/auth/CIDRGroupsMappingManager.java | 24 +- .../cassandra/auth/CIDRPermissionsManager.java | 22 +- .../cassandra/auth/CassandraRoleManager.java | 26 +- .../org/apache/cassandra/auth/DCPermissions.java | 3 +- .../org/apache/cassandra/auth/IRoleManager.java | 13 +- .../apache/cassandra/batchlog/BatchlogManager.java | 41 +- .../apache/cassandra/cache/AutoSavingCache.java | 10 +- .../cassandra/concurrent/NamedThreadFactory.java | 38 +- .../org/apache/cassandra/concurrent/Stage.java | 2 - .../config/CassandraRelevantProperties.java | 35 +- src/java/org/apache/cassandra/config/Config.java | 28 +- .../cassandra/config/DatabaseDescriptor.java | 262 +- .../apache/cassandra/config/GuardrailsOptions.java | 14 - .../cassandra/config/YamlConfigurationLoader.java | 39 +- .../org/apache/cassandra/cql3/QueryProcessor.java | 101 +- .../cassandra/cql3/functions/UDAggregate.java | 75 - .../cassandra/cql3/functions/UDFunction.java | 73 - .../cql3/functions/masking/ColumnMask.java | 79 - .../cql3/restrictions/StatementRestrictions.java | 5 +- .../cql3/statements/DescribeStatement.java | 14 +- .../cql3/statements/PropertyDefinitions.java | 2 +- .../statements/schema/AlterKeyspaceStatement.java | 88 +- .../statements/schema/AlterSchemaStatement.java | 77 +- .../statements/schema/AlterTableStatement.java | 171 +- .../cql3/statements/schema/AlterTypeStatement.java | 5 +- .../cql3/statements/schema/AlterViewStatement.java | 5 +- .../schema/CreateAggregateStatement.java | 5 +- .../statements/schema/CreateFunctionStatement.java | 4 +- .../statements/schema/CreateIndexStatement.java | 8 +- .../statements/schema/CreateKeyspaceStatement.java | 16 +- .../statements/schema/CreateTableStatement.java | 20 +- .../statements/schema/CreateTriggerStatement.java | 5 +- .../statements/schema/CreateTypeStatement.java | 4 +- .../statements/schema/CreateViewStatement.java | 9 +- .../statements/schema/DropAggregateStatement.java | 4 +- .../statements/schema/DropFunctionStatement.java | 5 +- .../cql3/statements/schema/DropIndexStatement.java | 5 +- .../statements/schema/DropKeyspaceStatement.java | 5 +- .../cql3/statements/schema/DropTableStatement.java | 4 +- .../statements/schema/DropTriggerStatement.java | 5 +- .../cql3/statements/schema/DropTypeStatement.java | 5 +- .../cql3/statements/schema/DropViewStatement.java | 5 +- .../cql3/statements/schema/TableAttributes.java | 4 +- .../cassandra/db/AbstractMutationVerbHandler.java | 185 - .../org/apache/cassandra/db/ColumnFamilyStore.java | 114 +- .../org/apache/cassandra/db/CounterMutation.java | 6 - .../cassandra/db/CounterMutationVerbHandler.java | 8 +- .../org/apache/cassandra/db/DiskBoundaries.java | 23 +- .../apache/cassandra/db/DiskBoundaryManager.java | 84 +- src/java/org/apache/cassandra/db/Keyspace.java | 132 +- src/java/org/apache/cassandra/db/Mutation.java | 7 +- .../apache/cassandra/db/MutationVerbHandler.java | 9 +- .../cassandra/db/PartitionRangeReadCommand.java | 65 +- src/java/org/apache/cassandra/db/ReadCommand.java | 72 +- .../cassandra/db/ReadCommandVerbHandler.java | 144 +- .../apache/cassandra/db/ReadRepairVerbHandler.java | 8 +- src/java/org/apache/cassandra/db/ReadResponse.java | 7 - .../cassandra/db/SinglePartitionReadCommand.java | 54 +- .../apache/cassandra/db/SizeEstimatesRecorder.java | 43 +- .../org/apache/cassandra/db/SystemKeyspace.java | 274 +- .../commitlog/AbstractCommitLogSegmentManager.java | 7 +- .../db/commitlog/CommitLogDescriptor.java | 5 +- .../cassandra/db/commitlog/CommitLogSegment.java | 2 +- .../db/compaction/CompactionIterator.java | 2 +- .../cassandra/db/compaction/CompactionManager.java | 31 +- .../db/compaction/CompactionStrategyManager.java | 6 - .../db/compaction/ShardManagerNoDisks.java | 4 +- .../db/compaction/UnifiedCompactionStrategy.java | 16 +- .../org/apache/cassandra/db/filter/RowFilter.java | 1 - .../apache/cassandra/db/guardrails/Guardrail.java | 20 +- .../apache/cassandra/db/guardrails/Guardrails.java | 21 - .../cassandra/db/guardrails/GuardrailsConfig.java | 7 - .../cassandra/db/guardrails/GuardrailsMBean.java | 12 - .../org/apache/cassandra/db/lifecycle/Tracker.java | 10 +- .../db/memtable/AbstractAllocatorMemtable.java | 7 +- .../org/apache/cassandra/db/memtable/Memtable.java | 11 +- .../cassandra/db/memtable/ShardBoundaries.java | 13 +- .../cassandra/db/partitions/PartitionUpdate.java | 81 +- .../streaming/CassandraCompressedStreamReader.java | 2 +- .../db/streaming/CassandraStreamReader.java | 80 +- .../org/apache/cassandra/db/view/TableViews.java | 55 +- .../org/apache/cassandra/db/view/ViewBuilder.java | 4 +- .../apache/cassandra/db/view/ViewBuilderTask.java | 2 +- .../org/apache/cassandra/db/view/ViewManager.java | 37 +- .../org/apache/cassandra/db/view/ViewUtils.java | 17 +- .../db/virtual/ClusterMetadataLogTable.java | 87 - .../apache/cassandra/db/virtual/LocalTable.java | 145 - .../apache/cassandra/db/virtual/PeersTable.java | 200 -- .../cassandra/db/virtual/SystemViewsKeyspace.java | 3 - .../org/apache/cassandra/dht/AbstractBounds.java | 2 +- .../org/apache/cassandra/dht/BootStrapper.java | 108 +- .../apache/cassandra/dht/BootstrapDiagnostics.java | 15 +- .../org/apache/cassandra/dht/BootstrapEvent.java | 10 +- .../cassandra/dht/ComparableObjectToken.java | 2 +- src/java/org/apache/cassandra/dht/Datacenters.java | 16 +- .../org/apache/cassandra/dht/IPartitioner.java | 4 +- .../org/apache/cassandra/dht/LocalPartitioner.java | 4 +- .../cassandra/dht/OrderPreservingPartitioner.java | 24 - src/java/org/apache/cassandra/dht/OwnedRanges.java | 139 - src/java/org/apache/cassandra/dht/Range.java | 28 - .../org/apache/cassandra/dht/RangeStreamer.java | 296 +- src/java/org/apache/cassandra/dht/Token.java | 27 - .../dht/tokenallocator/OfflineTokenAllocator.java | 9 +- .../dht/tokenallocator/TokenAllocation.java | 80 +- .../exceptions/InvalidRoutingException.java | 62 - .../cassandra/exceptions/RequestFailureReason.java | 17 +- .../cassandra/exceptions/UnavailableException.java | 3 +- .../exceptions/WriteTimeoutException.java | 3 +- .../org/apache/cassandra/gms/ApplicationState.java | 24 +- .../org/apache/cassandra/gms/EndpointState.java | 16 +- .../org/apache/cassandra/gms/FailureDetector.java | 25 +- .../org/apache/cassandra/gms/GossipDigestAck.java | 2 +- .../cassandra/gms/GossipDigestAckVerbHandler.java | 11 +- .../cassandra/gms/GossipDigestSynVerbHandler.java | 5 +- src/java/org/apache/cassandra/gms/Gossiper.java | 1079 ++++-- .../org/apache/cassandra/gms/GossiperEvent.java | 7 +- .../org/apache/cassandra/gms/GossiperMBean.java | 2 - src/java/org/apache/cassandra/gms/NewGossiper.java | 178 - .../org/apache/cassandra/gms/VersionedValue.java | 93 +- .../apache/cassandra/hints/HintVerbHandler.java | 12 +- .../org/apache/cassandra/hints/HintsCatalog.java | 4 - .../apache/cassandra/hints/HintsDescriptor.java | 5 +- .../cassandra/hints/HintsDispatchExecutor.java | 7 +- .../cassandra/hints/HintsDispatchTrigger.java | 2 +- .../org/apache/cassandra/hints/HintsReader.java | 7 +- .../cassandra/index/SecondaryIndexManager.java | 7 +- .../org/apache/cassandra/index/TargetParser.java | 8 - .../cassandra/index/internal/CassandraIndex.java | 11 +- .../index/sai/virtual/ColumnIndexesSystemView.java | 9 +- .../sai/virtual/SSTableIndexesSystemView.java | 7 +- .../index/sai/virtual/SegmentsSystemView.java | 5 +- .../cassandra/io/sstable/CQLSSTableWriter.java | 28 +- .../io/sstable/SSTableSimpleIterator.java | 26 - .../cassandra/io/sstable/format/SSTableReader.java | 5 +- .../format/SSTableReaderLoadingBuilder.java | 2 +- .../cassandra/io/sstable/format/big/BigFormat.java | 97 +- .../io/sstable/format/big/BigTableWriter.java | 1 + .../io/sstable/indexsummary/IndexSummary.java | 2 - .../AbstractCloudMetadataServiceSnitch.java | 32 +- .../locator/AbstractReplicaCollection.java | 40 +- .../locator/AbstractReplicationStrategy.java | 265 +- .../cassandra/locator/CMSPlacementStrategy.java | 155 - .../org/apache/cassandra/locator/Endpoints.java | 5 - .../cassandra/locator/EndpointsByReplica.java | 64 - .../cassandra/locator/EndpointsForRange.java | 7 +- .../cassandra/locator/EndpointsForToken.java | 32 +- .../locator/GossipingPropertyFileSnitch.java | 59 +- .../cassandra/locator/InetAddressAndPort.java | 32 - .../apache/cassandra/locator/LocalStrategy.java | 57 +- .../org/apache/cassandra/locator/MetaStrategy.java | 87 - .../cassandra/locator/NetworkTopologyStrategy.java | 137 +- .../apache/cassandra/locator/PendingRangeMaps.java | 212 ++ .../cassandra/locator/PropertyFileSnitch.java | 248 +- .../cassandra/locator/RackInferringSnitch.java | 38 +- .../apache/cassandra/locator/RangesByEndpoint.java | 75 - src/java/org/apache/cassandra/locator/Replica.java | 40 +- .../apache/cassandra/locator/ReplicaLayout.java | 83 +- .../org/apache/cassandra/locator/ReplicaPlan.java | 227 +- .../org/apache/cassandra/locator/ReplicaPlans.java | 394 +- .../apache/cassandra/locator/SimpleStrategy.java | 66 +- .../apache/cassandra/locator/TokenMetadata.java | 1611 +++++++++ ...Strategy.java => TokenMetadataDiagnostics.java} | 33 +- .../cassandra/locator/TokenMetadataEvent.java | 62 + .../apache/cassandra/metrics/KeyspaceMetrics.java | 10 - .../org/apache/cassandra/metrics/PaxosMetrics.java | 3 - .../apache/cassandra/metrics/StorageMetrics.java | 2 - .../org/apache/cassandra/metrics/TCMMetrics.java | 154 - .../org/apache/cassandra/metrics/TableMetrics.java | 2 - .../cassandra/net/InboundMessageHandler.java | 6 +- src/java/org/apache/cassandra/net/InboundSink.java | 31 +- src/java/org/apache/cassandra/net/Message.java | 142 +- .../org/apache/cassandra/net/MessageDelivery.java | 44 - .../org/apache/cassandra/net/MessagingService.java | 56 +- .../apache/cassandra/net/OutboundConnection.java | 10 +- .../apache/cassandra/net/ResponseVerbHandler.java | 65 +- src/java/org/apache/cassandra/net/Verb.java | 40 - .../apache/cassandra/repair/RepairCoordinator.java | 4 +- .../org/apache/cassandra/repair/RepairJob.java | 8 +- .../cassandra/repair/RepairMessageVerbHandler.java | 23 - .../org/apache/cassandra/repair/RepairSession.java | 2 +- .../apache/cassandra/schema/ColumnMetadata.java | 61 - .../schema/DefaultSchemaUpdateHandler.java | 356 ++ .../DefaultSchemaUpdateHandlerFactory.java} | 19 +- .../schema/DistributedMetadataLogKeyspace.java | 284 -- .../apache/cassandra/schema/DistributedSchema.java | 281 +- .../org/apache/cassandra/schema/DroppedColumn.java | 34 - .../org/apache/cassandra/schema/IndexMetadata.java | 41 - src/java/org/apache/cassandra/schema/Indexes.java | 36 - .../apache/cassandra/schema/KeyspaceMetadata.java | 77 +- .../apache/cassandra/schema/KeyspaceParams.java | 35 +- .../org/apache/cassandra/schema/Keyspaces.java | 142 +- .../cassandra/schema/MigrationCoordinator.java | 761 ++++ .../schema/OfflineSchemaUpdateHandler.java | 96 + .../apache/cassandra/schema/PartitionDenylist.java | 17 +- .../apache/cassandra/schema/ReplicationParams.java | 187 +- src/java/org/apache/cassandra/schema/Schema.java | 770 +++- .../apache/cassandra/schema/SchemaConstants.java | 3 +- .../apache/cassandra/schema/SchemaDiagnostics.java | 44 +- .../org/apache/cassandra/schema/SchemaEvent.java | 9 +- .../apache/cassandra/schema/SchemaKeyspace.java | 55 +- .../apache/cassandra/schema/SchemaProvider.java | 188 +- .../cassandra/schema/SchemaPullVerbHandler.java | 20 +- .../cassandra/schema/SchemaPushVerbHandler.java | 21 +- .../cassandra/schema/SchemaTransformation.java | 97 +- .../cassandra/schema/SchemaTransformations.java | 29 +- .../cassandra/schema/SchemaUpdateHandler.java | 78 + .../SchemaUpdateHandlerFactory.java} | 29 +- .../schema/SchemaUpdateHandlerFactoryProvider.java | 65 + .../schema/SystemDistributedKeyspace.java | 155 +- src/java/org/apache/cassandra/schema/TableId.java | 35 +- .../org/apache/cassandra/schema/TableMetadata.java | 171 +- .../apache/cassandra/schema/TableMetadataRef.java | 131 +- .../cassandra/schema/TableMetadataRefCache.java | 158 + .../org/apache/cassandra/schema/TableParams.java | 144 - src/java/org/apache/cassandra/schema/Tables.java | 38 - .../apache/cassandra/schema/TriggerMetadata.java | 32 - src/java/org/apache/cassandra/schema/Triggers.java | 39 - src/java/org/apache/cassandra/schema/Types.java | 66 - .../org/apache/cassandra/schema/UserFunctions.java | 64 - .../org/apache/cassandra/schema/ViewMetadata.java | 52 - src/java/org/apache/cassandra/schema/Views.java | 38 - .../service/AbstractWriteResponseHandler.java | 4 - .../cassandra/service/ActiveRepairService.java | 118 +- .../apache/cassandra/service/CassandraDaemon.java | 239 +- .../org/apache/cassandra/service/ClientState.java | 21 - .../org/apache/cassandra/service/ClientWarn.java | 22 +- .../apache/cassandra/service/EchoVerbHandler.java | 3 +- .../service/PendingRangeCalculatorService.java | 98 + .../PendingRangeCalculatorServiceDiagnostics.java | 66 + .../PendingRangeCalculatorServiceEvent.java | 75 + .../apache/cassandra/service/RangeRelocator.java | 323 ++ src/java/org/apache/cassandra/service/Rebuild.java | 253 -- .../apache/cassandra/service/StartupChecks.java | 64 +- .../org/apache/cassandra/service/StorageProxy.java | 145 +- .../apache/cassandra/service/StorageService.java | 3766 +++++++++++++++----- .../cassandra/service/StorageServiceMBean.java | 7 +- .../cassandra/service/WriteResponseHandler.java | 2 - .../service/disk/usage/DiskUsageBroadcaster.java | 1 - .../org/apache/cassandra/service/paxos/Paxos.java | 88 +- .../cassandra/service/paxos/PaxosPrepare.java | 14 +- .../cassandra/service/paxos/PaxosRepair.java | 39 +- .../service/paxos/cleanup/PaxosCleanup.java | 18 +- .../service/paxos/cleanup/PaxosCleanupRequest.java | 5 - .../paxos/cleanup/PaxosStartPrepareCleanup.java | 3 + .../service/paxos/uncommitted/PaxosRows.java | 2 +- .../paxos/uncommitted/UncommittedTableData.java | 4 +- .../service/paxos/v1/AbstractPaxosVerbHandler.java | 73 - .../service/paxos/v1/PrepareVerbHandler.java | 6 +- .../service/paxos/v1/ProposeVerbHandler.java | 6 +- .../service/reads/AbstractReadExecutor.java | 11 +- .../cassandra/service/reads/ReadCallback.java | 33 +- .../service/reads/ReplicaFilteringProtection.java | 3 +- .../cassandra/service/reads/ResponseResolver.java | 1 + .../service/reads/range/ReplicaPlanIterator.java | 8 +- .../reads/repair/BlockingPartitionRepair.java | 54 +- .../service/reads/repair/BlockingReadRepair.java | 7 - .../reads/repair/RowIteratorMergeListener.java | 20 +- .../apache/cassandra/streaming/DataMovement.java | 111 - .../streaming/DataMovementVerbHandler.java | 112 - .../streaming/StreamDeserializingTask.java | 31 +- .../StreamReceivedOutOfTokenRangeException.java | 49 - .../apache/cassandra/streaming/StreamSession.java | 68 +- .../cassandra/tcm/AbstractLocalProcessor.java | 202 -- .../cassandra/tcm/AtomicLongBackedProcessor.java | 182 - .../org/apache/cassandra/tcm/CMSOperations.java | 199 -- .../apache/cassandra/tcm/CMSOperationsMBean.java | 45 - .../org/apache/cassandra/tcm/ClusterMetadata.java | 945 ----- .../cassandra/tcm/ClusterMetadataService.java | 860 ----- src/java/org/apache/cassandra/tcm/Commit.java | 408 --- .../cassandra/tcm/CurrentEpochRequestHandler.java | 42 - src/java/org/apache/cassandra/tcm/Discovery.java | 260 -- src/java/org/apache/cassandra/tcm/Epoch.java | 202 -- .../apache/cassandra/tcm/EpochAwareDebounce.java | 82 - src/java/org/apache/cassandra/tcm/FetchCMSLog.java | 121 - .../org/apache/cassandra/tcm/FetchPeerLog.java | 90 - src/java/org/apache/cassandra/tcm/MetadataKey.java | 81 - .../org/apache/cassandra/tcm/MetadataKeys.java | 55 - .../apache/cassandra/tcm/MetadataSnapshots.java | 121 - .../org/apache/cassandra/tcm/MetadataValue.java | 25 - .../apache/cassandra/tcm/MultiStepOperation.java | 187 - .../apache/cassandra/tcm/PaxosBackedProcessor.java | 219 -- .../org/apache/cassandra/tcm/PeerLogFetcher.java | 108 - src/java/org/apache/cassandra/tcm/Period.java | 207 -- src/java/org/apache/cassandra/tcm/Processor.java | 73 - .../cassandra/tcm/RecentlySealedPeriods.java | 140 - .../org/apache/cassandra/tcm/RemoteProcessor.java | 341 -- src/java/org/apache/cassandra/tcm/Retry.java | 202 -- src/java/org/apache/cassandra/tcm/Sealed.java | 128 - src/java/org/apache/cassandra/tcm/Startup.java | 500 --- .../cassandra/tcm/StubClusterMetadataService.java | 124 - .../org/apache/cassandra/tcm/TCM_implementation.md | 75 - .../cassandra/tcm/TransactionalClusterMetadata.md | 77 - .../org/apache/cassandra/tcm/Transformation.java | 320 -- .../cassandra/tcm/compatibility/GossipHelper.java | 392 -- .../tcm/compatibility/TokenRingUtils.java | 222 -- .../tcm/extensions/AbstractExtensionValue.java | 80 - .../cassandra/tcm/extensions/EpochValue.java | 54 - .../cassandra/tcm/extensions/ExtensionKey.java | 71 - .../cassandra/tcm/extensions/ExtensionValue.java | 36 - .../apache/cassandra/tcm/extensions/IntValue.java | 54 - .../cassandra/tcm/extensions/StringValue.java | 54 - .../tcm/listeners/ClientNotificationListener.java | 128 - .../tcm/listeners/InitializationListener.java | 36 - .../tcm/listeners/LegacyStateListener.java | 174 - .../cassandra/tcm/listeners/LogListener.java | 33 - .../tcm/listeners/MetadataSnapshotListener.java | 51 - .../tcm/listeners/PlacementsChangeListener.java | 52 - .../cassandra/tcm/listeners/SchemaListener.java | 57 - src/java/org/apache/cassandra/tcm/log/Entry.java | 189 - .../org/apache/cassandra/tcm/log/LocalLog.java | 858 ----- .../org/apache/cassandra/tcm/log/LogState.java | 267 -- .../org/apache/cassandra/tcm/log/LogStorage.java | 55 - .../org/apache/cassandra/tcm/log/Replication.java | 260 -- .../cassandra/tcm/log/SystemKeyspaceStorage.java | 162 - .../apache/cassandra/tcm/membership/Directory.java | 757 ---- .../apache/cassandra/tcm/membership/Location.java | 83 - .../cassandra/tcm/membership/NodeAddresses.java | 145 - .../apache/cassandra/tcm/membership/NodeId.java | 126 - .../apache/cassandra/tcm/membership/NodeState.java | 46 - .../cassandra/tcm/membership/NodeVersion.java | 137 - .../tcm/migration/ClusterMetadataHolder.java | 95 - .../apache/cassandra/tcm/migration/Election.java | 264 -- .../cassandra/tcm/migration/GossipCMSListener.java | 80 - .../cassandra/tcm/migration/GossipProcessor.java | 42 - .../cassandra/tcm/ownership/DataPlacement.java | 206 -- .../cassandra/tcm/ownership/DataPlacements.java | 277 -- .../org/apache/cassandra/tcm/ownership/Delta.java | 138 - .../cassandra/tcm/ownership/EntireRange.java | 50 - .../cassandra/tcm/ownership/MovementMap.java | 165 - .../cassandra/tcm/ownership/PlacementDeltas.java | 245 -- .../cassandra/tcm/ownership/PlacementForRange.java | 437 --- .../cassandra/tcm/ownership/PlacementProvider.java | 54 - .../tcm/ownership/PlacementTransitionPlan.java | 128 - .../tcm/ownership/PrimaryRangeComparator.java | 51 - .../cassandra/tcm/ownership/ReplicationMap.java | 106 - .../apache/cassandra/tcm/ownership/TokenMap.java | 290 -- .../tcm/ownership/UniformRangePlacement.java | 349 -- .../tcm/ownership/VersionedEndpoints.java | 210 -- .../apache/cassandra/tcm/sequences/AddToCMS.java | 208 -- .../cassandra/tcm/sequences/BootstrapAndJoin.java | 523 --- .../tcm/sequences/BootstrapAndReplace.java | 500 --- .../tcm/sequences/CancelCMSReconfiguration.java | 105 - .../cassandra/tcm/sequences/DataMovements.java | 143 - .../tcm/sequences/InProgressSequences.java | 304 -- .../cassandra/tcm/sequences/LeaveStreams.java | 47 - .../cassandra/tcm/sequences/LockedRanges.java | 451 --- .../org/apache/cassandra/tcm/sequences/Move.java | 586 --- .../cassandra/tcm/sequences/ProgressBarrier.java | 575 --- .../cassandra/tcm/sequences/ReconfigureCMS.java | 367 -- .../cassandra/tcm/sequences/RemoveNodeStreams.java | 165 - .../tcm/sequences/ReplaceSameAddress.java | 99 - .../cassandra/tcm/sequences/SequenceState.java | 124 - .../tcm/sequences/SingleNodeSequences.java | 168 - .../tcm/sequences/UnbootstrapAndLeave.java | 367 -- .../tcm/sequences/UnbootstrapStreams.java | 233 -- .../AsymmetricMetadataSerializer.java | 53 - .../tcm/serialization/MessageSerializers.java | 87 - .../tcm/serialization/MetadataSerializer.java | 22 - .../PartitionerAwareMetadataSerializer.java | 56 - .../UDTAndFunctionsAwareMetadataSerializer.java | 63 - .../serialization/UDTAwareMetadataSerializer.java | 61 - .../serialization/VerboseMetadataSerializer.java | 53 - .../cassandra/tcm/serialization/Version.java | 97 - .../cassandra/tcm/transformations/AlterSchema.java | 280 -- .../tcm/transformations/ApplyPlacementDeltas.java | 148 - .../cassandra/tcm/transformations/Assassinate.java | 133 - .../transformations/CancelInProgressSequence.java | 97 - .../tcm/transformations/CustomTransformation.java | 264 -- .../tcm/transformations/ForceSnapshot.java | 81 - .../cassandra/tcm/transformations/PrepareJoin.java | 355 -- .../tcm/transformations/PrepareLeave.java | 320 -- .../cassandra/tcm/transformations/PrepareMove.java | 300 -- .../tcm/transformations/PrepareReplace.java | 386 -- .../cassandra/tcm/transformations/Register.java | 216 -- .../cassandra/tcm/transformations/SealPeriod.java | 100 - .../cassandra/tcm/transformations/Startup.java | 157 - .../cassandra/tcm/transformations/Unregister.java | 104 - .../cassandra/tcm/transformations/UnsafeJoin.java | 107 - .../cms/AdvanceCMSReconfiguration.java | 393 -- .../cms/BaseMembershipTransformation.java | 95 - .../tcm/transformations/cms/FinishAddToCMS.java | 111 - .../tcm/transformations/cms/Initialize.java | 92 - .../tcm/transformations/cms/PreInitialize.java | 135 - .../cms/PrepareCMSReconfiguration.java | 289 -- .../tcm/transformations/cms/RemoveFromCMS.java | 175 - .../tcm/transformations/cms/StartAddToCMS.java | 121 - src/java/org/apache/cassandra/tools/JMXTool.java | 5 +- src/java/org/apache/cassandra/tools/NodeProbe.java | 28 +- src/java/org/apache/cassandra/tools/NodeTool.java | 5 - .../cassandra/tools/SSTableExpiredBlockers.java | 4 +- .../org/apache/cassandra/tools/SSTableExport.java | 1 - .../cassandra/tools/SSTableLevelResetter.java | 8 +- .../cassandra/tools/SSTableOfflineRelevel.java | 6 +- .../cassandra/tools/StandaloneSSTableUtil.java | 7 +- .../apache/cassandra/tools/StandaloneScrubber.java | 5 +- .../apache/cassandra/tools/StandaloneSplitter.java | 6 +- .../apache/cassandra/tools/StandaloneUpgrader.java | 8 +- .../apache/cassandra/tools/StandaloneVerifier.java | 8 +- .../tools/TransformClusterMetadataHelper.java | 95 - src/java/org/apache/cassandra/tools/Util.java | 2 +- .../cassandra/tools/nodetool/AbortBootstrap.java | 48 - .../cassandra/tools/nodetool/DescribeCMS.java | 44 - .../cassandra/tools/nodetool/InitializeCMS.java | 39 - .../org/apache/cassandra/tools/nodetool/Join.java | 2 + .../cassandra/tools/nodetool/ReconfigureCMS.java | 122 - .../cassandra/tools/nodetool/RemoveNode.java | 21 +- .../cassandra/tools/nodetool/stats/StatsTable.java | 4 +- .../tools/nodetool/stats/StatsTableComparator.java | 8 +- .../tools/nodetool/stats/TableStatsHolder.java | 9 +- .../tools/nodetool/stats/TableStatsPrinter.java | 22 +- .../apache/cassandra/tracing/TraceKeyspace.java | 65 +- .../apache/cassandra/transport/SimpleClient.java | 7 +- .../org/apache/cassandra/utils/BiMultiValMap.java | 16 - .../apache/cassandra/utils/CassandraVersion.java | 1 - src/java/org/apache/cassandra/utils/CounterId.java | 4 +- .../org/apache/cassandra/utils/FBUtilities.java | 60 +- .../org/apache/cassandra/utils/NativeLibrary.java | 5 - .../utils/RMIClientSocketFactoryImpl.java | 3 +- .../cassandra/utils/RecomputingSupplier.java | 125 + .../cassandra/utils/btree/AbstractBTreeMap.java | 157 - .../apache/cassandra/utils/btree/BTreeBiMap.java | 102 - .../org/apache/cassandra/utils/btree/BTreeMap.java | 232 -- .../cassandra/utils/btree/BTreeMultimap.java | 214 -- .../org/apache/cassandra/utils/btree/BTreeSet.java | 45 +- .../cassandra/utils/concurrent/AbstractFuture.java | 33 - .../cassandra/utils/concurrent/AsyncFuture.java | 11 - .../apache/cassandra/utils/concurrent/Future.java | 10 - .../cassandra/utils/concurrent/LoadingMap.java | 7 - .../cassandra/utils/concurrent/SyncFuture.java | 11 - .../cassandra/utils/concurrent/WaitQueue.java | 1 - test/conf/logback-dtest.xml | 5 +- test/conf/logback-simulator.xml | 1 + test/data/serialization/5.1/gms.EndpointState.bin | Bin 73 -> 0 bytes test/data/serialization/5.1/gms.Gossip.bin | Bin 166 -> 0 bytes .../serialization/5.1/service.SyncComplete.bin | Bin 256 -> 0 bytes .../data/serialization/5.1/service.SyncRequest.bin | Bin 111 -> 0 bytes .../5.1/service.ValidationComplete.bin | Bin 597 -> 0 bytes .../5.1/service.ValidationRequest.bin | Bin 74 -> 0 bytes .../serialization/5.1/utils.EstimatedHistogram.bin | Bin 97500 -> 0 bytes .../org/apache/cassandra/distributed/Cluster.java | 41 +- .../apache/cassandra/distributed/Constants.java | 4 - .../cassandra/distributed/action/GossipHelper.java | 282 +- .../cassandra/distributed/api/ICoordinator.java | 22 - .../ConcurrentQuiescentCheckerIntegrationTest.java | 123 - .../cassandra/distributed/fuzz/HarryHelper.java | 67 +- .../fuzz/InJVMTokenAwareVisitorExecutor.java | 111 - .../cassandra/distributed/fuzz/InJvmSut.java | 43 +- .../cassandra/distributed/fuzz/InJvmSutBase.java | 43 +- .../cassandra/distributed/harry/ClusterState.java | 24 - .../distributed/harry/ExistingClusterSUT.java | 96 - .../cassandra/distributed/harry/FlaggedRunner.java | 85 - .../distributed/impl/AbstractCluster.java | 49 +- .../distributed/impl/DistributedTestSnitch.java | 2 +- .../cassandra/distributed/impl/Instance.java | 449 ++- .../cassandra/distributed/impl/IsolatedJmx.java | 5 +- .../apache/cassandra/distributed/impl/Listen.java | 7 + .../apache/cassandra/distributed/impl/Query.java | 7 + .../distributed/impl/TestChangeListener.java | 119 - .../distributed/impl/UnsafeGossipHelper.java | 8 +- .../mock/nodetool/InternalNodeProbe.java | 2 - .../cassandra/distributed/shared/ClusterUtils.java | 469 +-- .../cassandra/distributed/test/AlterTest.java | 12 + .../cassandra/distributed/test/AuthTest.java | 77 +- .../distributed/test/ByteBuddyExamplesTest.java | 15 +- .../cassandra/distributed/test/CASAddTest.java | 18 +- .../distributed/test/CASContentionTest.java | 6 - .../cassandra/distributed/test/CASMultiDCTest.java | 6 - .../apache/cassandra/distributed/test/CASTest.java | 6 - .../cassandra/distributed/test/CASTestBase.java | 24 +- .../distributed/test/ClearSnapshotTest.java | 5 +- .../distributed/test/CompactionDiskSpaceTest.java | 2 +- .../test/CreateTableNonDeterministicTest.java | 89 - .../distributed/test/DecommissionTest.java | 71 +- .../distributed/test/FailureLoggingTest.java | 19 + .../cassandra/distributed/test/FrozenUDTTest.java | 5 +- .../cassandra/distributed/test/GossipTest.java | 287 +- .../test/HintedHandoffAddRemoveNodesTest.java | 80 +- .../distributed/test/IPMembershipTest.java | 11 +- .../test/InternodeEncryptionEnforcementTest.java | 128 +- .../cassandra/distributed/test/JVMDTestTest.java | 8 +- .../distributed/test/MigrationCoordinatorTest.java | 123 + .../distributed/test/MixedModeFuzzTest.java | 5 +- .../cassandra/distributed/test/MoveTest.java | 5 +- .../distributed/test/PartitionDenylistTest.java | 1 + .../distributed/test/PaxosRepair2Test.java | 5 +- .../distributed/test/PaxosRepairTest.java | 38 +- .../test/PaxosUncommittedIndexTest.java | 2 +- ...ava => ReadRepairEmptyRangeTombstonesTest.java} | 27 +- .../cassandra/distributed/test/ReadRepairTest.java | 61 +- .../cassandra/distributed/test/RemoveNodeTest.java | 99 - .../distributed/test/RepairCoordinatorFast.java | 22 +- .../test/RepairCoordinatorNeighbourDown.java | 24 +- .../distributed/test/RepairDigestTrackingTest.java | 54 +- .../distributed/test/RepairErrorsTest.java | 12 +- .../distributed/test/SSTableIdGenerationTest.java | 6 - .../cassandra/distributed/test/SchemaTest.java | 161 +- .../distributed/test/SecondaryIndexTest.java | 2 +- .../cassandra/distributed/test/TestBaseImpl.java | 31 +- .../test/TransientRangeMovement2Test.java | 134 - .../test/TransientRangeMovementTest.java | 272 -- .../test/UpdateSystemAuthAfterDCExpansionTest.java | 33 +- .../guardrails/GuardrailBulkLoadEnabledTest.java | 179 - .../test/guardrails/GuardrailDiskUsageTest.java | 26 +- ...rdrailItemsPerCollectionOnSSTableWriteTest.java | 9 +- .../hostreplacement/AssassinatedEmptyNodeTest.java | 11 +- .../test/hostreplacement/BaseAssassinatedCase.java | 8 +- .../test/hostreplacement/FailedBootstrapTest.java | 48 +- .../HostReplacementOfDownedClusterTest.java | 57 +- .../test/hostreplacement/HostReplacementTest.java | 18 +- ...AsHibernatingNodeWithoutReplaceAddressTest.java | 16 +- .../distributed/test/jmx/JMXGetterCheckTest.java | 9 +- .../distributed/test/log/BootWithMetadataTest.java | 140 - .../distributed/test/log/BounceGossipTest.java | 247 -- .../test/log/BounceIndexRebuildTest.java | 52 - .../test/log/BounceResetHostIdTest.java | 52 - .../test/log/CMSMembershipMetricsTest.java | 119 - .../distributed/test/log/CMSTestBase.java | 131 - .../test/log/ClusterMetadataTestHelper.java | 1078 ------ .../test/log/ConflictingAddressRestartTest.java | 85 - .../distributed/test/log/ConsistentLeaveTest.java | 156 - .../distributed/test/log/ConsistentMoveTest.java | 165 - .../distributed/test/log/CoordinatorPathTest.java | 260 -- .../test/log/CoordinatorPathTestBase.java | 1152 ------ .../distributed/test/log/DiscoverCMSTest.java | 84 - .../distributed/test/log/DistributedLogTest.java | 200 -- .../distributed/test/log/FailedLeaveTest.java | 176 - .../test/log/FetchLogFromPeersTest.java | 379 -- .../distributed/test/log/ForceSnapshotTest.java | 157 - .../distributed/test/log/FuzzTestBase.java | 141 - .../distributed/test/log/GossipDeadlockTest.java | 147 - .../log/InProgressSequenceCoordinationTest.java | 409 --- .../test/log/MetadataChangeSimulationTest.java | 763 ---- .../distributed/test/log/ModelChecker.java | 307 -- .../cassandra/distributed/test/log/ModelState.java | 364 -- .../test/log/OperationalEquivalenceTest.java | 204 -- .../distributed/test/log/PauseCommitsTest.java | 56 - .../distributed/test/log/PlacementSimulator.java | 1789 ---------- .../test/log/PlacementSimulatorTest.java | 379 -- .../test/log/QuorumIntersectionSimulatorTest.java | 142 - .../distributed/test/log/ReconfigureCMSTest.java | 141 - .../distributed/test/log/RegisterTest.java | 195 - .../test/log/RequestCurrentEpochTest.java | 102 - .../distributed/test/log/ResumableStartupTest.java | 151 - .../cassandra/distributed/test/log/RngUtils.java | 106 - .../distributed/test/log/SimulatedOperation.java | 562 --- .../distributed/test/log/SnapshotTest.java | 244 -- .../test/log/SystemKeyspaceStorageTest.java | 235 -- .../distributed/test/log/TestProcessor.java | 137 - .../test/log/TriggeredReconfigureCMSTest.java | 151 - .../ring/AssignSameTokenToMultipleNodesTest.java | 52 - .../test/ring/BootstrapResetProgressTest.java | 156 - .../distributed/test/ring/BootstrapTest.java | 193 +- .../distributed/test/ring/CMSMembershipTest.java | 187 - ...geMovementTest.java => CleanupFailureTest.java} | 77 +- .../ring/CommunicationDuringDecommissionTest.java | 18 +- .../test/ring/ConsistentBootstrapTest.java | 251 -- .../distributed/test/ring/DecommissionTest.java | 210 -- .../distributed/test/ring/NodeNotInRingTest.java | 3 +- .../distributed/test/ring/PendingWritesTest.java | 109 + .../distributed/test/ring/RangeVersioningTest.java | 72 - .../test/ring/ReadsDuringBootstrapTest.java | 115 + .../test/ring/StopProcessingExceptionTest.java | 78 - .../test/streaming/StreamCloseInMiddleTest.java | 22 +- .../test/tcm/LogReplicationSmokeTest.java | 101 - .../test/topology/DecommissionAvoidTimeouts.java | 27 +- .../distributed/upgrade/BatchUpgradeTest.java | 2 - .../ClusterMetadataSingleNodeUpgradeTest.java | 47 - .../upgrade/ClusterMetadataUpgradeHarryTest.java | 143 - .../upgrade/ClusterMetadataUpgradeHintsTest.java | 76 - .../upgrade/ClusterMetadataUpgradeHostIdTest.java | 103 - .../ClusterMetadataUpgradeIgnoreHostTest.java | 50 - .../ClusterMetadataUpgradeIgnoreHostsTest.java | 50 - .../upgrade/ClusterMetadataUpgradeTest.java | 66 - .../upgrade/CompactStorageColumnDeleteTest.java | 2 - .../upgrade/CompactStorageHiddenColumnTest.java | 2 - ...CompactStorageImplicitNullInClusteringTest.java | 2 - .../upgrade/CompactStoragePagingTest.java | 2 - .../CompactionHistorySystemTableUpgradeTest.java | 26 +- .../upgrade/DropCompactStorageTest.java | 1 - .../upgrade/MixedModeBatchTestBase.java | 2 - .../upgrade/MixedModeConsistencyV30Test.java | 4 +- .../upgrade/MixedModeFrom3ReplicationTest.java | 2 - .../upgrade/MixedModeIndexTestBase.java | 4 +- .../distributed/upgrade/MixedModeRepairTest.java | 2 +- .../MixedModeTTLOverflowUpgradeTestBase.java | 6 +- .../upgrade/MixedModeWritetimeOrTTLTest.java | 6 +- .../upgrade/Pre40MessageFilterTest.java | 2 +- .../distributed/upgrade/UpgradeTestBase.java | 43 +- .../util/byterewrite/StatusChangeListener.java | 133 + .../distributed/util/byterewrite/Undead.java | 2 +- .../org/apache/cassandra/cql3/CorruptionTest.java | 15 +- .../db/commitlog/CommitLogStressTest.java | 2 +- .../db/compaction/LongCompactionsTest.java | 2 +- .../LongLeveledCompactionStrategyCQLTest.java | 3 +- .../LongLeveledCompactionStrategyTest.java | 29 +- .../io/sstable/CQLSSTableWriterLongTest.java | 10 + .../locator/DynamicEndpointSnitchLongTest.java | 2 - .../cassandra/streaming/LongStreamingTest.java | 7 +- .../cassandra/test/microbench/MutationBench.java | 22 +- .../test/microbench/PendingRangesBench.java | 115 + .../simulator/asm/GlobalMethodTransformer.java | 8 +- .../cassandra/simulator/asm/InterceptAgent.java | 6 +- .../systems/InterceptorOfSystemMethods.java | 13 +- .../org/apache/cassandra/simulator/ActionList.java | 12 - .../org/apache/cassandra/simulator/Actions.java | 6 +- .../cassandra/simulator/ClusterSimulation.java | 76 +- .../main/org/apache/cassandra/simulator/Debug.java | 12 +- .../org/apache/cassandra/simulator/Ordered.java | 4 +- .../cassandra/simulator/SimulationRunner.java | 2 + .../apache/cassandra/simulator/SimulatorUtils.java | 9 - .../simulator/cluster/ClusterActions.java | 57 +- .../simulator/cluster/KeyspaceActions.java | 216 +- .../simulator/cluster/OnClusterChangeRf.java | 5 +- .../simulator/cluster/OnClusterChangeTopology.java | 5 +- .../cassandra/simulator/cluster/OnClusterJoin.java | 88 +- .../simulator/cluster/OnClusterLeave.java | 96 +- .../simulator/cluster/OnClusterReplace.java | 161 +- .../cluster/OnClusterSyncPendingRanges.java | 15 +- .../simulator/cluster/OnClusterUpdateGossip.java | 64 + .../simulator/cluster/OnInstanceBootstrap.java | 54 + .../simulator/cluster/OnInstanceGossipWith.java | 50 + .../simulator/cluster/OnInstanceGossipWithAll.java | 22 +- .../simulator/cluster/OnInstanceMarkShutdown.java | 14 +- .../simulator/cluster/OnInstanceRepair.java | 8 +- .../cluster/OnInstanceSendShutdownToAll.java | 21 +- .../cluster/OnInstanceSetBootstrapReplacing.java | 13 +- .../cluster/OnInstanceSetBootstrapping.java | 13 +- .../simulator/cluster/OnInstanceSetLeaving.java | 10 +- .../simulator/cluster/OnInstanceSetLeft.java} | 11 +- .../simulator/cluster/OnInstanceSetNormal.java} | 24 +- ...iesce.java => OnInstanceSyncPendingRanges.java} | 35 +- .../cluster/OnInstanceSyncSchemaForBootstrap.java | 26 +- .../apache/cassandra/simulator/cluster/Utils.java | 23 +- .../simulator/harry/HarryValidatingQuery.java | 147 - .../simulator/systems/InterceptingAwaitable.java | 6 +- .../simulator/systems/InterceptingExecutor.java | 3 +- .../systems/InterceptingGlobalMethods.java | 3 - .../simulator/systems/InterceptingMonitors.java | 5 +- .../simulator/systems/SimulatedAction.java | 26 +- .../simulator/systems/SimulatedActionCallable.java | 4 +- .../simulator/systems/SimulatedActionTask.java | 8 - .../systems/SimulatedFailureDetector.java | 6 - .../simulator/systems/SimulatedSnitch.java | 7 - .../simulator/systems/SimulatedSystems.java | 12 +- .../test/AlwaysDeliverNetworkScheduler.java | 77 - .../simulator/test/FixedLossNetworkScheduler.java | 158 - .../simulator/test/HarrySimulatorTest.java | 797 ----- .../simulator/test/ShortPaxosSimulationTest.java | 68 - .../simulator/test/SimulatedVisitExectuor.java | 182 - .../simulator/test/SimulationTestBase.java | 122 +- .../simulator/test/TrivialSimulationTest.java | 1 - .../cassandra/AbstractSerializationsTester.java | 3 +- test/unit/org/apache/cassandra/SchemaLoader.java | 37 +- .../unit/org/apache/cassandra/ServerTestUtils.java | 166 +- test/unit/org/apache/cassandra/Util.java | 106 +- .../cassandra/auth/AllowAllCIDRAuthorizerTest.java | 3 + .../cassandra/auth/CassandraAuthorizerTest.java | 3 +- .../CassandraCIDRAuthorizerEnforceModeTest.java | 2 + .../CassandraCIDRAuthorizerMonitorModeTest.java | 2 + .../auth/CassandraNetworkAuthorizerTest.java | 1 + .../cassandra/auth/CassandraRoleManagerTest.java | 9 +- .../cassandra/auth/CreateAndAlterRoleTest.java | 6 +- .../apache/cassandra/auth/GrantAndRevokeTest.java | 3 +- .../cassandra/auth/MutualTlsAuthenticatorTest.java | 7 +- .../auth/MutualTlsInternodeAuthenticatorTest.java | 5 +- ...alTlsWithPasswordFallbackAuthenticatorTest.java | 4 +- .../cassandra/auth/PasswordAuthenticatorTest.java | 6 +- .../org/apache/cassandra/auth/RoleOptionsTest.java | 2 +- .../cassandra/batchlog/BatchlogManagerTest.java | 31 +- .../cassandra/cql3/AlterSchemaStatementTest.java | 67 - test/unit/org/apache/cassandra/cql3/BatchTest.java | 2 +- .../apache/cassandra/cql3/CDCStatementTest.java | 3 +- test/unit/org/apache/cassandra/cql3/CQLTester.java | 99 +- .../cassandra/cql3/CustomNowInSecondsTest.java | 6 +- .../org/apache/cassandra/cql3/KeyCacheCqlTest.java | 10 +- .../org/apache/cassandra/cql3/OutOfSpaceTest.java | 25 +- .../unit/org/apache/cassandra/cql3/PagingTest.java | 16 +- .../apache/cassandra/cql3/RandomSchemaTest.java | 29 - test/unit/org/apache/cassandra/cql3/ViewTest.java | 4 +- .../cql3/functions/masking/ColumnMaskTester.java | 1 + .../masking/SelectMaskedPermissionTest.java | 1 + .../functions/masking/UnmaskPermissionTest.java | 1 + .../cql3/selection/SelectionColumnMappingTest.java | 6 +- .../cql3/statements/DescribeStatementTest.java | 12 +- .../validation/entities/FrozenCollectionsTest.java | 5 +- .../cql3/validation/entities/JsonTest.java | 10 +- .../validation/entities/SecondaryIndexTest.java | 9 +- .../cql3/validation/entities/UserTypesTest.java | 7 +- .../cql3/validation/entities/VirtualTableTest.java | 6 +- .../cql3/validation/operations/AlterNTSTest.java | 37 +- .../cql3/validation/operations/AlterTest.java | 219 +- .../operations/CompactStorageSplit2Test.java | 1 + .../cql3/validation/operations/CreateTest.java | 96 +- .../operations/DropRecreateAndRestoreTest.java | 3 - .../InsertUpdateIfConditionCollectionsTest.java | 11 +- .../InsertUpdateIfConditionStaticsTest.java | 11 +- .../operations/InsertUpdateIfConditionTest.java | 35 +- .../validation/operations/SelectLimitTest.java | 9 +- .../unit/org/apache/cassandra/db/CellSpecTest.java | 1 - test/unit/org/apache/cassandra/db/CleanupTest.java | 86 +- .../apache/cassandra/db/CleanupTransientTest.java | 29 +- .../db/ColumnFamilyStoreClientModeTest.java | 21 +- .../apache/cassandra/db/ColumnFamilyStoreTest.java | 7 - test/unit/org/apache/cassandra/db/ColumnsTest.java | 4 +- .../cassandra/db/CorruptPrimaryIndexTest.java | 2 +- .../org/apache/cassandra/db/CounterCacheTest.java | 24 +- .../CounterMutationVerbHandlerOutOfRangeTest.java | 192 - .../cassandra/db/DiskBoundaryManagerTest.java | 32 +- test/unit/org/apache/cassandra/db/ImportTest.java | 104 +- .../unit/org/apache/cassandra/db/KeyspaceTest.java | 21 +- .../db/MutationVerbHandlerOutOfRangeTest.java | 221 -- .../org/apache/cassandra/db/ReadCommandTest.java | 5 +- .../db/ReadCommandVerbHandlerOutOfRangeTest.java | 272 -- .../cassandra/db/ReadCommandVerbHandlerTest.java | 30 +- .../org/apache/cassandra/db/ReadResponseTest.java | 14 +- .../cassandra/db/RecoveryManagerFlushedTest.java | 23 +- .../apache/cassandra/db/RepairedDataInfoTest.java | 5 +- .../unit/org/apache/cassandra/db/RowCacheTest.java | 35 +- .../apache/cassandra/db/SchemaCQLHelperTest.java | 8 + .../apache/cassandra/db/SecondaryIndexTest.java | 13 +- .../db/SinglePartitionSliceCommandTest.java | 2 +- .../cassandra/db/SystemKeyspaceMigrator41Test.java | 9 +- .../apache/cassandra/db/SystemKeyspaceTest.java | 14 +- .../cassandra/db/TopPartitionTrackerTest.java | 22 +- .../commitlog/CommitLogSegmentManagerCDCTest.java | 56 +- .../cassandra/db/commitlog/CommitLogTest.java | 57 +- .../db/commitlog/CommitLogUpgradeTest.java | 22 +- .../db/compaction/CompactionControllerTest.java | 3 +- .../db/compaction/CompactionIteratorTest.java | 32 +- ...ompactionStrategyManagerBoundaryReloadTest.java | 32 +- .../compaction/CompactionStrategyManagerTest.java | 9 +- .../db/compaction/LeveledGenerationsTest.java | 1 + .../cassandra/db/compaction/NeverPurgeTest.java | 6 +- .../db/compaction/PartialCompactionsTest.java | 6 +- .../cassandra/db/compaction/ShardManagerTest.java | 11 +- .../TimeWindowCompactionStrategyTest.java | 6 +- .../compaction/UnifiedCompactionStrategyTest.java | 6 +- .../db/compaction/unified/ControllerTest.java | 7 +- .../unified/ShardedCompactionWriterTest.java | 16 +- .../compaction/unified/ShardedMultiWriterTest.java | 1 + .../writers/CompactionAwareWriterTest.java | 12 +- .../cassandra/db/context/CounterContextTest.java | 7 - .../cassandra/db/filter/ColumnFilterTest.java | 16 +- .../apache/cassandra/db/filter/RowFilterTest.java | 1 - .../db/guardrails/GuardrailKeyspacesTest.java | 10 + .../GuardrailMaximumReplicationFactorTest.java | 6 +- .../GuardrailMinimumReplicationFactorTest.java | 7 +- .../db/guardrails/GuardrailTablesTest.java | 3 +- .../cassandra/db/guardrails/GuardrailTester.java | 9 +- .../apache/cassandra/db/lifecycle/HelpersTest.java | 6 +- .../db/lifecycle/LifecycleTransactionTest.java | 11 +- .../cassandra/db/lifecycle/LogTransactionTest.java | 7 + .../db/lifecycle/RealTransactionsTest.java | 5 +- .../apache/cassandra/db/lifecycle/TrackerTest.java | 4 +- .../apache/cassandra/db/lifecycle/ViewTest.java | 6 +- .../cassandra/db/memtable/MemtableQuickTest.java | 4 +- .../db/memtable/MemtableSizeTestBase.java | 1 + .../cassandra/db/partitions/PurgeFunctionTest.java | 1 - .../repair/AbstractPendingAntiCompactionTest.java | 14 +- .../rows/PartitionSerializationExceptionTest.java | 5 +- .../apache/cassandra/db/rows/RowsMergingTest.java | 3 +- .../db/rows/ThrottledUnfilteredIteratorTest.java | 14 +- .../db/rows/UnfilteredRowIteratorsTest.java | 1 - .../cassandra/db/streaming/StreamRequestTest.java | 3 - .../db/transform/RTTransformationsTest.java | 2 - .../cassandra/db/view/ViewBuilderTaskTest.java | 2 +- .../apache/cassandra/db/view/ViewUtilsTest.java | 68 +- .../db/virtual/BatchMetricsTableTest.java | 7 + .../db/virtual/CIDRFilteringMetricsTableTest.java | 2 + .../cassandra/db/virtual/CQLMetricsTableTest.java | 7 + .../cassandra/db/virtual/ClientsTableTest.java | 7 + .../db/virtual/CredentialsCacheKeysTableTest.java | 4 +- .../cassandra/db/virtual/GossipInfoTableTest.java | 7 + .../virtual/JmxPermissionsCacheKeysTableTest.java | 3 +- .../db/virtual/LocalRepairTablesTest.java | 2 + .../cassandra/db/virtual/LogMessagesTableTest.java | 7 + .../NetworkPermissionsCacheKeysTableTest.java | 3 +- .../db/virtual/PermissionsCacheKeysTableTest.java | 3 +- .../db/virtual/RolesCacheKeysTableTest.java | 3 +- .../db/virtual/SSTableTasksTableTest.java | 3 +- .../cassandra/db/virtual/SettingsTableTest.java | 7 + .../db/virtual/StreamingVirtualTableTest.java | 1 + .../db/virtual/SystemPropertiesTableTest.java | 7 + .../org/apache/cassandra/dht/BootStrapperTest.java | 101 +- .../apache/cassandra/dht/LengthPartitioner.java | 2 +- .../dht/tokenallocator/TokenAllocationTest.java | 129 +- .../apache/cassandra/gms/ExpireEndpointTest.java | 65 + .../apache/cassandra/gms/FailureDetectorTest.java | 26 +- .../apache/cassandra/gms/GossipShutdownTest.java | 6 +- .../org/apache/cassandra/gms/GossiperTest.java | 96 +- .../org/apache/cassandra/gms/NewGossiperTest.java | 154 - .../gms/PendingRangeCalculatorServiceTest.java | 134 + .../apache/cassandra/gms/SerializationsTest.java | 28 +- .../org/apache/cassandra/gms/ShadowRoundTest.java | 218 ++ .../org/apache/cassandra/hints/AlteredHints.java | 2 +- .../apache/cassandra/hints/DTestSerializer.java | 6 +- .../apache/cassandra/hints/HintMessageTest.java | 2 +- test/unit/org/apache/cassandra/hints/HintTest.java | 41 +- .../apache/cassandra/hints/HintsReaderTest.java | 6 +- .../org/apache/cassandra/hints/HintsStoreTest.java | 2 +- .../index/internal/CustomCassandraIndex.java | 37 +- .../index/sai/memory/VectorMemoryIndexTest.java | 23 +- .../index/sai/virtual/IndexesSystemViewTest.java | 3 + .../index/sai/virtual/SSTablesSystemViewTest.java | 3 + .../index/sasi/disk/PerSSTableIndexWriterTest.java | 3 +- .../cassandra/index/sasi/plan/OperationTest.java | 3 +- .../cassandra/io/compress/CQLCompressionTest.java | 4 +- .../io/sstable/CQLSSTableWriterClientTest.java | 22 +- .../sstable/CQLSSTableWriterConcurrencyTest.java | 7 + .../cassandra/io/sstable/CQLSSTableWriterTest.java | 4 - .../cassandra/io/sstable/LegacySSTableTest.java | 8 +- .../io/sstable/RangeAwareSSTableWriterTest.java | 7 +- .../cassandra/io/sstable/SSTableLoaderTest.java | 11 +- .../io/sstable/SSTableWriterTestBase.java | 4 +- .../apache/cassandra/io/sstable/VerifyTest.java | 20 +- ...r.java => AbstractReplicationStrategyTest.java} | 39 +- .../cassandra/locator/AlibabaCloudSnitchTest.java | 34 +- .../locator/AssureSufficientLiveNodesTest.java | 20 +- .../cassandra/locator/CloudstackSnitchTest.java | 42 +- .../locator/DynamicEndpointSnitchTest.java | 20 - .../apache/cassandra/locator/Ec2SnitchTest.java | 34 +- .../cassandra/locator/GoogleCloudSnitchTest.java | 34 +- .../apache/cassandra/locator/MetaStrategyTest.java | 161 - .../locator/NetworkTopologyStrategyTest.java | 261 +- .../cassandra/locator/PendingRangeMapsTest.java | 108 + .../cassandra/locator/PendingRangesTest.java | 273 +- .../cassandra/locator/PropertyFileSnitchTest.java | 338 +- .../apache/cassandra/locator/ReplicaPlansTest.java | 18 +- .../cassandra/locator/ReplicationFactorTest.java | 4 +- .../ReplicationStrategyEndpointCacheTest.java | 107 + .../cassandra/locator/SimpleStrategyTest.java | 176 +- .../cassandra/locator/TokenMetadataTest.java | 399 +++ .../ClientRequestRowAndColumnMetricsTest.java | 3 +- .../cassandra/metrics/TrieMemtableMetricsTest.java | 2 + .../org/apache/cassandra/net/ConnectionTest.java | 45 +- .../unit/org/apache/cassandra/net/FramingTest.java | 2 - .../org/apache/cassandra/net/HandshakeTest.java | 26 +- .../net/MessageSerializationPropertyTest.java | 2 - .../unit/org/apache/cassandra/net/MessageTest.java | 15 +- .../apache/cassandra/net/MessagingServiceTest.java | 2 - .../cassandra/net/MockMessagingServiceTest.java | 4 +- .../cassandra/net/OutboundConnectionsTest.java | 2 - .../cassandra/net/OutboundMessageQueueTest.java | 2 - .../cassandra/net/ProxyHandlerConnectionsTest.java | 2 - .../net/StartupClusterConnectivityCheckerTest.java | 4 - .../org/apache/cassandra/repair/FuzzTestBase.java | 41 +- .../org/apache/cassandra/repair/RepairJobTest.java | 4 - .../RepairMessageVerbHandlerOutOfRangeTest.java | 273 -- .../consistent/CoordinatorMessagingTest.java | 2 +- .../repair/consistent/CoordinatorSessionTest.java | 8 +- .../repair/consistent/CoordinatorSessionsTest.java | 2 +- .../repair/consistent/LocalSessionTest.java | 2 +- .../messages/RepairMessageSerializationsTest.java | 2 - .../repair/messages/RepairMessageTest.java | 6 +- .../schema/CreateTableValidationTest.java | 49 +- .../cassandra/schema/MigrationCoordinatorTest.java | 443 +++ ...KSTest.java => MigrationManagerDropKSTest.java} | 2 +- ...aChangesTest.java => MigrationManagerTest.java} | 24 +- .../org/apache/cassandra/schema/MockSchema.java | 166 +- .../schema/RemoveWithoutDroppingTest.java | 125 + .../SchemaChangeDuringRangeMovementTest.java | 254 -- .../cassandra/schema/SchemaKeyspaceTest.java | 80 +- .../org/apache/cassandra/schema/SchemaTest.java | 319 +- .../apache/cassandra/schema/SchemaTestUtil.java | 57 +- .../cassandra/schema/TableMetadataSerDeTest.java | 187 - .../apache/cassandra/schema/TableMetadataTest.java | 8 - .../cassandra/service/ActiveRepairServiceTest.java | 92 +- .../cassandra/service/BootstrapTransientTest.java | 174 +- .../apache/cassandra/service/ClientStateTest.java | 11 +- .../service/DefaultFSErrorHandlerTest.java | 2 - .../cassandra/service/DiskFailurePolicyTest.java | 2 - .../cassandra/service/JoinTokenRingTest.java | 24 +- .../cassandra/service/LeaveAndBootstrapTest.java | 739 ++++ .../cassandra/service/LegacyAuthFailTest.java | 7 + .../org/apache/cassandra/service/MoveTest.java | 1102 ++++++ .../cassandra/service/MoveTransientTest.java | 705 ++++ .../cassandra/service/PartitionDenylistTest.java | 56 +- .../org/apache/cassandra/service/RemoveTest.java | 92 +- .../cassandra/service/SerializationsTest.java | 3 - .../apache/cassandra/service/StorageProxyTest.java | 18 +- .../cassandra/service/StorageServiceAccessor.java} | 13 +- .../cassandra/service/StorageServiceDrainTest.java | 10 +- .../service/StorageServiceServerM3PTest.java | 12 +- .../service/StorageServiceServerTest.java | 572 +-- .../cassandra/service/StorageServiceTest.java | 133 +- .../service/WriteResponseHandlerTest.java | 18 +- .../service/WriteResponseHandlerTransientTest.java | 33 +- .../paxos/PaxosVerbHandlerOutOfRangeTest.java | 195 - .../service/reads/AbstractReadResponseTest.java | 7 +- .../cassandra/service/reads/DataResolverTest.java | 38 +- .../service/reads/DigestResolverTest.java | 3 +- .../cassandra/service/reads/ReadExecutorTest.java | 5 +- .../service/reads/range/ReplicaPlanMergerTest.java | 14 - .../service/reads/range/TokenUpdater.java | 48 +- .../reads/repair/AbstractReadRepairTest.java | 48 +- .../reads/repair/BlockingReadRepairTest.java | 4 +- .../repair/DiagEventsBlockingReadRepairTest.java | 4 +- .../reads/repair/RepairedDataVerifierTest.java | 3 +- ...SnapshotsTest.java => SnapshotManagerTest.java} | 2 +- .../cassandra/streaming/StreamRateLimiterTest.java | 8 +- .../cassandra/streaming/StreamReaderTest.java | 547 --- .../streaming/StreamSessionOwnedRangesTest.java | 221 -- .../cassandra/streaming/StreamSessionTest.java | 2 +- .../cassandra/streaming/StreamingTransferTest.java | 2 - .../apache/cassandra/tcm/BootWithMetadataTest.java | 184 - .../apache/cassandra/tcm/ClusterMetadataTest.java | 110 - .../tcm/ClusterMetadataTransformationTest.java | 316 -- .../cassandra/tcm/DiscoverySimulationTest.java | 186 - .../org/apache/cassandra/tcm/LogStateTest.java | 102 - .../cassandra/tcm/RecentlySealedPeriodsTest.java | 112 - .../apache/cassandra/tcm/RemoteProcessorTest.java | 110 - .../tcm/compatibility/GossipHelperTest.java | 233 -- .../listeners/ClientNotificationListenerTest.java | 63 - .../cassandra/tcm/log/DistributedLogStateTest.java | 157 - .../org/apache/cassandra/tcm/log/LocalLogTest.java | 256 -- .../tcm/log/LocalStorageLogStateTest.java | 138 - .../tcm/log/LogListenerNotificationTest.java | 138 - .../apache/cassandra/tcm/log/LogStateTestBase.java | 273 -- .../cassandra/tcm/membership/MembershipUtils.java | 60 - .../cassandra/tcm/ownership/DeltaMapTest.java | 217 -- .../cassandra/tcm/ownership/OwnershipUtils.java | 242 -- .../tcm/ownership/PrimaryRangeComparatorTest.java | 107 - .../UniformRangePlacementIntegrationTest.java | 100 - .../tcm/ownership/UniformRangePlacementTest.java | 320 -- .../InProgressSequenceCancellationTest.java | 344 -- .../tcm/sequences/ProgressBarrierTest.java | 351 -- .../cassandra/tcm/sequences/SequencesUtils.java | 172 - .../tcm/transformations/EventsMetadataTest.java | 191 - .../tcm/transformations/PrepareLeaveTest.java | 177 - .../cassandra/tools/JMXCompatabilityTest.java | 38 +- .../tools/StandaloneSplitterWithCQLTesterTest.java | 20 - .../tools/StandaloneVerifierOnSSTablesTest.java | 3 +- .../cassandra/tools/SystemExitException.java | 3 - .../apache/cassandra/tools/TopPartitionsTest.java | 7 +- .../tools/nodetool/CIDRFilteringStatsTest.java | 3 + .../tools/nodetool/DropCIDRGroupTest.java | 4 + .../tools/nodetool/ForceCompactionTest.java | 3 +- .../tools/nodetool/GetAuthCacheConfigTest.java | 1 + .../tools/nodetool/GetCIDRGroupsOfIPTest.java | 4 + .../cassandra/tools/nodetool/GossipInfoTest.java | 1 + .../InvalidateCIDRPermissionsCacheTest.java | 3 + .../nodetool/InvalidateCredentialsCacheTest.java | 4 + .../InvalidateJmxPermissionsCacheTest.java | 19 +- .../InvalidateNetworkPermissionsCacheTest.java | 3 + .../nodetool/InvalidatePermissionsCacheTest.java | 41 +- .../tools/nodetool/InvalidateRolesCacheTest.java | 3 + .../tools/nodetool/ListCIDRGroupTest.java | 6 +- .../tools/nodetool/ReloadCIDRGroupsCacheTest.java | 3 + .../tools/nodetool/SetAuthCacheConfigTest.java | 1 + .../tools/nodetool/TableHistogramsTest.java | 3 +- .../cassandra/tools/nodetool/TableStatsTest.java | 4 +- .../tools/nodetool/UpdateCIDRGroupTest.java | 3 + .../cassandra/tools/nodetool/VerifyTest.java | 1 + .../nodetool/stats/TableStatsPrinterTest.java | 74 +- .../cassandra/transport/CQLConnectionTest.java | 9 +- .../cassandra/triggers/TriggersSchemaTest.java | 8 +- .../apache/cassandra/triggers/TriggersTest.java | 2 +- .../apache/cassandra/utils/FBUtilitiesTest.java | 35 - .../cassandra/utils/RecomputingSupplierTest.java | 157 + .../cassandra/utils/btree/BTreeBiMapGuavaTest.java | 78 - .../cassandra/utils/btree/BTreeBiMapTest.java | 132 - .../cassandra/utils/btree/BTreeMapGuavaTest.java | 128 - .../apache/cassandra/utils/btree/BTreeMapTest.java | 133 - .../cassandra/utils/btree/BTreeMultimapTest.java | 118 - .../cassandra/utils/btree/BTreeSetGuavaTest.java | 121 - .../concurrent/AbstractTransactionalTest.java | 5 +- tools/bin/addtocmstool | 49 - .../io/sstable/StressCQLSSTableWriter.java | 25 +- .../apache/cassandra/stress/CompactionStress.java | 18 +- .../org/apache/cassandra/stress/StressProfile.java | 3 +- 1013 files changed, 22045 insertions(+), 67194 deletions(-) delete mode 100755 ci/harry_simulation.sh delete mode 100644 conf/harry-example.yaml delete mode 100644 src/java/org/apache/cassandra/db/AbstractMutationVerbHandler.java delete mode 100644 src/java/org/apache/cassandra/db/virtual/ClusterMetadataLogTable.java delete mode 100644 src/java/org/apache/cassandra/db/virtual/LocalTable.java delete mode 100644 src/java/org/apache/cassandra/db/virtual/PeersTable.java delete mode 100644 src/java/org/apache/cassandra/dht/OwnedRanges.java delete mode 100644 src/java/org/apache/cassandra/exceptions/InvalidRoutingException.java delete mode 100644 src/java/org/apache/cassandra/gms/NewGossiper.java delete mode 100644 src/java/org/apache/cassandra/locator/CMSPlacementStrategy.java delete mode 100644 src/java/org/apache/cassandra/locator/MetaStrategy.java create mode 100644 src/java/org/apache/cassandra/locator/PendingRangeMaps.java create mode 100644 src/java/org/apache/cassandra/locator/TokenMetadata.java rename src/java/org/apache/cassandra/locator/{SystemStrategy.java => TokenMetadataDiagnostics.java} (52%) create mode 100644 src/java/org/apache/cassandra/locator/TokenMetadataEvent.java delete mode 100644 src/java/org/apache/cassandra/metrics/TCMMetrics.java create mode 100644 src/java/org/apache/cassandra/schema/DefaultSchemaUpdateHandler.java rename src/java/org/apache/cassandra/{tools/nodetool/SealPeriod.java => schema/DefaultSchemaUpdateHandlerFactory.java} (56%) delete mode 100644 src/java/org/apache/cassandra/schema/DistributedMetadataLogKeyspace.java create mode 100644 src/java/org/apache/cassandra/schema/MigrationCoordinator.java create mode 100644 src/java/org/apache/cassandra/schema/OfflineSchemaUpdateHandler.java create mode 100644 src/java/org/apache/cassandra/schema/SchemaUpdateHandler.java rename src/java/org/apache/cassandra/{tcm/listeners/ChangeListener.java => schema/SchemaUpdateHandlerFactory.java} (52%) create mode 100644 src/java/org/apache/cassandra/schema/SchemaUpdateHandlerFactoryProvider.java create mode 100644 src/java/org/apache/cassandra/schema/TableMetadataRefCache.java create mode 100644 src/java/org/apache/cassandra/service/PendingRangeCalculatorService.java create mode 100644 src/java/org/apache/cassandra/service/PendingRangeCalculatorServiceDiagnostics.java create mode 100644 src/java/org/apache/cassandra/service/PendingRangeCalculatorServiceEvent.java create mode 100644 src/java/org/apache/cassandra/service/RangeRelocator.java delete mode 100644 src/java/org/apache/cassandra/service/Rebuild.java delete mode 100644 src/java/org/apache/cassandra/service/paxos/v1/AbstractPaxosVerbHandler.java delete mode 100644 src/java/org/apache/cassandra/streaming/DataMovement.java delete mode 100644 src/java/org/apache/cassandra/streaming/DataMovementVerbHandler.java delete mode 100644 src/java/org/apache/cassandra/streaming/StreamReceivedOutOfTokenRangeException.java delete mode 100644 src/java/org/apache/cassandra/tcm/AbstractLocalProcessor.java delete mode 100644 src/java/org/apache/cassandra/tcm/AtomicLongBackedProcessor.java delete mode 100644 src/java/org/apache/cassandra/tcm/CMSOperations.java delete mode 100644 src/java/org/apache/cassandra/tcm/CMSOperationsMBean.java delete mode 100644 src/java/org/apache/cassandra/tcm/ClusterMetadata.java delete mode 100644 src/java/org/apache/cassandra/tcm/ClusterMetadataService.java delete mode 100644 src/java/org/apache/cassandra/tcm/Commit.java delete mode 100644 src/java/org/apache/cassandra/tcm/CurrentEpochRequestHandler.java delete mode 100644 src/java/org/apache/cassandra/tcm/Discovery.java delete mode 100644 src/java/org/apache/cassandra/tcm/Epoch.java delete mode 100644 src/java/org/apache/cassandra/tcm/EpochAwareDebounce.java delete mode 100644 src/java/org/apache/cassandra/tcm/FetchCMSLog.java delete mode 100644 src/java/org/apache/cassandra/tcm/FetchPeerLog.java delete mode 100644 src/java/org/apache/cassandra/tcm/MetadataKey.java delete mode 100644 src/java/org/apache/cassandra/tcm/MetadataKeys.java delete mode 100644 src/java/org/apache/cassandra/tcm/MetadataSnapshots.java delete mode 100644 src/java/org/apache/cassandra/tcm/MetadataValue.java delete mode 100644 src/java/org/apache/cassandra/tcm/MultiStepOperation.java delete mode 100644 src/java/org/apache/cassandra/tcm/PaxosBackedProcessor.java delete mode 100644 src/java/org/apache/cassandra/tcm/PeerLogFetcher.java delete mode 100644 src/java/org/apache/cassandra/tcm/Period.java delete mode 100644 src/java/org/apache/cassandra/tcm/Processor.java delete mode 100644 src/java/org/apache/cassandra/tcm/RecentlySealedPeriods.java delete mode 100644 src/java/org/apache/cassandra/tcm/RemoteProcessor.java delete mode 100644 src/java/org/apache/cassandra/tcm/Retry.java delete mode 100644 src/java/org/apache/cassandra/tcm/Sealed.java delete mode 100644 src/java/org/apache/cassandra/tcm/Startup.java delete mode 100644 src/java/org/apache/cassandra/tcm/StubClusterMetadataService.java delete mode 100644 src/java/org/apache/cassandra/tcm/TCM_implementation.md delete mode 100644 src/java/org/apache/cassandra/tcm/TransactionalClusterMetadata.md delete mode 100644 src/java/org/apache/cassandra/tcm/Transformation.java delete mode 100644 src/java/org/apache/cassandra/tcm/compatibility/GossipHelper.java delete mode 100644 src/java/org/apache/cassandra/tcm/compatibility/TokenRingUtils.java delete mode 100644 src/java/org/apache/cassandra/tcm/extensions/AbstractExtensionValue.java delete mode 100644 src/java/org/apache/cassandra/tcm/extensions/EpochValue.java delete mode 100644 src/java/org/apache/cassandra/tcm/extensions/ExtensionKey.java delete mode 100644 src/java/org/apache/cassandra/tcm/extensions/ExtensionValue.java delete mode 100644 src/java/org/apache/cassandra/tcm/extensions/IntValue.java delete mode 100644 src/java/org/apache/cassandra/tcm/extensions/StringValue.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/ClientNotificationListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/InitializationListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/LegacyStateListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/LogListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/MetadataSnapshotListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/PlacementsChangeListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/listeners/SchemaListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/log/Entry.java delete mode 100644 src/java/org/apache/cassandra/tcm/log/LocalLog.java delete mode 100644 src/java/org/apache/cassandra/tcm/log/LogState.java delete mode 100644 src/java/org/apache/cassandra/tcm/log/LogStorage.java delete mode 100644 src/java/org/apache/cassandra/tcm/log/Replication.java delete mode 100644 src/java/org/apache/cassandra/tcm/log/SystemKeyspaceStorage.java delete mode 100644 src/java/org/apache/cassandra/tcm/membership/Directory.java delete mode 100644 src/java/org/apache/cassandra/tcm/membership/Location.java delete mode 100644 src/java/org/apache/cassandra/tcm/membership/NodeAddresses.java delete mode 100644 src/java/org/apache/cassandra/tcm/membership/NodeId.java delete mode 100644 src/java/org/apache/cassandra/tcm/membership/NodeState.java delete mode 100644 src/java/org/apache/cassandra/tcm/membership/NodeVersion.java delete mode 100644 src/java/org/apache/cassandra/tcm/migration/ClusterMetadataHolder.java delete mode 100644 src/java/org/apache/cassandra/tcm/migration/Election.java delete mode 100644 src/java/org/apache/cassandra/tcm/migration/GossipCMSListener.java delete mode 100644 src/java/org/apache/cassandra/tcm/migration/GossipProcessor.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/DataPlacement.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/DataPlacements.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/Delta.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/EntireRange.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/MovementMap.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/PlacementDeltas.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/PlacementForRange.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/PlacementProvider.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/PlacementTransitionPlan.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/PrimaryRangeComparator.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/ReplicationMap.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/TokenMap.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/UniformRangePlacement.java delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/VersionedEndpoints.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/AddToCMS.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/BootstrapAndJoin.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/BootstrapAndReplace.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/CancelCMSReconfiguration.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/DataMovements.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/LeaveStreams.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/LockedRanges.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/Move.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/ProgressBarrier.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/ReconfigureCMS.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/RemoveNodeStreams.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/ReplaceSameAddress.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/SequenceState.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/SingleNodeSequences.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/UnbootstrapAndLeave.java delete mode 100644 src/java/org/apache/cassandra/tcm/sequences/UnbootstrapStreams.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/AsymmetricMetadataSerializer.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/MessageSerializers.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/MetadataSerializer.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/PartitionerAwareMetadataSerializer.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/UDTAndFunctionsAwareMetadataSerializer.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/UDTAwareMetadataSerializer.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/VerboseMetadataSerializer.java delete mode 100644 src/java/org/apache/cassandra/tcm/serialization/Version.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/AlterSchema.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/ApplyPlacementDeltas.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/Assassinate.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/CancelInProgressSequence.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/CustomTransformation.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/ForceSnapshot.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/PrepareJoin.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/PrepareLeave.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/PrepareMove.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/PrepareReplace.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/Register.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/SealPeriod.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/Startup.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/Unregister.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/UnsafeJoin.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/AdvanceCMSReconfiguration.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/BaseMembershipTransformation.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/FinishAddToCMS.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/Initialize.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/PreInitialize.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/PrepareCMSReconfiguration.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/RemoveFromCMS.java delete mode 100644 src/java/org/apache/cassandra/tcm/transformations/cms/StartAddToCMS.java delete mode 100644 src/java/org/apache/cassandra/tools/TransformClusterMetadataHelper.java delete mode 100644 src/java/org/apache/cassandra/tools/nodetool/AbortBootstrap.java delete mode 100644 src/java/org/apache/cassandra/tools/nodetool/DescribeCMS.java delete mode 100644 src/java/org/apache/cassandra/tools/nodetool/InitializeCMS.java delete mode 100644 src/java/org/apache/cassandra/tools/nodetool/ReconfigureCMS.java create mode 100644 src/java/org/apache/cassandra/utils/RecomputingSupplier.java delete mode 100644 src/java/org/apache/cassandra/utils/btree/AbstractBTreeMap.java delete mode 100644 src/java/org/apache/cassandra/utils/btree/BTreeBiMap.java delete mode 100644 src/java/org/apache/cassandra/utils/btree/BTreeMap.java delete mode 100644 src/java/org/apache/cassandra/utils/btree/BTreeMultimap.java delete mode 100644 test/data/serialization/5.1/gms.EndpointState.bin delete mode 100644 test/data/serialization/5.1/gms.Gossip.bin delete mode 100644 test/data/serialization/5.1/service.SyncComplete.bin delete mode 100644 test/data/serialization/5.1/service.SyncRequest.bin delete mode 100644 test/data/serialization/5.1/service.ValidationComplete.bin delete mode 100644 test/data/serialization/5.1/service.ValidationRequest.bin delete mode 100644 test/data/serialization/5.1/utils.EstimatedHistogram.bin delete mode 100644 test/distributed/org/apache/cassandra/distributed/fuzz/ConcurrentQuiescentCheckerIntegrationTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/fuzz/InJVMTokenAwareVisitorExecutor.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/harry/ClusterState.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/harry/ExistingClusterSUT.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/harry/FlaggedRunner.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/impl/TestChangeListener.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/CreateTableNonDeterministicTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/MigrationCoordinatorTest.java rename test/distributed/org/apache/cassandra/distributed/test/{ReadRepairEmptyRangeTombstonesTestBase.java => ReadRepairEmptyRangeTombstonesTest.java} (95%) delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/RemoveNodeTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/TransientRangeMovement2Test.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/TransientRangeMovementTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/guardrails/GuardrailBulkLoadEnabledTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/BootWithMetadataTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/BounceGossipTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/BounceIndexRebuildTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/BounceResetHostIdTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/CMSMembershipMetricsTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/CMSTestBase.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ClusterMetadataTestHelper.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ConflictingAddressRestartTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ConsistentLeaveTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ConsistentMoveTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/CoordinatorPathTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/CoordinatorPathTestBase.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/DiscoverCMSTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/DistributedLogTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/FailedLeaveTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/FetchLogFromPeersTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ForceSnapshotTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/FuzzTestBase.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/GossipDeadlockTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/InProgressSequenceCoordinationTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/MetadataChangeSimulationTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ModelChecker.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ModelState.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/OperationalEquivalenceTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/PauseCommitsTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/PlacementSimulator.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/PlacementSimulatorTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/QuorumIntersectionSimulatorTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ReconfigureCMSTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/RegisterTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/RequestCurrentEpochTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/ResumableStartupTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/RngUtils.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/SimulatedOperation.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/SnapshotTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/SystemKeyspaceStorageTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/TestProcessor.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/TriggeredReconfigureCMSTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/AssignSameTokenToMultipleNodesTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/BootstrapResetProgressTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/CMSMembershipTest.java rename test/distributed/org/apache/cassandra/distributed/test/ring/{CleanupDuringRangeMovementTest.java => CleanupFailureTest.java} (53%) delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/ConsistentBootstrapTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/DecommissionTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/PendingWritesTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/RangeVersioningTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/ReadsDuringBootstrapTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/StopProcessingExceptionTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/test/tcm/LogReplicationSmokeTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataSingleNodeUpgradeTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeHarryTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeHintsTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeHostIdTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeIgnoreHostTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeIgnoreHostsTest.java delete mode 100644 test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/util/byterewrite/StatusChangeListener.java create mode 100644 test/microbench/org/apache/cassandra/test/microbench/PendingRangesBench.java rename src/java/org/apache/cassandra/exceptions/CoordinatorBehindException.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnClusterSyncPendingRanges.java (72%) create mode 100644 test/simulator/main/org/apache/cassandra/simulator/cluster/OnClusterUpdateGossip.java create mode 100644 test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java create mode 100644 test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java copy src/java/org/apache/cassandra/streaming/StreamRequestOutOfTokenRangeException.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWithAll.java (54%) rename src/java/org/apache/cassandra/tcm/log/LogReader.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceMarkShutdown.java (68%) rename src/java/org/apache/cassandra/streaming/StreamRequestOutOfTokenRangeException.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSendShutdownToAll.java (61%) copy src/java/org/apache/cassandra/repair/RepairOutOfTokenRangeException.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetBootstrapReplacing.java (60%) rename src/java/org/apache/cassandra/repair/RepairOutOfTokenRangeException.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetBootstrapping.java (67%) rename src/java/org/apache/cassandra/tcm/NotCMSException.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetLeaving.java (69%) rename test/{distributed/org/apache/cassandra/distributed/test/ReadRepairEmptyRangeTombstonesWithFlushesTest.java => simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetLeft.java} (70%) rename test/{distributed/org/apache/cassandra/distributed/shared/PreventSystemExit.java => simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetNormal.java} (58%) rename test/simulator/main/org/apache/cassandra/simulator/cluster/{Quiesce.java => OnInstanceSyncPendingRanges.java} (53%) rename src/java/org/apache/cassandra/tcm/listeners/UpgradeMigrationListener.java => test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSyncSchemaForBootstrap.java (51%) delete mode 100644 test/simulator/main/org/apache/cassandra/simulator/harry/HarryValidatingQuery.java delete mode 100644 test/simulator/test/org/apache/cassandra/simulator/test/AlwaysDeliverNetworkScheduler.java delete mode 100644 test/simulator/test/org/apache/cassandra/simulator/test/FixedLossNetworkScheduler.java delete mode 100644 test/simulator/test/org/apache/cassandra/simulator/test/HarrySimulatorTest.java delete mode 100644 test/simulator/test/org/apache/cassandra/simulator/test/SimulatedVisitExectuor.java delete mode 100644 test/unit/org/apache/cassandra/cql3/AlterSchemaStatementTest.java delete mode 100644 test/unit/org/apache/cassandra/db/CounterMutationVerbHandlerOutOfRangeTest.java delete mode 100644 test/unit/org/apache/cassandra/db/MutationVerbHandlerOutOfRangeTest.java delete mode 100644 test/unit/org/apache/cassandra/db/ReadCommandVerbHandlerOutOfRangeTest.java create mode 100644 test/unit/org/apache/cassandra/gms/ExpireEndpointTest.java delete mode 100644 test/unit/org/apache/cassandra/gms/NewGossiperTest.java create mode 100644 test/unit/org/apache/cassandra/gms/PendingRangeCalculatorServiceTest.java create mode 100644 test/unit/org/apache/cassandra/gms/ShadowRoundTest.java rename test/unit/org/apache/cassandra/locator/{WithPartitioner.java => AbstractReplicationStrategyTest.java} (50%) delete mode 100644 test/unit/org/apache/cassandra/locator/MetaStrategyTest.java create mode 100644 test/unit/org/apache/cassandra/locator/PendingRangeMapsTest.java create mode 100644 test/unit/org/apache/cassandra/locator/ReplicationStrategyEndpointCacheTest.java create mode 100644 test/unit/org/apache/cassandra/locator/TokenMetadataTest.java delete mode 100644 test/unit/org/apache/cassandra/repair/RepairMessageVerbHandlerOutOfRangeTest.java create mode 100644 test/unit/org/apache/cassandra/schema/MigrationCoordinatorTest.java rename test/unit/org/apache/cassandra/schema/{DropKSTest.java => MigrationManagerDropKSTest.java} (99%) rename test/unit/org/apache/cassandra/schema/{SchemaChangesTest.java => MigrationManagerTest.java} (97%) create mode 100644 test/unit/org/apache/cassandra/schema/RemoveWithoutDroppingTest.java delete mode 100644 test/unit/org/apache/cassandra/schema/SchemaChangeDuringRangeMovementTest.java delete mode 100644 test/unit/org/apache/cassandra/schema/TableMetadataSerDeTest.java create mode 100644 test/unit/org/apache/cassandra/service/LeaveAndBootstrapTest.java create mode 100644 test/unit/org/apache/cassandra/service/MoveTest.java create mode 100644 test/unit/org/apache/cassandra/service/MoveTransientTest.java rename test/{distributed/org/apache/cassandra/distributed/test/ReadRepairEmptyRangeTombstonesWithoutFlushesTest.java => unit/org/apache/cassandra/service/StorageServiceAccessor.java} (75%) delete mode 100644 test/unit/org/apache/cassandra/service/paxos/PaxosVerbHandlerOutOfRangeTest.java rename test/unit/org/apache/cassandra/service/snapshot/{MetadataSnapshotsTest.java => SnapshotManagerTest.java} (99%) delete mode 100644 test/unit/org/apache/cassandra/streaming/StreamReaderTest.java delete mode 100644 test/unit/org/apache/cassandra/streaming/StreamSessionOwnedRangesTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/BootWithMetadataTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ClusterMetadataTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ClusterMetadataTransformationTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/DiscoverySimulationTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/LogStateTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/RecentlySealedPeriodsTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/RemoteProcessorTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/compatibility/GossipHelperTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/listeners/ClientNotificationListenerTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/log/DistributedLogStateTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/log/LocalLogTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/log/LocalStorageLogStateTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/log/LogListenerNotificationTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/log/LogStateTestBase.java delete mode 100644 test/unit/org/apache/cassandra/tcm/membership/MembershipUtils.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ownership/DeltaMapTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ownership/OwnershipUtils.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ownership/PrimaryRangeComparatorTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ownership/UniformRangePlacementIntegrationTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/ownership/UniformRangePlacementTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/sequences/InProgressSequenceCancellationTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/sequences/ProgressBarrierTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/sequences/SequencesUtils.java delete mode 100644 test/unit/org/apache/cassandra/tcm/transformations/EventsMetadataTest.java delete mode 100644 test/unit/org/apache/cassandra/tcm/transformations/PrepareLeaveTest.java create mode 100644 test/unit/org/apache/cassandra/utils/RecomputingSupplierTest.java delete mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeBiMapGuavaTest.java delete mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeBiMapTest.java delete mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeMapGuavaTest.java delete mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeMapTest.java delete mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeMultimapTest.java delete mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeSetGuavaTest.java delete mode 100755 tools/bin/addtocmstool --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org