diff --git a/fdbserver/workloads/DcLag.actor.cpp b/fdbserver/workloads/DcLag.actor.cpp index 93044caee58..1b2a5df8151 100644 --- a/fdbserver/workloads/DcLag.actor.cpp +++ b/fdbserver/workloads/DcLag.actor.cpp @@ -158,7 +158,8 @@ struct DcLagWorkload : TestWorkload { TraceEvent("DcLag").detail("StartTime", startTime).detail("EndTime", workloadEnd); // Clog and wait for recovery to happen - if (!self->clogTlog(self->testDuration)) { + double clogDuration = self->testDuration * (0.5 + 0.4 * deterministicRandom()->random01()); + if (!self->clogTlog(clogDuration)) { return Void(); // skip the test if no satellite found } diff --git a/fdbserver/workloads/FailoverWithSSLag.actor.cpp b/fdbserver/workloads/FailoverWithSSLag.actor.cpp index 12022cf5c75..5f34a20d9a1 100644 --- a/fdbserver/workloads/FailoverWithSSLag.actor.cpp +++ b/fdbserver/workloads/FailoverWithSSLag.actor.cpp @@ -259,7 +259,8 @@ struct FailoverWithSSLagWorkload : TestWorkload { } // Clog connections between remote tlogs and storage servers. - if (!self->findAndClogRemoteStorages(self->testDuration)) { + double clogDuration = self->testDuration * (0.5 + 0.4 * deterministicRandom()->random01()); + if (!self->findAndClogRemoteStorages(clogDuration)) { // Couldn't find remote tlogs/storage servers. Probably configuration will // need to be adjusted. self->testSuccess = false;