This is an automated email from the ASF dual-hosted git repository.
benedict pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git.
from eb960b1 Merge branch 'cassandra-4.0' into trunk
new 5a0d615 [CASSANDRA-17176] Introduce TimeUUID
new 8960b4d [CASSANDRA-17177] List Appends Are Not Linearizable
new d292327 CEP-14: Paxos Improvements
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.build/build-rat.xml | 1 +
.circleci/config.yml | 6 +-
.circleci/config.yml.HIGHRES | 6 +-
.circleci/config.yml.LOWRES | 6 +-
.circleci/config.yml.MIDRES | 6 +-
NEWS.txt | 24 +
build.xml | 44 +-
.../apache/cassandra/auth/FunctionResource.java | 2 +-
src/java/org/apache/cassandra/batchlog/Batch.java | 16 +-
.../cassandra/batchlog/BatchRemoveVerbHandler.java | 7 +-
.../apache/cassandra/batchlog/BatchlogManager.java | 36 +-
.../apache/cassandra/cache/AutoSavingCache.java | 5 +-
.../cassandra/concurrent/ExecutorFactory.java | 26 +-
.../apache/cassandra/concurrent/FutureTask.java | 4 +-
.../cassandra/concurrent/InfiniteLoopExecutor.java | 73 +-
.../org/apache/cassandra/concurrent/Stage.java | 14 +-
.../cassandra/concurrent/SyncFutureTask.java | 3 +-
.../config/CassandraRelevantProperties.java | 15 +-
src/java/org/apache/cassandra/config/Config.java | 202 +++-
.../apache/cassandra/config/DataStorageSpec.java | 2 +-
.../cassandra/config/DatabaseDescriptor.java | 199 +++-
.../org/apache/cassandra/config/DurationSpec.java | 4 +-
.../apache/cassandra/config/EncryptionOptions.java | 17 +-
src/java/org/apache/cassandra/cql3/CQL3Type.java | 6 +
src/java/org/apache/cassandra/cql3/Lists.java | 7 +-
.../org/apache/cassandra/cql3/QueryOptions.java | 16 +
.../org/apache/cassandra/cql3/QueryProcessor.java | 40 +-
src/java/org/apache/cassandra/cql3/Sets.java | 2 +-
.../apache/cassandra/cql3/UntypedResultSet.java | 18 +
.../apache/cassandra/cql3/UpdateParameters.java | 6 +
.../cassandra/cql3/functions/AggregateFcts.java | 28 +-
.../cql3/functions/BytesConversionFcts.java | 16 +-
.../cassandra/cql3/functions/FunctionCall.java | 4 +-
.../cassandra/cql3/functions/FunctionResolver.java | 5 +-
.../apache/cassandra/cql3/functions/TimeFcts.java | 16 +-
.../cassandra/cql3/statements/CQL3CasRequest.java | 50 +-
.../cql3/statements/ModificationStatement.java | 12 +-
.../cassandra/cql3/statements/SelectStatement.java | 50 +-
.../schema/CreateAggregateStatement.java | 4 +-
.../statements/schema/CreateFunctionStatement.java | 6 +-
.../statements/schema/DropAggregateStatement.java | 2 +-
.../statements/schema/DropFunctionStatement.java | 2 +-
.../org/apache/cassandra/db/ColumnFamilyStore.java | 84 +-
.../org/apache/cassandra/db/ConsistencyLevel.java | 6 +-
.../org/apache/cassandra/db/CounterMutation.java | 7 +
src/java/org/apache/cassandra/db/IMutation.java | 2 +
src/java/org/apache/cassandra/db/Keyspace.java | 5 +
src/java/org/apache/cassandra/db/Mutation.java | 25 +-
.../apache/cassandra/db/MutationVerbHandler.java | 16 +-
.../cassandra/db/PartitionRangeReadCommand.java | 4 +-
src/java/org/apache/cassandra/db/ReadCommand.java | 3 +-
src/java/org/apache/cassandra/db/ReadQuery.java | 8 +-
src/java/org/apache/cassandra/db/ReadResponse.java | 12 +
.../org/apache/cassandra/db/SimpleBuilders.java | 5 +-
.../cassandra/db/SinglePartitionReadCommand.java | 17 +-
.../org/apache/cassandra/db/SystemKeyspace.java | 242 +++-
.../cassandra/db/SystemKeyspaceMigrator40.java | 3 +-
.../cassandra/db/commitlog/CommitLogReplayer.java | 1 -
.../db/compaction/AbstractCompactionStrategy.java | 4 +-
.../db/compaction/AbstractCompactionTask.java | 4 +-
.../db/compaction/AbstractStrategyHolder.java | 4 +-
.../cassandra/db/compaction/CompactionInfo.java | 12 +-
.../compaction/CompactionInterruptedException.java | 10 +-
.../db/compaction/CompactionIterator.java | 103 +-
.../cassandra/db/compaction/CompactionManager.java | 29 +-
.../db/compaction/CompactionStrategyHolder.java | 4 +-
.../db/compaction/CompactionStrategyManager.java | 16 +-
.../cassandra/db/compaction/CompactionTask.java | 8 +-
.../db/compaction/PendingRepairHolder.java | 8 +-
.../db/compaction/PendingRepairManager.java | 86 +-
.../apache/cassandra/db/compaction/Scrubber.java | 6 +-
.../apache/cassandra/db/compaction/Upgrader.java | 5 +-
.../apache/cassandra/db/compaction/Verifier.java | 8 +-
.../compaction/writers/CompactionAwareWriter.java | 4 +-
.../db/lifecycle/LifecycleTransaction.java | 3 +-
.../org/apache/cassandra/db/lifecycle/LogFile.java | 11 +-
.../cassandra/db/lifecycle/LogTransaction.java | 6 +-
...TimeUUIDType.java => AbstractTimeUUIDType.java} | 37 +-
.../apache/cassandra/db/marshal/AbstractType.java | 10 +
.../cassandra/db/marshal/ByteArrayAccessor.java | 14 +
.../cassandra/db/marshal/ByteBufferAccessor.java | 14 +
.../marshal/LegacyTimeUUIDType.java} | 15 +-
.../org/apache/cassandra/db/marshal/ListType.java | 3 +-
.../apache/cassandra/db/marshal/TimeUUIDType.java | 135 +--
.../org/apache/cassandra/db/marshal/TupleType.java | 14 +-
.../apache/cassandra/db/marshal/ValueAccessor.java | 8 +
.../db/partitions/AbstractBTreePartition.java | 44 +-
.../cassandra/db/partitions/PartitionUpdate.java | 49 +-
.../db/repair/CassandraKeyspaceRepairManager.java | 3 +-
.../db/repair/CassandraTableRepairManager.java | 6 +-
.../db/repair/CassandraValidationIterator.java | 11 +-
.../cassandra/db/repair/PendingAntiCompaction.java | 26 +-
.../org/apache/cassandra/db/rows/AbstractCell.java | 5 +
.../org/apache/cassandra/db/rows/BTreeRow.java | 12 +
.../org/apache/cassandra/db/rows/BufferCell.java | 9 -
src/java/org/apache/cassandra/db/rows/Cell.java | 4 +
.../org/apache/cassandra/db/rows/CellPath.java | 2 +
.../org/apache/cassandra/db/rows/ColumnData.java | 3 +
.../cassandra/db/rows/ComplexColumnData.java | 13 +-
.../org/apache/cassandra/db/rows/NativeCell.java | 1 -
src/java/org/apache/cassandra/db/rows/Row.java | 8 +-
.../db/rows/UnfilteredRowIteratorSerializer.java | 2 +-
.../db/streaming/CassandraOutgoingFile.java | 4 +-
.../db/streaming/CassandraStreamManager.java | 4 +-
.../db/streaming/CassandraStreamReader.java | 6 +-
.../apache/cassandra/db/view/ViewBuilderTask.java | 8 +-
.../org/apache/cassandra/db/view/ViewUtils.java | 1 -
.../cassandra/db/virtual/SSTableTasksTable.java | 4 +-
.../apache/cassandra/db/virtual/SimpleDataSet.java | 5 +-
.../db/virtual/StreamingVirtualTable.java | 6 +-
.../cassandra/db/virtual/VirtualMutation.java | 8 +
.../apache/cassandra/dht/Murmur3Partitioner.java | 11 +-
src/java/org/apache/cassandra/dht/Range.java | 2 +-
.../exceptions/CasWriteTimeoutException.java | 3 +-
.../exceptions/RequestFailureException.java | 2 +-
.../cassandra/exceptions/RequestFailureReason.java | 5 +-
.../org/apache/cassandra/gms/EndpointState.java | 18 +-
.../org/apache/cassandra/gms/GossipDigestAck2.java | 5 -
.../cassandra/gms/GossipDigestAck2VerbHandler.java | 2 +-
src/java/org/apache/cassandra/gms/Gossiper.java | 15 +-
.../org/apache/cassandra/gms/VersionedValue.java | 8 +
.../cassandra/hadoop/cql3/CqlInputFormat.java | 2 +-
src/java/org/apache/cassandra/index/Index.java | 22 +-
.../cassandra/index/SecondaryIndexManager.java | 59 +-
.../index/internal/CollatedViewIndexBuilder.java | 9 +-
.../cassandra/index/sasi/SASIIndexBuilder.java | 6 +-
.../apache/cassandra/io/FSDiskFullWriteError.java | 6 -
src/java/org/apache/cassandra/io/FSError.java | 21 +-
.../io/FSNoDiskAvailableForWriteError.java | 6 -
src/java/org/apache/cassandra/io/FSReadError.java | 20 +-
src/java/org/apache/cassandra/io/FSWriteError.java | 20 +-
.../cassandra/io/sstable/CQLSSTableWriter.java | 2 +-
.../apache/cassandra/io/sstable/Descriptor.java | 4 +-
.../cassandra/io/sstable/IndexSummaryManager.java | 7 +-
.../io/sstable/IndexSummaryRedistribution.java | 7 +-
.../org/apache/cassandra/io/sstable/SSTable.java | 3 +-
.../cassandra/io/sstable/SSTableTxnWriter.java | 10 +-
.../io/sstable/SimpleSSTableMultiWriter.java | 4 +-
.../io/sstable/format/RangeAwareSSTableWriter.java | 6 +-
.../cassandra/io/sstable/format/SSTableReader.java | 5 +-
.../cassandra/io/sstable/format/SSTableWriter.java | 15 +-
.../cassandra/io/sstable/format/big/BigFormat.java | 4 +-
.../io/sstable/format/big/BigTableWriter.java | 4 +-
.../io/sstable/metadata/IMetadataSerializer.java | 4 +-
.../io/sstable/metadata/MetadataCollector.java | 3 +-
.../io/sstable/metadata/MetadataSerializer.java | 3 +-
.../io/sstable/metadata/StatsMetadata.java | 17 +-
.../io/util/ChecksummedSequentialWriter.java | 2 -
src/java/org/apache/cassandra/io/util/File.java | 183 ++-
.../org/apache/cassandra/io/util/PathUtils.java | 40 +-
.../cassandra/io/util/SequentialWriterOption.java | 1 +
.../locator/AbstractReplicaCollection.java | 133 ++-
.../locator/AbstractReplicationStrategy.java | 18 +-
.../org/apache/cassandra/locator/Endpoints.java | 24 +-
.../cassandra/locator/EndpointsForToken.java | 39 +
.../locator/{InOurDcTester.java => InOurDc.java} | 31 +-
.../cassandra/locator/ReplicaCollection.java | 12 +-
.../apache/cassandra/locator/ReplicaLayout.java | 12 +-
.../org/apache/cassandra/locator/ReplicaPlan.java | 171 +--
.../org/apache/cassandra/locator/ReplicaPlans.java | 36 +-
.../org/apache/cassandra/locator/Replicas.java | 2 +-
.../apache/cassandra/locator/TokenMetadata.java | 2 +-
.../metrics/ClientRequestsMetricsHolder.java | 4 +-
.../DecayingEstimatedHistogramReservoir.java | 51 +-
.../cassandra/metrics/HintedHandoffMetrics.java | 5 +-
.../PaxosMetrics.java} | 19 +-
src/java/org/apache/cassandra/net/Message.java | 39 +-
.../org/apache/cassandra/net/MessagingService.java | 18 +
.../apache/cassandra/net/OutboundMessageQueue.java | 1 -
src/java/org/apache/cassandra/net/ParamType.java | 3 +-
.../org/apache/cassandra/net/RequestCallback.java | 7 +
.../cassandra/net/RequestCallbackWithFailure.java | 24 +-
.../org/apache/cassandra/net/RequestCallbacks.java | 22 +-
src/java/org/apache/cassandra/net/Verb.java | 47 +-
.../cassandra/repair/AbstractRepairTask.java | 8 +-
.../cassandra/repair/IncrementalRepairTask.java | 5 +-
.../cassandra/repair/KeyspaceRepairManager.java | 4 +-
.../org/apache/cassandra/repair/LocalSyncTask.java | 6 +-
.../repair/NoSuchRepairSessionException.java | 4 +-
.../apache/cassandra/repair/NormalRepairTask.java | 6 +-
.../apache/cassandra/repair/PreviewRepairTask.java | 7 +-
.../org/apache/cassandra/repair/RepairJob.java | 75 +-
.../org/apache/cassandra/repair/RepairJobDesc.java | 23 +-
.../cassandra/repair/RepairMessageVerbHandler.java | 5 +-
.../apache/cassandra/repair/RepairRunnable.java | 21 +-
.../org/apache/cassandra/repair/RepairSession.java | 26 +-
.../cassandra/repair/RepairSessionResult.java | 6 +-
.../cassandra/repair/StreamingRepairTask.java | 6 +-
.../cassandra/repair/TableRepairManager.java | 6 +-
.../repair/consistent/ConsistentSession.java | 9 +-
.../repair/consistent/CoordinatorSessions.java | 8 +-
.../cassandra/repair/consistent/LocalSessions.java | 65 +-
.../repair/consistent/admin/CleanupSummary.java | 24 +-
.../repair/consistent/admin/PendingStat.java | 16 +-
.../cassandra/repair/messages/CleanupMessage.java | 13 +-
.../cassandra/repair/messages/FailSession.java | 13 +-
.../cassandra/repair/messages/FinalizeCommit.java | 13 +-
.../cassandra/repair/messages/FinalizePromise.java | 13 +-
.../cassandra/repair/messages/FinalizePropose.java | 13 +-
.../repair/messages/PrepareConsistentRequest.java | 13 +-
.../repair/messages/PrepareConsistentResponse.java | 13 +-
.../cassandra/repair/messages/PrepareMessage.java | 13 +-
.../cassandra/repair/messages/RepairOption.java | 33 +-
.../cassandra/repair/messages/StatusRequest.java | 13 +-
.../cassandra/repair/messages/StatusResponse.java | 13 +-
.../cassandra/schema/MigrationCoordinator.java | 3 +
.../apache/cassandra/schema/SchemaKeyspace.java | 10 +-
.../schema/SystemDistributedKeyspace.java | 15 +-
src/java/org/apache/cassandra/schema/TableId.java | 7 +-
.../DisableSslContextFactory.java} | 33 +-
.../cassandra/serializers/TimeUUIDSerializer.java | 38 -
.../service/AbstractWriteResponseHandler.java | 25 +-
.../cassandra/service/ActiveRepairService.java | 128 +-
.../service/ActiveRepairServiceMBean.java | 2 +
.../cassandra/service/BatchlogResponseHandler.java | 2 +-
.../org/apache/cassandra/service/CASRequest.java | 7 +-
.../apache/cassandra/service/CassandraDaemon.java | 13 +
.../org/apache/cassandra/service/ClientState.java | 19 +-
.../DatacenterSyncWriteResponseHandler.java | 7 +-
.../service/DatacenterWriteResponseHandler.java | 11 +-
.../service/FailureRecordingCallback.java | 153 +++
.../service/PendingRangeCalculatorService.java | 6 +
.../org/apache/cassandra/service/StorageProxy.java | 193 +--
.../cassandra/service/StorageProxyMBean.java | 6 +
.../apache/cassandra/service/StorageService.java | 326 ++++-
.../cassandra/service/StorageServiceMBean.java | 42 +
.../cassandra/service/WriteResponseHandler.java | 11 +-
.../service/paxos/AbstractPaxosRepair.java | 290 +++++
.../org/apache/cassandra/service/paxos/Ballot.java | 151 +++
.../cassandra/service/paxos/BallotGenerator.java | 44 +-
.../org/apache/cassandra/service/paxos/Commit.java | 400 ++++++-
.../cassandra/service/paxos/CommitVerbHandler.java | 39 -
.../service/paxos/ContentionStrategy.java | 651 ++++++++++
.../org/apache/cassandra/service/paxos/Paxos.java | 1195 ++++++++++++++++++-
.../org/apache/cassandra/service/paxos/Paxos.md | 345 ++++++
.../cassandra/service/paxos/PaxosCommit.java | 325 +++++
.../service/paxos/PaxosCommitAndPrepare.java | 145 +++
.../paxos/PaxosOperationLock.java} | 12 +-
.../cassandra/service/paxos/PaxosPrepare.java | 1253 ++++++++++++++++++++
.../service/paxos/PaxosPrepareRefresh.java | 245 ++++
.../cassandra/service/paxos/PaxosPropose.java | 479 ++++++++
.../cassandra/service/paxos/PaxosRepair.java | 706 +++++++++++
.../service/paxos/PaxosRepairHistory.java | 480 ++++++++
.../service/paxos/PaxosRequestCallback.java | 76 ++
.../apache/cassandra/service/paxos/PaxosState.java | 813 +++++++++++--
.../service/paxos/TablePaxosRepairHistory.java | 80 ++
.../service/paxos/cleanup/PaxosCleanup.java | 156 +++
.../paxos/cleanup/PaxosCleanupComplete.java | 144 +++
.../paxos/cleanup/PaxosCleanupException.java | 9 +-
.../service/paxos/cleanup/PaxosCleanupHistory.java | 68 ++
.../cleanup/PaxosCleanupLocalCoordinator.java | 189 +++
.../service/paxos/cleanup/PaxosCleanupRequest.java | 142 +++
.../paxos/cleanup/PaxosCleanupResponse.java | 87 ++
.../service/paxos/cleanup/PaxosCleanupSession.java | 267 +++++
.../paxos/cleanup/PaxosFinishPrepareCleanup.java | 169 +++
.../paxos/cleanup/PaxosStartPrepareCleanup.java | 192 +++
.../service/paxos/cleanup/PaxosTableRepairs.java | 235 ++++
.../paxos/uncommitted/PaxosBallotTracker.java | 207 ++++
.../service/paxos/uncommitted/PaxosKeyState.java | 168 +++
.../service/paxos/uncommitted/PaxosRows.java | 359 ++++++
.../paxos/uncommitted/PaxosStateTracker.java | 322 +++++
.../paxos/uncommitted/PaxosUncommittedIndex.java | 264 +++++
.../paxos/uncommitted/PaxosUncommittedTracker.java | 376 ++++++
.../paxos/uncommitted/UncommittedDataFile.java | 384 ++++++
.../paxos/uncommitted/UncommittedPaxosKey.java} | 15 +-
.../paxos/uncommitted/UncommittedTableData.java | 617 ++++++++++
.../paxos/{ => v1}/AbstractPaxosCallback.java | 23 +-
.../service/paxos/{ => v1}/PrepareCallback.java | 51 +-
.../service/paxos/{ => v1}/PrepareVerbHandler.java | 27 +-
.../service/paxos/{ => v1}/ProposeCallback.java | 22 +-
.../service/paxos/{ => v1}/ProposeVerbHandler.java | 29 +-
.../service/reads/AbstractReadExecutor.java | 6 +-
.../cassandra/service/reads/DataResolver.java | 30 +-
.../cassandra/service/reads/DigestResolver.java | 2 +-
.../cassandra/service/reads/ReadCallback.java | 4 +-
.../cassandra/service/reads/ResponseResolver.java | 11 +-
.../reads/ShortReadPartitionsProtection.java | 2 +-
.../service/reads/repair/AbstractReadRepair.java | 5 +-
.../reads/repair/BlockingPartitionRepair.java | 14 +-
.../service/reads/repair/BlockingReadRepair.java | 4 +-
.../service/reads/repair/NoopReadRepair.java | 4 +-
.../repair/PartitionIteratorMergeListener.java | 4 +-
.../service/reads/repair/ReadOnlyReadRepair.java | 4 +-
.../cassandra/service/reads/repair/ReadRepair.java | 8 +-
.../reads/repair/ReadRepairDiagnostics.java | 8 +-
.../service/reads/repair/ReadRepairStrategy.java | 4 +-
.../reads/repair/RowIteratorMergeListener.java | 6 +-
.../apache/cassandra/streaming/OutgoingStream.java | 4 +-
.../apache/cassandra/streaming/PreviewKind.java | 5 +-
.../cassandra/streaming/StreamCoordinator.java | 7 +-
.../apache/cassandra/streaming/StreamEvent.java | 10 +-
.../apache/cassandra/streaming/StreamManager.java | 19 +-
.../org/apache/cassandra/streaming/StreamPlan.java | 9 +-
.../cassandra/streaming/StreamResultFuture.java | 16 +-
.../apache/cassandra/streaming/StreamSession.java | 11 +-
.../apache/cassandra/streaming/StreamState.java | 7 +-
.../cassandra/streaming/StreamTransferTask.java | 6 +-
.../apache/cassandra/streaming/StreamingState.java | 12 +-
.../cassandra/streaming/TableStreamManager.java | 4 +-
.../async/StreamCompressionSerializer.java | 1 -
.../management/ProgressInfoCompositeData.java | 4 +-
.../management/SessionInfoCompositeData.java | 3 +-
.../management/StreamStateCompositeData.java | 3 +-
.../streaming/messages/StreamInitMessage.java | 28 +-
.../streaming/messages/StreamMessageHeader.java | 24 +-
.../apache/cassandra/tools/nodetool/Repair.java | 8 +
.../apache/cassandra/tracing/TraceKeyspace.java | 4 +-
.../org/apache/cassandra/tracing/TraceState.java | 9 +-
.../apache/cassandra/tracing/TraceStateImpl.java | 6 +-
src/java/org/apache/cassandra/tracing/Tracing.java | 31 +-
.../org/apache/cassandra/tracing/TracingImpl.java | 4 +-
.../org/apache/cassandra/transport/CBUtil.java | 14 +
.../org/apache/cassandra/transport/Message.java | 21 +-
.../apache/cassandra/utils/BiLongAccumulator.java | 2 +-
.../apache/cassandra/utils/CassandraVersion.java | 26 +-
.../apache/cassandra/utils/CloseableIterator.java | 45 +
.../cassandra/utils/CollectionSerializer.java | 125 ++
src/java/org/apache/cassandra/utils/CounterId.java | 4 +-
.../apache/cassandra/utils/EstimatedHistogram.java | 9 +-
.../org/apache/cassandra/utils/MonotonicClock.java | 4 +-
src/java/org/apache/cassandra/utils/Nemesis.java | 2 +-
.../apache/cassandra/utils/NullableSerializer.java | 70 ++
src/java/org/apache/cassandra/utils/TimeUUID.java | 574 +++++++++
src/java/org/apache/cassandra/utils/UUIDGen.java | 451 +------
...{BiLongAccumulator.java => VoidSerializer.java} | 14 +-
.../cassandra/utils/binlog/ExternalArchiver.java | 2 +-
.../cassandra/utils/concurrent/AbstractFuture.java | 1 -
.../concurrent/ConditionAsConsumer.java} | 17 +-
.../cassandra/utils/concurrent/IntrusiveStack.java | 58 +-
.../org/apache/cassandra/utils/concurrent/Ref.java | 3 +-
.../cassandra/utils/concurrent/SyncFuture.java | 2 +-
.../cassandra/utils/concurrent/SyncPromise.java | 269 +++++
.../apache/cassandra/utils/memory/BufferPool.java | 3 +-
.../cassandra/utils/memory/LongBufferPoolTest.java | 1 +
test/conf/cassandra.yaml | 2 +-
test/conf/logback-simulator.xml | 4 +
test/data/serialization/4.1/gms.EndpointState.bin | Bin 0 -> 73 bytes
test/data/serialization/4.1/gms.Gossip.bin | Bin 0 -> 166 bytes
.../serialization/4.1/service.SyncComplete.bin | Bin 0 -> 256 bytes
.../data/serialization/4.1/service.SyncRequest.bin | Bin 0 -> 111 bytes
.../4.1/service.ValidationComplete.bin | Bin 0 -> 597 bytes
.../4.1/service.ValidationRequest.bin | Bin 0 -> 74 bytes
.../{4.0 => 4.1}/utils.EstimatedHistogram.bin | Bin
.../distributed/api/ConsistencyLevel.java} | 26 +-
.../distributed/api/IClassTransformer.java | 21 +-
.../cassandra/distributed/api/ICoordinator.java | 72 ++
.../apache/cassandra/distributed/api/IMessage.java | 46 +-
.../cassandra/distributed/api/QueryResult.java | 86 ++
.../cassandra/distributed/api/QueryResults.java | 224 ++++
.../org/apache/cassandra/distributed/api/Row.java | 219 ++++
.../distributed/api/SimpleQueryResult.java | 163 +++
.../distributed/impl/AbstractCluster.java | 38 +-
.../cassandra/distributed/impl/Coordinator.java | 41 +-
.../impl/DelegatingInvokableInstance.java | 2 +-
.../impl/DirectStreamingConnectionFactory.java | 38 +-
.../cassandra/distributed/impl/Instance.java | 60 +-
.../distributed/impl/IsolatedExecutor.java | 85 +-
.../cassandra/distributed/impl/MessageFilters.java | 207 ++++
.../cassandra/distributed/impl/MessageImpl.java | 10 +-
.../distributed/impl/ShutdownExecutor.java} | 22 +-
.../cassandra/distributed/impl/TracingUtil.java | 6 +-
.../distributed/impl/UnsafeGossipHelper.java | 24 +-
.../distributed/test/CASCommonTestCases.java | 204 ++++
.../distributed/test/CASContentionTest.java | 110 ++
.../cassandra/distributed/test/CASMultiDCTest.java | 150 +++
.../apache/cassandra/distributed/test/CASTest.java | 891 +++++++-------
.../cassandra/distributed/test/CASTestBase.java | 221 ++++
.../distributed/test/CasCriticalSectionTest.java | 218 ++++
.../distributed/test/IncRepairAdminTest.java | 12 +-
.../cassandra/distributed/test/LegacyCASTest.java | 118 ++
.../distributed/test/MessageForwardingTest.java | 11 +-
.../cassandra/distributed/test/MoveTest.java | 90 ++
.../distributed/test/PaxosRepairTest.java | 620 ++++++++++
.../distributed/test/PaxosRepairTest2.java | 612 ++++++++++
.../test/PaxosUncommittedIndexTest.java | 54 +
.../test/ReadDigestConsistencyTest.java | 3 +-
.../cassandra/distributed/test/ReadRepairTest.java | 2 +-
.../distributed/test/SecondaryIndexTest.java | 3 +-
.../io/sstable/format/ForwardingSSTableReader.java | 4 +-
.../cassandra/test/microbench/MessageOutBench.java | 8 +-
.../test/microbench/TimedMonitorBench.java | 198 ++++
.../microbench/ZeroCopyStreamingBenchmark.java | 5 +-
.../cassandra/simulator/asm/ClassTransformer.java | 81 +-
.../org/apache/cassandra/simulator/asm/Flag.java | 2 +-
.../simulator/asm/GlobalMethodTransformer.java | 8 +
.../cassandra/simulator/asm/InterceptAgent.java | 15 +-
.../cassandra/simulator/asm/InterceptClasses.java | 216 +++-
.../cassandra/simulator/asm/MethodLogger.java | 10 +-
.../simulator/asm/ShadowingTransformer.java | 2 +-
.../asm/ThreadLocalRandomCheckTransformer.java | 56 +
.../org/apache/cassandra/simulator/asm/Utils.java | 25 +
.../systems/InterceptorOfSystemMethods.java | 46 +-
.../org/apache/cassandra/simulator/Action.java | 158 ++-
.../org/apache/cassandra/simulator/ActionList.java | 6 +
.../org/apache/cassandra/simulator/ActionPlan.java | 13 +-
.../apache/cassandra/simulator/ActionSchedule.java | 86 +-
.../cassandra/simulator/ClusterSimulation.java | 136 ++-
.../main/org/apache/cassandra/simulator/Debug.java | 3 +-
.../cassandra/simulator/FutureActionScheduler.java | 4 +-
.../org/apache/cassandra/simulator/OrderOns.java | 5 +
.../org/apache/cassandra/simulator/Ordered.java | 7 +-
.../simulator/RunnableActionScheduler.java | 2 +-
.../cassandra/simulator/SimulationRunner.java | 54 +-
.../simulator/asm/InterceptAsClassTransformer.java | 49 +
.../simulator/cluster/ClusterActions.java | 14 +-
.../simulator/cluster/KeyspaceActions.java | 10 +-
.../simulator/cluster/OnClusterChangeTopology.java | 3 +-
.../cassandra/simulator/cluster/OnClusterJoin.java | 1 +
.../simulator/cluster/OnClusterLeave.java | 4 +-
.../simulator/cluster/OnClusterReplace.java | 1 +
.../simulator/cluster/OnInstanceRepair.java | 2 +-
.../OnInstanceTopologyChangePaxosRepair.java | 71 ++
.../cassandra/simulator/debug/Reconcile.java | 134 ++-
.../apache/cassandra/simulator/debug/Record.java | 121 +-
.../cassandra/simulator/debug/SelfReconcile.java | 76 +-
.../apache/cassandra/simulator/package-info.java | 1 +
.../apache/cassandra/simulator/paxos/Ballots.java | 67 +-
.../paxos/PairOfSequencesPaxosSimulation.java | 20 +-
.../simulator/paxos/PaxosClusterSimulation.java | 7 +-
.../simulator/paxos/PaxosRepairValidator.java | 5 +-
.../cassandra/simulator/paxos/PaxosSimulation.java | 78 +-
.../simulator/paxos/PaxosSimulationRunner.java | 9 +-
.../paxos/PaxosTopologyChangeVerifier.java | 9 +-
.../simulator/systems/InterceptedExecution.java | 3 +-
.../simulator/systems/InterceptedWait.java | 127 +-
.../simulator/systems/InterceptibleThread.java | 110 +-
.../simulator/systems/InterceptingAwaitable.java | 45 +-
.../simulator/systems/InterceptingExecutor.java | 326 ++++-
.../systems/InterceptingExecutorFactory.java | 35 +-
.../systems/InterceptingGlobalMethods.java | 157 ++-
.../simulator/systems/InterceptingMonitors.java | 273 +++--
.../simulator/systems/InterceptingWaitQueue.java | 15 +-
.../systems/InterceptorOfConsequences.java | 43 +-
.../simulator/systems/InterceptorOfExecution.java | 5 +-
.../systems/InterceptorOfGlobalMethods.java | 96 ++
.../simulator/systems/InterceptorOfWaits.java | 46 -
.../simulator/systems/NonInterceptible.java | 46 +-
.../simulator/systems/SimulatedAction.java | 134 ++-
.../simulator/systems/SimulatedActionCallable.java | 1 -
.../simulator/systems/SimulatedActionTask.java | 27 +-
.../simulator/systems/SimulatedBallots.java | 30 +-
.../simulator/systems/SimulatedExecution.java | 1 +
.../systems/SimulatedFutureActionScheduler.java | 12 +-
.../simulator/systems/SimulatedSystems.java | 10 +-
.../cassandra/simulator/systems/SimulatedTime.java | 267 ++++-
.../simulator/systems/SimulatedWaits.java | 156 ---
.../simulator/test/ShortPaxosSimulationTest.java | 25 +-
.../simulator/test/SimulationTestBase.java | 32 +-
...ulationTest.java => TrivialSimulationTest.java} | 2 +-
.../cassandra/AbstractSerializationsTester.java | 3 +-
test/unit/org/apache/cassandra/Util.java | 1 +
.../cassandra/batchlog/BatchlogManagerTest.java | 16 +-
.../apache/cassandra/batchlog/BatchlogTest.java | 6 +-
.../DebuggableThreadPoolExecutorTest.java | 6 +-
.../config/DatabaseDescriptorRefTest.java | 2 +
.../LoadOldYAMLBackwardCompatibilityTest.java | 2 +-
.../cassandra/config/ParseAndConvertUnitsTest.java | 2 +-
.../apache/cassandra/cql3/CQL3TypeLiteralTest.java | 6 +-
test/unit/org/apache/cassandra/cql3/CQLTester.java | 6 +-
.../cassandra/cql3/PstmtPersistenceTest.java | 1 -
.../cql3/conditions/ColumnConditionTest.java | 7 +-
.../cassandra/cql3/functions/CastFctsTest.java | 4 +-
.../cassandra/cql3/functions/TimeFctsTest.java | 21 +-
.../cql3/validation/entities/TimeuuidTest.java | 6 +-
.../cql3/validation/entities/UFScriptTest.java | 6 +-
.../cql3/validation/entities/UFTypesTest.java | 5 +-
.../unit/org/apache/cassandra/db/CellSpecTest.java | 5 +-
test/unit/org/apache/cassandra/db/DigestTest.java | 4 +-
.../org/apache/cassandra/db/ReadCommandTest.java | 9 +-
.../cassandra/db/ReadCommandVerbHandlerTest.java | 4 +-
test/unit/org/apache/cassandra/db/ScrubTest.java | 4 +-
.../cassandra/db/SystemKeyspaceMigrator40Test.java | 13 +-
test/unit/org/apache/cassandra/db/VerifyTest.java | 16 +-
.../db/compaction/AbstractPendingRepairTest.java | 6 +-
.../db/compaction/AntiCompactionBytemanTest.java | 4 +-
.../db/compaction/AntiCompactionTest.java | 28 +-
.../db/compaction/CancelCompactionsTest.java | 7 +-
.../db/compaction/CompactionInfoTest.java | 7 +-
...CompactionStrategyManagerPendingRepairTest.java | 24 +-
.../compaction/CompactionStrategyManagerTest.java | 9 +-
.../db/compaction/CompactionTaskTest.java | 12 +-
.../compaction/LeveledCompactionStrategyTest.java | 6 +-
.../db/compaction/PendingRepairManagerTest.java | 33 +-
.../writers/CompactionAwareWriterTest.java | 5 +-
.../cassandra/db/filter/ColumnFilterTest.java | 1 +
.../cassandra/db/marshal/CompositeTypeTest.java | 22 +-
.../db/marshal/DynamicCompositeTypeTest.java | 4 +-
.../cassandra/db/marshal/JsonConversionTest.java | 5 +-
.../apache/cassandra/db/marshal/RoundTripTest.java | 15 +-
.../cassandra/db/marshal/TimeUUIDTypeTest.java | 54 +-
.../cassandra/db/marshal/TypeValidationTest.java | 3 +-
.../apache/cassandra/db/marshal/UUIDTypeTest.java | 19 +-
.../db/partition/PartitionUpdateTest.java | 2 +-
.../repair/AbstractPendingAntiCompactionTest.java | 6 +-
...pactionManagerGetSSTablesForValidationTest.java | 12 +-
.../repair/PendingAntiCompactionBytemanTest.java | 4 +-
.../db/repair/PendingAntiCompactionTest.java | 75 +-
.../CassandraEntireSSTableStreamWriterTest.java | 4 +-
.../db/streaming/CassandraStreamManagerTest.java | 15 +-
...TableStreamConcurrentComponentMutationTest.java | 6 +-
.../db/virtual/SSTableTasksTableTest.java | 5 +-
.../db/virtual/StreamingVirtualTableTest.java | 4 +-
.../org/apache/cassandra/hints/AlteredHints.java | 3 +-
.../apache/cassandra/hints/HintWriteTTLTest.java | 4 +-
.../index/internal/CassandraIndexTest.java | 8 +-
.../io/sstable/IndexSummaryManagerTest.java | 3 +-
.../cassandra/io/sstable/LegacySSTableTest.java | 13 +-
.../cassandra/io/sstable/SSTableRewriterTest.java | 35 +-
.../cassandra/io/sstable/SSTableWriterTest.java | 13 +-
.../io/sstable/SSTableWriterTestBase.java | 4 +-
.../sstable/metadata/MetadataSerializerTest.java | 3 -
.../apache/cassandra/locator/ReplicaPlansTest.java | 4 +-
.../DecayingEstimatedHistogramReservoirTest.java | 50 +-
.../unit/org/apache/cassandra/net/MessageTest.java | 13 +-
.../cassandra/net/WriteCallbackInfoTest.java | 4 +-
.../cassandra/repair/AbstractRepairTest.java | 9 +-
.../apache/cassandra/repair/LocalSyncTaskTest.java | 26 +-
.../org/apache/cassandra/repair/RepairJobTest.java | 103 +-
.../apache/cassandra/repair/RepairSessionTest.java | 9 +-
.../cassandra/repair/StreamingRepairTaskTest.java | 14 +-
.../repair/SymmetricRemoteSyncTaskTest.java | 5 +-
.../cassandra/repair/ValidationTaskTest.java | 5 +-
.../org/apache/cassandra/repair/ValidatorTest.java | 25 +-
.../consistent/AbstractConsistentSessionTest.java | 9 +-
.../consistent/CoordinatorMessagingTest.java | 13 +-
.../repair/consistent/CoordinatorSessionTest.java | 8 +-
.../repair/consistent/CoordinatorSessionsTest.java | 25 +-
.../repair/consistent/LocalSessionAccessor.java | 10 +-
.../repair/consistent/LocalSessionTest.java | 95 +-
.../repair/consistent/PendingRepairStatTest.java | 8 +-
.../messages/RepairMessageSerializationsTest.java | 13 +-
.../messages/RepairMessageSerializerTest.java | 18 +-
.../cassandra/service/ActiveRepairServiceTest.java | 8 +-
.../apache/cassandra/service/PaxosStateTest.java | 177 +++
.../cassandra/service/SerializationsTest.java | 10 +-
.../service/WriteResponseHandlerTest.java | 2 +-
.../service/WriteResponseHandlerTransientTest.java | 12 +-
.../service/paxos/AbstractPaxosRepairTest.java | 174 +++
.../service/paxos/ContentionStrategyTest.java | 430 +++++++
.../cassandra/service/paxos/PaxosProposeTest.java | 97 ++
.../service/paxos/PaxosRepairHistoryTest.java | 531 +++++++++
.../cassandra/service/paxos/PaxosRepairTest.java | 172 +++
.../cassandra/service/paxos/PaxosStateTest.java | 323 +++++
.../paxos/cleanup/PaxosTableRepairsTest.java | 262 ++++
.../paxos/uncommitted/PaxosBallotTrackerTest.java | 258 ++++
.../paxos/uncommitted/PaxosMockUpdateSupplier.java | 113 ++
.../service/paxos/uncommitted/PaxosRowsTest.java | 165 +++
.../paxos/uncommitted/PaxosStateTrackerTest.java | 242 ++++
.../paxos/uncommitted/PaxosUncommittedTests.java | 94 ++
.../PaxosUncommittedTrackerIntegrationTest.java | 141 +++
.../uncommitted/PaxosUncommittedTrackerTest.java | 248 ++++
.../uncommitted/UncommittedTableDataTest.java | 650 ++++++++++
.../reads/repair/AbstractReadRepairTest.java | 10 +-
.../reads/repair/BlockingReadRepairTest.java | 10 +-
.../repair/DiagEventsBlockingReadRepairTest.java | 8 +-
.../reads/repair/InstrumentedReadRepair.java | 4 +-
.../reads/repair/ReadOnlyReadRepairTest.java | 4 +-
.../service/reads/repair/ReadRepairTest.java | 6 +-
.../service/reads/repair/TestableReadRepair.java | 4 +-
...ntireSSTableStreamingCorrectFilesCountTest.java | 4 +-
.../streaming/StreamTransferTaskTest.java | 10 +-
.../cassandra/streaming/StreamingTransferTest.java | 5 +-
.../async/StreamingInboundHandlerTest.java | 16 +-
.../async/StreamingMultiplexedChannelTest.java | 7 +-
.../tools/nodetool/CompactionStatsTest.java | 6 +-
.../org/apache/cassandra/tracing/TracingTest.java | 8 +-
.../cassandra/transport/ErrorMessageTest.java | 6 +-
.../cassandra/utils/CassandraVersionTest.java | 12 +-
.../utils/MergeIteratorComparisonTest.java | 14 +-
.../unit/org/apache/cassandra/utils/UUIDTests.java | 26 +-
.../utils/concurrent/AbstractTestAsyncPromise.java | 56 +-
.../utils/concurrent/AbstractTestAwaitable.java | 40 +-
.../cassandra/utils/concurrent/SemaphoreTest.java | 21 +-
.../stress/generate/PartitionGenerator.java | 6 +-
.../stress/generate/PartitionIterator.java | 9 +-
.../stress/generate/values/Generator.java | 4 +-
.../stress/generate/values/TimeUUIDs.java | 4 +-
577 files changed, 28975 insertions(+), 4537 deletions(-)
copy src/java/org/apache/cassandra/db/marshal/{TimeUUIDType.java =>
AbstractTimeUUIDType.java} (81%)
copy src/java/org/apache/cassandra/{batchlog/BatchRemoveVerbHandler.java =>
db/marshal/LegacyTimeUUIDType.java} (64%)
rename src/java/org/apache/cassandra/locator/{InOurDcTester.java =>
InOurDc.java} (71%)
copy src/java/org/apache/cassandra/{batchlog/BatchRemoveVerbHandler.java =>
metrics/PaxosMetrics.java} (65%)
copy
test/unit/org/apache/cassandra/service/reads/repair/InstrumentedReadRepair.java
=> src/java/org/apache/cassandra/net/RequestCallbackWithFailure.java (63%)
copy src/java/org/apache/cassandra/{io/FSWriteError.java =>
security/DisableSslContextFactory.java} (55%)
delete mode 100644
src/java/org/apache/cassandra/serializers/TimeUUIDSerializer.java
create mode 100644
src/java/org/apache/cassandra/service/FailureRecordingCallback.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/AbstractPaxosRepair.java
create mode 100644 src/java/org/apache/cassandra/service/paxos/Ballot.java
delete mode 100644
src/java/org/apache/cassandra/service/paxos/CommitVerbHandler.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/ContentionStrategy.java
create mode 100644 src/java/org/apache/cassandra/service/paxos/Paxos.md
create mode 100644 src/java/org/apache/cassandra/service/paxos/PaxosCommit.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosCommitAndPrepare.java
copy src/java/org/apache/cassandra/{utils/CloseableIterator.java =>
service/paxos/PaxosOperationLock.java} (80%)
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosPrepare.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosPrepareRefresh.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosPropose.java
create mode 100644 src/java/org/apache/cassandra/service/paxos/PaxosRepair.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosRepairHistory.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosRequestCallback.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/TablePaxosRepairHistory.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanup.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupComplete.java
copy test/simulator/asm/org/apache/cassandra/simulator/asm/Flag.java =>
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupException.java
(81%)
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupHistory.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupLocalCoordinator.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupResponse.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupSession.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosFinishPrepareCleanup.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosStartPrepareCleanup.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosTableRepairs.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosBallotTracker.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosKeyState.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosRows.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTracker.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedIndex.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTracker.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedDataFile.java
copy src/java/org/apache/cassandra/{repair/NoSuchRepairSessionException.java
=> service/paxos/uncommitted/UncommittedPaxosKey.java} (71%)
create mode 100644
src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java
rename src/java/org/apache/cassandra/service/paxos/{ =>
v1}/AbstractPaxosCallback.java (81%)
rename src/java/org/apache/cassandra/service/paxos/{ =>
v1}/PrepareCallback.java (57%)
rename src/java/org/apache/cassandra/service/paxos/{ =>
v1}/PrepareVerbHandler.java (60%)
rename src/java/org/apache/cassandra/service/paxos/{ =>
v1}/ProposeCallback.java (86%)
rename src/java/org/apache/cassandra/service/paxos/{ =>
v1}/ProposeVerbHandler.java (56%)
create mode 100644
src/java/org/apache/cassandra/utils/CollectionSerializer.java
create mode 100644 src/java/org/apache/cassandra/utils/NullableSerializer.java
create mode 100644 src/java/org/apache/cassandra/utils/TimeUUID.java
copy src/java/org/apache/cassandra/utils/{BiLongAccumulator.java =>
VoidSerializer.java} (58%)
copy src/java/org/apache/cassandra/{batchlog/BatchRemoveVerbHandler.java =>
utils/concurrent/ConditionAsConsumer.java} (66%)
create mode 100644
src/java/org/apache/cassandra/utils/concurrent/SyncPromise.java
create mode 100644 test/data/serialization/4.1/gms.EndpointState.bin
create mode 100644 test/data/serialization/4.1/gms.Gossip.bin
create mode 100644 test/data/serialization/4.1/service.SyncComplete.bin
create mode 100644 test/data/serialization/4.1/service.SyncRequest.bin
create mode 100644 test/data/serialization/4.1/service.ValidationComplete.bin
create mode 100644 test/data/serialization/4.1/service.ValidationRequest.bin
copy test/data/serialization/{4.0 => 4.1}/utils.EstimatedHistogram.bin (100%)
copy test/{simulator/main/org/apache/cassandra/simulator/debug/Capture.java =>
distributed/org/apache/cassandra/distributed/api/ConsistencyLevel.java} (69%)
copy src/java/org/apache/cassandra/batchlog/BatchRemoveVerbHandler.java =>
test/distributed/org/apache/cassandra/distributed/api/IClassTransformer.java
(62%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/api/ICoordinator.java
copy src/java/org/apache/cassandra/io/FSReadError.java =>
test/distributed/org/apache/cassandra/distributed/api/IMessage.java (60%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/api/QueryResult.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/api/QueryResults.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/api/Row.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/api/SimpleQueryResult.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/impl/MessageFilters.java
rename test/{simulator/main/org/apache/cassandra/simulator/debug/Capture.java
=> distributed/org/apache/cassandra/distributed/impl/ShutdownExecutor.java}
(68%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/CASCommonTestCases.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/CASContentionTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/CASMultiDCTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/CASTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/CasCriticalSectionTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/LegacyCASTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/MoveTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/PaxosRepairTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/PaxosRepairTest2.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/PaxosUncommittedIndexTest.java
create mode 100644
test/microbench/org/apache/cassandra/test/microbench/TimedMonitorBench.java
create mode 100644
test/simulator/asm/org/apache/cassandra/simulator/asm/ThreadLocalRandomCheckTransformer.java
create mode 100644
test/simulator/main/org/apache/cassandra/simulator/asm/InterceptAsClassTransformer.java
create mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceTopologyChangePaxosRepair.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/systems/InterceptorOfWaits.java
delete mode 100644
test/simulator/main/org/apache/cassandra/simulator/systems/SimulatedWaits.java
copy src/java/org/apache/cassandra/io/FSNoDiskAvailableForWriteError.java =>
test/simulator/test/org/apache/cassandra/simulator/test/ShortPaxosSimulationTest.java
(56%)
rename
test/simulator/test/org/apache/cassandra/simulator/test/{SimulationTest.java =>
TrivialSimulationTest.java} (98%)
create mode 100644 test/unit/org/apache/cassandra/service/PaxosStateTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/AbstractPaxosRepairTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/ContentionStrategyTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/PaxosProposeTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/PaxosRepairHistoryTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/PaxosRepairTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/PaxosStateTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/cleanup/PaxosTableRepairsTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosBallotTrackerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosMockUpdateSupplier.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosRowsTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTrackerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTests.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTrackerIntegrationTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTrackerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableDataTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
