1 /* GIO - GLib Input, Output and Streaming Library
3 * Copyright 2011 Red Hat, Inc.
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2.1 of the License, or (at your option) any later version.
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
15 * You should have received a copy of the GNU Lesser General
16 * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
25 #include "gnetworkmonitornetlink.h"
26 #include "gcredentials.h"
27 #include "ginetaddressmask.h"
28 #include "ginitable.h"
29 #include "giomodule-priv.h"
31 #include "glib/gstdio.h"
32 #include "gnetworkingprivate.h"
33 #include "gnetworkmonitor.h"
35 #include "gunixcredentialsmessage.h"
37 /* must come at the end to pick system includes from
38 * gnetworkingprivate.h */
39 #include <linux/netlink.h>
40 #include <linux/rtnetlink.h>
42 static GInitableIface *initable_parent_iface;
43 static void g_network_monitor_netlink_iface_init (GNetworkMonitorInterface *iface);
44 static void g_network_monitor_netlink_initable_iface_init (GInitableIface *iface);
46 struct _GNetworkMonitorNetlinkPrivate
49 GSource *source, *dump_source;
50 GMainContext *context;
52 GPtrArray *dump_networks;
55 static gboolean read_netlink_messages (GNetworkMonitorNetlink *nl,
57 static gboolean read_netlink_messages_callback (GSocket *socket,
58 GIOCondition condition,
60 static gboolean request_dump (GNetworkMonitorNetlink *nl,
63 #define g_network_monitor_netlink_get_type _g_network_monitor_netlink_get_type
64 G_DEFINE_TYPE_WITH_CODE (GNetworkMonitorNetlink, g_network_monitor_netlink, G_TYPE_NETWORK_MONITOR_BASE,
65 G_ADD_PRIVATE (GNetworkMonitorNetlink)
66 G_IMPLEMENT_INTERFACE (G_TYPE_NETWORK_MONITOR,
67 g_network_monitor_netlink_iface_init)
68 G_IMPLEMENT_INTERFACE (G_TYPE_INITABLE,
69 g_network_monitor_netlink_initable_iface_init)
70 _g_io_modules_ensure_extension_points_registered ();
71 g_io_extension_point_implement (G_NETWORK_MONITOR_EXTENSION_POINT_NAME,
77 g_network_monitor_netlink_init (GNetworkMonitorNetlink *nl)
79 nl->priv = g_network_monitor_netlink_get_instance_private (nl);
83 g_network_monitor_netlink_initable_init (GInitable *initable,
84 GCancellable *cancellable,
87 GNetworkMonitorNetlink *nl = G_NETWORK_MONITOR_NETLINK (initable);
89 struct sockaddr_nl snl;
91 /* We create the socket the old-school way because sockaddr_netlink
92 * can't be represented as a GSocketAddress
94 sockfd = g_socket (PF_NETLINK, SOCK_RAW, NETLINK_ROUTE, NULL);
98 g_set_error (error, G_IO_ERROR, g_io_error_from_errno (errsv),
99 _("Could not create network monitor: %s"),
104 snl.nl_family = AF_NETLINK;
105 snl.nl_pid = snl.nl_pad = 0;
106 snl.nl_groups = RTMGRP_IPV4_ROUTE | RTMGRP_IPV6_ROUTE;
107 if (bind (sockfd, (struct sockaddr *)&snl, sizeof (snl)) != 0)
110 g_set_error (error, G_IO_ERROR, g_io_error_from_errno (errsv),
111 _("Could not create network monitor: %s"),
113 (void) g_close (sockfd, NULL);
117 nl->priv->sock = g_socket_new_from_fd (sockfd, error);
120 g_prefix_error (error, "%s", _("Could not create network monitor: "));
121 (void) g_close (sockfd, NULL);
125 if (!g_socket_set_option (nl->priv->sock, SOL_SOCKET, SO_PASSCRED,
129 g_set_error (error, G_IO_ERROR, g_io_error_from_errno (errsv),
130 _("Could not create network monitor: %s"),
135 /* Request the current state */
136 if (!request_dump (nl, error))
139 /* And read responses; since we haven't yet marked the socket
140 * non-blocking, each call will block until a message is received.
142 while (nl->priv->dump_networks)
144 GError *local_error = NULL;
145 if (!read_netlink_messages (nl, &local_error))
147 g_warning ("%s", local_error->message);
148 g_clear_error (&local_error);
153 g_socket_set_blocking (nl->priv->sock, FALSE);
154 nl->priv->context = g_main_context_ref_thread_default ();
155 nl->priv->source = g_socket_create_source (nl->priv->sock, G_IO_IN, NULL);
156 g_source_set_callback (nl->priv->source,
157 (GSourceFunc) read_netlink_messages_callback, nl, NULL);
158 g_source_attach (nl->priv->source, nl->priv->context);
160 return initable_parent_iface->init (initable, cancellable, error);
164 request_dump (GNetworkMonitorNetlink *nl,
168 struct rtgenmsg *gen;
169 gchar buf[NLMSG_SPACE (sizeof (*gen))];
171 memset (buf, 0, sizeof (buf));
172 n = (struct nlmsghdr*) buf;
173 n->nlmsg_len = NLMSG_LENGTH (sizeof (*gen));
174 n->nlmsg_type = RTM_GETROUTE;
175 n->nlmsg_flags = NLM_F_REQUEST | NLM_F_DUMP;
177 gen = NLMSG_DATA (n);
178 gen->rtgen_family = AF_UNSPEC;
180 if (g_socket_send (nl->priv->sock, buf, sizeof (buf),
183 g_prefix_error (error, "%s", _("Could not get network status: "));
187 nl->priv->dump_networks = g_ptr_array_new_with_free_func (g_object_unref);
192 timeout_request_dump (gpointer user_data)
194 GNetworkMonitorNetlink *nl = user_data;
196 g_source_destroy (nl->priv->dump_source);
197 g_source_unref (nl->priv->dump_source);
198 nl->priv->dump_source = NULL;
200 request_dump (nl, NULL);
206 queue_request_dump (GNetworkMonitorNetlink *nl)
208 if (nl->priv->dump_networks)
211 if (nl->priv->dump_source)
213 g_source_destroy (nl->priv->dump_source);
214 g_source_unref (nl->priv->dump_source);
217 nl->priv->dump_source = g_timeout_source_new_seconds (1);
218 g_source_set_callback (nl->priv->dump_source,
219 (GSourceFunc) timeout_request_dump, nl, NULL);
220 g_source_attach (nl->priv->dump_source, nl->priv->context);
223 static GInetAddressMask *
224 create_inet_address_mask (GSocketFamily family,
228 GInetAddress *dest_addr;
229 GInetAddressMask *network;
232 dest_addr = g_inet_address_new_from_bytes (dest, family);
234 dest_addr = g_inet_address_new_any (family);
235 network = g_inet_address_mask_new (dest_addr, dest_len, NULL);
236 g_object_unref (dest_addr);
242 add_network (GNetworkMonitorNetlink *nl,
243 GSocketFamily family,
247 GInetAddressMask *network = create_inet_address_mask (family, dest, dest_len);
248 g_return_if_fail (network != NULL);
250 if (nl->priv->dump_networks)
251 g_ptr_array_add (nl->priv->dump_networks, g_object_ref (network));
253 g_network_monitor_base_add_network (G_NETWORK_MONITOR_BASE (nl), network);
255 g_object_unref (network);
259 remove_network (GNetworkMonitorNetlink *nl,
260 GSocketFamily family,
264 GInetAddressMask *network = create_inet_address_mask (family, dest, dest_len);
265 g_return_if_fail (network != NULL);
267 if (nl->priv->dump_networks)
269 GInetAddressMask **dump_networks = (GInetAddressMask **)nl->priv->dump_networks->pdata;
272 for (i = 0; i < nl->priv->dump_networks->len; i++)
274 if (g_inet_address_mask_equal (network, dump_networks[i]))
275 g_ptr_array_remove_index_fast (nl->priv->dump_networks, i--);
280 g_network_monitor_base_remove_network (G_NETWORK_MONITOR_BASE (nl), network);
283 g_object_unref (network);
287 finish_dump (GNetworkMonitorNetlink *nl)
289 g_network_monitor_base_set_networks (G_NETWORK_MONITOR_BASE (nl),
290 (GInetAddressMask **)nl->priv->dump_networks->pdata,
291 nl->priv->dump_networks->len);
292 g_ptr_array_free (nl->priv->dump_networks, TRUE);
293 nl->priv->dump_networks = NULL;
297 read_netlink_messages (GNetworkMonitorNetlink *nl,
303 GError *local_error = NULL;
304 GSocketAddress *addr = NULL;
305 struct nlmsghdr *msg;
308 struct sockaddr_nl source_sockaddr;
310 guint8 *dest, *gateway, *oif;
311 gboolean retval = TRUE;
316 flags = MSG_PEEK | MSG_TRUNC;
317 len = g_socket_receive_message (nl->priv->sock, NULL, &iv, 1,
318 NULL, NULL, &flags, NULL, &local_error);
325 iv.buffer = g_malloc (len);
327 len = g_socket_receive_message (nl->priv->sock, &addr, &iv, 1,
328 NULL, NULL, NULL, NULL, &local_error);
335 if (!g_socket_address_to_native (addr, &source_sockaddr, sizeof (source_sockaddr), &local_error))
341 /* If the sender port id is 0 (not fakeable) then the message is from the kernel */
342 if (source_sockaddr.nl_pid != 0)
345 msg = (struct nlmsghdr *) iv.buffer;
346 for (; len > 0; msg = NLMSG_NEXT (msg, len))
348 if (!NLMSG_OK (msg, (size_t) len))
350 g_set_error_literal (&local_error,
352 G_IO_ERROR_PARTIAL_INPUT,
353 "netlink message was truncated; shouldn't happen...");
358 switch (msg->nlmsg_type)
362 rtmsg = NLMSG_DATA (msg);
364 if (rtmsg->rtm_family != AF_INET && rtmsg->rtm_family != AF_INET6)
366 if (rtmsg->rtm_type == RTN_UNREACHABLE)
369 attrlen = NLMSG_PAYLOAD (msg, sizeof (struct rtmsg));
370 attr = RTM_RTA (rtmsg);
371 dest = gateway = oif = NULL;
372 while (RTA_OK (attr, attrlen))
374 if (attr->rta_type == RTA_DST)
375 dest = RTA_DATA (attr);
376 else if (attr->rta_type == RTA_GATEWAY)
377 gateway = RTA_DATA (attr);
378 else if (attr->rta_type == RTA_OIF)
379 oif = RTA_DATA (attr);
380 attr = RTA_NEXT (attr, attrlen);
383 if (dest || gateway || oif)
385 /* Unless we're processing the results of a dump, ignore
386 * IPv6 link-local multicast routes, which are added and
387 * removed all the time for some reason.
389 #define UNALIGNED_IN6_IS_ADDR_MC_LINKLOCAL(a) \
390 ((a[0] == 0xff) && ((a[1] & 0xf) == 0x2))
392 if (!nl->priv->dump_networks &&
393 rtmsg->rtm_family == AF_INET6 &&
394 rtmsg->rtm_dst_len != 0 &&
395 (dest && UNALIGNED_IN6_IS_ADDR_MC_LINKLOCAL (dest)))
398 if (msg->nlmsg_type == RTM_NEWROUTE)
399 add_network (nl, rtmsg->rtm_family, dest, rtmsg->rtm_dst_len);
401 remove_network (nl, rtmsg->rtm_family, dest, rtmsg->rtm_dst_len);
402 queue_request_dump (nl);
412 struct nlmsgerr *e = NLMSG_DATA (msg);
414 g_set_error (&local_error,
416 g_io_error_from_errno (-e->error),
418 g_strerror (-e->error));
424 g_set_error (&local_error,
426 G_IO_ERROR_INVALID_DATA,
427 "unexpected netlink message %d",
436 g_clear_object (&addr);
438 if (!retval && nl->priv->dump_networks)
442 g_propagate_prefixed_error (error, local_error, "Error on netlink socket: ");
448 g_network_monitor_netlink_finalize (GObject *object)
450 GNetworkMonitorNetlink *nl = G_NETWORK_MONITOR_NETLINK (object);
452 if (nl->priv->source)
454 g_source_destroy (nl->priv->source);
455 g_source_unref (nl->priv->source);
458 if (nl->priv->dump_source)
460 g_source_destroy (nl->priv->dump_source);
461 g_source_unref (nl->priv->dump_source);
466 g_socket_close (nl->priv->sock, NULL);
467 g_object_unref (nl->priv->sock);
470 g_clear_pointer (&nl->priv->context, g_main_context_unref);
471 g_clear_pointer (&nl->priv->dump_networks, g_ptr_array_unref);
473 G_OBJECT_CLASS (g_network_monitor_netlink_parent_class)->finalize (object);
477 read_netlink_messages_callback (GSocket *socket,
478 GIOCondition condition,
481 GError *error = NULL;
482 GNetworkMonitorNetlink *nl = G_NETWORK_MONITOR_NETLINK (user_data);
484 if (!read_netlink_messages (nl, &error))
486 g_warning ("Error reading netlink message: %s", error->message);
487 g_clear_error (&error);
495 g_network_monitor_netlink_class_init (GNetworkMonitorNetlinkClass *nl_class)
497 GObjectClass *gobject_class = G_OBJECT_CLASS (nl_class);
499 gobject_class->finalize = g_network_monitor_netlink_finalize;
503 g_network_monitor_netlink_iface_init (GNetworkMonitorInterface *monitor_iface)
508 g_network_monitor_netlink_initable_iface_init (GInitableIface *iface)
510 initable_parent_iface = g_type_interface_peek_parent (iface);
512 iface->init = g_network_monitor_netlink_initable_init;