rename sessionCipher to sessionStoreQueue

// FREEBIE
pull/1/head
Michael Kirk 8 years ago
parent 60dcadb0d7
commit 7578176e37

@ -993,7 +993,7 @@ NSString *const OWSMessageSenderRateLimitedException = @"RateLimitedException";
__block NSException *encryptionException; __block NSException *encryptionException;
// Mutating session state is not thread safe, so we operate on a serial queue, shared with decryption // Mutating session state is not thread safe, so we operate on a serial queue, shared with decryption
// operations. // operations.
dispatch_sync([OWSDispatch sessionCipher], ^{ dispatch_sync([OWSDispatch sessionStoreQueue], ^{
@try { @try {
messageDict = [self encryptedMessageWithPlaintext:plainText messageDict = [self encryptedMessageWithPlaintext:plainText
toRecipient:recipient.uniqueId toRecipient:recipient.uniqueId

@ -251,7 +251,7 @@ NS_ASSUME_NONNULL_BEGIN
return; return;
} }
dispatch_async([OWSDispatch sessionCipher], ^{ dispatch_async([OWSDispatch sessionStoreQueue], ^{
NSData *plaintextData; NSData *plaintextData;
@try { @try {
@ -300,7 +300,7 @@ NS_ASSUME_NONNULL_BEGIN
return; return;
} }
dispatch_async([OWSDispatch sessionCipher], ^{ dispatch_async([OWSDispatch sessionStoreQueue], ^{
NSData *plaintextData; NSData *plaintextData;
@try { @try {
// Check whether we need to refresh our PreKeys every time we receive a PreKeyWhisperMessage. // Check whether we need to refresh our PreKeys every time we receive a PreKeyWhisperMessage.

@ -15,7 +15,7 @@ NS_ASSUME_NONNULL_BEGIN
* Signal protocol session state must be coordinated on a serial queue. This is sometimes used synchronously, * Signal protocol session state must be coordinated on a serial queue. This is sometimes used synchronously,
* so never dispatching sync *from* this queue to avoid deadlock. * so never dispatching sync *from* this queue to avoid deadlock.
*/ */
+ (dispatch_queue_t)sessionCipher; + (dispatch_queue_t)sessionStoreQueue;
/** /**
* Serial message sending queue * Serial message sending queue

@ -18,12 +18,12 @@ NS_ASSUME_NONNULL_BEGIN
return queue; return queue;
} }
+ (dispatch_queue_t)sessionCipher + (dispatch_queue_t)sessionStoreQueue
{ {
static dispatch_once_t onceToken; static dispatch_once_t onceToken;
static dispatch_queue_t queue; static dispatch_queue_t queue;
dispatch_once(&onceToken, ^{ dispatch_once(&onceToken, ^{
queue = dispatch_queue_create("org.whispersystems.signal.sessionCipher", NULL); queue = dispatch_queue_create("org.whispersystems.signal.sessionStoreQueue", NULL);
}); });
return queue; return queue;
} }

Loading…
Cancel
Save