This is an automatic generated email to let you know that the following patch were queued at the http://git.linuxtv.org/cgit.cgi/v4l-utils.git tree:
Subject: v4l2-compliance: split node at testNode() in two nodes Author: André Almeida <andrealm...@collabora.com> Date: Thu Aug 8 22:02:04 2019 -0300 v4l2-compliance tests deals with memory-to-memory devices (m2m) like they are a single device, through the struct node. This is indeed the most usual case. However, there are m2m devices that have two separated devices for the capture queue and for the output queue, and the current design does not support they. Split the node on testNode and related functions in two arguments: struct node node and struct node node_m2m_cap. For now, use the same node in both arguments. Signed-off-by: André Almeida <andrealm...@collabora.com> Signed-off-by: Hans Verkuil <hverkuil-ci...@xs4all.nl> utils/v4l2-compliance/v4l2-compliance.cpp | 20 +++---- utils/v4l2-compliance/v4l2-compliance.h | 22 ++++++-- utils/v4l2-compliance/v4l2-test-buffers.cpp | 88 +++++++++++++++-------------- utils/v4l2-compliance/v4l2-test-media.cpp | 2 +- 4 files changed, 74 insertions(+), 58 deletions(-) --- http://git.linuxtv.org/cgit.cgi/v4l-utils.git/commit/?id=8d411705aa29f3ad77a4d48797b7ad07bfcce471 diff --git a/utils/v4l2-compliance/v4l2-compliance.cpp b/utils/v4l2-compliance/v4l2-compliance.cpp index fbeb96be7e90..d950906439ed 100644 --- a/utils/v4l2-compliance/v4l2-compliance.cpp +++ b/utils/v4l2-compliance/v4l2-compliance.cpp @@ -908,7 +908,7 @@ err: return result; } -void testNode(struct node &node, struct node &expbuf_node, media_type type, +void testNode(struct node &node, struct node &node_m2m_cap, struct node &expbuf_node, media_type type, unsigned frame_count, unsigned all_fmt_frame_count) { struct node node2; @@ -1333,33 +1333,33 @@ void testNode(struct node &node, struct node &expbuf_node, media_type type, node.reopen(); if (!(node.codec_mask & (STATEFUL_ENCODER | STATEFUL_DECODER))) { printf("\ttest MMAP (no poll): %s\n", - ok(testMmap(&node, frame_count, POLL_MODE_NONE))); + ok(testMmap(&node, &node_m2m_cap, frame_count, POLL_MODE_NONE))); node.reopen(); } printf("\ttest MMAP (select): %s\n", - ok(testMmap(&node, frame_count, POLL_MODE_SELECT))); + ok(testMmap(&node, &node_m2m_cap, frame_count, POLL_MODE_SELECT))); node.reopen(); printf("\ttest MMAP (epoll): %s\n", - ok(testMmap(&node, frame_count, POLL_MODE_EPOLL))); + ok(testMmap(&node, &node_m2m_cap, frame_count, POLL_MODE_EPOLL))); node.reopen(); if (!(node.codec_mask & (STATEFUL_ENCODER | STATEFUL_DECODER))) { printf("\ttest USERPTR (no poll): %s\n", - ok(testUserPtr(&node, frame_count, POLL_MODE_NONE))); + ok(testUserPtr(&node, &node_m2m_cap, frame_count, POLL_MODE_NONE))); node.reopen(); } printf("\ttest USERPTR (select): %s\n", - ok(testUserPtr(&node, frame_count, POLL_MODE_SELECT))); + ok(testUserPtr(&node, &node_m2m_cap, frame_count, POLL_MODE_SELECT))); node.reopen(); if (options[OptSetExpBufDevice] || !(node.valid_memorytype & (1 << V4L2_MEMORY_DMABUF))) { if (!(node.codec_mask & (STATEFUL_ENCODER | STATEFUL_DECODER))) { printf("\ttest DMABUF (no poll): %s\n", - ok(testDmaBuf(&expbuf_node, &node, frame_count, - POLL_MODE_NONE))); + ok(testDmaBuf(&expbuf_node, &node, &node_m2m_cap, + frame_count, POLL_MODE_NONE))); node.reopen(); } printf("\ttest DMABUF (select): %s\n", - ok(testDmaBuf(&expbuf_node, &node, frame_count, POLL_MODE_SELECT))); + ok(testDmaBuf(&expbuf_node, &node, &node_m2m_cap, frame_count, POLL_MODE_SELECT))); node.reopen(); } else if (!options[OptSetExpBufDevice]) { printf("\ttest DMABUF: Cannot test, specify --expbuf-device\n"); @@ -1707,7 +1707,7 @@ int main(int argc, char **argv) } } - testNode(node, expbuf_node, type, frame_count, all_fmt_frame_count); + testNode(node, node, expbuf_node, type, frame_count, all_fmt_frame_count); if (!expbuf_device.empty()) expbuf_node.close(); diff --git a/utils/v4l2-compliance/v4l2-compliance.h b/utils/v4l2-compliance/v4l2-compliance.h index 152a6c6d9c76..6aba3828c27a 100644 --- a/utils/v4l2-compliance/v4l2-compliance.h +++ b/utils/v4l2-compliance/v4l2-compliance.h @@ -258,7 +258,7 @@ int check_string(const char *s, size_t len); int check_ustring(const __u8 *s, int len); int check_0(const void *p, int len); int restoreFormat(struct node *node); -void testNode(struct node &node, struct node &expbuf_node, media_type type, +void testNode(struct node &node, struct node &node_m2m_cap, struct node &expbuf_node, media_type type, unsigned frame_count, unsigned all_fmt_frame_count); std::string stream_from(std::string pixelformat, bool &use_hdr); @@ -331,9 +331,23 @@ int testReqBufs(struct node *node); int testReadWrite(struct node *node); int testExpBuf(struct node *node); int testBlockingWait(struct node *node); -int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode); -int testUserPtr(struct node *node, unsigned frame_count, enum poll_mode pollmode); -int testDmaBuf(struct node *expbuf_node, struct node *node, unsigned frame_count, +/* + * struct node node: + * the current media node being tested + * + * struct node node_m2m_cap: + * the capture device to be used when testing loopback or m2m, for + * instance, if the node we are testing is m2m, then node == node_m2m_cap, + * but if we have a topology like output->capture, node will be the output + * and node_m2m_cap will be the capture device that v4l2-compliance will + * use to test the loop + */ +int testMmap(struct node *node, struct node *node_m2m_cap, unsigned frame_count, + enum poll_mode pollmode); +int testUserPtr(struct node *node, struct node *node_m2m_cap, + unsigned frame_count, enum poll_mode pollmode); +int testDmaBuf(struct node *expbuf_node, struct node *node, + struct node *node_m2m_cap, unsigned frame_count, enum poll_mode pollmode); int testRequests(struct node *node, bool test_streaming); void streamAllFormats(struct node *node, unsigned frame_count); diff --git a/utils/v4l2-compliance/v4l2-test-buffers.cpp b/utils/v4l2-compliance/v4l2-test-buffers.cpp index fefe3e7b5669..029d0ed0ea02 100644 --- a/utils/v4l2-compliance/v4l2-test-buffers.cpp +++ b/utils/v4l2-compliance/v4l2-test-buffers.cpp @@ -836,7 +836,7 @@ static int setupM2M(struct node *node, cv4l_queue &q, bool init = true) return 0; } -static int captureBufs(struct node *node, const cv4l_queue &q, +static int captureBufs(struct node *node, struct node *node_m2m_cap, const cv4l_queue &q, cv4l_queue &m2m_q, unsigned frame_count, int pollmode, unsigned &capture_count) { @@ -885,8 +885,8 @@ static int captureBufs(struct node *node, const cv4l_queue &q, V4L2_FMT_FLAG_COMPRESSED) valid_output_flags = V4L2_BUF_FLAG_TIMECODE | V4L2_BUF_FLAG_TSTAMP_SRC_MASK; if (node->is_m2m) { - node->g_fmt(fmt_q, m2m_q.g_type()); - if (node->buftype_pixfmts[m2m_q.g_type()][fmt_q.g_pixelformat()] & + node_m2m_cap->g_fmt(fmt_q, m2m_q.g_type()); + if (node_m2m_cap->buftype_pixfmts[m2m_q.g_type()][fmt_q.g_pixelformat()] & V4L2_FMT_FLAG_COMPRESSED) valid_output_flags = V4L2_BUF_FLAG_TIMECODE | V4L2_BUF_FLAG_TSTAMP_SRC_MASK; @@ -1045,7 +1045,7 @@ static int captureBufs(struct node *node, const cv4l_queue &q, buf.init(m2m_q); do { - ret = buf.dqbuf(node); + ret = buf.dqbuf(node_m2m_cap); } while (ret == EAGAIN); capture_count++; @@ -1072,16 +1072,16 @@ static int captureBufs(struct node *node, const cv4l_queue &q, } fail_on_test(buf.g_flags() & V4L2_BUF_FLAG_DONE); if (!count || stopped) { - if (!(node->codec_mask & (STATEFUL_ENCODER | STATEFUL_DECODER))) + if (!(node_m2m_cap->codec_mask & (STATEFUL_ENCODER | STATEFUL_DECODER))) break; if (buf.g_flags() & V4L2_BUF_FLAG_LAST) { - fail_on_test(buf.dqbuf(node) != EPIPE); + fail_on_test(buf.dqbuf(node_m2m_cap) != EPIPE); fail_on_test(!got_eos && !got_source_change); if (!count) break; - fail_on_test(node->streamoff(m2m_q.g_type())); - m2m_q.munmap_bufs(node); - fail_on_test(setupM2M(node, m2m_q, false)); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); + m2m_q.munmap_bufs(node_m2m_cap); + fail_on_test(setupM2M(node_m2m_cap, m2m_q, false)); stopped = false; got_source_change = false; @@ -1089,12 +1089,12 @@ static int captureBufs(struct node *node, const cv4l_queue &q, memset(&cmd, 0, sizeof(cmd)); cmd.cmd = V4L2_DEC_CMD_START; - fail_on_test(doioctl(node, VIDIOC_DECODER_CMD, &cmd)); + fail_on_test(doioctl(node_m2m_cap, VIDIOC_DECODER_CMD, &cmd)); continue; } } buf.s_flags(buf.g_flags() & ~V4L2_BUF_FLAG_REQUEST_FD); - fail_on_test(buf.qbuf(node, m2m_q)); + fail_on_test(buf.qbuf(node_m2m_cap, m2m_q)); // If the queued buffer is immediately returned as a last // empty buffer, then FLAG_DONE is set here. // Need to look at this more closely. @@ -1210,7 +1210,8 @@ static int setupMmap(struct node *node, cv4l_queue &q) return 0; } -int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) +int testMmap(struct node *node, struct node *node_m2m_cap, unsigned frame_count, + enum poll_mode pollmode) { bool can_stream = node->g_caps() & V4L2_CAP_STREAMING; bool have_createbufs = true; @@ -1338,15 +1339,15 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) fail_on_test(ev.type != V4L2_EVENT_SOURCE_CHANGE); fail_on_test(!(ev.u.src_change.changes & V4L2_EVENT_SRC_CH_RESOLUTION)); } - fail_on_test(setupM2M(node, m2m_q)); + fail_on_test(setupM2M(node_m2m_cap, m2m_q)); } - fail_on_test(captureBufs(node, q, m2m_q, frame_count, + fail_on_test(captureBufs(node, node_m2m_cap, q, m2m_q, frame_count, pollmode, capture_count)); fail_on_test(node->streamoff(q.g_type())); fail_on_test(node->streamoff(q.g_type())); if (node->is_m2m) - fail_on_test(node->streamoff(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); if (node->codec_mask & STATEFUL_ENCODER) { struct v4l2_encoder_cmd cmd; @@ -1357,7 +1358,7 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) /* No buffers are queued, call STREAMON, then STOP */ fail_on_test(node->streamon(q.g_type())); - fail_on_test(node->streamon(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamon(m2m_q.g_type())); fail_on_test(doioctl(node, VIDIOC_ENCODER_CMD, &cmd)); fail_on_test(buf_cap.querybuf(node, 0)); @@ -1367,11 +1368,11 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) for (unsigned p = 0; p < buf_cap.g_num_planes(); p++) fail_on_test(buf_cap.g_bytesused(p)); fail_on_test(node->streamoff(q.g_type())); - fail_on_test(node->streamoff(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); /* Call STREAMON, queue one CAPTURE buffer, then STOP */ fail_on_test(node->streamon(q.g_type())); - fail_on_test(node->streamon(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamon(m2m_q.g_type())); fail_on_test(buf_cap.querybuf(node, 0)); fail_on_test(buf_cap.qbuf(node)); fail_on_test(doioctl(node, VIDIOC_ENCODER_CMD, &cmd)); @@ -1381,7 +1382,7 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) for (unsigned p = 0; p < buf_cap.g_num_planes(); p++) fail_on_test(buf_cap.g_bytesused(p)); fail_on_test(node->streamoff(q.g_type())); - fail_on_test(node->streamoff(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); } if (node->codec_mask & STATEFUL_DECODER) { @@ -1393,7 +1394,7 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) /* No buffers are queued, call STREAMON, then STOP */ fail_on_test(node->streamon(q.g_type())); - fail_on_test(node->streamon(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamon(m2m_q.g_type())); fail_on_test(doioctl(node, VIDIOC_DECODER_CMD, &cmd)); fail_on_test(buf_cap.querybuf(node, 0)); @@ -1403,11 +1404,11 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) for (unsigned p = 0; p < buf_cap.g_num_planes(); p++) fail_on_test(buf_cap.g_bytesused(p)); fail_on_test(node->streamoff(q.g_type())); - fail_on_test(node->streamoff(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); /* Call STREAMON, queue one CAPTURE buffer, then STOP */ fail_on_test(node->streamon(q.g_type())); - fail_on_test(node->streamon(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamon(m2m_q.g_type())); fail_on_test(buf_cap.querybuf(node, 0)); fail_on_test(buf_cap.qbuf(node)); fail_on_test(doioctl(node, VIDIOC_DECODER_CMD, &cmd)); @@ -1417,7 +1418,7 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) for (unsigned p = 0; p < buf_cap.g_num_planes(); p++) fail_on_test(buf_cap.g_bytesused(p)); fail_on_test(node->streamoff(q.g_type())); - fail_on_test(node->streamoff(m2m_q.g_type())); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); } if (node->supports_orphaned_bufs) { @@ -1436,15 +1437,15 @@ int testMmap(struct node *node, unsigned frame_count, enum poll_mode pollmode) if (node->is_m2m) { if (node->supports_orphaned_bufs) { fail_on_test(m2m_q.reqbufs(node, 0)); - m2m_q.munmap_bufs(node); + m2m_q.munmap_bufs(node_m2m_cap); } else if (m2m_q.reqbufs(node, 0) != EBUSY) { // It's either a bug or this driver should set // V4L2_BUF_CAP_SUPPORTS_ORPHANED_BUFS warn("Can free buffers even if still mmap()ed\n"); q.munmap_bufs(node); } else { - m2m_q.munmap_bufs(node); - fail_on_test(m2m_q.reqbufs(node, 0)); + m2m_q.munmap_bufs(node_m2m_cap); + fail_on_test(m2m_q.reqbufs(node_m2m_cap, 0)); } fail_on_test(!capture_count); } @@ -1528,7 +1529,8 @@ static int setupUserPtr(struct node *node, cv4l_queue &q) return 0; } -int testUserPtr(struct node *node, unsigned frame_count, enum poll_mode pollmode) +int testUserPtr(struct node *node, struct node *node_m2m_cap, unsigned frame_count, + enum poll_mode pollmode) { bool can_stream = node->g_caps() & V4L2_CAP_STREAMING; int type; @@ -1592,16 +1594,16 @@ int testUserPtr(struct node *node, unsigned frame_count, enum poll_mode pollmode fail_on_test(ev.type != V4L2_EVENT_SOURCE_CHANGE); fail_on_test(!(ev.u.src_change.changes & V4L2_EVENT_SRC_CH_RESOLUTION)); } - fail_on_test(setupM2M(node, m2m_q)); + fail_on_test(setupM2M(node_m2m_cap, m2m_q)); } - fail_on_test(captureBufs(node, q, m2m_q, frame_count, + fail_on_test(captureBufs(node, node_m2m_cap, q, m2m_q, frame_count, pollmode, capture_count)); fail_on_test(node->streamoff(q.g_type())); fail_on_test(node->streamoff(q.g_type())); if (node->is_m2m) { - fail_on_test(node->streamoff(m2m_q.g_type())); - m2m_q.munmap_bufs(node); - fail_on_test(m2m_q.reqbufs(node, 0)); + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); + m2m_q.munmap_bufs(node_m2m_cap); + fail_on_test(m2m_q.reqbufs(node_m2m_cap, 0)); fail_on_test(!capture_count); } stream_close(); @@ -1670,7 +1672,7 @@ static int setupDmaBuf(struct node *expbuf_node, struct node *node, return 0; } -int testDmaBuf(struct node *expbuf_node, struct node *node, +int testDmaBuf(struct node *expbuf_node, struct node *node, struct node *node_m2m_cap, unsigned frame_count, enum poll_mode pollmode) { bool can_stream = node->g_caps() & V4L2_CAP_STREAMING; @@ -1746,9 +1748,9 @@ int testDmaBuf(struct node *expbuf_node, struct node *node, fail_on_test(ev.type != V4L2_EVENT_SOURCE_CHANGE); fail_on_test(!(ev.u.src_change.changes & V4L2_EVENT_SRC_CH_RESOLUTION)); } - fail_on_test(setupM2M(node, m2m_q)); + fail_on_test(setupM2M(node_m2m_cap, m2m_q)); } - fail_on_test(captureBufs(node, q, m2m_q, frame_count, + fail_on_test(captureBufs(node, node_m2m_cap, q, m2m_q, frame_count, pollmode, capture_count)); fail_on_test(node->streamoff(q.g_type())); fail_on_test(node->streamoff(q.g_type())); @@ -1765,18 +1767,18 @@ int testDmaBuf(struct node *expbuf_node, struct node *node, fail_on_test(q.reqbufs(node, 0)); } if (node->is_m2m) { - fail_on_test(node->streamoff(m2m_q.g_type())); - if (node->supports_orphaned_bufs) { + fail_on_test(node_m2m_cap->streamoff(m2m_q.g_type())); + if (node_m2m_cap->supports_orphaned_bufs) { fail_on_test(m2m_q.reqbufs(node, 0)); - m2m_q.munmap_bufs(node); - } else if (m2m_q.reqbufs(node, 0) != EBUSY) { + m2m_q.munmap_bufs(node_m2m_cap); + } else if (m2m_q.reqbufs(node_m2m_cap, 0) != EBUSY) { // It's either a bug or this driver should set // V4L2_BUF_CAP_SUPPORTS_ORPHANED_BUFS warn("Can free buffers even if still mmap()ed\n"); q.munmap_bufs(node); } else { - m2m_q.munmap_bufs(node); - fail_on_test(m2m_q.reqbufs(node, 0)); + m2m_q.munmap_bufs(node_m2m_cap); + fail_on_test(m2m_q.reqbufs(node_m2m_cap, 0)); } fail_on_test(!capture_count); } @@ -2086,7 +2088,7 @@ int testRequests(struct node *node, bool test_streaming) if (test_streaming) { unsigned capture_count; - fail_on_test(captureBufs(node, q, m2m_q, num_bufs, + fail_on_test(captureBufs(node, node, q, m2m_q, num_bufs, POLL_MODE_SELECT, capture_count)); } fail_on_test(node->streamoff(q.g_type())); @@ -2824,7 +2826,7 @@ static void streamM2MRun(struct node *node, unsigned frame_count) fcc2s(cap_fmt.g_pixelformat()).c_str(), pixfmt2s(cap_fmt.g_pixelformat()).c_str(), cap_fmt.g_width(), cap_fmt.g_height(), - ok(testMmap(node, frame_count, POLL_MODE_SELECT))); + ok(testMmap(node, node, frame_count, POLL_MODE_SELECT))); } static int streamM2MOutFormat(struct node *node, __u32 pixelformat, __u32 w, __u32 h, diff --git a/utils/v4l2-compliance/v4l2-test-media.cpp b/utils/v4l2-compliance/v4l2-test-media.cpp index 03314b9dbe4c..a8b84b9a5908 100644 --- a/utils/v4l2-compliance/v4l2-test-media.cpp +++ b/utils/v4l2-compliance/v4l2-test-media.cpp @@ -601,7 +601,7 @@ void walkTopology(struct node &node, struct node &expbuf_node, continue; } - testNode(test_node, expbuf_node, type, + testNode(test_node, test_node, expbuf_node, type, frame_count, all_fmt_frame_count); test_node.close(); } _______________________________________________ linuxtv-commits mailing list linuxtv-commits@linuxtv.org https://www.linuxtv.org/cgi-bin/mailman/listinfo/linuxtv-commits
