[PATCH v4 1/4] converter: converter_v4l2_m2m: Rectify streams sanity check

[Paul Elder]

On Mon, Jun 24, 2024 at 07:18:56PM +0530, Umang Jain wrote:
> The streams sanity check tries to determine if all the stream indexes
> passed in outputs std::map<> are unique. However, since the data
> container is std::map<>, all its keys (stream indexes in this case),
> are already unique.
> 
> Instead, rectify the sanity check to ensure all the framebuffers passed
> in the outputs std::map<> are unique to each index. Hence, no two stream
> indexes should have same framebuffer. Update the comment to reflect
> the change.
> 
> Signed-off-by: Umang Jain <umang.jain at ideasonboard.com>
> Reviewed-by: Kieran Bingham <kieran.bingham at ideasonboard.com>

Reviewed-by: Paul Elder <paul.elder at ideasonboard.com>

> ---
>  src/libcamera/converter/converter_v4l2_m2m.cpp | 11 ++++++-----
>  1 file changed, 6 insertions(+), 5 deletions(-)
> 
> diff --git a/src/libcamera/converter/converter_v4l2_m2m.cpp b/src/libcamera/converter/converter_v4l2_m2m.cpp
> index d8929fc5..27a50e34 100644
> --- a/src/libcamera/converter/converter_v4l2_m2m.cpp
> +++ b/src/libcamera/converter/converter_v4l2_m2m.cpp
> @@ -403,13 +403,13 @@ void V4L2M2MConverter::stop()
>  int V4L2M2MConverter::queueBuffers(FrameBuffer *input,
>  				   const std::map<unsigned int, FrameBuffer *> &outputs)
>  {
> -	unsigned int mask = 0;
> +	std::set<FrameBuffer *> outputBufs;
>  	int ret;
>  
>  	/*
>  	 * Validate the outputs as a sanity check: at least one output is
>  	 * required, all outputs must reference a valid stream and no two
> -	 * outputs can reference the same stream.
> +	 * streams can reference same output framebuffers.
>  	 */
>  	if (outputs.empty())
>  		return -EINVAL;
> @@ -419,12 +419,13 @@ int V4L2M2MConverter::queueBuffers(FrameBuffer *input,
>  			return -EINVAL;
>  		if (index >= streams_.size())
>  			return -EINVAL;
> -		if (mask & (1 << index))
> -			return -EINVAL;
>  
> -		mask |= 1 << index;
> +		outputBufs.insert(buffer);
>  	}
>  
> +	if (outputBufs.size() != streams_.size())
> +		return -EINVAL;
> +
>  	/* Queue the input and output buffers to all the streams. */
>  	for (auto [index, buffer] : outputs) {
>  		ret = streams_[index].queueBuffers(input, buffer);
> -- 
> 2.44.0
>