2 * Copyright (C) <1999> Erik Walthinsen <omega@temple-baptist.com>
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Library General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Library General Public License for more details.
14 * You should have received a copy of the GNU Library General Public
15 * License along with this library; if not, write to the
16 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
17 * Boston, MA 02111-1307, USA.
26 #include "gstflxdec.h"
27 #include <gst/video/video.h>
29 #define JIFFIE (GST_SECOND/70)
31 GST_DEBUG_CATEGORY_STATIC (flxdec_debug);
32 #define GST_CAT_DEFAULT flxdec_debug
34 /* flx element information */
35 static GstElementDetails flxdec_details = {
37 "Codec/Decoder/Audio",
39 "Sepp Wijnands <mrrazz@garbage-coderz.net>, Zeeshan Ali <zeenix@gmail.com>"
42 /* Flx signals and args */
55 static GstStaticPadTemplate sink_factory = GST_STATIC_PAD_TEMPLATE ("sink",
58 GST_STATIC_CAPS ("video/x-fli")
62 static GstStaticPadTemplate src_video_factory = GST_STATIC_PAD_TEMPLATE ("src",
65 GST_STATIC_CAPS (GST_VIDEO_CAPS_xRGB_HOST_ENDIAN)
69 static void gst_flxdec_class_init (GstFlxDecClass * klass);
70 static void gst_flxdec_base_init (GstFlxDecClass * klass);
71 static void gst_flxdec_init (GstFlxDec * flxdec);
73 static GstFlowReturn gst_flxdec_chain (GstPad * pad, GstBuffer * buf);
75 static GstStateChangeReturn gst_flxdec_change_state (GstElement * element,
76 GstStateChange transition);
78 static gboolean gst_flxdec_src_event_handler (GstPad * pad, GstEvent * event);
79 static gboolean gst_flxdec_sink_event_handler (GstPad * pad, GstEvent * event);
81 static void gst_flxdec_set_property (GObject * object, guint prop_id,
82 const GValue * value, GParamSpec * pspec);
83 static void gst_flxdec_get_property (GObject * object, guint prop_id,
84 GValue * value, GParamSpec * pspec);
87 static void flx_decode_color (GstFlxDec *, guchar *, guchar *, gint);
88 static void flx_decode_brun (GstFlxDec *, guchar *, guchar *);
89 static void flx_decode_delta_fli (GstFlxDec *, guchar *, guchar *);
90 static void flx_decode_delta_flc (GstFlxDec *, guchar *, guchar *);
92 #define rndalign(off) ((off) + ((off) % 2))
94 static GstElementClass *parent_class = NULL;
97 gst_flxdec_get_type (void)
99 static GType flxdec_type = 0;
102 static const GTypeInfo flxdec_info = {
103 sizeof (GstFlxDecClass),
104 (GBaseInitFunc) gst_flxdec_base_init,
106 (GClassInitFunc) gst_flxdec_class_init,
111 (GInstanceInitFunc) gst_flxdec_init,
115 g_type_register_static (GST_TYPE_ELEMENT, "GstFlxDec", &flxdec_info, 0);
121 gst_flxdec_base_init (GstFlxDecClass * klass)
123 GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass);
125 gst_element_class_set_details (gstelement_class, &flxdec_details);
126 gst_element_class_add_pad_template (gstelement_class,
127 gst_static_pad_template_get (&sink_factory));
128 gst_element_class_add_pad_template (gstelement_class,
129 gst_static_pad_template_get (&src_video_factory));
133 gst_flxdec_class_init (GstFlxDecClass * klass)
135 GObjectClass *gobject_class;
136 GstElementClass *gstelement_class;
138 gobject_class = (GObjectClass *) klass;
139 gstelement_class = (GstElementClass *) klass;
141 parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
143 GST_DEBUG_CATEGORY_INIT (flxdec_debug, "flxdec", 0, "FLX video decoder");
145 gobject_class->set_property = gst_flxdec_set_property;
146 gobject_class->get_property = gst_flxdec_get_property;
148 gstelement_class->change_state = gst_flxdec_change_state;
152 gst_flxdec_init (GstFlxDec * flxdec)
155 gst_pad_new_from_template (gst_static_pad_template_get (&sink_factory),
157 gst_element_add_pad (GST_ELEMENT (flxdec), flxdec->sinkpad);
158 gst_pad_set_chain_function (flxdec->sinkpad, gst_flxdec_chain);
159 gst_pad_set_event_function (flxdec->sinkpad, gst_flxdec_sink_event_handler);
162 gst_pad_new_from_template (gst_static_pad_template_get
163 (&src_video_factory), "src");
164 gst_element_add_pad (GST_ELEMENT (flxdec), flxdec->srcpad);
165 gst_pad_set_event_function (flxdec->srcpad, gst_flxdec_src_event_handler);
167 gst_pad_use_fixed_caps (flxdec->srcpad);
169 flxdec->frame = NULL;
170 flxdec->delta = NULL;
172 flxdec->adapter = gst_adapter_new ();
176 gst_flxdec_src_event_handler (GstPad * pad, GstEvent * event)
178 GstFlxDec *flxdec = (GstFlxDec *) gst_pad_get_parent (pad);
180 g_return_val_if_fail (GST_IS_EVENT (event), FALSE);
182 /* TODO: implement the seek and other event handling */
184 return gst_pad_push_event (flxdec->sinkpad, event);
188 gst_flxdec_sink_event_handler (GstPad * pad, GstEvent * event)
190 GstFlxDec *flxdec = (GstFlxDec *) gst_pad_get_parent (pad);
192 g_return_val_if_fail (GST_IS_EVENT (event), FALSE);
194 if (GST_EVENT_TYPE (event) == GST_EVENT_EOS ||
195 GST_EVENT_TYPE (event) == GST_EVENT_NEWSEGMENT)
196 GST_STREAM_LOCK (flxdec->srcpad);
198 gst_pad_push_event (flxdec->srcpad, gst_event_ref (event));
200 if (GST_EVENT_TYPE (event) == GST_EVENT_EOS ||
201 GST_EVENT_TYPE (event) == GST_EVENT_NEWSEGMENT)
202 GST_STREAM_UNLOCK (flxdec->srcpad);
208 flx_decode_chunks (GstFlxDec * flxdec, gulong count, gchar * data, gchar * dest)
212 g_return_if_fail (data != NULL);
215 hdr = (FlxFrameChunk *) data;
216 data += FlxFrameChunkSize;
220 flx_decode_color (flxdec, data, dest, 2);
221 data += rndalign (hdr->size) - FlxFrameChunkSize;
225 flx_decode_color (flxdec, data, dest, 0);
226 data += rndalign (hdr->size) - FlxFrameChunkSize;
230 flx_decode_brun (flxdec, data, dest);
231 data += rndalign (hdr->size) - FlxFrameChunkSize;
235 flx_decode_delta_fli (flxdec, data, dest);
236 data += rndalign (hdr->size) - FlxFrameChunkSize;
240 flx_decode_delta_flc (flxdec, data, dest);
241 data += rndalign (hdr->size) - FlxFrameChunkSize;
245 memset (dest, 0, flxdec->size);
249 data += rndalign (hdr->size) - FlxFrameChunkSize;
253 GST_WARNING ("Unimplented chunk type: 0x%02x size: %d - skipping",
255 data += rndalign (hdr->size) - FlxFrameChunkSize;
263 flx_decode_color (GstFlxDec * flxdec, guchar * data, guchar * dest, gint scale)
265 guint packs, count, indx;
267 g_return_if_fail (flxdec != NULL);
269 packs = (data[0] + (data[1] << 8));
274 GST_LOG ("GstFlxDec: cmap packs: %d", packs);
276 /* color map index + skip count */
279 /* number of rgb triplets */
280 count = *data++ & 0xff;
284 GST_LOG ("GstFlxDec: cmap count: %d (indx: %d)\n", count, indx);
285 flx_set_palette_vector (flxdec->converter, indx, count, data, scale);
292 flx_decode_brun (GstFlxDec * flxdec, guchar * data, guchar * dest)
294 gulong count, lines, row;
297 g_return_if_fail (flxdec != NULL);
299 lines = flxdec->hdr.height;
302 * should not be used anymore, since the flc format can
303 * contain more then 255 RLE packets. we use the frame
308 row = flxdec->hdr.width;
314 count = 0x100 - count;
333 flx_decode_delta_fli (GstFlxDec * flxdec, guchar * data, guchar * dest)
335 gulong count, packets, lines, start_line, start_l;
338 g_return_if_fail (flxdec != NULL);
339 g_return_if_fail (flxdec->delta != NULL);
342 /* use last frame for delta */
343 memcpy (dest, GST_BUFFER_DATA (flxdec->delta),
344 GST_BUFFER_SIZE (flxdec->delta));
346 start_line = (data[0] + (data[1] << 8));
347 lines = (data[2] + (data[3] << 8));
350 /* start position of delta */
351 dest += (flxdec->hdr.width * start_line);
368 count = 0x100 - count;
380 start_p += flxdec->hdr.width;
386 flx_decode_delta_flc (GstFlxDec * flxdec, guchar * data, guchar * dest)
388 gulong count, lines, start_l, opcode;
391 g_return_if_fail (flxdec != NULL);
392 g_return_if_fail (flxdec->delta != NULL);
395 /* use last frame for delta */
396 memcpy (dest, GST_BUFFER_DATA (flxdec->delta),
397 GST_BUFFER_SIZE (flxdec->delta));
399 lines = (data[0] + (data[1] << 8));
406 dest = start_p + (flxdec->hdr.width * (start_l - lines));
408 /* process opcode(s) */
409 while ((opcode = (data[0] + (data[1] << 8))) & 0xc000) {
411 if ((opcode & 0xc000) == 0xc000) {
413 start_l += (0x10000 - opcode);
414 dest += flxdec->hdr.width * (0x10000 - opcode);
417 dest += flxdec->hdr.width;
418 *dest++ = (opcode & 0xff);
423 /* last opcode is the packet count */
432 /* replicate word run */
433 count = 0x100 - count;
440 /* literal word run */
452 gst_flxdec_chain (GstPad * pad, GstBuffer * buf)
456 GstFlowReturn res = GST_FLOW_OK;
460 FlxFrameChunk *flxfh;
462 g_return_val_if_fail (buf != NULL, GST_FLOW_ERROR);
463 flxdec = (GstFlxDec *) gst_pad_get_parent (pad);
464 g_return_val_if_fail (flxdec != NULL, GST_FLOW_ERROR);
466 gst_adapter_push (flxdec->adapter, buf);
467 avail = gst_adapter_available (flxdec->adapter);
469 if (flxdec->state == GST_FLXDEC_READ_HEADER) {
470 if (avail >= FlxHeaderSize) {
471 const guint8 *data = gst_adapter_peek (flxdec->adapter, FlxHeaderSize);
473 memcpy ((gchar *) & flxdec->hdr, data, FlxHeaderSize);
474 gst_adapter_flush (flxdec->adapter, FlxHeaderSize);
479 if (flxh->type != FLX_MAGICHDR_FLI &&
480 flxh->type != FLX_MAGICHDR_FLC && flxh->type != FLX_MAGICHDR_FLX) {
481 GST_ELEMENT_ERROR (flxdec, STREAM, WRONG_TYPE, (NULL),
482 ("not a flx file (type %d)\n", flxh->type));
483 return GST_FLOW_ERROR;
487 GST_LOG ("size : %d\n", flxh->size);
488 GST_LOG ("frames : %d\n", flxh->frames);
489 GST_LOG ("width : %d\n", flxh->width);
490 GST_LOG ("height : %d\n", flxh->height);
491 GST_LOG ("depth : %d\n", flxh->depth);
492 GST_LOG ("speed : %d\n", flxh->speed);
494 flxdec->next_time = 0;
496 if (flxh->type == FLX_MAGICHDR_FLI) {
497 flxdec->frame_time = JIFFIE * flxh->speed;
499 flxdec->frame_time = flxh->speed * GST_MSECOND;
502 caps = gst_caps_from_string (GST_VIDEO_CAPS_xRGB_HOST_ENDIAN);
503 gst_caps_set_simple (caps,
504 "width", G_TYPE_INT, flxh->width,
505 "height", G_TYPE_INT, flxh->height,
506 "framerate", G_TYPE_DOUBLE,
507 (gdouble) (GST_SECOND / flxdec->frame_time), NULL);
509 gst_pad_set_caps (flxdec->srcpad, caps);
510 gst_caps_unref (caps);
512 if (flxh->depth <= 8)
514 flx_colorspace_converter_new (flxh->width, flxh->height);
516 if (flxh->type == FLX_MAGICHDR_FLC || flxh->type == FLX_MAGICHDR_FLX) {
517 GST_LOG ("(FLC) aspect_dx : %d\n", flxh->aspect_dx);
518 GST_LOG ("(FLC) aspect_dy : %d\n", flxh->aspect_dy);
519 GST_LOG ("(FLC) oframe1 : 0x%08x\n", flxh->oframe1);
520 GST_LOG ("(FLC) oframe2 : 0x%08x\n", flxh->oframe2);
523 flxdec->size = (flxh->width * flxh->height);
525 /* create delta and output frame */
526 flxdec->frame = gst_buffer_new ();
527 flxdec->delta = gst_buffer_new ();
528 GST_BUFFER_DATA (flxdec->frame) = g_malloc (flxdec->size);
529 GST_BUFFER_SIZE (flxdec->frame) = flxdec->size;
530 GST_BUFFER_DATA (flxdec->delta) = g_malloc (flxdec->size);
531 GST_BUFFER_SIZE (flxdec->delta) = flxdec->size;
533 flxdec->state = GST_FLXDEC_PLAYING;
535 } else if (flxdec->state == GST_FLXDEC_PLAYING) {
538 if (avail >= FlxFrameChunkSize) {
539 guchar *chunk = NULL;
542 gst_adapter_peek (flxdec->adapter, FlxFrameChunkSize);
543 flxfh = (FlxFrameChunk *) g_memdup (data, FlxFrameChunkSize);
547 if (avail < flxfh->size) {
551 gst_adapter_flush (flxdec->adapter, FlxFrameChunkSize);
552 data = gst_adapter_peek (flxdec->adapter,
553 flxfh->size - FlxFrameChunkSize);
554 chunk = g_memdup (data, flxfh->size - FlxFrameChunkSize);
555 to_flush = flxfh->size - FlxFrameChunkSize;
557 if (((FlxFrameType *) chunk)->chunks == 0)
560 /* create 32 bits output frame */
561 res = gst_pad_alloc_buffer (flxdec->srcpad,
562 GST_BUFFER_OFFSET_NONE,
563 flxdec->size * 4, GST_PAD_CAPS (flxdec->srcpad), &out);
565 if (res != GST_FLOW_OK)
569 flx_decode_chunks (flxdec,
570 ((FlxFrameType *) chunk)->chunks,
571 chunk + FlxFrameTypeSize, GST_BUFFER_DATA (flxdec->frame));
573 /* save copy of the current frame for possible delta. */
574 memcpy (GST_BUFFER_DATA (flxdec->delta),
575 GST_BUFFER_DATA (flxdec->frame), GST_BUFFER_SIZE (flxdec->delta));
577 /* convert current frame. */
578 flx_colorspace_convert (flxdec->converter,
579 GST_BUFFER_DATA (flxdec->frame), GST_BUFFER_DATA (out));
581 GST_BUFFER_TIMESTAMP (out) = flxdec->next_time;
582 flxdec->next_time += flxdec->frame_time;
584 gst_pad_push (flxdec->srcpad, out);
588 gst_adapter_flush (flxdec->adapter, to_flush);
599 static GstStateChangeReturn
600 gst_flxdec_change_state (GstElement * element, GstStateChange transition)
604 flxdec = GST_FLXDEC (element);
606 switch (transition) {
607 case GST_STATE_CHANGE_NULL_TO_READY:
609 case GST_STATE_CHANGE_READY_TO_PAUSED:
610 gst_adapter_clear (flxdec->adapter);
611 flxdec->state = GST_FLXDEC_READ_HEADER;
613 case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
615 case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
617 case GST_STATE_CHANGE_PAUSED_TO_READY:
618 gst_buffer_unref (flxdec->frame);
619 flxdec->frame = NULL;
620 gst_buffer_unref (flxdec->delta);
621 flxdec->delta = NULL;
623 case GST_STATE_CHANGE_READY_TO_NULL:
627 return parent_class->change_state (element, transition);
629 //return GST_STATE_CHANGE_SUCCESS;
633 gst_flxdec_set_property (GObject * object, guint prop_id, const GValue * value,
638 g_return_if_fail (GST_IS_FLXDEC (object));
639 flxdec = GST_FLXDEC (object);
648 gst_flxdec_get_property (GObject * object, guint prop_id, GValue * value,
653 g_return_if_fail (GST_IS_FLXDEC (object));
654 flxdec = GST_FLXDEC (object);
658 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
664 plugin_init (GstPlugin * plugin)
666 return gst_element_register (plugin, "flxdec",
667 GST_RANK_PRIMARY, GST_TYPE_FLXDEC);
670 GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
674 plugin_init, VERSION, GST_LICENSE, GST_PACKAGE, GST_ORIGIN)