From eefaa30fa48aed9c66d0a61f1a257cf3abfbf40e Mon Sep 17 00:00:00 2001 From: sfc-gh-tclinkenbeard Date: Fri, 9 Oct 2020 07:43:21 -0700 Subject: [PATCH] Added retry loop for getReadVersion in IncrementalBackupWorkload --- fdbserver/workloads/IncrementalBackup.actor.cpp | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/fdbserver/workloads/IncrementalBackup.actor.cpp b/fdbserver/workloads/IncrementalBackup.actor.cpp index cd2cbb0bef..7e1026b5cc 100644 --- a/fdbserver/workloads/IncrementalBackup.actor.cpp +++ b/fdbserver/workloads/IncrementalBackup.actor.cpp @@ -70,8 +70,16 @@ struct IncrementalBackupWorkload : TestWorkload { ACTOR static Future _check(Database cx, IncrementalBackupWorkload* self) { state Reference backupContainer; state UID backupUID; - state Reference tr(new ReadYourWritesTransaction(cx)); - state Version v = wait(tr->getReadVersion()); + state Version v; + state Transaction tr(cx); + loop { + try { + wait(store(v, tr.getReadVersion())); + break; + } catch (Error& e) { + wait(tr.onError(e)); + } + } // Wait for backup container to be created and avoid race condition TraceEvent("IBackupWaitContainer"); loop {