aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2022-12-22 22:19:59 +0300
committeralexvru <alexvru@ydb.tech>2022-12-22 22:19:59 +0300
commite13b044080568fc776845584d2c38846ff812640 (patch)
tree334512cb2b2bebf666015c9957419fc24d498f17
parent20fd4cc774d43eb2e87b3c0a23987cebfc85e7bd (diff)
downloadydb-e13b044080568fc776845584d2c38846ff812640.tar.gz
Correct reply order in tablet pipe
-rw-r--r--ydb/core/tablet/tablet_pipe_client.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/tablet/tablet_pipe_client.cpp b/ydb/core/tablet/tablet_pipe_client.cpp
index 28f0b0e5c5..55df667343 100644
--- a/ydb/core/tablet/tablet_pipe_client.cpp
+++ b/ydb/core/tablet/tablet_pipe_client.cpp
@@ -295,14 +295,14 @@ namespace NTabletPipe {
Become(&TThis::StateWork);
+ ctx.Send(Owner, new TEvTabletPipe::TEvClientConnected(TabletId, NKikimrProto::OK, ctx.SelfID, ServerId, Leader, false));
+
BLOG_D("send queued");
while (TAutoPtr<IEventHandle> x = PayloadQueue->Pop())
Push(ctx, x);
PayloadQueue.Destroy();
- ctx.Send(Owner, new TEvTabletPipe::TEvClientConnected(TabletId, NKikimrProto::OK, ctx.SelfID, ServerId, Leader, false));
-
if (IsShutdown) {
BLOG_D("shutdown pipe due to pending shutdown request");
return NotifyDisconnect(ctx);