RtspFace/PipeLinePool.cpp
@@ -87,10 +87,6 @@ PipeLine* PipeLinePool::get_free() { if (pipelines_free.empty()) { PLP_MUTEX_LOCK(pl_mutex, nullptr); } PLP_MUTEX_LOCK(tsafe_mutex, nullptr); @@ -118,6 +114,19 @@ pipelines_free.insert(pl); PLP_MUTEX_UNLOCK(tsafe_mutex,); } PLP_MUTEX_UNLOCK(pl_mutex,); bool PipeLinePool::wait_free() { if (pipelines_free.empty()) { PLP_MUTEX_LOCK(pl_mutex, false); } return true; } bool PipeLinePool::notify_free() { PLP_MUTEX_UNLOCK(pl_mutex, false); }