From 9fd16bd38e49a9aef4e66d501d2808982694c11a Mon Sep 17 00:00:00 2001 From: Hui Liu Date: Fri, 23 Sep 2022 08:55:18 -0700 Subject: [PATCH] disable MoveKeysWorkload for a few tests that need to manipulate dd --- fdbserver/workloads/DataLossRecovery.actor.cpp | 2 ++ fdbserver/workloads/PhysicalShardMove.actor.cpp | 2 ++ .../workloads/StorageServerCheckpointRestoreTest.actor.cpp | 2 ++ 3 files changed, 6 insertions(+) diff --git a/fdbserver/workloads/DataLossRecovery.actor.cpp b/fdbserver/workloads/DataLossRecovery.actor.cpp index 86b7f9de3f..996c403efb 100644 --- a/fdbserver/workloads/DataLossRecovery.actor.cpp +++ b/fdbserver/workloads/DataLossRecovery.actor.cpp @@ -63,6 +63,8 @@ struct DataLossRecoveryWorkload : TestWorkload { Future setup(Database const& cx) override { return Void(); } + void disableFailureInjectionWorkloads(std::set& out) const override { out.insert("MoveKeysWorkload"); } + Future start(Database const& cx) override { if (!enabled) { return Void(); diff --git a/fdbserver/workloads/PhysicalShardMove.actor.cpp b/fdbserver/workloads/PhysicalShardMove.actor.cpp index 80bdcddbee..d8b767e322 100644 --- a/fdbserver/workloads/PhysicalShardMove.actor.cpp +++ b/fdbserver/workloads/PhysicalShardMove.actor.cpp @@ -70,6 +70,8 @@ struct PhysicalShardMoveWorkLoad : TestWorkload { return _start(this, cx); } + void disableFailureInjectionWorkloads(std::set& out) const override { out.insert("MoveKeysWorkload"); } + ACTOR Future _start(PhysicalShardMoveWorkLoad* self, Database cx) { int ignore = wait(setDDMode(cx, 0)); state std::map kvs({ { "TestKeyA"_sr, "TestValueA"_sr }, diff --git a/fdbserver/workloads/StorageServerCheckpointRestoreTest.actor.cpp b/fdbserver/workloads/StorageServerCheckpointRestoreTest.actor.cpp index 42b93b7654..e79a3784de 100644 --- a/fdbserver/workloads/StorageServerCheckpointRestoreTest.actor.cpp +++ b/fdbserver/workloads/StorageServerCheckpointRestoreTest.actor.cpp @@ -67,6 +67,8 @@ struct SSCheckpointRestoreWorkload : TestWorkload { return _start(this, cx); } + void disableFailureInjectionWorkloads(std::set& out) const override { out.insert("MoveKeysWorkload"); } + ACTOR Future _start(SSCheckpointRestoreWorkload* self, Database cx) { state Key key = "TestKey"_sr; state Key endKey = "TestKey0"_sr;