| Line | Branch | Exec | Source |
|---|---|---|---|
| 1 | /* | ||
| 2 | * V210 decoder | ||
| 3 | * | ||
| 4 | * Copyright (C) 2009 Michael Niedermayer <michaelni@gmx.at> | ||
| 5 | * Copyright (c) 2009 Baptiste Coudurier <baptiste dot coudurier at gmail dot com> | ||
| 6 | * | ||
| 7 | * This file is part of FFmpeg. | ||
| 8 | * | ||
| 9 | * FFmpeg is free software; you can redistribute it and/or | ||
| 10 | * modify it under the terms of the GNU Lesser General Public | ||
| 11 | * License as published by the Free Software Foundation; either | ||
| 12 | * version 2.1 of the License, or (at your option) any later version. | ||
| 13 | * | ||
| 14 | * FFmpeg is distributed in the hope that it will be useful, | ||
| 15 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
| 16 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | ||
| 17 | * Lesser General Public License for more details. | ||
| 18 | * | ||
| 19 | * You should have received a copy of the GNU Lesser General Public | ||
| 20 | * License along with FFmpeg; if not, write to the Free Software | ||
| 21 | * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA | ||
| 22 | */ | ||
| 23 | |||
| 24 | #include "avcodec.h" | ||
| 25 | #include "codec_internal.h" | ||
| 26 | #include "v210dec.h" | ||
| 27 | #include "v210dec_init.h" | ||
| 28 | #include "libavutil/bswap.h" | ||
| 29 | #include "libavutil/imgutils.h" | ||
| 30 | #include "libavutil/internal.h" | ||
| 31 | #include "libavutil/intreadwrite.h" | ||
| 32 | #include "libavutil/mem.h" | ||
| 33 | #include "thread.h" | ||
| 34 | |||
| 35 | typedef struct ThreadData { | ||
| 36 | AVFrame *frame; | ||
| 37 | const uint8_t *buf; | ||
| 38 | int stride; | ||
| 39 | } ThreadData; | ||
| 40 | |||
| 41 | 18 | static av_cold int decode_init(AVCodecContext *avctx) | |
| 42 | { | ||
| 43 | 18 | V210DecContext *s = avctx->priv_data; | |
| 44 | |||
| 45 | 18 | avctx->pix_fmt = AV_PIX_FMT_YUV422P10; | |
| 46 | 18 | avctx->bits_per_raw_sample = 10; | |
| 47 | |||
| 48 | 18 | s->thread_count = av_clip(avctx->thread_count, 1, avctx->height/4); | |
| 49 | 18 | s->aligned_input = 0; | |
| 50 | 18 | ff_v210dec_init(s); | |
| 51 | |||
| 52 | 18 | return 0; | |
| 53 | } | ||
| 54 | |||
| 55 | 90520 | static void decode_row(const uint32_t *src, uint16_t *y, uint16_t *u, uint16_t *v, const int width, | |
| 56 | void (*unpack_frame)(const uint32_t *src, uint16_t *y, uint16_t *u, uint16_t *v, int width)) | ||
| 57 | { | ||
| 58 | uint32_t val; | ||
| 59 | 90520 | int w = (FFMAX(0, width - 12) / 12) * 12; | |
| 60 | |||
| 61 | 90520 | unpack_frame(src, y, u, v, w); | |
| 62 | |||
| 63 | 90520 | y += w; | |
| 64 | 90520 | u += w >> 1; | |
| 65 | 90520 | v += w >> 1; | |
| 66 | 90520 | src += (w << 1) / 3; | |
| 67 | |||
| 68 |
2/2✓ Branch 0 taken 185160 times.
✓ Branch 1 taken 90520 times.
|
275680 | while (w < width - 5) { |
| 69 | 185160 | READ_PIXELS(u, y, v); | |
| 70 | 185160 | READ_PIXELS(y, u, y); | |
| 71 | 185160 | READ_PIXELS(v, y, u); | |
| 72 | 185160 | READ_PIXELS(y, v, y); | |
| 73 | 185160 | w += 6; | |
| 74 | } | ||
| 75 | |||
| 76 |
1/2✓ Branch 0 taken 90520 times.
✗ Branch 1 not taken.
|
90520 | if (w++ < width) { |
| 77 | 90520 | READ_PIXELS(u, y, v); | |
| 78 | |||
| 79 |
1/2✓ Branch 0 taken 90520 times.
✗ Branch 1 not taken.
|
90520 | if (w++ < width) { |
| 80 | 90520 | val = av_le2ne32(*src++); | |
| 81 | 90520 | *y++ = val & 0x3FF; | |
| 82 | |||
| 83 |
2/2✓ Branch 0 taken 89800 times.
✓ Branch 1 taken 720 times.
|
90520 | if (w++ < width) { |
| 84 | 89800 | *u++ = (val >> 10) & 0x3FF; | |
| 85 | 89800 | *y++ = (val >> 20) & 0x3FF; | |
| 86 | 89800 | val = av_le2ne32(*src++); | |
| 87 | 89800 | *v++ = val & 0x3FF; | |
| 88 | |||
| 89 |
1/2✓ Branch 0 taken 89800 times.
✗ Branch 1 not taken.
|
89800 | if (w++ < width) { |
| 90 | 89800 | *y++ = (val >> 10) & 0x3FF; | |
| 91 | |||
| 92 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 89800 times.
|
89800 | if (w++ < width) { |
| 93 | ✗ | *u++ = (val >> 20) & 0x3FF; | |
| 94 | ✗ | val = av_le2ne32(*src++); | |
| 95 | ✗ | *y++ = val & 0x3FF; | |
| 96 | ✗ | *v++ = (val >> 10) & 0x3FF; | |
| 97 | |||
| 98 | ✗ | if (w++ < width) | |
| 99 | ✗ | *y++ = (val >> 20) & 0x3FF; | |
| 100 | } | ||
| 101 | } | ||
| 102 | } | ||
| 103 | } | ||
| 104 | } | ||
| 105 | 90520 | } | |
| 106 | |||
| 107 | 401 | static int v210_decode_slice(AVCodecContext *avctx, void *arg, int jobnr, int threadnr) | |
| 108 | { | ||
| 109 | 401 | V210DecContext *s = avctx->priv_data; | |
| 110 | 401 | ThreadData *td = arg; | |
| 111 | 401 | AVFrame *frame = td->frame; | |
| 112 | 401 | int stride = td->stride; | |
| 113 | 401 | int slice_start = (avctx->height * jobnr) / s->thread_count; | |
| 114 | 401 | int slice_end = (avctx->height * (jobnr+1)) / s->thread_count; | |
| 115 | 401 | const uint8_t *psrc = td->buf + stride * slice_start; | |
| 116 | 401 | int16_t *py = (uint16_t*)frame->data[0] + slice_start * frame->linesize[0] / 2; | |
| 117 | 401 | int16_t *pu = (uint16_t*)frame->data[1] + slice_start * frame->linesize[1] / 2; | |
| 118 | 401 | int16_t *pv = (uint16_t*)frame->data[2] + slice_start * frame->linesize[2] / 2; | |
| 119 | |||
| 120 |
2/2✓ Branch 0 taken 90520 times.
✓ Branch 1 taken 401 times.
|
90921 | for (int h = slice_start; h < slice_end; h++) { |
| 121 | 90520 | decode_row((const uint32_t *)psrc, py, pu, pv, avctx->width, s->unpack_frame); | |
| 122 | 90520 | psrc += stride; | |
| 123 | 90520 | py += frame->linesize[0] / 2; | |
| 124 | 90520 | pu += frame->linesize[1] / 2; | |
| 125 | 90520 | pv += frame->linesize[2] / 2; | |
| 126 | } | ||
| 127 | |||
| 128 | 401 | return 0; | |
| 129 | } | ||
| 130 | |||
| 131 | 405 | static int v210_stride(int width, int align) { | |
| 132 | 405 | int aligned_width = ((width + align - 1) / align) * align; | |
| 133 | 405 | return aligned_width * 8 / 3; | |
| 134 | } | ||
| 135 | |||
| 136 | 402 | static int decode_frame(AVCodecContext *avctx, AVFrame *pic, | |
| 137 | int *got_frame, AVPacket *avpkt) | ||
| 138 | { | ||
| 139 | 402 | V210DecContext *s = avctx->priv_data; | |
| 140 | ThreadData td; | ||
| 141 | int ret, stride, aligned_input; | ||
| 142 | 402 | const uint8_t *psrc = avpkt->data; | |
| 143 | |||
| 144 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 402 times.
|
402 | if (s->custom_stride ) |
| 145 | ✗ | stride = s->custom_stride > 0 ? s->custom_stride : 0; | |
| 146 | else { | ||
| 147 | 402 | stride = v210_stride(avctx->width, 48); | |
| 148 |
2/2✓ Branch 0 taken 1 times.
✓ Branch 1 taken 401 times.
|
402 | if (avpkt->size < stride * avctx->height) { |
| 149 | int align; | ||
| 150 |
2/2✓ Branch 0 taken 3 times.
✓ Branch 1 taken 1 times.
|
4 | for (align = 24; align >= 6; align >>= 1) { |
| 151 | 3 | int small_stride = v210_stride(avctx->width, align); | |
| 152 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 3 times.
|
3 | if (avpkt->size == small_stride * avctx->height) { |
| 153 | ✗ | stride = small_stride; | |
| 154 | ✗ | if (!s->stride_warning_shown) | |
| 155 | ✗ | av_log(avctx, AV_LOG_WARNING, "Broken v210 with too small padding (%d byte) detected\n", align * 8 / 3); | |
| 156 | ✗ | s->stride_warning_shown = 1; | |
| 157 | ✗ | break; | |
| 158 | } | ||
| 159 | } | ||
| 160 |
2/4✓ Branch 0 taken 1 times.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 1 times.
|
1 | if (align < 6 && avctx->codec_tag == MKTAG('b', 'x', 'y', '2')) |
| 161 | ✗ | stride = 0; | |
| 162 | } | ||
| 163 | } | ||
| 164 | |||
| 165 |
1/6✗ Branch 0 not taken.
✓ Branch 1 taken 402 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
|
402 | if (stride == 0 && ((avctx->width & 1) || (int64_t)avctx->width * avctx->height > INT_MAX / 6)) { |
| 166 | ✗ | av_log(avctx, AV_LOG_ERROR, "Strideless v210 is not supported for size %dx%d\n", avctx->width, avctx->height); | |
| 167 | ✗ | return AVERROR_INVALIDDATA; | |
| 168 | } | ||
| 169 | |||
| 170 |
4/6✓ Branch 0 taken 402 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 401 times.
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 401 times.
|
402 | if (stride > 0 && avpkt->size < (int64_t)stride * avctx->height || |
| 171 | ✗ | stride == 0 && avpkt->size < v210_stride(avctx->width * avctx->height, 6)) { | |
| 172 | 1 | av_log(avctx, AV_LOG_ERROR, "packet too small\n"); | |
| 173 | 1 | return AVERROR_INVALIDDATA; | |
| 174 | } | ||
| 175 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 401 times.
|
401 | if ( avctx->codec_tag == MKTAG('C', '2', '1', '0') |
| 176 | ✗ | && avpkt->size > 64 | |
| 177 | ✗ | && AV_RN32(psrc) == AV_RN32("INFO") | |
| 178 | ✗ | && avpkt->size - 64 >= stride * avctx->height) | |
| 179 | ✗ | psrc += 64; | |
| 180 | |||
| 181 |
2/4✓ Branch 0 taken 401 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 401 times.
✗ Branch 3 not taken.
|
401 | aligned_input = !((uintptr_t)psrc & 0x1f) && !(stride & 0x1f); |
| 182 |
2/2✓ Branch 0 taken 9 times.
✓ Branch 1 taken 392 times.
|
401 | if (aligned_input != s->aligned_input) { |
| 183 | 9 | s->aligned_input = aligned_input; | |
| 184 | 9 | ff_v210dec_init(s); | |
| 185 | } | ||
| 186 | |||
| 187 |
1/2✗ Branch 1 not taken.
✓ Branch 2 taken 401 times.
|
401 | if ((ret = ff_thread_get_buffer(avctx, pic, 0)) < 0) |
| 188 | ✗ | return ret; | |
| 189 | |||
| 190 |
1/2✓ Branch 0 taken 401 times.
✗ Branch 1 not taken.
|
401 | if (stride) { |
| 191 | 401 | td.stride = stride; | |
| 192 | 401 | td.buf = psrc; | |
| 193 | 401 | td.frame = pic; | |
| 194 | 401 | avctx->execute2(avctx, v210_decode_slice, &td, NULL, s->thread_count); | |
| 195 | } else { | ||
| 196 | uint8_t *pointers[4]; | ||
| 197 | int linesizes[4]; | ||
| 198 | ✗ | int ret = av_image_alloc(pointers, linesizes, avctx->width, avctx->height, avctx->pix_fmt, 1); | |
| 199 | ✗ | if (ret < 0) | |
| 200 | ✗ | return ret; | |
| 201 | ✗ | decode_row((const uint32_t *)psrc, (uint16_t *)pointers[0], (uint16_t *)pointers[1], (uint16_t *)pointers[2], avctx->width * avctx->height, s->unpack_frame); | |
| 202 | ✗ | av_image_copy2(pic->data, pic->linesize, pointers, linesizes, | |
| 203 | avctx->pix_fmt, avctx->width, avctx->height); | ||
| 204 | ✗ | av_freep(&pointers[0]); | |
| 205 | } | ||
| 206 | |||
| 207 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 401 times.
|
401 | if (avctx->field_order > AV_FIELD_PROGRESSIVE) { |
| 208 | /* we have interlaced material flagged in container */ | ||
| 209 | ✗ | pic->flags |= AV_FRAME_FLAG_INTERLACED; | |
| 210 | ✗ | if (avctx->field_order == AV_FIELD_TT || avctx->field_order == AV_FIELD_TB) | |
| 211 | ✗ | pic->flags |= AV_FRAME_FLAG_TOP_FIELD_FIRST; | |
| 212 | } | ||
| 213 | |||
| 214 | 401 | *got_frame = 1; | |
| 215 | |||
| 216 | 401 | return avpkt->size; | |
| 217 | } | ||
| 218 | |||
| 219 | #define V210DEC_FLAGS AV_OPT_FLAG_DECODING_PARAM | AV_OPT_FLAG_VIDEO_PARAM | ||
| 220 | static const AVOption v210dec_options[] = { | ||
| 221 | {"custom_stride", "Custom V210 stride", offsetof(V210DecContext, custom_stride), AV_OPT_TYPE_INT, | ||
| 222 | {.i64 = 0}, -1, INT_MAX, V210DEC_FLAGS}, | ||
| 223 | {NULL} | ||
| 224 | }; | ||
| 225 | |||
| 226 | static const AVClass v210dec_class = { | ||
| 227 | .class_name = "V210 Decoder", | ||
| 228 | .item_name = av_default_item_name, | ||
| 229 | .option = v210dec_options, | ||
| 230 | .version = LIBAVUTIL_VERSION_INT, | ||
| 231 | }; | ||
| 232 | |||
| 233 | const FFCodec ff_v210_decoder = { | ||
| 234 | .p.name = "v210", | ||
| 235 | CODEC_LONG_NAME("Uncompressed 4:2:2 10-bit"), | ||
| 236 | .p.type = AVMEDIA_TYPE_VIDEO, | ||
| 237 | .p.id = AV_CODEC_ID_V210, | ||
| 238 | .priv_data_size = sizeof(V210DecContext), | ||
| 239 | .init = decode_init, | ||
| 240 | FF_CODEC_DECODE_CB(decode_frame), | ||
| 241 | .p.capabilities = AV_CODEC_CAP_DR1 | | ||
| 242 | AV_CODEC_CAP_SLICE_THREADS | | ||
| 243 | AV_CODEC_CAP_FRAME_THREADS, | ||
| 244 | .p.priv_class = &v210dec_class, | ||
| 245 | }; | ||
| 246 |