Annotation of sys/netbt/sco_upper.c, Revision 1.1.1.1
1.1 nbrk 1: /* $OpenBSD: sco_upper.c,v 1.1 2007/06/01 02:46:12 uwe Exp $ */
2: /* $NetBSD: sco_upper.c,v 1.6 2007/03/30 20:47:03 plunky Exp $ */
3:
4: /*-
5: * Copyright (c) 2006 Itronix Inc.
6: * All rights reserved.
7: *
8: * Written by Iain Hibbert for Itronix Inc.
9: *
10: * Redistribution and use in source and binary forms, with or without
11: * modification, are permitted provided that the following conditions
12: * are met:
13: * 1. Redistributions of source code must retain the above copyright
14: * notice, this list of conditions and the following disclaimer.
15: * 2. Redistributions in binary form must reproduce the above copyright
16: * notice, this list of conditions and the following disclaimer in the
17: * documentation and/or other materials provided with the distribution.
18: * 3. The name of Itronix Inc. may not be used to endorse
19: * or promote products derived from this software without specific
20: * prior written permission.
21: *
22: * THIS SOFTWARE IS PROVIDED BY ITRONIX INC. ``AS IS'' AND
23: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
24: * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
25: * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL ITRONIX INC. BE LIABLE FOR ANY
26: * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
27: * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
28: * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
29: * ON ANY THEORY OF LIABILITY, WHETHER IN
30: * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
31: * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
32: * POSSIBILITY OF SUCH DAMAGE.
33: */
34:
35: #include <sys/cdefs.h>
36:
37: #include <sys/param.h>
38: #include <sys/kernel.h>
39: #include <sys/mbuf.h>
40: #include <sys/proc.h>
41: #include <sys/systm.h>
42:
43: #include <netbt/bluetooth.h>
44: #include <netbt/hci.h>
45: #include <netbt/sco.h>
46:
47: /****************************************************************************
48: *
49: * SCO - Upper Protocol API
50: */
51:
52: struct sco_pcb_list sco_pcb = LIST_HEAD_INITIALIZER(sco_pcb);
53:
54: /*
55: * sco_attach(handle, proto, upper)
56: *
57: * Attach a new instance of SCO pcb to handle
58: */
59: int
60: sco_attach(struct sco_pcb **handle,
61: const struct btproto *proto, void *upper)
62: {
63: struct sco_pcb *pcb;
64:
65: KASSERT(handle != NULL);
66: KASSERT(proto != NULL);
67: KASSERT(upper != NULL);
68:
69: pcb = malloc(sizeof(struct sco_pcb), M_BLUETOOTH, M_NOWAIT);
70: if (pcb == NULL)
71: return ENOMEM;
72: bzero(pcb, sizeof *pcb);
73:
74: pcb->sp_proto = proto;
75: pcb->sp_upper = upper;
76:
77: LIST_INSERT_HEAD(&sco_pcb, pcb, sp_next);
78:
79: *handle = pcb;
80: return 0;
81: }
82:
83: /*
84: * sco_bind(pcb, sockaddr)
85: *
86: * Bind SCO pcb to local address
87: */
88: int
89: sco_bind(struct sco_pcb *pcb, struct sockaddr_bt *addr)
90: {
91:
92: bdaddr_copy(&pcb->sp_laddr, &addr->bt_bdaddr);
93: return 0;
94: }
95:
96: /*
97: * sco_sockaddr(pcb, sockaddr)
98: *
99: * Copy local address of PCB to sockaddr
100: */
101: int
102: sco_sockaddr(struct sco_pcb *pcb, struct sockaddr_bt *addr)
103: {
104:
105: memset(addr, 0, sizeof(struct sockaddr_bt));
106: addr->bt_len = sizeof(struct sockaddr_bt);
107: addr->bt_family = AF_BLUETOOTH;
108: bdaddr_copy(&addr->bt_bdaddr, &pcb->sp_laddr);
109: return 0;
110: }
111:
112: /*
113: * sco_connect(pcb, sockaddr)
114: *
115: * Initiate a SCO connection to the destination address.
116: */
117: int
118: sco_connect(struct sco_pcb *pcb, struct sockaddr_bt *dest)
119: {
120: hci_add_sco_con_cp cp;
121: struct hci_unit *unit;
122: struct hci_link *acl, *sco;
123: int err;
124:
125: if (pcb->sp_flags & SP_LISTENING)
126: return EINVAL;
127:
128: bdaddr_copy(&pcb->sp_raddr, &dest->bt_bdaddr);
129:
130: if (bdaddr_any(&pcb->sp_raddr))
131: return EDESTADDRREQ;
132:
133: if (bdaddr_any(&pcb->sp_laddr)) {
134: err = hci_route_lookup(&pcb->sp_laddr, &pcb->sp_raddr);
135: if (err)
136: return err;
137: }
138:
139: unit = hci_unit_lookup(&pcb->sp_laddr);
140: if (unit == NULL)
141: return ENETDOWN;
142:
143: /*
144: * We must have an already open ACL connection before we open the SCO
145: * connection, and since SCO connections dont happen on their own we
146: * will not open one, the application wanting this should have opened
147: * it previously.
148: */
149: acl = hci_link_lookup_bdaddr(unit, &pcb->sp_raddr, HCI_LINK_ACL);
150: if (acl == NULL || acl->hl_state != HCI_LINK_OPEN)
151: return EHOSTUNREACH;
152:
153: sco = hci_link_alloc(unit);
154: if (sco == NULL)
155: return ENOMEM;
156:
157: sco->hl_type = HCI_LINK_SCO;
158: bdaddr_copy(&sco->hl_bdaddr, &pcb->sp_raddr);
159:
160: sco->hl_link = hci_acl_open(unit, &pcb->sp_raddr);
161: KASSERT(sco->hl_link == acl);
162:
163: cp.con_handle = htole16(acl->hl_handle);
164: cp.pkt_type = htole16(0x00e0); /* HV1, HV2, HV3 */
165: err = hci_send_cmd(unit, HCI_CMD_ADD_SCO_CON, &cp, sizeof(cp));
166: if (err) {
167: hci_link_free(sco, err);
168: return err;
169: }
170:
171: sco->hl_sco = pcb;
172: pcb->sp_link = sco;
173:
174: pcb->sp_mtu = unit->hci_max_sco_size;
175: return 0;
176: }
177:
178: /*
179: * sco_peeraddr(pcb, sockaddr)
180: *
181: * Copy remote address of SCO pcb to sockaddr
182: */
183: int
184: sco_peeraddr(struct sco_pcb *pcb, struct sockaddr_bt *addr)
185: {
186:
187: memset(addr, 0, sizeof(struct sockaddr_bt));
188: addr->bt_len = sizeof(struct sockaddr_bt);
189: addr->bt_family = AF_BLUETOOTH;
190: bdaddr_copy(&addr->bt_bdaddr, &pcb->sp_raddr);
191: return 0;
192: }
193:
194: /*
195: * sco_disconnect(pcb, linger)
196: *
197: * Initiate disconnection of connected SCO pcb
198: */
199: int
200: sco_disconnect(struct sco_pcb *pcb, int linger)
201: {
202: hci_discon_cp cp;
203: struct hci_link *sco;
204: int err;
205:
206: sco = pcb->sp_link;
207: if (sco == NULL)
208: return EINVAL;
209:
210: cp.con_handle = htole16(sco->hl_handle);
211: cp.reason = 0x13; /* "Remote User Terminated Connection" */
212:
213: err = hci_send_cmd(sco->hl_unit, HCI_CMD_DISCONNECT, &cp, sizeof(cp));
214: if (err || linger == 0) {
215: sco->hl_sco = NULL;
216: pcb->sp_link = NULL;
217: hci_link_free(sco, err);
218: }
219:
220: return err;
221: }
222:
223: /*
224: * sco_detach(handle)
225: *
226: * Detach SCO pcb from handle and clear up
227: */
228: int
229: sco_detach(struct sco_pcb **handle)
230: {
231: struct sco_pcb *pcb;
232:
233: KASSERT(handle != NULL);
234: pcb = *handle;
235: *handle = NULL;
236:
237: if (pcb == NULL)
238: return EINVAL;
239:
240: if (pcb->sp_link != NULL) {
241: sco_disconnect(pcb, 0);
242: pcb->sp_link = NULL;
243: }
244:
245: LIST_REMOVE(pcb, sp_next);
246: free(pcb, M_BLUETOOTH);
247: return 0;
248: }
249:
250: /*
251: * sco_listen(pcb)
252: *
253: * Mark pcb as a listener.
254: */
255: int
256: sco_listen(struct sco_pcb *pcb)
257: {
258:
259: if (pcb->sp_link != NULL)
260: return EINVAL;
261:
262: pcb->sp_flags |= SP_LISTENING;
263: return 0;
264: }
265:
266: /*
267: * sco_send(pcb, mbuf)
268: *
269: * Send data on SCO pcb.
270: *
271: * Gross hackage, we just output the packet directly onto the unit queue.
272: * This will work fine for one channel per unit, but for more channels it
273: * really needs fixing. We set the context so that when the packet is sent,
274: * we can drop a record from the socket buffer.
275: */
276: int
277: sco_send(struct sco_pcb *pcb, struct mbuf *m)
278: {
279: hci_scodata_hdr_t *hdr;
280: int plen;
281:
282: if (pcb->sp_link == NULL) {
283: m_freem(m);
284: return EINVAL;
285: }
286:
287: plen = m->m_pkthdr.len;
288: DPRINTFN(10, "%d bytes\n", plen);
289:
290: /*
291: * This is a temporary limitation, as USB devices cannot
292: * handle SCO packet sizes that are not an integer number
293: * of Isochronous frames. See ubt(4)
294: */
295: if (plen != pcb->sp_mtu) {
296: m_freem(m);
297: return EMSGSIZE;
298: }
299:
300: M_PREPEND(m, sizeof(hci_scodata_hdr_t), M_DONTWAIT);
301: if (m == NULL)
302: return ENOMEM;
303:
304: hdr = mtod(m, hci_scodata_hdr_t *);
305: hdr->type = HCI_SCO_DATA_PKT;
306: hdr->con_handle = htole16(pcb->sp_link->hl_handle);
307: hdr->length = plen;
308:
309: pcb->sp_pending++;
310: M_SETCTX(m, pcb->sp_link);
311: hci_output_sco(pcb->sp_link->hl_unit, m);
312:
313: return 0;
314: }
315:
316: /*
317: * sco_setopt(pcb, option, addr)
318: *
319: * Set SCO pcb options
320: */
321: int
322: sco_setopt(struct sco_pcb *pcb, int opt, void *addr)
323: {
324: int err = 0;
325:
326: switch (opt) {
327: default:
328: err = ENOPROTOOPT;
329: break;
330: }
331:
332: return err;
333: }
334:
335: /*
336: * sco_getopt(pcb, option, addr)
337: *
338: * Get SCO pcb options
339: */
340: int
341: sco_getopt(struct sco_pcb *pcb, int opt, void *addr)
342: {
343:
344: switch (opt) {
345: case SO_SCO_MTU:
346: *(uint16_t *)addr = pcb->sp_mtu;
347: return sizeof(uint16_t);
348:
349: case SO_SCO_HANDLE:
350: if (pcb->sp_link) {
351: *(uint16_t *)addr = pcb->sp_link->hl_handle;
352: return sizeof(uint16_t);
353: }
354: break;
355:
356: default:
357: break;
358: }
359: return 0;
360: }
CVSweb
![[BACK]](/icons/back.gif){kind=icon}
Return to sco_upper.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / sys / netbt