Commit 959c3ef3 authored by Junghak Sung's avatar Junghak Sung Committed by Mauro Carvalho Chehab

[media] media: videobuf2: Add copy_timestamp to struct vb2_queue

Add copy_timestamp to struct vb2_queue as a flag set if vb2-core should
copy timestamps.
Signed-off-by: default avatarJunghak Sung <jh1009.sung@samsung.com>
Signed-off-by: default avatarGeunyoung Kim <nenggun.kim@samsung.com>
Acked-by: default avatarSeung-Woo Kim <sw0312.kim@samsung.com>
Acked-by: default avatarInki Dae <inki.dae@samsung.com>
Signed-off-by: default avatarHans Verkuil <hansverk@cisco.com>
Signed-off-by: default avatarMauro Carvalho Chehab <mchehab@osg.samsung.com>
parent d6dd645e
...@@ -1399,7 +1399,7 @@ int vb2_core_qbuf(struct vb2_queue *q, unsigned int index, void *pb) ...@@ -1399,7 +1399,7 @@ int vb2_core_qbuf(struct vb2_queue *q, unsigned int index, void *pb)
q->waiting_for_buffers = false; q->waiting_for_buffers = false;
vb->state = VB2_BUF_STATE_QUEUED; vb->state = VB2_BUF_STATE_QUEUED;
call_bufop(q, set_timestamp, vb, pb); call_bufop(q, copy_timestamp, vb, pb);
trace_vb2_qbuf(q, vb); trace_vb2_qbuf(q, vb);
......
...@@ -107,7 +107,7 @@ static int __verify_length(struct vb2_buffer *vb, const struct v4l2_buffer *b) ...@@ -107,7 +107,7 @@ static int __verify_length(struct vb2_buffer *vb, const struct v4l2_buffer *b)
return 0; return 0;
} }
static int __set_timestamp(struct vb2_buffer *vb, const void *pb) static int __copy_timestamp(struct vb2_buffer *vb, const void *pb)
{ {
const struct v4l2_buffer *b = pb; const struct v4l2_buffer *b = pb;
struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb); struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb);
...@@ -118,8 +118,7 @@ static int __set_timestamp(struct vb2_buffer *vb, const void *pb) ...@@ -118,8 +118,7 @@ static int __set_timestamp(struct vb2_buffer *vb, const void *pb)
* For output buffers copy the timestamp if needed, * For output buffers copy the timestamp if needed,
* and the timecode field and flag if needed. * and the timecode field and flag if needed.
*/ */
if ((q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK) == if (q->copy_timestamp)
V4L2_BUF_FLAG_TIMESTAMP_COPY)
vb->timestamp = timeval_to_ns(&b->timestamp); vb->timestamp = timeval_to_ns(&b->timestamp);
vbuf->flags |= b->flags & V4L2_BUF_FLAG_TIMECODE; vbuf->flags |= b->flags & V4L2_BUF_FLAG_TIMECODE;
if (b->flags & V4L2_BUF_FLAG_TIMECODE) if (b->flags & V4L2_BUF_FLAG_TIMECODE)
...@@ -238,8 +237,7 @@ static int __fill_v4l2_buffer(struct vb2_buffer *vb, void *pb) ...@@ -238,8 +237,7 @@ static int __fill_v4l2_buffer(struct vb2_buffer *vb, void *pb)
*/ */
b->flags &= ~V4L2_BUFFER_MASK_FLAGS; b->flags &= ~V4L2_BUFFER_MASK_FLAGS;
b->flags |= q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK; b->flags |= q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK;
if ((q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK) != if (!q->copy_timestamp) {
V4L2_BUF_FLAG_TIMESTAMP_COPY) {
/* /*
* For non-COPY timestamps, drop timestamp source bits * For non-COPY timestamps, drop timestamp source bits
* and obtain the timestamp source from the queue. * and obtain the timestamp source from the queue.
...@@ -403,8 +401,7 @@ static int __fill_vb2_buffer(struct vb2_buffer *vb, ...@@ -403,8 +401,7 @@ static int __fill_vb2_buffer(struct vb2_buffer *vb,
/* Zero flags that the vb2 core handles */ /* Zero flags that the vb2 core handles */
vbuf->flags = b->flags & ~V4L2_BUFFER_MASK_FLAGS; vbuf->flags = b->flags & ~V4L2_BUFFER_MASK_FLAGS;
if ((vb->vb2_queue->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK) != if (!vb->vb2_queue->copy_timestamp || !V4L2_TYPE_IS_OUTPUT(b->type)) {
V4L2_BUF_FLAG_TIMESTAMP_COPY || !V4L2_TYPE_IS_OUTPUT(b->type)) {
/* /*
* Non-COPY timestamps and non-OUTPUT queues will get * Non-COPY timestamps and non-OUTPUT queues will get
* their timestamp and timestamp source flags from the * their timestamp and timestamp source flags from the
...@@ -433,7 +430,7 @@ static int __fill_vb2_buffer(struct vb2_buffer *vb, ...@@ -433,7 +430,7 @@ static int __fill_vb2_buffer(struct vb2_buffer *vb,
static const struct vb2_buf_ops v4l2_buf_ops = { static const struct vb2_buf_ops v4l2_buf_ops = {
.fill_user_buffer = __fill_v4l2_buffer, .fill_user_buffer = __fill_v4l2_buffer,
.fill_vb2_buffer = __fill_vb2_buffer, .fill_vb2_buffer = __fill_vb2_buffer,
.set_timestamp = __set_timestamp, .copy_timestamp = __copy_timestamp,
}; };
/** /**
...@@ -760,6 +757,8 @@ int vb2_queue_init(struct vb2_queue *q) ...@@ -760,6 +757,8 @@ int vb2_queue_init(struct vb2_queue *q)
q->buf_ops = &v4l2_buf_ops; q->buf_ops = &v4l2_buf_ops;
q->is_multiplanar = V4L2_TYPE_IS_MULTIPLANAR(q->type); q->is_multiplanar = V4L2_TYPE_IS_MULTIPLANAR(q->type);
q->is_output = V4L2_TYPE_IS_OUTPUT(q->type); q->is_output = V4L2_TYPE_IS_OUTPUT(q->type);
q->copy_timestamp = (q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK)
== V4L2_BUF_FLAG_TIMESTAMP_COPY;
return vb2_core_queue_init(q); return vb2_core_queue_init(q);
} }
...@@ -1114,12 +1113,10 @@ static size_t __vb2_perform_fileio(struct vb2_queue *q, char __user *data, size_ ...@@ -1114,12 +1113,10 @@ static size_t __vb2_perform_fileio(struct vb2_queue *q, char __user *data, size_
bool is_multiplanar = q->is_multiplanar; bool is_multiplanar = q->is_multiplanar;
/* /*
* When using write() to write data to an output video node the vb2 core * When using write() to write data to an output video node the vb2 core
* should set timestamps if V4L2_BUF_FLAG_TIMESTAMP_COPY is set. Nobody * should copy timestamps if V4L2_BUF_FLAG_TIMESTAMP_COPY is set. Nobody
* else is able to provide this information with the write() operation. * else is able to provide this information with the write() operation.
*/ */
bool set_timestamp = !read && bool copy_timestamp = !read && q->copy_timestamp;
(q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK) ==
V4L2_BUF_FLAG_TIMESTAMP_COPY;
int ret, index; int ret, index;
dprintk(3, "mode %s, offset %ld, count %zd, %sblocking\n", dprintk(3, "mode %s, offset %ld, count %zd, %sblocking\n",
...@@ -1236,7 +1233,7 @@ static size_t __vb2_perform_fileio(struct vb2_queue *q, char __user *data, size_ ...@@ -1236,7 +1233,7 @@ static size_t __vb2_perform_fileio(struct vb2_queue *q, char __user *data, size_
fileio->b.m.planes = &fileio->p; fileio->b.m.planes = &fileio->p;
fileio->b.length = 1; fileio->b.length = 1;
} }
if (set_timestamp) if (copy_timestamp)
v4l2_get_timestamp(&fileio->b.timestamp); v4l2_get_timestamp(&fileio->b.timestamp);
ret = vb2_internal_qbuf(q, &fileio->b); ret = vb2_internal_qbuf(q, &fileio->b);
dprintk(5, "vb2_dbuf result: %d\n", ret); dprintk(5, "vb2_dbuf result: %d\n", ret);
...@@ -1301,16 +1298,14 @@ static int vb2_thread(void *data) ...@@ -1301,16 +1298,14 @@ static int vb2_thread(void *data)
struct vb2_queue *q = data; struct vb2_queue *q = data;
struct vb2_threadio_data *threadio = q->threadio; struct vb2_threadio_data *threadio = q->threadio;
struct vb2_fileio_data *fileio = q->fileio; struct vb2_fileio_data *fileio = q->fileio;
bool set_timestamp = false; bool copy_timestamp = false;
int prequeue = 0; int prequeue = 0;
int index = 0; int index = 0;
int ret = 0; int ret = 0;
if (q->is_output) { if (q->is_output) {
prequeue = q->num_buffers; prequeue = q->num_buffers;
set_timestamp = copy_timestamp = q->copy_timestamp;
(q->timestamp_flags & V4L2_BUF_FLAG_TIMESTAMP_MASK) ==
V4L2_BUF_FLAG_TIMESTAMP_COPY;
} }
set_freezable(); set_freezable();
...@@ -1343,7 +1338,7 @@ static int vb2_thread(void *data) ...@@ -1343,7 +1338,7 @@ static int vb2_thread(void *data)
if (threadio->fnc(vb, threadio->priv)) if (threadio->fnc(vb, threadio->priv))
break; break;
call_void_qop(q, wait_finish, q); call_void_qop(q, wait_finish, q);
if (set_timestamp) if (copy_timestamp)
v4l2_get_timestamp(&fileio->b.timestamp); v4l2_get_timestamp(&fileio->b.timestamp);
if (!threadio->stop) if (!threadio->stop)
ret = vb2_internal_qbuf(q, &fileio->b); ret = vb2_internal_qbuf(q, &fileio->b);
......
...@@ -373,7 +373,7 @@ struct vb2_buf_ops { ...@@ -373,7 +373,7 @@ struct vb2_buf_ops {
int (*fill_user_buffer)(struct vb2_buffer *vb, void *pb); int (*fill_user_buffer)(struct vb2_buffer *vb, void *pb);
int (*fill_vb2_buffer)(struct vb2_buffer *vb, const void *pb, int (*fill_vb2_buffer)(struct vb2_buffer *vb, const void *pb,
struct vb2_plane *planes); struct vb2_plane *planes);
int (*set_timestamp)(struct vb2_buffer *vb, const void *pb); int (*copy_timestamp)(struct vb2_buffer *vb, const void *pb);
}; };
/** /**
...@@ -436,6 +436,7 @@ struct vb2_buf_ops { ...@@ -436,6 +436,7 @@ struct vb2_buf_ops {
* called since poll() needs to return POLLERR in that situation. * called since poll() needs to return POLLERR in that situation.
* @is_multiplanar: set if buffer type is multiplanar * @is_multiplanar: set if buffer type is multiplanar
* @is_output: set if buffer type is output * @is_output: set if buffer type is output
* @copy_timestamp: set if vb2-core should set timestamps
* @last_buffer_dequeued: used in poll() and DQBUF to immediately return if the * @last_buffer_dequeued: used in poll() and DQBUF to immediately return if the
* last decoded buffer was already dequeued. Set for capture queues * last decoded buffer was already dequeued. Set for capture queues
* when a buffer with the V4L2_BUF_FLAG_LAST is dequeued. * when a buffer with the V4L2_BUF_FLAG_LAST is dequeued.
...@@ -485,6 +486,7 @@ struct vb2_queue { ...@@ -485,6 +486,7 @@ struct vb2_queue {
unsigned int waiting_for_buffers:1; unsigned int waiting_for_buffers:1;
unsigned int is_multiplanar:1; unsigned int is_multiplanar:1;
unsigned int is_output:1; unsigned int is_output:1;
unsigned int copy_timestamp:1;
unsigned int last_buffer_dequeued:1; unsigned int last_buffer_dequeued:1;
struct vb2_fileio_data *fileio; struct vb2_fileio_data *fileio;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment