mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-23 10:11:08 +00:00
Code Issues 1 Projects Releases Wiki Activity

Some sanity checking emit a warning when interrupting a queue bacause we do it wrongly

Browse source 
Original commit message from CVS:
Some sanity checking
emit a warning when interrupting a queue bacause we do it wrongly
This commit is contained in:
Wim Taymans 2002-06-04 23:00:36 +00:00
parent b6f6293cc3
commit a0979c2ddc
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
gst/schedulers/gstbasicscheduler.c
View file

@ -131,7 +131,7 @@ static GstSchedulerClass *parent_class = NULL;
#define do_element_switch(element) G_STMT_START{ \ #define do_element_switch(element) G_STMT_START{ \
GstElement *from = SCHED (element)->current; \ GstElement *from = SCHED (element)->current; \
if (from->post_run_func) \ if (from && from->post_run_func) \
from->post_run_func (from); \ from->post_run_func (from); \
SCHED (element)->current = element; \ SCHED (element)->current = element; \
if (element->pre_run_func) \ if (element->pre_run_func) \
@ -141,7 +141,7 @@ static GstSchedulerClass *parent_class = NULL;
#define do_switch_to_main(sched) G_STMT_START{ \ #define do_switch_to_main(sched) G_STMT_START{ \
GstElement *current = ((GstBasicScheduler*)sched)->current; \ GstElement *current = ((GstBasicScheduler*)sched)->current; \
if (current->post_run_func) \ if (current && current->post_run_func) \
current->post_run_func (current); \ current->post_run_func (current); \
SCHED (current)->current = NULL; \ SCHED (current)->current = NULL; \
do_cothread_switch \ do_cothread_switch \
@ -1114,8 +1114,12 @@ gst_basic_scheduler_yield (GstScheduler *sched, GstElement *element)
static gboolean static gboolean
gst_basic_scheduler_interrupt (GstScheduler *sched, GstElement *element) gst_basic_scheduler_interrupt (GstScheduler *sched, GstElement *element)
{ {
GST_FLAG_SET (element, GST_ELEMENT_COTHREAD_STOPPING);
if (GST_FLAG_IS_SET (element, GST_ELEMENT_DECOUPLED)) {
g_warning ("interrupt decoupled element");
}
GST_FLAG_SET (element, GST_ELEMENT_COTHREAD_STOPPING);
do_switch_to_main (sched); do_switch_to_main (sched);
return FALSE; return FALSE;