mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-22 05:56:31 +00:00
Code Issues 1 Projects Releases Wiki Activity

check/states/sinks.c (test_livesrc_sink): Add checks that the state-changed messages actually have the right order an...

Browse source 
Original commit message from CVS:
2005-11-03  Andy Wingo  <wingo@pobox.com>

* check/states/sinks.c (test_livesrc_sink): Add checks that the
state-changed messages actually have the right order and the right
values.
This commit is contained in:
Andy Wingo 2005-11-03 17:53:27 +00:00
parent 43fe0b06e9
commit e2200c1f82
3 changed files with 184 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2005-11-03 Andy Wingo <wingo@pobox.com>
* check/states/sinks.c (test_livesrc_sink): Add checks that the
state-changed messages actually have the right order and the right
values.
2005-11-03 Wim Taymans <wim@fluendo.com>
* check/states/sinks.c: (GST_START_TEST), (gst_object_suite):

89
check/states/sinks.c
View file

@ -22,6 +22,28 @@
#include <gst/check/gstcheck.h>
static void
pop_state_change_message (GstBus * bus, GstElement * src, GstState old,
GstState new, GstState pending)
{
GstMessage *message = NULL;
GstState _old, _new, _pending;
message = gst_bus_poll (bus, GST_MESSAGE_STATE_CHANGED, GST_SECOND);
fail_unless (message != NULL,
"Expected state change message, but got nothing");
gst_message_parse_state_changed (message, &_old, &_new, &_pending);
fail_unless (GST_MESSAGE_SRC (message) == (GstObject *) src,
"Unexpected state change order");
fail_unless (old == _old, "Unexpected old state");
fail_unless (new == _new, "Unexpected new state");
fail_unless (pending == _pending, "Unexpected pending state");
gst_message_unref (message);
}
/* a sink should go ASYNC to PAUSE. forcing PLAYING is possible */
GST_START_TEST (test_sink)
{
@ -192,6 +214,7 @@ GST_START_TEST (test_livesrc_sink)
GstStateChangeReturn ret;
GstState current, pending;
GstPad *srcpad, *sinkpad;
GstBus *bus;
pipeline = gst_pipeline_new ("pipeline");
src = gst_element_factory_make ("fakesrc", "src");
@ -207,10 +230,26 @@ GST_START_TEST (test_livesrc_sink)
gst_object_unref (srcpad);
gst_object_unref (sinkpad);
bus = gst_element_get_bus (pipeline);
ret = gst_element_set_state (pipeline, GST_STATE_PAUSED);
fail_unless (ret == GST_STATE_CHANGE_NO_PREROLL,
"no no_preroll state return");
pop_state_change_message (bus, sink, GST_STATE_NULL, GST_STATE_READY,
GST_STATE_VOID_PENDING);
pop_state_change_message (bus, src, GST_STATE_NULL, GST_STATE_READY,
GST_STATE_VOID_PENDING);
pop_state_change_message (bus, pipeline, GST_STATE_NULL, GST_STATE_READY,
GST_STATE_PAUSED);
/* this order only holds true for live sources because they do not push
buffers in PAUSED */
pop_state_change_message (bus, src, GST_STATE_READY, GST_STATE_PAUSED,
GST_STATE_VOID_PENDING);
pop_state_change_message (bus, pipeline, GST_STATE_READY, GST_STATE_PAUSED,
GST_STATE_VOID_PENDING);
ret = gst_element_set_state (pipeline, GST_STATE_PAUSED);
fail_unless (ret == GST_STATE_CHANGE_NO_PREROLL,
"no no_preroll state return the second time");
@ -239,6 +278,56 @@ GST_START_TEST (test_livesrc_sink)
fail_unless (ret == GST_STATE_CHANGE_SUCCESS, "not playing");
fail_unless (current == GST_STATE_PLAYING, "not playing");
fail_unless (pending == GST_STATE_VOID_PENDING, "not playing");
#ifdef WIM_EARNS_HIS_KEEP
/* now we have four messages on the bus: src from paused to playing, sink from
ready to paused and paused to playing, and pipeline from paused to playing.
the pipeline message should be last, and the sink messages should go in
order, but the src message can be interleaved with the sink one. */
{
GstMessage *m;
GstState old, new, pending;
gint n_src = 1, n_sink = 2;
while (n_src + n_sink > 0) {
m = gst_bus_poll (bus, GST_MESSAGE_STATE_CHANGED, GST_SECOND);
fail_unless (m != NULL, "expected state change message");
gst_message_parse_state_changed (m, &old, &new, &pending);
if (GST_MESSAGE_SRC (m) == (GstObject *) src) {
fail_unless (n_src == 1, "already got one message from the src");
n_src--;
fail_unless (old == GST_STATE_PAUSED, "unexpected old");
fail_unless (new == GST_STATE_PLAYING, "unexpected new (got %d)", new);
fail_unless (pending == GST_STATE_VOID_PENDING, "unexpected pending");
} else if (GST_MESSAGE_SRC (m) == (GstObject *) sink) {
if (n_sink == 2) {
fail_unless (old == GST_STATE_READY, "unexpected old");
fail_unless (new == GST_STATE_PAUSED, "unexpected new");
fail_unless (pending == GST_STATE_PLAYING, "unexpected pending");
} else if (n_sink == 1) {
fail_unless (old == GST_STATE_PAUSED, "unexpected old");
fail_unless (new == GST_STATE_PLAYING, "unexpected new");
fail_unless (pending == GST_STATE_VOID_PENDING, "unexpected pending");
} else {
g_assert_not_reached ();
}
n_sink--;
} else {
g_critical
("Unexpected state change message src %s (%d src %d sink pending)",
GST_OBJECT_NAME (GST_MESSAGE_SRC (m)), n_src, n_sink);
}
gst_message_unref (m);
}
}
pop_state_change_message (bus, pipeline, GST_STATE_PAUSED, GST_STATE_PLAYING,
GST_STATE_VOID_PENDING);
#endif
gst_object_unref (bus);
gst_element_set_state (pipeline, GST_STATE_NULL);
gst_object_unref (pipeline);
}
GST_END_TEST;

89
tests/check/generic/sinks.c
View file

@ -22,6 +22,28 @@
#include <gst/check/gstcheck.h>
static void
pop_state_change_message (GstBus * bus, GstElement * src, GstState old,
GstState new, GstState pending)
{
GstMessage *message = NULL;
GstState _old, _new, _pending;
message = gst_bus_poll (bus, GST_MESSAGE_STATE_CHANGED, GST_SECOND);
fail_unless (message != NULL,
"Expected state change message, but got nothing");
gst_message_parse_state_changed (message, &_old, &_new, &_pending);
fail_unless (GST_MESSAGE_SRC (message) == (GstObject *) src,
"Unexpected state change order");
fail_unless (old == _old, "Unexpected old state");
fail_unless (new == _new, "Unexpected new state");
fail_unless (pending == _pending, "Unexpected pending state");
gst_message_unref (message);
}
/* a sink should go ASYNC to PAUSE. forcing PLAYING is possible */
GST_START_TEST (test_sink)
{
@ -192,6 +214,7 @@ GST_START_TEST (test_livesrc_sink)
GstStateChangeReturn ret;
GstState current, pending;
GstPad *srcpad, *sinkpad;
GstBus *bus;
pipeline = gst_pipeline_new ("pipeline");
src = gst_element_factory_make ("fakesrc", "src");
@ -207,10 +230,26 @@ GST_START_TEST (test_livesrc_sink)
gst_object_unref (srcpad);
gst_object_unref (sinkpad);
bus = gst_element_get_bus (pipeline);
ret = gst_element_set_state (pipeline, GST_STATE_PAUSED);
fail_unless (ret == GST_STATE_CHANGE_NO_PREROLL,
"no no_preroll state return");
pop_state_change_message (bus, sink, GST_STATE_NULL, GST_STATE_READY,
GST_STATE_VOID_PENDING);
pop_state_change_message (bus, src, GST_STATE_NULL, GST_STATE_READY,
GST_STATE_VOID_PENDING);
pop_state_change_message (bus, pipeline, GST_STATE_NULL, GST_STATE_READY,
GST_STATE_PAUSED);
/* this order only holds true for live sources because they do not push
buffers in PAUSED */
pop_state_change_message (bus, src, GST_STATE_READY, GST_STATE_PAUSED,
GST_STATE_VOID_PENDING);
pop_state_change_message (bus, pipeline, GST_STATE_READY, GST_STATE_PAUSED,
GST_STATE_VOID_PENDING);
ret = gst_element_set_state (pipeline, GST_STATE_PAUSED);
fail_unless (ret == GST_STATE_CHANGE_NO_PREROLL,
"no no_preroll state return the second time");
@ -239,6 +278,56 @@ GST_START_TEST (test_livesrc_sink)
fail_unless (ret == GST_STATE_CHANGE_SUCCESS, "not playing");
fail_unless (current == GST_STATE_PLAYING, "not playing");
fail_unless (pending == GST_STATE_VOID_PENDING, "not playing");
#ifdef WIM_EARNS_HIS_KEEP
/* now we have four messages on the bus: src from paused to playing, sink from
ready to paused and paused to playing, and pipeline from paused to playing.
the pipeline message should be last, and the sink messages should go in
order, but the src message can be interleaved with the sink one. */
{
GstMessage *m;
GstState old, new, pending;
gint n_src = 1, n_sink = 2;
while (n_src + n_sink > 0) {
m = gst_bus_poll (bus, GST_MESSAGE_STATE_CHANGED, GST_SECOND);
fail_unless (m != NULL, "expected state change message");
gst_message_parse_state_changed (m, &old, &new, &pending);
if (GST_MESSAGE_SRC (m) == (GstObject *) src) {
fail_unless (n_src == 1, "already got one message from the src");
n_src--;
fail_unless (old == GST_STATE_PAUSED, "unexpected old");
fail_unless (new == GST_STATE_PLAYING, "unexpected new (got %d)", new);
fail_unless (pending == GST_STATE_VOID_PENDING, "unexpected pending");
} else if (GST_MESSAGE_SRC (m) == (GstObject *) sink) {
if (n_sink == 2) {
fail_unless (old == GST_STATE_READY, "unexpected old");
fail_unless (new == GST_STATE_PAUSED, "unexpected new");
fail_unless (pending == GST_STATE_PLAYING, "unexpected pending");
} else if (n_sink == 1) {
fail_unless (old == GST_STATE_PAUSED, "unexpected old");
fail_unless (new == GST_STATE_PLAYING, "unexpected new");
fail_unless (pending == GST_STATE_VOID_PENDING, "unexpected pending");
} else {
g_assert_not_reached ();
}
n_sink--;
} else {
g_critical
("Unexpected state change message src %s (%d src %d sink pending)",
GST_OBJECT_NAME (GST_MESSAGE_SRC (m)), n_src, n_sink);
}
gst_message_unref (m);
}
}
pop_state_change_message (bus, pipeline, GST_STATE_PAUSED, GST_STATE_PLAYING,
GST_STATE_VOID_PENDING);
#endif
gst_object_unref (bus);
gst_element_set_state (pipeline, GST_STATE_NULL);
gst_object_unref (pipeline);
}
GST_END_TEST;