FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

udpsrc: fix multicast support on windows builds

Browse Source 
On windows builds, sets source address for bind to INADDR_ANY, while
maintaining the original multicast group address for subsequent join.

Fixes #595978
This commit is contained in:
Keith Nicholson 2010-06-18 16:49:08 +02:00 committed by Wim Taymans
parent e25cdc31d3
commit 0773eed960
1 changed files with 29 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
gst/udp/gstudpsrc.c
View File

@ -758,6 +758,7 @@ gst_udpsrc_start (GstBaseSrc * bsrc)
GstUDPSrc *src; GstUDPSrc *src;
gint ret; gint ret;
int rcvsize; int rcvsize;
struct sockaddr_storage bind_address;
#ifdef G_OS_WIN32 #ifdef G_OS_WIN32
gint len; gint len;
#else #else
@ -789,14 +790,36 @@ gst_udpsrc_start (GstBaseSrc * bsrc)
GST_DEBUG_OBJECT (src, "binding on port %d", src->uri.port); GST_DEBUG_OBJECT (src, "binding on port %d", src->uri.port);
len = gst_udp_get_sockaddr_length (&src->myaddr); /* Take a temporary copy of the address in case we need to fix it for bind */
if ((ret = bind (src->sock.fd, (struct sockaddr *) &src->myaddr, len)) < 0) memcpy (&bind_address, &src->myaddr, sizeof (struct sockaddr_storage));
#ifdef G_OS_WIN32
/* Windows does not allow binding to a multicast group so fix source address */
if (gst_udp_is_multicast (&src->myaddr)) {
switch (((struct sockaddr *) &bind_address)->sa_family) {
case AF_INET:
((struct sockaddr_in *) &bind_address)->sin_addr.s_addr =
htonl (INADDR_ANY);
break;
case AF_INET6:
((struct sockaddr_in6 *) &bind_address)->sin6_addr = in6addr_any;
break;
default:
break;
}
}
#endif
len = gst_udp_get_sockaddr_length (&bind_address);
if ((ret = bind (src->sock.fd, (struct sockaddr *) &bind_address, len)) < 0)
goto bind_error; goto bind_error;
len = sizeof (src->myaddr); if (!gst_udp_is_multicast (&src->myaddr)) {
if ((ret = getsockname (src->sock.fd, (struct sockaddr *) &src->myaddr, len = sizeof (src->myaddr);
&len)) < 0) if ((ret = getsockname (src->sock.fd, (struct sockaddr *) &src->myaddr,
goto getsockname_error; &len)) < 0)
goto getsockname_error;
}
} else { } else {
GST_DEBUG_OBJECT (src, "using provided socket %d", src->sockfd); GST_DEBUG_OBJECT (src, "using provided socket %d", src->sockfd);
/* we use the configured socket, try to get some info about it */ /* we use the configured socket, try to get some info about it */