mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-05 15:08:53 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst/base/gstcollectpads.c: Broadcast the condition when shutting down, to make sure we wake all threads up. Shut down...

Browse source 
Original commit message from CVS:
* gst/base/gstcollectpads.c: (gst_collectpads_finalize),
(gst_collectpads_stop):
Broadcast the condition when shutting down, to make sure we wake all
threads up. Shut down pads on finalize, for safety.
This commit is contained in:
Jan Schmidt 2005-08-01 21:17:01 +00:00
parent 4572dcaa86
commit 75c955843e
3 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2005-08-01 Jan Schmidt <thaytan@mad.scientist.com>
* gst/base/gstcollectpads.c: (gst_collectpads_finalize),
(gst_collectpads_stop):
Broadcast the condition when shutting down, to make sure we wake all
threads up. Shut down pads on finalize, for safety.
2005-08-01 Jan Schmidt <thaytan@mad.scientist.com> 2005-08-01 Jan Schmidt <thaytan@mad.scientist.com>
* gst/base/gstbasetransform.c: (gst_base_transform_init), * gst/base/gstbasetransform.c: (gst_base_transform_init),
(gst_base_transform_handle_buffer), (gst_base_transform_handle_buffer),

3
gst/base/gstcollectpads.c
View file

@ -84,6 +84,7 @@ gst_collectpads_finalize (GObject * object)
{ {
GstCollectPads *pads = GST_COLLECTPADS (object); GstCollectPads *pads = GST_COLLECTPADS (object);
gst_collectpads_stop (pads);
g_cond_free (pads->cond); g_cond_free (pads->cond);
/* FIXME, free data */ /* FIXME, free data */
@ -310,7 +311,7 @@ gst_collectpads_stop (GstCollectPads * pads)
GST_LOCK (pads); GST_LOCK (pads);
pads->started = FALSE; pads->started = FALSE;
GST_COLLECTPADS_SIGNAL (pads); GST_COLLECTPADS_BROADCAST (pads);
GST_UNLOCK (pads); GST_UNLOCK (pads);
} }

3
libs/gst/base/gstcollectpads.c
View file

@ -84,6 +84,7 @@ gst_collectpads_finalize (GObject * object)
{ {
GstCollectPads *pads = GST_COLLECTPADS (object); GstCollectPads *pads = GST_COLLECTPADS (object);
gst_collectpads_stop (pads);
g_cond_free (pads->cond); g_cond_free (pads->cond);
/* FIXME, free data */ /* FIXME, free data */
@ -310,7 +311,7 @@ gst_collectpads_stop (GstCollectPads * pads)
GST_LOCK (pads); GST_LOCK (pads);
pads->started = FALSE; pads->started = FALSE;
GST_COLLECTPADS_SIGNAL (pads); GST_COLLECTPADS_BROADCAST (pads);
GST_UNLOCK (pads); GST_UNLOCK (pads);
} }