Function renderPendingRgbaFrame

apps/desktop/src/utils/socket.ts:506–549

()

	}

	function renderPendingRgbaFrame() {
		if (!pendingRgbaFrame || !mainThreadWebGPU || !directCanvas) return;

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

		if (buffer.byteLength < 24) return;

		const metadataOffset = buffer.byteLength - 24;
		const meta = new DataView(buffer, metadataOffset, 24);
		const strideBytes = meta.getUint32(0, true);
		const height = meta.getUint32(4, true);
		const width = meta.getUint32(8, true);

		if (width > 0 && height > 0) {
			const frameDataSize = strideBytes * height;
			if (strideBytes === 0 || buffer.byteLength - 24 < frameDataSize) return;

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

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

			const timing = renderFrameWebGPU(
				mainThreadWebGPU,
				frameData,
				width,
				height,
				strideBytes,
			);

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

	function schedulePendingRgbaFrame(buffer: ArrayBuffer, receivedAt: number) {
		pendingRgbaFrame = { buffer, receivedAt };