diff --git a/fdbserver/LogRouter.cpp b/fdbserver/LogRouter.cpp index 1f55f77e15..da0b6026e8 100644 --- a/fdbserver/LogRouter.cpp +++ b/fdbserver/LogRouter.cpp @@ -226,7 +226,7 @@ struct LogRouterData { Optional> reqSequence = Optional>()); // Keeps pushing TLogPeekStreamReply until it's removed from the cluster or should recover - Future logRouterPeekStream(const TLogPeekStreamRequest& req); + Future 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 LogRouterData::logRouterPeekMessages(PromiseType replyPromise, .detail("PoppedVersion", poppedVersion); } -Future LogRouterData::logRouterPeekStream(const TLogPeekStreamRequest& req) { +Future LogRouterData::logRouterPeekStream(TLogPeekStreamRequest req) { activePeekStreams++; Version begin = req.begin;