diff --git a/server/core/Reader/ReaderWorker.js b/server/core/Reader/ReaderWorker.js index dbf9c4ac..25485b95 100644 --- a/server/core/Reader/ReaderWorker.js +++ b/server/core/Reader/ReaderWorker.js @@ -13,7 +13,7 @@ const ayncExit = new (require('../AsyncExit'))(); const utils = require('../utils'); const log = new (require('../AppLogger'))().log;//singleton -const cleanDirPeriod = 30*60*1000;//раз в полчаса +const cleanDirPeriod = 60*60*1000;//каждый час const remoteSendPeriod = 119*1000;//примерно раз 2 минуты const queue = new LimitedQueue(5, 100, 2*60*1000 + 15000);//2 минуты ожидание подвижек @@ -285,7 +285,7 @@ class ReaderWorker { if (!fileName || sent[fileName]) return; - log(`remoteStorage.putFile ${remoteDir}/${path.basename(fileName)}`); + log(`remoteSendFile ${remoteDir}/${path.basename(fileName)}`); //отправляем в remoteStorage await this.remoteStorage.putFile(fileName, remoteDir); @@ -335,7 +335,7 @@ class ReaderWorker { } } - log(`clean dir ${dir}, maxSize=${maxSize}, found ${files.length} files, total size=${size}`); + log(LM_WARN, `clean dir ${dir}, maxSize=${maxSize}, found ${files.length} files, total size=${size}`); files.sort((a, b) => a.stat.mtimeMs - b.stat.mtimeMs); @@ -383,7 +383,7 @@ class ReaderWorker { i++; } - log(`removed ${j} files`); + log(LM_WARN, `removed ${j} files`); } async periodicCleanDir() {