summaryrefslogtreecommitdiffstats
path: root/gst/flx/gstflxdec.c
diff options
context:
space:
mode:
authorAndy Wingo <wingo@pobox.com>2001-12-22 23:26:33 +0000
committerAndy Wingo <wingo@pobox.com>2001-12-22 23:26:33 +0000
commitad6ed7da2d0d15eecc924dfe408320652481e885 (patch)
tree5adb0cfc1d7b419d6b4246f616400dca7678bac0 /gst/flx/gstflxdec.c
parente5d9d6e2a512540848f5d38e01b9678a1ef5c761 (diff)
downloadgst-plugins-bad-ad6ed7da2d0d15eecc924dfe408320652481e885.tar.gz
gst-plugins-bad-ad6ed7da2d0d15eecc924dfe408320652481e885.tar.bz2
gst-plugins-bad-ad6ed7da2d0d15eecc924dfe408320652481e885.zip
Initial revision
Original commit message from CVS: Initial revision
Diffstat (limited to 'gst/flx/gstflxdec.c')
-rw-r--r--gst/flx/gstflxdec.c644
1 files changed, 644 insertions, 0 deletions
diff --git a/gst/flx/gstflxdec.c b/gst/flx/gstflxdec.c
new file mode 100644
index 00000000..d6052bb6
--- /dev/null
+++ b/gst/flx/gstflxdec.c
@@ -0,0 +1,644 @@
+/* Gnome-Streamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+#include <string.h>
+
+#include "flx_fmt.h"
+#include "gstflxdec.h"
+
+static GstCaps* flxdec_typefind(GstBuffer *buf, gpointer private);
+
+/* flx element information */
+static GstElementDetails flxdec_details = {
+ "FLX Decoder",
+ "flxdec",
+ "FLX decoder",
+ VERSION,
+ "Sepp Wijnands <mrrazz@garbage-coderz.net>"
+ "(C) 2001",
+};
+
+static GstTypeDefinition flxdec_definition = {
+ "flxdec_video/fli",
+ "video/fli",
+ ".flc .fli",
+ flxdec_typefind,
+};
+
+/* Flx signals and args */
+enum {
+ /* FILL ME */
+ LAST_SIGNAL
+};
+
+enum {
+ ARG_0
+};
+
+/* input */
+GST_PADTEMPLATE_FACTORY (sink_factory,
+ "sink",
+ GST_PAD_SINK,
+ GST_PAD_ALWAYS,
+ GST_CAPS_NEW (
+ "flxdec_sink",
+ "video/fli",
+ NULL
+ )
+)
+
+/* output */
+GST_PADTEMPLATE_FACTORY (src_video_factory,
+ "src",
+ GST_PAD_SRC,
+ GST_PAD_ALWAYS,
+ GST_CAPS_NEW (
+ "src_video",
+ "video/raw",
+ "format", GST_PROPS_FOURCC (GST_MAKE_FOURCC ('R', 'G', 'B', ' ')),
+ "bpp", GST_PROPS_INT (32),
+ "depth", GST_PROPS_INT (32),
+ "endianness", GST_PROPS_INT (G_LITTLE_ENDIAN),
+ "red_mask", GST_PROPS_INT (0x00ff0000),
+ "green_mask", GST_PROPS_INT (0x0000ff00),
+ "blue_mask", GST_PROPS_INT (0x000000ff),
+ "width", GST_PROPS_INT_RANGE(320, 1280),
+ "height", GST_PROPS_INT_RANGE(200, 1024)
+ )
+)
+
+
+static void gst_flxdec_class_init (GstFlxDecClass *klass);
+static void gst_flxdec_init (GstFlxDec *flxdec);
+
+static void gst_flxdec_loop (GstElement *element);
+
+static void gst_flxdec_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
+static void gst_flxdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
+
+
+static void flx_decode_color(GstFlxDec *, guchar *, guchar *);
+static void flx_decode_brun(GstFlxDec *, guchar *, guchar *);
+static void flx_decode_delta_fli(GstFlxDec *, guchar *, guchar *);
+static void flx_decode_delta_flc(GstFlxDec *, guchar *, guchar *);
+
+#define rndalign(off) ((off) + ((off) % 2))
+
+static GstElementClass *parent_class = NULL;
+
+static GstCaps*
+flxdec_typefind (GstBuffer *buf, gpointer private)
+{
+ guchar *data = GST_BUFFER_DATA(buf);
+ GstCaps *new;
+
+ // check magic
+ if ((data[4] == 0x11 || data[4] == 0x12
+ || data[4] == 0x30 || data[4] == 0x44) && data[5] == 0xaf) {
+ // check the frame type of the first frame
+ if ((data[132] == 0x00 || data[132] == 0xfa) && data[133] == 0xf1) {
+ g_print("GstFlxDec: found supported flx format\n");
+ new = gst_caps_new("flxdec_typefind","video/fli", NULL);
+ return new;
+ }
+ }
+
+ return NULL;
+}
+
+
+GType
+gst_flxdec_get_type(void)
+{
+ static GType flxdec_type = 0;
+
+ if (!flxdec_type) {
+ static const GTypeInfo flxdec_info = {
+ sizeof(GstFlxDecClass), NULL,
+ NULL,
+ (GClassInitFunc)gst_flxdec_class_init,
+ NULL,
+ NULL,
+ sizeof(GstFlxDec),
+ 0,
+ (GInstanceInitFunc)gst_flxdec_init,
+ };
+ flxdec_type = g_type_register_static(GST_TYPE_ELEMENT, "GstFlxDec", &flxdec_info, 0);
+ }
+ return flxdec_type;
+}
+
+static void
+gst_flxdec_class_init (GstFlxDecClass *klass)
+{
+ GObjectClass *gobject_class;
+ GstElementClass *gstelement_class;
+
+ gobject_class = (GObjectClass*)klass;
+ gstelement_class = (GstElementClass*)klass;
+
+ parent_class = g_type_class_ref(GST_TYPE_ELEMENT);
+
+ gobject_class->set_property = NULL;
+ gobject_class->get_property = NULL;
+
+}
+
+
+
+static void
+gst_flxdec_init(GstFlxDec *flxdec)
+{
+ flxdec->sinkpad = gst_pad_new_from_template (
+ GST_PADTEMPLATE_GET (sink_factory), "sink");
+ gst_element_add_pad(GST_ELEMENT(flxdec),flxdec->sinkpad);
+ gst_element_set_loop_function(GST_ELEMENT(flxdec),gst_flxdec_loop);
+
+ flxdec->srcpad = gst_pad_new_from_template (
+ GST_PADTEMPLATE_GET (src_video_factory), "src");
+ gst_element_add_pad(GST_ELEMENT(flxdec),flxdec->srcpad);
+
+ flxdec->buf = NULL;
+ flxdec->offset = 0;
+ flxdec->new_buf = TRUE;
+
+}
+
+static void
+flx_decode_chunks (GstFlxDec *flxdec , gulong count, gchar *data, gchar *dest)
+{
+ FlxFrameChunk *hdr;
+
+ g_return_if_fail(data != NULL);
+
+ while (count--) {
+ hdr = (FlxFrameChunk *) data;
+ data += FlxFrameChunkSize;
+
+ switch(hdr->id)
+ {
+ case FLX_COLOR64:
+ case FLX_COLOR256:
+ flx_decode_color(flxdec, data, dest);
+ data += rndalign(hdr->size) - FlxFrameChunkSize;
+ break;
+
+ case FLX_BRUN:
+ flx_decode_brun(flxdec, data, dest);
+ data += rndalign(hdr->size) - FlxFrameChunkSize;
+ break;
+
+ case FLX_LC:
+ flx_decode_delta_fli(flxdec, data, dest);
+ data += rndalign(hdr->size) - FlxFrameChunkSize;
+ break;
+
+ case FLX_SS2:
+ flx_decode_delta_flc(flxdec, data, dest);
+ data += rndalign(hdr->size) - FlxFrameChunkSize;
+ break;
+
+ case FLX_BLACK:
+ memset(dest, 0, flxdec->size);
+ break;
+
+ case FLX_MINI:
+ data += rndalign(hdr->size) - FlxFrameChunkSize;
+ break;
+
+ default:
+ g_print("GstFlxDec: Unimplented chunk type: 0x%02x size: %d\n",
+ hdr->id, hdr->size);
+ g_print("GstFlxDec: Skipping...\n");
+ data += rndalign(hdr->size) - FlxFrameChunkSize;
+ break;
+ }
+ }
+}
+
+
+static void
+flx_decode_color(GstFlxDec *flxdec, guchar *data, guchar *dest)
+{
+ guint packs, count, indx;
+
+ g_return_if_fail(flxdec != NULL);
+
+ packs = (data[0] + (data[1] << 8));
+
+ data += 2;
+ indx = 0;
+
+ g_print("GstFlxDec: cmap packs: %d\n", packs);
+ while (packs--) {
+ /* color map index + skip count */
+ indx += *data++;
+
+ /* number of rgb triplets */
+ count = *data++ & 0xff;
+ if (count == 0)
+ count = 256;
+
+ g_print("GstFlxDec: cmap count: %d (indx: %d)\n", count, indx);
+ flx_set_palette_vector(flxdec->converter, indx, count, data);
+
+ data += (count * 3);
+ }
+}
+
+static void
+flx_decode_brun(GstFlxDec *flxdec, guchar *data, guchar *dest)
+{
+ gulong count, lines, row;
+ guchar x;
+
+ g_return_if_fail(flxdec != NULL);
+
+ lines = flxdec->hdr.height;
+ while(lines--) {
+ /* packet count.
+ * should not be used anymore, since the flc format can
+ * contain more then 255 RLE packets. we use the frame
+ * width instead.
+ */
+ data++;
+
+ row = flxdec->hdr.width;
+ while(row) {
+ count = *data++;
+
+ if (count > 0x7f) {
+ /* literal run */
+ count = 0x100 - count;
+ row -= count;
+
+ while(count--)
+ *dest++ = *data++;
+
+ } else {
+ /* replicate run */
+ row -= count;
+ x = *data++;
+
+ while(count--)
+ *dest++ = x;
+ }
+ }
+ }
+}
+
+static void
+flx_decode_delta_fli(GstFlxDec *flxdec, guchar *data, guchar *dest)
+{
+ gulong count, packets, lines, start_line, start_l;
+ guchar *start_p, x;
+
+ g_return_if_fail(flxdec != NULL);
+ g_return_if_fail(flxdec->delta != NULL);
+
+
+ /* use last frame for delta */
+ memcpy(dest, GST_BUFFER_DATA(flxdec->delta),
+ GST_BUFFER_SIZE(flxdec->delta));
+
+ start_line = (data[0] + (data[1] << 8));
+ lines = (data[2] + (data[3] << 8));
+ data += 4;
+
+ /* start position of delta */
+ dest += (flxdec->hdr.width * start_line);
+ start_p = dest;
+ start_l = lines;
+
+ while(lines--) {
+ /* packet count */
+ packets = *data++;
+
+ dest = start_p + (flxdec->hdr.width * (start_l - lines));
+
+ while(packets--) {
+ /* skip count */
+ dest += *data++;
+
+ /* RLE count */
+ count = *data++;
+
+ if (count > 0x7f) {
+ /* literal run */
+ count = 0x100 - count;
+ x = *data++;
+
+ while (count--)
+ *dest++ = x;
+
+ } else {
+ /* replicate run */
+ while (count--)
+ *dest++ = *data++;
+ }
+ }
+ }
+}
+
+static void
+flx_decode_delta_flc(GstFlxDec *flxdec, guchar *data, guchar *dest)
+{
+ gulong count, lines, start_l, opcode;
+ guchar *start_p;
+
+ g_return_if_fail(flxdec != NULL);
+ g_return_if_fail(flxdec->delta != NULL);
+
+
+ /* use last frame for delta */
+ memcpy(dest, GST_BUFFER_DATA(flxdec->delta),
+ GST_BUFFER_SIZE(flxdec->delta));
+
+ lines = (data[0] + (data[1] << 8));
+ data += 2;
+
+ start_p = dest;
+ start_l = lines;
+
+ while(lines--) {
+ dest = start_p + (flxdec->hdr.width * (start_l - lines));
+
+ /* process opcode(s) */
+ while ((opcode = (data[0] + (data[1] << 8))) & 0xc000) {
+ data += 2;
+ if ((opcode & 0xc000) == 0xc000) {
+ /* skip count */
+ start_l += (0x10000 - opcode);
+ dest += flxdec->hdr.width * (0x10000 - opcode);
+ } else {
+ /* last pixel */
+ dest += flxdec->hdr.width;
+ *dest++ = (opcode & 0xff);
+ }
+ }
+ data += 2;
+
+ /* last opcode is the packet count */
+ while(opcode--) {
+ /* skip count */
+ dest += *data++;
+
+ /* RLE count */
+ count = *data++;
+
+ if (count > 0x7f) {
+ /* replicate word run */
+ count = 0x100 - count;
+ while (count--) {
+ *dest++ = data[0];
+ *dest++ = data[1];
+ }
+ data += 2;
+ } else {
+ /* literal word run */
+ while (count--) {
+ *dest++ = *data++;
+ *dest++ = *data++;
+ }
+ }
+ }
+ }
+}
+
+static GstBuffer*
+flx_get_data(GstFlxDec *flxdec, gulong size)
+{
+ GstBuffer *retbuf;
+
+ g_return_val_if_fail (flxdec != NULL, NULL);
+
+ if (flxdec->new_buf) {
+ retbuf = gst_pad_pullregion(flxdec->sinkpad,
+ GST_REGION_OFFSET_LEN, 0, size);
+ flxdec->new_buf = FALSE;
+ flxdec->offset = size;
+ } else {
+ retbuf = gst_pad_pullregion(flxdec->sinkpad, GST_REGION_OFFSET_LEN,
+ flxdec->offset, size);
+ flxdec->offset += size;
+ }
+
+ return retbuf;
+}
+
+
+static void
+gst_flxdec_loop (GstElement *element)
+{
+ GstBuffer *buf;
+ GstBuffer *databuf;
+ guchar *data, *chunk;
+
+ GstFlxDec *flxdec;
+ FlxHeader *flxh;
+ FlxFrameChunk *flxfh;
+
+ g_return_if_fail (element != NULL);
+ g_return_if_fail (GST_IS_FLXDEC(element));
+
+ GST_DEBUG (0, "entering loop function\n");
+
+ flxdec = GST_FLXDEC(element);
+
+ databuf = flx_get_data(flxdec, FlxHeaderSize);
+
+ g_return_if_fail (databuf != NULL);
+
+ data = GST_BUFFER_DATA(databuf);
+
+ memcpy((char *) &flxdec->hdr, data, sizeof(FlxHeader));
+
+ gst_buffer_unref (databuf);
+
+ flxh = &flxdec->hdr;
+
+ // check header
+ if (flxh->type != FLX_MAGICHDR_FLI &&
+ flxh->type != FLX_MAGICHDR_FLC &&
+ flxh->type != FLX_MAGICHDR_FLX)
+ return;
+
+
+ g_print("GstFlxDec: size : %d\n", flxh->size);
+ g_print("GstFlxDec: frames : %d\n", flxh->frames);
+ g_print("GstFlxDec: width : %d\n", flxh->width);
+ g_print("GstFlxDec: height : %d\n", flxh->height);
+ g_print("GstFlxDec: depth : %d\n", flxh->depth);
+ g_print("GstFlxDec: speed : %d\n", flxh->speed);
+
+ gst_pad_set_caps (flxdec->srcpad,
+ gst_caps_new (
+ "src_video",
+ "video/raw",
+ gst_props_new (
+ "format", GST_PROPS_FOURCC (GST_MAKE_FOURCC ('R', 'G', 'B', ' ')),
+ "bpp", GST_PROPS_INT (32),
+ "depth", GST_PROPS_INT (32),
+ "endianness", GST_PROPS_INT (G_LITTLE_ENDIAN),
+ "red_mask", GST_PROPS_INT (0x00ff0000),
+ "green_mask", GST_PROPS_INT (0x0000ff00),
+ "blue_mask", GST_PROPS_INT (0x000000ff),
+ "width", GST_PROPS_INT (flxh->width),
+ "height", GST_PROPS_INT (flxh->height),
+ NULL)));
+
+ if (flxh->depth <= 8)
+ flxdec->converter = flx_colorspace_converter_new(flxh->width, flxh->height);
+
+ if (flxh->type == FLX_MAGICHDR_FLC ||
+ flxh->type == FLX_MAGICHDR_FLX) {
+ g_print("GstFlxDec: (FLC) aspect_dx : %d\n",
+ flxh->aspect_dx);
+ g_print("GstFlxDec: (FLC) aspect_dy : %d\n",
+ flxh->aspect_dy);
+ g_print("GstFlxDec: (FLC) oframe1 : 0x%08x\n",
+ flxh->oframe1);
+ g_print("GstFlxDec: (FLC) oframe2 : 0x%08x\n",
+ flxh->oframe2);
+ }
+
+
+ flxdec->size = (flxh->width * flxh->height);
+
+ // create delta and output frame
+ flxdec->frame = gst_buffer_new();
+ flxdec->delta = gst_buffer_new();
+ GST_BUFFER_DATA(flxdec->frame) = g_malloc(flxdec->size);
+ GST_BUFFER_SIZE(flxdec->frame) = flxdec->size;
+ GST_BUFFER_DATA(flxdec->delta) = g_malloc(flxdec->size);
+ GST_BUFFER_SIZE(flxdec->delta) = flxdec->size;
+
+ do
+ {
+
+ databuf = flx_get_data(flxdec, FlxFrameChunkSize);
+
+ flxfh = (FlxFrameChunk *) GST_BUFFER_DATA(databuf);
+
+ switch(flxfh->id)
+ {
+ case FLX_FRAME_TYPE:
+ buf = flx_get_data(flxdec, flxfh->size-FlxFrameChunkSize);
+
+ chunk = GST_BUFFER_DATA(buf);
+
+ if (((FlxFrameType *)chunk)->chunks == 0)
+ break;
+
+ // create 32 bits output frame
+ flxdec->out = gst_buffer_new();
+ GST_BUFFER_DATA(flxdec->out) = g_malloc(flxdec->size * 4);
+ GST_BUFFER_SIZE(flxdec->out) = flxdec->size * 4;
+
+
+ // decode chunks
+ flx_decode_chunks(flxdec,
+ ((FlxFrameType *)chunk)->chunks,
+ GST_BUFFER_DATA(buf) + FlxFrameTypeSize,
+ GST_BUFFER_DATA(flxdec->frame));
+
+ // destroy input buffer
+ gst_buffer_unref(buf);
+
+ // save copy of the current frame for possible delta.
+ memcpy(GST_BUFFER_DATA(flxdec->delta),
+ GST_BUFFER_DATA(flxdec->frame),
+ GST_BUFFER_SIZE(flxdec->delta));
+
+ // convert current frame.
+ flx_colorspace_convert(flxdec->converter,
+ GST_BUFFER_DATA(flxdec->frame),
+ GST_BUFFER_DATA(flxdec->out));
+
+ //GST_BUFFER_FLAG_SET(flxdec->out, GST_BUFFER_FLUSH);
+ gst_pad_push(flxdec->srcpad, flxdec->out);
+
+ break;
+ }
+
+ // destroy header buffer
+ gst_buffer_unref(databuf);
+
+ }
+ while (!GST_ELEMENT_IS_COTHREAD_STOPPING (element));
+
+}
+
+static void
+gst_flxdec_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
+{
+ GstFlxDec *flxdec;
+
+ /* it's not null if we got it, but it might not be ours */
+ g_return_if_fail(GST_IS_FLXDEC(object));
+ flxdec = GST_FLXDEC(object);
+
+ switch (prop_id) {
+ default:
+ break;
+ }
+}
+
+static void
+gst_flxdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
+{
+ GstFlxDec *flxdec;
+
+ /* it's not null if we got it, but it might not be ours */
+ g_return_if_fail(GST_IS_FLXDEC(object));
+ flxdec = GST_FLXDEC(object);
+
+ switch (prop_id) {
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static gboolean
+plugin_init (GModule *module, GstPlugin *plugin)
+{
+ GstElementFactory *factory;
+ GstTypeFactory *type;
+
+ factory = gst_elementfactory_new("flxdec", GST_TYPE_FLXDEC, &flxdec_details);
+ g_return_val_if_fail(factory != NULL, FALSE);
+
+ gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (sink_factory));
+ gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (src_video_factory));
+
+ gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory));
+
+ type = gst_typefactory_new (&flxdec_definition);
+ gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (type));
+
+ return TRUE;
+}
+
+GstPluginDesc plugin_desc = {
+ GST_VERSION_MAJOR,
+ GST_VERSION_MINOR,
+ "flxdec",
+ plugin_init
+};