mpegvideo.c 160.0 KB
Newer Older
F
Fabrice Bellard 已提交
1 2
/*
 * The simplest mpeg encoder (well, it was the simplest!)
F
Fabrice Bellard 已提交
3
 * Copyright (c) 2000,2001 Fabrice Bellard.
F
Fabrice Bellard 已提交
4
 *
F
Fabrice Bellard 已提交
5 6 7 8
 * This library 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 of the License, or (at your option) any later version.
F
Fabrice Bellard 已提交
9
 *
F
Fabrice Bellard 已提交
10
 * This library is distributed in the hope that it will be useful,
F
Fabrice Bellard 已提交
11
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
F
Fabrice Bellard 已提交
12 13
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
F
Fabrice Bellard 已提交
14
 *
F
Fabrice Bellard 已提交
15 16 17
 * You should have received a copy of the GNU Lesser 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
M
Michael Niedermayer 已提交
18
 *
19
 * 4MV & hq & b-frame encoding stuff by Michael Niedermayer <michaelni@gmx.at>
F
Fabrice Bellard 已提交
20
 */
21
 
M
Michael Niedermayer 已提交
22 23 24 25 26
/**
 * @file mpegvideo.c
 * The simplest mpeg encoder (well, it was the simplest!).
 */ 
 
27
#include <ctype.h>
28
#include <limits.h>
F
Fabrice Bellard 已提交
29 30 31 32
#include "avcodec.h"
#include "dsputil.h"
#include "mpegvideo.h"

33 34 35 36
#ifdef USE_FASTMEMCPY
#include "fastmemcpy.h"
#endif

37 38 39
//#undef NDEBUG
//#include <assert.h>

40
#ifdef CONFIG_ENCODERS
41
static void encode_picture(MpegEncContext *s, int picture_number);
42
#endif //CONFIG_ENCODERS
43 44
static void dct_unquantize_mpeg1_c(MpegEncContext *s, 
                                   DCTELEM *block, int n, int qscale);
45 46
static void dct_unquantize_mpeg2_c(MpegEncContext *s,
                                   DCTELEM *block, int n, int qscale);
47 48
static void dct_unquantize_h263_c(MpegEncContext *s, 
                                  DCTELEM *block, int n, int qscale);
49
static void draw_edges_c(uint8_t *buf, int wrap, int width, int height, int w);
50
#ifdef CONFIG_ENCODERS
51
static int dct_quantize_c(MpegEncContext *s, DCTELEM *block, int n, int qscale, int *overflow);
M
Michael Niedermayer 已提交
52
static int dct_quantize_trellis_c(MpegEncContext *s, DCTELEM *block, int n, int qscale, int *overflow);
53
static int sse_mb(MpegEncContext *s);
54
#endif //CONFIG_ENCODERS
M
Michael Niedermayer 已提交
55

I
Ivan Kalvachev 已提交
56 57 58 59 60 61
#ifdef HAVE_XVMC
extern int  XVMC_field_start(MpegEncContext*s, AVCodecContext *avctx);
extern void XVMC_field_end(MpegEncContext *s);
extern void XVMC_decode_mb(MpegEncContext *s, DCTELEM block[6][64]);
#endif

62
void (*draw_edges)(uint8_t *buf, int wrap, int width, int height, int w)= draw_edges_c;
M
Michael Niedermayer 已提交
63

F
Fabrice Bellard 已提交
64 65 66 67 68 69

/* enable all paranoid tests for rounding, overflows, etc... */
//#define PARANOID

//#define DEBUG

70

F
Fabrice Bellard 已提交
71 72 73
/* for jpeg fast DCT */
#define CONST_BITS 14

74
static const uint16_t aanscales[64] = {
F
Fabrice Bellard 已提交
75 76 77 78 79 80 81
    /* precomputed values scaled up by 14 bits */
    16384, 22725, 21407, 19266, 16384, 12873,  8867,  4520,
    22725, 31521, 29692, 26722, 22725, 17855, 12299,  6270,
    21407, 29692, 27969, 25172, 21407, 16819, 11585,  5906,
    19266, 26722, 25172, 22654, 19266, 15137, 10426,  5315,
    16384, 22725, 21407, 19266, 16384, 12873,  8867,  4520,
    12873, 17855, 16819, 15137, 12873, 10114,  6967,  3552,
M
Michael Niedermayer 已提交
82 83
    8867 , 12299, 11585, 10426,  8867,  6967,  4799,  2446,
    4520 ,  6270,  5906,  5315,  4520,  3552,  2446,  1247
F
Fabrice Bellard 已提交
84 85
};

86
static const uint8_t h263_chroma_roundtab[16] = {
87
//  0  1  2  3  4  5  6  7  8  9 10 11 12 13 14 15
F
Fabrice Bellard 已提交
88 89 90
    0, 0, 0, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2,
};

91
#ifdef CONFIG_ENCODERS
92
static uint8_t (*default_mv_penalty)[MAX_MV*2+1]=NULL;
93
static uint8_t default_fcode_tab[MAX_MV*2+1];
94

M
Michael Niedermayer 已提交
95 96
enum PixelFormat ff_yuv420p_list[2]= {PIX_FMT_YUV420P, -1};

97
static void convert_matrix(MpegEncContext *s, int (*qmat)[64], uint16_t (*qmat16)[64], uint16_t (*qmat16_bias)[64],
98
                           const uint16_t *quant_matrix, int bias, int qmin, int qmax)
F
Fabrice Bellard 已提交
99
{
100 101
    int qscale;

102
    for(qscale=qmin; qscale<=qmax; qscale++){
103
        int i;
104
        if (s->dsp.fdct == ff_jpeg_fdct_islow) {
105
            for(i=0;i<64;i++) {
106
                const int j= s->dsp.idct_permutation[i];
107 108 109 110 111
                /* 16 <= qscale * quant_matrix[i] <= 7905 */
                /* 19952         <= aanscales[i] * qscale * quant_matrix[i]           <= 249205026 */
                /* (1<<36)/19952 >= (1<<36)/(aanscales[i] * qscale * quant_matrix[i]) >= (1<<36)/249205026 */
                /* 3444240       >= (1<<36)/(aanscales[i] * qscale * quant_matrix[i]) >= 275 */
                
112
                qmat[qscale][i] = (int)((uint64_t_C(1) << QMAT_SHIFT) / 
113 114
                                (qscale * quant_matrix[j]));
            }
115
        } else if (s->dsp.fdct == fdct_ifast) {
116
            for(i=0;i<64;i++) {
117
                const int j= s->dsp.idct_permutation[i];
118 119 120 121 122
                /* 16 <= qscale * quant_matrix[i] <= 7905 */
                /* 19952         <= aanscales[i] * qscale * quant_matrix[i]           <= 249205026 */
                /* (1<<36)/19952 >= (1<<36)/(aanscales[i] * qscale * quant_matrix[i]) >= (1<<36)/249205026 */
                /* 3444240       >= (1<<36)/(aanscales[i] * qscale * quant_matrix[i]) >= 275 */
                
123
                qmat[qscale][i] = (int)((uint64_t_C(1) << (QMAT_SHIFT + 14)) / 
124 125 126 127
                                (aanscales[i] * qscale * quant_matrix[j]));
            }
        } else {
            for(i=0;i<64;i++) {
128
                const int j= s->dsp.idct_permutation[i];
129 130 131 132 133
                /* We can safely suppose that 16 <= quant_matrix[i] <= 255
                   So 16           <= qscale * quant_matrix[i]             <= 7905
                   so (1<<19) / 16 >= (1<<19) / (qscale * quant_matrix[i]) >= (1<<19) / 7905
                   so 32768        >= (1<<19) / (qscale * quant_matrix[i]) >= 67
                */
134
                qmat[qscale][i] = (int)((uint64_t_C(1) << QMAT_SHIFT) / (qscale * quant_matrix[j]));
M
Michael Niedermayer 已提交
135
//                qmat  [qscale][i] = (1 << QMAT_SHIFT_MMX) / (qscale * quant_matrix[i]);
136
                qmat16[qscale][i] = (1 << QMAT_SHIFT_MMX) / (qscale * quant_matrix[j]);
137 138 139 140

                if(qmat16[qscale][i]==0 || qmat16[qscale][i]==128*256) qmat16[qscale][i]=128*256-1;
                qmat16_bias[qscale][i]= ROUNDED_DIV(bias<<(16-QUANT_BIAS_SHIFT), qmat16[qscale][i]);
            }
F
Fabrice Bellard 已提交
141 142 143
        }
    }
}
144 145
#endif //CONFIG_ENCODERS

M
Michael Niedermayer 已提交
146
void ff_init_scantable(uint8_t *permutation, ScanTable *st, const uint8_t *src_scantable){
147 148
    int i;
    int end;
M
Michael Niedermayer 已提交
149 150
    
    st->scantable= src_scantable;
151 152 153 154

    for(i=0; i<64; i++){
        int j;
        j = src_scantable[i];
M
Michael Niedermayer 已提交
155
        st->permutated[i] = permutation[j];
156 157 158
#ifdef ARCH_POWERPC
        st->inverse[j] = i;
#endif
159 160 161 162 163 164 165 166 167 168 169
    }
    
    end=-1;
    for(i=0; i<64; i++){
        int j;
        j = st->permutated[i];
        if(j>end) end=j;
        st->raster_end[i]= end;
    }
}

170 171
/* init common dct for both encoder and decoder */
int DCT_common_init(MpegEncContext *s)
F
Fabrice Bellard 已提交
172
{
173
    s->dct_unquantize_h263 = dct_unquantize_h263_c;
174 175
    s->dct_unquantize_mpeg1 = dct_unquantize_mpeg1_c;
    s->dct_unquantize_mpeg2 = dct_unquantize_mpeg2_c;
176

177
#ifdef CONFIG_ENCODERS
178
    s->dct_quantize= dct_quantize_c;
179
#endif
180 181 182
        
#ifdef HAVE_MMX
    MPV_common_init_mmx(s);
183 184 185
#endif
#ifdef ARCH_ALPHA
    MPV_common_init_axp(s);
N
Nick Kurshev 已提交
186
#endif
187 188 189
#ifdef HAVE_MLIB
    MPV_common_init_mlib(s);
#endif
190 191 192
#ifdef HAVE_MMI
    MPV_common_init_mmi(s);
#endif
193
#ifdef ARCH_ARMV4L
194
    MPV_common_init_armv4l(s);
195
#endif
196 197 198
#ifdef ARCH_POWERPC
    MPV_common_init_ppc(s);
#endif
199

200
#ifdef CONFIG_ENCODERS
201 202
    s->fast_dct_quantize= s->dct_quantize;

M
Michael Niedermayer 已提交
203 204 205 206
    if(s->flags&CODEC_FLAG_TRELLIS_QUANT){
        s->dct_quantize= dct_quantize_trellis_c; //move before MPV_common_init_*
    }

207 208
#endif //CONFIG_ENCODERS

209 210 211
    /* load & permutate scantables
       note: only wmv uses differnt ones 
    */
M
Michael Niedermayer 已提交
212 213 214 215
    ff_init_scantable(s->dsp.idct_permutation, &s->inter_scantable  , ff_zigzag_direct);
    ff_init_scantable(s->dsp.idct_permutation, &s->intra_scantable  , ff_zigzag_direct);
    ff_init_scantable(s->dsp.idct_permutation, &s->intra_h_scantable, ff_alternate_horizontal_scan);
    ff_init_scantable(s->dsp.idct_permutation, &s->intra_v_scantable, ff_alternate_vertical_scan);
216

217 218
    s->picture_structure= PICT_FRAME;
    
219 220 221
    return 0;
}

M
cleanup  
Michael Niedermayer 已提交
222
/**
M
Michael Niedermayer 已提交
223 224
 * allocates a Picture
 * The pixels are allocated/set by calling get_buffer() if shared=0
M
cleanup  
Michael Niedermayer 已提交
225
 */
M
Michael Niedermayer 已提交
226
static int alloc_picture(MpegEncContext *s, Picture *pic, int shared){
227 228
    const int big_mb_num= s->mb_stride*(s->mb_height+1) + 1; //the +1 is needed so memset(,,stride*height) doesnt sig11
    const int mb_array_size= s->mb_stride*s->mb_height;
M
Michael Niedermayer 已提交
229
    int i;
230
    
M
Michael Niedermayer 已提交
231 232 233 234 235 236 237 238 239
    if(shared){
        assert(pic->data[0]);
        assert(pic->type == 0 || pic->type == FF_BUFFER_TYPE_SHARED);
        pic->type= FF_BUFFER_TYPE_SHARED;
    }else{
        int r;
        
        assert(!pic->data[0]);
        
M
Michael Niedermayer 已提交
240
        r= s->avctx->get_buffer(s->avctx, (AVFrame*)pic);
M
Michael Niedermayer 已提交
241 242
        
        if(r<0 || !pic->age || !pic->type || !pic->data[0]){
243
            fprintf(stderr, "get_buffer() failed (%d %d %d %p)\n", r, pic->age, pic->type, pic->data[0]);
M
Michael Niedermayer 已提交
244 245 246 247 248 249 250 251 252 253 254 255 256 257 258
            return -1;
        }

        if(s->linesize && (s->linesize != pic->linesize[0] || s->uvlinesize != pic->linesize[1])){
            fprintf(stderr, "get_buffer() failed (stride changed)\n");
            return -1;
        }

        if(pic->linesize[1] != pic->linesize[2]){
            fprintf(stderr, "get_buffer() failed (uv stride missmatch)\n");
            return -1;
        }

        s->linesize  = pic->linesize[0];
        s->uvlinesize= pic->linesize[1];
M
cleanup  
Michael Niedermayer 已提交
259
    }
M
Michael Niedermayer 已提交
260 261 262
    
    if(pic->qscale_table==NULL){
        if (s->encoding) {        
263 264 265 266
            CHECKED_ALLOCZ(pic->mb_var   , mb_array_size * sizeof(int16_t))
            CHECKED_ALLOCZ(pic->mc_mb_var, mb_array_size * sizeof(int16_t))
            CHECKED_ALLOCZ(pic->mb_mean  , mb_array_size * sizeof(int8_t))
            CHECKED_ALLOCZ(pic->mb_cmp_score, mb_array_size * sizeof(int32_t))
M
Michael Niedermayer 已提交
267
        }
M
cleanup  
Michael Niedermayer 已提交
268

269 270 271 272
        CHECKED_ALLOCZ(pic->mbskip_table , mb_array_size * sizeof(uint8_t)+2) //the +2 is for the slice end check
        CHECKED_ALLOCZ(pic->qscale_table , mb_array_size * sizeof(uint8_t))
        CHECKED_ALLOCZ(pic->mb_type_base , big_mb_num    * sizeof(int))
        pic->mb_type= pic->mb_type_base + s->mb_stride+1;
M
Michael Niedermayer 已提交
273 274 275 276 277 278
        if(s->out_format == FMT_H264){
            for(i=0; i<2; i++){
                CHECKED_ALLOCZ(pic->motion_val[i], 2 * 16 * s->mb_num * sizeof(uint16_t))
                CHECKED_ALLOCZ(pic->ref_index[i] , 4 * s->mb_num * sizeof(uint8_t))
            }
        }
279
        pic->qstride= s->mb_stride;
M
Michael Niedermayer 已提交
280
    }
M
Michael Niedermayer 已提交
281

282 283 284 285 286 287
    //it might be nicer if the application would keep track of these but it would require a API change
    memmove(s->prev_pict_types+1, s->prev_pict_types, PREV_PICT_TYPES_BUFFER_SIZE-1);
    s->prev_pict_types[0]= s->pict_type;
    if(pic->age < PREV_PICT_TYPES_BUFFER_SIZE && s->prev_pict_types[pic->age] == B_TYPE)
        pic->age= INT_MAX; // skiped MBs in b frames are quite rare in mpeg1/2 and its a bit tricky to skip them anyway
    
M
cleanup  
Michael Niedermayer 已提交
288 289 290 291 292
    return 0;
fail: //for the CHECKED_ALLOCZ macro
    return -1;
}

M
Michael Niedermayer 已提交
293 294 295
/**
 * deallocates a picture
 */
M
cleanup  
Michael Niedermayer 已提交
296 297
static void free_picture(MpegEncContext *s, Picture *pic){
    int i;
M
Michael Niedermayer 已提交
298 299

    if(pic->data[0] && pic->type!=FF_BUFFER_TYPE_SHARED){
M
Michael Niedermayer 已提交
300
        s->avctx->release_buffer(s->avctx, (AVFrame*)pic);
M
Michael Niedermayer 已提交
301 302
    }

M
cleanup  
Michael Niedermayer 已提交
303 304 305
    av_freep(&pic->mb_var);
    av_freep(&pic->mc_mb_var);
    av_freep(&pic->mb_mean);
306
    av_freep(&pic->mb_cmp_score);
M
cleanup  
Michael Niedermayer 已提交
307 308
    av_freep(&pic->mbskip_table);
    av_freep(&pic->qscale_table);
M
Michael Niedermayer 已提交
309 310 311 312 313 314
    av_freep(&pic->mb_type_base);
    pic->mb_type= NULL;
    for(i=0; i<2; i++){
        av_freep(&pic->motion_val[i]);
        av_freep(&pic->ref_index[i]);
    }
315 316
    
    if(pic->type == FF_BUFFER_TYPE_SHARED){
M
Michael Niedermayer 已提交
317 318 319 320 321
        for(i=0; i<4; i++){
            pic->base[i]=
            pic->data[i]= NULL;
        }
        pic->type= 0;        
M
cleanup  
Michael Niedermayer 已提交
322 323 324
    }
}

325 326 327
/* init common structure for both encoder and decoder */
int MPV_common_init(MpegEncContext *s)
{
328
    int y_size, c_size, yc_size, i, mb_array_size, x, y;
329

330
    dsputil_init(&s->dsp, s->avctx);
331
    DCT_common_init(s);
332

333
    s->flags= s->avctx->flags;
334

M
cleanup  
Michael Niedermayer 已提交
335
    s->mb_width  = (s->width  + 15) / 16;
F
Fabrice Bellard 已提交
336
    s->mb_height = (s->height + 15) / 16;
337 338
    s->mb_stride = s->mb_width + 1;
    mb_array_size= s->mb_height * s->mb_stride;
339

340 341 342
    /* set default edge pos, will be overriden in decode_header if needed */
    s->h_edge_pos= s->mb_width*16;
    s->v_edge_pos= s->mb_height*16;
343 344

    s->mb_num = s->mb_width * s->mb_height;
345 346 347 348 349 350 351
    
    s->block_wrap[0]=
    s->block_wrap[1]=
    s->block_wrap[2]=
    s->block_wrap[3]= s->mb_width*2 + 2;
    s->block_wrap[4]=
    s->block_wrap[5]= s->mb_width + 2;
352 353 354 355 356

    y_size = (2 * s->mb_width + 2) * (2 * s->mb_height + 2);
    c_size = (s->mb_width + 2) * (s->mb_height + 2);
    yc_size = y_size + 2 * c_size;

357
    /* convert fourcc to upper case */
358 359 360 361
    s->avctx->codec_tag=   toupper( s->avctx->codec_tag     &0xFF)          
                        + (toupper((s->avctx->codec_tag>>8 )&0xFF)<<8 )
                        + (toupper((s->avctx->codec_tag>>16)&0xFF)<<16) 
                        + (toupper((s->avctx->codec_tag>>24)&0xFF)<<24);
362

363 364
    CHECKED_ALLOCZ(s->allocated_edge_emu_buffer, (s->width+64)*2*17*2); //(width + edge + align)*interlaced*MBsize*tolerance
    s->edge_emu_buffer= s->allocated_edge_emu_buffer + (s->width+64)*2*17;
M
cleanup  
Michael Niedermayer 已提交
365

M
Michael Niedermayer 已提交
366
    s->avctx->coded_frame= (AVFrame*)&s->current_picture;
M
cleanup  
Michael Niedermayer 已提交
367

368 369 370 371 372 373 374 375
    CHECKED_ALLOCZ(s->mb_index2xy, (s->mb_num+1)*sizeof(int)) //error ressilience code looks cleaner with this
    for(y=0; y<s->mb_height; y++){
        for(x=0; x<s->mb_width; x++){
            s->mb_index2xy[ x + y*s->mb_width ] = x + y*s->mb_stride;
        }
    }
    s->mb_index2xy[ s->mb_height*s->mb_width ] = (s->mb_height-1)*s->mb_stride + s->mb_width; //FIXME really needed?
    
376
    if (s->encoding) {
377
        int mv_table_size= s->mb_stride * (s->mb_height+2) + 1;
378 379

        /* Allocate MV tables */
380 381 382 383 384 385 386 387 388 389 390 391
        CHECKED_ALLOCZ(s->p_mv_table_base            , mv_table_size * 2 * sizeof(int16_t))
        CHECKED_ALLOCZ(s->b_forw_mv_table_base       , mv_table_size * 2 * sizeof(int16_t))
        CHECKED_ALLOCZ(s->b_back_mv_table_base       , mv_table_size * 2 * sizeof(int16_t))
        CHECKED_ALLOCZ(s->b_bidir_forw_mv_table_base , mv_table_size * 2 * sizeof(int16_t))
        CHECKED_ALLOCZ(s->b_bidir_back_mv_table_base , mv_table_size * 2 * sizeof(int16_t))
        CHECKED_ALLOCZ(s->b_direct_mv_table_base     , mv_table_size * 2 * sizeof(int16_t))
        s->p_mv_table           = s->p_mv_table_base            + s->mb_stride + 1;
        s->b_forw_mv_table      = s->b_forw_mv_table_base       + s->mb_stride + 1;
        s->b_back_mv_table      = s->b_back_mv_table_base       + s->mb_stride + 1;
        s->b_bidir_forw_mv_table= s->b_bidir_forw_mv_table_base + s->mb_stride + 1;
        s->b_bidir_back_mv_table= s->b_bidir_back_mv_table_base + s->mb_stride + 1;
        s->b_direct_mv_table    = s->b_direct_mv_table_base     + s->mb_stride + 1;
392

M
cleanup  
Michael Niedermayer 已提交
393
        //FIXME should be linesize instead of s->width*2 but that isnt known before get_buffer()
M
Michael Niedermayer 已提交
394
        CHECKED_ALLOCZ(s->me.scratchpad,  s->width*2*16*3*sizeof(uint8_t)) 
395
        
M
Michael Niedermayer 已提交
396 397
        CHECKED_ALLOCZ(s->me.map      , ME_MAP_SIZE*sizeof(uint32_t))
        CHECKED_ALLOCZ(s->me.score_map, ME_MAP_SIZE*sizeof(uint32_t))
398

399 400 401 402
        if(s->codec_id==CODEC_ID_MPEG4){
            CHECKED_ALLOCZ(s->tex_pb_buffer, PB_BUFFER_SIZE);
            CHECKED_ALLOCZ(   s->pb2_buffer, PB_BUFFER_SIZE);
        }
M
Michael Niedermayer 已提交
403
        
404 405 406
        if(s->msmpeg4_version){
            CHECKED_ALLOCZ(s->ac_stats, 2*2*(MAX_LEVEL+1)*(MAX_RUN+1)*2*sizeof(int));
        }
M
Michael Niedermayer 已提交
407
        CHECKED_ALLOCZ(s->avctx->stats_out, 256);
408 409 410

        /* Allocate MB type table */
        CHECKED_ALLOCZ(s->mb_type  , mb_array_size * sizeof(uint8_t)) //needed for encoding
411
    }
412
        
413
    CHECKED_ALLOCZ(s->error_status_table, mb_array_size*sizeof(uint8_t))
414
    
415
    if (s->out_format == FMT_H263 || s->encoding) {
F
Fabrice Bellard 已提交
416
        int size;
417

F
Fabrice Bellard 已提交
418 419
        /* MV prediction */
        size = (2 * s->mb_width + 2) * (2 * s->mb_height + 2);
420
        CHECKED_ALLOCZ(s->motion_val, size * 2 * sizeof(int16_t));
421 422 423
    }

    if(s->codec_id==CODEC_ID_MPEG4){
424
        /* interlaced direct mode decoding tables */
425 426
        CHECKED_ALLOCZ(s->field_mv_table, mb_array_size*2*2 * sizeof(int16_t))
        CHECKED_ALLOCZ(s->field_select_table, mb_array_size*2* sizeof(int8_t))
F
Fabrice Bellard 已提交
427
    }
M
Michael Niedermayer 已提交
428
    if (s->out_format == FMT_H263) {
F
Fabrice Bellard 已提交
429
        /* ac values */
430
        CHECKED_ALLOCZ(s->ac_val[0], yc_size * sizeof(int16_t) * 16);
F
Fabrice Bellard 已提交
431 432 433 434
        s->ac_val[1] = s->ac_val[0] + y_size;
        s->ac_val[2] = s->ac_val[1] + c_size;
        
        /* cbp values */
435
        CHECKED_ALLOCZ(s->coded_block, y_size);
M
Michael Niedermayer 已提交
436 437
        
        /* divx501 bitstream reorder buffer */
438
        CHECKED_ALLOCZ(s->bitstream_buffer, BITSTREAM_BUFFER_SIZE);
M
cleanup  
Michael Niedermayer 已提交
439

440
        /* cbp, ac_pred, pred_dir */
441 442
        CHECKED_ALLOCZ(s->cbp_table  , mb_array_size * sizeof(uint8_t))
        CHECKED_ALLOCZ(s->pred_dir_table, mb_array_size * sizeof(uint8_t))
443
    }
444 445 446 447
    
    if (s->h263_pred || s->h263_plus || !s->encoding) {
        /* dc values */
        //MN: we need these for error resilience of intra-frames
448
        CHECKED_ALLOCZ(s->dc_val[0], yc_size * sizeof(int16_t));
449 450 451 452 453 454
        s->dc_val[1] = s->dc_val[0] + y_size;
        s->dc_val[2] = s->dc_val[1] + c_size;
        for(i=0;i<yc_size;i++)
            s->dc_val[0][i] = 1024;
    }

455
    /* which mb is a intra block */
456 457
    CHECKED_ALLOCZ(s->mbintra_table, mb_array_size);
    memset(s->mbintra_table, 1, mb_array_size);
458
    
F
Fabrice Bellard 已提交
459 460
    /* default structure is frame */
    s->picture_structure = PICT_FRAME;
461
    
462
    /* init macroblock skip table */
463
    CHECKED_ALLOCZ(s->mbskip_table, mb_array_size+2);
464
    //Note the +1 is for a quicker mpeg4 slice_end detection
465
    CHECKED_ALLOCZ(s->prev_pict_types, PREV_PICT_TYPES_BUFFER_SIZE);
466
    
467
    s->block= s->blocks[0];
468

469 470
    s->parse_context.state= -1;

F
Fabrice Bellard 已提交
471 472 473
    s->context_initialized = 1;
    return 0;
 fail:
474
    MPV_common_end(s);
F
Fabrice Bellard 已提交
475 476 477
    return -1;
}

478 479 480

//extern int sads;

F
Fabrice Bellard 已提交
481 482 483 484 485
/* init common structure for both encoder and decoder */
void MPV_common_end(MpegEncContext *s)
{
    int i;

486 487 488
    av_freep(&s->parse_context.buffer);
    s->parse_context.buffer_size=0;

489
    av_freep(&s->mb_type);
490 491 492 493 494 495 496 497 498 499 500 501 502
    av_freep(&s->p_mv_table_base);
    av_freep(&s->b_forw_mv_table_base);
    av_freep(&s->b_back_mv_table_base);
    av_freep(&s->b_bidir_forw_mv_table_base);
    av_freep(&s->b_bidir_back_mv_table_base);
    av_freep(&s->b_direct_mv_table_base);
    s->p_mv_table= NULL;
    s->b_forw_mv_table= NULL;
    s->b_back_mv_table= NULL;
    s->b_bidir_forw_mv_table= NULL;
    s->b_bidir_back_mv_table= NULL;
    s->b_direct_mv_table= NULL;
    
503 504 505 506 507
    av_freep(&s->motion_val);
    av_freep(&s->dc_val[0]);
    av_freep(&s->ac_val[0]);
    av_freep(&s->coded_block);
    av_freep(&s->mbintra_table);
508 509
    av_freep(&s->cbp_table);
    av_freep(&s->pred_dir_table);
M
Michael Niedermayer 已提交
510 511 512
    av_freep(&s->me.scratchpad);
    av_freep(&s->me.map);
    av_freep(&s->me.score_map);
513
    
514
    av_freep(&s->mbskip_table);
515
    av_freep(&s->prev_pict_types);
516
    av_freep(&s->bitstream_buffer);
517 518
    av_freep(&s->tex_pb_buffer);
    av_freep(&s->pb2_buffer);
519
    av_freep(&s->allocated_edge_emu_buffer); s->edge_emu_buffer= NULL;
520 521
    av_freep(&s->field_mv_table);
    av_freep(&s->field_select_table);
M
Michael Niedermayer 已提交
522
    av_freep(&s->avctx->stats_out);
523
    av_freep(&s->ac_stats);
524
    av_freep(&s->error_status_table);
525
    av_freep(&s->mb_index2xy);
M
cleanup  
Michael Niedermayer 已提交
526 527 528

    for(i=0; i<MAX_PICTURE_COUNT; i++){
        free_picture(s, &s->picture[i]);
F
Fabrice Bellard 已提交
529
    }
530
    avcodec_default_free_buffers(s->avctx);
F
Fabrice Bellard 已提交
531 532 533
    s->context_initialized = 0;
}

534 535
#ifdef CONFIG_ENCODERS

F
Fabrice Bellard 已提交
536 537 538 539
/* init video encoder */
int MPV_encode_init(AVCodecContext *avctx)
{
    MpegEncContext *s = avctx->priv_data;
540
    int i;
541
    int chroma_h_shift, chroma_v_shift;
542

F
Fabrice Bellard 已提交
543
    s->bit_rate = avctx->bit_rate;
544
    s->bit_rate_tolerance = avctx->bit_rate_tolerance;
F
Fabrice Bellard 已提交
545 546
    s->width = avctx->width;
    s->height = avctx->height;
547
    if(avctx->gop_size > 600){
548
        fprintf(stderr, "Warning keyframe interval too large! reducing it ...\n");
549 550
        avctx->gop_size=600;
    }
F
Fabrice Bellard 已提交
551
    s->gop_size = avctx->gop_size;
552 553
    s->rtp_mode = avctx->rtp_mode;
    s->rtp_payload_size = avctx->rtp_payload_size;
554 555
    if (avctx->rtp_callback)
        s->rtp_callback = avctx->rtp_callback;
556 557 558
    s->max_qdiff= avctx->max_qdiff;
    s->qcompress= avctx->qcompress;
    s->qblur= avctx->qblur;
559
    s->avctx = avctx;
560
    s->flags= avctx->flags;
561
    s->max_b_frames= avctx->max_b_frames;
562
    s->b_frame_strategy= avctx->b_frame_strategy;
563
    s->codec_id= avctx->codec->id;
564 565 566 567
    s->luma_elim_threshold  = avctx->luma_elim_threshold;
    s->chroma_elim_threshold= avctx->chroma_elim_threshold;
    s->strict_std_compliance= avctx->strict_std_compliance;
    s->data_partitioning= avctx->flags & CODEC_FLAG_PART;
M
Michael Niedermayer 已提交
568
    s->quarter_sample= (avctx->flags & CODEC_FLAG_QPEL)!=0;
569
    s->mpeg_quant= avctx->mpeg_quant;
570

F
Fabrice Bellard 已提交
571 572 573 574 575 576
    if (s->gop_size <= 1) {
        s->intra_only = 1;
        s->gop_size = 12;
    } else {
        s->intra_only = 0;
    }
577

M
Michael Niedermayer 已提交
578
    s->me_method = avctx->me_method;
579

580
    /* Fixed QSCALE */
F
Fabrice Bellard 已提交
581
    s->fixed_qscale = (avctx->flags & CODEC_FLAG_QSCALE);
582
    
583
    s->adaptive_quant= (   s->avctx->lumi_masking
584
                        || s->avctx->dark_masking
585 586 587 588
                        || s->avctx->temporal_cplx_masking 
                        || s->avctx->spatial_cplx_masking
                        || s->avctx->p_masking)
                       && !s->fixed_qscale;
589 590
    
    s->progressive_sequence= !(avctx->flags & CODEC_FLAG_INTERLACED_DCT);
591

592 593 594 595 596 597 598 599 600 601 602 603 604 605 606
    if((s->flags & CODEC_FLAG_4MV) && s->codec_id != CODEC_ID_MPEG4){
        fprintf(stderr, "4MV not supporetd by codec\n");
        return -1;
    }
    
    if(s->quarter_sample && s->codec_id != CODEC_ID_MPEG4){
        fprintf(stderr, "qpel not supporetd by codec\n");
        return -1;
    }

    if(s->data_partitioning && s->codec_id != CODEC_ID_MPEG4){
        fprintf(stderr, "data partitioning not supporetd by codec\n");
        return -1;
    }
    
M
10l  
Michael Niedermayer 已提交
607
    if(s->max_b_frames && s->codec_id != CODEC_ID_MPEG4 && s->codec_id != CODEC_ID_MPEG1VIDEO){
608 609 610 611 612 613 614 615 616
        fprintf(stderr, "b frames not supporetd by codec\n");
        return -1;
    }
    
    if(s->mpeg_quant && s->codec_id != CODEC_ID_MPEG4){ //FIXME mpeg2 uses that too
        fprintf(stderr, "mpeg2 style quantization not supporetd by codec\n");
        return -1;
    }
        
617 618 619 620 621 622 623 624 625 626 627 628 629 630 631
    if(s->codec_id==CODEC_ID_MJPEG){
        s->intra_quant_bias= 1<<(QUANT_BIAS_SHIFT-1); //(a + x/2)/x
        s->inter_quant_bias= 0;
    }else if(s->mpeg_quant || s->codec_id==CODEC_ID_MPEG1VIDEO){
        s->intra_quant_bias= 3<<(QUANT_BIAS_SHIFT-3); //(a + x*3/8)/x
        s->inter_quant_bias= 0;
    }else{
        s->intra_quant_bias=0;
        s->inter_quant_bias=-(1<<(QUANT_BIAS_SHIFT-2)); //(a - x/4)/x
    }
    
    if(avctx->intra_quant_bias != FF_DEFAULT_QUANT_BIAS)
        s->intra_quant_bias= avctx->intra_quant_bias;
    if(avctx->inter_quant_bias != FF_DEFAULT_QUANT_BIAS)
        s->inter_quant_bias= avctx->inter_quant_bias;
632 633 634
        
    avcodec_get_chroma_sub_sample(avctx->pix_fmt, &chroma_h_shift, &chroma_v_shift);

F
Fabrice Bellard 已提交
635 636 637
    switch(avctx->codec->id) {
    case CODEC_ID_MPEG1VIDEO:
        s->out_format = FMT_MPEG1;
638 639
        s->low_delay= 0; //s->max_b_frames ? 0 : 1;
        avctx->delay= s->low_delay ? 0 : (s->max_b_frames + 1);
F
Fabrice Bellard 已提交
640
        break;
641
    case CODEC_ID_LJPEG:
F
Fabrice Bellard 已提交
642 643 644
    case CODEC_ID_MJPEG:
        s->out_format = FMT_MJPEG;
        s->intra_only = 1; /* force intra only for jpeg */
645
        s->mjpeg_write_tables = 1; /* write all tables */
646
	s->mjpeg_data_only_frames = 0; /* write all the needed headers */
647 648
        s->mjpeg_vsample[0] = 1<<chroma_v_shift;
        s->mjpeg_vsample[1] = 1;
649
        s->mjpeg_vsample[2] = 1; 
650
        s->mjpeg_hsample[0] = 1<<chroma_h_shift;
651 652
        s->mjpeg_hsample[1] = 1; 
        s->mjpeg_hsample[2] = 1; 
F
Fabrice Bellard 已提交
653 654
        if (mjpeg_init(s) < 0)
            return -1;
M
Michael Niedermayer 已提交
655
        avctx->delay=0;
M
Michael Niedermayer 已提交
656
        s->low_delay=1;
F
Fabrice Bellard 已提交
657
        break;
M
Michael Niedermayer 已提交
658
#ifdef CONFIG_RISKY
F
Fabrice Bellard 已提交
659
    case CODEC_ID_H263:
660 661
        if (h263_get_picture_format(s->width, s->height) == 7) {
            printf("Input picture size isn't suitable for h263 codec! try h263+\n");
F
Fabrice Bellard 已提交
662
            return -1;
663
        }
F
Fabrice Bellard 已提交
664
        s->out_format = FMT_H263;
M
Michael Niedermayer 已提交
665
        avctx->delay=0;
M
Michael Niedermayer 已提交
666
        s->low_delay=1;
F
Fabrice Bellard 已提交
667 668 669 670
        break;
    case CODEC_ID_H263P:
        s->out_format = FMT_H263;
        s->h263_plus = 1;
671 672 673 674
	/* Fx */
	s->unrestricted_mv=(avctx->flags & CODEC_FLAG_H263P_UMV) ? 1:0;
	s->h263_aic= (avctx->flags & CODEC_FLAG_H263P_AIC) ? 1:0;
	/* /Fx */
675
        /* These are just to be sure */
M
Michael Niedermayer 已提交
676
        s->umvplus = 1;
M
Michael Niedermayer 已提交
677
        avctx->delay=0;
M
Michael Niedermayer 已提交
678
        s->low_delay=1;
F
Fabrice Bellard 已提交
679
        break;
680 681 682 683 684 685 686 687
    case CODEC_ID_FLV1:
        s->out_format = FMT_H263;
        s->h263_flv = 2; /* format = 1; 11-bit codes */
        s->unrestricted_mv = 1;
        s->rtp_mode=0; /* don't allow GOB */
        avctx->delay=0;
        s->low_delay=1;
        break;
F
Fabrice Bellard 已提交
688 689 690
    case CODEC_ID_RV10:
        s->out_format = FMT_H263;
        s->h263_rv10 = 1;
M
Michael Niedermayer 已提交
691
        avctx->delay=0;
M
Michael Niedermayer 已提交
692
        s->low_delay=1;
F
Fabrice Bellard 已提交
693
        break;
F
Fabrice Bellard 已提交
694
    case CODEC_ID_MPEG4:
F
Fabrice Bellard 已提交
695 696 697
        s->out_format = FMT_H263;
        s->h263_pred = 1;
        s->unrestricted_mv = 1;
M
Michael Niedermayer 已提交
698
        s->low_delay= s->max_b_frames ? 0 : 1;
699
        avctx->delay= s->low_delay ? 0 : (s->max_b_frames + 1);
F
Fabrice Bellard 已提交
700
        break;
701
    case CODEC_ID_MSMPEG4V1:
F
Fabrice Bellard 已提交
702 703 704 705
        s->out_format = FMT_H263;
        s->h263_msmpeg4 = 1;
        s->h263_pred = 1;
        s->unrestricted_mv = 1;
706
        s->msmpeg4_version= 1;
M
Michael Niedermayer 已提交
707
        avctx->delay=0;
M
Michael Niedermayer 已提交
708
        s->low_delay=1;
709 710 711 712 713 714 715
        break;
    case CODEC_ID_MSMPEG4V2:
        s->out_format = FMT_H263;
        s->h263_msmpeg4 = 1;
        s->h263_pred = 1;
        s->unrestricted_mv = 1;
        s->msmpeg4_version= 2;
M
Michael Niedermayer 已提交
716
        avctx->delay=0;
M
Michael Niedermayer 已提交
717
        s->low_delay=1;
718 719 720 721 722 723 724
        break;
    case CODEC_ID_MSMPEG4V3:
        s->out_format = FMT_H263;
        s->h263_msmpeg4 = 1;
        s->h263_pred = 1;
        s->unrestricted_mv = 1;
        s->msmpeg4_version= 3;
M
Michael Niedermayer 已提交
725
        s->flipflop_rounding=1;
M
Michael Niedermayer 已提交
726
        avctx->delay=0;
M
Michael Niedermayer 已提交
727
        s->low_delay=1;
F
Fabrice Bellard 已提交
728
        break;
M
Michael Niedermayer 已提交
729 730 731 732 733 734
    case CODEC_ID_WMV1:
        s->out_format = FMT_H263;
        s->h263_msmpeg4 = 1;
        s->h263_pred = 1;
        s->unrestricted_mv = 1;
        s->msmpeg4_version= 4;
M
Michael Niedermayer 已提交
735
        s->flipflop_rounding=1;
M
Michael Niedermayer 已提交
736
        avctx->delay=0;
M
Michael Niedermayer 已提交
737
        s->low_delay=1;
M
Michael Niedermayer 已提交
738 739 740 741 742 743 744
        break;
    case CODEC_ID_WMV2:
        s->out_format = FMT_H263;
        s->h263_msmpeg4 = 1;
        s->h263_pred = 1;
        s->unrestricted_mv = 1;
        s->msmpeg4_version= 5;
M
Michael Niedermayer 已提交
745
        s->flipflop_rounding=1;
M
Michael Niedermayer 已提交
746
        avctx->delay=0;
M
Michael Niedermayer 已提交
747
        s->low_delay=1;
M
Michael Niedermayer 已提交
748
        break;
M
Michael Niedermayer 已提交
749
#endif
F
Fabrice Bellard 已提交
750 751 752
    default:
        return -1;
    }
M
Michael Niedermayer 已提交
753
    
754 755 756 757 758
    { /* set up some save defaults, some codecs might override them later */
        static int done=0;
        if(!done){
            int i;
            done=1;
759

760 761
            default_mv_penalty= av_mallocz( sizeof(uint8_t)*(MAX_FCODE+1)*(2*MAX_MV+1) );
            memset(default_mv_penalty, 0, sizeof(uint8_t)*(MAX_FCODE+1)*(2*MAX_MV+1));
762
            memset(default_fcode_tab , 0, sizeof(uint8_t)*(2*MAX_MV+1));
763 764 765 766 767 768

            for(i=-16; i<16; i++){
                default_fcode_tab[i + MAX_MV]= 1;
            }
        }
    }
M
Michael Niedermayer 已提交
769
    s->me.mv_penalty= default_mv_penalty;
770
    s->fcode_tab= default_fcode_tab;
771 772 773
    s->y_dc_scale_table=
    s->c_dc_scale_table= ff_mpeg1_dc_scale_table;
 
774
    /* dont use mv_penalty table for crap MV as it would be confused */
M
Michael Niedermayer 已提交
775 776
    //FIXME remove after fixing / removing old ME
    if (s->me_method < ME_EPZS) s->me.mv_penalty = default_mv_penalty;
777

778 779
    s->encoding = 1;

F
Fabrice Bellard 已提交
780 781 782 783
    /* init */
    if (MPV_common_init(s) < 0)
        return -1;
    
M
Michael Niedermayer 已提交
784 785
    ff_init_me(s);

786
#ifdef CONFIG_ENCODERS
M
Michael Niedermayer 已提交
787
#ifdef CONFIG_RISKY
788 789 790 791
    if (s->out_format == FMT_H263)
        h263_encode_init(s);
    if(s->msmpeg4_version)
        ff_msmpeg4_encode_init(s);
792
#endif
M
Michael Niedermayer 已提交
793 794 795
    if (s->out_format == FMT_MPEG1)
        ff_mpeg1_encode_init(s);
#endif
796

797 798
    /* init default q matrix */
    for(i=0;i<64;i++) {
799
        int j= s->dsp.idct_permutation[i];
M
Michael Niedermayer 已提交
800
#ifdef CONFIG_RISKY
801
        if(s->codec_id==CODEC_ID_MPEG4 && s->mpeg_quant){
802 803
            s->intra_matrix[j] = ff_mpeg4_default_intra_matrix[i];
            s->inter_matrix[j] = ff_mpeg4_default_non_intra_matrix[i];
804
        }else if(s->out_format == FMT_H263){
805 806
            s->intra_matrix[j] =
            s->inter_matrix[j] = ff_mpeg1_default_non_intra_matrix[i];
M
Michael Niedermayer 已提交
807 808 809
        }else
#endif
        { /* mpeg1 */
810 811
            s->intra_matrix[j] = ff_mpeg1_default_intra_matrix[i];
            s->inter_matrix[j] = ff_mpeg1_default_non_intra_matrix[i];
812
        }
813 814 815
    }

    /* precompute matrix */
816
    /* for mjpeg, we do include qscale in the matrix */
817
    if (s->out_format != FMT_MJPEG) {
818
        convert_matrix(s, s->q_intra_matrix, s->q_intra_matrix16, s->q_intra_matrix16_bias, 
819
                       s->intra_matrix, s->intra_quant_bias, 1, 31);
820
        convert_matrix(s, s->q_inter_matrix, s->q_inter_matrix16, s->q_inter_matrix16_bias, 
821
                       s->inter_matrix, s->inter_quant_bias, 1, 31);
822 823
    }

824 825
    if(ff_rate_control_init(s) < 0)
        return -1;
F
Fabrice Bellard 已提交
826 827

    s->picture_number = 0;
828
    s->picture_in_gop_number = 0;
F
Fabrice Bellard 已提交
829 830 831
    s->fake_picture_number = 0;
    /* motion detector init */
    s->f_code = 1;
832
    s->b_code = 1;
F
Fabrice Bellard 已提交
833 834 835 836 837 838 839 840 841 842 843

    return 0;
}

int MPV_encode_end(AVCodecContext *avctx)
{
    MpegEncContext *s = avctx->priv_data;

#ifdef STATS
    print_stats();
#endif
844 845 846

    ff_rate_control_uninit(s);

F
Fabrice Bellard 已提交
847 848 849
    MPV_common_end(s);
    if (s->out_format == FMT_MJPEG)
        mjpeg_close(s);
850
      
F
Fabrice Bellard 已提交
851 852 853
    return 0;
}

854 855
#endif //CONFIG_ENCODERS

M
Michael Niedermayer 已提交
856 857
void init_rl(RLTable *rl)
{
858 859
    int8_t max_level[MAX_RUN+1], max_run[MAX_LEVEL+1];
    uint8_t index_run[MAX_RUN+1];
M
Michael Niedermayer 已提交
860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893
    int last, run, level, start, end, i;

    /* compute max_level[], max_run[] and index_run[] */
    for(last=0;last<2;last++) {
        if (last == 0) {
            start = 0;
            end = rl->last;
        } else {
            start = rl->last;
            end = rl->n;
        }

        memset(max_level, 0, MAX_RUN + 1);
        memset(max_run, 0, MAX_LEVEL + 1);
        memset(index_run, rl->n, MAX_RUN + 1);
        for(i=start;i<end;i++) {
            run = rl->table_run[i];
            level = rl->table_level[i];
            if (index_run[run] == rl->n)
                index_run[run] = i;
            if (level > max_level[run])
                max_level[run] = level;
            if (run > max_run[level])
                max_run[level] = run;
        }
        rl->max_level[last] = av_malloc(MAX_RUN + 1);
        memcpy(rl->max_level[last], max_level, MAX_RUN + 1);
        rl->max_run[last] = av_malloc(MAX_LEVEL + 1);
        memcpy(rl->max_run[last], max_run, MAX_LEVEL + 1);
        rl->index_run[last] = av_malloc(MAX_RUN + 1);
        memcpy(rl->index_run[last], index_run, MAX_RUN + 1);
    }
}

F
Fabrice Bellard 已提交
894
/* draw the edges of width 'w' of an image of size width, height */
895
//FIXME check that this is ok for mpeg4 interlaced
896
static void draw_edges_c(uint8_t *buf, int wrap, int width, int height, int w)
F
Fabrice Bellard 已提交
897
{
898
    uint8_t *ptr, *last_line;
F
Fabrice Bellard 已提交
899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922
    int i;

    last_line = buf + (height - 1) * wrap;
    for(i=0;i<w;i++) {
        /* top and bottom */
        memcpy(buf - (i + 1) * wrap, buf, width);
        memcpy(last_line + (i + 1) * wrap, last_line, width);
    }
    /* left and right */
    ptr = buf;
    for(i=0;i<height;i++) {
        memset(ptr - w, ptr[0], w);
        memset(ptr + width, ptr[width-1], w);
        ptr += wrap;
    }
    /* corners */
    for(i=0;i<w;i++) {
        memset(buf - (i + 1) * wrap - w, buf[0], w); /* top left */
        memset(buf - (i + 1) * wrap + width, buf[width-1], w); /* top right */
        memset(last_line + (i + 1) * wrap - w, last_line[0], w); /* top left */
        memset(last_line + (i + 1) * wrap + width, last_line[width-1], w); /* top right */
    }
}

M
Michael Niedermayer 已提交
923 924 925 926 927 928 929 930 931
static int find_unused_picture(MpegEncContext *s, int shared){
    int i;
    
    if(shared){
        for(i=0; i<MAX_PICTURE_COUNT; i++){
            if(s->picture[i].data[0]==NULL && s->picture[i].type==0) break;
        }
    }else{
        for(i=0; i<MAX_PICTURE_COUNT; i++){
M
Michael Niedermayer 已提交
932
            if(s->picture[i].data[0]==NULL && s->picture[i].type!=0) break; //FIXME
M
Michael Niedermayer 已提交
933 934 935 936 937 938 939 940 941 942
        }
        for(i=0; i<MAX_PICTURE_COUNT; i++){
            if(s->picture[i].data[0]==NULL) break;
        }
    }

    assert(i<MAX_PICTURE_COUNT);
    return i;
}

F
Fabrice Bellard 已提交
943
/* generic function for encode/decode called before a frame is coded/decoded */
944
int MPV_frame_start(MpegEncContext *s, AVCodecContext *avctx)
F
Fabrice Bellard 已提交
945
{
M
Michael Niedermayer 已提交
946
    int i;
M
Michael Niedermayer 已提交
947
    AVFrame *pic;
F
Fabrice Bellard 已提交
948

949
    s->mb_skiped = 0;
M
Michael Niedermayer 已提交
950

M
Michael Niedermayer 已提交
951
    assert(s->last_picture_ptr==NULL || s->out_format != FMT_H264 || s->codec_id == CODEC_ID_SVQ3);
M
Michael Niedermayer 已提交
952

M
cleanup  
Michael Niedermayer 已提交
953
    /* mark&release old frames */
M
Michael Niedermayer 已提交
954 955
    if (s->pict_type != B_TYPE && s->last_picture_ptr) {
        avctx->release_buffer(avctx, (AVFrame*)s->last_picture_ptr);
M
cleanup  
Michael Niedermayer 已提交
956 957 958 959 960

        /* release forgotten pictures */
        /* if(mpeg124/h263) */
        if(!s->encoding){
            for(i=0; i<MAX_PICTURE_COUNT; i++){
M
Michael Niedermayer 已提交
961
                if(s->picture[i].data[0] && &s->picture[i] != s->next_picture_ptr && s->picture[i].reference){
M
cleanup  
Michael Niedermayer 已提交
962
                    fprintf(stderr, "releasing zombie picture\n");
M
Michael Niedermayer 已提交
963
                    avctx->release_buffer(avctx, (AVFrame*)&s->picture[i]);                
M
cleanup  
Michael Niedermayer 已提交
964 965
                }
            }
966
        }
967
    }
968 969
alloc:
    if(!s->encoding){
M
Michael Niedermayer 已提交
970 971 972 973 974 975 976
        /* release non refernce frames */
        for(i=0; i<MAX_PICTURE_COUNT; i++){
            if(s->picture[i].data[0] && !s->picture[i].reference /*&& s->picture[i].type!=FF_BUFFER_TYPE_SHARED*/){
                s->avctx->release_buffer(s->avctx, (AVFrame*)&s->picture[i]);
            }
        }

M
Michael Niedermayer 已提交
977
        i= find_unused_picture(s, 0);
M
cleanup  
Michael Niedermayer 已提交
978
    
M
Michael Niedermayer 已提交
979
        pic= (AVFrame*)&s->picture[i];
M
Michael Niedermayer 已提交
980
        pic->reference= s->pict_type != B_TYPE ? 3 : 0;
M
Michael Niedermayer 已提交
981 982 983

        if(s->current_picture_ptr)
            pic->coded_picture_number= s->current_picture_ptr->coded_picture_number+1;
M
cleanup  
Michael Niedermayer 已提交
984
        
985 986
        if( alloc_picture(s, (Picture*)pic, 0) < 0)
            return -1;
987

M
Michael Niedermayer 已提交
988
        s->current_picture_ptr= &s->picture[i];
M
cleanup  
Michael Niedermayer 已提交
989
    }
990

M
Michael Niedermayer 已提交
991 992
    s->current_picture_ptr->pict_type= s->pict_type;
    s->current_picture_ptr->quality= s->qscale;
993
    s->current_picture_ptr->key_frame= s->pict_type == I_TYPE;
M
Michael Niedermayer 已提交
994

M
Michael Niedermayer 已提交
995
    s->current_picture= *s->current_picture_ptr;
M
Michael Niedermayer 已提交
996
  
M
Michael Niedermayer 已提交
997
  if(s->out_format != FMT_H264 || s->codec_id == CODEC_ID_SVQ3){
M
cleanup  
Michael Niedermayer 已提交
998
    if (s->pict_type != B_TYPE) {
M
Michael Niedermayer 已提交
999 1000
        s->last_picture_ptr= s->next_picture_ptr;
        s->next_picture_ptr= s->current_picture_ptr;
F
Fabrice Bellard 已提交
1001
    }
1002
    
M
Michael Niedermayer 已提交
1003 1004 1005
    if(s->last_picture_ptr) s->last_picture= *s->last_picture_ptr;
    if(s->next_picture_ptr) s->next_picture= *s->next_picture_ptr;
    if(s->new_picture_ptr ) s->new_picture = *s->new_picture_ptr;
1006
    
1007 1008 1009 1010 1011 1012 1013 1014
    if(s->pict_type != I_TYPE && s->last_picture_ptr==NULL){
        fprintf(stderr, "warning: first frame is no keyframe\n");
        assert(s->pict_type != B_TYPE); //these should have been dropped if we dont have a reference
        goto alloc;
    }

    assert(s->pict_type == I_TYPE || (s->last_picture_ptr && s->last_picture_ptr->data[0]));

M
Michael Niedermayer 已提交
1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025
    if(s->picture_structure!=PICT_FRAME){
        int i;
        for(i=0; i<4; i++){
            if(s->picture_structure == PICT_BOTTOM_FIELD){
                 s->current_picture.data[i] += s->current_picture.linesize[i];
            } 
            s->current_picture.linesize[i] *= 2;
            s->last_picture.linesize[i] *=2;
            s->next_picture.linesize[i] *=2;
        }
    }
M
Michael Niedermayer 已提交
1026
  }
M
cleanup  
Michael Niedermayer 已提交
1027
   
1028 1029 1030
    s->hurry_up= s->avctx->hurry_up;
    s->error_resilience= avctx->error_resilience;

1031 1032 1033 1034 1035 1036 1037 1038 1039
    /* set dequantizer, we cant do it during init as it might change for mpeg4
       and we cant do it in the header decode as init isnt called for mpeg4 there yet */
    if(s->out_format == FMT_H263){
        if(s->mpeg_quant)
            s->dct_unquantize = s->dct_unquantize_mpeg2;
        else
            s->dct_unquantize = s->dct_unquantize_h263;
    }else 
        s->dct_unquantize = s->dct_unquantize_mpeg1;
1040

I
Ivan Kalvachev 已提交
1041 1042 1043 1044
#ifdef HAVE_XVMC
    if(s->avctx->xvmc_acceleration)
        return XVMC_field_start(s, avctx);
#endif
1045
    return 0;
F
Fabrice Bellard 已提交
1046
}
1047

F
Fabrice Bellard 已提交
1048 1049 1050
/* generic function for encode/decode called after a frame has been coded/decoded */
void MPV_frame_end(MpegEncContext *s)
{
M
cleanup  
Michael Niedermayer 已提交
1051
    int i;
F
Fabrice Bellard 已提交
1052
    /* draw edge for correct motion prediction if outside */
I
Ivan Kalvachev 已提交
1053 1054 1055 1056 1057 1058
#ifdef HAVE_XVMC
//just to make sure that all data is rendered.
    if(s->avctx->xvmc_acceleration){
        XVMC_field_end(s);
    }else
#endif
M
2x100l  
Michael Niedermayer 已提交
1059
    if(s->codec_id!=CODEC_ID_SVQ1 && s->codec_id != CODEC_ID_MPEG1VIDEO){
M
cleanup  
Michael Niedermayer 已提交
1060 1061 1062 1063 1064
        if (s->pict_type != B_TYPE && !s->intra_only && !(s->flags&CODEC_FLAG_EMU_EDGE)) {
            draw_edges(s->current_picture.data[0], s->linesize  , s->h_edge_pos   , s->v_edge_pos   , EDGE_WIDTH  );
            draw_edges(s->current_picture.data[1], s->uvlinesize, s->h_edge_pos>>1, s->v_edge_pos>>1, EDGE_WIDTH/2);
            draw_edges(s->current_picture.data[2], s->uvlinesize, s->h_edge_pos>>1, s->v_edge_pos>>1, EDGE_WIDTH/2);
        }
F
Fabrice Bellard 已提交
1065
    }
M
Michael Niedermayer 已提交
1066
    emms_c();
1067
    
M
Michael Niedermayer 已提交
1068
    s->last_pict_type    = s->pict_type;
1069 1070 1071
    if(s->pict_type!=B_TYPE){
        s->last_non_b_pict_type= s->pict_type;
    }
M
Michael Niedermayer 已提交
1072 1073
#if 0
        /* copy back current_picture variables */
M
cleanup  
Michael Niedermayer 已提交
1074 1075 1076 1077 1078 1079 1080
    for(i=0; i<MAX_PICTURE_COUNT; i++){
        if(s->picture[i].data[0] == s->current_picture.data[0]){
            s->picture[i]= s->current_picture;
            break;
        }    
    }
    assert(i<MAX_PICTURE_COUNT);
M
Michael Niedermayer 已提交
1081
#endif    
M
cleanup  
Michael Niedermayer 已提交
1082

M
Michael Niedermayer 已提交
1083 1084 1085 1086 1087 1088 1089
    if(s->encoding){
        /* release non refernce frames */
        for(i=0; i<MAX_PICTURE_COUNT; i++){
            if(s->picture[i].data[0] && !s->picture[i].reference /*&& s->picture[i].type!=FF_BUFFER_TYPE_SHARED*/){
                s->avctx->release_buffer(s->avctx, (AVFrame*)&s->picture[i]);
            }
        }
M
cleanup  
Michael Niedermayer 已提交
1090
    }
M
Michael Niedermayer 已提交
1091 1092 1093 1094 1095 1096
    // clear copies, to avoid confusion
#if 0
    memset(&s->last_picture, 0, sizeof(Picture));
    memset(&s->next_picture, 0, sizeof(Picture));
    memset(&s->current_picture, 0, sizeof(Picture));
#endif
F
Fabrice Bellard 已提交
1097 1098
}

1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176
/**
 * draws an line from (ex, ey) -> (sx, sy).
 * @param w width of the image
 * @param h height of the image
 * @param stride stride/linesize of the image
 * @param color color of the arrow
 */
static void draw_line(uint8_t *buf, int sx, int sy, int ex, int ey, int w, int h, int stride, int color){
    int t, x, y, f;
    
    sx= clip(sx, 0, w-1);
    sy= clip(sy, 0, h-1);
    ex= clip(ex, 0, w-1);
    ey= clip(ey, 0, h-1);
    
    buf[sy*stride + sx]+= color;
    
    if(ABS(ex - sx) > ABS(ey - sy)){
        if(sx > ex){
            t=sx; sx=ex; ex=t;
            t=sy; sy=ey; ey=t;
        }
        buf+= sx + sy*stride;
        ex-= sx;
        f= ((ey-sy)<<16)/ex;
        for(x= 0; x <= ex; x++){
            y= ((x*f) + (1<<15))>>16;
            buf[y*stride + x]+= color;
        }
    }else{
        if(sy > ey){
            t=sx; sx=ex; ex=t;
            t=sy; sy=ey; ey=t;
        }
        buf+= sx + sy*stride;
        ey-= sy;
        if(ey) f= ((ex-sx)<<16)/ey;
        else   f= 0;
        for(y= 0; y <= ey; y++){
            x= ((y*f) + (1<<15))>>16;
            buf[y*stride + x]+= color;
        }
    }
}

/**
 * draws an arrow from (ex, ey) -> (sx, sy).
 * @param w width of the image
 * @param h height of the image
 * @param stride stride/linesize of the image
 * @param color color of the arrow
 */
static void draw_arrow(uint8_t *buf, int sx, int sy, int ex, int ey, int w, int h, int stride, int color){ 
    int dx,dy;

    sx= clip(sx, -100, w+100);
    sy= clip(sy, -100, h+100);
    ex= clip(ex, -100, w+100);
    ey= clip(ey, -100, h+100);
    
    dx= ex - sx;
    dy= ey - sy;
    
    if(dx*dx + dy*dy > 3*3){
        int rx=  dx + dy;
        int ry= -dx + dy;
        int length= ff_sqrt((rx*rx + ry*ry)<<8);
        
        //FIXME subpixel accuracy
        rx= ROUNDED_DIV(rx*3<<4, length);
        ry= ROUNDED_DIV(ry*3<<4, length);
        
        draw_line(buf, sx, sy, sx + rx, sy + ry, w, h, stride, color);
        draw_line(buf, sx, sy, sx - ry, sy + rx, w, h, stride, color);
    }
    draw_line(buf, sx, sy, ex, ey, w, h, stride, color);
}

1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250
/**
 * prints debuging info for the given picture.
 */
void ff_print_debug_info(MpegEncContext *s, Picture *pict){

    if(!pict || !pict->mb_type) return;

    if(s->avctx->debug&(FF_DEBUG_SKIP | FF_DEBUG_QP | FF_DEBUG_MB_TYPE)){
        int x,y;

        for(y=0; y<s->mb_height; y++){
            for(x=0; x<s->mb_width; x++){
                if(s->avctx->debug&FF_DEBUG_SKIP){
                    int count= s->mbskip_table[x + y*s->mb_stride];
                    if(count>9) count=9;
                    printf("%1d", count);
                }
                if(s->avctx->debug&FF_DEBUG_QP){
                    printf("%2d", pict->qscale_table[x + y*s->mb_stride]);
                }
                if(s->avctx->debug&FF_DEBUG_MB_TYPE){
                    int mb_type= pict->mb_type[x + y*s->mb_stride];
                    
                    //Type & MV direction
                    if(IS_PCM(mb_type))
                        printf("P");
                    else if(IS_INTRA(mb_type) && IS_ACPRED(mb_type))
                        printf("A");
                    else if(IS_INTRA4x4(mb_type))
                        printf("i");
                    else if(IS_INTRA16x16(mb_type))
                        printf("I");
                    else if(IS_DIRECT(mb_type) && IS_SKIP(mb_type))
                        printf("d");
                    else if(IS_DIRECT(mb_type))
                        printf("D");
                    else if(IS_GMC(mb_type) && IS_SKIP(mb_type))
                        printf("g");
                    else if(IS_GMC(mb_type))
                        printf("G");
                    else if(IS_SKIP(mb_type))
                        printf("S");
                    else if(!USES_LIST(mb_type, 1))
                        printf(">");
                    else if(!USES_LIST(mb_type, 0))
                        printf("<");
                    else{
                        assert(USES_LIST(mb_type, 0) && USES_LIST(mb_type, 1));
                        printf("X");
                    }
                    
                    //segmentation
                    if(IS_8X8(mb_type))
                        printf("+");
                    else if(IS_16X8(mb_type))
                        printf("-");
                    else if(IS_8X16(mb_type))
                        printf("");
                    else if(IS_INTRA(mb_type) || IS_16X16(mb_type))
                        printf(" ");
                    else
                        printf("?");
                    
                        
                    if(IS_INTERLACED(mb_type) && s->codec_id == CODEC_ID_H264)
                        printf("=");
                    else
                        printf(" ");
                }
//                printf(" ");
            }
            printf("\n");
        }
    }
1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283
    
    if((s->avctx->debug&FF_DEBUG_VIS_MV) && s->motion_val){
        const int shift= 1 + s->quarter_sample;
        int mb_y;
        uint8_t *ptr= pict->data[0];
        s->low_delay=0; //needed to see the vectors without trashing the buffers

        for(mb_y=0; mb_y<s->mb_height; mb_y++){
            int mb_x;
            for(mb_x=0; mb_x<s->mb_width; mb_x++){
                const int mb_index= mb_x + mb_y*s->mb_stride;
                if(IS_8X8(s->current_picture.mb_type[mb_index])){
                    int i;
                    for(i=0; i<4; i++){
                        int sx= mb_x*16 + 4 + 8*(i&1);
                        int sy= mb_y*16 + 4 + 8*(i>>1);
                        int xy= 1 + mb_x*2 + (i&1) + (mb_y*2 + 1 + (i>>1))*(s->mb_width*2 + 2);
                        int mx= (s->motion_val[xy][0]>>shift) + sx;
                        int my= (s->motion_val[xy][1]>>shift) + sy;
                        draw_arrow(ptr, sx, sy, mx, my, s->width, s->height, s->linesize, 100);
                    }
                }else{
                    int sx= mb_x*16 + 8;
                    int sy= mb_y*16 + 8;
                    int xy= 1 + mb_x*2 + (mb_y*2 + 1)*(s->mb_width*2 + 2);
                    int mx= (s->motion_val[xy][0]>>shift) + sx;
                    int my= (s->motion_val[xy][1]>>shift) + sy;
                    draw_arrow(ptr, sx, sy, mx, my, s->width, s->height, s->linesize, 100);
                }
                s->mbskip_table[mb_index]=0;
            }
        }
    }
1284 1285
}

1286 1287
#ifdef CONFIG_ENCODERS

M
Michael Niedermayer 已提交
1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320
static int get_sae(uint8_t *src, int ref, int stride){
    int x,y;
    int acc=0;
    
    for(y=0; y<16; y++){
        for(x=0; x<16; x++){
            acc+= ABS(src[x+y*stride] - ref);
        }
    }
    
    return acc;
}

static int get_intra_count(MpegEncContext *s, uint8_t *src, uint8_t *ref, int stride){
    int x, y, w, h;
    int acc=0;
    
    w= s->width &~15;
    h= s->height&~15;
    
    for(y=0; y<h; y+=16){
        for(x=0; x<w; x+=16){
            int offset= x + y*stride;
            int sad = s->dsp.pix_abs16x16(src + offset, ref + offset, stride);
            int mean= (s->dsp.pix_sum(src + offset, stride) + 128)>>8;
            int sae = get_sae(src + offset, mean, stride);
            
            acc+= sae + 500 < sad;
        }
    }
    return acc;
}

M
Michael Niedermayer 已提交
1321

M
Michael Niedermayer 已提交
1322
static int load_input_picture(MpegEncContext *s, AVFrame *pic_arg){
1323
    AVFrame *pic=NULL;
M
Michael Niedermayer 已提交
1324
    int i;
M
cleanup  
Michael Niedermayer 已提交
1325
    const int encoding_delay= s->max_b_frames;
M
Michael Niedermayer 已提交
1326
    int direct=1;
1327 1328
    
  if(pic_arg){
M
Michael Niedermayer 已提交
1329 1330 1331 1332 1333 1334
    if(encoding_delay && !(s->flags&CODEC_FLAG_INPUT_PRESERVED)) direct=0;
    if(pic_arg->linesize[0] != s->linesize) direct=0;
    if(pic_arg->linesize[1] != s->uvlinesize) direct=0;
    if(pic_arg->linesize[2] != s->uvlinesize) direct=0;
  
//    printf("%d %d %d %d\n",pic_arg->linesize[0], pic_arg->linesize[1], s->linesize, s->uvlinesize);
M
cleanup  
Michael Niedermayer 已提交
1335
    
M
Michael Niedermayer 已提交
1336 1337
    if(direct){
        i= find_unused_picture(s, 1);
M
cleanup  
Michael Niedermayer 已提交
1338

M
Michael Niedermayer 已提交
1339
        pic= (AVFrame*)&s->picture[i];
M
Michael Niedermayer 已提交
1340
        pic->reference= 3;
M
cleanup  
Michael Niedermayer 已提交
1341
    
M
Michael Niedermayer 已提交
1342 1343 1344 1345 1346 1347 1348
        for(i=0; i<4; i++){
            pic->data[i]= pic_arg->data[i];
            pic->linesize[i]= pic_arg->linesize[i];
        }
        alloc_picture(s, (Picture*)pic, 1);
    }else{
        i= find_unused_picture(s, 0);
M
cleanup  
Michael Niedermayer 已提交
1349

M
Michael Niedermayer 已提交
1350
        pic= (AVFrame*)&s->picture[i];
M
Michael Niedermayer 已提交
1351
        pic->reference= 3;
M
cleanup  
Michael Niedermayer 已提交
1352

M
Michael Niedermayer 已提交
1353
        alloc_picture(s, (Picture*)pic, 0);
M
Michael Niedermayer 已提交
1354 1355 1356 1357 1358 1359
        for(i=0; i<4; i++){
            /* the input will be 16 pixels to the right relative to the actual buffer start
             * and the current_pic, so the buffer can be reused, yes its not beatifull 
             */
            pic->data[i]+= 16; 
        }
M
Michael Niedermayer 已提交
1360 1361 1362 1363

        if(   pic->data[0] == pic_arg->data[0] 
           && pic->data[1] == pic_arg->data[1]
           && pic->data[2] == pic_arg->data[2]){
M
cleanup  
Michael Niedermayer 已提交
1364
       // empty
M
Michael Niedermayer 已提交
1365 1366
        }else{
            int h_chroma_shift, v_chroma_shift;
M
cleanup  
Michael Niedermayer 已提交
1367
        
M
Michael Niedermayer 已提交
1368
            avcodec_get_chroma_sub_sample(s->avctx->pix_fmt, &h_chroma_shift, &v_chroma_shift);
M
cleanup  
Michael Niedermayer 已提交
1369
        
M
Michael Niedermayer 已提交
1370 1371 1372 1373 1374 1375 1376 1377 1378
            for(i=0; i<3; i++){
                int src_stride= pic_arg->linesize[i];
                int dst_stride= i ? s->uvlinesize : s->linesize;
                int h_shift= i ? h_chroma_shift : 0;
                int v_shift= i ? v_chroma_shift : 0;
                int w= s->width >>h_shift;
                int h= s->height>>v_shift;
                uint8_t *src= pic_arg->data[i];
                uint8_t *dst= pic->data[i];
M
cleanup  
Michael Niedermayer 已提交
1379
            
M
Michael Niedermayer 已提交
1380 1381 1382 1383 1384 1385 1386 1387
                if(src_stride==dst_stride)
                    memcpy(dst, src, src_stride*h);
                else{
                    while(h--){
                        memcpy(dst, src, w);
                        dst += dst_stride;
                        src += src_stride;
                    }
M
cleanup  
Michael Niedermayer 已提交
1388
                }
1389
            }
M
cleanup  
Michael Niedermayer 已提交
1390 1391
        }
    }
M
Michael Niedermayer 已提交
1392 1393
    pic->quality= pic_arg->quality;
    pic->pict_type= pic_arg->pict_type;
1394
    pic->pts = pic_arg->pts;
M
Michael Niedermayer 已提交
1395 1396 1397
    
    if(s->input_picture[encoding_delay])
        pic->display_picture_number= s->input_picture[encoding_delay]->display_picture_number + 1;
1398 1399
    
  }
M
Michael Niedermayer 已提交
1400 1401 1402 1403 1404 1405

    /* shift buffer entries */
    for(i=1; i<MAX_PICTURE_COUNT /*s->encoding_delay+1*/; i++)
        s->input_picture[i-1]= s->input_picture[i];
        
    s->input_picture[encoding_delay]= (Picture*)pic;
M
cleanup  
Michael Niedermayer 已提交
1406 1407 1408

    return 0;
}
1409

M
cleanup  
Michael Niedermayer 已提交
1410 1411 1412 1413 1414 1415 1416
static void select_input_picture(MpegEncContext *s){
    int i;
    const int encoding_delay= s->max_b_frames;
    int coded_pic_num=0;    

    if(s->reordered_input_picture[0])
        coded_pic_num= s->reordered_input_picture[0]->coded_picture_number + 1;
M
Michael Niedermayer 已提交
1417

M
cleanup  
Michael Niedermayer 已提交
1418 1419 1420 1421 1422 1423
    for(i=1; i<MAX_PICTURE_COUNT; i++)
        s->reordered_input_picture[i-1]= s->reordered_input_picture[i];
    s->reordered_input_picture[MAX_PICTURE_COUNT-1]= NULL;

    /* set next picture types & ordering */
    if(s->reordered_input_picture[0]==NULL && s->input_picture[0]){
M
Michael Niedermayer 已提交
1424
        if(/*s->picture_in_gop_number >= s->gop_size ||*/ s->next_picture_ptr==NULL || s->intra_only){
M
Michael Niedermayer 已提交
1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439
            s->reordered_input_picture[0]= s->input_picture[0];
            s->reordered_input_picture[0]->pict_type= I_TYPE;
            s->reordered_input_picture[0]->coded_picture_number= coded_pic_num;
        }else{
            int b_frames;
            
            if(s->flags&CODEC_FLAG_PASS2){
                for(i=0; i<s->max_b_frames+1; i++){
                    int pict_num= s->input_picture[0]->display_picture_number + i;
                    int pict_type= s->rc_context.entry[pict_num].new_pict_type;
                    s->input_picture[i]->pict_type= pict_type;
                    
                    if(i + 1 >= s->rc_context.num_entries) break;
                }
            }
M
Michael Niedermayer 已提交
1440

M
Michael Niedermayer 已提交
1441 1442
            if(s->input_picture[0]->pict_type){
                /* user selected pict_type */
1443 1444 1445
                for(b_frames=0; b_frames<s->max_b_frames+1; b_frames++){
                    if(s->input_picture[b_frames]->pict_type!=B_TYPE) break;
                }
M
Michael Niedermayer 已提交
1446
            
1447 1448 1449 1450
                if(b_frames > s->max_b_frames){
                    fprintf(stderr, "warning, too many bframes in a row\n");
                    b_frames = s->max_b_frames;
                }
M
Michael Niedermayer 已提交
1451 1452
            }else if(s->b_frame_strategy==0){
                b_frames= s->max_b_frames;
1453
                while(b_frames && !s->input_picture[b_frames]) b_frames--;
M
Michael Niedermayer 已提交
1454 1455
            }else if(s->b_frame_strategy==1){
                for(i=1; i<s->max_b_frames+1; i++){
1456
                    if(s->input_picture[i] && s->input_picture[i]->b_frame_score==0){
M
Michael Niedermayer 已提交
1457
                        s->input_picture[i]->b_frame_score= 
M
Michael Niedermayer 已提交
1458 1459
                            get_intra_count(s, s->input_picture[i  ]->data[0], 
                                               s->input_picture[i-1]->data[0], s->linesize) + 1;
M
Michael Niedermayer 已提交
1460 1461 1462
                    }
                }
                for(i=0; i<s->max_b_frames; i++){
1463
                    if(s->input_picture[i]==NULL || s->input_picture[i]->b_frame_score - 1 > s->mb_num/40) break;
M
Michael Niedermayer 已提交
1464 1465 1466
                }
                                
                b_frames= FFMAX(0, i-1);
1467
                
M
Michael Niedermayer 已提交
1468 1469 1470 1471 1472 1473 1474
                /* reset scores */
                for(i=0; i<b_frames+1; i++){
                    s->input_picture[i]->b_frame_score=0;
                }
            }else{
                fprintf(stderr, "illegal b frame strategy\n");
                b_frames=0;
1475
            }
M
Michael Niedermayer 已提交
1476 1477 1478 1479 1480 1481 1482 1483 1484

            emms_c();
//static int b_count=0;
//b_count+= b_frames;
//printf("b_frames: %d\n", b_count);
                        
            s->reordered_input_picture[0]= s->input_picture[b_frames];
            if(   s->picture_in_gop_number + b_frames >= s->gop_size 
               || s->reordered_input_picture[0]->pict_type== I_TYPE)
M
cleanup  
Michael Niedermayer 已提交
1485
                s->reordered_input_picture[0]->pict_type= I_TYPE;
M
Michael Niedermayer 已提交
1486 1487 1488 1489 1490 1491 1492 1493
            else
                s->reordered_input_picture[0]->pict_type= P_TYPE;
            s->reordered_input_picture[0]->coded_picture_number= coded_pic_num;
            for(i=0; i<b_frames; i++){
                coded_pic_num++;
                s->reordered_input_picture[i+1]= s->input_picture[i];
                s->reordered_input_picture[i+1]->pict_type= B_TYPE;
                s->reordered_input_picture[i+1]->coded_picture_number= coded_pic_num;
1494 1495 1496
            }
        }
    }
M
cleanup  
Michael Niedermayer 已提交
1497 1498
    
    if(s->reordered_input_picture[0]){
M
Michael Niedermayer 已提交
1499
        s->reordered_input_picture[0]->reference= s->reordered_input_picture[0]->pict_type!=B_TYPE ? 3 : 0;
M
Michael Niedermayer 已提交
1500 1501

        s->new_picture= *s->reordered_input_picture[0];
M
Michael Niedermayer 已提交
1502 1503

        if(s->reordered_input_picture[0]->type == FF_BUFFER_TYPE_SHARED){
M
Michael Niedermayer 已提交
1504 1505
            // input is a shared pix, so we cant modifiy it -> alloc a new one & ensure that the shared one is reuseable
        
M
Michael Niedermayer 已提交
1506 1507 1508 1509 1510 1511 1512 1513
            int i= find_unused_picture(s, 0);
            Picture *pic= &s->picture[i];

            /* mark us unused / free shared pic */
            for(i=0; i<4; i++)
                s->reordered_input_picture[0]->data[i]= NULL;
            s->reordered_input_picture[0]->type= 0;
            
M
Michael Niedermayer 已提交
1514
            //FIXME bad, copy * except
M
Michael Niedermayer 已提交
1515 1516 1517 1518 1519 1520 1521
            pic->pict_type = s->reordered_input_picture[0]->pict_type;
            pic->quality   = s->reordered_input_picture[0]->quality;
            pic->coded_picture_number = s->reordered_input_picture[0]->coded_picture_number;
            pic->reference = s->reordered_input_picture[0]->reference;
            
            alloc_picture(s, pic, 0);

M
Michael Niedermayer 已提交
1522
            s->current_picture_ptr= pic;
M
Michael Niedermayer 已提交
1523
        }else{
M
Michael Niedermayer 已提交
1524 1525
            // input is not a shared pix -> reuse buffer for current_pix

M
Michael Niedermayer 已提交
1526 1527 1528
            assert(   s->reordered_input_picture[0]->type==FF_BUFFER_TYPE_USER 
                   || s->reordered_input_picture[0]->type==FF_BUFFER_TYPE_INTERNAL);
            
M
Michael Niedermayer 已提交
1529
            s->current_picture_ptr= s->reordered_input_picture[0];
M
Michael Niedermayer 已提交
1530
            for(i=0; i<4; i++){
M
Michael Niedermayer 已提交
1531 1532
                //reverse the +16 we did before storing the input
                s->current_picture_ptr->data[i]-=16;
M
Michael Niedermayer 已提交
1533
            }
M
cleanup  
Michael Niedermayer 已提交
1534
        }
M
Michael Niedermayer 已提交
1535
        s->current_picture= *s->current_picture_ptr;
M
cleanup  
Michael Niedermayer 已提交
1536 1537 1538 1539 1540
    
        s->picture_number= s->new_picture.display_picture_number;
//printf("dpn:%d\n", s->picture_number);
    }else{
       memset(&s->new_picture, 0, sizeof(Picture));
1541 1542 1543
    }
}

F
Fabrice Bellard 已提交
1544 1545 1546 1547
int MPV_encode_picture(AVCodecContext *avctx,
                       unsigned char *buf, int buf_size, void *data)
{
    MpegEncContext *s = avctx->priv_data;
M
Michael Niedermayer 已提交
1548
    AVFrame *pic_arg = data;
1549
    int i;
F
Fabrice Bellard 已提交
1550 1551 1552

    init_put_bits(&s->pb, buf, buf_size, NULL, NULL);

M
cleanup  
Michael Niedermayer 已提交
1553
    s->picture_in_gop_number++;
F
Fabrice Bellard 已提交
1554

M
cleanup  
Michael Niedermayer 已提交
1555
    load_input_picture(s, pic_arg);
1556
    
M
cleanup  
Michael Niedermayer 已提交
1557
    select_input_picture(s);
1558 1559
    
    /* output? */
M
cleanup  
Michael Niedermayer 已提交
1560
    if(s->new_picture.data[0]){
1561

M
cleanup  
Michael Niedermayer 已提交
1562 1563 1564 1565 1566 1567 1568
        s->pict_type= s->new_picture.pict_type;
        if (s->fixed_qscale){ /* the ratecontrol needs the last qscale so we dont touch it for CBR */
            s->qscale= (int)(s->new_picture.quality+0.5);
            assert(s->qscale);
        }
//emms_c();
//printf("qs:%f %f %d\n", s->new_picture.quality, s->current_picture.quality, s->qscale);
1569
        MPV_frame_start(s, avctx);
1570 1571

        encode_picture(s, s->picture_number);
1572
        
J
Juanjo 已提交
1573
        avctx->real_pict_num  = s->picture_number;
1574 1575 1576 1577 1578 1579
        avctx->header_bits = s->header_bits;
        avctx->mv_bits     = s->mv_bits;
        avctx->misc_bits   = s->misc_bits;
        avctx->i_tex_bits  = s->i_tex_bits;
        avctx->p_tex_bits  = s->p_tex_bits;
        avctx->i_count     = s->i_count;
1580
        avctx->p_count     = s->mb_num - s->i_count - s->skip_count; //FIXME f/b_count in avctx
1581 1582 1583 1584 1585 1586
        avctx->skip_count  = s->skip_count;

        MPV_frame_end(s);

        if (s->out_format == FMT_MJPEG)
            mjpeg_picture_trailer(s);
1587 1588 1589
        
        if(s->flags&CODEC_FLAG_PASS1)
            ff_write_pass1_stats(s);
M
Michael Niedermayer 已提交
1590 1591 1592 1593

        for(i=0; i<4; i++){
            avctx->error[i] += s->current_picture_ptr->error[i];
        }
F
Fabrice Bellard 已提交
1594 1595
    }

1596
    s->input_picture_number++;
F
Fabrice Bellard 已提交
1597 1598

    flush_put_bits(&s->pb);
1599
    s->frame_bits  = (pbBufPtr(&s->pb) - s->pb.buf) * 8;
M
Michael Niedermayer 已提交
1600
    
1601
    s->total_bits += s->frame_bits;
1602
    avctx->frame_bits  = s->frame_bits;
1603
    
1604
    return pbBufPtr(&s->pb) - s->pb.buf;
F
Fabrice Bellard 已提交
1605 1606
}

1607 1608
#endif //CONFIG_ENCODERS

M
Michael Niedermayer 已提交
1609
static inline void gmc1_motion(MpegEncContext *s,
1610
                               uint8_t *dest_y, uint8_t *dest_cb, uint8_t *dest_cr,
M
Michael Niedermayer 已提交
1611
                               int dest_offset,
1612
                               uint8_t **ref_picture, int src_offset)
M
Michael Niedermayer 已提交
1613
{
1614
    uint8_t *ptr;
M
Michael Niedermayer 已提交
1615
    int offset, src_x, src_y, linesize, uvlinesize;
M
Michael Niedermayer 已提交
1616
    int motion_x, motion_y;
M
Michael Niedermayer 已提交
1617
    int emu=0;
M
Michael Niedermayer 已提交
1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630

    motion_x= s->sprite_offset[0][0];
    motion_y= s->sprite_offset[0][1];
    src_x = s->mb_x * 16 + (motion_x >> (s->sprite_warping_accuracy+1));
    src_y = s->mb_y * 16 + (motion_y >> (s->sprite_warping_accuracy+1));
    motion_x<<=(3-s->sprite_warping_accuracy);
    motion_y<<=(3-s->sprite_warping_accuracy);
    src_x = clip(src_x, -16, s->width);
    if (src_x == s->width)
        motion_x =0;
    src_y = clip(src_y, -16, s->height);
    if (src_y == s->height)
        motion_y =0;
1631

M
Michael Niedermayer 已提交
1632
    linesize = s->linesize;
M
Michael Niedermayer 已提交
1633
    uvlinesize = s->uvlinesize;
1634
    
M
Michael Niedermayer 已提交
1635 1636 1637
    ptr = ref_picture[0] + (src_y * linesize) + src_x + src_offset;

    dest_y+=dest_offset;
M
Michael Niedermayer 已提交
1638
    if(s->flags&CODEC_FLAG_EMU_EDGE){
1639 1640
        if(src_x<0 || src_y<0 || src_x + 17 >= s->h_edge_pos
                              || src_y + 17 >= s->v_edge_pos){
1641
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr, linesize, 17, 17, src_x, src_y, s->h_edge_pos, s->v_edge_pos);
M
Michael Niedermayer 已提交
1642 1643 1644
            ptr= s->edge_emu_buffer;
        }
    }
1645 1646
    
    if((motion_x|motion_y)&7){
1647 1648
        s->dsp.gmc1(dest_y  , ptr  , linesize, 16, motion_x&15, motion_y&15, 128 - s->no_rounding);
        s->dsp.gmc1(dest_y+8, ptr+8, linesize, 16, motion_x&15, motion_y&15, 128 - s->no_rounding);
1649 1650 1651 1652 1653
    }else{
        int dxy;
        
        dxy= ((motion_x>>3)&1) | ((motion_y>>2)&2);
        if (s->no_rounding){
1654
	    s->dsp.put_no_rnd_pixels_tab[0][dxy](dest_y, ptr, linesize, 16);
1655
        }else{
1656 1657
            s->dsp.put_pixels_tab       [0][dxy](dest_y, ptr, linesize, 16);
        }
1658 1659 1660
    }
    
    if(s->flags&CODEC_FLAG_GRAY) return;
M
Michael Niedermayer 已提交
1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673 1674

    motion_x= s->sprite_offset[1][0];
    motion_y= s->sprite_offset[1][1];
    src_x = s->mb_x * 8 + (motion_x >> (s->sprite_warping_accuracy+1));
    src_y = s->mb_y * 8 + (motion_y >> (s->sprite_warping_accuracy+1));
    motion_x<<=(3-s->sprite_warping_accuracy);
    motion_y<<=(3-s->sprite_warping_accuracy);
    src_x = clip(src_x, -8, s->width>>1);
    if (src_x == s->width>>1)
        motion_x =0;
    src_y = clip(src_y, -8, s->height>>1);
    if (src_y == s->height>>1)
        motion_y =0;

M
Michael Niedermayer 已提交
1675
    offset = (src_y * uvlinesize) + src_x + (src_offset>>1);
M
Michael Niedermayer 已提交
1676
    ptr = ref_picture[1] + offset;
1677 1678 1679
    if(s->flags&CODEC_FLAG_EMU_EDGE){
        if(src_x<0 || src_y<0 || src_x + 9 >= s->h_edge_pos>>1
                              || src_y + 9 >= s->v_edge_pos>>1){
1680
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr, uvlinesize, 9, 9, src_x, src_y, s->h_edge_pos>>1, s->v_edge_pos>>1);
1681 1682 1683
            ptr= s->edge_emu_buffer;
            emu=1;
        }
M
Michael Niedermayer 已提交
1684
    }
1685
    s->dsp.gmc1(dest_cb + (dest_offset>>1), ptr, uvlinesize, 8, motion_x&15, motion_y&15, 128 - s->no_rounding);
M
Michael Niedermayer 已提交
1686
    
M
Michael Niedermayer 已提交
1687
    ptr = ref_picture[2] + offset;
M
Michael Niedermayer 已提交
1688
    if(emu){
1689
        ff_emulated_edge_mc(s->edge_emu_buffer, ptr, uvlinesize, 9, 9, src_x, src_y, s->h_edge_pos>>1, s->v_edge_pos>>1);
M
Michael Niedermayer 已提交
1690 1691
        ptr= s->edge_emu_buffer;
    }
1692
    s->dsp.gmc1(dest_cr + (dest_offset>>1), ptr, uvlinesize, 8, motion_x&15, motion_y&15, 128 - s->no_rounding);
M
Michael Niedermayer 已提交
1693 1694 1695 1696
    
    return;
}

1697
static inline void gmc_motion(MpegEncContext *s,
1698
                               uint8_t *dest_y, uint8_t *dest_cb, uint8_t *dest_cr,
1699
                               int dest_offset,
1700
                               uint8_t **ref_picture, int src_offset)
1701
{
1702
    uint8_t *ptr;
1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716
    int linesize, uvlinesize;
    const int a= s->sprite_warping_accuracy;
    int ox, oy;

    linesize = s->linesize;
    uvlinesize = s->uvlinesize;

    ptr = ref_picture[0] + src_offset;

    dest_y+=dest_offset;
    
    ox= s->sprite_offset[0][0] + s->sprite_delta[0][0]*s->mb_x*16 + s->sprite_delta[0][1]*s->mb_y*16;
    oy= s->sprite_offset[0][1] + s->sprite_delta[1][0]*s->mb_x*16 + s->sprite_delta[1][1]*s->mb_y*16;

1717
    s->dsp.gmc(dest_y, ptr, linesize, 16,
1718 1719 1720 1721 1722 1723
           ox, 
           oy, 
           s->sprite_delta[0][0], s->sprite_delta[0][1],
           s->sprite_delta[1][0], s->sprite_delta[1][1], 
           a+1, (1<<(2*a+1)) - s->no_rounding,
           s->h_edge_pos, s->v_edge_pos);
1724
    s->dsp.gmc(dest_y+8, ptr, linesize, 16,
1725 1726 1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741
           ox + s->sprite_delta[0][0]*8, 
           oy + s->sprite_delta[1][0]*8, 
           s->sprite_delta[0][0], s->sprite_delta[0][1],
           s->sprite_delta[1][0], s->sprite_delta[1][1], 
           a+1, (1<<(2*a+1)) - s->no_rounding,
           s->h_edge_pos, s->v_edge_pos);

    if(s->flags&CODEC_FLAG_GRAY) return;


    dest_cb+=dest_offset>>1;
    dest_cr+=dest_offset>>1;
    
    ox= s->sprite_offset[1][0] + s->sprite_delta[0][0]*s->mb_x*8 + s->sprite_delta[0][1]*s->mb_y*8;
    oy= s->sprite_offset[1][1] + s->sprite_delta[1][0]*s->mb_x*8 + s->sprite_delta[1][1]*s->mb_y*8;

    ptr = ref_picture[1] + (src_offset>>1);
1742
    s->dsp.gmc(dest_cb, ptr, uvlinesize, 8,
1743 1744 1745 1746 1747 1748 1749 1750
           ox, 
           oy, 
           s->sprite_delta[0][0], s->sprite_delta[0][1],
           s->sprite_delta[1][0], s->sprite_delta[1][1], 
           a+1, (1<<(2*a+1)) - s->no_rounding,
           s->h_edge_pos>>1, s->v_edge_pos>>1);
    
    ptr = ref_picture[2] + (src_offset>>1);
1751
    s->dsp.gmc(dest_cr, ptr, uvlinesize, 8,
1752 1753 1754 1755 1756 1757 1758 1759
           ox, 
           oy, 
           s->sprite_delta[0][0], s->sprite_delta[0][1],
           s->sprite_delta[1][0], s->sprite_delta[1][1], 
           a+1, (1<<(2*a+1)) - s->no_rounding,
           s->h_edge_pos>>1, s->v_edge_pos>>1);
}

1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772
/**
 * Copies a rectangular area of samples to a temporary buffer and replicates the boarder samples.
 * @param buf destination buffer
 * @param src source buffer
 * @param linesize number of bytes between 2 vertically adjacent samples in both the source and destination buffers
 * @param block_w width of block
 * @param block_h height of block
 * @param src_x x coordinate of the top left sample of the block in the source buffer
 * @param src_y y coordinate of the top left sample of the block in the source buffer
 * @param w width of the source buffer
 * @param h height of the source buffer
 */
void ff_emulated_edge_mc(uint8_t *buf, uint8_t *src, int linesize, int block_w, int block_h, 
1773 1774 1775
                                    int src_x, int src_y, int w, int h){
    int x, y;
    int start_y, start_x, end_y, end_x;
1776

1777 1778 1779
    if(src_y>= h){
        src+= (h-1-src_y)*linesize;
        src_y=h-1;
M
Michael Niedermayer 已提交
1780 1781 1782
    }else if(src_y<=-block_h){
        src+= (1-block_h-src_y)*linesize;
        src_y=1-block_h;
1783 1784 1785 1786
    }
    if(src_x>= w){
        src+= (w-1-src_x);
        src_x=w-1;
M
Michael Niedermayer 已提交
1787 1788 1789
    }else if(src_x<=-block_w){
        src+= (1-block_w-src_x);
        src_x=1-block_w;
1790 1791
    }

M
Michael Niedermayer 已提交
1792 1793 1794 1795
    start_y= FFMAX(0, -src_y);
    start_x= FFMAX(0, -src_x);
    end_y= FFMIN(block_h, h-src_y);
    end_x= FFMIN(block_w, w-src_x);
M
Michael Niedermayer 已提交
1796

1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831
    // copy existing part
    for(y=start_y; y<end_y; y++){
        for(x=start_x; x<end_x; x++){
            buf[x + y*linesize]= src[x + y*linesize];
        }
    }

    //top
    for(y=0; y<start_y; y++){
        for(x=start_x; x<end_x; x++){
            buf[x + y*linesize]= buf[x + start_y*linesize];
        }
    }

    //bottom
    for(y=end_y; y<block_h; y++){
        for(x=start_x; x<end_x; x++){
            buf[x + y*linesize]= buf[x + (end_y-1)*linesize];
        }
    }
                                    
    for(y=0; y<block_h; y++){
       //left
        for(x=0; x<start_x; x++){
            buf[x + y*linesize]= buf[start_x + y*linesize];
        }
       
       //right
        for(x=end_x; x<block_w; x++){
            buf[x + y*linesize]= buf[end_x - 1 + y*linesize];
        }
    }
}


F
Fabrice Bellard 已提交
1832 1833
/* apply one mpeg motion vector to the three components */
static inline void mpeg_motion(MpegEncContext *s,
1834
                               uint8_t *dest_y, uint8_t *dest_cb, uint8_t *dest_cr,
F
Fabrice Bellard 已提交
1835
                               int dest_offset,
1836
                               uint8_t **ref_picture, int src_offset,
M
Michael Niedermayer 已提交
1837
                               int field_based, op_pixels_func (*pix_op)[4],
F
Fabrice Bellard 已提交
1838 1839
                               int motion_x, int motion_y, int h)
{
1840
    uint8_t *ptr;
1841
    int dxy, offset, mx, my, src_x, src_y, height, v_edge_pos, linesize, uvlinesize;
1842
    int emu=0;
M
Michael Niedermayer 已提交
1843
#if 0    
M
Michael Niedermayer 已提交
1844 1845 1846 1847 1848
if(s->quarter_sample)
{
    motion_x>>=1;
    motion_y>>=1;
}
M
Michael Niedermayer 已提交
1849
#endif
F
Fabrice Bellard 已提交
1850 1851 1852 1853 1854 1855
    dxy = ((motion_y & 1) << 1) | (motion_x & 1);
    src_x = s->mb_x * 16 + (motion_x >> 1);
    src_y = s->mb_y * (16 >> field_based) + (motion_y >> 1);
                
    /* WARNING: do no forget half pels */
    height = s->height >> field_based;
1856
    v_edge_pos = s->v_edge_pos >> field_based;
F
Fabrice Bellard 已提交
1857 1858 1859 1860 1861 1862
    src_x = clip(src_x, -16, s->width);
    if (src_x == s->width)
        dxy &= ~1;
    src_y = clip(src_y, -16, height);
    if (src_y == height)
        dxy &= ~2;
M
Michael Niedermayer 已提交
1863 1864
    linesize   = s->current_picture.linesize[0] << field_based;
    uvlinesize = s->current_picture.linesize[1] << field_based;
F
Fabrice Bellard 已提交
1865 1866
    ptr = ref_picture[0] + (src_y * linesize) + (src_x) + src_offset;
    dest_y += dest_offset;
1867 1868

    if(s->flags&CODEC_FLAG_EMU_EDGE){
1869 1870
        if(src_x<0 || src_y<0 || src_x + (motion_x&1) + 16 > s->h_edge_pos
                              || src_y + (motion_y&1) + h  > v_edge_pos){
1871
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr - src_offset, s->linesize, 17, 17+field_based,  //FIXME linesize? and uv below
1872 1873
                             src_x, src_y<<field_based, s->h_edge_pos, s->v_edge_pos);
            ptr= s->edge_emu_buffer + src_offset;
1874 1875 1876
            emu=1;
        }
    }
M
Michael Niedermayer 已提交
1877
    pix_op[0][dxy](dest_y, ptr, linesize, h);
F
Fabrice Bellard 已提交
1878

M
Michael Niedermayer 已提交
1879 1880
    if(s->flags&CODEC_FLAG_GRAY) return;

F
Fabrice Bellard 已提交
1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904
    if (s->out_format == FMT_H263) {
        dxy = 0;
        if ((motion_x & 3) != 0)
            dxy |= 1;
        if ((motion_y & 3) != 0)
            dxy |= 2;
        mx = motion_x >> 2;
        my = motion_y >> 2;
    } else {
        mx = motion_x / 2;
        my = motion_y / 2;
        dxy = ((my & 1) << 1) | (mx & 1);
        mx >>= 1;
        my >>= 1;
    }
    
    src_x = s->mb_x * 8 + mx;
    src_y = s->mb_y * (8 >> field_based) + my;
    src_x = clip(src_x, -8, s->width >> 1);
    if (src_x == (s->width >> 1))
        dxy &= ~1;
    src_y = clip(src_y, -8, height >> 1);
    if (src_y == (height >> 1))
        dxy &= ~2;
1905
    offset = (src_y * uvlinesize) + src_x + (src_offset >> 1);
F
Fabrice Bellard 已提交
1906
    ptr = ref_picture[1] + offset;
1907
    if(emu){
1908
        ff_emulated_edge_mc(s->edge_emu_buffer, ptr - (src_offset >> 1), s->uvlinesize, 9, 9+field_based, 
1909 1910
                         src_x, src_y<<field_based, s->h_edge_pos>>1, s->v_edge_pos>>1);
        ptr= s->edge_emu_buffer + (src_offset >> 1);
1911
    }
M
Michael Niedermayer 已提交
1912
    pix_op[1][dxy](dest_cb + (dest_offset >> 1), ptr, uvlinesize, h >> 1);
1913

F
Fabrice Bellard 已提交
1914
    ptr = ref_picture[2] + offset;
1915
    if(emu){
1916
        ff_emulated_edge_mc(s->edge_emu_buffer, ptr - (src_offset >> 1), s->uvlinesize, 9, 9+field_based, 
1917 1918
                         src_x, src_y<<field_based, s->h_edge_pos>>1, s->v_edge_pos>>1);
        ptr= s->edge_emu_buffer + (src_offset >> 1);
1919
    }
M
Michael Niedermayer 已提交
1920
    pix_op[1][dxy](dest_cr + (dest_offset >> 1), ptr, uvlinesize, h >> 1);
F
Fabrice Bellard 已提交
1921 1922
}

M
Michael Niedermayer 已提交
1923
static inline void qpel_motion(MpegEncContext *s,
1924
                               uint8_t *dest_y, uint8_t *dest_cb, uint8_t *dest_cr,
M
Michael Niedermayer 已提交
1925
                               int dest_offset,
1926
                               uint8_t **ref_picture, int src_offset,
M
Michael Niedermayer 已提交
1927 1928
                               int field_based, op_pixels_func (*pix_op)[4],
                               qpel_mc_func (*qpix_op)[16],
M
Michael Niedermayer 已提交
1929 1930
                               int motion_x, int motion_y, int h)
{
1931
    uint8_t *ptr;
1932
    int dxy, offset, mx, my, src_x, src_y, height, v_edge_pos, linesize, uvlinesize;
M
Michael Niedermayer 已提交
1933
    int emu=0;
M
Michael Niedermayer 已提交
1934 1935 1936 1937 1938 1939

    dxy = ((motion_y & 3) << 2) | (motion_x & 3);
    src_x = s->mb_x * 16 + (motion_x >> 2);
    src_y = s->mb_y * (16 >> field_based) + (motion_y >> 2);

    height = s->height >> field_based;
1940
    v_edge_pos = s->v_edge_pos >> field_based;
M
Michael Niedermayer 已提交
1941 1942 1943 1944 1945 1946 1947
    src_x = clip(src_x, -16, s->width);
    if (src_x == s->width)
        dxy &= ~3;
    src_y = clip(src_y, -16, height);
    if (src_y == height)
        dxy &= ~12;
    linesize = s->linesize << field_based;
1948
    uvlinesize = s->uvlinesize << field_based;
M
Michael Niedermayer 已提交
1949 1950 1951
    ptr = ref_picture[0] + (src_y * linesize) + src_x + src_offset;
    dest_y += dest_offset;
//printf("%d %d %d\n", src_x, src_y, dxy);
M
Michael Niedermayer 已提交
1952 1953
    
    if(s->flags&CODEC_FLAG_EMU_EDGE){
1954 1955
        if(src_x<0 || src_y<0 || src_x + (motion_x&3) + 16 > s->h_edge_pos
                              || src_y + (motion_y&3) + h  > v_edge_pos){
1956
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr - src_offset, s->linesize, 17, 17+field_based, 
1957 1958
                             src_x, src_y<<field_based, s->h_edge_pos, s->v_edge_pos);
            ptr= s->edge_emu_buffer + src_offset;
M
Michael Niedermayer 已提交
1959 1960 1961
            emu=1;
        }
    }
1962 1963 1964 1965 1966 1967 1968 1969
    if(!field_based)
        qpix_op[0][dxy](dest_y, ptr, linesize);
    else{
        //damn interlaced mode
        //FIXME boundary mirroring is not exactly correct here
        qpix_op[1][dxy](dest_y  , ptr  , linesize);
        qpix_op[1][dxy](dest_y+8, ptr+8, linesize);
    }
M
Michael Niedermayer 已提交
1970

M
Michael Niedermayer 已提交
1971 1972
    if(s->flags&CODEC_FLAG_GRAY) return;

1973 1974 1975
    if(field_based){
        mx= motion_x/2;
        my= motion_y>>1;
M
Michael Niedermayer 已提交
1976 1977 1978 1979
    }else if(s->workaround_bugs&FF_BUG_QPEL_CHROMA2){
        static const int rtab[8]= {0,0,1,1,0,0,0,1};
        mx= (motion_x>>1) + rtab[motion_x&7];
        my= (motion_y>>1) + rtab[motion_y&7];
M
Michael Niedermayer 已提交
1980
    }else if(s->workaround_bugs&FF_BUG_QPEL_CHROMA){
1981 1982 1983 1984 1985 1986 1987 1988
        mx= (motion_x>>1)|(motion_x&1);
        my= (motion_y>>1)|(motion_y&1);
    }else{
        mx= motion_x/2;
        my= motion_y/2;
    }
    mx= (mx>>1)|(mx&1);
    my= (my>>1)|(my&1);
M
Michael Niedermayer 已提交
1989

1990 1991 1992
    dxy= (mx&1) | ((my&1)<<1);
    mx>>=1;
    my>>=1;
M
Michael Niedermayer 已提交
1993 1994 1995 1996 1997 1998 1999 2000 2001 2002

    src_x = s->mb_x * 8 + mx;
    src_y = s->mb_y * (8 >> field_based) + my;
    src_x = clip(src_x, -8, s->width >> 1);
    if (src_x == (s->width >> 1))
        dxy &= ~1;
    src_y = clip(src_y, -8, height >> 1);
    if (src_y == (height >> 1))
        dxy &= ~2;

2003
    offset = (src_y * uvlinesize) + src_x + (src_offset >> 1);
M
Michael Niedermayer 已提交
2004
    ptr = ref_picture[1] + offset;
M
Michael Niedermayer 已提交
2005
    if(emu){
2006
        ff_emulated_edge_mc(s->edge_emu_buffer, ptr - (src_offset >> 1), s->uvlinesize, 9, 9 + field_based, 
2007 2008
                         src_x, src_y<<field_based, s->h_edge_pos>>1, s->v_edge_pos>>1);
        ptr= s->edge_emu_buffer + (src_offset >> 1);
M
Michael Niedermayer 已提交
2009
    }
2010
    pix_op[1][dxy](dest_cb + (dest_offset >> 1), ptr,  uvlinesize, h >> 1);
M
Michael Niedermayer 已提交
2011
    
M
Michael Niedermayer 已提交
2012
    ptr = ref_picture[2] + offset;
M
Michael Niedermayer 已提交
2013
    if(emu){
2014
        ff_emulated_edge_mc(s->edge_emu_buffer, ptr - (src_offset >> 1), s->uvlinesize, 9, 9 + field_based, 
2015 2016
                         src_x, src_y<<field_based, s->h_edge_pos>>1, s->v_edge_pos>>1);
        ptr= s->edge_emu_buffer + (src_offset >> 1);
M
Michael Niedermayer 已提交
2017
    }
2018
    pix_op[1][dxy](dest_cr + (dest_offset >> 1), ptr,  uvlinesize, h >> 1);
M
Michael Niedermayer 已提交
2019 2020
}

2021 2022 2023 2024 2025 2026 2027 2028
inline int ff_h263_round_chroma(int x){
    if (x >= 0)
        return  (h263_chroma_roundtab[x & 0xf] + ((x >> 3) & ~1));
    else {
        x = -x;
        return -(h263_chroma_roundtab[x & 0xf] + ((x >> 3) & ~1));
    }
}
M
Michael Niedermayer 已提交
2029

M
doxy  
Michael Niedermayer 已提交
2030 2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041
/**
 * motion compesation of a single macroblock
 * @param s context
 * @param dest_y luma destination pointer
 * @param dest_cb chroma cb/u destination pointer
 * @param dest_cr chroma cr/v destination pointer
 * @param dir direction (0->forward, 1->backward)
 * @param ref_picture array[3] of pointers to the 3 planes of the reference picture
 * @param pic_op halfpel motion compensation function (average or put normally)
 * @param pic_op qpel motion compensation function (average or put normally)
 * the motion vectors are taken from s->mv and the MV type from s->mv_type
 */
F
Fabrice Bellard 已提交
2042
static inline void MPV_motion(MpegEncContext *s, 
2043 2044
                              uint8_t *dest_y, uint8_t *dest_cb, uint8_t *dest_cr,
                              int dir, uint8_t **ref_picture, 
M
Michael Niedermayer 已提交
2045
                              op_pixels_func (*pix_op)[4], qpel_mc_func (*qpix_op)[16])
F
Fabrice Bellard 已提交
2046 2047 2048
{
    int dxy, offset, mx, my, src_x, src_y, motion_x, motion_y;
    int mb_x, mb_y, i;
2049
    uint8_t *ptr, *dest;
M
Michael Niedermayer 已提交
2050
    int emu=0;
F
Fabrice Bellard 已提交
2051 2052 2053 2054 2055 2056

    mb_x = s->mb_x;
    mb_y = s->mb_y;

    switch(s->mv_type) {
    case MV_TYPE_16X16:
M
Michael Niedermayer 已提交
2057
#ifdef CONFIG_RISKY
M
Michael Niedermayer 已提交
2058
        if(s->mcsel){
2059 2060 2061 2062 2063 2064 2065
            if(s->real_sprite_warping_points==1){
                gmc1_motion(s, dest_y, dest_cb, dest_cr, 0,
                            ref_picture, 0);
            }else{
                gmc_motion(s, dest_y, dest_cb, dest_cr, 0,
                            ref_picture, 0);
            }
M
Michael Niedermayer 已提交
2066
        }else if(s->quarter_sample){
M
Michael Niedermayer 已提交
2067 2068 2069 2070
            qpel_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref_picture, 0,
                        0, pix_op, qpix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 16);
M
Michael Niedermayer 已提交
2071 2072 2073 2074
        }else if(s->mspel){
            ff_mspel_motion(s, dest_y, dest_cb, dest_cr,
                        ref_picture, pix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 16);
M
Michael Niedermayer 已提交
2075 2076 2077
        }else
#endif
        {
M
Michael Niedermayer 已提交
2078 2079 2080 2081 2082
            mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref_picture, 0,
                        0, pix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 16);
        }           
F
Fabrice Bellard 已提交
2083 2084
        break;
    case MV_TYPE_8X8:
M
Michael Niedermayer 已提交
2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107
        mx = 0;
        my = 0;
        if(s->quarter_sample){
            for(i=0;i<4;i++) {
                motion_x = s->mv[dir][i][0];
                motion_y = s->mv[dir][i][1];

                dxy = ((motion_y & 3) << 2) | (motion_x & 3);
                src_x = mb_x * 16 + (motion_x >> 2) + (i & 1) * 8;
                src_y = mb_y * 16 + (motion_y >> 2) + (i >>1) * 8;
                    
                /* WARNING: do no forget half pels */
                src_x = clip(src_x, -16, s->width);
                if (src_x == s->width)
                    dxy &= ~3;
                src_y = clip(src_y, -16, s->height);
                if (src_y == s->height)
                    dxy &= ~12;
                    
                ptr = ref_picture[0] + (src_y * s->linesize) + (src_x);
                if(s->flags&CODEC_FLAG_EMU_EDGE){
                    if(src_x<0 || src_y<0 || src_x + (motion_x&3) + 8 > s->h_edge_pos
                                          || src_y + (motion_y&3) + 8 > s->v_edge_pos){
2108
                        ff_emulated_edge_mc(s->edge_emu_buffer, ptr, s->linesize, 9, 9, src_x, src_y, s->h_edge_pos, s->v_edge_pos);
M
Michael Niedermayer 已提交
2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121
                        ptr= s->edge_emu_buffer;
                    }
                }
                dest = dest_y + ((i & 1) * 8) + (i >> 1) * 8 * s->linesize;
                qpix_op[1][dxy](dest, ptr, s->linesize);

                mx += s->mv[dir][i][0]/2;
                my += s->mv[dir][i][1]/2;
            }
        }else{
            for(i=0;i<4;i++) {
                motion_x = s->mv[dir][i][0];
                motion_y = s->mv[dir][i][1];
F
Fabrice Bellard 已提交
2122

M
Michael Niedermayer 已提交
2123 2124 2125
                dxy = ((motion_y & 1) << 1) | (motion_x & 1);
                src_x = mb_x * 16 + (motion_x >> 1) + (i & 1) * 8;
                src_y = mb_y * 16 + (motion_y >> 1) + (i >>1) * 8;
F
Fabrice Bellard 已提交
2126
                    
M
Michael Niedermayer 已提交
2127 2128 2129 2130 2131 2132 2133
                /* WARNING: do no forget half pels */
                src_x = clip(src_x, -16, s->width);
                if (src_x == s->width)
                    dxy &= ~1;
                src_y = clip(src_y, -16, s->height);
                if (src_y == s->height)
                    dxy &= ~2;
F
Fabrice Bellard 已提交
2134
                    
M
Michael Niedermayer 已提交
2135 2136 2137 2138
                ptr = ref_picture[0] + (src_y * s->linesize) + (src_x);
                if(s->flags&CODEC_FLAG_EMU_EDGE){
                    if(src_x<0 || src_y<0 || src_x + (motion_x&1) + 8 > s->h_edge_pos
                                          || src_y + (motion_y&1) + 8 > s->v_edge_pos){
2139
                        ff_emulated_edge_mc(s->edge_emu_buffer, ptr, s->linesize, 9, 9, src_x, src_y, s->h_edge_pos, s->v_edge_pos);
M
Michael Niedermayer 已提交
2140 2141
                        ptr= s->edge_emu_buffer;
                    }
M
Michael Niedermayer 已提交
2142
                }
M
Michael Niedermayer 已提交
2143 2144 2145 2146 2147
                dest = dest_y + ((i & 1) * 8) + (i >> 1) * 8 * s->linesize;
                pix_op[1][dxy](dest, ptr, s->linesize, 8);

                mx += s->mv[dir][i][0];
                my += s->mv[dir][i][1];
M
Michael Niedermayer 已提交
2148
            }
F
Fabrice Bellard 已提交
2149
        }
M
Michael Niedermayer 已提交
2150

M
Michael Niedermayer 已提交
2151
        if(s->flags&CODEC_FLAG_GRAY) break;
F
Fabrice Bellard 已提交
2152 2153
        /* In case of 8X8, we construct a single chroma motion vector
           with a special rounding */
2154 2155
        mx= ff_h263_round_chroma(mx);
        my= ff_h263_round_chroma(my);
F
Fabrice Bellard 已提交
2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168
        dxy = ((my & 1) << 1) | (mx & 1);
        mx >>= 1;
        my >>= 1;

        src_x = mb_x * 8 + mx;
        src_y = mb_y * 8 + my;
        src_x = clip(src_x, -8, s->width/2);
        if (src_x == s->width/2)
            dxy &= ~1;
        src_y = clip(src_y, -8, s->height/2);
        if (src_y == s->height/2)
            dxy &= ~2;
        
M
Michael Niedermayer 已提交
2169
        offset = (src_y * (s->uvlinesize)) + src_x;
F
Fabrice Bellard 已提交
2170
        ptr = ref_picture[1] + offset;
M
Michael Niedermayer 已提交
2171
        if(s->flags&CODEC_FLAG_EMU_EDGE){
2172 2173
                if(src_x<0 || src_y<0 || src_x + (dxy &1) + 8 > s->h_edge_pos>>1
                                      || src_y + (dxy>>1) + 8 > s->v_edge_pos>>1){
2174
                    ff_emulated_edge_mc(s->edge_emu_buffer, ptr, s->uvlinesize, 9, 9, src_x, src_y, s->h_edge_pos>>1, s->v_edge_pos>>1);
M
Michael Niedermayer 已提交
2175 2176 2177 2178
                    ptr= s->edge_emu_buffer;
                    emu=1;
                }
            }
M
Michael Niedermayer 已提交
2179
        pix_op[1][dxy](dest_cb, ptr, s->uvlinesize, 8);
M
Michael Niedermayer 已提交
2180

F
Fabrice Bellard 已提交
2181
        ptr = ref_picture[2] + offset;
M
Michael Niedermayer 已提交
2182
        if(emu){
2183
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr, s->uvlinesize, 9, 9, src_x, src_y, s->h_edge_pos>>1, s->v_edge_pos>>1);
M
Michael Niedermayer 已提交
2184 2185
            ptr= s->edge_emu_buffer;
        }
M
Michael Niedermayer 已提交
2186
        pix_op[1][dxy](dest_cr, ptr, s->uvlinesize, 8);
F
Fabrice Bellard 已提交
2187 2188 2189
        break;
    case MV_TYPE_FIELD:
        if (s->picture_structure == PICT_FRAME) {
2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209 2210 2211 2212
            if(s->quarter_sample){
                /* top field */
                qpel_motion(s, dest_y, dest_cb, dest_cr, 0,
                            ref_picture, s->field_select[dir][0] ? s->linesize : 0,
                            1, pix_op, qpix_op,
                            s->mv[dir][0][0], s->mv[dir][0][1], 8);
                /* bottom field */
                qpel_motion(s, dest_y, dest_cb, dest_cr, s->linesize,
                            ref_picture, s->field_select[dir][1] ? s->linesize : 0,
                            1, pix_op, qpix_op,
                            s->mv[dir][1][0], s->mv[dir][1][1], 8);
            }else{
                /* top field */       
                mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                            ref_picture, s->field_select[dir][0] ? s->linesize : 0,
                            1, pix_op,
                            s->mv[dir][0][0], s->mv[dir][0][1], 8);
                /* bottom field */
                mpeg_motion(s, dest_y, dest_cb, dest_cr, s->linesize,
                            ref_picture, s->field_select[dir][1] ? s->linesize : 0,
                            1, pix_op,
                            s->mv[dir][1][0], s->mv[dir][1][1], 8);
            }
F
Fabrice Bellard 已提交
2213
        } else {
2214 2215
            int offset;
            if(s->picture_structure == s->field_select[dir][0] + 1 || s->pict_type == B_TYPE || s->first_field){
M
Michael Niedermayer 已提交
2216
                offset= s->field_select[dir][0] ? s->linesize : 0;
2217 2218
            }else{
                ref_picture= s->current_picture.data;
M
Michael Niedermayer 已提交
2219
                offset= s->field_select[dir][0] ? s->linesize : -s->linesize; 
2220
            } 
F
Fabrice Bellard 已提交
2221

2222 2223 2224 2225
            mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref_picture, offset,
                        0, pix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 16);
F
Fabrice Bellard 已提交
2226
        }
2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260
        break;
    case MV_TYPE_16X8:{
        int offset;
         uint8_t ** ref2picture;

            if(s->picture_structure == s->field_select[dir][0] + 1 || s->pict_type == B_TYPE || s->first_field){
                ref2picture= ref_picture;
                offset= s->field_select[dir][0] ? s->linesize : 0;
            }else{
                ref2picture= s->current_picture.data;
                offset= s->field_select[dir][0] ? s->linesize : -s->linesize; 
            } 

            mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref2picture, offset,
                        0, pix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 8);


            if(s->picture_structure == s->field_select[dir][1] + 1 || s->pict_type == B_TYPE || s->first_field){
                ref2picture= ref_picture;
                offset= s->field_select[dir][1] ? s->linesize : 0;
            }else{
                ref2picture= s->current_picture.data;
                offset= s->field_select[dir][1] ? s->linesize : -s->linesize; 
            } 
            // I know it is ugly but this is the only way to fool emu_edge without rewrite mpeg_motion
            mpeg_motion(s, dest_y+16*s->linesize, dest_cb+8*s->uvlinesize, dest_cr+8*s->uvlinesize,
                        0,
                        ref2picture, offset,
                        0, pix_op,
                        s->mv[dir][1][0], s->mv[dir][1][1]+16, 8);
        }
        
F
Fabrice Bellard 已提交
2261
        break;
2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326
    case MV_TYPE_DMV:
    {
    op_pixels_func (*dmv_pix_op)[4];
    int offset;

        dmv_pix_op = s->dsp.put_pixels_tab;

        if(s->picture_structure == PICT_FRAME){
            //put top field from top field
            mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref_picture, 0,
                        1, dmv_pix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 8);
            //put bottom field from bottom field
            mpeg_motion(s, dest_y, dest_cb, dest_cr, s->linesize,
                        ref_picture, s->linesize,
                        1, dmv_pix_op,
                        s->mv[dir][0][0], s->mv[dir][0][1], 8);

            dmv_pix_op = s->dsp.avg_pixels_tab; 
        
            //avg top field from bottom field
            mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref_picture, s->linesize,
                        1, dmv_pix_op,
                        s->mv[dir][2][0], s->mv[dir][2][1], 8);
            //avg bottom field from top field
            mpeg_motion(s, dest_y, dest_cb, dest_cr, s->linesize,
                        ref_picture, 0,
                        1, dmv_pix_op,
                        s->mv[dir][3][0], s->mv[dir][3][1], 8);

        }else{
            offset=(s->picture_structure == PICT_BOTTOM_FIELD)? 
                         s->linesize : 0;

            //put field from the same parity
            //same parity is never in the same frame
            mpeg_motion(s, dest_y, dest_cb, dest_cr, 0,
                        ref_picture,offset,
                        0,dmv_pix_op,
                        s->mv[dir][0][0],s->mv[dir][0][1],16);

            // after put we make avg of the same block
            dmv_pix_op=s->dsp.avg_pixels_tab; 

            //opposite parity is always in the same frame if this is second field
            if(!s->first_field){
                ref_picture = s->current_picture.data;    
                //top field is one linesize from frame beginig
                offset=(s->picture_structure == PICT_BOTTOM_FIELD)? 
                        -s->linesize : s->linesize;
            }else 
                offset=(s->picture_structure == PICT_BOTTOM_FIELD)? 
                        0 : s->linesize;

            //avg field from the opposite parity
            mpeg_motion(s, dest_y, dest_cb, dest_cr,0,
                        ref_picture, offset,
                        0,dmv_pix_op,
                        s->mv[dir][2][0],s->mv[dir][2][1],16);
        }
    }
    break;

F
Fabrice Bellard 已提交
2327 2328 2329 2330 2331 2332
    }
}


/* put block[] to dest[] */
static inline void put_dct(MpegEncContext *s, 
2333
                           DCTELEM *block, int i, uint8_t *dest, int line_size)
F
Fabrice Bellard 已提交
2334
{
2335
    s->dct_unquantize(s, block, i, s->qscale);
2336
    s->dsp.idct_put (dest, line_size, block);
F
Fabrice Bellard 已提交
2337 2338 2339 2340
}

/* add block[] to dest[] */
static inline void add_dct(MpegEncContext *s, 
2341
                           DCTELEM *block, int i, uint8_t *dest, int line_size)
F
Fabrice Bellard 已提交
2342
{
M
Michael Niedermayer 已提交
2343
    if (s->block_last_index[i] >= 0) {
2344
        s->dsp.idct_add (dest, line_size, block);
M
Michael Niedermayer 已提交
2345 2346
    }
}
2347

M
Michael Niedermayer 已提交
2348
static inline void add_dequant_dct(MpegEncContext *s, 
2349
                           DCTELEM *block, int i, uint8_t *dest, int line_size)
M
Michael Niedermayer 已提交
2350
{
F
Fabrice Bellard 已提交
2351
    if (s->block_last_index[i] >= 0) {
M
Michael Niedermayer 已提交
2352
        s->dct_unquantize(s, block, i, s->qscale);
2353

2354
        s->dsp.idct_add (dest, line_size, block);
F
Fabrice Bellard 已提交
2355 2356 2357
    }
}

2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370
/**
 * cleans dc, ac, coded_block for the current non intra MB
 */
void ff_clean_intra_table_entries(MpegEncContext *s)
{
    int wrap = s->block_wrap[0];
    int xy = s->block_index[0];
    
    s->dc_val[0][xy           ] = 
    s->dc_val[0][xy + 1       ] = 
    s->dc_val[0][xy     + wrap] =
    s->dc_val[0][xy + 1 + wrap] = 1024;
    /* ac pred */
2371 2372
    memset(s->ac_val[0][xy       ], 0, 32 * sizeof(int16_t));
    memset(s->ac_val[0][xy + wrap], 0, 32 * sizeof(int16_t));
2373 2374 2375 2376 2377 2378 2379 2380 2381 2382 2383 2384
    if (s->msmpeg4_version>=3) {
        s->coded_block[xy           ] =
        s->coded_block[xy + 1       ] =
        s->coded_block[xy     + wrap] =
        s->coded_block[xy + 1 + wrap] = 0;
    }
    /* chroma */
    wrap = s->block_wrap[4];
    xy = s->mb_x + 1 + (s->mb_y + 1) * wrap;
    s->dc_val[1][xy] =
    s->dc_val[2][xy] = 1024;
    /* ac pred */
2385 2386
    memset(s->ac_val[1][xy], 0, 16 * sizeof(int16_t));
    memset(s->ac_val[2][xy], 0, 16 * sizeof(int16_t));
2387
    
2388
    s->mbintra_table[s->mb_x + s->mb_y*s->mb_stride]= 0;
2389 2390
}

F
Fabrice Bellard 已提交
2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401 2402
/* generic function called after a macroblock has been parsed by the
   decoder or after it has been encoded by the encoder.

   Important variables used:
   s->mb_intra : true if intra macroblock
   s->mv_dir   : motion vector direction
   s->mv_type  : motion vector type
   s->mv       : motion vector
   s->interlaced_dct : true if interlaced dct used (mpeg2)
 */
void MPV_decode_mb(MpegEncContext *s, DCTELEM block[6][64])
{
2403
    int mb_x, mb_y;
2404
    const int mb_xy = s->mb_y * s->mb_stride + s->mb_x;
I
Ivan Kalvachev 已提交
2405 2406 2407 2408 2409 2410
#ifdef HAVE_XVMC
    if(s->avctx->xvmc_acceleration){
        XVMC_decode_mb(s,block);
        return;
    }
#endif
F
Fabrice Bellard 已提交
2411 2412 2413 2414

    mb_x = s->mb_x;
    mb_y = s->mb_y;

M
cleanup  
Michael Niedermayer 已提交
2415
    s->current_picture.qscale_table[mb_xy]= s->qscale;
2416

F
Fabrice Bellard 已提交
2417 2418
    /* update DC predictors for P macroblocks */
    if (!s->mb_intra) {
2419
        if (s->h263_pred || s->h263_aic) {
M
Michael Niedermayer 已提交
2420
            if(s->mbintra_table[mb_xy])
2421
                ff_clean_intra_table_entries(s);
F
Fabrice Bellard 已提交
2422
        } else {
2423 2424
            s->last_dc[0] =
            s->last_dc[1] =
F
Fabrice Bellard 已提交
2425 2426 2427
            s->last_dc[2] = 128 << s->intra_dc_precision;
        }
    }
2428
    else if (s->h263_pred || s->h263_aic)
M
Michael Niedermayer 已提交
2429
        s->mbintra_table[mb_xy]=1;
2430

2431
    if ((s->flags&CODEC_FLAG_PSNR) || !(s->encoding && (s->intra_only || s->pict_type==B_TYPE))) { //FIXME precalc
2432
        uint8_t *dest_y, *dest_cb, *dest_cr;
M
Michael Niedermayer 已提交
2433
        int dct_linesize, dct_offset;
M
Michael Niedermayer 已提交
2434 2435
        op_pixels_func (*op_pix)[4];
        qpel_mc_func (*op_qpix)[16];
M
Michael Niedermayer 已提交
2436 2437
        const int linesize= s->current_picture.linesize[0]; //not s->linesize as this woulnd be wrong for field pics
        const int uvlinesize= s->current_picture.linesize[1];
2438

M
cleanup  
Michael Niedermayer 已提交
2439 2440 2441
        /* avoid copy if macroblock skipped in last frame too */
        /* skip only during decoding as we might trash the buffers during encoding a bit */
        if(!s->encoding){
2442
            uint8_t *mbskip_ptr = &s->mbskip_table[mb_xy];
M
cleanup  
Michael Niedermayer 已提交
2443
            const int age= s->current_picture.age;
M
Michael Niedermayer 已提交
2444

M
cleanup  
Michael Niedermayer 已提交
2445 2446 2447 2448 2449 2450
            assert(age);

            if (s->mb_skiped) {
                s->mb_skiped= 0;
                assert(s->pict_type!=I_TYPE);
 
M
Michael Niedermayer 已提交
2451 2452 2453
                (*mbskip_ptr) ++; /* indicate that this time we skiped it */
                if(*mbskip_ptr >99) *mbskip_ptr= 99;

M
cleanup  
Michael Niedermayer 已提交
2454
                /* if previous was skipped too, then nothing to do !  */
2455 2456
                if (*mbskip_ptr >= age && s->current_picture.reference){
                    return;
M
cleanup  
Michael Niedermayer 已提交
2457
                }
2458 2459 2460 2461
            } else if(!s->current_picture.reference){
                (*mbskip_ptr) ++; /* increase counter so the age can be compared cleanly */
                if(*mbskip_ptr >99) *mbskip_ptr= 99;
            } else{
2462 2463
                *mbskip_ptr = 0; /* not skipped */
            }
M
Michael Niedermayer 已提交
2464
        }
F
Fabrice Bellard 已提交
2465 2466

        if (s->interlaced_dct) {
M
Michael Niedermayer 已提交
2467 2468
            dct_linesize = linesize * 2;
            dct_offset = linesize;
F
Fabrice Bellard 已提交
2469
        } else {
M
Michael Niedermayer 已提交
2470 2471
            dct_linesize = linesize;
            dct_offset = linesize * 8;
F
Fabrice Bellard 已提交
2472
        }
2473 2474 2475 2476
        
        dest_y=  s->dest[0];
        dest_cb= s->dest[1];
        dest_cr= s->dest[2];
F
Fabrice Bellard 已提交
2477 2478 2479

        if (!s->mb_intra) {
            /* motion handling */
2480
            /* decoding or more than one mb_type (MC was allready done otherwise) */
2481
            if(!s->encoding){
2482
                if ((!s->no_rounding) || s->pict_type==B_TYPE){                
2483 2484
		    op_pix = s->dsp.put_pixels_tab;
                    op_qpix= s->dsp.put_qpel_pixels_tab;
2485
                }else{
2486 2487
                    op_pix = s->dsp.put_no_rnd_pixels_tab;
                    op_qpix= s->dsp.put_no_rnd_qpel_pixels_tab;
2488
                }
F
Fabrice Bellard 已提交
2489

2490
                if (s->mv_dir & MV_DIR_FORWARD) {
M
cleanup  
Michael Niedermayer 已提交
2491
                    MPV_motion(s, dest_y, dest_cb, dest_cr, 0, s->last_picture.data, op_pix, op_qpix);
2492 2493
		    op_pix = s->dsp.avg_pixels_tab;
                    op_qpix= s->dsp.avg_qpel_pixels_tab;
2494 2495
                }
                if (s->mv_dir & MV_DIR_BACKWARD) {
M
cleanup  
Michael Niedermayer 已提交
2496
                    MPV_motion(s, dest_y, dest_cb, dest_cr, 1, s->next_picture.data, op_pix, op_qpix);
2497
                }
F
Fabrice Bellard 已提交
2498 2499
            }

M
Michael Niedermayer 已提交
2500
            /* skip dequant / idct if we are really late ;) */
2501
            if(s->hurry_up>1) return;
M
Michael Niedermayer 已提交
2502

F
Fabrice Bellard 已提交
2503
            /* add dct residue */
2504 2505
            if(s->encoding || !(   s->mpeg2 || s->h263_msmpeg4 || s->codec_id==CODEC_ID_MPEG1VIDEO 
                                || (s->codec_id==CODEC_ID_MPEG4 && !s->mpeg_quant))){
M
Michael Niedermayer 已提交
2506 2507 2508 2509 2510
                add_dequant_dct(s, block[0], 0, dest_y, dct_linesize);
                add_dequant_dct(s, block[1], 1, dest_y + 8, dct_linesize);
                add_dequant_dct(s, block[2], 2, dest_y + dct_offset, dct_linesize);
                add_dequant_dct(s, block[3], 3, dest_y + dct_offset + 8, dct_linesize);

M
Michael Niedermayer 已提交
2511
                if(!(s->flags&CODEC_FLAG_GRAY)){
M
Michael Niedermayer 已提交
2512 2513
                    add_dequant_dct(s, block[4], 4, dest_cb, uvlinesize);
                    add_dequant_dct(s, block[5], 5, dest_cr, uvlinesize);
M
Michael Niedermayer 已提交
2514
                }
M
Michael Niedermayer 已提交
2515
            } else if(s->codec_id != CODEC_ID_WMV2){
M
Michael Niedermayer 已提交
2516 2517 2518 2519
                add_dct(s, block[0], 0, dest_y, dct_linesize);
                add_dct(s, block[1], 1, dest_y + 8, dct_linesize);
                add_dct(s, block[2], 2, dest_y + dct_offset, dct_linesize);
                add_dct(s, block[3], 3, dest_y + dct_offset + 8, dct_linesize);
F
Fabrice Bellard 已提交
2520

M
Michael Niedermayer 已提交
2521
                if(!(s->flags&CODEC_FLAG_GRAY)){
M
Michael Niedermayer 已提交
2522 2523
                    add_dct(s, block[4], 4, dest_cb, uvlinesize);
                    add_dct(s, block[5], 5, dest_cr, uvlinesize);
M
Michael Niedermayer 已提交
2524
                }
M
Michael Niedermayer 已提交
2525 2526 2527
            } 
#ifdef CONFIG_RISKY
            else{
M
Michael Niedermayer 已提交
2528
                ff_wmv2_add_mb(s, block, dest_y, dest_cb, dest_cr);
M
Michael Niedermayer 已提交
2529
            }
M
Michael Niedermayer 已提交
2530
#endif
F
Fabrice Bellard 已提交
2531 2532
        } else {
            /* dct only in intra block */
2533 2534 2535 2536 2537 2538 2539
            if(s->encoding || !(s->mpeg2 || s->codec_id==CODEC_ID_MPEG1VIDEO)){
                put_dct(s, block[0], 0, dest_y, dct_linesize);
                put_dct(s, block[1], 1, dest_y + 8, dct_linesize);
                put_dct(s, block[2], 2, dest_y + dct_offset, dct_linesize);
                put_dct(s, block[3], 3, dest_y + dct_offset + 8, dct_linesize);

                if(!(s->flags&CODEC_FLAG_GRAY)){
M
Michael Niedermayer 已提交
2540 2541
                    put_dct(s, block[4], 4, dest_cb, uvlinesize);
                    put_dct(s, block[5], 5, dest_cr, uvlinesize);
2542 2543
                }
            }else{
2544 2545 2546 2547
                s->dsp.idct_put(dest_y                 , dct_linesize, block[0]);
                s->dsp.idct_put(dest_y              + 8, dct_linesize, block[1]);
                s->dsp.idct_put(dest_y + dct_offset    , dct_linesize, block[2]);
                s->dsp.idct_put(dest_y + dct_offset + 8, dct_linesize, block[3]);
2548 2549

                if(!(s->flags&CODEC_FLAG_GRAY)){
M
Michael Niedermayer 已提交
2550 2551
                    s->dsp.idct_put(dest_cb, uvlinesize, block[4]);
                    s->dsp.idct_put(dest_cr, uvlinesize, block[5]);
2552
                }
M
Michael Niedermayer 已提交
2553
            }
F
Fabrice Bellard 已提交
2554 2555 2556 2557
        }
    }
}

2558 2559
#ifdef CONFIG_ENCODERS

2560
static inline void dct_single_coeff_elimination(MpegEncContext *s, int n, int threshold)
2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575
{
    static const char tab[64]=
        {3,2,2,1,1,1,1,1,
         1,1,1,1,1,1,1,1,
         1,1,1,1,1,1,1,1,
         0,0,0,0,0,0,0,0,
         0,0,0,0,0,0,0,0,
         0,0,0,0,0,0,0,0,
         0,0,0,0,0,0,0,0,
         0,0,0,0,0,0,0,0};
    int score=0;
    int run=0;
    int i;
    DCTELEM *block= s->block[n];
    const int last_index= s->block_last_index[n];
2576
    int skip_dc;
2577

2578 2579 2580
    if(threshold<0){
        skip_dc=0;
        threshold= -threshold;
2581 2582
    }else
        skip_dc=1;
2583

2584 2585 2586 2587
    /* are all which we could set to zero are allready zero? */
    if(last_index<=skip_dc - 1) return;

    for(i=0; i<=last_index; i++){
2588
        const int j = s->intra_scantable.permutated[i];
2589 2590 2591 2592 2593 2594 2595 2596 2597 2598 2599 2600 2601
        const int level = ABS(block[j]);
        if(level==1){
            if(skip_dc && i==0) continue;
            score+= tab[run];
            run=0;
        }else if(level>1){
            return;
        }else{
            run++;
        }
    }
    if(score >= threshold) return;
    for(i=skip_dc; i<=last_index; i++){
2602
        const int j = s->intra_scantable.permutated[i];
2603 2604 2605 2606 2607 2608
        block[j]=0;
    }
    if(block[0]) s->block_last_index[n]= 0;
    else         s->block_last_index[n]= -1;
}

2609 2610 2611 2612 2613
static inline void clip_coeffs(MpegEncContext *s, DCTELEM *block, int last_index)
{
    int i;
    const int maxlevel= s->max_qcoeff;
    const int minlevel= s->min_qcoeff;
2614 2615 2616 2617 2618 2619 2620 2621
    
    if(s->mb_intra){
        i=1; //skip clipping of intra dc
    }else
        i=0;
    
    for(;i<=last_index; i++){
        const int j= s->intra_scantable.permutated[i];
2622 2623 2624 2625
        int level = block[j];
       
        if     (level>maxlevel) level=maxlevel;
        else if(level<minlevel) level=minlevel;
2626

M
cleanup  
Michael Niedermayer 已提交
2627
        block[j]= level;
2628 2629 2630 2631
    }
}

#if 0
2632
static int pix_vcmp16x8(uint8_t *s, int stride){ //FIXME move to dsputil & optimize
2633 2634 2635 2636 2637 2638 2639 2640 2641 2642 2643 2644 2645 2646
    int score=0;
    int x,y;
    
    for(y=0; y<7; y++){
        for(x=0; x<16; x+=4){
            score+= ABS(s[x  ] - s[x  +stride]) + ABS(s[x+1] - s[x+1+stride]) 
                   +ABS(s[x+2] - s[x+2+stride]) + ABS(s[x+3] - s[x+3+stride]);
        }
        s+= stride;
    }
    
    return score;
}

2647
static int pix_diff_vcmp16x8(uint8_t *s1, uint8_t*s2, int stride){ //FIXME move to dsputil & optimize
2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663
    int score=0;
    int x,y;
    
    for(y=0; y<7; y++){
        for(x=0; x<16; x++){
            score+= ABS(s1[x  ] - s2[x ] - s1[x  +stride] + s2[x +stride]);
        }
        s1+= stride;
        s2+= stride;
    }
    
    return score;
}
#else
#define SQ(a) ((a)*(a))

2664
static int pix_vcmp16x8(uint8_t *s, int stride){ //FIXME move to dsputil & optimize
2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678
    int score=0;
    int x,y;
    
    for(y=0; y<7; y++){
        for(x=0; x<16; x+=4){
            score+= SQ(s[x  ] - s[x  +stride]) + SQ(s[x+1] - s[x+1+stride]) 
                   +SQ(s[x+2] - s[x+2+stride]) + SQ(s[x+3] - s[x+3+stride]);
        }
        s+= stride;
    }
    
    return score;
}

2679
static int pix_diff_vcmp16x8(uint8_t *s1, uint8_t*s2, int stride){ //FIXME move to dsputil & optimize
2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694
    int score=0;
    int x,y;
    
    for(y=0; y<7; y++){
        for(x=0; x<16; x++){
            score+= SQ(s1[x  ] - s2[x ] - s1[x  +stride] + s2[x +stride]);
        }
        s1+= stride;
        s2+= stride;
    }
    
    return score;
}

#endif
2695

2696 2697
#endif //CONFIG_ENCODERS

2698 2699 2700 2701 2702
/**
 *
 * @param h is the normal height, this will be reduced automatically if needed for the last row
 */
void ff_draw_horiz_band(MpegEncContext *s, int y, int h){
M
Michael Niedermayer 已提交
2703
    if (s->avctx->draw_horiz_band) {
2704
        AVFrame *src;
2705
        uint8_t *src_ptr[3];
M
Michael Niedermayer 已提交
2706
        int offset[4];
2707 2708 2709 2710 2711 2712 2713
        
        if(s->picture_structure != PICT_FRAME){
            h <<= 1;
            y <<= 1;
            if(s->first_field  && !(s->avctx->slice_flags&SLICE_FLAG_ALLOW_FIELD)) return;
        }

2714
        h= FFMIN(h, s->height - y);
2715

2716 2717 2718 2719 2720 2721 2722
        if(s->pict_type==B_TYPE || s->low_delay || (s->avctx->slice_flags&SLICE_FLAG_CODED_ORDER)) 
            src= (AVFrame*)s->current_picture_ptr;
        else if(s->last_picture_ptr)
            src= (AVFrame*)s->last_picture_ptr;
        else
            return;
            
M
Michael Niedermayer 已提交
2723
        if(s->pict_type==B_TYPE && s->picture_structure == PICT_FRAME && s->out_format != FMT_H264){
M
Michael Niedermayer 已提交
2724 2725 2726 2727 2728 2729 2730 2731 2732
            offset[0]=
            offset[1]=
            offset[2]=
            offset[3]= 0;
        }else{
            offset[0]= y * s->linesize;;
            offset[1]= 
            offset[2]= (y>>1) * s->uvlinesize;;
            offset[3]= 0;
2733
        }
M
Michael Niedermayer 已提交
2734

M
cleanup  
Michael Niedermayer 已提交
2735 2736
        emms_c();

2737 2738
        s->avctx->draw_horiz_band(s->avctx, src, offset,
                                  y, s->picture_structure, h);
2739 2740 2741
    }
}

2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763
void ff_init_block_index(MpegEncContext *s){ //FIXME maybe rename
    const int linesize= s->current_picture.linesize[0]; //not s->linesize as this woulnd be wrong for field pics
    const int uvlinesize= s->current_picture.linesize[1];
        
    s->block_index[0]= s->block_wrap[0]*(s->mb_y*2 + 1) - 1 + s->mb_x*2;
    s->block_index[1]= s->block_wrap[0]*(s->mb_y*2 + 1)     + s->mb_x*2;
    s->block_index[2]= s->block_wrap[0]*(s->mb_y*2 + 2) - 1 + s->mb_x*2;
    s->block_index[3]= s->block_wrap[0]*(s->mb_y*2 + 2)     + s->mb_x*2;
    s->block_index[4]= s->block_wrap[4]*(s->mb_y + 1)                    + s->block_wrap[0]*(s->mb_height*2 + 2) + s->mb_x;
    s->block_index[5]= s->block_wrap[4]*(s->mb_y + 1 + s->mb_height + 2) + s->block_wrap[0]*(s->mb_height*2 + 2) + s->mb_x;
    
    if(s->pict_type==B_TYPE && s->avctx->draw_horiz_band && s->picture_structure==PICT_FRAME){
        s->dest[0] = s->current_picture.data[0] + s->mb_x * 16 - 16;
        s->dest[1] = s->current_picture.data[1] + s->mb_x * 8 - 8;
        s->dest[2] = s->current_picture.data[2] + s->mb_x * 8 - 8;
    }else{
        s->dest[0] = s->current_picture.data[0] + (s->mb_y * 16* linesize  ) + s->mb_x * 16 - 16;
        s->dest[1] = s->current_picture.data[1] + (s->mb_y * 8 * uvlinesize) + s->mb_x * 8 - 8;
        s->dest[2] = s->current_picture.data[2] + (s->mb_y * 8 * uvlinesize) + s->mb_x * 8 - 8;
    }    
}

2764 2765
#ifdef CONFIG_ENCODERS

2766
static void encode_mb(MpegEncContext *s, int motion_x, int motion_y)
F
Fabrice Bellard 已提交
2767
{
2768 2769 2770
    const int mb_x= s->mb_x;
    const int mb_y= s->mb_y;
    int i;
2771
    int skip_dct[6];
2772 2773
    int dct_offset   = s->linesize*8; //default for progressive frames
    
2774
    for(i=0; i<6; i++) skip_dct[i]=0;
2775 2776
    
    if(s->adaptive_quant){
2777
        s->dquant= s->current_picture.qscale_table[mb_x + mb_y*s->mb_stride] - s->qscale;
2778 2779

        if(s->out_format==FMT_H263){
2780 2781
            if     (s->dquant> 2) s->dquant= 2;
            else if(s->dquant<-2) s->dquant=-2;
2782 2783 2784
        }
            
        if(s->codec_id==CODEC_ID_MPEG4){        
2785 2786 2787
            if(!s->mb_intra){
                if(s->mv_dir&MV_DIRECT)
                    s->dquant=0;
M
10l  
Michael Niedermayer 已提交
2788 2789

                assert(s->dquant==0 || s->mv_type!=MV_TYPE_8X8);
2790 2791 2792 2793 2794 2795
            }
        }
        s->qscale+= s->dquant;
        s->y_dc_scale= s->y_dc_scale_table[ s->qscale ];
        s->c_dc_scale= s->c_dc_scale_table[ s->qscale ];
    }
2796

2797
    if (s->mb_intra) {
2798
        uint8_t *ptr;
2799
        int wrap_y;
2800
        int emu=0;
2801

2802
        wrap_y = s->linesize;
M
cleanup  
Michael Niedermayer 已提交
2803
        ptr = s->new_picture.data[0] + (mb_y * 16 * wrap_y) + mb_x * 16;
2804

2805
        if(mb_x*16+16 > s->width || mb_y*16+16 > s->height){
2806
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr, wrap_y, 16, 16, mb_x*16, mb_y*16, s->width, s->height);
2807 2808 2809
            ptr= s->edge_emu_buffer;
            emu=1;
        }
2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825
        
        if(s->flags&CODEC_FLAG_INTERLACED_DCT){
            int progressive_score, interlaced_score;
            
            progressive_score= pix_vcmp16x8(ptr, wrap_y  ) + pix_vcmp16x8(ptr + wrap_y*8, wrap_y );
            interlaced_score = pix_vcmp16x8(ptr, wrap_y*2) + pix_vcmp16x8(ptr + wrap_y  , wrap_y*2);
            
            if(progressive_score > interlaced_score + 100){
                s->interlaced_dct=1;
            
                dct_offset= wrap_y;
                wrap_y<<=1;
            }else
                s->interlaced_dct=0;
        }
        
2826 2827 2828 2829
	s->dsp.get_pixels(s->block[0], ptr                 , wrap_y);
        s->dsp.get_pixels(s->block[1], ptr              + 8, wrap_y);
        s->dsp.get_pixels(s->block[2], ptr + dct_offset    , wrap_y);
        s->dsp.get_pixels(s->block[3], ptr + dct_offset + 8, wrap_y);
2830

M
Michael Niedermayer 已提交
2831 2832 2833 2834
        if(s->flags&CODEC_FLAG_GRAY){
            skip_dct[4]= 1;
            skip_dct[5]= 1;
        }else{
2835
            int wrap_c = s->uvlinesize;
M
cleanup  
Michael Niedermayer 已提交
2836
            ptr = s->new_picture.data[1] + (mb_y * 8 * wrap_c) + mb_x * 8;
2837
            if(emu){
2838
                ff_emulated_edge_mc(s->edge_emu_buffer, ptr, wrap_c, 8, 8, mb_x*8, mb_y*8, s->width>>1, s->height>>1);
2839 2840
                ptr= s->edge_emu_buffer;
            }
2841
	    s->dsp.get_pixels(s->block[4], ptr, wrap_c);
2842

M
cleanup  
Michael Niedermayer 已提交
2843
            ptr = s->new_picture.data[2] + (mb_y * 8 * wrap_c) + mb_x * 8;
2844
            if(emu){
2845
                ff_emulated_edge_mc(s->edge_emu_buffer, ptr, wrap_c, 8, 8, mb_x*8, mb_y*8, s->width>>1, s->height>>1);
2846 2847
                ptr= s->edge_emu_buffer;
            }
2848
            s->dsp.get_pixels(s->block[5], ptr, wrap_c);
M
Michael Niedermayer 已提交
2849
        }
2850
    }else{
M
Michael Niedermayer 已提交
2851 2852
        op_pixels_func (*op_pix)[4];
        qpel_mc_func (*op_qpix)[16];
2853 2854
        uint8_t *dest_y, *dest_cb, *dest_cr;
        uint8_t *ptr_y, *ptr_cb, *ptr_cr;
2855
        int wrap_y, wrap_c;
2856
        int emu=0;
2857

2858 2859 2860
        dest_y  = s->dest[0];
        dest_cb = s->dest[1];
        dest_cr = s->dest[2];
2861
        wrap_y = s->linesize;
2862
        wrap_c = s->uvlinesize;
M
cleanup  
Michael Niedermayer 已提交
2863 2864 2865
        ptr_y  = s->new_picture.data[0] + (mb_y * 16 * wrap_y) + mb_x * 16;
        ptr_cb = s->new_picture.data[1] + (mb_y * 8 * wrap_c) + mb_x * 8;
        ptr_cr = s->new_picture.data[2] + (mb_y * 8 * wrap_c) + mb_x * 8;
2866

2867
        if ((!s->no_rounding) || s->pict_type==B_TYPE){
2868 2869
	    op_pix = s->dsp.put_pixels_tab;
            op_qpix= s->dsp.put_qpel_pixels_tab;
M
Michael Niedermayer 已提交
2870
        }else{
2871 2872
            op_pix = s->dsp.put_no_rnd_pixels_tab;
            op_qpix= s->dsp.put_no_rnd_qpel_pixels_tab;
2873 2874 2875
        }

        if (s->mv_dir & MV_DIR_FORWARD) {
M
cleanup  
Michael Niedermayer 已提交
2876
            MPV_motion(s, dest_y, dest_cb, dest_cr, 0, s->last_picture.data, op_pix, op_qpix);
2877 2878
            op_pix = s->dsp.avg_pixels_tab;
            op_qpix= s->dsp.avg_qpel_pixels_tab;
2879 2880
        }
        if (s->mv_dir & MV_DIR_BACKWARD) {
M
cleanup  
Michael Niedermayer 已提交
2881
            MPV_motion(s, dest_y, dest_cb, dest_cr, 1, s->next_picture.data, op_pix, op_qpix);
2882
        }
2883

2884
        if(mb_x*16+16 > s->width || mb_y*16+16 > s->height){
2885
            ff_emulated_edge_mc(s->edge_emu_buffer, ptr_y, wrap_y, 16, 16, mb_x*16, mb_y*16, s->width, s->height);
2886 2887 2888
            ptr_y= s->edge_emu_buffer;
            emu=1;
        }
2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906
        
        if(s->flags&CODEC_FLAG_INTERLACED_DCT){
            int progressive_score, interlaced_score;
            
            progressive_score= pix_diff_vcmp16x8(ptr_y           , dest_y           , wrap_y  ) 
                             + pix_diff_vcmp16x8(ptr_y + wrap_y*8, dest_y + wrap_y*8, wrap_y  );
            interlaced_score = pix_diff_vcmp16x8(ptr_y           , dest_y           , wrap_y*2)
                             + pix_diff_vcmp16x8(ptr_y + wrap_y  , dest_y + wrap_y  , wrap_y*2);
            
            if(progressive_score > interlaced_score + 600){
                s->interlaced_dct=1;
            
                dct_offset= wrap_y;
                wrap_y<<=1;
            }else
                s->interlaced_dct=0;
        }
        
2907 2908 2909 2910
	s->dsp.diff_pixels(s->block[0], ptr_y                 , dest_y                 , wrap_y);
        s->dsp.diff_pixels(s->block[1], ptr_y              + 8, dest_y              + 8, wrap_y);
        s->dsp.diff_pixels(s->block[2], ptr_y + dct_offset    , dest_y + dct_offset    , wrap_y);
        s->dsp.diff_pixels(s->block[3], ptr_y + dct_offset + 8, dest_y + dct_offset + 8, wrap_y);
M
Michael Niedermayer 已提交
2911 2912 2913 2914 2915
        
        if(s->flags&CODEC_FLAG_GRAY){
            skip_dct[4]= 1;
            skip_dct[5]= 1;
        }else{
2916
            if(emu){
2917
                ff_emulated_edge_mc(s->edge_emu_buffer, ptr_cb, wrap_c, 8, 8, mb_x*8, mb_y*8, s->width>>1, s->height>>1);
2918 2919
                ptr_cb= s->edge_emu_buffer;
            }
2920
            s->dsp.diff_pixels(s->block[4], ptr_cb, dest_cb, wrap_c);
2921
            if(emu){
2922
                ff_emulated_edge_mc(s->edge_emu_buffer, ptr_cr, wrap_c, 8, 8, mb_x*8, mb_y*8, s->width>>1, s->height>>1);
2923 2924
                ptr_cr= s->edge_emu_buffer;
            }
2925
            s->dsp.diff_pixels(s->block[5], ptr_cr, dest_cr, wrap_c);
M
Michael Niedermayer 已提交
2926
        }
2927
        /* pre quantization */         
2928
        if(s->current_picture.mc_mb_var[s->mb_stride*mb_y+ mb_x]<2*s->qscale*s->qscale){
2929
            //FIXME optimize
2930 2931 2932 2933
	    if(s->dsp.pix_abs8x8(ptr_y               , dest_y               , wrap_y) < 20*s->qscale) skip_dct[0]= 1;
            if(s->dsp.pix_abs8x8(ptr_y            + 8, dest_y            + 8, wrap_y) < 20*s->qscale) skip_dct[1]= 1;
            if(s->dsp.pix_abs8x8(ptr_y +dct_offset   , dest_y +dct_offset   , wrap_y) < 20*s->qscale) skip_dct[2]= 1;
            if(s->dsp.pix_abs8x8(ptr_y +dct_offset+ 8, dest_y +dct_offset+ 8, wrap_y) < 20*s->qscale) skip_dct[3]= 1;
2934 2935
            if(s->dsp.pix_abs8x8(ptr_cb              , dest_cb              , wrap_c) < 20*s->qscale) skip_dct[4]= 1;
            if(s->dsp.pix_abs8x8(ptr_cr              , dest_cr              , wrap_c) < 20*s->qscale) skip_dct[5]= 1;
2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951
#if 0
{
 static int stat[7];
 int num=0;
 for(i=0; i<6; i++)
  if(skip_dct[i]) num++;
 stat[num]++;
 
 if(s->mb_x==0 && s->mb_y==0){
  for(i=0; i<7; i++){
   printf("%6d %1d\n", stat[i], i);
  }
 }
}
#endif
        }
2952

2953 2954 2955 2956 2957 2958
    }
            
#if 0
            {
                float adap_parm;
                
2959 2960
                adap_parm = ((s->avg_mb_var << 1) + s->mb_var[s->mb_stride*mb_y+mb_x] + 1.0) /
                            ((s->mb_var[s->mb_stride*mb_y+mb_x] << 1) + s->avg_mb_var + 1.0);
2961 2962
            
                printf("\ntype=%c qscale=%2d adap=%0.2f dquant=%4.2f var=%4d avgvar=%4d", 
2963
                        (s->mb_type[s->mb_stride*mb_y+mb_x] > 0) ? 'I' : 'P', 
2964
                        s->qscale, adap_parm, s->qscale*adap_parm,
2965
                        s->mb_var[s->mb_stride*mb_y+mb_x], s->avg_mb_var);
2966 2967 2968
            }
#endif
    /* DCT & quantize */
2969 2970 2971
    if(s->out_format==FMT_MJPEG){
        for(i=0;i<6;i++) {
            int overflow;
2972
            s->block_last_index[i] = s->dct_quantize(s, s->block[i], i, 8, &overflow);
2973
            if (overflow) clip_coeffs(s, s->block[i], s->block_last_index[i]);
2974 2975 2976
        }
    }else{
        for(i=0;i<6;i++) {
2977 2978
            if(!skip_dct[i]){
                int overflow;
2979
                s->block_last_index[i] = s->dct_quantize(s, s->block[i], i, s->qscale, &overflow);
2980
            // FIXME we could decide to change to quantizer instead of clipping
2981 2982
            // JS: I don't think that would be a good idea it could lower quality instead
            //     of improve it. Just INTRADC clipping deserves changes in quantizer
2983 2984 2985
                if (overflow) clip_coeffs(s, s->block[i], s->block_last_index[i]);
            }else
                s->block_last_index[i]= -1;
2986
        }
2987 2988
        if(s->luma_elim_threshold && !s->mb_intra)
            for(i=0; i<4; i++)
2989
                dct_single_coeff_elimination(s, i, s->luma_elim_threshold);
2990 2991
        if(s->chroma_elim_threshold && !s->mb_intra)
            for(i=4; i<6; i++)
2992
                dct_single_coeff_elimination(s, i, s->chroma_elim_threshold);
2993 2994
    }

M
Michael Niedermayer 已提交
2995 2996 2997 2998
    if((s->flags&CODEC_FLAG_GRAY) && s->mb_intra){
        s->block_last_index[4]=
        s->block_last_index[5]= 0;
        s->block[4][0]=
M
bugs  
Michael Niedermayer 已提交
2999
        s->block[5][0]= (1024 + s->c_dc_scale/2)/ s->c_dc_scale;
M
Michael Niedermayer 已提交
3000 3001
    }

3002
    /* huffman encode */
M
Michael Niedermayer 已提交
3003 3004 3005
    switch(s->codec_id){ //FIXME funct ptr could be slightly faster
    case CODEC_ID_MPEG1VIDEO:
        mpeg1_encode_mb(s, s->block, motion_x, motion_y); break;
M
Michael Niedermayer 已提交
3006
#ifdef CONFIG_RISKY
M
Michael Niedermayer 已提交
3007 3008 3009 3010 3011 3012 3013 3014 3015 3016
    case CODEC_ID_MPEG4:
        mpeg4_encode_mb(s, s->block, motion_x, motion_y); break;
    case CODEC_ID_MSMPEG4V2:
    case CODEC_ID_MSMPEG4V3:
    case CODEC_ID_WMV1:
        msmpeg4_encode_mb(s, s->block, motion_x, motion_y); break;
    case CODEC_ID_WMV2:
         ff_wmv2_encode_mb(s, s->block, motion_x, motion_y); break;
    case CODEC_ID_H263:
    case CODEC_ID_H263P:
3017
    case CODEC_ID_FLV1:
M
Michael Niedermayer 已提交
3018 3019
    case CODEC_ID_RV10:
        h263_encode_mb(s, s->block, motion_x, motion_y); break;
M
Michael Niedermayer 已提交
3020 3021 3022
#endif
    case CODEC_ID_MJPEG:
        mjpeg_encode_mb(s, s->block); break;
M
Michael Niedermayer 已提交
3023 3024
    default:
        assert(0);
3025 3026 3027
    }
}

3028 3029
#endif //CONFIG_ENCODERS

M
cleanup  
Michael Niedermayer 已提交
3030 3031 3032 3033 3034 3035
/**
 * combines the (truncated) bitstream to a complete frame
 * @returns -1 if no complete frame could be created
 */
int ff_combine_frame( MpegEncContext *s, int next, uint8_t **buf, int *buf_size){
    ParseContext *pc= &s->parse_context;
3036 3037 3038 3039 3040 3041 3042 3043 3044 3045 3046 3047 3048

#if 0
    if(pc->overread){
        printf("overread %d, state:%X next:%d index:%d o_index:%d\n", pc->overread, pc->state, next, pc->index, pc->overread_index);
        printf("%X %X %X %X\n", (*buf)[0], (*buf)[1],(*buf)[2],(*buf)[3]);
    }
#endif

    /* copy overreaded byes from last frame into buffer */
    for(; pc->overread>0; pc->overread--){
        pc->buffer[pc->index++]= pc->buffer[pc->overread_index++];
    }
    
M
cleanup  
Michael Niedermayer 已提交
3049 3050
    pc->last_index= pc->index;

3051 3052
    /* copy into buffer end return */
    if(next == END_NOT_FOUND){
M
cleanup  
Michael Niedermayer 已提交
3053 3054 3055 3056 3057 3058
        pc->buffer= av_fast_realloc(pc->buffer, &pc->buffer_size, (*buf_size) + pc->index + FF_INPUT_BUFFER_PADDING_SIZE);

        memcpy(&pc->buffer[pc->index], *buf, *buf_size);
        pc->index += *buf_size;
        return -1;
    }
M
Michael Niedermayer 已提交
3059 3060

    *buf_size=
3061 3062 3063
    pc->overread_index= pc->index + next;
    
    /* append to buffer */
M
cleanup  
Michael Niedermayer 已提交
3064 3065 3066 3067 3068 3069 3070 3071
    if(pc->index){
        pc->buffer= av_fast_realloc(pc->buffer, &pc->buffer_size, next + pc->index + FF_INPUT_BUFFER_PADDING_SIZE);

        memcpy(&pc->buffer[pc->index], *buf, next + FF_INPUT_BUFFER_PADDING_SIZE );
        pc->index = 0;
        *buf= pc->buffer;
    }

3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084
    /* store overread bytes */
    for(;next < 0; next++){
        pc->state = (pc->state<<8) | pc->buffer[pc->last_index + next];
        pc->overread++;
    }

#if 0
    if(pc->overread){
        printf("overread %d, state:%X next:%d index:%d o_index:%d\n", pc->overread, pc->state, next, pc->index, pc->overread_index);
        printf("%X %X %X %X\n", (*buf)[0], (*buf)[1],(*buf)[2],(*buf)[3]);
    }
#endif

M
cleanup  
Michael Niedermayer 已提交
3085 3086 3087
    return 0;
}

M
Michael Niedermayer 已提交
3088 3089 3090 3091 3092 3093 3094 3095 3096 3097
void ff_mpeg_flush(AVCodecContext *avctx){
    int i;
    MpegEncContext *s = avctx->priv_data;
    
    for(i=0; i<MAX_PICTURE_COUNT; i++){
       if(s->picture[i].data[0] && (   s->picture[i].type == FF_BUFFER_TYPE_INTERNAL
                                    || s->picture[i].type == FF_BUFFER_TYPE_USER))
        avctx->release_buffer(avctx, (AVFrame*)&s->picture[i]);
    }
    s->last_picture_ptr = s->next_picture_ptr = NULL;
3098 3099 3100 3101 3102 3103 3104
    
    s->parse_context.state= -1;
    s->parse_context.frame_start_found= 0;
    s->parse_context.overread= 0;
    s->parse_context.overread_index= 0;
    s->parse_context.index= 0;
    s->parse_context.last_index= 0;
M
Michael Niedermayer 已提交
3105 3106
}

3107
#ifdef CONFIG_ENCODERS
3108
void ff_copy_bits(PutBitContext *pb, uint8_t *src, int length)
3109
{
3110 3111 3112 3113
    int bytes= length>>4;
    int bits= length&15;
    int i;

3114 3115
    if(length==0) return;

3116 3117
    for(i=0; i<bytes; i++) put_bits(pb, 16, be2me_16(((uint16_t*)src)[i]));
    put_bits(pb, bits, be2me_16(((uint16_t*)src)[i])>>(16-bits));
3118 3119
}

3120
static inline void copy_context_before_encode(MpegEncContext *d, MpegEncContext *s, int type){
3121 3122 3123 3124 3125
    int i;

    memcpy(d->last_mv, s->last_mv, 2*2*2*sizeof(int)); //FIXME is memcpy faster then a loop?

    /* mpeg1 */
3126
    d->mb_skip_run= s->mb_skip_run;
3127 3128 3129 3130 3131 3132 3133 3134
    for(i=0; i<3; i++)
        d->last_dc[i]= s->last_dc[i];
    
    /* statistics */
    d->mv_bits= s->mv_bits;
    d->i_tex_bits= s->i_tex_bits;
    d->p_tex_bits= s->p_tex_bits;
    d->i_count= s->i_count;
3135 3136
    d->f_count= s->f_count;
    d->b_count= s->b_count;
3137 3138
    d->skip_count= s->skip_count;
    d->misc_bits= s->misc_bits;
3139
    d->last_bits= 0;
3140

3141
    d->mb_skiped= 0;
M
Michael Niedermayer 已提交
3142
    d->qscale= s->qscale;
3143 3144
}

3145
static inline void copy_context_after_encode(MpegEncContext *d, MpegEncContext *s, int type){
3146 3147 3148 3149 3150 3151
    int i;

    memcpy(d->mv, s->mv, 2*4*2*sizeof(int)); 
    memcpy(d->last_mv, s->last_mv, 2*2*2*sizeof(int)); //FIXME is memcpy faster then a loop?
    
    /* mpeg1 */
3152
    d->mb_skip_run= s->mb_skip_run;
3153 3154 3155 3156 3157 3158 3159 3160
    for(i=0; i<3; i++)
        d->last_dc[i]= s->last_dc[i];
    
    /* statistics */
    d->mv_bits= s->mv_bits;
    d->i_tex_bits= s->i_tex_bits;
    d->p_tex_bits= s->p_tex_bits;
    d->i_count= s->i_count;
3161 3162
    d->f_count= s->f_count;
    d->b_count= s->b_count;
3163 3164 3165 3166
    d->skip_count= s->skip_count;
    d->misc_bits= s->misc_bits;

    d->mb_intra= s->mb_intra;
3167
    d->mb_skiped= s->mb_skiped;
3168 3169 3170
    d->mv_type= s->mv_type;
    d->mv_dir= s->mv_dir;
    d->pb= s->pb;
3171 3172 3173 3174
    if(s->data_partitioning){
        d->pb2= s->pb2;
        d->tex_pb= s->tex_pb;
    }
3175 3176 3177
    d->block= s->block;
    for(i=0; i<6; i++)
        d->block_last_index[i]= s->block_last_index[i];
3178
    d->interlaced_dct= s->interlaced_dct;
M
Michael Niedermayer 已提交
3179
    d->qscale= s->qscale;
3180 3181
}

3182 3183 3184 3185
static inline void encode_mb_hq(MpegEncContext *s, MpegEncContext *backup, MpegEncContext *best, int type, 
                           PutBitContext pb[2], PutBitContext pb2[2], PutBitContext tex_pb[2],
                           int *dmin, int *next_block, int motion_x, int motion_y)
{
3186 3187
    int score;
    uint8_t *dest_backup[3];
3188 3189 3190 3191 3192 3193 3194 3195 3196
    
    copy_context_before_encode(s, backup, type);

    s->block= s->blocks[*next_block];
    s->pb= pb[*next_block];
    if(s->data_partitioning){
        s->pb2   = pb2   [*next_block];
        s->tex_pb= tex_pb[*next_block];
    }
3197 3198 3199 3200 3201 3202 3203 3204 3205
    
    if(*next_block){
        memcpy(dest_backup, s->dest, sizeof(s->dest));
        s->dest[0] = s->me.scratchpad;
        s->dest[1] = s->me.scratchpad + 16;
        s->dest[2] = s->me.scratchpad + 16 + 8;
        assert(2*s->uvlinesize == s->linesize); //should be no prob for encoding
        assert(s->linesize >= 64); //FIXME
    }
3206 3207

    encode_mb(s, motion_x, motion_y);
3208 3209
    
    score= get_bit_count(&s->pb);
3210
    if(s->data_partitioning){
3211 3212
        score+= get_bit_count(&s->pb2);
        score+= get_bit_count(&s->tex_pb);
3213
    }
3214 3215 3216
   
    if(s->avctx->mb_decision == FF_MB_DECISION_RD){
        MPV_decode_mb(s, s->block);
3217

3218 3219 3220 3221 3222 3223 3224 3225 3226 3227
        score *= s->qscale * s->qscale * 109;
        score += sse_mb(s) << 7;
    }
    
    if(*next_block){
        memcpy(s->dest, dest_backup, sizeof(s->dest));
    }

    if(score<*dmin){
        *dmin= score;
3228 3229 3230 3231 3232
        *next_block^=1;

        copy_context_after_encode(best, s, type);
    }
}
3233
                
3234
static int sse(MpegEncContext *s, uint8_t *src1, uint8_t *src2, int w, int h, int stride){
3235 3236 3237 3238 3239
    uint32_t *sq = squareTbl + 256;
    int acc=0;
    int x,y;
    
    if(w==16 && h==16) 
M
Michael Niedermayer 已提交
3240 3241 3242
        return s->dsp.sse[0](NULL, src1, src2, stride);
    else if(w==8 && h==8)
        return s->dsp.sse[1](NULL, src1, src2, stride);
3243 3244 3245 3246 3247 3248
    
    for(y=0; y<h; y++){
        for(x=0; x<w; x++){
            acc+= sq[src1[x + y*stride] - src2[x + y*stride]];
        } 
    }
M
Michael Niedermayer 已提交
3249 3250 3251
    
    assert(acc>=0);
    
3252 3253
    return acc;
}
3254

3255 3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269 3270 3271
static int sse_mb(MpegEncContext *s){
    int w= 16;
    int h= 16;

    if(s->mb_x*16 + 16 > s->width ) w= s->width - s->mb_x*16;
    if(s->mb_y*16 + 16 > s->height) h= s->height- s->mb_y*16;

    if(w==16 && h==16)
        return  s->dsp.sse[0](NULL, s->new_picture.data[0] + s->mb_x*16 + s->mb_y*s->linesize*16, s->dest[0], s->linesize)
               +s->dsp.sse[1](NULL, s->new_picture.data[1] + s->mb_x*8  + s->mb_y*s->uvlinesize*8,s->dest[1], s->uvlinesize)
               +s->dsp.sse[1](NULL, s->new_picture.data[2] + s->mb_x*8  + s->mb_y*s->uvlinesize*8,s->dest[2], s->uvlinesize);
    else
        return  sse(s, s->new_picture.data[0] + s->mb_x*16 + s->mb_y*s->linesize*16, s->dest[0], w, h, s->linesize)
               +sse(s, s->new_picture.data[1] + s->mb_x*8  + s->mb_y*s->uvlinesize*8,s->dest[1], w>>1, h>>1, s->uvlinesize)
               +sse(s, s->new_picture.data[2] + s->mb_x*8  + s->mb_y*s->uvlinesize*8,s->dest[2], w>>1, h>>1, s->uvlinesize);
}

3272 3273
static void encode_picture(MpegEncContext *s, int picture_number)
{
M
Michael Niedermayer 已提交
3274
    int mb_x, mb_y, pdif = 0;
3275
    int i;
3276
    int bits;
3277
    MpegEncContext best_s, backup_s;
3278 3279 3280
    uint8_t bit_buf[2][3000];
    uint8_t bit_buf2[2][3000];
    uint8_t bit_buf_tex[2][3000];
3281 3282 3283 3284 3285 3286 3287
    PutBitContext pb[2], pb2[2], tex_pb[2];

    for(i=0; i<2; i++){
        init_put_bits(&pb    [i], bit_buf    [i], 3000, NULL, NULL);
        init_put_bits(&pb2   [i], bit_buf2   [i], 3000, NULL, NULL);
        init_put_bits(&tex_pb[i], bit_buf_tex[i], 3000, NULL, NULL);
    }
F
Fabrice Bellard 已提交
3288 3289

    s->picture_number = picture_number;
3290
    
3291
    /* Reset the average MB variance */
M
cleanup  
Michael Niedermayer 已提交
3292 3293
    s->current_picture.mb_var_sum = 0;
    s->current_picture.mc_mb_var_sum = 0;
3294

M
Michael Niedermayer 已提交
3295
#ifdef CONFIG_RISKY
3296
    /* we need to initialize some time vars before we can encode b-frames */
3297 3298
    // RAL: Condition added for MPEG1VIDEO
    if (s->codec_id == CODEC_ID_MPEG1VIDEO || (s->h263_pred && !s->h263_msmpeg4))
3299
        ff_set_mpeg4_time(s, s->picture_number); 
M
Michael Niedermayer 已提交
3300 3301
#endif
        
3302
    s->scene_change_score=0;
3303 3304
    
    s->qscale= (int)(s->frame_qscale + 0.5); //FIXME qscale / ... stuff for ME ratedistoration
M
Michael Niedermayer 已提交
3305
    
M
Michael Niedermayer 已提交
3306
    if(s->pict_type==I_TYPE){
M
Michael Niedermayer 已提交
3307 3308
        if(s->msmpeg4_version >= 3) s->no_rounding=1;
        else                        s->no_rounding=0;
M
Michael Niedermayer 已提交
3309 3310
    }else if(s->pict_type!=B_TYPE){
        if(s->flipflop_rounding || s->codec_id == CODEC_ID_H263P || s->codec_id == CODEC_ID_MPEG4)
M
Michael Niedermayer 已提交
3311 3312
            s->no_rounding ^= 1;          
    }
M
Michael Niedermayer 已提交
3313
    
3314
    /* Estimate motion for every MB */
3315
    s->mb_intra=0; //for the rate distoration & bit compare functions
3316
    if(s->pict_type != I_TYPE){
M
Michael Niedermayer 已提交
3317 3318
        if(s->pict_type != B_TYPE){
            if((s->avctx->pre_me && s->last_non_b_pict_type==I_TYPE) || s->avctx->pre_me==2){
3319
                s->me.pre_pass=1;
M
Michael Niedermayer 已提交
3320
                s->me.dia_size= s->avctx->pre_dia_size;
3321

M
Michael Niedermayer 已提交
3322 3323 3324 3325 3326 3327 3328
                for(mb_y=s->mb_height-1; mb_y >=0 ; mb_y--) {
                    for(mb_x=s->mb_width-1; mb_x >=0 ; mb_x--) {
                        s->mb_x = mb_x;
                        s->mb_y = mb_y;
                        ff_pre_estimate_p_frame_motion(s, mb_x, mb_y);
                    }
                }
3329
                s->me.pre_pass=0;
M
Michael Niedermayer 已提交
3330 3331 3332
            }
        }

M
Michael Niedermayer 已提交
3333
        s->me.dia_size= s->avctx->dia_size;
3334 3335 3336 3337 3338 3339 3340 3341 3342 3343 3344 3345
        for(mb_y=0; mb_y < s->mb_height; mb_y++) {
            s->block_index[0]= s->block_wrap[0]*(mb_y*2 + 1) - 1;
            s->block_index[1]= s->block_wrap[0]*(mb_y*2 + 1);
            s->block_index[2]= s->block_wrap[0]*(mb_y*2 + 2) - 1;
            s->block_index[3]= s->block_wrap[0]*(mb_y*2 + 2);
            for(mb_x=0; mb_x < s->mb_width; mb_x++) {
                s->mb_x = mb_x;
                s->mb_y = mb_y;
                s->block_index[0]+=2;
                s->block_index[1]+=2;
                s->block_index[2]+=2;
                s->block_index[3]+=2;
M
Michael Niedermayer 已提交
3346
                
3347
                /* compute motion vector & mb_type and store in context */
3348 3349 3350 3351
                if(s->pict_type==B_TYPE)
                    ff_estimate_b_frame_motion(s, mb_x, mb_y);
                else
                    ff_estimate_p_frame_motion(s, mb_x, mb_y);
3352 3353
            }
        }
3354
    }else /* if(s->pict_type == I_TYPE) */{
3355 3356
        /* I-Frame */
        //FIXME do we need to zero them?
3357
        memset(s->motion_val[0], 0, sizeof(int16_t)*(s->mb_width*2 + 2)*(s->mb_height*2 + 2)*2);
3358 3359
        memset(s->p_mv_table   , 0, sizeof(int16_t)*(s->mb_stride)*s->mb_height*2);
        memset(s->mb_type      , MB_TYPE_INTRA, sizeof(uint8_t)*s->mb_stride*s->mb_height);
M
Michael Niedermayer 已提交
3360 3361 3362 3363 3364 3365 3366
        
        if(!s->fixed_qscale){
            /* finding spatial complexity for I-frame rate control */
            for(mb_y=0; mb_y < s->mb_height; mb_y++) {
                for(mb_x=0; mb_x < s->mb_width; mb_x++) {
                    int xx = mb_x * 16;
                    int yy = mb_y * 16;
M
cleanup  
Michael Niedermayer 已提交
3367
                    uint8_t *pix = s->new_picture.data[0] + (yy * s->linesize) + xx;
M
Michael Niedermayer 已提交
3368
                    int varc;
3369
		    int sum = s->dsp.pix_sum(pix, s->linesize);
M
Michael Niedermayer 已提交
3370
    
3371
		    varc = (s->dsp.pix_norm1(pix, s->linesize) - (((unsigned)(sum*sum))>>8) + 500 + 128)>>8;
M
Michael Niedermayer 已提交
3372

3373 3374
                    s->current_picture.mb_var [s->mb_stride * mb_y + mb_x] = varc;
                    s->current_picture.mb_mean[s->mb_stride * mb_y + mb_x] = (sum+128)>>8;
M
cleanup  
Michael Niedermayer 已提交
3375
                    s->current_picture.mb_var_sum    += varc;
M
Michael Niedermayer 已提交
3376 3377 3378
                }
            }
        }
3379
    }
3380 3381
    emms_c();

3382
    if(s->scene_change_score > 0 && s->pict_type == P_TYPE){
M
Michael Niedermayer 已提交
3383
        s->pict_type= I_TYPE;
3384
        memset(s->mb_type   , MB_TYPE_INTRA, sizeof(uint8_t)*s->mb_stride*s->mb_height);
M
cleanup  
Michael Niedermayer 已提交
3385
//printf("Scene change detected, encoding as I Frame %d %d\n", s->current_picture.mb_var_sum, s->current_picture.mc_mb_var_sum);
M
Michael Niedermayer 已提交
3386
    }
M
cleanup  
Michael Niedermayer 已提交
3387

M
Michael Niedermayer 已提交
3388
    if(!s->umvplus){
3389 3390
        if(s->pict_type==P_TYPE || s->pict_type==S_TYPE) {
            s->f_code= ff_get_best_fcode(s, s->p_mv_table, MB_TYPE_INTER);
3391
        
3392 3393
            ff_fix_long_p_mvs(s);
        }
3394

3395 3396
        if(s->pict_type==B_TYPE){
            int a, b;
3397

3398 3399 3400
            a = ff_get_best_fcode(s, s->b_forw_mv_table, MB_TYPE_FORWARD);
            b = ff_get_best_fcode(s, s->b_bidir_forw_mv_table, MB_TYPE_BIDIR);
            s->f_code = FFMAX(a, b);
3401

3402 3403 3404
            a = ff_get_best_fcode(s, s->b_back_mv_table, MB_TYPE_BACKWARD);
            b = ff_get_best_fcode(s, s->b_bidir_back_mv_table, MB_TYPE_BIDIR);
            s->b_code = FFMAX(a, b);
3405

3406 3407 3408 3409 3410
            ff_fix_long_b_mvs(s, s->b_forw_mv_table, s->f_code, MB_TYPE_FORWARD);
            ff_fix_long_b_mvs(s, s->b_back_mv_table, s->b_code, MB_TYPE_BACKWARD);
            ff_fix_long_b_mvs(s, s->b_bidir_forw_mv_table, s->f_code, MB_TYPE_BIDIR);
            ff_fix_long_b_mvs(s, s->b_bidir_back_mv_table, s->b_code, MB_TYPE_BIDIR);
        }
3411
    }
3412
    
3413
    if (s->fixed_qscale) 
M
cleanup  
Michael Niedermayer 已提交
3414
        s->frame_qscale = s->current_picture.quality;
3415 3416
    else
        s->frame_qscale = ff_rate_estimate_qscale(s);
3417

3418
    if(s->adaptive_quant){
M
Michael Niedermayer 已提交
3419
#ifdef CONFIG_RISKY
3420 3421 3422 3423 3424 3425
        switch(s->codec_id){
        case CODEC_ID_MPEG4:
            ff_clean_mpeg4_qscales(s);
            break;
        case CODEC_ID_H263:
        case CODEC_ID_H263P:
3426
        case CODEC_ID_FLV1:
3427 3428 3429
            ff_clean_h263_qscales(s);
            break;
        }
M
Michael Niedermayer 已提交
3430
#endif
3431

M
cleanup  
Michael Niedermayer 已提交
3432
        s->qscale= s->current_picture.qscale_table[0];
3433
    }else
3434 3435
        s->qscale= (int)(s->frame_qscale + 0.5);
        
F
Fabrice Bellard 已提交
3436 3437
    if (s->out_format == FMT_MJPEG) {
        /* for mjpeg, we do include qscale in the matrix */
3438
        s->intra_matrix[0] = ff_mpeg1_default_intra_matrix[0];
3439
        for(i=1;i<64;i++){
3440
            int j= s->dsp.idct_permutation[i];
3441 3442 3443

            s->intra_matrix[j] = CLAMP_TO_8BIT((ff_mpeg1_default_intra_matrix[i] * s->qscale) >> 3);
        }
3444
        convert_matrix(s, s->q_intra_matrix, s->q_intra_matrix16, 
3445
                       s->q_intra_matrix16_bias, s->intra_matrix, s->intra_quant_bias, 8, 8);
F
Fabrice Bellard 已提交
3446
    }
M
cleanup  
Michael Niedermayer 已提交
3447 3448 3449 3450 3451 3452 3453
    
    //FIXME var duplication
    s->current_picture.key_frame= s->pict_type == I_TYPE;
    s->current_picture.pict_type= s->pict_type;

    if(s->current_picture.key_frame)
        s->picture_in_gop_number=0;
F
Fabrice Bellard 已提交
3454

3455
    s->last_bits= get_bit_count(&s->pb);
F
Fabrice Bellard 已提交
3456 3457 3458 3459
    switch(s->out_format) {
    case FMT_MJPEG:
        mjpeg_picture_header(s);
        break;
M
Michael Niedermayer 已提交
3460
#ifdef CONFIG_RISKY
F
Fabrice Bellard 已提交
3461
    case FMT_H263:
M
Michael Niedermayer 已提交
3462 3463 3464
        if (s->codec_id == CODEC_ID_WMV2) 
            ff_wmv2_encode_picture_header(s, picture_number);
        else if (s->h263_msmpeg4) 
F
Fabrice Bellard 已提交
3465 3466 3467 3468 3469
            msmpeg4_encode_picture_header(s, picture_number);
        else if (s->h263_pred)
            mpeg4_encode_picture_header(s, picture_number);
        else if (s->h263_rv10) 
            rv10_encode_picture_header(s, picture_number);
M
Michael Niedermayer 已提交
3470 3471
        else if (s->codec_id == CODEC_ID_FLV1)
            ff_flv_encode_picture_header(s, picture_number);
F
Fabrice Bellard 已提交
3472 3473 3474
        else
            h263_encode_picture_header(s, picture_number);
        break;
M
Michael Niedermayer 已提交
3475
#endif
F
Fabrice Bellard 已提交
3476 3477 3478 3479
    case FMT_MPEG1:
        mpeg1_encode_picture_header(s, picture_number);
        break;
    }
3480 3481 3482 3483 3484 3485 3486 3487
    bits= get_bit_count(&s->pb);
    s->header_bits= bits - s->last_bits;
    s->last_bits= bits;
    s->mv_bits=0;
    s->misc_bits=0;
    s->i_tex_bits=0;
    s->p_tex_bits=0;
    s->i_count=0;
3488 3489
    s->f_count=0;
    s->b_count=0;
3490 3491
    s->skip_count=0;

3492 3493 3494 3495 3496
    for(i=0; i<3; i++){
        /* init last dc values */
        /* note: quant matrix value (8) is implied here */
        s->last_dc[i] = 128;
        
M
10l  
Michael Niedermayer 已提交
3497
        s->current_picture_ptr->error[i] = 0;
3498
    }
3499
    s->mb_skip_run = 0;
F
Fabrice Bellard 已提交
3500 3501
    s->last_mv[0][0][0] = 0;
    s->last_mv[0][0][1] = 0;
3502 3503 3504 3505
    s->last_mv[1][0][0] = 0;
    s->last_mv[1][0][1] = 0;
     
    s->last_mv_dir = 0;
F
Fabrice Bellard 已提交
3506

M
Michael Niedermayer 已提交
3507
#ifdef CONFIG_RISKY
3508 3509 3510 3511
    switch(s->codec_id){
    case CODEC_ID_H263:
    case CODEC_ID_H263P:
    case CODEC_ID_FLV1:
3512
        s->gob_index = ff_h263_get_gob_height(s);
3513 3514 3515 3516 3517 3518
        break;
    case CODEC_ID_MPEG4:
        if(s->partitioned_frame)
            ff_mpeg4_init_partitions(s);
        break;
    }
M
Michael Niedermayer 已提交
3519
#endif
3520 3521 3522

    s->resync_mb_x=0;
    s->resync_mb_y=0;
3523
    s->first_slice_line = 1;
M
Michael Niedermayer 已提交
3524
    s->ptr_lastgob = s->pb.buf;
3525
    for(mb_y=0; mb_y < s->mb_height; mb_y++) {
3526 3527 3528
        s->mb_x=0;
        s->mb_y= mb_y;

M
Michael Niedermayer 已提交
3529 3530
        s->y_dc_scale= s->y_dc_scale_table[ s->qscale ];
        s->c_dc_scale= s->c_dc_scale_table[ s->qscale ];
3531
        ff_init_block_index(s);
3532
        
3533
        for(mb_x=0; mb_x < s->mb_width; mb_x++) {
3534 3535
            const int xy= mb_y*s->mb_stride + mb_x;
            int mb_type= s->mb_type[xy];
3536
//            int d;
3537
            int dmin= INT_MAX;
3538 3539

            s->mb_x = mb_x;
3540
            ff_update_block_index(s);
M
Michael Niedermayer 已提交
3541 3542

            /* write gob / video packet header  */
M
Michael Niedermayer 已提交
3543
#ifdef CONFIG_RISKY
M
Michael Niedermayer 已提交
3544 3545 3546 3547 3548 3549 3550
            if(s->rtp_mode){
                int current_packet_size, is_gob_start;
                
                current_packet_size= pbBufPtr(&s->pb) - s->ptr_lastgob;
                is_gob_start=0;
                
                if(s->codec_id==CODEC_ID_MPEG4){
3551
                    if(current_packet_size >= s->rtp_payload_size
M
Michael Niedermayer 已提交
3552 3553
                       && s->mb_y + s->mb_x>0){

3554
                        if(s->partitioned_frame){
3555 3556 3557 3558 3559 3560 3561 3562 3563 3564 3565
                            ff_mpeg4_merge_partitions(s);
                            ff_mpeg4_init_partitions(s);
                        }
                        ff_mpeg4_encode_video_packet_header(s);

                        if(s->flags&CODEC_FLAG_PASS1){
                            int bits= get_bit_count(&s->pb);
                            s->misc_bits+= bits - s->last_bits;
                            s->last_bits= bits;
                        }
                        ff_mpeg4_clean_buffers(s);
M
Michael Niedermayer 已提交
3566
                        is_gob_start=1;
3567
                    }
3568 3569 3570 3571 3572 3573 3574
                }else if(s->codec_id==CODEC_ID_MPEG1VIDEO){
                    if(   current_packet_size >= s->rtp_payload_size 
                       && s->mb_y + s->mb_x>0 && s->mb_skip_run==0){
                        ff_mpeg1_encode_slice_header(s);
                        ff_mpeg1_clean_buffers(s);
                        is_gob_start=1;
                    }
M
Michael Niedermayer 已提交
3575
                }else{
3576
                    if(current_packet_size >= s->rtp_payload_size
M
Michael Niedermayer 已提交
3577 3578 3579 3580 3581 3582 3583 3584
                       && s->mb_x==0 && s->mb_y>0 && s->mb_y%s->gob_index==0){
                       
                        h263_encode_gob_header(s, mb_y);                       
                        is_gob_start=1;
                    }
                }

                if(is_gob_start){
3585 3586 3587 3588 3589
                    s->ptr_lastgob = pbBufPtr(&s->pb);
                    s->first_slice_line=1;
                    s->resync_mb_x=mb_x;
                    s->resync_mb_y=mb_y;
                }
3590
            }
M
Michael Niedermayer 已提交
3591
#endif
3592

3593 3594 3595
            if(  (s->resync_mb_x   == s->mb_x)
               && s->resync_mb_y+1 == s->mb_y){
                s->first_slice_line=0; 
3596 3597
            }

3598 3599
            s->mb_skiped=0;

3600
            if(mb_type & (mb_type-1)){ // more than 1 MB type possible
3601
                int next_block=0;
3602
                int pb_bits_count, pb2_bits_count, tex_pb_bits_count;
3603 3604

                copy_context_before_encode(&backup_s, s, -1);
3605 3606
                backup_s.pb= s->pb;
                best_s.data_partitioning= s->data_partitioning;
3607
                best_s.partitioned_frame= s->partitioned_frame;
3608 3609 3610 3611
                if(s->data_partitioning){
                    backup_s.pb2= s->pb2;
                    backup_s.tex_pb= s->tex_pb;
                }
3612

3613
                if(mb_type&MB_TYPE_INTER){
3614
                    s->mv_dir = MV_DIR_FORWARD;
M
Michael Niedermayer 已提交
3615
                    s->mv_type = MV_TYPE_16X16;
3616
                    s->mb_intra= 0;
3617 3618
                    s->mv[0][0][0] = s->p_mv_table[xy][0];
                    s->mv[0][0][1] = s->p_mv_table[xy][1];
3619 3620
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_INTER, pb, pb2, tex_pb, 
                                 &dmin, &next_block, s->mv[0][0][0], s->mv[0][0][1]);
F
Fabrice Bellard 已提交
3621
                }
3622
                if(mb_type&MB_TYPE_INTER4V){                 
3623
                    s->mv_dir = MV_DIR_FORWARD;
M
Michael Niedermayer 已提交
3624 3625 3626 3627 3628 3629
                    s->mv_type = MV_TYPE_8X8;
                    s->mb_intra= 0;
                    for(i=0; i<4; i++){
                        s->mv[0][i][0] = s->motion_val[s->block_index[i]][0];
                        s->mv[0][i][1] = s->motion_val[s->block_index[i]][1];
                    }
3630 3631
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_INTER4V, pb, pb2, tex_pb, 
                                 &dmin, &next_block, 0, 0);
3632 3633 3634 3635 3636 3637 3638
                }
                if(mb_type&MB_TYPE_FORWARD){
                    s->mv_dir = MV_DIR_FORWARD;
                    s->mv_type = MV_TYPE_16X16;
                    s->mb_intra= 0;
                    s->mv[0][0][0] = s->b_forw_mv_table[xy][0];
                    s->mv[0][0][1] = s->b_forw_mv_table[xy][1];
3639 3640
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_FORWARD, pb, pb2, tex_pb, 
                                 &dmin, &next_block, s->mv[0][0][0], s->mv[0][0][1]);
3641 3642 3643 3644 3645 3646 3647
                }
                if(mb_type&MB_TYPE_BACKWARD){
                    s->mv_dir = MV_DIR_BACKWARD;
                    s->mv_type = MV_TYPE_16X16;
                    s->mb_intra= 0;
                    s->mv[1][0][0] = s->b_back_mv_table[xy][0];
                    s->mv[1][0][1] = s->b_back_mv_table[xy][1];
3648 3649
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_BACKWARD, pb, pb2, tex_pb, 
                                 &dmin, &next_block, s->mv[1][0][0], s->mv[1][0][1]);
3650 3651 3652 3653 3654 3655 3656 3657 3658
                }
                if(mb_type&MB_TYPE_BIDIR){
                    s->mv_dir = MV_DIR_FORWARD | MV_DIR_BACKWARD;
                    s->mv_type = MV_TYPE_16X16;
                    s->mb_intra= 0;
                    s->mv[0][0][0] = s->b_bidir_forw_mv_table[xy][0];
                    s->mv[0][0][1] = s->b_bidir_forw_mv_table[xy][1];
                    s->mv[1][0][0] = s->b_bidir_back_mv_table[xy][0];
                    s->mv[1][0][1] = s->b_bidir_back_mv_table[xy][1];
3659 3660
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_BIDIR, pb, pb2, tex_pb, 
                                 &dmin, &next_block, 0, 0);
3661 3662
                }
                if(mb_type&MB_TYPE_DIRECT){
M
Michael Niedermayer 已提交
3663 3664 3665
                    int mx= s->b_direct_mv_table[xy][0];
                    int my= s->b_direct_mv_table[xy][1];
                    
3666 3667
                    s->mv_dir = MV_DIR_FORWARD | MV_DIR_BACKWARD | MV_DIRECT;
                    s->mb_intra= 0;
M
Michael Niedermayer 已提交
3668
#ifdef CONFIG_RISKY
M
Michael Niedermayer 已提交
3669
                    ff_mpeg4_set_direct_mv(s, mx, my);
M
Michael Niedermayer 已提交
3670
#endif
3671
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_DIRECT, pb, pb2, tex_pb, 
M
Michael Niedermayer 已提交
3672
                                 &dmin, &next_block, mx, my);
M
Michael Niedermayer 已提交
3673
                }
3674
                if(mb_type&MB_TYPE_INTRA){
3675
                    s->mv_dir = 0;
M
Michael Niedermayer 已提交
3676
                    s->mv_type = MV_TYPE_16X16;
3677 3678 3679
                    s->mb_intra= 1;
                    s->mv[0][0][0] = 0;
                    s->mv[0][0][1] = 0;
3680 3681
                    encode_mb_hq(s, &backup_s, &best_s, MB_TYPE_INTRA, pb, pb2, tex_pb, 
                                 &dmin, &next_block, 0, 0);
3682 3683 3684 3685 3686 3687
                    if(s->h263_pred || s->h263_aic){
                        if(best_s.mb_intra)
                            s->mbintra_table[mb_x + mb_y*s->mb_stride]=1;
                        else
                            ff_clean_intra_table_entries(s); //old mode?
                    }
M
Michael Niedermayer 已提交
3688
                }
3689
                copy_context_after_encode(s, &best_s, -1);
3690 3691 3692 3693 3694 3695 3696 3697 3698 3699 3700 3701 3702 3703 3704 3705 3706
                
                pb_bits_count= get_bit_count(&s->pb);
                flush_put_bits(&s->pb);
                ff_copy_bits(&backup_s.pb, bit_buf[next_block^1], pb_bits_count);
                s->pb= backup_s.pb;
                
                if(s->data_partitioning){
                    pb2_bits_count= get_bit_count(&s->pb2);
                    flush_put_bits(&s->pb2);
                    ff_copy_bits(&backup_s.pb2, bit_buf2[next_block^1], pb2_bits_count);
                    s->pb2= backup_s.pb2;
                    
                    tex_pb_bits_count= get_bit_count(&s->tex_pb);
                    flush_put_bits(&s->tex_pb);
                    ff_copy_bits(&backup_s.tex_pb, bit_buf_tex[next_block^1], tex_pb_bits_count);
                    s->tex_pb= backup_s.tex_pb;
                }
3707
                s->last_bits= get_bit_count(&s->pb);
3708 3709 3710 3711 3712 3713 3714 3715 3716 3717 3718 3719
                
                if (s->out_format == FMT_H263 && s->pict_type!=B_TYPE)
                    ff_h263_update_motion_val(s);
        
                if(next_block==0){
                    s->dsp.put_pixels_tab[0][0](s->dest[0], s->me.scratchpad     , s->linesize  ,16);
                    s->dsp.put_pixels_tab[1][0](s->dest[1], s->me.scratchpad + 16, s->uvlinesize, 8);
                    s->dsp.put_pixels_tab[1][0](s->dest[2], s->me.scratchpad + 24, s->uvlinesize, 8);
                }

                if(s->avctx->mb_decision == FF_MB_DECISION_BITS)
                    MPV_decode_mb(s, s->block);
F
Fabrice Bellard 已提交
3720
            } else {
3721
                int motion_x, motion_y;
3722
                int intra_score;
3723
                int inter_score= s->current_picture.mb_cmp_score[mb_x + mb_y*s->mb_stride];
3724
                
3725
              if(s->avctx->mb_decision==FF_MB_DECISION_SIMPLE && s->pict_type==P_TYPE){ //FIXME check if the mess is usefull at all
3726 3727
                /* get luma score */
                if((s->avctx->mb_cmp&0xFF)==FF_CMP_SSE){
3728
                    intra_score= (s->current_picture.mb_var[mb_x + mb_y*s->mb_stride]<<8) - 500; //FIXME dont scale it down so we dont have to fix it
3729 3730 3731
                }else{
                    uint8_t *dest_y;

3732
                    int mean= s->current_picture.mb_mean[mb_x + mb_y*s->mb_stride]; //FIXME
3733 3734 3735 3736 3737 3738 3739 3740 3741 3742 3743 3744 3745 3746 3747
                    mean*= 0x01010101;
                    
                    dest_y  = s->new_picture.data[0] + (mb_y * 16 * s->linesize    ) + mb_x * 16;
                
                    for(i=0; i<16; i++){
                        *(uint32_t*)(&s->me.scratchpad[i*s->linesize+ 0]) = mean;
                        *(uint32_t*)(&s->me.scratchpad[i*s->linesize+ 4]) = mean;
                        *(uint32_t*)(&s->me.scratchpad[i*s->linesize+ 8]) = mean;
                        *(uint32_t*)(&s->me.scratchpad[i*s->linesize+12]) = mean;
                    }

                    s->mb_intra=1;
                    intra_score= s->dsp.mb_cmp[0](s, s->me.scratchpad, dest_y, s->linesize);
                                        
/*                    printf("intra:%7d inter:%7d var:%7d mc_var.%7d\n", intra_score>>8, inter_score>>8, 
3748 3749
                        s->current_picture.mb_var[mb_x + mb_y*s->mb_stride],
                        s->current_picture.mc_mb_var[mb_x + mb_y*s->mb_stride]);*/
3750 3751 3752 3753 3754 3755 3756 3757 3758 3759 3760 3761 3762 3763 3764 3765 3766 3767 3768 3769 3770 3771 3772 3773 3774 3775 3776 3777 3778 3779 3780 3781 3782 3783 3784 3785 3786 3787 3788 3789 3790 3791 3792 3793 3794 3795 3796 3797 3798 3799 3800 3801 3802 3803 3804 3805
                }
                
                /* get chroma score */
                if(s->avctx->mb_cmp&FF_CMP_CHROMA){
                    int i;
                    
                    s->mb_intra=1;
                    for(i=1; i<3; i++){
                        uint8_t *dest_c;
                        int mean;
                        
                        if(s->out_format == FMT_H263){
                            mean= (s->dc_val[i][mb_x + (mb_y+1)*(s->mb_width+2)] + 4)>>3; //FIXME not exact but simple ;)
                        }else{
                            mean= (s->last_dc[i] + 4)>>3;
                        }
                        dest_c = s->new_picture.data[i] + (mb_y * 8  * (s->uvlinesize)) + mb_x * 8;
                        
                        mean*= 0x01010101;
                        for(i=0; i<8; i++){
                            *(uint32_t*)(&s->me.scratchpad[i*s->uvlinesize+ 0]) = mean;
                            *(uint32_t*)(&s->me.scratchpad[i*s->uvlinesize+ 4]) = mean;
                        }
                        
                        intra_score+= s->dsp.mb_cmp[1](s, s->me.scratchpad, dest_c, s->uvlinesize);
                    }                
                }

                /* bias */
                switch(s->avctx->mb_cmp&0xFF){
                default:
                case FF_CMP_SAD:
                    intra_score+= 32*s->qscale;
                    break;
                case FF_CMP_SSE:
                    intra_score+= 24*s->qscale*s->qscale;
                    break;
                case FF_CMP_SATD:
                    intra_score+= 96*s->qscale;
                    break;
                case FF_CMP_DCT:
                    intra_score+= 48*s->qscale;
                    break;
                case FF_CMP_BIT:
                    intra_score+= 16;
                    break;
                case FF_CMP_PSNR:
                case FF_CMP_RD:
                    intra_score+= (s->qscale*s->qscale*109*8 + 64)>>7;
                    break;
                }

                if(intra_score < inter_score)
                    mb_type= MB_TYPE_INTRA;
              }  
                
3806
                s->mv_type=MV_TYPE_16X16;
3807
                // only one MB-Type possible
3808
                
3809 3810
                switch(mb_type){
                case MB_TYPE_INTRA:
3811
                    s->mv_dir = 0;
3812
                    s->mb_intra= 1;
3813 3814
                    motion_x= s->mv[0][0][0] = 0;
                    motion_y= s->mv[0][0][1] = 0;
3815 3816
                    break;
                case MB_TYPE_INTER:
3817 3818 3819 3820
                    s->mv_dir = MV_DIR_FORWARD;
                    s->mb_intra= 0;
                    motion_x= s->mv[0][0][0] = s->p_mv_table[xy][0];
                    motion_y= s->mv[0][0][1] = s->p_mv_table[xy][1];
3821
                    break;
3822 3823 3824 3825 3826 3827 3828 3829 3830 3831
                case MB_TYPE_INTER4V:
                    s->mv_dir = MV_DIR_FORWARD;
                    s->mv_type = MV_TYPE_8X8;
                    s->mb_intra= 0;
                    for(i=0; i<4; i++){
                        s->mv[0][i][0] = s->motion_val[s->block_index[i]][0];
                        s->mv[0][i][1] = s->motion_val[s->block_index[i]][1];
                    }
                    motion_x= motion_y= 0;
                    break;
3832
                case MB_TYPE_DIRECT:
3833 3834
                    s->mv_dir = MV_DIR_FORWARD | MV_DIR_BACKWARD | MV_DIRECT;
                    s->mb_intra= 0;
3835 3836
                    motion_x=s->b_direct_mv_table[xy][0];
                    motion_y=s->b_direct_mv_table[xy][1];
M
Michael Niedermayer 已提交
3837
#ifdef CONFIG_RISKY
M
Michael Niedermayer 已提交
3838
                    ff_mpeg4_set_direct_mv(s, motion_x, motion_y);
M
Michael Niedermayer 已提交
3839
#endif
3840 3841
                    break;
                case MB_TYPE_BIDIR:
3842
                    s->mv_dir = MV_DIR_FORWARD | MV_DIR_BACKWARD;
3843
                    s->mb_intra= 0;
3844 3845 3846 3847 3848 3849
                    motion_x=0;
                    motion_y=0;
                    s->mv[0][0][0] = s->b_bidir_forw_mv_table[xy][0];
                    s->mv[0][0][1] = s->b_bidir_forw_mv_table[xy][1];
                    s->mv[1][0][0] = s->b_bidir_back_mv_table[xy][0];
                    s->mv[1][0][1] = s->b_bidir_back_mv_table[xy][1];
3850 3851
                    break;
                case MB_TYPE_BACKWARD:
3852 3853 3854 3855
                    s->mv_dir = MV_DIR_BACKWARD;
                    s->mb_intra= 0;
                    motion_x= s->mv[1][0][0] = s->b_back_mv_table[xy][0];
                    motion_y= s->mv[1][0][1] = s->b_back_mv_table[xy][1];
3856 3857
                    break;
                case MB_TYPE_FORWARD:
3858 3859 3860 3861 3862
                    s->mv_dir = MV_DIR_FORWARD;
                    s->mb_intra= 0;
                    motion_x= s->mv[0][0][0] = s->b_forw_mv_table[xy][0];
                    motion_y= s->mv[0][0][1] = s->b_forw_mv_table[xy][1];
//                    printf(" %d %d ", motion_x, motion_y);
3863 3864
                    break;
                default:
3865 3866
                    motion_x=motion_y=0; //gcc warning fix
                    printf("illegal MB type\n");
3867
                }
3868

3869
                encode_mb(s, motion_x, motion_y);
3870 3871 3872

                // RAL: Update last macrobloc type
                s->last_mv_dir = s->mv_dir;
3873 3874 3875 3876 3877
            
                if (s->out_format == FMT_H263 && s->pict_type!=B_TYPE)
                    ff_h263_update_motion_val(s);

                MPV_decode_mb(s, s->block);
F
Fabrice Bellard 已提交
3878
            }
3879

3880 3881 3882 3883 3884
            /* clean the MV table in IPS frames for direct mode in B frames */
            if(s->mb_intra /* && I,P,S_TYPE */){
                s->p_mv_table[xy][0]=0;
                s->p_mv_table[xy][1]=0;
            }
3885 3886 3887 3888 3889 3890 3891
            
            if(s->flags&CODEC_FLAG_PSNR){
                int w= 16;
                int h= 16;

                if(s->mb_x*16 + 16 > s->width ) w= s->width - s->mb_x*16;
                if(s->mb_y*16 + 16 > s->height) h= s->height- s->mb_y*16;
M
Michael Niedermayer 已提交
3892

M
10l  
Michael Niedermayer 已提交
3893
                s->current_picture_ptr->error[0] += sse(
3894 3895
                    s, s->new_picture.data[0] + s->mb_x*16 + s->mb_y*s->linesize*16,
                    s->dest[0], w, h, s->linesize);
M
10l  
Michael Niedermayer 已提交
3896
                s->current_picture_ptr->error[1] += sse(
3897 3898
                    s, s->new_picture.data[1] + s->mb_x*8  + s->mb_y*s->uvlinesize*8,
                    s->dest[1], w>>1, h>>1, s->uvlinesize);
M
10l  
Michael Niedermayer 已提交
3899
                s->current_picture_ptr->error[2] += sse(
3900 3901
                    s, s->new_picture    .data[2] + s->mb_x*8  + s->mb_y*s->uvlinesize*8,
                    s->dest[2], w>>1, h>>1, s->uvlinesize);
3902
            }
3903
//printf("MB %d %d bits\n", s->mb_x+s->mb_y*s->mb_stride, get_bit_count(&s->pb));
F
Fabrice Bellard 已提交
3904 3905
        }
    }
3906
    emms_c();
3907

M
Michael Niedermayer 已提交
3908
#ifdef CONFIG_RISKY
3909
    if(s->codec_id==CODEC_ID_MPEG4 && s->partitioned_frame)
3910 3911 3912
        ff_mpeg4_merge_partitions(s);

    if (s->msmpeg4_version && s->msmpeg4_version<4 && s->pict_type == I_TYPE)
M
Michael Niedermayer 已提交
3913 3914
        msmpeg4_encode_ext_header(s);

3915 3916
    if(s->codec_id==CODEC_ID_MPEG4) 
        ff_mpeg4_stuffing(&s->pb);
M
Michael Niedermayer 已提交
3917
#endif
3918

3919 3920
    //if (s->gob_number)
    //    fprintf(stderr,"\nNumber of GOB: %d", s->gob_number);
3921 3922 3923 3924
    
    /* Send the last GOB if RTP */    
    if (s->rtp_mode) {
        flush_put_bits(&s->pb);
3925
        pdif = pbBufPtr(&s->pb) - s->ptr_lastgob;
3926 3927 3928
        /* Call the RTP callback to send the last GOB */
        if (s->rtp_callback)
            s->rtp_callback(s->ptr_lastgob, pdif, s->gob_number);
3929
        s->ptr_lastgob = pbBufPtr(&s->pb);
3930 3931
        //fprintf(stderr,"\nGOB: %2d size: %d (last)", s->gob_number, pdif);
    }
F
Fabrice Bellard 已提交
3932 3933
}

M
Michael Niedermayer 已提交
3934 3935 3936 3937
static int dct_quantize_trellis_c(MpegEncContext *s, 
                        DCTELEM *block, int n,
                        int qscale, int *overflow){
    const int *qmat;
3938
    const uint8_t *scantable= s->intra_scantable.scantable;
M
Michael Niedermayer 已提交
3939 3940 3941 3942 3943 3944
    int max=0;
    unsigned int threshold1, threshold2;
    int bias=0;
    int run_tab[65];
    int level_tab[65];
    int score_tab[65];
3945 3946 3947 3948 3949
    int last_run=0;
    int last_level=0;
    int last_score= 0;
    int last_i= 0;
    int coeff[3][64];
M
Michael Niedermayer 已提交
3950
    int coeff_count[64];
3951
    int lambda, qmul, qadd, start_i, last_non_zero, i;
M
Michael Niedermayer 已提交
3952 3953 3954
    const int esc_length= s->ac_esc_length;
    uint8_t * length;
    uint8_t * last_length;
3955 3956
    int score_limit=0;
    int left_limit= 0;
M
Michael Niedermayer 已提交
3957
        
3958
    s->dsp.fdct (block);
M
Michael Niedermayer 已提交
3959 3960 3961

    qmul= qscale*16;
    qadd= ((qscale-1)|1)*8;
3962

M
Michael Niedermayer 已提交
3963 3964 3965 3966 3967 3968 3969 3970 3971 3972 3973 3974 3975 3976 3977 3978 3979 3980 3981
    if (s->mb_intra) {
        int q;
        if (!s->h263_aic) {
            if (n < 4)
                q = s->y_dc_scale;
            else
                q = s->c_dc_scale;
            q = q << 3;
        } else{
            /* For AIC we skip quant/dequant of INTRADC */
            q = 1 << 3;
            qadd=0;
        }
            
        /* note: block[0] is assumed to be positive */
        block[0] = (block[0] + (q >> 1)) / q;
        start_i = 1;
        last_non_zero = 0;
        qmat = s->q_intra_matrix[qscale];
3982
        if(s->mpeg_quant || s->codec_id== CODEC_ID_MPEG1VIDEO)
M
Michael Niedermayer 已提交
3983 3984 3985 3986 3987 3988 3989 3990 3991 3992 3993 3994 3995
            bias= 1<<(QMAT_SHIFT-1);
        length     = s->intra_ac_vlc_length;
        last_length= s->intra_ac_vlc_last_length;
    } else {
        start_i = 0;
        last_non_zero = -1;
        qmat = s->q_inter_matrix[qscale];
        length     = s->inter_ac_vlc_length;
        last_length= s->inter_ac_vlc_last_length;
    }

    threshold1= (1<<QMAT_SHIFT) - bias - 1;
    threshold2= (threshold1<<1);
3996

M
Michael Niedermayer 已提交
3997 3998 3999 4000 4001 4002 4003 4004 4005 4006 4007 4008 4009
    for(i=start_i; i<64; i++) {
        const int j = scantable[i];
        const int k= i-start_i;
        int level = block[j];
        level = level * qmat[j];

//        if(   bias+level >= (1<<(QMAT_SHIFT - 3))
//           || bias-level >= (1<<(QMAT_SHIFT - 3))){
        if(((unsigned)(level+threshold1))>threshold2){
            if(level>0){
                level= (bias + level)>>QMAT_SHIFT;
                coeff[0][k]= level;
                coeff[1][k]= level-1;
4010
//                coeff[2][k]= level-2;
M
Michael Niedermayer 已提交
4011 4012 4013 4014
            }else{
                level= (bias - level)>>QMAT_SHIFT;
                coeff[0][k]= -level;
                coeff[1][k]= -level+1;
4015
//                coeff[2][k]= -level+2;
M
Michael Niedermayer 已提交
4016
            }
4017
            coeff_count[k]= FFMIN(level, 2);
M
Michael Niedermayer 已提交
4018 4019 4020
            max |=level;
            last_non_zero = i;
        }else{
4021
            coeff[0][k]= (level>>31)|1;
M
Michael Niedermayer 已提交
4022 4023 4024 4025 4026 4027 4028 4029 4030 4031 4032
            coeff_count[k]= 1;
        }
    }
    
    *overflow= s->max_qcoeff < max; //overflow might have happend
    
    if(last_non_zero < start_i){
        memset(block + start_i, 0, (64-start_i)*sizeof(DCTELEM));
        return last_non_zero;
    }

4033
    lambda= (qscale*qscale*64*105 + 64)>>7; //FIXME finetune
M
Michael Niedermayer 已提交
4034
        
4035
    score_tab[0]= 0;
M
Michael Niedermayer 已提交
4036 4037 4038 4039
    for(i=0; i<=last_non_zero - start_i; i++){
        int level_index, run, j;
        const int dct_coeff= block[ scantable[i + start_i] ];
        const int zero_distoration= dct_coeff*dct_coeff;
4040
        int best_score=256*256*256*120;
M
Michael Niedermayer 已提交
4041

4042
        last_score += zero_distoration;
M
Michael Niedermayer 已提交
4043 4044 4045 4046 4047 4048 4049 4050 4051 4052 4053 4054 4055
        for(level_index=0; level_index < coeff_count[i]; level_index++){
            int distoration;
            int level= coeff[level_index][i];
            int unquant_coeff;
            
            assert(level);

            if(s->out_format == FMT_H263){
                if(level>0){
                    unquant_coeff= level*qmul + qadd;
                }else{
                    unquant_coeff= level*qmul - qadd;
                }
4056
            }else{ //MPEG1
4057
                j= s->dsp.idct_permutation[ scantable[i + start_i] ]; //FIXME optimize
4058 4059 4060 4061 4062 4063 4064 4065 4066 4067 4068 4069 4070 4071 4072 4073 4074 4075 4076
                if(s->mb_intra){
                    if (level < 0) {
                        unquant_coeff = (int)((-level) * qscale * s->intra_matrix[j]) >> 3;
                        unquant_coeff = -((unquant_coeff - 1) | 1);
                    } else {
                        unquant_coeff = (int)(  level  * qscale * s->intra_matrix[j]) >> 3;
                        unquant_coeff =   (unquant_coeff - 1) | 1;
                    }
                }else{
                    if (level < 0) {
                        unquant_coeff = ((((-level) << 1) + 1) * qscale * ((int) s->inter_matrix[j])) >> 4;
                        unquant_coeff = -((unquant_coeff - 1) | 1);
                    } else {
                        unquant_coeff = (((  level  << 1) + 1) * qscale * ((int) s->inter_matrix[j])) >> 4;
                        unquant_coeff =   (unquant_coeff - 1) | 1;
                    }
                }
                unquant_coeff<<= 3;
            }
4077

M
Michael Niedermayer 已提交
4078 4079 4080
            distoration= (unquant_coeff - dct_coeff) * (unquant_coeff - dct_coeff);
            level+=64;
            if((level&(~127)) == 0){
4081
                for(run=0; run<=i - left_limit; run++){
4082
                    int score= distoration + length[UNI_AC_ENC_INDEX(run, level)]*lambda;
M
Michael Niedermayer 已提交
4083 4084 4085 4086 4087 4088 4089 4090 4091 4092 4093
                    score += score_tab[i-run];
                    
                    if(score < best_score){
                        best_score= 
                        score_tab[i+1]= score;
                        run_tab[i+1]= run;
                        level_tab[i+1]= level-64;
                    }
                }

                if(s->out_format == FMT_H263){
4094
                    for(run=0; run<=i - left_limit; run++){
4095
                        int score= distoration + last_length[UNI_AC_ENC_INDEX(run, level)]*lambda;
M
Michael Niedermayer 已提交
4096
                        score += score_tab[i-run];
4097 4098 4099 4100 4101
                        if(score < last_score){
                            last_score= score;
                            last_run= run;
                            last_level= level-64;
                            last_i= i+1;
M
Michael Niedermayer 已提交
4102 4103 4104 4105 4106
                        }
                    }
                }
            }else{
                distoration += esc_length*lambda;
4107
                for(run=0; run<=i - left_limit; run++){
M
Michael Niedermayer 已提交
4108 4109 4110 4111 4112 4113 4114 4115 4116 4117 4118
                    int score= distoration + score_tab[i-run];
                    
                    if(score < best_score){
                        best_score= 
                        score_tab[i+1]= score;
                        run_tab[i+1]= run;
                        level_tab[i+1]= level-64;
                    }
                }

                if(s->out_format == FMT_H263){
4119
                    for(run=0; run<=i - left_limit; run++){
M
Michael Niedermayer 已提交
4120
                        int score= distoration + score_tab[i-run];
4121 4122 4123 4124 4125
                        if(score < last_score){
                            last_score= score;
                            last_run= run;
                            last_level= level-64;
                            last_i= i+1;
M
Michael Niedermayer 已提交
4126 4127 4128 4129 4130 4131
                        }
                    }
                }
            }
        }

4132
        for(j=left_limit; j<=i; j++){
M
Michael Niedermayer 已提交
4133 4134
            score_tab[j] += zero_distoration;
        }
4135 4136 4137 4138 4139 4140
        score_limit+= zero_distoration;
        if(score_tab[i+1] < score_limit)
            score_limit= score_tab[i+1];
        
        //Note: there is a vlc code in mpeg4 which is 1 bit shorter then another one with a shorter run and the same level
        while(score_tab[ left_limit ] > score_limit + lambda) left_limit++;
M
Michael Niedermayer 已提交
4141
    }
4142 4143 4144

        //FIXME add some cbp penalty

M
Michael Niedermayer 已提交
4145
    if(s->out_format != FMT_H263){
4146
        last_score= 256*256*256*120;
4147
        for(i= left_limit; i<=last_non_zero - start_i + 1; i++){
4148
            int score= score_tab[i];
4149 4150
            if(i) score += lambda*2; //FIXME exacter?

4151 4152 4153 4154 4155 4156
            if(score < last_score){
                last_score= score;
                last_i= i;
                last_level= level_tab[i];
                last_run= run_tab[i];
            }
M
Michael Niedermayer 已提交
4157 4158 4159
        }
    }
    
4160
    last_non_zero= last_i - 1 + start_i;
M
Michael Niedermayer 已提交
4161 4162 4163 4164 4165
    memset(block + start_i, 0, (64-start_i)*sizeof(DCTELEM));
    
    if(last_non_zero < start_i)
        return last_non_zero;
    
4166 4167
    i= last_i;
    assert(last_level);
M
Michael Niedermayer 已提交
4168
//FIXME use permutated scantable
4169
    block[ s->dsp.idct_permutation[ scantable[last_non_zero] ] ]= last_level;
4170
    i -= last_run + 1;
M
Michael Niedermayer 已提交
4171 4172
    
    for(;i>0 ; i -= run_tab[i] + 1){
4173
        const int j= s->dsp.idct_permutation[ scantable[i - 1 + start_i] ];
M
Michael Niedermayer 已提交
4174 4175 4176 4177 4178 4179 4180 4181
    
        block[j]= level_tab[i];
        assert(block[j]);
    }

    return last_non_zero;
}

M
Michael Niedermayer 已提交
4182
static int dct_quantize_c(MpegEncContext *s, 
F
Fabrice Bellard 已提交
4183
                        DCTELEM *block, int n,
4184
                        int qscale, int *overflow)
F
Fabrice Bellard 已提交
4185 4186 4187
{
    int i, j, level, last_non_zero, q;
    const int *qmat;
4188
    const uint8_t *scantable= s->intra_scantable.scantable;
4189 4190 4191
    int bias;
    int max=0;
    unsigned int threshold1, threshold2;
4192

4193
    s->dsp.fdct (block);
F
Fabrice Bellard 已提交
4194 4195

    if (s->mb_intra) {
4196 4197 4198 4199 4200 4201 4202 4203 4204 4205
        if (!s->h263_aic) {
            if (n < 4)
                q = s->y_dc_scale;
            else
                q = s->c_dc_scale;
            q = q << 3;
        } else
            /* For AIC we skip quant/dequant of INTRADC */
            q = 1 << 3;
            
F
Fabrice Bellard 已提交
4206 4207 4208 4209
        /* note: block[0] is assumed to be positive */
        block[0] = (block[0] + (q >> 1)) / q;
        i = 1;
        last_non_zero = 0;
4210
        qmat = s->q_intra_matrix[qscale];
M
Michael Niedermayer 已提交
4211
        bias= s->intra_quant_bias<<(QMAT_SHIFT - QUANT_BIAS_SHIFT);
F
Fabrice Bellard 已提交
4212 4213 4214
    } else {
        i = 0;
        last_non_zero = -1;
4215
        qmat = s->q_inter_matrix[qscale];
M
Michael Niedermayer 已提交
4216
        bias= s->inter_quant_bias<<(QMAT_SHIFT - QUANT_BIAS_SHIFT);
F
Fabrice Bellard 已提交
4217
    }
M
Michael Niedermayer 已提交
4218 4219
    threshold1= (1<<QMAT_SHIFT) - bias - 1;
    threshold2= (threshold1<<1);
F
Fabrice Bellard 已提交
4220 4221

    for(;i<64;i++) {
M
Michael Niedermayer 已提交
4222
        j = scantable[i];
F
Fabrice Bellard 已提交
4223 4224 4225
        level = block[j];
        level = level * qmat[j];

M
Michael Niedermayer 已提交
4226 4227
//        if(   bias+level >= (1<<QMAT_SHIFT)
//           || bias-level >= (1<<QMAT_SHIFT)){
4228 4229
        if(((unsigned)(level+threshold1))>threshold2){
            if(level>0){
M
Michael Niedermayer 已提交
4230
                level= (bias + level)>>QMAT_SHIFT;
4231 4232
                block[j]= level;
            }else{
M
Michael Niedermayer 已提交
4233
                level= (bias - level)>>QMAT_SHIFT;
4234 4235 4236
                block[j]= -level;
            }
            max |=level;
F
Fabrice Bellard 已提交
4237
            last_non_zero = i;
4238 4239
        }else{
            block[j]=0;
F
Fabrice Bellard 已提交
4240 4241
        }
    }
4242 4243
    *overflow= s->max_qcoeff < max; //overflow might have happend
    
M
Michael Niedermayer 已提交
4244
    /* we need this permutation so that we correct the IDCT, we only permute the !=0 elements */
4245 4246
    if (s->dsp.idct_permutation_type != FF_NO_IDCT_PERM)
	ff_block_permute(block, s->dsp.idct_permutation, scantable, last_non_zero);
M
Michael Niedermayer 已提交
4247

F
Fabrice Bellard 已提交
4248 4249 4250
    return last_non_zero;
}

4251 4252
#endif //CONFIG_ENCODERS

4253 4254
static void dct_unquantize_mpeg1_c(MpegEncContext *s, 
                                   DCTELEM *block, int n, int qscale)
F
Fabrice Bellard 已提交
4255
{
M
Michael Niedermayer 已提交
4256
    int i, level, nCoeffs;
4257
    const uint16_t *quant_matrix;
F
Fabrice Bellard 已提交
4258

4259
    nCoeffs= s->block_last_index[n];
M
Michael Niedermayer 已提交
4260
    
F
Fabrice Bellard 已提交
4261 4262 4263 4264 4265 4266 4267
    if (s->mb_intra) {
        if (n < 4) 
            block[0] = block[0] * s->y_dc_scale;
        else
            block[0] = block[0] * s->c_dc_scale;
        /* XXX: only mpeg1 */
        quant_matrix = s->intra_matrix;
4268 4269
        for(i=1;i<=nCoeffs;i++) {
            int j= s->intra_scantable.permutated[i];
M
Michael Niedermayer 已提交
4270
            level = block[j];
F
Fabrice Bellard 已提交
4271 4272 4273
            if (level) {
                if (level < 0) {
                    level = -level;
M
Michael Niedermayer 已提交
4274
                    level = (int)(level * qscale * quant_matrix[j]) >> 3;
F
Fabrice Bellard 已提交
4275 4276 4277
                    level = (level - 1) | 1;
                    level = -level;
                } else {
M
Michael Niedermayer 已提交
4278
                    level = (int)(level * qscale * quant_matrix[j]) >> 3;
F
Fabrice Bellard 已提交
4279 4280 4281 4282 4283 4284
                    level = (level - 1) | 1;
                }
#ifdef PARANOID
                if (level < -2048 || level > 2047)
                    fprintf(stderr, "unquant error %d %d\n", i, level);
#endif
M
Michael Niedermayer 已提交
4285
                block[j] = level;
F
Fabrice Bellard 已提交
4286 4287 4288 4289
            }
        }
    } else {
        i = 0;
4290
        quant_matrix = s->inter_matrix;
4291 4292
        for(;i<=nCoeffs;i++) {
            int j= s->intra_scantable.permutated[i];
M
Michael Niedermayer 已提交
4293
            level = block[j];
F
Fabrice Bellard 已提交
4294 4295 4296 4297
            if (level) {
                if (level < 0) {
                    level = -level;
                    level = (((level << 1) + 1) * qscale *
M
Michael Niedermayer 已提交
4298
                             ((int) (quant_matrix[j]))) >> 4;
F
Fabrice Bellard 已提交
4299 4300 4301 4302
                    level = (level - 1) | 1;
                    level = -level;
                } else {
                    level = (((level << 1) + 1) * qscale *
M
Michael Niedermayer 已提交
4303
                             ((int) (quant_matrix[j]))) >> 4;
F
Fabrice Bellard 已提交
4304 4305 4306 4307 4308 4309
                    level = (level - 1) | 1;
                }
#ifdef PARANOID
                if (level < -2048 || level > 2047)
                    fprintf(stderr, "unquant error %d %d\n", i, level);
#endif
M
Michael Niedermayer 已提交
4310
                block[j] = level;
F
Fabrice Bellard 已提交
4311 4312 4313 4314
            }
        }
    }
}
4315

4316 4317 4318 4319
static void dct_unquantize_mpeg2_c(MpegEncContext *s, 
                                   DCTELEM *block, int n, int qscale)
{
    int i, level, nCoeffs;
4320
    const uint16_t *quant_matrix;
4321

4322 4323
    if(s->alternate_scan) nCoeffs= 63;
    else nCoeffs= s->block_last_index[n];
4324 4325 4326 4327 4328 4329 4330
    
    if (s->mb_intra) {
        if (n < 4) 
            block[0] = block[0] * s->y_dc_scale;
        else
            block[0] = block[0] * s->c_dc_scale;
        quant_matrix = s->intra_matrix;
4331 4332
        for(i=1;i<=nCoeffs;i++) {
            int j= s->intra_scantable.permutated[i];
4333 4334 4335 4336 4337 4338 4339 4340 4341 4342 4343 4344 4345 4346 4347 4348 4349 4350 4351
            level = block[j];
            if (level) {
                if (level < 0) {
                    level = -level;
                    level = (int)(level * qscale * quant_matrix[j]) >> 3;
                    level = -level;
                } else {
                    level = (int)(level * qscale * quant_matrix[j]) >> 3;
                }
#ifdef PARANOID
                if (level < -2048 || level > 2047)
                    fprintf(stderr, "unquant error %d %d\n", i, level);
#endif
                block[j] = level;
            }
        }
    } else {
        int sum=-1;
        i = 0;
4352
        quant_matrix = s->inter_matrix;
4353 4354
        for(;i<=nCoeffs;i++) {
            int j= s->intra_scantable.permutated[i];
4355 4356 4357 4358 4359 4360 4361 4362 4363 4364 4365 4366 4367 4368 4369 4370 4371 4372 4373 4374 4375 4376 4377 4378
            level = block[j];
            if (level) {
                if (level < 0) {
                    level = -level;
                    level = (((level << 1) + 1) * qscale *
                             ((int) (quant_matrix[j]))) >> 4;
                    level = -level;
                } else {
                    level = (((level << 1) + 1) * qscale *
                             ((int) (quant_matrix[j]))) >> 4;
                }
#ifdef PARANOID
                if (level < -2048 || level > 2047)
                    fprintf(stderr, "unquant error %d %d\n", i, level);
#endif
                block[j] = level;
                sum+=level;
            }
        }
        block[63]^=sum&1;
    }
}


4379 4380 4381 4382
static void dct_unquantize_h263_c(MpegEncContext *s, 
                                  DCTELEM *block, int n, int qscale)
{
    int i, level, qmul, qadd;
M
Michael Niedermayer 已提交
4383
    int nCoeffs;
4384
    
4385 4386 4387 4388 4389
    assert(s->block_last_index[n]>=0);
    
    qadd = (qscale - 1) | 1;
    qmul = qscale << 1;
    
4390
    if (s->mb_intra) {
4391 4392 4393 4394 4395
        if (!s->h263_aic) {
            if (n < 4) 
                block[0] = block[0] * s->y_dc_scale;
            else
                block[0] = block[0] * s->c_dc_scale;
4396 4397
        }else
            qadd = 0;
4398
        i = 1;
4399
        nCoeffs= 63; //does not allways use zigzag table 
4400 4401
    } else {
        i = 0;
4402
        nCoeffs= s->inter_scantable.raster_end[ s->block_last_index[n] ];
4403 4404
    }

4405
    for(;i<=nCoeffs;i++) {
4406 4407 4408 4409 4410 4411 4412 4413 4414 4415 4416 4417 4418 4419 4420
        level = block[i];
        if (level) {
            if (level < 0) {
                level = level * qmul - qadd;
            } else {
                level = level * qmul + qadd;
            }
#ifdef PARANOID
                if (level < -2048 || level > 2047)
                    fprintf(stderr, "unquant error %d %d\n", i, level);
#endif
            block[i] = level;
        }
    }
}
F
Fabrice Bellard 已提交
4421

4422

4423 4424 4425 4426 4427 4428 4429 4430 4431 4432 4433 4434 4435 4436
static const AVOption mpeg4_options[] =
{
    AVOPTION_CODEC_INT("bitrate", "desired video bitrate", bit_rate, 4, 240000000, 800000),
    AVOPTION_CODEC_INT("ratetol", "number of bits the bitstream is allowed to diverge from the reference"
		       "the reference can be CBR (for CBR pass1) or VBR (for pass2)",
		       bit_rate_tolerance, 4, 240000000, 8000),
    AVOPTION_CODEC_INT("qmin", "minimum quantizer", qmin, 1, 31, 2),
    AVOPTION_CODEC_INT("qmax", "maximum quantizer", qmax, 1, 31, 31),
    AVOPTION_CODEC_STRING("rc_eq", "rate control equation",
			  rc_eq, "tex^qComp,option1,options2", 0),
    AVOPTION_CODEC_INT("rc_minrate", "rate control minimum bitrate",
		       rc_min_rate, 4, 24000000, 0),
    AVOPTION_CODEC_INT("rc_maxrate", "rate control maximum bitrate",
		       rc_max_rate, 4, 24000000, 0),
Z
Zdenek Kabelac 已提交
4437 4438 4439 4440 4441 4442 4443 4444 4445 4446 4447 4448 4449 4450 4451 4452 4453 4454 4455 4456 4457 4458 4459 4460 4461 4462 4463 4464 4465 4466 4467 4468 4469 4470 4471 4472 4473 4474 4475 4476 4477 4478 4479 4480 4481 4482 4483 4484 4485 4486 4487 4488
    AVOPTION_CODEC_DOUBLE("rc_buf_aggresivity", "rate control buffer aggresivity",
			  rc_buffer_aggressivity, 4, 24000000, 0),
    AVOPTION_CODEC_DOUBLE("rc_initial_cplx", "initial complexity for pass1 ratecontrol",
			  rc_initial_cplx, 0., 9999999., 0),
    AVOPTION_CODEC_DOUBLE("i_quant_factor", "qscale factor between p and i frames",
			  i_quant_factor, 0., 0., 0),
    AVOPTION_CODEC_DOUBLE("i_quant_offset", "qscale offset between p and i frames",
			  i_quant_factor, -999999., 999999., 0),
    AVOPTION_CODEC_INT("dct_algo", "dct alghorithm",
		       dct_algo, 0, 5, 0), // fixme - "Auto,FastInt,Int,MMX,MLib,Altivec"
    AVOPTION_CODEC_DOUBLE("lumi_masking", "luminance masking",
			  lumi_masking, 0., 999999., 0),
    AVOPTION_CODEC_DOUBLE("temporal_cplx_masking", "temporary complexity masking",
			  temporal_cplx_masking, 0., 999999., 0),
    AVOPTION_CODEC_DOUBLE("spatial_cplx_masking", "spatial complexity masking",
			  spatial_cplx_masking, 0., 999999., 0),
    AVOPTION_CODEC_DOUBLE("p_masking", "p block masking",
			  p_masking, 0., 999999., 0),
    AVOPTION_CODEC_DOUBLE("dark_masking", "darkness masking",
			  dark_masking, 0., 999999., 0),
    AVOPTION_CODEC_INT("idct_algo", "idct alghorithm",
		       idct_algo, 0, 8, 0), // fixme - "Auto,Int,Simple,SimpleMMX,LibMPEG2MMX,PS2,MLib,ARM,Altivec"

    AVOPTION_CODEC_INT("mb_qmin", "minimum MB quantizer",
		       mb_qmin, 0, 8, 0),
    AVOPTION_CODEC_INT("mb_qmax", "maximum MB quantizer",
		       mb_qmin, 0, 8, 0),

    AVOPTION_CODEC_INT("me_cmp", "ME compare function",
		       me_cmp, 0, 24000000, 0),
    AVOPTION_CODEC_INT("me_sub_cmp", "subpixel ME compare function",
		       me_sub_cmp, 0, 24000000, 0),


    AVOPTION_CODEC_INT("dia_size", "ME diamond size & shape",
		       dia_size, 0, 24000000, 0),
    AVOPTION_CODEC_INT("last_predictor_count", "amount of previous MV predictors",
		       last_predictor_count, 0, 24000000, 0),

    AVOPTION_CODEC_INT("pre_me", "pre pass for ME",
		       pre_me, 0, 24000000, 0),
    AVOPTION_CODEC_INT("me_pre_cmp", "ME pre pass compare function",
		       me_pre_cmp, 0, 24000000, 0),

    AVOPTION_CODEC_INT("me_range", "maximum ME search range",
		       me_range, 0, 24000000, 0),
    AVOPTION_CODEC_INT("pre_dia_size", "ME pre pass diamod size & shape",
		       pre_dia_size, 0, 24000000, 0),
    AVOPTION_CODEC_INT("me_subpel_quality", "subpel ME quality",
		       me_subpel_quality, 0, 24000000, 0),
    AVOPTION_CODEC_INT("me_range", "maximum ME search range",
		       me_range, 0, 24000000, 0),
4489 4490 4491 4492
    AVOPTION_CODEC_FLAG("psnr", "calculate PSNR of compressed frames",
		        flags, CODEC_FLAG_PSNR, 0),
    AVOPTION_CODEC_RCOVERRIDE("rc_override", "ratecontrol override (=startframe,endframe,qscale,quality_factor)",
			      rc_override),
4493
    AVOPTION_SUB(avoptions_common),
4494 4495 4496
    AVOPTION_END()
};

4497 4498
#ifdef CONFIG_ENCODERS

F
Fabrice Bellard 已提交
4499 4500 4501 4502 4503 4504 4505 4506 4507 4508
AVCodec mpeg1video_encoder = {
    "mpeg1video",
    CODEC_TYPE_VIDEO,
    CODEC_ID_MPEG1VIDEO,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
};

M
Michael Niedermayer 已提交
4509 4510
#ifdef CONFIG_RISKY

F
Fabrice Bellard 已提交
4511 4512 4513 4514 4515 4516 4517 4518 4519 4520 4521 4522 4523 4524 4525 4526 4527 4528 4529 4530
AVCodec h263_encoder = {
    "h263",
    CODEC_TYPE_VIDEO,
    CODEC_ID_H263,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
};

AVCodec h263p_encoder = {
    "h263p",
    CODEC_TYPE_VIDEO,
    CODEC_ID_H263P,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
};

4531 4532 4533 4534 4535 4536 4537 4538 4539 4540
AVCodec flv_encoder = {
    "flv",
    CODEC_TYPE_VIDEO,
    CODEC_ID_FLV1,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
};

F
Fabrice Bellard 已提交
4541 4542 4543 4544 4545 4546 4547 4548 4549 4550
AVCodec rv10_encoder = {
    "rv10",
    CODEC_TYPE_VIDEO,
    CODEC_ID_RV10,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
};

F
Fabrice Bellard 已提交
4551 4552
AVCodec mpeg4_encoder = {
    "mpeg4",
F
Fabrice Bellard 已提交
4553
    CODEC_TYPE_VIDEO,
F
Fabrice Bellard 已提交
4554
    CODEC_ID_MPEG4,
F
Fabrice Bellard 已提交
4555 4556 4557 4558
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
4559
    .options = mpeg4_options,
F
Fabrice Bellard 已提交
4560 4561
};

4562 4563 4564 4565 4566 4567 4568 4569
AVCodec msmpeg4v1_encoder = {
    "msmpeg4v1",
    CODEC_TYPE_VIDEO,
    CODEC_ID_MSMPEG4V1,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
Z
Zdenek Kabelac 已提交
4570
    .options = mpeg4_options,
4571 4572 4573 4574 4575 4576 4577 4578 4579 4580
};

AVCodec msmpeg4v2_encoder = {
    "msmpeg4v2",
    CODEC_TYPE_VIDEO,
    CODEC_ID_MSMPEG4V2,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
Z
Zdenek Kabelac 已提交
4581
    .options = mpeg4_options,
4582 4583 4584
};

AVCodec msmpeg4v3_encoder = {
F
Fabrice Bellard 已提交
4585 4586
    "msmpeg4",
    CODEC_TYPE_VIDEO,
4587
    CODEC_ID_MSMPEG4V3,
F
Fabrice Bellard 已提交
4588 4589 4590 4591
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
Z
Zdenek Kabelac 已提交
4592
    .options = mpeg4_options,
F
Fabrice Bellard 已提交
4593
};
M
Michael Niedermayer 已提交
4594 4595 4596 4597 4598 4599 4600 4601 4602

AVCodec wmv1_encoder = {
    "wmv1",
    CODEC_TYPE_VIDEO,
    CODEC_ID_WMV1,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
Z
Zdenek Kabelac 已提交
4603
    .options = mpeg4_options,
M
Michael Niedermayer 已提交
4604 4605
};

M
Michael Niedermayer 已提交
4606 4607 4608 4609 4610 4611 4612 4613 4614 4615 4616
#endif

AVCodec mjpeg_encoder = {
    "mjpeg",
    CODEC_TYPE_VIDEO,
    CODEC_ID_MJPEG,
    sizeof(MpegEncContext),
    MPV_encode_init,
    MPV_encode_picture,
    MPV_encode_end,
};
4617 4618 4619

#endif //CONFIG_ENCODERS