Lines Matching refs:depay
142 flush_data (GstRtpQDM2Depay * depay) in flush_data() argument
147 if ((avail = gst_adapter_available (depay->adapter))) in flush_data()
148 gst_adapter_flush (depay->adapter, avail); in flush_data()
150 GST_DEBUG ("Flushing %d packets", depay->nbpackets); in flush_data()
152 for (i = 0; depay->packets[i]; i++) { in flush_data()
153 QDM2Packet *pack = depay->packets[i]; in flush_data()
167 if (depay->packetsize > 0xff) { in flush_data()
170 GST_WRITE_UINT16_BE (data + 1, depay->packetsize - 3); in flush_data()
173 data[1] = depay->packetsize - 2; in flush_data()
177 for (; i < depay->packetsize; i++) in flush_data()
183 if (depay->packetsize > 0xff) in flush_data()
188 GST_MEMDUMP ("Extracted packet", data, depay->packetsize); in flush_data()
192 gst_memory_new_wrapped (0, data, depay->packetsize, 0, in flush_data()
193 depay->packetsize, data, g_free)); in flush_data()
195 gst_adapter_push (depay->adapter, buf); in flush_data()
202 add_packet (GstRtpQDM2Depay * depay, guint32 pid, guint32 len, guint8 * data) in add_packet() argument
206 if (G_UNLIKELY (!depay->configured)) in add_packet()
211 if (G_UNLIKELY (depay->packets[pid] == NULL)) { in add_packet()
212 depay->packets[pid] = g_malloc0 (sizeof (QDM2Packet)); in add_packet()
213 depay->nbpackets = MAX (depay->nbpackets, pid + 1); in add_packet()
215 packet = depay->packets[pid]; in add_packet()
221 packet->data = g_malloc0 (depay->packetsize); in add_packet()
223 if (depay->packetsize > 0xff) in add_packet()