FFmpeg
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
udp.c
Go to the documentation of this file.
1 /*
2  * UDP prototype streaming system
3  * Copyright (c) 2000, 2001, 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  * UDP protocol
25  */
26 
27 #define _DEFAULT_SOURCE
28 #define _BSD_SOURCE /* Needed for using struct ip_mreq with recent glibc */
29 
30 #include "avformat.h"
31 #include "avio_internal.h"
32 #include "libavutil/avassert.h"
33 #include "libavutil/parseutils.h"
34 #include "libavutil/fifo.h"
35 #include "libavutil/intreadwrite.h"
36 #include "libavutil/avstring.h"
37 #include "libavutil/opt.h"
38 #include "libavutil/log.h"
39 #include "libavutil/time.h"
40 #include "internal.h"
41 #include "network.h"
42 #include "os_support.h"
43 #include "url.h"
44 
45 #if HAVE_UDPLITE_H
46 #include "udplite.h"
47 #else
48 /* On many Linux systems, udplite.h is missing but the kernel supports UDP-Lite.
49  * So, we provide a fallback here.
50  */
51 #define UDPLITE_SEND_CSCOV 10
52 #define UDPLITE_RECV_CSCOV 11
53 #endif
54 
55 #ifndef IPPROTO_UDPLITE
56 #define IPPROTO_UDPLITE 136
57 #endif
58 
59 #if HAVE_PTHREAD_CANCEL
60 #include <pthread.h>
61 #endif
62 
63 #ifndef HAVE_PTHREAD_CANCEL
64 #define HAVE_PTHREAD_CANCEL 0
65 #endif
66 
67 #ifndef IPV6_ADD_MEMBERSHIP
68 #define IPV6_ADD_MEMBERSHIP IPV6_JOIN_GROUP
69 #define IPV6_DROP_MEMBERSHIP IPV6_LEAVE_GROUP
70 #endif
71 
72 #define UDP_TX_BUF_SIZE 32768
73 #define UDP_MAX_PKT_SIZE 65536
74 #define UDP_HEADER_SIZE 8
75 
76 typedef struct UDPContext {
77  const AVClass *class;
78  int udp_fd;
79  int ttl;
82  int pkt_size;
91 
92  /* Circular Buffer variables for use in UDP receive code */
96  int64_t bitrate; /* number of bits to send per second */
97  int64_t burst_bits;
98  int close_req;
99 #if HAVE_PTHREAD_CANCEL
100  pthread_t circular_buffer_thread;
102  pthread_cond_t cond;
103  int thread_started;
104 #endif
107  char *localaddr;
108  int timeout;
110  char *sources;
111  char *block;
112 } UDPContext;
113 
114 #define OFFSET(x) offsetof(UDPContext, x)
115 #define D AV_OPT_FLAG_DECODING_PARAM
116 #define E AV_OPT_FLAG_ENCODING_PARAM
117 static const AVOption options[] = {
118  { "buffer_size", "System data size (in bytes)", OFFSET(buffer_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
119  { "bitrate", "Bits to send per second", OFFSET(bitrate), AV_OPT_TYPE_INT64, { .i64 = 0 }, 0, INT64_MAX, .flags = E },
120  { "burst_bits", "Max length of bursts in bits (when using bitrate)", OFFSET(burst_bits), AV_OPT_TYPE_INT64, { .i64 = 0 }, 0, INT64_MAX, .flags = E },
121  { "localport", "Local port", OFFSET(local_port), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, D|E },
122  { "local_port", "Local port", OFFSET(local_port), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
123  { "localaddr", "Local address", OFFSET(localaddr), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E },
124  { "udplite_coverage", "choose UDPLite head size which should be validated by checksum", OFFSET(udplite_coverage), AV_OPT_TYPE_INT, {.i64 = 0}, 0, INT_MAX, D|E },
125  { "pkt_size", "Maximum UDP packet size", OFFSET(pkt_size), AV_OPT_TYPE_INT, { .i64 = 1472 }, -1, INT_MAX, .flags = D|E },
126  { "reuse", "explicitly allow reusing UDP sockets", OFFSET(reuse_socket), AV_OPT_TYPE_BOOL, { .i64 = -1 }, -1, 1, D|E },
127  { "reuse_socket", "explicitly allow reusing UDP sockets", OFFSET(reuse_socket), AV_OPT_TYPE_BOOL, { .i64 = -1 }, -1, 1, .flags = D|E },
128  { "broadcast", "explicitly allow or disallow broadcast destination", OFFSET(is_broadcast), AV_OPT_TYPE_BOOL, { .i64 = 0 }, 0, 1, E },
129  { "ttl", "Time to live (multicast only)", OFFSET(ttl), AV_OPT_TYPE_INT, { .i64 = 16 }, 0, INT_MAX, E },
130  { "connect", "set if connect() should be called on socket", OFFSET(is_connected), AV_OPT_TYPE_BOOL, { .i64 = 0 }, 0, 1, .flags = D|E },
131  { "fifo_size", "set the UDP receiving circular buffer size, expressed as a number of packets with size of 188 bytes", OFFSET(circular_buffer_size), AV_OPT_TYPE_INT, {.i64 = 7*4096}, 0, INT_MAX, D },
132  { "overrun_nonfatal", "survive in case of UDP receiving circular buffer overrun", OFFSET(overrun_nonfatal), AV_OPT_TYPE_BOOL, {.i64 = 0}, 0, 1, D },
133  { "timeout", "set raise error timeout (only in read mode)", OFFSET(timeout), AV_OPT_TYPE_INT, { .i64 = 0 }, 0, INT_MAX, D },
134  { "sources", "Source list", OFFSET(sources), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E },
135  { "block", "Block list", OFFSET(block), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E },
136  { NULL }
137 };
138 
139 static const AVClass udp_class = {
140  .class_name = "udp",
141  .item_name = av_default_item_name,
142  .option = options,
143  .version = LIBAVUTIL_VERSION_INT,
144 };
145 
147  .class_name = "udplite",
148  .item_name = av_default_item_name,
149  .option = options,
150  .version = LIBAVUTIL_VERSION_INT,
151 };
152 
153 static void log_net_error(void *ctx, int level, const char* prefix)
154 {
155  char errbuf[100];
156  av_strerror(ff_neterrno(), errbuf, sizeof(errbuf));
157  av_log(ctx, level, "%s: %s\n", prefix, errbuf);
158 }
159 
160 static int udp_set_multicast_ttl(int sockfd, int mcastTTL,
161  struct sockaddr *addr)
162 {
163 #ifdef IP_MULTICAST_TTL
164  if (addr->sa_family == AF_INET) {
165  if (setsockopt(sockfd, IPPROTO_IP, IP_MULTICAST_TTL, &mcastTTL, sizeof(mcastTTL)) < 0) {
166  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IP_MULTICAST_TTL)");
167  return -1;
168  }
169  }
170 #endif
171 #if defined(IPPROTO_IPV6) && defined(IPV6_MULTICAST_HOPS)
172  if (addr->sa_family == AF_INET6) {
173  if (setsockopt(sockfd, IPPROTO_IPV6, IPV6_MULTICAST_HOPS, &mcastTTL, sizeof(mcastTTL)) < 0) {
174  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IPV6_MULTICAST_HOPS)");
175  return -1;
176  }
177  }
178 #endif
179  return 0;
180 }
181 
182 static int udp_join_multicast_group(int sockfd, struct sockaddr *addr,struct sockaddr *local_addr)
183 {
184 #ifdef IP_ADD_MEMBERSHIP
185  if (addr->sa_family == AF_INET) {
186  struct ip_mreq mreq;
187 
188  mreq.imr_multiaddr.s_addr = ((struct sockaddr_in *)addr)->sin_addr.s_addr;
189  if (local_addr)
190  mreq.imr_interface= ((struct sockaddr_in *)local_addr)->sin_addr;
191  else
192  mreq.imr_interface.s_addr= INADDR_ANY;
193  if (setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, (const void *)&mreq, sizeof(mreq)) < 0) {
194  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IP_ADD_MEMBERSHIP)");
195  return -1;
196  }
197  }
198 #endif
199 #if HAVE_STRUCT_IPV6_MREQ && defined(IPPROTO_IPV6)
200  if (addr->sa_family == AF_INET6) {
201  struct ipv6_mreq mreq6;
202 
203  memcpy(&mreq6.ipv6mr_multiaddr, &(((struct sockaddr_in6 *)addr)->sin6_addr), sizeof(struct in6_addr));
204  mreq6.ipv6mr_interface= 0;
205  if (setsockopt(sockfd, IPPROTO_IPV6, IPV6_ADD_MEMBERSHIP, &mreq6, sizeof(mreq6)) < 0) {
206  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IPV6_ADD_MEMBERSHIP)");
207  return -1;
208  }
209  }
210 #endif
211  return 0;
212 }
213 
214 static int udp_leave_multicast_group(int sockfd, struct sockaddr *addr,struct sockaddr *local_addr)
215 {
216 #ifdef IP_DROP_MEMBERSHIP
217  if (addr->sa_family == AF_INET) {
218  struct ip_mreq mreq;
219 
220  mreq.imr_multiaddr.s_addr = ((struct sockaddr_in *)addr)->sin_addr.s_addr;
221  if (local_addr)
222  mreq.imr_interface= ((struct sockaddr_in *)local_addr)->sin_addr;
223  else
224  mreq.imr_interface.s_addr= INADDR_ANY;
225  if (setsockopt(sockfd, IPPROTO_IP, IP_DROP_MEMBERSHIP, (const void *)&mreq, sizeof(mreq)) < 0) {
226  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IP_DROP_MEMBERSHIP)");
227  return -1;
228  }
229  }
230 #endif
231 #if HAVE_STRUCT_IPV6_MREQ && defined(IPPROTO_IPV6)
232  if (addr->sa_family == AF_INET6) {
233  struct ipv6_mreq mreq6;
234 
235  memcpy(&mreq6.ipv6mr_multiaddr, &(((struct sockaddr_in6 *)addr)->sin6_addr), sizeof(struct in6_addr));
236  mreq6.ipv6mr_interface= 0;
237  if (setsockopt(sockfd, IPPROTO_IPV6, IPV6_DROP_MEMBERSHIP, &mreq6, sizeof(mreq6)) < 0) {
238  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IPV6_DROP_MEMBERSHIP)");
239  return -1;
240  }
241  }
242 #endif
243  return 0;
244 }
245 
247  const char *hostname, int port,
248  int type, int family, int flags)
249 {
250  struct addrinfo hints = { 0 }, *res = 0;
251  int error;
252  char sport[16];
253  const char *node = 0, *service = "0";
254 
255  if (port > 0) {
256  snprintf(sport, sizeof(sport), "%d", port);
257  service = sport;
258  }
259  if ((hostname) && (hostname[0] != '\0') && (hostname[0] != '?')) {
260  node = hostname;
261  }
262  hints.ai_socktype = type;
263  hints.ai_family = family;
264  hints.ai_flags = flags;
265  if ((error = getaddrinfo(node, service, &hints, &res))) {
266  res = NULL;
267  av_log(h, AV_LOG_ERROR, "getaddrinfo(%s, %s): %s\n",
268  node ? node : "unknown",
269  service,
270  gai_strerror(error));
271  }
272 
273  return res;
274 }
275 
277  int sockfd, struct sockaddr *addr,
278  int addr_len, char **sources,
279  int nb_sources, int include)
280 {
281 #if HAVE_STRUCT_GROUP_SOURCE_REQ && defined(MCAST_BLOCK_SOURCE) && !defined(_WIN32)
282  /* These ones are available in the microsoft SDK, but don't seem to work
283  * as on linux, so just prefer the v4-only approach there for now. */
284  int i;
285  for (i = 0; i < nb_sources; i++) {
286  struct group_source_req mreqs;
287  int level = addr->sa_family == AF_INET ? IPPROTO_IP : IPPROTO_IPV6;
288  struct addrinfo *sourceaddr = udp_resolve_host(h, sources[i], 0,
289  SOCK_DGRAM, AF_UNSPEC,
290  0);
291  if (!sourceaddr)
292  return AVERROR(ENOENT);
293 
294  mreqs.gsr_interface = 0;
295  memcpy(&mreqs.gsr_group, addr, addr_len);
296  memcpy(&mreqs.gsr_source, sourceaddr->ai_addr, sourceaddr->ai_addrlen);
297  freeaddrinfo(sourceaddr);
298 
299  if (setsockopt(sockfd, level,
300  include ? MCAST_JOIN_SOURCE_GROUP : MCAST_BLOCK_SOURCE,
301  (const void *)&mreqs, sizeof(mreqs)) < 0) {
302  if (include)
303  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(MCAST_JOIN_SOURCE_GROUP)");
304  else
305  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(MCAST_BLOCK_SOURCE)");
306  return ff_neterrno();
307  }
308  }
309 #elif HAVE_STRUCT_IP_MREQ_SOURCE && defined(IP_BLOCK_SOURCE)
310  int i;
311  if (addr->sa_family != AF_INET) {
313  "Setting multicast sources only supported for IPv4\n");
314  return AVERROR(EINVAL);
315  }
316  for (i = 0; i < nb_sources; i++) {
317  struct ip_mreq_source mreqs;
318  struct addrinfo *sourceaddr = udp_resolve_host(h, sources[i], 0,
319  SOCK_DGRAM, AF_UNSPEC,
320  0);
321  if (!sourceaddr)
322  return AVERROR(ENOENT);
323  if (sourceaddr->ai_addr->sa_family != AF_INET) {
324  freeaddrinfo(sourceaddr);
325  av_log(NULL, AV_LOG_ERROR, "%s is of incorrect protocol family\n",
326  sources[i]);
327  return AVERROR(EINVAL);
328  }
329 
330  mreqs.imr_multiaddr.s_addr = ((struct sockaddr_in *)addr)->sin_addr.s_addr;
331  mreqs.imr_interface.s_addr = INADDR_ANY;
332  mreqs.imr_sourceaddr.s_addr = ((struct sockaddr_in *)sourceaddr->ai_addr)->sin_addr.s_addr;
333  freeaddrinfo(sourceaddr);
334 
335  if (setsockopt(sockfd, IPPROTO_IP,
336  include ? IP_ADD_SOURCE_MEMBERSHIP : IP_BLOCK_SOURCE,
337  (const void *)&mreqs, sizeof(mreqs)) < 0) {
338  if (include)
339  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IP_ADD_SOURCE_MEMBERSHIP)");
340  else
341  log_net_error(NULL, AV_LOG_ERROR, "setsockopt(IP_BLOCK_SOURCE)");
342  return ff_neterrno();
343  }
344  }
345 #else
346  return AVERROR(ENOSYS);
347 #endif
348  return 0;
349 }
351  struct sockaddr_storage *addr,
352  const char *hostname, int port)
353 {
354  struct addrinfo *res0;
355  int addr_len;
356 
357  res0 = udp_resolve_host(h, hostname, port, SOCK_DGRAM, AF_UNSPEC, 0);
358  if (!res0) return AVERROR(EIO);
359  memcpy(addr, res0->ai_addr, res0->ai_addrlen);
360  addr_len = res0->ai_addrlen;
361  freeaddrinfo(res0);
362 
363  return addr_len;
364 }
365 
366 static int udp_socket_create(URLContext *h, struct sockaddr_storage *addr,
367  socklen_t *addr_len, const char *localaddr)
368 {
369  UDPContext *s = h->priv_data;
370  int udp_fd = -1;
371  struct addrinfo *res0, *res;
372  int family = AF_UNSPEC;
373 
374  if (((struct sockaddr *) &s->dest_addr)->sa_family)
375  family = ((struct sockaddr *) &s->dest_addr)->sa_family;
376  res0 = udp_resolve_host(h, (localaddr && localaddr[0]) ? localaddr : NULL,
377  s->local_port,
378  SOCK_DGRAM, family, AI_PASSIVE);
379  if (!res0)
380  goto fail;
381  for (res = res0; res; res=res->ai_next) {
382  if (s->udplite_coverage)
383  udp_fd = ff_socket(res->ai_family, SOCK_DGRAM, IPPROTO_UDPLITE);
384  else
385  udp_fd = ff_socket(res->ai_family, SOCK_DGRAM, 0);
386  if (udp_fd != -1) break;
387  log_net_error(NULL, AV_LOG_ERROR, "socket");
388  }
389 
390  if (udp_fd < 0)
391  goto fail;
392 
393  memcpy(addr, res->ai_addr, res->ai_addrlen);
394  *addr_len = res->ai_addrlen;
395 
396  freeaddrinfo(res0);
397 
398  return udp_fd;
399 
400  fail:
401  if (udp_fd >= 0)
402  closesocket(udp_fd);
403  if(res0)
404  freeaddrinfo(res0);
405  return -1;
406 }
407 
408 static int udp_port(struct sockaddr_storage *addr, int addr_len)
409 {
410  char sbuf[sizeof(int)*3+1];
411  int error;
412 
413  if ((error = getnameinfo((struct sockaddr *)addr, addr_len, NULL, 0, sbuf, sizeof(sbuf), NI_NUMERICSERV)) != 0) {
414  av_log(NULL, AV_LOG_ERROR, "getnameinfo: %s\n", gai_strerror(error));
415  return -1;
416  }
417 
418  return strtol(sbuf, NULL, 10);
419 }
420 
421 
422 /**
423  * If no filename is given to av_open_input_file because you want to
424  * get the local port first, then you must call this function to set
425  * the remote server address.
426  *
427  * url syntax: udp://host:port[?option=val...]
428  * option: 'ttl=n' : set the ttl value (for multicast only)
429  * 'localport=n' : set the local port
430  * 'pkt_size=n' : set max packet size
431  * 'reuse=1' : enable reusing the socket
432  * 'overrun_nonfatal=1': survive in case of circular buffer overrun
433  *
434  * @param h media file context
435  * @param uri of the remote server
436  * @return zero if no error.
437  */
438 int ff_udp_set_remote_url(URLContext *h, const char *uri)
439 {
440  UDPContext *s = h->priv_data;
441  char hostname[256], buf[10];
442  int port;
443  const char *p;
444 
445  av_url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &port, NULL, 0, uri);
446 
447  /* set the destination address */
448  s->dest_addr_len = udp_set_url(h, &s->dest_addr, hostname, port);
449  if (s->dest_addr_len < 0) {
450  return AVERROR(EIO);
451  }
452  s->is_multicast = ff_is_multicast_address((struct sockaddr*) &s->dest_addr);
453  p = strchr(uri, '?');
454  if (p) {
455  if (av_find_info_tag(buf, sizeof(buf), "connect", p)) {
456  int was_connected = s->is_connected;
457  s->is_connected = strtol(buf, NULL, 10);
458  if (s->is_connected && !was_connected) {
459  if (connect(s->udp_fd, (struct sockaddr *) &s->dest_addr,
460  s->dest_addr_len)) {
461  s->is_connected = 0;
462  log_net_error(h, AV_LOG_ERROR, "connect");
463  return AVERROR(EIO);
464  }
465  }
466  }
467  }
468 
469  return 0;
470 }
471 
472 /**
473  * Return the local port used by the UDP connection
474  * @param h media file context
475  * @return the local port number
476  */
478 {
479  UDPContext *s = h->priv_data;
480  return s->local_port;
481 }
482 
483 /**
484  * Return the udp file handle for select() usage to wait for several RTP
485  * streams at the same time.
486  * @param h media file context
487  */
489 {
490  UDPContext *s = h->priv_data;
491  return s->udp_fd;
492 }
493 
494 #if HAVE_PTHREAD_CANCEL
495 static void *circular_buffer_task_rx( void *_URLContext)
496 {
497  URLContext *h = _URLContext;
498  UDPContext *s = h->priv_data;
499  int old_cancelstate;
500 
501  pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate);
502  pthread_mutex_lock(&s->mutex);
503  if (ff_socket_nonblock(s->udp_fd, 0) < 0) {
504  av_log(h, AV_LOG_ERROR, "Failed to set blocking mode");
505  s->circular_buffer_error = AVERROR(EIO);
506  goto end;
507  }
508  while(1) {
509  int len;
510 
511  pthread_mutex_unlock(&s->mutex);
512  /* Blocking operations are always cancellation points;
513  see "General Information" / "Thread Cancelation Overview"
514  in Single Unix. */
515  pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &old_cancelstate);
516  len = recv(s->udp_fd, s->tmp+4, sizeof(s->tmp)-4, 0);
517  pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate);
518  pthread_mutex_lock(&s->mutex);
519  if (len < 0) {
520  if (ff_neterrno() != AVERROR(EAGAIN) && ff_neterrno() != AVERROR(EINTR)) {
522  goto end;
523  }
524  continue;
525  }
526  AV_WL32(s->tmp, len);
527 
528  if(av_fifo_space(s->fifo) < len + 4) {
529  /* No Space left */
530  if (s->overrun_nonfatal) {
531  av_log(h, AV_LOG_WARNING, "Circular buffer overrun. "
532  "Surviving due to overrun_nonfatal option\n");
533  continue;
534  } else {
535  av_log(h, AV_LOG_ERROR, "Circular buffer overrun. "
536  "To avoid, increase fifo_size URL option. "
537  "To survive in such case, use overrun_nonfatal option\n");
538  s->circular_buffer_error = AVERROR(EIO);
539  goto end;
540  }
541  }
542  av_fifo_generic_write(s->fifo, s->tmp, len+4, NULL);
543  pthread_cond_signal(&s->cond);
544  }
545 
546 end:
547  pthread_cond_signal(&s->cond);
548  pthread_mutex_unlock(&s->mutex);
549  return NULL;
550 }
551 
552 static void *circular_buffer_task_tx( void *_URLContext)
553 {
554  URLContext *h = _URLContext;
555  UDPContext *s = h->priv_data;
556  int old_cancelstate;
557  int64_t target_timestamp = av_gettime_relative();
558  int64_t start_timestamp = av_gettime_relative();
559  int64_t sent_bits = 0;
560  int64_t burst_interval = s->bitrate ? (s->burst_bits * 1000000 / s->bitrate) : 0;
561  int64_t max_delay = s->bitrate ? ((int64_t)h->max_packet_size * 8 * 1000000 / s->bitrate + 1) : 0;
562 
563  pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate);
564  pthread_mutex_lock(&s->mutex);
565 
566  if (ff_socket_nonblock(s->udp_fd, 0) < 0) {
567  av_log(h, AV_LOG_ERROR, "Failed to set blocking mode");
568  s->circular_buffer_error = AVERROR(EIO);
569  goto end;
570  }
571 
572  for(;;) {
573  int len;
574  const uint8_t *p;
575  uint8_t tmp[4];
576  int64_t timestamp;
577 
578  len=av_fifo_size(s->fifo);
579 
580  while (len<4) {
581  if (s->close_req)
582  goto end;
583  if (pthread_cond_wait(&s->cond, &s->mutex) < 0) {
584  goto end;
585  }
586  len=av_fifo_size(s->fifo);
587  }
588 
589  av_fifo_generic_read(s->fifo, tmp, 4, NULL);
590  len=AV_RL32(tmp);
591 
592  av_assert0(len >= 0);
593  av_assert0(len <= sizeof(s->tmp));
594 
595  av_fifo_generic_read(s->fifo, s->tmp, len, NULL);
596 
597  pthread_mutex_unlock(&s->mutex);
598  pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &old_cancelstate);
599 
600  if (s->bitrate) {
601  timestamp = av_gettime_relative();
602  if (timestamp < target_timestamp) {
603  int64_t delay = target_timestamp - timestamp;
604  if (delay > max_delay) {
605  delay = max_delay;
606  start_timestamp = timestamp + delay;
607  sent_bits = 0;
608  }
609  av_usleep(delay);
610  } else {
611  if (timestamp - burst_interval > target_timestamp) {
612  start_timestamp = timestamp - burst_interval;
613  sent_bits = 0;
614  }
615  }
616  sent_bits += len * 8;
617  target_timestamp = start_timestamp + sent_bits * 1000000 / s->bitrate;
618  }
619 
620  p = s->tmp;
621  while (len) {
622  int ret;
623  av_assert0(len > 0);
624  if (!s->is_connected) {
625  ret = sendto (s->udp_fd, p, len, 0,
626  (struct sockaddr *) &s->dest_addr,
627  s->dest_addr_len);
628  } else
629  ret = send(s->udp_fd, p, len, 0);
630  if (ret >= 0) {
631  len -= ret;
632  p += ret;
633  } else {
634  ret = ff_neterrno();
635  if (ret != AVERROR(EAGAIN) && ret != AVERROR(EINTR)) {
636  pthread_mutex_lock(&s->mutex);
637  s->circular_buffer_error = ret;
638  pthread_mutex_unlock(&s->mutex);
639  return NULL;
640  }
641  }
642  }
643 
644  pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate);
645  pthread_mutex_lock(&s->mutex);
646  }
647 
648 end:
649  pthread_mutex_unlock(&s->mutex);
650  return NULL;
651 }
652 
653 
654 #endif
655 
656 static int parse_source_list(char *buf, char **sources, int *num_sources,
657  int max_sources)
658 {
659  char *source_start;
660 
661  source_start = buf;
662  while (1) {
663  char *next = strchr(source_start, ',');
664  if (next)
665  *next = '\0';
666  sources[*num_sources] = av_strdup(source_start);
667  if (!sources[*num_sources])
668  return AVERROR(ENOMEM);
669  source_start = next + 1;
670  (*num_sources)++;
671  if (*num_sources >= max_sources || !next)
672  break;
673  }
674  return 0;
675 }
676 
677 /* put it in UDP context */
678 /* return non zero if error */
679 static int udp_open(URLContext *h, const char *uri, int flags)
680 {
681  char hostname[1024], localaddr[1024] = "";
682  int port, udp_fd = -1, tmp, bind_ret = -1, dscp = -1;
683  UDPContext *s = h->priv_data;
684  int is_output;
685  const char *p;
686  char buf[256];
687  struct sockaddr_storage my_addr;
688  socklen_t len;
689  int i, num_include_sources = 0, num_exclude_sources = 0;
690  char *include_sources[32], *exclude_sources[32];
691 
692  h->is_streamed = 1;
693 
694  is_output = !(flags & AVIO_FLAG_READ);
695  if (s->buffer_size < 0)
696  s->buffer_size = is_output ? UDP_TX_BUF_SIZE : UDP_MAX_PKT_SIZE;
697 
698  if (s->sources) {
699  if (parse_source_list(s->sources, include_sources,
700  &num_include_sources,
701  FF_ARRAY_ELEMS(include_sources)))
702  goto fail;
703  }
704 
705  if (s->block) {
706  if (parse_source_list(s->block, exclude_sources, &num_exclude_sources,
707  FF_ARRAY_ELEMS(exclude_sources)))
708  goto fail;
709  }
710 
711  if (s->pkt_size > 0)
712  h->max_packet_size = s->pkt_size;
713 
714  p = strchr(uri, '?');
715  if (p) {
716  if (av_find_info_tag(buf, sizeof(buf), "reuse", p)) {
717  char *endptr = NULL;
718  s->reuse_socket = strtol(buf, &endptr, 10);
719  /* assume if no digits were found it is a request to enable it */
720  if (buf == endptr)
721  s->reuse_socket = 1;
722  }
723  if (av_find_info_tag(buf, sizeof(buf), "overrun_nonfatal", p)) {
724  char *endptr = NULL;
725  s->overrun_nonfatal = strtol(buf, &endptr, 10);
726  /* assume if no digits were found it is a request to enable it */
727  if (buf == endptr)
728  s->overrun_nonfatal = 1;
729  if (!HAVE_PTHREAD_CANCEL)
731  "'overrun_nonfatal' option was set but it is not supported "
732  "on this build (pthread support is required)\n");
733  }
734  if (av_find_info_tag(buf, sizeof(buf), "ttl", p)) {
735  s->ttl = strtol(buf, NULL, 10);
736  }
737  if (av_find_info_tag(buf, sizeof(buf), "udplite_coverage", p)) {
738  s->udplite_coverage = strtol(buf, NULL, 10);
739  }
740  if (av_find_info_tag(buf, sizeof(buf), "localport", p)) {
741  s->local_port = strtol(buf, NULL, 10);
742  }
743  if (av_find_info_tag(buf, sizeof(buf), "pkt_size", p)) {
744  s->pkt_size = strtol(buf, NULL, 10);
745  }
746  if (av_find_info_tag(buf, sizeof(buf), "buffer_size", p)) {
747  s->buffer_size = strtol(buf, NULL, 10);
748  }
749  if (av_find_info_tag(buf, sizeof(buf), "connect", p)) {
750  s->is_connected = strtol(buf, NULL, 10);
751  }
752  if (av_find_info_tag(buf, sizeof(buf), "dscp", p)) {
753  dscp = strtol(buf, NULL, 10);
754  }
755  if (av_find_info_tag(buf, sizeof(buf), "fifo_size", p)) {
756  s->circular_buffer_size = strtol(buf, NULL, 10);
757  if (!HAVE_PTHREAD_CANCEL)
759  "'circular_buffer_size' option was set but it is not supported "
760  "on this build (pthread support is required)\n");
761  }
762  if (av_find_info_tag(buf, sizeof(buf), "bitrate", p)) {
763  s->bitrate = strtoll(buf, NULL, 10);
764  if (!HAVE_PTHREAD_CANCEL)
766  "'bitrate' option was set but it is not supported "
767  "on this build (pthread support is required)\n");
768  }
769  if (av_find_info_tag(buf, sizeof(buf), "burst_bits", p)) {
770  s->burst_bits = strtoll(buf, NULL, 10);
771  }
772  if (av_find_info_tag(buf, sizeof(buf), "localaddr", p)) {
773  av_strlcpy(localaddr, buf, sizeof(localaddr));
774  }
775  if (av_find_info_tag(buf, sizeof(buf), "sources", p)) {
776  if (parse_source_list(buf, include_sources, &num_include_sources,
777  FF_ARRAY_ELEMS(include_sources)))
778  goto fail;
779  }
780  if (av_find_info_tag(buf, sizeof(buf), "block", p)) {
781  if (parse_source_list(buf, exclude_sources, &num_exclude_sources,
782  FF_ARRAY_ELEMS(exclude_sources)))
783  goto fail;
784  }
785  if (!is_output && av_find_info_tag(buf, sizeof(buf), "timeout", p))
786  s->timeout = strtol(buf, NULL, 10);
787  if (is_output && av_find_info_tag(buf, sizeof(buf), "broadcast", p))
788  s->is_broadcast = strtol(buf, NULL, 10);
789  }
790  /* handling needed to support options picking from both AVOption and URL */
791  s->circular_buffer_size *= 188;
792  if (flags & AVIO_FLAG_WRITE) {
793  h->max_packet_size = s->pkt_size;
794  } else {
796  }
797  h->rw_timeout = s->timeout;
798 
799  /* fill the dest addr */
800  av_url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &port, NULL, 0, uri);
801 
802  /* XXX: fix av_url_split */
803  if (hostname[0] == '\0' || hostname[0] == '?') {
804  /* only accepts null hostname if input */
805  if (!(flags & AVIO_FLAG_READ))
806  goto fail;
807  } else {
808  if (ff_udp_set_remote_url(h, uri) < 0)
809  goto fail;
810  }
811 
812  if ((s->is_multicast || s->local_port <= 0) && (h->flags & AVIO_FLAG_READ))
813  s->local_port = port;
814 
815  if (localaddr[0])
816  udp_fd = udp_socket_create(h, &my_addr, &len, localaddr);
817  else
818  udp_fd = udp_socket_create(h, &my_addr, &len, s->localaddr);
819  if (udp_fd < 0)
820  goto fail;
821 
822  s->local_addr_storage=my_addr; //store for future multicast join
823 
824  /* Follow the requested reuse option, unless it's multicast in which
825  * case enable reuse unless explicitly disabled.
826  */
827  if (s->reuse_socket > 0 || (s->is_multicast && s->reuse_socket < 0)) {
828  s->reuse_socket = 1;
829  if (setsockopt (udp_fd, SOL_SOCKET, SO_REUSEADDR, &(s->reuse_socket), sizeof(s->reuse_socket)) != 0)
830  goto fail;
831  }
832 
833  if (s->is_broadcast) {
834 #ifdef SO_BROADCAST
835  if (setsockopt (udp_fd, SOL_SOCKET, SO_BROADCAST, &(s->is_broadcast), sizeof(s->is_broadcast)) != 0)
836 #endif
837  goto fail;
838  }
839 
840  /* Set the checksum coverage for UDP-Lite (RFC 3828) for sending and receiving.
841  * The receiver coverage has to be less than or equal to the sender coverage.
842  * Otherwise, the receiver will drop all packets.
843  */
844  if (s->udplite_coverage) {
845  if (setsockopt (udp_fd, IPPROTO_UDPLITE, UDPLITE_SEND_CSCOV, &(s->udplite_coverage), sizeof(s->udplite_coverage)) != 0)
846  av_log(h, AV_LOG_WARNING, "socket option UDPLITE_SEND_CSCOV not available");
847 
848  if (setsockopt (udp_fd, IPPROTO_UDPLITE, UDPLITE_RECV_CSCOV, &(s->udplite_coverage), sizeof(s->udplite_coverage)) != 0)
849  av_log(h, AV_LOG_WARNING, "socket option UDPLITE_RECV_CSCOV not available");
850  }
851 
852  if (dscp >= 0) {
853  dscp <<= 2;
854  if (setsockopt (udp_fd, IPPROTO_IP, IP_TOS, &dscp, sizeof(dscp)) != 0)
855  goto fail;
856  }
857 
858  /* If multicast, try binding the multicast address first, to avoid
859  * receiving UDP packets from other sources aimed at the same UDP
860  * port. This fails on windows. This makes sending to the same address
861  * using sendto() fail, so only do it if we're opened in read-only mode. */
862  if (s->is_multicast && !(h->flags & AVIO_FLAG_WRITE)) {
863  bind_ret = bind(udp_fd,(struct sockaddr *)&s->dest_addr, len);
864  }
865  /* bind to the local address if not multicast or if the multicast
866  * bind failed */
867  /* the bind is needed to give a port to the socket now */
868  if (bind_ret < 0 && bind(udp_fd,(struct sockaddr *)&my_addr, len) < 0) {
869  log_net_error(h, AV_LOG_ERROR, "bind failed");
870  goto fail;
871  }
872 
873  len = sizeof(my_addr);
874  getsockname(udp_fd, (struct sockaddr *)&my_addr, &len);
875  s->local_port = udp_port(&my_addr, len);
876 
877  if (s->is_multicast) {
878  if (h->flags & AVIO_FLAG_WRITE) {
879  /* output */
880  if (udp_set_multicast_ttl(udp_fd, s->ttl, (struct sockaddr *)&s->dest_addr) < 0)
881  goto fail;
882  }
883  if (h->flags & AVIO_FLAG_READ) {
884  /* input */
885  if (num_include_sources && num_exclude_sources) {
886  av_log(h, AV_LOG_ERROR, "Simultaneously including and excluding multicast sources is not supported\n");
887  goto fail;
888  }
889  if (num_include_sources) {
890  if (udp_set_multicast_sources(h, udp_fd,
891  (struct sockaddr *)&s->dest_addr,
892  s->dest_addr_len,
893  include_sources,
894  num_include_sources, 1) < 0)
895  goto fail;
896  } else {
897  if (udp_join_multicast_group(udp_fd, (struct sockaddr *)&s->dest_addr,(struct sockaddr *)&s->local_addr_storage) < 0)
898  goto fail;
899  }
900  if (num_exclude_sources) {
901  if (udp_set_multicast_sources(h, udp_fd,
902  (struct sockaddr *)&s->dest_addr,
903  s->dest_addr_len,
904  exclude_sources,
905  num_exclude_sources, 0) < 0)
906  goto fail;
907  }
908  }
909  }
910 
911  if (is_output) {
912  /* limit the tx buf size to limit latency */
913  tmp = s->buffer_size;
914  if (setsockopt(udp_fd, SOL_SOCKET, SO_SNDBUF, &tmp, sizeof(tmp)) < 0) {
915  log_net_error(h, AV_LOG_ERROR, "setsockopt(SO_SNDBUF)");
916  goto fail;
917  }
918  } else {
919  /* set udp recv buffer size to the requested value (default 64K) */
920  tmp = s->buffer_size;
921  if (setsockopt(udp_fd, SOL_SOCKET, SO_RCVBUF, &tmp, sizeof(tmp)) < 0) {
922  log_net_error(h, AV_LOG_WARNING, "setsockopt(SO_RECVBUF)");
923  }
924  len = sizeof(tmp);
925  if (getsockopt(udp_fd, SOL_SOCKET, SO_RCVBUF, &tmp, &len) < 0) {
926  log_net_error(h, AV_LOG_WARNING, "getsockopt(SO_RCVBUF)");
927  } else {
928  av_log(h, AV_LOG_DEBUG, "end receive buffer size reported is %d\n", tmp);
929  if(tmp < s->buffer_size)
930  av_log(h, AV_LOG_WARNING, "attempted to set receive buffer to size %d but it only ended up set as %d", s->buffer_size, tmp);
931  }
932 
933  /* make the socket non-blocking */
934  ff_socket_nonblock(udp_fd, 1);
935  }
936  if (s->is_connected) {
937  if (connect(udp_fd, (struct sockaddr *) &s->dest_addr, s->dest_addr_len)) {
938  log_net_error(h, AV_LOG_ERROR, "connect");
939  goto fail;
940  }
941  }
942 
943  for (i = 0; i < num_include_sources; i++)
944  av_freep(&include_sources[i]);
945  for (i = 0; i < num_exclude_sources; i++)
946  av_freep(&exclude_sources[i]);
947 
948  s->udp_fd = udp_fd;
949 
950 #if HAVE_PTHREAD_CANCEL
951  /*
952  Create thread in case of:
953  1. Input and circular_buffer_size is set
954  2. Output and bitrate and circular_buffer_size is set
955  */
956 
957  if (is_output && s->bitrate && !s->circular_buffer_size) {
958  /* Warn user in case of 'circular_buffer_size' is not set */
959  av_log(h, AV_LOG_WARNING,"'bitrate' option was set but 'circular_buffer_size' is not, but required\n");
960  }
961 
962  if ((!is_output && s->circular_buffer_size) || (is_output && s->bitrate && s->circular_buffer_size)) {
963  int ret;
964 
965  /* start the task going */
967  ret = pthread_mutex_init(&s->mutex, NULL);
968  if (ret != 0) {
969  av_log(h, AV_LOG_ERROR, "pthread_mutex_init failed : %s\n", strerror(ret));
970  goto fail;
971  }
972  ret = pthread_cond_init(&s->cond, NULL);
973  if (ret != 0) {
974  av_log(h, AV_LOG_ERROR, "pthread_cond_init failed : %s\n", strerror(ret));
975  goto cond_fail;
976  }
977  ret = pthread_create(&s->circular_buffer_thread, NULL, is_output?circular_buffer_task_tx:circular_buffer_task_rx, h);
978  if (ret != 0) {
979  av_log(h, AV_LOG_ERROR, "pthread_create failed : %s\n", strerror(ret));
980  goto thread_fail;
981  }
982  s->thread_started = 1;
983  }
984 #endif
985 
986  return 0;
987 #if HAVE_PTHREAD_CANCEL
988  thread_fail:
989  pthread_cond_destroy(&s->cond);
990  cond_fail:
991  pthread_mutex_destroy(&s->mutex);
992 #endif
993  fail:
994  if (udp_fd >= 0)
995  closesocket(udp_fd);
996  av_fifo_freep(&s->fifo);
997  for (i = 0; i < num_include_sources; i++)
998  av_freep(&include_sources[i]);
999  for (i = 0; i < num_exclude_sources; i++)
1000  av_freep(&exclude_sources[i]);
1001  return AVERROR(EIO);
1002 }
1003 
1004 static int udplite_open(URLContext *h, const char *uri, int flags)
1005 {
1006  UDPContext *s = h->priv_data;
1007 
1008  // set default checksum coverage
1010 
1011  return udp_open(h, uri, flags);
1012 }
1013 
1014 static int udp_read(URLContext *h, uint8_t *buf, int size)
1015 {
1016  UDPContext *s = h->priv_data;
1017  int ret;
1018 #if HAVE_PTHREAD_CANCEL
1019  int avail, nonblock = h->flags & AVIO_FLAG_NONBLOCK;
1020 
1021  if (s->fifo) {
1022  pthread_mutex_lock(&s->mutex);
1023  do {
1024  avail = av_fifo_size(s->fifo);
1025  if (avail) { // >=size) {
1026  uint8_t tmp[4];
1027 
1028  av_fifo_generic_read(s->fifo, tmp, 4, NULL);
1029  avail= AV_RL32(tmp);
1030  if(avail > size){
1031  av_log(h, AV_LOG_WARNING, "Part of datagram lost due to insufficient buffer size\n");
1032  avail= size;
1033  }
1034 
1035  av_fifo_generic_read(s->fifo, buf, avail, NULL);
1036  av_fifo_drain(s->fifo, AV_RL32(tmp) - avail);
1037  pthread_mutex_unlock(&s->mutex);
1038  return avail;
1039  } else if(s->circular_buffer_error){
1040  int err = s->circular_buffer_error;
1041  pthread_mutex_unlock(&s->mutex);
1042  return err;
1043  } else if(nonblock) {
1044  pthread_mutex_unlock(&s->mutex);
1045  return AVERROR(EAGAIN);
1046  }
1047  else {
1048  /* FIXME: using the monotonic clock would be better,
1049  but it does not exist on all supported platforms. */
1050  int64_t t = av_gettime() + 100000;
1051  struct timespec tv = { .tv_sec = t / 1000000,
1052  .tv_nsec = (t % 1000000) * 1000 };
1053  if (pthread_cond_timedwait(&s->cond, &s->mutex, &tv) < 0) {
1054  pthread_mutex_unlock(&s->mutex);
1055  return AVERROR(errno == ETIMEDOUT ? EAGAIN : errno);
1056  }
1057  nonblock = 1;
1058  }
1059  } while( 1);
1060  }
1061 #endif
1062 
1063  if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
1064  ret = ff_network_wait_fd(s->udp_fd, 0);
1065  if (ret < 0)
1066  return ret;
1067  }
1068  ret = recv(s->udp_fd, buf, size, 0);
1069 
1070  return ret < 0 ? ff_neterrno() : ret;
1071 }
1072 
1073 static int udp_write(URLContext *h, const uint8_t *buf, int size)
1074 {
1075  UDPContext *s = h->priv_data;
1076  int ret;
1077 
1078 #if HAVE_PTHREAD_CANCEL
1079  if (s->fifo) {
1080  uint8_t tmp[4];
1081 
1082  pthread_mutex_lock(&s->mutex);
1083 
1084  /*
1085  Return error if last tx failed.
1086  Here we can't know on which packet error was, but it needs to know that error exists.
1087  */
1088  if (s->circular_buffer_error<0) {
1089  int err=s->circular_buffer_error;
1090  pthread_mutex_unlock(&s->mutex);
1091  return err;
1092  }
1093 
1094  if(av_fifo_space(s->fifo) < size + 4) {
1095  /* What about a partial packet tx ? */
1096  pthread_mutex_unlock(&s->mutex);
1097  return AVERROR(ENOMEM);
1098  }
1099  AV_WL32(tmp, size);
1100  av_fifo_generic_write(s->fifo, tmp, 4, NULL); /* size of packet */
1101  av_fifo_generic_write(s->fifo, (uint8_t *)buf, size, NULL); /* the data */
1102  pthread_cond_signal(&s->cond);
1103  pthread_mutex_unlock(&s->mutex);
1104  return size;
1105  }
1106 #endif
1107  if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
1108  ret = ff_network_wait_fd(s->udp_fd, 1);
1109  if (ret < 0)
1110  return ret;
1111  }
1112 
1113  if (!s->is_connected) {
1114  ret = sendto (s->udp_fd, buf, size, 0,
1115  (struct sockaddr *) &s->dest_addr,
1116  s->dest_addr_len);
1117  } else
1118  ret = send(s->udp_fd, buf, size, 0);
1119 
1120  return ret < 0 ? ff_neterrno() : ret;
1121 }
1122 
1123 static int udp_close(URLContext *h)
1124 {
1125  UDPContext *s = h->priv_data;
1126 
1127 #if HAVE_PTHREAD_CANCEL
1128  // Request close once writing is finished
1129  if (s->thread_started && !(h->flags & AVIO_FLAG_READ)) {
1130  pthread_mutex_lock(&s->mutex);
1131  s->close_req = 1;
1132  pthread_cond_signal(&s->cond);
1133  pthread_mutex_unlock(&s->mutex);
1134  }
1135 #endif
1136 
1137  if (s->is_multicast && (h->flags & AVIO_FLAG_READ))
1138  udp_leave_multicast_group(s->udp_fd, (struct sockaddr *)&s->dest_addr,(struct sockaddr *)&s->local_addr_storage);
1139 #if HAVE_PTHREAD_CANCEL
1140  if (s->thread_started) {
1141  int ret;
1142  // Cancel only read, as write has been signaled as success to the user
1143  if (h->flags & AVIO_FLAG_READ)
1144  pthread_cancel(s->circular_buffer_thread);
1145  ret = pthread_join(s->circular_buffer_thread, NULL);
1146  if (ret != 0)
1147  av_log(h, AV_LOG_ERROR, "pthread_join(): %s\n", strerror(ret));
1148  pthread_mutex_destroy(&s->mutex);
1149  pthread_cond_destroy(&s->cond);
1150  }
1151 #endif
1152  closesocket(s->udp_fd);
1153  av_fifo_freep(&s->fifo);
1154  return 0;
1155 }
1156 
1158  .name = "udp",
1159  .url_open = udp_open,
1160  .url_read = udp_read,
1161  .url_write = udp_write,
1162  .url_close = udp_close,
1163  .url_get_file_handle = udp_get_file_handle,
1164  .priv_data_size = sizeof(UDPContext),
1165  .priv_data_class = &udp_class,
1167 };
1168 
1170  .name = "udplite",
1171  .url_open = udplite_open,
1172  .url_read = udp_read,
1173  .url_write = udp_write,
1174  .url_close = udp_close,
1175  .url_get_file_handle = udp_get_file_handle,
1176  .priv_data_size = sizeof(UDPContext),
1177  .priv_data_class = &udplite_context_class,
1179 };
static int udp_open(URLContext *h, const char *uri, int flags)
Definition: udp.c:679
void av_url_split(char *proto, int proto_size, char *authorization, int authorization_size, char *hostname, int hostname_size, int *port_ptr, char *path, int path_size, const char *url)
Split a URL string into components.
Definition: utils.c:4384
#define NULL
Definition: coverity.c:32
static int udp_set_multicast_sources(URLContext *h, int sockfd, struct sockaddr *addr, int addr_len, char **sources, int nb_sources, int include)
Definition: udp.c:276
static const AVClass udplite_context_class
Definition: udp.c:146
const char * s
Definition: avisynth_c.h:768
static void log_net_error(void *ctx, int level, const char *prefix)
Definition: udp.c:153
static av_always_inline int pthread_mutex_destroy(pthread_mutex_t *mutex)
Definition: os2threads.h:106
#define URL_PROTOCOL_FLAG_NETWORK
Definition: url.h:34
#define NI_NUMERICSERV
Definition: network.h:193
#define HAVE_PTHREAD_CANCEL
Definition: udp.c:64
static av_always_inline int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
Definition: os2threads.h:164
AVOption.
Definition: opt.h:245
#define AV_LOG_WARNING
Something somehow does not look correct.
Definition: log.h:182
#define LIBAVUTIL_VERSION_INT
Definition: version.h:70
const URLProtocol ff_udplite_protocol
Definition: udp.c:1169
char * block
Definition: udp.c:111
int is_streamed
true if streamed (no seek possible), default = false
Definition: url.h:45
static int parse_source_list(char *buf, char **sources, int *num_sources, int max_sources)
Definition: udp.c:656
#define AVIO_FLAG_READ
read-only
Definition: avio.h:606
int64_t rw_timeout
maximum time to wait for (network) read/write operation completion, in mcs
Definition: url.h:48
static int udp_set_url(URLContext *h, struct sockaddr_storage *addr, const char *hostname, int port)
Definition: udp.c:350
#define AVIO_FLAG_WRITE
write-only
Definition: avio.h:607
#define AI_PASSIVE
Definition: network.h:169
#define UDPLITE_SEND_CSCOV
Definition: udp.c:51
#define IPPROTO_UDPLITE
Definition: udp.c:56
int flags
Definition: url.h:43
int udplite_coverage
Definition: udp.c:80
#define freeaddrinfo
Definition: network.h:208
int av_usleep(unsigned usec)
Sleep for a period of time.
Definition: time.c:76
static av_always_inline int pthread_cond_destroy(pthread_cond_t *cond)
Definition: os2threads.h:138
int av_fifo_generic_write(AVFifoBuffer *f, void *src, int size, int(*func)(void *, void *, int))
Feed data from a user-supplied callback to an AVFifoBuffer.
Definition: fifo.c:122
int ff_socket(int af, int type, int proto)
Definition: network.c:166
int64_t bitrate
Definition: udp.c:96
static int16_t block[64]
Definition: dct.c:113
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Definition: log.h:72
#define av_assert0(cond)
assert() equivalent, that is always enabled.
Definition: avassert.h:37
#define UDPLITE_RECV_CSCOV
Definition: udp.c:52
HMTX pthread_mutex_t
Definition: os2threads.h:49
uint8_t
AVOptions.
miscellaneous OS support macros and functions.
int ff_udp_get_local_port(URLContext *h)
Return the local port used by the UDP connection.
Definition: udp.c:477
static av_cold int end(AVCodecContext *avctx)
Definition: avrndec.c:90
int av_fifo_space(const AVFifoBuffer *f)
Return the amount of space in bytes in the AVFifoBuffer, that is the amount of data you can write int...
Definition: fifo.c:82
int is_broadcast
Definition: udp.c:84
static int udp_leave_multicast_group(int sockfd, struct sockaddr *addr, struct sockaddr *local_addr)
Definition: udp.c:214
#define UDP_HEADER_SIZE
Definition: udp.c:74
static int udp_port(struct sockaddr_storage *addr, int addr_len)
Definition: udp.c:408
int av_find_info_tag(char *arg, int arg_size, const char *tag1, const char *info)
Attempt to find a specific tag in a URL.
Definition: parseutils.c:705
static av_always_inline int pthread_cond_signal(pthread_cond_t *cond)
Definition: os2threads.h:146
ptrdiff_t size
Definition: opengl_enc.c:101
static int udp_close(URLContext *h)
Definition: udp.c:1123
#define av_log(a,...)
int circular_buffer_size
Definition: udp.c:93
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
Definition: log.h:176
int ff_udp_set_remote_url(URLContext *h, const char *uri)
If no filename is given to av_open_input_file because you want to get the local port first...
Definition: udp.c:438
av_default_item_name
#define closesocket
Definition: ffserver.c:28
#define AVERROR(e)
Definition: error.h:43
#define E
Definition: udp.c:116
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
Definition: log.h:197
int av_fifo_generic_read(AVFifoBuffer *f, void *dest, int buf_size, void(*func)(void *, void *, int))
Feed data from an AVFifoBuffer to a user-supplied callback.
Definition: fifo.c:213
int reuse_socket
Definition: udp.c:86
#define UDP_TX_BUF_SIZE
Definition: udp.c:72
simple assert() macros that are a bit more flexible than ISO C assert().
#define D
Definition: udp.c:115
static struct addrinfo * udp_resolve_host(URLContext *h, const char *hostname, int port, int type, int family, int flags)
Definition: udp.c:246
int dest_addr_len
Definition: udp.c:89
static int max_delay(struct NCSofa *sofa)
Definition: af_sofalizer.c:507
int ff_is_multicast_address(struct sockaddr *addr)
Definition: network.c:131
size_t av_strlcpy(char *dst, const char *src, size_t size)
Copy the string src to dst, but no more than size - 1 bytes, and null-terminate dst.
Definition: avstring.c:83
#define fail()
Definition: checkasm.h:82
int timeout
Definition: udp.c:108
#define OFFSET(x)
Definition: udp.c:114
char * localaddr
Definition: udp.c:107
int ai_addrlen
Definition: network.h:132
static const AVOption options[]
Definition: udp.c:117
uint8_t tmp[UDP_MAX_PKT_SIZE+4]
Definition: udp.c:105
#define ff_neterrno()
Definition: network.h:64
AVFormatContext * ctx
Definition: movenc.c:48
int overrun_nonfatal
Definition: udp.c:87
static av_always_inline int pthread_join(pthread_t thread, void **value_ptr)
Definition: os2threads.h:88
static av_always_inline int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr)
Definition: os2threads.h:98
static int udp_get_file_handle(URLContext *h)
Return the udp file handle for select() usage to wait for several RTP streams at the same time...
Definition: udp.c:488
int is_connected
Definition: udp.c:90
struct sockaddr_storage local_addr_storage
Definition: udp.c:109
static pthread_mutex_t * mutex
Definition: w32pthreads.h:258
Definition: udp.c:76
int ff_socket_nonblock(int socket, int enable)
int64_t burst_bits
Definition: udp.c:97
#define FF_ARRAY_ELEMS(a)
int ttl
Definition: udp.c:79
int64_t av_gettime(void)
Get the current time in microseconds.
Definition: time.c:39
static av_always_inline int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
Definition: os2threads.h:74
#define IPV6_ADD_MEMBERSHIP
Definition: udp.c:68
char * av_strdup(const char *s)
Duplicate a string.
Definition: mem.c:267
int av_fifo_size(const AVFifoBuffer *f)
Return the amount of data in bytes in the AVFifoBuffer, that is the amount of data you can read from ...
Definition: fifo.c:77
#define AVIO_FLAG_NONBLOCK
Use non-blocking mode.
Definition: avio.h:625
int local_port
Definition: udp.c:85
int pkt_size
Definition: udp.c:82
#define IPV6_DROP_MEMBERSHIP
Definition: udp.c:69
a very simple circular buffer FIFO implementation
void * buf
Definition: avisynth_c.h:690
Definition: url.h:38
GLint GLenum type
Definition: opengl_enc.c:105
Describe the class of an AVClass context structure.
Definition: log.h:67
char * sources
Definition: udp.c:110
void * priv_data
Definition: url.h:41
#define gai_strerror
Definition: network.h:215
AVFifoBuffer * fifo
Definition: udp.c:94
#define snprintf
Definition: snprintf.h:34
misc parsing utilities
const char * name
Definition: url.h:54
int ai_socktype
Definition: network.h:130
int64_t av_gettime_relative(void)
Get the current time in microseconds since some unspecified starting point.
Definition: time.c:56
static int flags
Definition: cpu.c:47
uint8_t level
Definition: svq3.c:206
int av_strerror(int errnum, char *errbuf, size_t errbuf_size)
Put a description of the AVERROR code errnum in errbuf.
Definition: error.c:105
#define getaddrinfo
Definition: network.h:207
Main libavformat public API header.
struct sockaddr_storage dest_addr
Definition: udp.c:88
static int udp_read(URLContext *h, uint8_t *buf, int size)
Definition: udp.c:1014
int remaining_in_dg
Definition: udp.c:106
struct addrinfo * ai_next
Definition: network.h:135
static av_always_inline int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr)
Definition: os2threads.h:127
static int udp_set_multicast_ttl(int sockfd, int mcastTTL, struct sockaddr *addr)
Definition: udp.c:160
int udp_fd
Definition: udp.c:78
#define getnameinfo
Definition: network.h:209
AVFifoBuffer * av_fifo_alloc(unsigned int size)
Initialize an AVFifoBuffer.
Definition: fifo.c:43
static int udplite_open(URLContext *h, const char *uri, int flags)
Definition: udp.c:1004
int len
static int udp_join_multicast_group(int sockfd, struct sockaddr *addr, struct sockaddr *local_addr)
Definition: udp.c:182
int circular_buffer_error
Definition: udp.c:95
static av_always_inline int pthread_mutex_unlock(pthread_mutex_t *mutex)
Definition: os2threads.h:120
static uint8_t tmp[8]
Definition: des.c:38
int close_req
Definition: udp.c:98
int buffer_size
Definition: udp.c:81
static int udp_socket_create(URLContext *h, struct sockaddr_storage *addr, socklen_t *addr_len, const char *localaddr)
Definition: udp.c:366
int is_multicast
Definition: udp.c:83
int ai_flags
Definition: network.h:128
int max_packet_size
if non zero, the stream is packetized with this max packet size
Definition: url.h:44
static const AVClass udp_class
Definition: udp.c:139
#define UDP_MAX_PKT_SIZE
Definition: udp.c:73
#define av_freep(p)
int ff_network_wait_fd(int fd, int write)
Definition: network.c:73
unbuffered private I/O API
void av_fifo_freep(AVFifoBuffer **f)
Free an AVFifoBuffer and reset pointer to NULL.
Definition: fifo.c:63
static av_always_inline int pthread_mutex_lock(pthread_mutex_t *mutex)
Definition: os2threads.h:113
void av_fifo_drain(AVFifoBuffer *f, int size)
Discard data from the FIFO.
Definition: fifo.c:233
struct sockaddr * ai_addr
Definition: network.h:133
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_RL32
Definition: bytestream.h:87
static int udp_write(URLContext *h, const uint8_t *buf, int size)
Definition: udp.c:1073
#define AV_WL32(p, v)
Definition: intreadwrite.h:426
const URLProtocol ff_udp_protocol
Definition: udp.c:1157
int ai_family
Definition: network.h:129