mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-24 10:41:04 +00:00
Sync'ed files up to nautilus-media/media-info versions, and fixed them for errors and deprecated functions
Original commit message from CVS: Sync'ed files up to nautilus-media/media-info versions, and fixed them for errors and deprecated functions
This commit is contained in:
Iain Holmes
parent
f66c702c65
commit
f600f3e4e8
6 changed files with 1049 additions and 592 deletions
|
|
@ -2,7 +2,7 @@ librarydir = $(libdir)
|
||||||
|
|
||||||
library_LTLIBRARIES = libgstmedia-info-@GST_MAJORMINOR@.la
|
library_LTLIBRARIES = libgstmedia-info-@GST_MAJORMINOR@.la
|
||||||
|
|
||||||
libgstmedia_info_@GST_MAJORMINOR@_la_SOURCES = media-info.c
|
libgstmedia_info_@GST_MAJORMINOR@_la_SOURCES = media-info.c media-info-priv.c
|
||||||
|
|
||||||
libincludedir = $(includedir)/gstreamer-@GST_MAJORMINOR@/gst/media-info
|
libincludedir = $(includedir)/gstreamer-@GST_MAJORMINOR@/gst/media-info
|
||||||
libinclude_HEADERS = media-info.h
|
libinclude_HEADERS = media-info.h
|
||||||
|
|
@ -11,6 +11,7 @@ libgstmedia_info_@GST_MAJORMINOR@_la_CFLAGS = $(GST_CFLAGS) $(GST_PLUGIN_CFLAGS)
|
||||||
libgstmedia_info_@GST_MAJORMINOR@_la_LIBADD = $(GST_LIBS) $(GST_PLUGIN_LIBS)
|
libgstmedia_info_@GST_MAJORMINOR@_la_LIBADD = $(GST_LIBS) $(GST_PLUGIN_LIBS)
|
||||||
|
|
||||||
noinst_PROGRAMS = media-info-test
|
noinst_PROGRAMS = media-info-test
|
||||||
|
noinst_HEADERS = media-info-priv.h
|
||||||
|
|
||||||
media_info_test_SOURCES = media-info-test.c
|
media_info_test_SOURCES = media-info-test.c
|
||||||
media_info_test_CFLAGS = $(GST_CFLAGS)
|
media_info_test_CFLAGS = $(GST_CFLAGS)
|
||||||
|
|
|
||||||
641
gst-libs/gst/media-info/media-info-priv.c
Normal file
641
gst-libs/gst/media-info/media-info-priv.c
Normal file
|
|
@ -0,0 +1,641 @@
|
||||||
|
/* GStreamer
|
||||||
|
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
|
||||||
|
*
|
||||||
|
* 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., 59 Temple Place - Suite 330,
|
||||||
|
* Boston, MA 02111-1307, USA.
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* media-info-priv.c - handling of internal stuff */
|
||||||
|
|
||||||
|
#include <gst/gst.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include "media-info.h"
|
||||||
|
#include "media-info-priv.h"
|
||||||
|
|
||||||
|
|
||||||
|
/* helper structs bits */
|
||||||
|
GstMediaInfoStream *
|
||||||
|
gmi_stream_new (void)
|
||||||
|
{
|
||||||
|
GstMediaInfoStream *stream;
|
||||||
|
|
||||||
|
stream = (GstMediaInfoStream *) g_malloc (sizeof (GstMediaInfoStream));
|
||||||
|
|
||||||
|
stream->length_tracks = 0;
|
||||||
|
stream->length_time = 0;
|
||||||
|
stream->bitrate = 0;
|
||||||
|
stream->seekable = FALSE;
|
||||||
|
stream->path = NULL;
|
||||||
|
stream->mime = NULL;
|
||||||
|
stream->tracks = NULL;
|
||||||
|
|
||||||
|
return stream;
|
||||||
|
}
|
||||||
|
|
||||||
|
void
|
||||||
|
gmi_stream_free (GstMediaInfoStream *stream)
|
||||||
|
{
|
||||||
|
if (stream->mime) g_free (stream->mime);
|
||||||
|
/* FIXME: free tracks */
|
||||||
|
g_free (stream);
|
||||||
|
}
|
||||||
|
|
||||||
|
GstMediaInfoTrack *
|
||||||
|
gmi_track_new (void)
|
||||||
|
{
|
||||||
|
GstMediaInfoTrack *track;
|
||||||
|
|
||||||
|
track = g_malloc (sizeof (GstMediaInfoTrack));
|
||||||
|
|
||||||
|
track->metadata = NULL;
|
||||||
|
track->streaminfo = NULL;
|
||||||
|
track->format = NULL;
|
||||||
|
track->length_time = 0;
|
||||||
|
track->con_streams = NULL;
|
||||||
|
|
||||||
|
return track;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* private functions
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* callbacks */
|
||||||
|
static void
|
||||||
|
have_type_callback (GstElement *typefind, GstCaps *type, GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
priv->type = type;
|
||||||
|
}
|
||||||
|
|
||||||
|
void
|
||||||
|
deep_notify_callback (GObject *object, GstObject *origin,
|
||||||
|
GParamSpec *pspec, GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
GValue value = { 0, };
|
||||||
|
|
||||||
|
if (strcmp (pspec->name, "metadata") == 0)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("DEBUG: deep_notify: have metadata !\n");
|
||||||
|
g_value_init (&value, pspec->value_type);
|
||||||
|
g_object_get_property (G_OBJECT (origin), pspec->name, &value);
|
||||||
|
priv->metadata = g_value_peek_pointer (&value);
|
||||||
|
}
|
||||||
|
else if (strcmp (pspec->name, "caps") == 0)
|
||||||
|
{
|
||||||
|
/* check if we're getting it from the source we want it from */
|
||||||
|
if (GST_IS_PAD (origin) && GST_PAD (origin) == priv->decoder_pad)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("DEBUG: deep_notify: have caps on decoder_pad !\n");
|
||||||
|
g_value_init (&value, pspec->value_type);
|
||||||
|
g_object_get_property (G_OBJECT (origin), pspec->name, &value);
|
||||||
|
priv->format = g_value_peek_pointer (&value);
|
||||||
|
}
|
||||||
|
else GMI_DEBUG("DEBUG: igoring caps on object %s:%s\n",
|
||||||
|
gst_object_get_name (gst_object_get_parent (origin)),
|
||||||
|
gst_object_get_name (origin));
|
||||||
|
}
|
||||||
|
else if (strcmp (pspec->name, "offset") == 0)
|
||||||
|
{
|
||||||
|
/* we REALLY ignore offsets, we hate them */
|
||||||
|
}
|
||||||
|
else if (strcmp (pspec->name, "streaminfo") == 0)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("DEBUG: deep_notify: have streaminfo !\n");
|
||||||
|
g_value_init (&value, pspec->value_type);
|
||||||
|
g_object_get_property (G_OBJECT (origin), pspec->name, &value);
|
||||||
|
priv->streaminfo = g_value_peek_pointer (&value);
|
||||||
|
}
|
||||||
|
else GMI_DEBUG("DEBUG: ignoring notify of %s\n", pspec->name);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* helpers */
|
||||||
|
|
||||||
|
/* reset info to a state where it can be used to query for media info
|
||||||
|
* clear caps, metadata, and so on */
|
||||||
|
void
|
||||||
|
gmi_reset (GstMediaInfo *info)
|
||||||
|
{
|
||||||
|
GstMediaInfoPriv *priv = info->priv;
|
||||||
|
/* clear out some stuff */
|
||||||
|
if (priv->format)
|
||||||
|
{
|
||||||
|
GMI_DEBUG ("unreffing priv->format, error before this ?\n");
|
||||||
|
gst_caps_unref (priv->format);
|
||||||
|
priv->format = NULL;
|
||||||
|
}
|
||||||
|
if (priv->metadata)
|
||||||
|
{
|
||||||
|
GMI_DEBUG ("unreffing priv->metadata, error before this ?\n");
|
||||||
|
gst_caps_unref (priv->metadata);
|
||||||
|
priv->metadata = NULL;
|
||||||
|
}
|
||||||
|
if (priv->stream)
|
||||||
|
{
|
||||||
|
GMI_DEBUG ("freeing priv->stream, error before this ?\n");
|
||||||
|
g_free (priv->stream);
|
||||||
|
priv->stream = NULL;
|
||||||
|
}
|
||||||
|
if (priv->location)
|
||||||
|
{
|
||||||
|
GMI_DEBUG ("freeing priv->location, error before this ?\n");
|
||||||
|
g_free (priv->location);
|
||||||
|
priv->location = NULL;
|
||||||
|
}
|
||||||
|
priv->flags = 0;
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_NULL;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* seek to a track and reset metadata and streaminfo structs */
|
||||||
|
gboolean
|
||||||
|
gmi_seek_to_track (GstMediaInfo *info, long track)
|
||||||
|
{
|
||||||
|
GstEvent *event;
|
||||||
|
GstFormat track_format = 0;
|
||||||
|
GstMediaInfoPriv *priv = info->priv;
|
||||||
|
gboolean res;
|
||||||
|
|
||||||
|
/* FIXME: consider more nicks as "track" */
|
||||||
|
track_format = gst_format_get_by_nick ("logical_stream");
|
||||||
|
if (track_format == 0) return FALSE;
|
||||||
|
GMI_DEBUG("Track format: %d\n", track_format);
|
||||||
|
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
g_warning ("Couldn't set to play");
|
||||||
|
g_assert (GST_IS_PAD (info->priv->decoder_pad));
|
||||||
|
event = gst_event_new_seek (track_format |
|
||||||
|
GST_SEEK_METHOD_SET |
|
||||||
|
GST_SEEK_FLAG_FLUSH,
|
||||||
|
track);
|
||||||
|
res = gst_pad_send_event (info->priv->decoder_pad, event);
|
||||||
|
if (!res)
|
||||||
|
{
|
||||||
|
g_warning ("seek to logical track on pad %s:%s failed of element %s",
|
||||||
|
GST_DEBUG_PAD_NAME(info->priv->decoder_pad),
|
||||||
|
gst_element_get_factory((gst_pad_get_parent(info->priv->decoder_pad)))->details->longname);
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
/* clear structs because of the seek */
|
||||||
|
if (priv->metadata)
|
||||||
|
{
|
||||||
|
gst_caps_unref (priv->metadata);
|
||||||
|
priv->metadata = NULL;
|
||||||
|
}
|
||||||
|
if (priv->streaminfo)
|
||||||
|
{
|
||||||
|
gst_caps_unref (priv->streaminfo);
|
||||||
|
priv->streaminfo = NULL;
|
||||||
|
}
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* create a good decoder for this mime type */
|
||||||
|
/* FIXME: maybe make this more generic with a type, so it can be used
|
||||||
|
* for taggers and other things as well */
|
||||||
|
GstElement *
|
||||||
|
gmi_get_decoder (GstMediaInfo *info, const char *mime)
|
||||||
|
{
|
||||||
|
GstElement *decoder;
|
||||||
|
gchar *factory = NULL;
|
||||||
|
|
||||||
|
/* check if we have an active codec element in the hash table for this */
|
||||||
|
decoder = g_hash_table_lookup (info->priv->decoders, mime);
|
||||||
|
if (decoder == NULL)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("DEBUG: no decoder in table, inserting one\n");
|
||||||
|
/* FIXME: please figure out proper mp3 mimetypes */
|
||||||
|
if ((strcmp (mime, "application/x-ogg") == 0) ||
|
||||||
|
(strcmp (mime, "application/ogg") == 0))
|
||||||
|
factory = g_strdup ("vorbisfile");
|
||||||
|
else if ((strcmp (mime, "audio/mpeg") == 0) ||
|
||||||
|
(strcmp (mime, "audio/x-mp3") == 0) ||
|
||||||
|
(strcmp (mime, "audio/mp3") == 0))
|
||||||
|
factory = g_strdup ("mad");
|
||||||
|
else if (strcmp (mime, "application/x-flac") == 0)
|
||||||
|
factory = g_strdup ("flacdec");
|
||||||
|
else if (strcmp (mime, "audio/x-wav") == 0)
|
||||||
|
factory = g_strdup ("wavparse");
|
||||||
|
else if (strcmp (mime, "audio/x-mod") == 0 ||
|
||||||
|
strcmp (mime, "audio/x-s3m") == 0 ||
|
||||||
|
strcmp (mime, "audio/x-xm") == 0 ||
|
||||||
|
strcmp (mime, "audio/x-it") == 0)
|
||||||
|
factory = g_strdup ("modplug");
|
||||||
|
|
||||||
|
if (factory == NULL)
|
||||||
|
return NULL;
|
||||||
|
|
||||||
|
GMI_DEBUG("DEBUG: using factory %s\n", factory);
|
||||||
|
decoder = gst_element_factory_make (factory, "decoder");
|
||||||
|
g_free (factory);
|
||||||
|
|
||||||
|
if (decoder)
|
||||||
|
{
|
||||||
|
g_hash_table_insert (info->priv->decoders, g_strdup (mime), decoder);
|
||||||
|
/* ref it so we don't lose it when removing from bin */
|
||||||
|
g_object_ref (GST_OBJECT (decoder));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return decoder;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* set the decoder to be used for decoding
|
||||||
|
* install callback handlers
|
||||||
|
*/
|
||||||
|
void
|
||||||
|
gmi_set_decoder (GstMediaInfo *info, GstElement *decoder)
|
||||||
|
{
|
||||||
|
GstMediaInfoPriv *priv = info->priv;
|
||||||
|
|
||||||
|
/* set up pipeline and connect signal handlers */
|
||||||
|
priv->decoder = decoder;
|
||||||
|
gst_bin_add (GST_BIN (priv->pipeline), decoder);
|
||||||
|
if (!gst_element_link (priv->source, decoder))
|
||||||
|
g_warning ("Couldn't connect source and decoder\n");
|
||||||
|
/* FIXME: we should be connecting to ALL possible src pads */
|
||||||
|
if (!(priv->decoder_pad = gst_element_get_pad (decoder, "src")))
|
||||||
|
g_warning ("Couldn't get decoder pad\n");
|
||||||
|
if (!(priv->source_pad = gst_element_get_pad (priv->source, "src")))
|
||||||
|
g_warning ("Couldn't get source pad\n");
|
||||||
|
}
|
||||||
|
|
||||||
|
/* clear the decoder (if it was set)
|
||||||
|
*/
|
||||||
|
void
|
||||||
|
gmi_clear_decoder (GstMediaInfo *info)
|
||||||
|
{
|
||||||
|
if (info->priv->decoder)
|
||||||
|
{
|
||||||
|
/* clear up decoder */
|
||||||
|
/* FIXME: shouldn't need to set state here */
|
||||||
|
gst_element_set_state (info->priv->pipeline, GST_STATE_READY);
|
||||||
|
gst_element_unlink (info->priv->source, info->priv->decoder);
|
||||||
|
gst_bin_remove (GST_BIN (info->priv->pipeline), info->priv->decoder);
|
||||||
|
info->priv->decoder = NULL;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/****
|
||||||
|
* typefind functions
|
||||||
|
* find the type of a file and store it in the caps of the info
|
||||||
|
* FIXME: we might better return GstCaps instead of storing them
|
||||||
|
* internally */
|
||||||
|
|
||||||
|
/* prepare for typefind, move from NULL to TYPEFIND */
|
||||||
|
gboolean
|
||||||
|
gmip_find_type_pre (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
/* clear vars that need clearing */
|
||||||
|
if (priv->type)
|
||||||
|
{
|
||||||
|
/* we don't need to unref, this is done inside gsttypefind.c
|
||||||
|
gst_caps_unref (priv->type);
|
||||||
|
*/
|
||||||
|
priv->type = NULL;
|
||||||
|
}
|
||||||
|
|
||||||
|
GMI_DEBUG("DEBUG: gmip_find_type_pre: start\n");
|
||||||
|
/* find out type */
|
||||||
|
/* FIXME: we could move caps for typefind out of struct and
|
||||||
|
* just use it through this function only */
|
||||||
|
|
||||||
|
gst_bin_add (GST_BIN (priv->pipeline), priv->typefind);
|
||||||
|
g_object_set (G_OBJECT (priv->source), "location", priv->location, NULL);
|
||||||
|
if (!gst_element_link (priv->source, priv->typefind))
|
||||||
|
g_warning ("Couldn't connect source and typefind\n");
|
||||||
|
g_signal_connect (G_OBJECT (priv->typefind), "have-type",
|
||||||
|
G_CALLBACK (have_type_callback), priv);
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't set to play");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_TYPEFIND;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* finish off typefind */
|
||||||
|
gboolean
|
||||||
|
gmip_find_type_post (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
/*clear up typefind */
|
||||||
|
gst_element_set_state (priv->pipeline, GST_STATE_READY);
|
||||||
|
gst_element_unlink (priv->source, priv->typefind);
|
||||||
|
gst_bin_remove (GST_BIN (priv->pipeline), priv->typefind);
|
||||||
|
|
||||||
|
if (priv->type == NULL)
|
||||||
|
{
|
||||||
|
g_warning ("iteration ended, type not found !\n");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_STREAM;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* complete version */
|
||||||
|
gboolean
|
||||||
|
gmip_find_type (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
if (!gmip_find_type_pre (priv))
|
||||||
|
return FALSE;
|
||||||
|
GMI_DEBUG("DEBUG: gmip_find_type: iterating\n");
|
||||||
|
while ((priv->type == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
GMI_DEBUG("+");
|
||||||
|
GMI_DEBUG("\n");
|
||||||
|
return gmip_find_type_post (priv);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* FIXME: why not have these functions work on priv types ? */
|
||||||
|
gboolean
|
||||||
|
gmip_find_stream_pre (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't set to play");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_STREAM;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_stream_post (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
GstMediaInfoStream *stream = priv->stream;
|
||||||
|
const GstFormat *formats;
|
||||||
|
GstFormat track_format = 0;
|
||||||
|
GstFormat format;
|
||||||
|
gint64 value;
|
||||||
|
gboolean res;
|
||||||
|
glong bytes = 0;
|
||||||
|
|
||||||
|
|
||||||
|
GMI_DEBUG("gmip_find_stream_post: start\n");
|
||||||
|
/* find a format that matches the "track" concept */
|
||||||
|
/* FIXME: this is used in vorbis, but we might have to loop when
|
||||||
|
* more codecs have tracks */
|
||||||
|
track_format = gst_format_get_by_nick ("logical_stream");
|
||||||
|
|
||||||
|
/* get supported formats on decoder pad */
|
||||||
|
formats = gst_pad_get_formats (priv->decoder_pad);
|
||||||
|
while (*formats)
|
||||||
|
{
|
||||||
|
const GstFormatDefinition *definition;
|
||||||
|
|
||||||
|
format = *formats;
|
||||||
|
|
||||||
|
g_assert (GST_IS_PAD (priv->decoder_pad));
|
||||||
|
definition = gst_format_get_details (*formats);
|
||||||
|
GMI_DEBUG("trying to figure out length for format %s\n", definition->nick);
|
||||||
|
|
||||||
|
res = gst_pad_query (priv->decoder_pad, GST_QUERY_TOTAL,
|
||||||
|
&format, &value);
|
||||||
|
|
||||||
|
if (res)
|
||||||
|
{
|
||||||
|
switch (format)
|
||||||
|
{
|
||||||
|
case GST_FORMAT_TIME:
|
||||||
|
stream->length_time = value;
|
||||||
|
GMI_DEBUG(" total %s: %lld\n", definition->nick, value);
|
||||||
|
break;
|
||||||
|
case GST_FORMAT_DEFAULT:
|
||||||
|
case GST_FORMAT_BYTES:
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
/* separation is necessary because track_format doesn't resolve to
|
||||||
|
* int */
|
||||||
|
if (format == track_format)
|
||||||
|
{
|
||||||
|
stream->length_tracks = value;
|
||||||
|
GMI_DEBUG(" total %s: %lld\n", definition->nick, value);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
GMI_DEBUG("unhandled format %s\n", definition->nick);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
GMI_DEBUG("query didn't return result for %s\n", definition->nick);
|
||||||
|
|
||||||
|
formats++;
|
||||||
|
}
|
||||||
|
if (stream->length_tracks == 0) stream->length_tracks = 1;
|
||||||
|
/* now get number of bytes from the sink pad to get the bitrate */
|
||||||
|
format = GST_FORMAT_BYTES;
|
||||||
|
g_assert (GST_IS_PAD (priv->source_pad));
|
||||||
|
res = gst_pad_query (priv->source_pad, GST_QUERY_TOTAL,
|
||||||
|
&format, &value);
|
||||||
|
if (!res) g_warning ("Failed to query on sink pad !");
|
||||||
|
bytes = value;
|
||||||
|
GMI_DEBUG("bitrate calc: bytes gotten: %ld\n", bytes);
|
||||||
|
|
||||||
|
if (bytes)
|
||||||
|
{
|
||||||
|
double seconds = (double) stream->length_time / GST_SECOND;
|
||||||
|
double bits = bytes * 8;
|
||||||
|
stream->bitrate = (long) (bits / seconds);
|
||||||
|
}
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_METADATA; /* metadata of first track */
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* get properties of complete physical stream
|
||||||
|
* and return them in pre-alloced stream struct in priv->stream */
|
||||||
|
gboolean
|
||||||
|
gmip_find_stream (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("DEBUG:gmip_find_stream start\n");
|
||||||
|
|
||||||
|
gmip_find_stream_pre (priv);
|
||||||
|
/* iterate until caps are found */
|
||||||
|
/* FIXME: this should be done through the plugin sending some signal
|
||||||
|
* that it is ready for queries */
|
||||||
|
while (gst_bin_iterate (GST_BIN (priv->pipeline)) &&
|
||||||
|
priv->format == NULL)
|
||||||
|
;
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PAUSED)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
g_warning ("Couldn't set to paused");
|
||||||
|
|
||||||
|
if (priv->format == NULL)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("DEBUG: gmip_find_stream: couldn't get caps !");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
return gmip_find_stream_post (priv);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* find metadata encoded in media and store in priv->metadata */
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_metadata_pre (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
/* FIXME: this is a hack to set max allowed iterations for metadata
|
||||||
|
* querying - we should make gst smarter by itself instead */
|
||||||
|
priv->metadata_iters = 0;
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't set to play");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_metadata_post (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PAUSED)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
return FALSE;
|
||||||
|
priv->current_track->metadata = priv->metadata;
|
||||||
|
priv->metadata = NULL;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_metadata (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
gmip_find_track_metadata_pre (priv);
|
||||||
|
GMI_DEBUG("DEBUG: gmip_find_metadata: iterating\n");
|
||||||
|
while ((priv->metadata == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
GMI_DEBUG("+");
|
||||||
|
GMI_DEBUG("\n");
|
||||||
|
gmip_find_track_metadata_post (priv);
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* find streaminfo found by decoder and store in priv->streaminfo */
|
||||||
|
/* FIXME: this is an exact copy, so reuse this functioin instead */
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_streaminfo_pre (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't set to play");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_streaminfo_post (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
GstFormat format, track_format;
|
||||||
|
|
||||||
|
gst_element_set_state (priv->pipeline, GST_STATE_PAUSED);
|
||||||
|
|
||||||
|
/* now add total length to this, and maybe even bitrate ? FIXME */
|
||||||
|
track_format = gst_format_get_by_nick ("logical_stream");
|
||||||
|
if (track_format == 0)
|
||||||
|
{
|
||||||
|
g_print ("FIXME: implement getting length of whole track\n");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/* which one are we at ? */
|
||||||
|
long track_num;
|
||||||
|
gint64 value_start, value_end;
|
||||||
|
gboolean res;
|
||||||
|
|
||||||
|
res = gst_pad_query (priv->decoder_pad, GST_QUERY_POSITION,
|
||||||
|
&track_format, &value_start);
|
||||||
|
if (res)
|
||||||
|
{
|
||||||
|
format = GST_FORMAT_TIME;
|
||||||
|
track_num = value_start;
|
||||||
|
GMI_DEBUG("DEBUG: we are currently at %ld\n", track_num);
|
||||||
|
res = gst_pad_convert (priv->decoder_pad,
|
||||||
|
track_format, track_num,
|
||||||
|
&format, &value_start);
|
||||||
|
res &= gst_pad_convert (priv->decoder_pad,
|
||||||
|
track_format, track_num + 1,
|
||||||
|
&format, &value_end);
|
||||||
|
if (res)
|
||||||
|
{
|
||||||
|
GstPropsEntry *length;
|
||||||
|
/* substract to get the length */
|
||||||
|
GMI_DEBUG("DEBUG: start %lld, end %lld\n", value_start, value_end);
|
||||||
|
value_end -= value_start;
|
||||||
|
/* FIXME: check units; this is in seconds */
|
||||||
|
length = gst_props_entry_new ("length",
|
||||||
|
GST_PROPS_INT ((int) (value_end / 1E6)));
|
||||||
|
gst_props_add_entry (gst_caps_get_props (priv->streaminfo), length);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
priv->current_track->streaminfo = priv->streaminfo;
|
||||||
|
priv->streaminfo = NULL;
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_streaminfo (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
gmip_find_track_streaminfo_pre (priv);
|
||||||
|
GMI_DEBUG("DEBUG: gmip_find_streaminfo: iterating\n");
|
||||||
|
while ((priv->streaminfo == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
GMI_DEBUG("+");
|
||||||
|
GMI_DEBUG("\n");
|
||||||
|
gmip_find_track_streaminfo_post (priv);
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* find format found by decoder and store in priv->format */
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_format_pre (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't set to play");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_format_post (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
if (gst_element_set_state (priv->pipeline, GST_STATE_PAUSED)
|
||||||
|
== GST_STATE_FAILURE)
|
||||||
|
return FALSE;
|
||||||
|
priv->current_track->format = priv->format;
|
||||||
|
priv->format = NULL;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gmip_find_track_format (GstMediaInfoPriv *priv)
|
||||||
|
{
|
||||||
|
gmip_find_track_format_pre (priv);
|
||||||
|
GMI_DEBUG("DEBUG: gmip_find_format: iterating\n");
|
||||||
|
while ((priv->format == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
GMI_DEBUG("+");
|
||||||
|
GMI_DEBUG("\n");
|
||||||
|
gmip_find_track_format_post (priv);
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
122
gst-libs/gst/media-info/media-info-priv.h
Normal file
122
gst-libs/gst/media-info/media-info-priv.h
Normal file
|
|
@ -0,0 +1,122 @@
|
||||||
|
/* GStreamer
|
||||||
|
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
|
||||||
|
*
|
||||||
|
* 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., 59 Temple Place - Suite 330,
|
||||||
|
* Boston, MA 02111-1307, USA.
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* media-info-priv.h: private stuff */
|
||||||
|
|
||||||
|
#ifndef __GST_MEDIA_INFO_PRIV_H__
|
||||||
|
#define __GST_MEDIA_INFO_PRIV_H__
|
||||||
|
|
||||||
|
#include <gst/gst.h>
|
||||||
|
|
||||||
|
/* debug */
|
||||||
|
#define DEBUG
|
||||||
|
#ifdef DEBUG
|
||||||
|
static gboolean _gmi_debug = TRUE;
|
||||||
|
#else
|
||||||
|
static gboolean _gmi_debug = FALSE;
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#define GMI_DEBUG(format, args...) \
|
||||||
|
{ if (_gmi_debug) { g_print ( format , ## args ); }}
|
||||||
|
|
||||||
|
|
||||||
|
/* state machine enum; FIXME: can we move this to priv.c ? */
|
||||||
|
typedef enum
|
||||||
|
{
|
||||||
|
GST_MEDIA_INFO_STATE_NULL,
|
||||||
|
GST_MEDIA_INFO_STATE_TYPEFIND,
|
||||||
|
GST_MEDIA_INFO_STATE_STREAM,
|
||||||
|
GST_MEDIA_INFO_STATE_METADATA,
|
||||||
|
GST_MEDIA_INFO_STATE_STREAMINFO,
|
||||||
|
GST_MEDIA_INFO_STATE_FORMAT,
|
||||||
|
GST_MEDIA_INFO_STATE_DONE
|
||||||
|
} GstMediaInfoState;
|
||||||
|
|
||||||
|
/* private structure */
|
||||||
|
struct GstMediaInfoPriv
|
||||||
|
{
|
||||||
|
GstElement *pipeline;
|
||||||
|
|
||||||
|
GstElement *typefind;
|
||||||
|
|
||||||
|
GstCaps *type;
|
||||||
|
GstPad *decoder_pad; /* pad for querying decoded caps */
|
||||||
|
GstPad *source_pad; /* pad for querying encoded caps */
|
||||||
|
|
||||||
|
GstCaps *format;
|
||||||
|
GstCaps *metadata;
|
||||||
|
gint metadata_iters;
|
||||||
|
GstCaps *streaminfo;
|
||||||
|
|
||||||
|
GstElement *decoder; /* will be != NULL during collection */
|
||||||
|
gchar *source_element; /* type of element used as source */
|
||||||
|
GstElement *source;
|
||||||
|
|
||||||
|
GHashTable *decoders; /* a table of decoder GstElements */
|
||||||
|
|
||||||
|
GstMediaInfoState state; /* current state of state machine */
|
||||||
|
gchar *location; /* location set on the info object */
|
||||||
|
guint16 flags; /* flags supplied for detection */
|
||||||
|
GstMediaInfoTrack *current_track; /* track pointer under inspection */
|
||||||
|
glong current_track_num; /* current track under inspection */
|
||||||
|
|
||||||
|
GstMediaInfoStream *stream; /* total stream properties */
|
||||||
|
char *cache; /* location of cache */
|
||||||
|
};
|
||||||
|
|
||||||
|
/* declarations */
|
||||||
|
GstMediaInfoStream *
|
||||||
|
gmi_stream_new (void);
|
||||||
|
void gmi_stream_free (GstMediaInfoStream *stream);
|
||||||
|
|
||||||
|
GstMediaInfoTrack *
|
||||||
|
gmi_track_new (void);
|
||||||
|
|
||||||
|
void gmi_reset (GstMediaInfo *info);
|
||||||
|
gboolean gmi_seek_to_track (GstMediaInfo *info,
|
||||||
|
long track);
|
||||||
|
|
||||||
|
GstElement * gmi_get_decoder (GstMediaInfo *info,
|
||||||
|
const char *mime);
|
||||||
|
void gmi_set_decoder (GstMediaInfo *info,
|
||||||
|
GstElement *decoder);
|
||||||
|
void gmi_clear_decoder (GstMediaInfo *info);
|
||||||
|
|
||||||
|
void deep_notify_callback (GObject *object,
|
||||||
|
GstObject *origin,
|
||||||
|
GParamSpec *pspec,
|
||||||
|
GstMediaInfoPriv *priv);
|
||||||
|
|
||||||
|
gboolean gmip_find_type_pre (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_type_post (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_type (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_stream_pre (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_stream_post (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_stream (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_metadata_pre (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_metadata_post (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_metadata (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_streaminfo_pre (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_streaminfo_post (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_streaminfo (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_format_pre (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_format_post (GstMediaInfoPriv *priv);
|
||||||
|
gboolean gmip_find_track_format (GstMediaInfoPriv *priv);
|
||||||
|
|
||||||
|
#endif /* __GST_MEDIA_INFO_PRIV_H__ */
|
||||||
|
|
@ -67,6 +67,11 @@ info_print (GstMediaInfoStream *stream)
|
||||||
g_print ("- bitrate: %.3f kbps\n", stream->bitrate / 1000.0);
|
g_print ("- bitrate: %.3f kbps\n", stream->bitrate / 1000.0);
|
||||||
g_print ("- number of tracks: %ld\n", stream->length_tracks);
|
g_print ("- number of tracks: %ld\n", stream->length_tracks);
|
||||||
p = stream->tracks;
|
p = stream->tracks;
|
||||||
|
if (p == NULL)
|
||||||
|
{
|
||||||
|
g_print ("- no track information, probably an error\n");
|
||||||
|
return;
|
||||||
|
}
|
||||||
for (i = 0; i < stream->length_tracks; ++i)
|
for (i = 0; i < stream->length_tracks; ++i)
|
||||||
{
|
{
|
||||||
g_print ("- track %d\n", i);
|
g_print ("- track %d\n", i);
|
||||||
|
|
@ -85,7 +90,7 @@ int
|
||||||
main (int argc, char *argv[])
|
main (int argc, char *argv[])
|
||||||
{
|
{
|
||||||
GstMediaInfo *info;
|
GstMediaInfo *info;
|
||||||
GstMediaInfoStream *stream;
|
GstMediaInfoStream *stream = NULL;
|
||||||
gint i;
|
gint i;
|
||||||
|
|
||||||
g_assert (argc > 1);
|
g_assert (argc > 1);
|
||||||
|
|
@ -93,14 +98,23 @@ main (int argc, char *argv[])
|
||||||
gst_init (&argc, &argv);
|
gst_init (&argc, &argv);
|
||||||
|
|
||||||
info = g_object_new (GST_MEDIA_INFO_TYPE, NULL);
|
info = g_object_new (GST_MEDIA_INFO_TYPE, NULL);
|
||||||
|
g_print ("stream: %p, &stream: %p\n", stream, &stream);
|
||||||
for (i = 1; i < argc; ++i)
|
for (i = 1; i < argc; ++i)
|
||||||
{
|
{
|
||||||
|
|
||||||
|
/*
|
||||||
stream = gst_media_info_read (info, argv[i], GST_MEDIA_INFO_ALL);
|
stream = gst_media_info_read (info, argv[i], GST_MEDIA_INFO_ALL);
|
||||||
|
*/
|
||||||
|
gst_media_info_read_with_idler (info, argv[i], GST_MEDIA_INFO_ALL);
|
||||||
|
while (gst_media_info_read_idler (info, &stream) && stream == NULL)
|
||||||
|
/* keep idling */ g_print ("+");
|
||||||
g_print ("\nFILE: %s\n", argv[i]);
|
g_print ("\nFILE: %s\n", argv[i]);
|
||||||
|
g_print ("stream: %p, &stream: %p\n", stream, &stream);
|
||||||
if (stream)
|
if (stream)
|
||||||
info_print (stream);
|
info_print (stream);
|
||||||
else
|
else
|
||||||
g_print ("no media info found.\n");
|
g_print ("no media info found.\n");
|
||||||
|
stream = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
|
|
|
||||||
|
|
@ -20,102 +20,19 @@
|
||||||
#include <gst/gst.h>
|
#include <gst/gst.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include "media-info.h"
|
#include "media-info.h"
|
||||||
|
#include "media-info-priv.h"
|
||||||
static gboolean _gst_media_info_debug = TRUE;
|
|
||||||
|
|
||||||
#ifdef G_HAVE_ISO_VARARGS
|
|
||||||
#define GMI_DEBUG(...) \
|
|
||||||
G_STMT_START { \
|
|
||||||
if (_gst_media_info_debug) { g_print ( __VA_ARGS__ ); } \
|
|
||||||
} G_STMT_END
|
|
||||||
#elif defined(G_HAVE_GNUC_VARARGS)
|
|
||||||
#define GMI_DEBUG(format, args...) \
|
|
||||||
G_STMT_START { \
|
|
||||||
if (_gst_media_info_debug) { g_print ( format , ## args ); } \
|
|
||||||
} G_STMT_END
|
|
||||||
#else
|
|
||||||
#error Variable argument macros not supported by compiler
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
struct GstMediaInfoPriv
|
|
||||||
{
|
|
||||||
GstElement *pipeline;
|
|
||||||
|
|
||||||
GstElement *typefind;
|
|
||||||
|
|
||||||
GstCaps *type;
|
|
||||||
GstPad *decoder_pad; /* pad for querying decoded caps */
|
|
||||||
GstPad *source_pad; /* pad for querying encoded caps */
|
|
||||||
|
|
||||||
GstCaps *format;
|
|
||||||
GstCaps *metadata;
|
|
||||||
GstCaps *streaminfo;
|
|
||||||
|
|
||||||
GstElement *decoder; /* will be != NULL during collection */
|
|
||||||
gchar *source_element; /* type of element used as source */
|
|
||||||
GstElement *source;
|
|
||||||
|
|
||||||
GHashTable *decoders; /* a table of decoder GstElements */
|
|
||||||
|
|
||||||
GstMediaInfoStream *stream; /* total stream properties */
|
|
||||||
char *cache; /* location of cache */
|
|
||||||
};
|
|
||||||
|
|
||||||
static void gst_media_info_class_init (GstMediaInfoClass *klass);
|
static void gst_media_info_class_init (GstMediaInfoClass *klass);
|
||||||
static void gst_media_info_instance_init (GstMediaInfo *info);
|
static void gst_media_info_instance_init (GstMediaInfo *info);
|
||||||
|
|
||||||
static void gst_media_info_get_property (GObject *object, guint prop_id,
|
static void gst_media_info_get_property (GObject *object, guint prop_id,
|
||||||
GValue *value, GParamSpec *pspec);
|
GValue *value,
|
||||||
|
GParamSpec *pspec);
|
||||||
|
|
||||||
|
|
||||||
static void gst_media_info_reset (GstMediaInfo *info);
|
/* FIXME: this is a lousy hack that needs to go */
|
||||||
|
#define MAX_METADATA_ITERS 5
|
||||||
|
|
||||||
static void deep_notify_callback (GObject *object, GstObject *origin,
|
|
||||||
GParamSpec *pspec, GstMediaInfo *info);
|
|
||||||
|
|
||||||
/* helper structs bits */
|
|
||||||
static GstMediaInfoStream *
|
|
||||||
gst_media_info_stream_new (void)
|
|
||||||
{
|
|
||||||
GstMediaInfoStream *stream;
|
|
||||||
|
|
||||||
stream = g_malloc (sizeof (GstMediaInfoStream));
|
|
||||||
|
|
||||||
stream->length_tracks = 0;
|
|
||||||
stream->length_time = 0;
|
|
||||||
stream->bitrate = 0;
|
|
||||||
stream->seekable = FALSE;
|
|
||||||
stream->path = NULL;
|
|
||||||
stream->mime = NULL;
|
|
||||||
stream->tracks = NULL;
|
|
||||||
|
|
||||||
return stream;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
gst_media_info_stream_free (GstMediaInfoStream *stream)
|
|
||||||
{
|
|
||||||
if (stream->mime) g_free (stream->mime);
|
|
||||||
/* FIXME: free tracks */
|
|
||||||
g_free (stream);
|
|
||||||
}
|
|
||||||
|
|
||||||
static GstMediaInfoTrack *
|
|
||||||
gst_media_info_track_new (void)
|
|
||||||
{
|
|
||||||
GstMediaInfoTrack *track;
|
|
||||||
|
|
||||||
track = g_malloc (sizeof (GstMediaInfoTrack));
|
|
||||||
|
|
||||||
track->metadata = NULL;
|
|
||||||
track->streaminfo = NULL;
|
|
||||||
track->format = NULL;
|
|
||||||
track->length_time = 0;
|
|
||||||
track->con_streams = NULL;
|
|
||||||
|
|
||||||
return track;
|
|
||||||
}
|
|
||||||
/* GObject-y bits */
|
/* GObject-y bits */
|
||||||
|
|
||||||
/* signal stuff */
|
/* signal stuff */
|
||||||
|
|
@ -241,6 +158,7 @@ gst_media_info_instance_init (GstMediaInfo *info)
|
||||||
info->priv->source = NULL;
|
info->priv->source = NULL;
|
||||||
info->priv->source_element = NULL;
|
info->priv->source_element = NULL;
|
||||||
}
|
}
|
||||||
|
info->priv->location = NULL;
|
||||||
info->priv->decoder = NULL;
|
info->priv->decoder = NULL;
|
||||||
info->priv->type = NULL;
|
info->priv->type = NULL;
|
||||||
info->priv->format = NULL;
|
info->priv->format = NULL;
|
||||||
|
|
@ -254,7 +172,7 @@ gst_media_info_instance_init (GstMediaInfo *info)
|
||||||
|
|
||||||
/* attach notify handler */
|
/* attach notify handler */
|
||||||
g_signal_connect (G_OBJECT (info->priv->pipeline), "deep_notify",
|
g_signal_connect (G_OBJECT (info->priv->pipeline), "deep_notify",
|
||||||
G_CALLBACK (deep_notify_callback), info);
|
G_CALLBACK (deep_notify_callback), info->priv);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* get/set */
|
/* get/set */
|
||||||
|
|
@ -285,445 +203,6 @@ gst_media_info_new (const gchar *source_element)
|
||||||
return info;
|
return info;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* private functions
|
|
||||||
*/
|
|
||||||
|
|
||||||
/* callbacks */
|
|
||||||
static void
|
|
||||||
have_type_callback (GstElement *typefind, GstCaps *type, GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
info->priv->type = type;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
deep_notify_callback (GObject *object, GstObject *origin,
|
|
||||||
GParamSpec *pspec, GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
GValue value = { 0, };
|
|
||||||
|
|
||||||
if (strcmp (pspec->name, "metadata") == 0)
|
|
||||||
{
|
|
||||||
GMI_DEBUG("DEBUG: deep_notify: have metadata !\n");
|
|
||||||
g_value_init (&value, pspec->value_type);
|
|
||||||
g_object_get_property (G_OBJECT (origin), pspec->name, &value);
|
|
||||||
info->priv->metadata = g_value_peek_pointer (&value);
|
|
||||||
}
|
|
||||||
else if (strcmp (pspec->name, "caps") == 0)
|
|
||||||
{
|
|
||||||
/* check if we're getting it from the source we want it from */
|
|
||||||
if (GST_IS_PAD (origin) && GST_PAD (origin) == info->priv->decoder_pad)
|
|
||||||
{
|
|
||||||
GMI_DEBUG("DEBUG: deep_notify: have caps on decoder_pad !\n");
|
|
||||||
g_value_init (&value, pspec->value_type);
|
|
||||||
g_object_get_property (G_OBJECT (origin), pspec->name, &value);
|
|
||||||
info->priv->format = g_value_peek_pointer (&value);
|
|
||||||
}
|
|
||||||
else GMI_DEBUG("DEBUG: igoring caps on object %s:%s\n",
|
|
||||||
gst_object_get_name (gst_object_get_parent (origin)),
|
|
||||||
gst_object_get_name (origin));
|
|
||||||
}
|
|
||||||
else if (strcmp (pspec->name, "offset") == 0)
|
|
||||||
{
|
|
||||||
/* we REALLY ignore offsets, we hate them */
|
|
||||||
}
|
|
||||||
else if (strcmp (pspec->name, "streaminfo") == 0)
|
|
||||||
{
|
|
||||||
GMI_DEBUG("DEBUG: deep_notify: have streaminfo !\n");
|
|
||||||
g_value_init (&value, pspec->value_type);
|
|
||||||
g_object_get_property (G_OBJECT (origin), pspec->name, &value);
|
|
||||||
info->priv->streaminfo = g_value_peek_pointer (&value);
|
|
||||||
}
|
|
||||||
else GMI_DEBUG("DEBUG: ignoring notify of %s\n", pspec->name);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* helpers */
|
|
||||||
|
|
||||||
/* reset info to a state where it can be used to query for media info
|
|
||||||
* clear caps, metadata, and so on */
|
|
||||||
static void
|
|
||||||
gst_media_info_reset (GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
/* clear out some stuff */
|
|
||||||
if (priv->format)
|
|
||||||
{
|
|
||||||
gst_caps_unref (priv->format);
|
|
||||||
priv->format = NULL;
|
|
||||||
}
|
|
||||||
if (priv->metadata)
|
|
||||||
{
|
|
||||||
gst_caps_unref (priv->metadata);
|
|
||||||
priv->metadata = NULL;
|
|
||||||
}
|
|
||||||
if (priv->stream)
|
|
||||||
{
|
|
||||||
g_free (priv->stream);
|
|
||||||
priv->stream = NULL;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/* seek to a track and reset metadata and streaminfo structs */
|
|
||||||
static gboolean
|
|
||||||
gst_media_info_seek_to_track (GstMediaInfo *info, long track)
|
|
||||||
{
|
|
||||||
GstEvent *event;
|
|
||||||
GstFormat track_format = 0;
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
gboolean res;
|
|
||||||
|
|
||||||
/* FIXME: consider more nicks as "track" */
|
|
||||||
track_format = gst_format_get_by_nick ("logical_stream");
|
|
||||||
if (track_format == 0) return FALSE;
|
|
||||||
GMI_DEBUG("Track format: %d\n", track_format);
|
|
||||||
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to play");
|
|
||||||
g_assert (GST_IS_PAD (info->priv->decoder_pad));
|
|
||||||
event = gst_event_new_seek (track_format |
|
|
||||||
GST_SEEK_METHOD_SET |
|
|
||||||
GST_SEEK_FLAG_FLUSH,
|
|
||||||
track);
|
|
||||||
res = gst_pad_send_event (info->priv->decoder_pad, event);
|
|
||||||
g_assert (res);
|
|
||||||
if (!res)
|
|
||||||
{
|
|
||||||
g_warning ("seek to logical track failed");
|
|
||||||
return FALSE;
|
|
||||||
}
|
|
||||||
/* clear structs because of the seek */
|
|
||||||
if (priv->metadata)
|
|
||||||
{
|
|
||||||
gst_caps_unref (priv->metadata);
|
|
||||||
priv->metadata = NULL;
|
|
||||||
}
|
|
||||||
if (priv->streaminfo)
|
|
||||||
{
|
|
||||||
gst_caps_unref (priv->streaminfo);
|
|
||||||
priv->streaminfo = NULL;
|
|
||||||
}
|
|
||||||
return TRUE;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* create a good decoder for this mime type */
|
|
||||||
/* FIXME: maybe make this more generic with a type, so it can be used
|
|
||||||
* for taggers and other things as well */
|
|
||||||
GstElement *
|
|
||||||
gst_media_info_get_decoder (GstMediaInfo *info, const char *mime)
|
|
||||||
{
|
|
||||||
GstElement *decoder;
|
|
||||||
gchar *factory = NULL;
|
|
||||||
|
|
||||||
/* check if we have an active codec element in the hash table for this */
|
|
||||||
decoder = g_hash_table_lookup (info->priv->decoders, mime);
|
|
||||||
if (decoder == NULL)
|
|
||||||
{
|
|
||||||
GMI_DEBUG("DEBUG: no decoder in table, inserting one\n");
|
|
||||||
if (strcmp (mime, "application/x-ogg") == 0)
|
|
||||||
factory = g_strdup ("vorbisfile");
|
|
||||||
else if (strcmp (mime, "audio/x-mp3") == 0)
|
|
||||||
factory = g_strdup ("mad");
|
|
||||||
else if (strcmp (mime, "audio/x-wav") == 0)
|
|
||||||
factory = g_strdup ("wavparse");
|
|
||||||
|
|
||||||
if (factory == NULL)
|
|
||||||
return NULL;
|
|
||||||
|
|
||||||
GMI_DEBUG("DEBUG: using factory %s\n", factory);
|
|
||||||
decoder = gst_element_factory_make (factory, "decoder");
|
|
||||||
g_free (factory);
|
|
||||||
|
|
||||||
if (decoder)
|
|
||||||
{
|
|
||||||
g_hash_table_insert (info->priv->decoders, g_strdup (mime), decoder);
|
|
||||||
/* ref it so we don't lose it when removing from bin */
|
|
||||||
g_object_ref (GST_OBJECT (decoder));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return decoder;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* find the type of a file and store it in the caps of the info
|
|
||||||
* FIXME: we might better return GstCaps instead of storing them
|
|
||||||
* internally */
|
|
||||||
static void
|
|
||||||
gst_media_info_find_type (GstMediaInfo *info, const char *location)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
|
|
||||||
/* clear vars that need clearing */
|
|
||||||
if (priv->type)
|
|
||||||
{
|
|
||||||
gst_caps_unref (priv->type);
|
|
||||||
priv->type = NULL;
|
|
||||||
}
|
|
||||||
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_find_type: start\n");
|
|
||||||
/* find out type */
|
|
||||||
/* FIXME: we could move caps for typefind out of struct and
|
|
||||||
* just use it through this function only */
|
|
||||||
|
|
||||||
gst_bin_add (GST_BIN (priv->pipeline), priv->typefind);
|
|
||||||
g_object_set (G_OBJECT (priv->source), "location", location, NULL);
|
|
||||||
if (!gst_element_link (priv->source, priv->typefind))
|
|
||||||
g_warning ("Couldn't link source and typefind\n");
|
|
||||||
g_signal_connect (G_OBJECT (priv->typefind), "have-type",
|
|
||||||
G_CALLBACK (have_type_callback), info);
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to play");
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_find_type: iterating\n");
|
|
||||||
while ((priv->type == NULL) &&
|
|
||||||
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
|
||||||
GMI_DEBUG("+");
|
|
||||||
GMI_DEBUG("\n");
|
|
||||||
|
|
||||||
/*clear up typefind */
|
|
||||||
gst_element_set_state (priv->pipeline, GST_STATE_READY);
|
|
||||||
gst_element_unlink (priv->source, priv->typefind);
|
|
||||||
gst_bin_remove (GST_BIN (priv->pipeline), priv->typefind);
|
|
||||||
}
|
|
||||||
/* get properties of complete physical stream
|
|
||||||
* and return them in pre-alloced stream struct */
|
|
||||||
static gboolean
|
|
||||||
gst_media_info_get_stream (GstMediaInfo *info, GstMediaInfoStream *stream)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
const GstFormat *formats;
|
|
||||||
GstFormat track_format = 0;
|
|
||||||
GstFormat format;
|
|
||||||
gint64 value;
|
|
||||||
gboolean res;
|
|
||||||
glong bytes = 0;
|
|
||||||
|
|
||||||
GMI_DEBUG("DEBUG:gst_media_info_get_stream start\n");
|
|
||||||
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to play");
|
|
||||||
/* iterate until caps are found */
|
|
||||||
/* FIXME: this should be done through the plugin sending some signal
|
|
||||||
* that it is ready for queries */
|
|
||||||
while (gst_bin_iterate (GST_BIN (priv->pipeline)) &&
|
|
||||||
priv->format == NULL)
|
|
||||||
;
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PAUSED)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to paused");
|
|
||||||
if (priv->format == NULL)
|
|
||||||
{
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_get_stream: couldn't get caps !");
|
|
||||||
return FALSE;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* find a format that matches the "track" concept */
|
|
||||||
/* FIXME: this is used in vorbis, but we might have to loop when
|
|
||||||
* more codecs have tracks */
|
|
||||||
track_format = gst_format_get_by_nick ("logical_stream");
|
|
||||||
|
|
||||||
/* get supported formats on decoder pad */
|
|
||||||
formats = gst_pad_get_formats (priv->decoder_pad);
|
|
||||||
while (*formats)
|
|
||||||
{
|
|
||||||
const GstFormatDefinition *definition;
|
|
||||||
|
|
||||||
format = *formats;
|
|
||||||
|
|
||||||
g_assert (GST_IS_PAD (priv->decoder_pad));
|
|
||||||
res = gst_pad_query (priv->decoder_pad, GST_QUERY_TOTAL,
|
|
||||||
&format, &value);
|
|
||||||
|
|
||||||
definition = gst_format_get_details (*formats);
|
|
||||||
GMI_DEBUG("trying to figure out length for format %s\n", definition->nick);
|
|
||||||
|
|
||||||
if (res)
|
|
||||||
{
|
|
||||||
switch (format)
|
|
||||||
{
|
|
||||||
case GST_FORMAT_TIME:
|
|
||||||
stream->length_time = value;
|
|
||||||
g_print (" total %s: %" G_GINT64_FORMAT "\n", definition->nick, value);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
/* separation is necessary because track_format doesn't resolve to
|
|
||||||
* int */
|
|
||||||
if (format == track_format)
|
|
||||||
{
|
|
||||||
stream->length_tracks = value;
|
|
||||||
g_print (" total %s: %" G_GINT64_FORMAT "\n", definition->nick, value);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
g_print ("warning: unhandled format %s\n", definition->nick);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
GMI_DEBUG("query didn't return result for %s\n", definition->nick);
|
|
||||||
|
|
||||||
formats++;
|
|
||||||
}
|
|
||||||
if (stream->length_tracks == 0) stream->length_tracks = 1;
|
|
||||||
/* now get number of bytes from the sink pad to get the bitrate */
|
|
||||||
format = GST_FORMAT_BYTES;
|
|
||||||
g_assert (GST_IS_PAD (priv->source_pad));
|
|
||||||
res = gst_pad_query (priv->source_pad, GST_QUERY_TOTAL,
|
|
||||||
&format, &value);
|
|
||||||
if (!res) g_warning ("Failed to query on sink pad !");
|
|
||||||
bytes = value;
|
|
||||||
|
|
||||||
if (bytes)
|
|
||||||
{
|
|
||||||
double seconds = stream->length_time / GST_SECOND;
|
|
||||||
double bits = bytes * 8;
|
|
||||||
stream->bitrate = (long) (bits / seconds);
|
|
||||||
}
|
|
||||||
return TRUE;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* find metadata encoded in media */
|
|
||||||
GstCaps *
|
|
||||||
gst_media_info_find_metadata (GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
GstCaps *metadata;
|
|
||||||
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to play");
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_find_metadata: iterating\n");
|
|
||||||
while ((priv->metadata == NULL) &&
|
|
||||||
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
|
||||||
GMI_DEBUG("+");
|
|
||||||
GMI_DEBUG("\n");
|
|
||||||
gst_element_set_state (priv->pipeline, GST_STATE_PAUSED);
|
|
||||||
metadata = priv->metadata;
|
|
||||||
priv->metadata = NULL;
|
|
||||||
return metadata;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* find streaminfo found by decoder */
|
|
||||||
GstCaps *
|
|
||||||
gst_media_info_find_streaminfo (GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
GstCaps *streaminfo;
|
|
||||||
GstFormat format, track_format;
|
|
||||||
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to play");
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_find_streaminfo: iterating\n");
|
|
||||||
while ((priv->streaminfo == NULL) &&
|
|
||||||
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
|
||||||
GMI_DEBUG("+");
|
|
||||||
GMI_DEBUG("\n");
|
|
||||||
gst_element_set_state (priv->pipeline, GST_STATE_PAUSED);
|
|
||||||
streaminfo = priv->streaminfo;
|
|
||||||
priv->streaminfo = NULL;
|
|
||||||
|
|
||||||
/* now add total length to this, and maybe even bitrate ? FIXME */
|
|
||||||
track_format = gst_format_get_by_nick ("logical_stream");
|
|
||||||
if (track_format == 0)
|
|
||||||
{
|
|
||||||
g_print ("FIXME: implement getting length of whole track\n");
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
/* which one are we at ? */
|
|
||||||
long track_num;
|
|
||||||
gint64 value_start, value_end;
|
|
||||||
gboolean res;
|
|
||||||
|
|
||||||
res = gst_pad_query (priv->decoder_pad, GST_QUERY_POSITION,
|
|
||||||
&track_format, &value_start);
|
|
||||||
if (res)
|
|
||||||
{
|
|
||||||
format = GST_FORMAT_TIME;
|
|
||||||
track_num = value_start;
|
|
||||||
GMI_DEBUG("DEBUG: we are currently at %ld\n", track_num);
|
|
||||||
res = gst_pad_convert (priv->decoder_pad,
|
|
||||||
track_format, track_num,
|
|
||||||
&format, &value_start);
|
|
||||||
res &= gst_pad_convert (priv->decoder_pad,
|
|
||||||
track_format, track_num + 1,
|
|
||||||
&format, &value_end);
|
|
||||||
if (res)
|
|
||||||
{
|
|
||||||
GstPropsEntry *length;
|
|
||||||
/* substract to get the length */
|
|
||||||
GMI_DEBUG("DEBUG: start %" G_GINT64_FORMAT ", end %"
|
|
||||||
G_GINT64_FORMAT "\n", value_start, value_end);
|
|
||||||
value_end -= value_start;
|
|
||||||
g_print ("DEBUG: length: %d\n", (int) value_end);
|
|
||||||
length = gst_props_entry_new ("length", GST_PROPS_INT ((int) value_end));
|
|
||||||
gst_props_add_entry (gst_caps_get_props (streaminfo), length);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return streaminfo;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* find format found by decoder */
|
|
||||||
GstCaps *
|
|
||||||
gst_media_info_find_format (GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
GstCaps *format;
|
|
||||||
|
|
||||||
if (gst_element_set_state (priv->pipeline, GST_STATE_PLAYING)
|
|
||||||
== GST_STATE_FAILURE)
|
|
||||||
g_warning ("Couldn't set to play");
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_find_format: iterating\n");
|
|
||||||
while ((priv->format == NULL) &&
|
|
||||||
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
|
||||||
GMI_DEBUG("+");
|
|
||||||
GMI_DEBUG("\n");
|
|
||||||
gst_element_set_state (priv->pipeline, GST_STATE_PAUSED);
|
|
||||||
format = priv->format;
|
|
||||||
priv->format = NULL;
|
|
||||||
return format;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* clear the decoder
|
|
||||||
* (if it was set)
|
|
||||||
*/
|
|
||||||
static void
|
|
||||||
gst_media_info_clear_decoder (GstMediaInfo *info)
|
|
||||||
{
|
|
||||||
if (info->priv->decoder)
|
|
||||||
{
|
|
||||||
/* clear up decoder */
|
|
||||||
/* FIXME: shouldn't need to set state here */
|
|
||||||
gst_element_set_state (info->priv->pipeline, GST_STATE_READY);
|
|
||||||
gst_element_unlink (info->priv->source, info->priv->decoder);
|
|
||||||
gst_bin_remove (GST_BIN (info->priv->pipeline), info->priv->decoder);
|
|
||||||
info->priv->decoder = NULL;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/* set the decoder to be used for decoding
|
|
||||||
* install callback handlers
|
|
||||||
*/
|
|
||||||
|
|
||||||
static void
|
|
||||||
gst_media_info_set_decoder (GstMediaInfo *info, GstElement *decoder)
|
|
||||||
{
|
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
|
||||||
|
|
||||||
/* set up pipeline and connect signal handlers */
|
|
||||||
priv->decoder = decoder;
|
|
||||||
gst_bin_add (GST_BIN (priv->pipeline), decoder);
|
|
||||||
if (!gst_element_link (priv->source, decoder))
|
|
||||||
g_warning ("Couldn't link source and decoder\n");
|
|
||||||
/* FIXME: we should be link to ALL possible src pads */
|
|
||||||
if (!(priv->decoder_pad = gst_element_get_pad (decoder, "src")))
|
|
||||||
g_warning ("Couldn't get decoder pad\n");
|
|
||||||
if (!(priv->source_pad = gst_element_get_pad (priv->source, "src")))
|
|
||||||
g_warning ("Couldn't get source pad\n");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* public methods
|
* public methods
|
||||||
*/
|
*/
|
||||||
|
|
@ -753,71 +232,266 @@ gst_media_info_set_source (GstMediaInfo *info, const char *source)
|
||||||
return TRUE;
|
return TRUE;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* idler-based implementation
|
||||||
|
* set up read on a given location
|
||||||
|
* FIXME: maybe we should check if the info is cleared when calling this
|
||||||
|
* function ? What happens if it gets called again on same info before
|
||||||
|
* previous one is done ?
|
||||||
|
*/
|
||||||
|
void
|
||||||
|
gst_media_info_read_with_idler (GstMediaInfo *info, const char *location,
|
||||||
|
guint16 flags)
|
||||||
|
{
|
||||||
|
GstMediaInfoPriv *priv = info->priv;
|
||||||
|
|
||||||
|
gmi_reset (info); /* reset all structs */
|
||||||
|
priv->location = g_strdup (location);
|
||||||
|
priv->flags = flags;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* an idler which does the work of actually collecting all data
|
||||||
|
* this must be called repeatedly, until streamp is set to a non-NULL value
|
||||||
|
* returns: TRUE if it was able to idle, FALSE if there was an error
|
||||||
|
*/
|
||||||
|
gboolean
|
||||||
|
gst_media_info_read_idler (GstMediaInfo *info, GstMediaInfoStream **streamp)
|
||||||
|
{
|
||||||
|
GstMediaInfoPriv *priv ;
|
||||||
|
/* if it's NULL then we're sure something went wrong higher up) */
|
||||||
|
if (info == NULL) return FALSE;
|
||||||
|
|
||||||
|
priv = info->priv;
|
||||||
|
|
||||||
|
g_assert (streamp != NULL);
|
||||||
|
switch (priv->state)
|
||||||
|
{
|
||||||
|
case GST_MEDIA_INFO_STATE_NULL:
|
||||||
|
/* need to find type */
|
||||||
|
GMI_DEBUG("idler: NULL, need to find type\n");
|
||||||
|
return gmip_find_type_pre (priv);
|
||||||
|
|
||||||
|
case GST_MEDIA_INFO_STATE_TYPEFIND:
|
||||||
|
{
|
||||||
|
gchar *mime;
|
||||||
|
GstElement *decoder;
|
||||||
|
|
||||||
|
GMI_DEBUG("STATE_TYPEFIND\n");
|
||||||
|
if ((priv->type == NULL) && gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
{
|
||||||
|
GMI_DEBUG("?");
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
if (priv->type == NULL)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't find type\n");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
/* do the state transition */
|
||||||
|
GMI_DEBUG("doing find_type_post\n");
|
||||||
|
gmip_find_type_post (priv);
|
||||||
|
GMI_DEBUG("finding out mime type\n");
|
||||||
|
mime = g_strdup (gst_caps_get_mime (priv->type));
|
||||||
|
GMI_DEBUG("found out mime type: %s\n", mime);
|
||||||
|
decoder = gmi_get_decoder (info, mime);
|
||||||
|
if (decoder == NULL)
|
||||||
|
{
|
||||||
|
/* FIXME: pop up error */
|
||||||
|
GMI_DEBUG("DEBUG: no decoder found for mime %s\n", mime);
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
priv->stream = gmi_stream_new ();
|
||||||
|
GMI_DEBUG("DEBUG: new stream: %p\n", priv->stream);
|
||||||
|
priv->stream->mime = mime;
|
||||||
|
priv->stream->path = priv->location;
|
||||||
|
gmi_set_decoder (info, decoder);
|
||||||
|
|
||||||
|
gmip_find_stream_pre (priv);
|
||||||
|
}
|
||||||
|
case GST_MEDIA_INFO_STATE_STREAM:
|
||||||
|
{
|
||||||
|
GMI_DEBUG("STATE_STREAM\n");
|
||||||
|
if ((priv->format == NULL) && gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
{
|
||||||
|
GMI_DEBUG("?");
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
if (priv->format == NULL)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't find format\n");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
/* do state transition; stream -> first track metadata */
|
||||||
|
priv->current_track_num = 0;
|
||||||
|
gmip_find_stream_post (priv);
|
||||||
|
priv->current_track = gmi_track_new ();
|
||||||
|
gmip_find_track_metadata_pre (priv);
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
/* these ones are repeated per track */
|
||||||
|
case GST_MEDIA_INFO_STATE_METADATA:
|
||||||
|
{
|
||||||
|
if ((priv->metadata == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)) &&
|
||||||
|
priv->metadata_iters < MAX_METADATA_ITERS)
|
||||||
|
{
|
||||||
|
GMI_DEBUG("?");
|
||||||
|
priv->metadata_iters++;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
if (priv->metadata_iters == MAX_METADATA_ITERS)
|
||||||
|
g_print ("iterated a few times, didn't find metadata\n");
|
||||||
|
if (priv->metadata == NULL)
|
||||||
|
{
|
||||||
|
/* this is not a permanent failure */
|
||||||
|
GMI_DEBUG("Couldn't find metadata\n");
|
||||||
|
}
|
||||||
|
GMI_DEBUG("found metadata of track %ld\n", priv->current_track_num);
|
||||||
|
if (!gmip_find_track_metadata_post (priv)) return FALSE;
|
||||||
|
GMI_DEBUG("METADATA: going to STREAMINFO\n");
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_STREAMINFO;
|
||||||
|
return gmip_find_track_streaminfo_pre (priv);
|
||||||
|
}
|
||||||
|
case GST_MEDIA_INFO_STATE_STREAMINFO:
|
||||||
|
{
|
||||||
|
if ((priv->streaminfo == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
{
|
||||||
|
GMI_DEBUG("?");
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
if (priv->streaminfo == NULL)
|
||||||
|
{
|
||||||
|
/* this is not a permanent failure */
|
||||||
|
GMI_DEBUG("Couldn't find streaminfo\n");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
GMI_DEBUG("found streaminfo of track %ld\n", priv->current_track_num);
|
||||||
|
if (!gmip_find_track_streaminfo_post (priv)) return FALSE;
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_FORMAT;
|
||||||
|
return gmip_find_track_format_pre (priv);
|
||||||
|
}
|
||||||
|
case GST_MEDIA_INFO_STATE_FORMAT:
|
||||||
|
{
|
||||||
|
if ((priv->format == NULL) &&
|
||||||
|
gst_bin_iterate (GST_BIN (priv->pipeline)))
|
||||||
|
{
|
||||||
|
GMI_DEBUG("?");
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
if (priv->format == NULL)
|
||||||
|
{
|
||||||
|
g_warning ("Couldn't find format\n");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
GMI_DEBUG("found format of track %ld\n", priv->current_track_num);
|
||||||
|
if (!gmip_find_track_format_post (priv)) return FALSE;
|
||||||
|
/* save the track info */
|
||||||
|
priv->stream->tracks = g_list_append (priv->stream->tracks,
|
||||||
|
priv->current_track);
|
||||||
|
/* these alloc'd data types have been handed off */
|
||||||
|
priv->current_track = NULL;
|
||||||
|
priv->location = NULL;
|
||||||
|
/* now see if we need to seek to a next track or not */
|
||||||
|
priv->current_track_num++;
|
||||||
|
if (priv->current_track_num < priv->stream->length_tracks)
|
||||||
|
{
|
||||||
|
gmi_seek_to_track (info, priv->current_track_num);
|
||||||
|
priv->current_track = gmi_track_new ();
|
||||||
|
if (!gmip_find_track_metadata_pre (priv))
|
||||||
|
{
|
||||||
|
g_free (priv->current_track);
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_METADATA;
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
priv->state = GST_MEDIA_INFO_STATE_DONE;
|
||||||
|
*streamp = priv->stream;
|
||||||
|
priv->stream = NULL;
|
||||||
|
GMI_DEBUG("TOTALLY DONE, setting pointer *streamp to %p\n", *streamp);
|
||||||
|
gmi_clear_decoder (info);
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
case GST_MEDIA_INFO_STATE_DONE:
|
||||||
|
return TRUE;
|
||||||
|
default:
|
||||||
|
g_warning ("don't know what to do\n");
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* main function
|
||||||
|
* read all possible info from the file pointed to by location
|
||||||
|
* use flags to limit the type of information searched for */
|
||||||
GstMediaInfoStream *
|
GstMediaInfoStream *
|
||||||
gst_media_info_read (GstMediaInfo *info, const char *location, guint16 flags)
|
gst_media_info_read (GstMediaInfo *info, const char *location, guint16 flags)
|
||||||
{
|
{
|
||||||
GstMediaInfoPriv *priv = info->priv;
|
GstMediaInfoPriv *priv = info->priv;
|
||||||
GstElement *decoder = NULL;
|
|
||||||
const gchar *mime;
|
|
||||||
GstMediaInfoStream *stream = NULL;
|
GstMediaInfoStream *stream = NULL;
|
||||||
|
GstElement *decoder = NULL;
|
||||||
|
gchar *mime;
|
||||||
int i;
|
int i;
|
||||||
|
|
||||||
GMI_DEBUG("DEBUG: gst_media_info_read: start\n");
|
GMI_DEBUG("DEBUG: gst_media_info_read: start\n");
|
||||||
gst_media_info_reset (info); /* reset all structs */
|
gmi_reset (info); /* reset all structs */
|
||||||
/* find out type */
|
priv->location = g_strdup (location);
|
||||||
/* FIXME: we could move caps for typefind out of struct and
|
priv->flags = flags;
|
||||||
* just use it through this function only */
|
|
||||||
gst_media_info_find_type (info, location);
|
|
||||||
|
|
||||||
if (priv->type == NULL)
|
if (!gmip_find_type (priv)) return NULL;
|
||||||
{
|
|
||||||
/* iteration ended, still don't have type, ugh */
|
mime = g_strdup (gst_caps_get_mime (priv->type));
|
||||||
g_warning ("iteration ended, type not found !\n");
|
|
||||||
return NULL;
|
|
||||||
}
|
|
||||||
stream = gst_media_info_stream_new ();
|
|
||||||
mime = gst_caps_get_mime (priv->type);
|
|
||||||
if (flags & GST_MEDIA_INFO_MIME)
|
|
||||||
stream->mime = g_strdup (mime);
|
|
||||||
stream->path = g_strdup (location);
|
|
||||||
GMI_DEBUG("mime type: %s\n", mime);
|
GMI_DEBUG("mime type: %s\n", mime);
|
||||||
decoder = gst_media_info_get_decoder (info, mime);
|
|
||||||
|
/* c) figure out decoder */
|
||||||
|
decoder = gmi_get_decoder (info, mime);
|
||||||
|
g_print ("DEBUG: using decoder %s\n", gst_element_get_name (decoder));
|
||||||
|
|
||||||
/* if it's NULL, then that's a sign we can't decode it */
|
/* if it's NULL, then that's a sign we can't decode it */
|
||||||
if (decoder == NULL)
|
if (decoder == NULL)
|
||||||
{
|
{
|
||||||
g_warning ("Can't find a decoder for type %s\n", mime);
|
g_warning ("Can't find a decoder for type %s\n", mime);
|
||||||
gst_media_info_stream_free (stream);
|
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* b) create media info stream object */
|
||||||
|
priv->stream = gmi_stream_new ();
|
||||||
|
priv->stream->mime = mime;
|
||||||
|
priv->stream->path = priv->location;
|
||||||
|
|
||||||
/* install this decoder in the pipeline */
|
/* install this decoder in the pipeline */
|
||||||
gst_media_info_set_decoder (info, decoder);
|
gmi_set_decoder (info, decoder);
|
||||||
|
|
||||||
/* collect total stream properties */
|
/* collect total stream properties */
|
||||||
gst_media_info_get_stream (info, stream);
|
/* d) get all stream properties */
|
||||||
|
gmip_find_stream (priv);
|
||||||
|
|
||||||
/* if we have multiple tracks, loop over them; if not, just get
|
/* e) if we have multiple tracks, loop over them; if not, just get
|
||||||
* metadata and return it */
|
* metadata and return it */
|
||||||
GMI_DEBUG("DEBUG: num tracks %ld\n", stream->length_tracks);
|
GMI_DEBUG("DEBUG: num tracks %ld\n", priv->stream->length_tracks);
|
||||||
for (i = 0; i < stream->length_tracks; ++i)
|
for (i = 0; i < priv->stream->length_tracks; ++i)
|
||||||
{
|
{
|
||||||
GstMediaInfoTrack *track = gst_media_info_track_new ();
|
priv->current_track = gmi_track_new ();
|
||||||
if (i > 0)
|
if (i > 0)
|
||||||
{
|
{
|
||||||
GMI_DEBUG("seeking to track %d\n", i);
|
GMI_DEBUG("seeking to track %d\n", i);
|
||||||
gst_media_info_seek_to_track (info, i);
|
gmi_seek_to_track (info, i);
|
||||||
}
|
}
|
||||||
if (flags & GST_MEDIA_INFO_METADATA)
|
if (flags & GST_MEDIA_INFO_METADATA)
|
||||||
track->metadata = gst_media_info_find_metadata (info);
|
gmip_find_track_metadata (priv);
|
||||||
if (flags & GST_MEDIA_INFO_STREAMINFO)
|
if (flags & GST_MEDIA_INFO_STREAMINFO)
|
||||||
track->streaminfo = gst_media_info_find_streaminfo (info);
|
gmip_find_track_streaminfo (priv);
|
||||||
if (flags & GST_MEDIA_INFO_FORMAT)
|
if (flags & GST_MEDIA_INFO_FORMAT)
|
||||||
track->format = gst_media_info_find_format (info);
|
gmip_find_track_format (priv);
|
||||||
stream->tracks = g_list_append (stream->tracks, track);
|
priv->stream->tracks = g_list_append (priv->stream->tracks,
|
||||||
|
priv->current_track);
|
||||||
|
priv->current_track = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
gst_media_info_clear_decoder (info);
|
/* f) clear decoder */
|
||||||
|
gmi_clear_decoder (info);
|
||||||
/* please return it */
|
/* please return it */
|
||||||
|
stream = priv->stream;
|
||||||
|
priv->stream = NULL;
|
||||||
return stream;
|
return stream;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -828,4 +502,3 @@ gboolean gst_media_info_write (GstMediaInfo *media_info,
|
||||||
const char *location,
|
const char *location,
|
||||||
GstCaps *media_info);
|
GstCaps *media_info);
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -95,6 +95,12 @@ typedef struct
|
||||||
GType gst_media_info_get_type (void);
|
GType gst_media_info_get_type (void);
|
||||||
|
|
||||||
GstMediaInfo * gst_media_info_new (const char *source_element);
|
GstMediaInfo * gst_media_info_new (const char *source_element);
|
||||||
|
|
||||||
|
void gst_media_info_read_with_idler (GstMediaInfo *media_info,
|
||||||
|
const char *location,
|
||||||
|
guint16 GST_MEDIA_INFO_FLAGS);
|
||||||
|
gboolean gst_media_info_read_idler (GstMediaInfo *media_info,
|
||||||
|
GstMediaInfoStream **streamp);
|
||||||
GstMediaInfoStream *
|
GstMediaInfoStream *
|
||||||
gst_media_info_read (GstMediaInfo *media_info,
|
gst_media_info_read (GstMediaInfo *media_info,
|
||||||
const char *location,
|
const char *location,
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue