mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

ext/lame/gstlame.c: On EOS, flush encoder and send remaining data. Fix return value handling in sink event function.

Browse source 
Original commit message from CVS:
* ext/lame/gstlame.c: (gst_lame_sink_event):
On EOS, flush encoder and send remaining data. Fix
return value handling in sink event function.
This commit is contained in:
Tim-Philipp Müller 2006-03-28 15:10:18 +00:00
parent 31b41270ac
commit d35582a50b
1 changed files with 24 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
ext/lame/gstlame.c
View file

@ -947,22 +947,36 @@ gst_lame_get_property (GObject * object, guint prop_id, GValue * value,
static gboolean static gboolean
gst_lame_sink_event (GstPad * pad, GstEvent * event) gst_lame_sink_event (GstPad * pad, GstEvent * event)
{ {
gboolean ret;
GstLame *lame; GstLame *lame;
lame = GST_LAME (gst_pad_get_parent (pad)); lame = GST_LAME (gst_pad_get_parent (pad));
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_EOS: case GST_EVENT_EOS:{
GST_DEBUG_OBJECT (lame, "handling EOS event"); GstBuffer *buf;
/* FIXME, push last data packet */ gint size;
gst_pad_push_event (lame->srcpad, event); GST_DEBUG_OBJECT (lame, "handling EOS event");
buf = gst_buffer_new_and_alloc (7200);
size = lame_encode_flush (lame->lgf, GST_BUFFER_DATA (buf), 7200);
if (size > 0) {
GST_BUFFER_SIZE (buf) = size;
GST_DEBUG_OBJECT (lame, "pushing final packet of %u bytes", size);
gst_buffer_set_caps (buf, GST_PAD_CAPS (lame->srcpad));
gst_pad_push (lame->srcpad, buf);
} else {
GST_DEBUG_OBJECT (lame, "no final packet (size=%d)", size);
gst_buffer_unref (buf);
}
ret = gst_pad_event_default (pad, event);
break; break;
}
case GST_EVENT_FLUSH_START: case GST_EVENT_FLUSH_START:
GST_DEBUG_OBJECT (lame, "handling FLUSH start event"); GST_DEBUG_OBJECT (lame, "handling FLUSH start event");
/* forward event */ /* forward event */
gst_pad_push_event (lame->srcpad, event); ret = gst_pad_push_event (lame->srcpad, event);
break; break;
case GST_EVENT_FLUSH_STOP: case GST_EVENT_FLUSH_STOP:
{ {
@ -976,7 +990,7 @@ gst_lame_sink_event (GstPad * pad, GstEvent * event)
mp3_data = g_malloc (mp3_buffer_size); mp3_data = g_malloc (mp3_buffer_size);
mp3_size = lame_encode_flush (lame->lgf, mp3_data, mp3_buffer_size); mp3_size = lame_encode_flush (lame->lgf, mp3_data, mp3_buffer_size);
gst_pad_push_event (lame->srcpad, event); ret = gst_pad_push_event (lame->srcpad, event);
break; break;
} }
case GST_EVENT_TAG: case GST_EVENT_TAG:
@ -990,14 +1004,14 @@ gst_lame_sink_event (GstPad * pad, GstEvent * event)
} else { } else {
g_assert_not_reached (); g_assert_not_reached ();
} }
gst_pad_push_event (lame->srcpad, event); ret = gst_pad_push_event (lame->srcpad, event);
break; break;
default: default:
gst_pad_push_event (lame->srcpad, event); ret = gst_pad_event_default (pad, event);
break; break;
} }
gst_object_unref (lame); gst_object_unref (lame);
return TRUE; return ret;
} }
static GstFlowReturn static GstFlowReturn