FFmpeg coverage

Line	Branch	Exec	Source
1			/*
2			* RTP network protocol
3			* Copyright (c) 2002 Fabrice Bellard
4			*
5			* This file is part of FFmpeg.
6			*
7			* FFmpeg is free software; you can redistribute it and/or
8			* modify it under the terms of the GNU Lesser General Public
9			* License as published by the Free Software Foundation; either
10			* version 2.1 of the License, or (at your option) any later version.
11			*
12			* FFmpeg is distributed in the hope that it will be useful,
13			* but WITHOUT ANY WARRANTY; without even the implied warranty of
14			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15			* Lesser General Public License for more details.
16			*
17			* You should have received a copy of the GNU Lesser General Public
18			* License along with FFmpeg; if not, write to the Free Software
19			* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20			*/
21
22			/**
23			* @file
24			* RTP protocol
25			*/
26
27			#include "libavutil/mem.h"
28			#include "libavutil/parseutils.h"
29			#include "libavutil/avstring.h"
30			#include "libavutil/opt.h"
31			#include "avformat.h"
32			#include "rtp.h"
33			#include "rtpproto.h"
34			#include "url.h"
35			#include "ip.h"
36
37			#include <stdarg.h>
38			#include "network.h"
39			#include "os_support.h"
40			#include <fcntl.h>
41			#if HAVE_POLL_H
42			#include <poll.h>
43			#endif
44
45			typedef struct RTPContext {
46			const AVClass *class;
47			URLContext *rtp_hd, *rtcp_hd, *fec_hd;
48			int rtp_fd, rtcp_fd;
49			IPSourceFilters filters;
50			int write_to_source;
51			struct sockaddr_storage last_rtp_source, last_rtcp_source;
52			socklen_t last_rtp_source_len, last_rtcp_source_len;
53			int ttl;
54			int buffer_size;
55			int rtcp_port, local_rtpport, local_rtcpport;
56			int connect;
57			int pkt_size;
58			int dscp;
59			char *sources;
60			char *block;
61			char *fec_options_str;
62			int64_t rw_timeout;
63			char *localaddr;
64			} RTPContext;
65
66			#define OFFSET(x) offsetof(RTPContext, x)
67			#define D AV_OPT_FLAG_DECODING_PARAM
68			#define E AV_OPT_FLAG_ENCODING_PARAM
69			static const AVOption options[] = {
70			{ "ttl", "Time to live (multicast only)", OFFSET(ttl), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, 255, .flags = D|E },
71			{ "buffer_size", "Send/Receive buffer size (in bytes)", OFFSET(buffer_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
72			{ "rtcp_port", "Custom rtcp port", OFFSET(rtcp_port), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
73			{ "local_rtpport", "Local rtp port", OFFSET(local_rtpport), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
74			{ "local_rtcpport", "Local rtcp port", OFFSET(local_rtcpport), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
75			{ "connect", "Connect socket", OFFSET(connect), AV_OPT_TYPE_BOOL, { .i64 = 0 }, 0, 1, .flags = D|E },
76			{ "write_to_source", "Send packets to the source address of the latest received packet", OFFSET(write_to_source), AV_OPT_TYPE_BOOL, { .i64 = 0 }, 0, 1, .flags = D|E },
77			{ "pkt_size", "Maximum packet size", OFFSET(pkt_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
78			{ "dscp", "DSCP class", OFFSET(dscp), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
79			{ "timeout", "set timeout (in microseconds) of socket I/O operations", OFFSET(rw_timeout), AV_OPT_TYPE_INT64, { .i64 = -1 }, -1, INT64_MAX, .flags = D|E },
80			{ "sources", "Source list", OFFSET(sources), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E },
81			{ "block", "Block list", OFFSET(block), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E },
82			{ "fec", "FEC", OFFSET(fec_options_str), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = E },
83			{ "localaddr", "Local address", OFFSET(localaddr), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E },
84			{ NULL }
85			};
86
87			static const AVClass rtp_class = {
88			.class_name = "rtp",
89			.item_name = av_default_item_name,
90			.option = options,
91			.version = LIBAVUTIL_VERSION_INT,
92			};
93
94			/**
95			* If no filename is given to av_open_input_file because you want to
96			* get the local port first, then you must call this function to set
97			* the remote server address.
98			*
99			* @param h media file context
100			* @param uri of the remote server
101			* @return zero if no error.
102			*/
103
104		✗	int ff_rtp_set_remote_url(URLContext *h, const char *uri)
105			{
106		✗	RTPContext *s = h->priv_data;
107			char hostname[256];
108			int port, rtcp_port;
109			const char *p;
110
111			char buf[1024];
112			char path[1024];
113
114		✗	av_url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &port,
115			path, sizeof(path), uri);
116		✗	rtcp_port = port + 1;
117
118		✗	p = strchr(uri, '?');
119		✗	if (p) {
120		✗	if (av_find_info_tag(buf, sizeof(buf), "rtcpport", p)) {
121		✗	rtcp_port = strtol(buf, NULL, 10);
122			}
123			}
124
125		✗	ff_url_join(buf, sizeof(buf), "udp", NULL, hostname, port, "%s", path);
126		✗	ff_udp_set_remote_url(s->rtp_hd, buf);
127
128		✗	ff_url_join(buf, sizeof(buf), "udp", NULL, hostname, rtcp_port, "%s", path);
129		✗	ff_udp_set_remote_url(s->rtcp_hd, buf);
130		✗	return 0;
131			}
132
133		✗	static int get_port(const struct sockaddr_storage *ss)
134			{
135		✗	if (ss->ss_family == AF_INET)
136		✗	return ntohs(((const struct sockaddr_in *)ss)->sin_port);
137			#if HAVE_STRUCT_SOCKADDR_IN6
138		✗	if (ss->ss_family == AF_INET6)
139		✗	return ntohs(((const struct sockaddr_in6 *)ss)->sin6_port);
140			#endif
141		✗	return 0;
142			}
143
144		✗	static void set_port(struct sockaddr_storage *ss, int port)
145			{
146		✗	if (ss->ss_family == AF_INET)
147		✗	((struct sockaddr_in *)ss)->sin_port = htons(port);
148			#if HAVE_STRUCT_SOCKADDR_IN6
149		✗	else if (ss->ss_family == AF_INET6)
150		✗	((struct sockaddr_in6 *)ss)->sin6_port = htons(port);
151			#endif
152		✗	}
153
154			/**
155			* add option to url of the form:
156			* "http://host:port/path?option1=val1&option2=val2...
157			*/
158
159		✗	static av_printf_format(3, 4) void url_add_option(char *buf, int buf_size, const char *fmt, ...)
160			{
161			char buf1[1024];
162			va_list ap;
163
164		✗	va_start(ap, fmt);
165		✗	if (strchr(buf, '?'))
166		✗	av_strlcat(buf, "&", buf_size);
167			else
168		✗	av_strlcat(buf, "?", buf_size);
169		✗	vsnprintf(buf1, sizeof(buf1), fmt, ap);
170		✗	av_strlcat(buf, buf1, buf_size);
171		✗	va_end(ap);
172		✗	}
173
174		✗	static void build_udp_url(RTPContext *s,
175			char *buf, int buf_size,
176			const char *hostname,
177			const char *localaddr,
178			int port, int local_port,
179			const char *include_sources,
180			const char *exclude_sources)
181			{
182		✗	ff_url_join(buf, buf_size, "udp", NULL, hostname, port, NULL);
183		✗	if (local_port >= 0)
184		✗	url_add_option(buf, buf_size, "localport=%d", local_port);
185		✗	if (s->ttl >= 0)
186		✗	url_add_option(buf, buf_size, "ttl=%d", s->ttl);
187		✗	if (s->buffer_size >= 0)
188		✗	url_add_option(buf, buf_size, "buffer_size=%d", s->buffer_size);
189		✗	if (s->pkt_size >= 0)
190		✗	url_add_option(buf, buf_size, "pkt_size=%d", s->pkt_size);
191		✗	if (s->connect)
192		✗	url_add_option(buf, buf_size, "connect=1");
193		✗	if (s->dscp >= 0)
194		✗	url_add_option(buf, buf_size, "dscp=%d", s->dscp);
195		✗	url_add_option(buf, buf_size, "fifo_size=0");
196		✗	if (include_sources && include_sources[0])
197		✗	url_add_option(buf, buf_size, "sources=%s", include_sources);
198		✗	if (exclude_sources && exclude_sources[0])
199		✗	url_add_option(buf, buf_size, "block=%s", exclude_sources);
200		✗	if (localaddr && localaddr[0])
201		✗	url_add_option(buf, buf_size, "localaddr=%s", localaddr);
202		✗	}
203
204			/**
205			* url syntax: rtp://host:port[?option=val...]
206			* option: 'ttl=n' : set the ttl value (for multicast only)
207			* 'rtcpport=n' : set the remote rtcp port to n
208			* 'localrtpport=n' : set the local rtp port to n
209			* 'localrtcpport=n' : set the local rtcp port to n
210			* 'pkt_size=n' : set max packet size
211			* 'connect=0/1' : do a connect() on the UDP socket
212			* 'sources=ip[,ip]' : list allowed source IP addresses
213			* 'block=ip[,ip]' : list disallowed source IP addresses
214			* 'write_to_source=0/1' : send packets to the source address of the latest received packet
215			* 'dscp=n' : set DSCP value to n (QoS)
216			* deprecated option:
217			* 'localport=n' : set the local port to n
218			*
219			* if rtcpport isn't set the rtcp port will be the rtp port + 1
220			* if local rtp port isn't set any available port will be used for the local
221			* rtp and rtcp ports
222			* if the local rtcp port is not set it will be the local rtp port + 1
223			*/
224
225		✗	static int rtp_open(URLContext *h, const char *uri, int flags)
226			{
227		✗	RTPContext *s = h->priv_data;
228		✗	AVDictionary *fec_opts = NULL;
229			int rtp_port;
230		✗	char hostname[256], include_sources[1024] = "", exclude_sources[1024] = "";
231		✗	char *sources = include_sources, *block = exclude_sources;
232		✗	char *fec_protocol = NULL;
233			char buf[1024];
234			char path[1024];
235			const char *p;
236		✗	int i, max_retry_count = 3;
237			int rtcpflags;
238
239		✗	av_url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &rtp_port,
240			path, sizeof(path), uri);
241			/* extract parameters */
242		✗	if (s->rtcp_port < 0)
243		✗	s->rtcp_port = rtp_port + 1;
244
245		✗	p = strchr(uri, '?');
246		✗	if (p) {
247		✗	if (av_find_info_tag(buf, sizeof(buf), "ttl", p)) {
248		✗	s->ttl = strtol(buf, NULL, 10);
249			}
250		✗	if (av_find_info_tag(buf, sizeof(buf), "rtcpport", p)) {
251		✗	s->rtcp_port = strtol(buf, NULL, 10);
252			}
253		✗	if (av_find_info_tag(buf, sizeof(buf), "localport", p)) {
254		✗	s->local_rtpport = strtol(buf, NULL, 10);
255			}
256		✗	if (av_find_info_tag(buf, sizeof(buf), "localrtpport", p)) {
257		✗	s->local_rtpport = strtol(buf, NULL, 10);
258			}
259		✗	if (av_find_info_tag(buf, sizeof(buf), "localrtcpport", p)) {
260		✗	s->local_rtcpport = strtol(buf, NULL, 10);
261			}
262		✗	if (av_find_info_tag(buf, sizeof(buf), "pkt_size", p)) {
263		✗	s->pkt_size = strtol(buf, NULL, 10);
264			}
265		✗	if (av_find_info_tag(buf, sizeof(buf), "connect", p)) {
266		✗	s->connect = strtol(buf, NULL, 10);
267			}
268		✗	if (av_find_info_tag(buf, sizeof(buf), "write_to_source", p)) {
269		✗	s->write_to_source = strtol(buf, NULL, 10);
270			}
271		✗	if (av_find_info_tag(buf, sizeof(buf), "dscp", p)) {
272		✗	s->dscp = strtol(buf, NULL, 10);
273			}
274		✗	if (av_find_info_tag(buf, sizeof(buf), "timeout", p)) {
275		✗	s->rw_timeout = strtol(buf, NULL, 10);
276			}
277		✗	if (av_find_info_tag(buf, sizeof(buf), "sources", p)) {
278		✗	av_strlcpy(include_sources, buf, sizeof(include_sources));
279		✗	ff_ip_parse_sources(h, buf, &s->filters);
280			} else {
281		✗	ff_ip_parse_sources(h, s->sources, &s->filters);
282		✗	sources = s->sources;
283			}
284		✗	if (av_find_info_tag(buf, sizeof(buf), "block", p)) {
285		✗	av_strlcpy(exclude_sources, buf, sizeof(exclude_sources));
286		✗	ff_ip_parse_blocks(h, buf, &s->filters);
287			} else {
288		✗	ff_ip_parse_blocks(h, s->block, &s->filters);
289		✗	block = s->block;
290			}
291		✗	if (av_find_info_tag(buf, sizeof(buf), "localaddr", p)) {
292		✗	av_freep(&s->localaddr);
293		✗	s->localaddr = av_strdup(buf);
294		✗	if (!s->localaddr)
295		✗	goto fail;
296			}
297			}
298		✗	if (s->rw_timeout >= 0)
299		✗	h->rw_timeout = s->rw_timeout;
300
301		✗	if (s->fec_options_str) {
302		✗	p = s->fec_options_str;
303
304		✗	if (!(fec_protocol = av_get_token(&p, "="))) {
305		✗	av_log(h, AV_LOG_ERROR, "Failed to parse the FEC protocol value\n");
306		✗	goto fail;
307			}
308		✗	if (strcmp(fec_protocol, "prompeg")) {
309		✗	av_log(h, AV_LOG_ERROR, "Unsupported FEC protocol %s\n", fec_protocol);
310		✗	goto fail;
311			}
312
313		✗	p = s->fec_options_str + strlen(fec_protocol);
314		✗	while (*p && *p == '=') p++;
315
316		✗	if (av_dict_parse_string(&fec_opts, p, "=", ":", 0) < 0) {
317		✗	av_log(h, AV_LOG_ERROR, "Failed to parse the FEC options\n");
318		✗	goto fail;
319			}
320		✗	if (s->ttl > 0) {
321		✗	av_dict_set_int(&fec_opts, "ttl", s->ttl, 0);
322			}
323			}
324
325		✗	for (i = 0; i < max_retry_count; i++) {
326		✗	build_udp_url(s, buf, sizeof(buf),
327		✗	hostname, s->localaddr, rtp_port, s->local_rtpport,
328			sources, block);
329		✗	if (ffurl_open_whitelist(&s->rtp_hd, buf, flags, &h->interrupt_callback,
330			NULL, h->protocol_whitelist, h->protocol_blacklist, h) < 0)
331		✗	goto fail;
332		✗	s->local_rtpport = ff_udp_get_local_port(s->rtp_hd);
333		✗	if(s->local_rtpport == 65535) {
334		✗	s->local_rtpport = -1;
335		✗	continue;
336			}
337		✗	rtcpflags = flags | AVIO_FLAG_WRITE;
338		✗	if (s->local_rtcpport < 0) {
339		✗	s->local_rtcpport = s->local_rtpport + 1;
340		✗	build_udp_url(s, buf, sizeof(buf),
341		✗	hostname, s->localaddr, s->rtcp_port, s->local_rtcpport,
342			sources, block);
343		✗	if (ffurl_open_whitelist(&s->rtcp_hd, buf, rtcpflags,
344		✗	&h->interrupt_callback, NULL,
345			h->protocol_whitelist, h->protocol_blacklist, h) < 0) {
346		✗	s->local_rtpport = s->local_rtcpport = -1;
347		✗	continue;
348			}
349		✗	break;
350			}
351		✗	build_udp_url(s, buf, sizeof(buf),
352		✗	hostname, s->localaddr, s->rtcp_port, s->local_rtcpport,
353			sources, block);
354		✗	if (ffurl_open_whitelist(&s->rtcp_hd, buf, rtcpflags, &h->interrupt_callback,
355			NULL, h->protocol_whitelist, h->protocol_blacklist, h) < 0)
356		✗	goto fail;
357		✗	break;
358			}
359
360		✗	s->fec_hd = NULL;
361		✗	if (fec_protocol) {
362		✗	ff_url_join(buf, sizeof(buf), fec_protocol, NULL, hostname, rtp_port, NULL);
363		✗	if (ffurl_open_whitelist(&s->fec_hd, buf, flags, &h->interrupt_callback,
364			&fec_opts, h->protocol_whitelist, h->protocol_blacklist, h) < 0)
365		✗	goto fail;
366			}
367
368			/* just to ease handle access. XXX: need to suppress direct handle
369			access */
370		✗	s->rtp_fd = ffurl_get_file_handle(s->rtp_hd);
371		✗	s->rtcp_fd = ffurl_get_file_handle(s->rtcp_hd);
372
373		✗	h->max_packet_size = s->rtp_hd->max_packet_size;
374		✗	h->is_streamed = 1;
375
376		✗	av_free(fec_protocol);
377		✗	av_dict_free(&fec_opts);
378
379		✗	return 0;
380
381		✗	fail:
382		✗	ff_ip_reset_filters(&s->filters);
383		✗	ffurl_closep(&s->rtp_hd);
384		✗	ffurl_closep(&s->rtcp_hd);
385		✗	ffurl_closep(&s->fec_hd);
386		✗	av_free(fec_protocol);
387		✗	av_dict_free(&fec_opts);
388		✗	return AVERROR(EIO);
389			}
390
391		✗	static int rtp_read(URLContext *h, uint8_t *buf, int size)
392			{
393		✗	RTPContext *s = h->priv_data;
394			int len, n, i;
395		✗	struct pollfd p[2] = {{s->rtp_fd, POLLIN, 0}, {s->rtcp_fd, POLLIN, 0}};
396		✗	int poll_delay = h->flags & AVIO_FLAG_NONBLOCK ? 0 : POLLING_TIME;
397		✗	struct sockaddr_storage *addrs[2] = { &s->last_rtp_source, &s->last_rtcp_source };
398		✗	socklen_t *addr_lens[2] = { &s->last_rtp_source_len, &s->last_rtcp_source_len };
399		✗	int runs = h->rw_timeout / 1000 / POLLING_TIME;
400
401			for(;;) {
402		✗	if (ff_check_interrupt(&h->interrupt_callback))
403		✗	return AVERROR_EXIT;
404		✗	n = poll(p, 2, poll_delay);
405		✗	if (n > 0) {
406			/* first try RTCP, then RTP */
407		✗	for (i = 1; i >= 0; i--) {
408		✗	if (!(p[i].revents & POLLIN))
409		✗	continue;
410		✗	*addr_lens[i] = sizeof(*addrs[i]);
411		✗	len = recvfrom(p[i].fd, buf, size, 0,
412		✗	(struct sockaddr *)addrs[i], addr_lens[i]);
413		✗	if (len < 0) {
414		✗	if (ff_neterrno() == AVERROR(EAGAIN) ||
415		✗	ff_neterrno() == AVERROR(EINTR))
416		✗	continue;
417		✗	return AVERROR(EIO);
418			}
419		✗	if (ff_ip_check_source_lists(addrs[i], &s->filters))
420		✗	continue;
421		✗	return len;
422			}
423		✗	} else if (n == 0 && h->rw_timeout > 0 && --runs <= 0) {
424		✗	return AVERROR(ETIMEDOUT);
425		✗	} else if (n < 0) {
426		✗	if (ff_neterrno() == AVERROR(EINTR))
427		✗	continue;
428		✗	return AVERROR(EIO);
429			}
430		✗	if (h->flags & AVIO_FLAG_NONBLOCK)
431		✗	return AVERROR(EAGAIN);
432			}
433			}
434
435		✗	static int rtp_write(URLContext *h, const uint8_t *buf, int size)
436			{
437		✗	RTPContext *s = h->priv_data;
438			int ret, ret_fec;
439			URLContext *hd;
440
441		✗	if (size < 2)
442		✗	return AVERROR(EINVAL);
443
444		✗	if ((buf[0] & 0xc0) != (RTP_VERSION << 6))
445		✗	av_log(h, AV_LOG_WARNING, "Data doesn't look like RTP packets, "
446			"make sure the RTP muxer is used\n");
447
448		✗	if (s->write_to_source) {
449			int fd;
450			struct sockaddr_storage *source, temp_source;
451			socklen_t *source_len, temp_len;
452		✗	if (!s->last_rtp_source.ss_family && !s->last_rtcp_source.ss_family) {
453		✗	av_log(h, AV_LOG_ERROR,
454			"Unable to send packet to source, no packets received yet\n");
455			// Intentionally not returning an error here
456		✗	return size;
457			}
458
459		✗	if (RTP_PT_IS_RTCP(buf[1])) {
460		✗	fd = s->rtcp_fd;
461		✗	source = &s->last_rtcp_source;
462		✗	source_len = &s->last_rtcp_source_len;
463			} else {
464		✗	fd = s->rtp_fd;
465		✗	source = &s->last_rtp_source;
466		✗	source_len = &s->last_rtp_source_len;
467			}
468		✗	if (!source->ss_family) {
469		✗	source = &temp_source;
470		✗	source_len = &temp_len;
471		✗	if (RTP_PT_IS_RTCP(buf[1])) {
472		✗	temp_source = s->last_rtp_source;
473		✗	temp_len = s->last_rtp_source_len;
474		✗	set_port(source, get_port(source) + 1);
475		✗	av_log(h, AV_LOG_INFO,
476			"Not received any RTCP packets yet, inferring peer port "
477			"from the RTP port\n");
478			} else {
479		✗	temp_source = s->last_rtcp_source;
480		✗	temp_len = s->last_rtcp_source_len;
481		✗	set_port(source, get_port(source) - 1);
482		✗	av_log(h, AV_LOG_INFO,
483			"Not received any RTP packets yet, inferring peer port "
484			"from the RTCP port\n");
485			}
486			}
487
488		✗	if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
489		✗	ret = ff_network_wait_fd(fd, 1);
490		✗	if (ret < 0)
491		✗	return ret;
492			}
493		✗	ret = sendto(fd, buf, size, 0, (struct sockaddr *) source,
494			*source_len);
495
496		✗	return ret < 0 ? ff_neterrno() : ret;
497			}
498
499		✗	if (RTP_PT_IS_RTCP(buf[1])) {
500			/* RTCP payload type */
501		✗	hd = s->rtcp_hd;
502			} else {
503			/* RTP payload type */
504		✗	hd = s->rtp_hd;
505			}
506
507		✗	if ((ret = ffurl_write(hd, buf, size)) < 0) {
508		✗	return ret;
509			}
510
511		✗	if (s->fec_hd && !RTP_PT_IS_RTCP(buf[1])) {
512		✗	if ((ret_fec = ffurl_write(s->fec_hd, buf, size)) < 0) {
513		✗	av_log(h, AV_LOG_ERROR, "Failed to send FEC\n");
514		✗	return ret_fec;
515			}
516			}
517
518		✗	return ret;
519			}
520
521		✗	static int rtp_close(URLContext *h)
522			{
523		✗	RTPContext *s = h->priv_data;
524
525		✗	ff_ip_reset_filters(&s->filters);
526
527		✗	ffurl_closep(&s->rtp_hd);
528		✗	ffurl_closep(&s->rtcp_hd);
529		✗	ffurl_closep(&s->fec_hd);
530		✗	return 0;
531			}
532
533			/**
534			* Return the local rtp port used by the RTP connection
535			* @param h media file context
536			* @return the local port number
537			*/
538
539		✗	int ff_rtp_get_local_rtp_port(URLContext *h)
540			{
541		✗	RTPContext *s = h->priv_data;
542		✗	return ff_udp_get_local_port(s->rtp_hd);
543			}
544
545			/**
546			* Return the local rtcp port used by the RTP connection
547			* @param h media file context
548			* @return the local port number
549			*/
550
551		✗	static int rtp_get_file_handle(URLContext *h)
552			{
553		✗	RTPContext *s = h->priv_data;
554		✗	return s->rtp_fd;
555			}
556
557		✗	static int rtp_get_multi_file_handle(URLContext *h, int **handles,
558			int *numhandles)
559			{
560		✗	RTPContext *s = h->priv_data;
561		✗	int *hs = *handles = av_malloc(sizeof(**handles) * 2);
562		✗	if (!hs)
563		✗	return AVERROR(ENOMEM);
564		✗	hs[0] = s->rtp_fd;
565		✗	hs[1] = s->rtcp_fd;
566		✗	*numhandles = 2;
567		✗	return 0;
568			}
569
570			const URLProtocol ff_rtp_protocol = {
571			.name = "rtp",
572			.url_open = rtp_open,
573			.url_read = rtp_read,
574			.url_write = rtp_write,
575			.url_close = rtp_close,
576			.url_get_file_handle = rtp_get_file_handle,
577			.url_get_multi_file_handle = rtp_get_multi_file_handle,
578			.priv_data_size = sizeof(RTPContext),
579			.flags = URL_PROTOCOL_FLAG_NETWORK,
580			.priv_data_class = &rtp_class,
581			};
582