mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-14 13:21:28 +00:00
Code Issues 1 Projects Releases Wiki Activity
gstreamer/tests/check/libs/player.c
Guillaume Desmottes 0467923415 player: inhibit signals after gst_player_stop() has been called 
Also wait for the state change to STOP to have been announced before
destroying the player so it won't appear as leaked by leak detector
tools.

https://bugzilla.gnome.org/show_bug.cgi?id=766607
2016-05-30 12:43:22 +03:00

1681 lines
50 KiB
C
Raw Blame History

/* GStreamer
*
* Copyright (C) 2014-2015 Sebastian Dröge <sebastian@centricular.com>
* Copyright (C) 2015 Brijesh Singh <brijesh.ksingh@gmail.com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
* Boston, MA 02110-1301, USA.
*/
/* TODO:
* - start with pause, go to playing
* - play, pause, play
* - set uri in play/pause
* - play/pause after eos
* - seek in play/pause/stopped, after eos, back to 0, after duration
* - http buffering
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#ifdef HAVE_VALGRIND
# include <valgrind/valgrind.h>
#endif
#include <gst/check/gstcheck.h>
#define fail_unless_equals_int(a, b) \
G_STMT_START { \
int first = a; \
int second = b; \
fail_unless(first == second, \
"'" #a "' (%d) is not equal to '" #b"' (%d)", first, second); \
} G_STMT_END;
#define fail_unless_equals_uint64(a, b) \
G_STMT_START { \
guint64 first = a; \
guint64 second = b; \
fail_unless(first == second, \
"'" #a "' (%" G_GUINT64_FORMAT ") is not equal to '" #b"' (%" \
G_GUINT64_FORMAT ")", first, second); \
} G_STMT_END;
#define fail_unless_equals_double(a, b) \
G_STMT_START { \
double first = a; \
double second = b; \
fail_unless(first == second, \
"'" #a "' (%lf) is not equal to '" #b"' (%lf)", first, second); \
} G_STMT_END;
#include <gst/player/player.h>
START_TEST (test_create_and_free)
{
GstPlayer *player;
player = gst_player_new (NULL, NULL);
fail_unless (player != NULL);
g_object_unref (player);
}
END_TEST;
START_TEST (test_set_and_get_uri)
{
GstPlayer *player;
gchar *uri;
player = gst_player_new (NULL, NULL);
fail_unless (player != NULL);
gst_player_set_uri (player, "file:///path/to/a/file");
uri = gst_player_get_uri (player);
fail_unless (g_strcmp0 (uri, "file:///path/to/a/file") == 0);
g_free (uri);
g_object_unref (player);
}
END_TEST;
START_TEST (test_set_and_get_position_update_interval)
{
GstPlayer *player;
guint interval = 0;
player = gst_player_new (NULL, NULL);
fail_unless (player != NULL);
gst_player_set_position_update_interval (player, 500);
interval = gst_player_get_position_update_interval (player);
fail_unless (interval == 500);
g_object_set (player, "position-update-interval", 1000, NULL);
g_object_get (player, "position-update-interval", &interval, NULL);
fail_unless_equals_int (interval, 1000);
g_object_unref (player);
}
END_TEST;
typedef enum
{
STATE_CHANGE_BUFFERING,
STATE_CHANGE_DURATION_CHANGED,
STATE_CHANGE_END_OF_STREAM,
STATE_CHANGE_ERROR,
STATE_CHANGE_WARNING,
STATE_CHANGE_POSITION_UPDATED,
STATE_CHANGE_STATE_CHANGED,
STATE_CHANGE_VIDEO_DIMENSIONS_CHANGED,
STATE_CHANGE_MEDIA_INFO_UPDATED,
STATE_CHANGE_SEEK_DONE,
STATE_CHANGE_URI_LOADED,
} TestPlayerStateChange;
static const gchar *
test_player_state_change_get_name (TestPlayerStateChange change)
{
switch (change) {
case STATE_CHANGE_BUFFERING:
return "buffering";
case STATE_CHANGE_DURATION_CHANGED:
return "duration-changed";
case STATE_CHANGE_END_OF_STREAM:
return "end-of-stream";
case STATE_CHANGE_WARNING:
return "warning";
case STATE_CHANGE_ERROR:
return "error";
case STATE_CHANGE_POSITION_UPDATED:
return "position-updated";
case STATE_CHANGE_STATE_CHANGED:
return "state-changed";
case STATE_CHANGE_VIDEO_DIMENSIONS_CHANGED:
return "video-dimensions-changed";
case STATE_CHANGE_MEDIA_INFO_UPDATED:
return "media-info-updated";
case STATE_CHANGE_SEEK_DONE:
return "seek-done";
case STATE_CHANGE_URI_LOADED:
return "uri-loaded";
default:
g_assert_not_reached ();
break;
}
}
typedef struct _TestPlayerState TestPlayerState;
struct _TestPlayerState
{
GMainLoop *loop;
gint buffering_percent;
guint64 position, duration, seek_done_position;
gboolean end_of_stream, error, warning, seek_done;
GstPlayerState state;
gint width, height;
GstPlayerMediaInfo *media_info;
gchar *uri_loaded;
gboolean stopping;
void (*test_callback) (GstPlayer * player, TestPlayerStateChange change,
TestPlayerState * old_state, TestPlayerState * new_state);
gpointer test_data;
};
static void
test_player_state_change_debug (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
GST_DEBUG_OBJECT (player, "Changed %s:\n"
"\tbuffering %d%% -> %d%%\n"
"\tposition %" GST_TIME_FORMAT " -> %" GST_TIME_FORMAT "\n"
"\tduration %" GST_TIME_FORMAT " -> %" GST_TIME_FORMAT "\n"
"\tseek position %" GST_TIME_FORMAT " -> %" GST_TIME_FORMAT "\n"
"\tend-of-stream %d -> %d\n"
"\terror %d -> %d\n"
"\tseek_done %d -> %d\n"
"\tstate %s -> %s\n"
"\twidth/height %d/%d -> %d/%d\n"
"\tmedia_info %p -> %p\n"
"\turi_loaded %s -> %s",
test_player_state_change_get_name (change),
old_state->buffering_percent, new_state->buffering_percent,
GST_TIME_ARGS (old_state->position), GST_TIME_ARGS (new_state->position),
GST_TIME_ARGS (old_state->duration), GST_TIME_ARGS (new_state->duration),
GST_TIME_ARGS (old_state->seek_done_position),
GST_TIME_ARGS (new_state->seek_done_position), old_state->end_of_stream,
new_state->end_of_stream, old_state->error, new_state->error,
old_state->seek_done, new_state->seek_done,
gst_player_state_get_name (old_state->state),
gst_player_state_get_name (new_state->state), old_state->width,
old_state->height, new_state->width, new_state->height,
old_state->media_info, new_state->media_info,
old_state->uri_loaded, new_state->uri_loaded);
}
static void
test_player_state_reset (TestPlayerState * state)
{
state->buffering_percent = 100;
state->position = state->duration = state->seek_done_position = -1;
state->end_of_stream = state->error = state->seek_done = FALSE;
state->state = GST_PLAYER_STATE_STOPPED;
state->width = state->height = 0;
state->media_info = NULL;
state->stopping = FALSE;
g_clear_pointer (&state->uri_loaded, g_free);
}
static void
buffering_cb (GstPlayer * player, gint percent, TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->buffering_percent = percent;
test_player_state_change_debug (player, STATE_CHANGE_BUFFERING, &old_state,
state);
state->test_callback (player, STATE_CHANGE_BUFFERING, &old_state, state);
}
static void
duration_changed_cb (GstPlayer * player, guint64 duration,
TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->duration = duration;
test_player_state_change_debug (player, STATE_CHANGE_DURATION_CHANGED,
&old_state, state);
state->test_callback (player, STATE_CHANGE_DURATION_CHANGED, &old_state,
state);
}
static void
end_of_stream_cb (GstPlayer * player, TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->end_of_stream = TRUE;
test_player_state_change_debug (player, STATE_CHANGE_END_OF_STREAM,
&old_state, state);
state->test_callback (player, STATE_CHANGE_END_OF_STREAM, &old_state, state);
}
static void
error_cb (GstPlayer * player, GError * error, TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->error = TRUE;
test_player_state_change_debug (player, STATE_CHANGE_ERROR, &old_state,
state);
state->test_callback (player, STATE_CHANGE_ERROR, &old_state, state);
}
static void
warning_cb (GstPlayer * player, GError * error, TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->warning = TRUE;
test_player_state_change_debug (player, STATE_CHANGE_WARNING, &old_state,
state);
state->test_callback (player, STATE_CHANGE_WARNING, &old_state, state);
}
static void
position_updated_cb (GstPlayer * player, guint64 position,
TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->position = position;
test_player_state_change_debug (player, STATE_CHANGE_POSITION_UPDATED,
&old_state, state);
state->test_callback (player, STATE_CHANGE_POSITION_UPDATED, &old_state,
state);
}
static void
media_info_updated_cb (GstPlayer * player, GstPlayerMediaInfo * media_info,
TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->media_info = media_info;
test_player_state_change_debug (player, STATE_CHANGE_MEDIA_INFO_UPDATED,
&old_state, state);
state->test_callback (player, STATE_CHANGE_MEDIA_INFO_UPDATED, &old_state,
state);
}
static void
state_changed_cb (GstPlayer * player, GstPlayerState player_state,
TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping || player_state == GST_PLAYER_STATE_STOPPED);
state->state = player_state;
if (player_state == GST_PLAYER_STATE_STOPPED)
test_player_state_reset (state);
test_player_state_change_debug (player, STATE_CHANGE_STATE_CHANGED,
&old_state, state);
state->test_callback (player, STATE_CHANGE_STATE_CHANGED, &old_state, state);
}
static void
video_dimensions_changed_cb (GstPlayer * player, gint width, gint height,
TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->width = width;
state->height = height;
test_player_state_change_debug (player, STATE_CHANGE_VIDEO_DIMENSIONS_CHANGED,
&old_state, state);
state->test_callback (player, STATE_CHANGE_VIDEO_DIMENSIONS_CHANGED,
&old_state, state);
}
static void
seek_done_cb (GstPlayer * player, guint64 position, TestPlayerState * state)
{
TestPlayerState old_state = *state;
g_assert (!state->stopping);
state->seek_done = TRUE;
state->seek_done_position = position;
test_player_state_change_debug (player, STATE_CHANGE_SEEK_DONE,
&old_state, state);
state->test_callback (player, STATE_CHANGE_SEEK_DONE, &old_state, state);
}
static void
uri_loaded_cb (GstPlayer * player, const gchar * uri, TestPlayerState * state)
{
TestPlayerState old_state = *state;
state->uri_loaded = g_strdup (uri);
state->test_callback (player, STATE_CHANGE_URI_LOADED, &old_state, state);
}
static GstPlayer *
test_player_new (TestPlayerState * state)
{
GstPlayer *player;
GstElement *playbin, *fakesink;
player =
gst_player_new (NULL,
gst_player_g_main_context_signal_dispatcher_new (NULL));
fail_unless (player != NULL);
test_player_state_reset (state);
playbin = gst_player_get_pipeline (player);
fakesink = gst_element_factory_make ("fakesink", "audio-sink");
g_object_set (fakesink, "sync", TRUE, NULL);
g_object_set (playbin, "audio-sink", fakesink, NULL);
fakesink = gst_element_factory_make ("fakesink", "video-sink");
g_object_set (fakesink, "sync", TRUE, NULL);
g_object_set (playbin, "video-sink", fakesink, NULL);
gst_object_unref (playbin);
g_signal_connect (player, "buffering", G_CALLBACK (buffering_cb), state);
g_signal_connect (player, "duration-changed",
G_CALLBACK (duration_changed_cb), state);
g_signal_connect (player, "end-of-stream", G_CALLBACK (end_of_stream_cb),
state);
g_signal_connect (player, "error", G_CALLBACK (error_cb), state);
g_signal_connect (player, "warning", G_CALLBACK (warning_cb), state);
g_signal_connect (player, "position-updated",
G_CALLBACK (position_updated_cb), state);
g_signal_connect (player, "state-changed", G_CALLBACK (state_changed_cb),
state);
g_signal_connect (player, "media-info-updated",
G_CALLBACK (media_info_updated_cb), state);
g_signal_connect (player, "video-dimensions-changed",
G_CALLBACK (video_dimensions_changed_cb), state);
g_signal_connect (player, "seek-done", G_CALLBACK (seek_done_cb), state);
g_signal_connect (player, "uri-loaded", G_CALLBACK (uri_loaded_cb), state);
return player;
}
static void
test_player_stopped_cb (GstPlayer * player, TestPlayerStateChange change,
TestPlayerState * old_state, TestPlayerState * new_state)
{
if (new_state->state == GST_PLAYER_STATE_STOPPED) {
g_main_loop_quit (new_state->loop);
}
}
static void
stop_player (GstPlayer * player, TestPlayerState * state)
{
if (state->state != GST_PLAYER_STATE_STOPPED) {
/* Make sure all pending operations are finished so the player won't be
* appear as 'leaked' to leak detection tools. */
state->test_callback = test_player_stopped_cb;
gst_player_stop (player);
state->stopping = TRUE;
g_main_loop_run (state->loop);
}
}
static void
test_play_audio_video_eos_cb (GstPlayer * player, TestPlayerStateChange change,
TestPlayerState * old_state, TestPlayerState * new_state)
{
gint step = GPOINTER_TO_INT (new_state->test_data);
gboolean video;
video = ! !(step & 0x10);
step = (step & (~0x10));
switch (step) {
case 0:
fail_unless_equals_int (change, STATE_CHANGE_URI_LOADED);
if (video)
fail_unless (g_str_has_suffix (new_state->uri_loaded,
"audio-video-short.ogg"));
else
fail_unless (g_str_has_suffix (new_state->uri_loaded,
"audio-short.ogg"));
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 1:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_STOPPED);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_BUFFERING);
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 2:
fail_unless_equals_int (change, STATE_CHANGE_MEDIA_INFO_UPDATED);
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 3:
fail_unless_equals_int (change, STATE_CHANGE_VIDEO_DIMENSIONS_CHANGED);
if (video) {
fail_unless_equals_int (new_state->width, 320);
fail_unless_equals_int (new_state->height, 240);
} else {
fail_unless_equals_int (new_state->width, 0);
fail_unless_equals_int (new_state->height, 0);
}
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 4:
fail_unless_equals_int (change, STATE_CHANGE_DURATION_CHANGED);
fail_unless_equals_uint64 (new_state->duration,
G_GUINT64_CONSTANT (464399092));
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 5:
fail_unless_equals_int (change, STATE_CHANGE_POSITION_UPDATED);
fail_unless_equals_uint64 (new_state->position, G_GUINT64_CONSTANT (0));
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 6:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_BUFFERING);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_PLAYING);
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
break;
case 7:
if (change == STATE_CHANGE_POSITION_UPDATED) {
fail_unless (old_state->position <= new_state->position);
} else {
fail_unless_equals_uint64 (old_state->position, old_state->duration);
fail_unless_equals_int (change, STATE_CHANGE_END_OF_STREAM);
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
}
break;
case 8:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_PLAYING);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_STOPPED);
new_state->test_data =
GINT_TO_POINTER ((video ? 0x10 : 0x00) | (step + 1));
g_main_loop_quit (new_state->loop);
break;
default:
fail ();
break;
}
}
START_TEST (test_play_audio_eos)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_audio_video_eos_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio-short.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 9);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_audio_info (GstPlayerMediaInfo * media_info)
{
gint i = 0;
GList *list;
for (list = gst_player_get_audio_streams (media_info);
list != NULL; list = list->next) {
GstPlayerStreamInfo *stream = (GstPlayerStreamInfo *) list->data;
GstPlayerAudioInfo *audio_info = (GstPlayerAudioInfo *) stream;
fail_unless (gst_player_stream_info_get_tags (stream) != NULL);
fail_unless (gst_player_stream_info_get_caps (stream) != NULL);
fail_unless_equals_string (gst_player_stream_info_get_stream_type (stream),
"audio");
if (i == 0) {
fail_unless_equals_string (gst_player_stream_info_get_codec (stream),
"MPEG-1 Layer 3 (MP3)");
fail_unless_equals_int (gst_player_audio_info_get_sample_rate
(audio_info), 48000);
fail_unless_equals_int (gst_player_audio_info_get_channels (audio_info),
2);
fail_unless_equals_int (gst_player_audio_info_get_max_bitrate
(audio_info), 192000);
fail_unless (gst_player_audio_info_get_language (audio_info) != NULL);
} else {
fail_unless_equals_string (gst_player_stream_info_get_codec (stream),
"MPEG-4 AAC");
fail_unless_equals_int (gst_player_audio_info_get_sample_rate
(audio_info), 48000);
fail_unless_equals_int (gst_player_audio_info_get_channels (audio_info),
6);
fail_unless (gst_player_audio_info_get_language (audio_info) != NULL);
}
i++;
}
}
static void
test_video_info (GstPlayerMediaInfo * media_info)
{
GList *list;
for (list = gst_player_get_video_streams (media_info);
list != NULL; list = list->next) {
gint fps_d, fps_n;
guint par_d, par_n;
GstPlayerStreamInfo *stream = (GstPlayerStreamInfo *) list->data;
GstPlayerVideoInfo *video_info = (GstPlayerVideoInfo *) stream;
fail_unless (gst_player_stream_info_get_tags (stream) != NULL);
fail_unless (gst_player_stream_info_get_caps (stream) != NULL);
fail_unless_equals_int (gst_player_stream_info_get_index (stream), 0);
fail_unless (strstr (gst_player_stream_info_get_codec (stream),
"H.264") != NULL
|| strstr (gst_player_stream_info_get_codec (stream), "H264") != NULL);
fail_unless_equals_int (gst_player_video_info_get_width (video_info), 320);
fail_unless_equals_int (gst_player_video_info_get_height (video_info), 240);
gst_player_video_info_get_framerate (video_info, &fps_n, &fps_d);
fail_unless_equals_int (fps_n, 24);
fail_unless_equals_int (fps_d, 1);
gst_player_video_info_get_pixel_aspect_ratio (video_info, &par_n, &par_d);
fail_unless_equals_int (par_n, 33);
fail_unless_equals_int (par_d, 20);
}
}
static void
test_subtitle_info (GstPlayerMediaInfo * media_info)
{
GList *list;
for (list = gst_player_get_subtitle_streams (media_info);
list != NULL; list = list->next) {
GstPlayerStreamInfo *stream = (GstPlayerStreamInfo *) list->data;
GstPlayerSubtitleInfo *sub = (GstPlayerSubtitleInfo *) stream;
fail_unless_equals_string (gst_player_stream_info_get_stream_type (stream),
"subtitle");
fail_unless (gst_player_stream_info_get_tags (stream) != NULL);
fail_unless (gst_player_stream_info_get_caps (stream) != NULL);
fail_unless_equals_string (gst_player_stream_info_get_codec (stream),
"Timed Text");
fail_unless (gst_player_subtitle_info_get_language (sub) != NULL);
}
}
static void
test_media_info_object (GstPlayer * player, GstPlayerMediaInfo * media_info)
{
GList *list;
/* gloabl tag */
fail_unless (gst_player_media_info_is_seekable (media_info) == TRUE);
fail_unless (gst_player_media_info_get_tags (media_info) != NULL);
fail_unless_equals_string (gst_player_media_info_get_title (media_info),
"Sintel");
fail_unless_equals_string (gst_player_media_info_get_container_format
(media_info), "Matroska");
fail_unless (gst_player_media_info_get_image_sample (media_info) == NULL);
fail_unless (strstr (gst_player_media_info_get_uri (media_info),
"sintel.mkv") != NULL);
/* number of streams */
list = gst_player_media_info_get_stream_list (media_info);
fail_unless (list != NULL);
fail_unless_equals_int (g_list_length (list), 10);
list = gst_player_get_video_streams (media_info);
fail_unless (list != NULL);
fail_unless_equals_int (g_list_length (list), 1);
list = gst_player_get_audio_streams (media_info);
fail_unless (list != NULL);
fail_unless_equals_int (g_list_length (list), 2);
list = gst_player_get_subtitle_streams (media_info);
fail_unless (list != NULL);
fail_unless_equals_int (g_list_length (list), 7);
/* test subtitle */
test_subtitle_info (media_info);
/* test audio */
test_audio_info (media_info);
/* test video */
test_video_info (media_info);
}
static void
test_play_media_info_cb (GstPlayer * player, TestPlayerStateChange change,
TestPlayerState * old_state, TestPlayerState * new_state)
{
gint completed = GPOINTER_TO_INT (new_state->test_data);
if (change == STATE_CHANGE_MEDIA_INFO_UPDATED) {
test_media_info_object (player, new_state->media_info);
new_state->test_data = GINT_TO_POINTER (completed + 1);
g_main_loop_quit (new_state->loop);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR) {
g_main_loop_quit (new_state->loop);
}
}
START_TEST (test_play_media_info)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_media_info_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/sintel.mkv", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 1);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_error_invalid_external_suburi_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
gchar *suburi;
suburi = gst_filename_to_uri (TEST_PATH "/foo.srt", NULL);
fail_unless (suburi != NULL);
new_state->test_data = GINT_TO_POINTER (steps + 1);
/* load invalid suburi */
fail_unless (gst_player_set_subtitle_uri (player, suburi) != FALSE);
g_free (suburi);
} else if (steps && change == STATE_CHANGE_WARNING) {
new_state->test_data = GINT_TO_POINTER (steps + 1);
g_main_loop_quit (new_state->loop);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR)
g_main_loop_quit (new_state->loop);
}
static void
test_play_stream_disable_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data) & 0xf;
gint mask = GPOINTER_TO_INT (new_state->test_data) & 0xf0;
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
new_state->test_data = GINT_TO_POINTER (0x10 + steps + 1);
gst_player_set_audio_track_enabled (player, FALSE);
} else if (mask == 0x10 && change == STATE_CHANGE_POSITION_UPDATED) {
GstPlayerAudioInfo *audio;
audio = gst_player_get_current_audio_track (player);
fail_unless (audio == NULL);
new_state->test_data = GINT_TO_POINTER (0x20 + steps + 1);
gst_player_set_subtitle_track_enabled (player, FALSE);
} else if (mask == 0x20 && change == STATE_CHANGE_POSITION_UPDATED) {
GstPlayerSubtitleInfo *sub;
sub = gst_player_get_current_subtitle_track (player);
fail_unless (sub == NULL);
new_state->test_data = GINT_TO_POINTER (0x30 + steps + 1);
g_main_loop_quit (new_state->loop);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR) {
g_main_loop_quit (new_state->loop);
}
}
START_TEST (test_play_stream_disable)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_stream_disable_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/sintel.mkv", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 0x33);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_stream_switch_audio_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
gint ret;
new_state->test_data = GINT_TO_POINTER (steps + 1);
ret = gst_player_set_audio_track (player, 1);
fail_unless_equals_int (ret, 1);
} else if (steps && change == STATE_CHANGE_POSITION_UPDATED) {
gint index;
GstPlayerAudioInfo *audio;
audio = gst_player_get_current_audio_track (player);
fail_unless (audio != NULL);
index = gst_player_stream_info_get_index ((GstPlayerStreamInfo *) audio);
fail_unless_equals_int (index, 1);
g_object_unref (audio);
new_state->test_data = GINT_TO_POINTER (steps + 1);
g_main_loop_quit (new_state->loop);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR) {
g_main_loop_quit (new_state->loop);
}
}
START_TEST (test_play_stream_switch_audio)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_stream_switch_audio_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/sintel.mkv", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 2);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_stream_switch_subtitle_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
gint ret;
new_state->test_data = GINT_TO_POINTER (steps + 1);
ret = gst_player_set_subtitle_track (player, 5);
fail_unless_equals_int (ret, 1);
} else if (steps && change == STATE_CHANGE_POSITION_UPDATED) {
gint index;
GstPlayerSubtitleInfo *sub;
sub = gst_player_get_current_subtitle_track (player);
fail_unless (sub != NULL);
index = gst_player_stream_info_get_index ((GstPlayerStreamInfo *) sub);
fail_unless_equals_int (index, 5);
g_object_unref (sub);
new_state->test_data = GINT_TO_POINTER (steps + 1);
g_main_loop_quit (new_state->loop);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR) {
g_main_loop_quit (new_state->loop);
}
}
START_TEST (test_play_stream_switch_subtitle)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_stream_switch_subtitle_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/sintel.mkv", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 2);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
START_TEST (test_play_error_invalid_external_suburi)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_error_invalid_external_suburi_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio-video.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 2);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static gboolean
has_subtitle_stream (TestPlayerState * new_state)
{
if (gst_player_get_subtitle_streams (new_state->media_info))
return TRUE;
return FALSE;
}
static void
test_play_external_suburi_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
gchar *suburi;
suburi = gst_filename_to_uri (TEST_PATH "/test_sub.srt", NULL);
fail_unless (suburi != NULL);
fail_unless (gst_player_set_subtitle_uri (player, suburi) != FALSE);
g_free (suburi);
new_state->test_data = GINT_TO_POINTER (steps + 1);
} else if (change == STATE_CHANGE_MEDIA_INFO_UPDATED &&
has_subtitle_stream (new_state)) {
gchar *current_suburi, *suburi;
current_suburi = gst_player_get_subtitle_uri (player);
fail_unless (current_suburi != NULL);
suburi = gst_filename_to_uri (TEST_PATH "/test_sub.srt", NULL);
fail_unless (suburi != NULL);
fail_unless_equals_int (g_strcmp0 (current_suburi, suburi), 0);
g_free (current_suburi);
g_free (suburi);
new_state->test_data = GINT_TO_POINTER (steps + 1);
g_main_loop_quit (new_state->loop);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR)
g_main_loop_quit (new_state->loop);
}
START_TEST (test_play_external_suburi)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_external_suburi_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio-video.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 2);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_rate_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data) & 0xf;
gint mask = GPOINTER_TO_INT (new_state->test_data) & 0xf0;
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
guint64 dur = -1, pos = -1;
g_object_get (player, "position", &pos, "duration", &dur, NULL);
pos = pos + dur * 0.2; /* seek 20% */
gst_player_seek (player, pos);
/* default rate should be 1.0 */
fail_unless_equals_double (gst_player_get_rate (player), 1.0);
new_state->test_data = GINT_TO_POINTER (mask + steps + 1);
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR) {
g_main_loop_quit (new_state->loop);
} else if (steps == 1 && change == STATE_CHANGE_SEEK_DONE) {
if (mask == 0x10)
gst_player_set_rate (player, 1.5);
else if (mask == 0x20)
gst_player_set_rate (player, -1.0);
new_state->test_data = GINT_TO_POINTER (mask + steps + 1);
} else if (steps && (change == STATE_CHANGE_POSITION_UPDATED)) {
if (steps == 10) {
g_main_loop_quit (new_state->loop);
} else {
if (mask == 0x10 && (new_state->position > old_state->position))
new_state->test_data = GINT_TO_POINTER (mask + steps + 1);
else if (mask == 0x20 && (new_state->position < old_state->position))
new_state->test_data = GINT_TO_POINTER (mask + steps + 1);
}
}
}
START_TEST (test_play_forward_rate)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_rate_cb;
state.test_data = GINT_TO_POINTER (0x10);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data) & 0xf, 10);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
START_TEST (test_play_backward_rate)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_rate_cb;
state.test_data = GINT_TO_POINTER (0x20);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data) & 0xf, 10);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
START_TEST (test_play_audio_video_eos)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_audio_video_eos_cb;
state.test_data = GINT_TO_POINTER (0x10);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio-video-short.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data) & (~0x10), 9);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_error_invalid_uri_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint step = GPOINTER_TO_INT (new_state->test_data);
switch (step) {
case 0:
fail_unless_equals_int (change, STATE_CHANGE_URI_LOADED);
fail_unless_equals_string (new_state->uri_loaded, "foo://bar");
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 1:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_STOPPED);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_BUFFERING);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 2:
fail_unless_equals_int (change, STATE_CHANGE_ERROR);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 3:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_BUFFERING);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_STOPPED);
new_state->test_data = GINT_TO_POINTER (step + 1);
g_main_loop_quit (new_state->loop);
break;
default:
fail ();
break;
}
}
START_TEST (test_play_error_invalid_uri)
{
GstPlayer *player;
TestPlayerState state;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_error_invalid_uri_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
gst_player_set_uri (player, "foo://bar");
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 4);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_error_invalid_uri_and_play_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint step = GPOINTER_TO_INT (new_state->test_data);
gchar *uri;
switch (step) {
case 0:
fail_unless_equals_int (change, STATE_CHANGE_URI_LOADED);
fail_unless_equals_string (new_state->uri_loaded, "foo://bar");
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 1:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_STOPPED);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_BUFFERING);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 2:
fail_unless_equals_int (change, STATE_CHANGE_ERROR);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 3:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_BUFFERING);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_STOPPED);
new_state->test_data = GINT_TO_POINTER (step + 1);
uri = gst_filename_to_uri (TEST_PATH "/audio-short.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
break;
case 4:
fail_unless_equals_int (change, STATE_CHANGE_URI_LOADED);
fail_unless (g_str_has_suffix (new_state->uri_loaded, "audio-short.ogg"));
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 5:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_STOPPED);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_BUFFERING);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 6:
fail_unless_equals_int (change, STATE_CHANGE_MEDIA_INFO_UPDATED);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 7:
fail_unless_equals_int (change, STATE_CHANGE_VIDEO_DIMENSIONS_CHANGED);
fail_unless_equals_int (new_state->width, 0);
fail_unless_equals_int (new_state->height, 0);
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 8:
fail_unless_equals_int (change, STATE_CHANGE_DURATION_CHANGED);
fail_unless_equals_uint64 (new_state->duration,
G_GUINT64_CONSTANT (464399092));
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 9:
fail_unless_equals_int (change, STATE_CHANGE_POSITION_UPDATED);
fail_unless_equals_uint64 (new_state->position, G_GUINT64_CONSTANT (0));
new_state->test_data = GINT_TO_POINTER (step + 1);
break;
case 10:
fail_unless_equals_int (change, STATE_CHANGE_STATE_CHANGED);
fail_unless_equals_int (old_state->state, GST_PLAYER_STATE_BUFFERING);
fail_unless_equals_int (new_state->state, GST_PLAYER_STATE_PLAYING);
new_state->test_data = GINT_TO_POINTER (step + 1);
g_main_loop_quit (new_state->loop);
break;
default:
fail ();
break;
}
}
START_TEST (test_play_error_invalid_uri_and_play)
{
GstPlayer *player;
TestPlayerState state;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_error_invalid_uri_and_play_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
gst_player_set_uri (player, "foo://bar");
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 11);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_seek_done_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint step = GPOINTER_TO_INT (new_state->test_data) & (~0x10);
if (new_state->state == GST_PLAYER_STATE_PLAYING && !step) {
gst_player_seek (player, 0);
new_state->test_data = GINT_TO_POINTER (step + 1);
} else if (change == STATE_CHANGE_SEEK_DONE || change == STATE_CHANGE_ERROR) {
fail_unless_equals_int (change, STATE_CHANGE_SEEK_DONE);
fail_unless_equals_uint64 (new_state->seek_done_position,
G_GUINT64_CONSTANT (0));
new_state->test_data = GINT_TO_POINTER (step + 1);
g_main_loop_quit (new_state->loop);
}
}
START_TEST (test_play_audio_video_seek_done)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_seek_done_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/audio-video.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data) & (~0x10), 2);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_play_position_update_interval_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
static gboolean do_quit = TRUE;
static GstClockTime last_position = GST_CLOCK_TIME_NONE;
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (new_state->state == GST_PLAYER_STATE_PLAYING && !steps) {
new_state->test_data = GINT_TO_POINTER (steps + 1);
} else if (steps && change == STATE_CHANGE_POSITION_UPDATED) {
GstClockTime position = gst_player_get_position (player);
new_state->test_data = GINT_TO_POINTER (steps + 1);
if (GST_CLOCK_TIME_IS_VALID (last_position)) {
GstClockTime interval = GST_CLOCK_DIFF (last_position, position);
GST_DEBUG_OBJECT (player,
"position update interval: %" GST_TIME_FORMAT "\n",
GST_TIME_ARGS (interval));
fail_unless (interval > (590 * GST_MSECOND)
&& interval < (610 * GST_MSECOND));
}
last_position = position;
if (do_quit && position >= 2000 * GST_MSECOND) {
do_quit = FALSE;
gst_player_set_position_update_interval (player, 0);
g_main_loop_quit (new_state->loop);
}
} else if (change == STATE_CHANGE_END_OF_STREAM ||
change == STATE_CHANGE_ERROR) {
g_main_loop_quit (new_state->loop);
}
}
static gboolean
quit_loop_cb (gpointer user_data)
{
GMainLoop *loop = user_data;
g_main_loop_quit (loop);
return G_SOURCE_REMOVE;
}
START_TEST (test_play_position_update_interval)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_play_position_update_interval_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
gst_player_set_position_update_interval (player, 600);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/sintel.mkv", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 5);
g_timeout_add (2000, quit_loop_cb, state.loop);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 5);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static void
test_restart_cb (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (!steps && change == STATE_CHANGE_URI_LOADED) {
fail_unless (g_str_has_suffix (new_state->uri_loaded, "sintel.mkv"));
new_state->test_data = GINT_TO_POINTER (steps + 1);
} else if (change == STATE_CHANGE_STATE_CHANGED
&& new_state->state == GST_PLAYER_STATE_BUFFERING) {
new_state->test_data = GINT_TO_POINTER (steps + 1);
g_main_loop_quit (new_state->loop);
}
}
static void
test_restart_cb2 (GstPlayer * player,
TestPlayerStateChange change, TestPlayerState * old_state,
TestPlayerState * new_state)
{
gint steps = GPOINTER_TO_INT (new_state->test_data);
if (!steps && change == STATE_CHANGE_URI_LOADED) {
fail_unless (g_str_has_suffix (new_state->uri_loaded, "audio-short.ogg"));
new_state->test_data = GINT_TO_POINTER (steps + 1);
} else if (change == STATE_CHANGE_STATE_CHANGED
&& new_state->state == GST_PLAYER_STATE_BUFFERING) {
new_state->test_data = GINT_TO_POINTER (steps + 1);
g_main_loop_quit (new_state->loop);
}
}
START_TEST (test_restart)
{
GstPlayer *player;
TestPlayerState state;
gchar *uri;
memset (&state, 0, sizeof (state));
state.loop = g_main_loop_new (NULL, FALSE);
state.test_callback = test_restart_cb;
state.test_data = GINT_TO_POINTER (0);
player = test_player_new (&state);
fail_unless (player != NULL);
uri = gst_filename_to_uri (TEST_PATH "/sintel.mkv", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 2);
stop_player (player, &state);
/* Try again with another URI */
state.test_data = GINT_TO_POINTER (0);
state.test_callback = test_restart_cb2;
uri = gst_filename_to_uri (TEST_PATH "/audio-short.ogg", NULL);
fail_unless (uri != NULL);
gst_player_set_uri (player, uri);
g_free (uri);
gst_player_play (player);
g_main_loop_run (state.loop);
fail_unless_equals_int (GPOINTER_TO_INT (state.test_data), 2);
stop_player (player, &state);
g_object_unref (player);
g_main_loop_unref (state.loop);
}
END_TEST;
static Suite *
player_suite (void)
{
Suite *s = suite_create ("GstPlayer");
TCase *tc_general = tcase_create ("general");
/* Use a longer timeout */
#ifdef HAVE_VALGRIND
if (RUNNING_ON_VALGRIND) {
tcase_set_timeout (tc_general, 5 * 60);
} else
#endif
{
tcase_set_timeout (tc_general, 2 * 60);
}
tcase_add_test (tc_general, test_create_and_free);
tcase_add_test (tc_general, test_set_and_get_uri);
tcase_add_test (tc_general, test_set_and_get_position_update_interval);
#ifdef HAVE_VALGRIND
if (RUNNING_ON_VALGRIND) {
} else
#endif
{
tcase_add_test (tc_general, test_play_position_update_interval);
}
tcase_add_test (tc_general, test_play_audio_eos);
tcase_add_test (tc_general, test_play_audio_video_eos);
tcase_add_test (tc_general, test_play_error_invalid_uri);
tcase_add_test (tc_general, test_play_error_invalid_uri_and_play);
tcase_add_test (tc_general, test_play_media_info);
tcase_add_test (tc_general, test_play_stream_disable);
tcase_add_test (tc_general, test_play_stream_switch_audio);
tcase_add_test (tc_general, test_play_stream_switch_subtitle);
tcase_add_test (tc_general, test_play_error_invalid_external_suburi);
tcase_add_test (tc_general, test_play_external_suburi);
tcase_add_test (tc_general, test_play_forward_rate);
tcase_add_test (tc_general, test_play_backward_rate);
tcase_add_test (tc_general, test_play_audio_video_seek_done);
tcase_add_test (tc_general, test_restart);
suite_add_tcase (s, tc_general);
return s;
}
int
main (int argc, char **argv)
{
int number_failed;
Suite *s;
SRunner *sr;
gst_check_init (&argc, &argv);
s = player_suite ();
sr = srunner_create (s);
srunner_run_all (sr, CK_NORMAL);
number_failed = srunner_ntests_failed (sr);
srunner_free (sr);
return (number_failed == 0) ? 0 : -1;
}
Reference in a new issue View git blame Copy permalink