external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

bugfix: fix rtcp nack blp encode bug (#2966)

Browse source 
Co-authored-by: Winlin <winlin@vip.126.com>
This commit is contained in:
ChenGH 2022-03-15 08:40:06 +08:00 • committed by GitHub
parent 636066124a
commit 70aa6b66bb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 35 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
trunk/src/kernel/srs_kernel_rtc_rtcp.cpp
View file

@ -1346,9 +1346,11 @@ srs_error_t SrsRtcpNack::encode(SrsBuffer *buffer)
if((sn - pid) < 1) { if((sn - pid) < 1) {
srs_info("skip seq %d", sn); srs_info("skip seq %d", sn);
} else if( (sn - pid) > 16) { } else if( (sn - pid) > 16) {
// add new chunk // append full chunk
chunks.push_back(chunk); chunks.push_back(chunk);
chunk.pid = sn;
// start new chunk
chunk.pid = sn;
chunk.blp = 0; chunk.blp = 0;
chunk.in_use = true; chunk.in_use = true;
pid = sn; pid = sn;

31
trunk/src/utest/srs_utest_rtc.cpp
View file

@ -1169,6 +1169,36 @@ VOID TEST(KernelRTCTest, SyncTimestampBySenderReportConsecutive)
} }
} }
VOID TEST(KernelRTCTest, SrsRtcpNack)
{
uint32_t sender_ssrc = 0x0A;
uint32_t media_ssrc = 0x0B;
SrsRtcpNack nack_encoder(sender_ssrc);
nack_encoder.set_media_ssrc(media_ssrc);
for (uint16_t seq = 15; seq < 45; seq++) {
nack_encoder.add_lost_sn(seq);
}
EXPECT_FALSE(nack_encoder.empty());
char buf[kRtcpPacketSize];
SrsBuffer stream(buf, sizeof(buf));
srs_error_t err = srs_success;
err = nack_encoder.encode(&stream);
EXPECT_EQ(srs_error_code(err), srs_success);
SrsRtcpNack nack_decoder;
stream.skip(-stream.pos());
err = nack_decoder.decode(&stream);
EXPECT_EQ(srs_error_code(err), srs_success);
vector<uint16_t> actual_lost_sn = nack_encoder.get_lost_sns();
vector<uint16_t> req_lost_sns = nack_decoder.get_lost_sns();
EXPECT_EQ(actual_lost_sn.size(), req_lost_sns.size());
}
VOID TEST(KernelRTCTest, SyncTimestampBySenderReportDuplicated) VOID TEST(KernelRTCTest, SyncTimestampBySenderReportDuplicated)
{ {
SrsRtcConnection s(NULL, SrsContextId()); SrsRtcConnection s(NULL, SrsContextId());
@ -1243,3 +1273,4 @@ VOID TEST(KernelRTCTest, SyncTimestampBySenderReportDuplicated)
} }
} }
} }