amass/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2024-11-25 20:27:34 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

整理webrtc相关日志

Browse Source
This commit is contained in:
xiongziliang 2022-02-27 21:26:49 +08:00
parent a0b464958c
commit f8ef5579ee
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
webrtc/RtpExt.cpp
View File

@ -582,7 +582,7 @@ RtpExt RtpExtContext::changeRtpExtId(const RtpHeader *header, bool is_recv, stri
if (is_recv) { if (is_recv) {
auto it = _rtp_ext_id_to_type.find(pr.first); auto it = _rtp_ext_id_to_type.find(pr.first);
if (it == _rtp_ext_id_to_type.end()) { if (it == _rtp_ext_id_to_type.end()) {
WarnL << "接收rtp时,忽略不识别的rtp ext, id=" << (int) pr.first; //TraceL << "接收rtp时,忽略不识别的rtp ext, id=" << (int) pr.first;
pr.second.clearExt(); pr.second.clearExt();
continue; continue;
} }
@ -598,7 +598,7 @@ RtpExt RtpExtContext::changeRtpExtId(const RtpHeader *header, bool is_recv, stri
pr.second.setType((RtpExtType) pr.first); pr.second.setType((RtpExtType) pr.first);
auto it = _rtp_ext_type_to_id.find((RtpExtType) pr.first); auto it = _rtp_ext_type_to_id.find((RtpExtType) pr.first);
if (it == _rtp_ext_type_to_id.end()) { if (it == _rtp_ext_type_to_id.end()) {
WarnL << "发送rtp时, 忽略不被客户端支持rtp ext:" << pr.second.dumpString(); //TraceL << "发送rtp时, 忽略不被客户端支持rtp ext:" << pr.second.dumpString();
pr.second.clearExt(); pr.second.clearExt();
continue; continue;
} }

6
webrtc/WebRtcTransport.cpp
View File

@ -816,7 +816,7 @@ void WebRtcTransportImp::onSendRtp(const RtpPacket::Ptr &rtp, bool flush, bool r
#endif #endif
} else { } else {
//发送rtx重传包 //发送rtx重传包
TraceL << "send rtx rtp:" << rtp->getSeq(); //TraceL << "send rtx rtp:" << rtp->getSeq();
} }
pair<bool/*rtx*/, MediaTrack *> ctx{rtx, track.get()}; pair<bool/*rtx*/, MediaTrack *> ctx{rtx, track.get()};
sendRtpPacket(rtp->data() + RtpPacket::kRtpTcpHeaderSize, rtp->size() - RtpPacket::kRtpTcpHeaderSize, flush, &ctx); sendRtpPacket(rtp->data() + RtpPacket::kRtpTcpHeaderSize, rtp->size() - RtpPacket::kRtpTcpHeaderSize, flush, &ctx);
@ -875,6 +875,10 @@ void WebRtcTransportImp::onShutdown(const SockException &ex){
void WebRtcTransportImp::setSession(Session::Ptr session) { void WebRtcTransportImp::setSession(Session::Ptr session) {
_history_sessions.emplace(session.get(), session); _history_sessions.emplace(session.get(), session);
if (_selected_session) {
InfoL << "network exchange: " << _selected_session->get_peer_ip() << ":" << _selected_session->get_peer_port()
<< " -> " << session->get_peer_ip() << ":" << session->get_peer_port();
}
_selected_session = std::move(session); _selected_session = std::move(session);
unrefSelf(); unrefSelf();
} }