mirrors/signal-desktop
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 2 Wiki Activity Actions

Fix paging queries in the worker system

Browse source
This commit is contained in:
Fedor Indutny 2024-07-24 13:06:32 -07:00 • committed by GitHub
parent 16864e381a
commit c619a7b6fd
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
ts/sql/main.ts
View file

@ -19,6 +19,13 @@ const MIN_TRACE_DURATION = 40;
const WORKER_COUNT = 4; const WORKER_COUNT = 4;
const PAGING_QUERIES = new Set<keyof ServerReadableDirectInterface>([
'pageMessages',
'finishPageMessages',
'getKnownMessageAttachments',
'finishGetKnownMessageAttachments',
]);
export type InitializeOptions = Readonly<{ export type InitializeOptions = Readonly<{
appVersion: string; appVersion: string;
configDir: string; configDir: string;
@ -216,7 +223,7 @@ export class MainSQL {
// pageMessages runs over several queries and needs to have access to // pageMessages runs over several queries and needs to have access to
// the same temporary table. // the same temporary table.
const isPaging = method === 'pageMessages'; const isPaging = PAGING_QUERIES.has(method);
const entry = isPaging ? this.pool.at(-1) : this.getWorker(); const entry = isPaging ? this.pool.at(-1) : this.getWorker();
strictAssert(entry != null, 'Must have a pool entry'); strictAssert(entry != null, 'Must have a pool entry');