From 9f08028f23d9e5cbfa159bec1e07d63b141a6809 Mon Sep 17 00:00:00 2001 From: zhangjixing <775834166@qq.com> Date: 星期五, 18 一月 2019 10:17:00 +0800 Subject: [PATCH] --- QiaoJiaSystem/StructureApp/AppPipeController.cpp | 37 +++++++++++++++++++++++-------------- 1 files changed, 23 insertions(+), 14 deletions(-) diff --git a/QiaoJiaSystem/StructureApp/AppPipeController.cpp b/QiaoJiaSystem/StructureApp/AppPipeController.cpp index db11a0c..457c8db 100644 --- a/QiaoJiaSystem/StructureApp/AppPipeController.cpp +++ b/QiaoJiaSystem/StructureApp/AppPipeController.cpp @@ -192,12 +192,12 @@ // int max=appPref.getIntData("n_cut_max_duration"); // recordInit(40,100); videoCaptureElement.registerConnector([&] { - + mutex.lock(); cv::Mat imageTemp = videoCaptureElement.getImage(); - std::string strNewTime; - strNewTime = AppUtil::getTimeUSecString(); - + std::string strNewTime = AppUtil::getTimeUSecString();; + mutex.unlock(); +//DBG("m_camId="<<m_camId<<" strNewTime="<<strNewTime); // cv::putText(imageTemp, strNewTime, cv::Point(408, 540), cv::HersheyFonts::FONT_HERSHEY_PLAIN, 5, // cv::Scalar(255, 255, 0), 2); if (m_camId.size() > 0) { @@ -206,7 +206,7 @@ if (bRecordVideoEnable) { newRecordVideoElement.pushImgBuf(strNewTime, imageTemp); newRecordVideoElement.setSdkTrigger(faceRpcElement.getTriggerState() ||//TODO - personElement.getTrigger() || + personElement.getTriggerState() || leftJudgment.getTriggerState() || rightJudgment.getTriggerState() || perimeterElement.getTriggerState() || @@ -214,7 +214,6 @@ perHubElement.getTriggerState() || perStaticElement.getTriggerState() ); - } @@ -254,9 +253,9 @@ imageDrawElement.submit(); } - if (bRecordVideoEnable) { - registerElement(triggerElement); - } +// if (bRecordVideoEnable) { +// registerElement(triggerElement); +// } }); @@ -303,7 +302,7 @@ registerElement(faceExtractElement); } registerElement(imageDrawElement); - registerElement(newRecordVideoElement); + // registerElement(newRecordVideoElement); videoCaptureElement.setOutPutInterval(3); faceExtractElement.setProperty("index", to_string(m_index)); registerElement(yoloRpcElement); @@ -437,10 +436,20 @@ leftJudgment.init(rule.strAreas, rule.strLine); rightJudgment.init(rule.strExAreas, rule.strExLine); yoloRpcElement.registerConnector([&] { - leftJudgment.setYoloObjects(yoloRpcElement.getLastScoreRects()); - rightJudgment.setYoloObjects(yoloRpcElement.getLastScoreRects()); - leftJudgment.setImage(yoloRpcElement.getImage()); - rightJudgment.setImage(yoloRpcElement.getImage()); + if(!leftJudgment.isBusy()) + { + leftJudgment.setYoloObjects(yoloRpcElement.getLastScoreRects()); + leftJudgment.setImage(yoloRpcElement.getImage()); + leftJudgment.submit(); + } + if(!rightJudgment.isBusy()) + { + rightJudgment.setYoloObjects(yoloRpcElement.getLastScoreRects()); + + rightJudgment.setImage(yoloRpcElement.getImage()); + rightJudgment.submit(); + } + }); registerElement(leftJudgment); registerElement(rightJudgment); -- Gitblit v1.8.0