This is an automated email from the ASF dual-hosted git repository.
belliottsmith pushed a change to branch cassandra-6.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 05fecbc54e Merge branch 'cassandra-5.0' into cassandra-6.0
add 4da20e07e8 Improve Rebootstrap: - Distinguish corrupt/incomplete
cases; latter case only refuses uncertain data - Ensures fresh quorum
durability before marking own log faulty - Refuse unsafe operations more
selectively once log marked faulty - Simplify and merge logic with standard
bootstrap, using DurabilityService Also Improve: - Maintain multiple stale
timestamp reservations to allow us to issue stale timestamps closer to any
conflicting transaction - Maintain richer Ac [...]
No new revisions were added by this update.
Summary of changes:
CHANGES.txt | 1 +
formalise/accord/execution/README.md | 2 +-
.../org/apache/cassandra/config/AccordConfig.java | 77 +-
.../config/CassandraRelevantProperties.java | 16 +-
.../cassandra/config/DatabaseDescriptor.java | 10 +-
.../db/streaming/CassandraStreamReceiver.java | 3 +-
.../cassandra/db/virtual/AccordDebugKeyspace.java | 37 +-
.../cassandra/exceptions/ExceptionSerializer.java | 17 +-
.../org/apache/cassandra/gms/FailureDetector.java | 16 +-
src/java/org/apache/cassandra/gms/Gossiper.java | 2 +-
.../org/apache/cassandra/journal/Compactor.java | 7 +-
.../apache/cassandra/journal/SegmentCompactor.java | 6 +-
.../cassandra/repair/RepairMessageVerbHandler.java | 21 +
.../org/apache/cassandra/repair/RepairSession.java | 9 +
.../org/apache/cassandra/schema/TableParams.java | 4 +-
.../apache/cassandra/service/StorageService.java | 11 +-
.../service/accord/AccordCommandStore.java | 20 +-
.../cassandra/service/accord/AccordDataStore.java | 148 +-
.../service/accord/AccordFetchCoordinator.java | 38 +-
.../cassandra/service/accord/AccordKeyspace.java | 6 +-
.../service/accord/AccordMessageSink.java | 27 +-
.../cassandra/service/accord/AccordOperations.java | 6 +-
.../service/accord/AccordResponseVerbHandler.java | 6 +-
.../cassandra/service/accord/AccordResult.java | 4 +-
.../cassandra/service/accord/AccordService.java | 360 +++-
.../service/accord/AccordVerbHandler.java | 6 +-
.../cassandra/service/accord/IAccordService.java | 25 +-
.../cassandra/service/accord/api/AccordAgent.java | 136 +-
.../service/accord/api/AccordTopologySorter.java | 18 +-
.../service/accord/api/AccordWaitStrategies.java | 30 +-
.../accord/api/CompositeTopologySorter.java | 10 +-
.../service/accord/debug/DebugExecution.java | 193 +-
.../service/accord/execution/AccordCache.java | 6 +-
.../service/accord/execution/AccordCacheEntry.java | 24 +-
.../accord/execution/AccordCacheEntryQueue.java | 8 +-
.../service/accord/execution/AccordExecutor.java | 91 +-
.../service/accord/execution/CancelTask.java | 9 +-
.../accord/execution/ExclusiveExecutor.java | 41 +-
.../service/accord/execution/IOTaskLoad.java | 2 +-
.../service/accord/execution/IOTaskSave.java | 2 +-
.../service/accord/execution/IOTaskWrapper.java | 2 +-
.../cassandra/service/accord/execution/Plain.java | 10 +-
.../service/accord/execution/PlainChain.java | 6 +-
.../accord/execution/PlainChainDebuggable.java | 4 +-
.../service/accord/execution/PlainRunnable.java | 6 +-
.../service/accord/execution/SafeTask.java | 73 +-
.../cassandra/service/accord/execution/Task.java | 201 ++-
.../service/accord/execution/TaskQueueMulti.java | 67 +-
.../service/accord/execution/Tranches.java | 29 +-
.../service/accord/execution/Unstoppable.java | 1 +
.../accord/interop/AccordInteropAdapter.java | 26 +-
.../accord/interop/AccordInteropExecution.java | 22 +-
.../accord/journal/AbstractSegmentCompactor.java | 39 +-
.../service/accord/journal/AccordJournal.java | 4 +-
.../service/accord/repair/AccordRepair.java | 7 +-
.../serializers/CommandStoreSerializers.java | 13 +-
.../accord/serializers/FetchSerializers.java | 24 +-
.../serializers/GetDurableBeforeSerializers.java | 4 +-
.../accord/topology/AccordEndpointInfos.java | 254 +++
...dEndpointMapper.java => AccordEndpointMap.java} | 35 +-
.../service/accord/topology/AccordFastPath.java | 303 ----
.../accord/topology/AccordFastPathCoordinator.java | 347 ----
.../accord/topology/AccordNodeInfoCoordinator.java | 366 ++++
.../service/accord/topology/AccordNodeInfos.java | 787 +++++++++
.../accord/topology/AccordStaleReplicas.java | 167 --
.../accord/topology/AccordSyncPropagator.java | 23 +-
.../service/accord/topology/AccordTopology.java | 19 +-
.../accord/topology/AccordTopologyService.java | 4 +-
.../service/accord/topology/EndpointMapping.java | 214 ---
.../cassandra/service/accord/txn/TxnRead.java | 4 +-
.../migration/ConsensusKeyMigrationState.java | 2 +-
.../cassandra/tcm/AbstractLocalProcessor.java | 2 +-
.../org/apache/cassandra/tcm/ClusterMetadata.java | 122 +-
.../cassandra/tcm/ClusterMetadataService.java | 27 +-
.../org/apache/cassandra/tcm/MetadataKeys.java | 6 +-
.../apache/cassandra/tcm/PaxosBackedProcessor.java | 2 +-
.../cassandra/tcm/StubClusterMetadataService.java | 6 +-
.../org/apache/cassandra/tcm/Transformation.java | 10 +-
.../cassandra/tcm/compatibility/GossipHelper.java | 12 +-
.../org/apache/cassandra/tcm/log/LocalLog.java | 20 +-
.../apache/cassandra/tcm/membership/Directory.java | 2 +-
.../cassandra/tcm/sequences/BootstrapAndJoin.java | 3 +-
...rdFastPath.java => AccordChangeDownStatus.java} | 36 +-
...cordFastPath.java => AccordChangeNodeInfo.java} | 63 +-
.../tcm/transformations/AccordMarkHardRemoved.java | 9 +-
.../tcm/transformations/AccordMarkStale.java | 11 +-
...rdMarkRejoining.java => AccordUnmarkStale.java} | 26 +-
.../cassandra/tcm/transformations/Startup.java | 2 +
...ck-dtest.xml => logback-dtest-info-rolling.xml} | 15 +-
.../{logback-dtest-quiet.xml => logback-info.xml} | 4 +-
.../distributed/impl/AbstractCluster.java | 12 +-
.../cassandra/distributed/impl/Instance.java | 44 +-
.../cassandra/distributed/impl/InstanceConfig.java | 2 +
.../distributed/test/ClearSnapshotTest.java | 2 +-
.../test/RepairParticipantShutdownTest.java | 78 +
.../test/accord/AccordIncrementalRepairTest.java | 12 +-
.../test/accord/AccordJournalIntegrationTest.java | 6 +-
.../distributed/test/accord/AccordLoadTest.java | 5 +-
.../test/accord/AccordNodetoolTest.java | 10 +-
.../AccordRecoverFromAvailabilityLossTest.java | 16 +-
.../test/accord/AccordRegainRangesTest.java | 2 +-
.../test/accord/AccordSimpleFastPathTest.java | 10 +-
.../distributed/test/accord/AccordTestBase.java | 36 +-
.../accord/journal/AccordJournalReplayTest.java | 2 +-
.../JournalAccessRouteIndexOnStartupRaceTest.java | 8 +-
.../accord/journal/StatefulJournalRestartTest.java | 6 +-
.../test/log/ClusterMetadataTestHelper.java | 9 +-
.../test/tcm/RepairMetadataKeyspaceTest.java | 17 +-
.../fuzz/accord/load/AccordLoadTestBase.java | 1857 ++++++++++++++++++++
.../accord/load/AccordRebootstrapLoadTest.java | 81 +
.../fuzz/accord/load/AccordYcsbLoadTest.java | 137 ++
.../cassandra/fuzz/accord/load/LoadSettings.java | 337 ++++
.../cassandra/fuzz/topology/AccordBounceTest.java | 4 +-
...HardCatchupTest.java => AccordCatchupTest.java} | 4 +-
.../fuzz/topology/AccordRebootstrapTest.java | 2 +-
.../fuzz/topology/AccordTopologyMixupTest.java | 8 +-
.../topology/HarryOnAccordTopologyMixupTest.java | 8 +-
.../cassandra/fuzz/topology/JournalGCTest.java | 1 +
.../accord/journal/AccordJournalBurnTest.java | 26 +-
.../org/apache/cassandra/harry/ColumnSpec.java | 4 +-
.../org/apache/cassandra/harry/gen/Generators.java | 5 +-
.../execution/AccordCommandStoreExecutorTest.java | 63 +-
.../simulator/test/AccordExecutorTest.java | 2 +-
.../config/DatabaseDescriptorRefTest.java | 11 +-
.../apache/cassandra/locator/MetaStrategyTest.java | 6 +-
.../cassandra/service/accord/AccordAgentTest.java | 50 +-
.../service/accord/AccordDurabilityStallTest.java | 10 +-
...ppingTest.java => AccordEndpointInfosTest.java} | 7 +-
.../service/accord/AccordExpungeTest.java | 2 +-
.../service/accord/AccordFailedKeyTestHarness.java | 4 +-
.../service/accord/AccordMessageSinkTest.java | 7 +-
.../service/accord/AccordNodeInfosTest.java | 249 +++
.../service/accord/AccordStaleReplicasTest.java | 63 -
.../cassandra/service/accord/AccordTestUtils.java | 51 +-
.../service/accord/AccordTopologyTest.java | 8 +-
.../service/accord/ControllableRangeIndex.java | 2 +-
.../cassandra/service/accord/EpochSyncTest.java | 11 +-
...intMapper.java => SimpleAccordEndpointMap.java} | 10 +-
.../accord/SimulatedAccordCommandStore.java | 7 +
.../accord/execution/AccordApplyFailureTest.java | 407 +++++
.../execution/AccordCacheEntryCycleTest.java | 2 +-
.../execution/AccordCacheEntryQueueTest.java | 4 +-
.../execution/AccordCacheEntryReentrancyTest.java | 2 +-
.../AccordCacheEntrySafeTaskCycleTest.java | 2 +-
.../accord/execution/AccordCacheEntryTest.java | 10 +-
.../service/accord/execution/AccordCacheTest.java | 2 +-
.../execution/AccordCommandFailureTestBase.java | 763 ++++++++
.../execution/AccordCommandStageFailureTest.java | 252 +++
.../accord/execution/AccordExecutionTestUtils.java | 12 +-
.../AccordExecutorCancelledConsequenceTest.java | 4 +-
...AccordExecutorContinuationCancellationTest.java | 4 +-
.../execution/AccordExecutorIncrDeadlockTest.java | 4 +-
.../AccordExecutorIncrRequeueRevocationTest.java | 4 +-
.../execution/AccordExecutorKeyAdoptionTest.java | 6 +-
.../execution/AccordExecutorLoadFailureTest.java | 6 +-
.../execution/AccordExecutorLoopFailureTest.java | 4 +-
.../AccordExecutorPresetupLoadingTest.java | 4 +-
.../execution/AccordExecutorRangeScanTest.java | 4 +-
.../execution/AccordFailedKeyAbandonTest.java | 6 +-
.../accord/execution/AccordFailedKeyBatchTest.java | 6 +-
.../accord/execution/AccordFailedKeyTest.java | 32 +-
.../service/accord/execution/CacheWedgeReport.java | 371 ++++
.../accord/execution/QueueCycleDetector.java | 67 +-
.../accord/execution/TaskLifecycleTest.java | 6 +-
.../accord/execution/TaskQueueMultiBlendTest.java | 159 ++
.../serializers/CommandsForKeySerializerTest.java | 2 +
.../topology/AccordFastPathCoordinatorTest.java | 258 ---
.../topology/AccordNodeInfoCoordinatorTest.java | 689 ++++++++
.../accord/topology/AccordSyncPropagatorTest.java | 20 +-
.../tcm/ClusterMetadataSerializerTest.java | 10 +-
.../tcm/ClusterMetadataTransformationTest.java | 22 +-
...joiningTest.java => AccordUnmarkStaleTest.java} | 12 +-
.../apache/cassandra/tools/CMSOfflineToolTest.java | 6 +-
.../cassandra/utils/CassandraGenerators.java | 45 +-
.../apache/cassandra/utils/NoSpamLoggerTest.java | 2 +-
.../cassandra/utils/concurrent/SignalLockTest.java | 2 +-
176 files changed, 8890 insertions(+), 2531 deletions(-)
create mode 100644
src/java/org/apache/cassandra/service/accord/topology/AccordEndpointInfos.java
rename
src/java/org/apache/cassandra/service/accord/topology/{AccordEndpointMapper.java
=> AccordEndpointMap.java} (65%)
delete mode 100644
src/java/org/apache/cassandra/service/accord/topology/AccordFastPath.java
delete mode 100644
src/java/org/apache/cassandra/service/accord/topology/AccordFastPathCoordinator.java
create mode 100644
src/java/org/apache/cassandra/service/accord/topology/AccordNodeInfoCoordinator.java
create mode 100644
src/java/org/apache/cassandra/service/accord/topology/AccordNodeInfos.java
delete mode 100644
src/java/org/apache/cassandra/service/accord/topology/AccordStaleReplicas.java
delete mode 100644
src/java/org/apache/cassandra/service/accord/topology/EndpointMapping.java
copy
src/java/org/apache/cassandra/tcm/transformations/{ReconfigureAccordFastPath.java
=> AccordChangeDownStatus.java} (64%)
rename
src/java/org/apache/cassandra/tcm/transformations/{ReconfigureAccordFastPath.java
=> AccordChangeNodeInfo.java} (55%)
rename
src/java/org/apache/cassandra/tcm/transformations/{AccordMarkRejoining.java =>
AccordUnmarkStale.java} (81%)
copy test/conf/{logback-dtest.xml => logback-dtest-info-rolling.xml} (80%)
copy test/conf/{logback-dtest-quiet.xml => logback-info.xml} (97%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/RepairParticipantShutdownTest.java
create mode 100644
test/distributed/org/apache/cassandra/fuzz/accord/load/AccordLoadTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/fuzz/accord/load/AccordRebootstrapLoadTest.java
create mode 100644
test/distributed/org/apache/cassandra/fuzz/accord/load/AccordYcsbLoadTest.java
create mode 100644
test/distributed/org/apache/cassandra/fuzz/accord/load/LoadSettings.java
rename
test/distributed/org/apache/cassandra/fuzz/topology/{AccordHardCatchupTest.java
=> AccordCatchupTest.java} (99%)
rename test/unit/org/apache/cassandra/service/accord/{EndpointMappingTest.java
=> AccordEndpointInfosTest.java} (82%)
create mode 100644
test/unit/org/apache/cassandra/service/accord/AccordNodeInfosTest.java
delete mode 100644
test/unit/org/apache/cassandra/service/accord/AccordStaleReplicasTest.java
rename
test/unit/org/apache/cassandra/service/accord/{SimpleAccordEndpointMapper.java
=> SimpleAccordEndpointMap.java} (91%)
create mode 100644
test/unit/org/apache/cassandra/service/accord/execution/AccordApplyFailureTest.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/execution/AccordCommandFailureTestBase.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/execution/AccordCommandStageFailureTest.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/execution/CacheWedgeReport.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/execution/TaskQueueMultiBlendTest.java
delete mode 100644
test/unit/org/apache/cassandra/service/accord/topology/AccordFastPathCoordinatorTest.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/topology/AccordNodeInfoCoordinatorTest.java
rename
test/unit/org/apache/cassandra/tcm/transformations/{AccordMarkRejoiningTest.java
=> AccordUnmarkStaleTest.java} (70%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
