From 26458587182bf9a2bc10a5fa8e5ab6e41211da74 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期一, 22 四月 2019 13:46:02 +0800
Subject: [PATCH] 推流按cap的时间来

---
 QiaoJiaSystem/GB28181DecoderModel/VideoCaptureElementWithRtp.cpp |    9 +++++----
 1 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/QiaoJiaSystem/GB28181DecoderModel/VideoCaptureElementWithRtp.cpp b/QiaoJiaSystem/GB28181DecoderModel/VideoCaptureElementWithRtp.cpp
index cedc675..9aedc2d 100644
--- a/QiaoJiaSystem/GB28181DecoderModel/VideoCaptureElementWithRtp.cpp
+++ b/QiaoJiaSystem/GB28181DecoderModel/VideoCaptureElementWithRtp.cpp
@@ -53,6 +53,9 @@
 #ifdef TestCode
                 DBG("waitSignal(\"DecoderImageOK\") after");
 #endif
+                //            浠巉fmpeg瑙g爜绫讳腑鑾峰彇鍥剧墖
+                p_this->m_fFmpegDecoderJPG.getImage().copyTo(p_this->m_image);
+
                 {
                     if (p_this->m_publishVideoRet) {
                         if (p_this->videoPublishElement == nullptr) {
@@ -60,12 +63,12 @@
                             cv::Size size_(appConfig.getIntProperty("pulish.width"), appConfig.getIntProperty("pulish.height"));
                             int gupIdx = appPref.getIntData("gpu.index");
                             DBG("videoPublishpath: "  << p_this->m_chanPubID << path << " h:" << size_.height);
-                            p_this->videoPublishElement = new ffmpeg::VideoPublishElement(path, size_, "flv", 25, gupIdx);
+                            p_this->videoPublishElement = new ffmpeg::PipeVideoPublishElement(path, size_, "flv", 25, gupIdx);
                             p_this->videoPublishElement->start();
                         } else {
-//                            DBG("videoPublishElement->setImage() : " << p_this->m_chanPubID);
                             if (!p_this->m_image.empty()) {
                                 p_this->videoPublishElement->setImage(p_this->m_image);
+                                p_this->videoPublishElement->submit();
                             } else {
                                 ERR("m_image.empty()");
                             }
@@ -92,8 +95,6 @@
                     p_this->m_picCount.store(0);
                 }
 
-//            浠巉fmpeg瑙g爜绫讳腑鑾峰彇鍥剧墖
-                p_this->m_fFmpegDecoderJPG.getImage().copyTo(p_this->m_image);
                 {
                     cv::Mat copyMat;
                     std::string imageName = p_this->m_fFmpegDecoderJPG.GetImageName();

--
Gitblit v1.8.0