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

default retries to infinite

This commit is contained in:
Jon Fu 2020-10-14 17:35:30 -04:00
parent 893e4c79f3
commit 28686b14f7
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
fdbserver/workloads/IncrementalBackup.actor.cpp
View File

@ -47,7 +47,7 @@ struct IncrementalBackupWorkload : TestWorkload {
submitOnly = getOption(options, LiteralStringRef("submitOnly"), false); submitOnly = getOption(options, LiteralStringRef("submitOnly"), false);
restoreOnly = getOption(options, LiteralStringRef("restoreOnly"), false); restoreOnly = getOption(options, LiteralStringRef("restoreOnly"), false);
waitForBackup = getOption(options, LiteralStringRef("waitForBackup"), false); waitForBackup = getOption(options, LiteralStringRef("waitForBackup"), false);
waitRetries = getOption(options, LiteralStringRef("waitRetries"), 20); waitRetries = getOption(options, LiteralStringRef("waitRetries"), -1);
stopBackup = getOption(options, LiteralStringRef("stopBackup"), false); stopBackup = getOption(options, LiteralStringRef("stopBackup"), false);
checkBeginVersion = getOption(options, LiteralStringRef("checkBeginVersion"), false); checkBeginVersion = getOption(options, LiteralStringRef("checkBeginVersion"), false);
} }
@ -106,7 +106,8 @@ struct IncrementalBackupWorkload : TestWorkload {
desc.contiguousLogEnd.present() ? desc.contiguousLogEnd.get() : invalidVersion) desc.contiguousLogEnd.present() ? desc.contiguousLogEnd.get() : invalidVersion)
.detail("TargetVersion", v); .detail("TargetVersion", v);
if (!desc.contiguousLogEnd.present()) continue; if (!desc.contiguousLogEnd.present()) continue;
if (desc.contiguousLogEnd.get() >= v || tries > self->waitRetries) break; if (desc.contiguousLogEnd.get() >= v) break;
if (self->waitRetries != -1 && tries > self->waitRetries) break;
// Avoid spamming requests with a delay // Avoid spamming requests with a delay
wait(delay(5.0)); wait(delay(5.0));
} }