mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-02 12:32:29 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtptwcc: fixed parsing of old sequence number

Browse source 
Co-authored-by: Havard Graff <havard.graff@gmail.com>
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-good/-/merge_requests/927>
This commit is contained in:
Tulio Beloqui 2020-12-16 16:31:18 +01:00 committed by GStreamer Marge Bot
parent abf4b57a1c
commit 3484f21b95
2 changed files with 61 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
gst/rtpmanager/rtptwcc.c
View file

@ -794,7 +794,7 @@ _check_for_lost_packets (RTPTWCCManager * twcc, GArray * twcc_packets,
/* we have gone backwards, don't reset the expectations, /* we have gone backwards, don't reset the expectations,
but process the packet nonetheless */ but process the packet nonetheless */
if (fb_pkt_count_diff < 0) { if (fb_pkt_count_diff < 0) {
GST_WARNING ("feedback packet count going backwards (%u < %u)", GST_DEBUG ("feedback packet count going backwards (%u < %u)",
fb_pkt_count, twcc->expected_parsed_fb_pkt_count); fb_pkt_count, twcc->expected_parsed_fb_pkt_count);
return; return;
} }
@ -802,11 +802,17 @@ _check_for_lost_packets (RTPTWCCManager * twcc, GArray * twcc_packets,
/* we have jumped forwards, reset expectations, but don't trigger /* we have jumped forwards, reset expectations, but don't trigger
lost packets in case the missing fb-packet(s) arrive later */ lost packets in case the missing fb-packet(s) arrive later */
if (fb_pkt_count_diff > 0) { if (fb_pkt_count_diff > 0) {
GST_WARNING ("feedback packet count jumped ahead (%u > %u)", GST_DEBUG ("feedback packet count jumped ahead (%u > %u)",
fb_pkt_count, twcc->expected_parsed_fb_pkt_count); fb_pkt_count, twcc->expected_parsed_fb_pkt_count);
goto done; goto done;
} }
if (base_seqnum < twcc->expected_parsed_seqnum) {
GST_DEBUG ("twcc seqnum is older than expected (%u < %u)", base_seqnum,
twcc->expected_parsed_seqnum);
return;
}
packets_lost = base_seqnum - twcc->expected_parsed_seqnum; packets_lost = base_seqnum - twcc->expected_parsed_seqnum;
for (i = 0; i < packets_lost; i++) { for (i = 0; i < packets_lost; i++) {
_add_twcc_packet (twcc_packets, twcc->expected_parsed_seqnum + i, _add_twcc_packet (twcc_packets, twcc->expected_parsed_seqnum + i,

53
tests/check/elements/rtpsession.c
View file

@ -3780,6 +3780,58 @@ GST_START_TEST (test_twcc_feedback_count_wrap)
GST_END_TEST; GST_END_TEST;
GST_START_TEST (test_twcc_feedback_old_seqnum)
{
SessionHarness *h = session_harness_new ();
guint i;
GstBuffer *buf;
GstEvent *event;
GValueArray *packets_array;
guint8 fci1[] = {
0x05, 0xfd, /* base sequence number: 1533 */
0x00, 0x00, /* packet status count: 0 */
0x00, 0x00, 0x00, /* reference time: 0 */
0x00, /* feedback packet count: 255 */
0x00, 0x00, /* packet chunk: run-length, 0 */
0x00, /* 0 recv-delta */
};
guint8 fci2[] = {
0x05, 0xdc, /* base sequence number: 1500 */
0x00, 0x00, /* packet status count: 0 */
0x00, 0x00, 0x00, /* reference time: 0 */
0x01, /* feedback packet count: 1 */
0x00, 0x00, /* packet chunk: run-length, 0 */
0x00, /* 0 recv-delta */
};
buf = generate_twcc_feedback_rtcp (fci1, sizeof (fci1));
session_harness_recv_rtcp (h, buf);
buf = generate_twcc_feedback_rtcp (fci2, sizeof (fci2));
session_harness_recv_rtcp (h, buf);
/* two reconfigure events */
for (i = 0; i < 2; i++)
gst_event_unref (gst_harness_pull_upstream_event (h->send_rtp_h));
for (i = 0; i < 2; i++) {
event = gst_harness_pull_upstream_event (h->send_rtp_h);
packets_array =
g_value_get_boxed (gst_structure_get_value (gst_event_get_structure
(event), "packets"));
/* we expect zero packets due to old sequence number */
fail_unless_equals_int (packets_array->n_values, 0);
gst_event_unref (event);
}
session_harness_free (h);
}
GST_END_TEST;
static Suite * static Suite *
rtpsession_suite (void) rtpsession_suite (void)
@ -3848,6 +3900,7 @@ rtpsession_suite (void)
tcase_add_loop_test (tc_chain, test_twcc_feedback_interval, 0, tcase_add_loop_test (tc_chain, test_twcc_feedback_interval, 0,
G_N_ELEMENTS (test_twcc_feedback_interval_ctx)); G_N_ELEMENTS (test_twcc_feedback_interval_ctx));
tcase_add_test (tc_chain, test_twcc_feedback_count_wrap); tcase_add_test (tc_chain, test_twcc_feedback_count_wrap);
tcase_add_test (tc_chain, test_twcc_feedback_old_seqnum);
return s; return s;