Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c4a06858fb | ||
|
|
15b0f05a05 | ||
|
|
67feee9aa1 | ||
|
|
185fb57b8c | ||
|
|
e9039f8208 |
@@ -47,10 +47,6 @@ class WorkerController extends BaseController {
|
|||||||
state = this.workerState.getState(request.workerId);
|
state = this.workerState.getState(request.workerId);
|
||||||
if (!state) break;
|
if (!state) break;
|
||||||
|
|
||||||
if (i == 0) {
|
|
||||||
state = Object.assign({dummy: '0'.repeat(1024)}, state);
|
|
||||||
}
|
|
||||||
|
|
||||||
res.write(splitter + JSON.stringify(state));
|
res.write(splitter + JSON.stringify(state));
|
||||||
res.flush();
|
res.flush();
|
||||||
|
|
||||||
|
|||||||
@@ -212,7 +212,10 @@ class ReaderWorker {
|
|||||||
while (i < files.length && size > maxSize) {
|
while (i < files.length && size > maxSize) {
|
||||||
const file = files[i];
|
const file = files[i];
|
||||||
const oldFile = `${dir}/${file.name}`;
|
const oldFile = `${dir}/${file.name}`;
|
||||||
if (this.remoteWebDavStorage) {
|
|
||||||
|
//отправляем только this.config.tempPublicDir
|
||||||
|
//TODO: убрать в будущем, т.к. уже делается ленивое сохранение compFilename в удаленном хранилище
|
||||||
|
if (this.remoteWebDavStorage && dir === this.config.tempPublicDir) {
|
||||||
try {
|
try {
|
||||||
//log(`remoteWebDavStorage.putFile ${path.basename(oldFile)}`);
|
//log(`remoteWebDavStorage.putFile ${path.basename(oldFile)}`);
|
||||||
await this.remoteWebDavStorage.putFile(oldFile);
|
await this.remoteWebDavStorage.putFile(oldFile);
|
||||||
|
|||||||
Reference in New Issue
Block a user