From 1afb2d42da83f82660696239af7e4cb4f2baabff Mon Sep 17 00:00:00 2001
From: Jingyu Zhou <jingyuzhou@gmail.com>
Date: Fri, 23 Aug 2024 17:41:39 -0700
Subject: [PATCH] Fix crash due to invalid ReplyPromise

---
 fdbserver/LogRouter.cpp | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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<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;