diff --git a/src/Http/HttpSession.cpp b/src/Http/HttpSession.cpp index ebe83bea..2d47e566 100644 --- a/src/Http/HttpSession.cpp +++ b/src/Http/HttpSession.cpp @@ -100,9 +100,9 @@ void HttpSession::onRecv(const Buffer::Ptr &pBuf) { } void HttpSession::onError(const SockException& err) { - if(_is_live_stream){ - uint64_t duration = _ticker.createdTime()/1000; + if (_is_live_stream) { //flv/ts播放器 + uint64_t duration = _ticker.createdTime() / 1000; WarnP(this) << "FLV/TS/FMP4播放器(" << _mediaInfo._vhost << "/" << _mediaInfo._app << "/" @@ -110,19 +110,16 @@ void HttpSession::onError(const SockException& err) { << ")断开:" << err.what() << ",耗时(s):" << duration; - GET_CONFIG(uint32_t,iFlowThreshold,General::kFlowThreshold); - if(_total_bytes_usage >= iFlowThreshold * 1024){ - NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastFlowReport, _mediaInfo, _total_bytes_usage, duration , true, static_cast(*this)); + GET_CONFIG(uint32_t, iFlowThreshold, General::kFlowThreshold); + if (_total_bytes_usage >= iFlowThreshold * 1024) { + NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastFlowReport, _mediaInfo, _total_bytes_usage, + duration, true, static_cast(*this)); } return; } //http客户端 - if (!_is_live_stream) { - TraceP(this) << err.what(); - } else { - WarnP(this) << err.what(); - } + TraceP(this) << err.what(); } void HttpSession::onManager() {