This commit is contained in:
Lukas Joswiak 2022-10-18 21:56:28 -07:00
parent a8f8757f77
commit 28540e5962
2 changed files with 2 additions and 6 deletions

View File

@ -3556,9 +3556,7 @@ ACTOR Future<Void> tLog(IKeyValueStore* persistentData,
forwardPromise(req.reply, self.tlogCache.get(req.recruitmentID));
}
}
when(wait(error)) {
throw internal_error();
}
when(wait(error)) { throw internal_error(); }
when(wait(activeSharedChange)) {
if (activeSharedTLog->get() == tlogId) {
TraceEvent("SharedTLogNowActive", self.dbgid).detail("NowActive", activeSharedTLog->get());

View File

@ -686,9 +686,7 @@ ACTOR Future<Void> registrationClient(
when(wait(FlowTransport::transport().onIncompatibleChanged())) { break; }
when(wait(issues->onChange())) { break; }
when(wait(recovered)) { break; }
when(wait(clusterId->onChange())) {
break;
}
when(wait(clusterId->onChange())) { break; }
}
}
}