libavformat.hg: udp.c comparison

comparison udp.c @ 885:da1d5db0ce5c libavformat

COSMETICS: Remove all trailing whitespace.

author	diego
date	Sat, 17 Dec 2005 18:14:38 +0000
parents	2ad855f5a156
children	edbe5c3717f9

comparison

equal deleted inserted replaced

-:2ece9c9dd94c
+:da1d5db0ce5c
 #ifdef CONFIG_IPV6
 int udp_ipv6_is_multicast_address(const struct sockaddr *addr) {
 if (addr->sa_family == AF_INET)
 return IN_MULTICAST(ntohl(((struct sockaddr_in *)addr)->sin_addr.s_addr));
 if (addr->sa_family == AF_INET6)
 return IN6_IS_ADDR_MULTICAST(&((struct sockaddr_in6 *)addr)->sin6_addr);
 return -1;
 }
 int udp_ipv6_set_multicast_ttl(int sockfd, int mcastTTL, struct sockaddr *addr) {
 if (addr->sa_family == AF_INET) {
 return 0;
 }
 int udp_ipv6_join_multicast_group(int sockfd, struct sockaddr *addr) {
 struct ip_mreq   mreq;
 struct ipv6_mreq mreq6;
 if (addr->sa_family == AF_INET) {
 mreq.imr_multiaddr.s_addr = ((struct sockaddr_in *)addr)->sin_addr.s_addr;
 mreq.imr_interface.s_addr= INADDR_ANY;
 if (setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, (const void *)&mreq, sizeof(mreq)) < 0) {
 perror("setsockopt(IP_ADD_MEMBERSHIP)");
 return 0;
 }
 int udp_ipv6_leave_multicast_group(int sockfd, struct sockaddr *addr) {
 struct ip_mreq   mreq;
 struct ipv6_mreq mreq6;
 if (addr->sa_family == AF_INET) {
 mreq.imr_multiaddr.s_addr = ((struct sockaddr_in *)addr)->sin_addr.s_addr;
 mreq.imr_interface.s_addr= INADDR_ANY;
 if (setsockopt(sockfd, IPPROTO_IP, IP_DROP_MEMBERSHIP, (const void *)&mreq, sizeof(mreq)) < 0) {
 perror("setsockopt(IP_DROP_MEMBERSHIP)");
 }
 if ((node) || (service)) {
 memset(&hints, 0, sizeof(hints));
 hints.ai_socktype = type;
 hints.ai_family   = family;
 hints.ai_flags = flags;
 if ((error = getaddrinfo(node, service, &hints, &res))) {
 av_log(NULL, AV_LOG_ERROR, "udp_ipv6_resolve_host: %s\n", gai_strerror(error));
 }
 }
 return res;
 struct sockaddr_storage clientaddr;
 socklen_t addrlen;
 char sbuf[NI_MAXSERV];
 char hbuf[NI_MAXHOST];
 struct addrinfo *res0 = NULL, *res = NULL;
 if (s->local_port != 0) {
 res0 = udp_ipv6_resolve_host(0, s->local_port, SOCK_DGRAM, AF_UNSPEC, AI_PASSIVE);
 if (res0 == 0)
 goto fail;
 for (res = res0; res; res=res->ai_next) {
 udp_fd = socket(res->ai_family, SOCK_DGRAM, 0);
 if (udp_fd > 0) break;
 perror("socket");
 }
 } else {
 udp_fd = socket(s->dest_addr.ss_family, SOCK_DGRAM, 0);
 if (udp_fd < 0)
 perror("socket");
 }
 if (udp_fd < 0)
 goto fail;
 if (s->local_port != 0) {
 if (bind(udp_fd, res0->ai_addr, res0->ai_addrlen) < 0) {
 perror("bind");
 goto fail;
 }
 freeaddrinfo(res0);
 res0 = NULL;
 }
 addrlen = sizeof(clientaddr);
 if (getsockname(udp_fd, (struct sockaddr *)&clientaddr, &addrlen) < 0) {
 perror("getsockname");
 goto fail;
 perror("getnameinfo");
 goto fail;
 }
 s->local_port = strtol(sbuf, NULL, 10);
 return udp_fd;
 fail:
 if (udp_fd >= 0)
 #ifdef CONFIG_BEOS_NETSERVER
 closesocket(udp_fd);
 #else
 * If no filename is given to av_open_input_file because you want to
 * get the local port first, then you must call this function to set
 * the remote server address.
 *
 * url syntax: udp://host:port[?option=val...]
 * option: 'multicast=1' : enable multicast
 *         'ttl=n'       : set the ttl value (for multicast only)
 *         'localport=n' : set the local port
 *         'pkt_size=n'  : set max packet size
 *
 * @param s1 media file context
 return udp_ipv6_set_remote_url(h, uri);
 #else
 UDPContext *s = h->priv_data;
 char hostname[256];
 int port;
 url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &port, NULL, 0, uri);
 /* set the destination address */
 if (resolve_host(&s->dest_addr.sin_addr, hostname) < 0)
 return AVERROR_IO;
 h->is_streamed = 1;
 h->max_packet_size = 1472;
 is_output = (flags & URL_WRONLY);
 s = av_malloc(sizeof(UDPContext));
 if (!s)
 return -ENOMEM;
 h->priv_data = s;
 }
 }
 /* fill the dest addr */
 url_split(NULL, 0, NULL, 0, hostname, sizeof(hostname), &port, NULL, 0, uri);
 /* XXX: fix url_split */
 if (hostname[0] == '\0' || hostname[0] == '?') {
 /* only accepts null hostname if input */
 if (s->is_multicast || (flags & URL_WRONLY))
 goto fail;
 } else {
 my_addr.sin_port = htons(s->local_port);
 }
 /* the bind is needed to give a port to the socket now */
 if (bind(udp_fd,(struct sockaddr *)&my_addr, sizeof(my_addr)) < 0)
 goto fail;
 len = sizeof(my_addr1);
 getsockname(udp_fd, (struct sockaddr *)&my_addr1, &len);
 s->local_port = ntohs(my_addr1.sin_port);
 #ifndef CONFIG_BEOS_NETSERVER
 if (s->is_multicast) {
 if (h->flags & URL_WRONLY) {
 /* output */
 if (setsockopt(udp_fd, IPPROTO_IP, IP_MULTICAST_TTL,
 &s->ttl, sizeof(s->ttl)) < 0) {
 perror("IP_MULTICAST_TTL");
 goto fail;
 }
 } else {
 /* input */
 memset(&s->mreq, 0, sizeof(s->mreq));
 s->mreq.imr_multiaddr = s->dest_addr.sin_addr;
 s->mreq.imr_interface.s_addr = htonl (INADDR_ANY);
 if (setsockopt(udp_fd, IPPROTO_IP, IP_ADD_MEMBERSHIP,
 &s->mreq, sizeof(s->mreq)) < 0) {
 perror("rtp: IP_ADD_MEMBERSHIP");
 goto fail;
 }
 }
 } else {
 if (udp_ipv6_join_multicast_group(udp_fd, (struct sockaddr *)&s->dest_addr) < 0)
 goto fail;
 }
 }
 #endif
 #endif
 if (is_output) {
 /* limit the tx buf size to limit latency */
 tmp = UDP_TX_BUF_SIZE;
 {
 UDPContext *s = h->priv_data;
 int ret;
 for(;;) {
 ret = sendto (s->udp_fd, buf, size, 0,
 (struct sockaddr *) &s->dest_addr,
 #ifndef CONFIG_IPV6
 sizeof (s->dest_addr));
 #else
 s->dest_addr_len);
 UDPContext *s = h->priv_data;
 #ifndef CONFIG_BEOS_NETSERVER
 #ifndef CONFIG_IPV6
 if (s->is_multicast && !(h->flags & URL_WRONLY)) {
 if (setsockopt(s->udp_fd, IPPROTO_IP, IP_DROP_MEMBERSHIP,
 &s->mreq, sizeof(s->mreq)) < 0) {
 perror("IP_DROP_MEMBERSHIP");
 }
 }
 #else

Mercurial > libavformat.hg

comparison udp.c @ 885:da1d5db0ce5c libavformat