gio: move resolver utils from gresolver.c to gthreadedresolver.c

Since there is only one resolver implementation now, we can move the
resolver utility functions from gresolver.c into gthreadedresolver.c,
and remove the prototypes from gnetworkingprivate.h.

https://bugzilla.gnome.org/show_bug.cgi?id=623187

1 files changed, 0 insertions, 555 deletions

diff --git a/gio/gresolver.c b/gio/gresolver.c
index 718dc48ca..3708ee2c3 100644
--- a/gio/gresolver.c
+++ b/gio/gresolver.c
@@ -28,7 +28,6 @@
 #include "gnetworkingprivate.h"
 #include "gasyncresult.h"
 #include "ginetaddress.h"
-#include "ginetsocketaddress.h"
 #include "gsimpleasyncresult.h"
 #include "gtask.h"
 #include "gsrvtarget.h"
@@ -157,17 +156,6 @@ g_resolver_class_init (GResolverClass *resolver_class)
   /* Make sure _g_networking_init() has been called */
   g_type_ensure (G_TYPE_INET_ADDRESS);
 
-  /* Initialize _g_resolver_addrinfo_hints */
-#ifdef AI_ADDRCONFIG
-  _g_resolver_addrinfo_hints.ai_flags |= AI_ADDRCONFIG;
-#endif
-  /* These two don't actually matter, they just get copied into the
-   * returned addrinfo structures (and then we ignore them). But if
-   * we leave them unset, we'll get back duplicate answers.
-   */
-  _g_resolver_addrinfo_hints.ai_socktype = SOCK_STREAM;
-  _g_resolver_addrinfo_hints.ai_protocol = IPPROTO_TCP;
-
   /**
    * GResolver::reload:
    * @resolver: a #GResolver
@@ -870,546 +858,3 @@ g_resolver_lookup_records_finish (GResolver     *resolver,
  * Since: 2.22
  */
 G_DEFINE_QUARK (g-resolver-error-quark, g_resolver_error)
-
-static GResolverError
-g_resolver_error_from_addrinfo_error (gint err)
-{
-  switch (err)
-    {
-    case EAI_FAIL:
-#if defined(EAI_NODATA) && (EAI_NODATA != EAI_NONAME)
-    case EAI_NODATA:
-#endif
-    case EAI_NONAME:
-      return G_RESOLVER_ERROR_NOT_FOUND;
-
-    case EAI_AGAIN:
-      return G_RESOLVER_ERROR_TEMPORARY_FAILURE;
-
-    default:
-      return G_RESOLVER_ERROR_INTERNAL;
-    }
-}
-
-struct addrinfo _g_resolver_addrinfo_hints;
-
-/* Private method to process a getaddrinfo() response. */
-GList *
-_g_resolver_addresses_from_addrinfo (const char       *hostname,
-                                     struct addrinfo  *res,
-                                     gint              gai_retval,
-                                     GError          **error)
-{
-  struct addrinfo *ai;
-  GSocketAddress *sockaddr;
-  GInetAddress *addr;
-  GList *addrs;
-
-  if (gai_retval != 0)
-    {
-      g_set_error (error, G_RESOLVER_ERROR,
-		   g_resolver_error_from_addrinfo_error (gai_retval),
-		   _("Error resolving '%s': %s"),
-		   hostname, gai_strerror (gai_retval));
-      return NULL;
-    }
-
-  g_return_val_if_fail (res != NULL, NULL);
-
-  addrs = NULL;
-  for (ai = res; ai; ai = ai->ai_next)
-    {
-      sockaddr = g_socket_address_new_from_native (ai->ai_addr, ai->ai_addrlen);
-      if (!sockaddr || !G_IS_INET_SOCKET_ADDRESS (sockaddr))
-        continue;
-
-      addr = g_object_ref (g_inet_socket_address_get_address ((GInetSocketAddress *)sockaddr));
-      addrs = g_list_prepend (addrs, addr);
-      g_object_unref (sockaddr);
-    }
-
-  return g_list_reverse (addrs);
-}
-
-/* Private method to set up a getnameinfo() request */
-void
-_g_resolver_address_to_sockaddr (GInetAddress            *address,
-                                 struct sockaddr_storage *sa,
-                                 gsize                   *len)
-{
-  GSocketAddress *sockaddr;
-
-  sockaddr = g_inet_socket_address_new (address, 0);
-  g_socket_address_to_native (sockaddr, (struct sockaddr *)sa, sizeof (*sa), NULL);
-  *len = g_socket_address_get_native_size (sockaddr);
-  g_object_unref (sockaddr);
-}
-
-/* Private method to process a getnameinfo() response. */
-char *
-_g_resolver_name_from_nameinfo (GInetAddress  *address,
-                                const gchar   *name,
-                                gint           gni_retval,
-                                GError       **error)
-{
-  if (gni_retval != 0)
-    {
-      gchar *phys;
-
-      phys = g_inet_address_to_string (address);
-      g_set_error (error, G_RESOLVER_ERROR,
-                   g_resolver_error_from_addrinfo_error (gni_retval),
-                   _("Error reverse-resolving '%s': %s"),
-                   phys ? phys : "(unknown)", gai_strerror (gni_retval));
-      g_free (phys);
-      return NULL;
-    }
-
-  return g_strdup (name);
-}
-
-#if defined(G_OS_UNIX)
-
-static gboolean
-parse_short (guchar  **p,
-             guchar   *end,
-             guint16  *value)
-{
-  if (*p + 2 > end)
-    return FALSE;
-  GETSHORT (*value, *p);
-  return TRUE;
-}
-
-static gboolean
-parse_long (guchar  **p,
-            guchar   *end,
-            guint32  *value)
-{
-  if (*p + 4 > end)
-    return FALSE;
-  GETLONG (*value, *p);
-  return TRUE;
-}
-
-static GVariant *
-parse_res_srv (guchar  *answer,
-               guchar  *end,
-               guchar  *p)
-{
-  gchar namebuf[1024];
-  guint16 priority, weight, port;
-  gint n;
-
-  if (!parse_short (&p, end, &priority) ||
-      !parse_short (&p, end, &weight) ||
-      !parse_short (&p, end, &port))
-    return NULL;
-
-  n = dn_expand (answer, end, p, namebuf, sizeof (namebuf));
-  if (n < 0)
-    return NULL;
-  *p += n;
-
-  return g_variant_new ("(qqqs)",
-                        priority,
-                        weight,
-                        port,
-                        namebuf);
-}
-
-static GVariant *
-parse_res_soa (guchar  *answer,
-               guchar  *end,
-               guchar  *p)
-{
-  gchar mnamebuf[1024];
-  gchar rnamebuf[1024];
-  guint32 serial, refresh, retry, expire, ttl;
-  gint n;
-
-  n = dn_expand (answer, end, p, mnamebuf, sizeof (mnamebuf));
-  if (n < 0)
-    return NULL;
-  p += n;
-
-  n = dn_expand (answer, end, p, rnamebuf, sizeof (rnamebuf));
-  if (n < 0)
-    return NULL;
-  p += n;
-
-  if (!parse_long (&p, end, &serial) ||
-      !parse_long (&p, end, &refresh) ||
-      !parse_long (&p, end, &retry) ||
-      !parse_long (&p, end, &expire) ||
-      !parse_long (&p, end, &ttl))
-    return NULL;
-
-  return g_variant_new ("(ssuuuuu)",
-                        mnamebuf,
-                        rnamebuf,
-                        serial,
-                        refresh,
-                        retry,
-                        expire,
-                        ttl);
-}
-
-static GVariant *
-parse_res_ns (guchar  *answer,
-              guchar  *end,
-              guchar  *p)
-{
-  gchar namebuf[1024];
-  gint n;
-
-  n = dn_expand (answer, end, p, namebuf, sizeof (namebuf));
-  if (n < 0)
-    return NULL;
-
-  return g_variant_new ("(s)", namebuf);
-}
-
-static GVariant *
-parse_res_mx (guchar  *answer,
-              guchar  *end,
-              guchar  *p)
-{
-  gchar namebuf[1024];
-  guint16 preference;
-  gint n;
-
-  if (!parse_short (&p, end, &preference))
-    return NULL;
-
-  n = dn_expand (answer, end, p, namebuf, sizeof (namebuf));
-  if (n < 0)
-    return NULL;
-  p += n;
-
-  return g_variant_new ("(qs)",
-                        preference,
-                        namebuf);
-}
-
-static GVariant *
-parse_res_txt (guchar  *answer,
-               guchar  *end,
-               guchar  *p)
-{
-  GVariant *record;
-  GPtrArray *array;
-  gsize len;
-
-  array = g_ptr_array_new_with_free_func (g_free);
-  while (p < end)
-    {
-      len = *(p++);
-      if (len > p - end)
-        break;
-      g_ptr_array_add (array, g_strndup ((gchar *)p, len));
-      p += len;
-    }
-
-  record = g_variant_new ("(@as)",
-                          g_variant_new_strv ((const gchar **)array->pdata, array->len));
-  g_ptr_array_free (array, TRUE);
-  return record;
-}
-
-gint
-_g_resolver_record_type_to_rrtype (GResolverRecordType type)
-{
-  switch (type)
-  {
-    case G_RESOLVER_RECORD_SRV:
-      return T_SRV;
-    case G_RESOLVER_RECORD_TXT:
-      return T_TXT;
-    case G_RESOLVER_RECORD_SOA:
-      return T_SOA;
-    case G_RESOLVER_RECORD_NS:
-      return T_NS;
-    case G_RESOLVER_RECORD_MX:
-      return T_MX;
-  }
-  g_return_val_if_reached (-1);
-}
-
-/* Private method to process a res_query response into GSrvTargets */
-GList *
-_g_resolver_records_from_res_query (const gchar      *rrname,
-                                    gint              rrtype,
-                                    guchar           *answer,
-                                    gint              len,
-                                    gint              herr,
-                                    GError          **error)
-{
-  gint count;
-  guchar *end, *p;
-  guint16 type, qclass, rdlength;
-  guint32 ttl;
-  HEADER *header;
-  GList *records;
-  GVariant *record;
-  gint n, i;
-
-  if (len <= 0)
-    {
-      GResolverError errnum;
-      const gchar *format;
-
-      if (len == 0 || herr == HOST_NOT_FOUND || herr == NO_DATA)
-        {
-          errnum = G_RESOLVER_ERROR_NOT_FOUND;
-          format = _("No DNS record of the requested type for '%s'");
-        }
-      else if (herr == TRY_AGAIN)
-        {
-          errnum = G_RESOLVER_ERROR_TEMPORARY_FAILURE;
-          format = _("Temporarily unable to resolve '%s'");
-        }
-      else
-        {
-          errnum = G_RESOLVER_ERROR_INTERNAL;
-          format = _("Error resolving '%s'");
-        }
-
-      g_set_error (error, G_RESOLVER_ERROR, errnum, format, rrname);
-      return NULL;
-    }
-
-  records = NULL;
-
-  header = (HEADER *)answer;
-  p = answer + sizeof (HEADER);
-  end = answer + len;
-
-  /* Skip query */
-  count = ntohs (header->qdcount);
-  for (i = 0; i < count && p < end; i++)
-    {
-      n = dn_skipname (p, end);
-      if (n < 0)
-        break;
-      p += n;
-      p += 4;
-    }
-
-  /* Incomplete response */
-  if (i < count)
-    {
-      g_set_error (error, G_RESOLVER_ERROR, G_RESOLVER_ERROR_TEMPORARY_FAILURE,
-                   _("Incomplete data received for '%s'"), rrname);
-      return NULL;
-    }
-
-  /* Read answers */
-  count = ntohs (header->ancount);
-  for (i = 0; i < count && p < end; i++)
-    {
-      n = dn_skipname (p, end);
-      if (n < 0)
-        break;
-      p += n;
-
-      if (!parse_short (&p, end, &type) ||
-          !parse_short (&p, end, &qclass) ||
-          !parse_long (&p, end, &ttl) ||
-          !parse_short (&p, end, &rdlength))
-        break;
-
-      ttl = ttl; /* To avoid -Wunused-but-set-variable */
-
-      if (p + rdlength > end)
-        break;
-
-      if (type == rrtype && qclass == C_IN)
-        {
-          switch (rrtype)
-            {
-            case T_SRV:
-              record = parse_res_srv (answer, end, p);
-              break;
-            case T_MX:
-              record = parse_res_mx (answer, end, p);
-              break;
-            case T_SOA:
-              record = parse_res_soa (answer, end, p);
-              break;
-            case T_NS:
-              record = parse_res_ns (answer, end, p);
-              break;
-            case T_TXT:
-              record = parse_res_txt (answer, p + rdlength, p);
-              break;
-            default:
-              g_warn_if_reached ();
-              record = NULL;
-              break;
-            }
-
-          if (record != NULL)
-            records = g_list_prepend (records, record);
-        }
-
-      p += rdlength;
-    }
-
-  /* Somehow got a truncated response */
-  if (i < count)
-    {
-      g_list_free_full (records, (GDestroyNotify)g_variant_unref);
-      g_set_error (error, G_RESOLVER_ERROR, G_RESOLVER_ERROR_TEMPORARY_FAILURE,
-                   _("Incomplete data received for '%s'"), rrname);
-      return NULL;
-    }
-
-  return records;
-}
-
-#elif defined(G_OS_WIN32)
-static GVariant *
-parse_dns_srv (DNS_RECORD *rec)
-{
-  return g_variant_new ("(qqqs)",
-                        (guint16)rec->Data.SRV.wPriority,
-                        (guint16)rec->Data.SRV.wWeight,
-                        (guint16)rec->Data.SRV.wPort,
-                        rec->Data.SRV.pNameTarget);
-}
-
-static GVariant *
-parse_dns_soa (DNS_RECORD *rec)
-{
-  return g_variant_new ("(ssuuuuu)",
-                        rec->Data.SOA.pNamePrimaryServer,
-                        rec->Data.SOA.pNameAdministrator,
-                        (guint32)rec->Data.SOA.dwSerialNo,
-                        (guint32)rec->Data.SOA.dwRefresh,
-                        (guint32)rec->Data.SOA.dwRetry,
-                        (guint32)rec->Data.SOA.dwExpire,
-                        (guint32)rec->Data.SOA.dwDefaultTtl);
-}
-
-static GVariant *
-parse_dns_ns (DNS_RECORD *rec)
-{
-  return g_variant_new ("(s)", rec->Data.NS.pNameHost);
-}
-
-static GVariant *
-parse_dns_mx (DNS_RECORD *rec)
-{
-  return g_variant_new ("(qs)",
-                        (guint16)rec->Data.MX.wPreference,
-                        rec->Data.MX.pNameExchange);
-}
-
-static GVariant *
-parse_dns_txt (DNS_RECORD *rec)
-{
-  GVariant *record;
-  GPtrArray *array;
-  DWORD i;
-
-  array = g_ptr_array_new ();
-  for (i = 0; i < rec->Data.TXT.dwStringCount; i++)
-    g_ptr_array_add (array, rec->Data.TXT.pStringArray[i]);
-  record = g_variant_new ("(@as)",
-                          g_variant_new_strv ((const gchar **)array->pdata, array->len));
-  g_ptr_array_free (array, TRUE);
-  return record;
-}
-
-WORD
-_g_resolver_record_type_to_dnstype (GResolverRecordType type)
-{
-  switch (type)
-  {
-    case G_RESOLVER_RECORD_SRV:
-      return DNS_TYPE_SRV;
-    case G_RESOLVER_RECORD_TXT:
-      return DNS_TYPE_TEXT;
-    case G_RESOLVER_RECORD_SOA:
-      return DNS_TYPE_SOA;
-    case G_RESOLVER_RECORD_NS:
-      return DNS_TYPE_NS;
-    case G_RESOLVER_RECORD_MX:
-      return DNS_TYPE_MX;
-  }
-  g_return_val_if_reached (-1);
-}
-
-/* Private method to process a DnsQuery response into GVariants */
-GList *
-_g_resolver_records_from_DnsQuery (const gchar  *rrname,
-                                   WORD          dnstype,
-                                   DNS_STATUS    status,
-                                   DNS_RECORD   *results,
-                                   GError      **error)
-{
-  DNS_RECORD *rec;
-  gpointer record;
-  GList *records;
-
-  if (status != ERROR_SUCCESS)
-    {
-      GResolverError errnum;
-      const gchar *format;
-
-      if (status == DNS_ERROR_RCODE_NAME_ERROR)
-        {
-          errnum = G_RESOLVER_ERROR_NOT_FOUND;
-          format = _("No DNS record of the requested type for '%s'");
-        }
-      else if (status == DNS_ERROR_RCODE_SERVER_FAILURE)
-        {
-          errnum = G_RESOLVER_ERROR_TEMPORARY_FAILURE;
-          format = _("Temporarily unable to resolve '%s'");
-        }
-      else
-        {
-          errnum = G_RESOLVER_ERROR_INTERNAL;
-          format = _("Error resolving '%s'");
-        }
-
-      g_set_error (error, G_RESOLVER_ERROR, errnum, format, rrname);
-      return NULL;
-    }
-
-  records = NULL;
-  for (rec = results; rec; rec = rec->pNext)
-    {
-      if (rec->wType != dnstype)
-        continue;
-      switch (dnstype)
-        {
-        case DNS_TYPE_SRV:
-          record = parse_dns_srv (rec);
-          break;
-        case DNS_TYPE_SOA:
-          record = parse_dns_soa (rec);
-          break;
-        case DNS_TYPE_NS:
-          record = parse_dns_ns (rec);
-          break;
-        case DNS_TYPE_MX:
-          record = parse_dns_mx (rec);
-          break;
-        case DNS_TYPE_TEXT:
-          record = parse_dns_txt (rec);
-          break;
-        default:
-          g_warn_if_reached ();
-          record = NULL;
-          break;
-        }
-      if (record != NULL)
-        records = g_list_prepend (records, g_variant_ref_sink (record));
-    }
-
-  return records;
-}
-
-#endif