mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-05 05:52:37 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtph264pay: use array instead of queue

Browse source
This commit is contained in:
Wim Taymans 2009-08-03 18:59:32 +02:00
parent 2bfb42c5f8
commit ddfa9961c6
2 changed files with 12 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
gst/rtp/gstrtph264pay.c
View file

@ -184,7 +184,7 @@ gst_rtp_h264_pay_class_init (GstRtpH264PayClass * klass)
static void static void
gst_rtp_h264_pay_init (GstRtpH264Pay * rtph264pay, GstRtpH264PayClass * klass) gst_rtp_h264_pay_init (GstRtpH264Pay * rtph264pay, GstRtpH264PayClass * klass)
{ {
rtph264pay->queue = g_queue_new (); rtph264pay->queue = g_array_new (FALSE, FALSE, sizeof (guint));
rtph264pay->profile = 0; rtph264pay->profile = 0;
rtph264pay->sps = NULL; rtph264pay->sps = NULL;
rtph264pay->pps = NULL; rtph264pay->pps = NULL;
@ -199,7 +199,7 @@ gst_rtp_h264_pay_finalize (GObject * object)
rtph264pay = GST_RTP_H264_PAY (object); rtph264pay = GST_RTP_H264_PAY (object);
g_queue_free (rtph264pay->queue); g_array_free (rtph264pay->queue, TRUE);
g_free (rtph264pay->sps); g_free (rtph264pay->sps);
g_free (rtph264pay->pps); g_free (rtph264pay->pps);
@ -732,10 +732,10 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
{ {
GstRtpH264Pay *rtph264pay; GstRtpH264Pay *rtph264pay;
GstFlowReturn ret; GstFlowReturn ret;
guint size, nal_len; guint size, nal_len, i;
guint8 *data, *nal_data; guint8 *data, *nal_data;
GstClockTime timestamp; GstClockTime timestamp;
GQueue *nal_queue; GArray *nal_queue;
rtph264pay = GST_RTP_H264_PAY (basepayload); rtph264pay = GST_RTP_H264_PAY (basepayload);
@ -799,6 +799,9 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
nal_data = data; nal_data = data;
nal_queue = rtph264pay->queue; nal_queue = rtph264pay->queue;
/* array must be empty when we get here */
g_assert (nal_queue->len == 0);
GST_DEBUG_OBJECT (basepayload, "found first start at %u, bytes left %u", GST_DEBUG_OBJECT (basepayload, "found first start at %u, bytes left %u",
next, size); next, size);
@ -849,12 +852,11 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
update = gst_rtp_h264_pay_decode_nal (rtph264pay, data, nal_len) || update = gst_rtp_h264_pay_decode_nal (rtph264pay, data, nal_len) ||
update; update;
} }
/* move to next NAL packet */ /* move to next NAL packet */
data += nal_len; data += nal_len;
size -= nal_len; size -= nal_len;
g_queue_push_tail (nal_queue, GUINT_TO_POINTER (nal_len)); g_array_append_val (nal_queue, nal_len);
} }
/* if has new SPS & PPS, update the output caps */ /* if has new SPS & PPS, update the output caps */
@ -863,7 +865,8 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
/* second pass to payload and push */ /* second pass to payload and push */
data = nal_data; data = nal_data;
while ((nal_len = GPOINTER_TO_UINT (g_queue_pop_head (nal_queue))) > 0) { for (i = 0; i < nal_queue->len; i++) {
nal_len = g_array_index (nal_queue, guint, i);
/* skip start code */ /* skip start code */
data += 4; data += 4;
@ -872,7 +875,6 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
gst_rtp_h264_pay_payload_nal (basepayload, data, nal_len, timestamp, gst_rtp_h264_pay_payload_nal (basepayload, data, nal_len, timestamp,
buffer); buffer);
if (ret != GST_FLOW_OK) { if (ret != GST_FLOW_OK) {
g_queue_clear (nal_queue);
break; break;
} }
@ -880,6 +882,7 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
data += nal_len; data += nal_len;
size -= nal_len; size -= nal_len;
} }
g_array_set_size (nal_queue, 0);
} }
gst_buffer_unref (buffer); gst_buffer_unref (buffer);

2
gst/rtp/gstrtph264pay.h
View file

@ -56,7 +56,7 @@ struct _GstRtpH264Pay
gboolean packetized; gboolean packetized;
guint nal_length_size; guint nal_length_size;
GQueue *queue; GArray *queue;
gchar *profile_level_id; gchar *profile_level_id;
gchar *sprop_parameter_sets; gchar *sprop_parameter_sets;