Simplify glib/glib/tests setup
[glib.git] / gio / gnetworkservice.c
blob9ec009964281970fc483a68c30428fec06cbef04
1 /* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */
3 /* GIO - GLib Input, Output and Streaming Library
5 * Copyright (C) 2008 Red Hat, Inc.
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
17 * You should have received a copy of the GNU Lesser General
18 * Public License along with this library; if not, write to the
19 * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
20 * Boston, MA 02111-1307, USA.
23 #include "config.h"
24 #include <glib.h>
25 #include "glibintl.h"
27 #include "gnetworkservice.h"
29 #include "gcancellable.h"
30 #include "ginetaddress.h"
31 #include "ginetsocketaddress.h"
32 #include "gioerror.h"
33 #include "gnetworkaddress.h"
34 #include "gnetworkingprivate.h"
35 #include "gresolver.h"
36 #include "gtask.h"
37 #include "gsocketaddressenumerator.h"
38 #include "gsocketconnectable.h"
39 #include "gsrvtarget.h"
41 #include <stdlib.h>
42 #include <string.h>
45 /**
46 * SECTION:gnetworkservice
47 * @short_description: A GSocketConnectable for resolving SRV records
48 * @include: gio/gio.h
50 * Like #GNetworkAddress does with hostnames, #GNetworkService
51 * provides an easy way to resolve a SRV record, and then attempt to
52 * connect to one of the hosts that implements that service, handling
53 * service priority/weighting, multiple IP addresses, and multiple
54 * address families.
56 * See #GSrvTarget for more information about SRV records, and see
57 * #GSocketConnectable for and example of using the connectable
58 * interface.
61 /**
62 * GNetworkService:
64 * A #GSocketConnectable for resolving a SRV record and connecting to
65 * that service.
68 struct _GNetworkServicePrivate
70 gchar *service, *protocol, *domain, *scheme;
71 GList *targets;
74 enum {
75 PROP_0,
76 PROP_SERVICE,
77 PROP_PROTOCOL,
78 PROP_DOMAIN,
79 PROP_SCHEME
82 static void g_network_service_set_property (GObject *object,
83 guint prop_id,
84 const GValue *value,
85 GParamSpec *pspec);
86 static void g_network_service_get_property (GObject *object,
87 guint prop_id,
88 GValue *value,
89 GParamSpec *pspec);
91 static void g_network_service_connectable_iface_init (GSocketConnectableIface *iface);
92 static GSocketAddressEnumerator *g_network_service_connectable_enumerate (GSocketConnectable *connectable);
93 static GSocketAddressEnumerator *g_network_service_connectable_proxy_enumerate (GSocketConnectable *connectable);
95 G_DEFINE_TYPE_WITH_CODE (GNetworkService, g_network_service, G_TYPE_OBJECT,
96 G_IMPLEMENT_INTERFACE (G_TYPE_SOCKET_CONNECTABLE,
97 g_network_service_connectable_iface_init))
99 static void
100 g_network_service_finalize (GObject *object)
102 GNetworkService *srv = G_NETWORK_SERVICE (object);
104 g_free (srv->priv->service);
105 g_free (srv->priv->protocol);
106 g_free (srv->priv->domain);
107 g_free (srv->priv->scheme);
109 if (srv->priv->targets)
110 g_resolver_free_targets (srv->priv->targets);
112 G_OBJECT_CLASS (g_network_service_parent_class)->finalize (object);
115 static void
116 g_network_service_class_init (GNetworkServiceClass *klass)
118 GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
120 g_type_class_add_private (klass, sizeof (GNetworkServicePrivate));
122 gobject_class->set_property = g_network_service_set_property;
123 gobject_class->get_property = g_network_service_get_property;
124 gobject_class->finalize = g_network_service_finalize;
126 g_object_class_install_property (gobject_class, PROP_SERVICE,
127 g_param_spec_string ("service",
128 P_("Service"),
129 P_("Service name, eg \"ldap\""),
130 NULL,
131 G_PARAM_READWRITE |
132 G_PARAM_CONSTRUCT_ONLY |
133 G_PARAM_STATIC_STRINGS));
134 g_object_class_install_property (gobject_class, PROP_PROTOCOL,
135 g_param_spec_string ("protocol",
136 P_("Protocol"),
137 P_("Network protocol, eg \"tcp\""),
138 NULL,
139 G_PARAM_READWRITE |
140 G_PARAM_CONSTRUCT_ONLY |
141 G_PARAM_STATIC_STRINGS));
142 g_object_class_install_property (gobject_class, PROP_DOMAIN,
143 g_param_spec_string ("domain",
144 P_("Domain"),
145 P_("Network domain, eg, \"example.com\""),
146 NULL,
147 G_PARAM_READWRITE |
148 G_PARAM_CONSTRUCT_ONLY |
149 G_PARAM_STATIC_STRINGS));
150 g_object_class_install_property (gobject_class, PROP_DOMAIN,
151 g_param_spec_string ("scheme",
152 P_("Scheme"),
153 P_("Network scheme (default is to use service)"),
154 NULL,
155 G_PARAM_READWRITE |
156 G_PARAM_STATIC_STRINGS));
160 static void
161 g_network_service_connectable_iface_init (GSocketConnectableIface *connectable_iface)
163 connectable_iface->enumerate = g_network_service_connectable_enumerate;
164 connectable_iface->proxy_enumerate = g_network_service_connectable_proxy_enumerate;
167 static void
168 g_network_service_init (GNetworkService *srv)
170 srv->priv = G_TYPE_INSTANCE_GET_PRIVATE (srv, G_TYPE_NETWORK_SERVICE,
171 GNetworkServicePrivate);
174 static void
175 g_network_service_set_property (GObject *object,
176 guint prop_id,
177 const GValue *value,
178 GParamSpec *pspec)
180 GNetworkService *srv = G_NETWORK_SERVICE (object);
182 switch (prop_id)
184 case PROP_SERVICE:
185 srv->priv->service = g_value_dup_string (value);
186 break;
188 case PROP_PROTOCOL:
189 srv->priv->protocol = g_value_dup_string (value);
190 break;
192 case PROP_DOMAIN:
193 srv->priv->domain = g_value_dup_string (value);
194 break;
196 case PROP_SCHEME:
197 g_network_service_set_scheme (srv, g_value_get_string (value));
198 break;
200 default:
201 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
202 break;
206 static void
207 g_network_service_get_property (GObject *object,
208 guint prop_id,
209 GValue *value,
210 GParamSpec *pspec)
212 GNetworkService *srv = G_NETWORK_SERVICE (object);
214 switch (prop_id)
216 case PROP_SERVICE:
217 g_value_set_string (value, g_network_service_get_service (srv));
218 break;
220 case PROP_PROTOCOL:
221 g_value_set_string (value, g_network_service_get_protocol (srv));
222 break;
224 case PROP_DOMAIN:
225 g_value_set_string (value, g_network_service_get_domain (srv));
226 break;
228 case PROP_SCHEME:
229 g_value_set_string (value, g_network_service_get_scheme (srv));
230 break;
232 default:
233 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
234 break;
239 * g_network_service_new:
240 * @service: the service type to look up (eg, "ldap")
241 * @protocol: the networking protocol to use for @service (eg, "tcp")
242 * @domain: the DNS domain to look up the service in
244 * Creates a new #GNetworkService representing the given @service,
245 * @protocol, and @domain. This will initially be unresolved; use the
246 * #GSocketConnectable interface to resolve it.
248 * Return value: (transfer full) (type GNetworkService): a new #GNetworkService
250 * Since: 2.22
252 GSocketConnectable *
253 g_network_service_new (const gchar *service,
254 const gchar *protocol,
255 const gchar *domain)
257 return g_object_new (G_TYPE_NETWORK_SERVICE,
258 "service", service,
259 "protocol", protocol,
260 "domain", domain,
261 NULL);
265 * g_network_service_get_service:
266 * @srv: a #GNetworkService
268 * Gets @srv's service name (eg, "ldap").
270 * Return value: @srv's service name
272 * Since: 2.22
274 const gchar *
275 g_network_service_get_service (GNetworkService *srv)
277 g_return_val_if_fail (G_IS_NETWORK_SERVICE (srv), NULL);
279 return srv->priv->service;
283 * g_network_service_get_protocol:
284 * @srv: a #GNetworkService
286 * Gets @srv's protocol name (eg, "tcp").
288 * Return value: @srv's protocol name
290 * Since: 2.22
292 const gchar *
293 g_network_service_get_protocol (GNetworkService *srv)
295 g_return_val_if_fail (G_IS_NETWORK_SERVICE (srv), NULL);
297 return srv->priv->protocol;
301 * g_network_service_get_domain:
302 * @srv: a #GNetworkService
304 * Gets the domain that @srv serves. This might be either UTF-8 or
305 * ASCII-encoded, depending on what @srv was created with.
307 * Return value: @srv's domain name
309 * Since: 2.22
311 const gchar *
312 g_network_service_get_domain (GNetworkService *srv)
314 g_return_val_if_fail (G_IS_NETWORK_SERVICE (srv), NULL);
316 return srv->priv->domain;
320 * g_network_service_get_scheme:
321 * @srv: a #GNetworkService
323 * Get's the URI scheme used to resolve proxies. By default, the service name
324 * is used as scheme.
326 * Return value: @srv's scheme name
328 * Since: 2.26
330 const gchar *
331 g_network_service_get_scheme (GNetworkService *srv)
333 g_return_val_if_fail (G_IS_NETWORK_SERVICE (srv), NULL);
335 if (srv->priv->scheme)
336 return srv->priv->scheme;
337 else
338 return srv->priv->service;
342 * g_network_service_set_scheme:
343 * @srv: a #GNetworkService
344 * @scheme: a URI scheme
346 * Set's the URI scheme used to resolve proxies. By default, the service name
347 * is used as scheme.
349 * Since: 2.26
351 void
352 g_network_service_set_scheme (GNetworkService *srv,
353 const gchar *scheme)
355 g_return_if_fail (G_IS_NETWORK_SERVICE (srv));
357 if (srv->priv->scheme)
358 g_free (srv->priv->scheme);
359 srv->priv->scheme = g_strdup (scheme);
361 g_object_notify (G_OBJECT (srv), "scheme");
364 static GList *
365 g_network_service_fallback_targets (GNetworkService *srv)
367 GSrvTarget *target;
368 struct servent *entry;
369 guint16 port;
371 entry = getservbyname (srv->priv->service, "tcp");
372 port = entry ? g_ntohs (entry->s_port) : 0;
373 #ifdef HAVE_ENDSERVENT
374 endservent ();
375 #endif
377 if (entry == NULL)
378 return NULL;
380 target = g_srv_target_new (srv->priv->domain, port, 0, 0);
381 return g_list_append (NULL, target);
384 #define G_TYPE_NETWORK_SERVICE_ADDRESS_ENUMERATOR (_g_network_service_address_enumerator_get_type ())
385 #define G_NETWORK_SERVICE_ADDRESS_ENUMERATOR(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), G_TYPE_NETWORK_SERVICE_ADDRESS_ENUMERATOR, GNetworkServiceAddressEnumerator))
387 typedef struct {
388 GSocketAddressEnumerator parent_instance;
390 GResolver *resolver;
391 GNetworkService *srv;
392 GSocketAddressEnumerator *addr_enum;
393 GList *t;
394 gboolean use_proxy;
396 GError *error;
398 } GNetworkServiceAddressEnumerator;
400 typedef struct {
401 GSocketAddressEnumeratorClass parent_class;
403 } GNetworkServiceAddressEnumeratorClass;
405 static GType _g_network_service_address_enumerator_get_type (void);
406 G_DEFINE_TYPE (GNetworkServiceAddressEnumerator, _g_network_service_address_enumerator, G_TYPE_SOCKET_ADDRESS_ENUMERATOR)
408 static GSocketAddress *
409 g_network_service_address_enumerator_next (GSocketAddressEnumerator *enumerator,
410 GCancellable *cancellable,
411 GError **error)
413 GNetworkServiceAddressEnumerator *srv_enum =
414 G_NETWORK_SERVICE_ADDRESS_ENUMERATOR (enumerator);
415 GSocketAddress *ret = NULL;
417 /* If we haven't yet resolved srv, do that */
418 if (!srv_enum->srv->priv->targets)
420 GList *targets;
421 GError *my_error = NULL;
423 targets = g_resolver_lookup_service (srv_enum->resolver,
424 srv_enum->srv->priv->service,
425 srv_enum->srv->priv->protocol,
426 srv_enum->srv->priv->domain,
427 cancellable, &my_error);
428 if (!targets && g_error_matches (my_error, G_RESOLVER_ERROR,
429 G_RESOLVER_ERROR_NOT_FOUND))
431 targets = g_network_service_fallback_targets (srv_enum->srv);
432 if (targets)
433 g_clear_error (&my_error);
436 if (my_error)
438 g_propagate_error (error, my_error);
439 return NULL;
442 srv_enum->srv->priv->targets = targets;
443 srv_enum->t = srv_enum->srv->priv->targets;
446 /* Delegate to GNetworkAddress */
449 if (srv_enum->addr_enum == NULL && srv_enum->t)
451 GError *error = NULL;
452 gchar *uri;
453 gchar *hostname;
454 GSocketConnectable *addr;
455 GSrvTarget *target = srv_enum->t->data;
457 srv_enum->t = g_list_next (srv_enum->t);
459 hostname = g_hostname_to_ascii (g_srv_target_get_hostname (target));
461 if (hostname == NULL)
463 if (srv_enum->error == NULL)
464 srv_enum->error =
465 g_error_new (G_IO_ERROR, G_IO_ERROR_INVALID_ARGUMENT,
466 "Received invalid hostname '%s' from GSrvTarget",
467 g_srv_target_get_hostname (target));
468 continue;
471 uri = _g_uri_from_authority (g_network_service_get_scheme (srv_enum->srv),
472 hostname,
473 g_srv_target_get_port (target),
474 NULL);
475 g_free (hostname);
477 addr = g_network_address_parse_uri (uri,
478 g_srv_target_get_port (target),
479 &error);
480 g_free (uri);
482 if (addr == NULL)
484 if (srv_enum->error == NULL)
485 srv_enum->error = error;
486 continue;
489 if (srv_enum->use_proxy)
490 srv_enum->addr_enum = g_socket_connectable_proxy_enumerate (addr);
491 else
492 srv_enum->addr_enum = g_socket_connectable_enumerate (addr);
493 g_object_unref (addr);
496 if (srv_enum->addr_enum)
498 GError *error = NULL;
500 ret = g_socket_address_enumerator_next (srv_enum->addr_enum,
501 cancellable,
502 &error);
504 if (error)
506 if (srv_enum->error == NULL)
507 srv_enum->error = error;
508 else
509 g_error_free (error);
512 if (!ret)
514 g_object_unref (srv_enum->addr_enum);
515 srv_enum->addr_enum = NULL;
519 while (srv_enum->addr_enum == NULL && srv_enum->t);
521 if (ret == NULL && srv_enum->error)
523 g_propagate_error (error, srv_enum->error);
524 srv_enum->error = NULL;
527 return ret;
530 static void next_async_resolved_targets (GObject *source_object,
531 GAsyncResult *result,
532 gpointer user_data);
533 static void next_async_have_targets (GTask *srv_enum);
534 static void next_async_have_address (GObject *source_object,
535 GAsyncResult *result,
536 gpointer user_data);
538 static void
539 g_network_service_address_enumerator_next_async (GSocketAddressEnumerator *enumerator,
540 GCancellable *cancellable,
541 GAsyncReadyCallback callback,
542 gpointer user_data)
544 GNetworkServiceAddressEnumerator *srv_enum =
545 G_NETWORK_SERVICE_ADDRESS_ENUMERATOR (enumerator);
546 GTask *task;
548 task = g_task_new (enumerator, cancellable, callback, user_data);
550 /* If we haven't yet resolved srv, do that */
551 if (!srv_enum->srv->priv->targets)
553 g_resolver_lookup_service_async (srv_enum->resolver,
554 srv_enum->srv->priv->service,
555 srv_enum->srv->priv->protocol,
556 srv_enum->srv->priv->domain,
557 cancellable,
558 next_async_resolved_targets,
559 task);
561 else
562 next_async_have_targets (task);
565 static void
566 next_async_resolved_targets (GObject *source_object,
567 GAsyncResult *result,
568 gpointer user_data)
570 GTask *task = user_data;
571 GNetworkServiceAddressEnumerator *srv_enum = g_task_get_source_object (task);
572 GError *error = NULL;
573 GList *targets;
575 targets = g_resolver_lookup_service_finish (srv_enum->resolver,
576 result, &error);
578 if (!targets && g_error_matches (error, G_RESOLVER_ERROR,
579 G_RESOLVER_ERROR_NOT_FOUND))
581 targets = g_network_service_fallback_targets (srv_enum->srv);
582 if (targets)
583 g_clear_error (&error);
586 if (error)
588 g_task_return_error (task, error);
589 g_object_unref (task);
591 else
593 srv_enum->t = srv_enum->srv->priv->targets = targets;
594 next_async_have_targets (task);
598 static void
599 next_async_have_targets (GTask *task)
601 GNetworkServiceAddressEnumerator *srv_enum = g_task_get_source_object (task);
603 /* Delegate to GNetworkAddress */
604 if (srv_enum->addr_enum == NULL && srv_enum->t)
606 GSocketConnectable *addr;
607 GSrvTarget *target = srv_enum->t->data;
609 srv_enum->t = g_list_next (srv_enum->t);
610 addr = g_network_address_new (g_srv_target_get_hostname (target),
611 (guint16) g_srv_target_get_port (target));
613 if (srv_enum->use_proxy)
614 srv_enum->addr_enum = g_socket_connectable_proxy_enumerate (addr);
615 else
616 srv_enum->addr_enum = g_socket_connectable_enumerate (addr);
618 g_object_unref (addr);
621 if (srv_enum->addr_enum)
623 g_socket_address_enumerator_next_async (srv_enum->addr_enum,
624 g_task_get_cancellable (task),
625 next_async_have_address,
626 task);
628 else
630 if (srv_enum->error)
632 g_task_return_error (task, srv_enum->error);
633 srv_enum->error = NULL;
635 else
636 g_task_return_pointer (task, NULL, NULL);
638 g_object_unref (task);
642 static void
643 next_async_have_address (GObject *source_object,
644 GAsyncResult *result,
645 gpointer user_data)
647 GTask *task = user_data;
648 GNetworkServiceAddressEnumerator *srv_enum = g_task_get_source_object (task);
649 GSocketAddress *address;
650 GError *error = NULL;
652 address = g_socket_address_enumerator_next_finish (srv_enum->addr_enum,
653 result,
654 &error);
656 if (error)
658 if (srv_enum->error == NULL)
659 srv_enum->error = error;
660 else
661 g_error_free (error);
664 if (!address)
666 g_object_unref (srv_enum->addr_enum);
667 srv_enum->addr_enum = NULL;
669 next_async_have_targets (task);
671 else
673 g_task_return_pointer (task, address, g_object_unref);
674 g_object_unref (task);
678 static GSocketAddress *
679 g_network_service_address_enumerator_next_finish (GSocketAddressEnumerator *enumerator,
680 GAsyncResult *result,
681 GError **error)
683 return g_task_propagate_pointer (G_TASK (result), error);
686 static void
687 _g_network_service_address_enumerator_init (GNetworkServiceAddressEnumerator *enumerator)
691 static void
692 g_network_service_address_enumerator_finalize (GObject *object)
694 GNetworkServiceAddressEnumerator *srv_enum =
695 G_NETWORK_SERVICE_ADDRESS_ENUMERATOR (object);
697 if (srv_enum->srv)
698 g_object_unref (srv_enum->srv);
700 if (srv_enum->addr_enum)
701 g_object_unref (srv_enum->addr_enum);
703 if (srv_enum->resolver)
704 g_object_unref (srv_enum->resolver);
706 if (srv_enum->error)
707 g_error_free (srv_enum->error);
709 G_OBJECT_CLASS (_g_network_service_address_enumerator_parent_class)->finalize (object);
712 static void
713 _g_network_service_address_enumerator_class_init (GNetworkServiceAddressEnumeratorClass *srvenum_class)
715 GObjectClass *object_class = G_OBJECT_CLASS (srvenum_class);
716 GSocketAddressEnumeratorClass *enumerator_class =
717 G_SOCKET_ADDRESS_ENUMERATOR_CLASS (srvenum_class);
719 enumerator_class->next = g_network_service_address_enumerator_next;
720 enumerator_class->next_async = g_network_service_address_enumerator_next_async;
721 enumerator_class->next_finish = g_network_service_address_enumerator_next_finish;
723 object_class->finalize = g_network_service_address_enumerator_finalize;
726 static GSocketAddressEnumerator *
727 g_network_service_connectable_enumerate (GSocketConnectable *connectable)
729 GNetworkServiceAddressEnumerator *srv_enum;
731 srv_enum = g_object_new (G_TYPE_NETWORK_SERVICE_ADDRESS_ENUMERATOR, NULL);
732 srv_enum->srv = g_object_ref (connectable);
733 srv_enum->resolver = g_resolver_get_default ();
734 srv_enum->use_proxy = FALSE;
736 return G_SOCKET_ADDRESS_ENUMERATOR (srv_enum);
739 static GSocketAddressEnumerator *
740 g_network_service_connectable_proxy_enumerate (GSocketConnectable *connectable)
742 GSocketAddressEnumerator *addr_enum;
743 GNetworkServiceAddressEnumerator *srv_enum;
745 addr_enum = g_network_service_connectable_enumerate (connectable);
746 srv_enum = G_NETWORK_SERVICE_ADDRESS_ENUMERATOR (addr_enum);
747 srv_enum->use_proxy = TRUE;
749 return addr_enum;