0ct0pu5/ente
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Shout less

Browse source
This commit is contained in:
Manav Rathi 2024-04-24 15:55:55 +05:30
parent a935f2e2cf
commit 105157c164
No known key found for this signature in database
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
web/apps/photos/src/services/upload/uploadManager.ts
View file

@ -56,7 +56,8 @@ import UploadService, {
uploader,
} from "./uploadService";
const MAX_CONCURRENT_UPLOADS = 4;
/** The number of uploads to process in parallel. */
const maxConcurrentUploads = 4;
class UIService {
private progressUpdater: ProgressUpdater;
@ -261,7 +262,7 @@ function segregatedFinishedUploadsToList(finishedUploads: FinishedUploads) {
class UploadManager {
private cryptoWorkers = new Array<
ComlinkWorker<typeof DedicatedCryptoWorker>
>(MAX_CONCURRENT_UPLOADS);
>(maxConcurrentUploads);
private parsedMetadataJSONMap: Map<string, ParsedMetadataJSON>;
private filesToBeUploaded: FileWithCollection2[];
private remainingFiles: FileWithCollection2[] = [];
@ -411,7 +412,7 @@ class UploadManager {
}
} finally {
this.uiService.setUploadStage(UPLOAD_STAGES.FINISH);
for (let i = 0; i < MAX_CONCURRENT_UPLOADS; i++) {
for (let i = 0; i < maxConcurrentUploads; i++) {
this.cryptoWorkers[i]?.terminate();
}
this.uploadInProgress = false;
@ -490,7 +491,7 @@ class UploadManager {
const uploadProcesses = [];
for (
let i = 0;
i < MAX_CONCURRENT_UPLOADS && this.filesToBeUploaded.length > 0;
i < maxConcurrentUploads && this.filesToBeUploaded.length > 0;
i++
) {
this.cryptoWorkers[i] = getDedicatedCryptoWorker();