Go to the documentation of this file.
22 #include "config_components.h"
86 if (rbuf[idx] ==
'\r') {
88 }
else if (rbuf[idx] ==
'\n') {
94 }
while (idx < rbufsize);
100 const char *extracontent, uint16_t seq)
131 if (!session_id[0]) {
135 if (strcmp(session_id, request->
session_id)) {
159 }
while (rbuflen > 0);
160 if (request->
seq != rt->
seq + 1) {
165 if (rt->
session_id[0] && strcmp(method,
"OPTIONS")) {
200 "Unable to get complete SDP Description in ANNOUNCE\n");
215 "Content-Length header value exceeds sdp allocated buffer (4KB)\n");
217 "Content-Length exceeds buffer size", request.
seq);
234 "Public: ANNOUNCE, PAUSE, SETUP, TEARDOWN, RECORD\r\n",
248 int transportidx = 0;
267 " protocol not supported (yet)\n");
273 "using first of all\n");
305 snprintf(responseheaders,
sizeof(responseheaders),
"Transport: "
306 "RTP/AVP/TCP;unicast;mode=receive;interleaved=%d-%d"
316 &
s->interrupt_callback, &
opts,
317 s->protocol_whitelist,
s->protocol_blacklist,
NULL);
335 snprintf(responseheaders,
sizeof(responseheaders),
"Transport: "
336 "RTP/AVP/UDP;unicast;mode=receive;source=%s;"
337 "client_port=%d-%d;server_port=%d-%d\r\n",
349 av_strlcatf(responseheaders,
sizeof(responseheaders),
"Session: %s\r\n",
372 snprintf(responseheaders,
sizeof(responseheaders),
"Session: %s\r\n",
381 int linelen,
char *uri,
int urisize,
382 char *method,
int methodsize,
386 const char *linept, *searchlinept;
387 linept = strchr(
line,
' ');
394 if (linept -
line > methodsize - 1) {
398 memcpy(method,
line, linept -
line);
399 method[linept -
line] =
'\0';
401 if (!strcmp(method,
"ANNOUNCE"))
403 else if (!strcmp(method,
"OPTIONS"))
405 else if (!strcmp(method,
"RECORD"))
407 else if (!strcmp(method,
"SETUP"))
409 else if (!strcmp(method,
"PAUSE"))
411 else if (!strcmp(method,
"TEARDOWN"))
424 && (*methodcode !=
SETUP)) {
441 searchlinept = strchr(linept,
' ');
446 if (searchlinept - linept > urisize - 1) {
450 memcpy(uri, linept, searchlinept - linept);
451 uri[searchlinept - linept] =
'\0';
453 char host[128], path[512], auth[128];
455 char ctl_host[128], ctl_path[512], ctl_auth[128];
458 path,
sizeof(path), uri);
460 sizeof(ctl_host), &ctl_port, ctl_path,
sizeof(ctl_path),
462 if (strcmp(host, ctl_host))
465 if (strcmp(path, ctl_path) && *methodcode !=
SETUP)
467 " %s\n", path, ctl_path);
470 "Updating control URI to %s\n", uri);
475 linept = searchlinept + 1;
487 unsigned char method[10];
499 sizeof(method), &methodcode);
509 if (methodcode ==
PAUSE) {
513 }
else if (methodcode ==
OPTIONS) {
515 "Public: ANNOUNCE, PAUSE, SETUP, TEARDOWN, "
516 "RECORD\r\n", request.
seq);
517 }
else if (methodcode ==
TEARDOWN) {
566 "Range: npt=%"PRId64
".%03"PRId64
"-\r\n",
616 unsigned char *content =
NULL;
621 "Accept: application/sdp\r\n");
628 "Require: com.real.retain-entity-for-setup\r\n",
652 char proto[128], host[128], path[512], auth[128];
657 const char *lower_proto =
"tcp";
659 unsigned char method[10];
668 av_url_split(proto,
sizeof(proto), auth,
sizeof(auth), host,
sizeof(host),
669 &port, path,
sizeof(path),
s->url);
675 if (!strcmp(proto,
"rtsps")) {
688 &
s->interrupt_callback,
NULL,
689 s->protocol_whitelist,
s->protocol_blacklist,
NULL)) {
701 sizeof(method), &methodcode);
710 }
else if (methodcode ==
OPTIONS) {
712 }
else if (methodcode ==
RECORD) {
716 }
else if (methodcode ==
SETUP)
733 #
if CONFIG_TLS_PROTOCOL
784 uint8_t *buf,
int buf_size)
810 if (
len > buf_size ||
len < 8)
824 id <= rtsp_st->interleaved_max)
857 for (
i = 0;
i <
s->nb_streams;
i++)
864 "Unsubscribe: %s\r\n",
875 int r, rule_nr,
first = 1;
885 for (
r = 0;
r <
s->nb_streams;
r++) {
886 if (
s->streams[
r]->id ==
i) {
962 int64_t timestamp,
int flags)
968 s->streams[stream_index]->time_base,
int initial_timeout
Timeout to wait for incoming connections.
@ RTSP_STATE_PAUSED
initialized, but not receiving data
void ff_rdt_subscribe_rule(char *cmd, int size, int stream_nr, int rule_nr)
Add subscription information to Subscribe parameter string.
int initial_pause
Do not begin to play the stream immediately.
int ff_rtsp_read_reply(AVFormatContext *s, RTSPMessageHeader *reply, unsigned char **content_ptr, int return_on_interleaved_data, const char *method)
Read a RTSP message from the server, or prepare to read data packets if we're reading data interleave...
int64_t last_cmd_time
timestamp of the last RTSP command that we sent to the RTSP server.
int64_t av_gettime_relative(void)
Get the current time in microseconds since some unspecified starting point.
#define AV_LOG_WARNING
Something somehow does not look correct.
void ff_rtsp_close_streams(AVFormatContext *s)
Close and free all streams within the RTSP (de)muxer.
static int rtsp_read_request(AVFormatContext *s, RTSPMessageHeader *request, const char *method)
Filter the word “frame” indicates either a video frame or a group of audio as stored in an AVFrame structure Format for each input and each output the list of supported formats For video that means pixel format For audio that means channel sample they are references to shared objects When the negotiation mechanism computes the intersection of the formats supported at each end of a all references to both lists are replaced with a reference to the intersection And when a single format is eventually chosen for a link amongst the remaining all references to the list are updated That means that if a filter requires that its input and output have the same format amongst a supported all it has to do is use a reference to the same list of formats query_formats can leave some formats unset and return AVERROR(EAGAIN) to cause the negotiation mechanism toagain later. That can be used by filters with complex requirements to use the format negotiated on one link to set the formats supported on another. Frame references ownership and permissions
void * transport_priv
RTP/RDT parse context if input, RTP AVFormatContext if output.
URLContext * rtp_handle
RTP stream handle (if UDP)
@ RTSP_STATE_SEEKING
initialized, requesting a seek
int ff_rtsp_send_cmd(AVFormatContext *s, const char *method, const char *url, const char *headers, RTSPMessageHeader *reply, unsigned char **content_ptr)
Send a command to the RTSP server and wait for the reply.
static int resetup_tcp(AVFormatContext *s)
#define AVERROR_EOF
End of file.
#define AVIO_FLAG_READ_WRITE
read-write pseudo flag
static int rtsp_read_options(AVFormatContext *s)
@ RTSP_TRANSPORT_RTP
Standards-compliant RTP.
#define AV_TIME_BASE_Q
Internal time base represented as fractional value.
int get_parameter_supported
Whether the server supports the GET_PARAMETER method.
static int ff_rtsp_averror(enum RTSPStatusCode status_code, int default_averror)
int interleaved_min
interleave IDs; copies of RTSPTransportField->interleaved_min/max for the selected transport.
static int rtsp_read_setup(AVFormatContext *s, char *host, char *controlurl)
static int rtsp_read_close(AVFormatContext *s)
static int rtsp_send_reply(AVFormatContext *s, enum RTSPStatusCode code, const char *extracontent, uint16_t seq)
int64_t range_start_offset
enum RTSPLowerTransport lower_transport
network layer transport protocol; e.g.
int rtp_port_min
Minimum and maximum local UDP ports.
int interleaved_min
interleave ids, if TCP transport; each TCP/RTSP data packet starts with a '$', stream length and stre...
Describe a single stream, as identified by a single m= line block in the SDP content.
#define AV_LOG_VERBOSE
Detailed information.
int ff_rtsp_send_cmd_async(AVFormatContext *s, const char *method, const char *url, const char *headers)
Send a command to the RTSP server without waiting for the reply.
char real_challenge[64]
the "RealChallenge1:" field from the server
void ff_network_close(void)
@ RTSP_SERVER_REAL
Realmedia-style server.
size_t av_strlcatf(char *dst, size_t size, const char *fmt,...)
int64_t seek_timestamp
the seek value requested when calling av_seek_frame().
int ff_network_init(void)
int ff_sdp_parse(AVFormatContext *s, const char *content)
Parse an SDP description of streams by populating an RTSPState struct within the AVFormatContext; als...
uint32_t av_get_random_seed(void)
Get a seed to use in conjunction with random functions.
void ff_rtp_send_punch_packets(URLContext *rtp_handle)
Send a dummy packet on both port pairs to set up the connection state in potential NAT routers,...
static int check_sessionid(AVFormatContext *s, RTSPMessageHeader *request)
int ff_rtp_get_local_rtp_port(URLContext *h)
Return the local rtp port used by the RTP connection.
static int read_seek(AVFormatContext *ctx, int stream_index, int64_t timestamp, int flags)
int nb_rtsp_streams
number of items in the 'rtsp_streams' variable
static int read_line(AVFormatContext *s, char *rbuf, const int rbufsize, int *rbuflen)
static int rtsp_read_header(AVFormatContext *s)
static int rtsp_read_packet(AVFormatContext *s, AVPacket *pkt)
static av_cold int read_close(AVFormatContext *ctx)
#define AVERROR_OPTION_NOT_FOUND
Option not found.
int ff_rtsp_setup_input_streams(AVFormatContext *s, RTSPMessageHeader *reply)
Get the description of the stream and set up the RTSPStream child objects.
@ RTSP_TRANSPORT_RDT
Realmedia Data Transport.
int ff_rtsp_tcp_read_packet(AVFormatContext *s, RTSPStream **prtsp_st, uint8_t *buf, int buf_size)
Receive one RTP packet from an TCP interleaved RTSP stream.
@ RTSP_STATE_STREAMING
initialized and sending/receiving data
int lower_transport_mask
A mask with all requested transport methods.
int stream_index
corresponding stream index, if any.
void ff_rdt_parse_close(RDTDemuxContext *s)
trying all byte sequences megabyte in length and selecting the best looking sequence will yield cases to try But first
int ff_rdt_parse_header(const uint8_t *buf, int len, int *pset_id, int *pseq_no, int *pstream_id, int *pis_keyframe, uint32_t *ptimestamp)
Parse RDT-style packet header.
URLContext * rtsp_hd_out
Additional output handle, used when input and output are done separately, eg for HTTP tunneling.
#define AV_LOG_TRACE
Extremely verbose debugging, useful for libav* development.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
#define RTSP_FLAG_LISTEN
Wait for incoming connections.
int ff_rtsp_parse_streaming_commands(AVFormatContext *s)
Parse RTSP commands (OPTIONS, PAUSE and TEARDOWN) during streaming in listen mode.
int ffurl_open_whitelist(URLContext **puc, const char *filename, int flags, const AVIOInterruptCB *int_cb, AVDictionary **options, const char *whitelist, const char *blacklist, URLContext *parent)
Create an URLContext for accessing to the resource indicated by url, and open it.
char control_uri[MAX_URL_SIZE]
some MS RTSP streams contain a URL in the SDP that we need to use for all subsequent RTSP requests,...
int ff_url_join(char *str, int size, const char *proto, const char *authorization, const char *hostname, int port, const char *fmt,...)
void ff_rtsp_undo_setup(AVFormatContext *s, int send_packets)
Undo the effect of ff_rtsp_make_setup_request, close the transport_priv and rtp_handle fields.
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
int ff_rtsp_open_transport_ctx(AVFormatContext *s, RTSPStream *rtsp_st)
Open RTSP transport context.
int64_t av_rescale_q(int64_t a, AVRational bq, AVRational cq)
Rescale a 64-bit integer by 2 rational numbers.
int ff_rtsp_fetch_packet(AVFormatContext *s, AVPacket *pkt)
Receive one packet from the RTSPStreams set up in the AVFormatContext (which should contain a RTSPSta...
static int parse_command_line(AVFormatContext *s, const char *line, int linelen, char *uri, int urisize, char *method, int methodsize, enum RTSPMethod *methodcode)
@ AVDISCARD_ALL
discard all
char session_id[512]
copy of RTSPMessageHeader->session_id, i.e.
#define LIBAVUTIL_VERSION_INT
static int read_header(FFV1Context *f)
Describe the class of an AVClass context structure.
AVRational time_base
This is the fundamental unit of time (in seconds) in terms of which frame timestamps are represented.
const char * av_default_item_name(void *ptr)
Return the context name.
static int rtsp_probe(const AVProbeData *p)
enum AVDiscard * real_setup
current stream setup.
This structure contains the data a format has to probe a file.
static int rtsp_read_play(AVFormatContext *s)
enum RTSPClientState state
indicator of whether we are currently receiving data from the server.
uint64_t last_rtcp_ntp_time
static int rtsp_read_record(AVFormatContext *s)
void ff_rtp_parse_close(RTPDemuxContext *s)
static int rtsp_listen(AVFormatContext *s)
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification.
int rtsp_flags
Various option flags for the RTSP muxer/demuxer.
const AVOption ff_rtsp_options[]
void ff_rtsp_close_connections(AVFormatContext *s)
Close all connection handles within the RTSP (de)muxer.
Private data for the RTSP demuxer.
enum RTSPLowerTransport lower_transport
the negotiated network layer transport protocol; e.g.
uint64_t first_rtcp_ntp_time
struct RTSPStream ** rtsp_streams
streams in this session
#define AV_NOPTS_VALUE
Undefined timestamp value.
int seq
RTSP command sequence number.
HTTPAuthState auth_state
authentication state
int64_t unwrapped_timestamp
void ff_rtsp_parse_line(AVFormatContext *s, RTSPMessageHeader *reply, const char *buf, RTSPState *rt, const char *method)
void av_dict_free(AVDictionary **pm)
Free all the memory allocated for an AVDictionary struct and all keys and values.
int av_strstart(const char *str, const char *pfx, const char **ptr)
Return non-zero if pfx is a prefix of str.
char last_subscription[1024]
the last value of the "SET_PARAMETER Subscribe:" RTSP command.
int timeout
copy of RTSPMessageHeader->timeout, i.e.
#define AV_LOG_INFO
Standard information.
#define i(width, name, range_min, range_max)
and forward the test the status of outputs and forward it to the corresponding return FFERROR_NOT_READY If the filters stores internally one or a few frame for some it can consider them to be part of the FIFO and delay acknowledging a status change accordingly Example code
#define AV_TIME_BASE
Internal time base represented as integer.
int need_subscription
The following are used for Real stream selection.
static int rtsp_read_seek(AVFormatContext *s, int stream_index, int64_t timestamp, int flags)
void av_url_split(char *proto, int proto_size, char *authorization, int authorization_size, char *hostname, int hostname_size, int *port_ptr, char *path, int path_size, const char *url)
Split a URL string into components.
@ RTSP_LOWER_TRANSPORT_TCP
TCP; interleaved in RTSP.
static const struct RTSPStatusMessage status_messages[]
void * av_calloc(size_t nmemb, size_t size)
int client_port_min
UDP client ports; these should be the local ports of the UDP RTP (and RTCP) sockets over which we rec...
static const AVClass rtsp_demuxer_class
const AVInputFormat ff_rtsp_demuxer
static int rtsp_read_announce(AVFormatContext *s)
int ffurl_closep(URLContext **hh)
Close the resource accessed by the URLContext h, and free the memory used by it.
static int read_packet(void *opaque, uint8_t *buf, int buf_size)
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
size_t av_strlcat(char *dst, const char *src, size_t size)
Append the string src to the string dst, but to a total length of no more than size - 1 bytes,...
int stale
Auth ok, but needs to be resent with a new nonce.
#define RTSP_DEFAULT_PORT
enum RTSPTransport transport
the negotiated data/packet transport protocol; e.g.
char control_url[MAX_URL_SIZE]
url for this stream (from SDP)
#define AVERROR_STREAM_NOT_FOUND
Stream not found.
RTSPStatusCode
RTSP handling.
int ffurl_write(URLContext *h, const unsigned char *buf, int size)
Write size bytes from buf to the resource accessed by h.
@ RTSP_SERVER_WMS
Windows Media server.
int av_dict_set_int(AVDictionary **pm, const char *key, int64_t value, int flags)
Convenience wrapper for av_dict_set that converts the value to a string and stores it.
enum AVDiscard * real_setup_cache
stream setup during the last frame read.
@ RTSP_STATE_IDLE
not initialized
@ RTSP_STATUS_ONLY_AGGREGATE
int ffurl_read_complete(URLContext *h, unsigned char *buf, int size)
Read as many bytes as possible (up to size), calling the read function multiple times if necessary.
This structure stores compressed data.
enum RTSPServerType server_type
brand of server that we're talking to; e.g.
void ff_rtp_reset_packet_queue(RTPDemuxContext *s)
uint64_t packets
The number of returned packets.
int mode_record
transport set to record data
#define flags(name, subs,...)
#define AVERROR_BUG
Internal bug, also see AVERROR_BUG2.
size_t av_strlcpy(char *dst, const char *src, size_t size)
Copy the string src to dst, but no more than size - 1 bytes, and null-terminate dst.
#define AVERROR_INVALIDDATA
Invalid data found when processing input.
int ff_rtsp_make_setup_request(AVFormatContext *s, const char *host, int port, int lower_transport, const char *real_challenge)
Do the SETUP requests for each stream for the chosen lower transport mode.
int ff_rtsp_connect(AVFormatContext *s)
Connect to the RTSP server and set up the individual media streams.
#define AVERROR_PROTOCOL_NOT_FOUND
Protocol not found.
static int rtsp_read_pause(AVFormatContext *s)
#define RTSPS_DEFAULT_PORT
@ RTSP_LOWER_TRANSPORT_UDP
UDP/unicast.
The official guide to swscale for confused that consecutive non overlapping rectangles of slice_bottom special converter These generally are unscaled converters of common like for each output line the vertical scaler pulls lines from a ring buffer When the ring buffer does not contain the wanted line
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_WL32 unsigned int_TMPL AV_WL24 unsigned int_TMPL AV_WL16 uint64_t_TMPL AV_WB64 unsigned int_TMPL AV_WB32 unsigned int_TMPL AV_WB24 unsigned int_TMPL AV_RB16