external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-02-13 20:01:56 +00:00
Code Issues Releases Wiki Activity

RTC: Update nack stat

Browse source
This commit is contained in:
winlin 2020-07-26 23:18:56 +08:00
parent 5f7de58095
commit b3212a12de
3 changed files with 14 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
trunk/src/app/srs_app_rtc_conn.cpp
View file

@ -486,6 +486,9 @@ void SrsRtcPlayStream::nack_fetch(vector<SrsRtpPacket2*>& pkts, uint32_t ssrc, u
SrsRtcAudioSendTrack* track = it->second; SrsRtcAudioSendTrack* track = it->second;
if (track->has_ssrc(ssrc)) { if (track->has_ssrc(ssrc)) {
// update recv nack statistic
track->on_recv_nack();
SrsRtpPacket2* pkt = track->fetch_rtp_packet(seq); SrsRtpPacket2* pkt = track->fetch_rtp_packet(seq);
if (pkt != NULL) { if (pkt != NULL) {
pkts.push_back(pkt); pkts.push_back(pkt);
@ -501,6 +504,9 @@ void SrsRtcPlayStream::nack_fetch(vector<SrsRtpPacket2*>& pkts, uint32_t ssrc, u
SrsRtcVideoSendTrack* track = it->second; SrsRtcVideoSendTrack* track = it->second;
if (track->has_ssrc(ssrc)) { if (track->has_ssrc(ssrc)) {
// update recv nack statistic
track->on_recv_nack();
SrsRtpPacket2* pkt = track->fetch_rtp_packet(seq); SrsRtpPacket2* pkt = track->fetch_rtp_packet(seq);
if (pkt != NULL) { if (pkt != NULL) {
pkts.push_back(pkt); pkts.push_back(pkt);

7
trunk/src/app/srs_app_rtc_source.cpp
View file

@ -1769,6 +1769,13 @@ srs_error_t SrsRtcSendTrack::on_rtcp(SrsRtpPacket2* pkt)
return srs_success; return srs_success;
} }
void SrsRtcSendTrack::on_recv_nack()
{
SrsRtcTrackStatistic* statistic = statistic_;
statistic->nacks++;
}
SrsRtcAudioSendTrack::SrsRtcAudioSendTrack(SrsRtcConnection* session, SrsRtcTrackDescription* track_desc) SrsRtcAudioSendTrack::SrsRtcAudioSendTrack(SrsRtcConnection* session, SrsRtcTrackDescription* track_desc)
: SrsRtcSendTrack(session, track_desc, true) : SrsRtcSendTrack(session, track_desc, true)
{ {

1
trunk/src/app/srs_app_rtc_source.hpp
View file

@ -517,6 +517,7 @@ public:
public: public:
virtual srs_error_t on_rtp(SrsRtpPacket2* pkt, SrsRtcPlayStreamStatistic& info); virtual srs_error_t on_rtp(SrsRtpPacket2* pkt, SrsRtcPlayStreamStatistic& info);
virtual srs_error_t on_rtcp(SrsRtpPacket2* pkt); virtual srs_error_t on_rtcp(SrsRtpPacket2* pkt);
virtual void on_recv_nack();
}; };
class SrsRtcAudioSendTrack : public SrsRtcSendTrack class SrsRtcAudioSendTrack : public SrsRtcSendTrack