summaryrefslogtreecommitdiffstats
path: root/gst/mpegvideoparse
diff options
context:
space:
mode:
Diffstat (limited to 'gst/mpegvideoparse')
-rw-r--r--gst/mpegvideoparse/Makefile.am9
-rw-r--r--gst/mpegvideoparse/mpegpacketiser.c438
-rw-r--r--gst/mpegvideoparse/mpegpacketiser.h116
-rw-r--r--gst/mpegvideoparse/mpegvideoparse.c629
-rw-r--r--gst/mpegvideoparse/mpegvideoparse.h79
-rw-r--r--gst/mpegvideoparse/mpegvideoparse.vcproj148
6 files changed, 1419 insertions, 0 deletions
diff --git a/gst/mpegvideoparse/Makefile.am b/gst/mpegvideoparse/Makefile.am
new file mode 100644
index 00000000..4f935788
--- /dev/null
+++ b/gst/mpegvideoparse/Makefile.am
@@ -0,0 +1,9 @@
+
+plugin_LTLIBRARIES = libgstmpegvideoparse.la
+
+libgstmpegvideoparse_la_SOURCES = mpegvideoparse.c mpegpacketiser.c
+libgstmpegvideoparse_la_CFLAGS = $(GST_CFLAGS)
+libgstmpegvideoparse_la_LIBADD = $(GST_BASE_LIBS) $(GST_LIBS)
+libgstmpegvideoparse_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
+
+noinst_HEADERS = mpegvideoparse.h mpegpacketiser.h
diff --git a/gst/mpegvideoparse/mpegpacketiser.c b/gst/mpegvideoparse/mpegpacketiser.c
new file mode 100644
index 00000000..5c054ed8
--- /dev/null
+++ b/gst/mpegvideoparse/mpegpacketiser.c
@@ -0,0 +1,438 @@
+/* GStreamer
+ * Copyright (C) <2007> Jan Schmidt <thaytan@mad.scientist.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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <string.h>
+
+/* The purpose of the packetiser is to parse the incoming buffers into 'blocks'
+ * that consist of the stream split at certain packet boundaries. It splits into
+ * a new block at the start of a GOP, Picture or Sequence packet.
+ * A GOP or sequence header always starts a new block. A Picture
+ * header starts a new block only if the previous packet was not a GOP -
+ * otherwise it is accumulated with the GOP */
+#include "mpegpacketiser.h"
+
+static void collect_packets (MPEGPacketiser * p, GstBuffer * buf);
+
+void
+mpeg_packetiser_init (MPEGPacketiser * p)
+{
+ p->adapter = gst_adapter_new ();
+ p->n_blocks = 0;
+ p->blocks = NULL;
+ mpeg_packetiser_flush (p);
+}
+
+void
+mpeg_packetiser_free (MPEGPacketiser * p)
+{
+ gst_object_unref (p->adapter);
+ g_free (p->blocks);
+}
+
+void
+mpeg_packetiser_add_buf (MPEGPacketiser * p, GstBuffer * buf)
+{
+ /* Add the buffer to our pool */
+ gst_adapter_push (p->adapter, buf);
+
+ /* Store the timestamp to apply to the next picture that gets collected */
+ if (p->cur_buf_ts != GST_CLOCK_TIME_NONE) {
+ p->prev_buf_ts = p->cur_buf_ts;
+ }
+ p->cur_buf_ts = GST_BUFFER_TIMESTAMP (buf);
+
+ /* read what new packets we have in this buffer */
+ collect_packets (p, buf);
+
+ p->tracked_offset += GST_BUFFER_SIZE (buf);
+}
+
+void
+mpeg_packetiser_flush (MPEGPacketiser * p)
+{
+ gst_adapter_clear (p->adapter);
+ p->adapter_offset = 0;
+
+ p->sync_word = 0xffffffff;
+ p->tracked_offset = 0;
+ p->prev_sync_packet = MPEG_PACKET_NONE;
+
+ /* Reset our block info */
+ p->cur_block_idx = -1;
+ p->first_block_idx = -1;
+
+ /* Clear any pending timestamps */
+ p->prev_buf_ts = GST_CLOCK_TIME_NONE;
+ p->cur_buf_ts = GST_CLOCK_TIME_NONE;
+}
+
+guint8 *
+mpeg_find_start_code (guint32 * sync_word, guint8 * cur, guint8 * end)
+{
+ guint32 code = *sync_word;
+
+ if (G_UNLIKELY (cur == NULL))
+ return NULL;
+
+ while (cur < end) {
+ code <<= 8;
+
+ if (code == 0x00000100) {
+ /* Reset the sync word accumulator */
+ *sync_word = 0xffffffff;
+ return cur;
+ }
+
+ /* Add the next available byte to the collected sync word */
+ code |= *cur++;
+ }
+
+ *sync_word = code;
+ return NULL;
+}
+
+/* When we need to reallocate the blocks array, grow it by this much */
+#define BLOCKS_INCREMENT 5
+
+/* Get the index of the next unfilled block in the buffer. May need to grow
+ * the array first */
+gint
+get_next_free_block (MPEGPacketiser * p)
+{
+ gint next;
+ gboolean grow_array = FALSE;
+
+ /* Get a free block from the blocks array. May need to grow
+ * the array first */
+ if (p->n_blocks == 0) {
+ grow_array = TRUE;
+ next = 0;
+ } else {
+ if (G_UNLIKELY (p->cur_block_idx == -1)) {
+ next = 0;
+ } else {
+ next = p->cur_block_idx;
+ if (((next + 1) % p->n_blocks) == p->first_block_idx)
+ grow_array = TRUE;
+ }
+ }
+
+ if (grow_array) {
+ gint old_n_blocks = p->n_blocks;
+
+ p->n_blocks += BLOCKS_INCREMENT;
+
+ p->blocks = g_realloc (p->blocks, sizeof (MPEGBlockInfo) * p->n_blocks);
+
+ /* Now we may need to move some data up to the end of the array, if the
+ * cur_block_idx is before the first_block_idx in the array. */
+ if (p->cur_block_idx < p->first_block_idx) {
+#if 0
+ g_print ("Moving %d blocks from idx %d to idx %d of %d\n",
+ old_n_blocks - p->first_block_idx,
+ p->first_block_idx, p->first_block_idx + BLOCKS_INCREMENT,
+ p->n_blocks);
+#endif
+
+ memmove (p->blocks + p->first_block_idx + BLOCKS_INCREMENT,
+ p->blocks + p->first_block_idx,
+ sizeof (MPEGBlockInfo) * (old_n_blocks - p->first_block_idx));
+ p->first_block_idx += BLOCKS_INCREMENT;
+ }
+ }
+
+ return next;
+}
+
+/* Mark the current block as complete */
+static void
+complete_current_block (MPEGPacketiser * p, guint64 offset)
+{
+ MPEGBlockInfo *block;
+
+ if (G_UNLIKELY (p->cur_block_idx == -1))
+ return; /* No block is in progress */
+
+ /* If we're pointing at the first_block_idx, then we're about to re-complete
+ * a previously completed buffer. Not allowed, because the array should have
+ * been previously expanded to cope via a get_next_free_block call. */
+ g_assert (p->cur_block_idx != p->first_block_idx);
+
+ /* Get the appropriate entry from the blocks array */
+ g_assert (p->blocks != NULL && p->cur_block_idx < p->n_blocks);
+ block = p->blocks + p->cur_block_idx;
+
+ /* Extend the block length to the current offset */
+ g_assert (block->offset < offset);
+ block->length = offset - block->offset;
+
+#if 0
+ g_print ("Completed block of type 0x%02x @ offset %" G_GUINT64_FORMAT
+ " with size %u\n", block->first_pack_type, block->offset, block->length);
+#endif
+
+ /* If this is the first complete block, set first_block_idx to be this block */
+ if (p->first_block_idx == -1)
+ p->first_block_idx = p->cur_block_idx;
+
+ /* Update the statistics regarding the packet we're handling */
+ if (block->flags & MPEG_BLOCK_FLAG_PICTURE)
+ p->n_pictures++;
+
+ /* And advance the cur_block_idx ptr to the next slot */
+ p->cur_block_idx = (p->cur_block_idx + 1) % p->n_blocks;
+}
+
+/* Accumulate the packet up to 'offset' into the current block
+ * (discard if no block is in progress). Update the block info
+ * to indicate what is in it. */
+static void
+append_to_current_block (MPEGPacketiser * p, guint64 offset, guint8 pack_type)
+{
+ MPEGBlockInfo *block;
+
+ if (G_UNLIKELY (p->cur_block_idx == -1))
+ return; /* No block in progress, drop this packet */
+
+ /* Get the appropriate entry from the blocks array */
+ g_assert (p->blocks != NULL && p->cur_block_idx < p->n_blocks);
+ block = p->blocks + p->cur_block_idx;
+
+ /* Extend the block length to the current offset */
+ g_assert (block->offset < offset);
+ block->length = offset - block->offset;
+
+ /* Update flags */
+ switch (pack_type) {
+ case MPEG_PACKET_SEQUENCE:
+ g_assert (!(block->flags &
+ (MPEG_BLOCK_FLAG_GOP | MPEG_BLOCK_FLAG_PICTURE)));
+ block->flags |= MPEG_BLOCK_FLAG_SEQUENCE;
+ break;
+ case MPEG_PACKET_GOP:
+ block->flags |= MPEG_BLOCK_FLAG_GOP;
+ break;
+ case MPEG_PACKET_PICTURE:
+ block->flags |= MPEG_BLOCK_FLAG_PICTURE;
+ break;
+ default:
+ break;
+ }
+}
+
+static void
+start_new_block (MPEGPacketiser * p, guint64 offset, guint8 pack_type)
+{
+ gint block_idx;
+ MPEGBlockInfo *block;
+
+ /* First, append data up to the start of this block to the current one, but
+ * not including this packet info */
+ complete_current_block (p, offset);
+
+ block_idx = get_next_free_block (p);
+ /* FIXME: Retrieve the appropriate entry from the blocks array */
+ /* Get the appropriate entry from the blocks array */
+ g_assert (p->blocks != NULL && block_idx < p->n_blocks);
+ block = p->blocks + block_idx;
+
+ /* Init the block */
+ block->first_pack_type = pack_type;
+ block->offset = offset;
+ block->ts = GST_CLOCK_TIME_NONE;
+
+ /* Initially, the length is 0. It grows as we encounter new sync headers */
+ block->length = 0;
+ switch (pack_type) {
+ case MPEG_PACKET_SEQUENCE:
+ block->flags = MPEG_BLOCK_FLAG_SEQUENCE;
+ break;
+ case MPEG_PACKET_GOP:
+ block->flags = MPEG_BLOCK_FLAG_GOP;
+ break;
+ case MPEG_PACKET_PICTURE:
+ block->flags = MPEG_BLOCK_FLAG_PICTURE;
+ break;
+ default:
+ /* We don't start blocks with other packet types */
+ g_assert_not_reached ();
+ }
+
+ /* Make this our current block */
+ p->cur_block_idx = block_idx;
+
+#if 0
+ g_print ("Started new block in slot %d with first pack 0x%02x @ offset %"
+ G_GUINT64_FORMAT "\n", block_idx, block->first_pack_type, block->offset);
+#endif
+
+}
+
+static void
+handle_packet (MPEGPacketiser * p, guint64 offset, guint8 pack_type)
+{
+ switch (pack_type) {
+ case MPEG_PACKET_SEQUENCE:
+ case MPEG_PACKET_GOP:
+ /* Start a new block */
+ start_new_block (p, offset, pack_type);
+ p->prev_sync_packet = pack_type;
+ break;
+ case MPEG_PACKET_PICTURE:{
+ MPEGBlockInfo *block;
+ GstClockTime ts;
+
+ /* Start a new block unless the previous sync packet was a GOP */
+ if (p->prev_sync_packet != MPEG_PACKET_GOP) {
+ start_new_block (p, offset, pack_type);
+ } else {
+ append_to_current_block (p, offset, pack_type);
+ }
+ p->prev_sync_packet = pack_type;
+
+ /* We have a picture packet, apply any pending timestamp. The logic here
+ * is that the timestamp on any incoming buffer needs to apply to the next
+ * picture packet where the _first_byte_ of the sync word starts after the
+ * packet boundary. We track the ts from the current buffer and a
+ * previous buffer in order to handle this correctly. It would still be
+ * possible to get it wrong if there was a PES packet smaller than 3 bytes
+ * but anyone that does that can suck it. */
+ if (offset >= p->tracked_offset) {
+ /* sync word started within this buffer - take the cur ts */
+ ts = p->cur_buf_ts;
+ p->cur_buf_ts = GST_CLOCK_TIME_NONE;
+ p->prev_buf_ts = GST_CLOCK_TIME_NONE;
+ } else {
+ /* sync word started in a previous buffer - take the old ts */
+ ts = p->prev_buf_ts;
+ p->prev_buf_ts = GST_CLOCK_TIME_NONE;
+ }
+
+ /* If we didn't drop the packet, set the timestamp on it */
+ if (G_LIKELY (p->cur_block_idx != -1)) {
+ block = p->blocks + p->cur_block_idx;
+ block->ts = ts;
+#if 0
+ g_print ("Picture @ offset %" G_GINT64_FORMAT " has ts %"
+ GST_TIME_FORMAT "\n", block->offset, GST_TIME_ARGS (block->ts));
+#endif
+ }
+ break;
+ }
+ default:
+ append_to_current_block (p, offset, pack_type);
+ break;
+ }
+}
+
+static void
+collect_packets (MPEGPacketiser * p, GstBuffer * buf)
+{
+ guint8 *cur;
+ guint8 *end = GST_BUFFER_DATA (buf) + GST_BUFFER_SIZE (buf);
+
+ cur = mpeg_find_start_code (&(p->sync_word), GST_BUFFER_DATA (buf), end);
+ while (cur != NULL) {
+ /* Calculate the offset as tracked since the last flush. Note that cur
+ * points to the last byte of the sync word, so we adjust by -3 to get the
+ * first byte */
+ guint64 offset = p->tracked_offset + (cur - GST_BUFFER_DATA (buf) - 3);
+
+ handle_packet (p, offset, *cur);
+ cur = mpeg_find_start_code (&(p->sync_word), cur, end);
+ }
+}
+
+void
+mpeg_packetiser_handle_eos (MPEGPacketiser * p)
+{
+ /* Append any remaining data to the current block */
+ if (p->tracked_offset > 0) {
+ complete_current_block (p, p->tracked_offset);
+ }
+}
+
+/* Returns a pointer to the block info for the completed block at the
+ * head of the queue, and extracts the bytes from the adapter if requested.
+ * Caller should move to the next block by calling mpeg_packetiser_next_block
+ * afterward.
+ */
+MPEGBlockInfo *
+mpeg_packetiser_get_block (MPEGPacketiser * p, GstBuffer ** buf)
+{
+ MPEGBlockInfo *block;
+
+ if (buf)
+ *buf = NULL;
+
+ if (G_UNLIKELY (p->first_block_idx == -1)) {
+ return NULL; /* No complete blocks to discard */
+ }
+
+ /* p->first_block_idx can't get set != -1 unless some block storage got
+ * allocated */
+ g_assert (p->blocks != NULL && p->n_blocks != 0);
+ block = p->blocks + p->first_block_idx;
+
+ /* Can only get the buffer out once, so we'll return NULL on later attempts */
+ if (buf != NULL && block->length > 0 && p->adapter_offset <= block->offset) {
+ /* Kick excess data out of the adapter */
+ if (p->adapter_offset < block->offset) {
+ guint64 to_flush = block->offset - p->adapter_offset;
+
+ g_assert (gst_adapter_available (p->adapter) >= to_flush);
+ gst_adapter_flush (p->adapter, to_flush);
+ p->adapter_offset += to_flush;
+ }
+
+ g_assert (gst_adapter_available (p->adapter) >= block->length);
+ *buf = gst_adapter_take_buffer (p->adapter, block->length);
+ p->adapter_offset += block->length;
+
+ GST_BUFFER_TIMESTAMP (*buf) = block->ts;
+ }
+ return block;
+}
+
+/* Advance the first_block pointer to discard a completed block
+ * from the queue */
+void
+mpeg_packetiser_next_block (MPEGPacketiser * p)
+{
+ gint next;
+ MPEGBlockInfo *block;
+
+ block = mpeg_packetiser_get_block (p, NULL);
+ if (G_UNLIKELY (block == NULL))
+ return; /* No complete blocks to discard */
+
+ /* Update the statistics regarding the block we're discarding */
+ if (block->flags & MPEG_BLOCK_FLAG_PICTURE)
+ p->n_pictures--;
+
+ next = (p->first_block_idx + 1) % p->n_blocks;
+ if (next == p->cur_block_idx)
+ p->first_block_idx = -1; /* Discarding the last block */
+ else
+ p->first_block_idx = next;
+}
diff --git a/gst/mpegvideoparse/mpegpacketiser.h b/gst/mpegvideoparse/mpegpacketiser.h
new file mode 100644
index 00000000..202c6d9c
--- /dev/null
+++ b/gst/mpegvideoparse/mpegpacketiser.h
@@ -0,0 +1,116 @@
+/* GStreamer
+ * Copyright (C) <2007> Jan Schmidt <thaytan@mad.scientist.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.
+ */
+#ifndef __MPEGPACKETISER_H__
+#define __MPEGPACKETISER_H__
+
+#include <gst/gst.h>
+#include <gst/base/gstadapter.h>
+
+typedef struct MPEGPacketiser MPEGPacketiser;
+typedef struct MPEGBlockInfo MPEGBlockInfo;
+
+/* Packet ID codes for different packet types we
+ * care about */
+#define MPEG_PACKET_PICTURE 0x00
+#define MPEG_PACKET_SLICE_MIN 0x01
+#define MPEG_PACKET_SLICE_MAX 0xaf
+#define MPEG_PACKET_SEQUENCE 0xb3
+#define MPEG_PACKET_EXTENSION 0xb5
+#define MPEG_PACKET_SEQUENCE_END 0xb7
+#define MPEG_PACKET_GOP 0xb8
+#define MPEG_PACKET_NONE 0xff
+
+/* Extension codes we care about */
+#define MPEG_PACKET_EXT_SEQUENCE 0x01
+#define MPEG_PACKET_EXT_SEQUENCE_DISPLAY 0x02
+#define MPEG_PACKET_EXT_QUANT_MATRIX 0x03
+
+/* Flags indicating what type of packets are in this block, some are mutually
+ * exclusive though - ie, sequence packs are accumulated separately. GOP &
+ * Picture may occur together or separately */
+#define MPEG_BLOCK_FLAG_SEQUENCE 0x01
+#define MPEG_BLOCK_FLAG_PICTURE 0x02
+#define MPEG_BLOCK_FLAG_GOP 0x04
+
+struct MPEGBlockInfo {
+ guint8 first_pack_type;
+ guint8 flags;
+
+ guint64 offset;
+ guint32 length;
+
+ GstClockTime ts;
+};
+
+struct MPEGPacketiser {
+ GstAdapter *adapter;
+ /* position in the adapter */
+ guint64 adapter_offset;
+
+ /* Sync word accumulator */
+ guint32 sync_word;
+
+ /* Offset since the last flush (unrelated to incoming buffer offsets) */
+ guint64 tracked_offset;
+
+ /* Number of picture packets currently collected */
+ guint n_pictures;
+
+ /* 2 sets of timestamps + offsets used to mark picture blocks
+ * The first is used when a sync word overlaps packet boundaries
+ * and comes from some buffer in the past. The next one comes from current
+ * buffer. These are only ever valid when handling streams from a demuxer,
+ * of course. */
+ GstClockTime prev_buf_ts;
+ GstClockTime cur_buf_ts;
+
+ /* MPEG id of the previous SEQUENCE, PICTURE or GOP packet.
+ MPEG_PACKET_NONE after a flush */
+ guint8 prev_sync_packet;
+
+ /* Indices into the blocks array. cur_block_idx is where we're writing and
+ indicates the end of the populated block entries.
+ first_block_idx is the read ptr. It may be -1 to indicate there are no
+ complete blocks available */
+ gint cur_block_idx;
+ gint first_block_idx;
+
+ /* An array of MPEGBlockInfo entries, used as a growable circular buffer
+ * indexed by cur_block_idx and bounded by last_block_idx */
+ gint n_blocks;
+ MPEGBlockInfo *blocks;
+};
+
+guint8 *mpeg_find_start_code (guint32 *sync_word, guint8 *cur, guint8 *end);
+
+void mpeg_packetiser_init (MPEGPacketiser *p);
+void mpeg_packetiser_free (MPEGPacketiser *p);
+
+void mpeg_packetiser_add_buf (MPEGPacketiser *p, GstBuffer *buf);
+void mpeg_packetiser_handle_eos (MPEGPacketiser *p);
+
+void mpeg_packetiser_flush (MPEGPacketiser *p);
+
+/* Get the blockinfo and buffer for the block at the head of the queue */
+MPEGBlockInfo *mpeg_packetiser_get_block (MPEGPacketiser *p, GstBuffer **buf);
+
+/* Advance to the next data block */
+void mpeg_packetiser_next_block (MPEGPacketiser *p);
+
+#endif
diff --git a/gst/mpegvideoparse/mpegvideoparse.c b/gst/mpegvideoparse/mpegvideoparse.c
new file mode 100644
index 00000000..18464507
--- /dev/null
+++ b/gst/mpegvideoparse/mpegvideoparse.c
@@ -0,0 +1,629 @@
+/* GStreamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) <2007> Jan Schmidt <thaytan@mad.scientist.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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <string.h>
+#include "mpegvideoparse.h"
+
+/* FIXME: there are still some things to do in this element.
+ * + Handle Sequence Display Extension to output the display size
+ * rather than the encoded size.
+ * + Collect a list of regions and the sequence headers that apply
+ * to each region so that we properly handle SEQUENCE_END followed
+ * by a new sequence.
+ * + At least detect when the sequence changes and error out instead.
+ * + Do all the other stuff (documentation, tests) to get it into
+ * ugly or good.
+ * + low priority:
+ * - handle seeking in raw elementary streams
+ * - calculate timestamps for all un-timestamped frames, taking into
+ * account frame re-ordering. Doing this probably requires introducing
+ * an extra end-to-end delay, however so might not be really desirable.
+ */
+GST_DEBUG_CATEGORY_STATIC (mpv_parse_debug);
+#define GST_CAT_DEFAULT mpv_parse_debug
+
+/* elementfactory information */
+static GstElementDetails mpegvideoparse_details =
+GST_ELEMENT_DETAILS ("MPEG video elementary stream parser",
+ "Codec/Parser/Video",
+ "Parses and frames MPEG-1 and MPEG-2 elementary video streams",
+ "Wim Taymans <wim.taymans@chello.be>\n"
+ "Jan Schmidt <thaytan@mad.scientist.com>");
+
+static GstStaticPadTemplate src_template =
+GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC,
+ GST_PAD_ALWAYS,
+ GST_STATIC_CAPS ("video/mpeg, "
+ "mpegversion = (int) [ 1, 2 ], "
+ "parsed = (boolean) true, "
+ "systemstream = (boolean) false, "
+ "width = (int) [ 16, 4096 ], "
+ "height = (int) [ 16, 4096 ], "
+ "pixel-aspect-ratio = (fraction) [ 0/1, MAX ], "
+ "framerate = (fraction) [ 0/1, MAX ]")
+ );
+
+static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
+ GST_PAD_SINK,
+ GST_PAD_ALWAYS,
+ GST_STATIC_CAPS ("video/mpeg, "
+ "mpegversion = (int) [ 1, 2 ], "
+ "parsed = (boolean) false, " "systemstream = (boolean) false")
+ );
+
+/* MpegVideoParse signals and args */
+enum
+{
+ /* FILL ME */
+ LAST_SIGNAL
+};
+
+enum
+{
+ ARG_0
+ /* FILL ME */
+};
+
+static void gst_mpegvideoparse_class_init (MpegVideoParseClass * klass);
+static void gst_mpegvideoparse_base_init (MpegVideoParseClass * klass);
+static void gst_mpegvideoparse_init (MpegVideoParse * mpegvideoparse);
+static void gst_mpegvideoparse_dispose (MpegVideoParse * mpegvideoparse);
+
+static GstFlowReturn gst_mpegvideoparse_chain (GstPad * pad, GstBuffer * buf);
+static gboolean mpv_parse_sink_event (GstPad * pad, GstEvent * event);
+static void gst_mpegvideoparse_flush (MpegVideoParse * mpegvideoparse);
+static GstStateChangeReturn
+gst_mpegvideoparse_change_state (GstElement * element,
+ GstStateChange transition);
+
+static GstElementClass *parent_class = NULL;
+
+/*static guint gst_mpegvideoparse_signals[LAST_SIGNAL] = { 0 }; */
+
+GType
+mpegvideoparse_get_type (void)
+{
+ static GType mpegvideoparse_type = 0;
+
+ if (!mpegvideoparse_type) {
+ static const GTypeInfo mpegvideoparse_info = {
+ sizeof (MpegVideoParseClass),
+ (GBaseInitFunc) gst_mpegvideoparse_base_init,
+ NULL,
+ (GClassInitFunc) gst_mpegvideoparse_class_init,
+ NULL,
+ NULL,
+ sizeof (MpegVideoParse),
+ 0,
+ (GInstanceInitFunc) gst_mpegvideoparse_init,
+ };
+
+ mpegvideoparse_type =
+ g_type_register_static (GST_TYPE_ELEMENT, "MpegVideoParse",
+ &mpegvideoparse_info, 0);
+ }
+ return mpegvideoparse_type;
+}
+
+static void
+gst_mpegvideoparse_base_init (MpegVideoParseClass * 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, &mpegvideoparse_details);
+}
+
+static void
+gst_mpegvideoparse_class_init (MpegVideoParseClass * klass)
+{
+ GObjectClass *gobject_class;
+ GstElementClass *gstelement_class;
+
+ gstelement_class = (GstElementClass *) klass;
+ gobject_class = G_OBJECT_CLASS (klass);
+
+ parent_class = g_type_class_peek_parent (klass);
+
+ gobject_class->dispose = (GObjectFinalizeFunc) (gst_mpegvideoparse_dispose);
+ gstelement_class->change_state = gst_mpegvideoparse_change_state;
+}
+
+static void
+mpv_parse_reset (MpegVideoParse * mpegvideoparse)
+{
+ mpegvideoparse->seq_hdr.mpeg_version = 0;
+ mpegvideoparse->seq_hdr.width = mpegvideoparse->seq_hdr.height = -1;
+ mpegvideoparse->seq_hdr.fps_n = mpegvideoparse->seq_hdr.par_w = 0;
+ mpegvideoparse->seq_hdr.fps_d = mpegvideoparse->seq_hdr.par_h = 1;
+}
+
+static void
+gst_mpegvideoparse_init (MpegVideoParse * mpegvideoparse)
+{
+ mpegvideoparse->sinkpad =
+ gst_pad_new_from_static_template (&sink_template, "sink");
+ gst_pad_set_chain_function (mpegvideoparse->sinkpad,
+ gst_mpegvideoparse_chain);
+ gst_pad_set_event_function (mpegvideoparse->sinkpad, mpv_parse_sink_event);
+ gst_element_add_pad (GST_ELEMENT (mpegvideoparse), mpegvideoparse->sinkpad);
+
+ mpegvideoparse->srcpad =
+ gst_pad_new_from_static_template (&src_template, "src");
+ gst_pad_use_fixed_caps (mpegvideoparse->srcpad);
+ gst_element_add_pad (GST_ELEMENT (mpegvideoparse), mpegvideoparse->srcpad);
+
+ mpeg_packetiser_init (&mpegvideoparse->packer);
+
+ mpv_parse_reset (mpegvideoparse);
+}
+
+void
+gst_mpegvideoparse_dispose (MpegVideoParse * mpegvideoparse)
+{
+ mpeg_packetiser_free (&mpegvideoparse->packer);
+ gst_buffer_replace (&mpegvideoparse->seq_hdr_buf, NULL);
+}
+
+/* Set the Pixel Aspect Ratio in our hdr from a DAR code in the data */
+static void
+set_par_from_dar (MPEGSeqHdr * hdr, guint8 asr_code)
+{
+ /* Pixel_width = DAR_width * display_vertical_size */
+ /* Pixel_height = DAR_height * display_horizontal_size */
+ switch (asr_code) {
+ case 0x02: /* 3:4 DAR = 4:3 pixels */
+ hdr->par_w = 4 * hdr->height;
+ hdr->par_h = 3 * hdr->width;
+ break;
+ case 0x03: /* 9:16 DAR */
+ hdr->par_w = 16 * hdr->height;
+ hdr->par_h = 9 * hdr->width;
+ break;
+ case 0x04: /* 1:2.21 DAR */
+ hdr->par_w = 221 * hdr->height;
+ hdr->par_h = 100 * hdr->width;
+ break;
+ case 0x01: /* Square pixels */
+ default:
+ hdr->par_w = hdr->par_h = 1;
+ break;
+ }
+}
+
+static void
+set_fps_from_code (MPEGSeqHdr * hdr, guint8 fps_code)
+{
+ const gint framerates[][2] = {
+ {30, 1}, {24000, 1001}, {24, 1}, {25, 1},
+ {30000, 1001}, {30, 1}, {50, 1}, {60000, 1001},
+ {60, 1}, {30, 1}
+ };
+
+ if (fps_code < 10) {
+ hdr->fps_n = framerates[fps_code][0];
+ hdr->fps_d = framerates[fps_code][1];
+ } else {
+ /* Force a valid framerate */
+ hdr->fps_n = 30;
+ hdr->fps_d = 1;
+ }
+}
+
+static void
+mpegvideoparse_parse_seq (MpegVideoParse * mpegvideoparse, GstBuffer * buf)
+{
+ MPEGSeqHdr new_hdr;
+ guint32 code;
+ guint8 dar_idx, fps_idx;
+ gint seq_data_length;
+ guint32 sync_word = 0xffffffff;
+ guint8 *cur, *end;
+ gboolean constrained_flag;
+ gboolean load_intra_flag;
+ gboolean load_non_intra_flag;
+
+ cur = GST_BUFFER_DATA (buf);
+ end = GST_BUFFER_DATA (buf) + GST_BUFFER_SIZE (buf);
+
+ if (GST_BUFFER_SIZE (buf) < 12)
+ return; /* Too small to be a sequence header */
+
+ seq_data_length = 12; /* minimum length. */
+
+ /* Skip the sync word */
+ cur += 4;
+
+ /* Parse the MPEG 1 bits */
+ new_hdr.mpeg_version = 1;
+
+ code = GST_READ_UINT32_BE (cur);
+ new_hdr.width = (code >> 20) & 0xfff;
+ new_hdr.height = (code >> 8) & 0xfff;
+
+ dar_idx = (code >> 4) & 0xf;
+ set_par_from_dar (&new_hdr, dar_idx);
+ fps_idx = code & 0xf;
+ set_fps_from_code (&new_hdr, fps_idx);
+
+ constrained_flag = (cur[7] >> 2) & 0x01;
+ load_intra_flag = (cur[7] >> 1) & 0x01;
+ if (load_intra_flag) {
+ seq_data_length += 64; /* 8 rows of 8 bytes of intra matrix */
+ if (GST_BUFFER_SIZE (buf) < seq_data_length)
+ return;
+ cur += 64;
+ }
+
+ load_non_intra_flag = cur[7] & 0x01;
+ if (load_non_intra_flag) {
+ seq_data_length += 64; /* 8 rows of 8 bytes of non-intra matrix */
+ if (GST_BUFFER_SIZE (buf) < seq_data_length)
+ return;
+ cur += 64;
+ }
+
+ /* Skip the rest of the MPEG-1 header */
+ cur += 8;
+
+ /* Read MPEG-2 sequence extensions */
+ cur = mpeg_find_start_code (&sync_word, cur, end);
+ while (cur != NULL) {
+ /* Cur points at the last byte of the start code */
+ if (cur[0] == MPEG_PACKET_EXTENSION) {
+ guint8 ext_code;
+
+ if ((end - cur - 1) < 1)
+ return; /* short extension packet extension */
+
+ ext_code = cur[1] >> 4;
+ if (ext_code == MPEG_PACKET_EXT_SEQUENCE) {
+ /* Parse a Sequence Extension */
+ guint8 horiz_size_ext, vert_size_ext;
+ guint8 fps_n_ext, fps_d_ext;
+
+ if ((end - cur - 1) < 7)
+ /* need at least 10 bytes, minus 3 for the start code 000001 */
+ return;
+
+ horiz_size_ext = ((cur[2] << 1) & 0x02) | ((cur[3] >> 7) & 0x01);
+ vert_size_ext = (cur[3] >> 5) & 0x03;
+ fps_n_ext = (cur[6] >> 5) & 0x03;
+ fps_d_ext = cur[6] & 0x1f;
+
+ new_hdr.fps_n *= (fps_n_ext + 1);
+ new_hdr.fps_d *= (fps_d_ext + 1);
+ new_hdr.width += (horiz_size_ext << 12);
+ new_hdr.height += (vert_size_ext << 12);
+ }
+
+ new_hdr.mpeg_version = 2;
+ }
+ cur = mpeg_find_start_code (&sync_word, cur, end);
+ }
+
+ if (new_hdr.par_w != mpegvideoparse->seq_hdr.par_w ||
+ new_hdr.par_h != mpegvideoparse->seq_hdr.par_h ||
+ new_hdr.fps_n != mpegvideoparse->seq_hdr.fps_n ||
+ new_hdr.fps_d != mpegvideoparse->seq_hdr.fps_d ||
+ new_hdr.width != mpegvideoparse->seq_hdr.width ||
+ new_hdr.height != mpegvideoparse->seq_hdr.height ||
+ new_hdr.mpeg_version != mpegvideoparse->seq_hdr.mpeg_version) {
+ GstCaps *caps;
+ GstBuffer *seq_buf;
+
+ /* Store the entire sequence header + sequence header extension
+ for output as codec_data */
+ seq_buf = gst_buffer_copy (buf);
+ gst_buffer_replace (&mpegvideoparse->seq_hdr_buf, seq_buf);
+ gst_buffer_unref (seq_buf);
+
+ /* And update the new_hdr into our stored version */
+ memcpy (&mpegvideoparse->seq_hdr, &new_hdr, sizeof (MPEGSeqHdr));
+
+ caps = gst_caps_new_simple ("video/mpeg",
+ "systemstream", G_TYPE_BOOLEAN, FALSE,
+ "parsed", G_TYPE_BOOLEAN, TRUE,
+ "mpegversion", G_TYPE_INT, new_hdr.mpeg_version,
+ "width", G_TYPE_INT, new_hdr.width,
+ "height", G_TYPE_INT, new_hdr.height,
+ "framerate", GST_TYPE_FRACTION, new_hdr.fps_n, new_hdr.fps_d,
+ "pixel-aspect-ratio", GST_TYPE_FRACTION, new_hdr.par_w, new_hdr.par_h,
+ "codec_data", GST_TYPE_BUFFER, seq_buf, NULL);
+
+ GST_DEBUG ("New mpegvideoparse caps: %" GST_PTR_FORMAT, caps);
+ gst_pad_set_caps (mpegvideoparse->srcpad, caps);
+ }
+}
+
+#if 0
+static guint64
+gst_mpegvideoparse_time_code (guchar * gop, MPEGSeqHdr * seq_hdr)
+{
+ guint32 data = GST_READ_UINT32_BE (gop);
+ guint64 seconds;
+ guint8 frames;
+
+ seconds = ((data & 0xfc000000) >> 26) * 3600; /* hours */
+ seconds += ((data & 0x03f00000) >> 20) * 60; /* minutes */
+ seconds += (data & 0x0007e000) >> 13; /* seconds */
+
+ frames = (data & 0x00001f80) >> 7;
+
+ return seconds * GST_SECOND + gst_util_uint64_scale_int (frames * GST_SECOND,
+ seq_hdr->fps_d, seq_hdr->fps_n);
+}
+#endif
+
+static void
+gst_mpegvideoparse_flush (MpegVideoParse * mpegvideoparse)
+{
+ GST_DEBUG_OBJECT (mpegvideoparse, "mpegvideoparse: flushing");
+
+ mpegvideoparse->next_offset = GST_BUFFER_OFFSET_NONE;
+}
+
+static GstFlowReturn
+mpegvideoparse_drain_avail (MpegVideoParse * mpegvideoparse)
+{
+ MPEGBlockInfo *cur;
+ GstBuffer *buf;
+ GstFlowReturn res = GST_FLOW_OK;
+
+ cur = mpeg_packetiser_get_block (&mpegvideoparse->packer, &buf);
+ while (cur != NULL) {
+ /* Handle the block */
+ GST_LOG_OBJECT (mpegvideoparse,
+ "Have block of size %u with pack_type 0x%02x and flags 0x%02x\n",
+ cur->length, cur->first_pack_type, cur->flags);
+
+ /* Don't start pushing out buffers until we've seen a sequence header */
+ if (mpegvideoparse->seq_hdr.mpeg_version == 0) {
+ if ((cur->flags & MPEG_BLOCK_FLAG_SEQUENCE) == 0) {
+ if (buf) {
+ GST_DEBUG_OBJECT (mpegvideoparse,
+ "No sequence header yet. Dropping buffer of %u bytes",
+ GST_BUFFER_SIZE (buf));
+ gst_buffer_unref (buf);
+ buf = NULL;
+ }
+ } else {
+ /* Found a sequence header */
+ mpegvideoparse_parse_seq (mpegvideoparse, buf);
+ }
+ }
+
+ if (buf != NULL) {
+ GST_DEBUG_OBJECT (mpegvideoparse,
+ "mpegvideoparse: pushing buffer of %u bytes with ts %"
+ GST_TIME_FORMAT, GST_BUFFER_SIZE (buf),
+ GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)));
+ gst_buffer_set_caps (buf, GST_PAD_CAPS (mpegvideoparse->srcpad));
+ if (mpegvideoparse->need_discont) {
+ GST_DEBUG_OBJECT (mpegvideoparse,
+ "setting discont flag on outgoing buffer");
+ GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DISCONT);
+ mpegvideoparse->need_discont = FALSE;
+ }
+ res = gst_pad_push (mpegvideoparse->srcpad, buf);
+ if (res != GST_FLOW_OK)
+ break;
+ }
+
+ /* Advance to the next data block */
+ mpeg_packetiser_next_block (&mpegvideoparse->packer);
+ cur = mpeg_packetiser_get_block (&mpegvideoparse->packer, &buf);
+ };
+
+ return res;
+}
+
+static GstFlowReturn
+gst_mpegvideoparse_chain (GstPad * pad, GstBuffer * buf)
+{
+ MpegVideoParse *mpegvideoparse;
+ GstFlowReturn res;
+ gboolean have_discont;
+ gint64 next_offset = GST_BUFFER_OFFSET_NONE;
+
+ g_return_val_if_fail (pad != NULL, GST_FLOW_ERROR);
+ g_return_val_if_fail (buf != NULL, GST_FLOW_ERROR);
+
+ mpegvideoparse =
+ GST_MPEGVIDEOPARSE (gst_object_get_parent (GST_OBJECT (pad)));
+
+ GST_DEBUG_OBJECT (mpegvideoparse,
+ "mpegvideoparse: received buffer of %u bytes with ts %"
+ GST_TIME_FORMAT, GST_BUFFER_SIZE (buf),
+ GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)));
+
+ /* If we have an offset, and the incoming offset doesn't match,
+ or we have a discont, handle it first by flushing out data
+ we have collected. */
+ have_discont = GST_BUFFER_IS_DISCONT (buf);
+
+ if (mpegvideoparse->next_offset != GST_BUFFER_OFFSET_NONE) {
+ if (GST_BUFFER_OFFSET_IS_VALID (buf)) {
+ if (mpegvideoparse->next_offset != GST_BUFFER_OFFSET (buf))
+ have_discont = TRUE;
+ next_offset = GST_BUFFER_OFFSET (buf) + GST_BUFFER_SIZE (buf);
+ } else {
+ next_offset = mpegvideoparse->next_offset + GST_BUFFER_SIZE (buf);
+ }
+ }
+
+ if (have_discont) {
+ GST_DEBUG_OBJECT (mpegvideoparse, "Have discont packet, draining data");
+ mpegvideoparse->need_discont = TRUE;
+
+ mpeg_packetiser_handle_eos (&mpegvideoparse->packer);
+ res = mpegvideoparse_drain_avail (mpegvideoparse);
+ mpeg_packetiser_flush (&mpegvideoparse->packer);
+ if (res != GST_FLOW_OK) {
+ mpegvideoparse->next_offset = next_offset;
+ gst_buffer_unref (buf);
+ return res;
+ }
+ }
+
+ /* Takes ownership of the data */
+ mpeg_packetiser_add_buf (&mpegvideoparse->packer, buf);
+
+ /* And push out what we can */
+ res = mpegvideoparse_drain_avail (mpegvideoparse);
+
+ /* Update our offset */
+ mpegvideoparse->next_offset = next_offset;
+
+ gst_object_unref (mpegvideoparse);
+ return res;
+}
+
+static gboolean
+mpv_parse_sink_event (GstPad * pad, GstEvent * event)
+{
+ gboolean res = TRUE;
+ MpegVideoParse *mpegvideoparse =
+ GST_MPEGVIDEOPARSE (gst_pad_get_parent (pad));
+
+ switch (GST_EVENT_TYPE (event)) {
+ case GST_EVENT_NEWSEGMENT:
+ {
+ gdouble rate, applied_rate;
+ GstFormat format;
+ gint64 start, stop, pos;
+ gboolean update;
+
+ gst_event_parse_new_segment_full (event, &update, &rate, &applied_rate,
+ &format, &start, &stop, &pos);
+
+ if (format == GST_FORMAT_BYTES) {
+ /* FIXME: Later, we might use a seek table to seek on elementary stream
+ files, and that would allow byte-to-time conversions. It's not a high
+ priority - most mpeg video is muxed and then the demuxer handles
+ seeking. In the meantime, here's some commented out logic copied
+ from mp3parse */
+#if 0
+ GstClockTime seg_start, seg_stop, seg_pos;
+
+ /* stop time is allowed to be open-ended, but not start & pos */
+ if (!mp3parse_bytepos_to_time (mp3parse, stop, &seg_stop))
+ seg_stop = GST_CLOCK_TIME_NONE;
+ if (mp3parse_bytepos_to_time (mp3parse, start, &seg_start) &&
+ mp3parse_bytepos_to_time (mp3parse, pos, &seg_pos)) {
+ gst_event_unref (event);
+ event = gst_event_new_new_segment_full (update, rate, applied_rate,
+ GST_FORMAT_TIME, seg_start, seg_stop, seg_pos);
+ format = GST_FORMAT_TIME;
+ GST_DEBUG_OBJECT (mp3parse, "Converted incoming segment to TIME. "
+ "start = %" G_GINT64_FORMAT ", stop = %" G_GINT64_FORMAT
+ "pos = %" G_GINT64_FORMAT, seg_start, seg_stop, seg_pos);
+ }
+#endif
+ }
+
+ if (format != GST_FORMAT_TIME) {
+ /* Unknown incoming segment format. Output a default open-ended
+ * TIME segment */
+ gst_event_unref (event);
+ event = gst_event_new_new_segment_full (update, rate, applied_rate,
+ GST_FORMAT_TIME, 0, GST_CLOCK_TIME_NONE, 0);
+ }
+
+ gst_event_parse_new_segment_full (event, &update, &rate, &applied_rate,
+ &format, &start, &stop, &pos);
+ GST_DEBUG_OBJECT (mpegvideoparse,
+ "Pushing newseg rate %g, applied rate %g, "
+ "format %d, start %lld, stop %lld, pos %lld\n",
+ rate, applied_rate, format, start, stop, pos);
+
+ res = gst_pad_event_default (pad, event);
+ break;
+ }
+ case GST_EVENT_FLUSH_STOP:
+ gst_mpegvideoparse_flush (mpegvideoparse);
+ res = gst_pad_event_default (pad, event);
+ break;
+ case GST_EVENT_EOS:
+
+ /* Push any remaining buffers out, then flush. */
+ mpeg_packetiser_handle_eos (&mpegvideoparse->packer);
+ mpegvideoparse_drain_avail (mpegvideoparse);
+ gst_mpegvideoparse_flush (mpegvideoparse);
+
+ res = gst_pad_event_default (pad, event);
+ break;
+ default:
+ res = gst_pad_event_default (pad, event);
+ break;
+ }
+
+ gst_object_unref (mpegvideoparse);
+ return res;
+}
+
+static GstStateChangeReturn
+gst_mpegvideoparse_change_state (GstElement * element,
+ GstStateChange transition)
+{
+ MpegVideoParse *mpegvideoparse;
+ GstStateChangeReturn ret;
+
+ g_return_val_if_fail (GST_IS_MPEGVIDEOPARSE (element),
+ GST_STATE_CHANGE_FAILURE);
+
+ mpegvideoparse = GST_MPEGVIDEOPARSE (element);
+
+ ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
+
+ switch (transition) {
+ case GST_STATE_CHANGE_PAUSED_TO_READY:
+ mpv_parse_reset (mpegvideoparse);
+ break;
+ default:
+ break;
+ }
+
+ return ret;
+}
+
+static gboolean
+plugin_init (GstPlugin * plugin)
+{
+ GST_DEBUG_CATEGORY_INIT (mpv_parse_debug, "mpegvideoparse", 0,
+ "MPEG Video Parser");
+
+ return gst_element_register (plugin, "mpegvideoparse",
+ GST_RANK_SECONDARY - 1, GST_TYPE_MPEGVIDEOPARSE);
+}
+
+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
+ GST_VERSION_MINOR,
+ "mpegvideoparse",
+ "MPEG-1 and MPEG-2 video parser",
+ plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)
diff --git a/gst/mpegvideoparse/mpegvideoparse.h b/gst/mpegvideoparse/mpegvideoparse.h
new file mode 100644
index 00000000..99c6722c
--- /dev/null
+++ b/gst/mpegvideoparse/mpegvideoparse.h
@@ -0,0 +1,79 @@
+/* GStreamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) <2007> Jan Schmidt <thaytan@mad.scientist.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.
+ */
+#ifndef __MPEGVIDEOPARSE_H__
+#define __MPEGVIDEOPARSE_H__
+
+#include <gst/gst.h>
+#include "mpegpacketiser.h"
+
+G_BEGIN_DECLS
+
+#define GST_TYPE_MPEGVIDEOPARSE \
+ (mpegvideoparse_get_type())
+#define GST_MPEGVIDEOPARSE(obj) \
+ (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_MPEGVIDEOPARSE,MpegVideoParse))
+#define GST_MPEGVIDEOPARSE_CLASS(klass) \
+ (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_MPEGVIDEOPARSE,MpegVideoParseClass))
+#define GST_IS_MPEGVIDEOPARSE(obj) \
+ (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MPEGVIDEOPARSE))
+#define GST_IS_MPEGVIDEOPARSE_CLASS(klass) \
+ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MPEGVIDEOPARSE))
+
+typedef struct _MpegVideoParse MpegVideoParse;
+typedef struct _MpegVideoParseClass MpegVideoParseClass;
+
+typedef struct MPEGSeqHdr
+{
+ /* 0 for unknown, else 1 or 2 */
+ guint8 mpeg_version;
+
+ /* Pixel-Aspect Ratio from DAR code via set_par_from_dar */
+ gint par_w, par_h;
+ /* Width and Height of the video */
+ gint width, height;
+ /* Framerate */
+ gint fps_n, fps_d;
+} MPEGSeqHdr;
+
+struct _MpegVideoParse {
+ GstElement element;
+
+ GstPad *sinkpad, *srcpad;
+
+ gint64 next_offset;
+ gboolean need_discont;
+
+ /* Info from the Sequence Header */
+ MPEGSeqHdr seq_hdr;
+ GstBuffer *seq_hdr_buf;
+
+ /* Packetise helper */
+ MPEGPacketiser packer;
+};
+
+struct _MpegVideoParseClass {
+ GstElementClass parent_class;
+};
+
+GType gst_mpegvideoparse_get_type(void);
+
+G_END_DECLS
+
+#endif /* __MPEGVIDEOPARSE_H__ */
diff --git a/gst/mpegvideoparse/mpegvideoparse.vcproj b/gst/mpegvideoparse/mpegvideoparse.vcproj
new file mode 100644
index 00000000..7aed71ac
--- /dev/null
+++ b/gst/mpegvideoparse/mpegvideoparse.vcproj
@@ -0,0 +1,148 @@
+<?xml version="1.0" encoding="Windows-1252"?>
+<VisualStudioProject
+ ProjectType="Visual C++"
+ Version="7.10"
+ Name="mpegvideoparse"
+ ProjectGUID="{979C216F-0ACF-4956-AE00-055A42D678E6}"
+ Keyword="Win32Proj">
+ <Platforms>
+ <Platform
+ Name="Win32"/>
+ </Platforms>
+ <Configurations>
+ <Configuration
+ Name="Debug|Win32"
+ OutputDirectory="../../win32/Debug"
+ IntermediateDirectory="../../win32/Debug"
+ ConfigurationType="2"
+ CharacterSet="2">
+ <Tool
+ Name="VCCLCompilerTool"
+ Optimization="0"
+ AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+ PreprocessorDefinitions="WIN32;_DEBUG;_WINDOWS;_USRDLL;mpegvideoparse_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+ MinimalRebuild="TRUE"
+ BasicRuntimeChecks="3"
+ RuntimeLibrary="3"
+ UsePrecompiledHeader="0"
+ WarningLevel="3"
+ Detect64BitPortabilityProblems="TRUE"
+ DebugInformationFormat="4"/>
+ <Tool
+ Name="VCCustomBuildTool"/>
+ <Tool
+ Name="VCLinkerTool"
+ AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+ OutputFile="$(OutDir)/mpegvideoparse.dll"
+ LinkIncremental="2"
+ AdditionalLibraryDirectories="../../../gstreamer/win32/Debug;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+ ModuleDefinitionFile=""
+ GenerateDebugInformation="TRUE"
+ ProgramDatabaseFile="$(OutDir)/mpegvideoparse.pdb"
+ SubSystem="2"
+ OptimizeReferences="2"
+ ImportLibrary="$(OutDir)/mpegvideoparse.lib"
+ TargetMachine="1"/>
+ <Tool
+ Name="VCMIDLTool"/>
+ <Tool
+ Name="VCPostBuildEventTool"
+ CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+ <Tool
+ Name="VCPreBuildEventTool"/>
+ <Tool
+ Name="VCPreLinkEventTool"/>
+ <Tool
+ Name="VCResourceCompilerTool"/>
+ <Tool
+ Name="VCWebServiceProxyGeneratorTool"/>
+ <Tool
+ Name="VCXMLDataGeneratorTool"/>
+ <Tool
+ Name="VCWebDeploymentTool"/>
+ <Tool
+ Name="VCManagedWrapperGeneratorTool"/>
+ <Tool
+ Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+ </Configuration>
+ <Configuration
+ Name="Release|Win32"
+ OutputDirectory="../../win32/Release"
+ IntermediateDirectory="../../win32/Release"
+ ConfigurationType="2"
+ CharacterSet="2">
+ <Tool
+ Name="VCCLCompilerTool"
+ AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+ PreprocessorDefinitions="WIN32;NDEBUG;GST_DISABLE_GST_DEBUG;_WINDOWS;_USRDLL;mpegvideoparse_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+ RuntimeLibrary="2"
+ UsePrecompiledHeader="0"
+ WarningLevel="3"
+ Detect64BitPortabilityProblems="TRUE"
+ DebugInformationFormat="3"/>
+ <Tool
+ Name="VCCustomBuildTool"/>
+ <Tool
+ Name="VCLinkerTool"
+ AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+ OutputFile="$(OutDir)/mpegvideoparse.dll"
+ LinkIncremental="1"
+ AdditionalLibraryDirectories="../../../gstreamer/win32/Release;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+ ModuleDefinitionFile=""
+ GenerateDebugInformation="TRUE"
+ SubSystem="2"
+ OptimizeReferences="2"
+ EnableCOMDATFolding="2"
+ ImportLibrary="$(OutDir)/mpegvideoparse.lib"
+ TargetMachine="1"/>
+ <Tool
+ Name="VCMIDLTool"/>
+ <Tool
+ Name="VCPostBuildEventTool"
+ CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+ <Tool
+ Name="VCPreBuildEventTool"/>
+ <Tool
+ Name="VCPreLinkEventTool"/>
+ <Tool
+ Name="VCResourceCompilerTool"/>
+ <Tool
+ Name="VCWebServiceProxyGeneratorTool"/>
+ <Tool
+ Name="VCXMLDataGeneratorTool"/>
+ <Tool
+ Name="VCWebDeploymentTool"/>
+ <Tool
+ Name="VCManagedWrapperGeneratorTool"/>
+ <Tool
+ Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+ </Configuration>
+ </Configurations>
+ <References>
+ </References>
+ <Files>
+ <Filter
+ Name="Source Files"
+ Filter="cpp;c;cxx;def;odl;idl;hpj;bat;asm;asmx"
+ UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}">
+ <File
+ RelativePath=".\mpegvideoparse.c">
+ </File>
+ </Filter>
+ <Filter
+ Name="Header Files"
+ Filter="h;hpp;hxx;hm;inl;inc;xsd"
+ UniqueIdentifier="{93995380-89BD-4b04-88EB-625FBE52EBFB}">
+ <File
+ RelativePath=".\mpegvideoparse.h">
+ </File>
+ </Filter>
+ <Filter
+ Name="Resource Files"
+ Filter="rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx"
+ UniqueIdentifier="{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}">
+ </Filter>
+ </Files>
+ <Globals>
+ </Globals>
+</VisualStudioProject>