2015-10-21 10:29:02 +02:00
|
|
|
/* dns-stuff.c - DNS related code including CERT RR (rfc-4398)
|
2015-10-22 09:22:41 +02:00
|
|
|
* Copyright (C) 2003, 2005, 2006, 2009 Free Software Foundation, Inc.
|
2015-10-21 10:29:02 +02:00
|
|
|
* Copyright (C) 2005, 2006, 2009, 2015 Werner Koch
|
2006-06-16 13:49:27 +02:00
|
|
|
*
|
2015-10-21 10:29:02 +02:00
|
|
|
* This file is part of GnuPG.
|
2006-06-16 13:49:27 +02:00
|
|
|
*
|
Change license for some files in common to LGPLv3+/GPLv2+.
Having the LGPL on the common GnuPG code helps to share code
between GnuPG and related projects (like GPGME and Libassuan). This
is good for interoperability and to reduces bugs.
* common/asshelp.c, common/asshelp.h, common/asshelp2.c, common/b64dec.c
* common/b64enc.c, common/convert.c, common/dns-cert.c
* common/dns-cert.h common/exechelp-posix.c, common/exechelp-w32.c
* common/exechelp-w32ce.c, common/exechelp.h, common/get-passphrase.c
* common/get-passphrase.h, common/gettime.c, common/gpgrlhelp.c
* common/helpfile.c, common/homedir.c, common/http.c, common/http.h
* common/i18n.c, common/init.c, common/init.h, common/iobuf.c
* common/iobuf.h, common/localename.c, common/membuf.c, common/membuf.h
* common/miscellaneous.c, common/openpgp-oid.c, common/openpgpdefs.h
* common/percent.c, common/pka.c, common/pka.h, common/session-env.c
* common/session-env.h, common/sexp-parse.h, common/sexputil.c
* common/signal.c, common/srv.c, common/srv.h, common/ssh-utils.c
* common/ssh-utils.h, common/sysutils.c, common/sysutils.h
* common/tlv.c, common/tlv.h, common/ttyio.c, common/ttyio.h
* common/userids.c, common/userids.h, common/xasprintf.c: Change
license to LGPLv3+/GPLv2+/
2012-04-20 15:43:06 +02:00
|
|
|
* This file is free software; you can redistribute it and/or modify
|
|
|
|
* it under the terms of either
|
2006-06-16 13:49:27 +02:00
|
|
|
*
|
Change license for some files in common to LGPLv3+/GPLv2+.
Having the LGPL on the common GnuPG code helps to share code
between GnuPG and related projects (like GPGME and Libassuan). This
is good for interoperability and to reduces bugs.
* common/asshelp.c, common/asshelp.h, common/asshelp2.c, common/b64dec.c
* common/b64enc.c, common/convert.c, common/dns-cert.c
* common/dns-cert.h common/exechelp-posix.c, common/exechelp-w32.c
* common/exechelp-w32ce.c, common/exechelp.h, common/get-passphrase.c
* common/get-passphrase.h, common/gettime.c, common/gpgrlhelp.c
* common/helpfile.c, common/homedir.c, common/http.c, common/http.h
* common/i18n.c, common/init.c, common/init.h, common/iobuf.c
* common/iobuf.h, common/localename.c, common/membuf.c, common/membuf.h
* common/miscellaneous.c, common/openpgp-oid.c, common/openpgpdefs.h
* common/percent.c, common/pka.c, common/pka.h, common/session-env.c
* common/session-env.h, common/sexp-parse.h, common/sexputil.c
* common/signal.c, common/srv.c, common/srv.h, common/ssh-utils.c
* common/ssh-utils.h, common/sysutils.c, common/sysutils.h
* common/tlv.c, common/tlv.h, common/ttyio.c, common/ttyio.h
* common/userids.c, common/userids.h, common/xasprintf.c: Change
license to LGPLv3+/GPLv2+/
2012-04-20 15:43:06 +02:00
|
|
|
* - the GNU Lesser General Public License as published by the Free
|
|
|
|
* Software Foundation; either version 3 of the License, or (at
|
|
|
|
* your option) any later version.
|
|
|
|
*
|
|
|
|
* or
|
|
|
|
*
|
|
|
|
* - the GNU General Public License as published by the Free
|
|
|
|
* Software Foundation; either version 2 of the License, or (at
|
|
|
|
* your option) any later version.
|
|
|
|
*
|
|
|
|
* or both in parallel, as here.
|
|
|
|
*
|
|
|
|
* This file is distributed in the hope that it will be useful,
|
2006-06-16 13:49:27 +02:00
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
2007-07-04 21:49:40 +02:00
|
|
|
* along with this program; if not, see <http://www.gnu.org/licenses/>.
|
2006-06-16 13:49:27 +02:00
|
|
|
*/
|
|
|
|
|
|
|
|
#include <config.h>
|
|
|
|
#include <sys/types.h>
|
2015-10-21 17:55:56 +02:00
|
|
|
#ifdef HAVE_W32_SYSTEM
|
|
|
|
# ifdef HAVE_WINSOCK2_H
|
|
|
|
# include <winsock2.h>
|
2009-12-08 13:20:11 +01:00
|
|
|
# endif
|
2015-10-21 17:55:56 +02:00
|
|
|
# include <windows.h>
|
|
|
|
#else
|
|
|
|
# include <netinet/in.h>
|
|
|
|
# include <arpa/nameser.h>
|
|
|
|
# include <resolv.h>
|
|
|
|
# include <netdb.h>
|
2009-12-08 13:20:11 +01:00
|
|
|
#endif
|
2015-10-21 17:55:56 +02:00
|
|
|
#include <string.h>
|
2009-12-08 13:20:11 +01:00
|
|
|
#ifdef USE_ADNS
|
|
|
|
# include <adns.h>
|
2006-06-16 13:49:27 +02:00
|
|
|
#endif
|
|
|
|
|
2015-10-21 22:11:59 +02:00
|
|
|
#if !defined(HAVE_GETADDRINFO) && !defined(USE_ADNS)
|
|
|
|
# error Either getaddrinfo or the ADNS libary is required.
|
|
|
|
#endif
|
|
|
|
|
2006-06-16 13:49:27 +02:00
|
|
|
#include "util.h"
|
2015-02-11 10:27:57 +01:00
|
|
|
#include "host2net.h"
|
2015-10-21 10:29:02 +02:00
|
|
|
#include "dns-stuff.h"
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2015-10-22 09:22:41 +02:00
|
|
|
/* Not every installation has gotten around to supporting SRVs or
|
|
|
|
CERTs yet... */
|
|
|
|
#ifndef T_SRV
|
|
|
|
#define T_SRV 33
|
|
|
|
#endif
|
2006-06-16 13:49:27 +02:00
|
|
|
#ifndef T_CERT
|
2015-10-06 17:34:13 +02:00
|
|
|
# define T_CERT 37
|
2006-06-16 13:49:27 +02:00
|
|
|
#endif
|
|
|
|
|
2011-11-28 18:11:59 +01:00
|
|
|
/* ADNS has no support for CERT yet. */
|
2009-12-08 13:20:11 +01:00
|
|
|
#define my_adns_r_cert 37
|
|
|
|
|
2015-10-20 19:03:26 +02:00
|
|
|
/* If set Tor mode shall be used. */
|
|
|
|
static int tor_mode;
|
2009-12-08 13:20:11 +01:00
|
|
|
|
2015-10-21 18:14:24 +02:00
|
|
|
/* Sets the module in Tor mode. Returns 0 is this is possible or an
|
2015-10-20 19:03:26 +02:00
|
|
|
error code. */
|
|
|
|
gpg_error_t
|
|
|
|
enable_dns_tormode (void)
|
|
|
|
{
|
|
|
|
#if defined(USE_DNS_CERT) && defined(USE_ADNS)
|
|
|
|
# if HAVE_ADNS_IF_TORMODE
|
|
|
|
tor_mode = 1;
|
|
|
|
return 0;
|
|
|
|
# endif
|
|
|
|
#endif
|
|
|
|
return gpg_error (GPG_ERR_NOT_IMPLEMENTED);
|
|
|
|
}
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2015-10-21 17:55:56 +02:00
|
|
|
/* Free an addressinfo linked list as returned by resolve_dns_name. */
|
|
|
|
void
|
|
|
|
free_dns_addrinfo (dns_addrinfo_t ai)
|
|
|
|
{
|
|
|
|
while (ai)
|
|
|
|
{
|
|
|
|
dns_addrinfo_t next = ai->next;
|
|
|
|
xfree (ai);
|
|
|
|
ai = next;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/* Resolve a name using the standard system function. */
|
|
|
|
static gpg_error_t
|
|
|
|
resolve_name_standard (const char *name, unsigned short port,
|
|
|
|
int want_family, int want_socktype,
|
|
|
|
dns_addrinfo_t *r_dai, char **r_canonname)
|
|
|
|
{
|
|
|
|
gpg_error_t err = 0;
|
|
|
|
dns_addrinfo_t daihead = NULL;
|
|
|
|
dns_addrinfo_t dai;
|
|
|
|
struct addrinfo *aibuf = NULL;
|
|
|
|
struct addrinfo hints, *ai;
|
|
|
|
char portstr[21];
|
|
|
|
int ret;
|
|
|
|
|
|
|
|
*r_dai = NULL;
|
|
|
|
if (r_canonname)
|
|
|
|
*r_canonname = NULL;
|
|
|
|
|
|
|
|
memset (&hints, 0, sizeof hints);
|
|
|
|
hints.ai_family = want_family;
|
|
|
|
hints.ai_socktype = want_socktype;
|
|
|
|
if (r_canonname)
|
|
|
|
hints.ai_flags = AI_CANONNAME;
|
|
|
|
|
|
|
|
if (port)
|
|
|
|
snprintf (portstr, sizeof portstr, "%hu", port);
|
|
|
|
else
|
|
|
|
*portstr = 0;
|
|
|
|
|
|
|
|
/* We can't use the the AI_IDN flag because that does the conversion
|
|
|
|
using the current locale. However, GnuPG always used UTF-8. To
|
|
|
|
support IDN we would need to make use of the libidn API. */
|
|
|
|
ret = getaddrinfo (name, *portstr? portstr : NULL, &hints, &aibuf);
|
|
|
|
if (ret)
|
|
|
|
{
|
|
|
|
aibuf = NULL;
|
|
|
|
switch (ret)
|
|
|
|
{
|
|
|
|
case EAI_AGAIN: err = gpg_error (GPG_ERR_EAGAIN); break;
|
|
|
|
case EAI_BADFLAGS: err = gpg_error (GPG_ERR_INV_FLAG); break;
|
|
|
|
case EAI_FAIL: err = gpg_error (GPG_ERR_SERVER_FAILED); break;
|
|
|
|
case EAI_MEMORY: err = gpg_error (GPG_ERR_ENOMEM); break;
|
|
|
|
case EAI_NODATA: err = gpg_error (GPG_ERR_NO_DATA); break;
|
|
|
|
case EAI_NONAME: err = gpg_error (GPG_ERR_NO_NAME); break;
|
|
|
|
case EAI_SERVICE: err = gpg_error (GPG_ERR_NOT_SUPPORTED); break;
|
|
|
|
case EAI_ADDRFAMILY:err = gpg_error (GPG_ERR_EADDRNOTAVAIL); break;
|
|
|
|
case EAI_FAMILY: err = gpg_error (GPG_ERR_EAFNOSUPPORT); break;
|
|
|
|
case EAI_SOCKTYPE: err = gpg_error (GPG_ERR_ESOCKTNOSUPPORT); break;
|
|
|
|
case EAI_SYSTEM: err = gpg_error_from_syserror (); break;
|
|
|
|
default: err = gpg_error (GPG_ERR_UNKNOWN_ERRNO); break;
|
|
|
|
}
|
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (r_canonname && aibuf && aibuf->ai_canonname)
|
|
|
|
{
|
|
|
|
*r_canonname = xtrystrdup (aibuf->ai_canonname);
|
|
|
|
if (!*r_canonname)
|
|
|
|
{
|
|
|
|
err = gpg_error_from_syserror ();
|
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
for (ai = aibuf; ai; ai = ai->ai_next)
|
|
|
|
{
|
|
|
|
if (ai->ai_family != AF_INET6 && ai->ai_family != AF_INET)
|
|
|
|
continue;
|
|
|
|
|
|
|
|
dai = xtrymalloc (sizeof *dai + ai->ai_addrlen - 1);
|
|
|
|
dai->family = ai->ai_family;
|
|
|
|
dai->socktype = ai->ai_socktype;
|
|
|
|
dai->protocol = ai->ai_protocol;
|
|
|
|
dai->addrlen = ai->ai_addrlen;
|
|
|
|
memcpy (dai->addr, ai->ai_addr, ai->ai_addrlen);
|
|
|
|
dai->next = daihead;
|
|
|
|
daihead = dai;
|
|
|
|
}
|
|
|
|
|
|
|
|
leave:
|
|
|
|
if (aibuf)
|
|
|
|
freeaddrinfo (aibuf);
|
|
|
|
if (err)
|
|
|
|
{
|
|
|
|
if (r_canonname)
|
|
|
|
{
|
|
|
|
xfree (*r_canonname);
|
|
|
|
*r_canonname = NULL;
|
|
|
|
}
|
|
|
|
free_dns_addrinfo (daihead);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
*r_dai = daihead;
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/* This a wrapper around getaddrinfo with slighly different semantics.
|
|
|
|
NAME is the name to resolve.
|
|
|
|
PORT is the requested port or 0.
|
|
|
|
WANT_FAMILY is either 0 (AF_UNSPEC), AF_INET6, or AF_INET4.
|
|
|
|
WANT_SOCKETTYPE is either SOCK_STREAM or SOCK_DGRAM.
|
|
|
|
|
|
|
|
On success the result is stored in a linked list with the head
|
|
|
|
stored at the address R_AI; the caller must call gpg_addrinfo_free
|
|
|
|
on this. If R_CANONNAME is not NULL the official name of the host
|
|
|
|
is stored there as a malloced string; if that name is not available
|
|
|
|
NULL is stored. */
|
|
|
|
gpg_error_t
|
|
|
|
resolve_dns_name (const char *name, unsigned short port,
|
|
|
|
int want_family, int want_socktype,
|
|
|
|
dns_addrinfo_t *r_ai, char **r_canonname)
|
|
|
|
{
|
|
|
|
#ifdef USE_ADNS_disabled_for_now
|
|
|
|
return resolve_name_adns (name, port, want_family, want_socktype,
|
|
|
|
r_ai, r_canonname);
|
|
|
|
#else
|
|
|
|
return resolve_name_standard (name, port, want_family, want_socktype,
|
|
|
|
r_ai, r_canonname);
|
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
/* Returns 0 on success or an error code. If a PGP CERT record was
|
2015-04-23 15:42:56 +02:00
|
|
|
found, the malloced data is returned at (R_KEY, R_KEYLEN) and
|
2011-11-30 17:14:08 +01:00
|
|
|
the other return parameters are set to NULL/0. If an IPGP CERT
|
|
|
|
record was found the fingerprint is stored as an allocated block at
|
|
|
|
R_FPR and its length at R_FPRLEN; an URL is is allocated as a
|
2015-02-25 12:03:21 +01:00
|
|
|
string and returned at R_URL. If WANT_CERTTYPE is 0 this function
|
|
|
|
returns the first CERT found with a supported type; it is expected
|
|
|
|
that only one CERT record is used. If WANT_CERTTYPE is one of the
|
2015-10-06 17:34:13 +02:00
|
|
|
supported certtypes only records with this certtype are considered
|
2015-04-23 15:42:56 +02:00
|
|
|
and the first found is returned. (R_KEY,R_KEYLEN) are optional. */
|
2011-11-30 17:14:08 +01:00
|
|
|
gpg_error_t
|
2015-02-25 12:03:21 +01:00
|
|
|
get_dns_cert (const char *name, int want_certtype,
|
2015-04-23 15:42:56 +02:00
|
|
|
void **r_key, size_t *r_keylen,
|
2012-02-07 10:15:57 +01:00
|
|
|
unsigned char **r_fpr, size_t *r_fprlen, char **r_url)
|
2006-06-16 13:49:27 +02:00
|
|
|
{
|
|
|
|
#ifdef USE_DNS_CERT
|
2009-12-08 13:20:11 +01:00
|
|
|
#ifdef USE_ADNS
|
2011-11-30 17:14:08 +01:00
|
|
|
gpg_error_t err;
|
2009-12-08 13:20:11 +01:00
|
|
|
adns_state state;
|
|
|
|
adns_answer *answer = NULL;
|
|
|
|
unsigned int ctype;
|
|
|
|
int count;
|
|
|
|
|
2015-02-25 16:34:19 +01:00
|
|
|
if (r_key)
|
|
|
|
*r_key = NULL;
|
2015-04-23 15:42:56 +02:00
|
|
|
if (r_keylen)
|
|
|
|
*r_keylen = 0;
|
2011-11-30 17:14:08 +01:00
|
|
|
*r_fpr = NULL;
|
|
|
|
*r_fprlen = 0;
|
|
|
|
*r_url = NULL;
|
|
|
|
|
2015-10-20 19:03:26 +02:00
|
|
|
if (tor_mode? adns_init_strcfg (&state, adns_if_noerrprint|adns_if_tormode,
|
|
|
|
NULL, "nameserver 8.8.8.8")
|
|
|
|
/* */: adns_init (&state, adns_if_noerrprint, NULL))
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, gpg_err_code_from_syserror ());
|
2009-12-08 13:20:11 +01:00
|
|
|
log_error ("error initializing adns: %s\n", strerror (errno));
|
2011-11-30 17:14:08 +01:00
|
|
|
return err;
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
|
|
|
|
2015-10-06 19:57:00 +02:00
|
|
|
if (adns_synchronous (state, name,
|
|
|
|
(adns_r_unknown
|
|
|
|
| (want_certtype < DNS_CERTTYPE_RRBASE
|
|
|
|
? my_adns_r_cert
|
|
|
|
: (want_certtype - DNS_CERTTYPE_RRBASE))),
|
2011-11-30 17:14:08 +01:00
|
|
|
adns_qf_quoteok_query, &answer))
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, gpg_err_code_from_syserror ());
|
2009-12-08 13:20:11 +01:00
|
|
|
/* log_error ("DNS query failed: %s\n", strerror (errno)); */
|
|
|
|
adns_finish (state);
|
2011-11-30 17:14:08 +01:00
|
|
|
return err;
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
2011-02-04 12:57:53 +01:00
|
|
|
if (answer->status != adns_s_ok)
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
|
|
|
/* log_error ("DNS query returned an error: %s (%s)\n", */
|
|
|
|
/* adns_strerror (answer->status), */
|
|
|
|
/* adns_errabbrev (answer->status)); */
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, GPG_ERR_NOT_FOUND);
|
2011-11-30 17:14:08 +01:00
|
|
|
goto leave;
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
|
|
|
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, GPG_ERR_NOT_FOUND);
|
2011-11-30 17:14:08 +01:00
|
|
|
for (count = 0; count < answer->nrrs; count++)
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
|
|
|
int datalen = answer->rrs.byteblock[count].len;
|
|
|
|
const unsigned char *data = answer->rrs.byteblock[count].data;
|
|
|
|
|
2015-10-06 19:57:00 +02:00
|
|
|
/* First check for our generic RR hack. */
|
|
|
|
if (datalen
|
|
|
|
&& want_certtype >= DNS_CERTTYPE_RRBASE
|
|
|
|
&& ((want_certtype - DNS_CERTTYPE_RRBASE)
|
|
|
|
== (answer->type & ~adns_r_unknown)))
|
|
|
|
{
|
|
|
|
/* Found the requested record - return it. */
|
|
|
|
*r_key = xtrymalloc (datalen);
|
|
|
|
if (!*r_key)
|
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
|
|
|
else
|
|
|
|
{
|
|
|
|
memcpy (*r_key, data, datalen);
|
|
|
|
*r_keylen = datalen;
|
|
|
|
err = 0;
|
|
|
|
}
|
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
|
2009-12-08 13:20:11 +01:00
|
|
|
if (datalen < 5)
|
|
|
|
continue; /* Truncated CERT record - skip. */
|
|
|
|
|
2015-02-11 10:27:57 +01:00
|
|
|
ctype = buf16_to_uint (data);
|
2009-12-08 13:20:11 +01:00
|
|
|
/* (key tag and algorithm fields are not required.) */
|
|
|
|
data += 5;
|
|
|
|
datalen -= 5;
|
|
|
|
|
2015-02-25 12:03:21 +01:00
|
|
|
if (want_certtype && want_certtype != ctype)
|
|
|
|
; /* Not of the requested certtype. */
|
2015-04-23 15:42:56 +02:00
|
|
|
else if (ctype == DNS_CERTTYPE_PGP && datalen >= 11 && r_key && r_keylen)
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
|
|
|
/* CERT type is PGP. Gpg checks for a minimum length of 11,
|
|
|
|
thus we do the same. */
|
2015-04-23 15:42:56 +02:00
|
|
|
*r_key = xtrymalloc (datalen);
|
2011-11-30 17:14:08 +01:00
|
|
|
if (!*r_key)
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
2011-11-30 17:14:08 +01:00
|
|
|
else
|
2015-04-23 15:42:56 +02:00
|
|
|
{
|
|
|
|
memcpy (*r_key, data, datalen);
|
|
|
|
*r_keylen = datalen;
|
|
|
|
err = 0;
|
|
|
|
}
|
2011-11-30 17:14:08 +01:00
|
|
|
goto leave;
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
2015-02-25 12:03:21 +01:00
|
|
|
else if (ctype == DNS_CERTTYPE_IPGP && datalen && datalen < 1023
|
2013-08-01 10:30:27 +02:00
|
|
|
&& datalen >= data[0] + 1 && r_fpr && r_fprlen && r_url)
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
2011-11-29 13:17:20 +01:00
|
|
|
/* CERT type is IPGP. We made sure that the data is
|
|
|
|
plausible and that the caller requested this
|
2009-12-08 13:20:11 +01:00
|
|
|
information. */
|
2011-11-30 17:14:08 +01:00
|
|
|
*r_fprlen = data[0];
|
|
|
|
if (*r_fprlen)
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
2011-11-30 17:14:08 +01:00
|
|
|
*r_fpr = xtrymalloc (*r_fprlen);
|
|
|
|
if (!*r_fpr)
|
|
|
|
{
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
2011-11-30 17:14:08 +01:00
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
memcpy (*r_fpr, data + 1, *r_fprlen);
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
|
|
|
else
|
2011-11-30 17:14:08 +01:00
|
|
|
*r_fpr = NULL;
|
2011-02-04 12:57:53 +01:00
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
if (datalen > *r_fprlen + 1)
|
2009-12-08 13:20:11 +01:00
|
|
|
{
|
2013-08-01 10:30:27 +02:00
|
|
|
*r_url = xtrymalloc (datalen - (*r_fprlen + 1) + 1);
|
2011-11-30 17:14:08 +01:00
|
|
|
if (!*r_url)
|
|
|
|
{
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
2011-11-30 17:14:08 +01:00
|
|
|
xfree (*r_fpr);
|
|
|
|
*r_fpr = NULL;
|
|
|
|
goto leave;
|
|
|
|
}
|
2013-08-01 10:30:27 +02:00
|
|
|
memcpy (*r_url,
|
|
|
|
data + (*r_fprlen + 1), datalen - (*r_fprlen + 1));
|
|
|
|
(*r_url)[datalen - (*r_fprlen + 1)] = '\0';
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
|
|
|
else
|
2011-11-30 17:14:08 +01:00
|
|
|
*r_url = NULL;
|
2011-02-04 12:57:53 +01:00
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
err = 0;
|
|
|
|
goto leave;
|
2009-12-08 13:20:11 +01:00
|
|
|
}
|
|
|
|
}
|
2011-02-04 12:57:53 +01:00
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
leave:
|
2009-12-08 13:20:11 +01:00
|
|
|
adns_free (answer);
|
|
|
|
adns_finish (state);
|
2011-11-30 17:14:08 +01:00
|
|
|
return err;
|
2009-12-08 13:20:11 +01:00
|
|
|
|
|
|
|
#else /*!USE_ADNS*/
|
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
gpg_error_t err;
|
2006-06-16 13:49:27 +02:00
|
|
|
unsigned char *answer;
|
2011-11-28 18:35:19 +01:00
|
|
|
int r;
|
2006-06-16 13:49:27 +02:00
|
|
|
u16 count;
|
|
|
|
|
2015-02-25 16:34:19 +01:00
|
|
|
if (r_key)
|
|
|
|
*r_key = NULL;
|
2015-04-23 15:42:56 +02:00
|
|
|
if (r_keylen)
|
|
|
|
*r_keylen = 0;
|
2011-11-30 17:14:08 +01:00
|
|
|
*r_fpr = NULL;
|
|
|
|
*r_fprlen = 0;
|
|
|
|
*r_url = NULL;
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
/* Allocate a 64k buffer which is the limit for an DNS response. */
|
|
|
|
answer = xtrymalloc (65536);
|
|
|
|
if (!answer)
|
2012-02-07 10:15:57 +01:00
|
|
|
return gpg_err_make (default_errsource, gpg_err_code_from_syserror ());
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, GPG_ERR_NOT_FOUND);
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2015-10-06 19:57:00 +02:00
|
|
|
r = res_query (name, C_IN,
|
|
|
|
(want_certtype < DNS_CERTTYPE_RRBASE
|
|
|
|
? T_CERT
|
|
|
|
: (want_certtype - DNS_CERTTYPE_RRBASE)),
|
|
|
|
answer, 65536);
|
2006-06-16 13:49:27 +02:00
|
|
|
/* Not too big, not too small, no errors and at least 1 answer. */
|
2011-11-30 17:14:08 +01:00
|
|
|
if (r >= sizeof (HEADER) && r <= 65536
|
2011-11-28 18:35:19 +01:00
|
|
|
&& (((HEADER *) answer)->rcode) == NOERROR
|
|
|
|
&& (count = ntohs (((HEADER *) answer)->ancount)))
|
2006-06-16 13:49:27 +02:00
|
|
|
{
|
|
|
|
int rc;
|
2011-11-28 18:35:19 +01:00
|
|
|
unsigned char *pt, *emsg;
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2011-11-28 18:35:19 +01:00
|
|
|
emsg = &answer[r];
|
2006-06-16 13:49:27 +02:00
|
|
|
|
2011-11-28 18:35:19 +01:00
|
|
|
pt = &answer[sizeof (HEADER)];
|
2006-06-16 13:49:27 +02:00
|
|
|
|
|
|
|
/* Skip over the query */
|
|
|
|
|
2011-11-28 18:35:19 +01:00
|
|
|
rc = dn_skipname (pt, emsg);
|
|
|
|
if (rc == -1)
|
2011-11-30 17:14:08 +01:00
|
|
|
{
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, GPG_ERR_INV_OBJ);
|
2011-11-30 17:14:08 +01:00
|
|
|
goto leave;
|
|
|
|
}
|
2011-11-28 18:35:19 +01:00
|
|
|
pt += rc + QFIXEDSZ;
|
2006-06-16 13:49:27 +02:00
|
|
|
|
|
|
|
/* There are several possible response types for a CERT request.
|
2011-11-28 18:35:19 +01:00
|
|
|
We're interested in the PGP (a key) and IPGP (a URI) types.
|
|
|
|
Skip all others. TODO: A key is better than a URI since
|
|
|
|
we've gone through all this bother to fetch it, so favor that
|
|
|
|
if we have both PGP and IPGP? */
|
|
|
|
|
|
|
|
while (count-- > 0 && pt < emsg)
|
|
|
|
{
|
|
|
|
u16 type, class, dlen, ctype;
|
|
|
|
|
|
|
|
rc = dn_skipname (pt, emsg); /* the name we just queried for */
|
|
|
|
if (rc == -1)
|
2011-11-30 17:14:08 +01:00
|
|
|
{
|
2012-02-07 10:15:57 +01:00
|
|
|
err = gpg_err_make (default_errsource, GPG_ERR_INV_OBJ);
|
2011-11-30 17:14:08 +01:00
|
|
|
goto leave;
|
|
|
|
}
|
2011-11-28 18:35:19 +01:00
|
|
|
|
|
|
|
pt += rc;
|
|
|
|
|
|
|
|
/* Truncated message? 15 bytes takes us to the point where
|
|
|
|
we start looking at the ctype. */
|
|
|
|
if ((emsg - pt) < 15)
|
|
|
|
break;
|
|
|
|
|
2015-02-11 10:27:57 +01:00
|
|
|
type = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
2011-11-28 18:35:19 +01:00
|
|
|
|
2015-02-11 10:27:57 +01:00
|
|
|
class = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
|
|
|
|
2011-11-28 18:35:19 +01:00
|
|
|
if (class != C_IN)
|
|
|
|
break;
|
|
|
|
|
|
|
|
/* ttl */
|
|
|
|
pt += 4;
|
|
|
|
|
|
|
|
/* data length */
|
2015-02-11 10:27:57 +01:00
|
|
|
dlen = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
2011-11-28 18:35:19 +01:00
|
|
|
|
2015-10-06 17:34:13 +02:00
|
|
|
/* Check the type and parse. */
|
2015-10-06 19:57:00 +02:00
|
|
|
if (want_certtype >= DNS_CERTTYPE_RRBASE
|
|
|
|
&& type == (want_certtype - DNS_CERTTYPE_RRBASE)
|
|
|
|
&& r_key)
|
|
|
|
{
|
|
|
|
*r_key = xtrymalloc (dlen);
|
|
|
|
if (!*r_key)
|
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
|
|
|
else
|
|
|
|
{
|
|
|
|
memcpy (*r_key, pt, dlen);
|
|
|
|
*r_keylen = dlen;
|
|
|
|
err = 0;
|
|
|
|
}
|
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
else if (want_certtype >= DNS_CERTTYPE_RRBASE)
|
|
|
|
{
|
|
|
|
/* We did not found the requested RR. */
|
|
|
|
pt += dlen;
|
|
|
|
}
|
|
|
|
else if (type == T_CERT)
|
2011-11-28 18:35:19 +01:00
|
|
|
{
|
2015-10-06 17:34:13 +02:00
|
|
|
/* We got a CERT type. */
|
|
|
|
ctype = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
2011-11-28 18:35:19 +01:00
|
|
|
|
2015-10-06 17:34:13 +02:00
|
|
|
/* Skip the CERT key tag and algo which we don't need. */
|
|
|
|
pt += 3;
|
2011-11-28 18:35:19 +01:00
|
|
|
|
2015-10-06 17:34:13 +02:00
|
|
|
dlen -= 5;
|
2011-11-28 18:35:19 +01:00
|
|
|
|
2015-10-06 17:34:13 +02:00
|
|
|
/* 15 bytes takes us to here */
|
|
|
|
if (want_certtype && want_certtype != ctype)
|
|
|
|
; /* Not of the requested certtype. */
|
|
|
|
else if (ctype == DNS_CERTTYPE_PGP && dlen && r_key && r_keylen)
|
2015-04-23 15:42:56 +02:00
|
|
|
{
|
2015-10-06 17:34:13 +02:00
|
|
|
/* PGP type */
|
|
|
|
*r_key = xtrymalloc (dlen);
|
|
|
|
if (!*r_key)
|
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
|
|
|
else
|
|
|
|
{
|
|
|
|
memcpy (*r_key, pt, dlen);
|
|
|
|
*r_keylen = dlen;
|
|
|
|
err = 0;
|
|
|
|
}
|
|
|
|
goto leave;
|
2015-04-23 15:42:56 +02:00
|
|
|
}
|
2015-10-06 17:34:13 +02:00
|
|
|
else if (ctype == DNS_CERTTYPE_IPGP
|
|
|
|
&& dlen && dlen < 1023 && dlen >= pt[0] + 1)
|
2011-11-28 18:35:19 +01:00
|
|
|
{
|
2015-10-06 17:34:13 +02:00
|
|
|
/* IPGP type */
|
|
|
|
*r_fprlen = pt[0];
|
|
|
|
if (*r_fprlen)
|
2011-11-30 17:14:08 +01:00
|
|
|
{
|
2015-10-06 17:34:13 +02:00
|
|
|
*r_fpr = xtrymalloc (*r_fprlen);
|
|
|
|
if (!*r_fpr)
|
|
|
|
{
|
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
memcpy (*r_fpr, &pt[1], *r_fprlen);
|
2011-11-30 17:14:08 +01:00
|
|
|
}
|
2015-10-06 17:34:13 +02:00
|
|
|
else
|
|
|
|
*r_fpr = NULL;
|
2011-11-28 18:35:19 +01:00
|
|
|
|
2015-10-06 17:34:13 +02:00
|
|
|
if (dlen > *r_fprlen + 1)
|
2011-11-30 17:14:08 +01:00
|
|
|
{
|
2015-10-06 17:34:13 +02:00
|
|
|
*r_url = xtrymalloc (dlen - (*r_fprlen + 1) + 1);
|
|
|
|
if (!*r_fpr)
|
|
|
|
{
|
|
|
|
err = gpg_err_make (default_errsource,
|
|
|
|
gpg_err_code_from_syserror ());
|
|
|
|
xfree (*r_fpr);
|
|
|
|
*r_fpr = NULL;
|
|
|
|
goto leave;
|
|
|
|
}
|
|
|
|
memcpy (*r_url, &pt[*r_fprlen + 1],
|
|
|
|
dlen - (*r_fprlen + 1));
|
|
|
|
(*r_url)[dlen - (*r_fprlen + 1)] = '\0';
|
2011-11-30 17:14:08 +01:00
|
|
|
}
|
2015-10-06 17:34:13 +02:00
|
|
|
else
|
|
|
|
*r_url = NULL;
|
|
|
|
|
|
|
|
err = 0;
|
|
|
|
goto leave;
|
2011-11-28 18:35:19 +01:00
|
|
|
}
|
|
|
|
|
2015-10-06 17:34:13 +02:00
|
|
|
/* No subtype matches, so continue with the next answer. */
|
|
|
|
pt += dlen;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
/* Not a requested type - might be a CNAME. Try next item. */
|
|
|
|
pt += dlen;
|
2011-11-28 18:35:19 +01:00
|
|
|
}
|
|
|
|
}
|
2006-06-16 13:49:27 +02:00
|
|
|
}
|
|
|
|
|
2011-11-30 17:14:08 +01:00
|
|
|
leave:
|
2011-11-28 18:35:19 +01:00
|
|
|
xfree (answer);
|
2011-11-30 17:14:08 +01:00
|
|
|
return err;
|
|
|
|
|
2011-11-28 18:35:19 +01:00
|
|
|
#endif /*!USE_ADNS */
|
2006-06-16 13:49:27 +02:00
|
|
|
#else /* !USE_DNS_CERT */
|
2010-03-22 13:46:05 +01:00
|
|
|
(void)name;
|
2015-02-25 16:34:19 +01:00
|
|
|
if (r_key)
|
|
|
|
*r_key = NULL;
|
2015-04-23 15:42:56 +02:00
|
|
|
if (r_keylen)
|
|
|
|
*r_keylen = NULL;
|
2014-02-10 20:14:14 +01:00
|
|
|
*r_fpr = NULL;
|
|
|
|
*r_fprlen = 0;
|
|
|
|
*r_url = NULL;
|
2010-03-22 13:46:05 +01:00
|
|
|
|
2012-02-07 10:15:57 +01:00
|
|
|
return gpg_err_make (default_errsource, GPG_ERR_NOT_SUPPORTED);
|
2006-06-16 13:49:27 +02:00
|
|
|
#endif
|
|
|
|
}
|
2015-10-22 09:22:41 +02:00
|
|
|
|
|
|
|
#ifdef USE_DNS_SRV
|
|
|
|
static int
|
|
|
|
priosort(const void *a,const void *b)
|
|
|
|
{
|
|
|
|
const struct srventry *sa=a,*sb=b;
|
|
|
|
if(sa->priority>sb->priority)
|
|
|
|
return 1;
|
|
|
|
else if(sa->priority<sb->priority)
|
|
|
|
return -1;
|
|
|
|
else
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
int
|
|
|
|
getsrv (const char *name,struct srventry **list)
|
|
|
|
{
|
|
|
|
int srvcount=0;
|
|
|
|
u16 count;
|
|
|
|
int i, rc;
|
|
|
|
|
|
|
|
*list = NULL;
|
|
|
|
|
|
|
|
#ifdef USE_ADNS
|
|
|
|
{
|
|
|
|
adns_state state;
|
|
|
|
adns_answer *answer = NULL;
|
|
|
|
|
|
|
|
rc = adns_init (&state, adns_if_noerrprint, NULL);
|
|
|
|
if (rc)
|
|
|
|
{
|
|
|
|
log_error ("error initializing adns: %s\n", strerror (errno));
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
rc = adns_synchronous (state, name, adns_r_srv, adns_qf_quoteok_query,
|
|
|
|
&answer);
|
|
|
|
if (rc)
|
|
|
|
{
|
|
|
|
log_error ("DNS query failed: %s\n", strerror (errno));
|
|
|
|
adns_finish (state);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
if (answer->status != adns_s_ok
|
|
|
|
|| answer->type != adns_r_srv || !answer->nrrs)
|
|
|
|
{
|
|
|
|
log_error ("DNS query returned an error or no records: %s (%s)\n",
|
|
|
|
adns_strerror (answer->status),
|
|
|
|
adns_errabbrev (answer->status));
|
|
|
|
adns_free (answer);
|
|
|
|
adns_finish (state);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (count = 0; count < answer->nrrs; count++)
|
|
|
|
{
|
|
|
|
struct srventry *srv = NULL;
|
|
|
|
struct srventry *newlist;
|
|
|
|
|
2015-10-22 09:52:51 +02:00
|
|
|
if (strlen (answer->rrs.srvha[count].ha.host) >= sizeof srv->target)
|
2015-10-22 09:22:41 +02:00
|
|
|
{
|
|
|
|
log_info ("hostname in SRV record too long - skipped\n");
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
newlist = xtryrealloc (*list, (srvcount+1)*sizeof(struct srventry));
|
|
|
|
if (!newlist)
|
|
|
|
goto fail;
|
|
|
|
*list = newlist;
|
|
|
|
memset (&(*list)[srvcount], 0, sizeof(struct srventry));
|
|
|
|
srv = &(*list)[srvcount];
|
|
|
|
srvcount++;
|
|
|
|
|
|
|
|
srv->priority = answer->rrs.srvha[count].priority;
|
|
|
|
srv->weight = answer->rrs.srvha[count].weight;
|
|
|
|
srv->port = answer->rrs.srvha[count].port;
|
|
|
|
strcpy (srv->target, answer->rrs.srvha[count].ha.host);
|
|
|
|
}
|
|
|
|
|
|
|
|
adns_free (answer);
|
|
|
|
adns_finish (state);
|
|
|
|
}
|
|
|
|
#else /*!USE_ADNS*/
|
|
|
|
{
|
|
|
|
unsigned char answer[2048];
|
|
|
|
HEADER *header = (HEADER *)answer;
|
|
|
|
unsigned char *pt, *emsg;
|
|
|
|
int r;
|
|
|
|
u16 dlen;
|
|
|
|
|
|
|
|
r = res_query (name, C_IN, T_SRV, answer, sizeof answer);
|
|
|
|
if (r < sizeof (HEADER) || r > sizeof answer)
|
|
|
|
return -1;
|
|
|
|
if (header->rcode != NOERROR || !(count=ntohs (header->ancount)))
|
|
|
|
return 0; /* Error or no record found. */
|
|
|
|
|
|
|
|
emsg = &answer[r];
|
|
|
|
pt = &answer[sizeof(HEADER)];
|
|
|
|
|
|
|
|
/* Skip over the query */
|
|
|
|
rc = dn_skipname (pt, emsg);
|
|
|
|
if (rc == -1)
|
|
|
|
goto fail;
|
|
|
|
|
|
|
|
pt += rc + QFIXEDSZ;
|
|
|
|
|
|
|
|
while (count-- > 0 && pt < emsg)
|
|
|
|
{
|
|
|
|
struct srventry *srv=NULL;
|
|
|
|
u16 type,class;
|
|
|
|
struct srventry *newlist;
|
|
|
|
|
|
|
|
newlist = xtryrealloc (*list, (srvcount+1)*sizeof(struct srventry));
|
|
|
|
if (!newlist)
|
|
|
|
goto fail;
|
|
|
|
*list = newlist;
|
|
|
|
memset(&(*list)[srvcount],0,sizeof(struct srventry));
|
|
|
|
srv=&(*list)[srvcount];
|
|
|
|
srvcount++;
|
|
|
|
|
|
|
|
rc = dn_skipname(pt,emsg); /* the name we just queried for */
|
|
|
|
if (rc == -1)
|
|
|
|
goto fail;
|
|
|
|
pt+=rc;
|
|
|
|
|
|
|
|
/* Truncated message? */
|
|
|
|
if((emsg-pt)<16)
|
|
|
|
goto fail;
|
|
|
|
|
|
|
|
type = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
|
|
|
/* We asked for SRV and got something else !? */
|
|
|
|
if(type!=T_SRV)
|
|
|
|
goto fail;
|
|
|
|
|
|
|
|
class = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
|
|
|
/* We asked for IN and got something else !? */
|
|
|
|
if(class!=C_IN)
|
|
|
|
goto fail;
|
|
|
|
|
|
|
|
pt += 4; /* ttl */
|
|
|
|
dlen = buf16_to_u16 (pt);
|
|
|
|
pt += 2;
|
|
|
|
|
|
|
|
srv->priority = buf16_to_ushort (pt);
|
|
|
|
pt += 2;
|
|
|
|
srv->weight = buf16_to_ushort (pt);
|
|
|
|
pt += 2;
|
|
|
|
srv->port = buf16_to_ushort (pt);
|
|
|
|
pt += 2;
|
|
|
|
|
|
|
|
/* Get the name. 2782 doesn't allow name compression, but
|
|
|
|
dn_expand still works to pull the name out of the
|
|
|
|
packet. */
|
2015-10-22 09:52:51 +02:00
|
|
|
rc = dn_expand(answer,emsg,pt,srv->target, sizeof srv->target);
|
2015-10-22 09:22:41 +02:00
|
|
|
if (rc == 1 && srv->target[0] == 0) /* "." */
|
|
|
|
{
|
|
|
|
xfree(*list);
|
|
|
|
*list = NULL;
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
if (rc == -1)
|
|
|
|
goto fail;
|
|
|
|
pt += rc;
|
|
|
|
/* Corrupt packet? */
|
|
|
|
if (dlen != rc+6)
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
#endif /*!USE_ADNS*/
|
|
|
|
|
|
|
|
/* Now we have an array of all the srv records. */
|
|
|
|
|
|
|
|
/* Order by priority */
|
|
|
|
qsort(*list,srvcount,sizeof(struct srventry),priosort);
|
|
|
|
|
|
|
|
/* For each priority, move the zero-weighted items first. */
|
|
|
|
for (i=0; i < srvcount; i++)
|
|
|
|
{
|
|
|
|
int j;
|
|
|
|
|
|
|
|
for (j=i;j < srvcount && (*list)[i].priority == (*list)[j].priority; j++)
|
|
|
|
{
|
|
|
|
if((*list)[j].weight==0)
|
|
|
|
{
|
|
|
|
/* Swap j with i */
|
|
|
|
if(j!=i)
|
|
|
|
{
|
|
|
|
struct srventry temp;
|
|
|
|
|
|
|
|
memcpy (&temp,&(*list)[j],sizeof(struct srventry));
|
|
|
|
memcpy (&(*list)[j],&(*list)[i],sizeof(struct srventry));
|
|
|
|
memcpy (&(*list)[i],&temp,sizeof(struct srventry));
|
|
|
|
}
|
|
|
|
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Run the RFC-2782 weighting algorithm. We don't need very high
|
|
|
|
quality randomness for this, so regular libc srand/rand is
|
|
|
|
sufficient. Fixme: It is a bit questionaly to reinitalize srand
|
|
|
|
- better use a gnupg fucntion for this. */
|
|
|
|
srand(time(NULL)*getpid());
|
|
|
|
|
|
|
|
for (i=0; i < srvcount; i++)
|
|
|
|
{
|
|
|
|
int j;
|
|
|
|
float prio_count=0,chose;
|
|
|
|
|
|
|
|
for (j=i; j < srvcount && (*list)[i].priority == (*list)[j].priority; j++)
|
|
|
|
{
|
|
|
|
prio_count+=(*list)[j].weight;
|
|
|
|
(*list)[j].run_count=prio_count;
|
|
|
|
}
|
|
|
|
|
|
|
|
chose=prio_count*rand()/RAND_MAX;
|
|
|
|
|
|
|
|
for (j=i;j<srvcount && (*list)[i].priority==(*list)[j].priority;j++)
|
|
|
|
{
|
|
|
|
if (chose<=(*list)[j].run_count)
|
|
|
|
{
|
|
|
|
/* Swap j with i */
|
|
|
|
if(j!=i)
|
|
|
|
{
|
|
|
|
struct srventry temp;
|
|
|
|
|
|
|
|
memcpy(&temp,&(*list)[j],sizeof(struct srventry));
|
|
|
|
memcpy(&(*list)[j],&(*list)[i],sizeof(struct srventry));
|
|
|
|
memcpy(&(*list)[i],&temp,sizeof(struct srventry));
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return srvcount;
|
|
|
|
|
|
|
|
fail:
|
|
|
|
xfree(*list);
|
|
|
|
*list=NULL;
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
#endif /*USE_DNS_SRV*/
|