diff --git a/server/core/Reader/ReaderWorker.js b/server/core/Reader/ReaderWorker.js index bfc4e372..dbf9c4ac 100644 --- a/server/core/Reader/ReaderWorker.js +++ b/server/core/Reader/ReaderWorker.js @@ -168,7 +168,12 @@ class ReaderWorker { const finishFilename = path.basename(compFilename); wState.finish({path: `/tmp/${finishFilename}`, size: stat.size}); - this.pushRemoteSend(compFilename, '/tmp'); + //асинхронно через 30 сек добавим в очередь на отправку + //т.к. gzipFileIfNotExists может переупаковать файл + (async() => { + await utils.sleep(30*1000); + this.pushRemoteSend(compFilename, '/tmp'); + })(); } catch (e) { log(LM_ERR, e.stack); @@ -340,7 +345,7 @@ class ReaderWorker { for (const file of files) { foundFiles.add(file.name); - //отсылаем на всякий случай перед удалением, если вдруг remoteSend не справился + //отсылаем на всякий случай перед удалением, если вдруг remoteSendAll не справился try { await this.remoteSendFile({fileName: file.name, remoteDir}); } catch (e) {