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

gst/: No unsafe task pausing please.

Browse source 
Original commit message from CVS:
* gst/gstpad.c: (gst_pad_event_default):
* gst/gstqueue.c: (gst_queue_loop):
No unsafe task pausing please.
This commit is contained in:
Wim Taymans 2005-06-23 17:09:21 +00:00
parent 830a0368b4
commit d56ab76d57
4 changed files with 12 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2005-06-23 Wim Taymans <wim@fluendo.com>
* gst/gstpad.c: (gst_pad_event_default):
* gst/gstqueue.c: (gst_queue_loop):
No unsafe task pausing please.
2005-06-23 Wim Taymans <wim@fluendo.com>
* gst/schedulers/threadscheduler.c:

6
gst/gstpad.c
View file

@ -2231,10 +2231,8 @@ gst_pad_event_default (GstPad * pad, GstEvent * event)
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_EOS:
{
if (GST_PAD_TASK (pad)) {
GST_DEBUG_OBJECT (pad, "pausing task because of eos");
gst_pad_pause_task (pad);
}
GST_DEBUG_OBJECT (pad, "pausing task because of eos");
gst_pad_pause_task (pad);
}
default:
break;

4
gst/gstqueue.c
View file

@ -733,11 +733,11 @@ restart:
result = gst_pad_push (pad, GST_BUFFER (data));
GST_QUEUE_MUTEX_LOCK;
if (result != GST_FLOW_OK) {
gst_task_pause (GST_PAD_TASK (queue->srcpad));
gst_pad_pause_task (queue->srcpad);
}
} else {
if (GST_EVENT_TYPE (data) == GST_EVENT_EOS) {
gst_task_pause (GST_PAD_TASK (queue->srcpad));
gst_pad_pause_task (queue->srcpad);
restart = FALSE;
}
GST_QUEUE_MUTEX_UNLOCK;

4
plugins/elements/gstqueue.c
View file

@ -733,11 +733,11 @@ restart:
result = gst_pad_push (pad, GST_BUFFER (data));
GST_QUEUE_MUTEX_LOCK;
if (result != GST_FLOW_OK) {
gst_task_pause (GST_PAD_TASK (queue->srcpad));
gst_pad_pause_task (queue->srcpad);
}
} else {
if (GST_EVENT_TYPE (data) == GST_EVENT_EOS) {
gst_task_pause (GST_PAD_TASK (queue->srcpad));
gst_pad_pause_task (queue->srcpad);
restart = FALSE;
}
GST_QUEUE_MUTEX_UNLOCK;