summaryrefslogtreecommitdiff
path: root/wearable/gst/udp/gstudpnetutils.c
diff options
context:
space:
mode:
Diffstat (limited to 'wearable/gst/udp/gstudpnetutils.c')
-rw-r--r--wearable/gst/udp/gstudpnetutils.c470
1 files changed, 0 insertions, 470 deletions
diff --git a/wearable/gst/udp/gstudpnetutils.c b/wearable/gst/udp/gstudpnetutils.c
deleted file mode 100644
index bdbffbc..0000000
--- a/wearable/gst/udp/gstudpnetutils.c
+++ /dev/null
@@ -1,470 +0,0 @@
-/* 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;
-
- /* consider no protocol to be udp:// */
- protocol = gst_uri_get_protocol (uristr);
- if (!protocol)
- goto no_protocol;
- 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 */
-no_protocol:
- {
- GST_ERROR ("error parsing uri %s: no protocol", uristr);
- return -1;
- }
-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-27 03:41:15 +0000