From fae6e4da8f516a9d6c3bad9bf6f35811ccacbad8 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Thu, 18 Feb 2021 14:44:12 +0100 Subject: Try to speed up server tests --- server/lib/activitypub/inbox-manager.ts | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'server/lib/activitypub') diff --git a/server/lib/activitypub/inbox-manager.ts b/server/lib/activitypub/inbox-manager.ts index 6d9bf7cf0..18ae49532 100644 --- a/server/lib/activitypub/inbox-manager.ts +++ b/server/lib/activitypub/inbox-manager.ts @@ -35,7 +35,7 @@ class InboxManager { }) setInterval(() => { - StatsManager.Instance.updateInboxStats(this.messagesProcessed, this.inboxQueue.length()) + StatsManager.Instance.updateInboxStats(this.messagesProcessed, this.getActivityPubMessagesWaiting()) }, SCHEDULER_INTERVALS_MS.updateInboxStats) } @@ -44,6 +44,10 @@ class InboxManager { .catch(err => logger.error('Cannot add options in inbox queue.', { options, err })) } + getActivityPubMessagesWaiting () { + return this.inboxQueue.length() + this.inboxQueue.running() + } + static get Instance () { return this.instance || (this.instance = new this()) } -- cgit v1.2.3