Supposedly fix possible race in direct read (#6140)

ydb-platform · Jul 2, 2024 · 8bf9bed · 8bf9bed
1 parent 8bebd27
commit 8bf9bed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ydb/core/persqueue/pq_impl.cpp b/ydb/core/persqueue/pq_impl.cpp
@@ -290,11 +290,11 @@ class TReadProxy : public TActorBootstrapped<TReadProxy> {
             }
             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());
         }