diff options
| author | Ilnaz Nizametdinov <i.nizametdinov@gmail.com> | 2022-07-04 23:03:15 +0300 |
|---|---|---|
| committer | Ilnaz Nizametdinov <i.nizametdinov@gmail.com> | 2022-07-04 23:03:15 +0300 |
| commit | 4b2ebcd45c514b32b527b5885225952898775fcc (patch) | |
| tree | 12e59f3cbf61440691da136dc1eb2bcb1550941f | |
| parent | 219751b228f6178193ccb5045b6ddcdd4432b5b5 (diff) | |
| download | ydb-4b2ebcd45c514b32b527b5885225952898775fcc.tar.gz | |
Send TEvSendStrongNotifications only if required KIKIMR-15260
ref:badbbe4db3f8e9486620592f9db024bef7a94527
| -rw-r--r-- | ydb/core/tx/scheme_board/replica.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/ydb/core/tx/scheme_board/replica.cpp b/ydb/core/tx/scheme_board/replica.cpp index 7aa4b2d4d32..100ae3454da 100644 --- a/ydb/core/tx/scheme_board/replica.cpp +++ b/ydb/core/tx/scheme_board/replica.cpp @@ -1068,9 +1068,11 @@ private: << ", generation# " << generation); info.Generation = info.PendingGeneration; - Send(ev->Sender, new TSchemeBoardEvents::TEvCommitResponse(owner, info.Generation), 0, ev->Cookie); - Send(SelfId(), new TEvPrivate::TEvSendStrongNotifications(owner)); + + if (WaitStrongNotifications.contains(owner)) { + Send(SelfId(), new TEvPrivate::TEvSendStrongNotifications(owner)); + } } void Handle(TEvPrivate::TEvSendStrongNotifications::TPtr& ev) { |