{"id":16358,"url":"https://patchwork.libcamera.org/api/1.1/patches/16358/?format=json","web_url":"https://patchwork.libcamera.org/patch/16358/","project":{"id":1,"url":"https://patchwork.libcamera.org/api/1.1/projects/1/?format=json","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/1.1/people/2/?format=json","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/1.1/series/3214/?format=json","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":"","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 ;\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 ;\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":"","List-Unsubscribe":",\n\t","List-Archive":"","List-Post":"","List-Help":"","List-Subscribe":",\n\t","From":"Laurent Pinchart via libcamera-devel\n\t","Reply-To":"Laurent Pinchart ","Cc":"Nicolas Dufresne ,\n\tVedant Paranjape ","Errors-To":"libcamera-devel-bounces@lists.libcamera.org","Sender":"\"libcamera-devel\" "},"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 \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 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 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"]}