From e15b8ebe169b22ef7c13af6e5df3ba4a3a4c5e30 Mon Sep 17 00:00:00 2001 From: Matthew Chen Date: Fri, 14 Sep 2018 14:02:17 -0400 Subject: [PATCH] Add names to operation queues. --- SignalServiceKit/src/Contacts/ContactsUpdater.m | 1 + .../src/Contacts/OWSContactDiscoveryOperation.swift | 2 +- SignalServiceKit/src/Messages/OWSMessageSender.m | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/SignalServiceKit/src/Contacts/ContactsUpdater.m b/SignalServiceKit/src/Contacts/ContactsUpdater.m index 0189292ad..8f16c182c 100644 --- a/SignalServiceKit/src/Contacts/ContactsUpdater.m +++ b/SignalServiceKit/src/Contacts/ContactsUpdater.m @@ -42,6 +42,7 @@ NS_ASSUME_NONNULL_BEGIN _contactIntersectionQueue = [NSOperationQueue new]; _contactIntersectionQueue.maxConcurrentOperationCount = 1; + _contactIntersectionQueue.name = self.logTag; OWSSingletonAssert(); diff --git a/SignalServiceKit/src/Contacts/OWSContactDiscoveryOperation.swift b/SignalServiceKit/src/Contacts/OWSContactDiscoveryOperation.swift index f5fe4fc27..301965b6c 100644 --- a/SignalServiceKit/src/Contacts/OWSContactDiscoveryOperation.swift +++ b/SignalServiceKit/src/Contacts/OWSContactDiscoveryOperation.swift @@ -156,7 +156,7 @@ class CDSOperation: OWSOperation { static let operationQueue: OperationQueue = { let queue = OperationQueue() queue.maxConcurrentOperationCount = 5 - + queue.name = CDSOperation.logTag() return queue }() diff --git a/SignalServiceKit/src/Messages/OWSMessageSender.m b/SignalServiceKit/src/Messages/OWSMessageSender.m index 6bc43cde4..12871617a 100644 --- a/SignalServiceKit/src/Messages/OWSMessageSender.m +++ b/SignalServiceKit/src/Messages/OWSMessageSender.m @@ -260,7 +260,7 @@ NSString *const OWSMessageSenderRateLimitedException = @"RateLimitedException"; sendingQueue = [NSOperationQueue new]; sendingQueue.qualityOfService = NSOperationQualityOfServiceUserInitiated; sendingQueue.maxConcurrentOperationCount = 1; - + sendingQueue.name = [NSString stringWithFormat:@"%@:%@", self.logTag, queueKey]; self.sendingQueueMap[queueKey] = sendingQueue; }