self-hosted/pigallery2
1
0
Fork 0
mirror of https://github.com/bpatrik/pigallery2.git synced 2024-12-25 02:04:15 +02:00
Code Issues Releases Activity

Fixing job progress

Browse Source
This commit is contained in:
Patrik J. Braun 2023-04-02 12:33:44 +02:00
parent d606df9479
commit e4710da4e5
2 changed files with 25 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
src/backend/model/jobs/jobs/FileJob.ts
View File

@ -76,53 +76,52 @@ export abstract class FileJob<S extends { indexedOnly?: boolean } = { indexedOnl
return false;
}
const processOneFile = async () => {
const filePath = this.fileQueue.shift();
try {
if ((await this.shouldProcess(filePath)) === true) {
this.Progress.Processed++;
this.Progress.log('processing: ' + filePath);
await this.processFile(filePath);
} else {
this.Progress.log('skipping: ' + filePath);
this.Progress.Skipped++;
}
} catch (e) {
console.error(e);
Logger.error(
LOG_TAG,
'Error during processing file:' + filePath + ', ' + e.toString()
);
this.Progress.log(
'Error during processing file:' + filePath + ', ' + e.toString()
);
}
};
if (!this.config.indexedOnly) {
if (this.directoryQueue.length > 0) {
await this.loadADirectoryFromDisk();
return true
} else if (this.fileQueue.length > 0) {
this.Progress.Left = this.fileQueue.length;
await processOneFile();
}
} else {
if (!this.DBProcessing.initiated) {
this.Progress.log('Counting files from db');
Logger.silly(LOG_TAG, 'Counting files from db');
this.Progress.All = await this.countMediaFromDB();
this.Progress.log('Found:' + this.Progress.All);
Logger.silly(LOG_TAG, 'Found:' + this.Progress.All);
this.DBProcessing.initiated = true;
return true;
}
if (this.fileQueue.length === 0) {
await this.loadMediaFilesFromDB();
} else {
this.Progress.Left = this.fileQueue.length;
await processOneFile();
return true;
}
}
const filePath = this.fileQueue.shift();
try {
if ((await this.shouldProcess(filePath)) === true) {
this.Progress.Processed++;
this.Progress.log('processing: ' + filePath);
await this.processFile(filePath);
} else {
this.Progress.log('skipping: ' + filePath);
this.Progress.Skipped++;
}
} catch (e) {
console.error(e);
Logger.error(
LOG_TAG,
'Error during processing file:' + filePath + ', ' + e.toString()
);
this.Progress.log(
'Error during processing file:' + filePath + ', ' + e.toString()
);
}
return true;
}

11
src/backend/model/threading/ThreadPool.ts
View File

@ -125,14 +125,3 @@ export class DiskManagerTH
}
}
export class ThumbnailTH
extends ThreadPool<void>
implements ITaskExecuter<RendererInput, void>
{
execute(input: RendererInput): Promise<void> {
return super.executeTask({
type: WorkerTaskTypes.thumbnail,
input,
} as ThumbnailTask);
}
}