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

Added connection fault disabler within setup of backup submission. It should be reviewed to determine the amount of time to wait before disabling

This commit is contained in:
Alvin Moore 2017-05-31 14:21:50 -07:00
parent 98604d33a0
commit 333f2e4865
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -56,6 +56,7 @@ struct AtomicSwitchoverWorkload : TestWorkload {
ACTOR static Future<Void> _setup(Database cx, AtomicSwitchoverWorkload* self) {
state DatabaseBackupAgent backupAgent(cx);
state Future<Void> disabler = disableConnectionFailuresAfter(300, "atomicSwitchover");
try {
TraceEvent("AS_Submit1");
Void _ = wait( backupAgent.submitBackup(self->extraDB, BackupAgentBase::getDefaultTag(), self->backupRanges, false, StringRef(), StringRef(), true) );
@ -96,7 +97,7 @@ struct AtomicSwitchoverWorkload : TestWorkload {
auto src = srcFuture.get().begin();
auto bkp = bkpFuture.get().begin();
while (src != srcFuture.get().end() && bkp != bkpFuture.get().end()) {
KeyRef bkpKey = bkp->key.substr(backupPrefix.size());
if (src->key != bkpKey && src->value != bkp->value) {
@ -156,7 +157,7 @@ struct AtomicSwitchoverWorkload : TestWorkload {
state Future<Void> switch2After = delay(self->switch2After);
state Future<Void> stopAfter = delay(self->stopAfter);
state Future<Void> disabler = disableConnectionFailuresAfter(300, "atomicSwitchover");
TraceEvent("AS_Wait1");
int _ = wait( backupAgent.waitBackup(self->extraDB, BackupAgentBase::getDefaultTag(), false) );
TraceEvent("AS_Ready1");
@ -186,4 +187,4 @@ struct AtomicSwitchoverWorkload : TestWorkload {
}
};
WorkloadFactory<AtomicSwitchoverWorkload> AtomicSwitchoverWorkloadFactory("AtomicSwitchover");
WorkloadFactory<AtomicSwitchoverWorkload> AtomicSwitchoverWorkloadFactory("AtomicSwitchover");