From 9db437c8155f3563a33e22ed2896072a9f1fbdb0 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Wed, 13 Oct 2021 11:47:32 +0200 Subject: Process slow followers in unicast job queue --- server/lib/schedulers/actor-follow-scheduler.ts | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'server/lib/schedulers/actor-follow-scheduler.ts') diff --git a/server/lib/schedulers/actor-follow-scheduler.ts b/server/lib/schedulers/actor-follow-scheduler.ts index 1b80316e9..a5a377573 100644 --- a/server/lib/schedulers/actor-follow-scheduler.ts +++ b/server/lib/schedulers/actor-follow-scheduler.ts @@ -2,7 +2,7 @@ import { isTestInstance } from '../../helpers/core-utils' import { logger } from '../../helpers/logger' import { ACTOR_FOLLOW_SCORE, SCHEDULER_INTERVALS_MS } from '../../initializers/constants' import { ActorFollowModel } from '../../models/actor/actor-follow' -import { ActorFollowScoreCache } from '../files-cache' +import { ActorFollowHealthCache } from '../actor-follow-health-cache' import { AbstractScheduler } from './abstract-scheduler' export class ActorFollowScheduler extends AbstractScheduler { @@ -22,13 +22,13 @@ export class ActorFollowScheduler extends AbstractScheduler { } private async processPendingScores () { - const pendingScores = ActorFollowScoreCache.Instance.getPendingFollowsScore() - const badServerIds = ActorFollowScoreCache.Instance.getBadFollowingServerIds() - const goodServerIds = ActorFollowScoreCache.Instance.getGoodFollowingServerIds() + const pendingScores = ActorFollowHealthCache.Instance.getPendingFollowsScore() + const badServerIds = ActorFollowHealthCache.Instance.getBadFollowingServerIds() + const goodServerIds = ActorFollowHealthCache.Instance.getGoodFollowingServerIds() - ActorFollowScoreCache.Instance.clearPendingFollowsScore() - ActorFollowScoreCache.Instance.clearBadFollowingServerIds() - ActorFollowScoreCache.Instance.clearGoodFollowingServerIds() + ActorFollowHealthCache.Instance.clearPendingFollowsScore() + ActorFollowHealthCache.Instance.clearBadFollowingServerIds() + ActorFollowHealthCache.Instance.clearGoodFollowingServerIds() for (const inbox of Object.keys(pendingScores)) { await ActorFollowModel.updateScore(inbox, pendingScores[inbox]) -- cgit v1.2.3