ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-12-23 22:55:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add more logging [skip ci]

Browse Source
This commit is contained in:
Ali
2020-04-22 13:08:52 +04:00
parent fa463177f6
commit 5acbd51bbe
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
submodules/TelegramCore/Sources/PendingMessageManager.swift
View File

@@ -180,6 +180,10 @@ public final class PendingMessageManager {
let removedMessageIds = self.pendingMessageIds.subtracting(messageIds)
let removedSecretMessageIds = Set(removedMessageIds.filter({ $0.peerId.namespace == Namespaces.Peer.SecretChat }))
if !removedMessageIds.isEmpty {
Logger.shared.log("PendingMessageManager", "removed messages: \(removedMessageIds)")
}
var updateUploadingPeerIds = Set<PeerId>()
var updateUploadingGroupIds = Set<Int64>()
for id in removedMessageIds {
@@ -207,6 +211,7 @@ public final class PendingMessageManager {
}
if !addedMessageIds.isEmpty {
Logger.shared.log("PendingMessageManager", "added messages: \(addedMessageIds)")
self.beginSendingMessages(Array(addedMessageIds).sorted())
}
@@ -251,6 +256,8 @@ public final class PendingMessageManager {
peersWithPendingMessages.insert(id.peerId)
}
Logger.shared.log("PendingMessageManager", "pengine messages: \(self.pendingMessageIds)")
self._hasPendingMessages.set(peersWithPendingMessages)
}
}
@@ -333,6 +340,8 @@ public final class PendingMessageManager {
}
}
Logger.shared.log("PendingMessageManager", "begin sending: \(ids)")
let disposable = MetaDisposable()
let messages = self.postbox.messagesAtIds(ids)
|> deliverOn(self.queue)
@@ -346,6 +355,8 @@ public final class PendingMessageManager {
if let strongSelf = self {
assert(strongSelf.queue.isCurrent())
Logger.shared.log("PendingMessageManager", "begin sending, continued: \(ids)")
for message in messages.filter({ !$0.flags.contains(.Sending) }).sorted(by: { $0.id < $1.id }) {
guard let messageContext = strongSelf.messageContexts[message.id] else {
continue