Method update

frontend/src/services/uploadService.ts:315–401

()

  }

  update() {
    for (let i = 0; i < this.task.length; i++) {
      if (!this.task[i]) continue;
      if (this.task[i]!.status == "completed") {
        this.task[i] = undefined;
      }
    }
    if (this.status == "suspend") {
      if (this.files.size == 0) {
        this.status = "stopped";
      }
      return;
    }
    let removeFile = false;
    for (const task of this.task) {
      if (!task) continue;
      if (task.status == "removing") {
        removeFile = true;
      }
      if (task.status == "failed") {
        task.status = "pending";
        this.suspend();
      }
    }
    if (this.status == "working" && this.current) {
      const currentFile = this.files.get(this.current)!;
      let reachTaskEnd = removeFile;

      if (removeFile) {
        this.task = [];
      }

      for (let i = 0; i < UploadService.concurrency; i++) {
        if (reachTaskEnd || !currentFile.prepared) {
          break;
        }
        if (this.task[i] == undefined) {
          const nextTask = currentFile.nextTask();
          if (!nextTask) {
            reachTaskEnd = true;
            break;
          }
          this.task[i] = nextTask;
        }
      }

      let tasks = 0;
      for (const uploadTask of this.task) {
        if (!uploadTask) continue;
        tasks++;
        if (uploadTask.status != "pending") continue;
        uploadTask.retries = 0;
        uploadTask.start(); // async
      }
      if (reachTaskEnd && currentFile.prepared && tasks == 0) {
        const currentFile = this.files.get(this.current)!;
        currentFile.onEnd();
        if (!removeFile) {