mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 04:36:20 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst-play: Port to GstPlay

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-examples/-/merge_requests/33>
This commit is contained in:
Philippe Normand 2020-11-14 11:01:01 +00:00
parent 50e61f52ed
commit 840fcf43f5
3 changed files with 109 additions and 105 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
meson.build
View file

@ -20,8 +20,8 @@ gmodule_dep = dependency('gmodule-2.0',
gst_dep = dependency('gstreamer-1.0', gst_dep = dependency('gstreamer-1.0',
fallback : ['gstreamer', 'gst_dep']) fallback : ['gstreamer', 'gst_dep'])
gstplayer_dep = dependency('gstreamer-player-1.0', version: '>= 1.7.1.1', gstplay_dep = dependency('gstreamer-play-1.0', version: '>= 1.19.0.1',
fallback: ['gst-plugins-bad', 'gstplayer_dep']) fallback: ['gst-plugins-bad', 'gstplay_dep'])
gsttag_dep = dependency('gstreamer-tag-1.0', gsttag_dep = dependency('gstreamer-tag-1.0',
fallback: ['gst-plugins-base', 'tag_dep']) fallback: ['gst-plugins-base', 'tag_dep'])
gstwebrtc_dep = dependency('gstreamer-webrtc-1.0', version: '>= 1.14.0', gstwebrtc_dep = dependency('gstreamer-webrtc-1.0', version: '>= 1.14.0',

208
playback/player/gst-play/gst-play.c
View file

@ -30,7 +30,7 @@
#include <math.h> #include <math.h>
#include "gst-play-kb.h" #include "gst-play-kb.h"
#include <gst/player/player.h> #include <gst/play/play.h>
#define VOLUME_STEPS 20 #define VOLUME_STEPS 20
@ -43,21 +43,22 @@ typedef struct
guint num_uris; guint num_uris;
gint cur_idx; gint cur_idx;
GstPlayer *player; GstPlay *player;
GstPlaySignalAdapter *signal_adapter;
GstState desired_state; GstState desired_state;
gboolean repeat; gboolean repeat;
GMainLoop *loop; GMainLoop *loop;
} GstPlay; } Player;
static gboolean play_next (GstPlay * play); static gboolean play_next (Player * play);
static gboolean play_prev (GstPlay * play); static gboolean play_prev (Player * play);
static void play_reset (GstPlay * play); static void play_reset (Player * play);
static void play_set_relative_volume (GstPlay * play, gdouble volume_step); static void play_set_relative_volume (Player * play, gdouble volume_step);
static void static void
end_of_stream_cb (GstPlayer * player, GstPlay * play) end_of_stream_cb (GstPlaySignalAdapter * adapter, Player * play)
{ {
gst_print ("\n"); gst_print ("\n");
/* and switch to next item in list */ /* and switch to next item in list */
@ -68,7 +69,7 @@ end_of_stream_cb (GstPlayer * player, GstPlay * play)
} }
static void static void
error_cb (GstPlayer * player, GError * err, GstPlay * play) error_cb (GstPlaySignalAdapter * adapter, GError * err, Player * play)
{ {
gst_printerr ("ERROR %s for %s\n", err->message, play->uris[play->cur_idx]); gst_printerr ("ERROR %s for %s\n", err->message, play->uris[play->cur_idx]);
@ -83,7 +84,8 @@ error_cb (GstPlayer * player, GError * err, GstPlay * play)
} }
static void static void
position_updated_cb (GstPlayer * player, GstClockTime pos, GstPlay * play) position_updated_cb (GstPlaySignalAdapter * adapter, GstClockTime pos,
Player * play)
{ {
GstClockTime dur = -1; GstClockTime dur = -1;
gchar status[64] = { 0, }; gchar status[64] = { 0, };
@ -105,13 +107,14 @@ position_updated_cb (GstPlayer * player, GstClockTime pos, GstPlay * play)
} }
static void static void
state_changed_cb (GstPlayer * player, GstPlayerState state, GstPlay * play) state_changed_cb (GstPlaySignalAdapter * adapter, GstPlayState state,
Player * play)
{ {
gst_print ("State changed: %s\n", gst_player_state_get_name (state)); gst_print ("State changed: %s\n", gst_play_state_get_name (state));
} }
static void static void
buffering_cb (GstPlayer * player, gint percent, GstPlay * play) buffering_cb (GstPlaySignalAdapter * adapter, gint percent, Player * play)
{ {
gst_print ("Buffering: %d\n", percent); gst_print ("Buffering: %d\n", percent);
} }
@ -148,7 +151,7 @@ print_one_tag (const GstTagList * list, const gchar * tag, gpointer user_data)
} }
static void static void
print_video_info (GstPlayerVideoInfo * info) print_video_info (GstPlayVideoInfo * info)
{ {
gint fps_n, fps_d; gint fps_n, fps_d;
guint par_n, par_d; guint par_n, par_d;
@ -156,159 +159,159 @@ print_video_info (GstPlayerVideoInfo * info)
if (info == NULL) if (info == NULL)
return; return;
gst_print (" width : %d\n", gst_player_video_info_get_width (info)); gst_print (" width : %d\n", gst_play_video_info_get_width (info));
gst_print (" height : %d\n", gst_player_video_info_get_height (info)); gst_print (" height : %d\n", gst_play_video_info_get_height (info));
gst_print (" max_bitrate : %d\n", gst_print (" max_bitrate : %d\n",
gst_player_video_info_get_max_bitrate (info)); gst_play_video_info_get_max_bitrate (info));
gst_print (" bitrate : %d\n", gst_player_video_info_get_bitrate (info)); gst_print (" bitrate : %d\n", gst_play_video_info_get_bitrate (info));
gst_player_video_info_get_framerate (info, &fps_n, &fps_d); gst_play_video_info_get_framerate (info, &fps_n, &fps_d);
gst_print (" framerate : %.2f\n", (gdouble) fps_n / fps_d); gst_print (" framerate : %.2f\n", (gdouble) fps_n / fps_d);
gst_player_video_info_get_pixel_aspect_ratio (info, &par_n, &par_d); gst_play_video_info_get_pixel_aspect_ratio (info, &par_n, &par_d);
gst_print (" pixel-aspect-ratio %u:%u\n", par_n, par_d); gst_print (" pixel-aspect-ratio %u:%u\n", par_n, par_d);
} }
static void static void
print_audio_info (GstPlayerAudioInfo * info) print_audio_info (GstPlayAudioInfo * info)
{ {
if (info == NULL) if (info == NULL)
return; return;
gst_print (" sample rate : %d\n", gst_print (" sample rate : %d\n",
gst_player_audio_info_get_sample_rate (info)); gst_play_audio_info_get_sample_rate (info));
gst_print (" channels : %d\n", gst_player_audio_info_get_channels (info)); gst_print (" channels : %d\n", gst_play_audio_info_get_channels (info));
gst_print (" max_bitrate : %d\n", gst_print (" max_bitrate : %d\n",
gst_player_audio_info_get_max_bitrate (info)); gst_play_audio_info_get_max_bitrate (info));
gst_print (" bitrate : %d\n", gst_player_audio_info_get_bitrate (info)); gst_print (" bitrate : %d\n", gst_play_audio_info_get_bitrate (info));
gst_print (" language : %s\n", gst_player_audio_info_get_language (info)); gst_print (" language : %s\n", gst_play_audio_info_get_language (info));
} }
static void static void
print_subtitle_info (GstPlayerSubtitleInfo * info) print_subtitle_info (GstPlaySubtitleInfo * info)
{ {
if (info == NULL) if (info == NULL)
return; return;
gst_print (" language : %s\n", gst_player_subtitle_info_get_language (info)); gst_print (" language : %s\n", gst_play_subtitle_info_get_language (info));
} }
static void static void
print_all_stream_info (GstPlayerMediaInfo * media_info) print_all_stream_info (GstPlayMediaInfo * media_info)
{ {
guint count = 0; guint count = 0;
GList *list, *l; GList *list, *l;
gst_print ("URI : %s\n", gst_player_media_info_get_uri (media_info)); gst_print ("URI : %s\n", gst_play_media_info_get_uri (media_info));
gst_print ("Duration: %" GST_TIME_FORMAT "\n", gst_print ("Duration: %" GST_TIME_FORMAT "\n",
GST_TIME_ARGS (gst_player_media_info_get_duration (media_info))); GST_TIME_ARGS (gst_play_media_info_get_duration (media_info)));
gst_print ("Global taglist:\n"); gst_print ("Global taglist:\n");
if (gst_player_media_info_get_tags (media_info)) if (gst_play_media_info_get_tags (media_info))
gst_tag_list_foreach (gst_player_media_info_get_tags (media_info), gst_tag_list_foreach (gst_play_media_info_get_tags (media_info),
print_one_tag, NULL); print_one_tag, NULL);
else else
gst_print (" (nil) \n"); gst_print (" (nil) \n");
list = gst_player_media_info_get_stream_list (media_info); list = gst_play_media_info_get_stream_list (media_info);
if (!list) if (!list)
return; return;
gst_print ("All Stream information\n"); gst_print ("All Stream information\n");
for (l = list; l != NULL; l = l->next) { for (l = list; l != NULL; l = l->next) {
GstTagList *tags = NULL; GstTagList *tags = NULL;
GstPlayerStreamInfo *stream = (GstPlayerStreamInfo *) l->data; GstPlayStreamInfo *stream = (GstPlayStreamInfo *) l->data;
gst_print (" Stream # %u \n", count++); gst_print (" Stream # %u \n", count++);
gst_print (" type : %s_%u\n", gst_print (" type : %s_%u\n",
gst_player_stream_info_get_stream_type (stream), gst_play_stream_info_get_stream_type (stream),
gst_player_stream_info_get_index (stream)); gst_play_stream_info_get_index (stream));
tags = gst_player_stream_info_get_tags (stream); tags = gst_play_stream_info_get_tags (stream);
gst_print (" taglist : \n"); gst_print (" taglist : \n");
if (tags) { if (tags) {
gst_tag_list_foreach (tags, print_one_tag, NULL); gst_tag_list_foreach (tags, print_one_tag, NULL);
} }
if (GST_IS_PLAYER_VIDEO_INFO (stream)) if (GST_IS_PLAY_VIDEO_INFO (stream))
print_video_info ((GstPlayerVideoInfo *) stream); print_video_info ((GstPlayVideoInfo *) stream);
else if (GST_IS_PLAYER_AUDIO_INFO (stream)) else if (GST_IS_PLAY_AUDIO_INFO (stream))
print_audio_info ((GstPlayerAudioInfo *) stream); print_audio_info ((GstPlayAudioInfo *) stream);
else else
print_subtitle_info ((GstPlayerSubtitleInfo *) stream); print_subtitle_info ((GstPlaySubtitleInfo *) stream);
} }
} }
static void static void
print_all_video_stream (GstPlayerMediaInfo * media_info) print_all_video_stream (GstPlayMediaInfo * media_info)
{ {
GList *list, *l; GList *list, *l;
list = gst_player_media_info_get_video_streams (media_info); list = gst_play_media_info_get_video_streams (media_info);
if (!list) if (!list)
return; return;
gst_print ("All video streams\n"); gst_print ("All video streams\n");
for (l = list; l != NULL; l = l->next) { for (l = list; l != NULL; l = l->next) {
GstPlayerVideoInfo *info = (GstPlayerVideoInfo *) l->data; GstPlayVideoInfo *info = (GstPlayVideoInfo *) l->data;
GstPlayerStreamInfo *sinfo = (GstPlayerStreamInfo *) info; GstPlayStreamInfo *sinfo = (GstPlayStreamInfo *) info;
gst_print (" %s_%d #\n", gst_player_stream_info_get_stream_type (sinfo), gst_print (" %s_%d #\n", gst_play_stream_info_get_stream_type (sinfo),
gst_player_stream_info_get_index (sinfo)); gst_play_stream_info_get_index (sinfo));
print_video_info (info); print_video_info (info);
} }
} }
static void static void
print_all_subtitle_stream (GstPlayerMediaInfo * media_info) print_all_subtitle_stream (GstPlayMediaInfo * media_info)
{ {
GList *list, *l; GList *list, *l;
list = gst_player_media_info_get_subtitle_streams (media_info); list = gst_play_media_info_get_subtitle_streams (media_info);
if (!list) if (!list)
return; return;
gst_print ("All subtitle streams:\n"); gst_print ("All subtitle streams:\n");
for (l = list; l != NULL; l = l->next) { for (l = list; l != NULL; l = l->next) {
GstPlayerSubtitleInfo *info = (GstPlayerSubtitleInfo *) l->data; GstPlaySubtitleInfo *info = (GstPlaySubtitleInfo *) l->data;
GstPlayerStreamInfo *sinfo = (GstPlayerStreamInfo *) info; GstPlayStreamInfo *sinfo = (GstPlayStreamInfo *) info;
gst_print (" %s_%d #\n", gst_player_stream_info_get_stream_type (sinfo), gst_print (" %s_%d #\n", gst_play_stream_info_get_stream_type (sinfo),
gst_player_stream_info_get_index (sinfo)); gst_play_stream_info_get_index (sinfo));
print_subtitle_info (info); print_subtitle_info (info);
} }
} }
static void static void
print_all_audio_stream (GstPlayerMediaInfo * media_info) print_all_audio_stream (GstPlayMediaInfo * media_info)
{ {
GList *list, *l; GList *list, *l;
list = gst_player_media_info_get_audio_streams (media_info); list = gst_play_media_info_get_audio_streams (media_info);
if (!list) if (!list)
return; return;
gst_print ("All audio streams: \n"); gst_print ("All audio streams: \n");
for (l = list; l != NULL; l = l->next) { for (l = list; l != NULL; l = l->next) {
GstPlayerAudioInfo *info = (GstPlayerAudioInfo *) l->data; GstPlayAudioInfo *info = (GstPlayAudioInfo *) l->data;
GstPlayerStreamInfo *sinfo = (GstPlayerStreamInfo *) info; GstPlayStreamInfo *sinfo = (GstPlayStreamInfo *) info;
gst_print (" %s_%d #\n", gst_player_stream_info_get_stream_type (sinfo), gst_print (" %s_%d #\n", gst_play_stream_info_get_stream_type (sinfo),
gst_player_stream_info_get_index (sinfo)); gst_play_stream_info_get_index (sinfo));
print_audio_info (info); print_audio_info (info);
} }
} }
static void static void
print_current_tracks (GstPlay * play) print_current_tracks (Player * play)
{ {
GstPlayerAudioInfo *audio = NULL; GstPlayAudioInfo *audio = NULL;
GstPlayerVideoInfo *video = NULL; GstPlayVideoInfo *video = NULL;
GstPlayerSubtitleInfo *subtitle = NULL; GstPlaySubtitleInfo *subtitle = NULL;
gst_print ("Current video track: \n"); gst_print ("Current video track: \n");
video = gst_player_get_current_video_track (play->player); video = gst_play_get_current_video_track (play->player);
print_video_info (video); print_video_info (video);
gst_print ("Current audio track: \n"); gst_print ("Current audio track: \n");
audio = gst_player_get_current_audio_track (play->player); audio = gst_play_get_current_audio_track (play->player);
print_audio_info (audio); print_audio_info (audio);
gst_print ("Current subtitle track: \n"); gst_print ("Current subtitle track: \n");
subtitle = gst_player_get_current_subtitle_track (play->player); subtitle = gst_play_get_current_subtitle_track (play->player);
print_subtitle_info (subtitle); print_subtitle_info (subtitle);
if (audio) if (audio)
@ -322,7 +325,7 @@ print_current_tracks (GstPlay * play)
} }
static void static void
print_media_info (GstPlayerMediaInfo * media_info) print_media_info (GstPlayMediaInfo * media_info)
{ {
print_all_stream_info (media_info); print_all_stream_info (media_info);
gst_print ("\n"); gst_print ("\n");
@ -334,7 +337,8 @@ print_media_info (GstPlayerMediaInfo * media_info)
} }
static void static void
media_info_cb (GstPlayer * player, GstPlayerMediaInfo * info, GstPlay * play) media_info_cb (GstPlaySignalAdapter * adapter, GstPlayMediaInfo * info,
Player * play)
{ {
static int once = 0; static int once = 0;
@ -345,38 +349,37 @@ media_info_cb (GstPlayer * player, GstPlayerMediaInfo * info, GstPlay * play)
} }
} }
static GstPlay * static Player *
play_new (gchar ** uris, gdouble initial_volume) play_new (gchar ** uris, gdouble initial_volume)
{ {
GstPlay *play; Player *play;
play = g_new0 (GstPlay, 1); play = g_new0 (Player, 1);
play->uris = uris; play->uris = uris;
play->num_uris = g_strv_length (uris); play->num_uris = g_strv_length (uris);
play->cur_idx = -1; play->cur_idx = -1;
play->player = play->player = gst_play_new (NULL);
gst_player_new (NULL);
play->loop = g_main_loop_new (NULL, FALSE); play->loop = g_main_loop_new (NULL, FALSE);
play->desired_state = GST_STATE_PLAYING; play->desired_state = GST_STATE_PLAYING;
GstPlayerSignalAdapter *player_sig_adapt play->signal_adapter
= gst_player_signal_adapter_new( = gst_play_signal_adapter_new_with_main_context (play->player,
play->player, g_main_loop_get_context (play->loop));
g_main_loop_get_context (play->loop));
g_signal_connect (player_sig_adapt, "position-updated", g_signal_connect (play->signal_adapter, "position-updated",
G_CALLBACK (position_updated_cb), play); G_CALLBACK (position_updated_cb), play);
g_signal_connect (player_sig_adapt, "state-changed", g_signal_connect (play->signal_adapter, "state-changed",
G_CALLBACK (state_changed_cb), play); G_CALLBACK (state_changed_cb), play);
g_signal_connect (player_sig_adapt, "buffering", G_CALLBACK (buffering_cb), play); g_signal_connect (play->signal_adapter, "buffering",
g_signal_connect (player_sig_adapt, "end-of-stream", G_CALLBACK (buffering_cb), play);
g_signal_connect (play->signal_adapter, "end-of-stream",
G_CALLBACK (end_of_stream_cb), play); G_CALLBACK (end_of_stream_cb), play);
g_signal_connect (player_sig_adapt, "error", G_CALLBACK (error_cb), play); g_signal_connect (play->signal_adapter, "error", G_CALLBACK (error_cb), play);
g_signal_connect (player_sig_adapt, "media-info-updated", g_signal_connect (play->signal_adapter, "media-info-updated",
G_CALLBACK (media_info_cb), play); G_CALLBACK (media_info_cb), play);
play_set_relative_volume (play, initial_volume - 1.0); play_set_relative_volume (play, initial_volume - 1.0);
@ -385,10 +388,11 @@ play_new (gchar ** uris, gdouble initial_volume)
} }
static void static void
play_free (GstPlay * play) play_free (Player * play)
{ {
play_reset (play); play_reset (play);
g_clear_object (&play->signal_adapter);
gst_object_unref (play->player); gst_object_unref (play->player);
g_main_loop_unref (play->loop); g_main_loop_unref (play->loop);
@ -399,12 +403,12 @@ play_free (GstPlay * play)
/* reset for new file/stream */ /* reset for new file/stream */
static void static void
play_reset (GstPlay * play) play_reset (Player * play)
{ {
} }
static void static void
play_set_relative_volume (GstPlay * play, gdouble volume_step) play_set_relative_volume (Player * play, gdouble volume_step)
{ {
gdouble volume; gdouble volume;
@ -418,7 +422,7 @@ play_set_relative_volume (GstPlay * play, gdouble volume_step)
} }
static gchar * static gchar *
play_uri_get_display_name (GstPlay * play, const gchar * uri) play_uri_get_display_name (Player * play, const gchar * uri)
{ {
gchar *loc; gchar *loc;
@ -435,7 +439,7 @@ play_uri_get_display_name (GstPlay * play, const gchar * uri)
} }
static void static void
play_uri (GstPlay * play, const gchar * next_uri) play_uri (Player * play, const gchar * next_uri)
{ {
gchar *loc; gchar *loc;
@ -446,12 +450,12 @@ play_uri (GstPlay * play, const gchar * next_uri)
g_free (loc); g_free (loc);
g_object_set (play->player, "uri", next_uri, NULL); g_object_set (play->player, "uri", next_uri, NULL);
gst_player_play (play->player); gst_play_play (play->player);
} }
/* returns FALSE if we have reached the end of the playlist */ /* returns FALSE if we have reached the end of the playlist */
static gboolean static gboolean
play_next (GstPlay * play) play_next (Player * play)
{ {
if ((play->cur_idx + 1) >= play->num_uris) { if ((play->cur_idx + 1) >= play->num_uris) {
if (play->repeat) { if (play->repeat) {
@ -467,7 +471,7 @@ play_next (GstPlay * play)
/* returns FALSE if we have reached the beginning of the playlist */ /* returns FALSE if we have reached the beginning of the playlist */
static gboolean static gboolean
play_prev (GstPlay * play) play_prev (Player * play)
{ {
if (play->cur_idx == 0 || play->num_uris <= 1) if (play->cur_idx == 0 || play->num_uris <= 1)
return FALSE; return FALSE;
@ -477,7 +481,7 @@ play_prev (GstPlay * play)
} }
static void static void
do_play (GstPlay * play) do_play (Player * play)
{ {
gint i; gint i;
@ -550,19 +554,19 @@ restore_terminal (void)
} }
static void static void
toggle_paused (GstPlay * play) toggle_paused (Player * play)
{ {
if (play->desired_state == GST_STATE_PLAYING) { if (play->desired_state == GST_STATE_PLAYING) {
play->desired_state = GST_STATE_PAUSED; play->desired_state = GST_STATE_PAUSED;
gst_player_pause (play->player); gst_play_pause (play->player);
} else { } else {
play->desired_state = GST_STATE_PLAYING; play->desired_state = GST_STATE_PLAYING;
gst_player_play (play->player); gst_play_play (play->player);
} }
} }
static void static void
relative_seek (GstPlay * play, gdouble percent) relative_seek (Player * play, gdouble percent)
{ {
gint64 dur = -1, pos = -1; gint64 dur = -1, pos = -1;
@ -578,18 +582,18 @@ relative_seek (GstPlay * play, gdouble percent)
pos = pos + dur * percent; pos = pos + dur * percent;
if (pos < 0) if (pos < 0)
pos = 0; pos = 0;
gst_player_seek (play->player, pos); gst_play_seek (play->player, pos);
} }
static void static void
keyboard_cb (const gchar * key_input, gpointer user_data) keyboard_cb (const gchar * key_input, gpointer user_data)
{ {
GstPlay *play = (GstPlay *) user_data; Player *play = (Player *) user_data;
switch (g_ascii_tolower (key_input[0])) { switch (g_ascii_tolower (key_input[0])) {
case 'i': case 'i':
{ {
GstPlayerMediaInfo *media_info = gst_player_get_media_info (play->player); GstPlayMediaInfo *media_info = gst_play_get_media_info (play->player);
if (media_info) { if (media_info) {
print_media_info (media_info); print_media_info (media_info);
g_object_unref (media_info); g_object_unref (media_info);
@ -640,7 +644,7 @@ keyboard_cb (const gchar * key_input, gpointer user_data)
int int
main (int argc, char **argv) main (int argc, char **argv)
{ {
GstPlay *play; Player *play;
GPtrArray *playlist; GPtrArray *playlist;
gboolean print_version = FALSE; gboolean print_version = FALSE;
gboolean interactive = FALSE; /* FIXME: maybe enable by default? */ gboolean interactive = FALSE; /* FIXME: maybe enable by default? */

2
playback/player/gst-play/meson.build
View file

@ -2,5 +2,5 @@ executable('gst-play',
['gst-play.c', ['gst-play.c',
'gst-play-kb.c', 'gst-play-kb.c',
'gst-play-kb.h'], 'gst-play-kb.h'],
dependencies : [gst_dep, gstplayer_dep, m_dep]) dependencies : [gst_dep, dependency('gstreamer-play-1.0'), m_dep])