优化弃帧逻辑

Hu Chunming
1 parent c19334fe
Showing 1 changed file with 14 additions and 1 deletions
src/decoder/dvpp/DvppDecoder.cpp
@@ -712,13 +712,26 @@ void DvppDecoder::doVdppVdecCallBack(acldvppStreamDesc *input, acldvppPicDesc *o
  
         bool bCached = false;
         if(width > 0 && height > 0 && outputSize > 0){
+            if (!m_bReal) {
+                while(m_bRunning) {
+                    // 非实时流，即为文件情形，因为不存在花屏问题，为保证不丢帧，这里做个循环等待
+                    m_decoded_data_queue_mtx.lock();
+                    if(m_decoded_data_queue.size() > 5){
+                        m_decoded_data_queue_mtx.unlock();
+                        std::this_thread::sleep_for(std::chrono::milliseconds(5));
+                        continue;
+                    }
+                    m_decoded_data_queue_mtx.unlock();
+                    break;
+                }
+            }
  
             // cout << m_dec_name << " 解码时间间隔： " << get_cur_time_ms() - last_ts << endl;
             // last_ts = get_cur_time_ms();
  
             // 换成解码后数据， 这里这样做的是为了保证解码一直持续进行，避免后续操作阻碍文件读取和解码从而导致花屏
             m_decoded_data_queue_mtx.lock();
-            if(m_decoded_data_queue.size() <= 5) {
+            if(m_decoded_data_queue.size() <= 25) {
                 DvppDataMemory* mem = new DvppDataMemory(width, width_stride, height, height_stride, outputSize, m_dec_name, to_string(m_dvpp_deviceId), false, frame_nb, (unsigned char *)outputDataDev);
                 if(mem){
                     m_decoded_data_queue.push(mem);