mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-12-20 23:36:38 +00:00
2affd3d483
Original commit message from CVS: * docs/plugins/Makefile.am: * docs/plugins/gst-plugins-bad-plugins-docs.sgml: * docs/plugins/gst-plugins-bad-plugins-sections.txt: * docs/plugins/gst-plugins-bad-plugins.args: * docs/plugins/gst-plugins-bad-plugins.hierarchy: * docs/plugins/gst-plugins-bad-plugins.interfaces: * docs/plugins/gst-plugins-bad-plugins.prerequisites: * docs/plugins/gst-plugins-bad-plugins.signals: * docs/plugins/inspect/plugin-alsaspdif.xml: * docs/plugins/inspect/plugin-amrwb.xml: * docs/plugins/inspect/plugin-app.xml: * docs/plugins/inspect/plugin-bayer.xml: * docs/plugins/inspect/plugin-bz2.xml: * docs/plugins/inspect/plugin-cdaudio.xml: * docs/plugins/inspect/plugin-cdxaparse.xml: * docs/plugins/inspect/plugin-dtsdec.xml: * docs/plugins/inspect/plugin-dvb.xml: * docs/plugins/inspect/plugin-dvdspu.xml: * docs/plugins/inspect/plugin-faac.xml: * docs/plugins/inspect/plugin-faad.xml: * docs/plugins/inspect/plugin-fbdevsink.xml: * docs/plugins/inspect/plugin-festival.xml: * docs/plugins/inspect/plugin-filter.xml: * docs/plugins/inspect/plugin-flvdemux.xml: * docs/plugins/inspect/plugin-freeze.xml: * docs/plugins/inspect/plugin-gsm.xml: * docs/plugins/inspect/plugin-gstinterlace.xml: * docs/plugins/inspect/plugin-gstrtpmanager.xml: * docs/plugins/inspect/plugin-h264parse.xml: * docs/plugins/inspect/plugin-interleave.xml: * docs/plugins/inspect/plugin-jack.xml: * docs/plugins/inspect/plugin-ladspa.xml: * docs/plugins/inspect/plugin-metadata.xml: * docs/plugins/inspect/plugin-mms.xml: * docs/plugins/inspect/plugin-modplug.xml: * docs/plugins/inspect/plugin-mpeg2enc.xml: * docs/plugins/inspect/plugin-mpeg4videoparse.xml: * docs/plugins/inspect/plugin-mpegtsparse.xml: * docs/plugins/inspect/plugin-mpegvideoparse.xml: * docs/plugins/inspect/plugin-musepack.xml: * docs/plugins/inspect/plugin-musicbrainz.xml: * docs/plugins/inspect/plugin-mve.xml: * docs/plugins/inspect/plugin-mythtv.xml * docs/plugins/inspect/plugin-nas.xml: * docs/plugins/inspect/plugin-neon.xml: * docs/plugins/inspect/plugin-nsfdec.xml: * docs/plugins/inspect/plugin-nuvdemux.xml: * docs/plugins/inspect/plugin-oss4.xml * docs/plugins/inspect/plugin-rawparse.xml: * docs/plugins/inspect/plugin-real.xml: * docs/plugins/inspect/plugin-replaygain.xml: * docs/plugins/inspect/plugin-rfbsrc.xml: * docs/plugins/inspect/plugin-sdl.xml: * docs/plugins/inspect/plugin-sdp.xml: * docs/plugins/inspect/plugin-selector.xml: * docs/plugins/inspect/plugin-sndfile.xml: * docs/plugins/inspect/plugin-soundtouch.xml: * docs/plugins/inspect/plugin-spcdec.xml: * docs/plugins/inspect/plugin-speed.xml: * docs/plugins/inspect/plugin-speexresample.xml: * docs/plugins/inspect/plugin-stereo.xml: * docs/plugins/inspect/plugin-subenc.xml * docs/plugins/inspect/plugin-timidity.xml: * docs/plugins/inspect/plugin-tta.xml: * docs/plugins/inspect/plugin-vcdsrc.xml: * docs/plugins/inspect/plugin-videosignal.xml: * docs/plugins/inspect/plugin-vmnc.xml: * docs/plugins/inspect/plugin-wildmidi.xml: * docs/plugins/inspect/plugin-x264.xml: * docs/plugins/inspect/plugin-xvid.xml: * docs/plugins/inspect/plugin-y4menc.xml: * ext/amrwb/gstamrwbdec.c: * ext/amrwb/gstamrwbenc.c: * ext/amrwb/gstamrwbparse.c: * ext/dc1394/gstdc1394.c: * ext/directfb/dfbvideosink.c: * ext/ivorbis/vorbisdec.c: * ext/jack/gstjackaudiosink.c: * ext/mpeg2enc/gstmpeg2enc.cc: * ext/mplex/gstmplex.cc: * ext/musicbrainz/gsttrm.c: * ext/mythtv/gstmythtvsrc.c: * ext/theora/theoradec.c: * ext/timidity/gsttimidity.c: * ext/timidity/gstwildmidi.c: * gst-libs/gst/app/gstappsink.c: * gst/deinterlace/gstdeinterlace.c: * gst/dvdspu/gstdvdspu.c: * gst/festival/gstfestival.c: * gst/freeze/gstfreeze.c: * gst/interleave/deinterleave.c: * gst/interleave/interleave.c: * gst/modplug/gstmodplug.cc: * gst/nuvdemux/gstnuvdemux.c: Add missing elements to docs. Fix doc-markup: use convinience syntax for examples (produces valid docbook), add several refsec2 when we have several titles. Fix some types.
397 lines
11 KiB
C
397 lines
11 KiB
C
/* GStreamer trm plugin
|
|
* Copyright (C) 2004 Jeremy Simon <jsimon13@yahoo.fr>
|
|
* Copyright (C) 2006 James Livingston <doclivingston gmail com>
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Library General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Library General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Library General Public
|
|
* License along with this library; if not, write to the
|
|
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
|
* Boston, MA 02111-1307, USA.
|
|
*/
|
|
|
|
/**
|
|
* SECTION:element-trm
|
|
*
|
|
* GstTRM computes <ulink url="http://www.musicbrainz.org/">MusicBrainz</ulink>
|
|
* TRM identifiers for audio streams using libmusicbrainz.
|
|
*
|
|
* A TRM identifier is something like an 'acoustic fingerprint', the aim is
|
|
* to uniquely identify the same song regardless of which source it comes from
|
|
* or which audio format the stream is in.
|
|
*
|
|
* The TRM element will collect about 30 seconds of audio and let
|
|
* libmusicbrainz calculate a preliminary audio signature from that. That audio
|
|
* signature will then be sent over the internet to a musicbrainz.org server
|
|
* which will calculate the TRM for that signature.
|
|
*
|
|
* The TRM element will post a tag message with a #GST_TAG_MUSICBRAINZ_TRMID
|
|
* tag on the bus once the TRM has been calculated (and also send a tag event
|
|
* with that information downstream).
|
|
*
|
|
* <refsect2>
|
|
* <title>Example pipeline</title>
|
|
* |[
|
|
* gst-launch -m filesrc location=somefile.ogg ! decodebin ! audioconvert ! trm ! fakesink
|
|
* ]| calculate the TRM and print the tag message with the TRM ID.
|
|
* </refsect2>
|
|
*/
|
|
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#include <string.h>
|
|
#include <sys/time.h>
|
|
|
|
#include "gsttrm.h"
|
|
|
|
enum
|
|
{
|
|
ARG_0,
|
|
ARG_PROXY_ADDRESS,
|
|
ARG_PROXY_PORT
|
|
};
|
|
|
|
GST_DEBUG_CATEGORY_STATIC (trm_debug);
|
|
#define GST_CAT_DEFAULT trm_debug
|
|
|
|
static const GstElementDetails gst_trm_details =
|
|
GST_ELEMENT_DETAILS ("MusicBrainz TRM generator",
|
|
"Filter/Analyzer/Audio",
|
|
"Compute MusicBrainz TRM Id using libmusicbrainz",
|
|
"Jeremy Simon <jsimon13@yahoo.fr>");
|
|
|
|
GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
|
|
GST_PAD_SRC,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS ("audio/x-raw-int, "
|
|
"endianness = (int) BYTE_ORDER, "
|
|
"signed = (bool) TRUE, "
|
|
"width = (int) { 8, 16 }, "
|
|
"depth = (int) { 8, 16 }, "
|
|
"rate = (int) [ 8000, 96000 ], " "channels = (int) [ 1, 2 ]")
|
|
);
|
|
|
|
|
|
GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
|
|
GST_PAD_SINK,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS ("audio/x-raw-int, "
|
|
"endianness = (int) BYTE_ORDER, "
|
|
"signed = (bool) TRUE, "
|
|
"width = (int) { 8, 16 }, "
|
|
"depth = (int) { 8, 16 }, "
|
|
"rate = (int) [ 8000, 96000 ], " "channels = (int) [ 1, 2 ]")
|
|
);
|
|
|
|
#define DEFAULT_PROXY_ADDRESS NULL
|
|
#define DEFAULT_PROXY_PORT 8080
|
|
|
|
static GstFlowReturn gst_trm_chain (GstPad * pad, GstBuffer * buffer);
|
|
static gboolean gst_trm_setcaps (GstPad * pad, GstCaps * caps);
|
|
|
|
static void gst_trm_set_property (GObject * object, guint prop_id,
|
|
const GValue * value, GParamSpec * pspec);
|
|
static void gst_trm_get_property (GObject * object, guint prop_id,
|
|
GValue * value, GParamSpec * pspec);
|
|
|
|
static GstStateChangeReturn
|
|
gst_trm_change_state (GstElement * element, GstStateChange transition);
|
|
|
|
static void gst_trm_emit_signature (GstTRM * trm);
|
|
|
|
|
|
GST_BOILERPLATE (GstTRM, gst_trm, GstElement, GST_TYPE_ELEMENT);
|
|
|
|
static void
|
|
gst_trm_base_init (gpointer klass)
|
|
{
|
|
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
|
|
|
|
gst_element_class_add_pad_template (element_class,
|
|
gst_static_pad_template_get (&src_template));
|
|
gst_element_class_add_pad_template (element_class,
|
|
gst_static_pad_template_get (&sink_template));
|
|
|
|
gst_element_class_set_details (element_class, &gst_trm_details);
|
|
}
|
|
|
|
static void
|
|
gst_trm_class_init (GstTRMClass * klass)
|
|
{
|
|
GObjectClass *gobject_class;
|
|
GstElementClass *gstelement_class;
|
|
|
|
gobject_class = (GObjectClass *) klass;
|
|
gstelement_class = (GstElementClass *) klass;
|
|
|
|
gobject_class->set_property = gst_trm_set_property;
|
|
gobject_class->get_property = gst_trm_get_property;
|
|
|
|
g_object_class_install_property (gobject_class, ARG_PROXY_ADDRESS,
|
|
g_param_spec_string ("proxy-address", "proxy address", "proxy address",
|
|
DEFAULT_PROXY_ADDRESS, G_PARAM_READWRITE));
|
|
g_object_class_install_property (gobject_class, ARG_PROXY_PORT,
|
|
g_param_spec_uint ("proxy-port", "proxy port", "proxy port",
|
|
1, 65535, DEFAULT_PROXY_PORT, G_PARAM_READWRITE));
|
|
|
|
gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_trm_change_state);
|
|
}
|
|
|
|
static void
|
|
gst_trm_init (GstTRM * trm, GstTRMClass * klass)
|
|
{
|
|
trm->sinkpad = gst_pad_new_from_static_template (&sink_template, "sink");
|
|
gst_pad_set_chain_function (trm->sinkpad, GST_DEBUG_FUNCPTR (gst_trm_chain));
|
|
gst_pad_set_setcaps_function (trm->sinkpad,
|
|
GST_DEBUG_FUNCPTR (gst_trm_setcaps));
|
|
gst_element_add_pad (GST_ELEMENT (trm), trm->sinkpad);
|
|
|
|
trm->srcpad = gst_pad_new_from_static_template (&src_template, "src");
|
|
gst_element_add_pad (GST_ELEMENT (trm), trm->srcpad);
|
|
|
|
trm->proxy_address = g_strdup (DEFAULT_PROXY_ADDRESS);
|
|
trm->proxy_port = DEFAULT_PROXY_PORT;
|
|
|
|
trm->trm = NULL;
|
|
trm->data_available = FALSE;
|
|
trm->signature_available = FALSE;
|
|
}
|
|
|
|
static gboolean
|
|
gst_trm_setcaps (GstPad * pad, GstCaps * caps)
|
|
{
|
|
GstTRM *trm;
|
|
GstStructure *structure;
|
|
const gchar *mimetype;
|
|
gint width;
|
|
|
|
trm = GST_TRM (gst_pad_get_parent (pad));
|
|
|
|
if (!gst_pad_set_caps (trm->srcpad, caps))
|
|
return FALSE;
|
|
|
|
structure = gst_caps_get_structure (caps, 0);
|
|
mimetype = gst_structure_get_name (structure);
|
|
|
|
if (!gst_structure_get_int (structure, "depth", &trm->depth) ||
|
|
!gst_structure_get_int (structure, "width", &width) ||
|
|
!gst_structure_get_int (structure, "channels", &trm->channels) ||
|
|
!gst_structure_get_int (structure, "rate", &trm->rate)) {
|
|
GST_DEBUG_OBJECT (trm, "failed to extract depth, width, channels or rate");
|
|
goto failure;
|
|
}
|
|
|
|
if (trm->depth != width) {
|
|
GST_DEBUG_OBJECT (trm, "depth != width (%d != %d)", trm->depth, width);
|
|
goto failure;
|
|
}
|
|
|
|
trm_SetPCMDataInfo (trm->trm, trm->rate, trm->channels, trm->depth);
|
|
|
|
gst_object_unref (trm);
|
|
return TRUE;
|
|
|
|
/* ERRORS */
|
|
failure:
|
|
{
|
|
GST_WARNING_OBJECT (trm, "FAILED with caps %" GST_PTR_FORMAT, caps);
|
|
gst_object_unref (trm);
|
|
return FALSE;
|
|
}
|
|
}
|
|
|
|
static GstFlowReturn
|
|
gst_trm_chain (GstPad * pad, GstBuffer * buf)
|
|
{
|
|
GstTRM *trm = GST_TRM (GST_PAD_PARENT (pad));
|
|
|
|
if (!trm->data_available) {
|
|
GstFormat tformat = GST_FORMAT_TIME;
|
|
gint64 total_duration;
|
|
|
|
/* FIXME: maybe we should only query this once we have as much data as
|
|
* we need (30secs or so), to get a better estimation of the length in
|
|
* the case of VBR files? */
|
|
if (gst_pad_query_peer_duration (pad, &tformat, &total_duration)) {
|
|
total_duration /= GST_SECOND;
|
|
trm_SetSongLength (trm->trm, total_duration);
|
|
trm->data_available = TRUE;
|
|
}
|
|
}
|
|
|
|
if (!trm->signature_available
|
|
&& trm_GenerateSignature (trm->trm, (char *) GST_BUFFER_DATA (buf),
|
|
GST_BUFFER_SIZE (buf))) {
|
|
GST_DEBUG ("Signature");
|
|
|
|
GST_OBJECT_LOCK (trm);
|
|
if (trm->proxy_address != NULL) {
|
|
if (!trm_SetProxy (trm->trm, trm->proxy_address, trm->proxy_port)) {
|
|
GST_OBJECT_UNLOCK (trm);
|
|
goto proxy_setup_error;
|
|
}
|
|
}
|
|
GST_OBJECT_UNLOCK (trm);
|
|
|
|
gst_trm_emit_signature (trm);
|
|
}
|
|
|
|
return gst_pad_push (trm->srcpad, buf);
|
|
|
|
/* ERRORS */
|
|
proxy_setup_error:
|
|
{
|
|
GST_ELEMENT_ERROR (trm, RESOURCE, SETTINGS, (NULL),
|
|
("Unable to set proxy server for trm lookup"));
|
|
return GST_FLOW_ERROR;
|
|
}
|
|
}
|
|
|
|
static void
|
|
gst_trm_emit_signature (GstTRM * trm)
|
|
{
|
|
char signature[17];
|
|
char ascii_sig[37];
|
|
|
|
if (trm->signature_available)
|
|
return;
|
|
|
|
if (trm_FinalizeSignature (trm->trm, signature, NULL) == 0) {
|
|
GstTagList *tags;
|
|
|
|
trm_ConvertSigToASCII (trm->trm, signature, ascii_sig);
|
|
ascii_sig[36] = '\0';
|
|
GST_DEBUG_OBJECT (trm, "Signature : %s", ascii_sig);
|
|
|
|
tags = gst_tag_list_new ();
|
|
gst_tag_list_add (tags, GST_TAG_MERGE_REPLACE,
|
|
GST_TAG_MUSICBRAINZ_TRMID, ascii_sig, NULL);
|
|
gst_element_found_tags_for_pad (GST_ELEMENT (trm), trm->srcpad, tags);
|
|
|
|
trm->signature_available = TRUE;
|
|
} else {
|
|
/* FIXME: should we be throwing an error here? */
|
|
}
|
|
}
|
|
|
|
|
|
static void
|
|
gst_trm_set_property (GObject * object, guint prop_id,
|
|
const GValue * value, GParamSpec * pspec)
|
|
{
|
|
GstTRM *trm;
|
|
|
|
trm = GST_TRM (object);
|
|
|
|
GST_OBJECT_LOCK (trm);
|
|
|
|
switch (prop_id) {
|
|
case ARG_PROXY_ADDRESS:{
|
|
g_free (trm->proxy_address);
|
|
trm->proxy_address = g_value_dup_string (value);
|
|
break;
|
|
}
|
|
case ARG_PROXY_PORT:{
|
|
trm->proxy_port = g_value_get_uint (value);
|
|
break;
|
|
}
|
|
default:
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
break;
|
|
}
|
|
|
|
GST_OBJECT_UNLOCK (trm);
|
|
}
|
|
|
|
static void
|
|
gst_trm_get_property (GObject * object, guint prop_id, GValue * value,
|
|
GParamSpec * pspec)
|
|
{
|
|
GstTRM *trm;
|
|
|
|
trm = GST_TRM (object);
|
|
|
|
GST_OBJECT_LOCK (trm);
|
|
|
|
switch (prop_id) {
|
|
case ARG_PROXY_ADDRESS:{
|
|
g_value_set_string (value, trm->proxy_address);
|
|
break;
|
|
}
|
|
case ARG_PROXY_PORT:{
|
|
g_value_set_uint (value, trm->proxy_port);
|
|
break;
|
|
}
|
|
default:{
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
break;
|
|
}
|
|
}
|
|
|
|
GST_OBJECT_UNLOCK (trm);
|
|
}
|
|
|
|
static GstStateChangeReturn
|
|
gst_trm_change_state (GstElement * element, GstStateChange transition)
|
|
{
|
|
GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
|
|
GstTRM *trm;
|
|
|
|
trm = GST_TRM (element);
|
|
|
|
switch (transition) {
|
|
case GST_STATE_CHANGE_READY_TO_PAUSED:
|
|
trm->trm = trm_New ();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
|
|
if (ret != GST_STATE_CHANGE_SUCCESS)
|
|
return ret;
|
|
|
|
switch (transition) {
|
|
case GST_STATE_CHANGE_PAUSED_TO_READY:
|
|
trm_Delete (trm->trm);
|
|
trm->trm = NULL;
|
|
trm->data_available = FALSE;
|
|
trm->signature_available = FALSE;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
static gboolean
|
|
plugin_init (GstPlugin * plugin)
|
|
{
|
|
gst_tag_register_musicbrainz_tags ();
|
|
|
|
if (!gst_element_register (plugin, "trm", GST_RANK_NONE, GST_TYPE_TRM))
|
|
return FALSE;
|
|
|
|
GST_DEBUG_CATEGORY_INIT (trm_debug, "trm", 0, "TRM calculation element");
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
|
|
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
|
|
GST_VERSION_MINOR,
|
|
"musicbrainz",
|
|
"A TRM signature producer based on libmusicbrainz",
|
|
plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)
|