vlc_object_attach( s, p_obj );
- if( vlc_thread_create( s, "stream out", DStreamThread,
- VLC_THREAD_PRIORITY_INPUT ) )
+ if( vlc_thread_create( s, DStreamThread, VLC_THREAD_PRIORITY_INPUT ) )
{
- vlc_object_detach( s );
stream_CommonDelete( s );
free( p_sys->psz_name );
free( p_sys );
void stream_DemuxSend( stream_t *s, block_t *p_block )
{
stream_sys_t *p_sys = s->p_sys;
- if( p_block )
- block_FifoPut( p_sys->p_fifo, p_block );
+ block_FifoPut( p_sys->p_fifo, p_block );
}
static void DStreamDelete( stream_t *s )
block_t *p_empty;
vlc_object_kill( s );
+#warning FIXME: not thread-safe:
if( p_sys->p_demux )
vlc_object_kill( p_sys->p_demux );
p_empty = block_New( s, 1 ); p_empty->i_buffer = 0;
block_FifoRelease( p_sys->p_fifo );
free( p_sys->psz_name );
free( p_sys );
- vlc_object_detach( s );
stream_CommonDelete( s );
}
vlc_object_kill( p_demux );
return NULL;
}
-