| /third_party/gstreamer/gstplugins_good/gst/rtpmanager/ |
| D | gstrtpjitterbuffer.c | 407 guint16 seqnum; member
1097 guint seqnum, guint count, guint rtptime) in alloc_item() argument
1108 item->seqnum = seqnum; in alloc_item()
2122 copy->seqnum, GST_TIME_ARGS (copy->timeout)); in timer_queue_append()
2124 g_hash_table_insert (queue->hashtable, GINT_TO_POINTER (copy->seqnum), copy); in timer_queue_append()
2135 GST_TIME_FORMAT, test->seqnum, GST_TIME_ARGS (test->timeout), in timer_queue_clear_until()
2137 g_hash_table_remove (queue->hashtable, GINT_TO_POINTER (test->seqnum)); in timer_queue_clear_until()
2144 timer_queue_find (TimerQueue * queue, guint16 seqnum) in timer_queue_find() argument
2146 return g_hash_table_lookup (queue->hashtable, GINT_TO_POINTER (seqnum)); in timer_queue_find()
2150 find_timer (GstRtpJitterBuffer * jitterbuffer, guint16 seqnum) in find_timer() argument
[all …]
|
| D | gstrtprtxreceive.c | 329 guint seqnum = 0; in gst_rtp_rtx_receive_src_event() local
334 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rtp_rtx_receive_src_event()
335 seqnum = -1; in gst_rtp_rtx_receive_src_event()
343 seqnum, ssrc); in gst_rtp_rtx_receive_src_event()
367 GUINT_TO_POINTER (seqnum), NULL, (gpointer *) & assoc)) { in gst_rtp_rtx_receive_src_event()
378 seqnum, ssrc); in gst_rtp_rtx_receive_src_event()
397 GUINT_TO_POINTER (seqnum)); in gst_rtp_rtx_receive_src_event()
403 seqnum, ssrc, assoc->ssrc); in gst_rtp_rtx_receive_src_event()
416 GUINT_TO_POINTER (seqnum), in gst_rtp_rtx_receive_src_event()
422 " needs to be retransmitted", seqnum, ssrc); in gst_rtp_rtx_receive_src_event()
[all …]
|
| D | gstrtprtxsend.c | 108 guint16 seqnum; member
377 guint16 seqnum; in gst_rtp_rtx_buffer_new() local
386 seqnum = data->next_seqnum++; in gst_rtp_rtx_buffer_new()
392 seqnum, ssrc); in gst_rtp_rtx_buffer_new()
427 gst_rtp_buffer_set_seq (&new_rtp, seqnum); in gst_rtp_rtx_buffer_new()
446 return gst_rtp_buffer_compare_seqnum (b->seqnum, a->seqnum); in buffer_queue_items_cmp()
462 guint seqnum = 0; in gst_rtp_rtx_send_src_event() local
467 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rtp_rtx_send_src_event()
468 seqnum = -1; in gst_rtp_rtx_send_src_event()
475 seqnum, ssrc); in gst_rtp_rtx_send_src_event()
[all …]
|
| D | gstrtprtxqueue.c | 231 guint seqnum; member
240 guint16 seqnum; in push_seqnum() local
249 seqnum = gst_rtp_buffer_get_seq (&rtpbuffer); in push_seqnum()
252 if (seqnum == data->seqnum) { in push_seqnum()
254 GST_DEBUG_OBJECT (rtx, "found %d", seqnum); in push_seqnum()
272 guint seqnum; in gst_rtp_rtx_queue_src_event() local
275 if (!gst_structure_get_uint (s, "seqnum", &seqnum)) in gst_rtp_rtx_queue_src_event()
276 seqnum = -1; in gst_rtp_rtx_queue_src_event()
278 GST_DEBUG_OBJECT (rtx, "request %d", seqnum); in gst_rtp_rtx_queue_src_event()
282 data.seqnum = seqnum; in gst_rtp_rtx_queue_src_event()
|
| D | rtpjitterbuffer.c | 969 guint16 seqnum; in rtp_jitter_buffer_insert() local
977 if (item->seqnum == -1) in rtp_jitter_buffer_insert()
980 seqnum = item->seqnum; in rtp_jitter_buffer_insert()
988 if (qitem->seqnum == -1) { in rtp_jitter_buffer_insert()
997 qseq = qitem->seqnum; in rtp_jitter_buffer_insert()
1000 gap = gst_rtp_buffer_compare_seqnum (seqnum, qseq); in rtp_jitter_buffer_insert()
1039 GST_DEBUG ("duplicate packet %d found", (gint) seqnum); in rtp_jitter_buffer_insert()
1255 while (high_buf && high_buf->seqnum == -1) in rtp_jitter_buffer_get_seqnum_diff()
1258 while (low_buf && low_buf->seqnum == -1) in rtp_jitter_buffer_get_seqnum_diff()
1264 high_seqnum = high_buf->seqnum; in rtp_jitter_buffer_get_seqnum_diff()
[all …]
|
| D | rtpstats.c | 34 gst_rtp_packet_rate_ctx_update (RTPPacketRateCtx * ctx, guint16 seqnum, in gst_rtp_packet_rate_ctx_update() argument
49 ctx->last_seqnum = seqnum; in gst_rtp_packet_rate_ctx_update()
55 diff_seqnum = gst_rtp_buffer_compare_seqnum (ctx->last_seqnum, seqnum); in gst_rtp_packet_rate_ctx_update()
77 ctx->last_seqnum = seqnum; in gst_rtp_packet_rate_ctx_update()
|
| D | rtpstats.h | 94 guint16 seqnum; member
217 guint32 gst_rtp_packet_rate_ctx_update (RTPPacketRateCtx *ctx, guint16 seqnum, guint32 ts);
|
| D | rtpsource.c | 1081 seqnr = pinfo->seqnum; in update_receiver_stats()
1084 gst_rtp_packet_rate_ctx_update (&src->packet_rate_ctx, pinfo->seqnum, in update_receiver_stats()
1945 rtp_source_register_nack (RTPSource * src, guint16 seqnum, in rtp_source_register_nack() argument
1956 diff = gst_rtp_buffer_compare_seqnum (tseq, seqnum); in rtp_source_register_nack()
1958 GST_TRACE ("[%u] %u %u diff %i len %u", i, tseq, seqnum, diff, len); in rtp_source_register_nack()
1965 GST_DEBUG ("update NACK #%u deadline to %" GST_TIME_FORMAT, seqnum, in rtp_source_register_nack()
1969 GST_DEBUG ("append NACK #%u with deadline %" GST_TIME_FORMAT, seqnum, in rtp_source_register_nack()
1971 g_array_append_val (src->nacks, seqnum); in rtp_source_register_nack()
1974 GST_DEBUG ("insert NACK #%u with deadline %" GST_TIME_FORMAT, seqnum, in rtp_source_register_nack()
1976 g_array_insert_val (src->nacks, i + 1, seqnum); in rtp_source_register_nack()
|
| /third_party/gstreamer/gstplugins_good/tests/check/elements/ |
| D | rtprtx.c | 54 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 …]
|
| D | rtpjitterbuffer.c | 623 guint seqnum; in construct_deterministic_initial_state() local
651 for (seqnum = 0; seqnum < next_seqnum; seqnum++) { in construct_deterministic_initial_state()
652 push_test_buffer (h, seqnum); in construct_deterministic_initial_state()
663 for (seqnum = 0; seqnum < next_seqnum; seqnum++) { in construct_deterministic_initial_state()
665 fail_unless_equals_uint64 (seqnum * TEST_BUF_DURATION, in construct_deterministic_initial_state()
667 fail_unless_equals_int (seqnum, get_rtp_seq_num (buf)); in construct_deterministic_initial_state()
869 guint seqnum; in GST_START_TEST() local
880 seqnum = next_seqnum + 2; in GST_START_TEST()
883 seqnum, seqnum * TEST_RTP_TS_DURATION))); in GST_START_TEST()
895 fail_unless_equals_int (seqnum, get_rtp_seq_num (out_buf)); in GST_START_TEST()
[all …]
|
| D | rtpbin.c | 111 guint16 seqnum; member
124 data->seqnum = 10; in init_data()
161 data->seqnum = 0; in chain_rtp_packet()
173 map.data[2] = (data->seqnum >> 8) & 0xff; in chain_rtp_packet()
174 map.data[3] = data->seqnum & 0xff; in chain_rtp_packet()
176 data->seqnum++; in chain_rtp_packet()
|
| /third_party/boringssl/src/ssl/ |
| D | ssl_aead_ctx.cc | 224 const uint8_t seqnum[8], size_t plaintext_len, Span<const uint8_t> header) { in GetAdditionalData()
229 OPENSSL_memcpy(storage, seqnum, 8); in GetAdditionalData()
242 uint16_t record_version, const uint8_t seqnum[8], in Open()
265 seqnum, plaintext_len, header); in Open()
291 OPENSSL_memcpy(nonce + nonce_len, seqnum, variable_nonce_len_); in Open()
317 const uint8_t seqnum[8], in SealScatter()
343 seqnum, in_len, header); in SealScatter()
368 OPENSSL_memcpy(nonce + nonce_len, seqnum, variable_nonce_len_); in SealScatter()
401 const uint8_t seqnum[8], Span<const uint8_t> header, in Seal()
420 record_version, seqnum, header, in, in_len, 0, 0)) { in Seal()
|
| /third_party/gstreamer/gstplugins_good/gst/imagefreeze/ |
| D | gstimagefreeze.c | 186 self->seqnum = 0; in gst_image_freeze_reset()
599 guint32 seqnum; in gst_image_freeze_src_event() local
601 seqnum = gst_event_get_seqnum (event); in gst_image_freeze_src_event()
634 gst_event_set_seqnum (e, seqnum); in gst_image_freeze_src_event()
656 gst_event_set_seqnum (e, seqnum); in gst_image_freeze_src_event()
669 self->seqnum = seqnum; in gst_image_freeze_src_event()
804 if (self->seqnum) in gst_image_freeze_src_loop()
805 gst_event_set_seqnum (e, self->seqnum); in gst_image_freeze_src_loop()
917 if (self->seqnum) in gst_image_freeze_src_loop()
918 gst_event_set_seqnum (e, self->seqnum); in gst_image_freeze_src_loop()
[all …]
|
| D | gstimagefreeze.h | 56 guint seqnum; member
|
| /third_party/gstreamer/gstplugins_good/gst/rtp/ |
| D | gstrtpulpfecdec.c | 399 gst_rtp_ulpfec_dec_handle_packet_loss (GstRtpUlpFecDec * self, guint16 seqnum, in gst_rtp_ulpfec_dec_handle_packet_loss() argument
406 self->caps_ssrc, seqnum); in gst_rtp_ulpfec_dec_handle_packet_loss()
413 gst_rtp_ulpfec_dec_start (self, buflist, self->fec_pt, seqnum); in gst_rtp_ulpfec_dec_handle_packet_loss()
418 if (seqnum == recovered_seq) { in gst_rtp_ulpfec_dec_handle_packet_loss()
433 self->caps_ssrc, seqnum, recovered_buffer); in gst_rtp_ulpfec_dec_handle_packet_loss()
463 seqnum); in gst_rtp_ulpfec_dec_handle_packet_loss()
480 guint seqnum; in gst_rtp_ulpfec_dec_handle_sink_event() local
510 "seqnum", G_TYPE_UINT, &seqnum, in gst_rtp_ulpfec_dec_handle_sink_event()
516 gst_rtp_ulpfec_dec_handle_packet_loss (self, seqnum, timestamp, in gst_rtp_ulpfec_dec_handle_sink_event()
|
| D | README | 44 seqnum-offset: (uint) [0 - MAXINT]
46 parameter is given, all sequence numbers below this seqnum should be
47 ignored. (default = seqnum of first RTP packet).
223 - deal with reordered packets based on the seqnum
283 ssrc=(guint)527842345, clock-base=(guint)1150776941, seqnum-base=(guint)30982
294 ssrc=(guint)527842345, clock-base=(guint)1150776941, seqnum-base=(guint)30982"
310 ssrc=(guint)1162703703, clock-base=(guint)816135835, seqnum-base=(guint)9294,
314 ssrc=(guint)3246149898, clock-base=(guint)4134514058, seqnum-base=(guint)57633,
325 clock-base=(guint)816135835, seqnum-base=(guint)9294, profile-level-id=(string)3,
330 clock-base=(guint)4134514058, seqnum-base=(guint)57633, encoding-params=(string)2,
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/audio/ |
| D | gstnonstreamaudiodecoder.c | 281 guint new_subsong, guint32 const *seqnum);
988 guint32 seqnum; in gst_nonstream_audio_decoder_src_event() local
994 seqnum = gst_event_get_seqnum (event); in gst_nonstream_audio_decoder_src_event()
998 "), switching to subsong %u", seqnum, subsong_idx); in gst_nonstream_audio_decoder_src_event()
1001 &seqnum); in gst_nonstream_audio_decoder_src_event()
1535 guint new_subsong, guint32 const *seqnum) in gst_nonstream_audio_decoder_switch_to_subsong() argument
1595 if (seqnum != NULL) { in gst_nonstream_audio_decoder_switch_to_subsong()
1596 gst_event_set_seqnum (fevent, *seqnum); in gst_nonstream_audio_decoder_switch_to_subsong()
1599 *seqnum); in gst_nonstream_audio_decoder_switch_to_subsong()
1638 if (seqnum != NULL) { in gst_nonstream_audio_decoder_switch_to_subsong()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/gst/midi/ |
| D | midiparse.c | 268 guint32 seqnum; in gst_midi_parse_perform_seek() local
281 seqnum = gst_event_get_seqnum (event); in gst_midi_parse_perform_seek()
285 seqnum = gst_util_seqnum_next (); in gst_midi_parse_perform_seek()
291 gst_event_set_seqnum (tevent, seqnum); in gst_midi_parse_perform_seek()
300 if (G_UNLIKELY (midiparse->seqnum == seqnum)) { in gst_midi_parse_perform_seek()
303 seqnum); in gst_midi_parse_perform_seek()
305 midiparse->seqnum = seqnum; in gst_midi_parse_perform_seek()
306 GST_DEBUG_OBJECT (midiparse, "seek with seqnum %" G_GUINT32_FORMAT, seqnum); in gst_midi_parse_perform_seek()
331 gst_event_set_seqnum (tevent, seqnum); in gst_midi_parse_perform_seek()
349 gst_message_set_seqnum (message, seqnum); in gst_midi_parse_perform_seek()
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/rtp/ |
| D | gstrtpbasepayload.c | 1048 payload->seqnum = payload->seqnum_base; in gst_rtp_base_payload_negotiate()
1159 guint16 seqnum; member
1194 gst_rtp_buffer_set_seq (&rtp, data->seqnum); in set_headers()
1199 data->seqnum++; in set_headers()
1245 payload->seqnum = priv->next_seqnum; in gst_rtp_base_payload_prepare_push()
1249 data.seqnum = payload->seqnum; in gst_rtp_base_payload_prepare_push()
1334 payload->seqnum = data.seqnum - 1; in gst_rtp_base_payload_prepare_push()
1341 priv->next_seqnum = data.seqnum; in gst_rtp_base_payload_prepare_push()
1349 payload->seqnum, data.rtptime, GST_TIME_ARGS (data.pts)); in gst_rtp_base_payload_prepare_push()
1502 "seqnum", G_TYPE_UINT, (guint) rtpbasepayload->seqnum, in gst_rtp_base_payload_create_stats()
[all …]
|
| D | gstrtpbasedepayload.c | 361 guint16 seqnum; in gst_rtp_base_depayload_handle_buffer() local
386 seqnum = gst_rtp_buffer_get_seq (&rtp); in gst_rtp_base_depayload_handle_buffer()
389 priv->last_seqnum = seqnum; in gst_rtp_base_depayload_handle_buffer()
395 GST_TIME_FORMAT ", dts %" GST_TIME_FORMAT, buf_discont, seqnum, rtptime, in gst_rtp_base_depayload_handle_buffer()
408 gap = gst_rtp_buffer_compare_seqnum (seqnum, priv->next_seqnum); in gst_rtp_base_depayload_handle_buffer()
412 GST_LOG_OBJECT (filter, "got packet %u, expected %u, gap %d", seqnum, in gst_rtp_base_depayload_handle_buffer()
434 priv->next_seqnum = (seqnum + 1) & 0xffff; in gst_rtp_base_depayload_handle_buffer()
|
| /third_party/eudev/src/udev/ |
| D | udevd.c | 94 unsigned long long int seqnum; member
486 event->seqnum = udev_device_get_seqnum(dev); in event_queue_insert()
525 if (loop_event->seqnum < event->delaying_seqnum) in is_devpath_busy()
529 if (loop_event->seqnum == event->delaying_seqnum) in is_devpath_busy()
533 if (loop_event->seqnum >= event->seqnum) in is_devpath_busy()
546 event->delaying_seqnum = loop_event->seqnum; in is_devpath_busy()
564 event->delaying_seqnum = loop_event->seqnum; in is_devpath_busy()
570 event->delaying_seqnum = loop_event->seqnum; in is_devpath_busy()
576 event->delaying_seqnum = loop_event->seqnum; in is_devpath_busy()
|
| /third_party/gstreamer/gstplugins_good/gst/multifile/ |
| D | gstsplitmuxsrc.c | 1090 guint32 seqnum) in gst_splitmux_push_event() argument
1094 if (seqnum) { in gst_splitmux_push_event()
1096 gst_event_set_seqnum (e, seqnum); in gst_splitmux_push_event()
1112 gst_splitmux_push_flush_stop (GstSplitMuxSrc * splitmux, guint32 seqnum) in gst_splitmux_push_flush_stop() argument
1117 if (seqnum) { in gst_splitmux_push_flush_stop()
1119 gst_event_set_seqnum (e, seqnum); in gst_splitmux_push_flush_stop()
1296 guint32 seqnum; in splitmux_src_pad_event() local
1314 seqnum = gst_event_get_seqnum (event); in splitmux_src_pad_event()
1340 gst_splitmux_push_event (splitmux, gst_event_new_flush_start (), seqnum); in splitmux_src_pad_event()
1364 gst_splitmux_push_flush_stop (splitmux, seqnum); in splitmux_src_pad_event()
[all …]
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | streamsynchronizer.c | 194 guint32 seqnum; in GST_START_TEST() local
246 seqnum = gst_event_get_seqnum (event); in GST_START_TEST()
252 gst_event_set_seqnum (event, seqnum); in GST_START_TEST()
|
| /third_party/gstreamer/gstplugins_bad/sys/ipcpipeline/ |
| D | gstipcpipelinecomm.c | 901 guint32 type, size, ret32 = TRUE, seqnum, slen; in gst_ipc_pipeline_comm_write_event_to_fd() local
938 size = sizeof (type) + sizeof (seqnum) + 1 + slen + 1; in gst_ipc_pipeline_comm_write_event_to_fd()
946 seqnum = GST_EVENT_SEQNUM (event); in gst_ipc_pipeline_comm_write_event_to_fd()
947 if (!gst_byte_writer_put_uint32_le (&bw, seqnum)) in gst_ipc_pipeline_comm_write_event_to_fd()
992 guint32 type, seqnum; in gst_ipc_pipeline_comm_read_event() local
1010 memcpy (&seqnum, payload, sizeof (seqnum)); in gst_ipc_pipeline_comm_read_event()
1011 payload += sizeof (seqnum); in gst_ipc_pipeline_comm_read_event()
1012 size -= sizeof (seqnum); in gst_ipc_pipeline_comm_read_event()
1031 gst_event_set_seqnum (event, seqnum); in gst_ipc_pipeline_comm_read_event()
2206 gchar *type, *ts, *seqnum, *rt_offset, *str, *str64, *s; in gst_value_serialize_event() local
[all …]
|
| /third_party/gstreamer/gstplugins_bad/ext/soundtouch/ |
| D | gstpitch.cc | 426 guint32 seqnum; in gst_pitch_src_event() local
435 seqnum = gst_event_get_seqnum (event); in gst_pitch_src_event()
446 gst_event_set_seqnum (event, seqnum); in gst_pitch_src_event()
678 gint seqnum; in gst_pitch_process_segment() local
732 seqnum = gst_event_get_seqnum (*event); in gst_pitch_process_segment()
735 gst_event_set_seqnum (*event, seqnum); in gst_pitch_process_segment()
|