Lines Matching refs:depay
126 GstRtpQCELPDepay *depay; in gst_rtp_qcelp_depay_finalize() local
128 depay = GST_RTP_QCELP_DEPAY (object); in gst_rtp_qcelp_depay_finalize()
130 if (depay->packets != NULL) { in gst_rtp_qcelp_depay_finalize()
131 g_ptr_array_foreach (depay->packets, (GFunc) gst_buffer_unref, NULL); in gst_rtp_qcelp_depay_finalize()
132 g_ptr_array_free (depay->packets, TRUE); in gst_rtp_qcelp_depay_finalize()
133 depay->packets = NULL; in gst_rtp_qcelp_depay_finalize()
162 get_frame_len (GstRtpQCELPDepay * depay, guint8 frame_type) in get_frame_len() argument
171 count_packets (GstRtpQCELPDepay * depay, guint8 * data, guint size) in count_packets() argument
178 frame_len = get_frame_len (depay, data[0]); in count_packets()
198 flush_packets (GstRtpQCELPDepay * depay) in flush_packets() argument
202 GST_DEBUG_OBJECT (depay, "flushing packets"); in flush_packets()
204 size = depay->packets->len; in flush_packets()
209 outbuf = g_ptr_array_index (depay->packets, i); in flush_packets()
210 g_ptr_array_index (depay->packets, i) = NULL; in flush_packets()
212 gst_rtp_base_depayload_push (GST_RTP_BASE_DEPAYLOAD (depay), outbuf); in flush_packets()
216 depay->interleaved = FALSE; in flush_packets()
217 depay->bundling = 0; in flush_packets()
221 add_packet (GstRtpQCELPDepay * depay, guint LLL, guint NNN, guint index, in add_packet() argument
231 GST_DEBUG_OBJECT (depay, "adding packet at index %u", idx); in add_packet()
233 old = g_ptr_array_index (depay->packets, idx); in add_packet()
238 g_ptr_array_index (depay->packets, idx) = outbuf; in add_packet()
242 create_erasure_buffer (GstRtpQCELPDepay * depay) in create_erasure_buffer() argument
259 GstRtpQCELPDepay *depay; in gst_rtp_qcelp_depay_process() local
266 depay = GST_RTP_QCELP_DEPAY (depayload); in gst_rtp_qcelp_depay_process()
289 GST_DEBUG_OBJECT (depay, "LLL %u, NNN %u", LLL, NNN); in gst_rtp_qcelp_depay_process()
299 if (!depay->interleaved) { in gst_rtp_qcelp_depay_process()
302 GST_DEBUG_OBJECT (depay, "starting interleaving group"); in gst_rtp_qcelp_depay_process()
304 depay->bundling = count_packets (depay, payload, payload_len); in gst_rtp_qcelp_depay_process()
305 GST_DEBUG_OBJECT (depay, "got bundling of %u", depay->bundling); in gst_rtp_qcelp_depay_process()
308 size = (depay->bundling - 1) * (LLL + 1); in gst_rtp_qcelp_depay_process()
310 if (depay->packets == NULL) in gst_rtp_qcelp_depay_process()
311 depay->packets = g_ptr_array_sized_new (size); in gst_rtp_qcelp_depay_process()
312 GST_DEBUG_OBJECT (depay, "created packet array of size %u", size); in gst_rtp_qcelp_depay_process()
313 g_ptr_array_set_size (depay->packets, size); in gst_rtp_qcelp_depay_process()
316 depay->interleaved = TRUE; in gst_rtp_qcelp_depay_process()
320 if (depay->interleaved) { in gst_rtp_qcelp_depay_process()
321 GST_DEBUG_OBJECT (depay, "stopping interleaving"); in gst_rtp_qcelp_depay_process()
323 flush_packets (depay); in gst_rtp_qcelp_depay_process()
325 depay->bundling = 0; in gst_rtp_qcelp_depay_process()
335 frame_len = get_frame_len (depay, payload[0]); in gst_rtp_qcelp_depay_process()
336 GST_DEBUG_OBJECT (depay, "got frame len %d", frame_len); in gst_rtp_qcelp_depay_process()
354 outbuf = create_erasure_buffer (depay); in gst_rtp_qcelp_depay_process()
365 if (!depay->interleaved || index == 0) { in gst_rtp_qcelp_depay_process()
373 add_packet (depay, LLL, NNN, index, outbuf); in gst_rtp_qcelp_depay_process()
385 if (depay->bundling > 0 && depay->bundling <= index) in gst_rtp_qcelp_depay_process()
388 while (index < depay->bundling) { in gst_rtp_qcelp_depay_process()
389 GST_DEBUG_OBJECT (depay, "filling with erasure buffer"); in gst_rtp_qcelp_depay_process()
391 outbuf = create_erasure_buffer (depay); in gst_rtp_qcelp_depay_process()
392 add_packet (depay, LLL, NNN, index, outbuf); in gst_rtp_qcelp_depay_process()
395 if (depay->interleaved && LLL == NNN) { in gst_rtp_qcelp_depay_process()
396 GST_DEBUG_OBJECT (depay, "interleave group ended, flushing"); in gst_rtp_qcelp_depay_process()
398 flush_packets (depay); in gst_rtp_qcelp_depay_process()
406 GST_ELEMENT_WARNING (depay, STREAM, DECODE, in gst_rtp_qcelp_depay_process()
412 GST_ELEMENT_WARNING (depay, STREAM, DECODE, in gst_rtp_qcelp_depay_process()
418 GST_ELEMENT_WARNING (depay, STREAM, DECODE, in gst_rtp_qcelp_depay_process()
424 GST_ELEMENT_WARNING (depay, STREAM, DECODE, in gst_rtp_qcelp_depay_process()