rtmp_amf_flv.c File Reference

Include dependency graph for rtmp_amf_flv.c:

Functions
static rtmp_packet_t *	rtmp_new_packet (rtmp_control_thread_t *p_thread, uint8_t stream_index, uint32_t timestamp, uint8_t content_type, uint32_t src_dst, rtmp_body_t *body)
static block_t *	rtmp_new_block (rtmp_control_thread_t *p_thread, uint8_t *buffer, int32_t length_buffer)
static rtmp_packet_t *	rtmp_encode_onBWDone (rtmp_control_thread_t *p_thread, double number)
static rtmp_packet_t *	rtmp_encode_server_bw (rtmp_control_thread_t *p_thread, uint32_t number)
static rtmp_packet_t *	rtmp_encode_NetConnection_connect_result (rtmp_control_thread_t *p_thread, double number)
static rtmp_packet_t *	rtmp_encode_createStream_result (rtmp_control_thread_t *p_thread, double stream_client, double stream_server)
static rtmp_packet_t *	rtmp_encode_ping_reset_stream (rtmp_control_thread_t *p_thread)
static rtmp_packet_t *	rtmp_encode_ping_clear_stream (rtmp_control_thread_t *p_thread, uint32_t src_dst)
static rtmp_packet_t *	rtmp_encode_NetStream_play_reset_onStatus (rtmp_control_thread_t *p_thread, char *psz_media)
static rtmp_packet_t *	rtmp_encode_NetStream_play_start_onStatus (rtmp_control_thread_t *p_thread, char *psz_media)
static uint8_t	rtmp_encode_header_size (vlc_object_t *p_this, uint8_t header_size)
static uint8_t	rtmp_decode_header_size (vlc_object_t *p_this, uint8_t header_size)
static uint8_t	rtmp_get_stream_index (uint8_t content_type)
static void	rtmp_body_append (rtmp_body_t *rtmp_body, uint8_t *buffer, uint32_t length)
static uint8_t *	rtmp_encode_ping (uint16_t type, uint32_t src_dst, uint32_t third_arg, uint32_t fourth_arg)
static uint8_t *	amf_encode_element (uint8_t element, const void *value)
static uint8_t *	amf_encode_object_variable (const char *key, uint8_t element, const void *value)
static double	amf_decode_number (uint8_t **buffer)
static int	amf_decode_boolean (uint8_t **buffer)
static char *	amf_decode_string (uint8_t **buffer)
static char *	amf_decode_object (uint8_t **buffer)
static void	flv_rebuild (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
static void	flv_get_metadata_audio (rtmp_control_thread_t *p_thread, rtmp_packet_t *packet_audio, uint8_t *stereo, uint8_t *audiosamplesize, uint32_t *audiosamplerate, uint8_t *audiocodecid)
static void	flv_get_metadata_video (rtmp_control_thread_t *p_thread, rtmp_packet_t *packet_video, uint8_t *videocodecid, uint8_t *frametype)
static rtmp_packet_t *	flv_build_onMetaData (access_t *p_access, uint64_t duration, uint8_t stereo, uint8_t audiosamplesize, uint32_t audiosamplerate, uint8_t audiocodecid, uint8_t videocodecid)
int	rtmp_handshake_passive (vlc_object_t *p_this, int fd)
int	rtmp_handshake_active (vlc_object_t *p_this, int fd)
static int	write_rtmp (rtmp_control_thread_t *p_thread, uint8_t *buf, rtmp_packet_t *pkt, const char *errmsg)
int	rtmp_connect_active (rtmp_control_thread_t *p_thread)
int	rtmp_connect_passive (rtmp_control_thread_t *p_thread)
static void	rtmp_packet_free (rtmp_packet_t *pkt)
rtmp_packet_t *	rtmp_build_bytes_read (rtmp_control_thread_t *p_thread, uint32_t reply)
rtmp_packet_t *	rtmp_build_publish_start (rtmp_control_thread_t *p_thread)
rtmp_packet_t *	rtmp_build_flv_over_rtmp (rtmp_control_thread_t *p_thread, block_t *p_buffer)
rtmp_packet_t *	rtmp_read_net_packet (rtmp_control_thread_t *p_thread)
static void	rtmp_handler_null (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
static void	rtmp_handler_chunk_size (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
static void	rtmp_handler_audio_data (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
static void	rtmp_handler_video_data (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
static void	rtmp_handler_notify (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
static void	rtmp_handler_invoke (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
uint8_t *	rtmp_encode_packet (rtmp_control_thread_t *p_thread, rtmp_packet_t *rtmp_packet)
rtmp_body_t *	rtmp_body_new (int length_buffer)
void	rtmp_body_reset (rtmp_body_t *rtmp_body)
block_t *	flv_get_metadata (access_t *p_access)
block_t *	flv_insert_header (access_t *p_access, block_t *first_packet)
void	rtmp_init_handler (rtmp_handler_t *rtmp_handler)
Variables
const uint8_t	RTMP_HEADER_SIZE_MASK = 0xC0
const uint8_t	RTMP_HEADER_SIZE_12 = 0x00
const uint8_t	RTMP_HEADER_SIZE_8 = 0x40
const uint8_t	RTMP_HEADER_SIZE_4 = 0x80
const uint8_t	RTMP_HEADER_SIZE_1 = 0xC0
const uint8_t	RTMP_HEADER_STREAM_MAX = 64
const uint8_t	RTMP_HEADER_STREAM_INDEX_MASK = 0x3F
const uint8_t	RTMP_HANDSHAKE = 0x03
const uint16_t	RTMP_HANDSHAKE_BODY_SIZE = 1536
const uint8_t	RTMP_CONTENT_TYPE_CHUNK_SIZE = 0x01
const uint8_t	RTMP_CONTENT_TYPE_UNKNOWN_02 = 0x02
const uint8_t	RTMP_CONTENT_TYPE_BYTES_READ = 0x03
const uint8_t	RTMP_CONTENT_TYPE_PING = 0x04
const uint8_t	RTMP_CONTENT_TYPE_SERVER_BW = 0x05
const uint8_t	RTMP_CONTENT_TYPE_CLIENT_BW = 0x06
const uint8_t	RTMP_CONTENT_TYPE_UNKNOWN_07 = 0x07
const uint8_t	RTMP_CONTENT_TYPE_AUDIO_DATA = 0x08
const uint8_t	RTMP_CONTENT_TYPE_VIDEO_DATA = 0x09
const uint8_t	RTMP_CONTENT_TYPE_UNKNOWN_0A_0E = 0x0A
const uint8_t	RTMP_CONTENT_TYPE_FLEX_STREAM = 0x0F
const uint8_t	RTMP_CONTENT_TYPE_FLEX_SHARED_OBJECT = 0x10
const uint8_t	RTMP_CONTENT_TYPE_MESSAGE = 0x11
const uint8_t	RTMP_CONTENT_TYPE_NOTIFY = 0x12
const uint8_t	RTMP_CONTENT_TYPE_SHARED_OBJECT = 0x13
const uint8_t	RTMP_CONTENT_TYPE_INVOKE = 0x14
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_CONNECT = 0x01
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_DISCONNECT = 0x02
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_SET_ATTRIBUTE = 0x03
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_UPDATE_DATA = 0x04
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_UPDATE_ATTRIBUTE = 0x05
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_SEND_MESSAGE = 0x06
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_STATUS = 0x07
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_CLEAR_DATA = 0x08
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_DELETE_DATA = 0x09
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_DELETE_ATTRIBUTE = 0x0A
const uint8_t	RTMP_SHARED_OBJECT_DATATYPE_INITIAL_DATA = 0x0B
const uint16_t	RTMP_PING_CLEAR_STREAM = 0x0000
const uint16_t	RTMP_PING_CLEAR_PLAYING_BUFFER = 0x0001
const uint16_t	RTMP_PING_BUFFER_TIME_CLIENT = 0x0003
const uint16_t	RTMP_PING_RESET_STREAM = 0x0004
const uint16_t	RTMP_PING_CLIENT_FROM_SERVER = 0x0006
const uint16_t	RTMP_PING_PONG_FROM_CLIENT = 0x0007
const uint8_t	RTMP_PING_SIZE_CLEAR_STREAM = 6
const uint8_t	RTMP_PING_SIZE_CLEAR_PLAYING_BUFFER = 6
const uint8_t	RTMP_PING_SIZE_BUFFER_TIME_CLIENT = 10
const uint8_t	RTMP_PING_SIZE_RESET_STREAM = 6
const uint8_t	RTMP_DEFAULT_STREAM_INDEX_CONTROL = 0x02
const uint8_t	RTMP_DEFAULT_STREAM_INDEX_INVOKE = 0x03
const uint8_t	RTMP_DEFAULT_STREAM_INDEX_NOTIFY = 0x04
const uint8_t	RTMP_DEFAULT_STREAM_INDEX_VIDEO_DATA = 0x05
const uint8_t	RTMP_DEFAULT_STREAM_INDEX_AUDIO_DATA = 0x06
const uint32_t	RTMP_DEFAULT_CHUNK_SIZE = 128
const double	RTMP_DEFAULT_STREAM_CLIENT_ID = 1.0
const double	RTMP_DEFAULT_STREAM_SERVER_ID = 1.0
const uint16_t	MAX_EMPTY_BLOCKS = 200
const uint16_t	RTMP_BODY_SIZE_ALLOC = 1024
const uint32_t	RTMP_TIME_CLIENT_BUFFER = 2000
const uint32_t	RTMP_SERVER_BW = 0x00000200
const uint32_t	RTMP_SRC_DST_CONNECT_OBJECT = 0x00000000
const uint32_t	RTMP_SRC_DST_CONNECT_OBJECT2 = 0x00000001
const uint32_t	RTMP_SRC_DST_DEFAULT = 0x01000000
const uint64_t	RTMP_AUDIOCODECS = 0x4083380000000000
const uint64_t	RTMP_VIDEOCODECS = 0x405f000000000000
const uint64_t	RTMP_VIDEOFUNCTION = 0x3ff0000000000000
const uint8_t	AMF_BOOLEAN_FALSE = 0x00
const uint8_t	AMF_BOOLEAN_TRUE = 0x01
const uint8_t	AMF_DATATYPE_NUMBER = 0x00
const uint8_t	AMF_DATATYPE_BOOLEAN = 0x01
const uint8_t	AMF_DATATYPE_STRING = 0x02
const uint8_t	AMF_DATATYPE_OBJECT = 0x03
const uint8_t	AMF_DATATYPE_MOVIE_CLIP = 0x04
const uint8_t	AMF_DATATYPE_NULL = 0x05
const uint8_t	AMF_DATATYPE_UNDEFINED = 0x06
const uint8_t	AMF_DATATYPE_REFERENCE = 0x07
const uint8_t	AMF_DATATYPE_MIXED_ARRAY = 0x08
const uint8_t	AMF_DATATYPE_END_OF_OBJECT = 0x09
const uint8_t	AMF_DATATYPE_ARRAY = 0x0A
const uint8_t	AMF_DATATYPE_DATE = 0x0B
const uint8_t	AMF_DATATYPE_LONG_STRING = 0x0C
const uint8_t	AMF_DATATYPE_UNSUPPORTED = 0x0D
const uint8_t	AMF_DATATYPE_RECORDSET = 0x0E
const uint8_t	AMF_DATATYPE_XML = 0x0F
const uint8_t	AMF_DATATYPE_TYPED_OBJECT = 0x10
const uint8_t	AMF_DATATYPE_AMF3_DATA = 0x11
const uint8_t	AMF_DATATYPE_SIZE_NUMBER = 9
const uint8_t	AMF_DATATYPE_SIZE_BOOLEAN = 2
const uint8_t	AMF_DATATYPE_SIZE_STRING = 3
const uint8_t	AMF_DATATYPE_SIZE_OBJECT = 1
const uint8_t	AMF_DATATYPE_SIZE_NULL = 1
const uint8_t	AMF_DATATYPE_SIZE_OBJECT_VARIABLE = 2
const uint8_t	AMF_DATATYPE_SIZE_MIXED_ARRAY = 5
const uint8_t	AMF_DATATYPE_SIZE_END_OF_OBJECT = 3
const uint64_t	AMF_CALL_NETCONNECTION_CONNECT = 0x3FF0000000000000
const uint64_t	AMF_CALL_NETCONNECTION_CONNECT_AUDIOCODECS = 0x4083380000000000
const uint64_t	AMF_CALL_NETCONNECTION_CONNECT_VIDEOCODECS = 0x405F000000000000
const uint64_t	AMF_CALL_NETCONNECTION_CONNECT_VIDEOFUNCTION = 0x3FF0000000000000
const uint64_t	AMF_CALL_NETCONNECTION_CONNECT_OBJECTENCODING = 0x0
const double	AMF_CALL_STREAM_CLIENT_NUMBER = 3.0
const double	AMF_CALL_ONBWDONE = 2.0
const uint64_t	AMF_CALL_NETSTREAM_PLAY = 0x0
const uint8_t	FLV_HEADER_SIGNATURE [3] = { 0x46, 0x4C, 0x56 }
const uint8_t	FLV_HEADER_VERSION = 0x01
const uint8_t	FLV_HEADER_AUDIO = 0x04
const uint8_t	FLV_HEADER_VIDEO = 0x01
const uint32_t	FLV_HEADER_SIZE = 0x00000009
const uint32_t	FLV_TAG_FIRST_PREVIOUS_TAG_SIZE = 0x00000000
const uint8_t	FLV_TAG_PREVIOUS_TAG_SIZE = 4
const uint8_t	FLV_TAG_SIZE = 11
const uint8_t	FLV_AUDIO_STEREO_MASK = 0x01
const uint8_t	FLV_AUDIO_STEREO_MONO = 0x00
const uint8_t	FLV_AUDIO_STEREO_STEREO = 0x01
const uint8_t	FLV_AUDIO_SIZE_MASK = 0x02
const uint8_t	FLV_AUDIO_SIZE_8_BIT = 0x00
const uint8_t	FLV_AUDIO_SIZE_16_BIT = 0x02
const uint8_t	FLV_AUDIO_RATE_MASK = 0x0C
const uint8_t	FLV_AUDIO_RATE_5_5_KHZ = 0x00
const uint8_t	FLV_AUDIO_RATE_11_KHZ = 0x04
const uint8_t	FLV_AUDIO_RATE_22_KHZ = 0x08
const uint8_t	FLV_AUDIO_RATE_44_KHZ = 0x0C
const uint8_t	FLV_AUDIO_CODEC_ID_MASK = 0xF0
const uint8_t	FLV_AUDIO_CODEC_ID_UNCOMPRESSED = 0x00
const uint8_t	FLV_AUDIO_CODEC_ID_ADPCM = 0x10
const uint8_t	FLV_AUDIO_CODEC_ID_MP3 = 0x20
const uint8_t	FLV_AUDIO_CODEC_ID_NELLYMOSER_8KHZ_MONO = 0x50
const uint8_t	FLV_AUDIO_CODEC_ID_NELLYMOSER = 0x60
const uint8_t	FLV_VIDEO_CODEC_ID_MASK = 0x0F
const uint8_t	FLV_VIDEO_CODEC_ID_SORENSEN_H263 = 0x02
const uint8_t	FLV_VIDEO_CODEC_ID_SCREEN_VIDEO = 0x03
const uint8_t	FLV_VIDEO_CODEC_ID_ON2_VP6 = 0x04
const uint8_t	FLV_VIDEO_CODEC_ID_ON2_VP6_ALPHA = 0x05
const uint8_t	FLV_VIDEO_CODEC_ID_SCREEN_VIDEO_2 = 0x06
const uint8_t	FLV_VIDEO_FRAME_TYPE_MASK = 0xF0
const uint8_t	FLV_VIDEO_FRAME_TYPE_KEYFRAME = 0x10
const uint8_t	FLV_VIDEO_FRAME_TYPE_INTER_FRAME = 0x20
const uint8_t	FLV_VIDEO_FRAME_TYPE_DISPOSABLE_INTER_FRAME = 0x30

---

Function Documentation

static int amf_decode_boolean

(

uint8_t **

buffer

)

[static]

Referenced by rtmp_handler_invoke().

static double amf_decode_number

(

uint8_t **

buffer

)

[static]

References ntoh64().

Referenced by rtmp_handler_invoke().

static char * amf_decode_object

(

uint8_t **

buffer

)

[static]

References amf_decode_string().

Referenced by rtmp_handler_invoke().

static char * amf_decode_string

(

uint8_t **

buffer

)

[static]

References i, and ntoh16.

Referenced by amf_decode_object(), and rtmp_handler_invoke().

static uint8_t * amf_encode_element	(	uint8_t	element,
		const void *	value
	)			[static]

References AMF_DATATYPE_BOOLEAN, AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_MIXED_ARRAY, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_SIZE_BOOLEAN, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_MIXED_ARRAY, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, hton16, hton32, and hton64.

Referenced by amf_encode_object_variable(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), and rtmp_encode_onBWDone().

static uint8_t * amf_encode_object_variable	(	const char *	key,
		uint8_t	element,
		const void *	value
	)			[static]

References AMF_DATATYPE_BOOLEAN, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_SIZE_BOOLEAN, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), and hton16.

Referenced by flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), and rtmp_encode_NetStream_play_start_onStatus().

static rtmp_packet_t * flv_build_onMetaData	(	access_t *	p_access,
		uint64_t	duration,
		uint8_t	stereo,
		uint8_t	audiosamplesize,
		uint32_t	audiosamplerate,
		uint8_t	audiocodecid,
		uint8_t	videocodecid
	)			[static]

References AMF_DATATYPE_BOOLEAN, AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_MIXED_ARRAY, AMF_DATATYPE_NUMBER, AMF_DATATYPE_SIZE_BOOLEAN, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_MIXED_ARRAY, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), amf_encode_object_variable(), rtmp_body_t::body, access_t::p_sys, access_sys_t::p_thread, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_NOTIFY, RTMP_DEFAULT_STREAM_INDEX_INVOKE, and rtmp_new_packet().

Referenced by flv_get_metadata().

block_t* flv_get_metadata

(

access_t *

p_access

)

References rtmp_body_t::body, rtmp_packet_t::body, flv_build_onMetaData(), flv_rebuild(), rtmp_body_t::length_buffer, rtmp_control_thread_t::metadata_audiocodecid, rtmp_control_thread_t::metadata_samplerate, rtmp_control_thread_t::metadata_samplesize, rtmp_control_thread_t::metadata_stereo, rtmp_control_thread_t::metadata_videocodecid, access_t::p_sys, access_sys_t::p_thread, rtmp_new_block(), and rtmp_packet_free().

Referenced by Read().

static void flv_get_metadata_audio	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	packet_audio,
		uint8_t *	stereo,
		uint8_t *	audiosamplesize,
		uint32_t *	audiosamplerate,
		uint8_t *	audiocodecid
	)			[static]

References rtmp_body_t::body, rtmp_packet_t::body, FLV_AUDIO_CODEC_ID_ADPCM, FLV_AUDIO_CODEC_ID_MASK, FLV_AUDIO_CODEC_ID_MP3, FLV_AUDIO_CODEC_ID_NELLYMOSER, FLV_AUDIO_CODEC_ID_NELLYMOSER_8KHZ_MONO, FLV_AUDIO_CODEC_ID_UNCOMPRESSED, FLV_AUDIO_RATE_11_KHZ, FLV_AUDIO_RATE_22_KHZ, FLV_AUDIO_RATE_44_KHZ, FLV_AUDIO_RATE_5_5_KHZ, FLV_AUDIO_RATE_MASK, FLV_AUDIO_SIZE_16_BIT, FLV_AUDIO_SIZE_8_BIT, FLV_AUDIO_SIZE_MASK, FLV_AUDIO_STEREO_MASK, FLV_AUDIO_STEREO_MONO, FLV_AUDIO_STEREO_STEREO, and msg_Warn.

Referenced by rtmp_handler_audio_data().

static void flv_get_metadata_video	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	packet_video,
		uint8_t *	videocodecid,
		uint8_t *	frametype
	)			[static]

References rtmp_body_t::body, rtmp_packet_t::body, FLV_VIDEO_CODEC_ID_MASK, FLV_VIDEO_CODEC_ID_ON2_VP6, FLV_VIDEO_CODEC_ID_ON2_VP6_ALPHA, FLV_VIDEO_CODEC_ID_SCREEN_VIDEO, FLV_VIDEO_CODEC_ID_SCREEN_VIDEO_2, FLV_VIDEO_CODEC_ID_SORENSEN_H263, FLV_VIDEO_FRAME_TYPE_DISPOSABLE_INTER_FRAME, FLV_VIDEO_FRAME_TYPE_INTER_FRAME, FLV_VIDEO_FRAME_TYPE_KEYFRAME, FLV_VIDEO_FRAME_TYPE_MASK, and msg_Warn.

Referenced by rtmp_handler_video_data().

block_t* flv_insert_header	(	access_t *	p_access,
		block_t *	first_packet
	)

References block_Realloc(), FLV_HEADER_AUDIO, FLV_HEADER_SIGNATURE, FLV_HEADER_SIZE, FLV_HEADER_VERSION, FLV_HEADER_VIDEO, rtmp_control_thread_t::has_audio, rtmp_control_thread_t::has_video, hton32, block_t::i_buffer, block_t::p_buffer, access_t::p_sys, p_sys, and access_sys_t::p_thread.

Referenced by Read().

static void flv_rebuild	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References rtmp_body_t::body, rtmp_packet_t::body, rtmp_packet_t::content_type, rtmp_control_thread_t::flv_tag_previous_tag_size, FLV_TAG_PREVIOUS_TAG_SIZE, FLV_TAG_SIZE, hton32, rtmp_body_t::length_body, rtmp_body_t::length_buffer, and rtmp_packet_t::timestamp.

Referenced by flv_get_metadata(), rtmp_handler_audio_data(), rtmp_handler_notify(), and rtmp_handler_video_data().

static void rtmp_body_append	(	rtmp_body_t *	rtmp_body,
		uint8_t *	buffer,
		uint32_t	length
	)			[static]

References rtmp_body_t::body, rtmp_body_t::length_body, and rtmp_body_t::length_buffer.

Referenced by flv_build_onMetaData(), rtmp_build_bytes_read(), rtmp_build_flv_over_rtmp(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), rtmp_encode_ping_clear_stream(), rtmp_encode_ping_reset_stream(), and rtmp_encode_server_bw().

rtmp_body_t* rtmp_body_new

(

int

length_buffer

)

References rtmp_body_t::body, rtmp_body_t::length_body, rtmp_body_t::length_buffer, and RTMP_BODY_SIZE_ALLOC.

Referenced by flv_build_onMetaData(), rtmp_build_bytes_read(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), rtmp_encode_ping_clear_stream(), rtmp_encode_ping_reset_stream(), rtmp_encode_server_bw(), and rtmp_read_net_packet().

void rtmp_body_reset

(

rtmp_body_t *

rtmp_body

)

References rtmp_body_t::length_body.

Referenced by rtmp_build_flv_over_rtmp().

rtmp_packet_t* rtmp_build_bytes_read	(	rtmp_control_thread_t *	p_thread,
		uint32_t	reply
	)

References rtmp_body_t::body, hton32, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_BYTES_READ, RTMP_DEFAULT_STREAM_INDEX_CONTROL, and rtmp_new_packet().

Referenced by Read().

rtmp_packet_t* rtmp_build_flv_over_rtmp	(	rtmp_control_thread_t *	p_thread,
		block_t *	p_buffer
	)

References rtmp_control_thread_t::flv_body, rtmp_control_thread_t::flv_content_type, rtmp_control_thread_t::flv_length_body, FLV_TAG_PREVIOUS_TAG_SIZE, FLV_TAG_SIZE, rtmp_control_thread_t::flv_timestamp, block_t::i_buffer, ntoh32, block_t::p_buffer, rtmp_body_append(), rtmp_body_reset(), rtmp_get_stream_index(), rtmp_new_packet(), and RTMP_SRC_DST_DEFAULT.

Referenced by Write().

rtmp_packet_t* rtmp_build_publish_start

(

rtmp_control_thread_t *

p_thread

)

References AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), amf_encode_object_variable(), rtmp_body_t::body, rtmp_control_thread_t::psz_publish, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_DEFAULT_STREAM_INDEX_INVOKE, rtmp_new_packet(), rtmp_control_thread_t::stream_client_id, and rtmp_control_thread_t::stream_server_id.

Referenced by Read().

int rtmp_connect_active

(

rtmp_control_thread_t *

p_thread

)

References AMF_BOOLEAN_FALSE, AMF_CALL_NETCONNECTION_CONNECT, AMF_CALL_NETCONNECTION_CONNECT_AUDIOCODECS, AMF_CALL_NETCONNECTION_CONNECT_OBJECTENCODING, AMF_CALL_NETCONNECTION_CONNECT_VIDEOCODECS, AMF_CALL_NETCONNECTION_CONNECT_VIDEOFUNCTION, AMF_CALL_NETSTREAM_PLAY, AMF_CALL_STREAM_CLIENT_NUMBER, AMF_DATATYPE_BOOLEAN, AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_SIZE_BOOLEAN, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), amf_encode_object_variable(), asprintf(), rtmp_body_t::body, rtmp_control_thread_t::lock, msg_Dbg, msg_Err, rtmp_control_thread_t::psz_application, vlc_url_t::psz_buffer, rtmp_control_thread_t::psz_media, rtmp_control_thread_t::psz_page_url, rtmp_control_thread_t::psz_swf_url, rtmp_control_thread_t::result_connect, rtmp_control_thread_t::result_play, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_CONTENT_TYPE_PING, RTMP_DEFAULT_STREAM_CLIENT_ID, RTMP_DEFAULT_STREAM_INDEX_CONTROL, RTMP_DEFAULT_STREAM_INDEX_INVOKE, rtmp_encode_packet(), rtmp_encode_ping(), rtmp_new_packet(), RTMP_PING_BUFFER_TIME_CLIENT, RTMP_PING_SIZE_BUFFER_TIME_CLIENT, RTMP_SRC_DST_CONNECT_OBJECT, RTMP_SRC_DST_CONNECT_OBJECT2, RTMP_SRC_DST_DEFAULT, RTMP_TIME_CLIENT_BUFFER, rtmp_control_thread_t::stream_client_id, rtmp_control_thread_t::url, vlc_cond_wait(), vlc_mutex_lock(), vlc_mutex_unlock(), rtmp_control_thread_t::wait, and write_rtmp().

int rtmp_connect_passive

(

rtmp_control_thread_t *

p_thread

)

References rtmp_control_thread_t::lock, msg_Err, rtmp_control_thread_t::result_play, vlc_cond_wait(), vlc_mutex_lock(), vlc_mutex_unlock(), and rtmp_control_thread_t::wait.

static uint8_t rtmp_decode_header_size	(	vlc_object_t *	p_this,
		uint8_t	header_size
	)			[static]

References msg_Err, RTMP_HEADER_SIZE_1, RTMP_HEADER_SIZE_12, RTMP_HEADER_SIZE_4, and RTMP_HEADER_SIZE_8.

Referenced by rtmp_read_net_packet().

static rtmp_packet_t * rtmp_encode_createStream_result	(	rtmp_control_thread_t *	p_thread,
		double	stream_client,
		double	stream_server
	)			[static]

References AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), rtmp_body_t::body, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_DEFAULT_STREAM_INDEX_INVOKE, and rtmp_new_packet().

Referenced by rtmp_handler_invoke().

static uint8_t rtmp_encode_header_size	(	vlc_object_t *	p_this,
		uint8_t	header_size
	)			[static]

References msg_Err, RTMP_HEADER_SIZE_1, RTMP_HEADER_SIZE_12, RTMP_HEADER_SIZE_4, and RTMP_HEADER_SIZE_8.

Referenced by rtmp_encode_packet().

static rtmp_packet_t * rtmp_encode_NetConnection_connect_result	(	rtmp_control_thread_t *	p_thread,
		double	number
	)			[static]

References AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), amf_encode_object_variable(), rtmp_body_t::body, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_DEFAULT_STREAM_INDEX_INVOKE, and rtmp_new_packet().

Referenced by rtmp_handler_invoke().

static rtmp_packet_t * rtmp_encode_NetStream_play_reset_onStatus	(	rtmp_control_thread_t *	p_thread,
		char *	psz_media
	)			[static]

References AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), amf_encode_object_variable(), asprintf(), rtmp_body_t::body, description, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_DEFAULT_STREAM_INDEX_NOTIFY, rtmp_new_packet(), RTMP_SRC_DST_DEFAULT, and rtmp_control_thread_t::stream_client_id.

Referenced by rtmp_handler_invoke().

static rtmp_packet_t * rtmp_encode_NetStream_play_start_onStatus	(	rtmp_control_thread_t *	p_thread,
		char *	psz_media
	)			[static]

References AMF_DATATYPE_END_OF_OBJECT, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_SIZE_END_OF_OBJECT, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_OBJECT, AMF_DATATYPE_SIZE_OBJECT_VARIABLE, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), amf_encode_object_variable(), asprintf(), rtmp_body_t::body, description, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_DEFAULT_STREAM_INDEX_NOTIFY, rtmp_new_packet(), RTMP_SRC_DST_DEFAULT, and rtmp_control_thread_t::stream_client_id.

Referenced by rtmp_handler_invoke().

static rtmp_packet_t * rtmp_encode_onBWDone	(	rtmp_control_thread_t *	p_thread,
		double	number
	)			[static]

References AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_SIZE_NULL, AMF_DATATYPE_SIZE_NUMBER, AMF_DATATYPE_SIZE_STRING, AMF_DATATYPE_STRING, amf_encode_element(), rtmp_body_t::body, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_INVOKE, RTMP_DEFAULT_STREAM_INDEX_INVOKE, rtmp_new_packet(), and RTMP_SRC_DST_CONNECT_OBJECT.

Referenced by rtmp_handler_invoke().

uint8_t* rtmp_encode_packet	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)

References rtmp_body_t::body, rtmp_packet_t::body, rtmp_control_thread_t::chunk_size_send, rtmp_packet_t::content_type, hton32, i, rtmp_body_t::length_body, rtmp_packet_t::length_encoded, rtmp_packet_t::length_header, rtmp_encode_header_size(), RTMP_HEADER_SIZE_1, rtmp_packet_t::src_dst, rtmp_packet_t::stream_index, rtmp_packet_t::timestamp, and rtmp_packet_t::timestamp_relative.

Referenced by Read(), rtmp_connect_active(), rtmp_handler_invoke(), and Write().

static uint8_t * rtmp_encode_ping	(	uint16_t	type,
		uint32_t	src_dst,
		uint32_t	third_arg,
		uint32_t	fourth_arg
	)			[static]

References hton16, hton32, RTMP_PING_BUFFER_TIME_CLIENT, RTMP_PING_CLEAR_PLAYING_BUFFER, RTMP_PING_CLEAR_STREAM, RTMP_PING_RESET_STREAM, RTMP_PING_SIZE_BUFFER_TIME_CLIENT, RTMP_PING_SIZE_CLEAR_PLAYING_BUFFER, RTMP_PING_SIZE_CLEAR_STREAM, RTMP_PING_SIZE_RESET_STREAM, and VLC_UNUSED.

Referenced by rtmp_connect_active(), rtmp_encode_ping_clear_stream(), and rtmp_encode_ping_reset_stream().

static rtmp_packet_t * rtmp_encode_ping_clear_stream	(	rtmp_control_thread_t *	p_thread,
		uint32_t	src_dst
	)			[static]

References rtmp_body_t::body, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_PING, RTMP_DEFAULT_STREAM_INDEX_CONTROL, rtmp_encode_ping(), rtmp_new_packet(), RTMP_PING_CLEAR_STREAM, and RTMP_PING_SIZE_CLEAR_STREAM.

Referenced by rtmp_handler_invoke().

static rtmp_packet_t * rtmp_encode_ping_reset_stream

(

rtmp_control_thread_t *

p_thread

)

[static]

References rtmp_body_t::body, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_PING, RTMP_DEFAULT_STREAM_INDEX_CONTROL, rtmp_encode_ping(), rtmp_new_packet(), RTMP_PING_RESET_STREAM, RTMP_PING_SIZE_RESET_STREAM, and RTMP_SRC_DST_CONNECT_OBJECT2.

Referenced by rtmp_handler_invoke().

static rtmp_packet_t * rtmp_encode_server_bw	(	rtmp_control_thread_t *	p_thread,
		uint32_t	number
	)			[static]

References rtmp_body_t::body, rtmp_body_append(), rtmp_body_new(), RTMP_CONTENT_TYPE_SERVER_BW, RTMP_DEFAULT_STREAM_INDEX_CONTROL, rtmp_new_packet(), and RTMP_SRC_DST_CONNECT_OBJECT.

Referenced by rtmp_handler_invoke().

static uint8_t rtmp_get_stream_index

(

uint8_t

content_type

)

[static]

References RTMP_CONTENT_TYPE_AUDIO_DATA, RTMP_CONTENT_TYPE_NOTIFY, RTMP_CONTENT_TYPE_VIDEO_DATA, RTMP_DEFAULT_STREAM_INDEX_AUDIO_DATA, RTMP_DEFAULT_STREAM_INDEX_NOTIFY, and RTMP_DEFAULT_STREAM_INDEX_VIDEO_DATA.

Referenced by rtmp_build_flv_over_rtmp().

static void rtmp_handler_audio_data	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References block_FifoPut(), rtmp_body_t::body, rtmp_packet_t::body, flv_get_metadata_audio(), flv_rebuild(), rtmp_control_thread_t::has_audio, rtmp_body_t::length_body, rtmp_control_thread_t::metadata_audiocodecid, rtmp_control_thread_t::metadata_samplerate, rtmp_control_thread_t::metadata_samplesize, rtmp_control_thread_t::metadata_stereo, rtmp_control_thread_t::p_fifo_input, rtmp_new_block(), and rtmp_packet_free().

Referenced by rtmp_init_handler().

static void rtmp_handler_chunk_size	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References rtmp_body_t::body, rtmp_packet_t::body, rtmp_control_thread_t::chunk_size_recv, ntoh32, and rtmp_packet_free().

Referenced by rtmp_init_handler().

static void rtmp_handler_invoke	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References AMF_CALL_ONBWDONE, AMF_DATATYPE_BOOLEAN, AMF_DATATYPE_NULL, AMF_DATATYPE_NUMBER, AMF_DATATYPE_OBJECT, AMF_DATATYPE_STRING, AMF_DATATYPE_UNDEFINED, amf_decode_boolean(), amf_decode_number(), amf_decode_object(), amf_decode_string(), block_FifoWake(), rtmp_body_t::body, rtmp_packet_t::body, rtmp_control_thread_t::fd, i, rtmp_body_t::length_body, rtmp_packet_t::length_encoded, rtmp_control_thread_t::lock, msg_Dbg, msg_Err, msg_Warn, net_Write, rtmp_control_thread_t::p_fifo_input, rtmp_control_thread_t::psz_publish, rtmp_control_thread_t::result_connect, rtmp_control_thread_t::result_play, rtmp_control_thread_t::result_stop, RTMP_DEFAULT_STREAM_SERVER_ID, rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), rtmp_encode_packet(), rtmp_encode_ping_clear_stream(), rtmp_encode_ping_reset_stream(), rtmp_encode_server_bw(), rtmp_packet_free(), RTMP_SERVER_BW, RTMP_SRC_DST_CONNECT_OBJECT, RTMP_SRC_DST_CONNECT_OBJECT2, strdup(), rtmp_control_thread_t::stream_client_id, rtmp_control_thread_t::stream_server_id, vlc_cond_signal(), vlc_mutex_lock(), vlc_mutex_unlock(), and rtmp_control_thread_t::wait.

Referenced by rtmp_init_handler().

static void rtmp_handler_notify	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References block_FifoPut(), rtmp_body_t::body, rtmp_packet_t::body, flv_rebuild(), rtmp_body_t::length_body, rtmp_control_thread_t::metadata_received, rtmp_control_thread_t::p_fifo_input, rtmp_new_block(), and rtmp_packet_free().

Referenced by rtmp_init_handler().

static void rtmp_handler_null	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References rtmp_packet_free(), and VLC_UNUSED.

Referenced by rtmp_init_handler().

static void rtmp_handler_video_data	(	rtmp_control_thread_t *	p_thread,
		rtmp_packet_t *	rtmp_packet
	)			[static]

References block_FifoPut(), rtmp_body_t::body, rtmp_packet_t::body, flv_get_metadata_video(), flv_rebuild(), rtmp_control_thread_t::has_video, rtmp_body_t::length_body, rtmp_control_thread_t::metadata_frametype, rtmp_control_thread_t::metadata_videocodecid, rtmp_control_thread_t::p_fifo_input, rtmp_new_block(), and rtmp_packet_free().

Referenced by rtmp_init_handler().

int rtmp_handshake_active	(	vlc_object_t *	p_this,
		int	fd
	)

References i, msg_Err, net_Read, net_Write, RTMP_HANDSHAKE, RTMP_HANDSHAKE_BODY_SIZE, and vlc_rand_bytes().

int rtmp_handshake_passive	(	vlc_object_t *	p_this,
		int	fd
	)

References i, msg_Err, net_Read, net_Write, RTMP_HANDSHAKE, and RTMP_HANDSHAKE_BODY_SIZE.

void rtmp_init_handler

(

rtmp_handler_t *

rtmp_handler

)

References RTMP_CONTENT_TYPE_AUDIO_DATA, RTMP_CONTENT_TYPE_BYTES_READ, RTMP_CONTENT_TYPE_CHUNK_SIZE, RTMP_CONTENT_TYPE_CLIENT_BW, RTMP_CONTENT_TYPE_FLEX_SHARED_OBJECT, RTMP_CONTENT_TYPE_FLEX_STREAM, RTMP_CONTENT_TYPE_INVOKE, RTMP_CONTENT_TYPE_MESSAGE, RTMP_CONTENT_TYPE_NOTIFY, RTMP_CONTENT_TYPE_PING, RTMP_CONTENT_TYPE_SERVER_BW, RTMP_CONTENT_TYPE_SHARED_OBJECT, RTMP_CONTENT_TYPE_UNKNOWN_02, RTMP_CONTENT_TYPE_UNKNOWN_07, RTMP_CONTENT_TYPE_UNKNOWN_0A_0E, RTMP_CONTENT_TYPE_VIDEO_DATA, rtmp_handler_audio_data(), rtmp_handler_chunk_size(), rtmp_handler_invoke(), rtmp_handler_notify(), rtmp_handler_null(), and rtmp_handler_video_data().

Referenced by ThreadControl().

static block_t * rtmp_new_block	(	rtmp_control_thread_t *	p_thread,
		uint8_t *	buffer,
		int32_t	length_buffer
	)			[static]

References block_FifoCount(), block_FifoGet(), block_New, block_Realloc(), block_Release(), block_t::i_buffer, MAX_EMPTY_BLOCKS, block_t::p_buffer, and rtmp_control_thread_t::p_empty_blocks.

Referenced by flv_get_metadata(), rtmp_handler_audio_data(), rtmp_handler_notify(), and rtmp_handler_video_data().

static rtmp_packet_t * rtmp_new_packet	(	rtmp_control_thread_t *	p_thread,
		uint8_t	stream_index,
		uint32_t	timestamp,
		uint8_t	content_type,
		uint32_t	src_dst,
		rtmp_body_t *	body
	)			[static]

References rtmp_body_t::body, rtmp_packet_t::body, rtmp_control_thread_t::chunk_size_send, rtmp_packet_t::content_type, rtmp_packet_t::length_body, rtmp_body_t::length_body, rtmp_body_t::length_buffer, rtmp_packet_t::length_encoded, rtmp_packet_t::length_header, rtmp_control_thread_t::rtmp_headers_send, rtmp_packet_t::src_dst, rtmp_packet_t::stream_index, rtmp_packet_t::timestamp, and rtmp_packet_t::timestamp_relative.

Referenced by flv_build_onMetaData(), rtmp_build_bytes_read(), rtmp_build_flv_over_rtmp(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), rtmp_encode_ping_clear_stream(), rtmp_encode_ping_reset_stream(), and rtmp_encode_server_bw().

static void rtmp_packet_free

(

rtmp_packet_t *

pkt

)

[static]

References rtmp_body_t::body, and rtmp_packet_t::body.

Referenced by flv_get_metadata(), rtmp_handler_audio_data(), rtmp_handler_chunk_size(), rtmp_handler_invoke(), rtmp_handler_notify(), rtmp_handler_null(), and rtmp_handler_video_data().

rtmp_packet_t* rtmp_read_net_packet

(

rtmp_control_thread_t *

p_thread

)

References rtmp_body_t::body, rtmp_packet_t::body, rtmp_control_thread_t::chunk_size_recv, rtmp_packet_t::content_type, rtmp_control_thread_t::fd, rtmp_body_t::length_body, rtmp_packet_t::length_body, rtmp_body_t::length_buffer, msg_Err, net_Read, ntoh32, rtmp_body_new(), rtmp_decode_header_size(), RTMP_HEADER_SIZE_MASK, RTMP_HEADER_STREAM_INDEX_MASK, rtmp_control_thread_t::rtmp_headers_recv, rtmp_packet_t::src_dst, rtmp_packet_t::stream_index, rtmp_packet_t::timestamp, rtmp_packet_t::timestamp_relative, and VLC_OBJECT.

Referenced by ThreadControl().

static int write_rtmp	(	rtmp_control_thread_t *	p_thread,
		uint8_t *	buf,
		rtmp_packet_t *	pkt,
		const char *	errmsg
	)			[static]

References rtmp_body_t::body, rtmp_packet_t::body, rtmp_control_thread_t::fd, rtmp_packet_t::length_encoded, msg_Err, and net_Write.

Referenced by rtmp_connect_active().

---

Variable Documentation

const uint8_t AMF_BOOLEAN_FALSE = 0x00

Referenced by rtmp_connect_active().

const uint8_t AMF_BOOLEAN_TRUE = 0x01

const uint64_t AMF_CALL_NETCONNECTION_CONNECT = 0x3FF0000000000000

Referenced by rtmp_connect_active().

const uint64_t AMF_CALL_NETCONNECTION_CONNECT_AUDIOCODECS = 0x4083380000000000

Referenced by rtmp_connect_active().

const uint64_t AMF_CALL_NETCONNECTION_CONNECT_OBJECTENCODING = 0x0

Referenced by rtmp_connect_active().

const uint64_t AMF_CALL_NETCONNECTION_CONNECT_VIDEOCODECS = 0x405F000000000000

Referenced by rtmp_connect_active().

const uint64_t AMF_CALL_NETCONNECTION_CONNECT_VIDEOFUNCTION = 0x3FF0000000000000

Referenced by rtmp_connect_active().

const uint64_t AMF_CALL_NETSTREAM_PLAY = 0x0

Referenced by rtmp_connect_active().

const double AMF_CALL_ONBWDONE = 2.0

Referenced by rtmp_handler_invoke().

const double AMF_CALL_STREAM_CLIENT_NUMBER = 3.0

Referenced by rtmp_connect_active().

const uint8_t AMF_DATATYPE_AMF3_DATA = 0x11

const uint8_t AMF_DATATYPE_ARRAY = 0x0A

const uint8_t AMF_DATATYPE_BOOLEAN = 0x01

Referenced by amf_encode_element(), amf_encode_object_variable(), flv_build_onMetaData(), rtmp_connect_active(), and rtmp_handler_invoke().

const uint8_t AMF_DATATYPE_DATE = 0x0B

const uint8_t AMF_DATATYPE_END_OF_OBJECT = 0x09

Referenced by amf_encode_element(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), and rtmp_encode_NetStream_play_start_onStatus().

const uint8_t AMF_DATATYPE_LONG_STRING = 0x0C

const uint8_t AMF_DATATYPE_MIXED_ARRAY = 0x08

Referenced by amf_encode_element(), and flv_build_onMetaData().

const uint8_t AMF_DATATYPE_MOVIE_CLIP = 0x04

const uint8_t AMF_DATATYPE_NULL = 0x05

Referenced by amf_encode_element(), amf_encode_object_variable(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), and rtmp_handler_invoke().

const uint8_t AMF_DATATYPE_NUMBER = 0x00

Referenced by amf_encode_element(), amf_encode_object_variable(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), and rtmp_handler_invoke().

const uint8_t AMF_DATATYPE_OBJECT = 0x03

Referenced by amf_encode_element(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), and rtmp_handler_invoke().

const uint8_t AMF_DATATYPE_RECORDSET = 0x0E

const uint8_t AMF_DATATYPE_REFERENCE = 0x07

const uint8_t AMF_DATATYPE_SIZE_BOOLEAN = 2

Referenced by amf_encode_element(), amf_encode_object_variable(), flv_build_onMetaData(), and rtmp_connect_active().

const uint8_t AMF_DATATYPE_SIZE_END_OF_OBJECT = 3

Referenced by amf_encode_element(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), and rtmp_encode_NetStream_play_start_onStatus().

const uint8_t AMF_DATATYPE_SIZE_MIXED_ARRAY = 5

Referenced by amf_encode_element(), and flv_build_onMetaData().

const uint8_t AMF_DATATYPE_SIZE_NULL = 1

Referenced by amf_encode_element(), amf_encode_object_variable(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), and rtmp_encode_onBWDone().

const uint8_t AMF_DATATYPE_SIZE_NUMBER = 9

Referenced by amf_encode_element(), amf_encode_object_variable(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), and rtmp_encode_onBWDone().

const uint8_t AMF_DATATYPE_SIZE_OBJECT = 1

Referenced by amf_encode_element(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), and rtmp_encode_NetStream_play_start_onStatus().

const uint8_t AMF_DATATYPE_SIZE_OBJECT_VARIABLE = 2

Referenced by amf_encode_object_variable(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), and rtmp_encode_NetStream_play_start_onStatus().

const uint8_t AMF_DATATYPE_SIZE_STRING = 3

Referenced by amf_encode_element(), amf_encode_object_variable(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), and rtmp_encode_onBWDone().

const uint8_t AMF_DATATYPE_STRING = 0x02

Referenced by amf_encode_element(), amf_encode_object_variable(), flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), and rtmp_handler_invoke().

const uint8_t AMF_DATATYPE_TYPED_OBJECT = 0x10

const uint8_t AMF_DATATYPE_UNDEFINED = 0x06

Referenced by rtmp_handler_invoke().

const uint8_t AMF_DATATYPE_UNSUPPORTED = 0x0D

const uint8_t AMF_DATATYPE_XML = 0x0F

const uint8_t FLV_AUDIO_CODEC_ID_ADPCM = 0x10

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_CODEC_ID_MASK = 0xF0

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_CODEC_ID_MP3 = 0x20

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_CODEC_ID_NELLYMOSER = 0x60

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_CODEC_ID_NELLYMOSER_8KHZ_MONO = 0x50

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_CODEC_ID_UNCOMPRESSED = 0x00

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_RATE_11_KHZ = 0x04

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_RATE_22_KHZ = 0x08

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_RATE_44_KHZ = 0x0C

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_RATE_5_5_KHZ = 0x00

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_RATE_MASK = 0x0C

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_SIZE_16_BIT = 0x02

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_SIZE_8_BIT = 0x00

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_SIZE_MASK = 0x02

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_STEREO_MASK = 0x01

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_STEREO_MONO = 0x00

Referenced by flv_get_metadata_audio().

const uint8_t FLV_AUDIO_STEREO_STEREO = 0x01

Referenced by flv_get_metadata_audio().

const uint8_t FLV_HEADER_AUDIO = 0x04

Referenced by flv_insert_header().

const uint8_t FLV_HEADER_SIGNATURE[3] = { 0x46, 0x4C, 0x56 }

Referenced by flv_insert_header().

const uint32_t FLV_HEADER_SIZE = 0x00000009

Referenced by flv_insert_header().

const uint8_t FLV_HEADER_VERSION = 0x01

Referenced by flv_insert_header().

const uint8_t FLV_HEADER_VIDEO = 0x01

Referenced by flv_insert_header().

const uint32_t FLV_TAG_FIRST_PREVIOUS_TAG_SIZE = 0x00000000

const uint8_t FLV_TAG_PREVIOUS_TAG_SIZE = 4

Referenced by flv_rebuild(), and rtmp_build_flv_over_rtmp().

const uint8_t FLV_TAG_SIZE = 11

Referenced by flv_rebuild(), and rtmp_build_flv_over_rtmp().

const uint8_t FLV_VIDEO_CODEC_ID_MASK = 0x0F

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_CODEC_ID_ON2_VP6 = 0x04

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_CODEC_ID_ON2_VP6_ALPHA = 0x05

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_CODEC_ID_SCREEN_VIDEO = 0x03

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_CODEC_ID_SCREEN_VIDEO_2 = 0x06

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_CODEC_ID_SORENSEN_H263 = 0x02

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_FRAME_TYPE_DISPOSABLE_INTER_FRAME = 0x30

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_FRAME_TYPE_INTER_FRAME = 0x20

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_FRAME_TYPE_KEYFRAME = 0x10

Referenced by flv_get_metadata_video().

const uint8_t FLV_VIDEO_FRAME_TYPE_MASK = 0xF0

Referenced by flv_get_metadata_video().

const uint16_t MAX_EMPTY_BLOCKS = 200

const uint64_t RTMP_AUDIOCODECS = 0x4083380000000000

const uint16_t RTMP_BODY_SIZE_ALLOC = 1024

Referenced by rtmp_body_new().

const uint8_t RTMP_CONTENT_TYPE_AUDIO_DATA = 0x08

Referenced by rtmp_get_stream_index(), and rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_BYTES_READ = 0x03

Referenced by rtmp_build_bytes_read(), and rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_CHUNK_SIZE = 0x01

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_CLIENT_BW = 0x06

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_FLEX_SHARED_OBJECT = 0x10

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_FLEX_STREAM = 0x0F

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_INVOKE = 0x14

Referenced by rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), rtmp_encode_onBWDone(), and rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_MESSAGE = 0x11

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_NOTIFY = 0x12

Referenced by flv_build_onMetaData(), rtmp_get_stream_index(), and rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_PING = 0x04

Referenced by rtmp_connect_active(), rtmp_encode_ping_clear_stream(), rtmp_encode_ping_reset_stream(), and rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_SERVER_BW = 0x05

Referenced by rtmp_encode_server_bw(), and rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_SHARED_OBJECT = 0x13

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_UNKNOWN_02 = 0x02

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_UNKNOWN_07 = 0x07

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_UNKNOWN_0A_0E = 0x0A

Referenced by rtmp_init_handler().

const uint8_t RTMP_CONTENT_TYPE_VIDEO_DATA = 0x09

Referenced by rtmp_get_stream_index(), and rtmp_init_handler().

const uint32_t RTMP_DEFAULT_CHUNK_SIZE = 128

const double RTMP_DEFAULT_STREAM_CLIENT_ID = 1.0

Referenced by rtmp_connect_active().

const uint8_t RTMP_DEFAULT_STREAM_INDEX_AUDIO_DATA = 0x06

Referenced by rtmp_get_stream_index().

const uint8_t RTMP_DEFAULT_STREAM_INDEX_CONTROL = 0x02

Referenced by rtmp_build_bytes_read(), rtmp_connect_active(), rtmp_encode_ping_clear_stream(), rtmp_encode_ping_reset_stream(), and rtmp_encode_server_bw().

const uint8_t RTMP_DEFAULT_STREAM_INDEX_INVOKE = 0x03

Referenced by flv_build_onMetaData(), rtmp_build_publish_start(), rtmp_connect_active(), rtmp_encode_createStream_result(), rtmp_encode_NetConnection_connect_result(), and rtmp_encode_onBWDone().

const uint8_t RTMP_DEFAULT_STREAM_INDEX_NOTIFY = 0x04

Referenced by rtmp_encode_NetStream_play_reset_onStatus(), rtmp_encode_NetStream_play_start_onStatus(), and rtmp_get_stream_index().

const uint8_t RTMP_DEFAULT_STREAM_INDEX_VIDEO_DATA = 0x05

Referenced by rtmp_get_stream_index().

const double RTMP_DEFAULT_STREAM_SERVER_ID = 1.0

Referenced by rtmp_handler_invoke().

const uint8_t RTMP_HANDSHAKE = 0x03

Referenced by rtmp_handshake_active(), and rtmp_handshake_passive().

const uint16_t RTMP_HANDSHAKE_BODY_SIZE = 1536

Referenced by rtmp_handshake_active(), and rtmp_handshake_passive().

const uint8_t RTMP_HEADER_SIZE_1 = 0xC0

Referenced by rtmp_decode_header_size(), rtmp_encode_header_size(), and rtmp_encode_packet().

const uint8_t RTMP_HEADER_SIZE_12 = 0x00

Referenced by rtmp_decode_header_size(), and rtmp_encode_header_size().

const uint8_t RTMP_HEADER_SIZE_4 = 0x80

Referenced by rtmp_decode_header_size(), and rtmp_encode_header_size().

const uint8_t RTMP_HEADER_SIZE_8 = 0x40

Referenced by rtmp_decode_header_size(), and rtmp_encode_header_size().

const uint8_t RTMP_HEADER_SIZE_MASK = 0xC0

Referenced by rtmp_read_net_packet().

const uint8_t RTMP_HEADER_STREAM_INDEX_MASK = 0x3F

Referenced by rtmp_read_net_packet().

const uint8_t RTMP_HEADER_STREAM_MAX = 64

const uint16_t RTMP_PING_BUFFER_TIME_CLIENT = 0x0003

Referenced by rtmp_connect_active(), and rtmp_encode_ping().

const uint16_t RTMP_PING_CLEAR_PLAYING_BUFFER = 0x0001

Referenced by rtmp_encode_ping().

const uint16_t RTMP_PING_CLEAR_STREAM = 0x0000

Referenced by rtmp_encode_ping(), and rtmp_encode_ping_clear_stream().

const uint16_t RTMP_PING_CLIENT_FROM_SERVER = 0x0006

const uint16_t RTMP_PING_PONG_FROM_CLIENT = 0x0007

const uint16_t RTMP_PING_RESET_STREAM = 0x0004

Referenced by rtmp_encode_ping(), and rtmp_encode_ping_reset_stream().

const uint8_t RTMP_PING_SIZE_BUFFER_TIME_CLIENT = 10

Referenced by rtmp_connect_active(), and rtmp_encode_ping().

const uint8_t RTMP_PING_SIZE_CLEAR_PLAYING_BUFFER = 6

Referenced by rtmp_encode_ping().

const uint8_t RTMP_PING_SIZE_CLEAR_STREAM = 6

Referenced by rtmp_encode_ping(), and rtmp_encode_ping_clear_stream().

const uint8_t RTMP_PING_SIZE_RESET_STREAM = 6

Referenced by rtmp_encode_ping(), and rtmp_encode_ping_reset_stream().

const uint32_t RTMP_SERVER_BW = 0x00000200

Referenced by rtmp_handler_invoke().

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_CLEAR_DATA = 0x08

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_CONNECT = 0x01

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_DELETE_ATTRIBUTE = 0x0A

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_DELETE_DATA = 0x09

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_DISCONNECT = 0x02

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_INITIAL_DATA = 0x0B

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_SEND_MESSAGE = 0x06

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_SET_ATTRIBUTE = 0x03

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_STATUS = 0x07

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_UPDATE_ATTRIBUTE = 0x05

const uint8_t RTMP_SHARED_OBJECT_DATATYPE_UPDATE_DATA = 0x04

const uint32_t RTMP_SRC_DST_CONNECT_OBJECT = 0x00000000

Referenced by rtmp_connect_active(), rtmp_encode_onBWDone(), rtmp_encode_server_bw(), and rtmp_handler_invoke().

const uint32_t RTMP_SRC_DST_CONNECT_OBJECT2 = 0x00000001

Referenced by rtmp_connect_active(), rtmp_encode_ping_reset_stream(), and rtmp_handler_invoke().

const uint32_t RTMP_SRC_DST_DEFAULT = 0x01000000

Referenced by rtmp_build_flv_over_rtmp(), rtmp_connect_active(), rtmp_encode_NetStream_play_reset_onStatus(), and rtmp_encode_NetStream_play_start_onStatus().

const uint32_t RTMP_TIME_CLIENT_BUFFER = 2000

Referenced by rtmp_connect_active().

const uint64_t RTMP_VIDEOCODECS = 0x405f000000000000

const uint64_t RTMP_VIDEOFUNCTION = 0x3ff0000000000000