Decrease batcher wait time to speed up startup

signalapp · Mar 31, 2021 · 5c8cb6b · 5c8cb6b
1 parent 6f7ecb1
commit 5c8cb6b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/ts/textsecure/MessageReceiver.ts b/ts/textsecure/MessageReceiver.ts
@@ -205,7 +205,7 @@ class MessageReceiverInner extends EventTarget {
 
     this.cacheAddBatcher = createBatcher<CacheAddItemType>({
       name: 'MessageReceiver.cacheAddBatcher',
-      wait: 200,
+      wait: 75,
       maxSize: 30,
       processBatch: (items: Array<CacheAddItemType>) => {
         // Not returning the promise here because we don't want to stall
@@ -215,13 +215,13 @@ class MessageReceiverInner extends EventTarget {
     });
     this.cacheUpdateBatcher = createBatcher<CacheUpdateItemType>({
       name: 'MessageReceiver.cacheUpdateBatcher',
-      wait: 500,
+      wait: 75,
       maxSize: 30,
       processBatch: this.cacheUpdateBatch.bind(this),
     });
     this.cacheRemoveBatcher = createBatcher<string>({
       name: 'MessageReceiver.cacheRemoveBatcher',
-      wait: 500,
+      wait: 75,
       maxSize: 30,
       processBatch: this.cacheRemoveBatch.bind(this),
     });

diff --git a/ts/util/messageBatcher.ts b/ts/util/messageBatcher.ts
@@ -7,7 +7,7 @@ import { createWaitBatcher } from './waitBatcher';
 
 const updateMessageBatcher = createBatcher<MessageAttributesType>({
   name: 'messageBatcher.updateMessageBatcher',
-  wait: 500,
+  wait: 75,
   maxSize: 50,
   processBatch: async (messageAttrs: Array<MessageAttributesType>) => {
     window.log.info('updateMessageBatcher', messageAttrs.length);
@@ -33,7 +33,7 @@ export function setBatchingStrategy(keepBatching = false): void {
 
 export const saveNewMessageBatcher = createWaitBatcher<MessageAttributesType>({
   name: 'messageBatcher.saveNewMessageBatcher',
-  wait: 500,
+  wait: 75,
   maxSize: 30,
   processBatch: async (messageAttrs: Array<MessageAttributesType>) => {
     window.log.info('saveNewMessageBatcher', messageAttrs.length);