Home
last modified time | relevance | path

Searched refs:seqnum (Results 1 – 25 of 135) sorted by relevance

123456

/third_party/gstreamer/gstplugins_good/gst/rtpmanager/
Drtptimerqueue.c74 gst_rtp_buffer_compare_seqnum (timer->seqnum, next->seqnum) < 0) in rtp_timer_is_later()
95 gst_rtp_buffer_compare_seqnum (timer->seqnum, prev->seqnum) > 0) in rtp_timer_is_sooner()
120 prev_gap = gst_rtp_buffer_compare_seqnum (timer->seqnum, prev->seqnum); in rtp_timer_is_closer_to_head()
121 head_gap = gst_rtp_buffer_compare_seqnum (head->seqnum, timer->seqnum); in rtp_timer_is_closer_to_head()
158 tail_gap = gst_rtp_buffer_compare_seqnum (timer->seqnum, tail->seqnum); in rtp_timer_is_closer_to_tail()
159 next_gap = gst_rtp_buffer_compare_seqnum (next->seqnum, timer->seqnum); in rtp_timer_is_closer_to_tail()
250 gst_rtp_buffer_compare_seqnum (timer->seqnum, it->seqnum) < 0) in rtp_timer_queue_insert_tail()
278 gst_rtp_buffer_compare_seqnum (timer->seqnum, it->seqnum) > 0) in rtp_timer_queue_insert_head()
362 rtp_timer_queue_find (RtpTimerQueue * queue, guint seqnum) in rtp_timer_queue_find() argument
364 return g_hash_table_lookup (queue->hashtable, GINT_TO_POINTER (seqnum)); in rtp_timer_queue_find()
[all …]
Drtptwcc.c54 guint16 seqnum; member
67 guint16 seqnum; member
158 recv_packet_init (RecvPacket * packet, guint16 seqnum, RTPPacketInfo * pinfo) in recv_packet_init() argument
161 packet->seqnum = seqnum; in recv_packet_init()
257 sent_packet_init (SentPacket * packet, guint16 seqnum, RTPPacketInfo * pinfo, in sent_packet_init() argument
265 packet->seqnum = seqnum; in sent_packet_init()
295 guint16 seqnum = twcc->send_seqnum++; in _set_twcc_seqnum_data() local
297 GST_WRITE_UINT16_BE (data, seqnum); in _set_twcc_seqnum_data()
298 sent_packet_init (&packet, seqnum, pinfo, buf); in _set_twcc_seqnum_data()
302 GST_TIME_FORMAT, seqnum, pinfo->pt, pinfo->marker, packet.size, in _set_twcc_seqnum_data()
[all …]
Drtptimerqueue.h62 guint16 seqnum; member
90 RtpTimer * rtp_timer_queue_find (RtpTimerQueue * queue, guint seqnum);
107 guint16 seqnum, GstClockTime timeout,
110 void rtp_timer_queue_set_expected (RtpTimerQueue * queue, guint16 seqnum,
113 void rtp_timer_queue_set_lost (RtpTimerQueue * queue, guint16 seqnum,
118 void rtp_timer_queue_set_deadline (RtpTimerQueue * queue, guint16 seqnum,
120 …d rtp_timer_queue_update_timer (RtpTimerQueue * queue, RtpTimer * timer, guint16 seqnum,
Dgstrtprtxreceive.c339 guint seqnum = 0; in gst_rtp_rtx_receive_src_event() local
344 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rtp_rtx_receive_src_event()
345 seqnum = -1; in gst_rtp_rtx_receive_src_event()
353 seqnum, ssrc); in gst_rtp_rtx_receive_src_event()
377 GUINT_TO_POINTER (seqnum), NULL, (gpointer *) & assoc)) { in gst_rtp_rtx_receive_src_event()
388 seqnum, ssrc); in gst_rtp_rtx_receive_src_event()
407 GUINT_TO_POINTER (seqnum)); in gst_rtp_rtx_receive_src_event()
413 seqnum, ssrc, assoc->ssrc); in gst_rtp_rtx_receive_src_event()
426 GUINT_TO_POINTER (seqnum), in gst_rtp_rtx_receive_src_event()
432 " needs to be retransmitted", seqnum, ssrc); in gst_rtp_rtx_receive_src_event()
[all …]
Dgstrtprtxsend.c114 guint16 seqnum; member
392 guint16 seqnum; in gst_rtp_rtx_buffer_new() local
401 seqnum = data->next_seqnum++; in gst_rtp_rtx_buffer_new()
407 seqnum, ssrc); in gst_rtp_rtx_buffer_new()
442 gst_rtp_buffer_set_seq (&new_rtp, seqnum); in gst_rtp_rtx_buffer_new()
461 return gst_rtp_buffer_compare_seqnum (b->seqnum, a->seqnum); in buffer_queue_items_cmp()
477 guint seqnum = 0; in gst_rtp_rtx_send_src_event() local
482 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rtp_rtx_send_src_event()
483 seqnum = -1; in gst_rtp_rtx_send_src_event()
490 seqnum, ssrc); in gst_rtp_rtx_send_src_event()
[all …]
Dgstrtprtxqueue.c240 guint seqnum; member
249 guint16 seqnum; in push_seqnum() local
258 seqnum = gst_rtp_buffer_get_seq (&rtpbuffer); in push_seqnum()
261 if (seqnum == data->seqnum) { in push_seqnum()
263 GST_DEBUG_OBJECT (rtx, "found %d", seqnum); in push_seqnum()
281 guint seqnum; in gst_rtp_rtx_queue_src_event() local
284 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rtp_rtx_queue_src_event()
285 seqnum = -1; in gst_rtp_rtx_queue_src_event()
287 GST_DEBUG_OBJECT (rtx, "request %d", seqnum); in gst_rtp_rtx_queue_src_event()
291 data.seqnum = seqnum; in gst_rtp_rtx_queue_src_event()
Dgstrtpjitterbuffer.c2013 new_drop_message (GstRtpJitterBuffer * jitterbuffer, guint seqnum, in new_drop_message() argument
2044 "seqnum", G_TYPE_UINT, seqnum, in new_drop_message()
2257 update_rtx_timers (GstRtpJitterBuffer * jitterbuffer, guint16 seqnum, in update_rtx_timers() argument
2264 if (timer && rtp_timer_queue_find (priv->rtx_stats_timers, timer->seqnum)) in update_rtx_timers()
2280 gap = gst_rtp_buffer_compare_seqnum (test->seqnum, seqnum); in update_rtx_timers()
2283 test->type, test->seqnum, seqnum, gap); in update_rtx_timers()
2294 rtp_timer_queue_update_timer (priv->timers, test, test->seqnum, in update_rtx_timers()
2401 guint16 seqnum, guint lost_packets, GstClockTime timestamp, in insert_lost_event() argument
2410 GST_DEBUG_OBJECT (jitterbuffer, "Packets #%d -> #%d lost", seqnum, in insert_lost_event()
2411 seqnum + lost_packets - 1); in insert_lost_event()
[all …]
Drtpjitterbuffer.c1006 guint16 seqnum; in rtp_jitter_buffer_insert() local
1014 if (item->seqnum == -1) in rtp_jitter_buffer_insert()
1017 seqnum = item->seqnum; in rtp_jitter_buffer_insert()
1025 if (qitem->seqnum == -1) { in rtp_jitter_buffer_insert()
1034 qseq = qitem->seqnum; in rtp_jitter_buffer_insert()
1037 gap = gst_rtp_buffer_compare_seqnum (seqnum, qseq); in rtp_jitter_buffer_insert()
1076 GST_DEBUG ("duplicate packet %d found", (gint) seqnum); in rtp_jitter_buffer_insert()
1102 GstClockTime pts, guint seqnum, guint count, guint rtptime, in rtp_jitter_buffer_alloc_item() argument
1114 item->seqnum = seqnum; in rtp_jitter_buffer_alloc_item()
1180 guint16 seqnum, guint lost_packets) in rtp_jitter_buffer_append_lost_event() argument
[all …]
Dgstrtphdrext-twcc.c193 twcc->seqnum = GST_READ_UINT16_BE (ext_data); in gst_rtp_header_extension_twcc_write()
197 twcc->seqnum = gst_rtp_buffer_get_seq (&rtp); in gst_rtp_header_extension_twcc_write()
201 GST_WRITE_UINT16_BE (data, twcc->seqnum); in gst_rtp_header_extension_twcc_write()
205 twcc->seqnum++; in gst_rtp_header_extension_twcc_write()
Dgstrtpst2022-1-fecdec.c272 lookup_media_packet (GstRTPST_2022_1_FecDec * dec, guint16 seqnum) in lookup_media_packet() argument
276 Item dummy = { seqnum, NULL }; in lookup_media_packet()
327 get_row_fec (GstRTPST_2022_1_FecDec * dec, guint16 seqnum) in get_row_fec() argument
337 dummy.seq = seqnum - dec->l; in get_row_fec()
347 seqdiff = gst_rtp_buffer_compare_seqnum (ret->seq, seqnum); in get_row_fec()
359 get_column_fec (GstRTPST_2022_1_FecDec * dec, guint16 seqnum) in get_column_fec() argument
367 g_hash_table_lookup (dec->column_fec_packets, GUINT_TO_POINTER (seqnum)); in get_column_fec()
395 guint16 seqnum) in xor_items() argument
428 item->seq = seqnum; in xor_items()
458 fec->D ? "row" : "column", seqnum, xored_payload_len, xored_timestamp); in xor_items()
[all …]
/third_party/gstreamer/gstplugins_good/tests/check/elements/
Drtptimerqueue.c34 fail_unless_equals_int (10, timer10->seqnum); in GST_START_TEST()
48 fail_unless_equals_int (0, timer0->seqnum); in GST_START_TEST()
80 fail_unless_equals_int (0, timer->seqnum); in GST_START_TEST()
85 fail_unless_equals_int (1, next->seqnum); in GST_START_TEST()
89 fail_unless_equals_int (3, timer->seqnum); in GST_START_TEST()
93 fail_unless_equals_int (2, prev->seqnum); in GST_START_TEST()
98 fail_unless_equals_int (2, timer->seqnum); in GST_START_TEST()
103 fail_unless_equals_int (1, prev->seqnum); in GST_START_TEST()
104 fail_unless_equals_int (3, next->seqnum); in GST_START_TEST()
108 fail_unless_equals_int (1, timer->seqnum); in GST_START_TEST()
[all …]
Drtpvp8.c54 create_rtp_vp8_buffer_full (guint seqnum, guint picid, gint picid_bits, in create_rtp_vp8_buffer_full() argument
77 packet[2] = (seqnum >> 8) & 0xff; in create_rtp_vp8_buffer_full()
78 packet[3] = (seqnum >> 0) & 0xff; in create_rtp_vp8_buffer_full()
96 create_rtp_vp8_buffer (guint seqnum, guint picid, guint picid_bits, in create_rtp_vp8_buffer() argument
99 return create_rtp_vp8_buffer_full (seqnum, picid, picid_bits, buf_pts, TRUE, in create_rtp_vp8_buffer()
608 gint seqnum = 100; in GST_START_TEST() local
617 gst_harness_push (h, create_rtp_vp8_buffer_full (seqnum, 23, in GST_START_TEST()
620 seqnum++; in GST_START_TEST()
628 gst_harness_push (h, create_rtp_vp8_buffer_full (seqnum, 24, in GST_START_TEST()
631 seqnum++; in GST_START_TEST()
[all …]
Drtprtx.c54 create_rtx_event (guint32 ssrc, guint8 payload_type, guint16 seqnum) in create_rtx_event() argument
58 "seqnum", G_TYPE_UINT, seqnum, in create_rtx_event()
102 create_rtp_buffer (guint32 ssrc, guint8 payload_type, guint16 seqnum) in create_rtp_buffer() argument
106 guint64 timestamp = gst_util_uint64_scale_int (seqnum, 90000, 30); in create_rtp_buffer()
112 gst_rtp_buffer_set_seq (&rtpbuf, seqnum); in create_rtp_buffer()
121 guint16 seqnum, guint32 timestamp) in create_rtp_buffer_with_timestamp() argument
124 GstBuffer *buf = create_rtp_buffer (ssrc, payload_type, seqnum); in create_rtp_buffer_with_timestamp()
220 guint seqnum = 100; in GST_START_TEST() local
250 for (i = 0; i < packets_num; i++, seqnum++) { in GST_START_TEST()
252 GstBuffer *inbuf = create_rtp_buffer (master_ssrc, master_pt, seqnum); in GST_START_TEST()
[all …]
Drtpfunnel.c131 generate_test_buffer (guint seqnum, guint ssrc, guint8 twcc_ext_id) in generate_test_buffer() argument
137 GST_BUFFER_PTS (buf) = seqnum * 20 * GST_MSECOND; in generate_test_buffer()
142 gst_rtp_buffer_set_seq (&rtp, seqnum); in generate_test_buffer()
143 gst_rtp_buffer_set_timestamp (&rtp, seqnum * 160); in generate_test_buffer()
148 GST_WRITE_UINT16_BE (&data, seqnum); in generate_test_buffer()
392 guint16 seqnum = i + offset; in GST_START_TEST() local
394 gst_harness_push (h0, generate_test_buffer (seqnum, 123, 5))); in GST_START_TEST()
399 guint16 seqnum = i + offset; in GST_START_TEST() local
401 fail_unless_equals_int (seqnum, get_twcc_seqnum (buf, 5)); in GST_START_TEST()
481 guint16 seqnum = i + offset0; in GST_START_TEST() local
[all …]
Drtpjitterbuffer.c532 push_test_buffer_now (GstHarness * h, guint seqnum, guint32 rtptime, in push_test_buffer_now() argument
538 GstBuffer *buf = generate_test_buffer_full (now, seqnum, rtptime); in push_test_buffer_now()
650 guint seqnum; in construct_deterministic_initial_state() local
678 for (seqnum = 0; seqnum < next_seqnum; seqnum++) { in construct_deterministic_initial_state()
679 push_test_buffer (h, seqnum); in construct_deterministic_initial_state()
690 for (seqnum = 0; seqnum < next_seqnum; seqnum++) { in construct_deterministic_initial_state()
692 fail_unless_equals_uint64 (seqnum * TEST_BUF_DURATION, in construct_deterministic_initial_state()
694 fail_unless_equals_int (seqnum, get_rtp_seq_num (buf)); in construct_deterministic_initial_state()
895 guint seqnum; in GST_START_TEST() local
906 seqnum = next_seqnum + 2; in GST_START_TEST()
[all …]
Drtpbin_buffer_list.c148 guint16 seqnum, guint32 timestamp) in create_rtp_buffer_fields() argument
165 info.data[2] = (seqnum >> 8) & 0xff; in create_rtp_buffer_fields()
166 info.data[3] = seqnum & 0xff; in create_rtp_buffer_fields()
178 check_seqnum (GstBuffer * buffer, guint16 seqnum) in check_seqnum() argument
192 fail_unless (current_seqnum == seqnum); in check_seqnum()
800 guint seqnum = 0; in create_buffer_list_muxed_rtcp() local
810 orig_buffer, payload_offset[0], payload_len[0], seqnum, 0); in create_buffer_list_muxed_rtcp()
813 seqnum++; in create_buffer_list_muxed_rtcp()
817 orig_buffer, payload_offset[0], payload_len[0], seqnum, 0); in create_buffer_list_muxed_rtcp()
820 seqnum++; in create_buffer_list_muxed_rtcp()
[all …]
Drtpvp9.c134 create_rtp_vp9_buffer_full (guint seqnum, guint picid, guint buffer_type, in create_rtp_vp9_buffer_full() argument
177 packet[2] = (seqnum >> 8) & 0xff; in create_rtp_vp9_buffer_full()
178 packet[3] = (seqnum >> 0) & 0xff; in create_rtp_vp9_buffer_full()
218 create_rtp_vp9_buffer (guint seqnum, guint picid, guint buffer_type, in create_rtp_vp9_buffer() argument
221 return create_rtp_vp9_buffer_full (seqnum, picid, buffer_type, buf_pts, TRUE, in create_rtp_vp9_buffer()
/third_party/gstreamer/gstplugins_bad/ext/avtp/
Dgstavtpaafdepay.c218 guint64 channels, depth, rate, format, tstamp, seqnum, streamid, in gst_avtp_aaf_depay_chain() local
241 res = avtp_aaf_pdu_get (pdu, AVTP_AAF_FIELD_SEQ_NUM, &seqnum); in gst_avtp_aaf_depay_chain()
292 avtpbasedepayload->seqnum = seqnum; in gst_avtp_aaf_depay_chain()
299 if (seqnum != avtpbasedepayload->seqnum) { in gst_avtp_aaf_depay_chain()
301 " received %" G_GUINT64_FORMAT, avtpbasedepayload->seqnum, seqnum); in gst_avtp_aaf_depay_chain()
302 avtpbasedepayload->seqnum = seqnum; in gst_avtp_aaf_depay_chain()
304 avtpbasedepayload->seqnum++; in gst_avtp_aaf_depay_chain()
/third_party/gstreamer/gstplugins_bad/gst/rist/
Dgstristrtxreceive.c177 guint seqnum = 0; in gst_rist_rtx_receive_src_event() local
181 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rist_rtx_receive_src_event()
182 seqnum = -1; in gst_rist_rtx_receive_src_event()
190 seqnum, ssrc); in gst_rist_rtx_receive_src_event()
214 guint16 seqnum = 0; in gst_rist_rtx_receive_chain() local
222 seqnum = gst_rtp_buffer_get_seq (&rtp); in gst_rist_rtx_receive_chain()
249 "ssrc: %X", seqnum, ssrc); in gst_rist_rtx_receive_chain()
Dgstrist.c48 gst_rist_rtp_ext_seq (guint32 * extseqnum, guint16 seqnum) in gst_rist_rtp_ext_seq() argument
57 result = seqnum; in gst_rist_rtp_ext_seq()
60 result = seqnum + (ext & ~(0xffff)); in gst_rist_rtp_ext_seq()
Dgstristrtxsend.c394 guint seqnum = 0; in gst_rist_rtx_send_src_event() local
399 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rist_rtx_send_src_event()
400 seqnum = -1; in gst_rist_rtx_send_src_event()
407 seqnum, ssrc); in gst_rist_rtx_send_src_event()
424 extseqnum = data->seqnum_ext << 16 | seqnum; in gst_rist_rtx_send_src_event()
427 extseqnum = gst_rist_rtp_ext_seq (&max_extseqnum, seqnum); in gst_rist_rtx_send_src_event()
450 seqnum, item->extseqnum); in gst_rist_rtx_send_src_event()
455 seqnum); in gst_rist_rtx_send_src_event()
585 guint16 seqnum; in process_buffer() local
595 seqnum = gst_rtp_buffer_get_seq (&rtp); in process_buffer()
[all …]
/third_party/gstreamer/gstplugins_good/gst/rtp/
Dgstrtpulpfecdec.c400 gst_rtp_ulpfec_dec_handle_packet_loss (GstRtpUlpFecDec * self, guint16 seqnum, in gst_rtp_ulpfec_dec_handle_packet_loss() argument
407 self->caps_ssrc, seqnum); in gst_rtp_ulpfec_dec_handle_packet_loss()
414 gst_rtp_ulpfec_dec_start (self, buflist, self->fec_pt, seqnum); in gst_rtp_ulpfec_dec_handle_packet_loss()
419 if (seqnum == recovered_seq) { in gst_rtp_ulpfec_dec_handle_packet_loss()
434 self->caps_ssrc, seqnum, recovered_buffer); in gst_rtp_ulpfec_dec_handle_packet_loss()
464 seqnum); in gst_rtp_ulpfec_dec_handle_packet_loss()
481 guint seqnum; in gst_rtp_ulpfec_dec_handle_sink_event() local
511 "seqnum", G_TYPE_UINT, &seqnum, in gst_rtp_ulpfec_dec_handle_sink_event()
517 gst_rtp_ulpfec_dec_handle_packet_loss (self, seqnum, timestamp, in gst_rtp_ulpfec_dec_handle_sink_event()
/third_party/gstreamer/gstplugins_bad/gst-libs/gst/audio/
Dgstnonstreamaudiodecoder.c256 guint new_subsong, guint32 const *seqnum);
964 guint32 seqnum; in gst_nonstream_audio_decoder_src_event() local
970 seqnum = gst_event_get_seqnum (event); in gst_nonstream_audio_decoder_src_event()
974 "), switching to subsong %u", seqnum, subsong_idx); in gst_nonstream_audio_decoder_src_event()
977 &seqnum); in gst_nonstream_audio_decoder_src_event()
1511 guint new_subsong, guint32 const *seqnum) in gst_nonstream_audio_decoder_switch_to_subsong() argument
1571 if (seqnum != NULL) { in gst_nonstream_audio_decoder_switch_to_subsong()
1572 gst_event_set_seqnum (fevent, *seqnum); in gst_nonstream_audio_decoder_switch_to_subsong()
1575 *seqnum); in gst_nonstream_audio_decoder_switch_to_subsong()
1614 if (seqnum != NULL) { in gst_nonstream_audio_decoder_switch_to_subsong()
[all …]
/third_party/gstreamer/gstplugins_good/gst/imagefreeze/
Dgstimagefreeze.c225 self->seqnum = 0; in gst_image_freeze_reset()
685 guint32 seqnum; in gst_image_freeze_src_event() local
694 seqnum = gst_event_get_seqnum (event); in gst_image_freeze_src_event()
730 gst_event_set_seqnum (e, seqnum); in gst_image_freeze_src_event()
753 gst_event_set_seqnum (e, seqnum); in gst_image_freeze_src_event()
765 self->seqnum = seqnum; in gst_image_freeze_src_event()
955 if (self->seqnum) in gst_image_freeze_src_loop()
956 gst_event_set_seqnum (e, self->seqnum); in gst_image_freeze_src_loop()
1159 if (self->seqnum) in gst_image_freeze_src_loop()
1160 gst_event_set_seqnum (e, self->seqnum); in gst_image_freeze_src_loop()
[all …]
/third_party/gstreamer/gstreamer/gst/
Dgstpipeline.c146 gdouble rate, guint32 seqnum);
657 guint32 seqnum = gst_message_get_seqnum (message); in gst_pipeline_handle_message() local
662 gst_pipeline_handle_instant_rate (pipeline, rate_multiplier, seqnum); in gst_pipeline_handle_message()
1089 guint32 seqnum) in gst_pipeline_handle_instant_rate() argument
1099 pipeline->priv->instant_rate_seqnum == seqnum) { in gst_pipeline_handle_instant_rate()
1102 seqnum); in gst_pipeline_handle_instant_rate()
1153 pipeline->priv->instant_rate_seqnum = seqnum; in gst_pipeline_handle_instant_rate()
1167 gst_event_set_seqnum (event, seqnum); in gst_pipeline_handle_instant_rate()

123456