[media] coda: keep queued buffers on a temporary list during start_streaming

Keeping buffers filled into the bitstream on a temporary list instead of
immediately calling vb2_buffer_done on each of them immediately allows
start_streaming to correctly decide whether they should be marked as
done or requeued if an error occurs after the bitstream has been filled.

Signed-off-by: Philipp Zabel <p.zabel@pengutronix.de>
Signed-off-by: Hans Verkuil <hans.verkuil@cisco.com>
Signed-off-by: Mauro Carvalho Chehab <mchehab@s-opensource.com>
This commit is contained in:
Philipp Zabel 2017-03-03 09:12:48 -03:00 committed by Mauro Carvalho Chehab
parent 888708b1de
commit 331e7860f3
3 changed files with 45 additions and 14 deletions

View File

@ -224,7 +224,7 @@ static bool coda_bitstream_try_queue(struct coda_ctx *ctx,
return true; return true;
} }
void coda_fill_bitstream(struct coda_ctx *ctx, bool streaming) void coda_fill_bitstream(struct coda_ctx *ctx, struct list_head *buffer_list)
{ {
struct vb2_v4l2_buffer *src_buf; struct vb2_v4l2_buffer *src_buf;
struct coda_buffer_meta *meta; struct coda_buffer_meta *meta;
@ -252,9 +252,16 @@ void coda_fill_bitstream(struct coda_ctx *ctx, bool streaming)
"dropping invalid JPEG frame %d\n", "dropping invalid JPEG frame %d\n",
ctx->qsequence); ctx->qsequence);
src_buf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx); src_buf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx);
v4l2_m2m_buf_done(src_buf, streaming ? if (buffer_list) {
VB2_BUF_STATE_ERROR : struct v4l2_m2m_buffer *m2m_buf;
VB2_BUF_STATE_QUEUED);
m2m_buf = container_of(src_buf,
struct v4l2_m2m_buffer,
vb);
list_add_tail(&m2m_buf->list, buffer_list);
} else {
v4l2_m2m_buf_done(src_buf, VB2_BUF_STATE_ERROR);
}
continue; continue;
} }
@ -295,7 +302,16 @@ void coda_fill_bitstream(struct coda_ctx *ctx, bool streaming)
trace_coda_bit_queue(ctx, src_buf, meta); trace_coda_bit_queue(ctx, src_buf, meta);
} }
v4l2_m2m_buf_done(src_buf, VB2_BUF_STATE_DONE); if (buffer_list) {
struct v4l2_m2m_buffer *m2m_buf;
m2m_buf = container_of(src_buf,
struct v4l2_m2m_buffer,
vb);
list_add_tail(&m2m_buf->list, buffer_list);
} else {
v4l2_m2m_buf_done(src_buf, VB2_BUF_STATE_DONE);
}
} else { } else {
break; break;
} }
@ -1747,7 +1763,7 @@ static int coda_prepare_decode(struct coda_ctx *ctx)
/* Try to copy source buffer contents into the bitstream ringbuffer */ /* Try to copy source buffer contents into the bitstream ringbuffer */
mutex_lock(&ctx->bitstream_mutex); mutex_lock(&ctx->bitstream_mutex);
coda_fill_bitstream(ctx, true); coda_fill_bitstream(ctx, NULL);
mutex_unlock(&ctx->bitstream_mutex); mutex_unlock(&ctx->bitstream_mutex);
if (coda_get_bitstream_payload(ctx) < 512 && if (coda_get_bitstream_payload(ctx) < 512 &&

View File

@ -1378,7 +1378,7 @@ static void coda_buf_queue(struct vb2_buffer *vb)
v4l2_m2m_buf_queue(ctx->fh.m2m_ctx, vbuf); v4l2_m2m_buf_queue(ctx->fh.m2m_ctx, vbuf);
if (vb2_is_streaming(vb->vb2_queue)) if (vb2_is_streaming(vb->vb2_queue))
/* This set buf->sequence = ctx->qsequence++ */ /* This set buf->sequence = ctx->qsequence++ */
coda_fill_bitstream(ctx, true); coda_fill_bitstream(ctx, NULL);
mutex_unlock(&ctx->bitstream_mutex); mutex_unlock(&ctx->bitstream_mutex);
} else { } else {
if (ctx->inst_type == CODA_INST_ENCODER && if (ctx->inst_type == CODA_INST_ENCODER &&
@ -1433,18 +1433,22 @@ static int coda_start_streaming(struct vb2_queue *q, unsigned int count)
struct coda_ctx *ctx = vb2_get_drv_priv(q); struct coda_ctx *ctx = vb2_get_drv_priv(q);
struct v4l2_device *v4l2_dev = &ctx->dev->v4l2_dev; struct v4l2_device *v4l2_dev = &ctx->dev->v4l2_dev;
struct coda_q_data *q_data_src, *q_data_dst; struct coda_q_data *q_data_src, *q_data_dst;
struct v4l2_m2m_buffer *m2m_buf, *tmp;
struct vb2_v4l2_buffer *buf; struct vb2_v4l2_buffer *buf;
struct list_head list;
int ret = 0; int ret = 0;
if (count < 1) if (count < 1)
return -EINVAL; return -EINVAL;
INIT_LIST_HEAD(&list);
q_data_src = get_q_data(ctx, V4L2_BUF_TYPE_VIDEO_OUTPUT); q_data_src = get_q_data(ctx, V4L2_BUF_TYPE_VIDEO_OUTPUT);
if (q->type == V4L2_BUF_TYPE_VIDEO_OUTPUT) { if (q->type == V4L2_BUF_TYPE_VIDEO_OUTPUT) {
if (ctx->inst_type == CODA_INST_DECODER && ctx->use_bit) { if (ctx->inst_type == CODA_INST_DECODER && ctx->use_bit) {
/* copy the buffers that were queued before streamon */ /* copy the buffers that were queued before streamon */
mutex_lock(&ctx->bitstream_mutex); mutex_lock(&ctx->bitstream_mutex);
coda_fill_bitstream(ctx, false); coda_fill_bitstream(ctx, &list);
mutex_unlock(&ctx->bitstream_mutex); mutex_unlock(&ctx->bitstream_mutex);
if (coda_get_bitstream_payload(ctx) < 512) { if (coda_get_bitstream_payload(ctx) < 512) {
@ -1460,7 +1464,7 @@ static int coda_start_streaming(struct vb2_queue *q, unsigned int count)
/* Don't start the coda unless both queues are on */ /* Don't start the coda unless both queues are on */
if (!(ctx->streamon_out && ctx->streamon_cap)) if (!(ctx->streamon_out && ctx->streamon_cap))
return 0; goto out;
q_data_dst = get_q_data(ctx, V4L2_BUF_TYPE_VIDEO_CAPTURE); q_data_dst = get_q_data(ctx, V4L2_BUF_TYPE_VIDEO_CAPTURE);
if ((q_data_src->width != q_data_dst->width && if ((q_data_src->width != q_data_dst->width &&
@ -1495,15 +1499,26 @@ static int coda_start_streaming(struct vb2_queue *q, unsigned int count)
ret = ctx->ops->start_streaming(ctx); ret = ctx->ops->start_streaming(ctx);
if (ctx->inst_type == CODA_INST_DECODER) { if (ctx->inst_type == CODA_INST_DECODER) {
if (ret == -EAGAIN) if (ret == -EAGAIN)
return 0; goto out;
else if (ret < 0)
goto err;
} }
if (ret < 0)
goto err;
return ret; out:
if (q->type == V4L2_BUF_TYPE_VIDEO_OUTPUT) {
list_for_each_entry_safe(m2m_buf, tmp, &list, list) {
list_del(&m2m_buf->list);
v4l2_m2m_buf_done(&m2m_buf->vb, VB2_BUF_STATE_DONE);
}
}
return 0;
err: err:
if (q->type == V4L2_BUF_TYPE_VIDEO_OUTPUT) { if (q->type == V4L2_BUF_TYPE_VIDEO_OUTPUT) {
list_for_each_entry_safe(m2m_buf, tmp, &list, list) {
list_del(&m2m_buf->list);
v4l2_m2m_buf_done(&m2m_buf->vb, VB2_BUF_STATE_QUEUED);
}
while ((buf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx))) while ((buf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx)))
v4l2_m2m_buf_done(buf, VB2_BUF_STATE_QUEUED); v4l2_m2m_buf_done(buf, VB2_BUF_STATE_QUEUED);
} else { } else {

View File

@ -259,7 +259,7 @@ int coda_decoder_queue_init(void *priv, struct vb2_queue *src_vq,
int coda_hw_reset(struct coda_ctx *ctx); int coda_hw_reset(struct coda_ctx *ctx);
void coda_fill_bitstream(struct coda_ctx *ctx, bool streaming); void coda_fill_bitstream(struct coda_ctx *ctx, struct list_head *buffer_list);
void coda_set_gdi_regs(struct coda_ctx *ctx); void coda_set_gdi_regs(struct coda_ctx *ctx);