Fix invalid read

This commit is contained in:
Lukas Joswiak 2021-07-13 10:44:37 -07:00
parent e0f3b2718a
commit 5338251946

View File

@ -1529,11 +1529,12 @@ struct TagPartitionedLogSystem : ILogSystem, ReferenceCounted<TagPartitionedLogS
}
}
state UID dbgid = self->dbgid;
state Future<Void> maxGetPoppedDuration = delay(SERVER_KNOBS->TXS_POPPED_MAX_DELAY);
wait(waitForAll(poppedReady) || maxGetPoppedDuration);
if (maxGetPoppedDuration.isReady()) {
TraceEvent(SevWarnAlways, "PoppedTxsNotReady", self->dbgid);
TraceEvent(SevWarnAlways, "PoppedTxsNotReady", dbgid);
}
Version maxPopped = 1;