diff options
author | alexvru <alexvru@ydb.tech> | 2022-12-22 22:19:59 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2022-12-22 22:19:59 +0300 |
commit | e13b044080568fc776845584d2c38846ff812640 (patch) | |
tree | 334512cb2b2bebf666015c9957419fc24d498f17 | |
parent | 20fd4cc774d43eb2e87b3c0a23987cebfc85e7bd (diff) | |
download | ydb-e13b044080568fc776845584d2c38846ff812640.tar.gz |
Correct reply order in tablet pipe
-rw-r--r-- | ydb/core/tablet/tablet_pipe_client.cpp | 4 |
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); |