mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-23 16:50:47 +00:00
Code Issues 1 Projects Releases Wiki Activity

validate: Do not auto flush pipeline bus

Browse source 
We want to see all messages in our async handler

And flush it when we are done.
This commit is contained in:
Thibault Saunier 2014-07-17 12:17:31 +02:00
parent fcb8a77e17
commit f6884a5a54
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
validate/tools/gst-validate.c
View file

@ -393,6 +393,8 @@ main (int argc, gchar ** argv)
gst_bin_add (GST_BIN (new_pipeline), pipeline); gst_bin_add (GST_BIN (new_pipeline), pipeline);
pipeline = new_pipeline; pipeline = new_pipeline;
} }
gst_pipeline_set_auto_flush_bus (GST_PIPELINE (pipeline), FALSE);
#ifdef G_OS_UNIX #ifdef G_OS_UNIX
signal_watch_id = signal_watch_id =
g_unix_signal_add (SIGINT, (GSourceFunc) intr_handler, pipeline); g_unix_signal_add (SIGINT, (GSourceFunc) intr_handler, pipeline);
@ -439,7 +441,6 @@ main (int argc, gchar ** argv)
bus = gst_element_get_bus (pipeline); bus = gst_element_get_bus (pipeline);
gst_bus_add_signal_watch (bus); gst_bus_add_signal_watch (bus);
g_signal_connect (bus, "message", (GCallback) bus_callback, mainloop); g_signal_connect (bus, "message", (GCallback) bus_callback, mainloop);
gst_object_unref (bus);
g_print ("Starting pipeline\n"); g_print ("Starting pipeline\n");
g_object_get (monitor, "handles-states", &monitor_handles_state, NULL); g_object_get (monitor, "handles-states", &monitor_handles_state, NULL);
@ -467,6 +468,12 @@ main (int argc, gchar ** argv)
} }
g_main_loop_run (mainloop); g_main_loop_run (mainloop);
gst_element_set_state (pipeline, GST_STATE_NULL);
gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
/* Clean the bus */
gst_bus_set_flushing (bus, TRUE);
gst_object_unref (bus);
rep_err = gst_validate_runner_printf (runner); rep_err = gst_validate_runner_printf (runner);
if (ret == 0) { if (ret == 0) {
@ -476,7 +483,6 @@ main (int argc, gchar ** argv)
} }
exit: exit:
gst_element_set_state (pipeline, GST_STATE_NULL);
g_main_loop_unref (mainloop); g_main_loop_unref (mainloop);
g_object_unref (pipeline); g_object_unref (pipeline);
g_object_unref (runner); g_object_unref (runner);