ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2026-01-20 11:09:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make "isQueueBusy" check synchronous

Browse Source
This commit is contained in:
chrwend
2016-03-23 20:28:28 -07:00
committed by Lukas Spieß
parent 6bbe8383c3
commit fa2ad00a2e
1 changed files with 20 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
Classes/BITChannel.m
View File

@@ -92,38 +92,42 @@ NS_ASSUME_NONNULL_BEGIN
#pragma mark - Adding to queue
- (BOOL)enqueueTelemetryItem:(BITTelemetryData *)item {
- (void)enqueueTelemetryItem:(BITTelemetryData *)item {
if (!item) {
// Case 1: Item is nil: Do not enqueue item and abort operation
BITHockeyLog(@"WARNING: TelemetryItem was nil.");
return NO;
return;
}
if (self.isQueueBusy) {
BITHockeyLog(@"The channel is saturated. %@ was dropped.", item.name);
if (![self timerIsRunning]) {
[self startTimer];
}
return NO;
}
NSDictionary *dict = [self dictionaryForTelemetryData:item];
__weak typeof(self) weakSelf = self;
dispatch_async(self.dataItemsOperations, ^{
typeof(self) strongSelf = weakSelf;
if (strongSelf.isQueueBusy) {
// Case 2: Channel is in blocked state: Trigger sender, start timer to check after again after a while and abort operation.
BITHockeyLog(@"The channel is saturated. %@ was dropped.", item.debugDescription);
if (![strongSelf timerIsRunning]) {
[strongSelf startTimer];
}
return;
}
// Enqueue item
NSDictionary *dict = [self dictionaryForTelemetryData:item];
[strongSelf appendDictionaryToJsonStream:dict];
if (strongSelf->_dataItemCount >= self.maxBatchSize) {
// Max batch count has been reached, so write queue to disk and delete all items.
// Case 3: Max batch count has been reached, so write queue to disk and delete all items.
[strongSelf persistDataItemQueue];
} else if (strongSelf->_dataItemCount == 1) {
// It is the first item, let's start the timer
// Case 4: It is the first item, let's start the timer.
if (![strongSelf timerIsRunning]) {
[strongSelf startTimer];
}
}
});
return YES;
}
#pragma mark - Envelope telemerty items