Patch Detail
Show a patch.
GET /api/patches/16358/?format=api
{ "id": 16358, "url": "https://patchwork.libcamera.org/api/patches/16358/?format=api", "web_url": "https://patchwork.libcamera.org/patch/16358/", "project": { "id": 1, "url": "https://patchwork.libcamera.org/api/projects/1/?format=api", "name": "libcamera", "link_name": "libcamera", "list_id": "libcamera_core", "list_email": "libcamera-devel@lists.libcamera.org", "web_url": "", "scm_url": "", "webscm_url": "" }, "msgid": "<20220623232210.18742-13-laurent.pinchart@ideasonboard.com>", "date": "2022-06-23T23:22:09", "name": "[libcamera-devel,12/13] gstreamer: Split completed request processing to a separate function", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "fe938f3d0b3ce026c0bef6f250899555af039b6f", "submitter": { "id": 2, "url": "https://patchwork.libcamera.org/api/people/2/?format=api", "name": "Laurent Pinchart", "email": "laurent.pinchart@ideasonboard.com" }, "delegate": null, "mbox": "https://patchwork.libcamera.org/patch/16358/mbox/", "series": [ { "id": 3214, "url": "https://patchwork.libcamera.org/api/series/3214/?format=api", "web_url": "https://patchwork.libcamera.org/project/libcamera/list/?series=3214", "date": "2022-06-23T23:21:57", "name": "gstreamer: Queue multiple requests", "version": 1, "mbox": "https://patchwork.libcamera.org/series/3214/mbox/" } ], "comments": "https://patchwork.libcamera.org/api/patches/16358/comments/", "check": "pending", "checks": "https://patchwork.libcamera.org/api/patches/16358/checks/", "tags": {}, "headers": { "Return-Path": "<libcamera-devel-bounces@lists.libcamera.org>", "X-Original-To": "parsemail@patchwork.libcamera.org", "Delivered-To": "parsemail@patchwork.libcamera.org", "Received": [ "from lancelot.ideasonboard.com (lancelot.ideasonboard.com\n\t[92.243.16.209])\n\tby patchwork.libcamera.org (Postfix) with ESMTPS id 2C482BD808\n\tfor <parsemail@patchwork.libcamera.org>;\n\tThu, 23 Jun 2022 23:22:50 +0000 (UTC)", "from lancelot.ideasonboard.com (localhost [IPv6:::1])\n\tby lancelot.ideasonboard.com (Postfix) with ESMTP id AAC2C65646;\n\tFri, 24 Jun 2022 01:22:49 +0200 (CEST)", "from perceval.ideasonboard.com (perceval.ideasonboard.com\n\t[213.167.242.64])\n\tby lancelot.ideasonboard.com (Postfix) with ESMTPS id 7186365635\n\tfor <libcamera-devel@lists.libcamera.org>;\n\tFri, 24 Jun 2022 01:22:34 +0200 (CEST)", "from pendragon.lan (62-78-145-57.bb.dnainternet.fi [62.78.145.57])\n\tby perceval.ideasonboard.com (Postfix) with ESMTPSA id F3B95DD;\n\tFri, 24 Jun 2022 01:22:33 +0200 (CEST)" ], "DKIM-Signature": [ "v=1; a=rsa-sha256; c=relaxed/simple; d=libcamera.org;\n\ts=mail; t=1656026569;\n\tbh=kuUV4cQDhCFEWyID8KjYDqKsQek9t8YM9CCLyC+tTtA=;\n\th=To:Date:In-Reply-To:References:Subject:List-Id:List-Unsubscribe:\n\tList-Archive:List-Post:List-Help:List-Subscribe:From:Reply-To:Cc:\n\tFrom;\n\tb=F4MG61uRQrBP9PokxLuohJeT1ZyBKFkomXOLHwl8nZhWeLxyVyrI59blgOLZSZHse\n\to9mWvjVEgLmbmJPx/Uas3e+xD5fmrD9wGA/6PKE261J2iBbmdcAgYy8mxs2yk6JirN\n\tFQ1QHX3fPh72FW5TTf8Yn91Q7VjU5oql0y6H6Q/pNd7L1Mw0i0i4jK7Q3jrH3Vhavd\n\tx+v1d7oFwHIixUboFwC19i9Omvfq+73dkkaaqFisA2iQ7bw0Jnc+Nc/DHY17ZvBPRN\n\tYRXD4kulQIzawj0tCTb2Ht/xRfSSwREPu5iTuQecb7y9hAefnCfOb8zw7rW5zJnuQU\n\tsHtE9sKWMiGxg==", "v=1; a=rsa-sha256; c=relaxed/simple; d=ideasonboard.com;\n\ts=mail; t=1656026554;\n\tbh=kuUV4cQDhCFEWyID8KjYDqKsQek9t8YM9CCLyC+tTtA=;\n\th=From:To:Cc:Subject:Date:In-Reply-To:References:From;\n\tb=VqyfgypRXQOpddR7Cho4y0v+6/5zlKZ1HaJIwCA27bWVJ01d2pwkZ4HF4zP5gds/X\n\tb1/T68BlZR9dxU+gQ0oSaEsoNhTG25wj11wf1EBwyjX2C3u4scEhi6yxxyW1NtAfwD\n\tmqL+/2n/otWRBhI+9gAPD9jFGdX1D28g9G4CwzpA=" ], "Authentication-Results": "lancelot.ideasonboard.com; dkim=pass (1024-bit key; \n\tunprotected) header.d=ideasonboard.com\n\theader.i=@ideasonboard.com\n\theader.b=\"VqyfgypR\"; dkim-atps=neutral", "To": "libcamera-devel@lists.libcamera.org", "Date": "Fri, 24 Jun 2022 02:22:09 +0300", "Message-Id": "<20220623232210.18742-13-laurent.pinchart@ideasonboard.com>", "X-Mailer": "git-send-email 2.35.1", "In-Reply-To": "<20220623232210.18742-1-laurent.pinchart@ideasonboard.com>", "References": "<20220623232210.18742-1-laurent.pinchart@ideasonboard.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "Subject": "[libcamera-devel] [PATCH 12/13] gstreamer: Split completed request\n\tprocessing to a separate function", "X-BeenThere": "libcamera-devel@lists.libcamera.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "<libcamera-devel.lists.libcamera.org>", "List-Unsubscribe": "<https://lists.libcamera.org/options/libcamera-devel>,\n\t<mailto:libcamera-devel-request@lists.libcamera.org?subject=unsubscribe>", "List-Archive": "<https://lists.libcamera.org/pipermail/libcamera-devel/>", "List-Post": "<mailto:libcamera-devel@lists.libcamera.org>", "List-Help": "<mailto:libcamera-devel-request@lists.libcamera.org?subject=help>", "List-Subscribe": "<https://lists.libcamera.org/listinfo/libcamera-devel>,\n\t<mailto:libcamera-devel-request@lists.libcamera.org?subject=subscribe>", "From": "Laurent Pinchart via libcamera-devel\n\t<libcamera-devel@lists.libcamera.org>", "Reply-To": "Laurent Pinchart <laurent.pinchart@ideasonboard.com>", "Cc": "Nicolas Dufresne <nicolas.dufresne@collabora.com>,\n\tVedant Paranjape <vedantparanjape160201@gmail.com>", "Errors-To": "libcamera-devel-bounces@lists.libcamera.org", "Sender": "\"libcamera-devel\" <libcamera-devel-bounces@lists.libcamera.org>" }, "content": "Simplify the task run function futher by moving the processing of\ncompleted requests to a separate function. No functional change\nintended, only increased readability.\n\nSigned-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>\n---\n src/gstreamer/gstlibcamerasrc.cpp | 125 +++++++++++++++++-------------\n 1 file changed, 73 insertions(+), 52 deletions(-)", "diff": "diff --git a/src/gstreamer/gstlibcamerasrc.cpp b/src/gstreamer/gstlibcamerasrc.cpp\nindex fb39d6093a3f..3feb87254916 100644\n--- a/src/gstreamer/gstlibcamerasrc.cpp\n+++ b/src/gstreamer/gstlibcamerasrc.cpp\n@@ -125,6 +125,7 @@ struct GstLibcameraSrcState {\n \n \tint queueRequest();\n \tvoid requestCompleted(Request *request);\n+\tint processRequest();\n };\n \n struct _GstLibcameraSrc {\n@@ -241,6 +242,63 @@ GstLibcameraSrcState::requestCompleted(Request *request)\n \tgst_task_resume(src_->task);\n }\n \n+int GstLibcameraSrcState::processRequest()\n+{\n+\tstd::unique_ptr<RequestWrap> wrap;\n+\n+\t{\n+\t\tMutexLocker locker(lock_);\n+\n+\t\tif (!completedRequests_.empty()) {\n+\t\t\twrap = std::move(completedRequests_.front());\n+\t\t\tcompletedRequests_.pop();\n+\t\t}\n+\t}\n+\n+\tif (!wrap)\n+\t\treturn -ENODATA;\n+\n+\tGstFlowReturn ret = GST_FLOW_OK;\n+\tgst_flow_combiner_reset(src_->flow_combiner);\n+\n+\tfor (GstPad *srcpad : srcpads_) {\n+\t\tStream *stream = gst_libcamera_pad_get_stream(srcpad);\n+\t\tGstBuffer *buffer = wrap->detachBuffer(stream);\n+\n+\t\tFrameBuffer *fb = gst_libcamera_buffer_get_frame_buffer(buffer);\n+\n+\t\tif (wrap->pts_) {\n+\t\t\tGST_BUFFER_PTS(buffer) = wrap->pts_;\n+\t\t\tgst_libcamera_pad_set_latency(srcpad, wrap->latency_);\n+\t\t} else {\n+\t\t\tGST_BUFFER_PTS(buffer) = 0;\n+\t\t}\n+\n+\t\tGST_BUFFER_OFFSET(buffer) = fb->metadata().sequence;\n+\t\tGST_BUFFER_OFFSET_END(buffer) = fb->metadata().sequence;\n+\n+\t\tret = gst_pad_push(srcpad, buffer);\n+\t\tret = gst_flow_combiner_update_pad_flow(src_->flow_combiner,\n+\t\t\t\t\t\t\tsrcpad, ret);\n+\t}\n+\n+\tif (ret != GST_FLOW_OK) {\n+\t\tif (ret == GST_FLOW_EOS) {\n+\t\t\tg_autoptr(GstEvent) eos = gst_event_new_eos();\n+\t\t\tguint32 seqnum = gst_util_seqnum_next();\n+\t\t\tgst_event_set_seqnum(eos, seqnum);\n+\t\t\tfor (GstPad *srcpad : srcpads_)\n+\t\t\t\tgst_pad_push_event(srcpad, gst_event_ref(eos));\n+\t\t} else if (ret != GST_FLOW_FLUSHING) {\n+\t\t\tGST_ELEMENT_FLOW_ERROR(src_, ret);\n+\t\t}\n+\n+\t\treturn -EPIPE;\n+\t}\n+\n+\treturn 0;\n+}\n+\n static bool\n gst_libcamera_src_open(GstLibcameraSrc *self)\n {\n@@ -308,8 +366,13 @@ gst_libcamera_src_task_run(gpointer user_data)\n \tGstLibcameraSrc *self = GST_LIBCAMERA_SRC(user_data);\n \tGstLibcameraSrcState *state = self->state;\n \n-\tint err = state->queueRequest();\n-\tif (err == -ENOMEM) {\n+\t/*\n+\t * Create and queue one request. If no buffers are available the\n+\t * function returns -ENOBUFS, which we ignore here as that's not a\n+\t * fatal error.\n+\t */\n+\tint ret = state->queueRequest();\n+\tif (ret == -ENOMEM) {\n \t\tGST_ELEMENT_ERROR(self, RESOURCE, NO_SPACE_LEFT,\n \t\t\t\t (\"Failed to allocate request for camera '%s'.\",\n \t\t\t\t state->cam_->id().c_str()),\n@@ -318,58 +381,16 @@ gst_libcamera_src_task_run(gpointer user_data)\n \t\treturn;\n \t}\n \n-\tstd::unique_ptr<RequestWrap> wrap;\n-\n-\t{\n-\t\tMutexLocker locker(state->lock_);\n-\n-\t\tif (!state->completedRequests_.empty()) {\n-\t\t\twrap = std::move(state->completedRequests_.front());\n-\t\t\tstate->completedRequests_.pop();\n-\t\t}\n-\t}\n-\n-\tif (!wrap) {\n-\t\tgst_task_pause(self->task);\n-\t\treturn;\n-\t}\n-\n-\tGstFlowReturn ret = GST_FLOW_OK;\n-\tgst_flow_combiner_reset(self->flow_combiner);\n-\n-\tfor (GstPad *srcpad : state->srcpads_) {\n-\t\tStream *stream = gst_libcamera_pad_get_stream(srcpad);\n-\t\tGstBuffer *buffer = wrap->detachBuffer(stream);\n-\n-\t\tFrameBuffer *fb = gst_libcamera_buffer_get_frame_buffer(buffer);\n-\n-\t\tif (wrap->pts_) {\n-\t\t\tGST_BUFFER_PTS(buffer) = wrap->pts_;\n-\t\t\tgst_libcamera_pad_set_latency(srcpad, wrap->latency_);\n-\t\t} else {\n-\t\t\tGST_BUFFER_PTS(buffer) = 0;\n-\t\t}\n-\n-\t\tGST_BUFFER_OFFSET(buffer) = fb->metadata().sequence;\n-\t\tGST_BUFFER_OFFSET_END(buffer) = fb->metadata().sequence;\n-\n-\t\tret = gst_pad_push(srcpad, buffer);\n-\t\tret = gst_flow_combiner_update_pad_flow(self->flow_combiner,\n-\t\t\t\t\t\t\tsrcpad, ret);\n-\t}\n-\n-\tif (ret != GST_FLOW_OK) {\n-\t\tif (ret == GST_FLOW_EOS) {\n-\t\t\tg_autoptr(GstEvent) eos = gst_event_new_eos();\n-\t\t\tguint32 seqnum = gst_util_seqnum_next();\n-\t\t\tgst_event_set_seqnum(eos, seqnum);\n-\t\t\tfor (GstPad *srcpad : state->srcpads_)\n-\t\t\t\tgst_pad_push_event(srcpad, gst_event_ref(eos));\n-\t\t} else if (ret != GST_FLOW_FLUSHING) {\n-\t\t\tGST_ELEMENT_FLOW_ERROR(self, ret);\n-\t\t}\n+\t/* Process one completed request, if available. */\n+\tret = state->processRequest();\n+\tswitch (ret) {\n+\tcase -EPIPE:\n \t\tgst_task_stop(self->task);\n \t\treturn;\n+\n+\tcase -ENODATA:\n+\t\tgst_task_pause(self->task);\n+\t\treturn;\n \t}\n \n \t/*\n", "prefixes": [ "libcamera-devel", "12/13" ] }