summaryrefslogtreecommitdiffstats
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rw-r--r--examples/seeking/Makefile.am4
-rw-r--r--examples/seeking/vorbisfile.c312
2 files changed, 314 insertions, 2 deletions
diff --git a/examples/seeking/Makefile.am b/examples/seeking/Makefile.am
index 3dd4f202..696b3159 100644
--- a/examples/seeking/Makefile.am
+++ b/examples/seeking/Makefile.am
@@ -1,7 +1,7 @@
-examples = seek spider_seek cdplayer cdparanoia
+examples = seek spider_seek cdplayer cdparanoia vorbisfile
noinst_PROGRAMS = $(examples)
# we have nothing but apps here, we can do this safely
LIBS = $(GST_LIBS) $(GTK_LIBS) $(FT2_LIBS)
-AM_CFLAGS = $(GST_CFLAGS) $(GTK_CFLAGS) $(FT2_CFLAGS)
+AM_CFLAGS = $(GST_CFLAGS) $(GTK_CFLAGS)
diff --git a/examples/seeking/vorbisfile.c b/examples/seeking/vorbisfile.c
new file mode 100644
index 00000000..c94199fe
--- /dev/null
+++ b/examples/seeking/vorbisfile.c
@@ -0,0 +1,312 @@
+#include <stdlib.h>
+#include <gst/gst.h>
+#include <string.h>
+
+static gboolean ready = FALSE;
+
+struct probe_context {
+ GstElement *pipeline;
+ GstElement *element;
+ GstPad *pad;
+ GstFormat ls_format;
+
+ gint total_ls;
+
+ GstCaps *metadata;
+ GstCaps *caps;
+};
+
+static void
+print_metadata (GstCaps *caps)
+{
+ g_print (" metadata:\n");
+ if (!caps || caps->properties == NULL) {
+ g_print (" none\n");
+ return;
+ }
+
+ if (!strcmp (gst_caps_get_mime (caps), "application/x-gst-metadata")) {
+ GstProps *props = caps->properties;
+ GList *walk = props->properties;
+
+ while (walk) {
+ GstPropsEntry *entry = (GstPropsEntry *) walk->data;
+ const gchar *name;
+ const gchar *str_val;
+ gint int_val;
+ GstPropsType type;
+
+ name = gst_props_entry_get_name (entry);
+ type = gst_props_entry_get_type (entry);
+ switch (type) {
+ case GST_PROPS_STRING_TYPE:
+ gst_props_entry_get_string (entry, &str_val);
+ g_print (" %s='%s'\n", name, str_val);
+ break;
+ case GST_PROPS_INT_TYPE:
+ gst_props_entry_get_int (entry, &int_val);
+ g_print (" %s=%d\n", name, int_val);
+ break;
+ default:
+ break;
+ }
+
+ walk = g_list_next (walk);
+ }
+ }
+ else {
+ g_print (" unkown metadata type\n");
+ }
+
+}
+
+static void
+print_format (GstCaps *caps)
+{
+ g_print (" format:\n");
+ if (!caps || caps->properties == NULL) {
+ g_print (" unkown\n");
+ return;
+ }
+ if (!strcmp (gst_caps_get_mime (caps), "audio/raw")) {
+ gint channels;
+ gint rate;
+
+ gst_caps_get_int (caps, "channels", &channels);
+ gst_caps_get_int (caps, "rate", &rate);
+
+ g_print (" channels: %d\n", channels);
+ g_print (" rate: %d\n", rate);
+ }
+ else {
+ g_print (" unkown format\n");
+ }
+}
+
+static void
+print_lbs_info (struct probe_context *context, gint stream)
+{
+ const GstFormat *formats;
+
+ g_print (" stream info:\n");
+
+ /* report info in all supported formats */
+ formats = gst_pad_get_formats (context->pad);
+ while (*formats) {
+ const GstFormatDefinition *definition;
+ gint64 value_start, value_end;
+ gboolean res;
+ GstFormat format;
+
+ if (*formats == context->ls_format) {
+ formats++;
+ continue;
+ }
+
+ definition = gst_format_get_details (*formats);
+
+ /* get start and end position of this stream */
+ format = *formats;
+ res = gst_pad_convert (context->pad,
+ context->ls_format, stream,
+ &format, &value_start);
+ res &= gst_pad_convert (context->pad,
+ context->ls_format, stream + 1,
+ &format, &value_end);
+
+ if (res) {
+ /* substract to get the length */
+ value_end -= value_start;
+
+ if (*formats == GST_FORMAT_TIME) {
+ value_end /= (GST_SECOND/100);
+ g_print (" %s: %lld:%02lld.%02lld\n", definition->nick,
+ value_end/6000, (value_end/100)%60, (value_end%100));
+ }
+ else {
+ g_print (" %s: %lld\n", definition->nick, value_end);
+ }
+ }
+ else
+ g_print (" could not get logical stream %s\n", definition->nick);
+
+ formats++;
+ }
+}
+
+static void
+deep_notify (GObject *object, GstObject *origin,
+ GParamSpec *pspec, gpointer data)
+{
+ struct probe_context *context = (struct probe_context *) data;
+ GValue value = { 0, };
+
+ if (!strcmp (pspec->name, "metadata")) {
+
+ g_value_init (&value, pspec->value_type);
+ g_object_get_property (G_OBJECT (origin), pspec->name, &value);
+ context->metadata = g_value_peek_pointer (&value);
+ }
+ else if (!strcmp (pspec->name, "caps")) {
+ if (GST_IS_PAD (origin) && GST_PAD (origin) == context->pad) {
+ g_value_init (&value, pspec->value_type);
+ g_object_get_property (G_OBJECT (origin), pspec->name, &value);
+ context->caps = g_value_peek_pointer (&value);
+
+ ready = TRUE;
+ }
+ }
+}
+
+static gboolean
+collect_logical_stream_properties (struct probe_context *context, gint stream)
+{
+ GstEvent *event;
+ gboolean res;
+ gint count;
+
+ g_print ("info for logical stream %d:\n", stream);
+
+ /* seek to stream */
+ event = gst_event_new_seek (context->ls_format |
+ GST_SEEK_METHOD_SET |
+ GST_SEEK_FLAG_FLUSH,
+ stream);
+ res = gst_pad_send_event (context->pad, event);
+ if (!res) {
+ g_warning ("seek to logical track failed");
+ return FALSE;
+ }
+
+ /* run the pipeline to get the info */
+ count = 0;
+ ready = FALSE;
+ while (gst_bin_iterate (GST_BIN (context->pipeline)) && !ready) {
+ count++;
+ if (count > 10) break;
+ }
+
+ print_metadata (context->metadata);
+ print_format (context->caps);
+ print_lbs_info (context, stream);
+
+ g_print ("\n");
+
+ return TRUE;
+}
+
+static void
+collect_stream_properties (struct probe_context *context)
+{
+ const GstFormat *formats;
+
+ ready = FALSE;
+ while (gst_bin_iterate (GST_BIN (context->pipeline)) && !ready);
+
+ g_print ("stream info:\n");
+
+ context->total_ls = -1;
+
+ /* report info in all supported formats */
+ formats = gst_pad_get_formats (context->pad);
+ while (*formats) {
+ const GstFormatDefinition *definition;
+ gint64 value;
+ gboolean res;
+ GstFormat format;
+
+ format = *formats;
+
+ res = gst_pad_query (context->pad, GST_PAD_QUERY_TOTAL,
+ &format, &value);
+
+ definition = gst_format_get_details (*formats);
+
+ if (res) {
+ if (format == GST_FORMAT_TIME) {
+ value /= (GST_SECOND/100);
+ g_print (" total %s: %lld:%02lld.%02lld\n", definition->nick,
+ value/6000, (value/100)%60, (value%100));
+ }
+ else {
+ if (format == context->ls_format)
+ context->total_ls = value;
+ g_print (" total %s: %lld\n", definition->nick, value);
+ }
+ }
+ formats++;
+ }
+
+ if (context->total_ls == -1) {
+ g_warning (" could not get number of logical streams");
+ }
+ g_print ("\n");
+}
+
+int
+main (int argc, char **argv)
+{
+ GstElement *pipeline;
+ GstElement *filesrc;
+ GstElement *vorbisfile;
+ GstPad *pad;
+ GstFormat logical_stream_format;
+ struct probe_context *context;
+ gint stream;
+
+ gst_init (&argc, &argv);
+
+ if (argc < 2) {
+ g_print ("usage: %s <oggfile>\n", argv[0]);
+ return (-1);
+ }
+
+ pipeline = gst_pipeline_new ("pipeline");
+
+ filesrc = gst_element_factory_make ("filesrc", "filesrc");
+ g_assert (filesrc);
+ g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
+
+ vorbisfile = gst_element_factory_make ("vorbisfile", "vorbisfile");
+ g_assert (vorbisfile);
+
+ gst_bin_add (GST_BIN (pipeline), filesrc);
+ gst_bin_add (GST_BIN (pipeline), vorbisfile);
+
+ gst_element_connect_pads (filesrc, "src", vorbisfile, "sink");
+
+ pad = gst_element_get_pad (vorbisfile, "src");
+ g_assert (pad);
+
+ logical_stream_format = gst_format_get_by_nick ("logical_stream");
+ g_assert (logical_stream_format != 0);
+
+ context = g_new0 (struct probe_context, 1);
+ context->pipeline = pipeline;
+ context->element = vorbisfile;
+ context->pad = pad;
+ context->ls_format = logical_stream_format;
+
+ g_signal_connect (G_OBJECT (pipeline), "deep_notify",
+ G_CALLBACK (deep_notify), context);
+
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+
+ /* at this point we can inspect the stream */
+ collect_stream_properties (context);
+
+ /* loop over all logical streams to get info */
+ stream = 0;
+ while (stream < context->total_ls) {
+ collect_logical_stream_properties (context, stream);
+ stream++;
+ }
+
+ /* stop probe */
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+
+ gst_buffer_print_stats();
+ gst_event_print_stats();
+
+ return 0;
+}
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-20 11:20:58 +0000