Method work

fdbserver/workloads/DDMetrics.actor.cpp:49–68

	}

	ACTOR Future<Void> work(Database cx, DDMetricsWorkload* self) {
		try {
			TraceEvent("DDMetricsWaiting").detail("StartDelay", self->startDelay);
			wait(delay(self->startDelay));
			TraceEvent("DDMetricsStarting").log();
			state double startTime = now();
			loop {
				wait(delay(2.5));
				int dif = wait(self->getHighPriorityRelocationsInFlight(cx, self));
				TraceEvent("DDMetricsCheck").detail("DIF", dif);
				if (dif == 0) {
					self->ddDone = now() - startTime;
					return Void();
				}
			}
		} catch (Error& e) {
			TraceEvent("DDMetricsError").error(e);
		}
		return Void();
	}

	Future<Void> start(Database const& cx) override { return clientId == 0 ? work(cx, this) : Void(); }