Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5f03ad5597 | ||
|
|
1efa3f055d | ||
|
|
8ccf11278b | ||
|
|
8a9e7ab4c3 | ||
|
|
c0fa7c0c51 |
@@ -97,8 +97,7 @@ class ReaderWorker {
|
|||||||
wState.finish({path: `/tmp/${finishFilename}`});
|
wState.finish({path: `/tmp/${finishFilename}`});
|
||||||
|
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
if (this.config.branch == 'development')
|
log(LM_ERR, e.stack);
|
||||||
console.error(e);
|
|
||||||
wState.set({state: 'error', error: (errMes ? errMes : e.message)});
|
wState.set({state: 'error', error: (errMes ? errMes : e.message)});
|
||||||
} finally {
|
} finally {
|
||||||
//clean
|
//clean
|
||||||
@@ -137,7 +136,6 @@ class ReaderWorker {
|
|||||||
|
|
||||||
async periodicCleanDir(dir, maxSize, timeout) {
|
async periodicCleanDir(dir, maxSize, timeout) {
|
||||||
try {
|
try {
|
||||||
log(`Start clean dir: ${dir}, maxSize=${maxSize}`);
|
|
||||||
const list = await fs.readdir(dir);
|
const list = await fs.readdir(dir);
|
||||||
|
|
||||||
let size = 0;
|
let size = 0;
|
||||||
@@ -149,21 +147,20 @@ class ReaderWorker {
|
|||||||
files.push({name, stat});
|
files.push({name, stat});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
log(`found ${files.length} files in dir ${dir}`);
|
log(`clean dir ${dir}, maxSize=${maxSize}, found ${files.length} files`);
|
||||||
|
|
||||||
files.sort((a, b) => a.stat.mtimeMs - b.stat.mtimeMs);
|
files.sort((a, b) => a.stat.mtimeMs - b.stat.mtimeMs);
|
||||||
|
|
||||||
let i = 0;
|
let i = 0;
|
||||||
while (i < files.length && size > maxSize) {
|
while (i < files.length && size > maxSize) {
|
||||||
const file = files[i];
|
const file = files[i];
|
||||||
log(`rm ${dir}/${file.name}`);
|
|
||||||
await fs.remove(`${dir}/${file.name}`);
|
await fs.remove(`${dir}/${file.name}`);
|
||||||
size -= file.stat.size;
|
size -= file.stat.size;
|
||||||
i++;
|
i++;
|
||||||
}
|
}
|
||||||
log(`removed ${i} files`);
|
log(`removed ${i} files`);
|
||||||
} catch(e) {
|
} catch(e) {
|
||||||
log(LM_ERR, e.message);
|
log(LM_ERR, e.stack);
|
||||||
} finally {
|
} finally {
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
this.periodicCleanDir(dir, maxSize, timeout);
|
this.periodicCleanDir(dir, maxSize, timeout);
|
||||||
|
|||||||
Reference in New Issue
Block a user