From 870cba46ddcd4bc62a9c198c7dce9c69444537cc Mon Sep 17 00:00:00 2001 From: alina sireneva Date: Sat, 10 May 2025 13:12:41 +0300 Subject: [PATCH] feat: warn every 100 queued updates --- packages/core/src/highlevel/updates/manager.ts | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/packages/core/src/highlevel/updates/manager.ts b/packages/core/src/highlevel/updates/manager.ts index ee3d51a8..3974e17e 100644 --- a/packages/core/src/highlevel/updates/manager.ts +++ b/packages/core/src/highlevel/updates/manager.ts @@ -85,6 +85,8 @@ import { // return state.rpsProcessing.getRps() // } +const WARN_EVERY = 100 + const KEEP_ALIVE_INTERVAL = 15 * 60 * 1000 // 15 minutes const UPDATES_TOO_LONG = { _: 'updatesTooLong' } as const @@ -330,6 +332,10 @@ export class UpdatesManager { assertNever(update) } + if (this.pendingUpdateContainers.length % WARN_EVERY === 0) { + this.log.warn('%d pending update containers, updatesLoopActive = %b. possible memory leak', this.pendingUpdateContainers.length, this.updatesLoopActive) + } + this.updatesLoopCv.notify() }