Function queueFrameFromBytes

apps/desktop/src/utils/frame-worker.ts:482–602

(
	bytes: Uint8Array,
	releaseCallback?: () => void,
)

}

function queueFrameFromBytes(
	bytes: Uint8Array,
	releaseCallback?: () => void,
): void {
	const meta = parseFrameMetadata(bytes);
	if (!meta) {
		releaseCallback?.();
		return;
	}

	const { width, height, frameNumber, targetTimeNs } = meta;
	const timing: FrameTiming = { frameNumber, targetTimeNs };

	if (renderMode === "webgpu" || renderMode === "pending") {
		for (const queued of frameQueue) {
			if (queued.mode === "webgpu" && queued.releaseCallback) {
				queued.releaseCallback();
			}
		}
		frameQueue = frameQueue.filter((f) => f.mode !== "webgpu");

		if (meta.format === "nv12") {
			const frameData = new Uint8ClampedArray(
				bytes.buffer,
				bytes.byteOffset,
				meta.totalSize,
			);
			frameQueue.push({
				mode: "webgpu",
				pixelFormat: "nv12",
				data: frameData,
				width,
				height,
				yStride: meta.yStride,
				fullRange: meta.fullRange,
				timing,
				releaseCallback,
			});
		} else {
			const metadataSize = 24;
			const frameData = new Uint8ClampedArray(
				bytes.buffer,
				bytes.byteOffset,
				bytes.byteLength - metadataSize,
			);
			frameQueue.push({
				mode: "webgpu",
				pixelFormat: "rgba",
				data: frameData.subarray(0, meta.availableLength),
				width,
				height,
				strideBytes: meta.strideBytes,
				timing,
				releaseCallback,
			});
		}
	} else if (meta.format === "rgba") {
		const expectedRowBytes = width * 4;