git.sesse.net Git - vlc/blob - modules/codec/libmpeg2.c

   1 /*****************************************************************************
   2  * libmpeg2.c: mpeg2 video decoder module making use of libmpeg2.
   3  *****************************************************************************
   4  * Copyright (C) 1999-2001 VideoLAN
   5  * $Id: libmpeg2.c,v 1.16 2003/05/04 01:36:20 massiot Exp $
   6  *
   7  * Authors: Gildas Bazin <gbazin@netcourrier.com>
   8  *
   9  * This program is free software; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
  22  *****************************************************************************/
  23
  24 /*****************************************************************************
  25  * Preamble
  26  *****************************************************************************/
  27 #include <vlc/vlc.h>
  28 #include <vlc/vout.h>
  29 #include <vlc/input.h>
  30 #include <vlc/decoder.h>
  31
  32 #include <stdlib.h>                                      /* malloc(), free() */
  33 #include <string.h>                                    /* memcpy(), memset() */
  34
  35 #include <mpeg2dec/mpeg2.h>
  36
  37 #include "vout_synchro.h"
  38
  39 /* Aspect ratio (ISO/IEC 13818-2 section 6.3.3, table 6-3) */
  40 #define AR_SQUARE_PICTURE       1                           /* square pixels */
  41 #define AR_3_4_PICTURE          2                        /* 3:4 picture (TV) */
  42 #define AR_16_9_PICTURE         3              /* 16:9 picture (wide screen) */
  43 #define AR_221_1_PICTURE        4                  /* 2.21:1 picture (movie) */
  44
  45 /*****************************************************************************
  46  * dec_thread_t : libmpeg2 decoder thread descriptor
  47  *****************************************************************************/
  48 typedef struct dec_thread_t
  49 {
  50     /*
  51      * libmpeg2 properties
  52      */
  53     mpeg2dec_t          *p_mpeg2dec;
  54     const mpeg2_info_t  *p_info;
  55
  56     /*
  57      * Input properties
  58      */
  59     decoder_fifo_t   *p_fifo;                  /* stores the PES stream data */
  60     pes_packet_t     *p_pes;                  /* current PES we are decoding */
  61     mtime_t          i_pts;
  62     mtime_t          i_previous_pts;
  63     mtime_t          i_current_pts;
  64     mtime_t          i_period_remainder;
  65     int              i_current_rate;
  66     picture_t *      p_picture_to_destroy;
  67
  68     /*
  69      * Output properties
  70      */
  71     vout_thread_t *p_vout;
  72     vout_synchro_t *p_synchro;
  73
  74 } dec_thread_t;
  75
  76 /*****************************************************************************
  77  * Local prototypes
  78  *****************************************************************************/
  79 static int  OpenDecoder  ( vlc_object_t * );
  80 static int  RunDecoder   ( decoder_fifo_t * );
  81 static void CloseDecoder ( dec_thread_t * );
  82
  83 static picture_t *GetNewPicture( dec_thread_t *, uint8_t ** );
  84
  85 /*****************************************************************************
  86  * Module descriptor
  87  *****************************************************************************/
  88 vlc_module_begin();
  89     set_description( _("MPEG I/II video decoder (using libmpeg2)") );
  90     set_capability( "decoder", 40 );
  91     set_callbacks( OpenDecoder, NULL );
  92     add_shortcut( "libmpeg2" );
  93 vlc_module_end();
  94
  95 /*****************************************************************************
  96  * OpenDecoder: probe the decoder and return score
  97  *****************************************************************************/
  98 static int OpenDecoder( vlc_object_t *p_this )
  99 {
 100     decoder_fifo_t *p_fifo = (decoder_fifo_t*) p_this;
 101
 102     if( p_fifo->i_fourcc != VLC_FOURCC('m','p','g','v') )
 103     {
 104         return VLC_EGENERIC;
 105     }
 106
 107     p_fifo->pf_run = RunDecoder;
 108     return VLC_SUCCESS;
 109 }
 110
 111 /*****************************************************************************
 112  * RunDecoder: the libmpeg2 decoder
 113  *****************************************************************************/
 114 static int RunDecoder( decoder_fifo_t *p_fifo )
 115 {
 116     dec_thread_t    *p_dec;
 117     data_packet_t   *p_data = NULL;
 118     mpeg2_state_t   state;
 119     picture_t       *p_pic;
 120     int             i_aspect, i_chroma;
 121
 122     /* Allocate the memory needed to store the thread's structure */
 123     if( (p_dec = (dec_thread_t *)malloc (sizeof(dec_thread_t)) )
 124         == NULL)
 125     {
 126         msg_Err( p_fifo, "out of memory" );
 127         goto error;
 128     }
 129
 130     /* Initialize the thread properties */
 131     memset( p_dec, 0, sizeof(dec_thread_t) );
 132     p_dec->p_fifo     = p_fifo;
 133     p_dec->p_pes      = NULL;
 134     p_dec->p_vout     = NULL;
 135     p_dec->p_mpeg2dec = NULL;
 136     p_dec->p_synchro  = NULL;
 137     p_dec->p_info     = NULL;
 138     p_dec->i_pts      = mdate() + DEFAULT_PTS_DELAY;
 139     p_dec->i_current_pts  = 0;
 140     p_dec->i_previous_pts = 0;
 141     p_dec->i_period_remainder = 0;
 142     p_dec->p_picture_to_destroy = NULL;
 143
 144     /* Initialize decoder */
 145     p_dec->p_mpeg2dec = mpeg2_init();
 146     if( p_dec->p_mpeg2dec == NULL)
 147         goto error;
 148
 149     p_dec->p_info = mpeg2_info( p_dec->p_mpeg2dec );
 150
 151     /* libmpeg2 decoder thread's main loop */
 152     while( (!p_dec->p_fifo->b_die) && (!p_dec->p_fifo->b_error) )
 153     {
 154         state = mpeg2_parse( p_dec->p_mpeg2dec );
 155
 156         switch( state )
 157         {
 158         case STATE_BUFFER:
 159             /* Feed libmpeg2 a data packet at a time */
 160             if( p_data == NULL )
 161             {
 162                 /* Get the next PES */
 163                 if( p_dec->p_pes )
 164                     input_DeletePES( p_dec->p_fifo->p_packets_mgt,
 165                                      p_dec->p_pes );
 166
 167                 input_ExtractPES( p_dec->p_fifo, &p_dec->p_pes );
 168                 if( !p_dec->p_pes )
 169                 {
 170                     p_dec->p_fifo->b_error = 1;
 171                     break;
 172                 }
 173
 174                 if( p_dec->p_pes->b_discontinuity && p_dec->p_synchro )
 175                 {
 176                     vout_SynchroReset( p_dec->p_synchro );
 177                     if ( p_dec->p_info->current_fbuf != NULL )
 178                         p_dec->p_picture_to_destroy
 179                             = p_dec->p_info->current_fbuf->id;
 180                 }
 181
 182                 if( p_dec->p_pes->i_pts )
 183                 {
 184                     mpeg2_pts( p_dec->p_mpeg2dec,
 185                                (uint32_t)p_dec->p_pes->i_pts );
 186                     p_dec->i_previous_pts = p_dec->i_current_pts;
 187                     p_dec->i_current_pts = p_dec->p_pes->i_pts;
 188                 }
 189
 190                 p_dec->i_current_rate = p_dec->p_pes->i_rate;
 191                 p_data = p_dec->p_pes->p_first;
 192             }
 193
 194             if( p_data != NULL )
 195             {
 196                 mpeg2_buffer( p_dec->p_mpeg2dec,
 197                               p_data->p_payload_start,
 198                               p_data->p_payload_end );
 199
 200                 p_data = p_data->p_next;
 201             }
 202             break;
 203
 204         case STATE_SEQUENCE:
 205         {
 206             /* Initialize video output */
 207             uint8_t *buf[3];
 208             buf[0] = buf[1] = buf[2] = NULL;
 209
 210             /* Check whether the input gives a particular aspect ratio */
 211             if( p_dec->p_fifo->p_demux_data
 212                 && ( *(int*)(p_dec->p_fifo->p_demux_data) & 0x7 ) )
 213             {
 214                 i_aspect = *(int*)(p_dec->p_fifo->p_demux_data);
 215                 switch( i_aspect )
 216                 {
 217                 case AR_3_4_PICTURE:
 218                     i_aspect = VOUT_ASPECT_FACTOR * 4 / 3;
 219                     break;
 220                 case AR_16_9_PICTURE:
 221                     i_aspect = VOUT_ASPECT_FACTOR * 16 / 9;
 222                     break;
 223                 case AR_221_1_PICTURE:
 224                     i_aspect = VOUT_ASPECT_FACTOR * 221 / 100;
 225                     break;
 226                 case AR_SQUARE_PICTURE:
 227                 default:
 228                     i_aspect = VOUT_ASPECT_FACTOR *
 229                                    p_dec->p_info->sequence->width /
 230                                    p_dec->p_info->sequence->height;
 231                     break;
 232                 }
 233             }
 234             else
 235             {
 236                 /* Use the value provided in the MPEG sequence header */
 237                 i_aspect = ((uint64_t)p_dec->p_info->sequence->display_width) *
 238                     p_dec->p_info->sequence->pixel_width * VOUT_ASPECT_FACTOR /
 239                     p_dec->p_info->sequence->display_height /
 240                     p_dec->p_info->sequence->pixel_height;
 241             }
 242
 243             i_chroma = VLC_FOURCC('Y','V','1','2');
 244
 245             p_dec->p_vout = vout_Request( p_dec->p_fifo, p_dec->p_vout,
 246                                           p_dec->p_info->sequence->width,
 247                                           p_dec->p_info->sequence->height,
 248                                           i_chroma, i_aspect );
 249
 250             msg_Dbg( p_dec->p_fifo, "%dx%d, aspect %d, %u.%03u fps",
 251                      p_dec->p_info->sequence->width,
 252                      p_dec->p_info->sequence->height, i_aspect,
 253                      (u32)((u64)1001000000 * 27 / p_dec->p_info->sequence->frame_period / 1001),
 254                      (u32)((u64)1001000000 * 27 / p_dec->p_info->sequence->frame_period % 1001) );
 255
 256             mpeg2_custom_fbuf( p_dec->p_mpeg2dec, 1 );
 257
 258             /* Set the first 2 reference frames */
 259             mpeg2_set_buf( p_dec->p_mpeg2dec, buf, NULL );
 260             mpeg2_set_buf( p_dec->p_mpeg2dec, buf, NULL );
 261
 262             p_dec->p_synchro = vout_SynchroInit( p_dec->p_fifo, p_dec->p_vout,
 263                 (u32)((u64)1001000000 * 27 / p_dec->p_info->sequence->frame_period) );
 264         }
 265         break;
 266
 267         case STATE_PICTURE:
 268         {
 269             uint8_t *buf[3];
 270             buf[0] = buf[1] = buf[2] = NULL;
 271
 272             vout_SynchroNewPicture( p_dec->p_synchro,
 273                 p_dec->p_info->current_picture->flags & PIC_MASK_CODING_TYPE,
 274                 p_dec->p_info->current_picture->nb_fields,
 275                 (p_dec->p_info->current_picture->flags & PIC_FLAG_PTS) ?
 276                     ( (p_dec->p_info->current_picture->pts ==
 277                                 (uint32_t)p_dec->i_current_pts) ?
 278                               p_dec->i_current_pts : p_dec->i_previous_pts ) : 0,
 279                 0,
 280                 p_dec->i_current_rate );
 281
 282             if ( !vout_SynchroChoose( p_dec->p_synchro,
 283                 p_dec->p_info->current_picture->flags & PIC_MASK_CODING_TYPE ) )
 284             {
 285                 mpeg2_skip( p_dec->p_mpeg2dec, 1 );
 286                 vout_SynchroTrash( p_dec->p_synchro );
 287                 mpeg2_set_buf( p_dec->p_mpeg2dec, buf, NULL );
 288             }
 289             else
 290             {
 291                 mpeg2_skip( p_dec->p_mpeg2dec, 0 );
 292                 vout_SynchroDecode( p_dec->p_synchro );
 293                 if( (p_pic = GetNewPicture( p_dec, buf )) == NULL ) break;
 294                 mpeg2_set_buf( p_dec->p_mpeg2dec, buf, p_pic );
 295             }
 296         }
 297         break;
 298
 299         case STATE_END:
 300         case STATE_SLICE:
 301             if( p_dec->p_info->display_fbuf
 302                 && p_dec->p_info->display_fbuf->id )
 303             {
 304                 p_pic = (picture_t *)p_dec->p_info->display_fbuf->id;
 305
 306                 if ( p_pic != NULL )
 307                 {
 308                     if ( p_dec->p_picture_to_destroy != p_pic )
 309                     {
 310                         vout_SynchroEnd( p_dec->p_synchro,
 311                             p_dec->p_info->display_picture->flags
 312                              & PIC_MASK_CODING_TYPE,
 313                             0 );
 314                         vout_DatePicture( p_dec->p_vout, p_pic,
 315                             vout_SynchroDate( p_dec->p_synchro ) );
 316                         vout_DisplayPicture( p_dec->p_vout, p_pic );
 317                     }
 318                     else
 319                     {
 320                         p_dec->p_picture_to_destroy = NULL;
 321                         vout_SynchroEnd( p_dec->p_synchro,
 322                             p_dec->p_info->display_picture->flags
 323                              & PIC_MASK_CODING_TYPE,
 324                             1 );
 325                         vout_DatePicture( p_dec->p_vout, p_pic, 0 );
 326                         vout_DisplayPicture( p_dec->p_vout, p_pic );
 327                     }
 328                 }
 329             }
 330
 331             if( p_dec->p_info->discard_fbuf &&
 332                 p_dec->p_info->discard_fbuf->id )
 333             {
 334                 p_pic = (picture_t *)p_dec->p_info->discard_fbuf->id;
 335                 vout_UnlinkPicture( p_dec->p_vout, p_pic );
 336             }
 337             break;
 338
 339         case STATE_INVALID:
 340         {
 341             uint8_t *buf[3];
 342             buf[0] = buf[1] = buf[2] = NULL;
 343
 344             msg_Warn( p_dec->p_fifo, "invalid picture encountered" );
 345             if ( (p_dec->p_info->current_picture->flags & PIC_MASK_CODING_TYPE)
 346                   != B_CODING_TYPE )
 347             {
 348                 vout_SynchroReset( p_dec->p_synchro );
 349             }
 350             mpeg2_skip( p_dec->p_mpeg2dec, 1 );
 351
 352             if( p_dec->p_info->current_fbuf &&
 353                 p_dec->p_info->current_fbuf->id )
 354             {
 355                 p_pic = (picture_t *)p_dec->p_info->current_fbuf->id;
 356                 vout_UnlinkPicture( p_dec->p_vout, p_pic );
 357                 vout_DestroyPicture( p_dec->p_vout, p_pic );
 358             }
 359             mpeg2_set_buf( p_dec->p_mpeg2dec, buf, NULL );
 360             break;
 361         }
 362
 363         default:
 364             break;
 365         }
 366     }
 367
 368     /* If b_error is set, the libmpeg2 decoder thread enters the error loop */
 369     if( p_dec->p_fifo->b_error )
 370     {
 371         DecoderError( p_dec->p_fifo );
 372     }
 373
 374     /* End of the libmpeg2 decoder thread */
 375     CloseDecoder( p_dec );
 376
 377     return 0;
 378
 379  error:
 380     DecoderError( p_fifo );
 381     if( p_dec )
 382     {
 383         if( p_dec->p_fifo )
 384             p_dec->p_fifo->b_error = 1;
 385
 386         /* End of the libmpeg2 decoder thread */
 387         CloseDecoder( p_dec );
 388     }
 389
 390     return -1;
 391 }
 392
 393 /*****************************************************************************
 394  * CloseDecoder: libmpeg2 decoder destruction
 395  *****************************************************************************/
 396 static void CloseDecoder( dec_thread_t * p_dec )
 397 {
 398     if( p_dec )
 399     {
 400         int i_pic;
 401
 402         if( p_dec->p_pes )
 403             input_DeletePES( p_dec->p_fifo->p_packets_mgt, p_dec->p_pes );
 404
 405         if( p_dec->p_vout )
 406         {
 407             /* Temporary hack to free the pictures in use by libmpeg2 */
 408             for( i_pic = 0; i_pic < p_dec->p_vout->render.i_pictures; i_pic++ )
 409             {
 410                 if( p_dec->p_vout->render.pp_picture[i_pic]->i_status ==
 411                       RESERVED_PICTURE )
 412                     vout_DestroyPicture( p_dec->p_vout,
 413                                      p_dec->p_vout->render.pp_picture[i_pic] );
 414                 if( p_dec->p_vout->render.pp_picture[i_pic]->i_refcount > 0 )
 415                     vout_UnlinkPicture( p_dec->p_vout,
 416                                      p_dec->p_vout->render.pp_picture[i_pic] );
 417             }
 418
 419             vout_Request( p_dec->p_fifo, p_dec->p_vout, 0, 0, 0, 0 );
 420         }
 421
 422         if( p_dec->p_synchro )
 423             vout_SynchroRelease( p_dec->p_synchro );
 424
 425         if( p_dec->p_mpeg2dec ) mpeg2_close( p_dec->p_mpeg2dec );
 426
 427         free( p_dec );
 428     }
 429 }
 430
 431 /*****************************************************************************
 432  * GetNewPicture: Get a new picture from the vout and set the buf struct
 433  *****************************************************************************/
 434 static picture_t *GetNewPicture( dec_thread_t *p_dec, uint8_t **pp_buf )
 435 {
 436     picture_t *p_pic;
 437
 438     /* Get a new picture */
 439     while( !(p_pic = vout_CreatePicture( p_dec->p_vout, 0, 0, 0 ) ) )
 440     {
 441         if( p_dec->p_fifo->b_die || p_dec->p_fifo->b_error )
 442             break;
 443
 444         msleep( VOUT_OUTMEM_SLEEP );
 445     }
 446     if( p_pic == NULL )
 447         return NULL;
 448     vout_LinkPicture( p_dec->p_vout, p_pic );
 449
 450     pp_buf[0] = p_pic->p[0].p_pixels;
 451     pp_buf[1] = p_pic->p[1].p_pixels;
 452     pp_buf[2] = p_pic->p[2].p_pixels;
 453
 454     return p_pic;
 455 }