FFmpeg
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
Data Structures | Macros | Enumerations | Functions | Variables
rtmpproto.c File Reference

RTMP protocol. More...

#include "libavcodec/bytestream.h"
#include "libavutil/avstring.h"
#include "libavutil/base64.h"
#include "libavutil/hmac.h"
#include "libavutil/intfloat.h"
#include "libavutil/lfg.h"
#include "libavutil/md5.h"
#include "libavutil/opt.h"
#include "libavutil/random_seed.h"
#include "avformat.h"
#include "internal.h"
#include "network.h"
#include "flv.h"
#include "rtmp.h"
#include "rtmpcrypt.h"
#include "rtmppkt.h"
#include "url.h"

Go to the source code of this file.

Data Structures

struct  TrackedMethod
 
struct  RTMPContext
 protocol handler context More...
 

Macros

#define APP_MAX_LENGTH   1024
 
#define PLAYPATH_MAX_LENGTH   512
 
#define TCURL_MAX_LENGTH   1024
 
#define FLASHVER_MAX_LENGTH   64
 
#define RTMP_PKTDATA_DEFAULT_SIZE   4096
 
#define RTMP_HEADER   11
 
#define PLAYER_KEY_OPEN_PART_LEN   30
 length of partial key used for first client digest signing More...
 
#define SERVER_KEY_OPEN_PART_LEN   36
 length of partial key used for first server digest signing More...
 
#define RTMP_CTRL_ABORT_MESSAGE   (2)
 
#define OFFSET(x)   offsetof(RTMPContext, x)
 
#define DEC   AV_OPT_FLAG_DECODING_PARAM
 
#define ENC   AV_OPT_FLAG_ENCODING_PARAM
 
#define RTMP_PROTOCOL(flavor)
 

Enumerations

enum  ClientState {
  STATE_START, STATE_HANDSHAKED, STATE_FCPUBLISH, STATE_PLAYING,
  STATE_SEEKING, STATE_PUBLISHING, STATE_RECEIVING, STATE_SENDING,
  STATE_STOPPED
}
 RTMP protocol handler state. More...
 

Functions

static int handle_chunk_size (URLContext *s, RTMPPacket *pkt)
 
static int handle_window_ack_size (URLContext *s, RTMPPacket *pkt)
 
static int handle_set_peer_bw (URLContext *s, RTMPPacket *pkt)
 
static int add_tracked_method (RTMPContext *rt, const char *name, int id)
 
static void del_tracked_method (RTMPContext *rt, int index)
 
static int find_tracked_method (URLContext *s, RTMPPacket *pkt, int offset, char **tracked_method)
 
static void free_tracked_methods (RTMPContext *rt)
 
static int rtmp_send_packet (RTMPContext *rt, RTMPPacket *pkt, int track)
 
static int rtmp_write_amf_data (URLContext *s, char *param, uint8_t **p)
 
static int gen_connect (URLContext *s, RTMPContext *rt)
 Generate 'connect' call and send it to the server. More...
 
static int read_connect (URLContext *s, RTMPContext *rt)
 
static int gen_release_stream (URLContext *s, RTMPContext *rt)
 Generate 'releaseStream' call and send it to the server. More...
 
static int gen_fcpublish_stream (URLContext *s, RTMPContext *rt)
 Generate 'FCPublish' call and send it to the server. More...
 
static int gen_fcunpublish_stream (URLContext *s, RTMPContext *rt)
 Generate 'FCUnpublish' call and send it to the server. More...
 
static int gen_create_stream (URLContext *s, RTMPContext *rt)
 Generate 'createStream' call and send it to the server. More...
 
static int gen_delete_stream (URLContext *s, RTMPContext *rt)
 Generate 'deleteStream' call and send it to the server. More...
 
static int gen_get_stream_length (URLContext *s, RTMPContext *rt)
 Generate 'getStreamLength' call and send it to the server. More...
 
static int gen_buffer_time (URLContext *s, RTMPContext *rt)
 Generate client buffer time and send it to the server. More...
 
static int gen_play (URLContext *s, RTMPContext *rt)
 Generate 'play' call and send it to the server, then ping the server to start actual playing. More...
 
static int gen_seek (URLContext *s, RTMPContext *rt, int64_t timestamp)
 
static int gen_pause (URLContext *s, RTMPContext *rt, int pause, uint32_t timestamp)
 Generate a pause packet that either pauses or unpauses the current stream. More...
 
static int gen_publish (URLContext *s, RTMPContext *rt)
 Generate 'publish' call and send it to the server. More...
 
static int gen_pong (URLContext *s, RTMPContext *rt, RTMPPacket *ppkt)
 Generate ping reply and send it to the server. More...
 
static int gen_swf_verification (URLContext *s, RTMPContext *rt)
 Generate SWF verification message and send it to the server. More...
 
static int gen_window_ack_size (URLContext *s, RTMPContext *rt)
 Generate window acknowledgement size message and send it to the server. More...
 
static int gen_check_bw (URLContext *s, RTMPContext *rt)
 Generate check bandwidth message and send it to the server. More...
 
static int gen_bytes_read (URLContext *s, RTMPContext *rt, uint32_t ts)
 Generate report on bytes read so far and send it to the server. More...
 
static int gen_fcsubscribe_stream (URLContext *s, RTMPContext *rt, const char *subscribe)
 
int ff_rtmp_calc_digest (const uint8_t *src, int len, int gap, const uint8_t *key, int keylen, uint8_t *dst)
 Calculate HMAC-SHA2 digest for RTMP handshake packets. More...
 
int ff_rtmp_calc_digest_pos (const uint8_t *buf, int off, int mod_val, int add_val)
 Calculate digest position for RTMP handshake packets. More...
 
static int rtmp_handshake_imprint_with_digest (uint8_t *buf, int encrypted)
 Put HMAC-SHA2 digest of packet data (except for the bytes where this digest will be stored) into that packet. More...
 
static int rtmp_validate_digest (uint8_t *buf, int off)
 Verify that the received server response has the expected digest value. More...
 
static int rtmp_calc_swf_verification (URLContext *s, RTMPContext *rt, uint8_t *buf)
 
static int rtmp_calc_swfhash (URLContext *s)
 
static int rtmp_handshake (URLContext *s, RTMPContext *rt)
 Perform handshake with the server by means of exchanging pseudorandom data signed with HMAC-SHA2 digest. More...
 
static int rtmp_receive_hs_packet (RTMPContext *rt, uint32_t *first_int, uint32_t *second_int, char *arraydata, int size)
 
static int rtmp_send_hs_packet (RTMPContext *rt, uint32_t first_int, uint32_t second_int, char *arraydata, int size)
 
static int rtmp_server_handshake (URLContext *s, RTMPContext *rt)
 rtmp handshake server side More...
 
static int handle_user_control (URLContext *s, RTMPPacket *pkt)
 
static int do_adobe_auth (RTMPContext *rt, const char *user, const char *salt, const char *opaque, const char *challenge)
 
static int do_llnw_auth (RTMPContext *rt, const char *user, const char *nonce)
 
static int handle_connect_error (URLContext *s, const char *desc)
 
static int handle_invoke_error (URLContext *s, RTMPPacket *pkt)
 
static int write_begin (URLContext *s)
 
static int write_status (URLContext *s, RTMPPacket *pkt, const char *status, const char *filename)
 
static int send_invoke_response (URLContext *s, RTMPPacket *pkt)
 
static int read_number_result (RTMPPacket *pkt, double *number)
 Read the AMF_NUMBER response ("_result") to a function call (e.g. More...
 
static int handle_invoke_result (URLContext *s, RTMPPacket *pkt)
 
static int handle_invoke_status (URLContext *s, RTMPPacket *pkt)
 
static int handle_invoke (URLContext *s, RTMPPacket *pkt)
 
static int update_offset (RTMPContext *rt, int size)
 
static int append_flv_data (RTMPContext *rt, RTMPPacket *pkt, int skip)
 
static int handle_notify (URLContext *s, RTMPPacket *pkt)
 
static int rtmp_parse_result (URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
 Parse received packet and possibly perform some action depending on the packet contents. More...
 
static int handle_metadata (RTMPContext *rt, RTMPPacket *pkt)
 
static int get_packet (URLContext *s, int for_header)
 Interact with the server by receiving and sending RTMP packets until there is some significant data (media data or expected status notification). More...
 
static int rtmp_close (URLContext *h)
 
static int inject_fake_duration_metadata (RTMPContext *rt)
 Insert a fake onMetadata packet into the FLV stream to notify the FLV demuxer about the duration of the stream. More...
 
static int rtmp_open (URLContext *s, const char *uri, int flags, AVDictionary **opts)
 Open RTMP connection and verify that the stream can be played. More...
 
static int rtmp_read (URLContext *s, uint8_t *buf, int size)
 
static int64_t rtmp_seek (URLContext *s, int stream_index, int64_t timestamp, int flags)
 
static int rtmp_pause (URLContext *s, int pause)
 
static int rtmp_write (URLContext *s, const uint8_t *buf, int size)
 

Variables

static const uint8_t rtmp_player_key []
 Client key used for digest signing. More...
 
static const uint8_t rtmp_server_key []
 Key used for RTMP server digest signing. More...
 
static const AVOption rtmp_options []
 

Detailed Description

RTMP protocol.

Definition in file rtmpproto.c.

Macro Definition Documentation

#define APP_MAX_LENGTH   1024

Definition at line 51 of file rtmpproto.c.

Referenced by gen_connect(), and rtmp_open().

#define PLAYPATH_MAX_LENGTH   512

Definition at line 52 of file rtmpproto.c.

Referenced by rtmp_open().

#define TCURL_MAX_LENGTH   1024

Definition at line 53 of file rtmpproto.c.

Referenced by rtmp_open().

#define FLASHVER_MAX_LENGTH   64

Definition at line 54 of file rtmpproto.c.

Referenced by rtmp_open().

#define RTMP_PKTDATA_DEFAULT_SIZE   4096

Definition at line 55 of file rtmpproto.c.

Referenced by read_connect(), send_invoke_response(), and write_status().

#define RTMP_HEADER   11
#define PLAYER_KEY_OPEN_PART_LEN   30

length of partial key used for first client digest signing

Definition at line 135 of file rtmpproto.c.

Referenced by rtmp_handshake_imprint_with_digest().

#define SERVER_KEY_OPEN_PART_LEN   36

length of partial key used for first server digest signing

Definition at line 146 of file rtmpproto.c.

Referenced by rtmp_validate_digest().

#define RTMP_CTRL_ABORT_MESSAGE   (2)

Definition at line 408 of file rtmpproto.c.

Referenced by read_connect().

#define OFFSET (   x)    offsetof(RTMPContext, x)

Definition at line 3124 of file rtmpproto.c.

#define DEC   AV_OPT_FLAG_DECODING_PARAM

Definition at line 3125 of file rtmpproto.c.

#define ENC   AV_OPT_FLAG_ENCODING_PARAM

Definition at line 3126 of file rtmpproto.c.

#define RTMP_PROTOCOL (   flavor)
Value:
static const AVClass flavor##_class = { \
.class_name = #flavor, \
.item_name = av_default_item_name, \
.option = rtmp_options, \
.version = LIBAVUTIL_VERSION_INT, \
}; \
\
const URLProtocol ff_##flavor##_protocol = { \
.name = #flavor, \
.url_open2 = rtmp_open, \
.url_read = rtmp_read, \
.url_read_seek = rtmp_seek, \
.url_read_pause = rtmp_pause, \
.url_write = rtmp_write, \
.url_close = rtmp_close, \
.priv_data_size = sizeof(RTMPContext), \
.priv_data_class= &flavor##_class, \
};
static int rtmp_read(URLContext *s, uint8_t *buf, int size)
Definition: rtmpproto.c:2922
#define URL_PROTOCOL_FLAG_NETWORK
Definition: url.h:34
static int rtmp_write(URLContext *s, const uint8_t *buf, int size)
Definition: rtmpproto.c:2983
#define LIBAVUTIL_VERSION_INT
Definition: version.h:86
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Definition: log.h:72
static int flags
Definition: log.c:57
av_default_item_name
static int rtmp_pause(URLContext *s, int pause)
Definition: rtmpproto.c:2969
static int rtmp_close(URLContext *h)
Definition: rtmpproto.c:2527
static int64_t rtmp_seek(URLContext *s, int stream_index, int64_t timestamp, int flags)
Definition: rtmpproto.c:2949
Describe the class of an AVClass context structure.
Definition: log.h:67
const char * name
Definition: url.h:55
static int rtmp_open(URLContext *s, const char *uri, int flags, AVDictionary **opts)
Open RTMP connection and verify that the stream can be played.
Definition: rtmpproto.c:2626
static const AVOption rtmp_options[]
Definition: rtmpproto.c:3128
protocol handler context
Definition: rtmpproto.c:77

Definition at line 3152 of file rtmpproto.c.

Enumeration Type Documentation

RTMP protocol handler state.

Enumerator
STATE_START 

client has not done anything yet

STATE_HANDSHAKED 

client has performed handshake

STATE_FCPUBLISH 

client FCPublishing stream (for output)

STATE_PLAYING 

client has started receiving multimedia data from server

STATE_SEEKING 

client has started the seek operation. Back on STATE_PLAYING when the time comes

STATE_PUBLISHING 

client has started sending multimedia data to server (for output)

STATE_RECEIVING 

received a publish command (for input)

STATE_SENDING 

received a play command (for output)

STATE_STOPPED 

the broadcast has been stopped

Definition at line 59 of file rtmpproto.c.

Function Documentation

static int handle_chunk_size ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 1527 of file rtmpproto.c.

Referenced by read_connect(), and rtmp_parse_result().

static int handle_window_ack_size ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 1614 of file rtmpproto.c.

Referenced by read_connect(), and rtmp_parse_result().

static int handle_set_peer_bw ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 1587 of file rtmpproto.c.

Referenced by read_connect(), and rtmp_parse_result().

static int add_tracked_method ( RTMPContext rt,
const char *  name,
int  id 
)
static

Definition at line 162 of file rtmpproto.c.

Referenced by rtmp_send_packet().

static void del_tracked_method ( RTMPContext rt,
int  index 
)
static

Definition at line 185 of file rtmpproto.c.

Referenced by find_tracked_method().

static int find_tracked_method ( URLContext s,
RTMPPacket pkt,
int  offset,
char **  tracked_method 
)
static

Definition at line 192 of file rtmpproto.c.

Referenced by handle_invoke_error(), and handle_invoke_result().

static void free_tracked_methods ( RTMPContext rt)
static

Definition at line 217 of file rtmpproto.c.

Referenced by rtmp_close(), and rtmp_open().

static int rtmp_send_packet ( RTMPContext rt,
RTMPPacket pkt,
int  track 
)
static
static int rtmp_write_amf_data ( URLContext s,
char *  param,
uint8_t **  p 
)
static

Definition at line 256 of file rtmpproto.c.

Referenced by gen_connect().

static int gen_connect ( URLContext s,
RTMPContext rt 
)
static

Generate 'connect' call and send it to the server.

Definition at line 319 of file rtmpproto.c.

Referenced by rtmp_open().

static int read_connect ( URLContext s,
RTMPContext rt 
)
static

Definition at line 410 of file rtmpproto.c.

Referenced by rtmp_open().

static int gen_release_stream ( URLContext s,
RTMPContext rt 
)
static

Generate 'releaseStream' call and send it to the server.

It should make the server release some channel for media streams.

Definition at line 598 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_fcpublish_stream ( URLContext s,
RTMPContext rt 
)
static

Generate 'FCPublish' call and send it to the server.

It should make the server prepare for receiving media streams.

Definition at line 622 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_fcunpublish_stream ( URLContext s,
RTMPContext rt 
)
static

Generate 'FCUnpublish' call and send it to the server.

It should make the server destroy stream.

Definition at line 646 of file rtmpproto.c.

Referenced by rtmp_close().

static int gen_create_stream ( URLContext s,
RTMPContext rt 
)
static

Generate 'createStream' call and send it to the server.

It should make the server allocate some channel for media streams.

Definition at line 670 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_delete_stream ( URLContext s,
RTMPContext rt 
)
static

Generate 'deleteStream' call and send it to the server.

It should make the server remove some channel for media streams.

Definition at line 695 of file rtmpproto.c.

Referenced by rtmp_close().

static int gen_get_stream_length ( URLContext s,
RTMPContext rt 
)
static

Generate 'getStreamLength' call and send it to the server.

If the server knows the duration of the selected stream, it will reply with the duration in seconds.

Definition at line 721 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_buffer_time ( URLContext s,
RTMPContext rt 
)
static

Generate client buffer time and send it to the server.

Definition at line 743 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_play ( URLContext s,
RTMPContext rt 
)
static

Generate 'play' call and send it to the server, then ping the server to start actual playing.

Definition at line 765 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_seek ( URLContext s,
RTMPContext rt,
int64_t  timestamp 
)
static

Definition at line 789 of file rtmpproto.c.

Referenced by rtmp_seek().

static int gen_pause ( URLContext s,
RTMPContext rt,
int  pause,
uint32_t  timestamp 
)
static

Generate a pause packet that either pauses or unpauses the current stream.

Definition at line 815 of file rtmpproto.c.

Referenced by rtmp_pause().

static int gen_publish ( URLContext s,
RTMPContext rt 
)
static

Generate 'publish' call and send it to the server.

Definition at line 842 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_pong ( URLContext s,
RTMPContext rt,
RTMPPacket ppkt 
)
static

Generate ping reply and send it to the server.

Definition at line 869 of file rtmpproto.c.

Referenced by handle_user_control().

static int gen_swf_verification ( URLContext s,
RTMPContext rt 
)
static

Generate SWF verification message and send it to the server.

Definition at line 895 of file rtmpproto.c.

Referenced by handle_user_control().

static int gen_window_ack_size ( URLContext s,
RTMPContext rt 
)
static

Generate window acknowledgement size message and send it to the server.

Definition at line 916 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int gen_check_bw ( URLContext s,
RTMPContext rt 
)
static

Generate check bandwidth message and send it to the server.

Definition at line 935 of file rtmpproto.c.

Referenced by handle_invoke().

static int gen_bytes_read ( URLContext s,
RTMPContext rt,
uint32_t  ts 
)
static

Generate report on bytes read so far and send it to the server.

Definition at line 956 of file rtmpproto.c.

Referenced by get_packet().

static int gen_fcsubscribe_stream ( URLContext s,
RTMPContext rt,
const char *  subscribe 
)
static

Definition at line 972 of file rtmpproto.c.

Referenced by handle_invoke_result().

int ff_rtmp_calc_digest ( const uint8_t src,
int  len,
int  gap,
const uint8_t key,
int  keylen,
uint8_t dst 
)

Calculate HMAC-SHA2 digest for RTMP handshake packets.

Parameters
srcinput buffer
leninput buffer length (should be 1536)
gapoffset in buffer where 32 bytes should not be taken into account when calculating digest (since it will be used to store that digest)
keydigest key
keylendigest key length
dstbuffer where calculated digest will be stored (32 bytes)

Definition at line 992 of file rtmpproto.c.

Referenced by ff_rtmpe_compute_secret_key(), rtmp_calc_swf_verification(), rtmp_calc_swfhash(), rtmp_handshake(), rtmp_handshake_imprint_with_digest(), and rtmp_validate_digest().

int ff_rtmp_calc_digest_pos ( const uint8_t buf,
int  off,
int  mod_val,
int  add_val 
)

Calculate digest position for RTMP handshake packets.

Parameters
bufinput buffer (should be 1536 bytes)
offoffset in buffer where to start calculating digest position
mod_valvalue used for computing modulo
add_valvalue added at the end (after computing modulo)

Definition at line 1015 of file rtmpproto.c.

Referenced by ff_rtmpe_compute_secret_key(), ff_rtmpe_gen_pub_key(), rtmp_handshake_imprint_with_digest(), and rtmp_validate_digest().

static int rtmp_handshake_imprint_with_digest ( uint8_t buf,
int  encrypted 
)
static

Put HMAC-SHA2 digest of packet data (except for the bytes where this digest will be stored) into that packet.

Parameters
bufhandshake data (1536 bytes)
encrypteduse an encrypted connection (RTMPE)
Returns
offset to the digest inside input data

Definition at line 1035 of file rtmpproto.c.

Referenced by rtmp_handshake().

static int rtmp_validate_digest ( uint8_t buf,
int  off 
)
static

Verify that the received server response has the expected digest value.

Parameters
bufhandshake data received from the server (1536 bytes)
offposition to search digest offset from
Returns
0 if digest is valid, digest position otherwise

Definition at line 1060 of file rtmpproto.c.

Referenced by rtmp_handshake().

static int rtmp_calc_swf_verification ( URLContext s,
RTMPContext rt,
uint8_t buf 
)
static

Definition at line 1078 of file rtmpproto.c.

Referenced by rtmp_handshake().

static int rtmp_calc_swfhash ( URLContext s)
static

Definition at line 1146 of file rtmpproto.c.

Referenced by rtmp_open().

static int rtmp_handshake ( URLContext s,
RTMPContext rt 
)
static

Perform handshake with the server by means of exchanging pseudorandom data signed with HMAC-SHA2 digest.

Returns
0 if handshake succeeds, negative value otherwise

Definition at line 1233 of file rtmpproto.c.

Referenced by rtmp_open().

static int rtmp_receive_hs_packet ( RTMPContext rt,
uint32_t *  first_int,
uint32_t *  second_int,
char *  arraydata,
int  size 
)
static

Definition at line 1412 of file rtmpproto.c.

Referenced by rtmp_server_handshake().

static int rtmp_send_hs_packet ( RTMPContext rt,
uint32_t  first_int,
uint32_t  second_int,
char *  arraydata,
int  size 
)
static

Definition at line 1433 of file rtmpproto.c.

Referenced by rtmp_server_handshake().

static int rtmp_server_handshake ( URLContext s,
RTMPContext rt 
)
static

rtmp handshake server side

Definition at line 1453 of file rtmpproto.c.

Referenced by rtmp_open().

static int handle_user_control ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 1560 of file rtmpproto.c.

Referenced by rtmp_parse_result().

static int do_adobe_auth ( RTMPContext rt,
const char *  user,
const char *  salt,
const char *  opaque,
const char *  challenge 
)
static

Definition at line 1640 of file rtmpproto.c.

Referenced by handle_connect_error().

static int do_llnw_auth ( RTMPContext rt,
const char *  user,
const char *  nonce 
)
static

Definition at line 1679 of file rtmpproto.c.

Referenced by handle_connect_error().

static int handle_connect_error ( URLContext s,
const char *  desc 
)
static

Definition at line 1738 of file rtmpproto.c.

Referenced by handle_invoke_error().

static int handle_invoke_error ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 1829 of file rtmpproto.c.

Referenced by handle_invoke().

static int write_begin ( URLContext s)
static

Definition at line 1868 of file rtmpproto.c.

Referenced by send_invoke_response().

static int write_status ( URLContext s,
RTMPPacket pkt,
const char *  status,
const char *  filename 
)
static

Definition at line 1894 of file rtmpproto.c.

Referenced by send_invoke_response().

static int send_invoke_response ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 1937 of file rtmpproto.c.

Referenced by handle_invoke().

static int read_number_result ( RTMPPacket pkt,
double *  number 
)
static

Read the AMF_NUMBER response ("_result") to a function call (e.g.

createStream()). This response should be made up of the AMF_STRING "result", a NULL object and then the response encoded as AMF_NUMBER. On a successful response, we will return set the value to number (otherwise number will not be changed).

Returns
0 if reading the value succeeds, negative value otherwise

Definition at line 2053 of file rtmpproto.c.

Referenced by handle_invoke_result().

static int handle_invoke_result ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 2083 of file rtmpproto.c.

Referenced by handle_invoke().

static int handle_invoke_status ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 2155 of file rtmpproto.c.

Referenced by handle_invoke().

static int handle_invoke ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 2192 of file rtmpproto.c.

Referenced by rtmp_parse_result().

static int update_offset ( RTMPContext rt,
int  size 
)
static

Definition at line 2223 of file rtmpproto.c.

Referenced by append_flv_data(), and handle_metadata().

static int append_flv_data ( RTMPContext rt,
RTMPPacket pkt,
int  skip 
)
static

Definition at line 2242 of file rtmpproto.c.

Referenced by get_packet(), and handle_notify().

static int handle_notify ( URLContext s,
RTMPPacket pkt 
)
static

Definition at line 2275 of file rtmpproto.c.

Referenced by get_packet().

static int rtmp_parse_result ( URLContext s,
RTMPContext rt,
RTMPPacket pkt 
)
static

Parse received packet and possibly perform some action depending on the packet contents.

Returns
0 for no errors, negative values for serious errors which prevent further communications, positive values for uncritical errors

Definition at line 2338 of file rtmpproto.c.

Referenced by get_packet(), and rtmp_write().

static int handle_metadata ( RTMPContext rt,
RTMPPacket pkt 
)
static

Definition at line 2383 of file rtmpproto.c.

Referenced by get_packet().

static int get_packet ( URLContext s,
int  for_header 
)
static

Interact with the server by receiving and sending RTMP packets until there is some significant data (media data or expected status notification).

Parameters
sreading context
for_headernon-zero value tells function to work until it gets notification from the server that playing has been started, otherwise function will work until some media data is received (or an error happens)
Returns
0 for successful operation, negative value in case of error

Definition at line 2444 of file rtmpproto.c.

Referenced by ff_audio_rechunk_interleave(), rtmp_open(), and rtmp_read().

static int rtmp_close ( URLContext h)
static

Definition at line 2527 of file rtmpproto.c.

Referenced by rtmp_open().

static int inject_fake_duration_metadata ( RTMPContext rt)
static

Insert a fake onMetadata packet into the FLV stream to notify the FLV demuxer about the duration of the stream.

This should only be done if there was no real onMetadata packet sent by the server at the start of the stream and if we were able to retrieve a valid duration via a getStreamLength call.

Returns
0 for successful operation, negative value in case of error

Definition at line 2563 of file rtmpproto.c.

Referenced by rtmp_open().

static int rtmp_open ( URLContext s,
const char *  uri,
int  flags,
AVDictionary **  opts 
)
static

Open RTMP connection and verify that the stream can be played.

URL syntax: rtmp://server[:port][/app][/playpath] where 'app' is first one or two directories in the path (e.g. /ondemand/, /flash/live/, etc.) and 'playpath' is a file name (the rest of the path, may be prefixed with "mp4:")

Definition at line 2626 of file rtmpproto.c.

static int rtmp_read ( URLContext s,
uint8_t buf,
int  size 
)
static

Definition at line 2922 of file rtmpproto.c.

static int64_t rtmp_seek ( URLContext s,
int  stream_index,
int64_t  timestamp,
int  flags 
)
static

Definition at line 2949 of file rtmpproto.c.

static int rtmp_pause ( URLContext s,
int  pause 
)
static

Definition at line 2969 of file rtmpproto.c.

static int rtmp_write ( URLContext s,
const uint8_t buf,
int  size 
)
static

Definition at line 2983 of file rtmpproto.c.

Variable Documentation

const uint8_t rtmp_player_key[]
static
Initial value:
= {
'G', 'e', 'n', 'u', 'i', 'n', 'e', ' ', 'A', 'd', 'o', 'b', 'e', ' ',
'F', 'l', 'a', 's', 'h', ' ', 'P', 'l', 'a', 'y', 'e', 'r', ' ', '0', '0', '1',
0xF0, 0xEE, 0xC2, 0x4A, 0x80, 0x68, 0xBE, 0xE8, 0x2E, 0x00, 0xD0, 0xD1, 0x02,
0x9E, 0x7E, 0x57, 0x6E, 0xEC, 0x5D, 0x2D, 0x29, 0x80, 0x6F, 0xAB, 0x93, 0xB8,
0xE6, 0x36, 0xCF, 0xEB, 0x31, 0xAE
}

Client key used for digest signing.

Definition at line 137 of file rtmpproto.c.

Referenced by rtmp_handshake(), and rtmp_handshake_imprint_with_digest().

const uint8_t rtmp_server_key[]
static
Initial value:
= {
'G', 'e', 'n', 'u', 'i', 'n', 'e', ' ', 'A', 'd', 'o', 'b', 'e', ' ',
'F', 'l', 'a', 's', 'h', ' ', 'M', 'e', 'd', 'i', 'a', ' ',
'S', 'e', 'r', 'v', 'e', 'r', ' ', '0', '0', '1',
0xF0, 0xEE, 0xC2, 0x4A, 0x80, 0x68, 0xBE, 0xE8, 0x2E, 0x00, 0xD0, 0xD1, 0x02,
0x9E, 0x7E, 0x57, 0x6E, 0xEC, 0x5D, 0x2D, 0x29, 0x80, 0x6F, 0xAB, 0x93, 0xB8,
0xE6, 0x36, 0xCF, 0xEB, 0x31, 0xAE
}

Key used for RTMP server digest signing.

Definition at line 148 of file rtmpproto.c.

Referenced by rtmp_handshake(), and rtmp_validate_digest().

const AVOption rtmp_options[]
static
Initial value:
= {
{"rtmp_app", "Name of application to connect to on the RTMP server", OFFSET(app), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
{"rtmp_buffer", "Set buffer time in milliseconds. The default is 3000.", OFFSET(client_buffer_time), AV_OPT_TYPE_INT, {.i64 = 3000}, 0, INT_MAX, DEC|ENC},
{"rtmp_conn", "Append arbitrary AMF data to the Connect message", OFFSET(conn), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
{"rtmp_flashver", "Version of the Flash plugin used to run the SWF player.", OFFSET(flashver), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
{"rtmp_flush_interval", "Number of packets flushed in the same request (RTMPT only).", OFFSET(flush_interval), AV_OPT_TYPE_INT, {.i64 = 10}, 0, INT_MAX, ENC},
{"rtmp_live", "Specify that the media is a live stream.", OFFSET(live), AV_OPT_TYPE_INT, {.i64 = -2}, INT_MIN, INT_MAX, DEC, "rtmp_live"},
{"any", "both", 0, AV_OPT_TYPE_CONST, {.i64 = -2}, 0, 0, DEC, "rtmp_live"},
{"live", "live stream", 0, AV_OPT_TYPE_CONST, {.i64 = -1}, 0, 0, DEC, "rtmp_live"},
{"recorded", "recorded stream", 0, AV_OPT_TYPE_CONST, {.i64 = 0}, 0, 0, DEC, "rtmp_live"},
{"rtmp_pageurl", "URL of the web page in which the media was embedded. By default no value will be sent.", OFFSET(pageurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
{"rtmp_playpath", "Stream identifier to play or to publish", OFFSET(playpath), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
{"rtmp_subscribe", "Name of live stream to subscribe to. Defaults to rtmp_playpath.", OFFSET(subscribe), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
{"rtmp_swfhash", "SHA256 hash of the decompressed SWF file (32 bytes).", OFFSET(swfhash), AV_OPT_TYPE_BINARY, .flags = DEC},
{"rtmp_swfsize", "Size of the decompressed SWF file, required for SWFVerification.", OFFSET(swfsize), AV_OPT_TYPE_INT, {.i64 = 0}, 0, INT_MAX, DEC},
{"rtmp_swfurl", "URL of the SWF player. By default no value will be sent", OFFSET(swfurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
{"rtmp_swfverify", "URL to player swf file, compute hash/size automatically.", OFFSET(swfverify), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
{"rtmp_tcurl", "URL of the target stream. Defaults to proto://host[:port]/app.", OFFSET(tcurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
{"rtmp_listen", "Listen for incoming rtmp connections", OFFSET(listen), AV_OPT_TYPE_INT, {.i64 = 0}, INT_MIN, INT_MAX, DEC, "rtmp_listen" },
{"listen", "Listen for incoming rtmp connections", OFFSET(listen), AV_OPT_TYPE_INT, {.i64 = 0}, INT_MIN, INT_MAX, DEC, "rtmp_listen" },
{"timeout", "Maximum timeout (in seconds) to wait for incoming connections. -1 is infinite. Implies -rtmp_listen 1", OFFSET(listen_timeout), AV_OPT_TYPE_INT, {.i64 = -1}, INT_MIN, INT_MAX, DEC, "rtmp_listen" },
{ NULL },
}
#define NULL
Definition: coverity.c:32
#define DEC
Definition: rtmpproto.c:3125
#define OFFSET(x)
Definition: rtmpproto.c:3124
#define ENC
Definition: rtmpproto.c:3126
offset must point to a pointer immediately followed by an int for the length
Definition: opt.h:229

Definition at line 3128 of file rtmpproto.c.