1 /*
2 *
3 * BlueZ - Bluetooth protocol stack for Linux
4 *
5 * Copyright (C) 2001-2002 Nokia Corporation
6 * Copyright (C) 2002-2003 Maxim Krasnyansky <maxk@qualcomm.com>
7 * Copyright (C) 2002-2010 Marcel Holtmann <marcel@holtmann.org>
8 * Copyright (C) 2002-2003 Stephen Crane <steve.crane@rococosoft.com>
9 *
10 *
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License as published by
13 * the Free Software Foundation; either version 2 of the License, or
14 * (at your option) any later version.
15 *
16 * This program is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
20 *
21 * You should have received a copy of the GNU General Public License
22 * along with this program; if not, write to the Free Software
23 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
24 *
25 */
26
27 #ifdef HAVE_CONFIG_H
28 #include <config.h>
29 #endif
30
31 #include <stdio.h>
32 #include <errno.h>
33 #include <unistd.h>
34 #include <stdlib.h>
35 #include <sys/stat.h>
36 #include <sys/socket.h>
37 #include <cutils/sockets.h>
38
39 #include <bluetooth/bluetooth.h>
40 #include <bluetooth/l2cap.h>
41 #include <bluetooth/sdp.h>
42 #include <bluetooth/sdp_lib.h>
43
44 #include <sys/un.h>
45 #include <netinet/in.h>
46
47 #include <glib.h>
48
49 #include "log.h"
50 #include "sdpd.h"
51
52 static guint l2cap_id = 0, unix_id = 0;
53
54 static int l2cap_sock, unix_sock;
55
56 /*
57 * SDP server initialization on startup includes creating the
58 * l2cap and unix sockets over which discovery and registration clients
59 * access us respectively
60 */
init_server(uint16_t mtu,int master,int compat)61 static int init_server(uint16_t mtu, int master, int compat)
62 {
63 struct l2cap_options opts;
64 struct sockaddr_l2 l2addr;
65 struct sockaddr_un unaddr;
66 socklen_t optlen;
67
68 /* Register the public browse group root */
69 register_public_browse_group();
70
71 /* Register the SDP server's service record */
72 register_server_service();
73
74 /* Create L2CAP socket */
75 l2cap_sock = socket(PF_BLUETOOTH, SOCK_SEQPACKET, BTPROTO_L2CAP);
76 if (l2cap_sock < 0) {
77 error("opening L2CAP socket: %s", strerror(errno));
78 return -1;
79 }
80
81 memset(&l2addr, 0, sizeof(l2addr));
82 l2addr.l2_family = AF_BLUETOOTH;
83 bacpy(&l2addr.l2_bdaddr, BDADDR_ANY);
84 l2addr.l2_psm = htobs(SDP_PSM);
85
86 if (bind(l2cap_sock, (struct sockaddr *) &l2addr, sizeof(l2addr)) < 0) {
87 error("binding L2CAP socket: %s", strerror(errno));
88 return -1;
89 }
90
91 if (master) {
92 int opt = L2CAP_LM_MASTER;
93 if (setsockopt(l2cap_sock, SOL_L2CAP, L2CAP_LM, &opt, sizeof(opt)) < 0) {
94 error("setsockopt: %s", strerror(errno));
95 return -1;
96 }
97 }
98
99 if (mtu > 0) {
100 memset(&opts, 0, sizeof(opts));
101 optlen = sizeof(opts);
102
103 if (getsockopt(l2cap_sock, SOL_L2CAP, L2CAP_OPTIONS, &opts, &optlen) < 0) {
104 error("getsockopt: %s", strerror(errno));
105 return -1;
106 }
107
108 opts.omtu = mtu;
109 opts.imtu = mtu;
110
111 if (setsockopt(l2cap_sock, SOL_L2CAP, L2CAP_OPTIONS, &opts, sizeof(opts)) < 0) {
112 error("setsockopt: %s", strerror(errno));
113 return -1;
114 }
115 }
116
117 if (listen(l2cap_sock, 5) < 0) {
118 error("listen: %s", strerror(errno));
119 return -1;
120 }
121
122 if (!compat) {
123 unix_sock = -1;
124 return 0;
125 }
126 #if 0
127 /* Create local Unix socket */
128 unix_sock = socket(PF_UNIX, SOCK_STREAM, 0);
129 if (unix_sock < 0) {
130 error("opening UNIX socket: %s", strerror(errno));
131 return -1;
132 }
133
134 memset(&unaddr, 0, sizeof(unaddr));
135 unaddr.sun_family = AF_UNIX;
136 strcpy(unaddr.sun_path, SDP_UNIX_PATH);
137
138 unlink(unaddr.sun_path);
139
140 if (bind(unix_sock, (struct sockaddr *) &unaddr, sizeof(unaddr)) < 0) {
141 error("binding UNIX socket: %s", strerror(errno));
142 return -1;
143 }
144
145 listen(unix_sock, 5);
146
147 chmod(SDP_UNIX_PATH, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH);
148 #else
149 unix_sock = android_get_control_socket("bluetooth");
150 if (unix_sock < 0) {
151 error("Unable to get the control socket for 'bluetooth'");
152 return -1;
153 }
154
155 if (listen(unix_sock, 5)) {
156 error("Listening on local socket failed: %s", strerror(errno));
157 return -1;
158 }
159
160 info("Got Unix socket fd '%d' from environment", unix_sock);
161 #endif
162 return 0;
163 }
164
io_session_event(GIOChannel * chan,GIOCondition cond,gpointer data)165 static gboolean io_session_event(GIOChannel *chan, GIOCondition cond, gpointer data)
166 {
167 sdp_pdu_hdr_t hdr;
168 uint8_t *buf;
169 int sk, len, size;
170
171 if (cond & G_IO_NVAL)
172 return FALSE;
173
174 sk = g_io_channel_unix_get_fd(chan);
175
176 if (cond & (G_IO_HUP | G_IO_ERR)) {
177 sdp_svcdb_collect_all(sk);
178 return FALSE;
179 }
180
181 len = recv(sk, &hdr, sizeof(sdp_pdu_hdr_t), MSG_PEEK);
182 if (len <= 0) {
183 sdp_svcdb_collect_all(sk);
184 return FALSE;
185 }
186
187 size = sizeof(sdp_pdu_hdr_t) + ntohs(hdr.plen);
188 buf = malloc(size);
189 if (!buf)
190 return TRUE;
191
192 len = recv(sk, buf, size, 0);
193 if (len <= 0) {
194 sdp_svcdb_collect_all(sk);
195 free(buf);
196 return FALSE;
197 }
198
199 handle_request(sk, buf, len);
200
201 return TRUE;
202 }
203
io_accept_event(GIOChannel * chan,GIOCondition cond,gpointer data)204 static gboolean io_accept_event(GIOChannel *chan, GIOCondition cond, gpointer data)
205 {
206 GIOChannel *io;
207 int nsk;
208
209 if (cond & (G_IO_HUP | G_IO_ERR | G_IO_NVAL))
210 return FALSE;
211
212 if (data == &l2cap_sock) {
213 struct sockaddr_l2 addr;
214 socklen_t len = sizeof(addr);
215
216 nsk = accept(l2cap_sock, (struct sockaddr *) &addr, &len);
217 } else if (data == &unix_sock) {
218 struct sockaddr_un addr;
219 socklen_t len = sizeof(addr);
220
221 nsk = accept(unix_sock, (struct sockaddr *) &addr, &len);
222 } else
223 return FALSE;
224
225 if (nsk < 0) {
226 error("Can't accept connection: %s", strerror(errno));
227 return TRUE;
228 }
229
230 io = g_io_channel_unix_new(nsk);
231 g_io_channel_set_close_on_unref(io, TRUE);
232
233 g_io_add_watch(io, G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL,
234 io_session_event, data);
235
236 g_io_channel_unref(io);
237
238 return TRUE;
239 }
240
start_sdp_server(uint16_t mtu,const char * did,uint32_t flags)241 int start_sdp_server(uint16_t mtu, const char *did, uint32_t flags)
242 {
243 int compat = flags & SDP_SERVER_COMPAT;
244 int master = flags & SDP_SERVER_MASTER;
245 GIOChannel *io;
246
247 info("Starting SDP server");
248
249 if (init_server(mtu, master, compat) < 0) {
250 error("Server initialization failed");
251 return -1;
252 }
253
254 if (did && strlen(did) > 0) {
255 const char *ptr = did;
256 uint16_t vid = 0x0000, pid = 0x0000, ver = 0x0000;
257
258 vid = (uint16_t) strtol(ptr, NULL, 16);
259 ptr = strchr(ptr, ':');
260 if (ptr) {
261 pid = (uint16_t) strtol(ptr + 1, NULL, 16);
262 ptr = strchr(ptr + 1, ':');
263 if (ptr)
264 ver = (uint16_t) strtol(ptr + 1, NULL, 16);
265 register_device_id(vid, pid, ver);
266 }
267 }
268
269 io = g_io_channel_unix_new(l2cap_sock);
270 g_io_channel_set_close_on_unref(io, TRUE);
271
272 l2cap_id = g_io_add_watch(io, G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL,
273 io_accept_event, &l2cap_sock);
274 g_io_channel_unref(io);
275
276 if (compat && unix_sock > fileno(stderr)) {
277 io = g_io_channel_unix_new(unix_sock);
278 g_io_channel_set_close_on_unref(io, TRUE);
279
280 unix_id = g_io_add_watch(io,
281 G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL,
282 io_accept_event, &unix_sock);
283 g_io_channel_unref(io);
284 }
285
286 return 0;
287 }
288
stop_sdp_server(void)289 void stop_sdp_server(void)
290 {
291 info("Stopping SDP server");
292
293 sdp_svcdb_reset();
294
295 if (unix_id > 0)
296 g_source_remove(unix_id);
297
298 if (l2cap_id > 0)
299 g_source_remove(l2cap_id);
300
301 l2cap_id = unix_id = 0;
302 l2cap_sock = unix_sock = -1;
303 }
304