From 3e52c086bcdeb2293e4a182863bcb984c79315d5 Mon Sep 17 00:00:00 2001 From: houxiao <houxiao@454eff88-639b-444f-9e54-f578c98de674> Date: 星期五, 11 八月 2017 18:49:23 +0800 Subject: [PATCH] bug fix for rtsp server --- RtspFace/PL_RTSPServer2.cpp | 11 +++++++++-- 1 files changed, 9 insertions(+), 2 deletions(-) diff --git a/RtspFace/PL_RTSPServer2.cpp b/RtspFace/PL_RTSPServer2.cpp index b0235bc..793276a 100644 --- a/RtspFace/PL_RTSPServer2.cpp +++ b/RtspFace/PL_RTSPServer2.cpp @@ -129,6 +129,12 @@ } } + int ret = pthread_mutex_lock(_this->in->queue_empty_mutex); + if (ret != 0) + { + LOG_WARN << "pthread_mutex_lock queue_empty_mutex, ret=" << ret << std::endl; + } + ScopeLocker<pthread_mutex_t>(_this->in->queue_mutex); if (_this->lastBuffer != nullptr) @@ -145,7 +151,7 @@ buffer = _this->lastBuffer->buffer; buffSize = _this->lastBuffer->buffSize; - LOG_INFO << "DeliverFrameCallback buffSize=" << buffSize << LOG_ENDL; + //LOG_INFO << "DeliverFrameCallback buffSize=" << buffSize << LOG_ENDL; //static size_t f = 0; //static FILE *pFile = fopen("/data/bb.264", "wb"); //fwrite(buffer, sizeof(char), buffSize, pFile); @@ -194,6 +200,7 @@ bool PL_RTSPServer2::init(void* args) { RTSPServer2_Internal* in = (RTSPServer2_Internal*)internal; + in->reset(); if (args) { @@ -288,7 +295,7 @@ int ret = pthread_mutex_unlock(in->queue_empty_mutex); if (ret != 0) { - //LOG_WARN << "pthread_mutex_unlock queue_empty_mutex, ret=" << ret << std::endl; + LOG_WARN << "pthread_mutex_unlock queue_empty_mutex, ret=" << ret << std::endl; } return true; } -- Gitblit v1.8.0