bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
gst_bus_add_signal_watch (bus);
g_signal_connect (G_OBJECT (bus), "message", G_CALLBACK (on_message), loop);
- gst_object_unref (GST_OBJECT (bus));
fail_if (gst_element_set_state (pipeline,
GST_STATE_PLAYING) == GST_STATE_CHANGE_FAILURE);
fail_unless (gst_element_set_state (pipeline,
GST_STATE_NULL) == GST_STATE_CHANGE_SUCCESS);
+ gst_bus_remove_signal_watch (bus);
+ gst_object_unref (GST_OBJECT (bus));
g_main_loop_unref (loop);
gst_object_unref (pipeline);
}
bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
gst_bus_add_signal_watch (bus);
g_signal_connect (G_OBJECT (bus), "message", G_CALLBACK (on_message), loop);
- gst_object_unref (GST_OBJECT (bus));
fail_if (gst_element_set_state (pipeline,
GST_STATE_PLAYING) == GST_STATE_CHANGE_FAILURE);
fail_unless (gst_element_set_state (pipeline,
GST_STATE_NULL) == GST_STATE_CHANGE_SUCCESS);
+ gst_bus_remove_signal_watch (bus);
+ gst_object_unref (GST_OBJECT (bus));
g_main_loop_unref (loop);
gst_object_unref (pipeline);
}
bus = gst_pipeline_get_bus (GST_PIPELINE (p->pipeline));
gst_bus_add_watch (bus, rtp_bus_callback, (gpointer) mainloop);
- gst_object_unref (bus);
/* Set pipeline to PLAYING. */
gst_element_set_state (p->pipeline, GST_STATE_PLAYING);
/* Release mainloop. */
g_main_loop_unref (mainloop);
+ gst_bus_remove_watch (bus);
+ gst_object_unref (bus);
+
fail_if (p->custom_event);
}
fail_unless (bus != NULL);
gst_bus_add_watch (bus, bus_handler, loop);
- gst_object_unref (bus);
conversions_test_size = G_N_ELEMENTS (conversion_table);
for (itr = 0; itr < conversions_test_size; itr++) {
"couldn't set pipeline to READY state");
}
+ gst_bus_remove_watch (bus);
+ gst_object_unref (bus);
g_main_loop_unref (loop);
videobox_test_deinit_context (&ctx);
g_signal_connect (bus, "message", (GCallback) on_message_cb, &omud);
- gst_object_unref (bus);
ret = gst_element_set_state (pipeline, GST_STATE_PLAYING);
fail_unless (ret == GST_STATE_CHANGE_SUCCESS
fail_unless (omud.eos == TRUE);
+ gst_bus_remove_signal_watch (bus);
+ gst_object_unref (bus);
gst_object_unref (pipeline);
g_main_loop_unref (loop);
}