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

Fix crash due to invalid ReplyPromise

This commit is contained in:
Jingyu Zhou 2024-08-23 17:41:39 -07:00
parent fac874595f
commit 1afb2d42da
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fdbserver/LogRouter.cpp
View File

@ -226,7 +226,7 @@ struct LogRouterData {
Optional<std::pair<UID, int>> reqSequence = Optional<std::pair<UID, int>>());
// Keeps pushing TLogPeekStreamReply until it's removed from the cluster or should recover
Future<Void> logRouterPeekStream(const TLogPeekStreamRequest& req);
Future<Void> logRouterPeekStream(TLogPeekStreamRequest req);
// Log router (LR) asynchronously pull data from satellite tLogs (preferred) or primary tLogs at tag
// (self->routerTag) for the version range from the LR's current version (exclusive) to its epoch's end version or
@ -696,7 +696,7 @@ Future<Void> LogRouterData::logRouterPeekMessages(PromiseType replyPromise,
.detail("PoppedVersion", poppedVersion);
}
Future<Void> LogRouterData::logRouterPeekStream(const TLogPeekStreamRequest& req) {
Future<Void> LogRouterData::logRouterPeekStream(TLogPeekStreamRequest req) {
activePeekStreams++;
Version begin = req.begin;