es_out_timeshift.c File Reference

Include dependency graph for es_out_timeshift.c:

Data Structures
struct	ts_cmd_header_t
struct	ts_cmd_add_t
struct	ts_cmd_del_t
struct	ts_cmd_send_t
struct	ts_cmd_control_t
struct	ts_cmd_privcontrol_t
union	ts_cmd_t
struct	ts_storage_t
struct	ts_thread_t
struct	es_out_id_t
struct	es_out_sys_t

Macros
#define	attribute_packed
#define	MAX_COMMAND_SIZE   sizeof(ts_cmd_t)
#define	TS_STORAGE_COMMAND_PREALLOC   30000

Typedefs
typedef struct ts_storage_t	ts_storage_t

Enumerations
enum	ts_storage_cmd_type_e {   C_ADD = 0 , C_SEND , C_DEL , C_CONTROL ,   C_PRIVCONTROL }

Functions
static void	Del (es_out_t *, es_out_id_t *)
static int	TsStart (es_out_t *)
static void	TsAutoStop (es_out_t *)
static void	TsStop (ts_thread_t *)
static void	TsPushCmd (ts_thread_t *, ts_cmd_t *)
static int	TsPopCmdLocked (ts_thread_t *, ts_cmd_t *, bool b_flush)
static bool	TsHasCmd (ts_thread_t *)
static bool	TsIsUnused (ts_thread_t *)
static int	TsChangePause (ts_thread_t *, bool b_source_paused, bool b_paused, vlc_tick_t i_date)
static int	TsChangeRate (ts_thread_t *, float src_rate, float rate)
static void *	TsRun (void *)
static ts_storage_t *	TsStorageNew (const char *psz_path, int64_t i_tmp_size_max)
static void	TsStorageDelete (ts_storage_t *)
static void	TsStoragePack (ts_storage_t *p_storage)
static bool	TsStorageIsFull (ts_storage_t *, const ts_cmd_t *p_cmd)
static bool	TsStorageIsEmpty (ts_storage_t *)
static void	TsStoragePushCmd (ts_storage_t *, const ts_cmd_t *p_cmd, bool b_flush)
static void	TsStoragePopCmd (ts_storage_t *p_storage, ts_cmd_t *p_cmd, bool b_flush)
static void	CmdClean (ts_cmd_t *)
static int	CmdInitAdd (ts_cmd_add_t *, input_source_t *, es_out_id_t *, const es_format_t *, bool b_copy)
static void	CmdInitSend (ts_cmd_send_t *, es_out_id_t *, block_t *)
static int	CmdInitDel (ts_cmd_del_t *, es_out_id_t *)
static int	CmdInitControl (ts_cmd_control_t *, input_source_t *, int i_query, va_list, bool b_copy)
static int	CmdInitPrivControl (ts_cmd_privcontrol_t *, int i_query, va_list, bool b_copy)
static void	CmdCleanAdd (ts_cmd_add_t *)
static void	CmdCleanSend (ts_cmd_send_t *)
static void	CmdCleanControl (ts_cmd_control_t *)
static void	CmdExecuteAdd (es_out_t *, ts_cmd_add_t *)
static int	CmdExecuteSend (es_out_t *, ts_cmd_send_t *)
static void	CmdExecuteDel (es_out_t *, ts_cmd_del_t *)
static int	CmdExecuteControl (es_out_t *, ts_cmd_control_t *)
static int	CmdExecutePrivControl (es_out_t *, ts_cmd_privcontrol_t *)
static int	GetTmpFile (char **filename, const char *dirname)
static void	Destroy (es_out_t *p_out)
static es_out_id_t *	Add (es_out_t *p_out, input_source_t *in, const es_format_t *p_fmt)
static int	Send (es_out_t *p_out, es_out_id_t *p_es, block_t *p_block)
static int	es_out_in_vaControl (es_out_t *p_out, input_source_t *in, int i_query, va_list args)
static int	es_out_in_Control (es_out_t *p_out, input_source_t *in, int i_query,...)
static int	ControlLockedGetEmpty (es_out_t *p_out, input_source_t *in, bool *pb_empty)
static int	ControlLockedGetWakeup (es_out_t *p_out, vlc_tick_t *pi_wakeup)
static int	ControlLockedGetBuffering (es_out_t *p_out, bool *pb_buffering)
static int	ControlLockedSetPauseState (es_out_t *p_out, bool b_source_paused, bool b_paused, vlc_tick_t i_date)
static int	ControlLockedSetRate (es_out_t *p_out, float src_rate, float rate)
static int	ControlLockedSetFrameNext (es_out_t *p_out)
static int	ControlLocked (es_out_t *p_out, input_source_t *in, int i_query, va_list args)
static int	Control (es_out_t *p_tsout, input_source_t *in, int i_query, va_list args)
static int	PrivControlLocked (es_out_t *p_tsout, int i_query, va_list args)
static int	PrivControl (es_out_t *p_tsout, int i_query, va_list args)
es_out_t *	input_EsOutTimeshiftNew (input_thread_t *p_input, es_out_t *p_next_out, float rate)
static void	TsDestroy (ts_thread_t *p_ts)

Variables
static const struct es_out_callbacks	es_out_timeshift_cbs
static const size_t	TsStorageSizeofCommand []

Macro Definition Documentation

attribute_packed

#define attribute_packed

MAX_COMMAND_SIZE

#define MAX_COMMAND_SIZE   sizeof(ts_cmd_t)

TS_STORAGE_COMMAND_PREALLOC

#define TS_STORAGE_COMMAND_PREALLOC   30000

Typedef Documentation

ts_storage_t

typedef struct ts_storage_t ts_storage_t

Enumeration Type Documentation

ts_storage_cmd_type_e

enum ts_storage_cmd_type_e

Enumerator
C_ADD
C_SEND
C_DEL
C_CONTROL
C_PRIVCONTROL

Function Documentation

Add()

static es_out_id_t * Add ( es_out_t *  p_out, input_source_t *  in, const es_format_t *  p_fmt  )

static

References es_out_sys_t::b_delayed, CmdExecuteAdd(), CmdInitAdd(), container_of, es_out_sys_t::lock, es_out_sys_t::p_ts, TsAutoStop(), TsPushCmd(), vlc_mutex_lock(), and vlc_mutex_unlock().

CmdClean()

static void CmdClean ( ts_cmd_t *  p_cmd )

static

References ts_cmd_t::add, C_ADD, C_CONTROL, C_DEL, C_PRIVCONTROL, C_SEND, CmdCleanAdd(), CmdCleanControl(), CmdCleanSend(), ts_cmd_t::control, ts_cmd_t::header, ts_cmd_header_t::i_type, ts_cmd_t::send, and vlc_assert_unreachable.

Referenced by TsPushCmd(), TsRun(), TsStop(), and TsStorageDelete().

CmdCleanAdd()

static void CmdCleanAdd ( ts_cmd_add_t *  p_cmd )

static

References es_format_Clean(), ts_cmd_add_t::in, input_source_Release(), and ts_cmd_add_t::p_fmt.

Referenced by CmdClean(), and TsRun().

CmdCleanControl()

static void CmdCleanControl ( ts_cmd_control_t *  p_cmd )

static

References ts_cmd_control_t::es_fmt, es_format_Clean(), ES_OUT_SET_ES_FMT, ES_OUT_SET_GROUP_EPG, ES_OUT_SET_GROUP_EPG_EVENT, ES_OUT_SET_GROUP_META, ES_OUT_SET_META, ts_cmd_control_t::i_query, ts_cmd_control_t::in, input_source_Release(), ts_cmd_control_t::int_epg, ts_cmd_control_t::int_epg_evt, ts_cmd_control_t::int_meta, ts_cmd_control_t::p_epg, ts_cmd_control_t::p_evt, ts_cmd_control_t::p_fmt, ts_cmd_control_t::p_meta, ts_cmd_control_t::u, vlc_epg_Delete(), vlc_epg_event_Delete(), and vlc_meta_Delete().

Referenced by CmdClean(), and TsRun().

CmdCleanSend()

static void CmdCleanSend ( ts_cmd_send_t *  p_cmd )

static

References block_Release, and ts_cmd_send_t::p_block.

Referenced by CmdClean(), and TsRun().

CmdExecuteAdd()

static void CmdExecuteAdd ( es_out_t *  p_tsout, ts_cmd_add_t *  p_cmd  )

static

References es_out_callbacks::add, es_out_t::cbs, container_of, es_out_sys_t::i_es, ts_cmd_add_t::in, ts_cmd_add_t::p_es, es_out_id_t::p_es, ts_cmd_add_t::p_fmt, es_out_sys_t::p_out, es_out_sys_t::pp_es, and TAB_APPEND.

Referenced by Add(), and TsRun().

CmdExecuteControl()

static int CmdExecuteControl ( es_out_t *  p_tsout, ts_cmd_control_t *  p_cmd  )

static

References ts_cmd_control_t::b_bool, container_of, ts_cmd_control_t::es_bool, ts_cmd_control_t::es_fmt, ES_OUT_DEL_GROUP, es_out_in_Control(), ES_OUT_RESET_PCR, ES_OUT_RESTART_ES, ES_OUT_SET_EPG_TIME, ES_OUT_SET_ES, ES_OUT_SET_ES_CAT_POLICY, ES_OUT_SET_ES_DEFAULT, ES_OUT_SET_ES_FMT, ES_OUT_SET_ES_SCRAMBLED_STATE, ES_OUT_SET_ES_STATE, ES_OUT_SET_GROUP, ES_OUT_SET_GROUP_EPG, ES_OUT_SET_GROUP_EPG_EVENT, ES_OUT_SET_GROUP_META, ES_OUT_SET_GROUP_PCR, ES_OUT_SET_META, ES_OUT_SET_NEXT_DISPLAY_TIME, ES_OUT_SET_PCR, ES_OUT_UNSET_ES, ts_cmd_control_t::es_policy, ts_cmd_control_t::i_cat, ts_cmd_control_t::i_i64, ts_cmd_control_t::i_int, ts_cmd_control_t::i_policy, ts_cmd_control_t::i_query, ts_cmd_control_t::in, ts_cmd_control_t::int_epg, ts_cmd_control_t::int_epg_evt, ts_cmd_control_t::int_i64, ts_cmd_control_t::int_meta, ts_cmd_control_t::p_epg, ts_cmd_control_t::p_es, es_out_id_t::p_es, ts_cmd_control_t::p_evt, ts_cmd_control_t::p_fmt, ts_cmd_control_t::p_meta, es_out_sys_t::p_out, ts_cmd_control_t::u, vlc_assert_unreachable, and VLC_EGENERIC.

Referenced by ControlLocked(), and TsRun().

CmdExecuteDel()

static void CmdExecuteDel ( es_out_t *  p_tsout, ts_cmd_del_t *  p_cmd  )

static

References container_of, es_out_Del(), es_out_sys_t::i_es, ts_cmd_del_t::p_es, es_out_id_t::p_es, es_out_sys_t::p_out, es_out_sys_t::pp_es, and TAB_REMOVE.

Referenced by Del(), and TsRun().

CmdExecutePrivControl()

static int CmdExecutePrivControl ( es_out_t *  p_tsout, ts_cmd_privcontrol_t *  p_cmd  )

static

References container_of, ES_OUT_PRIV_SET_EOS, ES_OUT_PRIV_SET_JITTER, ES_OUT_PRIV_SET_MODE, ES_OUT_PRIV_SET_TIMES, es_out_PrivControl(), ts_cmd_privcontrol_t::f_position, ts_cmd_privcontrol_t::i_cr_average, ts_cmd_privcontrol_t::i_int, ts_cmd_privcontrol_t::i_length, ts_cmd_privcontrol_t::i_normal_time, ts_cmd_privcontrol_t::i_pts_delay, ts_cmd_privcontrol_t::i_pts_jitter, ts_cmd_privcontrol_t::i_query, ts_cmd_privcontrol_t::i_time, ts_cmd_privcontrol_t::jitter, es_out_sys_t::p_out, ts_cmd_privcontrol_t::times, ts_cmd_privcontrol_t::u, and vlc_assert_unreachable.

Referenced by PrivControlLocked(), and TsRun().

CmdExecuteSend()

static int CmdExecuteSend ( es_out_t *  p_tsout, ts_cmd_send_t *  p_cmd  )

static

References block_Release, container_of, es_out_Send(), ts_cmd_send_t::p_block, ts_cmd_send_t::p_es, es_out_id_t::p_es, es_out_sys_t::p_out, and VLC_EGENERIC.

Referenced by Send(), and TsRun().

CmdInitAdd()

static int CmdInitAdd ( ts_cmd_add_t *  p_cmd, input_source_t *  in, es_out_id_t *  p_es, const es_format_t *  p_fmt, bool  b_copy  )

static

References C_ADD, es_format_Copy(), ts_cmd_add_t::header, ts_cmd_header_t::i_date, ts_cmd_header_t::i_type, ts_cmd_add_t::in, input_source_Hold(), ts_cmd_add_t::p_es, ts_cmd_add_t::p_fmt, VLC_EGENERIC, VLC_SUCCESS, and vlc_tick_now().

Referenced by Add().

CmdInitControl()

static int CmdInitControl ( ts_cmd_control_t *  p_cmd, input_source_t *  in, int  i_query, va_list  args, bool  b_copy  )

static

References ts_cmd_control_t::b_bool, C_CONTROL, ts_cmd_control_t::es_bool, ts_cmd_control_t::es_fmt, es_format_Copy(), ES_OUT_DEL_GROUP, ES_OUT_RESET_PCR, ES_OUT_RESTART_ES, ES_OUT_SET_EPG_TIME, ES_OUT_SET_ES, ES_OUT_SET_ES_CAT_POLICY, ES_OUT_SET_ES_DEFAULT, ES_OUT_SET_ES_FMT, ES_OUT_SET_ES_SCRAMBLED_STATE, ES_OUT_SET_ES_STATE, ES_OUT_SET_GROUP, ES_OUT_SET_GROUP_EPG, ES_OUT_SET_GROUP_EPG_EVENT, ES_OUT_SET_GROUP_META, ES_OUT_SET_GROUP_PCR, ES_OUT_SET_META, ES_OUT_SET_NEXT_DISPLAY_TIME, ES_OUT_SET_PCR, ES_OUT_UNSET_ES, ts_cmd_control_t::es_policy, ts_cmd_control_t::header, ts_cmd_control_t::i_cat, ts_cmd_header_t::i_date, ts_cmd_control_t::i_i64, ts_cmd_control_t::i_int, ts_cmd_control_t::i_policy, ts_cmd_control_t::i_query, ts_cmd_header_t::i_type, ts_cmd_control_t::in, input_source_Hold(), ts_cmd_control_t::int_epg, ts_cmd_control_t::int_epg_evt, ts_cmd_control_t::int_i64, ts_cmd_control_t::int_meta, ts_cmd_control_t::p_epg, ts_cmd_control_t::p_es, ts_cmd_control_t::p_evt, ts_cmd_control_t::p_fmt, ts_cmd_control_t::p_meta, ts_cmd_control_t::u, vlc_assert_unreachable, VLC_EGENERIC, vlc_epg_Duplicate(), vlc_epg_event_Duplicate(), vlc_meta_Merge(), vlc_meta_New(), VLC_SUCCESS, and vlc_tick_now().

Referenced by ControlLocked().

CmdInitDel()

static int CmdInitDel ( ts_cmd_del_t *  p_cmd, es_out_id_t *  p_es  )

static

References C_DEL, ts_cmd_del_t::header, ts_cmd_header_t::i_date, ts_cmd_header_t::i_type, ts_cmd_del_t::p_es, VLC_SUCCESS, and vlc_tick_now().

Referenced by Del().

CmdInitPrivControl()

static int CmdInitPrivControl ( ts_cmd_privcontrol_t *  p_cmd, int  i_query, va_list  args, bool  b_copy  )

static

References C_PRIVCONTROL, ES_OUT_PRIV_SET_EOS, ES_OUT_PRIV_SET_JITTER, ES_OUT_PRIV_SET_MODE, ES_OUT_PRIV_SET_TIMES, ts_cmd_privcontrol_t::f_position, ts_cmd_privcontrol_t::header, ts_cmd_privcontrol_t::i_cr_average, ts_cmd_header_t::i_date, ts_cmd_privcontrol_t::i_int, ts_cmd_privcontrol_t::i_length, ts_cmd_privcontrol_t::i_normal_time, ts_cmd_privcontrol_t::i_pts_delay, ts_cmd_privcontrol_t::i_pts_jitter, ts_cmd_privcontrol_t::i_query, ts_cmd_privcontrol_t::i_time, ts_cmd_header_t::i_type, ts_cmd_privcontrol_t::jitter, ts_cmd_privcontrol_t::times, ts_cmd_privcontrol_t::u, vlc_assert_unreachable, VLC_SUCCESS, vlc_tick_now(), and VLC_UNUSED.

Referenced by PrivControlLocked().

CmdInitSend()

static void CmdInitSend ( ts_cmd_send_t *  p_cmd, es_out_id_t *  p_es, block_t *  p_block  )

static

References C_SEND, ts_cmd_send_t::header, ts_cmd_header_t::i_date, ts_cmd_header_t::i_type, ts_cmd_send_t::p_block, ts_cmd_send_t::p_es, and vlc_tick_now().

Referenced by Send().

Control()

static int Control ( es_out_t *  p_tsout, input_source_t *  in, int  i_query, va_list  args  )

static

References container_of, ControlLocked(), es_out_sys_t::lock, TsAutoStop(), vlc_mutex_lock(), and vlc_mutex_unlock().

ControlLocked()

static int ControlLocked ( es_out_t *  p_out, input_source_t *  in, int  i_query, va_list  args  )

static

References es_out_sys_t::b_delayed, CmdExecuteControl(), CmdInitControl(), container_of, ControlLockedGetEmpty(), ES_OUT_DEL_GROUP, ES_OUT_GET_EMPTY, ES_OUT_GET_ES_STATE, ES_OUT_GET_PCR_SYSTEM, es_out_in_Control(), es_out_in_vaControl(), ES_OUT_MODIFY_PCR_SYSTEM, ES_OUT_POST_SUBNODE, ES_OUT_RESET_PCR, ES_OUT_RESTART_ES, ES_OUT_SET_EPG_TIME, ES_OUT_SET_ES, ES_OUT_SET_ES_CAT_POLICY, ES_OUT_SET_ES_DEFAULT, ES_OUT_SET_ES_FMT, ES_OUT_SET_ES_SCRAMBLED_STATE, ES_OUT_SET_ES_STATE, ES_OUT_SET_GROUP, ES_OUT_SET_GROUP_EPG, ES_OUT_SET_GROUP_EPG_EVENT, ES_OUT_SET_GROUP_META, ES_OUT_SET_GROUP_PCR, ES_OUT_SET_META, ES_OUT_SET_NEXT_DISPLAY_TIME, ES_OUT_SET_PCR, ES_OUT_SPU_SET_HIGHLIGHT, ES_OUT_UNSET_ES, ES_OUT_VOUT_ADD_OVERLAY, ES_OUT_VOUT_DEL_OVERLAY, ES_OUT_VOUT_SET_MOUSE_EVENT, es_out_id_t::p_es, es_out_sys_t::p_out, es_out_sys_t::p_ts, TsPushCmd(), vlc_assert_unreachable, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by Control().

ControlLockedGetBuffering()

static int ControlLockedGetBuffering ( es_out_t *  p_out, bool *  pb_buffering  )

static

References es_out_sys_t::b_delayed, container_of, es_out_GetBuffering(), es_out_sys_t::p_out, and VLC_SUCCESS.

Referenced by PrivControlLocked().

ControlLockedGetEmpty()

static int ControlLockedGetEmpty ( es_out_t *  p_out, input_source_t *  in, bool *  pb_empty  )

static

References es_out_sys_t::b_delayed, container_of, ES_OUT_GET_EMPTY, es_out_in_Control(), es_out_sys_t::p_out, es_out_sys_t::p_ts, TsHasCmd(), and VLC_SUCCESS.

Referenced by ControlLocked().

ControlLockedGetWakeup()

static int ControlLockedGetWakeup ( es_out_t *  p_out, vlc_tick_t *  pi_wakeup  )

static

References es_out_sys_t::b_delayed, container_of, es_out_GetWakeup(), input_CanPaceControl(), es_out_sys_t::p_input, es_out_sys_t::p_out, and VLC_SUCCESS.

Referenced by PrivControlLocked().

ControlLockedSetFrameNext()

static int ControlLockedSetFrameNext ( es_out_t *  p_out )

static

References container_of, es_out_SetFrameNext(), and es_out_sys_t::p_out.

Referenced by PrivControlLocked().

ControlLockedSetPauseState()

static int ControlLockedSetPauseState ( es_out_t *  p_out, bool  b_source_paused, bool  b_paused, vlc_tick_t  i_date  )

static

References es_out_sys_t::b_delayed, es_out_sys_t::b_input_paused, es_out_sys_t::b_input_paused_source, container_of, es_out_SetPauseState(), input_CanPaceControl(), msg_Err, es_out_sys_t::p_input, es_out_sys_t::p_out, es_out_sys_t::p_ts, TsChangePause(), TsStart(), and VLC_EGENERIC.

Referenced by PrivControlLocked().

ControlLockedSetRate()

static int ControlLockedSetRate ( es_out_t *  p_out, float  src_rate, float  rate  )

static

References es_out_sys_t::b_delayed, container_of, es_out_SetRate(), input_CanPaceControl(), es_out_sys_t::input_rate, es_out_sys_t::input_rate_source, msg_Err, es_out_sys_t::p_input, es_out_sys_t::p_out, es_out_sys_t::p_ts, TsChangeRate(), TsStart(), and VLC_EGENERIC.

Referenced by PrivControlLocked().

Del()

static void Del ( es_out_t *  p_out, es_out_id_t *  p_es  )

static

References es_out_sys_t::b_delayed, CmdExecuteDel(), CmdInitDel(), container_of, es_out_sys_t::lock, es_out_sys_t::p_ts, TsAutoStop(), TsPushCmd(), vlc_mutex_lock(), and vlc_mutex_unlock().

Referenced by Destroy().

Destroy()

static void Destroy ( es_out_t *  p_out )

static

References es_out_sys_t::b_delayed, container_of, Del(), es_out_sys_t::i_es, es_out_sys_t::p_ts, es_out_sys_t::pp_es, es_out_sys_t::psz_tmp_path, TAB_CLEAN, and TsStop().

es_out_in_Control()

static int es_out_in_Control ( es_out_t *  p_out, input_source_t *  in, int  i_query,   ...  )

inlinestatic

References es_out_in_vaControl().

Referenced by CmdExecuteControl(), ControlLocked(), and ControlLockedGetEmpty().

es_out_in_vaControl()

static int es_out_in_vaControl ( es_out_t *  p_out, input_source_t *  in, int  i_query, va_list  args  )

inlinestatic

References es_out_t::cbs, and es_out_callbacks::control.

Referenced by ControlLocked(), and es_out_in_Control().

GetTmpFile()

static int GetTmpFile ( char **  filename, const char *  dirname  )

static

References asprintf(), DIR_SEP, strdup(), unlikely, vlc_mkdir(), and vlc_mkstemp().

Referenced by TsStorageNew().

input_EsOutTimeshiftNew()

es_out_t * input_EsOutTimeshiftNew	(	input_thread_t *	p_input,
		es_out_t *	p_next_out,
		float	rate
	)

References es_out_sys_t::b_delayed, es_out_sys_t::b_input_paused, es_out_sys_t::b_input_paused_source, es_out_t::cbs, count, DIR_SEP_CHAR, es_out_timeshift_cbs, es_out_sys_t::i_es, es_out_sys_t::i_tmp_size_max, es_out_sys_t::input_rate, es_out_sys_t::input_rate_source, es_out_sys_t::lock, msg_Dbg, es_out_sys_t::out, es_out_sys_t::p_input, es_out_sys_t::p_out, es_out_sys_t::p_ts, es_out_sys_t::pp_es, es_out_sys_t::psz_tmp_path, strdup(), TAB_INIT, var_CreateGetInteger(), var_InheritString(), vlc_alloc(), and vlc_mutex_init_recursive().

Referenced by Init().

PrivControl()

static int PrivControl ( es_out_t *  p_tsout, int  i_query, va_list  args  )

static

References container_of, es_out_sys_t::lock, PrivControlLocked(), TsAutoStop(), vlc_mutex_lock(), and vlc_mutex_unlock().

PrivControlLocked()

static int PrivControlLocked ( es_out_t *  p_tsout, int  i_query, va_list  args  )

static

References es_out_sys_t::b_delayed, CmdExecutePrivControl(), CmdInitPrivControl(), container_of, ControlLockedGetBuffering(), ControlLockedGetWakeup(), ControlLockedSetFrameNext(), ControlLockedSetPauseState(), ControlLockedSetRate(), ES_OUT_PRIV_GET_BUFFERING, ES_OUT_PRIV_GET_GROUP_FORCED, ES_OUT_PRIV_GET_WAKE_UP, ES_OUT_PRIV_RESTART_ES, ES_OUT_PRIV_SET_DELAY, ES_OUT_PRIV_SET_EOS, ES_OUT_PRIV_SET_ES, ES_OUT_PRIV_SET_ES_CAT_IDS, ES_OUT_PRIV_SET_ES_DELAY, ES_OUT_PRIV_SET_ES_LIST, ES_OUT_PRIV_SET_FRAME_NEXT, ES_OUT_PRIV_SET_JITTER, ES_OUT_PRIV_SET_MODE, ES_OUT_PRIV_SET_PAUSE_STATE, ES_OUT_PRIV_SET_RATE, ES_OUT_PRIV_SET_RECORD_STATE, ES_OUT_PRIV_SET_TIMES, ES_OUT_PRIV_SET_VBI_PAGE, ES_OUT_PRIV_SET_VBI_TRANSPARENCY, ES_OUT_PRIV_START_ALL_ES, ES_OUT_PRIV_STOP_ALL_ES, ES_OUT_PRIV_UNSET_ES, es_out_vaPrivControl(), es_out_sys_t::p_out, es_out_sys_t::p_ts, ts_cmd_t::privcontrol, TsPushCmd(), vlc_assert_unreachable, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by PrivControl().

Send()

static int Send ( es_out_t *  p_out, es_out_id_t *  p_es, block_t *  p_block  )

static

References es_out_sys_t::b_delayed, CmdExecuteSend(), CmdInitSend(), container_of, es_out_sys_t::lock, es_out_sys_t::p_ts, TsAutoStop(), TsPushCmd(), vlc_mutex_lock(), vlc_mutex_unlock(), and VLC_SUCCESS.

TsAutoStop()

static void TsAutoStop ( es_out_t *  p_out )

static

References es_out_sys_t::b_delayed, container_of, msg_Warn, es_out_sys_t::p_input, es_out_sys_t::p_ts, TsIsUnused(), and TsStop().

Referenced by Add(), Control(), Del(), PrivControl(), and Send().

TsChangePause()

static int TsChangePause ( ts_thread_t *  p_ts, bool  b_source_paused, bool  b_paused, vlc_tick_t  i_date  )

static

References ts_thread_t::b_paused, es_out_SetPauseState(), ts_thread_t::i_cmd_delay, ts_thread_t::i_pause_date, ts_thread_t::lock, ts_thread_t::p_out, vlc_cond_signal(), vlc_mutex_lock(), vlc_mutex_unlock(), and ts_thread_t::wait.

Referenced by ControlLockedSetPauseState().

TsChangeRate()

static int TsChangeRate ( ts_thread_t *  p_ts, float  src_rate, float  rate  )

static

References es_out_SetRate(), ts_thread_t::i_cmd_delay, ts_thread_t::i_rate_date, ts_thread_t::i_rate_delay, ts_thread_t::lock, ts_thread_t::p_out, ts_thread_t::rate, ts_thread_t::rate_source, vlc_mutex_lock(), and vlc_mutex_unlock().

Referenced by ControlLockedSetRate().

TsDestroy()

static void TsDestroy ( ts_thread_t *  p_ts )

static

Referenced by TsStart(), and TsStop().

TsHasCmd()

static bool TsHasCmd ( ts_thread_t *  p_ts )

static

References ts_thread_t::lock, ts_thread_t::p_storage_r, TsStorageIsEmpty(), vlc_mutex_lock(), and vlc_mutex_unlock().

Referenced by ControlLockedGetEmpty().

TsIsUnused()

static bool TsIsUnused ( ts_thread_t *  p_ts )

static

References ts_thread_t::b_paused, ts_thread_t::lock, ts_thread_t::p_storage_r, ts_thread_t::rate, ts_thread_t::rate_source, TsStorageIsEmpty(), vlc_mutex_lock(), and vlc_mutex_unlock().

Referenced by TsAutoStop().

TsPopCmdLocked()

static int TsPopCmdLocked ( ts_thread_t *  p_ts, ts_cmd_t *  p_cmd, bool  b_flush  )

static

References ts_thread_t::lock, ts_storage_t::p_next, ts_thread_t::p_storage_r, TsStorageDelete(), TsStorageIsEmpty(), TsStoragePopCmd(), VLC_EGENERIC, vlc_mutex_assert, and VLC_SUCCESS.

Referenced by TsRun(), and TsStop().

TsPushCmd()

static void TsPushCmd ( ts_thread_t *  p_ts, ts_cmd_t *  p_cmd  )

static

References CmdClean(), ts_thread_t::i_tmp_size_max, ts_thread_t::lock, ts_storage_t::p_next, ts_thread_t::p_storage_r, ts_thread_t::p_storage_w, ts_thread_t::psz_tmp_path, TsStorageIsFull(), TsStorageNew(), TsStoragePack(), TsStoragePushCmd(), vlc_cond_signal(), vlc_mutex_lock(), vlc_mutex_unlock(), and ts_thread_t::wait.

Referenced by Add(), ControlLocked(), Del(), PrivControlLocked(), and Send().

TsRun()

static void * TsRun ( void *  p_data )

static

References ts_cmd_t::add, ts_thread_t::b_paused, C_ADD, C_CONTROL, C_DEL, C_PRIVCONTROL, C_SEND, CmdClean(), CmdCleanAdd(), CmdCleanControl(), CmdCleanSend(), CmdExecuteAdd(), CmdExecuteControl(), CmdExecuteDel(), CmdExecutePrivControl(), CmdExecuteSend(), ts_cmd_t::control, ts_cmd_t::del, ts_thread_t::done, es_out_GetBuffering(), es_out_SetRate(), vlc_value_t::f_float, ts_cmd_t::header, ts_thread_t::i_buffering_delay, ts_thread_t::i_cmd_delay, ts_cmd_header_t::i_date, ts_thread_t::i_rate_date, ts_thread_t::i_rate_delay, ts_cmd_header_t::i_type, INPUT_CONTROL_SET_RATE, input_ControlPushHelper(), ts_thread_t::lock, msg_Warn, ts_thread_t::p_input, ts_thread_t::p_out, ts_thread_t::p_tsout, ts_cmd_t::privcontrol, ts_thread_t::rate, ts_thread_t::rate_source, ts_cmd_t::send, TsPopCmdLocked(), vlc_assert_unreachable, vlc_cond_wait(), vlc_mutex_lock(), vlc_mutex_unlock(), vlc_sem_timedwait(), vlc_sem_trywait(), vlc_thread_set_name(), and ts_thread_t::wait.

Referenced by TsStart().

TsStart()

static int TsStart ( es_out_t *  p_out )

static

References es_out_sys_t::b_delayed, es_out_sys_t::b_input_paused, es_out_sys_t::b_input_paused_source, ts_thread_t::b_paused, container_of, ts_thread_t::done, ts_thread_t::i_buffering_delay, ts_thread_t::i_cmd_delay, ts_thread_t::i_pause_date, ts_thread_t::i_rate_date, ts_thread_t::i_rate_delay, ts_thread_t::i_tmp_size_max, es_out_sys_t::i_tmp_size_max, es_out_sys_t::input_rate, es_out_sys_t::input_rate_source, ts_thread_t::lock, msg_Err, es_out_sys_t::p_input, ts_thread_t::p_input, ts_thread_t::p_out, es_out_sys_t::p_out, ts_thread_t::p_storage_r, ts_thread_t::p_storage_w, es_out_sys_t::p_ts, ts_thread_t::p_tsout, ts_thread_t::psz_tmp_path, es_out_sys_t::psz_tmp_path, ts_thread_t::rate, ts_thread_t::rate_source, ts_thread_t::thread, TsDestroy(), TsRun(), vlc_clone(), vlc_cond_init(), VLC_EGENERIC, vlc_mutex_init(), vlc_sem_init(), VLC_SUCCESS, vlc_tick_now(), and ts_thread_t::wait.

Referenced by ControlLockedSetPauseState(), and ControlLockedSetRate().

TsStop()

static void TsStop ( ts_thread_t *  p_ts )

static

References CmdClean(), ts_thread_t::done, ts_thread_t::lock, ts_storage_t::p_next, ts_thread_t::p_storage_r, ts_thread_t::thread, TsDestroy(), TsPopCmdLocked(), TsStorageDelete(), vlc_cond_signal(), vlc_join(), vlc_mutex_lock(), vlc_mutex_unlock(), vlc_sem_post(), and ts_thread_t::wait.

Referenced by Destroy(), and TsAutoStop().

TsStorageDelete()

static void TsStorageDelete ( ts_storage_t *  p_storage )

static

References CmdClean(), ts_storage_t::p_cmd_buf, ts_storage_t::p_cmd_r, ts_storage_t::p_cmd_w, ts_storage_t::p_filer, ts_storage_t::p_filew, TsStoragePopCmd(), and vlc_unlink().

Referenced by TsPopCmdLocked(), TsStop(), and TsStorageNew().

TsStorageIsEmpty()

static bool TsStorageIsEmpty ( ts_storage_t *  p_storage )

static

References ts_storage_t::p_cmd_r, and ts_storage_t::p_cmd_w.

Referenced by TsHasCmd(), TsIsUnused(), TsPopCmdLocked(), and TsStoragePopCmd().

TsStorageIsFull()

static bool TsStorageIsFull ( ts_storage_t *  p_storage, const ts_cmd_t *  p_cmd  )

static

References C_SEND, ts_cmd_t::header, vlc_frame_t::i_buffer, ts_storage_t::i_cmd_buf, ts_storage_t::i_file_max, ts_storage_t::i_file_size, ts_cmd_header_t::i_type, MAX_COMMAND_SIZE, ts_cmd_send_t::p_block, ts_storage_t::p_cmd_buf, ts_storage_t::p_cmd_w, and ts_cmd_t::send.

Referenced by TsPushCmd(), and TsStoragePushCmd().

TsStorageNew()

static ts_storage_t * TsStorageNew ( const char *  psz_path, int64_t  i_tmp_size_max  )

static

References GetTmpFile(), ts_storage_t::i_cmd_buf, ts_storage_t::i_file_max, ts_storage_t::i_file_size, MAX_COMMAND_SIZE, ts_storage_t::p_cmd_buf, ts_storage_t::p_cmd_r, ts_storage_t::p_cmd_w, ts_storage_t::p_filer, ts_storage_t::p_filew, ts_storage_t::p_next, TS_STORAGE_COMMAND_PREALLOC, TsStorageDelete(), unlikely, vlc_alloc(), vlc_close(), vlc_fopen(), and vlc_unlink().

Referenced by TsPushCmd().

TsStoragePack()

static void TsStoragePack ( ts_storage_t *  p_storage )

static

References ts_storage_t::i_cmd_buf, ts_storage_t::p_cmd_buf, ts_storage_t::p_cmd_r, and ts_storage_t::p_cmd_w.

Referenced by TsPushCmd().

TsStoragePopCmd()

static void TsStoragePopCmd ( ts_storage_t *  p_storage, ts_cmd_t *  p_cmd, bool  b_flush  )

static

References block_Alloc, C_SEND, ts_cmd_t::header, vlc_frame_t::i_buffer, vlc_frame_t::i_dts, vlc_frame_t::i_flags, vlc_frame_t::i_length, vlc_frame_t::i_nb_samples, ts_cmd_send_t::i_offset, vlc_frame_t::i_pts, ts_cmd_header_t::i_type, ts_cmd_send_t::p_block, vlc_frame_t::p_buffer, ts_storage_t::p_cmd_r, ts_storage_t::p_filer, ts_cmd_t::send, TsStorageIsEmpty(), and TsStorageSizeofCommand.

Referenced by TsPopCmdLocked(), and TsStorageDelete().

TsStoragePushCmd()

static void TsStoragePushCmd ( ts_storage_t *  p_storage, const ts_cmd_t *  p_cmd, bool  b_flush  )

static

References block_Release, C_SEND, ts_cmd_t::header, vlc_frame_t::i_buffer, ts_storage_t::i_file_size, ts_cmd_send_t::i_offset, ts_cmd_header_t::i_type, ts_cmd_send_t::p_block, vlc_frame_t::p_buffer, ts_storage_t::p_cmd_w, ts_storage_t::p_filew, ts_cmd_t::send, TsStorageIsFull(), and TsStorageSizeofCommand.

Referenced by TsPushCmd().

Variable Documentation

es_out_timeshift_cbs

const struct es_out_callbacks es_out_timeshift_cbs

static

Initial value:

=
{
    .add = Add,
    .send = Send,
    .del = Del,
    .control = Control,
    .destroy = Destroy,
    .priv_control = PrivControl,
}

Referenced by input_EsOutTimeshiftNew().

TsStorageSizeofCommand

const size_t TsStorageSizeofCommand[]

static

Initial value:

=
{
    [C_ADD] = sizeof(ts_cmd_add_t),
    [C_SEND] = sizeof(ts_cmd_send_t),
    [C_DEL] = sizeof(ts_cmd_del_t),
    [C_CONTROL] = sizeof(ts_cmd_control_t),
    [C_PRIVCONTROL] = sizeof(ts_cmd_privcontrol_t)
}

Referenced by TsStoragePopCmd(), and TsStoragePushCmd().