5 * Copyright (C) 2007-2008 Intel Corporation. All rights reserved.
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2 as
9 * published by the Free Software Foundation.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
29 #include <arpa/inet.h>
30 #include <netinet/in.h>
32 #include <connman/plugin.h>
33 #include <connman/resolver.h>
34 #include <connman/log.h>
46 struct sockaddr_in sin;
51 static GSList *server_list = NULL;
52 static GSList *request_list = NULL;
54 static GIOChannel *listener_channel = NULL;
55 static guint listener_watch = 0;
57 static struct request_data *find_request(guint16 id)
61 for (list = request_list; list; list = list->next) {
62 struct request_data *data = list->data;
71 static struct server_data *find_server(const char *interface,
76 DBG("interface %s server %s", interface, server);
78 for (list = server_list; list; list = list->next) {
79 struct server_data *data = list->data;
81 if (data->interface == NULL || data->server == NULL)
84 if (g_str_equal(data->interface, interface) == TRUE &&
85 g_str_equal(data->server, server) == TRUE)
92 static gboolean server_event(GIOChannel *channel, GIOCondition condition,
95 struct request_data *req;
96 unsigned char buf[768];
99 sk = g_io_channel_unix_get_fd(channel);
101 len = recv(sk, buf, sizeof(buf), 0);
105 DBG("Received %d bytes (id 0x%04x)", len, buf[0] | buf[1] << 8);
107 req = find_request(buf[0] | buf[1] << 8);
111 request_list = g_slist_remove(request_list, req);
113 sk = g_io_channel_unix_get_fd(listener_channel);
115 err = sendto(sk, buf, len, 0, (struct sockaddr *) &req->sin, req->len);
122 static struct server_data *create_server(const char *interface,
125 struct server_data *data;
126 struct sockaddr_in sin;
129 DBG("interface %s server %s", interface, server);
131 sk = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
133 connman_error("Failed to create server %s socket", server);
137 if (setsockopt(sk, SOL_SOCKET, SO_BINDTODEVICE,
138 interface, strlen(interface) + 1) < 0) {
139 connman_error("Failed to bind server %s to interface %s",
145 memset(&sin, 0, sizeof(sin));
146 sin.sin_family = AF_INET;
147 sin.sin_port = htons(53);
148 sin.sin_addr.s_addr = inet_addr(server);
150 if (connect(sk, (struct sockaddr *) &sin, sizeof(sin)) < 0) {
151 connman_error("Failed to connect server %s", server);
156 data = g_try_new0(struct server_data, 1);
158 connman_error("Failed to allocate server %s data", server);
163 data->channel = g_io_channel_unix_new(sk);
164 if (data->channel == NULL) {
165 connman_error("Failed to create server %s channel", server);
171 g_io_channel_set_close_on_unref(data->channel, TRUE);
173 data->watch = g_io_add_watch(data->channel, G_IO_IN,
176 data->interface = g_strdup(interface);
177 data->server = g_strdup(server);
182 static void destroy_server(struct server_data *data)
184 DBG("interface %s server %s", data->interface, data->server);
187 g_source_remove(data->watch);
189 g_io_channel_unref(data->channel);
191 g_free(data->interface);
192 g_free(data->server);
196 static int dnsproxy_append(const char *interface, const char *domain,
199 struct server_data *data;
201 DBG("interface %s server %s", interface, server);
203 data = create_server(interface, server);
207 server_list = g_slist_append(server_list, data);
212 static int dnsproxy_remove(const char *interface, const char *domain,
215 struct server_data *data;
217 DBG("interface %s server %s", interface, server);
219 data = find_server(interface, server);
223 server_list = g_slist_remove(server_list, data);
225 destroy_server(data);
230 static struct connman_resolver dnsproxy_resolver = {
232 .priority = CONNMAN_RESOLVER_PRIORITY_HIGH,
233 .append = dnsproxy_append,
234 .remove = dnsproxy_remove,
237 static gboolean listener_event(GIOChannel *channel, GIOCondition condition,
241 unsigned char buf[768];
242 struct request_data *req;
243 struct sockaddr_in sin;
244 socklen_t size = sizeof(sin);
247 sk = g_io_channel_unix_get_fd(channel);
249 memset(&sin, 0, sizeof(sin));
250 len = recvfrom(sk, buf, sizeof(buf), 0,
251 (struct sockaddr *) &sin, &size);
255 DBG("Received %d bytes (id 0x%04x)", len, buf[0] | buf[1] << 8);
257 if (g_slist_length(server_list) == 0)
260 req = find_request(buf[0] | (buf[1] << 8));
262 req = g_try_new0(struct request_data, 1);
266 memcpy(&req->sin, &sin, sizeof(sin));
268 req->id = buf[0] | (buf[1] << 8);
270 request_list = g_slist_append(request_list, req);
272 memcpy(&req->sin, &sin, sizeof(sin));
276 for (list = server_list; list; list = list->next) {
277 struct server_data *data = list->data;
279 sk = g_io_channel_unix_get_fd(data->channel);
281 err = send(sk, buf, len, 0);
287 static int create_listener(void)
289 const char *ifname = "lo";
290 struct sockaddr_in sin;
295 sk = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
297 connman_error("Failed to create listener socket");
301 //setsockopt(sk, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
302 //setsockopt(sk, SOL_IP, IP_PKTINFO, &opt, sizeof(opt));
304 if (setsockopt(sk, SOL_SOCKET, SO_BINDTODEVICE,
305 ifname, strlen(ifname) + 1) < 0) {
306 connman_error("Failed to bind listener interface");
311 memset(&sin, 0, sizeof(sin));
312 sin.sin_family = AF_INET;
313 sin.sin_port = htons(53);
314 sin.sin_addr.s_addr = inet_addr("127.0.0.1");
315 //sin.sin_addr.s_addr = INADDR_ANY;
317 if (bind(sk, (struct sockaddr *) &sin, sizeof(sin)) < 0) {
318 connman_error("Failed to bind listener socket");
323 listener_channel = g_io_channel_unix_new(sk);
324 if (listener_channel == NULL) {
325 connman_error("Failed to create listener channel");
330 g_io_channel_set_close_on_unref(listener_channel, TRUE);
332 listener_watch = g_io_add_watch(listener_channel, G_IO_IN,
333 listener_event, NULL);
338 static void destroy_listener(void)
344 if (listener_watch > 0)
345 g_source_remove(listener_watch);
347 for (list = request_list; list; list = list->next) {
348 struct request_data *data = list->data;
350 DBG("Dropping request (id 0x%04x)", data->id);
356 g_slist_free(request_list);
359 g_io_channel_unref(listener_channel);
362 static int dnsproxy_init(void)
366 err = create_listener();
370 err = connman_resolver_register(&dnsproxy_resolver);
379 static void dnsproxy_exit(void)
383 connman_resolver_unregister(&dnsproxy_resolver);
386 CONNMAN_PLUGIN_DEFINE(dnsproxy, "DNS proxy resolver plugin", VERSION,
387 dnsproxy_init, dnsproxy_exit)