From 3c836908aa0cb5cb38f3eaa4b606065c83bde7fa Mon Sep 17 00:00:00 2001 From: Fedor Indutny <79877362+indutny-signal@users.noreply.github.com> Date: Mon, 24 Jan 2022 15:50:32 -0800 Subject: [PATCH] Revert "MessageReceiver: Pause processing of new messages on suspend" This reverts commit d74424a3b8a6c9a4b2d5d04586700a224a45f08d. --- ts/background.ts | 4 +--- ts/textsecure/MessageReceiver.ts | 16 ---------------- 2 files changed, 1 insertion(+), 19 deletions(-) diff --git a/ts/background.ts b/ts/background.ts index 84dbe502b0..3d89716ab3 100644 --- a/ts/background.ts +++ b/ts/background.ts @@ -1564,15 +1564,13 @@ export async function startApp(): Promise { window.Whisper.events.on('powerMonitorSuspend', () => { log.info('powerMonitor: suspend'); - messageReceiver?.pause(); suspendTasksWithTimeout(); }); window.Whisper.events.on('powerMonitorResume', () => { log.info('powerMonitor: resume'); - messageReceiver?.resume(); - resumeTasksWithTimeout(); server?.checkSockets(); + resumeTasksWithTimeout(); }); window.Whisper.events.on('powerMonitorLockScreen', () => { diff --git a/ts/textsecure/MessageReceiver.ts b/ts/textsecure/MessageReceiver.ts index fb9db389e5..19d7670c5d 100644 --- a/ts/textsecure/MessageReceiver.ts +++ b/ts/textsecure/MessageReceiver.ts @@ -187,22 +187,6 @@ export default class MessageReceiver private stoppingProcessing?: boolean; - pause(): void { - this.incomingQueue.pause(); - this.encryptedQueue.pause(); - this.decryptedQueue.pause(); - this.appQueue.pause(); - log.info('MessageReceiver: Paused'); - } - - resume(): void { - this.appQueue.start(); - this.decryptedQueue.start(); - this.encryptedQueue.start(); - this.incomingQueue.start(); - log.info('MessageReceiver: Resumed'); - } - constructor({ server, storage, serverTrustRoot }: MessageReceiverOptions) { super();