mirror of
https://github.com/FFmpeg/FFmpeg.git
synced 2025-01-08 13:22:53 +02:00
Make rtp protocol obey rfc3550
Originally committed as revision 22906 to svn://svn.ffmpeg.org/ffmpeg/trunk
This commit is contained in:
parent
3748b2b8e8
commit
9094d867aa
@ -67,8 +67,12 @@ void rtp_parse_set_dynamic_protocol(RTPDemuxContext *s, PayloadContext *ctx,
|
|||||||
int rtp_parse_packet(RTPDemuxContext *s, AVPacket *pkt,
|
int rtp_parse_packet(RTPDemuxContext *s, AVPacket *pkt,
|
||||||
const uint8_t *buf, int len);
|
const uint8_t *buf, int len);
|
||||||
void rtp_parse_close(RTPDemuxContext *s);
|
void rtp_parse_close(RTPDemuxContext *s);
|
||||||
|
#if (LIBAVFORMAT_VERSION_MAJOR <= 53)
|
||||||
int rtp_get_local_port(URLContext *h);
|
int rtp_get_local_port(URLContext *h);
|
||||||
|
#endif
|
||||||
|
int rtp_get_local_rtp_port(URLContext *h);
|
||||||
|
int rtp_get_local_rtcp_port(URLContext *h);
|
||||||
|
|
||||||
int rtp_set_remote_url(URLContext *h, const char *uri);
|
int rtp_set_remote_url(URLContext *h, const char *uri);
|
||||||
#if (LIBAVFORMAT_VERSION_MAJOR <= 52)
|
#if (LIBAVFORMAT_VERSION_MAJOR <= 52)
|
||||||
void rtp_get_file_handles(URLContext *h, int *prtp_fd, int *prtcp_fd);
|
void rtp_get_file_handles(URLContext *h, int *prtp_fd, int *prtcp_fd);
|
||||||
|
@ -114,16 +114,26 @@ static void build_udp_url(char *buf, int buf_size,
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* url syntax: rtp://host:port[?option=val...]
|
* url syntax: rtp://host:port[?option=val...]
|
||||||
* option: 'ttl=n' : set the ttl value (for multicast only)
|
* option: 'ttl=n' : set the ttl value (for multicast only)
|
||||||
* 'localport=n' : set the local port to n
|
* 'rtcpport=n' : set the remote rtcp port to n
|
||||||
* 'pkt_size=n' : set max packet size
|
* 'localrtpport=n' : set the local rtp port to n
|
||||||
|
* 'localrtcpport=n' : set the local rtcp port to n
|
||||||
|
* 'pkt_size=n' : set max packet size
|
||||||
|
* deprecated option:
|
||||||
|
* 'localport=n' : set the local port to n
|
||||||
*
|
*
|
||||||
|
* if rtcpport isn't set the rtcp port will be the rtp port + 1
|
||||||
|
* if local rtp port isn't set any available port will be used for the local
|
||||||
|
* rtp and rtcp ports
|
||||||
|
* if the local rtcp port is not set it will be the local rtp port + 1
|
||||||
*/
|
*/
|
||||||
|
|
||||||
static int rtp_open(URLContext *h, const char *uri, int flags)
|
static int rtp_open(URLContext *h, const char *uri, int flags)
|
||||||
{
|
{
|
||||||
RTPContext *s;
|
RTPContext *s;
|
||||||
int port, is_output, ttl, local_port, max_packet_size;
|
int rtp_port, rtcp_port,
|
||||||
|
is_output, ttl,
|
||||||
|
local_rtp_port, local_rtcp_port, max_packet_size;
|
||||||
char hostname[256];
|
char hostname[256];
|
||||||
char buf[1024];
|
char buf[1024];
|
||||||
char path[1024];
|
char path[1024];
|
||||||
@ -136,11 +146,13 @@ static int rtp_open(URLContext *h, const char *uri, int flags)
|
|||||||
return AVERROR(ENOMEM);
|
return AVERROR(ENOMEM);
|
||||||
h->priv_data = s;
|
h->priv_data = s;
|
||||||
|
|
||||||
ff_url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &port,
|
ff_url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &rtp_port,
|
||||||
path, sizeof(path), uri);
|
path, sizeof(path), uri);
|
||||||
/* extract parameters */
|
/* extract parameters */
|
||||||
ttl = -1;
|
ttl = -1;
|
||||||
local_port = -1;
|
rtcp_port = rtp_port+1;
|
||||||
|
local_rtp_port = -1;
|
||||||
|
local_rtcp_port = -1;
|
||||||
max_packet_size = -1;
|
max_packet_size = -1;
|
||||||
|
|
||||||
p = strchr(uri, '?');
|
p = strchr(uri, '?');
|
||||||
@ -148,8 +160,17 @@ static int rtp_open(URLContext *h, const char *uri, int flags)
|
|||||||
if (find_info_tag(buf, sizeof(buf), "ttl", p)) {
|
if (find_info_tag(buf, sizeof(buf), "ttl", p)) {
|
||||||
ttl = strtol(buf, NULL, 10);
|
ttl = strtol(buf, NULL, 10);
|
||||||
}
|
}
|
||||||
|
if (find_info_tag(buf, sizeof(buf), "rtcpport", p)) {
|
||||||
|
rtcp_port = strtol(buf, NULL, 10);
|
||||||
|
}
|
||||||
if (find_info_tag(buf, sizeof(buf), "localport", p)) {
|
if (find_info_tag(buf, sizeof(buf), "localport", p)) {
|
||||||
local_port = strtol(buf, NULL, 10);
|
local_rtp_port = strtol(buf, NULL, 10);
|
||||||
|
}
|
||||||
|
if (find_info_tag(buf, sizeof(buf), "localrtpport", p)) {
|
||||||
|
local_rtp_port = strtol(buf, NULL, 10);
|
||||||
|
}
|
||||||
|
if (find_info_tag(buf, sizeof(buf), "localrtcpport", p)) {
|
||||||
|
local_rtcp_port = strtol(buf, NULL, 10);
|
||||||
}
|
}
|
||||||
if (find_info_tag(buf, sizeof(buf), "pkt_size", p)) {
|
if (find_info_tag(buf, sizeof(buf), "pkt_size", p)) {
|
||||||
max_packet_size = strtol(buf, NULL, 10);
|
max_packet_size = strtol(buf, NULL, 10);
|
||||||
@ -157,16 +178,14 @@ static int rtp_open(URLContext *h, const char *uri, int flags)
|
|||||||
}
|
}
|
||||||
|
|
||||||
build_udp_url(buf, sizeof(buf),
|
build_udp_url(buf, sizeof(buf),
|
||||||
hostname, port, local_port, ttl, max_packet_size);
|
hostname, rtp_port, local_rtp_port, ttl, max_packet_size);
|
||||||
if (url_open(&s->rtp_hd, buf, flags) < 0)
|
if (url_open(&s->rtp_hd, buf, flags) < 0)
|
||||||
goto fail;
|
goto fail;
|
||||||
local_port = udp_get_local_port(s->rtp_hd);
|
if (local_rtp_port>=0 && local_rtcp_port<0)
|
||||||
/* XXX: need to open another connection if the port is not even */
|
local_rtcp_port = udp_get_local_port(s->rtp_hd) + 1;
|
||||||
|
|
||||||
/* well, should suppress localport in path */
|
|
||||||
|
|
||||||
build_udp_url(buf, sizeof(buf),
|
build_udp_url(buf, sizeof(buf),
|
||||||
hostname, port + 1, local_port + 1, ttl, max_packet_size);
|
hostname, rtcp_port, local_rtcp_port, ttl, max_packet_size);
|
||||||
if (url_open(&s->rtcp_hd, buf, flags) < 0)
|
if (url_open(&s->rtcp_hd, buf, flags) < 0)
|
||||||
goto fail;
|
goto fail;
|
||||||
|
|
||||||
@ -297,7 +316,19 @@ static int rtp_close(URLContext *h)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Return the local port used by the RTP connection
|
* Return the local rtp port used by the RTP connection
|
||||||
|
* @param s1 media file context
|
||||||
|
* @return the local port number
|
||||||
|
*/
|
||||||
|
|
||||||
|
int rtp_get_local_rtp_port(URLContext *h)
|
||||||
|
{
|
||||||
|
RTPContext *s = h->priv_data;
|
||||||
|
return udp_get_local_port(s->rtp_hd);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Return the local rtp port used by the RTP connection
|
||||||
* @param s1 media file context
|
* @param s1 media file context
|
||||||
* @return the local port number
|
* @return the local port number
|
||||||
*/
|
*/
|
||||||
@ -308,6 +339,18 @@ int rtp_get_local_port(URLContext *h)
|
|||||||
return udp_get_local_port(s->rtp_hd);
|
return udp_get_local_port(s->rtp_hd);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Return the local rtcp port used by the RTP connection
|
||||||
|
* @param s1 media file context
|
||||||
|
* @return the local port number
|
||||||
|
*/
|
||||||
|
|
||||||
|
int rtp_get_local_rtcp_port(URLContext *h)
|
||||||
|
{
|
||||||
|
RTPContext *s = h->priv_data;
|
||||||
|
return udp_get_local_port(s->rtcp_hd);
|
||||||
|
}
|
||||||
|
|
||||||
#if (LIBAVFORMAT_VERSION_MAJOR <= 52)
|
#if (LIBAVFORMAT_VERSION_MAJOR <= 52)
|
||||||
/**
|
/**
|
||||||
* Return the rtp and rtcp file handles for select() usage to wait for
|
* Return the rtp and rtcp file handles for select() usage to wait for
|
||||||
|
Loading…
Reference in New Issue
Block a user