diff options
Diffstat (limited to 'gst')
| -rw-r--r-- | gst/cdxaparse/Makefile.am | 11 | ||||
| -rw-r--r-- | gst/cdxaparse/gstcdxaparse.c | 132 | ||||
| -rw-r--r-- | gst/cdxaparse/gstcdxaparse.h | 16 | ||||
| -rw-r--r-- | gst/cdxaparse/gstcdxastrip.c | 411 | ||||
| -rw-r--r-- | gst/cdxaparse/gstcdxastrip.h | 67 | ||||
| -rw-r--r-- | gst/cdxaparse/gstvcdparse.c | 411 | ||||
| -rw-r--r-- | gst/cdxaparse/gstvcdparse.h | 67 |
7 files changed, 1013 insertions, 102 deletions
diff --git a/gst/cdxaparse/Makefile.am b/gst/cdxaparse/Makefile.am index 411579cc..ef9315b7 100644 --- a/gst/cdxaparse/Makefile.am +++ b/gst/cdxaparse/Makefile.am @@ -1,11 +1,12 @@ +plugin_LTLIBRARIES = libgstcdxaparse.la -plugin_LTLIBRARIES = \ - libgstcdxaparse.la - -libgstcdxaparse_la_SOURCES = gstcdxaparse.c +libgstcdxaparse_la_SOURCES = \ + gstcdxaparse.c \ + gstcdxastrip.c noinst_HEADERS = \ - gstcdxaparse.h + gstcdxaparse.h \ + gstcdxastrip.h libgstcdxaparse_la_CFLAGS = $(GST_CFLAGS) libgstcdxaparse_la_LIBADD = diff --git a/gst/cdxaparse/gstcdxaparse.c b/gst/cdxaparse/gstcdxaparse.c index 472f6482..ef9f521f 100644 --- a/gst/cdxaparse/gstcdxaparse.c +++ b/gst/cdxaparse/gstcdxaparse.c @@ -18,13 +18,13 @@ * Boston, MA 02111-1307, USA. */ - #ifdef HAVE_CONFIG_H #include "config.h" #endif #include <string.h> #include "gstcdxaparse.h" +#include "gstcdxastrip.h" #include "gst/riff/riff-ids.h" #include "gst/riff/riff-media.h" @@ -32,9 +32,8 @@ static void gst_cdxaparse_base_init (gpointer g_class); static void gst_cdxaparse_class_init (GstCDXAParseClass * klass); static void gst_cdxaparse_init (GstCDXAParse * cdxaparse); -static GstElementStateReturn gst_cdxaparse_change_state (GstElement * element); - static void gst_cdxaparse_loop (GstElement * element); +static GstElementStateReturn gst_cdxaparse_change_state (GstElement * element); static GstStaticPadTemplate sink_template_factory = GST_STATIC_PAD_TEMPLATE ("sink", @@ -50,20 +49,7 @@ GST_STATIC_PAD_TEMPLATE ("src", GST_STATIC_CAPS ("video/mpeg, " "systemstream = (boolean) TRUE") ); -/* CDXAParse signals and args */ -enum -{ - /* FILL ME */ - LAST_SIGNAL -}; - -enum -{ - ARG_0, - /* FILL ME */ -}; - -static GstElementClass *parent_class = NULL; +static GstRiffReadClass *parent_class = NULL; GType gst_cdxaparse_get_type (void) @@ -87,6 +73,7 @@ gst_cdxaparse_get_type (void) g_type_register_static (GST_TYPE_RIFF_READ, "GstCDXAParse", &cdxaparse_info, 0); } + return cdxaparse_type; } @@ -113,11 +100,7 @@ gst_cdxaparse_base_init (gpointer g_class) static void gst_cdxaparse_class_init (GstCDXAParseClass * klass) { - GstElementClass *gstelement_class; - GObjectClass *object_class; - - gstelement_class = (GstElementClass *) klass; - object_class = (GObjectClass *) klass; + GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass); parent_class = g_type_class_ref (GST_TYPE_RIFF_READ); @@ -127,23 +110,23 @@ gst_cdxaparse_class_init (GstCDXAParseClass * klass) static void gst_cdxaparse_init (GstCDXAParse * cdxaparse) { - /* sink */ + /* FIXME: this element needs to be event aware */ + cdxaparse->sinkpad = gst_pad_new_from_template (gst_static_pad_template_get (&sink_template_factory), "sink"); - gst_element_add_pad (GST_ELEMENT (cdxaparse), cdxaparse->sinkpad); GST_RIFF_READ (cdxaparse)->sinkpad = cdxaparse->sinkpad; - - - gst_element_set_loop_function (GST_ELEMENT (cdxaparse), gst_cdxaparse_loop); - - cdxaparse->state = GST_CDXAPARSE_START; + gst_element_add_pad (GST_ELEMENT (cdxaparse), cdxaparse->sinkpad); cdxaparse->srcpad = gst_pad_new_from_template (gst_static_pad_template_get (&src_template_factory), "src"); + /* FIXME: event, query */ gst_element_add_pad (GST_ELEMENT (cdxaparse), cdxaparse->srcpad); + gst_element_set_loop_function (GST_ELEMENT (cdxaparse), gst_cdxaparse_loop); + + cdxaparse->state = GST_CDXAPARSE_START; cdxaparse->seek_pending = FALSE; cdxaparse->seek_offset = 0; } @@ -211,23 +194,6 @@ gst_cdxaparse_other (GstCDXAParse * cdxa) return TRUE; } -/* - -A sector is 2352 bytes long and is composed of: - -! sync ! header ! subheader ! data ... ! edc ! -! 12 bytes ! 4 bytes ! 8 bytes ! 2324 bytes ! 4 bytes ! -!-------------------------------------------------------! - -We parse the data out of it and send it to the srcpad. - -sync : 00 FF FF FF FF FF FF FF FF FF FF 00 -header : hour minute second mode -sub-header : track channel sub_mode coding repeat (4 bytes) -edc : checksum - -*/ - static void gst_cdxaparse_loop (GstElement * element) { @@ -235,32 +201,49 @@ gst_cdxaparse_loop (GstElement * element) GstRiffRead *riff = GST_RIFF_READ (cdxa); if (cdxa->state == GST_CDXAPARSE_DATA) { - if (cdxa->dataleft > 0) { + gint sync; guint32 got_bytes, desired; GstBuffer *buf = NULL; GstBuffer *outbuf = NULL; - desired = GST_CDXA_SECTOR_SIZE; + /* resync */ + desired = cdxa->dataleft; + if (desired > 1024) + desired = 1024; + if (gst_bytestream_peek (riff->bs, &buf, desired) != desired) { + GST_ELEMENT_ERROR (element, RESOURCE, READ, (NULL), (NULL)); + return; + } + sync = gst_cdxastrip_sync (buf); + if (sync == -1) { + gst_bytestream_flush_fast (riff->bs, desired); + cdxa->dataleft -= desired; + return; + } + if (sync > 0) { + if (cdxa->dataleft < sync) + sync = cdxa->dataleft; + gst_bytestream_flush_fast (riff->bs, sync); + cdxa->dataleft -= sync; + if (cdxa->dataleft == 0) + return; + } + /* get data */ + desired = GST_CDXA_SECTOR_SIZE; if (!(buf = gst_riff_read_element_data (riff, desired, &got_bytes))) return; /* Skip CDXA headers, only keep data */ - outbuf = - gst_buffer_create_sub (buf, GST_CDXA_HEADER_SIZE, GST_CDXA_DATA_SIZE); - - gst_buffer_unref (buf); + outbuf = gst_cdxastrip_strip (buf); gst_pad_push (cdxa->srcpad, GST_DATA (outbuf)); - cdxa->byteoffset += got_bytes; - if (got_bytes < cdxa->dataleft) { + if (got_bytes < cdxa->dataleft) cdxa->dataleft -= got_bytes; - return; - } else { + else cdxa->dataleft = 0; - cdxa->state = GST_CDXAPARSE_OTHER; - } + return; } else { cdxa->state = GST_CDXAPARSE_OTHER; } @@ -268,30 +251,23 @@ gst_cdxaparse_loop (GstElement * element) switch (cdxa->state) { case GST_CDXAPARSE_START: - if (!gst_cdxaparse_stream_init (cdxa)) { + if (!gst_cdxaparse_stream_init (cdxa)) return; - } - cdxa->state = GST_CDXAPARSE_FMT; /* fall-through */ case GST_CDXAPARSE_FMT: - if (!gst_cdxaparse_fmt (cdxa)) { + if (!gst_cdxaparse_fmt (cdxa)) return; - } - cdxa->state = GST_CDXAPARSE_OTHER; /* fall-through */ case GST_CDXAPARSE_OTHER: - if (!gst_cdxaparse_other (cdxa)) { + if (!gst_cdxaparse_other (cdxa)) return; - } - break; case GST_CDXAPARSE_DATA: - default: g_assert_not_reached (); } @@ -303,27 +279,15 @@ gst_cdxaparse_change_state (GstElement * element) GstCDXAParse *cdxa = GST_CDXAPARSE (element); switch (GST_STATE_TRANSITION (element)) { - case GST_STATE_NULL_TO_READY: - break; - case GST_STATE_READY_TO_PAUSED: cdxa->state = GST_CDXAPARSE_START; break; - - case GST_STATE_PAUSED_TO_PLAYING: - break; - - case GST_STATE_PLAYING_TO_PAUSED: - break; - case GST_STATE_PAUSED_TO_READY: cdxa->state = GST_CDXAPARSE_START; - cdxa->seek_pending = FALSE; cdxa->seek_offset = 0; break; - - case GST_STATE_READY_TO_NULL: + default: break; } @@ -336,12 +300,14 @@ gst_cdxaparse_change_state (GstElement * element) static gboolean plugin_init (GstPlugin * plugin) { - if (!gst_library_load ("riff")) { + if (!gst_library_load ("riff") || !gst_library_load ("gstbytestream")) { return FALSE; } return gst_element_register (plugin, "cdxaparse", GST_RANK_PRIMARY, - GST_TYPE_CDXAPARSE); + GST_TYPE_CDXAPARSE) && + gst_element_register (plugin, "cdxastrip", + GST_RANK_PRIMARY, GST_TYPE_CDXASTRIP); } GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, diff --git a/gst/cdxaparse/gstcdxaparse.h b/gst/cdxaparse/gstcdxaparse.h index 1ad618a1..0177b94b 100644 --- a/gst/cdxaparse/gstcdxaparse.h +++ b/gst/cdxaparse/gstcdxaparse.h @@ -18,7 +18,6 @@ * Boston, MA 02111-1307, USA. */ - #ifndef __GST_CDXAPARSE_H__ #define __GST_CDXAPARSE_H__ @@ -26,9 +25,7 @@ #include "gst/riff/riff-ids.h" #include "gst/riff/riff-read.h" -#ifdef __cplusplus -extern "C" { -#endif /* __cplusplus */ +G_BEGIN_DECLS #define GST_TYPE_CDXAPARSE \ (gst_cdxaparse_get_type()) @@ -41,10 +38,6 @@ extern "C" { #define GST_IS_CDXAPARSE_CLASS(obj) \ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CDXAPARSE)) -#define GST_CDXA_SECTOR_SIZE 2352 -#define GST_CDXA_DATA_SIZE 2324 -#define GST_CDXA_HEADER_SIZE 24 - typedef enum { GST_CDXAPARSE_START, GST_CDXAPARSE_FMT, @@ -65,7 +58,6 @@ struct _GstCDXAParse { GstCDXAParseState state; guint64 dataleft, datasize, datastart; - int byteoffset; gboolean seek_pending; guint64 seek_offset; @@ -77,10 +69,6 @@ struct _GstCDXAParseClass { GType gst_cdxaparse_get_type (void); -#ifdef __cplusplus -} -#endif /* __cplusplus */ - +G_END_DECLS #endif /* __GST_CDXAPARSE_H__ */ - diff --git a/gst/cdxaparse/gstcdxastrip.c b/gst/cdxaparse/gstcdxastrip.c new file mode 100644 index 00000000..312c3028 --- /dev/null +++ b/gst/cdxaparse/gstcdxastrip.c @@ -0,0 +1,411 @@ +/* GStreamer CDXA sync strippper + * Copyright (C) 2004 Ronald Bultje <rbultje@ronald.bitfreak.net> + * + * 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. + */ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <string.h> +#include <gst/gst.h> +#include "gstcdxastrip.h" + +static void gst_cdxastrip_base_init (GstCDXAStripClass * klass); +static void gst_cdxastrip_class_init (GstCDXAStripClass * klass); +static void gst_cdxastrip_init (GstCDXAStrip * cdxastrip); + +static const GstEventMask *gst_cdxastrip_get_event_mask (GstPad * pad); +static gboolean gst_cdxastrip_handle_src_event (GstPad * pad, GstEvent * event); +static const GstFormat *gst_cdxastrip_get_src_formats (GstPad * pad); +static const GstQueryType *gst_cdxastrip_get_src_query_types (GstPad * pad); +static gboolean gst_cdxastrip_handle_src_query (GstPad * pad, + GstQueryType type, GstFormat * format, gint64 * value); + +static void gst_cdxastrip_chain (GstPad * pad, GstData * data); +static GstElementStateReturn gst_cdxastrip_change_state (GstElement * element); + +static GstStaticPadTemplate sink_template_factory = +GST_STATIC_PAD_TEMPLATE ("sink", + GST_PAD_SINK, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("video/x-vcd") + ); + +static GstStaticPadTemplate src_template_factory = +GST_STATIC_PAD_TEMPLATE ("src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("video/mpeg, " "systemstream = (boolean) TRUE") + ); + +static GstElementClass *parent_class = NULL; + +GType +gst_cdxastrip_get_type (void) +{ + static GType cdxastrip_type = 0; + + if (!cdxastrip_type) { + static const GTypeInfo cdxastrip_info = { + sizeof (GstCDXAStripClass), + (GBaseInitFunc) gst_cdxastrip_base_init, + NULL, + (GClassInitFunc) gst_cdxastrip_class_init, + NULL, + NULL, + sizeof (GstCDXAStrip), + 0, + (GInstanceInitFunc) gst_cdxastrip_init, + }; + + cdxastrip_type = + g_type_register_static (GST_TYPE_ELEMENT, "GstCDXAStrip", + &cdxastrip_info, 0); + } + + return cdxastrip_type; +} + +static void +gst_cdxastrip_base_init (GstCDXAStripClass * klass) +{ + GstElementClass *element_class = GST_ELEMENT_CLASS (klass); + static GstElementDetails gst_cdxastrip_details = + GST_ELEMENT_DETAILS ("vcd parser", + "Codec/Parser", + "Strip (S)VCD stream from its syncheaders", + "Ronald Bultje <rbultje@ronald.bitfreak.net>"); + + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&sink_template_factory)); + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&src_template_factory)); + + gst_element_class_set_details (element_class, &gst_cdxastrip_details); +} + +static void +gst_cdxastrip_class_init (GstCDXAStripClass * klass) +{ + GstElementClass *element_class = GST_ELEMENT_CLASS (klass); + + parent_class = g_type_class_ref (GST_TYPE_ELEMENT); + + element_class->change_state = gst_cdxastrip_change_state; +} + +static void +gst_cdxastrip_init (GstCDXAStrip * cdxastrip) +{ + GST_FLAG_SET (cdxastrip, GST_ELEMENT_EVENT_AWARE); + + cdxastrip->sinkpad = + gst_pad_new_from_template (gst_static_pad_template_get + (&sink_template_factory), "sink"); + gst_pad_set_chain_function (cdxastrip->sinkpad, gst_cdxastrip_chain); + gst_element_add_pad (GST_ELEMENT (cdxastrip), cdxastrip->sinkpad); + + cdxastrip->srcpad = + gst_pad_new_from_template (gst_static_pad_template_get + (&src_template_factory), "src"); + gst_pad_set_formats_function (cdxastrip->srcpad, + gst_cdxastrip_get_src_formats); + gst_pad_set_event_mask_function (cdxastrip->srcpad, + gst_cdxastrip_get_event_mask); + gst_pad_set_event_function (cdxastrip->srcpad, + gst_cdxastrip_handle_src_event); + gst_pad_set_query_type_function (cdxastrip->srcpad, + gst_cdxastrip_get_src_query_types); + gst_pad_set_query_function (cdxastrip->srcpad, + gst_cdxastrip_handle_src_query); + gst_element_add_pad (GST_ELEMENT (cdxastrip), cdxastrip->srcpad); +} + +/* + * Stuff. + */ + +static const GstFormat * +gst_cdxastrip_get_src_formats (GstPad * pad) +{ + static const GstFormat formats[] = { + GST_FORMAT_BYTES, + 0 + }; + + return formats; +} + +static const GstQueryType * +gst_cdxastrip_get_src_query_types (GstPad * pad) +{ + static const GstQueryType types[] = { + GST_QUERY_TOTAL, + GST_QUERY_POSITION, + 0 + }; + + return types; +} + +static gboolean +gst_cdxastrip_handle_src_query (GstPad * pad, + GstQueryType type, GstFormat * format, gint64 * value) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (gst_pad_get_parent (pad)); + + if (!gst_pad_query (GST_PAD_PEER (cdxa->sinkpad), type, format, value)) + return FALSE; + + if (*format != GST_FORMAT_BYTES) + return TRUE; + + switch (type) { + case GST_QUERY_TOTAL: + case GST_QUERY_POSITION:{ + gint num, rest; + + num = *value / GST_CDXA_SECTOR_SIZE; + rest = *value % GST_CDXA_SECTOR_SIZE; + + *value = num * GST_CDXA_DATA_SIZE; + if (rest > GST_CDXA_HEADER_SIZE) { + if (rest >= GST_CDXA_HEADER_SIZE + GST_CDXA_DATA_SIZE) + *value += GST_CDXA_DATA_SIZE; + else + *value += rest - GST_CDXA_HEADER_SIZE; + } + break; + } + default: + break; + } + + return TRUE; +} + +static const GstEventMask * +gst_cdxastrip_get_event_mask (GstPad * pad) +{ + static const GstEventMask masks[] = { + {GST_EVENT_SEEK, GST_SEEK_METHOD_SET | GST_SEEK_FLAG_KEY_UNIT}, + {0,} + }; + + return masks; +} + +static gboolean +gst_cdxastrip_handle_src_event (GstPad * pad, GstEvent * event) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (gst_pad_get_parent (pad)); + + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_SEEK: + switch (GST_EVENT_SEEK_FORMAT (event)) { + case GST_FORMAT_BYTES:{ + GstEvent *new; + gint64 off; + gint num, rest; + + off = GST_EVENT_SEEK_OFFSET (event); + num = off / GST_CDXA_DATA_SIZE; + rest = off % GST_CDXA_DATA_SIZE; + off = num * GST_CDXA_SECTOR_SIZE; + if (rest > 0) + off += rest + GST_CDXA_HEADER_SIZE; + new = gst_event_new_seek (GST_EVENT_SEEK_TYPE (event), off); + gst_event_unref (event); + event = new; + } + default: + break; + } + break; + default: + break; + } + + return gst_pad_send_event (GST_PAD_PEER (cdxa->sinkpad), event); +} + +/* + * A sector is 2352 bytes long and is composed of: + * + * ! sync ! header ! subheader ! data ... ! edc ! + * ! 12 bytes ! 4 bytes ! 8 bytes ! 2324 bytes ! 4 bytes ! + * !-------------------------------------------------------! + * + * We strip the data out of it and send it to the srcpad. + * + * sync : 00 FF FF FF FF FF FF FF FF FF FF 00 + * header : hour minute second mode + * sub-header : track channel sub_mode coding repeat (4 bytes) + * edc : checksum + */ + +GstBuffer * +gst_cdxastrip_strip (GstBuffer * buf) +{ + GstBuffer *sub; + + g_assert (GST_BUFFER_SIZE (buf) >= GST_CDXA_SECTOR_SIZE); + + /* Skip CDXA headers, only keep data. + * FIXME: check sync, resync, ... */ + sub = gst_buffer_create_sub (buf, GST_CDXA_HEADER_SIZE, GST_CDXA_DATA_SIZE); + gst_buffer_unref (buf); + + return sub; +} + +/* + * -1 = no sync (discard buffer), + * otherwise offset indicates syncpoint in buffer. + */ + +gint +gst_cdxastrip_sync (GstBuffer * buf) +{ + guint size, off = 0; + guint8 *data; + + for (size = GST_BUFFER_SIZE (buf), data = GST_BUFFER_DATA (buf); + size >= 12; size--, data++, off++) { + /* we could do a checksum check as well, but who cares... */ + if (!memcmp (data, "\000\377\377\377\377\377\377\377\377\377\377\000", 12)) + return off; + } + + return -1; +} + +/* + * Do stuff. + */ + +static void +gst_cdxastrip_handle_event (GstCDXAStrip * cdxa, GstEvent * event) +{ + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_DISCONTINUOUS:{ + gint64 new_off, off; + + if (gst_event_discont_get_value (event, GST_FORMAT_BYTES, &new_off)) { + GstEvent *new; + gint chunknum, rest; + + chunknum = new_off / GST_CDXA_SECTOR_SIZE; + rest = new_off % GST_CDXA_SECTOR_SIZE; + off = chunknum * GST_CDXA_DATA_SIZE; + if (rest > GST_CDXA_HEADER_SIZE) { + if (rest >= GST_CDXA_HEADER_SIZE + GST_CDXA_DATA_SIZE) + off += GST_CDXA_DATA_SIZE; + else + off += rest - GST_CDXA_HEADER_SIZE; + } + new = gst_event_new_discontinuous (GST_EVENT_DISCONT_NEW_MEDIA (event), + GST_FORMAT_BYTES, new_off, GST_FORMAT_UNDEFINED); + gst_event_unref (event); + event = new; + } + gst_pad_event_default (cdxa->sinkpad, event); + break; + } + case GST_EVENT_FLUSH: + if (cdxa->cache) { + gst_buffer_unref (cdxa->cache); + cdxa->cache = NULL; + } + /* fall-through */ + default: + gst_pad_event_default (cdxa->sinkpad, event); + break; + } +} + +static void +gst_cdxastrip_chain (GstPad * pad, GstData * data) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (gst_pad_get_parent (pad)); + GstBuffer *buf, *sub; + gint sync; + + if (GST_IS_EVENT (data)) { + gst_cdxastrip_handle_event (cdxa, GST_EVENT (data)); + return; + } + + buf = GST_BUFFER (data); + if (cdxa->cache) { + buf = gst_buffer_join (cdxa->cache, buf); + } + cdxa->cache = NULL; + + while (buf && GST_BUFFER_SIZE (buf) >= GST_CDXA_SECTOR_SIZE) { + /* sync */ + sync = gst_cdxastrip_sync (buf); + if (sync < 0) { + gst_buffer_unref (buf); + return; + } + sub = gst_buffer_create_sub (buf, sync, GST_BUFFER_SIZE (buf) - sync); + gst_buffer_unref (buf); + buf = sub; + if (GST_BUFFER_SIZE (buf) < GST_CDXA_SECTOR_SIZE) + break; + + /* one chunk */ + sub = gst_cdxastrip_strip (gst_buffer_ref (buf)); + gst_pad_push (cdxa->srcpad, GST_DATA (sub)); + + /* cache */ + if (GST_BUFFER_SIZE (buf) != GST_CDXA_SECTOR_SIZE) { + sub = gst_buffer_create_sub (buf, GST_CDXA_SECTOR_SIZE, + GST_BUFFER_SIZE (buf) - GST_CDXA_SECTOR_SIZE); + } else { + sub = NULL; + } + gst_buffer_unref (buf); + buf = sub; + } + + cdxa->cache = buf; +} + +static GstElementStateReturn +gst_cdxastrip_change_state (GstElement * element) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (element); + + switch (GST_STATE_TRANSITION (element)) { + case GST_STATE_PAUSED_TO_READY: + if (cdxa->cache) { + gst_buffer_unref (cdxa->cache); + cdxa->cache = NULL; + } + break; + default: + break; + } + + if (parent_class->change_state) + return parent_class->change_state (element); + + return GST_STATE_SUCCESS; +} diff --git a/gst/cdxaparse/gstcdxastrip.h b/gst/cdxaparse/gstcdxastrip.h new file mode 100644 index 00000000..59cf4ab6 --- /dev/null +++ b/gst/cdxaparse/gstcdxastrip.h @@ -0,0 +1,67 @@ +/* GStreamer CDXA sync strippper + * Copyright (C) 2004 Ronald Bultje <rbultje@ronald.bitfreak.net> + * + * 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. + */ + +#ifndef __GST_CDXASTRIP_H__ +#define __GST_CDXASTRIP_H__ + +#include <gst/gst.h> + +G_BEGIN_DECLS + +#define GST_TYPE_CDXASTRIP \ + (gst_cdxastrip_get_type()) +#define GST_CDXASTRIP(obj) \ + (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_CDXASTRIP,GstCDXAStrip)) +#define GST_CDXASTRIP_CLASS(klass) \ + (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_CDXASTRIP,GstCDXAStrip)) +#define GST_IS_CDXASTRIP(obj) \ + (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_CDXASTRIP)) +#define GST_IS_CDXASTRIP_CLASS(obj) \ + (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CDXASTRIP)) + +#define GST_CDXA_SECTOR_SIZE 2352 +#define GST_CDXA_DATA_SIZE 2324 +#define GST_CDXA_HEADER_SIZE 24 + +typedef struct _GstCDXAStrip GstCDXAStrip; +typedef struct _GstCDXAStripClass GstCDXAStripClass; + +struct _GstCDXAStrip { + GstElement parent; + + /* pads */ + GstPad *sinkpad, *srcpad; + GstBuffer *cache; +}; + +struct _GstCDXAStripClass { + GstElementClass parent_class; +}; + +GType gst_cdxastrip_get_type (void); + +/* + * Also useful for CDXAparse. + */ +GstBuffer * gst_cdxastrip_strip (GstBuffer * buf); +gint gst_cdxastrip_sync (GstBuffer * buf); + +G_END_DECLS + +#endif /* __GST_CDXASTRIP_H__ */ diff --git a/gst/cdxaparse/gstvcdparse.c b/gst/cdxaparse/gstvcdparse.c new file mode 100644 index 00000000..312c3028 --- /dev/null +++ b/gst/cdxaparse/gstvcdparse.c @@ -0,0 +1,411 @@ +/* GStreamer CDXA sync strippper + * Copyright (C) 2004 Ronald Bultje <rbultje@ronald.bitfreak.net> + * + * 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. + */ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <string.h> +#include <gst/gst.h> +#include "gstcdxastrip.h" + +static void gst_cdxastrip_base_init (GstCDXAStripClass * klass); +static void gst_cdxastrip_class_init (GstCDXAStripClass * klass); +static void gst_cdxastrip_init (GstCDXAStrip * cdxastrip); + +static const GstEventMask *gst_cdxastrip_get_event_mask (GstPad * pad); +static gboolean gst_cdxastrip_handle_src_event (GstPad * pad, GstEvent * event); +static const GstFormat *gst_cdxastrip_get_src_formats (GstPad * pad); +static const GstQueryType *gst_cdxastrip_get_src_query_types (GstPad * pad); +static gboolean gst_cdxastrip_handle_src_query (GstPad * pad, + GstQueryType type, GstFormat * format, gint64 * value); + +static void gst_cdxastrip_chain (GstPad * pad, GstData * data); +static GstElementStateReturn gst_cdxastrip_change_state (GstElement * element); + +static GstStaticPadTemplate sink_template_factory = +GST_STATIC_PAD_TEMPLATE ("sink", + GST_PAD_SINK, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("video/x-vcd") + ); + +static GstStaticPadTemplate src_template_factory = +GST_STATIC_PAD_TEMPLATE ("src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("video/mpeg, " "systemstream = (boolean) TRUE") + ); + +static GstElementClass *parent_class = NULL; + +GType +gst_cdxastrip_get_type (void) +{ + static GType cdxastrip_type = 0; + + if (!cdxastrip_type) { + static const GTypeInfo cdxastrip_info = { + sizeof (GstCDXAStripClass), + (GBaseInitFunc) gst_cdxastrip_base_init, + NULL, + (GClassInitFunc) gst_cdxastrip_class_init, + NULL, + NULL, + sizeof (GstCDXAStrip), + 0, + (GInstanceInitFunc) gst_cdxastrip_init, + }; + + cdxastrip_type = + g_type_register_static (GST_TYPE_ELEMENT, "GstCDXAStrip", + &cdxastrip_info, 0); + } + + return cdxastrip_type; +} + +static void +gst_cdxastrip_base_init (GstCDXAStripClass * klass) +{ + GstElementClass *element_class = GST_ELEMENT_CLASS (klass); + static GstElementDetails gst_cdxastrip_details = + GST_ELEMENT_DETAILS ("vcd parser", + "Codec/Parser", + "Strip (S)VCD stream from its syncheaders", + "Ronald Bultje <rbultje@ronald.bitfreak.net>"); + + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&sink_template_factory)); + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&src_template_factory)); + + gst_element_class_set_details (element_class, &gst_cdxastrip_details); +} + +static void +gst_cdxastrip_class_init (GstCDXAStripClass * klass) +{ + GstElementClass *element_class = GST_ELEMENT_CLASS (klass); + + parent_class = g_type_class_ref (GST_TYPE_ELEMENT); + + element_class->change_state = gst_cdxastrip_change_state; +} + +static void +gst_cdxastrip_init (GstCDXAStrip * cdxastrip) +{ + GST_FLAG_SET (cdxastrip, GST_ELEMENT_EVENT_AWARE); + + cdxastrip->sinkpad = + gst_pad_new_from_template (gst_static_pad_template_get + (&sink_template_factory), "sink"); + gst_pad_set_chain_function (cdxastrip->sinkpad, gst_cdxastrip_chain); + gst_element_add_pad (GST_ELEMENT (cdxastrip), cdxastrip->sinkpad); + + cdxastrip->srcpad = + gst_pad_new_from_template (gst_static_pad_template_get + (&src_template_factory), "src"); + gst_pad_set_formats_function (cdxastrip->srcpad, + gst_cdxastrip_get_src_formats); + gst_pad_set_event_mask_function (cdxastrip->srcpad, + gst_cdxastrip_get_event_mask); + gst_pad_set_event_function (cdxastrip->srcpad, + gst_cdxastrip_handle_src_event); + gst_pad_set_query_type_function (cdxastrip->srcpad, + gst_cdxastrip_get_src_query_types); + gst_pad_set_query_function (cdxastrip->srcpad, + gst_cdxastrip_handle_src_query); + gst_element_add_pad (GST_ELEMENT (cdxastrip), cdxastrip->srcpad); +} + +/* + * Stuff. + */ + +static const GstFormat * +gst_cdxastrip_get_src_formats (GstPad * pad) +{ + static const GstFormat formats[] = { + GST_FORMAT_BYTES, + 0 + }; + + return formats; +} + +static const GstQueryType * +gst_cdxastrip_get_src_query_types (GstPad * pad) +{ + static const GstQueryType types[] = { + GST_QUERY_TOTAL, + GST_QUERY_POSITION, + 0 + }; + + return types; +} + +static gboolean +gst_cdxastrip_handle_src_query (GstPad * pad, + GstQueryType type, GstFormat * format, gint64 * value) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (gst_pad_get_parent (pad)); + + if (!gst_pad_query (GST_PAD_PEER (cdxa->sinkpad), type, format, value)) + return FALSE; + + if (*format != GST_FORMAT_BYTES) + return TRUE; + + switch (type) { + case GST_QUERY_TOTAL: + case GST_QUERY_POSITION:{ + gint num, rest; + + num = *value / GST_CDXA_SECTOR_SIZE; + rest = *value % GST_CDXA_SECTOR_SIZE; + + *value = num * GST_CDXA_DATA_SIZE; + if (rest > GST_CDXA_HEADER_SIZE) { + if (rest >= GST_CDXA_HEADER_SIZE + GST_CDXA_DATA_SIZE) + *value += GST_CDXA_DATA_SIZE; + else + *value += rest - GST_CDXA_HEADER_SIZE; + } + break; + } + default: + break; + } + + return TRUE; +} + +static const GstEventMask * +gst_cdxastrip_get_event_mask (GstPad * pad) +{ + static const GstEventMask masks[] = { + {GST_EVENT_SEEK, GST_SEEK_METHOD_SET | GST_SEEK_FLAG_KEY_UNIT}, + {0,} + }; + + return masks; +} + +static gboolean +gst_cdxastrip_handle_src_event (GstPad * pad, GstEvent * event) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (gst_pad_get_parent (pad)); + + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_SEEK: + switch (GST_EVENT_SEEK_FORMAT (event)) { + case GST_FORMAT_BYTES:{ + GstEvent *new; + gint64 off; + gint num, rest; + + off = GST_EVENT_SEEK_OFFSET (event); + num = off / GST_CDXA_DATA_SIZE; + rest = off % GST_CDXA_DATA_SIZE; + off = num * GST_CDXA_SECTOR_SIZE; + if (rest > 0) + off += rest + GST_CDXA_HEADER_SIZE; + new = gst_event_new_seek (GST_EVENT_SEEK_TYPE (event), off); + gst_event_unref (event); + event = new; + } + default: + break; + } + break; + default: + break; + } + + return gst_pad_send_event (GST_PAD_PEER (cdxa->sinkpad), event); +} + +/* + * A sector is 2352 bytes long and is composed of: + * + * ! sync ! header ! subheader ! data ... ! edc ! + * ! 12 bytes ! 4 bytes ! 8 bytes ! 2324 bytes ! 4 bytes ! + * !-------------------------------------------------------! + * + * We strip the data out of it and send it to the srcpad. + * + * sync : 00 FF FF FF FF FF FF FF FF FF FF 00 + * header : hour minute second mode + * sub-header : track channel sub_mode coding repeat (4 bytes) + * edc : checksum + */ + +GstBuffer * +gst_cdxastrip_strip (GstBuffer * buf) +{ + GstBuffer *sub; + + g_assert (GST_BUFFER_SIZE (buf) >= GST_CDXA_SECTOR_SIZE); + + /* Skip CDXA headers, only keep data. + * FIXME: check sync, resync, ... */ + sub = gst_buffer_create_sub (buf, GST_CDXA_HEADER_SIZE, GST_CDXA_DATA_SIZE); + gst_buffer_unref (buf); + + return sub; +} + +/* + * -1 = no sync (discard buffer), + * otherwise offset indicates syncpoint in buffer. + */ + +gint +gst_cdxastrip_sync (GstBuffer * buf) +{ + guint size, off = 0; + guint8 *data; + + for (size = GST_BUFFER_SIZE (buf), data = GST_BUFFER_DATA (buf); + size >= 12; size--, data++, off++) { + /* we could do a checksum check as well, but who cares... */ + if (!memcmp (data, "\000\377\377\377\377\377\377\377\377\377\377\000", 12)) + return off; + } + + return -1; +} + +/* + * Do stuff. + */ + +static void +gst_cdxastrip_handle_event (GstCDXAStrip * cdxa, GstEvent * event) +{ + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_DISCONTINUOUS:{ + gint64 new_off, off; + + if (gst_event_discont_get_value (event, GST_FORMAT_BYTES, &new_off)) { + GstEvent *new; + gint chunknum, rest; + + chunknum = new_off / GST_CDXA_SECTOR_SIZE; + rest = new_off % GST_CDXA_SECTOR_SIZE; + off = chunknum * GST_CDXA_DATA_SIZE; + if (rest > GST_CDXA_HEADER_SIZE) { + if (rest >= GST_CDXA_HEADER_SIZE + GST_CDXA_DATA_SIZE) + off += GST_CDXA_DATA_SIZE; + else + off += rest - GST_CDXA_HEADER_SIZE; + } + new = gst_event_new_discontinuous (GST_EVENT_DISCONT_NEW_MEDIA (event), + GST_FORMAT_BYTES, new_off, GST_FORMAT_UNDEFINED); + gst_event_unref (event); + event = new; + } + gst_pad_event_default (cdxa->sinkpad, event); + break; + } + case GST_EVENT_FLUSH: + if (cdxa->cache) { + gst_buffer_unref (cdxa->cache); + cdxa->cache = NULL; + } + /* fall-through */ + default: + gst_pad_event_default (cdxa->sinkpad, event); + break; + } +} + +static void +gst_cdxastrip_chain (GstPad * pad, GstData * data) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (gst_pad_get_parent (pad)); + GstBuffer *buf, *sub; + gint sync; + + if (GST_IS_EVENT (data)) { + gst_cdxastrip_handle_event (cdxa, GST_EVENT (data)); + return; + } + + buf = GST_BUFFER (data); + if (cdxa->cache) { + buf = gst_buffer_join (cdxa->cache, buf); + } + cdxa->cache = NULL; + + while (buf && GST_BUFFER_SIZE (buf) >= GST_CDXA_SECTOR_SIZE) { + /* sync */ + sync = gst_cdxastrip_sync (buf); + if (sync < 0) { + gst_buffer_unref (buf); + return; + } + sub = gst_buffer_create_sub (buf, sync, GST_BUFFER_SIZE (buf) - sync); + gst_buffer_unref (buf); + buf = sub; + if (GST_BUFFER_SIZE (buf) < GST_CDXA_SECTOR_SIZE) + break; + + /* one chunk */ + sub = gst_cdxastrip_strip (gst_buffer_ref (buf)); + gst_pad_push (cdxa->srcpad, GST_DATA (sub)); + + /* cache */ + if (GST_BUFFER_SIZE (buf) != GST_CDXA_SECTOR_SIZE) { + sub = gst_buffer_create_sub (buf, GST_CDXA_SECTOR_SIZE, + GST_BUFFER_SIZE (buf) - GST_CDXA_SECTOR_SIZE); + } else { + sub = NULL; + } + gst_buffer_unref (buf); + buf = sub; + } + + cdxa->cache = buf; +} + +static GstElementStateReturn +gst_cdxastrip_change_state (GstElement * element) +{ + GstCDXAStrip *cdxa = GST_CDXASTRIP (element); + + switch (GST_STATE_TRANSITION (element)) { + case GST_STATE_PAUSED_TO_READY: + if (cdxa->cache) { + gst_buffer_unref (cdxa->cache); + cdxa->cache = NULL; + } + break; + default: + break; + } + + if (parent_class->change_state) + return parent_class->change_state (element); + + return GST_STATE_SUCCESS; +} diff --git a/gst/cdxaparse/gstvcdparse.h b/gst/cdxaparse/gstvcdparse.h new file mode 100644 index 00000000..59cf4ab6 --- /dev/null +++ b/gst/cdxaparse/gstvcdparse.h @@ -0,0 +1,67 @@ +/* GStreamer CDXA sync strippper + * Copyright (C) 2004 Ronald Bultje <rbultje@ronald.bitfreak.net> + * + * 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. + */ + +#ifndef __GST_CDXASTRIP_H__ +#define __GST_CDXASTRIP_H__ + +#include <gst/gst.h> + +G_BEGIN_DECLS + +#define GST_TYPE_CDXASTRIP \ + (gst_cdxastrip_get_type()) +#define GST_CDXASTRIP(obj) \ + (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_CDXASTRIP,GstCDXAStrip)) +#define GST_CDXASTRIP_CLASS(klass) \ + (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_CDXASTRIP,GstCDXAStrip)) +#define GST_IS_CDXASTRIP(obj) \ + (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_CDXASTRIP)) +#define GST_IS_CDXASTRIP_CLASS(obj) \ + (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CDXASTRIP)) + +#define GST_CDXA_SECTOR_SIZE 2352 +#define GST_CDXA_DATA_SIZE 2324 +#define GST_CDXA_HEADER_SIZE 24 + +typedef struct _GstCDXAStrip GstCDXAStrip; +typedef struct _GstCDXAStripClass GstCDXAStripClass; + +struct _GstCDXAStrip { + GstElement parent; + + /* pads */ + GstPad *sinkpad, *srcpad; + GstBuffer *cache; +}; + +struct _GstCDXAStripClass { + GstElementClass parent_class; +}; + +GType gst_cdxastrip_get_type (void); + +/* + * Also useful for CDXAparse. + */ +GstBuffer * gst_cdxastrip_strip (GstBuffer * buf); +gint gst_cdxastrip_sync (GstBuffer * buf); + +G_END_DECLS + +#endif /* __GST_CDXASTRIP_H__ */ |