stream.c File Reference

Include dependency graph for stream.c:


Data Structures

struct  stream_track_t
struct  access_entry_t
struct  stream_sys_t
 ************************************************************************** Struct definitions More...

Defines

#define STREAM_CACHE_TRACK   3
#define STREAM_CACHE_SIZE   (4*STREAM_CACHE_TRACK*1024*1024)
#define STREAM_CACHE_PREBUFFER_SIZE   (128)
#define STREAM_READ_ATONCE   1024
#define STREAM_CACHE_TRACK_SIZE   (STREAM_CACHE_SIZE/STREAM_CACHE_TRACK)
#define STREAM_PROBE_LINE   2048
 Read from the stream untill first newline.
#define STREAM_LINE_MAX   (2048*100)

Enumerations

enum  stream_read_method_t { STREAM_METHOD_BLOCK, STREAM_METHOD_STREAM }

Functions

static int AStreamReadBlock (stream_t *s, void *p_read, unsigned int i_read)
static int AStreamPeekBlock (stream_t *s, const uint8_t **p_peek, unsigned int i_read)
static int AStreamSeekBlock (stream_t *s, uint64_t i_pos)
static void AStreamPrebufferBlock (stream_t *s)
static block_t * AReadBlock (stream_t *s, bool *pb_eof)
static int AStreamReadStream (stream_t *s, void *p_read, unsigned int i_read)
static int AStreamPeekStream (stream_t *s, const uint8_t **pp_peek, unsigned int i_read)
static int AStreamSeekStream (stream_t *s, uint64_t i_pos)
static void AStreamPrebufferStream (stream_t *s)
static int AReadStream (stream_t *s, void *p_read, unsigned int i_read)
static int AStreamControl (stream_t *s, int i_query, va_list)
static void AStreamDestroy (stream_t *s)
static void UStreamDestroy (stream_t *s)
static int ASeek (stream_t *s, uint64_t i_pos)
stream_t * stream_CommonNew (vlc_object_t *p_obj)
void stream_CommonDelete (stream_t *s)
stream_t * stream_UrlNew (vlc_object_t *p_parent, const char *psz_url)
 Create a stream_t reading from an URL.
stream_t * stream_AccessNew (access_t *p_access, char **ppsz_list)
 This function creates a stream_t from a provided access_t.
static void AStreamControlReset (stream_t *s)
static void AStreamControlUpdate (stream_t *s)
static int AStreamRefillBlock (stream_t *s)
static int AStreamRefillStream (stream_t *s)
static int AStreamReadNoSeekStream (stream_t *s, void *p_read, unsigned int i_read)
char * stream_ReadLine (stream_t *s)
int stream_Read (stream_t *s, void *p_read, int i_read)
 Try to read "i_read" bytes into a buffer pointed by "p_read".
int stream_Peek (stream_t *s, const uint8_t **pp_peek, int i_peek)
 Store in pp_peek a pointer to the next "i_peek" bytes in the stream.
int stream_vaControl (stream_t *s, int i_query, va_list args)
 Use to control the "stream_t *".
void stream_Delete (stream_t *s)
 Destroy a stream.
int stream_Control (stream_t *s, int i_query,...)
block_t * stream_Block (stream_t *s, int i_size)
 Read "i_size" bytes and store them in a block_t.

Define Documentation

#define STREAM_CACHE_PREBUFFER_SIZE   (128)

Referenced by AStreamPrebufferBlock(), and AStreamPrebufferStream().

#define STREAM_CACHE_SIZE   (4*STREAM_CACHE_TRACK*1024*1024)

Referenced by AStreamRefillBlock(), AStreamSeekBlock(), and stream_AccessNew().

#define STREAM_CACHE_TRACK   3

Referenced by AStreamControlReset(), AStreamSeekStream(), and stream_AccessNew().

#define STREAM_CACHE_TRACK_SIZE   (STREAM_CACHE_SIZE/STREAM_CACHE_TRACK)

Referenced by AStreamPeekStream(), AStreamPrebufferStream(), AStreamReadNoSeekStream(), AStreamRefillStream(), and stream_AccessNew().

#define STREAM_LINE_MAX   (2048*100)

Referenced by stream_ReadLine().

#define STREAM_PROBE_LINE   2048

Read from the stream untill first newline.

Parameters:
s Stream handle to read from
Returns:
A pointer to the allocated output string. You need to free this when you are done.

Referenced by stream_ReadLine().

#define STREAM_READ_ATONCE   1024

Referenced by AStreamReadNoSeekStream(), AStreamSeekStream(), and stream_AccessNew().

Enumeration Type Documentation

enum stream_read_method_t

Enumerator:
STREAM_METHOD_BLOCK 
STREAM_METHOD_STREAM 

Function Documentation

static block_t * AReadBlock ( stream_t *  s,
bool *  pb_eof 
) [static]

References access_Delete(), access_New, access_t::b_die, access_t::b_eof, input_thread_private_t::counters, input_thread_private_t::counters_lock, block_t::i_buffer, stream_sys_t::i_list, stream_sys_t::i_list_index, access_t::info, libvlc_stats, stream_sys_t::list, msg_Dbg, input_thread_t::p, stream_sys_t::p_access, stream_t::p_input, input_thread_private_t::p_input_bitrate, stream_sys_t::p_list_access, vlc_object_t::p_parent, stream_t::p_parent, input_thread_private_t::p_read_bytes, input_thread_private_t::p_read_packets, stream_t::p_sys, p_sys, access_t::pf_block, access_t::psz_access, psz_name, access_entry_t::psz_path, stats_UpdateFloat, stats_UpdateInteger, vlc_internals, vlc_mutex_lock(), vlc_mutex_unlock(), VLC_OBJECT_INPUT, and vlc_object_kill.

Referenced by AStreamPrebufferBlock(), and AStreamRefillBlock().

static int AReadStream ( stream_t *  s,
void *  p_read,
unsigned int  i_read 
) [static]

References access_Delete(), access_New, access_t::b_die, input_thread_private_t::counters, input_thread_private_t::counters_lock, stream_sys_t::i_list, stream_sys_t::i_list_index, stream_sys_t::list, msg_Dbg, input_thread_t::p, stream_sys_t::p_access, stream_t::p_input, input_thread_private_t::p_input_bitrate, stream_sys_t::p_list_access, vlc_object_t::p_parent, stream_t::p_parent, input_thread_private_t::p_read_bytes, input_thread_private_t::p_read_packets, stream_t::p_sys, p_sys, access_t::pf_read, access_t::psz_access, psz_name, access_entry_t::psz_path, stats_UpdateFloat, stats_UpdateInteger, vlc_internals, vlc_mutex_lock(), vlc_mutex_unlock(), VLC_OBJECT_INPUT, and vlc_object_kill.

Referenced by AStreamPrebufferStream(), and AStreamRefillStream().

static int ASeek ( stream_t *  s,
uint64_t  i_pos 
) [static]

References access_Delete(), access_New, i, stream_sys_t::i_list, stream_sys_t::i_list_index, access_entry_t::i_size, stream_sys_t::list, list, msg_Dbg, stream_sys_t::p_access, stream_t::p_input, stream_sys_t::p_list_access, stream_t::p_sys, p_sys, access_t::pf_seek, access_t::psz_access, psz_name, and access_entry_t::psz_path.

Referenced by AStreamSeekBlock(), and AStreamSeekStream().

static int AStreamControl ( stream_t *  s,
int  i_query,
va_list  args 
) [static]

References ACCESS_CAN_FASTSEEK, ACCESS_CAN_SEEK, access_Control(), ACCESS_GET_CONTENT_TYPE, ACCESS_GET_PRIVATE_ID_STATE, ACCESS_SET_PRIVATE_ID_CA, ACCESS_SET_PRIVATE_ID_STATE, ACCESS_SET_SEEKPOINT, ACCESS_SET_TITLE, access_vaControl(), AStreamControlReset(), AStreamControlUpdate(), AStreamSeekBlock(), AStreamSeekStream(), i, stream_sys_t::i_list, stream_sys_t::i_pos, access_t::i_size, access_entry_t::i_size, access_t::info, stream_sys_t::list, stream_sys_t::method, msg_Err, stream_sys_t::p_access, stream_t::p_sys, p_sys, STREAM_CAN_FASTSEEK, STREAM_CAN_SEEK, STREAM_CONTROL_ACCESS, STREAM_GET_CONTENT_TYPE, STREAM_GET_POSITION, STREAM_GET_SIZE, STREAM_METHOD_BLOCK, STREAM_METHOD_STREAM, STREAM_SET_POSITION, STREAM_SET_RECORD_STATE, STREAM_UPDATE_SIZE, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by stream_AccessNew().

static void AStreamControlReset ( stream_t *  s  )  [static]

References AStreamPrebufferBlock(), AStreamPrebufferStream(), stream_sys_t::block, block_ChainRelease(), i, stream_track_t::i_date, stream_track_t::i_end, stream_sys_t::i_offset, access_t::i_pos, stream_sys_t::i_pos, stream_sys_t::i_size, stream_track_t::i_start, stream_sys_t::i_start, stream_sys_t::i_tk, stream_sys_t::i_used, access_t::info, stream_sys_t::method, stream_sys_t::p_access, stream_sys_t::p_current, stream_sys_t::p_first, stream_t::p_sys, p_sys, stream_sys_t::pp_last, stream_sys_t::stream, STREAM_CACHE_TRACK, STREAM_METHOD_BLOCK, STREAM_METHOD_STREAM, and stream_sys_t::tk.

Referenced by AStreamControl().

static void AStreamControlUpdate ( stream_t *  s  )  [static]

References i, stream_sys_t::i_list, stream_sys_t::i_list_index, access_t::i_pos, stream_sys_t::i_pos, access_entry_t::i_size, access_t::info, stream_sys_t::list, stream_sys_t::p_access, stream_t::p_sys, and p_sys.

Referenced by AStreamControl().

static void AStreamDestroy ( stream_t *  s  )  [static]

References access_Delete(), stream_sys_t::block, block_ChainRelease(), stream_sys_t::i_list, stream_sys_t::list, stream_sys_t::method, stream_sys_t::p_access, stream_sys_t::p_buffer, stream_sys_t::p_first, stream_sys_t::p_list_access, stream_sys_t::p_peek, stream_t::p_sys, p_sys, access_entry_t::psz_path, stream_sys_t::stream, stream_CommonDelete(), and STREAM_METHOD_BLOCK.

Referenced by stream_AccessNew(), and UStreamDestroy().

static int AStreamPeekBlock ( stream_t *  s,
const uint8_t **  p_peek,
unsigned int  i_read 
) [static]

References __MAX, __MIN, AStreamRefillBlock(), b, stream_sys_t::block, block_t::i_buffer, stream_sys_t::i_offset, stream_sys_t::i_peek, stream_sys_t::i_pos, stream_sys_t::i_size, stream_sys_t::i_start, block_t::p_buffer, stream_sys_t::p_current, block_t::p_next, stream_sys_t::p_peek, stream_t::p_sys, p_sys, stream_sys_t::pp_last, and realloc_or_free().

Referenced by stream_AccessNew().

static int AStreamPeekStream ( stream_t *  s,
const uint8_t **  pp_peek,
unsigned int  i_read 
) [static]

References AStreamRefillStream(), stream_track_t::i_end, stream_sys_t::i_offset, stream_sys_t::i_peek, stream_sys_t::i_pos, stream_track_t::i_start, stream_sys_t::i_tk, stream_sys_t::i_used, msg_Dbg, stream_track_t::p_buffer, stream_sys_t::p_peek, stream_t::p_sys, p_sys, realloc_or_free(), stream_sys_t::stream, STREAM_CACHE_TRACK_SIZE, stream_sys_t::tk, and tk.

Referenced by stream_AccessNew().

static void AStreamPrebufferBlock ( stream_t *  s  )  [static]

References AReadBlock(), b, stream_t::b_die, stream_sys_t::block, block_t::i_buffer, stream_sys_t::i_bytes, stream_sys_t::i_read_count, stream_sys_t::i_read_time, stream_sys_t::i_size, mdate(), msg_Dbg, stream_sys_t::p_current, stream_sys_t::p_first, block_t::p_next, stream_t::p_sys, p_sys, stream_sys_t::pp_last, stream_sys_t::stat, and STREAM_CACHE_PREBUFFER_SIZE.

Referenced by AStreamControlReset(), and stream_AccessNew().

static void AStreamPrebufferStream ( stream_t *  s  )  [static]

References __MIN, AReadStream(), stream_t::b_die, stream_sys_t::i_bytes, stream_track_t::i_end, stream_sys_t::i_read_count, stream_sys_t::i_read_size, stream_sys_t::i_read_time, stream_track_t::i_start, stream_sys_t::i_tk, mdate(), msg_Dbg, stream_track_t::p_buffer, stream_t::p_sys, p_sys, stream_sys_t::stat, stream_sys_t::stream, STREAM_CACHE_PREBUFFER_SIZE, STREAM_CACHE_TRACK_SIZE, stream_sys_t::tk, and tk.

Referenced by AStreamControlReset(), and stream_AccessNew().

static int AStreamReadBlock ( stream_t *  s,
void *  p_read,
unsigned int  i_read 
) [static]

References __MAX, __MIN, ACCESS_CAN_SEEK, access_Control(), AStreamRefillBlock(), AStreamSeekBlock(), stream_sys_t::block, block_t::i_buffer, stream_sys_t::i_offset, stream_sys_t::i_pos, stream_sys_t::p_access, block_t::p_buffer, stream_sys_t::p_current, block_t::p_next, stream_t::p_sys, and p_sys.

Referenced by stream_AccessNew().

static int AStreamReadNoSeekStream ( stream_t *  s,
void *  p_read,
unsigned int  i_read 
) [static]

References __MAX, __MIN, AStreamRefillStream(), stream_track_t::i_end, stream_sys_t::i_offset, stream_sys_t::i_pos, stream_track_t::i_start, stream_sys_t::i_tk, stream_sys_t::i_used, msg_Dbg, stream_track_t::p_buffer, stream_t::p_sys, p_sys, stream_sys_t::stream, STREAM_CACHE_TRACK_SIZE, STREAM_READ_ATONCE, stream_sys_t::tk, and tk.

Referenced by AStreamReadStream(), and AStreamSeekStream().

static int AStreamReadStream ( stream_t *  s,
void *  p_read,
unsigned int  i_read 
) [static]

References AStreamReadNoSeekStream(), AStreamSeekStream(), stream_sys_t::i_pos, stream_t::p_sys, and p_sys.

Referenced by stream_AccessNew().

static int AStreamRefillBlock ( stream_t *  s  )  [static]

References AReadBlock(), b, stream_t::b_die, stream_sys_t::block, block_Release(), block_t::i_buffer, stream_sys_t::i_bytes, stream_sys_t::i_read_count, stream_sys_t::i_read_time, stream_sys_t::i_size, stream_sys_t::i_start, mdate(), stream_sys_t::p_current, stream_sys_t::p_first, block_t::p_next, stream_t::p_sys, p_sys, stream_sys_t::pp_last, stream_sys_t::stat, STREAM_CACHE_SIZE, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by AStreamPeekBlock(), AStreamReadBlock(), and AStreamSeekBlock().

static int AStreamRefillStream ( stream_t *  s  )  [static]

References __MIN, AReadStream(), stream_t::b_die, stream_sys_t::i_bytes, stream_track_t::i_end, stream_sys_t::i_offset, stream_sys_t::i_read_count, stream_sys_t::i_read_time, stream_track_t::i_start, stream_sys_t::i_tk, stream_sys_t::i_used, mdate(), msg_Dbg, stream_track_t::p_buffer, stream_t::p_sys, p_sys, stream_sys_t::stat, stream_sys_t::stream, STREAM_CACHE_TRACK_SIZE, stream_sys_t::tk, tk, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by AStreamPeekStream(), AStreamReadNoSeekStream(), and AStreamSeekStream().

static int AStreamSeekBlock ( stream_t *  s,
uint64_t  i_pos 
) [static]

References ACCESS_CAN_FASTSEEK, ACCESS_CAN_SEEK, access_Control(), ASeek(), AStreamRefillBlock(), b, stream_sys_t::block, block_ChainRelease(), block_t::i_buffer, stream_sys_t::i_bytes, stream_sys_t::i_offset, stream_sys_t::i_pos, stream_sys_t::i_read_count, stream_sys_t::i_seek_count, stream_sys_t::i_seek_time, stream_sys_t::i_size, stream_sys_t::i_start, mdate(), msg_Dbg, msg_Err, msg_Warn, stream_sys_t::p_access, stream_sys_t::p_current, stream_sys_t::p_first, block_t::p_next, stream_t::p_sys, p_sys, stream_sys_t::pp_last, stream_sys_t::stat, STREAM_CACHE_SIZE, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by AStreamControl(), and AStreamReadBlock().

static int AStreamSeekStream ( stream_t *  s,
uint64_t  i_pos 
) [static]

References __MIN, ACCESS_CAN_FASTSEEK, ACCESS_CAN_SEEK, access_Control(), ASeek(), AStreamReadNoSeekStream(), AStreamRefillStream(), i, stream_track_t::i_date, stream_track_t::i_end, stream_sys_t::i_offset, stream_sys_t::i_pos, stream_sys_t::i_read_size, stream_track_t::i_start, stream_sys_t::i_tk, stream_sys_t::i_used, mdate(), msg_Dbg, msg_Err, msg_Warn, stream_sys_t::p_access, stream_t::p_sys, p_sys, stream_sys_t::stream, STREAM_CACHE_TRACK, STREAM_READ_ATONCE, tk, stream_sys_t::tk, VLC_EGENERIC, and VLC_SUCCESS.

Referenced by AStreamControl(), and AStreamReadStream().

stream_t* stream_AccessNew ( access_t *  p_access,
char **  ppsz_list 
)

This function creates a stream_t from a provided access_t.

An optional NULL terminated list of file may be provided. The content of these extra files will be concatenated after to the main access.

XXX ppsz_list is treated as const (I failed to avoid a warning when using const keywords for pointer of pointers)

References ACCESS_CAN_FASTSEEK, access_Control(), access_Delete(), access_New, AStreamControl(), AStreamDestroy(), AStreamPeekBlock(), AStreamPeekStream(), AStreamPrebufferBlock(), AStreamPrebufferStream(), AStreamReadBlock(), AStreamReadStream(), stream_sys_t::b_fastseek, stream_sys_t::block, i, stream_sys_t::i_bytes, stream_track_t::i_date, stream_track_t::i_end, stream_sys_t::i_list, stream_sys_t::i_list_index, stream_sys_t::i_offset, stream_sys_t::i_peek, access_t::i_pos, stream_sys_t::i_pos, stream_sys_t::i_read_count, stream_sys_t::i_read_size, stream_sys_t::i_read_time, stream_sys_t::i_seek_count, stream_sys_t::i_seek_time, stream_sys_t::i_size, access_t::i_size, access_entry_t::i_size, stream_track_t::i_start, stream_sys_t::i_start, stream_sys_t::i_tk, stream_sys_t::i_used, access_t::info, stream_sys_t::list, stream_sys_t::method, msg_Dbg, msg_Err, stream_sys_t::p_access, stream_track_t::p_buffer, stream_sys_t::p_buffer, stream_sys_t::p_current, stream_sys_t::p_first, access_t::p_input, stream_t::p_input, stream_sys_t::p_list_access, stream_sys_t::p_peek, stream_t::p_sys, p_sys, access_t::pf_block, stream_t::pf_control, stream_t::pf_destroy, stream_t::pf_peek, stream_t::pf_read, stream_sys_t::pp_last, access_t::psz_access, access_t::psz_location, psz_name, access_entry_t::psz_path, stream_t::psz_path, stream_sys_t::stat, strdup(), stream_sys_t::stream, STREAM_CACHE_SIZE, STREAM_CACHE_TRACK, STREAM_CACHE_TRACK_SIZE, stream_CommonDelete(), stream_CommonNew(), STREAM_METHOD_BLOCK, STREAM_METHOD_STREAM, STREAM_READ_ATONCE, TAB_APPEND, TAB_INIT, stream_sys_t::tk, VLC_OBJECT, and vlc_object_attach.

Referenced by InputSourceInit(), and stream_UrlNew().

void stream_CommonDelete ( stream_t *  s  ) 

References stream_text_t::conv, stream_t::p_text, stream_t::psz_path, vlc_iconv_close(), and vlc_object_release.

Referenced by AStreamDestroy(), Delete(), DStreamDelete(), stream_AccessNew(), stream_DemuxNew(), stream_FilterNew(), stream_MemoryNew(), and StreamDelete().

stream_t* stream_CommonNew ( vlc_object_t *  p_obj  ) 

References stream_text_t::b_little_endian, stream_text_t::conv, stream_text_t::i_char_width, stream_t::p_text, vlc_custom_create, VLC_OBJECT_GENERIC, and vlc_object_release.

Referenced by stream_AccessNew(), stream_DemuxNew(), stream_FilterNew(), and stream_MemoryNew().

static void UStreamDestroy ( stream_t *  s  )  [static]

References access_Delete(), AStreamDestroy(), and stream_t::p_parent.

Referenced by stream_UrlNew().

Generated on Tue May 25 08:05:34 2010 for VLC by  doxygen 1.5.6