From 9987ebb3c0ab170aa3e1c6d3b61eec422f987523 Mon Sep 17 00:00:00 2001
From: Matthew Chen <charlesmchen@gmail.com>
Date: Wed, 13 Sep 2017 18:06:38 -0400
Subject: [PATCH] Decrypt and process messages in batches.

// FREEBIE
---
 SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m | 2 +-
 SignalServiceKit/src/Messages/OWSMessageReceiver.m       | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m b/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m
index 176bde594..46a0bd0a3 100644
--- a/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m
+++ b/SignalServiceKit/src/Messages/OWSBatchMessageProcessor.m
@@ -299,7 +299,7 @@ NSString *const OWSBatchMessageProcessingJobFinderExtensionGroup = @"OWSBatchMes
 {
     AssertIsOnMainThread();
 
-    const NSUInteger kMaxBatchSize = 16;
+    const NSUInteger kMaxBatchSize = 10;
     NSArray<OWSBatchMessageProcessingJob *> *jobs = [self.finder nextJobsForBatchSize:kMaxBatchSize];
     OWSAssert(jobs);
     if (jobs.count < 1) {
diff --git a/SignalServiceKit/src/Messages/OWSMessageReceiver.m b/SignalServiceKit/src/Messages/OWSMessageReceiver.m
index 7a79747da..c7762f302 100644
--- a/SignalServiceKit/src/Messages/OWSMessageReceiver.m
+++ b/SignalServiceKit/src/Messages/OWSMessageReceiver.m
@@ -115,7 +115,6 @@ NSString *const OWSMessageProcessingJobFinderExtensionGroup = @"OWSMessageProces
                                        NSString *_Nonnull key,
                                        NSUInteger index,
                                        BOOL *_Nonnull stop) {
-                                       DDLogVerbose(@"key: %@", key);
                                        [jobIds addObject:key];
                                        if (jobIds.count >= maxBatchSize) {
                                            *stop = YES;
@@ -295,7 +294,7 @@ NSString *const OWSMessageProcessingJobFinderExtensionGroup = @"OWSMessageProces
 {
     AssertIsOnMainThread();
 
-    const NSUInteger kMaxBatchSize = 16;
+    const NSUInteger kMaxBatchSize = 10;
     NSArray<OWSMessageProcessingJob *> *jobs = [self.finder nextJobsForBatchSize:kMaxBatchSize];
     OWSAssert(jobs);
     if (jobs.count < 1) {