diff mbox

[FFmpeg-devel,4/4] libavcodec: v4l2m2m: fix error handling during buffer init

Message ID 20180804004031.12143-4-lorusak@gmail.com
State Accepted
Headers show

Commit Message

Lukas Rusak Aug. 4, 2018, 12:40 a.m. UTC 
From: Jorge Ramirez-Ortiz <jramirez@baylibre.com>

Signed-off-by: Jorge Ramirez-Ortiz <jramirez@baylibre.com>
---
 libavcodec/v4l2_context.c | 19 ++++++++++++++++---
 libavcodec/v4l2_m2m_dec.c |  9 +++++++--
 2 files changed, 23 insertions(+), 5 deletions(-)

Comments

Jorge Ramirez-Ortiz Aug. 6, 2018, 8:38 a.m. UTC | #1 
On 08/04/2018 02:40 AM, Lukas Rusak wrote:
> From: Jorge Ramirez-Ortiz <jramirez@baylibre.com>
>
> Signed-off-by: Jorge Ramirez-Ortiz <jramirez@baylibre.com>
> ---
>   libavcodec/v4l2_context.c | 19 ++++++++++++++++---
>   libavcodec/v4l2_m2m_dec.c |  9 +++++++--
>   2 files changed, 23 insertions(+), 5 deletions(-)
>
> diff --git a/libavcodec/v4l2_context.c b/libavcodec/v4l2_context.c
> index 9457fadb1e..fd3161ce2f 100644
> --- a/libavcodec/v4l2_context.c
> +++ b/libavcodec/v4l2_context.c
> @@ -263,6 +263,12 @@ static V4L2Buffer* v4l2_dequeue_v4l2buf(V4L2Context *ctx, int timeout)
>       /* if we are draining and there are no more capture buffers queued in the driver we are done */
>       if (!V4L2_TYPE_IS_OUTPUT(ctx->type) && ctx_to_m2mctx(ctx)->draining) {
>           for (i = 0; i < ctx->num_buffers; i++) {
> +            /* catpture buffer initialization happens during decode hence

could you amend the typo (/s/catpture/capture) when you resubmit please ^^

> +             * detection happens at runtime
> +             */
> +            if (!ctx->buffers)
> +                break;
> +
>               if (ctx->buffers[i].status == V4L2BUF_IN_DRIVER)
>                   goto start;
>           }
> @@ -724,9 +730,8 @@ int ff_v4l2_context_init(V4L2Context* ctx)
>           ctx->buffers[i].context = ctx;
>           ret = ff_v4l2_buffer_initialize(&ctx->buffers[i], i);
>           if (ret < 0) {
> -            av_log(logger(ctx), AV_LOG_ERROR, "%s buffer initialization (%s)\n", ctx->name, av_err2str(ret));
> -            av_free(ctx->buffers);
> -            return ret;
> +            av_log(logger(ctx), AV_LOG_ERROR, "%s buffer[%d] initialization (%s)\n", ctx->name, i, av_err2str(ret));
> +            goto error;
>           }
>       }
>   
> @@ -739,4 +744,12 @@ int ff_v4l2_context_init(V4L2Context* ctx)
>           V4L2_TYPE_IS_MULTIPLANAR(ctx->type) ? ctx->format.fmt.pix_mp.plane_fmt[0].bytesperline : ctx->format.fmt.pix.bytesperline);
>   
>       return 0;
> +
> +error:
> +    v4l2_release_buffers(ctx);
> +
> +    av_free(ctx->buffers);
> +    ctx->buffers = NULL;
> +
> +    return ret;
>   }
> diff --git a/libavcodec/v4l2_m2m_dec.c b/libavcodec/v4l2_m2m_dec.c
> index 29d894492f..c4f4f7837f 100644
> --- a/libavcodec/v4l2_m2m_dec.c
> +++ b/libavcodec/v4l2_m2m_dec.c
> @@ -92,8 +92,8 @@ static int v4l2_try_start(AVCodecContext *avctx)
>       if (!capture->buffers) {
>           ret = ff_v4l2_context_init(capture);
>           if (ret) {
> -            av_log(avctx, AV_LOG_DEBUG, "can't request output buffers\n");
> -            return ret;
> +            av_log(avctx, AV_LOG_ERROR, "can't request capture buffers\n");
> +            return AVERROR(ENOMEM);
>           }
>       }
>   
> @@ -157,6 +157,11 @@ static int v4l2_receive_frame(AVCodecContext *avctx, AVFrame *frame)
>           ret = v4l2_try_start(avctx);
>           if (ret) {
>               av_packet_unref(&avpkt);
> +
> +            /* cant recover */
> +            if (ret == AVERROR(ENOMEM))
> +                return ret;
> +
>               return 0;
>           }
>       }
diff mbox

Patch

diff --git a/libavcodec/v4l2_context.c b/libavcodec/v4l2_context.c
index 9457fadb1e..fd3161ce2f 100644
--- a/libavcodec/v4l2_context.c
+++ b/libavcodec/v4l2_context.c
@@ -263,6 +263,12 @@  static V4L2Buffer* v4l2_dequeue_v4l2buf(V4L2Context *ctx, int timeout)
     /* if we are draining and there are no more capture buffers queued in the driver we are done */
     if (!V4L2_TYPE_IS_OUTPUT(ctx->type) && ctx_to_m2mctx(ctx)->draining) {
         for (i = 0; i < ctx->num_buffers; i++) {
+            /* catpture buffer initialization happens during decode hence
+             * detection happens at runtime
+             */
+            if (!ctx->buffers)
+                break;
+
             if (ctx->buffers[i].status == V4L2BUF_IN_DRIVER)
                 goto start;
         }
@@ -724,9 +730,8 @@  int ff_v4l2_context_init(V4L2Context* ctx)
         ctx->buffers[i].context = ctx;
         ret = ff_v4l2_buffer_initialize(&ctx->buffers[i], i);
         if (ret < 0) {
-            av_log(logger(ctx), AV_LOG_ERROR, "%s buffer initialization (%s)\n", ctx->name, av_err2str(ret));
-            av_free(ctx->buffers);
-            return ret;
+            av_log(logger(ctx), AV_LOG_ERROR, "%s buffer[%d] initialization (%s)\n", ctx->name, i, av_err2str(ret));
+            goto error;
         }
     }
 
@@ -739,4 +744,12 @@  int ff_v4l2_context_init(V4L2Context* ctx)
         V4L2_TYPE_IS_MULTIPLANAR(ctx->type) ? ctx->format.fmt.pix_mp.plane_fmt[0].bytesperline : ctx->format.fmt.pix.bytesperline);
 
     return 0;
+
+error:
+    v4l2_release_buffers(ctx);
+
+    av_free(ctx->buffers);
+    ctx->buffers = NULL;
+
+    return ret;
 }
diff --git a/libavcodec/v4l2_m2m_dec.c b/libavcodec/v4l2_m2m_dec.c
index 29d894492f..c4f4f7837f 100644
--- a/libavcodec/v4l2_m2m_dec.c
+++ b/libavcodec/v4l2_m2m_dec.c
@@ -92,8 +92,8 @@  static int v4l2_try_start(AVCodecContext *avctx)
     if (!capture->buffers) {
         ret = ff_v4l2_context_init(capture);
         if (ret) {
-            av_log(avctx, AV_LOG_DEBUG, "can't request output buffers\n");
-            return ret;
+            av_log(avctx, AV_LOG_ERROR, "can't request capture buffers\n");
+            return AVERROR(ENOMEM);
         }
     }
 
@@ -157,6 +157,11 @@  static int v4l2_receive_frame(AVCodecContext *avctx, AVFrame *frame)
         ret = v4l2_try_start(avctx);
         if (ret) {
             av_packet_unref(&avpkt);
+
+            /* cant recover */
+            if (ret == AVERROR(ENOMEM))
+                return ret;
+
             return 0;
         }
     }