diff options
| author | Hazelnoot <acomputerdog@gmail.com> | 2024-11-27 23:19:14 -0500 |
|---|---|---|
| committer | Hazelnoot <acomputerdog@gmail.com> | 2024-12-08 08:01:33 -0500 |
| commit | ffbdfa912388c705ac288b68f45aa31fc9e75c40 (patch) | |
| tree | 221a825b0a28959638af7f5d7b7565f75046f62b /packages/backend/src/daemons | |
| parent | merge: Fix Content-Length resetting for partial content length requests (!796) (diff) | |
| download | sharkey-ffbdfa912388c705ac288b68f45aa31fc9e75c40.tar.gz sharkey-ffbdfa912388c705ac288b68f45aa31fc9e75c40.tar.bz2 sharkey-ffbdfa912388c705ac288b68f45aa31fc9e75c40.zip | |
Synchronize server startup
This prevents an edge case where the server begins processing inbound API / AP requests before any of the chart / management daemons are ready, potentially leading to incorrect chart statistics.
Diffstat (limited to 'packages/backend/src/daemons')
| -rw-r--r-- | packages/backend/src/daemons/QueueStatsService.ts | 4 | ||||
| -rw-r--r-- | packages/backend/src/daemons/ServerStatsService.ts | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/packages/backend/src/daemons/QueueStatsService.ts b/packages/backend/src/daemons/QueueStatsService.ts index ede104b9fe..77fcd71337 100644 --- a/packages/backend/src/daemons/QueueStatsService.ts +++ b/packages/backend/src/daemons/QueueStatsService.ts @@ -33,7 +33,7 @@ export class QueueStatsService implements OnApplicationShutdown { * Report queue stats regularly */ @bindThis - public start(): void { + public async start(): Promise<void> { const log = [] as any[]; ev.on('requestQueueStatsLog', x => { @@ -82,7 +82,7 @@ export class QueueStatsService implements OnApplicationShutdown { activeInboxJobs = 0; }; - tick(); + await tick(); this.intervalId = setInterval(tick, interval); } diff --git a/packages/backend/src/daemons/ServerStatsService.ts b/packages/backend/src/daemons/ServerStatsService.ts index 6e9d29dcbd..2ab087477a 100644 --- a/packages/backend/src/daemons/ServerStatsService.ts +++ b/packages/backend/src/daemons/ServerStatsService.ts @@ -68,7 +68,7 @@ export class ServerStatsService implements OnApplicationShutdown { if (log.length > 200) log.pop(); }; - tick(); + await tick(); this.intervalId = setInterval(tick, interval); } |