fmv/codecs/escape124.c

/*
 * Escape 124 Video Decoder
 * Copyright (C) 2008 Eli Friedman (eli.friedman@gmail.com)
 *
 * This file is part of FFmpeg.
 *
 * FFmpeg is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * FFmpeg 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with FFmpeg; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 */

#include <inttypes.h>
#include <stdlib.h>
#include <SDL2/SDL.h>

#include "../tiny_codec.h"
#define BITSTREAM_READER_LE
#include "../internal/get_bits.h"

typedef union MacroBlock
{
    uint16_t pixels[4];
    uint32_t pixels32[2];
} MacroBlock;

typedef union SuperBlock
{
    uint16_t pixels[64];
    uint32_t pixels32[32];
} SuperBlock;

typedef struct CodeBook
{
    unsigned depth;
    unsigned size;
    MacroBlock *blocks;
} CodeBook;


typedef struct Escape124Context
{
    unsigned num_superblocks;
    uint32_t line_bytes;
    uint8_t *buff1;
    uint8_t *buff2;
    CodeBook codebooks[3];
} Escape124Context;

/**
 * Initialize the decoder
 * @param avctx decoder context
 * @return 0 success, negative on error
 */
static void escape124_free_data(void *data)
{
    if(data)
    {
        unsigned i;
        Escape124Context *s = (Escape124Context*)data;
        for (i = 0; i < 3; i++)
        {
            free(s->codebooks[i].blocks);
        }
        free(s->buff1);
        free(s->buff2);
        free(s);
    }
}

static CodeBook unpack_codebook(GetBitContext* gb, unsigned depth, unsigned size)
{
    unsigned i, j;
    CodeBook cb = { 0 };

    if (size >= INT_MAX / 34 || get_bits_left(gb) < size * 34)
        return cb;

    if (size >= INT_MAX / sizeof(MacroBlock))
        return cb;

    cb.blocks = malloc(size ? size * sizeof(MacroBlock) : 1);
    if (!cb.blocks)
        return cb;

    cb.depth = depth;
    cb.size = size;
    for (i = 0; i < size; i++)
    {
        unsigned mask_bits = get_bits(gb, 4);
        unsigned color0 = get_bits(gb, 15);
        unsigned color1 = get_bits(gb, 15);

        for (j = 0; j < 4; j++)
        {
            if (mask_bits & (1 << j))
                cb.blocks[i].pixels[j] = color1;
            else
                cb.blocks[i].pixels[j] = color0;
        }
    }
    return cb;
}

static unsigned decode_skip_count(GetBitContext* gb)
{
    unsigned value;
    // This function reads a maximum of 23 bits,
    // which is within the padding space
    if (get_bits_left(gb) < 1)
        return -1;
    value = get_bits1(gb);
    if (!value)
        return value;

    value += get_bits(gb, 3);
    if (value != (1 + ((1 << 3) - 1)))
        return value;

    value += get_bits(gb, 7);
    if (value != (1 + ((1 << 3) - 1)) + ((1 << 7) - 1))
        return value;

    return value + get_bits(gb, 12);
}

static MacroBlock decode_macroblock(struct tiny_codec_s *avctx, GetBitContext *gb, unsigned *codebook_index, int superblock_index)
{
    // This function reads a maximum of 22 bits; the callers
    // guard this function appropriately
    unsigned block_index, depth;
    int value = get_bits1(gb);
    if (value)
    {
        static const int8_t transitions[3][2] = { {2, 1}, {0, 2}, {1, 0} };
        value = get_bits1(gb);
        *codebook_index = transitions[*codebook_index][value];
    }
    Escape124Context *s = (Escape124Context*)avctx->video.priv_data;
    depth = s->codebooks[*codebook_index].depth;

    // depth = 0 means that this shouldn't read any bits;
    // in theory, this is the same as get_bits(gb, 0), but
    // that doesn't actually work.
    block_index = get_bitsz(gb, depth);

    if (*codebook_index == 1)
    {
        block_index += superblock_index << s->codebooks[1].depth;
    }

    // This condition can occur with invalid bitstreams and
    // *codebook_index == 2
    if (block_index >= s->codebooks[*codebook_index].size)
        return (MacroBlock) { { 0 } };

    return s->codebooks[*codebook_index].blocks[block_index];
}

static void insert_mb_into_sb(SuperBlock* sb, MacroBlock mb, unsigned index)
{
   // Formula: ((index / 4) * 16 + (index % 4) * 2) / 2
   uint32_t *dst = sb->pixels32 + index + (index & -4);

   // This technically violates C99 aliasing rules, but it should be safe.
   dst[0] = mb.pixels32[0];
   dst[4] = mb.pixels32[1];
}

static void copy_superblock(uint16_t* dest, unsigned dest_stride,
                            uint16_t* src, unsigned src_stride)
{
    unsigned y;
    if (src)
        for (y = 0; y < 8; y++)
            memcpy(dest + y * dest_stride, src + y * src_stride,
                   sizeof(uint16_t) * 8);
    else
        for (y = 0; y < 8; y++)
            memset(dest + y * dest_stride, 0, sizeof(uint16_t) * 8);
}

static const uint16_t mask_matrix[] = {0x1,   0x2,   0x10,   0x20,
                                       0x4,   0x8,   0x40,   0x80,
                                       0x100, 0x200, 0x1000, 0x2000,
                                       0x400, 0x800, 0x4000, 0x8000};

static int escape124_decode_frame(struct tiny_codec_s *avctx, struct AVPacket *avpkt)
{
    Escape124Context *s = (Escape124Context*)avctx->video.priv_data;

    GetBitContext gb;
    unsigned frame_flags, frame_size;
    unsigned i;

    unsigned superblock_index, cb_index = 1,
             superblock_col_index = 0,
             superblocks_per_row = avctx->video.width / 8, skip = -1;

    uint16_t* old_frame_data, *new_frame_data;
    unsigned old_stride, new_stride;

    int ret;

    if ((ret = init_get_bits8(&gb, avpkt->data, avpkt->size)) < 0)
        return ret;

    // This call also guards the potential depth reads for the
    // codebook unpacking.
    if (get_bits_left(&gb) < 64)
        return -1;

    frame_flags = get_bits_long(&gb, 32);
    frame_size  = get_bits_long(&gb, 32);

    // Leave last frame unchanged
    // FIXME: Is this necessary?  I haven't seen it in any real samples
    if (!(frame_flags & 0x114) || !(frame_flags & 0x7800000))
    {
        //av_log(avctx, AV_LOG_DEBUG, "Skipping frame\n");
        return frame_size;
    }

    for (i = 0; i < 3; i++)
    {
        if (frame_flags & (1 << (17 + i)))
        {
            unsigned cb_depth, cb_size;
            if (i == 2)
            {
                // This codebook can be cut off at places other than
                // powers of 2, leaving some of the entries undefined.
                cb_size = get_bits_long(&gb, 20);
                if (!cb_size)
                {
                    //av_log(avctx, AV_LOG_ERROR, "Invalid codebook size 0.\n");
                    return -1;
                }
                cb_depth = av_log2(cb_size - 1) + 1;
            }
            else
            {
                cb_depth = get_bits(&gb, 4);
                if (i == 0)
                {
                    // This is the most basic codebook: pow(2,depth) entries
                    // for a depth-length key
                    cb_size = 1 << cb_depth;
                }
                else
                {
                    // This codebook varies per superblock
                    // FIXME: I don't think this handles integer overflow
                    // properly
                    cb_size = s->num_superblocks << cb_depth;
                }
            }
            if (s->num_superblocks >= INT_MAX >> cb_depth)
            {
                //av_log(avctx, AV_LOG_ERROR, "Depth or num_superblocks are too large\n");
                return -1;
            }

            free(s->codebooks[i].blocks);
            s->codebooks[i] = unpack_codebook(&gb, cb_depth, cb_size);
            if (!s->codebooks[i].blocks)
                return -1;
        }
    }

    new_frame_data = (uint16_t*)s->buff1;
    new_stride = s->line_bytes / 2;
    old_frame_data = (uint16_t*)s->buff2;
    old_stride = s->line_bytes / 2;
    //memcpy(old_frame_data, new_frame_data, s->line_bytes * avctx->video.height);

    for (superblock_index = 0; superblock_index < s->num_superblocks; superblock_index++)
    {
        MacroBlock mb;
        SuperBlock sb;
        unsigned multi_mask = 0;

        if (skip == -1)
        {
            // Note that this call will make us skip the rest of the blocks
            // if the frame prematurely ends
            skip = decode_skip_count(&gb);
        }

        if (skip)
        {
            copy_superblock(new_frame_data, new_stride,
                            old_frame_data, old_stride);
        }
        else
        {
            copy_superblock(sb.pixels, 8,
                            old_frame_data, old_stride);

            while (get_bits_left(&gb) >= 1 && !get_bits1(&gb))
            {
                unsigned mask;
                mb = decode_macroblock(avctx, &gb, &cb_index, superblock_index);
                mask = get_bits(&gb, 16);
                multi_mask |= mask;
                for (i = 0; i < 16; i++)
                {
                    if (mask & mask_matrix[i])
                    {
                        insert_mb_into_sb(&sb, mb, i);
                    }
                }
            }

            if (!get_bits1(&gb))
            {
                unsigned inv_mask = get_bits(&gb, 4);
                for (i = 0; i < 4; i++)
                {
                    if (inv_mask & (1 << i))
                    {
                        multi_mask ^= 0xF << i*4;
                    }
                    else
                    {
                        multi_mask ^= get_bits(&gb, 4) << i*4;
                    }
                }

                for (i = 0; i < 16; i++)
                {
                    if (multi_mask & mask_matrix[i])
                    {
                        mb = decode_macroblock(avctx, &gb, &cb_index, superblock_index);
                        insert_mb_into_sb(&sb, mb, i);
                    }
                }
            }
            else if (frame_flags & (1 << 16))
            {
                while (get_bits_left(&gb) >= 1 && !get_bits1(&gb))
                {
                    mb = decode_macroblock(avctx, &gb, &cb_index, superblock_index);
                    insert_mb_into_sb(&sb, mb, get_bits(&gb, 4));
                }
            }

            copy_superblock(new_frame_data, new_stride, sb.pixels, 8);
        }

        superblock_col_index++;
        new_frame_data += 8;
        if (old_frame_data)
            old_frame_data += 8;
        if (superblock_col_index == superblocks_per_row)
        {
            new_frame_data += new_stride * 8 - superblocks_per_row * 8;
            if (old_frame_data)
                old_frame_data += old_stride * 8 - superblocks_per_row * 8;
            superblock_col_index = 0;
        }
        skip--;
    }

    if(avctx->video.rgba)
    {
        uint8_t *rgba = avctx->video.rgba;
        for(i = 0; i < avctx->video.height; ++i)
        {
            uint16_t *px = (uint16_t*)s->buff1 + i * new_stride;
            for(int j = 0; j < avctx->video.width; ++j, ++px)
            {
                *rgba++ = ((*px) & 0x7C00) >> (10 - 3);
                *rgba++ = ((*px) & 0x03E0) >> (5 - 3);
                *rgba++ = ((*px) & 0x001F) << 3 ;
                *rgba++ = 0xFF;
            }
        }
    }
    FFSWAP(uint8_t*, s->buff1, s->buff2);

    return frame_size;
}

void escape124_decode_init(struct tiny_codec_s *avctx)
{
    avctx->video.decode = escape124_decode_frame;
    if(!avctx->video.priv_data)
    {
        Escape124Context *s = (Escape124Context*)malloc(sizeof(Escape124Context));
        avctx->video.priv_data = s;
        avctx->video.free_data = escape124_free_data;
        s->num_superblocks = ((unsigned)avctx->video.width / 8) *
                             ((unsigned)avctx->video.height / 8);
        s->line_bytes = avctx->video.width * 2;
        s->buff1 = (uint8_t*)calloc(1, s->line_bytes * avctx->video.height);
        s->buff2 = (uint8_t*)calloc(1, s->line_bytes * avctx->video.height);
        for(int i = 0; i < 3; i++)
        {
            s->codebooks[i].blocks = NULL;
        }
    }
}