File size: 1,958 Bytes
11fcc5a |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
import { get } from "svelte/store";
import { device } from "$lib/device";
import { queue, itemError } from "$lib/state/task-manager/queue";
import { runFFmpegWorker } from "$lib/task-manager/runners/ffmpeg";
import { runFetchWorker } from "$lib/task-manager/runners/fetch";
import type { CobaltPipelineItem } from "$lib/types/workers";
export const killWorker = (worker: Worker, unsubscribe: () => void, interval?: NodeJS.Timeout) => {
unsubscribe();
worker.terminate();
if (interval) clearInterval(interval);
}
export const startWorker = async ({ worker, workerId, dependsOn, parentId, workerArgs }: CobaltPipelineItem) => {
let files: File[] = [];
switch (worker) {
case "remux":
case "encode": {
if (workerArgs.files) {
files = workerArgs.files;
}
const parent = get(queue)[parentId];
if (parent?.state === "running" && dependsOn) {
for (const workerId of dependsOn) {
const file = parent.pipelineResults[workerId];
if (!file) {
return itemError(parentId, workerId, "queue.ffmpeg.no_args");
}
files.push(file);
}
}
if (files.length > 0 && workerArgs.ffargs && workerArgs.output) {
await runFFmpegWorker(
workerId,
parentId,
files,
workerArgs.ffargs,
workerArgs.output,
worker,
device.supports.multithreading,
/*resetStartCounter=*/true,
);
} else {
itemError(parentId, workerId, "queue.ffmpeg.no_args");
}
break;
}
case "fetch":
await runFetchWorker(workerId, parentId, workerArgs.url);
break;
}
}
|