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

gst/interleave/deinterleave.c: Don't leak input buffer in chain function; maintain our own list of source pads - ther...

Browse source 
Original commit message from CVS:
* gst/interleave/deinterleave.c: (gst_deinterleave_add_new_pads),
(gst_deinterleave_remove_pads), (gst_deinterleave_process),
(gst_deinterleave_chain):
Don't leak input buffer in chain function; maintain our own list of
source pads - there are no guarantees about the order of the list
in the GstElement struct, and we want a very specific order; lastly,
some more debugging.
This commit is contained in:
Tim-Philipp Müller 2007-03-22 22:14:29 +00:00
parent 0ca5b15aee
commit 63881aeec0
2 changed files with 36 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ChangeLog
View file

@ -1,3 +1,13 @@
2007-03-22 Tim-Philipp Müller <tim at centricular dot net>
* gst/interleave/deinterleave.c: (gst_deinterleave_add_new_pads),
(gst_deinterleave_remove_pads), (gst_deinterleave_process),
(gst_deinterleave_chain):
Don't leak input buffer in chain function; maintain our own list of
source pads - there are no guarantees about the order of the list
in the GstElement struct, and we want a very specific order; lastly,
some more debugging.
2007-03-22 Tim-Philipp Müller <tim at centricular dot net> 2007-03-22 Tim-Philipp Müller <tim at centricular dot net>
* ext/neon/gstneonhttpsrc.c: (gst_neonhttp_src_init): * ext/neon/gstneonhttpsrc.c: (gst_neonhttp_src_init):

54
gst/interleave/deinterleave.c
View file

@ -46,6 +46,8 @@ struct _GstDeinterleave
{ {
GstElement element; GstElement element;
/*< private > */
GList *srcpads;
GstCaps *sinkcaps; GstCaps *sinkcaps;
gint channels; gint channels;
@ -144,32 +146,33 @@ gst_deinterleave_add_new_pads (GstDeinterleave * self, GstCaps * caps)
g_free (name); g_free (name);
gst_pad_set_caps (pad, caps); gst_pad_set_caps (pad, caps);
gst_pad_use_fixed_caps (pad); gst_pad_use_fixed_caps (pad);
GST_PAD_UNSET_FLUSHING (pad); gst_pad_set_active (pad, TRUE);
gst_element_add_pad (GST_ELEMENT (self), pad); gst_element_add_pad (GST_ELEMENT (self), pad);
self->srcpads = g_list_prepend (self->srcpads, gst_object_ref (pad));
} }
gst_element_no_more_pads (GST_ELEMENT (self)); gst_element_no_more_pads (GST_ELEMENT (self));
self->srcpads = g_list_reverse (self->srcpads);
} }
static void static void
gst_deinterleave_remove_pads (GstDeinterleave * self) gst_deinterleave_remove_pads (GstDeinterleave * self)
{ {
GstElement *elem; GList *l;
GList *srcs, *l;
elem = GST_ELEMENT (self); GST_INFO_OBJECT (self, "removing pads");
GST_INFO_OBJECT (self, "remove_pads()"); for (l = self->srcpads; l; l = l->next) {
GstPad *pad = GST_PAD (l->data);
srcs = g_list_copy (elem->srcpads); gst_element_remove_pad (GST_ELEMENT_CAST (self), pad);
gst_object_unref (pad);
for (l = srcs; l; l = l->next) }
gst_element_remove_pad (elem, GST_PAD (l->data)); g_list_free (self->srcpads);
self->srcpads = NULL;
gst_pad_set_caps (self->sink, NULL); gst_pad_set_caps (self->sink, NULL);
gst_caps_replace (&self->sinkcaps, NULL); gst_caps_replace (&self->sinkcaps, NULL);
g_list_free (srcs);
} }
static gboolean static gboolean
@ -220,14 +223,11 @@ static GstFlowReturn
gst_deinterleave_process (GstDeinterleave * self, GstBuffer * buf) gst_deinterleave_process (GstDeinterleave * self, GstBuffer * buf)
{ {
GstFlowReturn ret; GstFlowReturn ret;
GstElement *elem;
GList *srcs; GList *srcs;
guint bufsize, i, j, channels, pads_pushed, nframes; guint bufsize, i, j, channels, pads_pushed, nframes;
GstBuffer **buffers_out; GstBuffer **buffers_out;
gfloat *in, *out; gfloat *in, *out;
elem = GST_ELEMENT (self);
channels = self->channels; channels = self->channels;
buffers_out = g_alloca (sizeof (GstBuffer *) * channels); buffers_out = g_alloca (sizeof (GstBuffer *) * channels);
nframes = GST_BUFFER_SIZE (buf) / channels / sizeof (gfloat); nframes = GST_BUFFER_SIZE (buf) / channels / sizeof (gfloat);
@ -237,7 +237,7 @@ gst_deinterleave_process (GstDeinterleave * self, GstBuffer * buf)
for (i = 0; i < channels; i++) for (i = 0; i < channels; i++)
buffers_out[i] = NULL; buffers_out[i] = NULL;
for (srcs = elem->srcpads, i = 0; srcs; srcs = srcs->next, i++) { for (srcs = self->srcpads, i = 0; srcs; srcs = srcs->next, i++) {
GstPad *pad = (GstPad *) srcs->data; GstPad *pad = (GstPad *) srcs->data;
buffers_out[i] = NULL; buffers_out[i] = NULL;
@ -249,15 +249,12 @@ gst_deinterleave_process (GstDeinterleave * self, GstBuffer * buf)
if (buffers_out[i] && GST_BUFFER_SIZE (buffers_out[i]) != bufsize) if (buffers_out[i] && GST_BUFFER_SIZE (buffers_out[i]) != bufsize)
goto alloc_buffer_bad_size; goto alloc_buffer_bad_size;
if (buffers_out[i]) { if (buffers_out[i])
GST_BUFFER_TIMESTAMP (buffers_out[i]) = GST_BUFFER_TIMESTAMP (buf); gst_buffer_stamp (buffers_out[i], buf);
GST_BUFFER_OFFSET (buffers_out[i]) = GST_BUFFER_OFFSET (buf);
GST_BUFFER_DURATION (buffers_out[i]) = GST_BUFFER_DURATION (buf);
}
} }
/* do the thing */ /* do the thing */
for (srcs = elem->srcpads, i = 0; srcs; srcs = srcs->next, i++) { for (srcs = self->srcpads, i = 0; srcs; srcs = srcs->next, i++) {
GstPad *pad = (GstPad *) srcs->data; GstPad *pad = (GstPad *) srcs->data;
in = (gfloat *) GST_BUFFER_DATA (buf); in = (gfloat *) GST_BUFFER_DATA (buf);
@ -281,11 +278,12 @@ gst_deinterleave_process (GstDeinterleave * self, GstBuffer * buf)
if (!pads_pushed) if (!pads_pushed)
ret = GST_FLOW_NOT_LINKED; ret = GST_FLOW_NOT_LINKED;
gst_buffer_unref (buf);
return ret; return ret;
alloc_buffer_failed: alloc_buffer_failed:
{ {
GST_WARNING ("gst_pad_alloc_buffer() returned %d", ret); GST_WARNING ("gst_pad_alloc_buffer() returned %s", gst_flow_get_name (ret));
goto clean_buffers; goto clean_buffers;
} }
@ -297,14 +295,16 @@ alloc_buffer_bad_size:
} }
push_failed: push_failed:
{ {
GST_DEBUG ("push() failed"); GST_DEBUG ("push() failed, flow = %s", gst_flow_get_name (ret));
goto clean_buffers; goto clean_buffers;
} }
clean_buffers: clean_buffers:
{ {
for (i = 0; i < channels; i++) for (i = 0; i < channels; i++) {
if (buffers_out[i]) if (buffers_out[i])
gst_buffer_unref (buffers_out[i]); gst_buffer_unref (buffers_out[i]);
}
gst_buffer_unref (buf);
return ret; return ret;
} }
} }
@ -315,14 +315,12 @@ gst_deinterleave_chain (GstPad * pad, GstBuffer * buffer)
GstDeinterleave *self; GstDeinterleave *self;
GstFlowReturn ret; GstFlowReturn ret;
self = GST_DEINTERLEAVE (gst_pad_get_parent (pad)); self = GST_DEINTERLEAVE (GST_PAD_PARENT (pad));
ret = gst_deinterleave_process (self, buffer); ret = gst_deinterleave_process (self, buffer);
if (ret != GST_FLOW_OK) if (ret != GST_FLOW_OK)
GST_WARNING_OBJECT (self, "process failed"); GST_DEBUG_OBJECT (self, "flow: %s", gst_flow_get_name (ret));
gst_object_unref (self);
return ret; return ret;
} }