74 path,
sizeof(path), uri);
80 rtcp_port = strtol(buf,
NULL, 10);
87 ff_url_join(buf,
sizeof(buf),
"udp",
NULL, hostname, rtcp_port,
"%s", path);
93 int type,
int family,
int flags)
95 struct addrinfo hints = { 0 }, *res = 0;
99 snprintf(service,
sizeof(service),
"%d", port);
103 if ((error =
getaddrinfo(hostname, service, &hints, &res))) {
117 return (((
const struct sockaddr_in *)a)->sin_addr.s_addr !=
118 ((
const struct sockaddr_in *)b)->sin_addr.s_addr);
121 #if HAVE_STRUCT_SOCKADDR_IN6
123 const uint8_t *s6_addr_a = ((
const struct sockaddr_in6 *)a)->sin6_addr.s6_addr;
124 const uint8_t *s6_addr_b = ((
const struct sockaddr_in6 *)b)->sin6_addr.s6_addr;
125 return memcmp(s6_addr_a, s6_addr_b, 16);
134 return ntohs(((
const struct sockaddr_in *)ss)->sin_port);
135 #if HAVE_STRUCT_SOCKADDR_IN6
137 return ntohs(((
const struct sockaddr_in6 *)ss)->sin6_port);
145 ((
struct sockaddr_in *)ss)->sin_port = htons(port);
146 #if HAVE_STRUCT_SOCKADDR_IN6
147 else if (ss->ss_family == AF_INET6)
148 ((
struct sockaddr_in6 *)ss)->sin6_port = htons(port);
182 if (strchr(buf,
'?'))
186 vsnprintf(buf1,
sizeof(buf1), fmt, ap);
192 const char *hostname,
int port,
193 int local_port,
int ttl,
194 int max_packet_size,
int connect,
195 const char *include_sources,
196 const char *exclude_sources)
200 url_add_option(buf, buf_size,
"localport=%d", local_port);
202 url_add_option(buf, buf_size,
"ttl=%d", ttl);
203 if (max_packet_size >=0)
204 url_add_option(buf, buf_size,
"pkt_size=%d", max_packet_size);
206 url_add_option(buf, buf_size,
"connect=1");
207 if (include_sources && include_sources[0])
208 url_add_option(buf, buf_size,
"sources=%s", include_sources);
209 if (exclude_sources && exclude_sources[0])
210 url_add_option(buf, buf_size,
"block=%s", exclude_sources);
215 int *address_list_size_ptr)
219 char tmp =
'\0', *p = buf, *next;
224 next = strchr(p,
',');
239 dynarray_add(address_list_ptr, address_list_size_ptr, source_addr);
276 int rtp_port, rtcp_port,
278 local_rtp_port, local_rtcp_port, max_packet_size;
279 char hostname[256], include_sources[1024] =
"", exclude_sources[1024] =
"";
285 path,
sizeof(path), uri);
288 rtcp_port = rtp_port+1;
290 local_rtcp_port = -1;
291 max_packet_size = -1;
294 p = strchr(uri,
'?');
297 ttl = strtol(buf,
NULL, 10);
300 rtcp_port = strtol(buf,
NULL, 10);
303 local_rtp_port = strtol(buf,
NULL, 10);
306 local_rtp_port = strtol(buf,
NULL, 10);
309 local_rtcp_port = strtol(buf,
NULL, 10);
312 max_packet_size = strtol(buf,
NULL, 10);
315 connect = strtol(buf,
NULL, 10);
321 av_strlcpy(include_sources, buf,
sizeof(include_sources));
325 av_strlcpy(exclude_sources, buf,
sizeof(exclude_sources));
331 hostname, rtp_port, local_rtp_port, ttl, max_packet_size,
332 connect, include_sources, exclude_sources);
335 if (local_rtp_port>=0 && local_rtcp_port<0)
339 hostname, rtcp_port, local_rtcp_port, ttl, max_packet_size,
340 connect, include_sources, exclude_sources);
365 struct pollfd p[2] = {{s->
rtp_fd, POLLIN, 0}, {s->
rtcp_fd, POLLIN, 0}};
373 n = poll(p, 2, poll_delay);
376 for (i = 1; i >= 0; i--) {
377 if (!(p[i].revents & POLLIN))
379 *addr_lens[i] =
sizeof(*addrs[i]);
380 len = recvfrom(p[i].fd, buf, size, 0,
381 (
struct sockaddr *)addrs[i], addr_lens[i]);
415 socklen_t *source_len, temp_len;
418 "Unable to send packet to source, no packets received yet\n");
429 source = &s->last_rtp_source;
433 source = &temp_source;
434 source_len = &temp_len;
436 temp_source = s->last_rtp_source;
440 "Not received any RTCP packets yet, inferring peer port "
441 "from the RTP port\n");
447 "Not received any RTP packets yet, inferring peer port "
448 "from the RTCP port\n");
457 ret = sendto(fd, buf, size, 0, (
struct sockaddr *) source,
526 int *hs = *handles =
av_malloc(
sizeof(**handles) * 2);