/***************************************************************************** * input_internal.h: Internal input structures ***************************************************************************** * Copyright (C) 1998-2006 the VideoLAN team * $Id$ * * Authors: Laurent Aimar * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA. *****************************************************************************/ #ifndef _INPUT_INTERNAL_H #define _INPUT_INTERNAL_H 1 #include #include #include /***************************************************************************** * Private input fields *****************************************************************************/ /* input_source_t: gathers all information per input source */ typedef struct { /* Input item description */ input_item_t *p_item; /* Access/Stream/Demux plugins */ access_t *p_access; stream_t *p_stream; demux_t *p_demux; /* Title infos for that input */ vlc_bool_t b_title_demux; /* Titles/Seekpoints provided by demux */ int i_title; input_title_t **title; int i_title_offset; int i_seekpoint_offset; int i_title_start; int i_title_end; int i_seekpoint_start; int i_seekpoint_end; /* Properties */ vlc_bool_t b_can_pace_control; vlc_bool_t b_can_pause; vlc_bool_t b_eof; /* eof of demuxer */ /* Clock average variation */ int i_cr_average; } input_source_t; /** Private input fields */ struct input_thread_private_t { /* Global properties */ vlc_bool_t b_can_pause; int i_rate; /* */ int64_t i_start; /* :start-time,0 by default */ int64_t i_stop; /* :stop-time, 0 if none */ /* Title infos FIXME multi-input (not easy) ? */ int i_title; input_title_t **title; int i_title_offset; int i_seekpoint_offset; /* User bookmarks FIXME won't be easy with multiples input */ int i_bookmark; seekpoint_t **bookmark; /* Global meta datas FIXME move to input_item_t ? */ vlc_meta_t *p_meta; /* Output */ es_out_t *p_es_out; sout_instance_t *p_sout; /* XXX Move it to es_out ? */ vlc_bool_t b_sout_keep; vlc_bool_t b_out_pace_control; /* idem ? */ /* Main input properties */ input_source_t input; /* Slave demuxers (subs, and others) */ int i_slave; input_source_t **slave; /* Stats counters */ struct { counter_t *p_read_packets; counter_t *p_read_bytes; counter_t *p_input_bitrate; counter_t *p_demux_read; counter_t *p_demux_bitrate; counter_t *p_decoded_audio; counter_t *p_decoded_video; counter_t *p_decoded_sub; counter_t *p_sout_sent_packets; counter_t *p_sout_sent_bytes; counter_t *p_sout_send_bitrate; counter_t *p_played_abuffers; counter_t *p_lost_abuffers; counter_t *p_displayed_pictures; counter_t *p_lost_pictures; vlc_mutex_t counters_lock; } counters; /* Buffer of pending actions */ vlc_mutex_t lock_control; int i_control; struct { /* XXX: val isn't duplicated so it won't works with string */ int i_type; vlc_value_t val; } control[INPUT_CONTROL_FIFO_SIZE]; }; /*************************************************************************** * Internal control helpers ***************************************************************************/ enum input_control_e { INPUT_CONTROL_SET_DIE, INPUT_CONTROL_SET_STATE, INPUT_CONTROL_SET_RATE, INPUT_CONTROL_SET_RATE_SLOWER, INPUT_CONTROL_SET_RATE_FASTER, INPUT_CONTROL_SET_POSITION, INPUT_CONTROL_SET_POSITION_OFFSET, INPUT_CONTROL_SET_TIME, INPUT_CONTROL_SET_TIME_OFFSET, INPUT_CONTROL_SET_PROGRAM, INPUT_CONTROL_SET_TITLE, INPUT_CONTROL_SET_TITLE_NEXT, INPUT_CONTROL_SET_TITLE_PREV, INPUT_CONTROL_SET_SEEKPOINT, INPUT_CONTROL_SET_SEEKPOINT_NEXT, INPUT_CONTROL_SET_SEEKPOINT_PREV, INPUT_CONTROL_SET_BOOKMARK, INPUT_CONTROL_SET_ES, INPUT_CONTROL_SET_AUDIO_DELAY, INPUT_CONTROL_SET_SPU_DELAY, INPUT_CONTROL_ADD_SLAVE, }; /* Internal helpers */ static inline void input_ControlPush( input_thread_t *p_input, int i_type, vlc_value_t *p_val ) { vlc_mutex_lock( &p_input->p->lock_control ); if( i_type == INPUT_CONTROL_SET_DIE ) { /* Special case, empty the control */ p_input->p->i_control = 1; p_input->p->control[0].i_type = i_type; memset( &p_input->p->control[0].val, 0, sizeof( vlc_value_t ) ); } else { if( p_input->p->i_control >= INPUT_CONTROL_FIFO_SIZE ) { msg_Err( p_input, "input control fifo overflow, trashing type=%d", i_type ); vlc_mutex_unlock( &p_input->p->lock_control ); return; } p_input->p->control[p_input->p->i_control].i_type = i_type; if( p_val ) p_input->p->control[p_input->p->i_control].val = *p_val; else memset( &p_input->p->control[p_input->p->i_control].val, 0, sizeof( vlc_value_t ) ); p_input->p->i_control++; } vlc_mutex_unlock( &p_input->p->lock_control ); } /********************************************************************** * Item metadata **********************************************************************/ typedef struct playlist_album_t { char *psz_artist; char *psz_album; vlc_bool_t b_found; } playlist_album_t; int input_MetaFetch ( playlist_t *, input_item_t * ); int input_ArtFind ( playlist_t *, input_item_t * ); vlc_bool_t input_MetaSatisfied ( playlist_t*, input_item_t*, uint32_t*, uint32_t* ); int input_DownloadAndCacheArt ( playlist_t *, input_item_t * ); /*************************************************************************** * Internal prototypes ***************************************************************************/ /* input.c */ #define input_CreateThreadExtended(a,b,c,d) __input_CreateThreadExtended(VLC_OBJECT(a),b,c,d) input_thread_t *__input_CreateThreadExtended ( vlc_object_t *, input_item_t *, const char *, sout_instance_t * ); void input_DestroyThreadExtended( input_thread_t *p_input, sout_instance_t ** ); /* var.c */ void input_ControlVarInit ( input_thread_t * ); void input_ControlVarClean( input_thread_t * ); void input_ControlVarNavigation( input_thread_t * ); void input_ControlVarTitle( input_thread_t *, int i_title ); void input_ConfigVarInit ( input_thread_t * ); /* stream.c */ stream_t *stream_AccessNew( access_t *p_access, vlc_bool_t ); void stream_AccessDelete( stream_t *s ); void stream_AccessReset( stream_t *s ); void stream_AccessUpdate( stream_t *s ); /* decoder.c FIXME make it public ?*/ void input_DecoderDiscontinuity( decoder_t * p_dec ); vlc_bool_t input_DecoderEmpty( decoder_t * p_dec ); void input_DecoderPreroll( decoder_t *p_dec, int64_t i_preroll_end ); /* es_out.c */ es_out_t *input_EsOutNew( input_thread_t * ); void input_EsOutDelete( es_out_t * ); es_out_id_t *input_EsOutGetFromID( es_out_t *, int i_id ); void input_EsOutDiscontinuity( es_out_t *, vlc_bool_t b_audio ); void input_EsOutSetDelay( es_out_t *, int i_cat, int64_t ); vlc_bool_t input_EsOutDecodersEmpty( es_out_t * ); /* clock.c */ enum /* Synchro states */ { SYNCHRO_OK = 0, SYNCHRO_START = 1, SYNCHRO_REINIT = 2, }; typedef struct { /* Synchronization information */ mtime_t delta_cr; mtime_t cr_ref, sysdate_ref; mtime_t last_sysdate; mtime_t last_cr; /* reference to detect unexpected stream * discontinuities */ mtime_t last_pts; int i_synchro_state; vlc_bool_t b_master; /* Config */ int i_cr_average; int i_delta_cr_residue; } input_clock_t; void input_ClockInit( input_clock_t *, vlc_bool_t b_master, int i_cr_average ); void input_ClockSetPCR( input_thread_t *, input_clock_t *, mtime_t ); mtime_t input_ClockGetTS( input_thread_t *, input_clock_t *, mtime_t ); /* Subtitles */ char **subtitles_Detect( input_thread_t *, char* path, const char *fname ); int subtitles_Filter( const char *); void MRLSplit( vlc_object_t *, char *, const char **, const char **, char ** ); static inline void input_ChangeState( input_thread_t *p_input, int state ) { vlc_value_t val; val.i_int = p_input->i_state = state; var_Change( p_input, "state", VLC_VAR_SETVALUE, &val, NULL ); } /* Access */ #define access2_New( a, b, c, d, e ) __access2_New(VLC_OBJECT(a), b, c, d, e ) access_t * __access2_New( vlc_object_t *p_obj, const char *psz_access, const char *psz_demux, const char *psz_path, vlc_bool_t b_quick ); access_t * access2_FilterNew( access_t *p_source, const char *psz_access_filter ); void access2_Delete( access_t * ); /* Demuxer */ #include /* stream_t *s could be null and then it mean a access+demux in one */ #define demux2_New( a, b, c, d, e, f,g ) __demux2_New(VLC_OBJECT(a),b,c,d,e,f,g) demux_t *__demux2_New(vlc_object_t *p_obj, const char *psz_access, const char *psz_demux, const char *psz_path, stream_t *s, es_out_t *out, vlc_bool_t ); void demux2_Delete(demux_t *); static inline int demux2_Demux( demux_t *p_demux ) { return p_demux->pf_demux( p_demux ); } static inline int demux2_vaControl( demux_t *p_demux, int i_query, va_list args ) { return p_demux->pf_control( p_demux, i_query, args ); } static inline int demux2_Control( demux_t *p_demux, int i_query, ... ) { va_list args; int i_result; va_start( args, i_query ); i_result = demux2_vaControl( p_demux, i_query, args ); va_end( args ); return i_result; } #endif