GstMessage *message;
GList *message_list = NULL;
+ g_return_if_fail (GST_IS_BUS (bus));
+
GST_OBJECT_LOCK (bus);
if (flushing) {
GstMessage *ret;
gulong id;
+ g_return_val_if_fail (GST_IS_BUS (bus), NULL);
+
poll_data = g_slice_new (GstBusPollData);
poll_data->source_running = TRUE;
poll_data->loop = g_main_loop_new (NULL, FALSE);