loudmouth: loudmouth/lm-asyncns-resolver.c@a7cf42557aef (annotated)

457 9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	1	/* -- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -- */
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	2	/*
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	3	* Copyright (C) 2008 Imendio AB
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	4	*
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	5	* This program is free software; you can redistribute it and/or
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	6	* modify it under the terms of the GNU Lesser General Public License as
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	7	* published by the Free Software Foundation; either version 2 of the
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	8	* License, or (at your option) any later version.
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	9	*
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	10	* This program is distributed in the hope that it will be useful,
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	11	* but WITHOUT ANY WARRANTY; without even the implied warranty of
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	13	* Lesser General Public License for more details.
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	14	*
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	15	* You should have received a copy of the GNU Lesser General Public
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	16	* License along with this program; if not, write to the
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	17	* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	18	* Boston, MA 02111-1307, USA.
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	19	*/
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	20
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	21	#include <config.h>
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	22
471 a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	23	#include <string.h>
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	24	#include <asyncns.h>
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	25	#define freeaddrinfo(x) asyncns_freeaddrinfo(x)
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	26
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	27	#include "lm-error.h"
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	28	#include "lm-internals.h"
457 9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	29	#include "lm-marshal.h"
471 a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	30	#include "lm-misc.h"
457 9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	31	#include "lm-asyncns-resolver.h"
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	32
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	33	#define GET_PRIV(obj) (G_TYPE_INSTANCE_GET_PRIVATE ((obj), LM_TYPE_ASYNCNS_RESOLVER, LmAsyncnsResolverPriv))
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	34
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	35	typedef struct LmAsyncnsResolverPriv LmAsyncnsResolverPriv;
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	36	struct LmAsyncnsResolverPriv {
471 a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	37	GSource *watch_resolv;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	38	asyncns_query_t *resolv_query;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	39	asyncns_t *asyncns_ctx;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	40	GIOChannel *resolv_channel;
457 9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	41	};
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	42
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	43	static void asyncns_resolver_finalize (GObject *object);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	44	static void asyncns_resolver_lookup (LmResolver *resolver);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	45	static void asyncns_resolver_cancel (LmResolver *resolver);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	46
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	47	G_DEFINE_TYPE (LmAsyncnsResolver, lm_asyncns_resolver, LM_TYPE_RESOLVER)
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	48
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	49	static void
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	50	lm_asyncns_resolver_class_init (LmAsyncnsResolverClass *class)
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	51	{
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	52	GObjectClass *object_class = G_OBJECT_CLASS (class);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	53	LmResolverClass *resolver_class = LM_RESOLVER_CLASS (class);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	54
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	55	object_class->finalize = asyncns_resolver_finalize;
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	56
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	57	resolver_class->lookup = asyncns_resolver_lookup;
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	58	resolver_class->cancel = asyncns_resolver_cancel;
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	59
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	60	g_type_class_add_private (object_class, sizeof (LmAsyncnsResolverPriv));
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	61	}
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	62
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	63	static void
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	64	lm_asyncns_resolver_init (LmAsyncnsResolver *asyncns_resolver)
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	65	{
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	66	LmAsyncnsResolverPriv *priv;
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	67
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	68	priv = GET_PRIV (asyncns_resolver);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	69	}
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	70
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	71	static void
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	72	asyncns_resolver_finalize (GObject *object)
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	73	{
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	74	LmAsyncnsResolverPriv *priv;
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	75
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	76	priv = GET_PRIV (object);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	77
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	78	(G_OBJECT_CLASS (lm_asyncns_resolver_parent_class)->finalize) (object);
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	79	}
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	80
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	81	static void
471 a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	82	asyncns_resolver_cleanup (LmResolver *resolver)
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	83	{
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	84	LmAsyncnsResolverPriv *priv = GET_PRIV (resolver);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	85
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	86	if (priv->resolv_channel != NULL) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	87	g_io_channel_unref (priv->resolv_channel);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	88	priv->resolv_channel = NULL;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	89	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	90
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	91	if (priv->watch_resolv) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	92	g_source_destroy (priv->watch_resolv);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	93	priv->watch_resolv = NULL;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	94	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	95
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	96	if (priv->asyncns_ctx) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	97	asyncns_free (priv->asyncns_ctx);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	98	priv->asyncns_ctx = NULL;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	99	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	100
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	101	priv->resolv_query = NULL;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	102	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	103
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	104	static gboolean
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	105	asyncns_resolver_done (GSource *source,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	106	GIOCondition condition,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	107	gpointer data)
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	108	{
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	109	LmAsyncnsResolverPriv *priv = GET_PRIV (data);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	110	struct addrinfo *ans;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	111	int err;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	112	gboolean result = FALSE;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	113
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	114	/* process pending data */
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	115	asyncns_wait (priv->asyncns_ctx, FALSE);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	116
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	117	if (!asyncns_isdone (priv->asyncns_ctx, priv->resolv_query)) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	118	result = TRUE;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	119	} else {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	120	err = asyncns_getaddrinfo_done (priv->asyncns_ctx, priv->resolv_query, &ans);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	121	priv->resolv_query = NULL;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	122	/* Signal that we are done */
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	123
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	124	if (err) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	125	_lm_resolver_set_result (LM_RESOLVER (data),
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	126	LM_RESOLVER_RESULT_FAILED,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	127	NULL);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	128	} else {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	129	_lm_resolver_set_result (LM_RESOLVER (data),
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	130	LM_RESOLVER_RESULT_OK,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	131	ans);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	132	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	133
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	134	asyncns_resolver_cleanup (LM_RESOLVER (data));
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	135	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	136
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	137	return result;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	138	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	139
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	140	static gboolean
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	141	asyncns_resolver_prep (LmResolver resolver, GError *error)
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	142	{
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	143	LmAsyncnsResolverPriv *priv = GET_PRIV (resolver);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	144	GMainContext *context;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	145
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	146
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	147	if (priv->asyncns_ctx) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	148	return TRUE;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	149	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	150
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	151	priv->asyncns_ctx = asyncns_new (1);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	152	if (priv->asyncns_ctx == NULL) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	153	g_set_error (error,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	154	LM_ERROR,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	155	LM_ERROR_CONNECTION_FAILED,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	156	"can't initialise libasyncns");
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	157	return FALSE;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	158	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	159
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	160	priv->resolv_channel =
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	161	g_io_channel_unix_new (asyncns_fd (priv->asyncns_ctx));
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	162
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	163	g_object_get (resolver, "context", &context, NULL);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	164
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	165	priv->watch_resolv =
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	166	lm_misc_add_io_watch (context,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	167	priv->resolv_channel,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	168	G_IO_IN,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	169	(GIOFunc) asyncns_resolver_done,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	170	socket);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	171
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	172	return TRUE;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	173	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	174
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	175	static void
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	176	asyncns_resolver_lookup_host (LmResolver *resolver)
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	177	{
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	178	LmAsyncnsResolverPriv *priv = GET_PRIV (resolver);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	179	gchar *host;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	180	struct addrinfo req;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	181
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	182	g_object_get (resolver, "host", &host, NULL);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	183
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	184	memset (&req, 0, sizeof(req));
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	185	req.ai_family = AF_UNSPEC;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	186	req.ai_socktype = SOCK_STREAM;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	187	req.ai_protocol = IPPROTO_TCP;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	188
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	189	if (!asyncns_resolver_prep (resolver, NULL)) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	190	g_warning ("Signal error\n");
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	191	return;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	192	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	193
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	194	priv->resolv_query =
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	195	asyncns_getaddrinfo (priv->asyncns_ctx,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	196	host,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	197	NULL,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	198	&req);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	199	/*
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	200	asyncns_setuserdata (priv->asyncns_ctx,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	201	priv->resolv_query,
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	202	(gpointer) PHASE_2);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	203	*/
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	204	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	205
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	206	static void
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	207	asyncns_resolver_lookup_service (LmResolver *resolver)
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	208	{
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	209	}
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	210
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	211	static void
457 9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	212	asyncns_resolver_lookup (LmResolver *resolver)
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	213	{
471 a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	214	gint type;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	215
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	216	/* Start the DNS querying */
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	217
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	218	/* Decide if we are going to lookup a srv or host */
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	219	g_object_get (resolver, "type", &type, NULL);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	220
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	221	switch (type) {
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	222	case LM_RESOLVER_HOST:
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	223	asyncns_resolver_lookup_host (resolver);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	224	break;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	225	case LM_RESOLVER_SRV:
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	226	asyncns_resolver_lookup_service (resolver);
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	227	break;
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	228	};
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	229
a7cf42557aef Copied in code from LmOldSocket to LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: 457 diff changeset	230	/* End of DNS querying */
457 9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	231	}
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	232
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	233	static void
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	234	asyncns_resolver_cancel (LmResolver *resolver)
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	235	{
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	236	}
9eeae02afc18 Added LmAsyncnsResolver Mikael Hallendal <micke@imendio.com> parents: diff changeset	237

author	Mikael Hallendal <micke@imendio.com>
	Thu, 31 Jul 2008 19:50:01 +0200
changeset 471	a7cf42557aef
parent 457	9eeae02afc18
child 472	5aa76e995f0d
permissions	-rw-r--r--