81 if (rbuf[idx] ==
'\r') {
83 }
else if (rbuf[idx] ==
'\n') {
89 }
while (idx < rbufsize);
95 const char *extracontent, uint16_t seq)
102 snprintf(message,
sizeof(message),
"RTSP/1.0 %d %s\r\n",
110 av_strlcatf(message,
sizeof(message),
"CSeq: %d\r\n", seq);
113 av_strlcat(message, extracontent,
sizeof(message));
115 av_dlog(s,
"Sending response:\n%s", message);
126 if (!session_id[0]) {
130 if (strcmp(session_id, request->
session_id)) {
147 ret =
read_line(s, rbuf,
sizeof(rbuf), &rbuflen);
151 av_dlog(s,
"Parsing[%d]: %s\n", rbuflen, rbuf);
154 }
while (rbuflen > 0);
155 if (request->
seq != rt->
seq + 1) {
160 if (rt->
session_id[0] && strcmp(method,
"OPTIONS")) {
191 "Unable to get complete SDP Description in ANNOUNCE\n");
204 "Content-Length header value exceeds sdp allocated buffer (4KB)\n");
206 "Content-Length exceeds buffer size", request.
seq);
223 "Public: ANNOUNCE, PAUSE, SETUP, TEARDOWN, RECORD\r\n",
235 char responseheaders[1024];
237 int transportidx = 0;
256 " protocol not supported (yet)\n");
262 "using first of all\n");
283 snprintf(responseheaders,
sizeof(responseheaders),
"Transport: "
284 "RTP/AVP/TCP;unicast;mode=receive;interleaved=%d-%d"
290 av_dlog(s,
"Opening: %s", url);
309 snprintf(responseheaders,
sizeof(responseheaders),
"Transport: "
310 "RTP/AVP/UDP;unicast;mode=receive;source=%s;"
311 "client_port=%d-%d;server_port=%d-%d\r\n",
323 av_strlcatf(responseheaders,
sizeof(responseheaders),
"Session: %s\r\n",
337 char responseheaders[1024];
346 snprintf(responseheaders,
sizeof(responseheaders),
"Session: %s\r\n",
355 int linelen,
char *uri,
int urisize,
356 char *method,
int methodsize,
360 const char *linept, *searchlinept;
361 linept = strchr(line,
' ');
362 if (linept - line > methodsize - 1) {
366 memcpy(method, line, linept - line);
367 method[linept - line] =
'\0';
369 if (!strcmp(method,
"ANNOUNCE"))
371 else if (!strcmp(method,
"OPTIONS"))
373 else if (!strcmp(method,
"RECORD"))
375 else if (!strcmp(method,
"SETUP"))
377 else if (!strcmp(method,
"PAUSE"))
379 else if (!strcmp(method,
"TEARDOWN"))
392 && (*methodcode !=
SETUP)) {
409 searchlinept = strchr(linept,
' ');
410 if (searchlinept ==
NULL) {
414 if (searchlinept - linept > urisize - 1) {
418 memcpy(uri, linept, searchlinept - linept);
419 uri[searchlinept - linept] =
'\0';
421 char host[128], path[512], auth[128];
423 char ctl_host[128], ctl_path[512], ctl_auth[128];
426 path,
sizeof(path), uri);
428 sizeof(ctl_host), &ctl_port, ctl_path,
sizeof(ctl_path),
430 if (strcmp(host, ctl_host))
433 if (strcmp(path, ctl_path) && *methodcode !=
SETUP)
435 " %s\n", path, ctl_path);
438 "Updating control URI to %s\n", uri);
443 linept = searchlinept + 1;
454 unsigned char rbuf[4096];
455 unsigned char method[10];
462 ret =
read_line(s, rbuf,
sizeof(rbuf), &rbuflen);
466 sizeof(method), &methodcode);
476 if (methodcode ==
PAUSE) {
480 }
else if (methodcode ==
OPTIONS) {
482 "Public: ANNOUNCE, PAUSE, SETUP, TEARDOWN, "
483 "RECORD\r\n", request.
seq);
484 }
else if (methodcode ==
TEARDOWN) {
521 snprintf(cmd,
sizeof(cmd),
522 "Range: npt=%"PRId64
".%03"PRId64
"-\r\n",
571 unsigned char *content =
NULL;
575 snprintf(cmd,
sizeof(cmd),
576 "Accept: application/sdp\r\n");
583 "Require: com.real.retain-entity-for-setup\r\n",
607 char host[128], path[512], auth[128];
611 unsigned char rbuf[4096];
612 unsigned char method[10];
640 ret =
read_line(s, rbuf,
sizeof(rbuf), &rbuflen);
644 sizeof(method), &methodcode);
653 }
else if (methodcode ==
OPTIONS) {
655 }
else if (methodcode ==
RECORD) {
659 }
else if (methodcode ==
SETUP)
720 av_dlog(s,
"tcp_read_packet:\n");
739 av_dlog(s,
"id=%d len=%d\n",
id, len);
740 if (len > buf_size || len < 12)
754 id <= rtsp_st->interleaved_max)
793 snprintf(cmd,
sizeof(cmd),
794 "Unsubscribe: %s\r\n",
805 int r, rule_nr, first = 1;
811 snprintf(cmd,
sizeof(cmd),
892 int64_t timestamp,
int flags)
936 .priv_class = &rtsp_demuxer_class,
int interleaved_min
interleave ids, if TCP transport; each TCP/RTSP data packet starts with a '$', stream length and stre...
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.
int rtp_port_min
Minimum and maximum local UDP ports.
Realmedia Data Transport.
static int rtsp_read_options(AVFormatContext *s)
void ff_rtsp_undo_setup(AVFormatContext *s)
Undo the effect of ff_rtsp_make_setup_request, close the transport_priv and rtp_handle fields...
AVIOInterruptCB interrupt_callback
Custom interrupt callbacks for the I/O layer.
static const struct RTSPStatusMessage status_messages[]
static int rtsp_read_request(AVFormatContext *s, RTSPMessageHeader *request, const char *method)
static int rtsp_read_close(AVFormatContext *s)
char control_uri[1024]
some MS RTSP streams contain a URL in the SDP that we need to use for all subsequent RTSP requests...
static int rtsp_read_header(AVFormatContext *s)
int ffurl_write(URLContext *h, const unsigned char *buf, int size)
Write size bytes from buf to the resource accessed by h.
#define RTSP_DEFAULT_PORT
int64_t range_start_offset
int ff_rtsp_open_transport_ctx(AVFormatContext *s, RTSPStream *rtsp_st)
Open RTSP transport context.
static int read_seek(AVFormatContext *ctx, int stream_index, int64_t timestamp, int flags)
static int rtsp_probe(AVProbeData *p)
enum AVDiscard * real_setup
current stream setup.
static int resetup_tcp(AVFormatContext *s)
enum AVDiscard * real_setup_cache
stream setup during the last frame read.
int mode_record
transport set to record data
int ff_rtsp_setup_input_streams(AVFormatContext *s, RTSPMessageHeader *reply)
Get the description of the stream and set up the RTSPStream child objects.
void ff_network_close(void)
initialized and sending/receiving data
char real_challenge[64]
the "RealChallenge1:" field from the server
static int rtsp_read_pause(AVFormatContext *s)
av_dlog(ac->avr,"%d samples - audio_convert: %s to %s (%s)\n", len, av_get_sample_fmt_name(ac->in_fmt), av_get_sample_fmt_name(ac->out_fmt), use_generic?ac->func_descr_generic:ac->func_descr)
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.
void ff_rdt_subscribe_rule(char *cmd, int size, int stream_nr, int rule_nr)
Add subscription information to Subscribe parameter string.
#define RTSP_FLAG_LISTEN
Wait for incoming connections.
char session_id[512]
copy of RTSPMessageHeader->session_id, i.e.
int64_t seek_timestamp
the seek value requested when calling av_seek_frame().
static int rtsp_send_reply(AVFormatContext *s, enum RTSPStatusCode code, const char *extracontent, uint16_t seq)
static int check_sessionid(AVFormatContext *s, RTSPMessageHeader *request)
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.
enum RTSPLowerTransport lower_transport
network layer transport protocol; e.g.
void av_freep(void *arg)
Free a memory block which has been allocated with av_malloc(z)() or av_realloc() and set the pointer ...
int ff_rtsp_connect(AVFormatContext *s)
Connect to the RTSP server and set up the individual media streams.
#define LIBAVFORMAT_IDENT
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
static int rtsp_read_packet(AVFormatContext *s, AVPacket *pkt)
int get_parameter_supported
Whether the server supports the GET_PARAMETER method.
miscellaneous OS support macros and functions.
void ff_rtp_reset_packet_queue(RTPDemuxContext *s)
int id
Format-specific stream ID.
void ff_rtsp_parse_line(RTSPMessageHeader *reply, const char *buf, RTSPState *rt, const char *method)
int initial_timeout
Timeout to wait for incoming connections.
static int read_line(AVFormatContext *s, char *rbuf, const int rbufsize, int *rbuflen)
URLContext * rtsp_hd_out
Additional output handle, used when input and output are done separately, eg for HTTP tunneling...
Aggregate operation not allowed.
static int rtsp_read_setup(AVFormatContext *s, char *host, char *controlurl)
Describe a single stream, as identified by a single m= line block in the SDP content.
static av_cold int read_close(AVFormatContext *ctx)
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 rtsp_read_play(AVFormatContext *s)
Only aggregate operation allowed.
int ff_rtp_get_local_rtp_port(URLContext *h)
Return the local rtp port used by the RTP connection.
int64_t av_rescale_q(int64_t a, AVRational bq, AVRational cq)
Rescale a 64-bit integer by 2 rational numbers.
int ff_sdp_parse(AVFormatContext *s, const char *content)
Parse an SDP description of streams by populating an RTSPState struct within the AVFormatContext; als...
int ff_rtsp_parse_streaming_commands(AVFormatContext *s)
Parse RTSP commands (OPTIONS, PAUSE and TEARDOWN) during streaming in listen mode.
Private data for the RTSP demuxer.
int64_t last_cmd_time
timestamp of the last RTSP command that we sent to the RTSP server.
int timeout
copy of RTSPMessageHeader->timeout, i.e.
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification. ...
const AVOption ff_rtsp_options[]
void av_log(void *avcl, int level, const char *fmt,...)
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.
static int parse_command_line(AVFormatContext *s, const char *line, int linelen, char *uri, int urisize, char *method, int methodsize, enum RTSPMethod *methodcode)
struct RTSPStream ** rtsp_streams
streams in this session
static int rtsp_read_record(AVFormatContext *s)
int stream_index
corresponding stream index, if any.
int seq
RTSP command sequence number.
unsigned int nb_streams
A list of all streams in the file.
char filename[1024]
input or output filename
int nb_rtsp_streams
number of items in the 'rtsp_streams' variable
int64_t first_rtcp_ntp_time
char last_subscription[1024]
the last value of the "SET_PARAMETER Subscribe:" RTSP command.
int64_t last_rtcp_ntp_time
int stale
Auth ok, but needs to be resent with a new nonce.
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)
Actual data handling.
static int read_header(FFV1Context *f)
int64_t av_gettime(void)
Get the current time in microseconds.
enum RTSPLowerTransport lower_transport
the negotiated network layer transport protocol; e.g.
#define AVIO_FLAG_READ_WRITE
int64_t unwrapped_timestamp
enum RTSPTransport transport
the negotiated data/packet transport protocol; e.g.
static int read_packet(AVFormatContext *ctx, AVPacket *pkt)
int rtsp_flags
Various option flags for the RTSP muxer/demuxer.
Describe the class of an AVClass context structure.
AVInputFormat ff_rtsp_demuxer
struct RTSPState RTSPState
Private data for the RTSP demuxer.
static int rtsp_listen(AVFormatContext *s)
size_t av_strlcatf(char *dst, size_t size, const char *fmt,...)
void ff_rtsp_close_streams(AVFormatContext *s)
Close and free all streams within the RTSP (de)muxer.
This structure contains the data a format has to probe a file.
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...
enum RTSPServerType server_type
brand of server that we're talking to; e.g.
int ffurl_close(URLContext *h)
Close the resource accessed by the URLContext h, and free the memory used by it.
RTSPStatusCode
RTSP handling.
enum RTSPClientState state
indicator of whether we are currently receiving data from the server.
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...
int av_strstart(const char *str, const char *pfx, const char **ptr)
Return non-zero if pfx is a prefix of str.
#define AVERROR_STREAM_NOT_FOUND
static const AVClass rtsp_demuxer_class
initialized, requesting a seek
int ffurl_open(URLContext **puc, const char *filename, int flags, const AVIOInterruptCB *int_cb, AVDictionary **options)
Create an URLContext for accessing to the resource indicated by url, and open it. ...
int need_subscription
The following are used for Real stream selection.
#define AVERROR_INVALIDDATA
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...
#define AVPROBE_SCORE_MAX
static int rtsp_read_seek(AVFormatContext *s, int stream_index, int64_t timestamp, int flags)
initialized, but not receiving data
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...
#define AVERROR_OPTION_NOT_FOUND
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.
TCP; interleaved in RTSP.
HTTPAuthState auth_state
authentication state
#define AVERROR_PROTOCOL_NOT_FOUND
char control_url[1024]
url for this stream (from SDP)
void * priv_data
Format private data.
Method Not Valid in This State.
uint64_t packets
The number of returned packets.
int lower_transport_mask
A mask with all requested transport methods.
static int rtsp_read_announce(AVFormatContext *s)
RTSP Version not supported.
unbuffered private I/O API
uint32_t av_get_random_seed(void)
Get random data.
AVRational time_base
This is the fundamental unit of time (in seconds) in terms of which frame timestamps are represented...
enum AVDiscard discard
Selects which packets can be discarded at will and do not need to be demuxed.
int interleaved_min
interleave IDs; copies of RTSPTransportField->interleaved_min/max for the selected transport...
This structure stores compressed data.
void ff_rtsp_close_connections(AVFormatContext *s)
Close all connection handles within the RTSP (de)muxer.
void * av_mallocz(size_t size)
Allocate a block of size bytes with alignment suitable for all memory accesses (including vectors if ...
URLContext * rtp_handle
RTP stream handle (if UDP)
void * transport_priv
RTP/RDT parse context if input, RTP AVFormatContext if output.
int client_port_min
UDP client ports; these should be the local ports of the UDP RTP (and RTCP) sockets over which we rec...
int initial_pause
Do not begin to play the stream immediately.
if(!(ptr_align%ac->ptr_align)&&samples_align >=aligned_len)