ASSERT_OBJECT_REFCOUNT (bin, "bin", 1);
+ gst_bus_set_flushing (bus, TRUE);
+
/* clean up */
ret = gst_element_set_state (GST_ELEMENT (bin), GST_STATE_NULL);
fail_unless (ret == GST_STATE_CHANGE_SUCCESS);
ASSERT_OBJECT_REFCOUNT (src, "src", 1);
ASSERT_OBJECT_REFCOUNT (bin, "bin", 1);
+ gst_bus_set_flushing (bus, TRUE);
+
/* clean up */
ret = gst_element_set_state (GST_ELEMENT (bin), GST_STATE_NULL);
fail_unless (ret == GST_STATE_CHANGE_SUCCESS);
+
gst_object_unref (bus);
gst_object_unref (bin);
}
fail_unless (gst_bus_have_pending (bus) == FALSE,
"Unexpected messages on bus");
- /* setting bin to NULL flushes the bus automatically */
+ gst_bus_set_flushing (bus, TRUE);
+
ret = gst_element_set_state (GST_ELEMENT (bin), GST_STATE_NULL);
fail_unless (ret == GST_STATE_CHANGE_SUCCESS);
GstFormat format = GST_FORMAT_BYTES;
gboolean res;
gint64 duration;
+ GstBus *bus;
GST_INFO ("preparing test");
ck_assert_int_eq (duration, 3000);
+ bus = gst_element_get_bus (bin);
+ gst_bus_set_flushing (bus, TRUE);
+ gst_object_unref (bus);
+
gst_element_set_state (bin, GST_STATE_NULL);
gst_object_unref (bin);
}
GstFormat format = GST_FORMAT_BYTES;
gboolean res;
gint64 duration;
+ GstBus *bus;
GST_INFO ("preparing test");
ck_assert_int_eq (duration, GST_CLOCK_TIME_NONE);
+ bus = gst_element_get_bus (bin);
+ gst_bus_set_flushing (bus, TRUE);
+ gst_object_unref (bus);
+
gst_element_set_state (bin, GST_STATE_NULL);
gst_object_unref (bin);
}