From 8bf9bede4981408507098dbc2d095ce3ac731643 Mon Sep 17 00:00:00 2001 From: FloatingCrowbar Date: Tue, 2 Jul 2024 12:03:55 +0300 Subject: [PATCH] Supposedly fix possible race in direct read (#6140) --- ydb/core/persqueue/pq_impl.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ydb/core/persqueue/pq_impl.cpp b/ydb/core/persqueue/pq_impl.cpp index 5e89d767f0e9..6871e01df006 100644 --- a/ydb/core/persqueue/pq_impl.cpp +++ b/ydb/core/persqueue/pq_impl.cpp @@ -290,11 +290,11 @@ class TReadProxy : public TActorBootstrapped { } Response->Record.SetStatus(NMsgBusProxy::MSTATUS_OK); Response->Record.SetErrorCode(NPersQueue::NErrorCode::OK); - ctx.Send(Sender, Response.Release()); ctx.Send( MakePQDReadCacheServiceActorId(), new TEvPQ::TEvStageDirectReadData(DirectReadKey, TabletGeneration, PreparedResponse) ); + ctx.Send(Sender, Response.Release()); } else { ctx.Send(Sender, Response.Release()); }