r4sas/webogram-i2p
1
0
Fork 0
Code Issues Releases Wiki Activity

Supported file download resume for tmpFS

Browse Source
This commit is contained in:
Igor Zhukov 2014-10-18 21:58:54 +02:00
parent 7c8171d09f
commit 75128f4c3b
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
app/js/lib/mtproto_wrapper.js
View File

@ -418,11 +418,14 @@ angular.module('izhukov.mtproto.wrapper', ['izhukov.utils', 'izhukov.mtproto'])
errorHandler = function (error) { errorHandler = function (error) {
deferred.reject(error); deferred.reject(error);
errorHandler = angular.noop; errorHandler = angular.noop;
if (cacheFileWriter) cacheFileWriter.truncate(0); if (cacheFileWriter &&
(!error || error.type != 'DOWNLOAD_CANCELED')) {
cacheFileWriter.truncate(0);
}
}; };
fileStorage.getFile(fileName).then(function (blob) { fileStorage.getFile(fileName, size).then(function (blob) {
if (toFileEntry) { if (toFileEntry) {
FileManager.copy(blob, toFileEntry).then(function () { FileManager.copy(blob, toFileEntry).then(function () {
deferred.resolve(); deferred.resolve();
@ -436,9 +439,16 @@ angular.module('izhukov.mtproto.wrapper', ['izhukov.utils', 'izhukov.mtproto'])
fileWriterPromise.then(function (fileWriter) { fileWriterPromise.then(function (fileWriter) {
cacheFileWriter = fileWriter; cacheFileWriter = fileWriter;
var limit = 524288, var limit = 524288,
offset,
startOffset = 0,
writeFilePromise = $q.when(), writeFilePromise = $q.when(),
writeFileDeferred; writeFileDeferred;
for (var offset = 0; offset < size; offset += limit) { if (fileWriter.length) {
startOffset = fileWriter.length;
fileWriter.seek(startOffset);
deferred.notify({done: startOffset, total: size});
}
for (offset = startOffset; offset < size; offset += limit) {
writeFileDeferred = $q.defer(); writeFileDeferred = $q.defer();
(function (isFinal, offset, writeFileDeferred, writeFilePromise) { (function (isFinal, offset, writeFileDeferred, writeFilePromise) {
return downloadRequest(dcID, function () { return downloadRequest(dcID, function () {
@ -479,7 +489,7 @@ angular.module('izhukov.mtproto.wrapper', ['izhukov.utils', 'izhukov.mtproto'])
writeFilePromise = writeFileDeferred.promise; writeFilePromise = writeFileDeferred.promise;
} }
}); });
}) });
deferred.promise.cancel = function () { deferred.promise.cancel = function () {
if (!canceled && !resolved) { if (!canceled && !resolved) {