summaryrefslogtreecommitdiff
path: root/gst/udp/gstudpnetutils.c
diff options
context:
space:
mode:
Diffstat (limited to 'gst/udp/gstudpnetutils.c')
-rw-r--r--gst/udp/gstudpnetutils.c462
1 files changed, 462 insertions, 0 deletions
diff --git a/gst/udp/gstudpnetutils.c b/gst/udp/gstudpnetutils.c
new file mode 100644
index 0000000..f488fcc
--- /dev/null
+++ b/gst/udp/gstudpnetutils.c
@@ -0,0 +1,462 @@
+/* GStreamer UDP network utility functions
+ * Copyright (C) 2006 Tim-Philipp Müller <tim centricular net>
+ * Copyright (C) 2006 Joni Valtanen <joni.valtanen@movial.fi>
+ * Copyright (C) 2009 Jarkko Palviainen <jarkko.palviainen@sesca.com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <errno.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <memory.h>
+
+#include <gst/gst.h>
+
+#include "gstudpnetutils.h"
+
+/* EAI_ADDRFAMILY was obsoleted in BSD at some point */
+#ifndef EAI_ADDRFAMILY
+#define EAI_ADDRFAMILY 1
+#endif
+
+#ifdef G_OS_WIN32
+
+gboolean
+gst_udp_net_utils_win32_wsa_startup (GstObject * obj)
+{
+ WSADATA w;
+ int error;
+
+ error = WSAStartup (0x0202, &w);
+
+ if (error) {
+ GST_WARNING_OBJECT (obj, "WSAStartup error: %d", error);
+ return FALSE;
+ }
+
+ if (w.wVersion != 0x0202) {
+ WSACleanup ();
+ GST_WARNING_OBJECT (obj, "Winsock version wrong : 0x%x", w.wVersion);
+ return FALSE;
+ }
+
+ return TRUE;
+}
+
+#endif
+
+int
+gst_udp_get_sockaddr_length (struct sockaddr_storage *addr)
+{
+ /* MacOS is picky about passing precisely the correct length,
+ * so we calculate it here for the given socket type.
+ */
+ switch (addr->ss_family) {
+ case AF_INET:
+ return sizeof (struct sockaddr_in);
+ case AF_INET6:
+ return sizeof (struct sockaddr_in6);
+ default:
+ /* don't know, Screw MacOS and use the full length */
+ return sizeof (*addr);
+ }
+}
+
+int
+gst_udp_get_addr (const char *hostname, int port, struct sockaddr_storage *addr)
+{
+ struct addrinfo hints, *res = NULL, *nres;
+ char service[NI_MAXSERV];
+ int ret;
+
+ memset (&hints, 0, sizeof (hints));
+ hints.ai_family = AF_UNSPEC;
+ hints.ai_socktype = SOCK_DGRAM;
+ g_snprintf (service, sizeof (service) - 1, "%d", port);
+ service[sizeof (service) - 1] = '\0';
+
+ if ((ret = getaddrinfo (hostname, (port == -1) ? NULL : service, &hints,
+ &res)) < 0) {
+ goto beach;
+ }
+
+ nres = res;
+ while (nres) {
+ if (nres->ai_family == AF_INET || nres->ai_family == AF_INET6)
+ break;
+ nres = nres->ai_next;
+ }
+
+ if (nres) {
+ memcpy (addr, nres->ai_addr, nres->ai_addrlen);
+ } else {
+ ret = EAI_ADDRFAMILY;
+ }
+
+ freeaddrinfo (res);
+beach:
+ return ret;
+}
+
+int
+gst_udp_set_loop (int sockfd, guint16 ss_family, gboolean loop)
+{
+ int ret = -1;
+ int l = (loop == FALSE) ? 0 : 1;
+
+ switch (ss_family) {
+ case AF_INET:
+ {
+ ret = setsockopt (sockfd, IPPROTO_IP, IP_MULTICAST_LOOP, &l, sizeof (l));
+ if (ret < 0)
+ return ret;
+
+ break;
+ }
+ case AF_INET6:
+ {
+ ret =
+ setsockopt (sockfd, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, &l,
+ sizeof (l));
+ if (ret < 0)
+ return ret;
+
+ break;
+ }
+ default:
+#ifdef G_OS_WIN32
+ WSASetLastError (WSAEAFNOSUPPORT);
+#else
+ errno = EAFNOSUPPORT;
+#endif
+ }
+
+ return ret;
+}
+
+int
+gst_udp_set_ttl (int sockfd, guint16 ss_family, int ttl, gboolean is_multicast)
+{
+ int optname = -1;
+ int ret = -1;
+
+ switch (ss_family) {
+ case AF_INET:
+ {
+ optname = (is_multicast == TRUE) ? IP_MULTICAST_TTL : IP_TTL;
+ ret = setsockopt (sockfd, IPPROTO_IP, optname, &ttl, sizeof (ttl));
+ if (ret < 0)
+ return ret;
+ break;
+ }
+ case AF_INET6:
+ {
+ optname =
+ (is_multicast == TRUE) ? IPV6_MULTICAST_HOPS : IPV6_UNICAST_HOPS;
+ ret = setsockopt (sockfd, IPPROTO_IPV6, optname, &ttl, sizeof (ttl));
+ if (ret < 0)
+ return ret;
+
+ /* When using IPV4 address with IPV6 socket, both TTL values
+ must be set in order to actually use the given value.
+ Has no effect when IPV6 address is used. */
+ optname = (is_multicast == TRUE) ? IP_MULTICAST_TTL : IP_TTL;
+ ret = setsockopt (sockfd, IPPROTO_IP, optname, &ttl, sizeof (ttl));
+ if (ret < 0)
+ return ret;
+ break;
+ }
+ default:
+#ifdef G_OS_WIN32
+ WSASetLastError (WSAEAFNOSUPPORT);
+#else
+ errno = EAFNOSUPPORT;
+#endif
+ }
+ return ret;
+}
+
+/* FIXME: Add interface selection for windows hosts. */
+int
+gst_udp_join_group (int sockfd, struct sockaddr_storage *addr, gchar * iface)
+{
+ int ret = -1;
+
+ switch (addr->ss_family) {
+ case AF_INET:
+ {
+#ifdef HAVE_IP_MREQN
+ struct ip_mreqn mreq4;
+#else
+ struct ip_mreq mreq4;
+#endif
+
+ memset (&mreq4, 0, sizeof (mreq4));
+ mreq4.imr_multiaddr.s_addr =
+ ((struct sockaddr_in *) addr)->sin_addr.s_addr;
+#ifdef HAVE_IP_MREQN
+ if (iface)
+ mreq4.imr_ifindex = if_nametoindex (iface);
+ else
+ mreq4.imr_ifindex = 0; /* Pick any. */
+#else
+ mreq4.imr_interface.s_addr = INADDR_ANY;
+#endif
+
+ if ((ret =
+ setsockopt (sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP,
+ (const void *) &mreq4, sizeof (mreq4))) < 0)
+ return ret;
+
+ break;
+ }
+ case AF_INET6:
+ {
+ struct ipv6_mreq mreq6;
+
+ memset (&mreq6, 0, sizeof (mreq6));
+ memcpy (&mreq6.ipv6mr_multiaddr,
+ &(((struct sockaddr_in6 *) addr)->sin6_addr),
+ sizeof (struct in6_addr));
+ mreq6.ipv6mr_interface = 0;
+#if !defined(G_OS_WIN32)
+ if (iface)
+ mreq6.ipv6mr_interface = if_nametoindex (iface);
+#endif
+
+ if ((ret =
+ setsockopt (sockfd, IPPROTO_IPV6, IPV6_JOIN_GROUP,
+ (const void *) &mreq6, sizeof (mreq6))) < 0)
+ return ret;
+
+ break;
+ }
+ default:
+#ifdef G_OS_WIN32
+ WSASetLastError (WSAEAFNOSUPPORT);
+#else
+ errno = EAFNOSUPPORT;
+#endif
+ }
+ return ret;
+}
+
+int
+gst_udp_leave_group (int sockfd, struct sockaddr_storage *addr)
+{
+ int ret = -1;
+
+ switch (addr->ss_family) {
+ case AF_INET:
+ {
+ struct ip_mreq mreq4;
+
+ memset (&mreq4, 0, sizeof (mreq4));
+ mreq4.imr_multiaddr.s_addr =
+ ((struct sockaddr_in *) addr)->sin_addr.s_addr;
+ mreq4.imr_interface.s_addr = INADDR_ANY;
+
+ if ((ret =
+ setsockopt (sockfd, IPPROTO_IP, IP_DROP_MEMBERSHIP,
+ (const void *) &mreq4, sizeof (mreq4))) < 0)
+ return ret;
+ }
+ break;
+
+ case AF_INET6:
+ {
+ struct ipv6_mreq mreq6;
+
+ memset (&mreq6, 0, sizeof (mreq6));
+ memcpy (&mreq6.ipv6mr_multiaddr,
+ &(((struct sockaddr_in6 *) addr)->sin6_addr),
+ sizeof (struct in6_addr));
+ mreq6.ipv6mr_interface = 0;
+
+ if ((ret =
+ setsockopt (sockfd, IPPROTO_IPV6, IPV6_LEAVE_GROUP,
+ (const void *) &mreq6, sizeof (mreq6))) < 0)
+ return ret;
+ }
+ break;
+
+ default:
+#ifdef G_OS_WIN32
+ WSASetLastError (WSAEAFNOSUPPORT);
+#else
+ errno = EAFNOSUPPORT;
+#endif
+ }
+
+ return ret;
+}
+
+int
+gst_udp_is_multicast (struct sockaddr_storage *addr)
+{
+ int ret = -1;
+
+ switch (addr->ss_family) {
+ case AF_INET:
+ {
+ struct sockaddr_in *addr4 = (struct sockaddr_in *) addr;
+
+ ret = IN_MULTICAST (g_ntohl (addr4->sin_addr.s_addr));
+ }
+ break;
+
+ case AF_INET6:
+ {
+ struct sockaddr_in6 *addr6 = (struct sockaddr_in6 *) addr;
+
+ ret = IN6_IS_ADDR_MULTICAST (&addr6->sin6_addr);
+ }
+ break;
+
+ default:
+#ifdef G_OS_WIN32
+ WSASetLastError (WSAEAFNOSUPPORT);
+#else
+ errno = EAFNOSUPPORT;
+#endif
+ }
+
+ return ret;
+}
+
+void
+gst_udp_uri_init (GstUDPUri * uri, const gchar * host, gint port)
+{
+ uri->host = NULL;
+ uri->port = -1;
+ gst_udp_uri_update (uri, host, port);
+}
+
+int
+gst_udp_uri_update (GstUDPUri * uri, const gchar * host, gint port)
+{
+ if (host) {
+ g_free (uri->host);
+ uri->host = g_strdup (host);
+ if (strchr (host, ':'))
+ uri->is_ipv6 = TRUE;
+ else
+ uri->is_ipv6 = FALSE;
+ }
+ if (port != -1)
+ uri->port = port;
+
+ return 0;
+}
+
+int
+gst_udp_parse_uri (const gchar * uristr, GstUDPUri * uri)
+{
+ gchar *protocol, *location_start;
+ gchar *location, *location_end;
+ gchar *colptr;
+
+ protocol = gst_uri_get_protocol (uristr);
+ if (strcmp (protocol, "udp") != 0)
+ goto wrong_protocol;
+ g_free (protocol);
+
+ location_start = gst_uri_get_location (uristr);
+ if (!location_start)
+ return FALSE;
+
+ GST_DEBUG ("got location '%s'", location_start);
+
+ /* VLC compatibility, strip everything before the @ sign. VLC uses that as the
+ * remote address. */
+ location = g_strstr_len (location_start, -1, "@");
+ if (location == NULL)
+ location = location_start;
+ else
+ location += 1;
+
+ if (location[0] == '[') {
+ GST_DEBUG ("parse IPV6 address '%s'", location);
+ location_end = strchr (location, ']');
+ if (location_end == NULL)
+ goto wrong_address;
+
+ uri->is_ipv6 = TRUE;
+ g_free (uri->host);
+ uri->host = g_strndup (location + 1, location_end - location - 1);
+ colptr = strrchr (location_end, ':');
+ } else {
+ GST_DEBUG ("parse IPV4 address '%s'", location);
+ uri->is_ipv6 = FALSE;
+ colptr = strrchr (location, ':');
+
+ g_free (uri->host);
+ if (colptr != NULL) {
+ uri->host = g_strndup (location, colptr - location);
+ } else {
+ uri->host = g_strdup (location);
+ }
+ }
+ GST_DEBUG ("host set to '%s'", uri->host);
+
+ if (colptr != NULL) {
+ uri->port = atoi (colptr + 1);
+ }
+ g_free (location_start);
+
+ return 0;
+
+ /* ERRORS */
+wrong_protocol:
+ {
+ GST_ERROR ("error parsing uri %s: wrong protocol (%s != udp)", uristr,
+ protocol);
+ g_free (protocol);
+ return -1;
+ }
+wrong_address:
+ {
+ GST_ERROR ("error parsing uri %s", uristr);
+ g_free (location);
+ return -1;
+ }
+}
+
+gchar *
+gst_udp_uri_string (GstUDPUri * uri)
+{
+ gchar *result;
+
+ if (uri->is_ipv6) {
+ result = g_strdup_printf ("udp://[%s]:%d", uri->host, uri->port);
+ } else {
+ result = g_strdup_printf ("udp://%s:%d", uri->host, uri->port);
+ }
+ return result;
+}
+
+void
+gst_udp_uri_free (GstUDPUri * uri)
+{
+ g_free (uri->host);
+ uri->host = NULL;
+ uri->port = -1;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-21 17:45:52 +0000