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

Implement progressive JPEG for photos

Browse Source
This commit is contained in:
Ali
2020-07-28 17:39:34 +04:00
parent 6f731d3b63
commit e1432e4171
562 changed files with 168453 additions and 188 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
submodules/Postbox/Sources/MediaBox.swift
View File

@@ -598,10 +598,40 @@ public final class MediaBox {
}
}
public func resourceData(_ resource: MediaResource, size: Int, in range: Range<Int>, mode: ResourceDataRangeMode = .complete) -> Signal<(Data, Bool), NoError> {
public func resourceData(_ resource: MediaResource, size: Int, in range: Range<Int>, mode: ResourceDataRangeMode = .complete, notifyAboutIncomplete: Bool = false, attemptSynchronously: Bool = false) -> Signal<(Data, Bool), NoError> {
return Signal { subscriber in
let disposable = MetaDisposable()
if attemptSynchronously {
let paths = self.storePathsForId(resource.id)
if let completeSize = fileSize(paths.complete) {
self.timeBasedCleanup.touch(paths: [
paths.complete
])
if let file = ManagedFile(queue: nil, path: paths.complete, mode: .read) {
let clippedLowerBound = min(completeSize, max(0, range.lowerBound))
let clippedUpperBound = min(completeSize, max(0, range.upperBound))
if clippedLowerBound < clippedUpperBound {
file.seek(position: Int64(clippedLowerBound))
let data = file.readData(count: clippedUpperBound)
subscriber.putNext((data, true))
} else {
subscriber.putNext((Data(), isComplete: true))
}
subscriber.putCompletion()
return EmptyDisposable
} else {
if let data = MediaBoxPartialFile.extractPartialData(path: paths.partial, metaPath: paths.partial + ".meta", range: Int32(range.lowerBound) ..< Int32(range.upperBound)) {
subscriber.putNext((data, true))
subscriber.putCompletion()
return EmptyDisposable
}
}
}
}
self.dataQueue.async {
guard let (fileContext, releaseContext) = self.fileContext(for: resource) else {
subscriber.putCompletion()
@@ -613,24 +643,25 @@ public final class MediaBox {
let dataDisposable = fileContext.data(range: range, waitUntilAfterInitialFetch: false, next: { result in
if let file = ManagedFile(queue: self.dataQueue, path: result.path, mode: .read), let fileSize = file.getSize() {
if result.complete {
if result.offset + result.size <= fileSize {
if fileSize >= result.offset + result.size {
file.seek(position: Int64(result.offset))
let resultData = file.readData(count: result.size)
subscriber.putNext((resultData, true))
subscriber.putCompletion()
} else {
assertionFailure("data.count >= result.offset + result.size")
}
let clippedLowerBound = min(result.offset, fileSize)
let clippedUpperBound = min(result.offset + result.size, fileSize)
if clippedUpperBound == clippedLowerBound {
subscriber.putNext((Data(), true))
subscriber.putCompletion()
} else if clippedUpperBound <= fileSize {
file.seek(position: Int64(clippedLowerBound))
let resultData = file.readData(count: clippedUpperBound - clippedLowerBound)
subscriber.putNext((resultData, true))
subscriber.putCompletion()
} else {
assertionFailure()
}
} else {
switch mode {
case .complete:
break
case .incremental:
break
case .complete, .incremental:
if notifyAboutIncomplete {
subscriber.putNext((Data(), false))
}
case .partial:
subscriber.putNext((Data(), false))
}