add traces

This commit is contained in:
Jon Fu 2020-10-13 16:07:09 -04:00
parent 1f39077d71
commit e096297bc1
3 changed files with 17 additions and 3 deletions

View File

@ -73,11 +73,22 @@ struct IncrementalBackupWorkload : TestWorkload {
state UID backupUID;
state Reference<ReadYourWritesTransaction> tr(new ReadYourWritesTransaction(cx));
state Version v = wait(tr->getReadVersion());
// Wait for backup container to be created and avoid race condition
TraceEvent("IBackupWaitContainer");
loop {
// Wait for backup container to be created and avoid race condition
TraceEvent("IBackupWaitContainer");
wait(success(
self->backupAgent.waitBackup(cx, self->tag.toString(), false, &backupContainer, &backupUID)));
if (!backupContainer.isValid()) {
TraceEvent("IBackupCheckListContainersAttempt");
state std::vector<std::string> containers =
wait(IBackupContainer::listContainers(self->backupDir.toString()));
TraceEvent("IBackupCheckListContainersSuccess")
.detail("Size", containers.size())
.detail("First", containers.front());
if (containers.size()) {
backupContainer = IBackupContainer::openContainer(containers.front());
}
}
state bool e = wait(backupContainer->exists());
if (e) break;
wait(delay(5.0));
@ -97,8 +108,10 @@ struct IncrementalBackupWorkload : TestWorkload {
}
if (self->stopBackup) {
try {
TraceEvent("IBackupDiscontinueBackup");
wait(self->backupAgent.discontinueBackup(cx, self->tag));
} catch (Error& e) {
TraceEvent("IBackupDiscontinueBackupException").error(e);
if (e.code() != error_code_backup_unneeded) {
throw;
}

View File

@ -216,6 +216,7 @@ public: // workload functions
snapFailed = true;
break;
}
TraceEvent("SnapCreateError").error(e);
++retry;
// snap v2 can fail for many reasons, so retry for 5 times and then fail it
if (self->retryLimit != -1 && retry > self->retryLimit) {

View File

@ -10,7 +10,6 @@ runConsistencyCheck = false
testName = 'IncrementalBackup'
tag = 'default'
submitOnly = true
waitForBackup = true
[[test]]
testTitle = 'PreSnapWorkloads'
@ -22,6 +21,7 @@ clearAfterTest = false
[[test]]
testTitle = 'TakeSnap'
clearAfterTest = false
runConsistencyCheck = false
[[test.workload]]
testName = 'SnapTest'