Function renderPendingNv12Frame

apps/desktop/src/utils/socket.ts:452–494

()

	}

	function renderPendingNv12Frame() {
		if (!pendingNv12Frame || !mainThreadWebGPU || !directCanvas) return;

		const { buffer, receivedAt } = pendingNv12Frame;
		pendingNv12Frame = null;

		const metadata = readNv12Metadata(buffer);
		if (!metadata) return;

		const { yStride, height, width, fullRange } = metadata;

		if (width > 0 && height > 0) {
			const ySize = yStride * height;
			const uvSize = yStride * (height / 2);
			const totalSize = ySize + uvSize;

			const frameData = new Uint8ClampedArray(buffer, 0, totalSize);
			const renderStart = performance.now();

			if (directCanvas.width !== width || directCanvas.height !== height) {
				directCanvas.width = width;
				directCanvas.height = height;
			}

			const timing = renderNv12FrameWebGPU(
				mainThreadWebGPU,
				frameData,
				width,
				height,
				yStride,
				fullRange,
			);

			storeRenderedFrame(frameData, width, height, yStride, true, fullRange);
			recordRender(
				performance.now() - renderStart,
				"webgpu",
				timing,
				receivedAt,
			);
			onmessage({ width, height });
		}
	}

	function schedulePendingNv12Frame(buffer: ArrayBuffer, receivedAt: number) {
		pendingNv12Frame = { buffer, receivedAt };