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.6 2001/01/12 17:33:18 massiot 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 "config.h"
  31 #include "common.h"
  32 #include "threads.h"
  33 #include "mtime.h"
  34 #include "intf_msg.h"
  35
  36 #include "stream_control.h"
  37 #include "input_ext-dec.h"
  38 #include "input_ext-intf.h"
  39
  40 #include "input.h"
  41
  42 /*****************************************************************************
  43  * input_RunDecoder: spawns a new decoder thread
  44  *****************************************************************************/
  45 vlc_thread_t input_RunDecoder( decoder_capabilities_t * p_decoder,
  46                                void * p_data )
  47 {
  48     return( p_decoder->pf_create_thread( p_data ) );
  49 }
  50
  51 /*****************************************************************************
  52  * input_EndDecoder: kills a decoder thread and waits until it's finished
  53  *****************************************************************************/
  54 void input_EndDecoder( input_thread_t * p_input, es_descriptor_t * p_es )
  55 {
  56     p_es->p_decoder_fifo->b_die = 1;
  57
  58     /* Make sure the thread leaves the NextDataPacket() function */
  59     input_NullPacket( p_input, p_es );
  60     if( p_es->p_pes != NULL )
  61     {
  62         input_DecodePES( p_es->p_decoder_fifo, p_es->p_pes );
  63     }
  64
  65     /* Waiting for the thread to exit */
  66     vlc_thread_join( p_es->thread_id );
  67
  68     /* Freeing all packets still in the decoder fifo. */
  69     while( !DECODER_FIFO_ISEMPTY( *p_es->p_decoder_fifo ) )
  70     {
  71         p_es->p_decoder_fifo->pf_delete_pes(
  72                             p_es->p_decoder_fifo->p_packets_mgt,
  73                             DECODER_FIFO_START( *p_es->p_decoder_fifo ) );
  74         DECODER_FIFO_INCSTART( *p_es->p_decoder_fifo );
  75     }
  76
  77     /* Destroy the lock and cond */
  78     vlc_cond_destroy( &p_es->p_decoder_fifo->data_wait );
  79     vlc_mutex_destroy( &p_es->p_decoder_fifo->data_lock );
  80
  81     free( p_es->p_decoder_fifo );
  82     p_es->p_decoder_fifo = NULL;
  83 }
  84
  85 /*****************************************************************************
  86  * input_DecodePES
  87  *****************************************************************************
  88  * Put a PES in the decoder's fifo.
  89  *****************************************************************************/
  90 void input_DecodePES( decoder_fifo_t * p_decoder_fifo, pes_packet_t * p_pes )
  91 {
  92     vlc_mutex_lock( &p_decoder_fifo->data_lock );
  93
  94     if( !DECODER_FIFO_ISFULL( *p_decoder_fifo ) )
  95     {
  96         p_decoder_fifo->buffer[p_decoder_fifo->i_end] = p_pes;
  97         DECODER_FIFO_INCEND( *p_decoder_fifo );
  98
  99         /* Warn the decoder that it's got work to do. */
 100         vlc_cond_signal( &p_decoder_fifo->data_wait );
 101     }
 102     else
 103     {
 104         /* The FIFO is full !!! This should not happen. */
 105         p_decoder_fifo->pf_delete_pes( p_decoder_fifo->p_packets_mgt,
 106                                        p_pes );
 107         intf_ErrMsg( "PES trashed - fifo full !" );
 108     }
 109     vlc_mutex_unlock( &p_decoder_fifo->data_lock );
 110 }