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

Cache eviction: switch to queue to avoid stack explosion

Browse Source
This commit is contained in:
Ali 2023-02-24 19:24:17 +04:00
parent 5ec0fc43fb
commit 4adb4fa5be
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
submodules/TelegramCore/Sources/Utils/AutomaticCacheEviction.swift
View File

@ -105,9 +105,17 @@ final class AutomaticCacheEvictionContext {
|> mapToSignal { channelCategoryMapping -> Signal<Never, NoError> in |> mapToSignal { channelCategoryMapping -> Signal<Never, NoError> in
var signals: Signal<Never, NoError> = .complete() var signals: Signal<Never, NoError> = .complete()
var matchingPeers = 0 let listSignal = Signal<PeerId, NoError> { subscriber in
for peerId in peerIds {
subscriber.putNext(peerId)
}
subscriber.putCompletion()
return EmptyDisposable
}
for peerId in peerIds { signals = listSignal |> mapToQueue { peerId -> Signal<Never, NoError> in
let timeout: Int32 let timeout: Int32
if let value = settings.exceptions.first(where: { $0.key == peerId }) { if let value = settings.exceptions.first(where: { $0.key == peerId }) {
timeout = value.value timeout = value.value
@ -127,15 +135,13 @@ final class AutomaticCacheEvictionContext {
} }
if timeout == Int32.max { if timeout == Int32.max {
continue return .complete()
} }
matchingPeers += 1
let minPeerTimestamp = Int32(CFAbsoluteTimeGetCurrent() + NSTimeIntervalSince1970) - timeout let minPeerTimestamp = Int32(CFAbsoluteTimeGetCurrent() + NSTimeIntervalSince1970) - timeout
//let minPeerTimestamp = Int32(CFAbsoluteTimeGetCurrent() + NSTimeIntervalSince1970) //let minPeerTimestamp = Int32(CFAbsoluteTimeGetCurrent() + NSTimeIntervalSince1970)
signals = signals |> then(mediaBox.storageBox.all(peerId: peerId) return mediaBox.storageBox.all(peerId: peerId)
|> mapToSignal { peerResourceIds -> Signal<Never, NoError> in |> mapToSignal { peerResourceIds -> Signal<Never, NoError> in
return Signal { subscriber in return Signal { subscriber in
var isCancelled = false var isCancelled = false
@ -185,11 +191,9 @@ final class AutomaticCacheEvictionContext {
isCancelled = true isCancelled = true
} }
} }
}) }
} }
Logger.shared.log("AutomaticCacheEviction", "have \(matchingPeers) peers with data")
return signals return signals
} }
}).start() }).start()