| /third_party/gstreamer/gstplugins_good/tests/check/elements/ |
| D | rtpjitterbuffer.c | 649 guint next_seqnum = latency_ms / TEST_BUF_MS + 1; in construct_deterministic_initial_state() local
678 for (seqnum = 0; seqnum < next_seqnum; seqnum++) { in construct_deterministic_initial_state()
690 for (seqnum = 0; seqnum < next_seqnum; seqnum++) { in construct_deterministic_initial_state()
709 return next_seqnum; in construct_deterministic_initial_state()
717 guint next_seqnum; in GST_START_TEST() local
721 next_seqnum = construct_deterministic_initial_state (h, latency_ms); in GST_START_TEST()
726 missing_seqnum = next_seqnum; in GST_START_TEST()
727 next_seqnum += 1; in GST_START_TEST()
728 push_test_buffer (h, next_seqnum); in GST_START_TEST()
745 fail_unless_equals_uint64 (next_seqnum * TEST_BUF_DURATION, in GST_START_TEST()
[all …]
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/rtp/ |
| D | gstrtpbasedepayload.c | 56 guint32 next_seqnum; member
718 if (G_LIKELY (priv->next_seqnum != -1)) { in gst_rtp_base_depayload_handle_buffer()
725 gap = gst_rtp_buffer_compare_seqnum (seqnum, priv->next_seqnum); in gst_rtp_base_depayload_handle_buffer()
730 priv->next_seqnum, gap); in gst_rtp_base_depayload_handle_buffer()
745 seqnum, priv->next_seqnum, gap, priv->max_reorder); in gst_rtp_base_depayload_handle_buffer()
749 "marking discont", seqnum, priv->next_seqnum); in gst_rtp_base_depayload_handle_buffer()
755 priv->next_seqnum = (seqnum + 1) & 0xffff; in gst_rtp_base_depayload_handle_buffer()
925 filter->priv->next_seqnum = -1; in gst_rtp_base_depayload_handle_event()
1546 priv->next_seqnum = -1; in gst_rtp_base_depayload_change_state()
|
| D | gstrtpbasepayload.c | 43 guint16 next_seqnum; member
1287 payload->priv->next_seqnum = payload->seqnum_base; in gst_rtp_base_payload_negotiate()
1845 payload->seqnum = priv->next_seqnum; in gst_rtp_base_payload_prepare_push()
1942 priv->next_seqnum = data.seqnum; in gst_rtp_base_payload_prepare_push()
2280 priv->next_seqnum = rtpbasepayload->seqnum_base; in gst_rtp_base_payload_change_state()
|
| /third_party/gstreamer/gstplugins_good/gst/rtp/ |
| D | gstrtpulpfecdec.h | 72 guint16 next_seqnum; member
|
| D | gstrtpulpfecdec.c | 389 gst_rtp_buffer_set_seq (&rtp, self->next_seqnum++); in gst_rtp_ulpfec_dec_chain()
442 gst_rtp_buffer_set_seq (&rtp, self->next_seqnum++); in gst_rtp_ulpfec_dec_handle_packet_loss()
581 self->next_seqnum = g_random_int_range (0, G_MAXINT16); in gst_rtp_ulpfec_dec_init()
|
| /third_party/gstreamer/gstplugins_good/gst/rtpmanager/ |
| D | gstrtpjitterbuffer.c | 341 guint32 next_seqnum; member
1441 if (priv->next_seqnum == -1) { in gst_jitter_buffer_sink_parse_caps()
1442 priv->next_seqnum = val; in gst_jitter_buffer_sink_parse_caps()
1586 priv->next_seqnum = -1; in gst_rtp_jitter_buffer_flush_stop()
2828 priv->next_seqnum = gst_rtp_buffer_get_seq (&gap_rtp); in gst_rtp_jitter_buffer_reset()
2831 priv->next_seqnum = seqnum; in gst_rtp_jitter_buffer_reset()
3238 priv->next_seqnum = (old_item->seqnum + old_item->count) & 0xffff; in gst_rtp_jitter_buffer_chain()
3573 priv->next_seqnum = (seqnum + item->count) & 0xffff; in pop_and_push_next()
3665 guint32 next_seqnum; in handle_next_buffer() local
3688 next_seqnum = priv->next_seqnum; in handle_next_buffer()
[all …]
|
| D | gstrtprtxsend.c | 129 guint16 seqnum_base, next_seqnum; member
142 data->next_seqnum = data->seqnum_base = g_random_int_range (0, G_MAXUINT16); in ssrc_rtx_data_new()
401 seqnum = data->next_seqnum++; in gst_rtp_rtx_buffer_new()
|
| /third_party/gstreamer/gstplugins_bad/gst/rist/ |
| D | gstristsrc.c | 314 guint16 next_seqnum = g_array_index (nacks, guint16, j); in gst_rist_src_on_sending_nacks() local
315 diff = gst_rtp_buffer_compare_seqnum (seqnum, next_seqnum); in gst_rist_src_on_sending_nacks()
316 GST_TRACE ("[%u][%u] %u %u diff %i", i, j, seqnum, next_seqnum, diff); in gst_rist_src_on_sending_nacks()
332 guint16 next_seqnum = g_array_index (nacks, guint16, i); in gst_rist_src_on_sending_nacks() local
333 diff = gst_rtp_buffer_compare_seqnum (seqnum, next_seqnum); in gst_rist_src_on_sending_nacks()
336 seqnum = next_seqnum; in gst_rist_src_on_sending_nacks()
|
| D | gstristrtxsend.c | 145 guint16 seqnum_base, next_seqnum; member
163 data->next_seqnum = data->seqnum_base = g_random_int_range (0, G_MAXUINT16); in ssrc_rtx_data_new()
|
| /third_party/gstreamer/gstreamer/libs/gst/base/ |
| D | gstaggregator.c | 365 guint32 next_seqnum; member
1595 priv->next_seqnum = seqnum; in gst_aggregator_flush_start()
2237 self->priv->next_seqnum = gst_event_get_seqnum (event); in gst_aggregator_send_event()
2366 if (gst_event_get_seqnum (event) == self->priv->next_seqnum) { in gst_aggregator_do_seek()
2369 self->priv->next_seqnum); in gst_aggregator_do_seek()
2374 self->priv->next_seqnum = gst_event_get_seqnum (event); in gst_aggregator_do_seek()
2390 gst_event_set_seqnum (event, self->priv->next_seqnum); in gst_aggregator_do_seek()
2410 gst_event_set_seqnum (event, self->priv->next_seqnum); in gst_aggregator_do_seek()
|
| /third_party/gstreamer/gstplugins_good/ |
| D | ChangeLog | 9893 1. priv->next_seqnum will be set to the first RTX packet
9898 And, since we now have a priv->next_seqnum that will never arrive
29876 rtpjitterbuffer: Fix calculating next_seqnum when dropping old buffers from a full queue.
51708 rtpjitterbuffer: signal when next_seqnum changed
51709 Signal the pushing thread when the next_seqnum changed and we might be
56670 rtpjitterbuffer: fix race when updating the next_seqnum
56672 event in the jitterbuffer, we end up not updating the next_seqnum and wait
57044 First send the lost event, then update the next_seqnum counter and then
|