]> git.sesse.net Git - vlc/blobdiff - modules/codec/libmpeg2.c
* modules/*: sanitization of the modules description strings.
[vlc] / modules / codec / libmpeg2.c
index 875cf0d4be4ff57b1d546654f3d9afd2938840ee..80d33e0dd6cf1b1b97ca198c39781c56dd1e1c30 100755 (executable)
-/*****************************************************************************\r
- * libmpeg2.c: mpeg2 video decoder module making use of libmpeg2.\r
- *****************************************************************************\r
- * Copyright (C) 1999-2001 VideoLAN\r
- * $Id: libmpeg2.c,v 1.5 2003/03/26 22:56:39 gbazin Exp $\r
- *\r
- * Authors: Gildas Bazin <gbazin@netcourrier.com>\r
- *\r
- * This program is free software; you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation; either version 2 of the License, or\r
- * (at your option) any later version.\r
- * \r
- * This program is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program; if not, write to the Free Software\r
- * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.\r
- *****************************************************************************/\r
-\r
-/*****************************************************************************\r
- * Preamble\r
- *****************************************************************************/\r
-#include <vlc/vlc.h>\r
-#include <vlc/vout.h>\r
-#include <vlc/input.h>\r
-#include <vlc/decoder.h>\r
-\r
-#include <stdlib.h>                                      /* malloc(), free() */\r
-#include <string.h>                                    /* memcpy(), memset() */\r
-\r
-#include <mpeg2dec/mpeg2.h>\r
-\r
-/* Aspect ratio (ISO/IEC 13818-2 section 6.3.3, table 6-3) */\r
-#define AR_SQUARE_PICTURE       1                           /* square pixels */\r
-#define AR_3_4_PICTURE          2                        /* 3:4 picture (TV) */\r
-#define AR_16_9_PICTURE         3              /* 16:9 picture (wide screen) */\r
-#define AR_221_1_PICTURE        4                  /* 2.21:1 picture (movie) */\r
-\r
-/*****************************************************************************\r
- * dec_thread_t : libmpeg2 decoder thread descriptor\r
- *****************************************************************************/\r
-typedef struct dec_thread_t\r
-{\r
-    /*\r
-     * libmpeg2 properties\r
-     */\r
-    mpeg2dec_t          *p_mpeg2dec;\r
-    const mpeg2_info_t  *p_info;\r
-\r
-    /*\r
-     * Input properties\r
-     */\r
-    decoder_fifo_t   *p_fifo;                  /* stores the PES stream data */\r
-    pes_packet_t     *p_pes;                  /* current PES we are decoding */\r
-    mtime_t          i_pts;\r
-    mtime_t          i_previous_pts;\r
-    mtime_t          i_current_pts;\r
-    mtime_t          i_period_remainder;\r
-\r
-    /*\r
-     * Output properties\r
-     */\r
-    vout_thread_t *p_vout;\r
-\r
-} dec_thread_t;\r
-\r
-/*****************************************************************************\r
- * Local prototypes\r
- *****************************************************************************/\r
-static int  OpenDecoder  ( vlc_object_t * );\r
-static int  RunDecoder   ( decoder_fifo_t * );\r
-static void CloseDecoder ( dec_thread_t * );\r
-\r
-/*****************************************************************************\r
- * Module descriptor\r
- *****************************************************************************/\r
-vlc_module_begin();\r
-    set_description( _("libmpeg2 decoder module") );\r
-    set_capability( "decoder", 40 );\r
-    set_callbacks( OpenDecoder, NULL );\r
-    add_shortcut( "libmpeg2" );\r
-vlc_module_end();\r
-\r
-/*****************************************************************************\r
- * OpenDecoder: probe the decoder and return score\r
- *****************************************************************************/\r
-static int OpenDecoder( vlc_object_t *p_this )\r
-{\r
-    decoder_fifo_t *p_fifo = (decoder_fifo_t*) p_this;\r
-\r
-    if( p_fifo->i_fourcc != VLC_FOURCC('m','p','g','v') )\r
-    {\r
-        return VLC_EGENERIC;\r
-    }\r
-\r
-    p_fifo->pf_run = RunDecoder;\r
-    return VLC_SUCCESS;\r
-}\r
-/*****************************************************************************\r
- * RunDecoder: the libmpeg2 decoder\r
- *****************************************************************************/\r
-static int RunDecoder( decoder_fifo_t *p_fifo )\r
-{\r
-    dec_thread_t    *p_dec;\r
-    data_packet_t   *p_data = NULL;\r
-    mpeg2_state_t   state;\r
-    picture_t       *p_pic;\r
-    int             i_aspect, i_chroma;\r
-\r
-    /* Allocate the memory needed to store the thread's structure */\r
-    if( (p_dec = (dec_thread_t *)malloc (sizeof(dec_thread_t)) )\r
-        == NULL)\r
-    {\r
-        msg_Err( p_fifo, "out of memory" );\r
-        goto error;\r
-    }\r
-\r
-    /* Initialize the thread properties */\r
-    memset( p_dec, 0, sizeof(dec_thread_t) );\r
-    p_dec->p_fifo     = p_fifo;\r
-    p_dec->p_pes      = NULL;\r
-    p_dec->p_vout     = NULL;\r
-    p_dec->p_mpeg2dec = NULL;\r
-    p_dec->p_info     = NULL;\r
-    p_dec->i_pts      = mdate() + DEFAULT_PTS_DELAY;\r
-    p_dec->i_current_pts  = 0;\r
-    p_dec->i_previous_pts = 0;\r
-    p_dec->i_period_remainder = 0;\r
-\r
-    /* Initialize decoder */\r
-    p_dec->p_mpeg2dec = mpeg2_init();\r
-    if( p_dec->p_mpeg2dec == NULL)\r
-        goto error;\r
-\r
-    p_dec->p_info = mpeg2_info( p_dec->p_mpeg2dec );\r
-\r
-    /* libmpeg2 decoder thread's main loop */\r
-    while( (!p_dec->p_fifo->b_die) && (!p_dec->p_fifo->b_error) )\r
-    {\r
-        state = mpeg2_parse( p_dec->p_mpeg2dec );\r
-\r
-        switch( state )\r
-        {\r
-        case STATE_BUFFER:\r
-            /* Feed libmpeg2 a data packet at a time */\r
-            if( p_data == NULL )\r
-            {\r
-                /* Get the next PES */\r
-                if( p_dec->p_pes )\r
-                    input_DeletePES( p_dec->p_fifo->p_packets_mgt,\r
-                                     p_dec->p_pes );\r
-\r
-                input_ExtractPES( p_dec->p_fifo, &p_dec->p_pes );\r
-                if( !p_dec->p_pes )\r
-                {\r
-                    p_dec->p_fifo->b_error = 1;\r
-                    break;\r
-                }\r
-\r
-                if( p_dec->p_pes->i_pts )\r
-                {\r
-                    mpeg2_pts( p_dec->p_mpeg2dec,\r
-                               (uint32_t)p_dec->p_pes->i_pts );\r
-                    p_dec->i_previous_pts = p_dec->i_current_pts;\r
-                    p_dec->i_current_pts = p_dec->p_pes->i_pts;\r
-                }\r
-                p_data = p_dec->p_pes->p_first;\r
-            }\r
-\r
-            if( p_data != NULL )\r
-            {\r
-                mpeg2_buffer( p_dec->p_mpeg2dec,\r
-                              p_data->p_payload_start,\r
-                              p_data->p_payload_end );\r
-\r
-                p_data = p_data->p_next;\r
-            }\r
-            break;\r
-\r
-        case STATE_SEQUENCE:\r
-            /* Initialize video output */\r
-\r
-            /* Check whether the input gives a particular aspect ratio */\r
-            if( p_dec->p_fifo->p_demux_data\r
-                && ( *(int*)(p_dec->p_fifo->p_demux_data) & 0x7 ) )\r
-            {\r
-                i_aspect = *(int*)(p_dec->p_fifo->p_demux_data);\r
-                switch( i_aspect )\r
-                {\r
-                case AR_3_4_PICTURE:\r
-                    i_aspect = VOUT_ASPECT_FACTOR * 4 / 3;\r
-                    break;\r
-                case AR_16_9_PICTURE:\r
-                    i_aspect = VOUT_ASPECT_FACTOR * 16 / 9;\r
-                    break;\r
-                case AR_221_1_PICTURE:\r
-                    i_aspect = VOUT_ASPECT_FACTOR * 221 / 100;\r
-                    break;\r
-                case AR_SQUARE_PICTURE:\r
-                default:\r
-                    i_aspect = VOUT_ASPECT_FACTOR *\r
-                                   p_dec->p_info->sequence->width /\r
-                                   p_dec->p_info->sequence->height;\r
-                    break;\r
-                }\r
-            }\r
-            else\r
-            {\r
-                /* Use the value provided in the MPEG sequence header */\r
-                i_aspect = ((uint64_t)p_dec->p_info->sequence->width) *\r
-                    p_dec->p_info->sequence->pixel_width * VOUT_ASPECT_FACTOR /\r
-                    p_dec->p_info->sequence->height /\r
-                    p_dec->p_info->sequence->pixel_height;\r
-            }\r
-\r
-            i_chroma = VLC_FOURCC('Y','V','1','2');\r
-\r
-            p_dec->p_vout = vout_Request( p_dec->p_fifo, p_dec->p_vout,\r
-                                          p_dec->p_info->sequence->width,\r
-                                          p_dec->p_info->sequence->height,\r
-                                          i_chroma, i_aspect );\r
-            break;\r
-\r
-        case STATE_PICTURE:\r
-        {\r
-            uint8_t *buf[3];\r
-\r
-            /* Get a new picture */\r
-            while( !(p_pic = vout_CreatePicture( p_dec->p_vout, 0, 0, 0 ) ) )\r
-            {\r
-                if( p_dec->p_fifo->b_die || p_dec->p_fifo->b_error )\r
-                    break;\r
-\r
-                msleep( VOUT_OUTMEM_SLEEP );\r
-            }\r
-            if( p_pic == NULL )\r
-                break;\r
-\r
-            buf[0] = p_pic->p[0].p_pixels;\r
-            buf[1] = p_pic->p[1].p_pixels;\r
-            buf[2] = p_pic->p[2].p_pixels;\r
-            mpeg2_set_buf( p_dec->p_mpeg2dec, buf, p_pic );\r
-\r
-            /* Store the date for the picture */\r
-            if( p_dec->p_info->current_picture->flags & PIC_FLAG_PTS )\r
-            {\r
-                p_pic->date = ( p_dec->p_info->current_picture->pts ==\r
-                                (uint32_t)p_dec->i_current_pts ) ?\r
-                              p_dec->i_current_pts : p_dec->i_previous_pts;\r
-            }\r
-        }\r
-        break;\r
-\r
-        case STATE_END:\r
-        case STATE_SLICE:\r
-            if( p_dec->p_info->display_fbuf\r
-                && p_dec->p_info->display_fbuf->id )\r
-            {\r
-                p_pic = (picture_t *)p_dec->p_info->display_fbuf->id;\r
-\r
-                /* Date the new picture */\r
-                if( p_dec->p_info->display_picture->flags & PIC_FLAG_PTS )\r
-                {\r
-                    p_dec->i_pts = p_pic->date;\r
-                    p_dec->i_period_remainder = 0;\r
-                }\r
-                else\r
-                {\r
-                    p_dec->i_pts += ( (p_dec->p_info->sequence->frame_period +\r
-                                       p_dec->i_period_remainder) / 27 );\r
-                    p_dec->i_period_remainder =\r
-                        p_dec->p_info->sequence->frame_period +\r
-                        p_dec->i_period_remainder -\r
-                        ( p_dec->p_info->sequence->frame_period +\r
-                          p_dec->i_period_remainder ) / 27 * 27;\r
-                }\r
-                vout_DatePicture( p_dec->p_vout, p_pic, p_dec->i_pts );\r
-\r
-                vout_DisplayPicture( p_dec->p_vout, p_pic );\r
-\r
-                /* Handle pulldown by adding some delay to the pts of the next\r
-                 * picture. */\r
-                if( p_dec->p_info->display_picture->nb_fields > 2 )\r
-                {\r
-                    int i_repeat_fields =\r
-                        p_dec->p_info->display_picture->nb_fields - 2;\r
-\r
-                    p_dec->i_pts += ( (p_dec->p_info->sequence->frame_period +\r
-                                       p_dec->i_period_remainder)\r
-                                      / 27 / 2 * i_repeat_fields );\r
-                    p_dec->i_period_remainder =\r
-                        p_dec->p_info->sequence->frame_period +\r
-                        p_dec->i_period_remainder -\r
-                        ( p_dec->p_info->sequence->frame_period +\r
-                          p_dec->i_period_remainder ) / 27 / 2 * 27 * 2;\r
-                }\r
-            }\r
-            break;\r
-\r
-        default:\r
-            break;\r
-        }\r
-    }\r
-\r
-    /* If b_error is set, the libmpeg2 decoder thread enters the error loop */\r
-    if( p_dec->p_fifo->b_error )\r
-    {\r
-        DecoderError( p_dec->p_fifo );\r
-    }\r
-\r
-    /* End of the libmpeg2 decoder thread */\r
-    CloseDecoder( p_dec );\r
-\r
-    return 0;\r
-\r
- error:\r
-    DecoderError( p_fifo );\r
-    if( p_dec )\r
-    {\r
-        if( p_dec->p_fifo )\r
-            p_dec->p_fifo->b_error = 1;\r
-\r
-        /* End of the libmpeg2 decoder thread */\r
-        CloseDecoder( p_dec );\r
-    }\r
-\r
-    return -1;\r
-}\r
-\r
-/*****************************************************************************\r
- * CloseDecoder: libmpeg2 decoder destruction\r
- *****************************************************************************/\r
-static void CloseDecoder( dec_thread_t * p_dec )\r
-{\r
-    if( p_dec )\r
-    {\r
-        if( p_dec->p_pes )\r
-            input_DeletePES( p_dec->p_fifo->p_packets_mgt, p_dec->p_pes );\r
-\r
-        vout_Request( p_dec->p_fifo, p_dec->p_vout, 0, 0, 0, 0 );\r
-\r
-        if( p_dec->p_mpeg2dec ) mpeg2_close( p_dec->p_mpeg2dec );\r
-\r
-        free( p_dec );\r
-    }\r
-}\r
+/*****************************************************************************
+ * libmpeg2.c: mpeg2 video decoder module making use of libmpeg2.
+ *****************************************************************************
+ * Copyright (C) 1999-2001 VideoLAN
+ * $Id: libmpeg2.c,v 1.6 2003/03/30 18:14:36 gbazin Exp $
+ *
+ * Authors: Gildas Bazin <gbazin@netcourrier.com>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ * 
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
+ *****************************************************************************/
+
+/*****************************************************************************
+ * Preamble
+ *****************************************************************************/
+#include <vlc/vlc.h>
+#include <vlc/vout.h>
+#include <vlc/input.h>
+#include <vlc/decoder.h>
+
+#include <stdlib.h>                                      /* malloc(), free() */
+#include <string.h>                                    /* memcpy(), memset() */
+
+#include <mpeg2dec/mpeg2.h>
+
+/* Aspect ratio (ISO/IEC 13818-2 section 6.3.3, table 6-3) */
+#define AR_SQUARE_PICTURE       1                           /* square pixels */
+#define AR_3_4_PICTURE          2                        /* 3:4 picture (TV) */
+#define AR_16_9_PICTURE         3              /* 16:9 picture (wide screen) */
+#define AR_221_1_PICTURE        4                  /* 2.21:1 picture (movie) */
+
+/*****************************************************************************
+ * dec_thread_t : libmpeg2 decoder thread descriptor
+ *****************************************************************************/
+typedef struct dec_thread_t
+{
+    /*
+     * libmpeg2 properties
+     */
+    mpeg2dec_t          *p_mpeg2dec;
+    const mpeg2_info_t  *p_info;
+
+    /*
+     * Input properties
+     */
+    decoder_fifo_t   *p_fifo;                  /* stores the PES stream data */
+    pes_packet_t     *p_pes;                  /* current PES we are decoding */
+    mtime_t          i_pts;
+    mtime_t          i_previous_pts;
+    mtime_t          i_current_pts;
+    mtime_t          i_period_remainder;
+
+    /*
+     * Output properties
+     */
+    vout_thread_t *p_vout;
+
+} dec_thread_t;
+
+/*****************************************************************************
+ * Local prototypes
+ *****************************************************************************/
+static int  OpenDecoder  ( vlc_object_t * );
+static int  RunDecoder   ( decoder_fifo_t * );
+static void CloseDecoder ( dec_thread_t * );
+
+/*****************************************************************************
+ * Module descriptor
+ *****************************************************************************/
+vlc_module_begin();
+    set_description( _("MPEG I/II video decoder (using libmpeg2)") );
+    set_capability( "decoder", 40 );
+    set_callbacks( OpenDecoder, NULL );
+    add_shortcut( "libmpeg2" );
+vlc_module_end();
+
+/*****************************************************************************
+ * OpenDecoder: probe the decoder and return score
+ *****************************************************************************/
+static int OpenDecoder( vlc_object_t *p_this )
+{
+    decoder_fifo_t *p_fifo = (decoder_fifo_t*) p_this;
+
+    if( p_fifo->i_fourcc != VLC_FOURCC('m','p','g','v') )
+    {
+        return VLC_EGENERIC;
+    }
+
+    p_fifo->pf_run = RunDecoder;
+    return VLC_SUCCESS;
+}
+/*****************************************************************************
+ * RunDecoder: the libmpeg2 decoder
+ *****************************************************************************/
+static int RunDecoder( decoder_fifo_t *p_fifo )
+{
+    dec_thread_t    *p_dec;
+    data_packet_t   *p_data = NULL;
+    mpeg2_state_t   state;
+    picture_t       *p_pic;
+    int             i_aspect, i_chroma;
+
+    /* Allocate the memory needed to store the thread's structure */
+    if( (p_dec = (dec_thread_t *)malloc (sizeof(dec_thread_t)) )
+        == NULL)
+    {
+        msg_Err( p_fifo, "out of memory" );
+        goto error;
+    }
+
+    /* Initialize the thread properties */
+    memset( p_dec, 0, sizeof(dec_thread_t) );
+    p_dec->p_fifo     = p_fifo;
+    p_dec->p_pes      = NULL;
+    p_dec->p_vout     = NULL;
+    p_dec->p_mpeg2dec = NULL;
+    p_dec->p_info     = NULL;
+    p_dec->i_pts      = mdate() + DEFAULT_PTS_DELAY;
+    p_dec->i_current_pts  = 0;
+    p_dec->i_previous_pts = 0;
+    p_dec->i_period_remainder = 0;
+
+    /* Initialize decoder */
+    p_dec->p_mpeg2dec = mpeg2_init();
+    if( p_dec->p_mpeg2dec == NULL)
+        goto error;
+
+    p_dec->p_info = mpeg2_info( p_dec->p_mpeg2dec );
+
+    /* libmpeg2 decoder thread's main loop */
+    while( (!p_dec->p_fifo->b_die) && (!p_dec->p_fifo->b_error) )
+    {
+        state = mpeg2_parse( p_dec->p_mpeg2dec );
+
+        switch( state )
+        {
+        case STATE_BUFFER:
+            /* Feed libmpeg2 a data packet at a time */
+            if( p_data == NULL )
+            {
+                /* Get the next PES */
+                if( p_dec->p_pes )
+                    input_DeletePES( p_dec->p_fifo->p_packets_mgt,
+                                     p_dec->p_pes );
+
+                input_ExtractPES( p_dec->p_fifo, &p_dec->p_pes );
+                if( !p_dec->p_pes )
+                {
+                    p_dec->p_fifo->b_error = 1;
+                    break;
+                }
+
+                if( p_dec->p_pes->i_pts )
+                {
+                    mpeg2_pts( p_dec->p_mpeg2dec,
+                               (uint32_t)p_dec->p_pes->i_pts );
+                    p_dec->i_previous_pts = p_dec->i_current_pts;
+                    p_dec->i_current_pts = p_dec->p_pes->i_pts;
+                }
+                p_data = p_dec->p_pes->p_first;
+            }
+
+            if( p_data != NULL )
+            {
+                mpeg2_buffer( p_dec->p_mpeg2dec,
+                              p_data->p_payload_start,
+                              p_data->p_payload_end );
+
+                p_data = p_data->p_next;
+            }
+            break;
+
+        case STATE_SEQUENCE:
+            /* Initialize video output */
+
+            /* Check whether the input gives a particular aspect ratio */
+            if( p_dec->p_fifo->p_demux_data
+                && ( *(int*)(p_dec->p_fifo->p_demux_data) & 0x7 ) )
+            {
+                i_aspect = *(int*)(p_dec->p_fifo->p_demux_data);
+                switch( i_aspect )
+                {
+                case AR_3_4_PICTURE:
+                    i_aspect = VOUT_ASPECT_FACTOR * 4 / 3;
+                    break;
+                case AR_16_9_PICTURE:
+                    i_aspect = VOUT_ASPECT_FACTOR * 16 / 9;
+                    break;
+                case AR_221_1_PICTURE:
+                    i_aspect = VOUT_ASPECT_FACTOR * 221 / 100;
+                    break;
+                case AR_SQUARE_PICTURE:
+                default:
+                    i_aspect = VOUT_ASPECT_FACTOR *
+                                   p_dec->p_info->sequence->width /
+                                   p_dec->p_info->sequence->height;
+                    break;
+                }
+            }
+            else
+            {
+                /* Use the value provided in the MPEG sequence header */
+                i_aspect = ((uint64_t)p_dec->p_info->sequence->width) *
+                    p_dec->p_info->sequence->pixel_width * VOUT_ASPECT_FACTOR /
+                    p_dec->p_info->sequence->height /
+                    p_dec->p_info->sequence->pixel_height;
+            }
+
+            i_chroma = VLC_FOURCC('Y','V','1','2');
+
+            p_dec->p_vout = vout_Request( p_dec->p_fifo, p_dec->p_vout,
+                                          p_dec->p_info->sequence->width,
+                                          p_dec->p_info->sequence->height,
+                                          i_chroma, i_aspect );
+            break;
+
+        case STATE_PICTURE:
+        {
+            uint8_t *buf[3];
+
+            /* Get a new picture */
+            while( !(p_pic = vout_CreatePicture( p_dec->p_vout, 0, 0, 0 ) ) )
+            {
+                if( p_dec->p_fifo->b_die || p_dec->p_fifo->b_error )
+                    break;
+
+                msleep( VOUT_OUTMEM_SLEEP );
+            }
+            if( p_pic == NULL )
+                break;
+
+            buf[0] = p_pic->p[0].p_pixels;
+            buf[1] = p_pic->p[1].p_pixels;
+            buf[2] = p_pic->p[2].p_pixels;
+            mpeg2_set_buf( p_dec->p_mpeg2dec, buf, p_pic );
+
+            /* Store the date for the picture */
+            if( p_dec->p_info->current_picture->flags & PIC_FLAG_PTS )
+            {
+                p_pic->date = ( p_dec->p_info->current_picture->pts ==
+                                (uint32_t)p_dec->i_current_pts ) ?
+                              p_dec->i_current_pts : p_dec->i_previous_pts;
+            }
+        }
+        break;
+
+        case STATE_END:
+        case STATE_SLICE:
+            if( p_dec->p_info->display_fbuf
+                && p_dec->p_info->display_fbuf->id )
+            {
+                p_pic = (picture_t *)p_dec->p_info->display_fbuf->id;
+
+                /* Date the new picture */
+                if( p_dec->p_info->display_picture->flags & PIC_FLAG_PTS )
+                {
+                    p_dec->i_pts = p_pic->date;
+                    p_dec->i_period_remainder = 0;
+                }
+                else
+                {
+                    p_dec->i_pts += ( (p_dec->p_info->sequence->frame_period +
+                                       p_dec->i_period_remainder) / 27 );
+                    p_dec->i_period_remainder =
+                        p_dec->p_info->sequence->frame_period +
+                        p_dec->i_period_remainder -
+                        ( p_dec->p_info->sequence->frame_period +
+                          p_dec->i_period_remainder ) / 27 * 27;
+                }
+                vout_DatePicture( p_dec->p_vout, p_pic, p_dec->i_pts );
+
+                vout_DisplayPicture( p_dec->p_vout, p_pic );
+
+                /* Handle pulldown by adding some delay to the pts of the next
+                 * picture. */
+                if( p_dec->p_info->display_picture->nb_fields > 2 )
+                {
+                    int i_repeat_fields =
+                        p_dec->p_info->display_picture->nb_fields - 2;
+
+                    p_dec->i_pts += ( (p_dec->p_info->sequence->frame_period +
+                                       p_dec->i_period_remainder)
+                                      / 27 / 2 * i_repeat_fields );
+                    p_dec->i_period_remainder =
+                        p_dec->p_info->sequence->frame_period +
+                        p_dec->i_period_remainder -
+                        ( p_dec->p_info->sequence->frame_period +
+                          p_dec->i_period_remainder ) / 27 / 2 * 27 * 2;
+                }
+            }
+            break;
+
+        default:
+            break;
+        }
+    }
+
+    /* If b_error is set, the libmpeg2 decoder thread enters the error loop */
+    if( p_dec->p_fifo->b_error )
+    {
+        DecoderError( p_dec->p_fifo );
+    }
+
+    /* End of the libmpeg2 decoder thread */
+    CloseDecoder( p_dec );
+
+    return 0;
+
+ error:
+    DecoderError( p_fifo );
+    if( p_dec )
+    {
+        if( p_dec->p_fifo )
+            p_dec->p_fifo->b_error = 1;
+
+        /* End of the libmpeg2 decoder thread */
+        CloseDecoder( p_dec );
+    }
+
+    return -1;
+}
+
+/*****************************************************************************
+ * CloseDecoder: libmpeg2 decoder destruction
+ *****************************************************************************/
+static void CloseDecoder( dec_thread_t * p_dec )
+{
+    if( p_dec )
+    {
+        if( p_dec->p_pes )
+            input_DeletePES( p_dec->p_fifo->p_packets_mgt, p_dec->p_pes );
+
+        vout_Request( p_dec->p_fifo, p_dec->p_vout, 0, 0, 0, 0 );
+
+        if( p_dec->p_mpeg2dec ) mpeg2_close( p_dec->p_mpeg2dec );
+
+        free( p_dec );
+    }
+}