2002-07-04 13:41:34 +03:00
/*
2002-11-18 19:24:39 +02:00
* RTSP / SDP client
2009-01-19 17:46:40 +02:00
* Copyright ( c ) 2002 Fabrice Bellard
2002-07-04 13:41:34 +03:00
*
2006-10-07 18:30:46 +03:00
* This file is part of FFmpeg .
*
* FFmpeg is free software ; you can redistribute it and / or
2002-07-04 13:41:34 +03:00
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation ; either
2006-10-07 18:30:46 +03:00
* version 2.1 of the License , or ( at your option ) any later version .
2002-07-04 13:41:34 +03:00
*
2006-10-07 18:30:46 +03:00
* FFmpeg is distributed in the hope that it will be useful ,
2002-07-04 13:41:34 +03:00
* but WITHOUT ANY WARRANTY ; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE . See the GNU
* Lesser General Public License for more details .
*
* You should have received a copy of the GNU Lesser General Public
2006-10-07 18:30:46 +03:00
* License along with FFmpeg ; if not , write to the Free Software
2006-01-13 00:43:26 +02:00
* Foundation , Inc . , 51 Franklin Street , Fifth Floor , Boston , MA 02110 - 1301 USA
2002-07-04 13:41:34 +03:00
*/
2008-05-09 14:56:36 +03:00
2009-09-18 00:47:11 +03:00
# include "libavutil/base64.h"
2008-05-09 14:56:36 +03:00
# include "libavutil/avstring.h"
2009-01-12 00:19:48 +02:00
# include "libavutil/intreadwrite.h"
2011-06-04 14:58:23 +03:00
# include "libavutil/mathematics.h"
2011-02-16 10:52:37 +02:00
# include "libavutil/parseutils.h"
2010-06-08 15:40:34 +03:00
# include "libavutil/random_seed.h"
2011-05-22 13:46:29 +03:00
# include "libavutil/dict.h"
2010-06-20 23:58:22 +03:00
# include "libavutil/opt.h"
2002-07-04 13:41:34 +03:00
# include "avformat.h"
2011-02-20 12:04:13 +02:00
# include "avio_internal.h"
2002-07-04 13:41:34 +03:00
2011-01-28 04:12:21 +02:00
# if HAVE_POLL_H
# include <poll.h>
2008-09-26 05:12:37 +03:00
# endif
2010-03-15 01:59:48 +02:00
# include "internal.h"
2007-02-04 19:05:44 +02:00
# include "network.h"
2010-03-10 09:44:51 +02:00
# include "os_support.h"
2010-06-08 15:40:34 +03:00
# include "http.h"
2007-10-29 11:15:35 +02:00
# include "rtsp.h"
2002-07-04 13:41:34 +03:00
2009-02-06 12:35:52 +02:00
# include "rtpdec.h"
2008-09-03 07:44:58 +03:00
# include "rdt.h"
2010-07-30 15:04:27 +03:00
# include "rtpdec_formats.h"
2010-10-08 11:54:53 +03:00
# include "rtpenc_chain.h"
2011-03-31 17:04:59 +03:00
# include "url.h"
2011-06-24 02:04:54 +03:00
# include "rtpenc.h"
2006-10-26 21:36:03 +03:00
2002-07-04 13:41:34 +03:00
//#define DEBUG
2011-01-28 04:12:21 +02:00
/* Timeout values for socket poll, in ms,
2010-03-29 20:36:08 +03:00
* and read_packet ( ) , in seconds */
2011-01-28 04:12:21 +02:00
# define POLL_TIMEOUT_MS 100
2010-03-29 20:36:08 +03:00
# define READ_PACKET_TIMEOUT_S 10
2011-01-28 04:12:21 +02:00
# define MAX_TIMEOUTS READ_PACKET_TIMEOUT_S * 1000 / POLL_TIMEOUT_MS
2010-08-07 14:16:07 +03:00
# define SDP_MAX_SIZE 16384
2010-10-01 20:41:31 +03:00
# define RECVBUF_SIZE 10 * RTP_MAX_PACKET_LENGTH
2012-03-19 21:40:23 +03:00
# define DEFAULT_REORDERING_DELAY 100000
2010-03-29 20:36:08 +03:00
2011-10-13 14:00:06 +03:00
# define OFFSET(x) offsetof(RTSPState, x)
# define DEC AV_OPT_FLAG_DECODING_PARAM
2011-06-24 01:49:09 +03:00
# define ENC AV_OPT_FLAG_ENCODING_PARAM
2011-10-17 20:04:41 +03:00
# define RTSP_FLAG_OPTS(name, longname) \
{ name , longname , OFFSET ( rtsp_flags ) , AV_OPT_TYPE_FLAGS , { 0 } , INT_MIN , INT_MAX , DEC , " rtsp_flags " } , \
2012-07-10 20:36:11 +03:00
{ " filter_src " , " Only receive packets from the negotiated peer IP " , 0 , AV_OPT_TYPE_CONST , { RTSP_FLAG_FILTER_SRC } , 0 , 0 , DEC , " rtsp_flags " } , \
{ " listen " , " Wait for incoming connections " , 0 , AV_OPT_TYPE_CONST , { RTSP_FLAG_LISTEN } , 0 , 0 , DEC , " rtsp_flags " }
2011-10-17 20:04:41 +03:00
2011-10-30 00:41:24 +03:00
# define RTSP_MEDIATYPE_OPTS(name, longname) \
{ name , longname , OFFSET ( media_type_mask ) , AV_OPT_TYPE_FLAGS , { ( 1 < < ( AVMEDIA_TYPE_DATA + 1 ) ) - 1 } , INT_MIN , INT_MAX , DEC , " allowed_media_types " } , \
{ " video " , " Video " , 0 , AV_OPT_TYPE_CONST , { 1 < < AVMEDIA_TYPE_VIDEO } , 0 , 0 , DEC , " allowed_media_types " } , \
{ " audio " , " Audio " , 0 , AV_OPT_TYPE_CONST , { 1 < < AVMEDIA_TYPE_AUDIO } , 0 , 0 , DEC , " allowed_media_types " } , \
{ " data " , " Data " , 0 , AV_OPT_TYPE_CONST , { 1 < < AVMEDIA_TYPE_DATA } , 0 , 0 , DEC , " allowed_media_types " }
2011-06-24 02:04:54 +03:00
const AVOption ff_rtsp_options [ ] = {
2011-10-13 14:00:06 +03:00
{ " initial_pause " , " Don't start playing the stream immediately " , OFFSET ( initial_pause ) , AV_OPT_TYPE_INT , { 0 } , 0 , 1 , DEC } ,
2012-02-23 12:38:24 +03:00
FF_RTP_FLAG_OPTS ( RTSPState , rtp_muxer_flags )
2011-06-24 01:49:09 +03:00
{ " rtsp_transport " , " RTSP transport protocols " , OFFSET ( lower_transport_mask ) , AV_OPT_TYPE_FLAGS , { 0 } , INT_MIN , INT_MAX , DEC | ENC , " rtsp_transport " } , \
{ " udp " , " UDP " , 0 , AV_OPT_TYPE_CONST , { 1 < < RTSP_LOWER_TRANSPORT_UDP } , 0 , 0 , DEC | ENC , " rtsp_transport " } , \
{ " tcp " , " TCP " , 0 , AV_OPT_TYPE_CONST , { 1 < < RTSP_LOWER_TRANSPORT_TCP } , 0 , 0 , DEC | ENC , " rtsp_transport " } , \
{ " udp_multicast " , " UDP multicast " , 0 , AV_OPT_TYPE_CONST , { 1 < < RTSP_LOWER_TRANSPORT_UDP_MULTICAST } , 0 , 0 , DEC , " rtsp_transport " } ,
{ " http " , " HTTP tunneling " , 0 , AV_OPT_TYPE_CONST , { ( 1 < < RTSP_LOWER_TRANSPORT_HTTP ) } , 0 , 0 , DEC , " rtsp_transport " } ,
2011-10-17 20:04:41 +03:00
RTSP_FLAG_OPTS ( " rtsp_flags " , " RTSP flags " ) ,
2011-10-30 00:41:24 +03:00
RTSP_MEDIATYPE_OPTS ( " allowed_media_types " , " Media types to accept from the server " ) ,
2012-01-22 00:28:11 +03:00
{ " min_port " , " Minimum local UDP port " , OFFSET ( rtp_port_min ) , AV_OPT_TYPE_INT , { RTSP_RTP_PORT_MIN } , 0 , 65535 , DEC | ENC } ,
{ " max_port " , " Maximum local UDP port " , OFFSET ( rtp_port_max ) , AV_OPT_TYPE_INT , { RTSP_RTP_PORT_MAX } , 0 , 65535 , DEC | ENC } ,
2012-07-10 20:36:11 +03:00
{ " timeout " , " Maximum timeout (in seconds) to wait for incoming connections. -1 is infinite. Implies flag listen " , OFFSET ( initial_timeout ) , AV_OPT_TYPE_INT , { - 1 } , INT_MIN , INT_MAX , DEC } ,
2011-06-24 02:04:54 +03:00
{ NULL } ,
} ;
2011-10-17 20:07:56 +03:00
static const AVOption sdp_options [ ] = {
RTSP_FLAG_OPTS ( " sdp_flags " , " SDP flags " ) ,
2011-10-30 00:41:24 +03:00
RTSP_MEDIATYPE_OPTS ( " allowed_media_types " , " Media types to accept from the server " ) ,
2011-10-17 20:07:56 +03:00
{ NULL } ,
} ;
static const AVOption rtp_options [ ] = {
RTSP_FLAG_OPTS ( " rtp_flags " , " RTP flags " ) ,
{ NULL } ,
} ;
2009-03-21 22:54:47 +02:00
static void get_word_until_chars ( char * buf , int buf_size ,
const char * sep , const char * * pp )
2002-07-04 13:41:34 +03:00
{
const char * p ;
char * q ;
p = * pp ;
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2002-07-04 13:41:34 +03:00
q = buf ;
while ( ! strchr ( sep , * p ) & & * p ! = ' \0 ' ) {
if ( ( q - buf ) < buf_size - 1 )
* q + + = * p ;
p + + ;
}
if ( buf_size > 0 )
* q = ' \0 ' ;
* pp = p ;
}
2009-03-21 22:54:47 +02:00
static void get_word_sep ( char * buf , int buf_size , const char * sep ,
const char * * pp )
2002-07-04 13:41:34 +03:00
{
2009-03-21 22:54:47 +02:00
if ( * * pp = = ' / ' ) ( * pp ) + + ;
get_word_until_chars ( buf , buf_size , sep , pp ) ;
}
2002-07-04 13:41:34 +03:00
2009-03-21 22:54:47 +02:00
static void get_word ( char * buf , int buf_size , const char * * pp )
{
get_word_until_chars ( buf , buf_size , SPACE_CHARS , pp ) ;
2002-07-04 13:41:34 +03:00
}
2010-10-21 15:13:02 +03:00
/** Parse a string p in the form of Range:npt=xx-xx, and determine the start
* and end time .
* Used for seeking in the rtp stream .
*/
static void rtsp_parse_range_npt ( const char * p , int64_t * start , int64_t * end )
{
char buf [ 256 ] ;
p + = strspn ( p , SPACE_CHARS ) ;
if ( ! av_stristart ( p , " npt= " , & p ) )
return ;
* start = AV_NOPTS_VALUE ;
* end = AV_NOPTS_VALUE ;
get_word_sep ( buf , sizeof ( buf ) , " - " , & p ) ;
2011-02-16 10:52:37 +02:00
av_parse_time ( start , buf , 1 ) ;
2010-10-21 15:13:02 +03:00
if ( * p = = ' - ' ) {
p + + ;
get_word_sep ( buf , sizeof ( buf ) , " - " , & p ) ;
2011-02-16 10:52:37 +02:00
av_parse_time ( end , buf , 1 ) ;
2010-10-21 15:13:02 +03:00
}
// av_log(NULL, AV_LOG_DEBUG, "Range Start: %lld\n", *start);
// av_log(NULL, AV_LOG_DEBUG, "Range End: %lld\n", *end);
}
static int get_sockaddr ( const char * buf , struct sockaddr_storage * sock )
{
2011-06-06 15:13:02 +03:00
struct addrinfo hints = { 0 } , * ai = NULL ;
2010-10-21 15:13:02 +03:00
hints . ai_flags = AI_NUMERICHOST ;
if ( getaddrinfo ( buf , NULL , & hints , & ai ) )
return - 1 ;
memcpy ( sock , ai - > ai_addr , FFMIN ( sizeof ( * sock ) , ai - > ai_addrlen ) ) ;
freeaddrinfo ( ai ) ;
return 0 ;
}
2010-10-21 15:18:48 +03:00
# if CONFIG_RTPDEC
2010-12-05 21:41:09 +02:00
static void init_rtp_handler ( RTPDynamicProtocolHandler * handler ,
RTSPStream * rtsp_st , AVCodecContext * codec )
{
if ( ! handler )
return ;
codec - > codec_id = handler - > codec_id ;
rtsp_st - > dynamic_handler = handler ;
2011-11-07 00:50:39 +03:00
if ( handler - > alloc ) {
2011-04-20 15:36:37 +03:00
rtsp_st - > dynamic_protocol_context = handler - > alloc ( ) ;
2011-11-07 00:50:39 +03:00
if ( ! rtsp_st - > dynamic_protocol_context )
rtsp_st - > dynamic_handler = NULL ;
}
2010-12-05 21:41:09 +02:00
}
2010-01-08 00:41:14 +02:00
/* parse the rtpmap description: <codec_name>/<clock_rate>[/<other params>] */
2010-01-08 00:44:03 +02:00
static int sdp_parse_rtpmap ( AVFormatContext * s ,
2010-12-07 15:29:44 +02:00
AVStream * st , RTSPStream * rtsp_st ,
2010-01-08 00:41:14 +02:00
int payload_type , const char * p )
2002-11-18 19:24:39 +02:00
{
2010-12-07 15:29:44 +02:00
AVCodecContext * codec = st - > codec ;
2002-11-18 19:24:39 +02:00
char buf [ 256 ] ;
2005-05-26 10:47:51 +03:00
int i ;
AVCodec * c ;
2006-06-18 14:33:14 +03:00
const char * c_name ;
2002-11-18 19:24:39 +02:00
2005-05-26 10:47:51 +03:00
/* Loop into AVRtpDynamicPayloadTypes[] and AVRtpPayloadTypes[] and
2010-01-13 17:55:42 +02:00
* see if we can handle this kind of payload .
* The space should normally not be there but some Real streams or
* particular servers ( " RealServer Version 6.1.3.970 " , see issue 1658 )
* have a trailing space . */
get_word_sep ( buf , sizeof ( buf ) , " / " , & p ) ;
2011-12-08 16:19:58 +03:00
if ( payload_type < RTP_PT_PRIVATE ) {
/* We are in a standard case
* ( from http : //www.iana.org/assignments/rtp-parameters). */
/* search into AVRtpPayloadTypes[] */
codec - > codec_id = ff_rtp_codec_id ( buf , codec - > codec_type ) ;
}
if ( codec - > codec_id = = CODEC_ID_NONE ) {
2010-12-05 21:41:09 +02:00
RTPDynamicProtocolHandler * handler =
ff_rtp_handler_find_by_name ( buf , codec - > codec_type ) ;
init_rtp_handler ( handler , rtsp_st , codec ) ;
2010-09-15 20:39:25 +03:00
/* If no dynamic handler was found, check with the list of standard
* allocated types , if such a stream for some reason happens to
* use a private payload type . This isn ' t handled in rtpdec . c , since
* the format name from the rtpmap line never is passed into rtpdec . */
if ( ! rtsp_st - > dynamic_handler )
codec - > codec_id = ff_rtp_codec_id ( buf , codec - > codec_type ) ;
2005-05-26 10:47:51 +03:00
}
c = avcodec_find_decoder ( codec - > codec_id ) ;
if ( c & & c - > name )
2006-06-18 14:33:14 +03:00
c_name = c - > name ;
2005-05-26 10:47:51 +03:00
else
2010-02-10 20:30:55 +02:00
c_name = " (null) " ;
2005-05-26 10:47:51 +03:00
2010-02-10 20:31:47 +02:00
get_word_sep ( buf , sizeof ( buf ) , " / " , & p ) ;
i = atoi ( buf ) ;
switch ( codec - > codec_type ) {
2010-03-31 02:30:55 +03:00
case AVMEDIA_TYPE_AUDIO :
2010-02-10 20:31:47 +02:00
av_log ( s , AV_LOG_DEBUG , " audio codec set to: %s \n " , c_name ) ;
codec - > sample_rate = RTSP_DEFAULT_AUDIO_SAMPLERATE ;
codec - > channels = RTSP_DEFAULT_NB_AUDIO_CHANNELS ;
if ( i > 0 ) {
codec - > sample_rate = i ;
2011-11-29 21:28:15 +03:00
avpriv_set_pts_info ( st , 32 , 1 , codec - > sample_rate ) ;
2010-02-10 20:31:47 +02:00
get_word_sep ( buf , sizeof ( buf ) , " / " , & p ) ;
i = atoi ( buf ) ;
if ( i > 0 )
codec - > channels = i ;
// TODO: there is a bug here; if it is a mono stream, and
// less than 22000Hz, faad upconverts to stereo and twice
// the frequency. No problem, but the sample rate is being
// set here by the sdp line. Patch on its way. (rdm)
2005-05-26 10:47:51 +03:00
}
2010-02-10 20:31:47 +02:00
av_log ( s , AV_LOG_DEBUG , " audio samplerate set to: %i \n " ,
codec - > sample_rate ) ;
av_log ( s , AV_LOG_DEBUG , " audio channels set to: %i \n " ,
codec - > channels ) ;
break ;
2010-03-31 02:30:55 +03:00
case AVMEDIA_TYPE_VIDEO :
2010-02-10 20:31:47 +02:00
av_log ( s , AV_LOG_DEBUG , " video codec set to: %s \n " , c_name ) ;
2010-12-07 15:29:44 +02:00
if ( i > 0 )
2011-11-29 21:28:15 +03:00
avpriv_set_pts_info ( st , 32 , 1 , i ) ;
2010-02-10 20:31:47 +02:00
break ;
default :
break ;
}
2011-11-29 17:51:26 +03:00
if ( rtsp_st - > dynamic_handler & & rtsp_st - > dynamic_handler - > init )
rtsp_st - > dynamic_handler - > init ( s , st - > index ,
rtsp_st - > dynamic_protocol_context ) ;
2010-02-10 20:31:47 +02:00
return 0 ;
2002-11-18 19:24:39 +02:00
}
2010-03-29 22:17:49 +03:00
/* parse the attribute line from the fmtp a line of an sdp response. This
2010-01-08 00:41:14 +02:00
* is broken out as a function because it is used in rtp_h264 . c , which is
* forthcoming . */
2010-02-23 02:35:50 +02:00
int ff_rtsp_next_attr_and_value ( const char * * p , char * attr , int attr_size ,
2010-02-23 13:05:36 +02:00
char * value , int value_size )
2006-10-29 12:58:51 +02:00
{
2010-06-25 10:56:45 +03:00
* p + = strspn ( * p , SPACE_CHARS ) ;
2010-01-08 00:41:14 +02:00
if ( * * p ) {
2006-10-29 12:58:51 +02:00
get_word_sep ( attr , attr_size , " = " , p ) ;
if ( * * p = = ' = ' )
( * p ) + + ;
get_word_sep ( value , value_size , " ; " , p ) ;
if ( * * p = = ' ; ' )
( * p ) + + ;
return 1 ;
}
return 0 ;
}
2002-11-18 19:24:39 +02:00
typedef struct SDPParseState {
/* SDP only */
2010-08-25 18:32:00 +03:00
struct sockaddr_storage default_ip ;
2010-01-08 00:41:14 +02:00
int default_ttl ;
int skip_media ; ///< set if an unknown m= line occurs
2002-11-18 19:24:39 +02:00
} SDPParseState ;
static void sdp_parse_line ( AVFormatContext * s , SDPParseState * s1 ,
2002-07-04 13:41:34 +03:00
int letter , const char * buf )
{
2003-10-29 16:25:27 +02:00
RTSPState * rt = s - > priv_data ;
2002-07-04 13:41:34 +03:00
char buf1 [ 64 ] , st_type [ 64 ] ;
const char * p ;
2010-03-31 02:30:55 +03:00
enum AVMediaType codec_type ;
2008-10-02 19:03:00 +03:00
int payload_type , i ;
2002-07-04 13:41:34 +03:00
AVStream * st ;
RTSPStream * rtsp_st ;
2010-08-25 18:32:00 +03:00
struct sockaddr_storage sdp_ip ;
2002-11-18 19:24:39 +02:00
int ttl ;
2011-01-29 18:46:18 +02:00
av_dlog ( s , " sdp: %c='%s' \n " , letter , buf ) ;
2002-07-04 13:41:34 +03:00
p = buf ;
2009-01-24 06:56:18 +02:00
if ( s1 - > skip_media & & letter ! = ' m ' )
return ;
2010-01-08 00:41:14 +02:00
switch ( letter ) {
2002-11-18 19:24:39 +02:00
case ' c ' :
get_word ( buf1 , sizeof ( buf1 ) , & p ) ;
if ( strcmp ( buf1 , " IN " ) ! = 0 )
return ;
get_word ( buf1 , sizeof ( buf1 ) , & p ) ;
2010-08-25 18:32:00 +03:00
if ( strcmp ( buf1 , " IP4 " ) & & strcmp ( buf1 , " IP6 " ) )
2002-11-18 19:24:39 +02:00
return ;
get_word_sep ( buf1 , sizeof ( buf1 ) , " / " , & p ) ;
2010-08-25 18:32:00 +03:00
if ( get_sockaddr ( buf1 , & sdp_ip ) )
2002-11-18 19:24:39 +02:00
return ;
ttl = 16 ;
if ( * p = = ' / ' ) {
p + + ;
get_word_sep ( buf1 , sizeof ( buf1 ) , " / " , & p ) ;
ttl = atoi ( buf1 ) ;
}
if ( s - > nb_streams = = 0 ) {
s1 - > default_ip = sdp_ip ;
s1 - > default_ttl = ttl ;
} else {
2011-02-02 11:08:01 +02:00
rtsp_st = rt - > rtsp_streams [ rt - > nb_rtsp_streams - 1 ] ;
2002-11-18 19:24:39 +02:00
rtsp_st - > sdp_ip = sdp_ip ;
rtsp_st - > sdp_ttl = ttl ;
}
break ;
2002-07-04 13:41:34 +03:00
case ' s ' :
2011-05-22 13:46:29 +03:00
av_dict_set ( & s - > metadata , " title " , p , 0 ) ;
2002-07-04 13:41:34 +03:00
break ;
case ' i ' :
if ( s - > nb_streams = = 0 ) {
2011-05-22 13:46:29 +03:00
av_dict_set ( & s - > metadata , " comment " , p , 0 ) ;
2002-07-04 13:41:34 +03:00
break ;
}
break ;
case ' m ' :
/* new stream */
2009-01-24 06:56:18 +02:00
s1 - > skip_media = 0 ;
2011-10-30 00:41:24 +03:00
codec_type = AVMEDIA_TYPE_UNKNOWN ;
2002-07-04 13:41:34 +03:00
get_word ( st_type , sizeof ( st_type ) , & p ) ;
if ( ! strcmp ( st_type , " audio " ) ) {
2010-03-31 02:30:55 +03:00
codec_type = AVMEDIA_TYPE_AUDIO ;
2002-07-04 13:41:34 +03:00
} else if ( ! strcmp ( st_type , " video " ) ) {
2010-03-31 02:30:55 +03:00
codec_type = AVMEDIA_TYPE_VIDEO ;
2009-03-03 18:48:56 +02:00
} else if ( ! strcmp ( st_type , " application " ) ) {
2010-03-31 02:30:55 +03:00
codec_type = AVMEDIA_TYPE_DATA ;
2011-10-30 00:41:24 +03:00
}
if ( codec_type = = AVMEDIA_TYPE_UNKNOWN | | ! ( rt - > media_type_mask & ( 1 < < codec_type ) ) ) {
2009-01-24 06:56:18 +02:00
s1 - > skip_media = 1 ;
2002-07-04 13:41:34 +03:00
return ;
}
rtsp_st = av_mallocz ( sizeof ( RTSPStream ) ) ;
if ( ! rtsp_st )
return ;
2003-10-29 16:25:27 +02:00
rtsp_st - > stream_index = - 1 ;
dynarray_add ( & rt - > rtsp_streams , & rt - > nb_rtsp_streams , rtsp_st ) ;
2002-11-18 19:24:39 +02:00
rtsp_st - > sdp_ip = s1 - > default_ip ;
rtsp_st - > sdp_ttl = s1 - > default_ttl ;
get_word ( buf1 , sizeof ( buf1 ) , & p ) ; /* port */
rtsp_st - > sdp_port = atoi ( buf1 ) ;
get_word ( buf1 , sizeof ( buf1 ) , & p ) ; /* protocol (ignored) */
2005-12-17 20:14:38 +02:00
2002-11-18 19:24:39 +02:00
/* XXX: handle list of formats */
get_word ( buf1 , sizeof ( buf1 ) , & p ) ; /* format list */
rtsp_st - > sdp_payload_type = atoi ( buf1 ) ;
2007-11-16 09:59:41 +02:00
if ( ! strcmp ( ff_rtp_enc_name ( rtsp_st - > sdp_payload_type ) , " MP2T " ) ) {
2003-10-29 16:25:27 +02:00
/* no corresponding stream */
2012-04-06 23:07:12 +03:00
} else if ( rt - > server_type = = RTSP_SERVER_WMS & &
codec_type = = AVMEDIA_TYPE_DATA ) {
/* RTX stream, a stream that carries all the other actual
* audio / video streams . Don ' t expose this to the callers . */
2003-10-29 16:25:27 +02:00
} else {
2011-06-18 12:43:24 +03:00
st = avformat_new_stream ( s , NULL ) ;
2003-10-29 16:25:27 +02:00
if ( ! st )
return ;
2011-06-18 12:43:24 +03:00
st - > id = rt - > nb_rtsp_streams - 1 ;
2003-10-29 16:25:27 +02:00
rtsp_st - > stream_index = st - > index ;
2005-07-18 01:24:36 +03:00
st - > codec - > codec_type = codec_type ;
2005-05-26 10:47:51 +03:00
if ( rtsp_st - > sdp_payload_type < RTP_PT_PRIVATE ) {
2010-12-05 21:41:44 +02:00
RTPDynamicProtocolHandler * handler ;
2003-10-29 16:25:27 +02:00
/* if standard payload type, we can find the codec right now */
2009-02-17 10:12:51 +02:00
ff_rtp_get_codec_info ( st - > codec , rtsp_st - > sdp_payload_type ) ;
2010-12-15 23:06:25 +02:00
if ( st - > codec - > codec_type = = AVMEDIA_TYPE_AUDIO & &
st - > codec - > sample_rate > 0 )
2011-11-29 21:28:15 +03:00
avpriv_set_pts_info ( st , 32 , 1 , st - > codec - > sample_rate ) ;
2010-12-05 21:41:44 +02:00
/* Even static payload types may need a custom depacketizer */
handler = ff_rtp_handler_find_by_id (
rtsp_st - > sdp_payload_type , st - > codec - > codec_type ) ;
init_rtp_handler ( handler , rtsp_st , st - > codec ) ;
2011-11-29 17:51:26 +03:00
if ( handler & & handler - > init )
handler - > init ( s , st - > index ,
rtsp_st - > dynamic_protocol_context ) ;
2003-10-29 16:25:27 +02:00
}
}
2002-07-04 13:41:34 +03:00
/* put a default control url */
2010-01-22 18:04:15 +02:00
av_strlcpy ( rtsp_st - > control_url , rt - > control_uri ,
2010-01-08 00:41:14 +02:00
sizeof ( rtsp_st - > control_url ) ) ;
2002-07-04 13:41:34 +03:00
break ;
case ' a ' :
2010-01-22 18:04:15 +02:00
if ( av_strstart ( p , " control: " , & p ) ) {
if ( s - > nb_streams = = 0 ) {
if ( ! strncmp ( p , " rtsp:// " , 7 ) )
av_strlcpy ( rt - > control_uri , p ,
sizeof ( rt - > control_uri ) ) ;
} else {
2010-11-28 23:17:39 +02:00
char proto [ 32 ] ;
/* get the control url */
2011-02-02 11:08:01 +02:00
rtsp_st = rt - > rtsp_streams [ rt - > nb_rtsp_streams - 1 ] ;
2005-12-17 20:14:38 +02:00
2010-11-28 23:17:39 +02:00
/* XXX: may need to add full url resolution */
av_url_split ( proto , sizeof ( proto ) , NULL , 0 , NULL , 0 ,
NULL , NULL , 0 , p ) ;
if ( proto [ 0 ] = = ' \0 ' ) {
/* relative control URL */
if ( rtsp_st - > control_url [ strlen ( rtsp_st - > control_url ) - 1 ] ! = ' / ' )
av_strlcat ( rtsp_st - > control_url , " / " ,
sizeof ( rtsp_st - > control_url ) ) ;
av_strlcat ( rtsp_st - > control_url , p ,
sizeof ( rtsp_st - > control_url ) ) ;
} else
av_strlcpy ( rtsp_st - > control_url , p ,
sizeof ( rtsp_st - > control_url ) ) ;
2010-01-22 18:04:15 +02:00
}
2009-01-10 01:36:17 +02:00
} else if ( av_strstart ( p , " rtpmap: " , & p ) & & s - > nb_streams > 0 ) {
2002-11-18 19:24:39 +02:00
/* NOTE: rtpmap is only supported AFTER the 'm=' tag */
2005-12-17 20:14:38 +02:00
get_word ( buf1 , sizeof ( buf1 ) , & p ) ;
2002-11-18 19:24:39 +02:00
payload_type = atoi ( buf1 ) ;
2011-02-02 11:08:01 +02:00
rtsp_st = rt - > rtsp_streams [ rt - > nb_rtsp_streams - 1 ] ;
2012-04-06 23:07:12 +03:00
if ( rtsp_st - > stream_index > = 0 ) {
st = s - > streams [ rtsp_st - > stream_index ] ;
sdp_parse_rtpmap ( s , st , rtsp_st , payload_type , p ) ;
}
2010-06-25 11:00:05 +03:00
} else if ( av_strstart ( p , " fmtp: " , & p ) | |
av_strstart ( p , " framesize: " , & p ) ) {
2002-11-18 19:24:39 +02:00
/* NOTE: fmtp is only supported AFTER the 'a=rtpmap:xxx' tag */
2006-10-29 12:58:51 +02:00
// let dynamic protocol handlers have a stab at the line.
get_word ( buf1 , sizeof ( buf1 ) , & p ) ;
payload_type = atoi ( buf1 ) ;
2011-02-02 11:08:01 +02:00
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
rtsp_st = rt - > rtsp_streams [ i ] ;
2010-01-08 00:41:14 +02:00
if ( rtsp_st - > sdp_payload_type = = payload_type & &
rtsp_st - > dynamic_handler & &
rtsp_st - > dynamic_handler - > parse_sdp_a_line )
rtsp_st - > dynamic_handler - > parse_sdp_a_line ( s , i ,
rtsp_st - > dynamic_protocol_context , buf ) ;
2006-10-29 12:58:51 +02:00
}
2010-01-08 00:41:14 +02:00
} else if ( av_strstart ( p , " range: " , & p ) ) {
2006-11-06 23:58:43 +02:00
int64_t start , end ;
// this is so that seeking on a streamed file can work.
rtsp_parse_range_npt ( p , & start , & end ) ;
2010-01-08 00:41:14 +02:00
s - > start_time = start ;
/* AV_NOPTS_VALUE means live broadcast (and can't seek) */
s - > duration = ( end = = AV_NOPTS_VALUE ) ?
AV_NOPTS_VALUE : end - start ;
2008-09-30 16:26:20 +03:00
} else if ( av_strstart ( p , " IsRealDataType:integer; " , & p ) ) {
if ( atoi ( p ) = = 1 )
rt - > transport = RTSP_TRANSPORT_RDT ;
2010-12-07 15:28:45 +02:00
} else if ( av_strstart ( p , " SampleRate:integer; " , & p ) & &
s - > nb_streams > 0 ) {
st = s - > streams [ s - > nb_streams - 1 ] ;
st - > codec - > sample_rate = atoi ( p ) ;
2009-03-17 14:34:57 +02:00
} else {
if ( rt - > server_type = = RTSP_SERVER_WMS )
ff_wms_parse_sdp_a_line ( s , p ) ;
if ( s - > nb_streams > 0 ) {
2012-04-06 23:07:12 +03:00
rtsp_st = rt - > rtsp_streams [ rt - > nb_rtsp_streams - 1 ] ;
2009-03-17 14:35:55 +02:00
if ( rt - > server_type = = RTSP_SERVER_REAL )
2012-04-06 23:07:12 +03:00
ff_real_parse_sdp_a_line ( s , rtsp_st - > stream_index , p ) ;
2009-03-17 14:35:55 +02:00
if ( rtsp_st - > dynamic_handler & &
rtsp_st - > dynamic_handler - > parse_sdp_a_line )
2010-01-08 00:41:14 +02:00
rtsp_st - > dynamic_handler - > parse_sdp_a_line ( s ,
2012-04-06 23:07:12 +03:00
rtsp_st - > stream_index ,
2009-03-17 14:35:55 +02:00
rtsp_st - > dynamic_protocol_context , buf ) ;
2009-03-17 14:34:57 +02:00
}
2002-07-04 13:41:34 +03:00
}
break ;
}
}
2010-10-29 11:43:57 +03:00
int ff_sdp_parse ( AVFormatContext * s , const char * content )
2002-07-04 13:41:34 +03:00
{
2011-01-28 04:12:21 +02:00
RTSPState * rt = s - > priv_data ;
2002-07-04 13:41:34 +03:00
const char * p ;
int letter ;
2009-01-10 01:44:52 +02:00
/* Some SDP lines, particularly for Realmedia or ASF RTSP streams,
* contain long SDP lines containing complete ASF Headers ( several
* kB ) or arrays of MDPR ( RM stream descriptor ) headers plus
* " rulebooks " describing their properties . Therefore , the SDP line
2009-04-14 16:22:40 +03:00
* buffer is large .
*
2010-06-14 11:23:59 +03:00
* The Vorbis FMTP line can be up to 16 KB - see xiph_parse_sdp_line
* in rtpdec_xiph . c . */
2009-04-14 16:22:40 +03:00
char buf [ 16384 ] , * q ;
2011-06-06 15:13:02 +03:00
SDPParseState sdp_parse_state = { { 0 } } , * s1 = & sdp_parse_state ;
2005-12-17 20:14:38 +02:00
2002-07-04 13:41:34 +03:00
p = content ;
2010-01-08 00:41:14 +02:00
for ( ; ; ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2002-07-04 13:41:34 +03:00
letter = * p ;
if ( letter = = ' \0 ' )
break ;
p + + ;
if ( * p ! = ' = ' )
goto next_line ;
p + + ;
/* get the content */
q = buf ;
2003-07-15 19:57:35 +03:00
while ( * p ! = ' \n ' & & * p ! = ' \r ' & & * p ! = ' \0 ' ) {
2002-07-04 13:41:34 +03:00
if ( ( q - buf ) < sizeof ( buf ) - 1 )
* q + + = * p ;
p + + ;
}
* q = ' \0 ' ;
2002-11-18 19:24:39 +02:00
sdp_parse_line ( s , s1 , letter , buf ) ;
2002-07-04 13:41:34 +03:00
next_line :
while ( * p ! = ' \n ' & & * p ! = ' \0 ' )
p + + ;
if ( * p = = ' \n ' )
p + + ;
}
2011-01-28 04:12:21 +02:00
rt - > p = av_malloc ( sizeof ( struct pollfd ) * 2 * ( rt - > nb_rtsp_streams + 1 ) ) ;
if ( ! rt - > p ) return AVERROR ( ENOMEM ) ;
2002-07-04 13:41:34 +03:00
return 0 ;
}
2010-10-21 15:18:48 +03:00
# endif /* CONFIG_RTPDEC */
2002-07-04 13:41:34 +03:00
2011-01-24 11:49:02 +02:00
void ff_rtsp_undo_setup ( AVFormatContext * s )
{
RTSPState * rt = s - > priv_data ;
int i ;
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
RTSPStream * rtsp_st = rt - > rtsp_streams [ i ] ;
if ( ! rtsp_st )
continue ;
if ( rtsp_st - > transport_priv ) {
if ( s - > oformat ) {
AVFormatContext * rtpctx = rtsp_st - > transport_priv ;
av_write_trailer ( rtpctx ) ;
if ( rt - > lower_transport = = RTSP_LOWER_TRANSPORT_TCP ) {
uint8_t * ptr ;
2011-03-17 09:16:07 +02:00
avio_close_dyn_buf ( rtpctx - > pb , & ptr ) ;
2011-01-24 11:49:02 +02:00
av_free ( ptr ) ;
} else {
2011-02-21 23:45:20 +02:00
avio_close ( rtpctx - > pb ) ;
2011-01-24 11:49:02 +02:00
}
2011-02-04 12:04:18 +02:00
avformat_free_context ( rtpctx ) ;
2011-01-24 11:49:02 +02:00
} else if ( rt - > transport = = RTSP_TRANSPORT_RDT & & CONFIG_RTPDEC )
ff_rdt_parse_close ( rtsp_st - > transport_priv ) ;
else if ( CONFIG_RTPDEC )
2011-10-12 12:37:42 +03:00
ff_rtp_parse_close ( rtsp_st - > transport_priv ) ;
2011-01-24 11:49:02 +02:00
}
rtsp_st - > transport_priv = NULL ;
if ( rtsp_st - > rtp_handle )
2011-03-31 18:36:06 +03:00
ffurl_close ( rtsp_st - > rtp_handle ) ;
2011-01-24 11:49:02 +02:00
rtsp_st - > rtp_handle = NULL ;
}
}
2009-11-12 12:31:37 +02:00
/* close and free RTSP streams */
2010-02-23 02:35:50 +02:00
void ff_rtsp_close_streams ( AVFormatContext * s )
2009-11-12 12:31:37 +02:00
{
2010-02-20 01:10:19 +02:00
RTSPState * rt = s - > priv_data ;
2009-11-12 12:31:37 +02:00
int i ;
RTSPStream * rtsp_st ;
2011-01-24 11:49:02 +02:00
ff_rtsp_undo_setup ( s ) ;
2010-01-08 00:41:14 +02:00
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
2009-11-12 12:31:37 +02:00
rtsp_st = rt - > rtsp_streams [ i ] ;
if ( rtsp_st ) {
if ( rtsp_st - > dynamic_handler & & rtsp_st - > dynamic_protocol_context )
2011-04-20 15:36:37 +03:00
rtsp_st - > dynamic_handler - > free (
2010-01-08 00:41:14 +02:00
rtsp_st - > dynamic_protocol_context ) ;
2011-02-01 21:09:24 +02:00
av_free ( rtsp_st ) ;
2009-11-12 12:31:37 +02:00
}
}
av_free ( rt - > rtsp_streams ) ;
if ( rt - > asf_ctx ) {
2011-12-11 12:38:28 +03:00
avformat_close_input ( & rt - > asf_ctx ) ;
2009-11-12 12:31:37 +02:00
}
2011-01-28 04:12:21 +02:00
av_free ( rt - > p ) ;
2010-10-01 20:41:31 +03:00
av_free ( rt - > recvbuf ) ;
2009-11-12 12:31:37 +02:00
}
2012-07-10 20:25:04 +03:00
int ff_rtsp_open_transport_ctx ( AVFormatContext * s , RTSPStream * rtsp_st )
2009-11-12 12:31:37 +02:00
{
RTSPState * rt = s - > priv_data ;
AVStream * st = NULL ;
/* open the RTP context */
if ( rtsp_st - > stream_index > = 0 )
st = s - > streams [ rtsp_st - > stream_index ] ;
if ( ! st )
s - > ctx_flags | = AVFMTCTX_NOHEADER ;
2010-10-21 15:18:48 +03:00
if ( s - > oformat & & CONFIG_RTSP_MUXER ) {
2012-05-25 22:26:00 +03:00
int ret = ff_rtp_chain_mux_open ( & rtsp_st - > transport_priv , s , st ,
rtsp_st - > rtp_handle ,
RTSP_TCP_MAX_PACKET_SIZE ) ;
2010-03-29 22:17:49 +03:00
/* Ownership of rtp_handle is passed to the rtp mux context */
2010-02-22 17:46:56 +02:00
rtsp_st - > rtp_handle = NULL ;
2012-05-25 22:26:00 +03:00
if ( ret < 0 )
return ret ;
2010-10-21 15:18:48 +03:00
} else if ( rt - > transport = = RTSP_TRANSPORT_RDT & & CONFIG_RTPDEC )
2009-11-12 12:31:37 +02:00
rtsp_st - > transport_priv = ff_rdt_parse_open ( s , st - > index ,
rtsp_st - > dynamic_protocol_context ,
rtsp_st - > dynamic_handler ) ;
2010-10-21 15:18:48 +03:00
else if ( CONFIG_RTPDEC )
2011-10-12 12:37:42 +03:00
rtsp_st - > transport_priv = ff_rtp_parse_open ( s , st , rtsp_st - > rtp_handle ,
2010-10-01 20:50:24 +03:00
rtsp_st - > sdp_payload_type ,
( rt - > lower_transport = = RTSP_LOWER_TRANSPORT_TCP | | ! s - > max_delay )
? 0 : RTP_REORDER_QUEUE_DEFAULT_SIZE ) ;
2009-11-12 12:31:37 +02:00
if ( ! rtsp_st - > transport_priv ) {
return AVERROR ( ENOMEM ) ;
2010-10-21 15:18:48 +03:00
} else if ( rt - > transport ! = RTSP_TRANSPORT_RDT & & CONFIG_RTPDEC ) {
2010-01-08 00:41:14 +02:00
if ( rtsp_st - > dynamic_handler ) {
2011-10-12 12:37:42 +03:00
ff_rtp_parse_set_dynamic_protocol ( rtsp_st - > transport_priv ,
rtsp_st - > dynamic_protocol_context ,
rtsp_st - > dynamic_handler ) ;
2009-11-12 12:31:37 +02:00
}
}
return 0 ;
}
2010-02-22 23:28:19 +02:00
# if CONFIG_RTSP_DEMUXER || CONFIG_RTSP_MUXER
2002-07-04 13:41:34 +03:00
static void rtsp_parse_range ( int * min_ptr , int * max_ptr , const char * * pp )
{
2012-04-26 01:37:29 +03:00
const char * q ;
char * p ;
2002-07-04 13:41:34 +03:00
int v ;
2012-04-26 01:37:29 +03:00
q = * pp ;
q + = strspn ( q , SPACE_CHARS ) ;
v = strtol ( q , & p , 10 ) ;
2002-07-04 13:41:34 +03:00
if ( * p = = ' - ' ) {
p + + ;
* min_ptr = v ;
2012-04-26 01:37:29 +03:00
v = strtol ( p , & p , 10 ) ;
2002-07-04 13:41:34 +03:00
* max_ptr = v ;
} else {
* min_ptr = v ;
* max_ptr = v ;
}
* pp = p ;
}
/* XXX: only one transport specification is parsed */
2009-02-22 00:26:44 +02:00
static void rtsp_parse_transport ( RTSPMessageHeader * reply , const char * p )
2002-07-04 13:41:34 +03:00
{
char transport_protocol [ 16 ] ;
char profile [ 16 ] ;
char lower_transport [ 16 ] ;
char parameter [ 16 ] ;
RTSPTransportField * th ;
char buf [ 256 ] ;
2005-12-17 20:14:38 +02:00
2002-07-04 13:41:34 +03:00
reply - > nb_transports = 0 ;
2005-12-17 20:14:38 +02:00
2010-01-08 00:41:14 +02:00
for ( ; ; ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2002-07-04 13:41:34 +03:00
if ( * p = = ' \0 ' )
break ;
th = & reply - > transports [ reply - > nb_transports ] ;
2005-12-17 20:14:38 +02:00
get_word_sep ( transport_protocol , sizeof ( transport_protocol ) ,
2002-07-04 13:41:34 +03:00
" / " , & p ) ;
2011-11-02 22:17:25 +03:00
if ( ! av_strcasecmp ( transport_protocol , " rtp " ) ) {
2007-12-28 13:25:25 +02:00
get_word_sep ( profile , sizeof ( profile ) , " /;, " , & p ) ;
lower_transport [ 0 ] = ' \0 ' ;
/* rtp/avp/<protocol> */
if ( * p = = ' / ' ) {
get_word_sep ( lower_transport , sizeof ( lower_transport ) ,
" ;, " , & p ) ;
2008-09-30 16:26:20 +03:00
}
th - > transport = RTSP_TRANSPORT_RTP ;
2011-11-02 22:17:25 +03:00
} else if ( ! av_strcasecmp ( transport_protocol , " x-pn-tng " ) | |
! av_strcasecmp ( transport_protocol , " x-real-rdt " ) ) {
2007-12-28 13:25:25 +02:00
/* x-pn-tng/<protocol> */
2007-12-28 13:23:25 +02:00
get_word_sep ( lower_transport , sizeof ( lower_transport ) , " /;, " , & p ) ;
profile [ 0 ] = ' \0 ' ;
2008-09-30 16:26:20 +03:00
th - > transport = RTSP_TRANSPORT_RDT ;
2002-07-04 13:41:34 +03:00
}
2011-11-02 22:17:25 +03:00
if ( ! av_strcasecmp ( lower_transport , " TCP " ) )
2008-09-30 16:18:41 +03:00
th - > lower_transport = RTSP_LOWER_TRANSPORT_TCP ;
2002-07-04 13:41:34 +03:00
else
2008-09-30 16:18:41 +03:00
th - > lower_transport = RTSP_LOWER_TRANSPORT_UDP ;
2005-12-17 20:14:38 +02:00
2002-07-04 13:41:34 +03:00
if ( * p = = ' ; ' )
p + + ;
/* get each parameter */
while ( * p ! = ' \0 ' & & * p ! = ' , ' ) {
get_word_sep ( parameter , sizeof ( parameter ) , " =;, " , & p ) ;
if ( ! strcmp ( parameter , " port " ) ) {
if ( * p = = ' = ' ) {
p + + ;
rtsp_parse_range ( & th - > port_min , & th - > port_max , & p ) ;
}
} else if ( ! strcmp ( parameter , " client_port " ) ) {
if ( * p = = ' = ' ) {
p + + ;
2005-12-17 20:14:38 +02:00
rtsp_parse_range ( & th - > client_port_min ,
2002-07-04 13:41:34 +03:00
& th - > client_port_max , & p ) ;
}
} else if ( ! strcmp ( parameter , " server_port " ) ) {
if ( * p = = ' = ' ) {
p + + ;
2005-12-17 20:14:38 +02:00
rtsp_parse_range ( & th - > server_port_min ,
2002-07-04 13:41:34 +03:00
& th - > server_port_max , & p ) ;
}
} else if ( ! strcmp ( parameter , " interleaved " ) ) {
if ( * p = = ' = ' ) {
p + + ;
2005-12-17 20:14:38 +02:00
rtsp_parse_range ( & th - > interleaved_min ,
2002-07-04 13:41:34 +03:00
& th - > interleaved_max , & p ) ;
}
} else if ( ! strcmp ( parameter , " multicast " ) ) {
2008-09-30 16:18:41 +03:00
if ( th - > lower_transport = = RTSP_LOWER_TRANSPORT_UDP )
th - > lower_transport = RTSP_LOWER_TRANSPORT_UDP_MULTICAST ;
2002-07-04 13:41:34 +03:00
} else if ( ! strcmp ( parameter , " ttl " ) ) {
if ( * p = = ' = ' ) {
p + + ;
th - > ttl = strtol ( p , ( char * * ) & p , 10 ) ;
}
} else if ( ! strcmp ( parameter , " destination " ) ) {
if ( * p = = ' = ' ) {
p + + ;
get_word_sep ( buf , sizeof ( buf ) , " ;, " , & p ) ;
2010-08-25 18:32:29 +03:00
get_sockaddr ( buf , & th - > destination ) ;
2002-07-04 13:41:34 +03:00
}
2010-09-03 22:25:59 +03:00
} else if ( ! strcmp ( parameter , " source " ) ) {
if ( * p = = ' = ' ) {
p + + ;
get_word_sep ( buf , sizeof ( buf ) , " ;, " , & p ) ;
av_strlcpy ( th - > source , buf , sizeof ( th - > source ) ) ;
}
2012-07-10 20:21:58 +03:00
} else if ( ! strcmp ( parameter , " mode " ) ) {
if ( * p = = ' = ' ) {
p + + ;
get_word_sep ( buf , sizeof ( buf ) , " ;, " , & p ) ;
if ( ! strcmp ( buf , " record " ) | |
! strcmp ( buf , " receive " ) )
th - > mode_record = 1 ;
}
2002-07-04 13:41:34 +03:00
}
2010-09-03 22:25:59 +03:00
2002-07-04 13:41:34 +03:00
while ( * p ! = ' ; ' & & * p ! = ' \0 ' & & * p ! = ' , ' )
p + + ;
if ( * p = = ' ; ' )
p + + ;
}
if ( * p = = ' , ' )
p + + ;
reply - > nb_transports + + ;
}
}
2011-01-05 23:23:42 +02:00
static void handle_rtp_info ( RTSPState * rt , const char * url ,
uint32_t seq , uint32_t rtptime )
{
int i ;
if ( ! rtptime | | ! url [ 0 ] )
return ;
if ( rt - > transport ! = RTSP_TRANSPORT_RTP )
return ;
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
RTSPStream * rtsp_st = rt - > rtsp_streams [ i ] ;
RTPDemuxContext * rtpctx = rtsp_st - > transport_priv ;
if ( ! rtpctx )
continue ;
if ( ! strcmp ( rtsp_st - > control_url , url ) ) {
rtpctx - > base_timestamp = rtptime ;
break ;
}
}
}
static void rtsp_parse_rtp_info ( RTSPState * rt , const char * p )
{
int read = 0 ;
char key [ 20 ] , value [ 1024 ] , url [ 1024 ] = " " ;
uint32_t seq = 0 , rtptime = 0 ;
for ( ; ; ) {
p + = strspn ( p , SPACE_CHARS ) ;
if ( ! * p )
break ;
get_word_sep ( key , sizeof ( key ) , " = " , & p ) ;
if ( * p ! = ' = ' )
break ;
p + + ;
get_word_sep ( value , sizeof ( value ) , " ;, " , & p ) ;
read + + ;
if ( ! strcmp ( key , " url " ) )
av_strlcpy ( url , value , sizeof ( url ) ) ;
else if ( ! strcmp ( key , " seq " ) )
2011-03-26 18:13:36 +02:00
seq = strtoul ( value , NULL , 10 ) ;
2011-01-05 23:23:42 +02:00
else if ( ! strcmp ( key , " rtptime " ) )
2011-03-26 18:13:36 +02:00
rtptime = strtoul ( value , NULL , 10 ) ;
2011-01-05 23:23:42 +02:00
if ( * p = = ' , ' ) {
handle_rtp_info ( rt , url , seq , rtptime ) ;
url [ 0 ] = ' \0 ' ;
seq = rtptime = 0 ;
read = 0 ;
}
if ( * p )
p + + ;
}
if ( read > 0 )
handle_rtp_info ( rt , url , seq , rtptime ) ;
}
2010-03-25 23:48:58 +02:00
void ff_rtsp_parse_line ( RTSPMessageHeader * reply , const char * buf ,
2011-01-02 12:10:12 +02:00
RTSPState * rt , const char * method )
2002-07-04 13:41:34 +03:00
{
const char * p ;
/* NOTE: we do case independent match for broken servers */
p = buf ;
2007-06-24 14:27:12 +03:00
if ( av_stristart ( p , " Session: " , & p ) ) {
2009-04-15 16:04:34 +03:00
int t ;
2002-07-04 13:41:34 +03:00
get_word_sep ( reply - > session_id , sizeof ( reply - > session_id ) , " ; " , & p ) ;
2009-04-15 16:04:34 +03:00
if ( av_stristart ( p , " ;timeout= " , & p ) & &
( t = strtol ( p , NULL , 10 ) ) > 0 ) {
reply - > timeout = t ;
}
2007-06-24 14:27:12 +03:00
} else if ( av_stristart ( p , " Content-Length: " , & p ) ) {
2002-07-04 13:41:34 +03:00
reply - > content_length = strtol ( p , NULL , 10 ) ;
2007-06-24 14:27:12 +03:00
} else if ( av_stristart ( p , " Transport: " , & p ) ) {
2002-07-04 13:41:34 +03:00
rtsp_parse_transport ( reply , p ) ;
2007-06-24 14:27:12 +03:00
} else if ( av_stristart ( p , " CSeq: " , & p ) ) {
2002-07-04 13:41:34 +03:00
reply - > seq = strtol ( p , NULL , 10 ) ;
2007-06-24 14:27:12 +03:00
} else if ( av_stristart ( p , " Range: " , & p ) ) {
2006-11-06 23:58:43 +02:00
rtsp_parse_range_npt ( p , & reply - > range_start , & reply - > range_end ) ;
2008-08-31 20:32:02 +03:00
} else if ( av_stristart ( p , " RealChallenge1: " , & p ) ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2008-08-31 20:32:02 +03:00
av_strlcpy ( reply - > real_challenge , p , sizeof ( reply - > real_challenge ) ) ;
2009-01-07 16:55:47 +02:00
} else if ( av_stristart ( p , " Server: " , & p ) ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2009-01-07 16:55:47 +02:00
av_strlcpy ( reply - > server , p , sizeof ( reply - > server ) ) ;
2009-07-27 17:03:53 +03:00
} else if ( av_stristart ( p , " Notice: " , & p ) | |
av_stristart ( p , " X-Notice: " , & p ) ) {
reply - > notice = strtol ( p , NULL , 10 ) ;
2009-10-25 02:06:31 +02:00
} else if ( av_stristart ( p , " Location: " , & p ) ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2009-10-25 02:06:31 +02:00
av_strlcpy ( reply - > location , p , sizeof ( reply - > location ) ) ;
2011-01-02 12:07:56 +02:00
} else if ( av_stristart ( p , " WWW-Authenticate: " , & p ) & & rt ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2011-01-02 12:07:56 +02:00
ff_http_auth_handle_header ( & rt - > auth_state , " WWW-Authenticate " , p ) ;
} else if ( av_stristart ( p , " Authentication-Info: " , & p ) & & rt ) {
2010-06-25 10:56:45 +03:00
p + = strspn ( p , SPACE_CHARS ) ;
2011-01-02 12:07:56 +02:00
ff_http_auth_handle_header ( & rt - > auth_state , " Authentication-Info " , p ) ;
2011-01-02 12:11:12 +02:00
} else if ( av_stristart ( p , " Content-Base: " , & p ) & & rt ) {
2010-11-15 17:08:53 +02:00
p + = strspn ( p , SPACE_CHARS ) ;
2011-01-02 12:11:12 +02:00
if ( method & & ! strcmp ( method , " DESCRIBE " ) )
av_strlcpy ( rt - > control_uri , p , sizeof ( rt - > control_uri ) ) ;
2011-01-05 23:23:42 +02:00
} else if ( av_stristart ( p , " RTP-Info: " , & p ) & & rt ) {
p + = strspn ( p , SPACE_CHARS ) ;
if ( method & & ! strcmp ( method , " PLAY " ) )
rtsp_parse_rtp_info ( rt , p ) ;
2011-05-09 20:11:16 +03:00
} else if ( av_stristart ( p , " Public: " , & p ) & & rt ) {
if ( strstr ( p , " GET_PARAMETER " ) & &
method & & ! strcmp ( method , " OPTIONS " ) )
rt - > get_parameter_supported = 1 ;
2011-01-02 14:32:18 +02:00
} else if ( av_stristart ( p , " x-Accept-Dynamic-Rate: " , & p ) & & rt ) {
p + = strspn ( p , SPACE_CHARS ) ;
rt - > accept_dynamic_rate = atoi ( p ) ;
2012-05-04 18:50:31 +03:00
} else if ( av_stristart ( p , " Content-Type: " , & p ) ) {
p + = strspn ( p , SPACE_CHARS ) ;
av_strlcpy ( reply - > content_type , p , sizeof ( reply - > content_type ) ) ;
2002-07-04 13:41:34 +03:00
}
}
2003-07-17 13:27:47 +03:00
/* skip a RTP/TCP interleaved packet */
2010-03-15 18:31:15 +02:00
void ff_rtsp_skip_packet ( AVFormatContext * s )
2003-07-17 13:27:47 +03:00
{
RTSPState * rt = s - > priv_data ;
int ret , len , len1 ;
uint8_t buf [ 1024 ] ;
2011-03-31 17:40:31 +03:00
ret = ffurl_read_complete ( rt - > rtsp_hd , buf , 3 ) ;
2003-07-17 13:27:47 +03:00
if ( ret ! = 3 )
return ;
2007-07-06 12:32:34 +03:00
len = AV_RB16 ( buf + 1 ) ;
2009-05-31 07:32:45 +03:00
2011-01-29 18:46:18 +02:00
av_dlog ( s , " skipping RTP packet len=%d \n " , len ) ;
2009-05-31 07:32:45 +03:00
2003-07-17 13:27:47 +03:00
/* skip payload */
while ( len > 0 ) {
len1 = len ;
if ( len1 > sizeof ( buf ) )
len1 = sizeof ( buf ) ;
2011-03-31 17:40:31 +03:00
ret = ffurl_read_complete ( rt - > rtsp_hd , buf , len1 ) ;
2003-07-17 13:27:47 +03:00
if ( ret ! = len1 )
return ;
len - = len1 ;
}
}
2002-07-04 13:41:34 +03:00
2010-02-23 02:35:50 +02:00
int ff_rtsp_read_reply ( AVFormatContext * s , RTSPMessageHeader * reply ,
2010-02-23 13:05:36 +02:00
unsigned char * * content_ptr ,
2011-01-02 12:06:21 +02:00
int return_on_interleaved_data , const char * method )
2002-07-04 13:41:34 +03:00
{
RTSPState * rt = s - > priv_data ;
char buf [ 4096 ] , buf1 [ 1024 ] , * q ;
unsigned char ch ;
const char * p ;
2011-10-12 12:26:45 +03:00
int ret , content_length , line_count = 0 , request = 0 ;
2002-07-04 13:41:34 +03:00
unsigned char * content = NULL ;
2011-10-12 12:26:45 +03:00
start :
line_count = 0 ;
request = 0 ;
content = NULL ;
2009-02-21 16:40:19 +02:00
memset ( reply , 0 , sizeof ( * reply ) ) ;
2002-07-04 13:41:34 +03:00
/* parse reply (XXX: use buffers) */
rt - > last_reply [ 0 ] = ' \0 ' ;
2010-01-08 00:41:14 +02:00
for ( ; ; ) {
2002-07-04 13:41:34 +03:00
q = buf ;
2010-01-08 00:41:14 +02:00
for ( ; ; ) {
2011-03-31 17:40:31 +03:00
ret = ffurl_read_complete ( rt - > rtsp_hd , & ch , 1 ) ;
2011-01-29 18:46:18 +02:00
av_dlog ( s , " ret=%d c=%02x [%c] \n " , ret , ch , ch ) ;
2009-03-21 22:46:36 +02:00
if ( ret ! = 1 )
2010-08-25 16:42:17 +03:00
return AVERROR_EOF ;
2002-07-04 13:41:34 +03:00
if ( ch = = ' \n ' )
break ;
2003-07-17 13:27:47 +03:00
if ( ch = = ' $ ' ) {
/* XXX: only parse it if first char on line ? */
2009-03-21 22:46:36 +02:00
if ( return_on_interleaved_data ) {
return 1 ;
} else
2010-03-15 18:31:15 +02:00
ff_rtsp_skip_packet ( s ) ;
2003-07-17 13:27:47 +03:00
} else if ( ch ! = ' \r ' ) {
2002-07-04 13:41:34 +03:00
if ( ( q - buf ) < sizeof ( buf ) - 1 )
* q + + = ch ;
}
}
* q = ' \0 ' ;
2009-05-31 07:32:45 +03:00
2011-01-29 18:46:18 +02:00
av_dlog ( s , " line='%s' \n " , buf ) ;
2009-05-31 07:32:45 +03:00
2002-07-04 13:41:34 +03:00
/* test if last line */
if ( buf [ 0 ] = = ' \0 ' )
break ;
p = buf ;
if ( line_count = = 0 ) {
/* get reply code */
get_word ( buf1 , sizeof ( buf1 ) , & p ) ;
2011-10-12 12:26:45 +03:00
if ( ! strncmp ( buf1 , " RTSP/ " , 5 ) ) {
get_word ( buf1 , sizeof ( buf1 ) , & p ) ;
reply - > status_code = atoi ( buf1 ) ;
av_strlcpy ( reply - > reason , p , sizeof ( reply - > reason ) ) ;
} else {
av_strlcpy ( reply - > reason , buf1 , sizeof ( reply - > reason ) ) ; // method
get_word ( buf1 , sizeof ( buf1 ) , & p ) ; // object
request = 1 ;
}
2002-07-04 13:41:34 +03:00
} else {
2011-01-02 12:10:12 +02:00
ff_rtsp_parse_line ( reply , p , rt , method ) ;
2007-06-24 02:10:32 +03:00
av_strlcat ( rt - > last_reply , p , sizeof ( rt - > last_reply ) ) ;
av_strlcat ( rt - > last_reply , " \n " , sizeof ( rt - > last_reply ) ) ;
2002-07-04 13:41:34 +03:00
}
line_count + + ;
}
2005-12-17 20:14:38 +02:00
2011-10-12 12:26:45 +03:00
if ( rt - > session_id [ 0 ] = = ' \0 ' & & reply - > session_id [ 0 ] ! = ' \0 ' & & ! request )
2007-06-24 02:10:32 +03:00
av_strlcpy ( rt - > session_id , reply - > session_id , sizeof ( rt - > session_id ) ) ;
2005-12-17 20:14:38 +02:00
2002-07-04 13:41:34 +03:00
content_length = reply - > content_length ;
if ( content_length > 0 ) {
/* leave some room for a trailing '\0' (useful for simple parsing) */
content = av_malloc ( content_length + 1 ) ;
2011-03-31 17:40:31 +03:00
ffurl_read_complete ( rt - > rtsp_hd , content , content_length ) ;
2002-07-04 13:41:34 +03:00
content [ content_length ] = ' \0 ' ;
}
if ( content_ptr )
* content_ptr = content ;
2007-07-16 13:56:40 +03:00
else
av_free ( content ) ;
2009-03-21 22:46:36 +02:00
2011-10-12 12:26:45 +03:00
if ( request ) {
char buf [ 1024 ] ;
char base64buf [ AV_BASE64_SIZE ( sizeof ( buf ) ) ] ;
const char * ptr = buf ;
if ( ! strcmp ( reply - > reason , " OPTIONS " ) ) {
snprintf ( buf , sizeof ( buf ) , " RTSP/1.0 200 OK \r \n " ) ;
if ( reply - > seq )
av_strlcatf ( buf , sizeof ( buf ) , " CSeq: %d \r \n " , reply - > seq ) ;
if ( reply - > session_id [ 0 ] )
av_strlcatf ( buf , sizeof ( buf ) , " Session: %s \r \n " ,
reply - > session_id ) ;
} else {
snprintf ( buf , sizeof ( buf ) , " RTSP/1.0 501 Not Implemented \r \n " ) ;
}
av_strlcat ( buf , " \r \n " , sizeof ( buf ) ) ;
if ( rt - > control_transport = = RTSP_MODE_TUNNEL ) {
av_base64_encode ( base64buf , sizeof ( base64buf ) , buf , strlen ( buf ) ) ;
ptr = base64buf ;
}
ffurl_write ( rt - > rtsp_hd_out , ptr , strlen ( ptr ) ) ;
rt - > last_cmd_time = av_gettime ( ) ;
/* Even if the request from the server had data, it is not the data
* that the caller wants or expects . The memory could also be leaked
* if the actual following reply has content data . */
if ( content_ptr )
av_freep ( content_ptr ) ;
/* If method is set, this is called from ff_rtsp_send_cmd,
* where a reply to exactly this request is awaited . For
2012-03-12 17:07:33 +03:00
* callers from within packet receiving , we just want to
2011-10-12 12:26:45 +03:00
* return to the caller and go back to receiving packets . */
if ( method )
goto start ;
return 0 ;
}
2010-03-25 00:38:48 +02:00
if ( rt - > seq ! = reply - > seq ) {
av_log ( s , AV_LOG_WARNING , " CSeq %d expected, %d received. \n " ,
rt - > seq , reply - > seq ) ;
}
2009-07-27 17:03:53 +03:00
/* EOS */
if ( reply - > notice = = 2101 /* End-of-Stream Reached */ | |
reply - > notice = = 2104 /* Start-of-Stream Reached */ | |
2010-01-08 00:41:14 +02:00
reply - > notice = = 2306 /* Continuous Feed Terminated */ ) {
2009-07-27 17:03:53 +03:00
rt - > state = RTSP_STATE_IDLE ;
2010-01-08 00:41:14 +02:00
} else if ( reply - > notice > = 4400 & & reply - > notice < 5500 ) {
2009-07-27 17:03:53 +03:00
return AVERROR ( EIO ) ; /* data or server error */
2010-01-08 00:41:14 +02:00
} else if ( reply - > notice = = 2401 /* Ticket Expired */ | |
2009-07-27 17:03:53 +03:00
( reply - > notice > = 5500 & & reply - > notice < 5600 ) /* end of term */ )
return AVERROR ( EPERM ) ;
2009-03-21 22:46:36 +02:00
return 0 ;
2002-07-04 13:41:34 +03:00
}
2011-01-25 02:29:38 +02:00
/**
* Send a command to the RTSP server without waiting for the reply .
*
* @ param s RTSP ( de ) muxer context
* @ param method the method for the request
* @ param url the target url for the request
* @ param headers extra header lines to include in the request
* @ param send_content if non - null , the data to send as request body content
* @ param send_content_length the length of the send_content data , or 0 if
* send_content is null
*
* @ return zero if success , nonzero otherwise
*/
static int ff_rtsp_send_cmd_with_content_async ( AVFormatContext * s ,
const char * method , const char * url ,
const char * headers ,
const unsigned char * send_content ,
int send_content_length )
2009-03-04 02:57:37 +02:00
{
RTSPState * rt = s - > priv_data ;
2010-06-08 15:40:34 +03:00
char buf [ 4096 ] , * out_buf ;
char base64buf [ AV_BASE64_SIZE ( sizeof ( buf ) ) ] ;
2009-03-04 02:57:37 +02:00
2010-06-08 15:40:34 +03:00
/* Add in RTSP headers */
out_buf = buf ;
2009-03-04 02:57:37 +02:00
rt - > seq + + ;
2010-03-25 23:46:14 +02:00
snprintf ( buf , sizeof ( buf ) , " %s %s RTSP/1.0 \r \n " , method , url ) ;
if ( headers )
av_strlcat ( buf , headers , sizeof ( buf ) ) ;
2010-03-26 00:04:41 +02:00
av_strlcatf ( buf , sizeof ( buf ) , " CSeq: %d \r \n " , rt - > seq ) ;
2010-03-25 23:46:14 +02:00
if ( rt - > session_id [ 0 ] ! = ' \0 ' & & ( ! headers | |
! strstr ( headers , " \n If-Match: " ) ) ) {
2010-03-26 00:04:41 +02:00
av_strlcatf ( buf , sizeof ( buf ) , " Session: %s \r \n " , rt - > session_id ) ;
2009-03-04 02:57:37 +02:00
}
2010-03-25 23:47:33 +02:00
if ( rt - > auth [ 0 ] ) {
char * str = ff_http_auth_create_response ( & rt - > auth_state ,
rt - > auth , url , method ) ;
if ( str )
av_strlcat ( buf , str , sizeof ( buf ) ) ;
av_free ( str ) ;
}
2010-02-17 21:24:02 +02:00
if ( send_content_length > 0 & & send_content )
av_strlcatf ( buf , sizeof ( buf ) , " Content-Length: %d \r \n " , send_content_length ) ;
2009-03-04 02:57:37 +02:00
av_strlcat ( buf , " \r \n " , sizeof ( buf ) ) ;
2009-05-31 07:32:45 +03:00
2010-06-08 15:40:34 +03:00
/* base64 encode rtsp if tunneling */
if ( rt - > control_transport = = RTSP_MODE_TUNNEL ) {
av_base64_encode ( base64buf , sizeof ( base64buf ) , buf , strlen ( buf ) ) ;
out_buf = base64buf ;
}
2011-01-29 18:46:18 +02:00
av_dlog ( s , " Sending: \n %s-- \n " , buf ) ;
2009-05-31 07:32:45 +03:00
2011-03-31 17:48:01 +03:00
ffurl_write ( rt - > rtsp_hd_out , out_buf , strlen ( out_buf ) ) ;
2010-06-08 15:40:34 +03:00
if ( send_content_length > 0 & & send_content ) {
if ( rt - > control_transport = = RTSP_MODE_TUNNEL ) {
av_log ( s , AV_LOG_ERROR , " tunneling of RTSP requests "
" with content data not supported \n " ) ;
return AVERROR_PATCHWELCOME ;
}
2011-03-31 17:48:01 +03:00
ffurl_write ( rt - > rtsp_hd_out , send_content , send_content_length ) ;
2010-06-08 15:40:34 +03:00
}
2009-04-15 16:04:34 +03:00
rt - > last_cmd_time = av_gettime ( ) ;
2010-06-05 22:45:46 +03:00
return 0 ;
2009-04-15 16:04:34 +03:00
}
2010-06-05 22:45:46 +03:00
int ff_rtsp_send_cmd_async ( AVFormatContext * s , const char * method ,
2010-06-05 22:49:55 +03:00
const char * url , const char * headers )
2010-02-17 21:24:02 +02:00
{
2010-06-05 22:45:46 +03:00
return ff_rtsp_send_cmd_with_content_async ( s , method , url , headers , NULL , 0 ) ;
2010-02-17 21:24:02 +02:00
}
2010-06-05 22:45:46 +03:00
int ff_rtsp_send_cmd ( AVFormatContext * s , const char * method , const char * url ,
2010-06-05 22:49:55 +03:00
const char * headers , RTSPMessageHeader * reply ,
unsigned char * * content_ptr )
2009-04-15 16:04:34 +03:00
{
2010-06-05 22:45:46 +03:00
return ff_rtsp_send_cmd_with_content ( s , method , url , headers , reply ,
2010-06-05 22:49:55 +03:00
content_ptr , NULL , 0 ) ;
2009-03-04 02:57:37 +02:00
}
2010-06-05 22:45:46 +03:00
int ff_rtsp_send_cmd_with_content ( AVFormatContext * s ,
2010-06-05 22:49:55 +03:00
const char * method , const char * url ,
const char * header ,
RTSPMessageHeader * reply ,
unsigned char * * content_ptr ,
const unsigned char * send_content ,
int send_content_length )
2010-02-17 21:24:02 +02:00
{
2010-03-25 23:49:43 +02:00
RTSPState * rt = s - > priv_data ;
HTTPAuthType cur_auth_type ;
2012-03-12 14:59:53 +03:00
int ret , attempts = 0 ;
2010-03-25 23:49:43 +02:00
retry :
cur_auth_type = rt - > auth_state . auth_type ;
2010-06-05 22:45:46 +03:00
if ( ( ret = ff_rtsp_send_cmd_with_content_async ( s , method , url , header ,
2010-06-05 22:49:55 +03:00
send_content ,
send_content_length ) ) )
2010-06-05 22:45:46 +03:00
return ret ;
2010-02-17 21:24:02 +02:00
2011-01-02 12:06:21 +02:00
if ( ( ret = ff_rtsp_read_reply ( s , reply , content_ptr , 0 , method ) ) < 0 )
2010-06-05 22:45:46 +03:00
return ret ;
2012-03-12 14:59:53 +03:00
attempts + + ;
2010-03-25 23:49:43 +02:00
2012-03-12 14:59:53 +03:00
if ( reply - > status_code = = 401 & &
( cur_auth_type = = HTTP_AUTH_NONE | | rt - > auth_state . stale ) & &
rt - > auth_state . auth_type ! = HTTP_AUTH_NONE & & attempts < 2 )
2010-03-25 23:49:43 +02:00
goto retry ;
2010-06-05 22:45:46 +03:00
2010-07-12 13:17:20 +03:00
if ( reply - > status_code > 400 ) {
2010-08-06 13:26:30 +03:00
av_log ( s , AV_LOG_ERROR , " method %s failed: %d%s \n " ,
2010-07-12 13:17:20 +03:00
method ,
2010-08-06 13:26:30 +03:00
reply - > status_code ,
reply - > reason ) ;
2010-07-12 13:17:20 +03:00
av_log ( s , AV_LOG_DEBUG , " %s \n " , rt - > last_reply ) ;
}
2010-06-05 22:45:46 +03:00
return 0 ;
2010-02-17 21:24:02 +02:00
}
2011-01-24 11:49:01 +02:00
int ff_rtsp_make_setup_request ( AVFormatContext * s , const char * host , int port ,
2010-01-08 00:41:14 +02:00
int lower_transport , const char * real_challenge )
2002-07-04 13:41:34 +03:00
{
RTSPState * rt = s - > priv_data ;
2012-01-18 12:46:37 +03:00
int rtx = 0 , j , i , err , interleave = 0 , port_off ;
2002-07-04 13:41:34 +03:00
RTSPStream * rtsp_st ;
2009-02-22 00:26:44 +02:00
RTSPMessageHeader reply1 , * reply = & reply1 ;
2008-03-17 14:16:39 +02:00
char cmd [ 2048 ] ;
2008-09-03 07:44:58 +03:00
const char * trans_pref ;
2008-09-30 16:26:20 +03:00
if ( rt - > transport = = RTSP_TRANSPORT_RDT )
2008-09-03 07:44:58 +03:00
trans_pref = " x-pn-tng " ;
else
trans_pref = " RTP/AVP " ;
2005-12-17 20:14:38 +02:00
2009-04-15 16:04:34 +03:00
/* default timeout: 1 minute */
rt - > timeout = 60 ;
2012-01-18 12:46:37 +03:00
/* Choose a random starting offset within the first half of the
* port range , to allow for a number of ports to try even if the offset
* happens to be at the end of the random range . */
port_off = av_get_random_seed ( ) % ( ( rt - > rtp_port_max - rt - > rtp_port_min ) / 2 ) ;
2012-01-18 12:46:37 +03:00
/* even random offset */
port_off - = port_off & 0x01 ;
2005-05-26 10:47:51 +03:00
2012-01-18 12:46:37 +03:00
for ( j = rt - > rtp_port_min + port_off , i = 0 ; i < rt - > nb_rtsp_streams ; + + i ) {
2002-07-04 13:41:34 +03:00
char transport [ 2048 ] ;
2011-07-03 17:35:10 +03:00
/*
2009-03-03 18:52:35 +02:00
* WMS serves all UDP data over a single connection , the RTX , which
* isn ' t necessarily the first in the SDP but has to be the first
* to be set up , else the second / third SETUP will fail with a 461.
*/
if ( lower_transport = = RTSP_LOWER_TRANSPORT_UDP & &
rt - > server_type = = RTSP_SERVER_WMS ) {
if ( i = = 0 ) {
/* rtx first */
for ( rtx = 0 ; rtx < rt - > nb_rtsp_streams ; rtx + + ) {
int len = strlen ( rt - > rtsp_streams [ rtx ] - > control_url ) ;
if ( len > = 4 & &
2010-01-08 00:41:14 +02:00
! strcmp ( rt - > rtsp_streams [ rtx ] - > control_url + len - 4 ,
" /rtx " ) )
2009-03-03 18:52:35 +02:00
break ;
}
if ( rtx = = rt - > nb_rtsp_streams )
return - 1 ; /* no RTX found */
rtsp_st = rt - > rtsp_streams [ rtx ] ;
} else
rtsp_st = rt - > rtsp_streams [ i > rtx ? i : i - 1 ] ;
} else
2009-03-03 18:53:04 +02:00
rtsp_st = rt - > rtsp_streams [ i ] ;
2002-07-04 13:41:34 +03:00
/* RTP/UDP */
2008-09-30 16:18:41 +03:00
if ( lower_transport = = RTSP_LOWER_TRANSPORT_UDP ) {
2002-07-24 20:40:26 +03:00
char buf [ 256 ] ;
2009-03-03 18:52:35 +02:00
if ( rt - > server_type = = RTSP_SERVER_WMS & & i > 1 ) {
port = reply - > transports [ 0 ] . client_port_min ;
goto have_port ;
}
2002-07-24 20:40:26 +03:00
/* first try in specified port range */
2012-01-22 00:28:11 +03:00
while ( j < = rt - > rtp_port_max ) {
2012-01-18 12:54:16 +03:00
ff_url_join ( buf , sizeof ( buf ) , " rtp " , NULL , host , - 1 ,
" ?localport=%d " , j ) ;
/* we will use two ports per rtp stream (rtp and rtcp) */
j + = 2 ;
if ( ! ffurl_open ( & rtsp_st - > rtp_handle , buf , AVIO_FLAG_READ_WRITE ,
& s - > interrupt_callback , NULL ) )
goto rtp_opened ;
2002-07-04 13:41:34 +03:00
}
2011-01-09 12:47:53 +02:00
av_log ( s , AV_LOG_ERROR , " Unable to open an input RTP port \n " ) ;
err = AVERROR ( EIO ) ;
goto fail ;
2002-07-24 20:40:26 +03:00
rtp_opened :
2011-10-12 12:37:42 +03:00
port = ff_rtp_get_local_rtp_port ( rtsp_st - > rtp_handle ) ;
2009-03-03 18:52:35 +02:00
have_port :
2008-09-03 07:47:44 +03:00
snprintf ( transport , sizeof ( transport ) - 1 ,
2008-09-30 16:20:23 +03:00
" %s/UDP; " , trans_pref ) ;
if ( rt - > server_type ! = RTSP_SERVER_REAL )
av_strlcat ( transport , " unicast; " , sizeof ( transport ) ) ;
av_strlcatf ( transport , sizeof ( transport ) ,
" client_port=%d " , port ) ;
2009-03-03 18:52:35 +02:00
if ( rt - > transport = = RTSP_TRANSPORT_RTP & &
! ( rt - > server_type = = RTSP_SERVER_WMS & & i > 0 ) )
2008-09-03 07:44:58 +03:00
av_strlcatf ( transport , sizeof ( transport ) , " -%d " , port + 1 ) ;
2002-07-04 13:41:34 +03:00
}
/* RTP/TCP */
2008-09-30 16:18:41 +03:00
else if ( lower_transport = = RTSP_LOWER_TRANSPORT_TCP ) {
2011-07-03 17:35:10 +03:00
/* For WMS streams, the application streams are only used for
2009-03-03 18:48:56 +02:00
* UDP . When trying to set it up for TCP streams , the server
* will return an error . Therefore , we skip those streams . */
if ( rt - > server_type = = RTSP_SERVER_WMS & &
2012-04-06 23:07:12 +03:00
( rtsp_st - > stream_index < 0 | |
s - > streams [ rtsp_st - > stream_index ] - > codec - > codec_type = =
AVMEDIA_TYPE_DATA ) )
2009-03-03 18:48:56 +02:00
continue ;
2008-09-03 07:47:44 +03:00
snprintf ( transport , sizeof ( transport ) - 1 ,
2009-02-01 15:37:45 +02:00
" %s/TCP; " , trans_pref ) ;
2011-03-21 14:19:09 +02:00
if ( rt - > transport ! = RTSP_TRANSPORT_RDT )
2009-02-01 15:37:45 +02:00
av_strlcat ( transport , " unicast; " , sizeof ( transport ) ) ;
av_strlcatf ( transport , sizeof ( transport ) ,
" interleaved=%d-%d " ,
interleave , interleave + 1 ) ;
interleave + = 2 ;
2002-07-04 13:41:34 +03:00
}
2008-09-30 16:18:41 +03:00
else if ( lower_transport = = RTSP_LOWER_TRANSPORT_UDP_MULTICAST ) {
2008-09-03 07:47:44 +03:00
snprintf ( transport , sizeof ( transport ) - 1 ,
2008-09-03 07:44:58 +03:00
" %s/UDP;multicast " , trans_pref ) ;
2002-07-04 13:41:34 +03:00
}
2010-02-20 01:11:59 +02:00
if ( s - > oformat ) {
2012-06-18 16:19:33 +03:00
av_strlcat ( transport , " ;mode=record " , sizeof ( transport ) ) ;
2010-02-20 01:11:59 +02:00
} else if ( rt - > server_type = = RTSP_SERVER_REAL | |
2010-02-22 18:11:38 +02:00
rt - > server_type = = RTSP_SERVER_WMS )
2008-09-03 07:44:58 +03:00
av_strlcat ( transport , " ;mode=play " , sizeof ( transport ) ) ;
2005-12-17 20:14:38 +02:00
snprintf ( cmd , sizeof ( cmd ) ,
2003-07-15 19:57:35 +03:00
" Transport: %s \r \n " ,
2010-03-25 23:46:14 +02:00
transport ) ;
2010-12-27 09:51:09 +02:00
if ( rt - > accept_dynamic_rate )
av_strlcat ( cmd , " x-Dynamic-Rate: 0 \r \n " , sizeof ( cmd ) ) ;
2010-10-21 15:18:48 +03:00
if ( i = = 0 & & rt - > server_type = = RTSP_SERVER_REAL & & CONFIG_RTPDEC ) {
2008-09-03 07:44:58 +03:00
char real_res [ 41 ] , real_csum [ 9 ] ;
ff_rdt_calc_response_and_checksum ( real_res , real_csum ,
real_challenge ) ;
av_strlcatf ( cmd , sizeof ( cmd ) ,
" If-Match: %s \r \n "
" RealChallenge2: %s, sd=%s \r \n " ,
rt - > session_id , real_res , real_csum ) ;
}
2010-03-25 23:46:14 +02:00
ff_rtsp_send_cmd ( s , " SETUP " , rtsp_st - > control_url , cmd , reply , NULL ) ;
2008-03-19 16:05:08 +02:00
if ( reply - > status_code = = 461 /* Unsupported protocol */ & & i = = 0 ) {
err = 1 ;
goto fail ;
2008-03-19 16:08:16 +02:00
} else if ( reply - > status_code ! = RTSP_STATUS_OK | |
reply - > nb_transports ! = 1 ) {
2002-07-04 13:41:34 +03:00
err = AVERROR_INVALIDDATA ;
goto fail ;
}
/* XXX: same protocol for all streams is required */
if ( i > 0 ) {
2008-09-30 16:26:20 +03:00
if ( reply - > transports [ 0 ] . lower_transport ! = rt - > lower_transport | |
reply - > transports [ 0 ] . transport ! = rt - > transport ) {
2002-07-04 13:41:34 +03:00
err = AVERROR_INVALIDDATA ;
goto fail ;
}
} else {
2008-09-30 16:18:41 +03:00
rt - > lower_transport = reply - > transports [ 0 ] . lower_transport ;
2008-09-30 16:26:20 +03:00
rt - > transport = reply - > transports [ 0 ] . transport ;
2002-07-04 13:41:34 +03:00
}
2010-12-23 17:05:24 +02:00
/* Fail if the server responded with another lower transport mode
* than what we requested . */
if ( reply - > transports [ 0 ] . lower_transport ! = lower_transport ) {
av_log ( s , AV_LOG_ERROR , " Nonmatching transport in server reply \n " ) ;
err = AVERROR_INVALIDDATA ;
goto fail ;
2002-07-04 13:41:34 +03:00
}
2008-09-30 16:18:41 +03:00
switch ( reply - > transports [ 0 ] . lower_transport ) {
case RTSP_LOWER_TRANSPORT_TCP :
2002-07-04 13:41:34 +03:00
rtsp_st - > interleaved_min = reply - > transports [ 0 ] . interleaved_min ;
rtsp_st - > interleaved_max = reply - > transports [ 0 ] . interleaved_max ;
break ;
2005-12-17 20:14:38 +02:00
2010-01-08 00:41:14 +02:00
case RTSP_LOWER_TRANSPORT_UDP : {
2011-01-06 17:22:58 +02:00
char url [ 1024 ] , options [ 30 ] = " " ;
2010-01-08 00:41:14 +02:00
2011-06-24 01:55:00 +03:00
if ( rt - > rtsp_flags & RTSP_FLAG_FILTER_SRC )
2011-01-06 17:22:58 +02:00
av_strlcpy ( options , " ?connect=1 " , sizeof ( options ) ) ;
2010-09-03 22:25:59 +03:00
/* Use source address if specified */
if ( reply - > transports [ 0 ] . source [ 0 ] ) {
ff_url_join ( url , sizeof ( url ) , " rtp " , NULL ,
reply - > transports [ 0 ] . source ,
2011-06-16 11:04:27 +03:00
reply - > transports [ 0 ] . server_port_min , " %s " , options ) ;
2010-09-03 22:25:59 +03:00
} else {
2010-09-03 22:26:27 +03:00
ff_url_join ( url , sizeof ( url ) , " rtp " , NULL , host ,
2011-06-16 11:04:27 +03:00
reply - > transports [ 0 ] . server_port_min , " %s " , options ) ;
2010-09-03 22:25:59 +03:00
}
2010-01-08 00:41:14 +02:00
if ( ! ( rt - > server_type = = RTSP_SERVER_WMS & & i > 1 ) & &
2011-10-12 12:37:42 +03:00
ff_rtp_set_remote_url ( rtsp_st - > rtp_handle , url ) < 0 ) {
2010-01-08 00:41:14 +02:00
err = AVERROR_INVALIDDATA ;
goto fail ;
2002-07-04 13:41:34 +03:00
}
2010-02-17 00:50:50 +02:00
/* Try to initialize the connection state in a
* potential NAT router by sending dummy packets .
* RTP / RTCP dummy packets are used for RDT , too .
*/
2010-10-21 15:18:48 +03:00
if ( ! ( rt - > server_type = = RTSP_SERVER_WMS & & i > 1 ) & & s - > iformat & &
CONFIG_RTPDEC )
2011-10-12 12:37:42 +03:00
ff_rtp_send_punch_packets ( rtsp_st - > rtp_handle ) ;
2002-07-04 13:41:34 +03:00
break ;
2010-01-08 00:41:14 +02:00
}
case RTSP_LOWER_TRANSPORT_UDP_MULTICAST : {
2012-03-08 16:32:39 +03:00
char url [ 1024 ] , namebuf [ 50 ] , optbuf [ 20 ] = " " ;
2010-08-25 18:32:29 +03:00
struct sockaddr_storage addr ;
2010-01-08 00:41:14 +02:00
int port , ttl ;
2010-08-25 18:32:29 +03:00
if ( reply - > transports [ 0 ] . destination . ss_family ) {
addr = reply - > transports [ 0 ] . destination ;
2010-01-08 00:41:14 +02:00
port = reply - > transports [ 0 ] . port_min ;
ttl = reply - > transports [ 0 ] . ttl ;
} else {
2010-08-25 18:32:29 +03:00
addr = rtsp_st - > sdp_ip ;
2010-01-08 00:41:14 +02:00
port = rtsp_st - > sdp_port ;
ttl = rtsp_st - > sdp_ttl ;
}
2012-03-08 16:32:39 +03:00
if ( ttl > 0 )
snprintf ( optbuf , sizeof ( optbuf ) , " ?ttl=%d " , ttl ) ;
2010-08-25 18:32:29 +03:00
getnameinfo ( ( struct sockaddr * ) & addr , sizeof ( addr ) ,
namebuf , sizeof ( namebuf ) , NULL , 0 , NI_NUMERICHOST ) ;
ff_url_join ( url , sizeof ( url ) , " rtp " , NULL , namebuf ,
2012-03-08 16:32:39 +03:00
port , " %s " , optbuf ) ;
2011-11-06 23:50:44 +03:00
if ( ffurl_open ( & rtsp_st - > rtp_handle , url , AVIO_FLAG_READ_WRITE ,
2011-11-05 12:04:04 +03:00
& s - > interrupt_callback , NULL ) < 0 ) {
2010-01-08 00:41:14 +02:00
err = AVERROR_INVALIDDATA ;
goto fail ;
2002-07-04 13:41:34 +03:00
}
break ;
}
2010-01-08 00:41:14 +02:00
}
2005-05-26 10:47:51 +03:00
2012-07-10 20:25:04 +03:00
if ( ( err = ff_rtsp_open_transport_ctx ( s , rtsp_st ) ) )
2003-10-29 16:25:27 +02:00
goto fail ;
2002-07-04 13:41:34 +03:00
}
2012-04-06 22:35:48 +03:00
if ( rt - > nb_rtsp_streams & & reply - > timeout > 0 )
2009-04-15 16:04:34 +03:00
rt - > timeout = reply - > timeout ;
2008-09-14 16:55:21 +03:00
if ( rt - > server_type = = RTSP_SERVER_REAL )
2008-09-07 04:22:18 +03:00
rt - > need_subscription = 1 ;
2008-03-17 14:16:39 +02:00
return 0 ;
fail :
2011-01-24 11:49:03 +02:00
ff_rtsp_undo_setup ( s ) ;
2008-03-17 14:16:39 +02:00
return err ;
}
2010-06-05 22:41:43 +03:00
void ff_rtsp_close_connections ( AVFormatContext * s )
{
RTSPState * rt = s - > priv_data ;
2011-03-31 18:36:06 +03:00
if ( rt - > rtsp_hd_out ! = rt - > rtsp_hd ) ffurl_close ( rt - > rtsp_hd_out ) ;
ffurl_close ( rt - > rtsp_hd ) ;
2010-06-20 00:46:39 +03:00
rt - > rtsp_hd = rt - > rtsp_hd_out = NULL ;
2010-06-05 22:41:43 +03:00
}
2010-02-23 02:35:50 +02:00
int ff_rtsp_connect ( AVFormatContext * s )
2008-03-17 14:16:39 +02:00
{
RTSPState * rt = s - > priv_data ;
2009-10-24 19:53:06 +03:00
char host [ 1024 ] , path [ 1024 ] , tcpname [ 1024 ] , cmd [ 2048 ] , auth [ 128 ] ;
2010-03-09 16:59:40 +02:00
int port , err , tcp_fd ;
2010-07-21 20:27:28 +03:00
RTSPMessageHeader reply1 = { 0 } , * reply = & reply1 ;
2008-09-30 16:18:41 +03:00
int lower_transport_mask = 0 ;
2011-01-10 12:45:24 +02:00
char real_challenge [ 64 ] = " " ;
2010-03-09 16:59:40 +02:00
struct sockaddr_storage peer ;
socklen_t peer_len = sizeof ( peer ) ;
2010-03-06 00:35:21 +02:00
2012-01-22 00:28:11 +03:00
if ( rt - > rtp_port_max < rt - > rtp_port_min ) {
av_log ( s , AV_LOG_ERROR , " Invalid UDP port range, max port %d less "
" than min port %d \n " , rt - > rtp_port_max ,
rt - > rtp_port_min ) ;
return AVERROR ( EINVAL ) ;
}
2010-03-06 00:35:21 +02:00
if ( ! ff_network_init ( ) )
return AVERROR ( EIO ) ;
2011-06-24 01:49:09 +03:00
2012-03-19 21:37:10 +03:00
if ( s - > max_delay < 0 ) /* Not set by the caller */
2012-03-19 21:40:23 +03:00
s - > max_delay = s - > iformat ? DEFAULT_REORDERING_DELAY : 0 ;
2012-03-19 21:37:10 +03:00
2010-06-08 15:40:34 +03:00
rt - > control_transport = RTSP_MODE_PLAIN ;
2011-06-24 01:49:09 +03:00
if ( rt - > lower_transport_mask & ( 1 < < RTSP_LOWER_TRANSPORT_HTTP ) ) {
rt - > lower_transport_mask = 1 < < RTSP_LOWER_TRANSPORT_TCP ;
rt - > control_transport = RTSP_MODE_TUNNEL ;
}
/* Only pass through valid flags from here */
rt - > lower_transport_mask & = ( 1 < < RTSP_LOWER_TRANSPORT_NB ) - 1 ;
redirect :
lower_transport_mask = rt - > lower_transport_mask ;
2008-03-17 14:16:39 +02:00
/* extract hostname and port */
2010-06-27 17:16:46 +03:00
av_url_split ( NULL , 0 , auth , sizeof ( auth ) ,
2010-03-08 11:05:03 +02:00
host , sizeof ( host ) , & port , path , sizeof ( path ) , s - > filename ) ;
2009-09-18 00:47:11 +03:00
if ( * auth ) {
2010-03-25 23:47:33 +02:00
av_strlcpy ( rt - > auth , auth , sizeof ( rt - > auth ) ) ;
2009-09-18 00:47:11 +03:00
}
2008-03-17 14:16:39 +02:00
if ( port < 0 )
port = RTSP_DEFAULT_PORT ;
2008-09-30 16:18:41 +03:00
if ( ! lower_transport_mask )
2009-02-16 18:27:35 +02:00
lower_transport_mask = ( 1 < < RTSP_LOWER_TRANSPORT_NB ) - 1 ;
2008-03-17 14:16:39 +02:00
2010-02-22 17:56:18 +02:00
if ( s - > oformat ) {
2010-03-22 17:07:05 +02:00
/* Only UDP or TCP - UDP multicast isn't supported. */
lower_transport_mask & = ( 1 < < RTSP_LOWER_TRANSPORT_UDP ) |
( 1 < < RTSP_LOWER_TRANSPORT_TCP ) ;
2010-06-08 15:40:34 +03:00
if ( ! lower_transport_mask | | rt - > control_transport = = RTSP_MODE_TUNNEL ) {
2010-02-22 17:56:18 +02:00
av_log ( s , AV_LOG_ERROR , " Unsupported lower transport method, "
2010-03-22 17:07:05 +02:00
" only UDP and TCP are supported for output. \n " ) ;
2010-02-22 17:56:18 +02:00
err = AVERROR ( EINVAL ) ;
goto fail ;
}
}
2010-03-26 00:21:09 +02:00
/* Construct the URI used in request; this is similar to s->filename,
* but with authentication credentials removed and RTSP specific options
* stripped out . */
ff_url_join ( rt - > control_uri , sizeof ( rt - > control_uri ) , " rtsp " , NULL ,
host , port , " %s " , path ) ;
2010-06-08 15:40:34 +03:00
if ( rt - > control_transport = = RTSP_MODE_TUNNEL ) {
/* set up initial handshake for tunneling */
char httpname [ 1024 ] ;
char sessioncookie [ 17 ] ;
char headers [ 1024 ] ;
2010-06-20 00:57:45 +03:00
ff_url_join ( httpname , sizeof ( httpname ) , " http " , auth , host , port , " %s " , path ) ;
2010-06-08 15:40:34 +03:00
snprintf ( sessioncookie , sizeof ( sessioncookie ) , " %08x%08x " ,
av_get_random_seed ( ) , av_get_random_seed ( ) ) ;
/* GET requests */
2011-11-06 23:50:44 +03:00
if ( ffurl_alloc ( & rt - > rtsp_hd , httpname , AVIO_FLAG_READ ,
& s - > interrupt_callback ) < 0 ) {
2010-06-08 15:40:34 +03:00
err = AVERROR ( EIO ) ;
goto fail ;
}
/* generate GET headers */
snprintf ( headers , sizeof ( headers ) ,
" x-sessioncookie: %s \r \n "
" Accept: application/x-rtsp-tunnelled \r \n "
" Pragma: no-cache \r \n "
" Cache-Control: no-cache \r \n " ,
sessioncookie ) ;
2011-11-07 12:45:57 +03:00
av_opt_set ( rt - > rtsp_hd - > priv_data , " headers " , headers , 0 ) ;
2010-06-08 15:40:34 +03:00
/* complete the connection */
2011-11-05 12:04:04 +03:00
if ( ffurl_connect ( rt - > rtsp_hd , NULL ) ) {
2010-06-08 15:40:34 +03:00
err = AVERROR ( EIO ) ;
goto fail ;
}
/* POST requests */
2011-11-06 23:50:44 +03:00
if ( ffurl_alloc ( & rt - > rtsp_hd_out , httpname , AVIO_FLAG_WRITE ,
& s - > interrupt_callback ) < 0 ) {
2010-06-08 15:40:34 +03:00
err = AVERROR ( EIO ) ;
goto fail ;
}
/* generate POST headers */
snprintf ( headers , sizeof ( headers ) ,
" x-sessioncookie: %s \r \n "
" Content-Type: application/x-rtsp-tunnelled \r \n "
" Pragma: no-cache \r \n "
" Cache-Control: no-cache \r \n "
" Content-Length: 32767 \r \n "
" Expires: Sun, 9 Jan 1972 00:00:00 GMT \r \n " ,
sessioncookie ) ;
2011-11-07 12:45:57 +03:00
av_opt_set ( rt - > rtsp_hd_out - > priv_data , " headers " , headers , 0 ) ;
http: Change the chunksize AVOption into chunked_post
The chunksize internal variable has two different uses - for
reading, it's the amount of data left of the current chunk
(or -1 if the server doesn't send data in chunked mode), where
it's only an internal state variable. For writing, it's used
to decide whether to enable chunked encoding (by default), by
using the value 0, or disable chunked encoding (value -1).
This, while consistent, doesn't make much sense to expose
as an AVOption. This splits the usage of the internal variable
into two variables, chunksize which is used for reading (as
before), and chunked_post which is the user-settable option,
with the values 0 and 1, where 1 is default.
Signed-off-by: Martin Storsjö <martin@martin.st>
2011-11-10 12:03:35 +03:00
av_opt_set ( rt - > rtsp_hd_out - > priv_data , " chunked_post " , " 0 " , 0 ) ;
2010-06-08 15:40:34 +03:00
2010-06-21 22:41:02 +03:00
/* Initialize the authentication state for the POST session. The HTTP
* protocol implementation doesn ' t properly handle multi - pass
* authentication for POST requests , since it would require one of
* the following :
* - implementing Expect : 100 - continue , which many HTTP servers
* don ' t support anyway , even less the RTSP servers that do HTTP
* tunneling
* - sending the whole POST data until getting a 401 reply specifying
* what authentication method to use , then resending all that data
* - waiting for potential 401 replies directly after sending the
* POST header ( waiting for some unspecified time )
* Therefore , we copy the full auth state , which works for both basic
* and digest . ( For digest , we would have to synchronize the nonce
* count variable between the two sessions , if we ' d do more requests
* with the original session , though . )
*/
ff_http_init_auth_state ( rt - > rtsp_hd_out , rt - > rtsp_hd ) ;
2010-06-22 17:15:00 +03:00
/* complete the connection */
2011-11-05 12:04:04 +03:00
if ( ffurl_connect ( rt - > rtsp_hd_out , NULL ) ) {
2010-06-22 17:15:00 +03:00
err = AVERROR ( EIO ) ;
goto fail ;
}
2010-06-08 15:40:34 +03:00
} else {
2010-06-14 12:09:59 +03:00
/* open the tcp connection */
2010-06-14 11:12:40 +03:00
ff_url_join ( tcpname , sizeof ( tcpname ) , " tcp " , NULL , host , port , NULL ) ;
2011-11-06 23:50:44 +03:00
if ( ffurl_open ( & rt - > rtsp_hd , tcpname , AVIO_FLAG_READ_WRITE ,
2011-11-05 12:04:04 +03:00
& s - > interrupt_callback , NULL ) < 0 ) {
2010-06-14 11:12:40 +03:00
err = AVERROR ( EIO ) ;
goto fail ;
}
2010-06-20 00:36:13 +03:00
rt - > rtsp_hd_out = rt - > rtsp_hd ;
2010-06-08 15:40:34 +03:00
}
2008-03-17 14:16:39 +02:00
rt - > seq = 0 ;
2011-03-31 18:51:24 +03:00
tcp_fd = ffurl_get_file_handle ( rt - > rtsp_hd ) ;
2010-03-09 16:59:40 +02:00
if ( ! getpeername ( tcp_fd , ( struct sockaddr * ) & peer , & peer_len ) ) {
getnameinfo ( ( struct sockaddr * ) & peer , peer_len , host , sizeof ( host ) ,
NULL , 0 , NI_NUMERICHOST ) ;
}
2010-01-08 00:41:14 +02:00
/* request options supported by the server; this also detects server
* type */
2008-08-31 20:32:58 +03:00
for ( rt - > server_type = RTSP_SERVER_RTP ; ; ) {
2010-03-25 23:46:14 +02:00
cmd [ 0 ] = 0 ;
2008-09-14 16:55:21 +03:00
if ( rt - > server_type = = RTSP_SERVER_REAL )
2008-08-31 20:32:58 +03:00
av_strlcat ( cmd ,
2011-07-03 17:35:10 +03:00
/*
2008-08-31 20:32:58 +03:00
* The following entries are required for proper
* streaming from a Realmedia server . They are
* interdependent in some way although we currently
* don ' t quite understand how . Values were copied
* from mplayer SVN r23589 .
2011-07-03 17:35:10 +03:00
* ClientChallenge is a 16 - byte ID in hex
* CompanyID is a 16 - byte ID in base64
2008-08-31 20:32:58 +03:00
*/
" ClientChallenge: 9e26d33f2984236010ef6253fb1887f7 \r \n "
" PlayerStarttime: [28/03/2003:22:50:23 00:00] \r \n "
" CompanyID: KnKV4M4I/B2FjJ1TToLycw== \r \n "
" GUID: 00000000-0000-0000-0000-000000000000 \r \n " ,
sizeof ( cmd ) ) ;
2010-03-25 23:46:14 +02:00
ff_rtsp_send_cmd ( s , " OPTIONS " , rt - > control_uri , cmd , reply , NULL ) ;
2008-08-31 20:32:58 +03:00
if ( reply - > status_code ! = RTSP_STATUS_OK ) {
err = AVERROR_INVALIDDATA ;
goto fail ;
}
/* detect server type if not standard-compliant RTP */
2008-09-14 16:55:21 +03:00
if ( rt - > server_type ! = RTSP_SERVER_REAL & & reply - > real_challenge [ 0 ] ) {
rt - > server_type = RTSP_SERVER_REAL ;
2008-08-31 20:32:58 +03:00
continue ;
2011-11-02 22:17:25 +03:00
} else if ( ! av_strncasecmp ( reply - > server , " WMServer/ " , 9 ) ) {
2009-01-07 16:55:47 +02:00
rt - > server_type = RTSP_SERVER_WMS ;
2010-01-08 00:41:14 +02:00
} else if ( rt - > server_type = = RTSP_SERVER_REAL )
2008-08-31 20:32:58 +03:00
strcpy ( real_challenge , reply - > real_challenge ) ;
break ;
}
2010-10-21 15:18:48 +03:00
if ( s - > iformat & & CONFIG_RTSP_DEMUXER )
2010-10-29 11:43:57 +03:00
err = ff_rtsp_setup_input_streams ( s , reply ) ;
2010-10-21 15:18:48 +03:00
else if ( CONFIG_RTSP_MUXER )
2010-10-29 11:41:49 +03:00
err = ff_rtsp_setup_output_streams ( s , host ) ;
2010-02-20 01:21:44 +02:00
if ( err )
2008-03-17 14:16:39 +02:00
goto fail ;
2008-03-19 16:05:08 +02:00
do {
2010-01-08 00:41:14 +02:00
int lower_transport = ff_log2_tab [ lower_transport_mask &
~ ( lower_transport_mask - 1 ) ] ;
2008-03-19 16:05:08 +02:00
2011-01-24 11:49:01 +02:00
err = ff_rtsp_make_setup_request ( s , host , port , lower_transport ,
2008-09-14 16:55:21 +03:00
rt - > server_type = = RTSP_SERVER_REAL ?
2008-09-03 07:44:58 +03:00
real_challenge : NULL ) ;
2008-03-19 16:05:08 +02:00
if ( err < 0 )
2008-03-19 16:08:16 +02:00
goto fail ;
2008-09-30 16:18:41 +03:00
lower_transport_mask & = ~ ( 1 < < lower_transport ) ;
if ( lower_transport_mask = = 0 & & err = = 1 ) {
2011-02-19 20:14:11 +02:00
err = AVERROR ( EPROTONOSUPPORT ) ;
2008-03-19 16:05:08 +02:00
goto fail ;
}
} while ( err ) ;
2008-03-17 14:16:39 +02:00
2011-01-10 12:45:24 +02:00
rt - > lower_transport_mask = lower_transport_mask ;
av_strlcpy ( rt - > real_challenge , real_challenge , sizeof ( rt - > real_challenge ) ) ;
2003-11-10 20:39:26 +02:00
rt - > state = RTSP_STATE_IDLE ;
2010-01-08 00:41:14 +02:00
rt - > seek_timestamp = 0 ; /* default is to start stream at position zero */
2002-07-04 13:41:34 +03:00
return 0 ;
fail :
2010-02-23 02:35:50 +02:00
ff_rtsp_close_streams ( s ) ;
2010-06-05 22:41:43 +03:00
ff_rtsp_close_connections ( s ) ;
2010-02-22 17:57:40 +02:00
if ( reply - > status_code > = 300 & & reply - > status_code < 400 & & s - > iformat ) {
2009-10-25 02:06:31 +02:00
av_strlcpy ( s - > filename , reply - > location , sizeof ( s - > filename ) ) ;
av_log ( s , AV_LOG_INFO , " Status %d: Redirecting to %s \n " ,
reply - > status_code ,
s - > filename ) ;
goto redirect ;
}
2010-03-06 00:35:21 +02:00
ff_network_close ( ) ;
2002-07-04 13:41:34 +03:00
return err ;
}
2010-10-05 14:03:48 +03:00
# endif /* CONFIG_RTSP_DEMUXER || CONFIG_RTSP_MUXER */
2002-07-04 13:41:34 +03:00
2010-10-21 15:18:48 +03:00
# if CONFIG_RTPDEC
2010-01-04 21:55:43 +02:00
static int udp_read_packet ( AVFormatContext * s , RTSPStream * * prtsp_st ,
2010-10-01 20:52:26 +03:00
uint8_t * buf , int buf_size , int64_t wait_end )
2010-01-04 21:55:43 +02:00
{
RTSPState * rt = s - > priv_data ;
RTSPStream * rtsp_st ;
2011-01-28 04:12:21 +02:00
int n , i , ret , tcp_fd , timeout_cnt = 0 ;
int max_p = 0 ;
struct pollfd * p = rt - > p ;
2010-01-04 21:55:43 +02:00
2010-01-08 00:41:14 +02:00
for ( ; ; ) {
2011-11-06 23:34:24 +03:00
if ( ff_check_interrupt ( & s - > interrupt_callback ) )
2011-03-13 01:42:27 +02:00
return AVERROR_EXIT ;
2010-10-01 20:52:26 +03:00
if ( wait_end & & wait_end - av_gettime ( ) < 0 )
return AVERROR ( EAGAIN ) ;
2011-01-28 04:12:21 +02:00
max_p = 0 ;
2010-01-04 21:55:43 +02:00
if ( rt - > rtsp_hd ) {
2011-03-31 18:51:24 +03:00
tcp_fd = ffurl_get_file_handle ( rt - > rtsp_hd ) ;
2011-01-28 04:12:21 +02:00
p [ max_p ] . fd = tcp_fd ;
p [ max_p + + ] . events = POLLIN ;
2010-01-04 21:55:43 +02:00
} else {
tcp_fd = - 1 ;
}
2010-01-08 00:41:14 +02:00
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
2010-01-04 21:55:43 +02:00
rtsp_st = rt - > rtsp_streams [ i ] ;
if ( rtsp_st - > rtp_handle ) {
2011-03-31 18:51:24 +03:00
p [ max_p ] . fd = ffurl_get_file_handle ( rtsp_st - > rtp_handle ) ;
2011-01-28 04:12:21 +02:00
p [ max_p + + ] . events = POLLIN ;
2011-10-12 12:37:42 +03:00
p [ max_p ] . fd = ff_rtp_get_rtcp_file_handle ( rtsp_st - > rtp_handle ) ;
2011-01-28 04:12:21 +02:00
p [ max_p + + ] . events = POLLIN ;
2010-01-04 21:55:43 +02:00
}
}
2011-01-28 04:12:21 +02:00
n = poll ( p , max_p , POLL_TIMEOUT_MS ) ;
2010-01-04 21:55:43 +02:00
if ( n > 0 ) {
2011-01-28 04:12:21 +02:00
int j = 1 - ( tcp_fd = = - 1 ) ;
2010-03-29 20:36:08 +03:00
timeout_cnt = 0 ;
2010-01-08 00:41:14 +02:00
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
2010-01-04 21:55:43 +02:00
rtsp_st = rt - > rtsp_streams [ i ] ;
if ( rtsp_st - > rtp_handle ) {
2011-01-28 04:12:21 +02:00
if ( p [ j ] . revents & POLLIN | | p [ j + 1 ] . revents & POLLIN ) {
2011-03-31 17:31:43 +03:00
ret = ffurl_read ( rtsp_st - > rtp_handle , buf , buf_size ) ;
2010-01-04 21:55:43 +02:00
if ( ret > 0 ) {
* prtsp_st = rtsp_st ;
return ret ;
}
}
2011-01-28 04:12:21 +02:00
j + = 2 ;
2010-01-04 21:55:43 +02:00
}
}
2010-10-05 22:46:25 +03:00
# if CONFIG_RTSP_DEMUXER
2011-01-28 04:12:21 +02:00
if ( tcp_fd ! = - 1 & & p [ 0 ] . revents & POLLIN ) {
2012-07-10 20:36:11 +03:00
if ( rt - > rtsp_flags & RTSP_FLAG_LISTEN ) {
if ( rt - > state = = RTSP_STATE_STREAMING ) {
if ( ! ff_rtsp_parse_streaming_commands ( s ) )
return AVERROR_EOF ;
else
av_log ( s , AV_LOG_WARNING ,
" Unable to answer to TEARDOWN \n " ) ;
} else
return 0 ;
} else {
RTSPMessageHeader reply ;
ret = ff_rtsp_read_reply ( s , & reply , NULL , 0 , NULL ) ;
if ( ret < 0 )
return ret ;
/* XXX: parse message */
if ( rt - > state ! = RTSP_STATE_STREAMING )
return 0 ;
}
2010-01-04 21:55:43 +02:00
}
2010-10-05 22:46:25 +03:00
# endif
2010-03-29 20:36:08 +03:00
} else if ( n = = 0 & & + + timeout_cnt > = MAX_TIMEOUTS ) {
2011-02-19 20:14:11 +02:00
return AVERROR ( ETIMEDOUT ) ;
2010-03-29 20:36:08 +03:00
} else if ( n < 0 & & errno ! = EINTR )
return AVERROR ( errno ) ;
2010-01-04 21:55:43 +02:00
}
}
2010-10-29 11:43:57 +03:00
int ff_rtsp_fetch_packet ( AVFormatContext * s , AVPacket * pkt )
2010-01-04 21:55:43 +02:00
{
RTSPState * rt = s - > priv_data ;
int ret , len ;
2010-10-01 20:52:26 +03:00
RTSPStream * rtsp_st , * first_queue_st = NULL ;
int64_t wait_end = 0 ;
2010-01-04 21:55:43 +02:00
2010-08-29 13:25:16 +03:00
if ( rt - > nb_byes = = rt - > nb_rtsp_streams )
return AVERROR_EOF ;
2010-01-04 21:55:43 +02:00
/* get next frames from the same RTP packet */
if ( rt - > cur_transport_priv ) {
2010-01-08 00:41:14 +02:00
if ( rt - > transport = = RTSP_TRANSPORT_RDT ) {
2010-01-04 21:55:43 +02:00
ret = ff_rdt_parse_packet ( rt - > cur_transport_priv , pkt , NULL , 0 ) ;
2010-01-08 00:41:14 +02:00
} else
2011-10-12 12:37:42 +03:00
ret = ff_rtp_parse_packet ( rt - > cur_transport_priv , pkt , NULL , 0 ) ;
2010-01-04 21:55:43 +02:00
if ( ret = = 0 ) {
rt - > cur_transport_priv = NULL ;
return 0 ;
} else if ( ret = = 1 ) {
return 0 ;
2010-01-08 00:41:14 +02:00
} else
2010-01-04 21:55:43 +02:00
rt - > cur_transport_priv = NULL ;
}
2010-10-01 20:52:26 +03:00
if ( rt - > transport = = RTSP_TRANSPORT_RTP ) {
int i ;
int64_t first_queue_time = 0 ;
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
RTPDemuxContext * rtpctx = rt - > rtsp_streams [ i ] - > transport_priv ;
2010-12-27 11:56:19 +02:00
int64_t queue_time ;
if ( ! rtpctx )
continue ;
queue_time = ff_rtp_queued_packet_time ( rtpctx ) ;
2010-10-01 20:52:26 +03:00
if ( queue_time & & ( queue_time - first_queue_time < 0 | |
! first_queue_time ) ) {
first_queue_time = queue_time ;
first_queue_st = rt - > rtsp_streams [ i ] ;
}
}
if ( first_queue_time )
wait_end = first_queue_time + s - > max_delay ;
}
2010-01-04 21:55:43 +02:00
/* read next RTP packet */
redo :
2010-10-01 20:41:31 +03:00
if ( ! rt - > recvbuf ) {
rt - > recvbuf = av_malloc ( RECVBUF_SIZE ) ;
if ( ! rt - > recvbuf )
return AVERROR ( ENOMEM ) ;
}
2010-01-04 21:55:43 +02:00
switch ( rt - > lower_transport ) {
default :
2010-10-05 22:46:25 +03:00
# if CONFIG_RTSP_DEMUXER
2010-01-04 21:55:43 +02:00
case RTSP_LOWER_TRANSPORT_TCP :
2010-10-29 11:43:57 +03:00
len = ff_rtsp_tcp_read_packet ( s , & rtsp_st , rt - > recvbuf , RECVBUF_SIZE ) ;
2010-01-04 21:55:43 +02:00
break ;
2010-10-05 22:46:25 +03:00
# endif
2010-01-04 21:55:43 +02:00
case RTSP_LOWER_TRANSPORT_UDP :
case RTSP_LOWER_TRANSPORT_UDP_MULTICAST :
2010-10-01 20:52:26 +03:00
len = udp_read_packet ( s , & rtsp_st , rt - > recvbuf , RECVBUF_SIZE , wait_end ) ;
2011-02-16 14:35:47 +02:00
if ( len > 0 & & rtsp_st - > transport_priv & & rt - > transport = = RTSP_TRANSPORT_RTP )
2011-10-12 12:37:42 +03:00
ff_rtp_check_and_send_back_rr ( rtsp_st - > transport_priv , len ) ;
2010-01-04 21:55:43 +02:00
break ;
}
2010-10-01 20:52:26 +03:00
if ( len = = AVERROR ( EAGAIN ) & & first_queue_st & &
rt - > transport = = RTSP_TRANSPORT_RTP ) {
rtsp_st = first_queue_st ;
2011-10-12 12:37:42 +03:00
ret = ff_rtp_parse_packet ( rtsp_st - > transport_priv , pkt , NULL , 0 ) ;
2010-10-01 20:52:26 +03:00
goto end ;
}
2010-01-04 21:55:43 +02:00
if ( len < 0 )
return len ;
if ( len = = 0 )
return AVERROR_EOF ;
2010-01-08 00:41:14 +02:00
if ( rt - > transport = = RTSP_TRANSPORT_RDT ) {
2010-10-01 20:43:27 +03:00
ret = ff_rdt_parse_packet ( rtsp_st - > transport_priv , pkt , & rt - > recvbuf , len ) ;
2010-04-20 10:34:28 +03:00
} else {
2011-10-12 12:37:42 +03:00
ret = ff_rtp_parse_packet ( rtsp_st - > transport_priv , pkt , & rt - > recvbuf , len ) ;
2010-04-20 10:34:28 +03:00
if ( ret < 0 ) {
/* Either bad packet, or a RTCP packet. Check if the
* first_rtcp_ntp_time field was initialized . */
RTPDemuxContext * rtpctx = rtsp_st - > transport_priv ;
if ( rtpctx - > first_rtcp_ntp_time ! = AV_NOPTS_VALUE ) {
/* first_rtcp_ntp_time has been initialized for this stream,
* copy the same value to all other uninitialized streams ,
* in order to map their timestamp origin to the same ntp time
* as this one . */
int i ;
2011-01-02 00:27:16 +02:00
AVStream * st = NULL ;
if ( rtsp_st - > stream_index > = 0 )
st = s - > streams [ rtsp_st - > stream_index ] ;
2010-04-20 10:34:28 +03:00
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
2010-09-03 10:10:21 +03:00
RTPDemuxContext * rtpctx2 = rt - > rtsp_streams [ i ] - > transport_priv ;
2011-01-02 00:27:16 +02:00
AVStream * st2 = NULL ;
if ( rt - > rtsp_streams [ i ] - > stream_index > = 0 )
st2 = s - > streams [ rt - > rtsp_streams [ i ] - > stream_index ] ;
if ( rtpctx2 & & st & & st2 & &
rtpctx2 - > first_rtcp_ntp_time = = AV_NOPTS_VALUE ) {
2010-04-20 10:34:28 +03:00
rtpctx2 - > first_rtcp_ntp_time = rtpctx - > first_rtcp_ntp_time ;
2011-01-02 00:27:16 +02:00
rtpctx2 - > rtcp_ts_offset = av_rescale_q (
rtpctx - > rtcp_ts_offset , st - > time_base ,
st2 - > time_base ) ;
}
2010-04-20 10:34:28 +03:00
}
}
2010-08-29 13:25:16 +03:00
if ( ret = = - RTCP_BYE ) {
rt - > nb_byes + + ;
av_log ( s , AV_LOG_DEBUG , " Received BYE for stream %d (%d/%d) \n " ,
rtsp_st - > stream_index , rt - > nb_byes , rt - > nb_rtsp_streams ) ;
if ( rt - > nb_byes = = rt - > nb_rtsp_streams )
return AVERROR_EOF ;
}
2010-04-20 10:34:28 +03:00
}
}
2010-10-01 20:52:26 +03:00
end :
2010-01-04 21:55:43 +02:00
if ( ret < 0 )
goto redo ;
2010-01-08 00:41:14 +02:00
if ( ret = = 1 )
2010-01-04 21:55:43 +02:00
/* more packets may follow, so we save the RTP context */
rt - > cur_transport_priv = rtsp_st - > transport_priv ;
return ret ;
}
2010-10-21 15:18:48 +03:00
# endif /* CONFIG_RTPDEC */
2010-01-04 21:55:43 +02:00
2010-10-21 15:18:48 +03:00
# if CONFIG_SDP_DEMUXER
2002-11-20 16:54:13 +02:00
static int sdp_probe ( AVProbeData * p1 )
2002-11-18 19:24:39 +02:00
{
2005-03-16 21:06:34 +02:00
const char * p = p1 - > buf , * p_end = p1 - > buf + p1 - > buf_size ;
2002-11-20 16:54:13 +02:00
2010-08-25 18:32:00 +03:00
/* we look for a line beginning "c=IN IP" */
2005-03-16 21:06:34 +02:00
while ( p < p_end & & * p ! = ' \0 ' ) {
2010-08-25 18:32:00 +03:00
if ( p + sizeof ( " c=IN IP " ) - 1 < p_end & &
av_strstart ( p , " c=IN IP " , NULL ) )
2002-11-20 16:54:13 +02:00
return AVPROBE_SCORE_MAX / 2 ;
2005-03-16 21:06:34 +02:00
2010-01-08 00:41:14 +02:00
while ( p < p_end - 1 & & * p ! = ' \n ' ) p + + ;
2005-03-16 21:06:34 +02:00
if ( + + p > = p_end )
2002-11-20 16:54:13 +02:00
break ;
if ( * p = = ' \r ' )
p + + ;
}
2002-11-18 19:24:39 +02:00
return 0 ;
}
2012-01-12 15:20:36 +03:00
static int sdp_read_header ( AVFormatContext * s )
2002-11-18 19:24:39 +02:00
{
2003-10-29 16:25:27 +02:00
RTSPState * rt = s - > priv_data ;
2002-11-18 19:24:39 +02:00
RTSPStream * rtsp_st ;
int size , i , err ;
char * content ;
char url [ 1024 ] ;
2010-03-06 00:35:21 +02:00
if ( ! ff_network_init ( ) )
return AVERROR ( EIO ) ;
2012-03-19 21:37:10 +03:00
if ( s - > max_delay < 0 ) /* Not set by the caller */
2012-03-19 21:40:23 +03:00
s - > max_delay = DEFAULT_REORDERING_DELAY ;
2012-03-19 21:37:10 +03:00
2002-11-18 19:24:39 +02:00
/* read the whole sdp file */
/* XXX: better loading */
content = av_malloc ( SDP_MAX_SIZE ) ;
2011-02-21 17:43:01 +02:00
size = avio_read ( s - > pb , content , SDP_MAX_SIZE - 1 ) ;
2002-11-18 19:24:39 +02:00
if ( size < = 0 ) {
av_free ( content ) ;
return AVERROR_INVALIDDATA ;
}
content [ size ] = ' \0 ' ;
2011-01-28 04:12:22 +02:00
err = ff_sdp_parse ( s , content ) ;
2002-11-18 19:24:39 +02:00
av_free ( content ) ;
2011-01-28 04:12:22 +02:00
if ( err ) goto fail ;
2002-11-18 19:24:39 +02:00
/* open each RTP stream */
2010-01-08 00:41:14 +02:00
for ( i = 0 ; i < rt - > nb_rtsp_streams ; i + + ) {
2010-08-25 18:32:00 +03:00
char namebuf [ 50 ] ;
2003-10-29 16:25:27 +02:00
rtsp_st = rt - > rtsp_streams [ i ] ;
2005-12-17 20:14:38 +02:00
2010-08-25 18:32:00 +03:00
getnameinfo ( ( struct sockaddr * ) & rtsp_st - > sdp_ip , sizeof ( rtsp_st - > sdp_ip ) ,
namebuf , sizeof ( namebuf ) , NULL , 0 , NI_NUMERICHOST ) ;
2010-03-06 00:35:21 +02:00
ff_url_join ( url , sizeof ( url ) , " rtp " , NULL ,
2010-08-25 18:32:00 +03:00
namebuf , rtsp_st - > sdp_port ,
2011-10-17 20:07:56 +03:00
" ?localport=%d&ttl=%d&connect=%d " , rtsp_st - > sdp_port ,
rtsp_st - > sdp_ttl ,
rt - > rtsp_flags & RTSP_FLAG_FILTER_SRC ? 1 : 0 ) ;
2011-11-06 23:50:44 +03:00
if ( ffurl_open ( & rtsp_st - > rtp_handle , url , AVIO_FLAG_READ_WRITE ,
2011-11-05 12:04:04 +03:00
& s - > interrupt_callback , NULL ) < 0 ) {
2002-11-18 19:24:39 +02:00
err = AVERROR_INVALIDDATA ;
goto fail ;
}
2012-07-10 20:25:04 +03:00
if ( ( err = ff_rtsp_open_transport_ctx ( s , rtsp_st ) ) )
2003-10-29 16:25:27 +02:00
goto fail ;
2002-11-18 19:24:39 +02:00
}
return 0 ;
2010-01-08 00:41:14 +02:00
fail :
2010-02-23 02:35:50 +02:00
ff_rtsp_close_streams ( s ) ;
2010-03-06 00:35:21 +02:00
ff_network_close ( ) ;
2002-11-18 19:24:39 +02:00
return err ;
}
static int sdp_read_close ( AVFormatContext * s )
{
2010-02-23 02:35:50 +02:00
ff_rtsp_close_streams ( s ) ;
2010-03-06 00:35:21 +02:00
ff_network_close ( ) ;
2002-11-18 19:24:39 +02:00
return 0 ;
}
2011-10-17 20:07:56 +03:00
static const AVClass sdp_demuxer_class = {
. class_name = " SDP demuxer " ,
. item_name = av_default_item_name ,
. option = sdp_options ,
. version = LIBAVUTIL_VERSION_INT ,
} ;
2011-01-26 00:03:28 +02:00
AVInputFormat ff_sdp_demuxer = {
2011-07-16 23:18:12 +03:00
. name = " sdp " ,
. long_name = NULL_IF_CONFIG_SMALL ( " SDP " ) ,
. priv_data_size = sizeof ( RTSPState ) ,
. read_probe = sdp_probe ,
. read_header = sdp_read_header ,
. read_packet = ff_rtsp_fetch_packet ,
. read_close = sdp_read_close ,
2012-03-19 13:17:47 +03:00
. priv_class = & sdp_demuxer_class ,
2002-11-18 19:24:39 +02:00
} ;
2010-10-21 15:18:48 +03:00
# endif /* CONFIG_SDP_DEMUXER */
2010-10-19 10:38:53 +03:00
2010-10-21 15:18:48 +03:00
# if CONFIG_RTP_DEMUXER
2010-10-19 10:38:53 +03:00
static int rtp_probe ( AVProbeData * p )
{
if ( av_strstart ( p - > filename , " rtp: " , NULL ) )
return AVPROBE_SCORE_MAX ;
return 0 ;
}
2012-01-12 15:20:36 +03:00
static int rtp_read_header ( AVFormatContext * s )
2010-10-19 10:38:53 +03:00
{
uint8_t recvbuf [ 1500 ] ;
char host [ 500 ] , sdp [ 500 ] ;
int ret , port ;
URLContext * in = NULL ;
int payload_type ;
2011-06-06 15:13:02 +03:00
AVCodecContext codec = { 0 } ;
2010-10-19 10:38:53 +03:00
struct sockaddr_storage addr ;
2011-02-20 12:04:12 +02:00
AVIOContext pb ;
2010-10-19 10:38:53 +03:00
socklen_t addrlen = sizeof ( addr ) ;
2011-12-02 12:06:18 +03:00
RTSPState * rt = s - > priv_data ;
2010-10-19 10:38:53 +03:00
if ( ! ff_network_init ( ) )
return AVERROR ( EIO ) ;
2011-11-06 23:50:44 +03:00
ret = ffurl_open ( & in , s - > filename , AVIO_FLAG_READ ,
2011-11-05 12:04:04 +03:00
& s - > interrupt_callback , NULL ) ;
2010-10-19 10:38:53 +03:00
if ( ret )
goto fail ;
while ( 1 ) {
2011-03-31 17:31:43 +03:00
ret = ffurl_read ( in , recvbuf , sizeof ( recvbuf ) ) ;
2010-10-19 10:38:53 +03:00
if ( ret = = AVERROR ( EAGAIN ) )
continue ;
if ( ret < 0 )
goto fail ;
if ( ret < 12 ) {
av_log ( s , AV_LOG_WARNING , " Received too short packet \n " ) ;
continue ;
}
if ( ( recvbuf [ 0 ] & 0xc0 ) ! = 0x80 ) {
av_log ( s , AV_LOG_WARNING , " Unsupported RTP version packet "
" received \n " ) ;
continue ;
}
2012-02-16 19:31:03 +03:00
if ( RTP_PT_IS_RTCP ( recvbuf [ 1 ] ) )
2012-02-13 18:05:43 +03:00
continue ;
2010-10-19 10:38:53 +03:00
payload_type = recvbuf [ 1 ] & 0x7f ;
break ;
}
2011-03-31 18:51:24 +03:00
getsockname ( ffurl_get_file_handle ( in ) , ( struct sockaddr * ) & addr , & addrlen ) ;
2011-03-31 18:36:06 +03:00
ffurl_close ( in ) ;
2010-10-19 10:38:53 +03:00
in = NULL ;
if ( ff_rtp_get_codec_info ( & codec , payload_type ) ) {
av_log ( s , AV_LOG_ERROR , " Unable to receive RTP payload type %d "
" without an SDP file describing it \n " ,
payload_type ) ;
goto fail ;
}
if ( codec . codec_type ! = AVMEDIA_TYPE_DATA ) {
av_log ( s , AV_LOG_WARNING , " Guessing on RTP content - if not received "
" properly you need an SDP file "
" describing it \n " ) ;
}
av_url_split ( NULL , 0 , NULL , 0 , host , sizeof ( host ) , & port ,
NULL , 0 , s - > filename ) ;
snprintf ( sdp , sizeof ( sdp ) ,
" v=0 \r \n c=IN IP%d %s \r \n m=%s %d RTP/AVP %d \r \n " ,
addr . ss_family = = AF_INET ? 4 : 6 , host ,
codec . codec_type = = AVMEDIA_TYPE_DATA ? " application " :
codec . codec_type = = AVMEDIA_TYPE_VIDEO ? " video " : " audio " ,
port , payload_type ) ;
av_log ( s , AV_LOG_VERBOSE , " SDP: \n %s \n " , sdp ) ;
2011-02-20 12:04:13 +02:00
ffio_init_context ( & pb , sdp , strlen ( sdp ) , 0 , NULL , NULL , NULL , NULL ) ;
2010-10-19 10:38:53 +03:00
s - > pb = & pb ;
/* sdp_read_header initializes this again */
ff_network_close ( ) ;
2011-12-02 12:06:18 +03:00
rt - > media_type_mask = ( 1 < < ( AVMEDIA_TYPE_DATA + 1 ) ) - 1 ;
2012-01-12 15:20:36 +03:00
ret = sdp_read_header ( s ) ;
2010-10-19 10:38:53 +03:00
s - > pb = NULL ;
return ret ;
fail :
if ( in )
2011-03-31 18:36:06 +03:00
ffurl_close ( in ) ;
2010-10-19 10:38:53 +03:00
ff_network_close ( ) ;
return ret ;
}
2011-10-17 20:07:56 +03:00
static const AVClass rtp_demuxer_class = {
. class_name = " RTP demuxer " ,
. item_name = av_default_item_name ,
. option = rtp_options ,
. version = LIBAVUTIL_VERSION_INT ,
} ;
2011-01-26 00:03:28 +02:00
AVInputFormat ff_rtp_demuxer = {
2011-07-16 23:18:12 +03:00
. name = " rtp " ,
. long_name = NULL_IF_CONFIG_SMALL ( " RTP input format " ) ,
. priv_data_size = sizeof ( RTSPState ) ,
. read_probe = rtp_probe ,
. read_header = rtp_read_header ,
. read_packet = ff_rtsp_fetch_packet ,
. read_close = sdp_read_close ,
2012-03-19 13:17:47 +03:00
. flags = AVFMT_NOFILE ,
. priv_class = & rtp_demuxer_class ,
2010-10-19 10:38:53 +03:00
} ;
2010-10-21 15:18:48 +03:00
# endif /* CONFIG_RTP_DEMUXER */