X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=src%2Faudio_output%2Fdec.c;h=ddd2f69008514a810f1c5c6097f461c5774c75e8;hb=2932220e9ed7d99f8b8397f1b578c9f0a3a1aa3b;hp=694957e0b7ead9d68b20392923906e87aab54e2f;hpb=d5b5b74679e4a5ae7353dacc87d6991f9325156e;p=vlc diff --git a/src/audio_output/dec.c b/src/audio_output/dec.c index 694957e0b7..ddd2f69008 100644 --- a/src/audio_output/dec.c +++ b/src/audio_output/dec.c @@ -28,48 +28,59 @@ # include "config.h" #endif -#include +#include -#ifdef HAVE_ALLOCA_H -# include -#endif +#include #include #include #include "aout_internal.h" -/** FIXME: Ugly but needed to access the counters */ -#include "input/input_internal.h" - /***************************************************************************** * aout_DecNew : create a decoder *****************************************************************************/ -static aout_input_t * DecNew( vlc_object_t * p_this, aout_instance_t * p_aout, +static aout_input_t * DecNew( aout_instance_t * p_aout, audio_sample_format_t *p_format, - audio_replay_gain_t *p_replay_gain ) + const audio_replay_gain_t *p_replay_gain, + const aout_request_vout_t *p_request_vout ) { aout_input_t * p_input; - input_thread_t * p_input_thread; /* Sanitize audio format */ if( p_format->i_channels > 32 ) { msg_Err( p_aout, "too many audio channels (%u)", p_format->i_channels ); - goto error; + return NULL; + } + if( p_format->i_channels <= 0 ) + { + msg_Err( p_aout, "no audio channels" ); + return NULL; + } + if( p_format->i_channels != aout_FormatNbChannels( p_format ) ) + { + msg_Err( p_aout, "incompatible audio channels count with layout mask" ); + return NULL; } if( p_format->i_rate > 192000 ) { msg_Err( p_aout, "excessive audio sample frequency (%u)", p_format->i_rate ); - goto error; + return NULL; + } + if( p_format->i_rate < 4000 ) + { + msg_Err( p_aout, "too low audio sample frequency (%u)", + p_format->i_rate ); + return NULL; } /* We can only be called by the decoder, so no need to lock * p_input->lock. */ - vlc_mutex_lock( &p_aout->mixer_lock ); + aout_lock_mixer( p_aout ); if ( p_aout->i_nb_inputs >= AOUT_MAX_INPUTS ) { @@ -77,18 +88,16 @@ static aout_input_t * DecNew( vlc_object_t * p_this, aout_instance_t * p_aout, goto error; } - p_input = malloc(sizeof(aout_input_t)); - if ( p_input == NULL ) - { - msg_Err( p_aout, "out of memory" ); + p_input = calloc( 1, sizeof(aout_input_t)); + if( !p_input ) goto error; - } - memset( p_input, 0, sizeof(aout_input_t) ); - vlc_mutex_init( p_aout, &p_input->lock ); + vlc_mutex_init( &p_input->lock ); - p_input->b_changed = 0; - p_input->b_error = 1; + p_input->b_changed = false; + p_input->b_error = true; + p_input->b_paused = false; + p_input->i_pause_date = 0; aout_FormatPrepare( p_format ); @@ -97,10 +106,11 @@ static aout_input_t * DecNew( vlc_object_t * p_this, aout_instance_t * p_aout, if( p_replay_gain ) p_input->replay_gain = *p_replay_gain; + aout_lock_input_fifos( p_aout ); p_aout->pp_inputs[p_aout->i_nb_inputs] = p_input; p_aout->i_nb_inputs++; - if ( p_aout->mixer.b_error ) + if ( !p_aout->p_mixer ) { int i; @@ -112,21 +122,24 @@ static aout_input_t * DecNew( vlc_object_t * p_this, aout_instance_t * p_aout, { for ( i = 0; i < p_aout->i_nb_inputs - 1; i++ ) { - vlc_mutex_lock( &p_aout->pp_inputs[i]->lock ); + aout_lock_input( p_aout, p_aout->pp_inputs[i] ); aout_InputDelete( p_aout, p_aout->pp_inputs[i] ); - vlc_mutex_unlock( &p_aout->pp_inputs[i]->lock ); + aout_unlock_input( p_aout, p_aout->pp_inputs[i] ); } - vlc_mutex_unlock( &p_aout->mixer_lock ); + aout_unlock_input_fifos( p_aout ); + aout_unlock_mixer( p_aout ); return p_input; } /* Create other input streams. */ for ( i = 0; i < p_aout->i_nb_inputs - 1; i++ ) { - vlc_mutex_lock( &p_aout->pp_inputs[i]->lock ); - aout_InputDelete( p_aout, p_aout->pp_inputs[i] ); - aout_InputNew( p_aout, p_aout->pp_inputs[i] ); - vlc_mutex_unlock( &p_aout->pp_inputs[i]->lock ); + aout_input_t *p_input = p_aout->pp_inputs[i]; + + aout_lock_input( p_aout, p_input ); + aout_InputDelete( p_aout, p_input ); + aout_InputNew( p_aout, p_input, &p_input->request_vout ); + aout_unlock_input( p_aout, p_input ); } } else @@ -137,66 +150,43 @@ static aout_input_t * DecNew( vlc_object_t * p_this, aout_instance_t * p_aout, if ( aout_MixerNew( p_aout ) == -1 ) { aout_OutputDelete( p_aout ); + aout_unlock_input_fifos( p_aout ); goto error; } - aout_InputNew( p_aout, p_input ); + aout_InputNew( p_aout, p_input, p_request_vout ); + aout_unlock_input_fifos( p_aout ); - vlc_mutex_unlock( &p_aout->mixer_lock ); - p_input->i_desync = var_CreateGetInteger( p_this, "audio-desync" ) * 1000; - - p_input_thread = (input_thread_t *)vlc_object_find( p_this, - VLC_OBJECT_INPUT, FIND_PARENT ); - if( p_input_thread ) - { - p_input->i_pts_delay = p_input_thread->i_pts_delay; - p_input->i_pts_delay += p_input->i_desync; - p_input->p_input_thread = p_input_thread; - vlc_object_release( p_input_thread ); - } - else - { - p_input->i_pts_delay = DEFAULT_PTS_DELAY; - p_input->i_pts_delay += p_input->i_desync; - p_input->p_input_thread = NULL; - } + aout_unlock_mixer( p_aout ); return p_input; error: - vlc_mutex_unlock( &p_aout->mixer_lock ); + aout_unlock_mixer( p_aout ); return NULL; } aout_input_t * __aout_DecNew( vlc_object_t * p_this, aout_instance_t ** pp_aout, audio_sample_format_t * p_format, - audio_replay_gain_t *p_replay_gain ) + const audio_replay_gain_t *p_replay_gain, + const aout_request_vout_t *p_request_video ) { - if ( *pp_aout == NULL ) + aout_instance_t *p_aout = *pp_aout; + if ( p_aout == NULL ) { - /* Create an audio output if there is none. */ - *pp_aout = vlc_object_find( p_this, VLC_OBJECT_AOUT, FIND_ANYWHERE ); + msg_Dbg( p_this, "no aout present, spawning one" ); + p_aout = aout_New( p_this ); - if( *pp_aout == NULL ) - { - msg_Dbg( p_this, "no aout present, spawning one" ); + /* Everything failed, I'm a loser, I just wanna die */ + if( p_aout == NULL ) + return NULL; - *pp_aout = aout_New( p_this ); - /* Everything failed, I'm a loser, I just wanna die */ - if( *pp_aout == NULL ) - { - return NULL; - } - vlc_object_attach( *pp_aout, p_this->p_libvlc ); - } - else - { - vlc_object_release( *pp_aout ); - } + vlc_object_attach( p_aout, p_this ); + *pp_aout = p_aout; } - return DecNew( p_this, *pp_aout, p_format, p_replay_gain ); + return DecNew( p_aout, p_format, p_replay_gain, p_request_video ); } /***************************************************************************** @@ -208,7 +198,7 @@ int aout_DecDelete( aout_instance_t * p_aout, aout_input_t * p_input ) /* This function can only be called by the decoder itself, so no need * to lock p_input->lock. */ - vlc_mutex_lock( &p_aout->mixer_lock ); + aout_lock_mixer( p_aout ); for ( i_input = 0; i_input < p_aout->i_nb_inputs; i_input++ ) { @@ -221,6 +211,7 @@ int aout_DecDelete( aout_instance_t * p_aout, aout_input_t * p_input ) if ( i_input == p_aout->i_nb_inputs ) { msg_Err( p_aout, "cannot find an input to delete" ); + aout_unlock_mixer( p_aout ); return -1; } @@ -238,17 +229,11 @@ int aout_DecDelete( aout_instance_t * p_aout, aout_input_t * p_input ) { aout_OutputDelete( p_aout ); aout_MixerDelete( p_aout ); - if ( var_Type( p_aout, "audio-device" ) != 0 ) - { - var_Destroy( p_aout, "audio-device" ); - } - if ( var_Type( p_aout, "audio-channels" ) != 0 ) - { - var_Destroy( p_aout, "audio-channels" ); - } + var_Destroy( p_aout, "audio-device" ); + var_Destroy( p_aout, "audio-channels" ); } - vlc_mutex_unlock( &p_aout->mixer_lock ); + aout_unlock_mixer( p_aout ); return 0; } @@ -267,32 +252,32 @@ aout_buffer_t * aout_DecNewBuffer( aout_input_t * p_input, aout_buffer_t * p_buffer; mtime_t duration; - vlc_mutex_lock( &p_input->lock ); + aout_lock_input( NULL, p_input ); if ( p_input->b_error ) { - vlc_mutex_unlock( &p_input->lock ); + aout_unlock_input( NULL, p_input ); return NULL; } duration = (1000000 * (mtime_t)i_nb_samples) / p_input->input.i_rate; /* This necessarily allocates in the heap. */ - aout_BufferAlloc( &p_input->input_alloc, duration, NULL, p_buffer ); + p_buffer = aout_BufferAlloc( &p_input->input_alloc, duration, NULL ); if( p_buffer != NULL ) - p_buffer->i_nb_bytes = i_nb_samples * p_input->input.i_bytes_per_frame + p_buffer->i_buffer = i_nb_samples * p_input->input.i_bytes_per_frame / p_input->input.i_frame_length; /* Suppose the decoder doesn't have more than one buffered buffer */ - p_input->b_changed = 0; + p_input->b_changed = false; - vlc_mutex_unlock( &p_input->lock ); + aout_unlock_input( NULL, p_input ); if( p_buffer == NULL ) return NULL; p_buffer->i_nb_samples = i_nb_samples; - p_buffer->start_date = p_buffer->end_date = 0; + p_buffer->i_pts = p_buffer->i_length = 0; return p_buffer; } @@ -312,96 +297,106 @@ void aout_DecDeleteBuffer( aout_instance_t * p_aout, aout_input_t * p_input, int aout_DecPlay( aout_instance_t * p_aout, aout_input_t * p_input, aout_buffer_t * p_buffer, int i_input_rate ) { - if ( p_buffer->start_date == 0 ) - { - msg_Warn( p_aout, "non-dated buffer received" ); - aout_BufferFree( p_buffer ); - return -1; - } + assert( i_input_rate >= INPUT_RATE_DEFAULT / AOUT_MAX_INPUT_RATE && + i_input_rate <= INPUT_RATE_DEFAULT * AOUT_MAX_INPUT_RATE ); - if( i_input_rate > INPUT_RATE_DEFAULT * AOUT_MAX_INPUT_RATE || - i_input_rate < INPUT_RATE_DEFAULT / AOUT_MAX_INPUT_RATE ) - { - aout_BufferFree( p_buffer ); - return 0; - } - - /* Apply the desynchronisation requested by the user */ - p_buffer->start_date += p_input->i_desync; - p_buffer->end_date += p_input->i_desync; - - if ( p_buffer->start_date > mdate() + p_input->i_pts_delay + - AOUT_MAX_ADVANCE_TIME ) - { - msg_Warn( p_aout, "received buffer in the future ("I64Fd")", - p_buffer->start_date - mdate()); - if( p_input->p_input_thread ) - { - vlc_mutex_lock( &p_input->p_input_thread->p->counters.counters_lock); - stats_UpdateInteger( p_aout, - p_input->p_input_thread->p->counters.p_lost_abuffers, - 1, NULL ); - vlc_mutex_unlock( &p_input->p_input_thread->p->counters.counters_lock); - } - aout_BufferFree( p_buffer ); - return -1; - } + assert( p_buffer->i_pts > 0 ); - p_buffer->end_date = p_buffer->start_date - + (mtime_t)p_buffer->i_nb_samples * 1000000 + p_buffer->i_length = (mtime_t)p_buffer->i_nb_samples * 1000000 / p_input->input.i_rate; - vlc_mutex_lock( &p_input->lock ); + aout_lock_mixer( p_aout ); + aout_lock_input( p_aout, p_input ); - if ( p_input->b_error ) + if( p_input->b_error ) { - vlc_mutex_unlock( &p_input->lock ); + aout_unlock_input( p_aout, p_input ); + aout_unlock_mixer( p_aout ); + aout_BufferFree( p_buffer ); return -1; } - if ( p_input->b_changed ) + if( p_input->b_changed ) { /* Maybe the allocation size has changed. Re-allocate a buffer. */ aout_buffer_t * p_new_buffer; mtime_t duration = (1000000 * (mtime_t)p_buffer->i_nb_samples) / p_input->input.i_rate; - aout_BufferAlloc( &p_input->input_alloc, duration, NULL, p_new_buffer ); - p_aout->p_libvlc->pf_memcpy( p_new_buffer->p_buffer, p_buffer->p_buffer, - p_buffer->i_nb_bytes ); + p_new_buffer = aout_BufferAlloc( &p_input->input_alloc, duration, NULL); + vlc_memcpy( p_new_buffer->p_buffer, p_buffer->p_buffer, + p_buffer->i_buffer ); p_new_buffer->i_nb_samples = p_buffer->i_nb_samples; - p_new_buffer->i_nb_bytes = p_buffer->i_nb_bytes; - p_new_buffer->start_date = p_buffer->start_date; - p_new_buffer->end_date = p_buffer->end_date; + p_new_buffer->i_buffer = p_buffer->i_buffer; + p_new_buffer->i_pts = p_buffer->i_pts; + p_new_buffer->i_length = p_buffer->i_length; aout_BufferFree( p_buffer ); p_buffer = p_new_buffer; - p_input->b_changed = 0; + p_input->b_changed = false; } - /* If the buffer is too early, wait a while. */ - mwait( p_buffer->start_date - AOUT_MAX_PREPARE_TIME ); + aout_InputCheckAndRestart( p_aout, p_input ); + aout_unlock_mixer( p_aout ); - if ( aout_InputPlay( p_aout, p_input, p_buffer, i_input_rate ) == -1 ) - { - vlc_mutex_unlock( &p_input->lock ); - return -1; - } + int i_ret = aout_InputPlay( p_aout, p_input, p_buffer, i_input_rate ); + + aout_unlock_input( p_aout, p_input ); - vlc_mutex_unlock( &p_input->lock ); + if( i_ret == -1 ) + return -1; /* Run the mixer if it is able to run. */ - vlc_mutex_lock( &p_aout->mixer_lock ); + aout_lock_mixer( p_aout ); + aout_MixerRun( p_aout ); - if( p_input->p_input_thread ) + + aout_unlock_mixer( p_aout ); + + return 0; +} + +int aout_DecGetResetLost( aout_instance_t *p_aout, aout_input_t *p_input ) +{ + aout_lock_input( p_aout, p_input ); + int i_value = p_input->i_buffer_lost; + p_input->i_buffer_lost = 0; + aout_unlock_input( p_aout, p_input ); + + return i_value; +} + +void aout_DecChangePause( aout_instance_t *p_aout, aout_input_t *p_input, bool b_paused, mtime_t i_date ) +{ + mtime_t i_duration = 0; + aout_lock_input( p_aout, p_input ); + assert( !p_input->b_paused || !b_paused ); + if( p_input->b_paused ) { - vlc_mutex_lock( &p_input->p_input_thread->p->counters.counters_lock); - stats_UpdateInteger( p_aout, - p_input->p_input_thread->p->counters.p_played_abuffers, - 1, NULL ); - vlc_mutex_unlock( &p_input->p_input_thread->p->counters.counters_lock); + i_duration = i_date - p_input->i_pause_date; } - vlc_mutex_unlock( &p_aout->mixer_lock ); + p_input->b_paused = b_paused; + p_input->i_pause_date = i_date; + aout_unlock_input( p_aout, p_input ); - return 0; + if( i_duration != 0 ) + { + aout_lock_mixer( p_aout ); + for( aout_buffer_t *p = p_input->mixer.fifo.p_first; p != NULL; p = p->p_next ) + { + p->i_pts += i_duration; + } + aout_unlock_mixer( p_aout ); + } +} + +void aout_DecFlush( aout_instance_t *p_aout, aout_input_t *p_input ) +{ + aout_lock_input_fifos( p_aout ); + + aout_FifoSet( p_aout, &p_input->mixer.fifo, 0 ); + p_input->mixer.begin = NULL; + + aout_unlock_input_fifos( p_aout ); } +