From 08e560f9695dc0654b39855ef85b38099e3ae210 Mon Sep 17 00:00:00 2001 From: Matthew Chen Date: Fri, 29 Sep 2017 14:38:32 -0400 Subject: [PATCH] Respond to CR. // FREEBIE --- SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m b/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m index b790e5e2b..5d4f4673e 100644 --- a/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m +++ b/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m @@ -318,7 +318,7 @@ NSString *const OWSMessageContentJobFinderExtensionGroup = @"OWSMessageContentJo AssertOnDispatchQueue(self.serialQueue); // We want a value that is just high enough to yield perf benefits. - const NSUInteger kIncomingMessageBatchSize = 16; + const NSUInteger kIncomingMessageBatchSize = 32; NSArray *jobs = [self.finder nextJobsForBatchSize:kIncomingMessageBatchSize]; OWSAssert(jobs); @@ -341,7 +341,7 @@ NSString *const OWSMessageContentJobFinderExtensionGroup = @"OWSMessageContentJo // This delay won't affect the first message to arrive when this queue is idle, // so by definition we're receiving more than one message and can benefit from // batching. - dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.f * NSEC_PER_SEC)), self.serialQueue, ^{ + dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.5f * NSEC_PER_SEC)), self.serialQueue, ^{ [self drainQueueWorkStep]; }); }