\brief AddNewFrame \param frameInfo
| 63 | /// \param frameInfo |
| 64 | /// |
| 65 | void AddNewFrame(frame_ptr frameInfo, size_t maxQueueSize) |
| 66 | { |
| 67 | #if SHOW_QUE_LOG |
| 68 | QUE_LOG << "AddNewFrame start: " << frameInfo->m_dt << std::endl; |
| 69 | #endif |
| 70 | std::lock_guard<std::mutex> lock(m_mutex); |
| 71 | |
| 72 | if (!maxQueueSize || (maxQueueSize > 0 && m_que.size() < maxQueueSize)) |
| 73 | m_que.push_back(frameInfo); |
| 74 | |
| 75 | #if SHOW_QUE_LOG |
| 76 | QUE_LOG << "AddNewFrame end: " << frameInfo->m_dt << ", frameInd " << frameInfo->m_frameInd << ", queue size " << m_que.size() << std::endl; |
| 77 | #endif |
| 78 | |
| 79 | m_cond.notify_all(); |
| 80 | } |
| 81 | |
| 82 | #if SHOW_QUE_LOG |
| 83 | /// |
no test coverage detected