-#include <gst/gst.h>\r
- \r
-/* Structure to contain all our information, so we can pass it around */\r
-typedef struct _CustomData {\r
- GstElement *playbin; /* Our one and only element */\r
- gboolean playing; /* Are we in the PLAYING state? */\r
- gboolean terminate; /* Should we terminate execution? */\r
- gboolean seek_enabled; /* Is seeking enabled for this media? */\r
- gboolean seek_done; /* Have we performed the seek already? */\r
- gint64 duration; /* How long does this media last, in nanoseconds */\r
-} CustomData;\r
- \r
-/* Forward definition of the message processing function */\r
-static void handle_message (CustomData *data, GstMessage *msg);\r
- \r
-int main(int argc, char *argv[]) {\r
- CustomData data;\r
- GstBus *bus;\r
- GstMessage *msg;\r
- GstStateChangeReturn ret;\r
-\r
- data.playing = FALSE;\r
- data.terminate = FALSE;\r
- data.seek_enabled = FALSE;\r
- data.seek_done = FALSE;\r
- data.duration = GST_CLOCK_TIME_NONE;\r
- \r
- /* Initialize GStreamer */\r
- gst_init (&argc, &argv);\r
- \r
- /* Create the elements */\r
- data.playbin = gst_element_factory_make ("playbin", "playbin");\r
- \r
- if (!data.playbin) {\r
- g_printerr ("Not all elements could be created.\n");\r
- return -1;\r
- }\r
- \r
- /* Set the URI to play */\r
- g_object_set (data.playbin, "uri", "https://www.freedesktop.org/software/gstreamer-sdk/data/media/sintel_trailer-480p.webm", NULL);\r
- \r
- /* Start playing */\r
- ret = gst_element_set_state (data.playbin, GST_STATE_PLAYING);\r
- if (ret == GST_STATE_CHANGE_FAILURE) {\r
- g_printerr ("Unable to set the pipeline to the playing state.\n");\r
- gst_object_unref (data.playbin);\r
- return -1;\r
- }\r
- \r
- /* Listen to the bus */\r
- bus = gst_element_get_bus (data.playbin);\r
- do {\r
- msg = gst_bus_timed_pop_filtered (bus, 100 * GST_MSECOND,\r
- GST_MESSAGE_STATE_CHANGED | GST_MESSAGE_ERROR | GST_MESSAGE_EOS | GST_MESSAGE_DURATION);\r
- \r
- /* Parse message */\r
- if (msg != NULL) {\r
- handle_message (&data, msg);\r
- } else {\r
- /* We got no message, this means the timeout expired */\r
- if (data.playing) {\r
- gint64 current = -1;\r
- \r
- /* Query the current position of the stream */\r
- if (!gst_element_query_position (data.playbin, GST_FORMAT_TIME, ¤t)) {\r
- g_printerr ("Could not query current position.\n");\r
- }\r
- \r
- /* If we didn't know it yet, query the stream duration */\r
- if (!GST_CLOCK_TIME_IS_VALID (data.duration)) {\r
- if (!gst_element_query_duration (data.playbin, GST_FORMAT_TIME, &data.duration)) {\r
- g_printerr ("Could not query current duration.\n");\r
- }\r
- }\r
- \r
- /* Print current position and total duration */\r
- g_print ("Position %" GST_TIME_FORMAT " / %" GST_TIME_FORMAT "\r",\r
- GST_TIME_ARGS (current), GST_TIME_ARGS (data.duration));\r
- \r
- /* If seeking is enabled, we have not done it yet, and the time is right, seek */\r
- if (data.seek_enabled && !data.seek_done && current > 10 * GST_SECOND) {\r
- g_print ("\nReached 10s, performing seek...\n");\r
- gst_element_seek_simple (data.playbin, GST_FORMAT_TIME,\r
- GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, 30 * GST_SECOND);\r
- data.seek_done = TRUE;\r
- }\r
- }\r
- }\r
- } while (!data.terminate);\r
- \r
- /* Free resources */\r
- gst_object_unref (bus);\r
- gst_element_set_state (data.playbin, GST_STATE_NULL);\r
- gst_object_unref (data.playbin);\r
- return 0;\r
-}\r
- \r
-static void handle_message (CustomData *data, GstMessage *msg) {\r
- GError *err;\r
- gchar *debug_info;\r
- \r
- switch (GST_MESSAGE_TYPE (msg)) {\r
- case GST_MESSAGE_ERROR:\r
- gst_message_parse_error (msg, &err, &debug_info);\r
- g_printerr ("Error received from element %s: %s\n", GST_OBJECT_NAME (msg->src), err->message);\r
- g_printerr ("Debugging information: %s\n", debug_info ? debug_info : "none");\r
- g_clear_error (&err);\r
- g_free (debug_info);\r
- data->terminate = TRUE;\r
- break;\r
- case GST_MESSAGE_EOS:\r
- g_print ("End-Of-Stream reached.\n");\r
- data->terminate = TRUE;\r
- break;\r
- case GST_MESSAGE_DURATION:\r
- /* The duration has changed, mark the current one as invalid */\r
- data->duration = GST_CLOCK_TIME_NONE;\r
- break;\r
- case GST_MESSAGE_STATE_CHANGED: {\r
- GstState old_state, new_state, pending_state;\r
- gst_message_parse_state_changed (msg, &old_state, &new_state, &pending_state);\r
- if (GST_MESSAGE_SRC (msg) == GST_OBJECT (data->playbin)) {\r
- g_print ("Pipeline state changed from %s to %s:\n",\r
- gst_element_state_get_name (old_state), gst_element_state_get_name (new_state));\r
- \r
- /* Remember whether we are in the PLAYING state or not */\r
- data->playing = (new_state == GST_STATE_PLAYING);\r
- \r
- if (data->playing) {\r
- /* We just moved to PLAYING. Check if seeking is possible */\r
- GstQuery *query;\r
- gint64 start, end;\r
- query = gst_query_new_seeking (GST_FORMAT_TIME);\r
- if (gst_element_query (data->playbin, query)) {\r
- gst_query_parse_seeking (query, NULL, &data->seek_enabled, &start, &end);\r
- if (data->seek_enabled) {\r
- g_print ("Seeking is ENABLED from %" GST_TIME_FORMAT " to %" GST_TIME_FORMAT "\n",\r
- GST_TIME_ARGS (start), GST_TIME_ARGS (end));\r
- } else {\r
- g_print ("Seeking is DISABLED for this stream.\n");\r
- }\r
- }\r
- else {\r
- g_printerr ("Seeking query failed.");\r
- }\r
- gst_query_unref (query);\r
- }\r
- }\r
- } break;\r
- default:\r
- /* We should not reach here */\r
- g_printerr ("Unexpected message received.\n");\r
- break;\r
- }\r
- gst_message_unref (msg);\r
-}\r
+#include <gst/gst.h>
+
+/* Structure to contain all our information, so we can pass it around */
+typedef struct _CustomData {
+ GstElement *playbin; /* Our one and only element */
+ gboolean playing; /* Are we in the PLAYING state? */
+ gboolean terminate; /* Should we terminate execution? */
+ gboolean seek_enabled; /* Is seeking enabled for this media? */
+ gboolean seek_done; /* Have we performed the seek already? */
+ gint64 duration; /* How long does this media last, in nanoseconds */
+} CustomData;
+
+/* Forward definition of the message processing function */
+static void handle_message (CustomData *data, GstMessage *msg);
+
+int main(int argc, char *argv[]) {
+ CustomData data;
+ GstBus *bus;
+ GstMessage *msg;
+ GstStateChangeReturn ret;
+
+ data.playing = FALSE;
+ data.terminate = FALSE;
+ data.seek_enabled = FALSE;
+ data.seek_done = FALSE;
+ data.duration = GST_CLOCK_TIME_NONE;
+
+ /* Initialize GStreamer */
+ gst_init (&argc, &argv);
+
+ /* Create the elements */
+ data.playbin = gst_element_factory_make ("playbin", "playbin");
+
+ if (!data.playbin) {
+ g_printerr ("Not all elements could be created.\n");
+ return -1;
+ }
+
+ /* Set the URI to play */
+ g_object_set (data.playbin, "uri", "https://www.freedesktop.org/software/gstreamer-sdk/data/media/sintel_trailer-480p.webm", NULL);
+
+ /* Start playing */
+ ret = gst_element_set_state (data.playbin, GST_STATE_PLAYING);
+ if (ret == GST_STATE_CHANGE_FAILURE) {
+ g_printerr ("Unable to set the pipeline to the playing state.\n");
+ gst_object_unref (data.playbin);
+ return -1;
+ }
+
+ /* Listen to the bus */
+ bus = gst_element_get_bus (data.playbin);
+ do {
+ msg = gst_bus_timed_pop_filtered (bus, 100 * GST_MSECOND,
+ GST_MESSAGE_STATE_CHANGED | GST_MESSAGE_ERROR | GST_MESSAGE_EOS | GST_MESSAGE_DURATION);
+
+ /* Parse message */
+ if (msg != NULL) {
+ handle_message (&data, msg);
+ } else {
+ /* We got no message, this means the timeout expired */
+ if (data.playing) {
+ gint64 current = -1;
+
+ /* Query the current position of the stream */
+ if (!gst_element_query_position (data.playbin, GST_FORMAT_TIME, ¤t)) {
+ g_printerr ("Could not query current position.\n");
+ }
+
+ /* If we didn't know it yet, query the stream duration */
+ if (!GST_CLOCK_TIME_IS_VALID (data.duration)) {
+ if (!gst_element_query_duration (data.playbin, GST_FORMAT_TIME, &data.duration)) {
+ g_printerr ("Could not query current duration.\n");
+ }
+ }
+
+ /* Print current position and total duration */
+ g_print ("Position %" GST_TIME_FORMAT " / %" GST_TIME_FORMAT "\r",
+ GST_TIME_ARGS (current), GST_TIME_ARGS (data.duration));
+
+ /* If seeking is enabled, we have not done it yet, and the time is right, seek */
+ if (data.seek_enabled && !data.seek_done && current > 10 * GST_SECOND) {
+ g_print ("\nReached 10s, performing seek...\n");
+ gst_element_seek_simple (data.playbin, GST_FORMAT_TIME,
+ GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, 30 * GST_SECOND);
+ data.seek_done = TRUE;
+ }
+ }
+ }
+ } while (!data.terminate);
+
+ /* Free resources */
+ gst_object_unref (bus);
+ gst_element_set_state (data.playbin, GST_STATE_NULL);
+ gst_object_unref (data.playbin);
+ return 0;
+}
+
+static void handle_message (CustomData *data, GstMessage *msg) {
+ GError *err;
+ gchar *debug_info;
+
+ switch (GST_MESSAGE_TYPE (msg)) {
+ case GST_MESSAGE_ERROR:
+ gst_message_parse_error (msg, &err, &debug_info);
+ g_printerr ("Error received from element %s: %s\n", GST_OBJECT_NAME (msg->src), err->message);
+ g_printerr ("Debugging information: %s\n", debug_info ? debug_info : "none");
+ g_clear_error (&err);
+ g_free (debug_info);
+ data->terminate = TRUE;
+ break;
+ case GST_MESSAGE_EOS:
+ g_print ("End-Of-Stream reached.\n");
+ data->terminate = TRUE;
+ break;
+ case GST_MESSAGE_DURATION:
+ /* The duration has changed, mark the current one as invalid */
+ data->duration = GST_CLOCK_TIME_NONE;
+ break;
+ case GST_MESSAGE_STATE_CHANGED: {
+ GstState old_state, new_state, pending_state;
+ gst_message_parse_state_changed (msg, &old_state, &new_state, &pending_state);
+ if (GST_MESSAGE_SRC (msg) == GST_OBJECT (data->playbin)) {
+ g_print ("Pipeline state changed from %s to %s:\n",
+ gst_element_state_get_name (old_state), gst_element_state_get_name (new_state));
+
+ /* Remember whether we are in the PLAYING state or not */
+ data->playing = (new_state == GST_STATE_PLAYING);
+
+ if (data->playing) {
+ /* We just moved to PLAYING. Check if seeking is possible */
+ GstQuery *query;
+ gint64 start, end;
+ query = gst_query_new_seeking (GST_FORMAT_TIME);
+ if (gst_element_query (data->playbin, query)) {
+ gst_query_parse_seeking (query, NULL, &data->seek_enabled, &start, &end);
+ if (data->seek_enabled) {
+ g_print ("Seeking is ENABLED from %" GST_TIME_FORMAT " to %" GST_TIME_FORMAT "\n",
+ GST_TIME_ARGS (start), GST_TIME_ARGS (end));
+ } else {
+ g_print ("Seeking is DISABLED for this stream.\n");
+ }
+ }
+ else {
+ g_printerr ("Seeking query failed.");
+ }
+ gst_query_unref (query);
+ }
+ }
+ } break;
+ default:
+ /* We should not reach here */
+ g_printerr ("Unexpected message received.\n");
+ break;
+ }
+ gst_message_unref (msg);
+}
projects / platform / upstream / gstreamer.git / blobdiff