wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Modify how cluster ID tests are run in simulation

This commit is contained in:
Lukas Joswiak 2022-10-18 17:59:49 -07:00
parent bba05b7c9b
commit 1fca3b7ddc
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
fdbserver/workloads/MachineAttrition.actor.cpp
View File

@ -74,6 +74,7 @@ struct MachineAttritionWorkload : FailureInjectionWorkload {
bool killProcess = false; bool killProcess = false;
bool killZone = false; bool killZone = false;
bool killSelf = false; bool killSelf = false;
bool killAll = false;
std::vector<std::string> targetIds; std::vector<std::string> targetIds;
bool replacement = false; bool replacement = false;
bool waitForVersion = false; bool waitForVersion = false;
@ -107,6 +108,10 @@ struct MachineAttritionWorkload : FailureInjectionWorkload {
killProcess = getOption(options, "killProcess"_sr, killProcess); killProcess = getOption(options, "killProcess"_sr, killProcess);
killZone = getOption(options, "killZone"_sr, killZone); killZone = getOption(options, "killZone"_sr, killZone);
killSelf = getOption(options, "killSelf"_sr, killSelf); killSelf = getOption(options, "killSelf"_sr, killSelf);
killAll =
getOption(options,
"killAll"_sr,
g_network->isSimulated() && !g_simulator->extraDatabases.empty() && BUGGIFY_WITH_PROB(0.01));
targetIds = getOption(options, "targetIds"_sr, std::vector<std::string>()); targetIds = getOption(options, "targetIds"_sr, std::vector<std::string>());
replacement = getOption(options, "replacement"_sr, reboot && deterministicRandom()->random01() < 0.5); replacement = getOption(options, "replacement"_sr, reboot && deterministicRandom()->random01() < 0.5);
waitForVersion = getOption(options, "waitForVersion"_sr, waitForVersion); waitForVersion = getOption(options, "waitForVersion"_sr, waitForVersion);
@ -357,7 +362,7 @@ struct MachineAttritionWorkload : FailureInjectionWorkload {
TraceEvent("Assassination").detail("TargetDataHall", target).detail("KillType", kt); TraceEvent("Assassination").detail("TargetDataHall", target).detail("KillType", kt);
g_simulator->killDataHall(target, kt); g_simulator->killDataHall(target, kt);
} else if (!g_simulator->extraDatabases.empty() && deterministicRandom()->random01() < 0.1) { } else if (self->killAll) {
state ISimulator::KillType kt = ISimulator::RebootProcessAndSwitch; state ISimulator::KillType kt = ISimulator::RebootProcessAndSwitch;
TraceEvent("Assassination").detail("KillType", kt); TraceEvent("Assassination").detail("KillType", kt);
g_simulator->killAll(kt, true); g_simulator->killAll(kt, true);