Skip to content

Commit e352043

Browse files
Proxy recovery: clear after fetch
1 parent 8847e72 commit e352043

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/sync/polling/fetchers/splitChangesFetcher.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,8 +71,11 @@ export function splitChangesFetcherFactory(fetchSplitChanges: IFetchSplitChanges
7171
if (lastProxyCheckTimestamp) {
7272
log.info(LOG_PREFIX_SYNC_SPLITS + 'Proxy error recovered');
7373
lastProxyCheckTimestamp = undefined;
74-
return Promise.all([storage.splits.clear(), storage.rbSegments.clear()])
75-
.then(() => splitChangesFetcher(storage.splits.getChangeNumber() as number, undefined, undefined, storage.rbSegments.getChangeNumber() as number));
74+
return splitChangesFetcher(-1, undefined, undefined, -1)
75+
.then((splitChangesResponse: ISplitChangesResponse) =>
76+
Promise.all([storage.splits.clear(), storage.rbSegments.clear()])
77+
.then(() => splitChangesResponse)
78+
);
7679
}
7780

7881
return data;

0 commit comments

Comments
 (0)