Decrypt and process messages in batches.

// FREEBIE
8 years ago · 9987ebb3c0
parent 023c804a61
commit 9987ebb3c0
2 changed files with 2 additions and 3 deletions
--- 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) {
--- 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) {