X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=modules%2Fstream_out%2Fdescription.c;h=e1ebd6c1bb7e837d531eed2ae36bdef27b069bff;hb=9cefd57da162f2f3f5ddc24d4fc9fcf176580765;hp=288567dc134972d2ddae36fe929c29a9ceda5a9d;hpb=13ae40b0efc4f1b1ce205d9a057537047fcab3f4;p=vlc diff --git a/modules/stream_out/description.c b/modules/stream_out/description.c index 288567dc13..e1ebd6c1bb 100644 --- a/modules/stream_out/description.c +++ b/modules/stream_out/description.c @@ -29,12 +29,14 @@ # include "config.h" #endif -#include +#include #include #include #include #include +#include + /***************************************************************************** * Exported prototypes *****************************************************************************/ @@ -48,23 +50,20 @@ static int Send( sout_stream_t *, sout_stream_id_t *, block_t* ); /***************************************************************************** * Module descriptor *****************************************************************************/ -vlc_module_begin(); - set_description( N_("Description stream output") ); - set_capability( "sout stream", 50 ); - add_shortcut( "description" ); - set_callbacks( Open, Close ); -vlc_module_end(); +vlc_module_begin () + set_description( N_("Description stream output") ) + set_capability( "sout stream", 50 ) + add_shortcut( "description" ) + set_callbacks( Open, Close ) +vlc_module_end () struct sout_stream_sys_t { - input_thread_t *p_input; - mtime_t i_stream_start; }; struct sout_stream_id_t { - int i_d_u_m_m_y; }; /***************************************************************************** @@ -80,8 +79,6 @@ static int Open( vlc_object_t *p_this ) p_stream->pf_send = Send; p_sys = p_stream->p_sys = malloc(sizeof(sout_stream_sys_t)); - p_sys->p_input = NULL; - p_sys->i_stream_start = 0; return VLC_SUCCESS; @@ -106,25 +103,13 @@ static sout_stream_id_t *Add( sout_stream_t *p_stream, es_format_t *p_fmt ) sout_stream_id_t *id; es_format_t *p_fmt_copy; input_item_t *p_item; + input_thread_t *p_input; msg_Dbg( p_stream, "Adding a stream" ); - - if( !p_sys->p_input ) - { - p_sys->p_input = vlc_object_find( p_stream, VLC_OBJECT_INPUT, - FIND_PARENT ); - /* This module is a children of the input object - * We don't want to keep a reference on it, because we will be alive - * as long as the input is alive. - * - * Since vlc_object_find() increments the reference count, - * we release the input just after finding it. - * */ - assert( p_sys->p_input ); - vlc_object_release( p_sys->p_input ); - } + p_input = vlc_object_find( p_stream, VLC_OBJECT_INPUT, FIND_PARENT ); + assert( p_input ); - p_item = input_GetItem(p_sys->p_input); + p_item = input_GetItem(p_input); p_fmt_copy = malloc(sizeof(es_format_t)); es_format_Copy( p_fmt_copy, p_fmt ); @@ -132,12 +117,12 @@ static sout_stream_id_t *Add( sout_stream_t *p_stream, es_format_t *p_fmt ) vlc_mutex_lock( &p_item->lock ); TAB_APPEND( p_item->i_es, p_item->es, p_fmt_copy ); vlc_mutex_unlock( &p_item->lock ); + vlc_object_release( p_input ); if( p_sys->i_stream_start <= 0 ) p_sys->i_stream_start = mdate(); id = malloc( sizeof( sout_stream_id_t ) ); - id->i_d_u_m_m_y = 0; return id; } @@ -157,8 +142,17 @@ static int Send( sout_stream_t *p_stream, sout_stream_id_t *id, block_ChainRelease( p_buffer ); - if( p_sys->p_input && p_sys->i_stream_start + 1500000 < mdate() ) - p_sys->p_input->b_eof = true; + if( p_sys->i_stream_start + 1500000 < mdate() ) + { + input_thread_t *p_input; + + p_input = vlc_object_find( p_stream, VLC_OBJECT_INPUT, FIND_PARENT ); + if( p_input ) + { + p_input->b_eof = true; + vlc_object_release( p_input ); + } + } return VLC_SUCCESS; }