This is an automated email from the ASF dual-hosted git repository.
polandll pushed a change to branch cassandra-5.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 2fc2be54ca Fix the correspondingMessagingVersion of SSTable format and
improve TTL overflow tests coverage
add d24baecac9 Simplify pylib/cqlshlib/helptopics.py using associative
array
add 5a9b79bb83 Merge branch 'cassandra-5.0' into trunk
add ab40d85cd1 Merge branch 'cassandra-5.0' into trunk
add de0a556c5d Merge branch 'cassandra-5.0' into trunk
add d707bb98b4 Merge branch 'cassandra-5.0' into trunk
add 881bb56be7 Merge branch 'cassandra-5.0' into trunk
add b774385b40 Merge branch 'cassandra-5.0' into trunk
add 798edb3edd Merge branch 'cassandra-5.0' into trunk
add 7022d1a5e6 Merge branch 'cassandra-5.0' into trunk
add 5ade7a6cd8 Merge branch 'cassandra-5.0' into trunk
add 8f3c8e721e Merge branch 'cassandra-5.0' into trunk
add 9f2005cd57 Merge branch 'cassandra-5.0' into trunk
add d3a7387836 Merge branch 'cassandra-5.0' into trunk
add 724c616f58 Merge branch 'cassandra-5.0' into trunk
add fb60ee2960 Merge branch 'cassandra-5.0' into trunk
add c834427852 Merge branch 'cassandra-5.0' into trunk
add 8a764dedcd Merge branch 'cassandra-5.0' into trunk
add d058194354 Merge branch 'cassandra-5.0' into trunk
add f713a6618f Merge branch 'cassandra-5.0' into trunk
add 64f553bf97 Merge branch 'cassandra-5.0' into trunk
add 555dec50c2 Merge branch 'cassandra-5.0' into trunk
add 56f351ec2e Merge branch 'cassandra-5.0' into trunk
add 94c3cf74ef Merge branch 'cassandra-5.0' into trunk
add 91d40b2780 Merge branch 'cassandra-5.0' into trunk
add cdeb199f78 Merge branch 'cassandra-5.0' into trunk
add 14f6e7898f Merge branch 'cassandra-5.0' into trunk
add 3884eaf47e Merge branch 'cassandra-5.0' into trunk
add 1e19887f72 Merge branch 'cassandra-5.0' into trunk
add 49e04e8df2 Merge branch 'cassandra-5.0' into trunk
add 119668f2b3 Merge branch 'cassandra-5.0' into trunk
add 02f751077f Merge branch 'cassandra-5.0' into trunk
add f8baabd95a Merge branch 'cassandra-5.0' into trunk
add d6534e5c4f Merge branch 'cassandra-5.0' into trunk
add 825ff89c70 Merge branch 'cassandra-5.0' into trunk
add 2df8875502 Merge branch 'cassandra-5.0' into trunk
add 9c7e1adb1d Merge branch 'cassandra-5.0' into trunk
add 77cf2185b6 Add jmh microbenchmarks to eclipse IDE
add 4226cbbec6 Merge branch 'cassandra-5.0' into trunk
add cbaef9094e Merge branch 'cassandra-5.0' into trunk
add 6fb82b75d5 Merge branch 'cassandra-5.0' into trunk
add 9e90ccc90f Merge branch 'cassandra-5.0' into trunk
add 052a264741 Merge branch 'cassandra-5.0' into trunk
add 269c04474f Merge branch 'cassandra-5.0' into trunk
add b04c2aeddc Merge branch 'cassandra-5.0' into trunk
add 7750a9430b Merge branch 'cassandra-5.0' into trunk
add 70766c7ae9 Merge branch 'cassandra-5.0' into trunk
add 16dc2a2393 Merge branch 'cassandra-5.0' into trunk
add e9b9f9a35f Merge branch 'cassandra-5.0' into trunk
add 4621ec7782 Merge branch 'cassandra-5.0' into trunk
add 999d263a5d Merge branch 'cassandra-5.0' into trunk
add 1f1ec5f503 Merge branch 'cassandra-5.0' into trunk
add 1c3c5008f9 Merge branch 'cassandra-5.0' into trunk
add 5aa7da5ebd Merge branch 'cassandra-5.0' into trunk
add abe09cff34 Clean up obsolete functions and simplify cql_version
handling in cqlsh
add bd7dc322d8 Merge branch 'cassandra-5.0' into trunk
add 9bacdc5bdb Merge branch 'cassandra-5.0' into trunk
add b966f6af11 Merge branch 'cassandra-5.0' into trunk
add df94834b19 Merge branch 'cassandra-5.0' into trunk
add d1a1c439f0 Merge branch 'cassandra-5.0' into trunk
add 7ecac39570 Merge branch 'cassandra-5.0' into trunk
add f8d5a1aa16 Merge branch 'cassandra-5.0' into trunk
add 1ba458c900 Merge branch 'cassandra-5.0' into trunk
add e1ddc34f58 Merge branch 'cassandra-5.0' into trunk
add 2a5e1b77c9 Merge branch 'cassandra-5.0' into trunk
add a67f4904f7 Merge branch 'cassandra-5.0' into trunk
add 759f2b2932 Merge branch 'cassandra-5.0' into trunk
add 1959502d8b Merge branch 'cassandra-5.0' into trunk
add 830f88d4ab Merge branch 'cassandra-5.0' into trunk
add 89065ffa21 Merge branch 'cassandra-5.0' into trunk
add 188df44c8c Merge branch 'cassandra-5.0' into trunk
add f7472774f4 Merge branch 'cassandra-5.0' into trunk
add 1087d88303 Merge branch 'cassandra-5.0' into trunk
add 3ebd09262b Merge branch 'cassandra-5.0' into trunk
add c2a4caa730 Merge branch 'cassandra-5.0' into trunk
add 9f0f1f7c47 Merge branch 'cassandra-5.0' into trunk
add 20d80118ac Add the ability to disable bulk loading of SSTables
add e76b63d081 Merge branch 'cassandra-5.0' into trunk
add e1fc195558 Fix invalid unit test check for CreateTableValidationTest
add 970ec2d1db Merge branch 'cassandra-5.0' into trunk
add c5bb672543 Merge branch 'cassandra-5.0' into trunk
add 9aa2109803 Javadoc BigFormat
add b3879ccb51 Merge branch 'cassandra-5.0' into trunk
add 02cdaf5b92 Merge branch 'cassandra-5.0' into trunk
add 77912be753 Merge branch 'cassandra-5.0' into trunk
add cfe48de019 Merge branch 'cassandra-5.0' into trunk
add 1dd3440ccb Merge branch 'cassandra-5.0' into trunk
add f2f2ef3f23 Merge branch 'cassandra-5.0' into trunk
add e8907eba15 Merge branch 'cassandra-5.0' into trunk
add 32cf1ea33d Add ELAPSED command to cqlsh
add 07fcac4547 Merge branch 'cassandra-5.0' into trunk
add 60314f2d6a Resolve deprecations in pylib
add a0eecdb996 Merge branch 'cassandra-5.0' into trunk
add c96185f188 Merge branch 'cassandra-5.0' into trunk
add d1158bfd8e Merge branch 'cassandra-5.0' into trunk
add fbf6508940 ninja fix for CASSANDRA-18827
add fdbb975188 Merge branch 'cassandra-5.0' into trunk
add 8cc2b48192 Merge branch 'cassandra-5.0' into trunk
add c60b2ca65f Merge branch 'cassandra-5.0' into trunk
add 16b43e4d4b Merge branch 'cassandra-5.0' into trunk
add 210a59b194 Merge branch 'cassandra-5.0' into trunk
add a1de444331 Merge branch 'cassandra-5.0' into trunk
add 90e0ef27e4 Merge branch 'cassandra-5.0' into trunk
add b8f36f0cba Merge branch 'cassandra-5.0' into trunk
add 2e600017ee Merge branch 'cassandra-5.0' into trunk
add 91406a6c73 Merge branch 'cassandra-5.0' into trunk
add 865d7c30e4 Merge branch 'cassandra-5.0' into trunk
add e63d3bfc4b Merge branch 'cassandra-5.0' into trunk
add c40e0778b3 Merge branch 'cassandra-5.0' into trunk
add 4b84c4332c Merge branch 'cassandra-5.0' into trunk
add 31729b8f92 Merge branch 'cassandra-5.0' into trunk
add b8b17dc5db Merge branch 'cassandra-5.0' into trunk
add a0b4cee198 Merge branch 'cassandra-5.0' into trunk
add 91f5562241 Merge branch 'cassandra-5.0' into trunk
add a9a09c1e6b Merge branch 'cassandra-5.0' into trunk
add 302b272b14 Merge branch 'cassandra-5.0' into trunk
add 3d15be1d5e Merge branch 'cassandra-5.0' into trunk
add 2feeb39d5a Merge branch 'cassandra-5.0' into trunk
add 6c18a6c4f4 Merge branch 'cassandra-5.0' into trunk
add 7d3a8d5312 Merge branch 'cassandra-5.0' into trunk
add c2c20ab843 Merge branch 'cassandra-5.0' into trunk
add 088f3ea3e9 Merge branch 'cassandra-5.0' into trunk
add 06202c9ff3 Merge branch 'cassandra-5.0' into trunk
add bf321d7951 Merge branch 'cassandra-5.0' into trunk
add afde441448 Merge branch 'cassandra-5.0' into trunk
add b094303ac2 Merge branch 'cassandra-5.0' into trunk
add 3d022d3c5f Merge branch 'cassandra-5.0' into trunk
add e8c5fe31a2 Merge branch 'cassandra-5.0' into trunk
add 45c6352938 Merge branch 'cassandra-5.0' into trunk
add f5fba9b702 Merge branch 'cassandra-5.0' into trunk
add f8c240147c Merge branch 'cassandra-5.0' into trunk
add a8d0584936 Merge branch 'cassandra-5.0' into trunk
add 70259c50ff Merge branch 'cassandra-5.0' into trunk
add 59eb8ba043 Merge branch 'cassandra-5.0' into trunk
add d6159cfe15 Merge branch 'cassandra-5.0' into trunk
add 4cabe486e1 Merge branch 'cassandra-5.0' into trunk
add b363568c0f Merge branch 'cassandra-5.0' into trunk
add 2d982a0e52 Merge branch 'cassandra-5.0' into trunk
add b9240d0004 Merge branch 'cassandra-5.0' into trunk
add 7377d5501d Merge branch 'cassandra-5.0' into trunk
add bb686fc27d Merge branch 'cassandra-5.0' into trunk
add 53c25f8faa Merge branch 'cassandra-5.0' into trunk
add 5850996ab1 Merge branch 'cassandra-5.0' into trunk
add e5d235dd4d Merge branch 'cassandra-5.0' into trunk
add 537ab03f58 Merge branch 'cassandra-5.0' into trunk
add 10d031bda4 Merge branch 'cassandra-5.0' into trunk
add 37d2ef11d6 Merge branch 'cassandra-5.0' into trunk
add 7b891db36d Merge branch 'cassandra-5.0' into trunk
add 753f81d53a Merge branch 'cassandra-5.0' into trunk
add c62de1b248 Merge branch 'cassandra-5.0' into trunk
add 30e0b55f93 Merge branch 'cassandra-5.0' into trunk
add 0a09c12975 Merge branch 'cassandra-5.0' into trunk
add dc62e1dba1 Merge branch 'cassandra-5.0' into trunk
add c0e0ea1bc6 Merge branch 'cassandra-5.0' into trunk
add c6cb8523b3 Merge branch 'cassandra-5.0' into trunk
add a77951ec0c Merge branch 'cassandra-5.0' into trunk
add 6a3bcc83d2 Merge branch 'cassandra-5.0' into trunk
add 337aa5ce33 Merge branch 'cassandra-5.0' into trunk
add ad66fd6547 Merge branch 'cassandra-5.0' into trunk
add 046b2e8465 Merge branch 'cassandra-5.0' into trunk
add 4f32cdbf7c Merge branch 'cassandra-5.0' into trunk
add ac0347bfa0 Merge branch 'cassandra-5.0' into trunk
add ed5a224283 Merge branch 'cassandra-5.0' into trunk
add 4083166870 Merge branch 'cassandra-5.0' into trunk
add a106f75af5 Merge branch 'cassandra-5.0' into trunk
add 1463fabac3 Merge branch 'cassandra-5.0' into trunk
add 1b7e895f56 Merge branch 'cassandra-5.0' into trunk
add 316a239c7c Merge branch 'cassandra-5.0' into trunk
add 1793c3fd36 Merge branch 'cassandra-5.0' into trunk
add 06dabb8b3a Merge branch 'cassandra-5.0' into trunk
add 360128b3eb Merge branch 'cassandra-5.0' into trunk
add ae0842372f Implementation of Transactional Cluster Metadata as
described in CEP-21
add d464c206e1 Revert bad dtest repo in circleci conf
add 87ce597ad0 Merge branch 'cassandra-5.0' into trunk
add 85b94c561d Merge branch 'cassandra-5.0' into trunk
add 58d2132afc Merge branch 'cassandra-5.0' into trunk
add 31a3ff1768 Test failure: org.apache.cassandra.db.RepairedDataInfoTest
add f6ea362d71 Test failure:
org.apache.cassandra.tools.JMXCompatabilityTest
add db52bef03a Test failure:
org.apache.cassandra.db.CorruptPrimaryIndexTest.bigPrimaryIndexDoesNotDetectDiskCorruption
add 9167d599f3 Test Failure:
org.apache.cassandra.db.compaction.writers.CompactionAwareWriterTest.test*CompactionWriter-trie
add 3b47b5e473 Merge branch 'cassandra-5.0' into trunk
add 008c1b397b Merge branch 'cassandra-5.0' into trunk
add f41ca379dd Merge branch 'cassandra-5.0' into trunk
add 7b7f79253d Merge branch 'cassandra-5.0' into trunk
add de1766a2f8 [CEP-21] Don't log unknown endpoint errors unnecessarily
add 30ed828c87 [CEP-21] Add log message for backwards compatibility
add 97bee6abc1 Merge branch 'cassandra-5.0' into trunk
add d40c9d1abf Merge branch 'cassandra-5.0' into trunk
add 64ae866095 Upgrade jackson to 2.15.3 and snakeyaml to 2.1
add 01d8cbdd1e Merge branch 'cassandra-5.0' into trunk
add cbabfd39b1 Merge branch 'cassandra-5.0' into trunk
add 5f2ff4f932 Merge branch 'cassandra-5.0' into trunk
add da868ab607 Test Failure:
org.apache.cassandra.distributed.upgrade.ClusterMetadataUpgradeTest.upgradeWithHintsTest
add 5613d0a4fe Test failure:
org.apache.cassandra.distributed.test.ring.DecommissionTest.test*Version*
add b45a0e0145 Remove dependency on bundled Harry jar
add ac201d2f04 Make nodetool tablestats use number of significant digits
for time and average values consistently
add 5f0359b229 Fix ConsistentMoveTest: nodes were getting stuck in
assertGossipStatus, since we would log the message, but never change the actual
gossip status.
add 179711eab6 Improve the situation with timeouts of all fuzz tests.
add a98a5a1d9d Reduce time the tests run to avoid timeouts
add e182744cd0 Introduce 5.1 messaging format that brings in Epoch
add f36a518208 Fix test Failure:
MixedModeFrom3LoggedBatchTest.testSimpleStrategy
add 2a807fc81b ninja-fix add addtocmstool tool to bin directory in deb/rpm
packages
add 500b845003 ninja-fix add addtocmstool tool to bin directory in rpm
noboolean package
add 64cdebdb69 Merge branch 'cassandra-5.0' into trunk
add 98fd6fc5a9 Merge branch 'cassandra-5.0' into trunk
add 390d8da961 Merge branch 'cassandra-5.0' into trunk
add bd25c05d52 Test failure:
materialized_views_test.TestMaterializedViewsConsistency.test_multi_partition_consistent_reads_after_write
add 11358bd3a8 Rewrite RegisterTest to verify serialization version ceiling
add f74c07d2d3 Lower the number of tables and repairs to avoid timeouts in
ClearSnapshotTest
add 8cd0690c0b Revert "Upgrade jackson to 2.15.3 and snakeyaml to 2.1"
add d91997cb04 Merge branch 'cassandra-5.0' into trunk
add 7204bc45b6 Revert "Revert "Upgrade jackson to 2.15.3 and snakeyaml to
2.1""
add f4c969adfc Merge branch 'cassandra-5.0' into trunk
add e0766e95bc Fix rejectSubsequentInProgressSequence test: cap message
sizes for commit failures
add 3ed0903131 In in-jvm dtests, don't mark internode messaging as started
until it actually is
add c5a2781b22 Enable bytebuddy rule after starting nodes to fix
DecommissionAvoidWriteTimeoutsTest
add ad86c9d201 Merge branch 'cassandra-5.0' into trunk
add ea1f9e4504 Merge branch 'cassandra-5.0' into trunk
add a75814c8f4 Merge branch 'cassandra-5.0' into trunk
add 8d6d1774e4 Avoid NPEs when initializing CFSs from local keyspaces
before ClusterMetadata is available
add 28630ccbbf Update expected error message which is too specific
add b470117733 Fix potential for unintended address clash in test case
add 1df9148ed1 Fix FetchLogFromPeersTest with vnodes
add 1a46e96890 Don't start MessagingService unnecessarily to speed up
tests and to avoid memory leak
add 8f759e01d5 Merge branch 'cassandra-5.0' into trunk
add c069a0ffb6 Merge branch 'cassandra-5.0' into trunk
add 901786ec27 Avoid race inserting new data in compaction_history during
truncation in SystemKeyspaceMigrator41Test.testMigrateCompactionHistory
add afa86df27d Merge branch 'cassandra-5.0' into trunk
add 85a0b9b5dc Merge branch 'cassandra-5.0' into trunk
add 08c46d0963 Merge branch 'cassandra-5.0' into trunk
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/CoordinatorBehindException.java | 32 +
.../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/SystemStrategy.java | 53 +
.../apache/cassandra/locator/TokenMetadata.java | 1611 ---------
.../locator/TokenMetadataDiagnostics.java | 46 -
.../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 +
.../repair/RepairOutOfTokenRangeException.java | 32 +
.../org/apache/cassandra/repair/RepairSession.java | 2 +-
.../apache/cassandra/schema/ColumnMetadata.java | 61 +
.../schema/DefaultSchemaUpdateHandler.java | 356 --
.../schema/DefaultSchemaUpdateHandlerFactory.java | 36 -
.../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 -
.../schema/SchemaUpdateHandlerFactory.java | 35 -
.../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 | 3784 +++++---------------
.../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 +
.../StreamRequestOutOfTokenRangeException.java | 36 +
.../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 +
.../org/apache/cassandra/tcm/NotCMSException.java | 27 +
.../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 +
.../cassandra/tcm/listeners/ChangeListener.java | 42 +
.../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 +
.../tcm/listeners/UpgradeMigrationListener.java | 39 +
src/java/org/apache/cassandra/tcm/log/Entry.java | 189 +
.../org/apache/cassandra/tcm/log/LocalLog.java | 858 +++++
.../org/apache/cassandra/tcm/log/LogReader.java | 33 +
.../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/SealPeriod.java | 33 +
.../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 -
.../{5.0 => 5.1}/gms.EndpointState.bin | Bin
.../data/serialization/{4.0 => 5.1}/gms.Gossip.bin | Bin
.../{5.0 => 5.1}/service.SyncComplete.bin | Bin
.../{4.0 => 5.1}/service.SyncRequest.bin | Bin
.../{5.0 => 5.1}/service.ValidationComplete.bin | Bin
.../{4.0 => 5.1}/service.ValidationRequest.bin | Bin
.../{4.0 => 5.1}/utils.EstimatedHistogram.bin | Bin
.../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 ++-
.../distributed/shared/PreventSystemExit.java | 44 +
.../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 +-
.../test/ReadRepairEmptyRangeTombstonesTest.java | 288 --
.../ReadRepairEmptyRangeTombstonesTestBase.java | 283 ++
...dRepairEmptyRangeTombstonesWithFlushesTest.java | 28 +
...pairEmptyRangeTombstonesWithoutFlushesTest.java | 28 +
.../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 +
.../test/ring/CleanupDuringRangeMovementTest.java | 145 +
.../distributed/test/ring/CleanupFailureTest.java | 112 -
.../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 | 29 -
.../simulator/cluster/OnClusterUpdateGossip.java | 64 -
.../simulator/cluster/OnInstanceBootstrap.java | 54 -
.../simulator/cluster/OnInstanceGossipWith.java | 50 -
.../simulator/cluster/OnInstanceGossipWithAll.java | 38 -
.../simulator/cluster/OnInstanceMarkShutdown.java | 29 -
.../simulator/cluster/OnInstanceRepair.java | 8 +-
.../cluster/OnInstanceSendShutdownToAll.java | 33 -
.../cluster/OnInstanceSetBootstrapReplacing.java | 31 -
.../cluster/OnInstanceSetBootstrapping.java | 29 -
.../simulator/cluster/OnInstanceSetLeaving.java | 29 -
.../simulator/cluster/OnInstanceSetLeft.java | 29 -
.../simulator/cluster/OnInstanceSetNormal.java | 36 -
.../cluster/OnInstanceSyncPendingRanges.java | 42 -
.../cluster/OnInstanceSyncSchemaForBootstrap.java | 37 -
.../cassandra/simulator/cluster/Quiesce.java | 55 +
.../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 +-
.../locator/AbstractReplicationStrategyTest.java | 45 -
.../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 ---
.../apache/cassandra/locator/WithPartitioner.java | 46 +
.../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 +-
.../org/apache/cassandra/schema/DropKSTest.java | 108 +
.../cassandra/schema/MigrationCoordinatorTest.java | 443 ---
.../schema/MigrationManagerDropKSTest.java | 108 -
.../cassandra/schema/MigrationManagerTest.java | 574 ---
.../org/apache/cassandra/schema/MockSchema.java | 166 +-
.../schema/RemoveWithoutDroppingTest.java | 125 -
.../SchemaChangeDuringRangeMovementTest.java | 254 ++
.../apache/cassandra/schema/SchemaChangesTest.java | 578 +++
.../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 | 29 -
.../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 +-
.../service/snapshot/MetadataSnapshotsTest.java | 224 ++
.../service/snapshot/SnapshotManagerTest.java | 224 --
.../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 +-
1032 files changed, 68797 insertions(+), 23716 deletions(-)
create mode 100755 ci/harry_simulation.sh
create mode 100644 conf/harry-example.yaml
create mode 100644
src/java/org/apache/cassandra/db/AbstractMutationVerbHandler.java
create mode 100644
src/java/org/apache/cassandra/db/virtual/ClusterMetadataLogTable.java
create mode 100644 src/java/org/apache/cassandra/db/virtual/LocalTable.java
create mode 100644 src/java/org/apache/cassandra/db/virtual/PeersTable.java
create mode 100644 src/java/org/apache/cassandra/dht/OwnedRanges.java
create mode 100644
src/java/org/apache/cassandra/exceptions/CoordinatorBehindException.java
create mode 100644
src/java/org/apache/cassandra/exceptions/InvalidRoutingException.java
create mode 100644 src/java/org/apache/cassandra/gms/NewGossiper.java
create mode 100644
src/java/org/apache/cassandra/locator/CMSPlacementStrategy.java
create mode 100644 src/java/org/apache/cassandra/locator/MetaStrategy.java
delete mode 100644 src/java/org/apache/cassandra/locator/PendingRangeMaps.java
create mode 100644 src/java/org/apache/cassandra/locator/SystemStrategy.java
delete mode 100644 src/java/org/apache/cassandra/locator/TokenMetadata.java
delete mode 100644
src/java/org/apache/cassandra/locator/TokenMetadataDiagnostics.java
delete mode 100644
src/java/org/apache/cassandra/locator/TokenMetadataEvent.java
create mode 100644 src/java/org/apache/cassandra/metrics/TCMMetrics.java
create mode 100644
src/java/org/apache/cassandra/repair/RepairOutOfTokenRangeException.java
delete mode 100644
src/java/org/apache/cassandra/schema/DefaultSchemaUpdateHandler.java
delete mode 100644
src/java/org/apache/cassandra/schema/DefaultSchemaUpdateHandlerFactory.java
create mode 100644
src/java/org/apache/cassandra/schema/DistributedMetadataLogKeyspace.java
delete mode 100644
src/java/org/apache/cassandra/schema/MigrationCoordinator.java
delete mode 100644
src/java/org/apache/cassandra/schema/OfflineSchemaUpdateHandler.java
delete mode 100644
src/java/org/apache/cassandra/schema/SchemaUpdateHandler.java
delete mode 100644
src/java/org/apache/cassandra/schema/SchemaUpdateHandlerFactory.java
delete mode 100644
src/java/org/apache/cassandra/schema/SchemaUpdateHandlerFactoryProvider.java
delete mode 100644
src/java/org/apache/cassandra/schema/TableMetadataRefCache.java
delete mode 100644
src/java/org/apache/cassandra/service/PendingRangeCalculatorService.java
delete mode 100644
src/java/org/apache/cassandra/service/PendingRangeCalculatorServiceDiagnostics.java
delete mode 100644
src/java/org/apache/cassandra/service/PendingRangeCalculatorServiceEvent.java
delete mode 100644 src/java/org/apache/cassandra/service/RangeRelocator.java
create mode 100644 src/java/org/apache/cassandra/service/Rebuild.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/v1/AbstractPaxosVerbHandler.java
create mode 100644 src/java/org/apache/cassandra/streaming/DataMovement.java
create mode 100644
src/java/org/apache/cassandra/streaming/DataMovementVerbHandler.java
create mode 100644
src/java/org/apache/cassandra/streaming/StreamReceivedOutOfTokenRangeException.java
create mode 100644
src/java/org/apache/cassandra/streaming/StreamRequestOutOfTokenRangeException.java
create mode 100644
src/java/org/apache/cassandra/tcm/AbstractLocalProcessor.java
create mode 100644
src/java/org/apache/cassandra/tcm/AtomicLongBackedProcessor.java
create mode 100644 src/java/org/apache/cassandra/tcm/CMSOperations.java
create mode 100644 src/java/org/apache/cassandra/tcm/CMSOperationsMBean.java
create mode 100644 src/java/org/apache/cassandra/tcm/ClusterMetadata.java
create mode 100644
src/java/org/apache/cassandra/tcm/ClusterMetadataService.java
create mode 100644 src/java/org/apache/cassandra/tcm/Commit.java
create mode 100644
src/java/org/apache/cassandra/tcm/CurrentEpochRequestHandler.java
create mode 100644 src/java/org/apache/cassandra/tcm/Discovery.java
create mode 100644 src/java/org/apache/cassandra/tcm/Epoch.java
create mode 100644 src/java/org/apache/cassandra/tcm/EpochAwareDebounce.java
create mode 100644 src/java/org/apache/cassandra/tcm/FetchCMSLog.java
create mode 100644 src/java/org/apache/cassandra/tcm/FetchPeerLog.java
create mode 100644 src/java/org/apache/cassandra/tcm/MetadataKey.java
create mode 100644 src/java/org/apache/cassandra/tcm/MetadataKeys.java
create mode 100644 src/java/org/apache/cassandra/tcm/MetadataSnapshots.java
create mode 100644 src/java/org/apache/cassandra/tcm/MetadataValue.java
create mode 100644 src/java/org/apache/cassandra/tcm/MultiStepOperation.java
create mode 100644 src/java/org/apache/cassandra/tcm/NotCMSException.java
create mode 100644 src/java/org/apache/cassandra/tcm/PaxosBackedProcessor.java
create mode 100644 src/java/org/apache/cassandra/tcm/PeerLogFetcher.java
create mode 100644 src/java/org/apache/cassandra/tcm/Period.java
create mode 100644 src/java/org/apache/cassandra/tcm/Processor.java
create mode 100644 src/java/org/apache/cassandra/tcm/RecentlySealedPeriods.java
create mode 100644 src/java/org/apache/cassandra/tcm/RemoteProcessor.java
create mode 100644 src/java/org/apache/cassandra/tcm/Retry.java
create mode 100644 src/java/org/apache/cassandra/tcm/Sealed.java
create mode 100644 src/java/org/apache/cassandra/tcm/Startup.java
create mode 100644
src/java/org/apache/cassandra/tcm/StubClusterMetadataService.java
create mode 100644 src/java/org/apache/cassandra/tcm/TCM_implementation.md
create mode 100644
src/java/org/apache/cassandra/tcm/TransactionalClusterMetadata.md
create mode 100644 src/java/org/apache/cassandra/tcm/Transformation.java
create mode 100644
src/java/org/apache/cassandra/tcm/compatibility/GossipHelper.java
create mode 100644
src/java/org/apache/cassandra/tcm/compatibility/TokenRingUtils.java
create mode 100644
src/java/org/apache/cassandra/tcm/extensions/AbstractExtensionValue.java
create mode 100644 src/java/org/apache/cassandra/tcm/extensions/EpochValue.java
create mode 100644
src/java/org/apache/cassandra/tcm/extensions/ExtensionKey.java
create mode 100644
src/java/org/apache/cassandra/tcm/extensions/ExtensionValue.java
create mode 100644 src/java/org/apache/cassandra/tcm/extensions/IntValue.java
create mode 100644
src/java/org/apache/cassandra/tcm/extensions/StringValue.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/ChangeListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/ClientNotificationListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/InitializationListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/LegacyStateListener.java
create mode 100644 src/java/org/apache/cassandra/tcm/listeners/LogListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/MetadataSnapshotListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/PlacementsChangeListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/SchemaListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/listeners/UpgradeMigrationListener.java
create mode 100644 src/java/org/apache/cassandra/tcm/log/Entry.java
create mode 100644 src/java/org/apache/cassandra/tcm/log/LocalLog.java
create mode 100644 src/java/org/apache/cassandra/tcm/log/LogReader.java
create mode 100644 src/java/org/apache/cassandra/tcm/log/LogState.java
create mode 100644 src/java/org/apache/cassandra/tcm/log/LogStorage.java
create mode 100644 src/java/org/apache/cassandra/tcm/log/Replication.java
create mode 100644
src/java/org/apache/cassandra/tcm/log/SystemKeyspaceStorage.java
create mode 100644 src/java/org/apache/cassandra/tcm/membership/Directory.java
create mode 100644 src/java/org/apache/cassandra/tcm/membership/Location.java
create mode 100644
src/java/org/apache/cassandra/tcm/membership/NodeAddresses.java
create mode 100644 src/java/org/apache/cassandra/tcm/membership/NodeId.java
create mode 100644 src/java/org/apache/cassandra/tcm/membership/NodeState.java
create mode 100644
src/java/org/apache/cassandra/tcm/membership/NodeVersion.java
create mode 100644
src/java/org/apache/cassandra/tcm/migration/ClusterMetadataHolder.java
create mode 100644 src/java/org/apache/cassandra/tcm/migration/Election.java
create mode 100644
src/java/org/apache/cassandra/tcm/migration/GossipCMSListener.java
create mode 100644
src/java/org/apache/cassandra/tcm/migration/GossipProcessor.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/DataPlacement.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/DataPlacements.java
create mode 100644 src/java/org/apache/cassandra/tcm/ownership/Delta.java
create mode 100644 src/java/org/apache/cassandra/tcm/ownership/EntireRange.java
create mode 100644 src/java/org/apache/cassandra/tcm/ownership/MovementMap.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/PlacementDeltas.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/PlacementForRange.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/PlacementProvider.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/PlacementTransitionPlan.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/PrimaryRangeComparator.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/ReplicationMap.java
create mode 100644 src/java/org/apache/cassandra/tcm/ownership/TokenMap.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/UniformRangePlacement.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/VersionedEndpoints.java
create mode 100644 src/java/org/apache/cassandra/tcm/sequences/AddToCMS.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/BootstrapAndJoin.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/BootstrapAndReplace.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/CancelCMSReconfiguration.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/DataMovements.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/LeaveStreams.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/LockedRanges.java
create mode 100644 src/java/org/apache/cassandra/tcm/sequences/Move.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/ProgressBarrier.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/ReconfigureCMS.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/RemoveNodeStreams.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/ReplaceSameAddress.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/SequenceState.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/SingleNodeSequences.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/UnbootstrapAndLeave.java
create mode 100644
src/java/org/apache/cassandra/tcm/sequences/UnbootstrapStreams.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/AsymmetricMetadataSerializer.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/MessageSerializers.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/MetadataSerializer.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/PartitionerAwareMetadataSerializer.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/UDTAndFunctionsAwareMetadataSerializer.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/UDTAwareMetadataSerializer.java
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/VerboseMetadataSerializer.java
create mode 100644 src/java/org/apache/cassandra/tcm/serialization/Version.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/AlterSchema.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/ApplyPlacementDeltas.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/Assassinate.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/CancelInProgressSequence.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/CustomTransformation.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/ForceSnapshot.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/PrepareJoin.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/PrepareLeave.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/PrepareMove.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/PrepareReplace.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/Register.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/SealPeriod.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/Startup.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/Unregister.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/UnsafeJoin.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/AdvanceCMSReconfiguration.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/BaseMembershipTransformation.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/FinishAddToCMS.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/Initialize.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/PreInitialize.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/PrepareCMSReconfiguration.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/RemoveFromCMS.java
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/cms/StartAddToCMS.java
create mode 100644
src/java/org/apache/cassandra/tools/TransformClusterMetadataHelper.java
create mode 100644
src/java/org/apache/cassandra/tools/nodetool/AbortBootstrap.java
create mode 100644
src/java/org/apache/cassandra/tools/nodetool/DescribeCMS.java
create mode 100644
src/java/org/apache/cassandra/tools/nodetool/InitializeCMS.java
create mode 100644
src/java/org/apache/cassandra/tools/nodetool/ReconfigureCMS.java
create mode 100644 src/java/org/apache/cassandra/tools/nodetool/SealPeriod.java
delete mode 100644 src/java/org/apache/cassandra/utils/RecomputingSupplier.java
create mode 100644
src/java/org/apache/cassandra/utils/btree/AbstractBTreeMap.java
create mode 100644 src/java/org/apache/cassandra/utils/btree/BTreeBiMap.java
create mode 100644 src/java/org/apache/cassandra/utils/btree/BTreeMap.java
create mode 100644 src/java/org/apache/cassandra/utils/btree/BTreeMultimap.java
copy test/data/serialization/{5.0 => 5.1}/gms.EndpointState.bin (100%)
copy test/data/serialization/{4.0 => 5.1}/gms.Gossip.bin (100%)
copy test/data/serialization/{5.0 => 5.1}/service.SyncComplete.bin (100%)
copy test/data/serialization/{4.0 => 5.1}/service.SyncRequest.bin (100%)
copy test/data/serialization/{5.0 => 5.1}/service.ValidationComplete.bin (100%)
copy test/data/serialization/{4.0 => 5.1}/service.ValidationRequest.bin (100%)
copy test/data/serialization/{4.0 => 5.1}/utils.EstimatedHistogram.bin (100%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/fuzz/ConcurrentQuiescentCheckerIntegrationTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/fuzz/InJVMTokenAwareVisitorExecutor.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/harry/ClusterState.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/harry/ExistingClusterSUT.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/harry/FlaggedRunner.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/impl/TestChangeListener.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/shared/PreventSystemExit.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/CreateTableNonDeterministicTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/MigrationCoordinatorTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/ReadRepairEmptyRangeTombstonesTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ReadRepairEmptyRangeTombstonesTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ReadRepairEmptyRangeTombstonesWithFlushesTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ReadRepairEmptyRangeTombstonesWithoutFlushesTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/RemoveNodeTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/TransientRangeMovement2Test.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/TransientRangeMovementTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/guardrails/GuardrailBulkLoadEnabledTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/BootWithMetadataTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/BounceGossipTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/BounceIndexRebuildTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/BounceResetHostIdTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/CMSMembershipMetricsTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/CMSTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ClusterMetadataTestHelper.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ConflictingAddressRestartTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ConsistentLeaveTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ConsistentMoveTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/CoordinatorPathTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/CoordinatorPathTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/DiscoverCMSTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/DistributedLogTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/FailedLeaveTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/FetchLogFromPeersTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ForceSnapshotTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/FuzzTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/GossipDeadlockTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/InProgressSequenceCoordinationTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/MetadataChangeSimulationTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ModelChecker.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ModelState.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/OperationalEquivalenceTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/PauseCommitsTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/PlacementSimulator.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/PlacementSimulatorTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/QuorumIntersectionSimulatorTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ReconfigureCMSTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/RegisterTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/RequestCurrentEpochTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/ResumableStartupTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/RngUtils.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/SimulatedOperation.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/SnapshotTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/SystemKeyspaceStorageTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/TestProcessor.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/TriggeredReconfigureCMSTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/AssignSameTokenToMultipleNodesTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/BootstrapResetProgressTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/CMSMembershipTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/CleanupDuringRangeMovementTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/CleanupFailureTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/ConsistentBootstrapTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/DecommissionTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/PendingWritesTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/RangeVersioningTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/ReadsDuringBootstrapTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/StopProcessingExceptionTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/tcm/LogReplicationSmokeTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataSingleNodeUpgradeTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeHarryTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeHintsTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeHostIdTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeIgnoreHostTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeIgnoreHostsTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/upgrade/ClusterMetadataUpgradeTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/util/byterewrite/StatusChangeListener.java
delete mode 100644
test/microbench/org/apache/cassandra/test/microbench/PendingRangesBench.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnClusterSyncPendingRanges.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnClusterUpdateGossip.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWithAll.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceMarkShutdown.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSendShutdownToAll.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetBootstrapReplacing.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetBootstrapping.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetLeaving.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetLeft.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSetNormal.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSyncPendingRanges.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceSyncSchemaForBootstrap.java
create mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/Quiesce.java
create mode 100644
test/simulator/main/org/apache/cassandra/simulator/harry/HarryValidatingQuery.java
create mode 100644
test/simulator/test/org/apache/cassandra/simulator/test/AlwaysDeliverNetworkScheduler.java
create mode 100644
test/simulator/test/org/apache/cassandra/simulator/test/FixedLossNetworkScheduler.java
create mode 100644
test/simulator/test/org/apache/cassandra/simulator/test/HarrySimulatorTest.java
create mode 100644
test/simulator/test/org/apache/cassandra/simulator/test/SimulatedVisitExectuor.java
create mode 100644
test/unit/org/apache/cassandra/cql3/AlterSchemaStatementTest.java
create mode 100644
test/unit/org/apache/cassandra/db/CounterMutationVerbHandlerOutOfRangeTest.java
create mode 100644
test/unit/org/apache/cassandra/db/MutationVerbHandlerOutOfRangeTest.java
create mode 100644
test/unit/org/apache/cassandra/db/ReadCommandVerbHandlerOutOfRangeTest.java
delete mode 100644 test/unit/org/apache/cassandra/gms/ExpireEndpointTest.java
create mode 100644 test/unit/org/apache/cassandra/gms/NewGossiperTest.java
delete mode 100644
test/unit/org/apache/cassandra/gms/PendingRangeCalculatorServiceTest.java
delete mode 100644 test/unit/org/apache/cassandra/gms/ShadowRoundTest.java
delete mode 100644
test/unit/org/apache/cassandra/locator/AbstractReplicationStrategyTest.java
create mode 100644 test/unit/org/apache/cassandra/locator/MetaStrategyTest.java
delete mode 100644
test/unit/org/apache/cassandra/locator/PendingRangeMapsTest.java
delete mode 100644
test/unit/org/apache/cassandra/locator/ReplicationStrategyEndpointCacheTest.java
delete mode 100644
test/unit/org/apache/cassandra/locator/TokenMetadataTest.java
create mode 100644 test/unit/org/apache/cassandra/locator/WithPartitioner.java
create mode 100644
test/unit/org/apache/cassandra/repair/RepairMessageVerbHandlerOutOfRangeTest.java
create mode 100644 test/unit/org/apache/cassandra/schema/DropKSTest.java
delete mode 100644
test/unit/org/apache/cassandra/schema/MigrationCoordinatorTest.java
delete mode 100644
test/unit/org/apache/cassandra/schema/MigrationManagerDropKSTest.java
delete mode 100644
test/unit/org/apache/cassandra/schema/MigrationManagerTest.java
delete mode 100644
test/unit/org/apache/cassandra/schema/RemoveWithoutDroppingTest.java
create mode 100644
test/unit/org/apache/cassandra/schema/SchemaChangeDuringRangeMovementTest.java
create mode 100644 test/unit/org/apache/cassandra/schema/SchemaChangesTest.java
create mode 100644
test/unit/org/apache/cassandra/schema/TableMetadataSerDeTest.java
delete mode 100644
test/unit/org/apache/cassandra/service/LeaveAndBootstrapTest.java
delete mode 100644 test/unit/org/apache/cassandra/service/MoveTest.java
delete mode 100644
test/unit/org/apache/cassandra/service/MoveTransientTest.java
delete mode 100644
test/unit/org/apache/cassandra/service/StorageServiceAccessor.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/PaxosVerbHandlerOutOfRangeTest.java
create mode 100644
test/unit/org/apache/cassandra/service/snapshot/MetadataSnapshotsTest.java
delete mode 100644
test/unit/org/apache/cassandra/service/snapshot/SnapshotManagerTest.java
create mode 100644
test/unit/org/apache/cassandra/streaming/StreamReaderTest.java
create mode 100644
test/unit/org/apache/cassandra/streaming/StreamSessionOwnedRangesTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/BootWithMetadataTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/ClusterMetadataTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ClusterMetadataTransformationTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/DiscoverySimulationTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/LogStateTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/RecentlySealedPeriodsTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/RemoteProcessorTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/compatibility/GossipHelperTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/listeners/ClientNotificationListenerTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/log/DistributedLogStateTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/log/LocalLogTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/log/LocalStorageLogStateTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/log/LogListenerNotificationTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/log/LogStateTestBase.java
create mode 100644
test/unit/org/apache/cassandra/tcm/membership/MembershipUtils.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ownership/DeltaMapTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ownership/OwnershipUtils.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ownership/PrimaryRangeComparatorTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ownership/UniformRangePlacementIntegrationTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ownership/UniformRangePlacementTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/sequences/InProgressSequenceCancellationTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/sequences/ProgressBarrierTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/sequences/SequencesUtils.java
create mode 100644
test/unit/org/apache/cassandra/tcm/transformations/EventsMetadataTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/transformations/PrepareLeaveTest.java
delete mode 100644
test/unit/org/apache/cassandra/utils/RecomputingSupplierTest.java
create mode 100644
test/unit/org/apache/cassandra/utils/btree/BTreeBiMapGuavaTest.java
create mode 100644
test/unit/org/apache/cassandra/utils/btree/BTreeBiMapTest.java
create mode 100644
test/unit/org/apache/cassandra/utils/btree/BTreeMapGuavaTest.java
create mode 100644 test/unit/org/apache/cassandra/utils/btree/BTreeMapTest.java
create mode 100644
test/unit/org/apache/cassandra/utils/btree/BTreeMultimapTest.java
create mode 100644
test/unit/org/apache/cassandra/utils/btree/BTreeSetGuavaTest.java
create mode 100755 tools/bin/addtocmstool
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
