You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

310 lines
11KB

  1. /*
  2. * RV30 decoder
  3. * Copyright (c) 2007 Konstantin Shishkov
  4. *
  5. * This file is part of FFmpeg.
  6. *
  7. * FFmpeg is free software; you can redistribute it and/or
  8. * modify it under the terms of the GNU Lesser General Public
  9. * License as published by the Free Software Foundation; either
  10. * version 2.1 of the License, or (at your option) any later version.
  11. *
  12. * FFmpeg is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  15. * Lesser General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU Lesser General Public
  18. * License along with FFmpeg; if not, write to the Free Software
  19. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  20. */
  21. /**
  22. * @file
  23. * RV30 decoder
  24. */
  25. #include "avcodec.h"
  26. #include "mpegutils.h"
  27. #include "mpegvideo.h"
  28. #include "golomb.h"
  29. #include "rv34.h"
  30. #include "rv30data.h"
  31. static int rv30_parse_slice_header(RV34DecContext *r, GetBitContext *gb, SliceInfo *si)
  32. {
  33. AVCodecContext *avctx = r->s.avctx;
  34. int mb_bits;
  35. int w = r->s.width, h = r->s.height;
  36. int mb_size;
  37. int rpr;
  38. memset(si, 0, sizeof(SliceInfo));
  39. if(get_bits(gb, 3))
  40. return -1;
  41. si->type = get_bits(gb, 2);
  42. if(si->type == 1) si->type = 0;
  43. if(get_bits1(gb))
  44. return -1;
  45. si->quant = get_bits(gb, 5);
  46. skip_bits1(gb);
  47. si->pts = get_bits(gb, 13);
  48. rpr = get_bits(gb, av_log2(r->max_rpr) + 1);
  49. if(rpr){
  50. if (rpr > r->max_rpr) {
  51. av_log(avctx, AV_LOG_ERROR, "rpr too large\n");
  52. return AVERROR_INVALIDDATA;
  53. }
  54. if (avctx->extradata_size < rpr * 2 + 8) {
  55. av_log(avctx, AV_LOG_ERROR,
  56. "Insufficient extradata - need at least %d bytes, got %d\n",
  57. 8 + rpr * 2, avctx->extradata_size);
  58. return AVERROR(EINVAL);
  59. }
  60. w = r->s.avctx->extradata[6 + rpr*2] << 2;
  61. h = r->s.avctx->extradata[7 + rpr*2] << 2;
  62. } else {
  63. w = r->orig_width;
  64. h = r->orig_height;
  65. }
  66. si->width = w;
  67. si->height = h;
  68. mb_size = ((w + 15) >> 4) * ((h + 15) >> 4);
  69. mb_bits = ff_rv34_get_start_offset(gb, mb_size);
  70. si->start = get_bits(gb, mb_bits);
  71. skip_bits1(gb);
  72. return 0;
  73. }
  74. /**
  75. * Decode 4x4 intra types array.
  76. */
  77. static int rv30_decode_intra_types(RV34DecContext *r, GetBitContext *gb, int8_t *dst)
  78. {
  79. int i, j, k;
  80. for(i = 0; i < 4; i++, dst += r->intra_types_stride - 4){
  81. for(j = 0; j < 4; j+= 2){
  82. unsigned code = get_interleaved_ue_golomb(gb) << 1;
  83. if (code > 80U*2U) {
  84. av_log(r->s.avctx, AV_LOG_ERROR, "Incorrect intra prediction code\n");
  85. return -1;
  86. }
  87. for(k = 0; k < 2; k++){
  88. int A = dst[-r->intra_types_stride] + 1;
  89. int B = dst[-1] + 1;
  90. *dst++ = rv30_itype_from_context[A * 90 + B * 9 + rv30_itype_code[code + k]];
  91. if(dst[-1] == 9){
  92. av_log(r->s.avctx, AV_LOG_ERROR, "Incorrect intra prediction mode\n");
  93. return -1;
  94. }
  95. }
  96. }
  97. }
  98. return 0;
  99. }
  100. /**
  101. * Decode macroblock information.
  102. */
  103. static int rv30_decode_mb_info(RV34DecContext *r)
  104. {
  105. static const int rv30_p_types[6] = { RV34_MB_SKIP, RV34_MB_P_16x16, RV34_MB_P_8x8, -1, RV34_MB_TYPE_INTRA, RV34_MB_TYPE_INTRA16x16 };
  106. static const int rv30_b_types[6] = { RV34_MB_SKIP, RV34_MB_B_DIRECT, RV34_MB_B_FORWARD, RV34_MB_B_BACKWARD, RV34_MB_TYPE_INTRA, RV34_MB_TYPE_INTRA16x16 };
  107. MpegEncContext *s = &r->s;
  108. GetBitContext *gb = &s->gb;
  109. unsigned code = get_interleaved_ue_golomb(gb);
  110. if (code > 11) {
  111. av_log(s->avctx, AV_LOG_ERROR, "Incorrect MB type code\n");
  112. return -1;
  113. }
  114. if(code > 5){
  115. av_log(s->avctx, AV_LOG_ERROR, "dquant needed\n");
  116. code -= 6;
  117. }
  118. if(s->pict_type != AV_PICTURE_TYPE_B)
  119. return rv30_p_types[code];
  120. else
  121. return rv30_b_types[code];
  122. }
  123. static inline void rv30_weak_loop_filter(uint8_t *src, const int step,
  124. const int stride, const int lim)
  125. {
  126. const uint8_t *cm = ff_crop_tab + MAX_NEG_CROP;
  127. int i, diff;
  128. for(i = 0; i < 4; i++){
  129. diff = ((src[-2*step] - src[1*step]) - (src[-1*step] - src[0*step])*4) >> 3;
  130. diff = av_clip(diff, -lim, lim);
  131. src[-1*step] = cm[src[-1*step] + diff];
  132. src[ 0*step] = cm[src[ 0*step] - diff];
  133. src += stride;
  134. }
  135. }
  136. static void rv30_loop_filter(RV34DecContext *r, int row)
  137. {
  138. MpegEncContext *s = &r->s;
  139. int mb_pos, mb_x;
  140. int i, j, k;
  141. uint8_t *Y, *C;
  142. int loc_lim, cur_lim, left_lim = 0, top_lim = 0;
  143. mb_pos = row * s->mb_stride;
  144. for(mb_x = 0; mb_x < s->mb_width; mb_x++, mb_pos++){
  145. int mbtype = s->current_picture_ptr->mb_type[mb_pos];
  146. if(IS_INTRA(mbtype) || IS_SEPARATE_DC(mbtype))
  147. r->deblock_coefs[mb_pos] = 0xFFFF;
  148. if(IS_INTRA(mbtype))
  149. r->cbp_chroma[mb_pos] = 0xFF;
  150. }
  151. /* all vertical edges are filtered first
  152. * and horizontal edges are filtered on the next iteration
  153. */
  154. mb_pos = row * s->mb_stride;
  155. for(mb_x = 0; mb_x < s->mb_width; mb_x++, mb_pos++){
  156. cur_lim = rv30_loop_filt_lim[s->current_picture_ptr->qscale_table[mb_pos]];
  157. if(mb_x)
  158. left_lim = rv30_loop_filt_lim[s->current_picture_ptr->qscale_table[mb_pos - 1]];
  159. for(j = 0; j < 16; j += 4){
  160. Y = s->current_picture_ptr->f->data[0] + mb_x*16 + (row*16 + j) * s->linesize + 4 * !mb_x;
  161. for(i = !mb_x; i < 4; i++, Y += 4){
  162. int ij = i + j;
  163. loc_lim = 0;
  164. if(r->deblock_coefs[mb_pos] & (1 << ij))
  165. loc_lim = cur_lim;
  166. else if(!i && r->deblock_coefs[mb_pos - 1] & (1 << (ij + 3)))
  167. loc_lim = left_lim;
  168. else if( i && r->deblock_coefs[mb_pos] & (1 << (ij - 1)))
  169. loc_lim = cur_lim;
  170. if(loc_lim)
  171. rv30_weak_loop_filter(Y, 1, s->linesize, loc_lim);
  172. }
  173. }
  174. for(k = 0; k < 2; k++){
  175. int cur_cbp, left_cbp = 0;
  176. cur_cbp = (r->cbp_chroma[mb_pos] >> (k*4)) & 0xF;
  177. if(mb_x)
  178. left_cbp = (r->cbp_chroma[mb_pos - 1] >> (k*4)) & 0xF;
  179. for(j = 0; j < 8; j += 4){
  180. C = s->current_picture_ptr->f->data[k + 1] + mb_x*8 + (row*8 + j) * s->uvlinesize + 4 * !mb_x;
  181. for(i = !mb_x; i < 2; i++, C += 4){
  182. int ij = i + (j >> 1);
  183. loc_lim = 0;
  184. if (cur_cbp & (1 << ij))
  185. loc_lim = cur_lim;
  186. else if(!i && left_cbp & (1 << (ij + 1)))
  187. loc_lim = left_lim;
  188. else if( i && cur_cbp & (1 << (ij - 1)))
  189. loc_lim = cur_lim;
  190. if(loc_lim)
  191. rv30_weak_loop_filter(C, 1, s->uvlinesize, loc_lim);
  192. }
  193. }
  194. }
  195. }
  196. mb_pos = row * s->mb_stride;
  197. for(mb_x = 0; mb_x < s->mb_width; mb_x++, mb_pos++){
  198. cur_lim = rv30_loop_filt_lim[s->current_picture_ptr->qscale_table[mb_pos]];
  199. if(row)
  200. top_lim = rv30_loop_filt_lim[s->current_picture_ptr->qscale_table[mb_pos - s->mb_stride]];
  201. for(j = 4*!row; j < 16; j += 4){
  202. Y = s->current_picture_ptr->f->data[0] + mb_x*16 + (row*16 + j) * s->linesize;
  203. for(i = 0; i < 4; i++, Y += 4){
  204. int ij = i + j;
  205. loc_lim = 0;
  206. if(r->deblock_coefs[mb_pos] & (1 << ij))
  207. loc_lim = cur_lim;
  208. else if(!j && r->deblock_coefs[mb_pos - s->mb_stride] & (1 << (ij + 12)))
  209. loc_lim = top_lim;
  210. else if( j && r->deblock_coefs[mb_pos] & (1 << (ij - 4)))
  211. loc_lim = cur_lim;
  212. if(loc_lim)
  213. rv30_weak_loop_filter(Y, s->linesize, 1, loc_lim);
  214. }
  215. }
  216. for(k = 0; k < 2; k++){
  217. int cur_cbp, top_cbp = 0;
  218. cur_cbp = (r->cbp_chroma[mb_pos] >> (k*4)) & 0xF;
  219. if(row)
  220. top_cbp = (r->cbp_chroma[mb_pos - s->mb_stride] >> (k*4)) & 0xF;
  221. for(j = 4*!row; j < 8; j += 4){
  222. C = s->current_picture_ptr->f->data[k+1] + mb_x*8 + (row*8 + j) * s->uvlinesize;
  223. for(i = 0; i < 2; i++, C += 4){
  224. int ij = i + (j >> 1);
  225. loc_lim = 0;
  226. if (r->cbp_chroma[mb_pos] & (1 << ij))
  227. loc_lim = cur_lim;
  228. else if(!j && top_cbp & (1 << (ij + 2)))
  229. loc_lim = top_lim;
  230. else if( j && cur_cbp & (1 << (ij - 2)))
  231. loc_lim = cur_lim;
  232. if(loc_lim)
  233. rv30_weak_loop_filter(C, s->uvlinesize, 1, loc_lim);
  234. }
  235. }
  236. }
  237. }
  238. }
  239. /**
  240. * Initialize decoder.
  241. */
  242. static av_cold int rv30_decode_init(AVCodecContext *avctx)
  243. {
  244. RV34DecContext *r = avctx->priv_data;
  245. int ret;
  246. r->orig_width = avctx->coded_width;
  247. r->orig_height = avctx->coded_height;
  248. if (avctx->extradata_size < 2) {
  249. av_log(avctx, AV_LOG_ERROR, "Extradata is too small.\n");
  250. return AVERROR(EINVAL);
  251. }
  252. r->rv30 = 1;
  253. if ((ret = ff_rv34_decode_init(avctx)) < 0)
  254. return ret;
  255. r->max_rpr = avctx->extradata[1] & 7;
  256. if(avctx->extradata_size < 2*r->max_rpr + 8){
  257. av_log(avctx, AV_LOG_WARNING, "Insufficient extradata - need at least %d bytes, got %d\n",
  258. 2*r->max_rpr + 8, avctx->extradata_size);
  259. }
  260. r->parse_slice_header = rv30_parse_slice_header;
  261. r->decode_intra_types = rv30_decode_intra_types;
  262. r->decode_mb_info = rv30_decode_mb_info;
  263. r->loop_filter = rv30_loop_filter;
  264. r->luma_dc_quant_i = rv30_luma_dc_quant;
  265. r->luma_dc_quant_p = rv30_luma_dc_quant;
  266. return 0;
  267. }
  268. AVCodec ff_rv30_decoder = {
  269. .name = "rv30",
  270. .long_name = NULL_IF_CONFIG_SMALL("RealVideo 3.0"),
  271. .type = AVMEDIA_TYPE_VIDEO,
  272. .id = AV_CODEC_ID_RV30,
  273. .priv_data_size = sizeof(RV34DecContext),
  274. .init = rv30_decode_init,
  275. .close = ff_rv34_decode_end,
  276. .decode = ff_rv34_decode_frame,
  277. .capabilities = AV_CODEC_CAP_DR1 | AV_CODEC_CAP_DELAY |
  278. AV_CODEC_CAP_FRAME_THREADS,
  279. .flush = ff_mpeg_flush,
  280. .pix_fmts = (const enum AVPixelFormat[]) {
  281. AV_PIX_FMT_YUV420P,
  282. AV_PIX_FMT_NONE
  283. },
  284. .init_thread_copy = ONLY_IF_THREADS_ENABLED(ff_rv34_decode_init_thread_copy),
  285. .update_thread_context = ONLY_IF_THREADS_ENABLED(ff_rv34_decode_update_thread_context),
  286. };