Method encodeInternal

src/video_encoder.ts:447–570

(clonedFrame: VideoFrame, options?: VideoEncoderEncodeOptions)

	lastBuffer: Buffer | null = null;

	private async encodeInternal(clonedFrame: VideoFrame, options?: VideoEncoderEncodeOptions) {
		const currentConfigId = this.currentConfigId;

		using lock = this.mutex.lock();
		await lock.ready; // Unconditional await here to queue a microtask

		if (this.currentConfigId !== currentConfigId) {
			clonedFrame.close();
			return;
		}

		// Spec 6.5: Decrement [[encodeQueueSize]] and run the Schedule Dequeue Event algorithm.
		this.decrementQueue();

		try {
			assert(this.codecContext);

			if (clonedFrame instanceof VideoFramePolyfill && clonedFrame.data instanceof Frame) {
				const otherFrame = clonedFrame.data;
				this.frame.ref(otherFrame);
			} else {
				// Copy frame data from VideoFrame to FFmpeg Frame
				this.frame.format = fromPixelFormat(clonedFrame.format as string);
				this.frame.width = clonedFrame.codedWidth;
				this.frame.height = clonedFrame.codedHeight;
				this.frame.pts = BigInt(clonedFrame.timestamp);
				this.frame.duration = BigInt(clonedFrame.duration ?? 0);
				this.frame.colorPrimaries
					= mapColorPrimaries(clonedFrame.colorSpace.primaries ?? 'unknown') ?? AVCOL_PRI_UNSPECIFIED;
				this.frame.colorSpace
					= mapMatrixCoefficients(clonedFrame.colorSpace.matrix ?? 'unknown') ?? AVCOL_SPC_UNSPECIFIED;
				this.frame.colorTrc
					= mapTransferCharacteristics(clonedFrame.colorSpace.transfer ?? 'unknown') ?? AVCOL_TRC_UNSPECIFIED;
				this.frame.colorRange = clonedFrame.colorSpace.fullRange === false
					? AVCOL_RANGE_MPEG
					: clonedFrame.colorSpace.fullRange === true
						? AVCOL_RANGE_JPEG
						: AVCOL_RANGE_UNSPECIFIED;
				this.frame.keyFrame = options?.keyFrame ? 1 : 0;

				const size = clonedFrame.allocationSize();
				if (!this.lastBuffer || this.lastBuffer.byteLength !== size) {
					this.lastBuffer = Buffer.from({ length: size });
				}

				await clonedFrame.copyTo(this.lastBuffer);
				this.frame.fromBuffer(this.lastBuffer);
			}
		} finally {
			clonedFrame.close();
		}

		if (!this.colorSpaceSet) {
			this.codecContext.colorPrimaries = this.frame.colorPrimaries;
			this.codecContext.colorTrc = this.frame.colorTrc;
			this.codecContext.colorSpace = this.frame.colorSpace;
			this.codecContext.colorRange = this.frame.colorRange;