{"id":13047,"url":"https://patchwork.libcamera.org/api/patches/13047/?format=json","web_url":"https://patchwork.libcamera.org/patch/13047/","project":{"id":1,"url":"https://patchwork.libcamera.org/api/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":"<20210719191438.189046-4-nfraprado@collabora.com>","date":"2021-07-19T19:14:38","name":"[libcamera-devel,3/3] libcamera: pipeline: rkisp1: Add internal request queue","commit_ref":null,"pull_url":null,"state":"superseded","archived":false,"hash":"44f662217994d6123bd1010bda3c90428cd97197","submitter":{"id":84,"url":"https://patchwork.libcamera.org/api/people/84/?format=json","name":"Nícolas F. R. A. Prado","email":"nfraprado@collabora.com"},"delegate":null,"mbox":"https://patchwork.libcamera.org/patch/13047/mbox/","series":[{"id":2256,"url":"https://patchwork.libcamera.org/api/series/2256/?format=json","web_url":"https://patchwork.libcamera.org/project/libcamera/list/?series=2256","date":"2021-07-19T19:14:35","name":"libcamera: pipeline: Add internal request queue","version":1,"mbox":"https://patchwork.libcamera.org/series/2256/mbox/"}],"comments":"https://patchwork.libcamera.org/api/patches/13047/comments/","check":"pending","checks":"https://patchwork.libcamera.org/api/patches/13047/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 AF1B0C322C\n\tfor ;\n\tMon, 19 Jul 2021 19:15:02 +0000 (UTC)","from lancelot.ideasonboard.com (localhost [IPv6:::1])\n\tby lancelot.ideasonboard.com (Postfix) with ESMTP id 7787B6853D;\n\tMon, 19 Jul 2021 21:15:02 +0200 (CEST)","from bhuna.collabora.co.uk (bhuna.collabora.co.uk\n\t[IPv6:2a00:1098:0:82:1000:25:2eeb:e3e3])\n\tby lancelot.ideasonboard.com (Postfix) with ESMTPS id 59B2668542\n\tfor ;\n\tMon, 19 Jul 2021 21:15:01 +0200 (CEST)","from localhost.localdomain (unknown\n\t[IPv6:2804:14c:1a9:2434:2e2f:cb19:fca8:1dff])\n\t(using TLSv1.2 with cipher ECDHE-RSA-AES128-GCM-SHA256 (128/128\n\tbits))\n\t(No client certificate requested) (Authenticated sender: nfraprado)\n\tby bhuna.collabora.co.uk (Postfix) with ESMTPSA id B03291F42E0E;\n\tMon, 19 Jul 2021 20:14:59 +0100 (BST)"],"From":"=?utf-8?b?TsOtY29sYXMgRi4gUi4gQS4gUHJhZG8=?= ","To":"libcamera-devel@lists.libcamera.org","Date":"Mon, 19 Jul 2021 16:14:38 -0300","Message-Id":"<20210719191438.189046-4-nfraprado@collabora.com>","X-Mailer":"git-send-email 2.32.0","In-Reply-To":"<20210719191438.189046-1-nfraprado@collabora.com>","References":"<20210719191438.189046-1-nfraprado@collabora.com>","MIME-Version":"1.0","Content-Type":"text/plain; charset=UTF-8","Content-Transfer-Encoding":"8bit","Subject":"[libcamera-devel] [PATCH 3/3] libcamera: pipeline: rkisp1: Add\n\tinternal request queue","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","Cc":"kernel@collabora.com, =?utf-8?q?Andr=C3=A9_Almeida?=\n\t","Errors-To":"libcamera-devel-bounces@lists.libcamera.org","Sender":"\"libcamera-devel\" "},"content":"Add an internal queue that stores requests until there are internal\nbuffers and V4L2 buffer slots available. This avoids the need to cancel\nrequests when there is a shortage of said buffers.\n\nSigned-off-by: Nícolas F. R. A. Prado \n---\n src/libcamera/pipeline/rkisp1/rkisp1.cpp | 73 +++++++++++++++++++-----\n 1 file changed, 59 insertions(+), 14 deletions(-)","diff":"diff --git a/src/libcamera/pipeline/rkisp1/rkisp1.cpp b/src/libcamera/pipeline/rkisp1/rkisp1.cpp\nindex f4ea2fd4d4d0..f1c75b7d37c5 100644\n--- a/src/libcamera/pipeline/rkisp1/rkisp1.cpp\n+++ b/src/libcamera/pipeline/rkisp1/rkisp1.cpp\n@@ -89,6 +89,9 @@ public:\n \n \tint loadIPA(unsigned int hwRevision);\n \n+\tvoid queuePendingRequests();\n+\tvoid cancelPendingRequests();\n+\n \tStream mainPathStream_;\n \tStream selfPathStream_;\n \tstd::unique_ptr sensor_;\n@@ -102,6 +105,8 @@ public:\n \n \tstd::unique_ptr ipa_;\n \n+\tstd::queue pendingRequests_;\n+\n private:\n \tvoid queueFrameAction(unsigned int frame,\n \t\t\t const ipa::rkisp1::RkISP1Action &action);\n@@ -199,13 +204,13 @@ RkISP1FrameInfo *RkISP1Frames::create(const RkISP1CameraData *data, Request *req\n \tunsigned int frame = data->frame_;\n \n \tif (pipe_->availableParamBuffers_.empty()) {\n-\t\tLOG(RkISP1, Error) << \"Parameters buffer underrun\";\n+\t\tLOG(RkISP1, Debug) << \"Parameters buffer underrun\";\n \t\treturn nullptr;\n \t}\n \tFrameBuffer *paramBuffer = pipe_->availableParamBuffers_.front();\n \n \tif (pipe_->availableStatBuffers_.empty()) {\n-\t\tLOG(RkISP1, Error) << \"Statisitc buffer underrun\";\n+\t\tLOG(RkISP1, Debug) << \"Statistic buffer underrun\";\n \t\treturn nullptr;\n \t}\n \tFrameBuffer *statBuffer = pipe_->availableStatBuffers_.front();\n@@ -373,6 +378,52 @@ void RkISP1CameraData::metadataReady(unsigned int frame, const ControlList &meta\n \tpipe->tryCompleteRequest(info->request);\n }\n \n+void RkISP1CameraData::queuePendingRequests()\n+{\n+\twhile (!pendingRequests_.empty()) {\n+\t\tRequest *request = pendingRequests_.front();\n+\n+\t\t/*\n+\t\t * If there aren't internal buffers available, we break and try\n+\t\t * again later. If there are, we're guaranteed to also have V4L2\n+\t\t * buffer slots available to queue the request, since we should\n+\t\t * always have more (or equal) buffer slots than internal\n+\t\t * buffers.\n+\t\t */\n+\t\tRkISP1FrameInfo *info = frameInfo_.create(this, request);\n+\t\tif (!info)\n+\t\t\tbreak;\n+\n+\t\tipa::rkisp1::RkISP1Event ev;\n+\t\tev.op = ipa::rkisp1::EventQueueRequest;\n+\t\tev.frame = frame_;\n+\t\tev.bufferId = info->paramBuffer->cookie();\n+\t\tev.controls = request->controls();\n+\t\tipa_->processEvent(ev);\n+\n+\t\tframe_++;\n+\n+\t\tpendingRequests_.pop();\n+\t}\n+}\n+\n+void RkISP1CameraData::cancelPendingRequests()\n+{\n+\twhile (!pendingRequests_.empty()) {\n+\t\tRequest *request = pendingRequests_.front();\n+\n+\t\tfor (auto it : request->buffers()) {\n+\t\t\tFrameBuffer *buffer = it.second;\n+\t\t\tbuffer->cancel();\n+\t\t\tpipe_->completeBuffer(request, buffer);\n+\t\t}\n+\n+\t\tpipe_->completeRequest(request);\n+\n+\t\tpendingRequests_.pop();\n+\t}\n+}\n+\n RkISP1CameraConfiguration::RkISP1CameraConfiguration(Camera *camera,\n \t\t\t\t\t\t RkISP1CameraData *data)\n \t: CameraConfiguration()\n@@ -827,6 +878,8 @@ void PipelineHandlerRkISP1::stop(Camera *camera)\n \n \tisp_->setFrameStartEnabled(false);\n \n+\tdata->cancelPendingRequests();\n+\n \tdata->ipa_->stop();\n \n \tselfPath_.stop();\n@@ -854,18 +907,8 @@ int PipelineHandlerRkISP1::queueRequestDevice(Camera *camera, Request *request)\n {\n \tRkISP1CameraData *data = cameraData(camera);\n \n-\tRkISP1FrameInfo *info = data->frameInfo_.create(data, request);\n-\tif (!info)\n-\t\treturn -ENOENT;\n-\n-\tipa::rkisp1::RkISP1Event ev;\n-\tev.op = ipa::rkisp1::EventQueueRequest;\n-\tev.frame = data->frame_;\n-\tev.bufferId = info->paramBuffer->cookie();\n-\tev.controls = request->controls();\n-\tdata->ipa_->processEvent(ev);\n-\n-\tdata->frame_++;\n+\tdata->pendingRequests_.push(request);\n+\tdata->queuePendingRequests();\n \n \treturn 0;\n }\n@@ -1062,6 +1105,8 @@ void PipelineHandlerRkISP1::tryCompleteRequest(Request *request)\n \tdata->frameInfo_.destroy(info->frame);\n \n \tcompleteRequest(request);\n+\n+\tdata->queuePendingRequests();\n }\n \n void PipelineHandlerRkISP1::bufferReady(FrameBuffer *buffer)\n","prefixes":["libcamera-devel","3/3"]}