git.sesse.net Git - vlc/blob - src/input/input_dec.c

   1 /*****************************************************************************
   2  * input_dec.c: Functions for the management of decoders
   3  *****************************************************************************
   4  * Copyright (C) 1999, 2000 VideoLAN
   5  * $Id: input_dec.c,v 1.11 2001/04/28 03:36:25 sam Exp $
   6  *
   7  * Authors: Christophe Massiot <massiot@via.ecp.fr>
   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 "defs.h"
  28
  29 #include <stdlib.h>
  30 #include <string.h>                                    /* memcpy(), memset() */
  31 #include <sys/types.h>                                              /* off_t */
  32
  33 #include "config.h"
  34 #include "common.h"
  35 #include "threads.h"
  36 #include "mtime.h"
  37 #include "intf_msg.h"
  38
  39 #include "stream_control.h"
  40 #include "input_ext-dec.h"
  41 #include "input_ext-intf.h"
  42
  43 #include "input.h"
  44
  45 /*****************************************************************************
  46  * input_RunDecoder: spawns a new decoder thread
  47  *****************************************************************************/
  48 vlc_thread_t input_RunDecoder( decoder_capabilities_t * p_decoder,
  49                                void * p_data )
  50 {
  51     return( p_decoder->pf_create_thread( p_data ) );
  52 }
  53
  54 /*****************************************************************************
  55  * input_EndDecoder: kills a decoder thread and waits until it's finished
  56  *****************************************************************************/
  57 void input_EndDecoder( input_thread_t * p_input, es_descriptor_t * p_es )
  58 {
  59     int i_dummy;
  60
  61     p_es->p_decoder_fifo->b_die = 1;
  62
  63     /* Make sure the thread leaves the NextDataPacket() function by
  64      * sending it a few null packets. */
  65     for( i_dummy = 0; i_dummy < PADDING_PACKET_NUMBER; i_dummy++ )
  66     {
  67         input_NullPacket( p_input, p_es );
  68     }
  69
  70     if( p_es->p_pes != NULL )
  71     {
  72         input_DecodePES( p_es->p_decoder_fifo, p_es->p_pes );
  73     }
  74
  75     /* Waiting for the thread to exit */
  76     /* I thought that unlocking was better since thread join can be long
  77      * but it actually creates late pictures and freezes --stef */
  78 //    vlc_mutex_unlock( &p_input->stream.stream_lock );
  79     vlc_thread_join( p_es->thread_id );
  80 //    vlc_mutex_lock( &p_input->stream.stream_lock );
  81
  82     /* Freeing all packets still in the decoder fifo. */
  83     while( !DECODER_FIFO_ISEMPTY( *p_es->p_decoder_fifo ) )
  84     {
  85         p_es->p_decoder_fifo->pf_delete_pes(
  86                             p_es->p_decoder_fifo->p_packets_mgt,
  87                             DECODER_FIFO_START( *p_es->p_decoder_fifo ) );
  88         DECODER_FIFO_INCSTART( *p_es->p_decoder_fifo );
  89     }
  90
  91     /* Destroy the lock and cond */
  92     vlc_cond_destroy( &p_es->p_decoder_fifo->data_wait );
  93     vlc_mutex_destroy( &p_es->p_decoder_fifo->data_lock );
  94
  95     free( p_es->p_decoder_fifo );
  96     p_es->p_decoder_fifo = NULL;
  97 }
  98
  99 /*****************************************************************************
 100  * input_DecodePES
 101  *****************************************************************************
 102  * Put a PES in the decoder's fifo.
 103  *****************************************************************************/
 104 void input_DecodePES( decoder_fifo_t * p_decoder_fifo, pes_packet_t * p_pes )
 105 {
 106     vlc_mutex_lock( &p_decoder_fifo->data_lock );
 107
 108     if( !DECODER_FIFO_ISFULL( *p_decoder_fifo ) )
 109     {
 110         p_decoder_fifo->buffer[p_decoder_fifo->i_end] = p_pes;
 111         DECODER_FIFO_INCEND( *p_decoder_fifo );
 112
 113         /* Warn the decoder that it's got work to do. */
 114         vlc_cond_signal( &p_decoder_fifo->data_wait );
 115     }
 116     else
 117     {
 118         /* The FIFO is full !!! This should not happen. */
 119         p_decoder_fifo->pf_delete_pes( p_decoder_fifo->p_packets_mgt,
 120                                        p_pes );
 121         intf_ErrMsg( "PES trashed - decoder fifo full !" );
 122     }
 123     vlc_mutex_unlock( &p_decoder_fifo->data_lock );
 124 }
 125
 126 /*****************************************************************************
 127  * input_EscapeDiscontinuity: send a NULL packet to the decoders
 128  *****************************************************************************/
 129 void input_EscapeDiscontinuity( input_thread_t * p_input,
 130                                 pgrm_descriptor_t * p_pgrm )
 131 {
 132     int     i_es, i;
 133
 134     for( i_es = 0; i_es < p_pgrm->i_es_number; i_es++ )
 135     {
 136         es_descriptor_t * p_es = p_pgrm->pp_es[i_es];
 137
 138         if( p_es->p_decoder_fifo != NULL )
 139         {
 140             for( i = 0; i < PADDING_PACKET_NUMBER; i++ )
 141             {
 142                 input_NullPacket( p_input, p_es );
 143             }
 144         }
 145     }
 146 }
 147
 148 /*****************************************************************************
 149  * input_EscapeAudioDiscontinuity: send a NULL packet to the audio decoders
 150  *****************************************************************************/
 151 void input_EscapeAudioDiscontinuity( input_thread_t * p_input,
 152                                      pgrm_descriptor_t * p_pgrm )
 153 {
 154     int     i_es, i;
 155
 156     for( i_es = 0; i_es < p_pgrm->i_es_number; i_es++ )
 157     {
 158         es_descriptor_t * p_es = p_pgrm->pp_es[i_es];
 159
 160         if( p_es->p_decoder_fifo != NULL && p_es->b_audio )
 161         {
 162             for( i = 0; i < PADDING_PACKET_NUMBER; i++ )
 163             {
 164                 input_NullPacket( p_input, p_es );
 165             }
 166         }
 167     }
 168 }
 169