Commit 61b29efe by xiongziliang

统一代码风格

parent 3a0fa271
......@@ -881,8 +881,7 @@ void installWebApi() {
//只是暂停流的检查,流媒体服务器做为流负载服务,收流就转发,RTSP/RTMP有自己暂停协议
lock_guard<recursive_mutex> lck(s_rtpServerMapMtx);
auto it = s_rtpServerMap.find(allArgs["stream_id"]);
if (it == s_rtpServerMap.end())
{
if (it == s_rtpServerMap.end()) {
val["hit"] = 0;
return;
}
......@@ -897,8 +896,7 @@ void installWebApi() {
lock_guard<recursive_mutex> lck(s_rtpServerMapMtx);
auto it = s_rtpServerMap.find(allArgs["stream_id"]);
if (it == s_rtpServerMap.end())
{
if (it == s_rtpServerMap.end()) {
val["hit"] = 0;
return;
}
......
......@@ -135,8 +135,10 @@ void RtpProcess::addTrackCompleted() {
}
bool RtpProcess::alive() {
if(_stop_rtp_check.load())
if (_stop_rtp_check.load()) {
return true;
}
GET_CONFIG(int, timeoutSec, RtpProxy::kTimeoutSec)
if (_last_frame_time.elapsedTime() / 1000 < timeoutSec) {
return true;
......
......@@ -56,10 +56,12 @@ public:
* 设置RtpProcess onDetach事件回调
*/
void setOnDetach(const function<void()> &cb);
/**
* 暂停Rtp服务的RTP流检测
*/
void pauseRtpCheck();
/**
* 恢复Rtp服务的RTP流检测
*/
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论