Skip to content

Commit 28147e3

Browse files
committed
delay current sync request instead of sending partial result
1 parent 2cfe0d3 commit 28147e3

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

ydb/core/tx/scheme_board/subscriber.cpp

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1040,10 +1040,13 @@ class TSubscriber: public TMonitorableActor<TDerived> {
10401040
this->Send(proxy, new TEvents::TEvPoisonPill());
10411041
}
10421042
}
1043+
10431044
if (CurrentSyncRequest) {
1044-
this->Send(Owner, new NInternalEvents::TEvSyncResponse(Path, true), 0, CurrentSyncRequest);
1045+
SBS_LOG_I("Delaying current sync request: " << CurrentSyncRequest);
1046+
DelayedSyncRequest = Max(DelayedSyncRequest, CurrentSyncRequest);
10451047
CurrentSyncRequest = 0;
10461048
}
1049+
10471050
ProxyToGroupMap.clear();
10481051
ProxyGroups.clear();
10491052
States.clear();

0 commit comments

Comments
 (0)