1878ed226SJulian Elischer /* 2878ed226SJulian Elischer * ng_btsocket_l2cap.c 3878ed226SJulian Elischer * 4878ed226SJulian Elischer * Copyright (c) 2001-2002 Maksim Yevmenkin <m_evmenkin@yahoo.com> 5878ed226SJulian Elischer * All rights reserved. 6878ed226SJulian Elischer * 7878ed226SJulian Elischer * Redistribution and use in source and binary forms, with or without 8878ed226SJulian Elischer * modification, are permitted provided that the following conditions 9878ed226SJulian Elischer * are met: 10878ed226SJulian Elischer * 1. Redistributions of source code must retain the above copyright 11878ed226SJulian Elischer * notice, this list of conditions and the following disclaimer. 12878ed226SJulian Elischer * 2. Redistributions in binary form must reproduce the above copyright 13878ed226SJulian Elischer * notice, this list of conditions and the following disclaimer in the 14878ed226SJulian Elischer * documentation and/or other materials provided with the distribution. 15878ed226SJulian Elischer * 16878ed226SJulian Elischer * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 17878ed226SJulian Elischer * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 18878ed226SJulian Elischer * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 19878ed226SJulian Elischer * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 20878ed226SJulian Elischer * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 21878ed226SJulian Elischer * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 22878ed226SJulian Elischer * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 23878ed226SJulian Elischer * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 24878ed226SJulian Elischer * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 25878ed226SJulian Elischer * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 26878ed226SJulian Elischer * SUCH DAMAGE. 27878ed226SJulian Elischer * 280986ab12SMaksim Yevmenkin * $Id: ng_btsocket_l2cap.c,v 1.16 2003/09/14 23:29:06 max Exp $ 29878ed226SJulian Elischer * $FreeBSD$ 30878ed226SJulian Elischer */ 31878ed226SJulian Elischer 32878ed226SJulian Elischer #include <sys/param.h> 33878ed226SJulian Elischer #include <sys/systm.h> 340986ab12SMaksim Yevmenkin #include <sys/bitstring.h> 35878ed226SJulian Elischer #include <sys/domain.h> 36878ed226SJulian Elischer #include <sys/endian.h> 37878ed226SJulian Elischer #include <sys/errno.h> 38878ed226SJulian Elischer #include <sys/filedesc.h> 39878ed226SJulian Elischer #include <sys/ioccom.h> 40878ed226SJulian Elischer #include <sys/kernel.h> 41878ed226SJulian Elischer #include <sys/lock.h> 42878ed226SJulian Elischer #include <sys/malloc.h> 43878ed226SJulian Elischer #include <sys/mbuf.h> 44878ed226SJulian Elischer #include <sys/mutex.h> 45878ed226SJulian Elischer #include <sys/protosw.h> 46878ed226SJulian Elischer #include <sys/queue.h> 47878ed226SJulian Elischer #include <sys/socket.h> 48878ed226SJulian Elischer #include <sys/socketvar.h> 49878ed226SJulian Elischer #include <sys/sysctl.h> 50878ed226SJulian Elischer #include <sys/taskqueue.h> 51878ed226SJulian Elischer #include <netgraph/ng_message.h> 52878ed226SJulian Elischer #include <netgraph/netgraph.h> 53878ed226SJulian Elischer #include "ng_bluetooth.h" 54878ed226SJulian Elischer #include "ng_hci.h" 55878ed226SJulian Elischer #include "ng_l2cap.h" 56878ed226SJulian Elischer #include "ng_btsocket.h" 57878ed226SJulian Elischer #include "ng_btsocket_l2cap.h" 58878ed226SJulian Elischer 59878ed226SJulian Elischer /* MALLOC define */ 60878ed226SJulian Elischer #ifdef NG_SEPARATE_MALLOC 61878ed226SJulian Elischer MALLOC_DEFINE(M_NETGRAPH_BTSOCKET_L2CAP, "netgraph_btsocks_l2cap", 62878ed226SJulian Elischer "Netgraph Bluetooth L2CAP sockets"); 63878ed226SJulian Elischer #else 64878ed226SJulian Elischer #define M_NETGRAPH_BTSOCKET_L2CAP M_NETGRAPH 65878ed226SJulian Elischer #endif /* NG_SEPARATE_MALLOC */ 66878ed226SJulian Elischer 67878ed226SJulian Elischer /* Netgraph node methods */ 68878ed226SJulian Elischer static ng_constructor_t ng_btsocket_l2cap_node_constructor; 69878ed226SJulian Elischer static ng_rcvmsg_t ng_btsocket_l2cap_node_rcvmsg; 70878ed226SJulian Elischer static ng_shutdown_t ng_btsocket_l2cap_node_shutdown; 71878ed226SJulian Elischer static ng_newhook_t ng_btsocket_l2cap_node_newhook; 72878ed226SJulian Elischer static ng_connect_t ng_btsocket_l2cap_node_connect; 73878ed226SJulian Elischer static ng_rcvdata_t ng_btsocket_l2cap_node_rcvdata; 74878ed226SJulian Elischer static ng_disconnect_t ng_btsocket_l2cap_node_disconnect; 75878ed226SJulian Elischer 76878ed226SJulian Elischer static void ng_btsocket_l2cap_input (void *, int); 77878ed226SJulian Elischer static void ng_btsocket_l2cap_rtclean (void *, int); 78878ed226SJulian Elischer 79878ed226SJulian Elischer /* Netgraph type descriptor */ 80878ed226SJulian Elischer static struct ng_type typestruct = { 81878ed226SJulian Elischer NG_ABI_VERSION, 82878ed226SJulian Elischer NG_BTSOCKET_L2CAP_NODE_TYPE, /* typename */ 83878ed226SJulian Elischer NULL, /* modevent */ 84878ed226SJulian Elischer ng_btsocket_l2cap_node_constructor, /* constructor */ 85878ed226SJulian Elischer ng_btsocket_l2cap_node_rcvmsg, /* control message */ 86878ed226SJulian Elischer ng_btsocket_l2cap_node_shutdown, /* destructor */ 87878ed226SJulian Elischer ng_btsocket_l2cap_node_newhook, /* new hook */ 88878ed226SJulian Elischer NULL, /* find hook */ 89878ed226SJulian Elischer ng_btsocket_l2cap_node_connect, /* connect hook */ 90878ed226SJulian Elischer ng_btsocket_l2cap_node_rcvdata, /* data */ 91878ed226SJulian Elischer ng_btsocket_l2cap_node_disconnect, /* disconnect hook */ 92878ed226SJulian Elischer NULL /* node command list */ 93878ed226SJulian Elischer }; 94878ed226SJulian Elischer 95878ed226SJulian Elischer /* Globals */ 96878ed226SJulian Elischer extern int ifqmaxlen; 97878ed226SJulian Elischer static u_int32_t ng_btsocket_l2cap_debug_level; 98878ed226SJulian Elischer static node_p ng_btsocket_l2cap_node; 99878ed226SJulian Elischer static struct ng_bt_itemq ng_btsocket_l2cap_queue; 100878ed226SJulian Elischer static struct mtx ng_btsocket_l2cap_queue_mtx; 101878ed226SJulian Elischer static struct task ng_btsocket_l2cap_queue_task; 102878ed226SJulian Elischer static LIST_HEAD(, ng_btsocket_l2cap_pcb) ng_btsocket_l2cap_sockets; 103878ed226SJulian Elischer static struct mtx ng_btsocket_l2cap_sockets_mtx; 104878ed226SJulian Elischer static LIST_HEAD(, ng_btsocket_l2cap_rtentry) ng_btsocket_l2cap_rt; 105878ed226SJulian Elischer static struct mtx ng_btsocket_l2cap_rt_mtx; 106878ed226SJulian Elischer static struct task ng_btsocket_l2cap_rt_task; 107878ed226SJulian Elischer 108878ed226SJulian Elischer /* Sysctl tree */ 109878ed226SJulian Elischer SYSCTL_DECL(_net_bluetooth_l2cap_sockets); 110878ed226SJulian Elischer SYSCTL_NODE(_net_bluetooth_l2cap_sockets, OID_AUTO, seq, CTLFLAG_RW, 111878ed226SJulian Elischer 0, "Bluetooth SEQPACKET L2CAP sockets family"); 112878ed226SJulian Elischer SYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, debug_level, 113878ed226SJulian Elischer CTLFLAG_RW, 114878ed226SJulian Elischer &ng_btsocket_l2cap_debug_level, NG_BTSOCKET_WARN_LEVEL, 115878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets debug level"); 116878ed226SJulian Elischer SYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_len, 117878ed226SJulian Elischer CTLFLAG_RD, 118878ed226SJulian Elischer &ng_btsocket_l2cap_queue.len, 0, 119878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets input queue length"); 120878ed226SJulian Elischer SYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_maxlen, 121878ed226SJulian Elischer CTLFLAG_RD, 122878ed226SJulian Elischer &ng_btsocket_l2cap_queue.maxlen, 0, 123878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets input queue max. length"); 124878ed226SJulian Elischer SYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_drops, 125878ed226SJulian Elischer CTLFLAG_RD, 126878ed226SJulian Elischer &ng_btsocket_l2cap_queue.drops, 0, 127878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets input queue drops"); 128878ed226SJulian Elischer 129878ed226SJulian Elischer /* Debug */ 130878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_INFO \ 131878ed226SJulian Elischer if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_INFO_LEVEL) \ 132878ed226SJulian Elischer printf 133878ed226SJulian Elischer 134878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_WARN \ 135878ed226SJulian Elischer if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_WARN_LEVEL) \ 136878ed226SJulian Elischer printf 137878ed226SJulian Elischer 138878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_ERR \ 139878ed226SJulian Elischer if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ERR_LEVEL) \ 140878ed226SJulian Elischer printf 141878ed226SJulian Elischer 142878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_ALERT \ 143878ed226SJulian Elischer if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ALERT_LEVEL) \ 144878ed226SJulian Elischer printf 145878ed226SJulian Elischer 146878ed226SJulian Elischer /* 147878ed226SJulian Elischer * Netgraph message processing routines 148878ed226SJulian Elischer */ 149878ed226SJulian Elischer 150878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_con_req_rsp 151f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 152878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_con_rsp_rsp 153f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 154878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_con_ind 155f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 156878ed226SJulian Elischer 157878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_cfg_req_rsp 158f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 159878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp 160f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 161878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_cfg_ind 162f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 163878ed226SJulian Elischer 164878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_discon_rsp 165f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 166878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_discon_ind 167f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 168878ed226SJulian Elischer 169878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_write_rsp 170f2bb1caeSJulian Elischer (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 171878ed226SJulian Elischer 172878ed226SJulian Elischer /* 173878ed226SJulian Elischer * Send L2CA_xxx messages to the lower layer 174878ed226SJulian Elischer */ 175878ed226SJulian Elischer 176878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_con_req 177878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 178878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_con_rsp_req 179878ed226SJulian Elischer (u_int32_t, ng_btsocket_l2cap_rtentry_p, bdaddr_p, int, int, int); 180878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_cfg_req 181878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 182878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_cfg_rsp 183878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 184878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_discon_req 185878ed226SJulian Elischer (u_int32_t, ng_btsocket_l2cap_pcb_p); 186878ed226SJulian Elischer 187878ed226SJulian Elischer static int ng_btsocket_l2cap_send2 188878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 189878ed226SJulian Elischer 190878ed226SJulian Elischer /* 191878ed226SJulian Elischer * Timeout processing routines 192878ed226SJulian Elischer */ 193878ed226SJulian Elischer 194878ed226SJulian Elischer static void ng_btsocket_l2cap_timeout (ng_btsocket_l2cap_pcb_p); 195878ed226SJulian Elischer static void ng_btsocket_l2cap_untimeout (ng_btsocket_l2cap_pcb_p); 196878ed226SJulian Elischer static void ng_btsocket_l2cap_process_timeout (void *); 197878ed226SJulian Elischer 198878ed226SJulian Elischer /* 199878ed226SJulian Elischer * Other stuff 200878ed226SJulian Elischer */ 201878ed226SJulian Elischer 202878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_addr(bdaddr_p, int); 203878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_token(u_int32_t); 204878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_cid (bdaddr_p, int); 205878ed226SJulian Elischer static int ng_btsocket_l2cap_result2errno(int); 206878ed226SJulian Elischer 207f2bb1caeSJulian Elischer #define ng_btsocket_l2cap_wakeup_input_task() \ 208f2bb1caeSJulian Elischer taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_queue_task) 209f2bb1caeSJulian Elischer 210f2bb1caeSJulian Elischer #define ng_btsocket_l2cap_wakeup_route_task() \ 211f2bb1caeSJulian Elischer taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_rt_task) 212f2bb1caeSJulian Elischer 213878ed226SJulian Elischer /***************************************************************************** 214878ed226SJulian Elischer ***************************************************************************** 215878ed226SJulian Elischer ** Netgraph node interface 216878ed226SJulian Elischer ***************************************************************************** 217878ed226SJulian Elischer *****************************************************************************/ 218878ed226SJulian Elischer 219878ed226SJulian Elischer /* 220878ed226SJulian Elischer * Netgraph node constructor. Do not allow to create node of this type. 221878ed226SJulian Elischer */ 222878ed226SJulian Elischer 223878ed226SJulian Elischer static int 224878ed226SJulian Elischer ng_btsocket_l2cap_node_constructor(node_p node) 225878ed226SJulian Elischer { 226878ed226SJulian Elischer return (EINVAL); 227878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_constructor */ 228878ed226SJulian Elischer 229878ed226SJulian Elischer /* 230878ed226SJulian Elischer * Do local shutdown processing. Let old node go and create new fresh one. 231878ed226SJulian Elischer */ 232878ed226SJulian Elischer 233878ed226SJulian Elischer static int 234878ed226SJulian Elischer ng_btsocket_l2cap_node_shutdown(node_p node) 235878ed226SJulian Elischer { 236878ed226SJulian Elischer int error = 0; 237878ed226SJulian Elischer 238878ed226SJulian Elischer NG_NODE_UNREF(node); 239878ed226SJulian Elischer 240878ed226SJulian Elischer /* Create new node */ 241878ed226SJulian Elischer error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 242878ed226SJulian Elischer if (error != 0) { 243878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 244878ed226SJulian Elischer "%s: Could not create Netgraph node, error=%d\n", __func__, error); 245878ed226SJulian Elischer 246878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 247878ed226SJulian Elischer 248878ed226SJulian Elischer return (error); 249878ed226SJulian Elischer } 250878ed226SJulian Elischer 251878ed226SJulian Elischer error = ng_name_node(ng_btsocket_l2cap_node, 252878ed226SJulian Elischer NG_BTSOCKET_L2CAP_NODE_TYPE); 253878ed226SJulian Elischer if (error != NULL) { 254878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 255878ed226SJulian Elischer "%s: Could not name Netgraph node, error=%d\n", __func__, error); 256878ed226SJulian Elischer 257878ed226SJulian Elischer NG_NODE_UNREF(ng_btsocket_l2cap_node); 258878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 259878ed226SJulian Elischer 260878ed226SJulian Elischer return (error); 261878ed226SJulian Elischer } 262878ed226SJulian Elischer 263878ed226SJulian Elischer return (0); 264878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_shutdown */ 265878ed226SJulian Elischer 266878ed226SJulian Elischer /* 267878ed226SJulian Elischer * We allow any hook to be connected to the node. 268878ed226SJulian Elischer */ 269878ed226SJulian Elischer 270878ed226SJulian Elischer static int 271878ed226SJulian Elischer ng_btsocket_l2cap_node_newhook(node_p node, hook_p hook, char const *name) 272878ed226SJulian Elischer { 273878ed226SJulian Elischer return (0); 274878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_newhook */ 275878ed226SJulian Elischer 276878ed226SJulian Elischer /* 277878ed226SJulian Elischer * Just say "YEP, that's OK by me!" 278878ed226SJulian Elischer */ 279878ed226SJulian Elischer 280878ed226SJulian Elischer static int 281878ed226SJulian Elischer ng_btsocket_l2cap_node_connect(hook_p hook) 282878ed226SJulian Elischer { 283878ed226SJulian Elischer NG_HOOK_SET_PRIVATE(hook, NULL); 284878ed226SJulian Elischer NG_HOOK_REF(hook); /* Keep extra reference to the hook */ 285878ed226SJulian Elischer 286878ed226SJulian Elischer #if 0 287878ed226SJulian Elischer NG_HOOK_FORCE_QUEUE(NG_HOOK_PEER(hook)); 288878ed226SJulian Elischer NG_HOOK_FORCE_QUEUE(hook); 289878ed226SJulian Elischer #endif 290878ed226SJulian Elischer 291878ed226SJulian Elischer return (0); 292878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_connect */ 293878ed226SJulian Elischer 294878ed226SJulian Elischer /* 295878ed226SJulian Elischer * Hook disconnection. Schedule route cleanup task 296878ed226SJulian Elischer */ 297878ed226SJulian Elischer 298878ed226SJulian Elischer static int 299878ed226SJulian Elischer ng_btsocket_l2cap_node_disconnect(hook_p hook) 300878ed226SJulian Elischer { 301878ed226SJulian Elischer /* 302878ed226SJulian Elischer * If hook has private information than we must have this hook in 303878ed226SJulian Elischer * the routing table and must schedule cleaning for the routing table. 304878ed226SJulian Elischer * Otherwise hook was connected but we never got "hook_info" message, 305878ed226SJulian Elischer * so we have never added this hook to the routing table and it save 306878ed226SJulian Elischer * to just delete it. 307878ed226SJulian Elischer */ 308878ed226SJulian Elischer 309878ed226SJulian Elischer if (NG_HOOK_PRIVATE(hook) != NULL) 310f2bb1caeSJulian Elischer return (ng_btsocket_l2cap_wakeup_route_task()); 311878ed226SJulian Elischer 312878ed226SJulian Elischer NG_HOOK_UNREF(hook); /* Remove extra reference */ 313878ed226SJulian Elischer 314878ed226SJulian Elischer return (0); 315878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_disconnect */ 316878ed226SJulian Elischer 317878ed226SJulian Elischer /* 318878ed226SJulian Elischer * Process incoming messages 319878ed226SJulian Elischer */ 320878ed226SJulian Elischer 321878ed226SJulian Elischer static int 322878ed226SJulian Elischer ng_btsocket_l2cap_node_rcvmsg(node_p node, item_p item, hook_p hook) 323878ed226SJulian Elischer { 324878ed226SJulian Elischer struct ng_mesg *msg = NGI_MSG(item); /* item still has message */ 325878ed226SJulian Elischer int error = 0; 326878ed226SJulian Elischer 327878ed226SJulian Elischer if (msg != NULL && msg->header.typecookie == NGM_L2CAP_COOKIE) { 328878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_queue_mtx); 329878ed226SJulian Elischer if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 330878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 331878ed226SJulian Elischer "%s: Input queue is full (msg)\n", __func__); 332878ed226SJulian Elischer 333878ed226SJulian Elischer NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 334878ed226SJulian Elischer NG_FREE_ITEM(item); 335878ed226SJulian Elischer error = ENOBUFS; 336878ed226SJulian Elischer } else { 337878ed226SJulian Elischer if (hook != NULL) { 338878ed226SJulian Elischer NG_HOOK_REF(hook); 339878ed226SJulian Elischer NGI_SET_HOOK(item, hook); 340878ed226SJulian Elischer } 341878ed226SJulian Elischer 342878ed226SJulian Elischer NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 343f2bb1caeSJulian Elischer error = ng_btsocket_l2cap_wakeup_input_task(); 344878ed226SJulian Elischer } 345878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 346878ed226SJulian Elischer } else { 347878ed226SJulian Elischer NG_FREE_ITEM(item); 348878ed226SJulian Elischer error = EINVAL; 349878ed226SJulian Elischer } 350878ed226SJulian Elischer 351878ed226SJulian Elischer return (error); 352878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_rcvmsg */ 353878ed226SJulian Elischer 354878ed226SJulian Elischer /* 355878ed226SJulian Elischer * Receive data on a hook 356878ed226SJulian Elischer */ 357878ed226SJulian Elischer 358878ed226SJulian Elischer static int 359878ed226SJulian Elischer ng_btsocket_l2cap_node_rcvdata(hook_p hook, item_p item) 360878ed226SJulian Elischer { 361878ed226SJulian Elischer int error = 0; 362878ed226SJulian Elischer 363878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_queue_mtx); 364878ed226SJulian Elischer if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 365878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 366878ed226SJulian Elischer "%s: Input queue is full (data)\n", __func__); 367878ed226SJulian Elischer 368878ed226SJulian Elischer NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 369878ed226SJulian Elischer NG_FREE_ITEM(item); 370878ed226SJulian Elischer error = ENOBUFS; 371878ed226SJulian Elischer } else { 372878ed226SJulian Elischer NG_HOOK_REF(hook); 373878ed226SJulian Elischer NGI_SET_HOOK(item, hook); 374878ed226SJulian Elischer 375878ed226SJulian Elischer NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 376f2bb1caeSJulian Elischer error = ng_btsocket_l2cap_wakeup_input_task(); 377878ed226SJulian Elischer } 378878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 379878ed226SJulian Elischer 380878ed226SJulian Elischer return (error); 381878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_rcvdata */ 382878ed226SJulian Elischer 383878ed226SJulian Elischer /* 384878ed226SJulian Elischer * Process L2CA_Connect respose. Socket layer must have initiated connection, 385878ed226SJulian Elischer * so we have to have a socket associated with message token. 386878ed226SJulian Elischer */ 387878ed226SJulian Elischer 388878ed226SJulian Elischer static int 389878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_con_req_rsp(struct ng_mesg *msg, 390f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 391878ed226SJulian Elischer { 392878ed226SJulian Elischer ng_l2cap_l2ca_con_op *op = NULL; 393878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 394878ed226SJulian Elischer int error = 0; 395878ed226SJulian Elischer 396878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 397878ed226SJulian Elischer return (EMSGSIZE); 398878ed226SJulian Elischer 399878ed226SJulian Elischer op = (ng_l2cap_l2ca_con_op *)(msg->data); 400878ed226SJulian Elischer 401f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 402f2bb1caeSJulian Elischer 403878ed226SJulian Elischer /* Look for the socket with the token */ 404878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 405f2bb1caeSJulian Elischer if (pcb == NULL) { 406f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 407878ed226SJulian Elischer return (ENOENT); 408f2bb1caeSJulian Elischer } 409878ed226SJulian Elischer 410878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 411878ed226SJulian Elischer 412878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 413878ed226SJulian Elischer "%s: Got L2CA_Connect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 414878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, status=%d, " \ 415878ed226SJulian Elischer "state=%d\n", __func__, msg->header.token, 416878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 417878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 418878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 419878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 420878ed226SJulian Elischer pcb->psm, op->lcid, op->result, op->status, 421878ed226SJulian Elischer pcb->state); 422878ed226SJulian Elischer 423878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 424878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 425f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 426f2bb1caeSJulian Elischer 427878ed226SJulian Elischer return (ENOENT); 428878ed226SJulian Elischer } 429878ed226SJulian Elischer 430878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 431878ed226SJulian Elischer 432878ed226SJulian Elischer if (op->result == NG_L2CAP_PENDING) { 433878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 434878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 435f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 436f2bb1caeSJulian Elischer 437878ed226SJulian Elischer return (0); 438878ed226SJulian Elischer } 439878ed226SJulian Elischer 440878ed226SJulian Elischer if (op->result == NG_L2CAP_SUCCESS) { 441878ed226SJulian Elischer /* 442878ed226SJulian Elischer * Channel is now open, so update local channel ID and 443878ed226SJulian Elischer * start configuration process. Source and destination 444878ed226SJulian Elischer * addresses as well as route must be already set. 445878ed226SJulian Elischer */ 446878ed226SJulian Elischer 447878ed226SJulian Elischer pcb->cid = op->lcid; 448878ed226SJulian Elischer 449878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 450878ed226SJulian Elischer if (error != 0) { 451878ed226SJulian Elischer /* Send disconnect request with "zero" token */ 452878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 453878ed226SJulian Elischer 454878ed226SJulian Elischer /* ... and close the socket */ 455878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 456878ed226SJulian Elischer soisdisconnected(pcb->so); 457f2bb1caeSJulian Elischer 458f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 459f2bb1caeSJulian Elischer *sop = pcb->so; 460878ed226SJulian Elischer } else { 461878ed226SJulian Elischer pcb->cfg_state = NG_BTSOCKET_L2CAP_CFG_IN_SENT; 462878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 463878ed226SJulian Elischer 464878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 465878ed226SJulian Elischer } 466878ed226SJulian Elischer } else { 467878ed226SJulian Elischer /* 468878ed226SJulian Elischer * We have failed to open connection, so convert result 469878ed226SJulian Elischer * code to "errno" code and disconnect the socket. Channel 470878ed226SJulian Elischer * already has been closed. 471878ed226SJulian Elischer */ 472878ed226SJulian Elischer 473878ed226SJulian Elischer pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 474878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 475878ed226SJulian Elischer soisdisconnected(pcb->so); 476f2bb1caeSJulian Elischer 477f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 478f2bb1caeSJulian Elischer *sop = pcb->so; 479878ed226SJulian Elischer } 480878ed226SJulian Elischer 481878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 482f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 483878ed226SJulian Elischer 484878ed226SJulian Elischer return (error); 485878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_con_req_rsp */ 486878ed226SJulian Elischer 487878ed226SJulian Elischer /* 488878ed226SJulian Elischer * Process L2CA_ConnectRsp response 489878ed226SJulian Elischer */ 490878ed226SJulian Elischer 491878ed226SJulian Elischer static int 492878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_con_rsp_rsp(struct ng_mesg *msg, 493f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 494878ed226SJulian Elischer { 495878ed226SJulian Elischer ng_l2cap_l2ca_con_rsp_op *op = NULL; 496878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 497878ed226SJulian Elischer 498878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 499878ed226SJulian Elischer return (EMSGSIZE); 500878ed226SJulian Elischer 501878ed226SJulian Elischer op = (ng_l2cap_l2ca_con_rsp_op *)(msg->data); 502878ed226SJulian Elischer 503f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 504f2bb1caeSJulian Elischer 505878ed226SJulian Elischer /* Look for the socket with the token */ 506878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 507f2bb1caeSJulian Elischer if (pcb == NULL) { 508f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 509878ed226SJulian Elischer return (ENOENT); 510f2bb1caeSJulian Elischer } 511878ed226SJulian Elischer 512878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 513878ed226SJulian Elischer 514878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 515878ed226SJulian Elischer "%s: Got L2CA_ConnectRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 516878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 517878ed226SJulian Elischer __func__, msg->header.token, 518878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 519878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 520878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 521878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 522878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state); 523878ed226SJulian Elischer 524878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 525878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 526f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 527f2bb1caeSJulian Elischer 528878ed226SJulian Elischer return (ENOENT); 529878ed226SJulian Elischer } 530878ed226SJulian Elischer 531878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 532878ed226SJulian Elischer 533878ed226SJulian Elischer /* Check the result and disconnect the socket on failure */ 534878ed226SJulian Elischer if (op->result != NG_L2CAP_SUCCESS) { 535878ed226SJulian Elischer /* Close the socket - channel already closed */ 536878ed226SJulian Elischer pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 537878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 538878ed226SJulian Elischer soisdisconnected(pcb->so); 539f2bb1caeSJulian Elischer 540f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 541f2bb1caeSJulian Elischer *sop = pcb->so; 542878ed226SJulian Elischer } else { 543878ed226SJulian Elischer /* Move to CONFIGURING state and wait for CONFIG_IND */ 544878ed226SJulian Elischer pcb->cfg_state = 0; 545878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 546878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 547878ed226SJulian Elischer } 548878ed226SJulian Elischer 549878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 550f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 551878ed226SJulian Elischer 552878ed226SJulian Elischer return (0); 553878ed226SJulian Elischer } /* ng_btsocket_process_l2ca_con_rsp_rsp */ 554878ed226SJulian Elischer 555878ed226SJulian Elischer /* 556878ed226SJulian Elischer * Process L2CA_Connect indicator. Find socket that listens on address 557878ed226SJulian Elischer * and PSM. Find exact or closest match. Create new socket and initiate 558878ed226SJulian Elischer * connection. 559878ed226SJulian Elischer */ 560878ed226SJulian Elischer 561878ed226SJulian Elischer static int 562878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_con_ind(struct ng_mesg *msg, 563f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 564878ed226SJulian Elischer { 565878ed226SJulian Elischer ng_l2cap_l2ca_con_ind_ip *ip = NULL; 566878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL, *pcb1 = NULL; 567878ed226SJulian Elischer int error = 0; 568878ed226SJulian Elischer u_int32_t token = 0; 569878ed226SJulian Elischer u_int16_t result = 0; 570878ed226SJulian Elischer 571878ed226SJulian Elischer if (msg->header.arglen != sizeof(*ip)) 572878ed226SJulian Elischer return (EMSGSIZE); 573878ed226SJulian Elischer 574878ed226SJulian Elischer ip = (ng_l2cap_l2ca_con_ind_ip *)(msg->data); 575878ed226SJulian Elischer 576878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 577878ed226SJulian Elischer "%s: Got L2CA_Connect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 578878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, ident=%d\n", 579878ed226SJulian Elischer __func__, 580878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 581878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 582878ed226SJulian Elischer ip->bdaddr.b[5], ip->bdaddr.b[4], ip->bdaddr.b[3], 583878ed226SJulian Elischer ip->bdaddr.b[2], ip->bdaddr.b[1], ip->bdaddr.b[0], 584878ed226SJulian Elischer ip->psm, ip->lcid, ip->ident); 585878ed226SJulian Elischer 586f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 587f2bb1caeSJulian Elischer 588878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_addr(&rt->src, ip->psm); 589878ed226SJulian Elischer if (pcb != NULL) { 590878ed226SJulian Elischer struct socket *so1 = NULL; 591878ed226SJulian Elischer 592878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 593878ed226SJulian Elischer 594878ed226SJulian Elischer /* 595878ed226SJulian Elischer * First check the pending connections queue and if we have 596878ed226SJulian Elischer * space then create new socket and set proper source address. 597878ed226SJulian Elischer */ 598878ed226SJulian Elischer 599878ed226SJulian Elischer if (pcb->so->so_qlen <= pcb->so->so_qlimit) 600878ed226SJulian Elischer so1 = sonewconn(pcb->so, 0); 601878ed226SJulian Elischer 602878ed226SJulian Elischer if (so1 == NULL) { 603878ed226SJulian Elischer result = NG_L2CAP_NO_RESOURCES; 604878ed226SJulian Elischer goto respond; 605878ed226SJulian Elischer } 606878ed226SJulian Elischer 607878ed226SJulian Elischer /* 608878ed226SJulian Elischer * If we got here than we have created new socket. So complete 609878ed226SJulian Elischer * connection. If we we listening on specific address then copy 610878ed226SJulian Elischer * source address from listening socket, otherwise copy source 611878ed226SJulian Elischer * address from hook's routing information. 612878ed226SJulian Elischer */ 613878ed226SJulian Elischer 614878ed226SJulian Elischer pcb1 = so2l2cap_pcb(so1); 615878ed226SJulian Elischer KASSERT((pcb1 != NULL), 616878ed226SJulian Elischer ("%s: pcb1 == NULL\n", __func__)); 617878ed226SJulian Elischer 618878ed226SJulian Elischer mtx_lock(&pcb1->pcb_mtx); 619878ed226SJulian Elischer 620878ed226SJulian Elischer if (bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)) != 0) 621878ed226SJulian Elischer bcopy(&pcb->src, &pcb1->src, sizeof(pcb1->src)); 622878ed226SJulian Elischer else 623878ed226SJulian Elischer bcopy(&rt->src, &pcb1->src, sizeof(pcb1->src)); 624878ed226SJulian Elischer 625878ed226SJulian Elischer pcb1->flags &= ~NG_BTSOCKET_L2CAP_CLIENT; 626878ed226SJulian Elischer 627878ed226SJulian Elischer bcopy(&ip->bdaddr, &pcb1->dst, sizeof(pcb1->dst)); 628878ed226SJulian Elischer pcb1->psm = ip->psm; 629878ed226SJulian Elischer pcb1->cid = ip->lcid; 630878ed226SJulian Elischer pcb1->rt = rt; 631878ed226SJulian Elischer 632878ed226SJulian Elischer /* Copy socket settings */ 633878ed226SJulian Elischer pcb1->imtu = pcb->imtu; 634878ed226SJulian Elischer bcopy(&pcb->oflow, &pcb1->oflow, sizeof(pcb1->oflow)); 635878ed226SJulian Elischer pcb1->flush_timo = pcb->flush_timo; 636878ed226SJulian Elischer 637878ed226SJulian Elischer token = pcb1->token; 638878ed226SJulian Elischer } else 639878ed226SJulian Elischer /* Nobody listens on requested BDADDR/PSM */ 640878ed226SJulian Elischer result = NG_L2CAP_PSM_NOT_SUPPORTED; 641878ed226SJulian Elischer 642878ed226SJulian Elischer respond: 643878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_con_rsp_req(token, rt, 644878ed226SJulian Elischer &ip->bdaddr, ip->ident, ip->lcid, result); 645878ed226SJulian Elischer if (pcb1 != NULL) { 646878ed226SJulian Elischer if (error != 0) { 647878ed226SJulian Elischer pcb1->so->so_error = error; 648878ed226SJulian Elischer pcb1->state = NG_BTSOCKET_L2CAP_CLOSED; 649878ed226SJulian Elischer soisdisconnected(pcb1->so); 650f2bb1caeSJulian Elischer 651f2bb1caeSJulian Elischer if (pcb1->so->so_state & SS_NOFDREF) 652f2bb1caeSJulian Elischer *sop = pcb1->so; 653878ed226SJulian Elischer } else { 654878ed226SJulian Elischer pcb1->state = NG_BTSOCKET_L2CAP_CONNECTING; 655878ed226SJulian Elischer soisconnecting(pcb1->so); 656878ed226SJulian Elischer 657878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb1); 658878ed226SJulian Elischer } 659878ed226SJulian Elischer 660878ed226SJulian Elischer mtx_unlock(&pcb1->pcb_mtx); 661878ed226SJulian Elischer } 662878ed226SJulian Elischer 663878ed226SJulian Elischer if (pcb != NULL) 664878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 665878ed226SJulian Elischer 666f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 667f2bb1caeSJulian Elischer 668878ed226SJulian Elischer return (error); 669878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_con_ind */ 670878ed226SJulian Elischer 671878ed226SJulian Elischer /* 672878ed226SJulian Elischer * Process L2CA_Config response 673878ed226SJulian Elischer */ 674878ed226SJulian Elischer 675878ed226SJulian Elischer static int 676878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_req_rsp(struct ng_mesg *msg, 677f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 678878ed226SJulian Elischer { 679878ed226SJulian Elischer ng_l2cap_l2ca_cfg_op *op = NULL; 680878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = NULL; 681878ed226SJulian Elischer 682878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 683878ed226SJulian Elischer return (EMSGSIZE); 684878ed226SJulian Elischer 685878ed226SJulian Elischer op = (ng_l2cap_l2ca_cfg_op *)(msg->data); 686878ed226SJulian Elischer 687f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 688f2bb1caeSJulian Elischer 689878ed226SJulian Elischer /* 690878ed226SJulian Elischer * Socket must have issued a Configure request, so we must have a 691878ed226SJulian Elischer * socket that wants to be configured. Use Netgraph message token 692878ed226SJulian Elischer * to find it 693878ed226SJulian Elischer */ 694878ed226SJulian Elischer 695878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 696878ed226SJulian Elischer if (pcb == NULL) { 697878ed226SJulian Elischer /* 698878ed226SJulian Elischer * XXX FIXME what to do here? We could not find a 699878ed226SJulian Elischer * socket with requested token. We even can not send 700878ed226SJulian Elischer * Disconnect, because we do not know channel ID 701878ed226SJulian Elischer */ 702878ed226SJulian Elischer 703f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 704878ed226SJulian Elischer return (ENOENT); 705878ed226SJulian Elischer } 706878ed226SJulian Elischer 707878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 708878ed226SJulian Elischer 709878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 710878ed226SJulian Elischer "%s: Got L2CA_Config response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 711878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 712878ed226SJulian Elischer "cfg_state=%x\n", 713878ed226SJulian Elischer __func__, msg->header.token, 714878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 715878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 716878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 717878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 718878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 719878ed226SJulian Elischer 720878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 721878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 722f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 723f2bb1caeSJulian Elischer 724878ed226SJulian Elischer return (ENOENT); 725878ed226SJulian Elischer } 726878ed226SJulian Elischer 727878ed226SJulian Elischer if (op->result == NG_L2CAP_SUCCESS) { 728878ed226SJulian Elischer /* 729878ed226SJulian Elischer * XXX FIXME Actually set flush and link timeout. 730878ed226SJulian Elischer * Set QoS here if required. Resolve conficts (flush_timo). 731878ed226SJulian Elischer * Save incoming MTU (peer's outgoing MTU) and outgoing flow 732878ed226SJulian Elischer * spec. 733878ed226SJulian Elischer */ 734878ed226SJulian Elischer 735878ed226SJulian Elischer pcb->imtu = op->imtu; 736878ed226SJulian Elischer bcopy(&op->oflow, &pcb->oflow, sizeof(pcb->oflow)); 737878ed226SJulian Elischer pcb->flush_timo = op->flush_timo; 738878ed226SJulian Elischer 739878ed226SJulian Elischer /* 740878ed226SJulian Elischer * We have configured incoming side, so record it and check 741878ed226SJulian Elischer * if configuration is complete. If complete then mark socket 742878ed226SJulian Elischer * as connected, otherwise wait for the peer. 743878ed226SJulian Elischer */ 744878ed226SJulian Elischer 745878ed226SJulian Elischer pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_IN_SENT; 746878ed226SJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN; 747878ed226SJulian Elischer 748878ed226SJulian Elischer if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 749878ed226SJulian Elischer /* Configuration complete - mark socket as open */ 750878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 751878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_OPEN; 752878ed226SJulian Elischer soisconnected(pcb->so); 753878ed226SJulian Elischer } 754878ed226SJulian Elischer } else { 755878ed226SJulian Elischer /* 756878ed226SJulian Elischer * Something went wrong. Could be unacceptable parameters, 757878ed226SJulian Elischer * reject or unknown option. That's too bad, but we will 758878ed226SJulian Elischer * not negotiate. Send Disconnect and close the channel. 759878ed226SJulian Elischer */ 760878ed226SJulian Elischer 761878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 762878ed226SJulian Elischer 763878ed226SJulian Elischer switch (op->result) { 764878ed226SJulian Elischer case NG_L2CAP_UNACCEPTABLE_PARAMS: 765878ed226SJulian Elischer case NG_L2CAP_UNKNOWN_OPTION: 766878ed226SJulian Elischer pcb->so->so_error = EINVAL; 767878ed226SJulian Elischer break; 768878ed226SJulian Elischer 769878ed226SJulian Elischer default: 770878ed226SJulian Elischer pcb->so->so_error = ECONNRESET; 771878ed226SJulian Elischer break; 772878ed226SJulian Elischer } 773878ed226SJulian Elischer 774878ed226SJulian Elischer /* Send disconnect with "zero" token */ 775878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 776878ed226SJulian Elischer 777878ed226SJulian Elischer /* ... and close the socket */ 778878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 779878ed226SJulian Elischer soisdisconnected(pcb->so); 780f2bb1caeSJulian Elischer 781f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 782f2bb1caeSJulian Elischer *sop = pcb->so; 783878ed226SJulian Elischer } 784878ed226SJulian Elischer 785878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 786f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 787878ed226SJulian Elischer 788878ed226SJulian Elischer return (0); 789878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_cfg_req_rsp */ 790878ed226SJulian Elischer 791878ed226SJulian Elischer /* 792878ed226SJulian Elischer * Process L2CA_ConfigRsp response 793878ed226SJulian Elischer */ 794878ed226SJulian Elischer 795878ed226SJulian Elischer static int 796878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(struct ng_mesg *msg, 797f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 798878ed226SJulian Elischer { 799878ed226SJulian Elischer ng_l2cap_l2ca_cfg_rsp_op *op = NULL; 800878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 801878ed226SJulian Elischer int error = 0; 802878ed226SJulian Elischer 803878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 804878ed226SJulian Elischer return (EMSGSIZE); 805878ed226SJulian Elischer 806878ed226SJulian Elischer op = (ng_l2cap_l2ca_cfg_rsp_op *)(msg->data); 807878ed226SJulian Elischer 808f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 809f2bb1caeSJulian Elischer 810878ed226SJulian Elischer /* Look for the socket with the token */ 811878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 812f2bb1caeSJulian Elischer if (pcb == NULL) { 813f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 814878ed226SJulian Elischer return (ENOENT); 815f2bb1caeSJulian Elischer } 816878ed226SJulian Elischer 817878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 818878ed226SJulian Elischer 819878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 820878ed226SJulian Elischer "%s: Got L2CA_ConfigRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 821878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 822878ed226SJulian Elischer "cfg_state=%x\n", 823878ed226SJulian Elischer __func__, msg->header.token, 824878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 825878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 826878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 827878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 828878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 829878ed226SJulian Elischer 830878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 831878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 832f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 833f2bb1caeSJulian Elischer 834878ed226SJulian Elischer return (ENOENT); 835878ed226SJulian Elischer } 836878ed226SJulian Elischer 837878ed226SJulian Elischer /* Check the result and disconnect socket of failure */ 838878ed226SJulian Elischer if (op->result != NG_L2CAP_SUCCESS) 839878ed226SJulian Elischer goto disconnect; 840878ed226SJulian Elischer 841878ed226SJulian Elischer /* 842878ed226SJulian Elischer * Now we done with remote side configuration. Configure local 843878ed226SJulian Elischer * side if we have not done it yet. 844878ed226SJulian Elischer */ 845878ed226SJulian Elischer 846878ed226SJulian Elischer pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 847878ed226SJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT; 848878ed226SJulian Elischer 849878ed226SJulian Elischer if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 850878ed226SJulian Elischer /* Configuration complete - mask socket as open */ 851878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 852878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_OPEN; 853878ed226SJulian Elischer soisconnected(pcb->so); 854878ed226SJulian Elischer } else { 855878ed226SJulian Elischer if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_IN_SENT)) { 856878ed226SJulian Elischer /* Send L2CA_Config request - incoming path */ 857878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 858878ed226SJulian Elischer if (error != 0) 859878ed226SJulian Elischer goto disconnect; 860878ed226SJulian Elischer 861878ed226SJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN_SENT; 862878ed226SJulian Elischer } 863878ed226SJulian Elischer } 864878ed226SJulian Elischer 865878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 866f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 867878ed226SJulian Elischer 868878ed226SJulian Elischer return (error); 869878ed226SJulian Elischer 870878ed226SJulian Elischer disconnect: 871878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 872878ed226SJulian Elischer 873878ed226SJulian Elischer /* Send disconnect with "zero" token */ 874878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 875878ed226SJulian Elischer 876878ed226SJulian Elischer /* ... and close the socket */ 877878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 878878ed226SJulian Elischer soisdisconnected(pcb->so); 879878ed226SJulian Elischer 880f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 881f2bb1caeSJulian Elischer *sop = pcb->so; 882f2bb1caeSJulian Elischer 883878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 884f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 885878ed226SJulian Elischer 886878ed226SJulian Elischer return (error); 887878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp */ 888878ed226SJulian Elischer 889878ed226SJulian Elischer /* 890878ed226SJulian Elischer * Process L2CA_Config indicator 891878ed226SJulian Elischer */ 892878ed226SJulian Elischer 893878ed226SJulian Elischer static int 894878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_ind(struct ng_mesg *msg, 895f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 896878ed226SJulian Elischer { 897878ed226SJulian Elischer ng_l2cap_l2ca_cfg_ind_ip *ip = NULL; 898878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 899878ed226SJulian Elischer int error = 0; 900878ed226SJulian Elischer 901878ed226SJulian Elischer if (msg->header.arglen != sizeof(*ip)) 902878ed226SJulian Elischer return (EMSGSIZE); 903878ed226SJulian Elischer 904878ed226SJulian Elischer ip = (ng_l2cap_l2ca_cfg_ind_ip *)(msg->data); 905878ed226SJulian Elischer 906f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 907f2bb1caeSJulian Elischer 908878ed226SJulian Elischer /* Check for the open socket that has given channel ID */ 909878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid); 910f2bb1caeSJulian Elischer if (pcb == NULL) { 911f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 912878ed226SJulian Elischer return (ENOENT); 913f2bb1caeSJulian Elischer } 914878ed226SJulian Elischer 915878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 916878ed226SJulian Elischer 917878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 918878ed226SJulian Elischer "%s: Got L2CA_Config indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 919878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d, cfg_state=%x\n", 920878ed226SJulian Elischer __func__, 921878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 922878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 923878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 924878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 925878ed226SJulian Elischer pcb->psm, pcb->cid, pcb->state, pcb->cfg_state); 926878ed226SJulian Elischer 927878ed226SJulian Elischer /* XXX FIXME re-configuration on open socket */ 928878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 929878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 930f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 931f2bb1caeSJulian Elischer 932878ed226SJulian Elischer return (ENOENT); 933878ed226SJulian Elischer } 934878ed226SJulian Elischer 935878ed226SJulian Elischer /* 936878ed226SJulian Elischer * XXX FIXME Actually set flush and link timeout. Set QoS here if 937878ed226SJulian Elischer * required. Resolve conficts (flush_timo). Note outgoing MTU (peer's 938878ed226SJulian Elischer * incoming MTU) and incoming flow spec. 939878ed226SJulian Elischer */ 940878ed226SJulian Elischer 941878ed226SJulian Elischer pcb->omtu = ip->omtu; 942878ed226SJulian Elischer bcopy(&ip->iflow, &pcb->iflow, sizeof(pcb->iflow)); 943878ed226SJulian Elischer pcb->flush_timo = ip->flush_timo; 944878ed226SJulian Elischer 945878ed226SJulian Elischer /* 946878ed226SJulian Elischer * Send L2CA_Config response to our peer and check for the errors, 947878ed226SJulian Elischer * if any send disconnect to close the channel. 948878ed226SJulian Elischer */ 949878ed226SJulian Elischer 950878ed226SJulian Elischer if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_OUT_SENT)) { 951878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_cfg_rsp(pcb); 952878ed226SJulian Elischer if (error != 0) { 953878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 954878ed226SJulian Elischer 955878ed226SJulian Elischer pcb->so->so_error = error; 956878ed226SJulian Elischer 957878ed226SJulian Elischer /* Send disconnect with "zero" token */ 958878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 959878ed226SJulian Elischer 960878ed226SJulian Elischer /* ... and close the socket */ 961878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 962878ed226SJulian Elischer soisdisconnected(pcb->so); 963f2bb1caeSJulian Elischer 964f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 965f2bb1caeSJulian Elischer *sop = pcb->so; 966f2bb1caeSJulian Elischer } else 967f2bb1caeSJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 968878ed226SJulian Elischer } 969878ed226SJulian Elischer 970878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 971f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 972878ed226SJulian Elischer 973878ed226SJulian Elischer return (error); 974878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2cap_cfg_ind */ 975878ed226SJulian Elischer 976878ed226SJulian Elischer /* 977878ed226SJulian Elischer * Process L2CA_Disconnect response 978878ed226SJulian Elischer */ 979878ed226SJulian Elischer 980878ed226SJulian Elischer static int 981878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_discon_rsp(struct ng_mesg *msg, 982f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 983878ed226SJulian Elischer { 984878ed226SJulian Elischer ng_l2cap_l2ca_discon_op *op = NULL; 985878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 986878ed226SJulian Elischer 987878ed226SJulian Elischer /* Check message */ 988878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 989878ed226SJulian Elischer return (EMSGSIZE); 990878ed226SJulian Elischer 991878ed226SJulian Elischer op = (ng_l2cap_l2ca_discon_op *)(msg->data); 992878ed226SJulian Elischer 993f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 994f2bb1caeSJulian Elischer 995878ed226SJulian Elischer /* 996878ed226SJulian Elischer * Socket layer must have issued L2CA_Disconnect request, so there 997878ed226SJulian Elischer * must be a socket that wants to be disconnected. Use Netgraph 998878ed226SJulian Elischer * message token to find it. 999878ed226SJulian Elischer */ 1000878ed226SJulian Elischer 1001878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1002f2bb1caeSJulian Elischer if (pcb == NULL) { 1003f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1004878ed226SJulian Elischer return (0); 1005f2bb1caeSJulian Elischer } 1006878ed226SJulian Elischer 1007878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1008878ed226SJulian Elischer 1009878ed226SJulian Elischer /* XXX Close socket no matter what op->result says */ 1010878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 1011878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1012878ed226SJulian Elischer "%s: Got L2CA_Disconnect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1013878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 1014878ed226SJulian Elischer __func__, msg->header.token, 1015878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1016878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1017878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1018878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1019878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state); 1020878ed226SJulian Elischer 1021878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1022878ed226SJulian Elischer 1023878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1024878ed226SJulian Elischer soisdisconnected(pcb->so); 1025f2bb1caeSJulian Elischer 1026f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 1027f2bb1caeSJulian Elischer *sop = pcb->so; 1028878ed226SJulian Elischer } 1029878ed226SJulian Elischer 1030878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1031f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1032878ed226SJulian Elischer 1033878ed226SJulian Elischer return (0); 1034878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_discon_rsp */ 1035878ed226SJulian Elischer 1036878ed226SJulian Elischer /* 1037878ed226SJulian Elischer * Process L2CA_Disconnect indicator 1038878ed226SJulian Elischer */ 1039878ed226SJulian Elischer 1040878ed226SJulian Elischer static int 1041878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_discon_ind(struct ng_mesg *msg, 1042f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 1043878ed226SJulian Elischer { 1044878ed226SJulian Elischer ng_l2cap_l2ca_discon_ind_ip *ip = NULL; 1045878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1046878ed226SJulian Elischer 1047878ed226SJulian Elischer /* Check message */ 1048878ed226SJulian Elischer if (msg->header.arglen != sizeof(*ip)) 1049878ed226SJulian Elischer return (EMSGSIZE); 1050878ed226SJulian Elischer 1051878ed226SJulian Elischer ip = (ng_l2cap_l2ca_discon_ind_ip *)(msg->data); 1052878ed226SJulian Elischer 1053f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1054f2bb1caeSJulian Elischer 1055878ed226SJulian Elischer /* Look for the socket with given channel ID */ 1056878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid); 1057f2bb1caeSJulian Elischer if (pcb == NULL) { 1058f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1059878ed226SJulian Elischer return (0); 1060f2bb1caeSJulian Elischer } 1061878ed226SJulian Elischer 1062878ed226SJulian Elischer /* 1063878ed226SJulian Elischer * Channel has already been destroyed, so disconnect the socket 1064878ed226SJulian Elischer * and be done with it. If there was any pending request we can 1065878ed226SJulian Elischer * not do anything here anyway. 1066878ed226SJulian Elischer */ 1067878ed226SJulian Elischer 1068878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1069878ed226SJulian Elischer 1070878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1071878ed226SJulian Elischer "%s: Got L2CA_Disconnect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1072878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d\n", 1073878ed226SJulian Elischer __func__, 1074878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1075878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1076878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1077878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1078878ed226SJulian Elischer pcb->psm, pcb->cid, pcb->state); 1079878ed226SJulian Elischer 1080878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1081878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1082878ed226SJulian Elischer 1083878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1084878ed226SJulian Elischer soisdisconnected(pcb->so); 1085878ed226SJulian Elischer 1086f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 1087f2bb1caeSJulian Elischer *sop = pcb->so; 1088f2bb1caeSJulian Elischer 1089878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1090f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1091878ed226SJulian Elischer 1092878ed226SJulian Elischer return (0); 1093878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_discon_ind */ 1094878ed226SJulian Elischer 1095878ed226SJulian Elischer /* 1096878ed226SJulian Elischer * Process L2CA_Write response 1097878ed226SJulian Elischer */ 1098878ed226SJulian Elischer 1099878ed226SJulian Elischer static int 1100878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_write_rsp(struct ng_mesg *msg, 1101f2bb1caeSJulian Elischer ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 1102878ed226SJulian Elischer { 1103878ed226SJulian Elischer ng_l2cap_l2ca_write_op *op = NULL; 1104878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1105878ed226SJulian Elischer 1106878ed226SJulian Elischer /* Check message */ 1107878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 1108878ed226SJulian Elischer return (EMSGSIZE); 1109878ed226SJulian Elischer 1110878ed226SJulian Elischer op = (ng_l2cap_l2ca_write_op *)(msg->data); 1111878ed226SJulian Elischer 1112f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1113f2bb1caeSJulian Elischer 1114878ed226SJulian Elischer /* Look for the socket with given token */ 1115878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1116f2bb1caeSJulian Elischer if (pcb == NULL) { 1117f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1118878ed226SJulian Elischer return (ENOENT); 1119f2bb1caeSJulian Elischer } 1120878ed226SJulian Elischer 1121878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1122878ed226SJulian Elischer 1123878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1124878ed226SJulian Elischer "%s: Got L2CA_Write response, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1125878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, length=%d, " \ 1126878ed226SJulian Elischer "state=%d\n", __func__, 1127878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1128878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1129878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1130878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1131878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, op->length, 1132878ed226SJulian Elischer pcb->state); 1133878ed226SJulian Elischer 1134878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1135878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1136f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1137f2bb1caeSJulian Elischer 1138878ed226SJulian Elischer return (ENOENT); 1139878ed226SJulian Elischer } 1140878ed226SJulian Elischer 1141878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1142878ed226SJulian Elischer 1143878ed226SJulian Elischer /* 1144878ed226SJulian Elischer * Check if we have more data to send 1145878ed226SJulian Elischer */ 1146878ed226SJulian Elischer 1147878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); 1148878ed226SJulian Elischer if (pcb->so->so_snd.sb_cc > 0) { 1149878ed226SJulian Elischer if (ng_btsocket_l2cap_send2(pcb) == 0) 1150878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 1151878ed226SJulian Elischer else 1152878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); /* XXX */ 1153878ed226SJulian Elischer } 1154878ed226SJulian Elischer 1155878ed226SJulian Elischer /* 1156878ed226SJulian Elischer * Now set the result, drop packet from the socket send queue and 1157878ed226SJulian Elischer * ask for more (wakeup sender) 1158878ed226SJulian Elischer */ 1159878ed226SJulian Elischer 1160878ed226SJulian Elischer pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 1161878ed226SJulian Elischer sowwakeup(pcb->so); 1162878ed226SJulian Elischer 1163878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1164f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1165878ed226SJulian Elischer 1166878ed226SJulian Elischer return (0); 1167878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_write_rsp */ 1168878ed226SJulian Elischer 1169878ed226SJulian Elischer /* 1170878ed226SJulian Elischer * Send L2CA_Connect request 1171878ed226SJulian Elischer */ 1172878ed226SJulian Elischer 1173878ed226SJulian Elischer static int 1174878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_con_req(ng_btsocket_l2cap_pcb_p pcb) 1175878ed226SJulian Elischer { 1176878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1177878ed226SJulian Elischer ng_l2cap_l2ca_con_ip *ip = NULL; 1178878ed226SJulian Elischer int error = 0; 1179878ed226SJulian Elischer 1180878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1181878ed226SJulian Elischer 1182878ed226SJulian Elischer if (pcb->rt == NULL || 1183878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1184878ed226SJulian Elischer return (ENETDOWN); 1185878ed226SJulian Elischer 1186878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON, 1187878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1188878ed226SJulian Elischer if (msg == NULL) 1189878ed226SJulian Elischer return (ENOMEM); 1190878ed226SJulian Elischer 1191878ed226SJulian Elischer msg->header.token = pcb->token; 1192878ed226SJulian Elischer 1193878ed226SJulian Elischer ip = (ng_l2cap_l2ca_con_ip *)(msg->data); 1194878ed226SJulian Elischer bcopy(&pcb->dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1195878ed226SJulian Elischer ip->psm = pcb->psm; 1196878ed226SJulian Elischer 1197878ed226SJulian Elischer NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1198878ed226SJulian Elischer 1199878ed226SJulian Elischer return (error); 1200878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_con_req */ 1201878ed226SJulian Elischer 1202878ed226SJulian Elischer /* 1203878ed226SJulian Elischer * Send L2CA_Connect response 1204878ed226SJulian Elischer */ 1205878ed226SJulian Elischer 1206878ed226SJulian Elischer static int 1207878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_con_rsp_req(u_int32_t token, 1208878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt, bdaddr_p dst, int ident, 1209878ed226SJulian Elischer int lcid, int result) 1210878ed226SJulian Elischer { 1211878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1212878ed226SJulian Elischer ng_l2cap_l2ca_con_rsp_ip *ip = NULL; 1213878ed226SJulian Elischer int error = 0; 1214878ed226SJulian Elischer 1215878ed226SJulian Elischer if (rt == NULL || rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 1216878ed226SJulian Elischer return (ENETDOWN); 1217878ed226SJulian Elischer 1218878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON_RSP, 1219878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1220878ed226SJulian Elischer if (msg == NULL) 1221878ed226SJulian Elischer return (ENOMEM); 1222878ed226SJulian Elischer 1223878ed226SJulian Elischer msg->header.token = token; 1224878ed226SJulian Elischer 1225878ed226SJulian Elischer ip = (ng_l2cap_l2ca_con_rsp_ip *)(msg->data); 1226878ed226SJulian Elischer bcopy(dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1227878ed226SJulian Elischer ip->ident = ident; 1228878ed226SJulian Elischer ip->lcid = lcid; 1229878ed226SJulian Elischer ip->result = result; 1230878ed226SJulian Elischer ip->status = 0; 1231878ed226SJulian Elischer 1232878ed226SJulian Elischer NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg, rt->hook, NULL); 1233878ed226SJulian Elischer 1234878ed226SJulian Elischer return (error); 1235878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_con_rsp_req */ 1236878ed226SJulian Elischer 1237878ed226SJulian Elischer /* 1238878ed226SJulian Elischer * Send L2CA_Config request 1239878ed226SJulian Elischer */ 1240878ed226SJulian Elischer 1241878ed226SJulian Elischer static int 1242878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_cfg_req(ng_btsocket_l2cap_pcb_p pcb) 1243878ed226SJulian Elischer { 1244878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1245878ed226SJulian Elischer ng_l2cap_l2ca_cfg_ip *ip = NULL; 1246878ed226SJulian Elischer int error = 0; 1247878ed226SJulian Elischer 1248878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1249878ed226SJulian Elischer 1250878ed226SJulian Elischer if (pcb->rt == NULL || 1251878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1252878ed226SJulian Elischer return (ENETDOWN); 1253878ed226SJulian Elischer 1254878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG, 1255878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1256878ed226SJulian Elischer if (msg == NULL) 1257878ed226SJulian Elischer return (ENOMEM); 1258878ed226SJulian Elischer 1259878ed226SJulian Elischer msg->header.token = pcb->token; 1260878ed226SJulian Elischer 1261878ed226SJulian Elischer ip = (ng_l2cap_l2ca_cfg_ip *)(msg->data); 1262878ed226SJulian Elischer ip->lcid = pcb->cid; 1263878ed226SJulian Elischer ip->imtu = pcb->imtu; 1264878ed226SJulian Elischer bcopy(&pcb->oflow, &ip->oflow, sizeof(ip->oflow)); 1265878ed226SJulian Elischer ip->flush_timo = pcb->flush_timo; 1266878ed226SJulian Elischer ip->link_timo = pcb->link_timo; 1267878ed226SJulian Elischer 1268878ed226SJulian Elischer NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1269878ed226SJulian Elischer 1270878ed226SJulian Elischer return (error); 1271878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_cfg_req */ 1272878ed226SJulian Elischer 1273878ed226SJulian Elischer /* 1274878ed226SJulian Elischer * Send L2CA_Config response 1275878ed226SJulian Elischer */ 1276878ed226SJulian Elischer 1277878ed226SJulian Elischer static int 1278878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_cfg_rsp(ng_btsocket_l2cap_pcb_p pcb) 1279878ed226SJulian Elischer { 1280878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1281878ed226SJulian Elischer ng_l2cap_l2ca_cfg_rsp_ip *ip = NULL; 1282878ed226SJulian Elischer int error = 0; 1283878ed226SJulian Elischer 1284878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1285878ed226SJulian Elischer 1286878ed226SJulian Elischer if (pcb->rt == NULL || 1287878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1288878ed226SJulian Elischer return (ENETDOWN); 1289878ed226SJulian Elischer 1290878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG_RSP, 1291878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1292878ed226SJulian Elischer if (msg == NULL) 1293878ed226SJulian Elischer return (ENOMEM); 1294878ed226SJulian Elischer 1295878ed226SJulian Elischer msg->header.token = pcb->token; 1296878ed226SJulian Elischer 1297878ed226SJulian Elischer ip = (ng_l2cap_l2ca_cfg_rsp_ip *)(msg->data); 1298878ed226SJulian Elischer ip->lcid = pcb->cid; 1299878ed226SJulian Elischer ip->omtu = pcb->omtu; 1300878ed226SJulian Elischer bcopy(&pcb->iflow, &ip->iflow, sizeof(ip->iflow)); 1301878ed226SJulian Elischer 1302878ed226SJulian Elischer NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1303878ed226SJulian Elischer 1304878ed226SJulian Elischer return (error); 1305878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_cfg_rsp */ 1306878ed226SJulian Elischer 1307878ed226SJulian Elischer /* 1308878ed226SJulian Elischer * Send L2CA_Disconnect request 1309878ed226SJulian Elischer */ 1310878ed226SJulian Elischer 1311878ed226SJulian Elischer static int 1312878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(u_int32_t token, 1313878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb) 1314878ed226SJulian Elischer { 1315878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1316878ed226SJulian Elischer ng_l2cap_l2ca_discon_ip *ip = NULL; 1317878ed226SJulian Elischer int error = 0; 1318878ed226SJulian Elischer 1319878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1320878ed226SJulian Elischer 1321878ed226SJulian Elischer if (pcb->rt == NULL || 1322878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1323878ed226SJulian Elischer return (ENETDOWN); 1324878ed226SJulian Elischer 1325878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_DISCON, 1326878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1327878ed226SJulian Elischer if (msg == NULL) 1328878ed226SJulian Elischer return (ENOMEM); 1329878ed226SJulian Elischer 1330878ed226SJulian Elischer msg->header.token = token; 1331878ed226SJulian Elischer 1332878ed226SJulian Elischer ip = (ng_l2cap_l2ca_discon_ip *)(msg->data); 1333878ed226SJulian Elischer ip->lcid = pcb->cid; 1334878ed226SJulian Elischer 1335878ed226SJulian Elischer NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1336878ed226SJulian Elischer 1337878ed226SJulian Elischer return (error); 1338878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_discon_req */ 1339878ed226SJulian Elischer 1340878ed226SJulian Elischer /***************************************************************************** 1341878ed226SJulian Elischer ***************************************************************************** 1342878ed226SJulian Elischer ** Socket interface 1343878ed226SJulian Elischer ***************************************************************************** 1344878ed226SJulian Elischer *****************************************************************************/ 1345878ed226SJulian Elischer 1346878ed226SJulian Elischer /* 1347878ed226SJulian Elischer * L2CAP sockets data input routine 1348878ed226SJulian Elischer */ 1349878ed226SJulian Elischer 1350878ed226SJulian Elischer static void 1351878ed226SJulian Elischer ng_btsocket_l2cap_data_input(struct mbuf *m, hook_p hook) 1352878ed226SJulian Elischer { 1353878ed226SJulian Elischer ng_l2cap_hdr_t *hdr = NULL; 1354878ed226SJulian Elischer ng_l2cap_clt_hdr_t *clt_hdr = NULL; 1355878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1356878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_t *rt = NULL; 1357878ed226SJulian Elischer 1358878ed226SJulian Elischer if (hook == NULL) { 1359878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1360878ed226SJulian Elischer "%s: Invalid source hook for L2CAP data packet\n", __func__); 1361878ed226SJulian Elischer goto drop; 1362878ed226SJulian Elischer } 1363878ed226SJulian Elischer 1364878ed226SJulian Elischer rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1365878ed226SJulian Elischer if (rt == NULL) { 1366878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1367878ed226SJulian Elischer "%s: Could not find out source bdaddr for L2CAP data packet\n", __func__); 1368878ed226SJulian Elischer goto drop; 1369878ed226SJulian Elischer } 1370878ed226SJulian Elischer 1371878ed226SJulian Elischer /* Make sure we can access header */ 1372878ed226SJulian Elischer if (m->m_pkthdr.len < sizeof(*hdr)) { 1373878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1374878ed226SJulian Elischer "%s: L2CAP data packet too small, len=%d\n", __func__, m->m_pkthdr.len); 1375878ed226SJulian Elischer goto drop; 1376878ed226SJulian Elischer } 1377878ed226SJulian Elischer 1378878ed226SJulian Elischer if (m->m_len < sizeof(*hdr)) { 1379878ed226SJulian Elischer m = m_pullup(m, sizeof(*hdr)); 1380878ed226SJulian Elischer if (m == NULL) 1381878ed226SJulian Elischer goto drop; 1382878ed226SJulian Elischer } 1383878ed226SJulian Elischer 1384878ed226SJulian Elischer /* Strip L2CAP packet header and verify packet length */ 1385878ed226SJulian Elischer hdr = mtod(m, ng_l2cap_hdr_t *); 1386878ed226SJulian Elischer m_adj(m, sizeof(*hdr)); 1387878ed226SJulian Elischer 1388878ed226SJulian Elischer if (hdr->length != m->m_pkthdr.len) { 1389878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1390878ed226SJulian Elischer "%s: Bad L2CAP data packet length, len=%d, length=%d\n", 1391878ed226SJulian Elischer __func__, m->m_pkthdr.len, hdr->length); 1392878ed226SJulian Elischer goto drop; 1393878ed226SJulian Elischer } 1394878ed226SJulian Elischer 1395878ed226SJulian Elischer /* 1396878ed226SJulian Elischer * Now process packet. Two cases: 1397878ed226SJulian Elischer * 1398878ed226SJulian Elischer * 1) Normal packet (cid != 2) then find connected socket and append 1399878ed226SJulian Elischer * mbuf to the socket queue. Wakeup socket. 1400878ed226SJulian Elischer * 1401878ed226SJulian Elischer * 2) Broadcast packet (cid == 2) then find all sockets that connected 1402878ed226SJulian Elischer * to the given PSM and have SO_BROADCAST bit set and append mbuf 1403878ed226SJulian Elischer * to the socket queue. Wakeup socket. 1404878ed226SJulian Elischer */ 1405878ed226SJulian Elischer 1406878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1407f2bb1caeSJulian Elischer "%s: Received L2CAP data packet: src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1408878ed226SJulian Elischer "dcid=%d, length=%d\n", 1409878ed226SJulian Elischer __func__, 1410878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1411878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1412878ed226SJulian Elischer hdr->dcid, hdr->length); 1413878ed226SJulian Elischer 14140986ab12SMaksim Yevmenkin if (hdr->dcid >= NG_L2CAP_FIRST_CID) { 1415f2bb1caeSJulian Elischer 1416f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1417f2bb1caeSJulian Elischer 1418878ed226SJulian Elischer /* Normal packet: find connected socket */ 1419878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, hdr->dcid); 1420f2bb1caeSJulian Elischer if (pcb == NULL) { 1421f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1422878ed226SJulian Elischer goto drop; 1423f2bb1caeSJulian Elischer } 1424878ed226SJulian Elischer 1425878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1426878ed226SJulian Elischer 1427878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1428878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1429878ed226SJulian Elischer "%s: No connected socket found, src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, " \ 1430878ed226SJulian Elischer "state=%d\n", __func__, 1431878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1432878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1433878ed226SJulian Elischer hdr->dcid, pcb->state); 1434878ed226SJulian Elischer 1435878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1436f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1437878ed226SJulian Elischer goto drop; 1438878ed226SJulian Elischer } 1439878ed226SJulian Elischer 1440878ed226SJulian Elischer /* Check packet size against socket's incoming MTU */ 1441878ed226SJulian Elischer if (hdr->length > pcb->imtu) { 1442878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1443878ed226SJulian Elischer "%s: L2CAP data packet too big, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1444878ed226SJulian Elischer "dcid=%d, length=%d, imtu=%d\n", 1445878ed226SJulian Elischer __func__, 1446878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1447878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1448878ed226SJulian Elischer hdr->dcid, hdr->length, pcb->imtu); 1449878ed226SJulian Elischer 1450878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1451f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1452878ed226SJulian Elischer goto drop; 1453878ed226SJulian Elischer } 1454878ed226SJulian Elischer 1455878ed226SJulian Elischer /* Check if we have enough space in socket receive queue */ 1456878ed226SJulian Elischer if (m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) { 1457878ed226SJulian Elischer 1458878ed226SJulian Elischer /* 1459878ed226SJulian Elischer * This is really bad. Receive queue on socket does 1460878ed226SJulian Elischer * not have enough space for the packet. We do not 1461878ed226SJulian Elischer * have any other choice but drop the packet. L2CAP 1462878ed226SJulian Elischer * does not provide any flow control. 1463878ed226SJulian Elischer */ 1464878ed226SJulian Elischer 1465878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1466878ed226SJulian Elischer "%s: Not enough space in socket receive queue. Dropping L2CAP data packet, " \ 1467878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, len=%d, space=%ld\n", 1468878ed226SJulian Elischer __func__, 1469878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1470878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1471878ed226SJulian Elischer hdr->dcid, m->m_pkthdr.len, 1472878ed226SJulian Elischer sbspace(&pcb->so->so_rcv)); 1473878ed226SJulian Elischer 1474878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1475f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1476878ed226SJulian Elischer goto drop; 1477878ed226SJulian Elischer } 1478878ed226SJulian Elischer 1479878ed226SJulian Elischer /* Append packet to the socket receive queue and wakeup */ 1480878ed226SJulian Elischer sbappendrecord(&pcb->so->so_rcv, m); 1481878ed226SJulian Elischer m = NULL; 1482878ed226SJulian Elischer 1483878ed226SJulian Elischer sorwakeup(pcb->so); 1484f2bb1caeSJulian Elischer 1485878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1486f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1487878ed226SJulian Elischer } else if (hdr->dcid == NG_L2CAP_CLT_CID) { 1488878ed226SJulian Elischer /* Broadcast packet: give packet to all sockets */ 1489878ed226SJulian Elischer 1490878ed226SJulian Elischer /* Check packet size against connectionless MTU */ 1491878ed226SJulian Elischer if (hdr->length > NG_L2CAP_MTU_DEFAULT) { 1492878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1493878ed226SJulian Elischer "%s: Connectionless L2CAP data packet too big, " \ 1494878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1495878ed226SJulian Elischer __func__, 1496878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1497878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1498878ed226SJulian Elischer hdr->length); 1499878ed226SJulian Elischer goto drop; 1500878ed226SJulian Elischer } 1501878ed226SJulian Elischer 1502878ed226SJulian Elischer /* Make sure we can access connectionless header */ 1503878ed226SJulian Elischer if (m->m_pkthdr.len < sizeof(*clt_hdr)) { 1504878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1505878ed226SJulian Elischer "%s: Can not get L2CAP connectionless packet header, " \ 1506878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1507878ed226SJulian Elischer __func__, 1508878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1509878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1510878ed226SJulian Elischer hdr->length); 1511878ed226SJulian Elischer goto drop; 1512878ed226SJulian Elischer } 1513878ed226SJulian Elischer 1514878ed226SJulian Elischer if (m->m_len < sizeof(*clt_hdr)) { 1515878ed226SJulian Elischer m = m_pullup(m, sizeof(*clt_hdr)); 1516878ed226SJulian Elischer if (m == NULL) 1517878ed226SJulian Elischer goto drop; 1518878ed226SJulian Elischer } 1519878ed226SJulian Elischer 1520878ed226SJulian Elischer /* Strip connectionless header and deliver packet */ 1521878ed226SJulian Elischer clt_hdr = mtod(m, ng_l2cap_clt_hdr_t *); 1522878ed226SJulian Elischer m_adj(m, sizeof(*clt_hdr)); 1523878ed226SJulian Elischer 1524878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1525878ed226SJulian Elischer "%s: Got L2CAP connectionless data packet, " \ 1526878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, length=%d\n", 1527878ed226SJulian Elischer __func__, 1528878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1529878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1530878ed226SJulian Elischer clt_hdr->psm, hdr->length); 1531878ed226SJulian Elischer 1532878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1533878ed226SJulian Elischer 1534878ed226SJulian Elischer LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) { 1535878ed226SJulian Elischer struct mbuf *copy = NULL; 1536878ed226SJulian Elischer 1537878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1538878ed226SJulian Elischer 1539878ed226SJulian Elischer if (bcmp(&rt->src, &pcb->src, sizeof(pcb->src)) != 0 || 1540878ed226SJulian Elischer pcb->psm != clt_hdr->psm || 1541878ed226SJulian Elischer pcb->state != NG_BTSOCKET_L2CAP_OPEN || 1542878ed226SJulian Elischer (pcb->so->so_options & SO_BROADCAST) == 0 || 1543878ed226SJulian Elischer m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) 1544878ed226SJulian Elischer goto next; 1545878ed226SJulian Elischer 1546878ed226SJulian Elischer /* 1547878ed226SJulian Elischer * Create a copy of the packet and append it to the 1548878ed226SJulian Elischer * socket's queue. If m_dup() failed - no big deal 1549878ed226SJulian Elischer * it is a broadcast traffic after all 1550878ed226SJulian Elischer */ 1551878ed226SJulian Elischer 1552a163d034SWarner Losh copy = m_dup(m, M_DONTWAIT); 1553878ed226SJulian Elischer if (copy != NULL) { 1554878ed226SJulian Elischer sbappendrecord(&pcb->so->so_rcv, copy); 1555878ed226SJulian Elischer sorwakeup(pcb->so); 1556878ed226SJulian Elischer } 1557878ed226SJulian Elischer next: 1558878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1559878ed226SJulian Elischer } 1560878ed226SJulian Elischer 1561878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1562878ed226SJulian Elischer } 1563878ed226SJulian Elischer drop: 1564878ed226SJulian Elischer NG_FREE_M(m); /* checks for m != NULL */ 1565878ed226SJulian Elischer } /* ng_btsocket_l2cap_data_input */ 1566878ed226SJulian Elischer 1567878ed226SJulian Elischer /* 1568878ed226SJulian Elischer * L2CAP sockets default message input routine 1569878ed226SJulian Elischer */ 1570878ed226SJulian Elischer 1571878ed226SJulian Elischer static void 1572878ed226SJulian Elischer ng_btsocket_l2cap_default_msg_input(struct ng_mesg *msg, hook_p hook) 1573878ed226SJulian Elischer { 1574878ed226SJulian Elischer switch (msg->header.cmd) { 1575878ed226SJulian Elischer case NGM_L2CAP_NODE_HOOK_INFO: { 1576878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_t *rt = NULL; 1577878ed226SJulian Elischer 1578878ed226SJulian Elischer if (hook == NULL || msg->header.arglen != sizeof(bdaddr_t)) 1579878ed226SJulian Elischer break; 1580878ed226SJulian Elischer 1581878ed226SJulian Elischer if (bcmp(msg->data, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 1582878ed226SJulian Elischer break; 1583878ed226SJulian Elischer 1584f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1585f2bb1caeSJulian Elischer 1586878ed226SJulian Elischer rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1587878ed226SJulian Elischer if (rt == NULL) { 1588878ed226SJulian Elischer MALLOC(rt, ng_btsocket_l2cap_rtentry_p, sizeof(*rt), 1589878ed226SJulian Elischer M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT|M_ZERO); 1590f2bb1caeSJulian Elischer if (rt == NULL) { 1591878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1592f2bb1caeSJulian Elischer break; 1593f2bb1caeSJulian Elischer } 1594f2bb1caeSJulian Elischer 1595f2bb1caeSJulian Elischer LIST_INSERT_HEAD(&ng_btsocket_l2cap_rt, rt, next); 1596878ed226SJulian Elischer 1597878ed226SJulian Elischer NG_HOOK_SET_PRIVATE(hook, rt); 1598878ed226SJulian Elischer } 1599878ed226SJulian Elischer 1600878ed226SJulian Elischer bcopy(msg->data, &rt->src, sizeof(rt->src)); 1601878ed226SJulian Elischer rt->hook = hook; 1602878ed226SJulian Elischer 1603f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1604f2bb1caeSJulian Elischer 1605878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1606878ed226SJulian Elischer "%s: Updating hook \"%s\", src bdaddr=%x:%x:%x:%x:%x:%x\n", 1607878ed226SJulian Elischer __func__, NG_HOOK_NAME(hook), 1608878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1609878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0]); 1610878ed226SJulian Elischer } break; 1611878ed226SJulian Elischer 1612878ed226SJulian Elischer default: 1613878ed226SJulian Elischer NG_BTSOCKET_L2CAP_WARN( 1614878ed226SJulian Elischer "%s: Unknown message, cmd=%d\n", __func__, msg->header.cmd); 1615878ed226SJulian Elischer break; 1616878ed226SJulian Elischer } 1617878ed226SJulian Elischer 1618878ed226SJulian Elischer NG_FREE_MSG(msg); /* Checks for msg != NULL */ 1619878ed226SJulian Elischer } /* ng_btsocket_l2cap_default_msg_input */ 1620878ed226SJulian Elischer 1621878ed226SJulian Elischer /* 1622878ed226SJulian Elischer * L2CAP sockets L2CA message input routine 1623878ed226SJulian Elischer */ 1624878ed226SJulian Elischer 1625878ed226SJulian Elischer static void 1626878ed226SJulian Elischer ng_btsocket_l2cap_l2ca_msg_input(struct ng_mesg *msg, hook_p hook) 1627878ed226SJulian Elischer { 1628878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt = NULL; 1629f2bb1caeSJulian Elischer struct socket *so = NULL; 1630878ed226SJulian Elischer 1631878ed226SJulian Elischer if (hook == NULL) { 1632878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1633878ed226SJulian Elischer "%s: Invalid source hook for L2CA message\n", __func__); 1634878ed226SJulian Elischer goto drop; 1635878ed226SJulian Elischer } 1636878ed226SJulian Elischer 1637878ed226SJulian Elischer rt = (ng_btsocket_l2cap_rtentry_p) NG_HOOK_PRIVATE(hook); 1638878ed226SJulian Elischer if (rt == NULL) { 1639878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1640878ed226SJulian Elischer "%s: Could not find out source bdaddr for L2CA message\n", __func__); 1641878ed226SJulian Elischer goto drop; 1642878ed226SJulian Elischer } 1643878ed226SJulian Elischer 1644878ed226SJulian Elischer switch (msg->header.cmd) { 1645878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON: /* L2CA_Connect response */ 1646f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_con_req_rsp(msg, rt, &so); 1647878ed226SJulian Elischer break; 1648878ed226SJulian Elischer 1649878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_RSP: /* L2CA_ConnectRsp response */ 1650f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_con_rsp_rsp(msg, rt, &so); 1651878ed226SJulian Elischer break; 1652878ed226SJulian Elischer 1653878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_IND: /* L2CA_Connect indicator */ 1654f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_con_ind(msg, rt, &so); 1655878ed226SJulian Elischer break; 1656878ed226SJulian Elischer 1657878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG: /* L2CA_Config response */ 1658f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_req_rsp(msg, rt, &so); 1659878ed226SJulian Elischer break; 1660878ed226SJulian Elischer 1661878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_RSP: /* L2CA_ConfigRsp response */ 1662f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(msg, rt, &so); 1663878ed226SJulian Elischer break; 1664878ed226SJulian Elischer 1665878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_IND: /* L2CA_Config indicator */ 1666f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_ind(msg, rt, &so); 1667878ed226SJulian Elischer break; 1668878ed226SJulian Elischer 1669878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON: /* L2CA_Disconnect response */ 1670f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_discon_rsp(msg, rt, &so); 1671878ed226SJulian Elischer break; 1672878ed226SJulian Elischer 1673878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON_IND: /* L2CA_Disconnect indicator */ 1674f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_discon_ind(msg, rt, &so); 1675878ed226SJulian Elischer break; 1676878ed226SJulian Elischer 1677878ed226SJulian Elischer case NGM_L2CAP_L2CA_WRITE: /* L2CA_Write response */ 1678f2bb1caeSJulian Elischer ng_btsocket_l2cap_process_l2ca_write_rsp(msg, rt, &so); 1679878ed226SJulian Elischer break; 1680878ed226SJulian Elischer 1681878ed226SJulian Elischer /* XXX FIXME add other L2CA messages */ 1682878ed226SJulian Elischer 1683878ed226SJulian Elischer default: 1684878ed226SJulian Elischer NG_BTSOCKET_L2CAP_WARN( 1685878ed226SJulian Elischer "%s: Unknown L2CA message, cmd=%d\n", __func__, msg->header.cmd); 1686878ed226SJulian Elischer break; 1687878ed226SJulian Elischer } 1688878ed226SJulian Elischer drop: 1689878ed226SJulian Elischer NG_FREE_MSG(msg); 1690f2bb1caeSJulian Elischer 1691f2bb1caeSJulian Elischer if (so != NULL) 1692f2bb1caeSJulian Elischer ng_btsocket_l2cap_detach(so); 1693878ed226SJulian Elischer } /* ng_btsocket_l2cap_l2ca_msg_input */ 1694878ed226SJulian Elischer 1695878ed226SJulian Elischer /* 1696878ed226SJulian Elischer * L2CAP sockets input routine 1697878ed226SJulian Elischer */ 1698878ed226SJulian Elischer 1699878ed226SJulian Elischer static void 1700878ed226SJulian Elischer ng_btsocket_l2cap_input(void *context, int pending) 1701878ed226SJulian Elischer { 1702878ed226SJulian Elischer item_p item = NULL; 1703878ed226SJulian Elischer hook_p hook = NULL; 1704878ed226SJulian Elischer 1705878ed226SJulian Elischer for (;;) { 1706878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_queue_mtx); 1707878ed226SJulian Elischer NG_BT_ITEMQ_DEQUEUE(&ng_btsocket_l2cap_queue, item); 1708878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 1709878ed226SJulian Elischer 1710878ed226SJulian Elischer if (item == NULL) 1711878ed226SJulian Elischer break; 1712878ed226SJulian Elischer 1713878ed226SJulian Elischer NGI_GET_HOOK(item, hook); 1714878ed226SJulian Elischer if (hook != NULL && NG_HOOK_NOT_VALID(hook)) 1715878ed226SJulian Elischer goto drop; 1716878ed226SJulian Elischer 1717878ed226SJulian Elischer switch(item->el_flags & NGQF_TYPE) { 1718878ed226SJulian Elischer case NGQF_DATA: { 1719878ed226SJulian Elischer struct mbuf *m = NULL; 1720878ed226SJulian Elischer 1721878ed226SJulian Elischer NGI_GET_M(item, m); 1722878ed226SJulian Elischer ng_btsocket_l2cap_data_input(m, hook); 1723878ed226SJulian Elischer } break; 1724878ed226SJulian Elischer 1725878ed226SJulian Elischer case NGQF_MESG: { 1726878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1727878ed226SJulian Elischer 1728878ed226SJulian Elischer NGI_GET_MSG(item, msg); 1729878ed226SJulian Elischer 1730878ed226SJulian Elischer switch (msg->header.cmd) { 1731878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON: 1732878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_RSP: 1733878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_IND: 1734878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG: 1735878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_RSP: 1736878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_IND: 1737878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON: 1738878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON_IND: 1739878ed226SJulian Elischer case NGM_L2CAP_L2CA_WRITE: 1740878ed226SJulian Elischer /* XXX FIXME add other L2CA messages */ 1741878ed226SJulian Elischer ng_btsocket_l2cap_l2ca_msg_input(msg, hook); 1742878ed226SJulian Elischer break; 1743878ed226SJulian Elischer 1744878ed226SJulian Elischer default: 1745878ed226SJulian Elischer ng_btsocket_l2cap_default_msg_input(msg, hook); 1746878ed226SJulian Elischer break; 1747878ed226SJulian Elischer } 1748878ed226SJulian Elischer } break; 1749878ed226SJulian Elischer 1750878ed226SJulian Elischer default: 1751878ed226SJulian Elischer KASSERT(0, 1752878ed226SJulian Elischer ("%s: invalid item type=%ld\n", __func__, (item->el_flags & NGQF_TYPE))); 1753878ed226SJulian Elischer break; 1754878ed226SJulian Elischer } 1755878ed226SJulian Elischer drop: 1756878ed226SJulian Elischer if (hook != NULL) 1757878ed226SJulian Elischer NG_HOOK_UNREF(hook); 1758878ed226SJulian Elischer 1759878ed226SJulian Elischer NG_FREE_ITEM(item); 1760878ed226SJulian Elischer } 1761878ed226SJulian Elischer } /* ng_btsocket_l2cap_input */ 1762878ed226SJulian Elischer 1763878ed226SJulian Elischer /* 1764878ed226SJulian Elischer * Route cleanup task. Gets scheduled when hook is disconnected. Here we 1765878ed226SJulian Elischer * will find all sockets that use "invalid" hook and disconnect them. 1766878ed226SJulian Elischer */ 1767878ed226SJulian Elischer 1768878ed226SJulian Elischer static void 1769878ed226SJulian Elischer ng_btsocket_l2cap_rtclean(void *context, int pending) 1770878ed226SJulian Elischer { 1771f2bb1caeSJulian Elischer ng_btsocket_l2cap_pcb_p pcb = NULL, pcb_next = NULL; 1772878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt = NULL; 1773878ed226SJulian Elischer 1774878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1775878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1776878ed226SJulian Elischer 1777878ed226SJulian Elischer /* 1778878ed226SJulian Elischer * First disconnect all sockets that use "invalid" hook 1779878ed226SJulian Elischer */ 1780878ed226SJulian Elischer 1781f2bb1caeSJulian Elischer for (pcb = LIST_FIRST(&ng_btsocket_l2cap_sockets); pcb != NULL; ) { 1782878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1783f2bb1caeSJulian Elischer pcb_next = LIST_NEXT(pcb, next); 1784878ed226SJulian Elischer 1785878ed226SJulian Elischer if (pcb->rt != NULL && 1786878ed226SJulian Elischer pcb->rt->hook != NULL && NG_HOOK_NOT_VALID(pcb->rt->hook)) { 1787878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1788878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1789878ed226SJulian Elischer 1790878ed226SJulian Elischer pcb->so->so_error = ENETDOWN; 1791878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1792878ed226SJulian Elischer soisdisconnected(pcb->so); 1793878ed226SJulian Elischer 1794878ed226SJulian Elischer pcb->token = 0; 1795f2bb1caeSJulian Elischer pcb->cid = 0; 1796878ed226SJulian Elischer pcb->rt = NULL; 1797f2bb1caeSJulian Elischer 1798f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) { 1799f2bb1caeSJulian Elischer struct socket *so = pcb->so; 1800f2bb1caeSJulian Elischer 1801f2bb1caeSJulian Elischer LIST_REMOVE(pcb, next); 1802f2bb1caeSJulian Elischer 1803f2bb1caeSJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1804f2bb1caeSJulian Elischer 1805f2bb1caeSJulian Elischer mtx_destroy(&pcb->pcb_mtx); 1806f2bb1caeSJulian Elischer bzero(pcb, sizeof(*pcb)); 1807f2bb1caeSJulian Elischer FREE(pcb, M_NETGRAPH_BTSOCKET_L2CAP); 1808f2bb1caeSJulian Elischer 1809f2bb1caeSJulian Elischer soisdisconnected(so); 1810f2bb1caeSJulian Elischer so->so_pcb = NULL; 1811f2bb1caeSJulian Elischer sotryfree(so); 1812f2bb1caeSJulian Elischer 1813f2bb1caeSJulian Elischer goto next; 1814f2bb1caeSJulian Elischer } 1815878ed226SJulian Elischer } 1816878ed226SJulian Elischer 1817878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1818f2bb1caeSJulian Elischer next: 1819f2bb1caeSJulian Elischer pcb = pcb_next; 1820878ed226SJulian Elischer } 1821878ed226SJulian Elischer 1822878ed226SJulian Elischer /* 1823878ed226SJulian Elischer * Now cleanup routing table 1824878ed226SJulian Elischer */ 1825878ed226SJulian Elischer 1826f2bb1caeSJulian Elischer for (rt = LIST_FIRST(&ng_btsocket_l2cap_rt); rt != NULL; ) { 1827878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt_next = LIST_NEXT(rt, next); 1828878ed226SJulian Elischer 1829878ed226SJulian Elischer if (rt->hook != NULL && NG_HOOK_NOT_VALID(rt->hook)) { 1830878ed226SJulian Elischer LIST_REMOVE(rt, next); 1831878ed226SJulian Elischer 1832878ed226SJulian Elischer NG_HOOK_SET_PRIVATE(rt->hook, NULL); 1833878ed226SJulian Elischer NG_HOOK_UNREF(rt->hook); /* Remove extra reference */ 1834878ed226SJulian Elischer 1835878ed226SJulian Elischer bzero(rt, sizeof(*rt)); 1836878ed226SJulian Elischer FREE(rt, M_NETGRAPH_BTSOCKET_L2CAP); 1837878ed226SJulian Elischer } 1838878ed226SJulian Elischer 1839878ed226SJulian Elischer rt = rt_next; 1840878ed226SJulian Elischer } 1841878ed226SJulian Elischer 1842878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1843878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1844878ed226SJulian Elischer } /* ng_btsocket_l2cap_rtclean */ 1845878ed226SJulian Elischer 1846878ed226SJulian Elischer /* 1847878ed226SJulian Elischer * Initialize everything 1848878ed226SJulian Elischer */ 1849878ed226SJulian Elischer 1850878ed226SJulian Elischer void 1851878ed226SJulian Elischer ng_btsocket_l2cap_init(void) 1852878ed226SJulian Elischer { 1853878ed226SJulian Elischer int error = 0; 1854878ed226SJulian Elischer 1855878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 1856878ed226SJulian Elischer ng_btsocket_l2cap_debug_level = NG_BTSOCKET_WARN_LEVEL; 1857878ed226SJulian Elischer 1858878ed226SJulian Elischer /* Register Netgraph node type */ 1859878ed226SJulian Elischer error = ng_newtype(&typestruct); 1860878ed226SJulian Elischer if (error != 0) { 1861878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1862878ed226SJulian Elischer "%s: Could not register Netgraph node type, error=%d\n", __func__, error); 1863878ed226SJulian Elischer 1864878ed226SJulian Elischer return; 1865878ed226SJulian Elischer } 1866878ed226SJulian Elischer 1867878ed226SJulian Elischer /* Create Netgrapg node */ 1868878ed226SJulian Elischer error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 1869878ed226SJulian Elischer if (error != 0) { 1870878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1871878ed226SJulian Elischer "%s: Could not create Netgraph node, error=%d\n", __func__, error); 1872878ed226SJulian Elischer 1873878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 1874878ed226SJulian Elischer 1875878ed226SJulian Elischer return; 1876878ed226SJulian Elischer } 1877878ed226SJulian Elischer 1878878ed226SJulian Elischer error = ng_name_node(ng_btsocket_l2cap_node, 1879878ed226SJulian Elischer NG_BTSOCKET_L2CAP_NODE_TYPE); 1880878ed226SJulian Elischer if (error != 0) { 1881878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1882878ed226SJulian Elischer "%s: Could not name Netgraph node, error=%d\n", __func__, error); 1883878ed226SJulian Elischer 1884878ed226SJulian Elischer NG_NODE_UNREF(ng_btsocket_l2cap_node); 1885878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 1886878ed226SJulian Elischer 1887878ed226SJulian Elischer return; 1888878ed226SJulian Elischer } 1889878ed226SJulian Elischer 1890878ed226SJulian Elischer /* Create input queue */ 1891878ed226SJulian Elischer NG_BT_ITEMQ_INIT(&ng_btsocket_l2cap_queue, ifqmaxlen); 1892878ed226SJulian Elischer mtx_init(&ng_btsocket_l2cap_queue_mtx, 1893878ed226SJulian Elischer "btsocks_l2cap_queue_mtx", NULL, MTX_DEF); 1894878ed226SJulian Elischer TASK_INIT(&ng_btsocket_l2cap_queue_task, 0, 1895878ed226SJulian Elischer ng_btsocket_l2cap_input, NULL); 1896878ed226SJulian Elischer 1897878ed226SJulian Elischer /* Create list of sockets */ 1898878ed226SJulian Elischer LIST_INIT(&ng_btsocket_l2cap_sockets); 1899878ed226SJulian Elischer mtx_init(&ng_btsocket_l2cap_sockets_mtx, 1900878ed226SJulian Elischer "btsocks_l2cap_sockets_mtx", NULL, MTX_DEF); 1901878ed226SJulian Elischer 1902878ed226SJulian Elischer /* Routing table */ 1903878ed226SJulian Elischer LIST_INIT(&ng_btsocket_l2cap_rt); 1904878ed226SJulian Elischer mtx_init(&ng_btsocket_l2cap_rt_mtx, 1905878ed226SJulian Elischer "btsocks_l2cap_rt_mtx", NULL, MTX_DEF); 1906878ed226SJulian Elischer TASK_INIT(&ng_btsocket_l2cap_rt_task, 0, 1907878ed226SJulian Elischer ng_btsocket_l2cap_rtclean, NULL); 1908878ed226SJulian Elischer } /* ng_btsocket_l2cap_init */ 1909878ed226SJulian Elischer 1910878ed226SJulian Elischer /* 1911878ed226SJulian Elischer * Abort connection on socket 1912878ed226SJulian Elischer */ 1913878ed226SJulian Elischer 1914878ed226SJulian Elischer int 1915878ed226SJulian Elischer ng_btsocket_l2cap_abort(struct socket *so) 1916878ed226SJulian Elischer { 1917878ed226SJulian Elischer so->so_error = ECONNABORTED; 1918878ed226SJulian Elischer 1919878ed226SJulian Elischer return (ng_btsocket_l2cap_detach(so)); 1920878ed226SJulian Elischer } /* ng_btsocket_l2cap_abort */ 1921878ed226SJulian Elischer 1922878ed226SJulian Elischer /* 1923878ed226SJulian Elischer * Accept connection on socket. Nothing to do here, socket must be connected 1924878ed226SJulian Elischer * and ready, so just return peer address and be done with it. 1925878ed226SJulian Elischer */ 1926878ed226SJulian Elischer 1927878ed226SJulian Elischer int 1928878ed226SJulian Elischer ng_btsocket_l2cap_accept(struct socket *so, struct sockaddr **nam) 1929878ed226SJulian Elischer { 1930878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 1931878ed226SJulian Elischer return (EINVAL); 1932878ed226SJulian Elischer 1933878ed226SJulian Elischer return (ng_btsocket_l2cap_peeraddr(so, nam)); 1934878ed226SJulian Elischer } /* ng_btsocket_l2cap_accept */ 1935878ed226SJulian Elischer 1936878ed226SJulian Elischer /* 1937878ed226SJulian Elischer * Create and attach new socket 1938878ed226SJulian Elischer */ 1939878ed226SJulian Elischer 1940878ed226SJulian Elischer int 1941878ed226SJulian Elischer ng_btsocket_l2cap_attach(struct socket *so, int proto, struct thread *td) 1942878ed226SJulian Elischer { 1943f2bb1caeSJulian Elischer static u_int32_t token = 0; 1944878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 1945878ed226SJulian Elischer int error; 1946878ed226SJulian Elischer 1947878ed226SJulian Elischer /* Check socket and protocol */ 1948878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 1949878ed226SJulian Elischer return (EPROTONOSUPPORT); 1950878ed226SJulian Elischer if (so->so_type != SOCK_SEQPACKET) 1951878ed226SJulian Elischer return (ESOCKTNOSUPPORT); 1952878ed226SJulian Elischer 1953878ed226SJulian Elischer #if 0 /* XXX sonewconn() calls "pru_attach" with proto == 0 */ 1954878ed226SJulian Elischer if (proto != 0) 1955878ed226SJulian Elischer if (proto != BLUETOOTH_PROTO_L2CAP) 1956878ed226SJulian Elischer return (EPROTONOSUPPORT); 1957878ed226SJulian Elischer #endif /* XXX */ 1958878ed226SJulian Elischer 1959878ed226SJulian Elischer if (pcb != NULL) 1960878ed226SJulian Elischer return (EISCONN); 1961878ed226SJulian Elischer 1962878ed226SJulian Elischer /* Reserve send and receive space if it is not reserved yet */ 1963878ed226SJulian Elischer if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 1964878ed226SJulian Elischer error = soreserve(so, NG_BTSOCKET_L2CAP_SENDSPACE, 1965878ed226SJulian Elischer NG_BTSOCKET_L2CAP_RECVSPACE); 1966878ed226SJulian Elischer if (error != 0) 1967878ed226SJulian Elischer return (error); 1968878ed226SJulian Elischer } 1969878ed226SJulian Elischer 1970878ed226SJulian Elischer /* Allocate the PCB */ 1971878ed226SJulian Elischer MALLOC(pcb, ng_btsocket_l2cap_pcb_p, sizeof(*pcb), 1972878ed226SJulian Elischer M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT | M_ZERO); 1973878ed226SJulian Elischer if (pcb == NULL) 1974878ed226SJulian Elischer return (ENOMEM); 1975878ed226SJulian Elischer 1976878ed226SJulian Elischer /* Link the PCB and the socket */ 1977878ed226SJulian Elischer so->so_pcb = (caddr_t) pcb; 1978878ed226SJulian Elischer pcb->so = so; 1979878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1980878ed226SJulian Elischer 1981878ed226SJulian Elischer /* Initialize PCB */ 1982878ed226SJulian Elischer pcb->imtu = pcb->omtu = NG_L2CAP_MTU_DEFAULT; 1983878ed226SJulian Elischer 1984878ed226SJulian Elischer /* Default flow */ 1985878ed226SJulian Elischer pcb->iflow.flags = 0x0; 1986878ed226SJulian Elischer pcb->iflow.service_type = NG_HCI_SERVICE_TYPE_BEST_EFFORT; 1987878ed226SJulian Elischer pcb->iflow.token_rate = 0xffffffff; /* maximum */ 1988878ed226SJulian Elischer pcb->iflow.token_bucket_size = 0xffffffff; /* maximum */ 1989878ed226SJulian Elischer pcb->iflow.peak_bandwidth = 0x00000000; /* maximum */ 1990878ed226SJulian Elischer pcb->iflow.latency = 0xffffffff; /* don't care */ 1991878ed226SJulian Elischer pcb->iflow.delay_variation = 0xffffffff; /* don't care */ 1992878ed226SJulian Elischer 1993878ed226SJulian Elischer bcopy(&pcb->iflow, &pcb->oflow, sizeof(pcb->oflow)); 1994878ed226SJulian Elischer 1995878ed226SJulian Elischer pcb->flush_timo = NG_L2CAP_FLUSH_TIMO_DEFAULT; 1996878ed226SJulian Elischer pcb->link_timo = NG_L2CAP_LINK_TIMO_DEFAULT; 1997878ed226SJulian Elischer 1998878ed226SJulian Elischer callout_handle_init(&pcb->timo); 1999878ed226SJulian Elischer 2000f2bb1caeSJulian Elischer /* 2001f2bb1caeSJulian Elischer * XXX Mark PCB mutex as DUPOK to prevent "duplicated lock of 2002f2bb1caeSJulian Elischer * the same type" message. When accepting new L2CAP connection 2003f2bb1caeSJulian Elischer * ng_btsocket_l2cap_process_l2ca_con_ind() holds both PCB mutexes 2004f2bb1caeSJulian Elischer * for "old" (accepting) PCB and "new" (created) PCB. 2005f2bb1caeSJulian Elischer */ 2006f2bb1caeSJulian Elischer 2007f2bb1caeSJulian Elischer mtx_init(&pcb->pcb_mtx, "btsocks_l2cap_pcb_mtx", NULL, 2008f2bb1caeSJulian Elischer MTX_DEF|MTX_DUPOK); 2009f2bb1caeSJulian Elischer 2010f2bb1caeSJulian Elischer /* 2011f2bb1caeSJulian Elischer * Add the PCB to the list 2012f2bb1caeSJulian Elischer * 2013f2bb1caeSJulian Elischer * XXX FIXME VERY IMPORTANT! 2014f2bb1caeSJulian Elischer * 2015f2bb1caeSJulian Elischer * This is totally FUBAR. We could get here in two cases: 2016f2bb1caeSJulian Elischer * 2017f2bb1caeSJulian Elischer * 1) When user calls socket() 2018f2bb1caeSJulian Elischer * 2) When we need to accept new incomming connection and call 2019f2bb1caeSJulian Elischer * sonewconn() 2020f2bb1caeSJulian Elischer * 2021f2bb1caeSJulian Elischer * In the first case we must aquire ng_btsocket_l2cap_sockets_mtx. 2022f2bb1caeSJulian Elischer * In the second case we hold ng_btsocket_l2cap_sockets_mtx already. 2023f2bb1caeSJulian Elischer * So we now need to distinguish between these cases. From reading 2024f2bb1caeSJulian Elischer * /sys/kern/uipc_socket2.c we can find out that sonewconn() calls 2025f2bb1caeSJulian Elischer * pru_attach with proto == 0 and td == NULL. For now use this fact 2026f2bb1caeSJulian Elischer * to figure out if we were called from socket() or from sonewconn(). 2027f2bb1caeSJulian Elischer */ 2028f2bb1caeSJulian Elischer 2029f2bb1caeSJulian Elischer if (td != NULL) 2030878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2031f2bb1caeSJulian Elischer else 2032f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2033f2bb1caeSJulian Elischer 2034f2bb1caeSJulian Elischer /* Set PCB token. Use ng_btsocket_l2cap_sockets_mtx for protection */ 2035f2bb1caeSJulian Elischer if (++ token == 0) 2036f2bb1caeSJulian Elischer token ++; 2037f2bb1caeSJulian Elischer 2038f2bb1caeSJulian Elischer pcb->token = token; 2039f2bb1caeSJulian Elischer 2040878ed226SJulian Elischer LIST_INSERT_HEAD(&ng_btsocket_l2cap_sockets, pcb, next); 2041f2bb1caeSJulian Elischer 2042f2bb1caeSJulian Elischer if (td != NULL) 2043878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2044878ed226SJulian Elischer 2045878ed226SJulian Elischer return (0); 2046878ed226SJulian Elischer } /* ng_btsocket_l2cap_attach */ 2047878ed226SJulian Elischer 2048878ed226SJulian Elischer /* 2049878ed226SJulian Elischer * Bind socket 2050878ed226SJulian Elischer */ 2051878ed226SJulian Elischer 2052878ed226SJulian Elischer int 2053878ed226SJulian Elischer ng_btsocket_l2cap_bind(struct socket *so, struct sockaddr *nam, 2054878ed226SJulian Elischer struct thread *td) 2055878ed226SJulian Elischer { 2056878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 2057878ed226SJulian Elischer struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2058878ed226SJulian Elischer int psm, error = 0; 2059878ed226SJulian Elischer 2060878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2061878ed226SJulian Elischer return (EINVAL); 2062878ed226SJulian Elischer 2063878ed226SJulian Elischer /* Verify address */ 2064878ed226SJulian Elischer if (sa == NULL) 2065878ed226SJulian Elischer return (EINVAL); 2066878ed226SJulian Elischer if (sa->l2cap_family != AF_BLUETOOTH) 2067878ed226SJulian Elischer return (EAFNOSUPPORT); 2068878ed226SJulian Elischer if (sa->l2cap_len != sizeof(*sa)) 2069878ed226SJulian Elischer return (EINVAL); 2070878ed226SJulian Elischer 2071878ed226SJulian Elischer psm = le16toh(sa->l2cap_psm); 2072878ed226SJulian Elischer 2073878ed226SJulian Elischer /* 2074878ed226SJulian Elischer * Check if other socket has this address already (look for exact 2075878ed226SJulian Elischer * match PSM and bdaddr) and assign socket address if it's available. 2076878ed226SJulian Elischer * 2077878ed226SJulian Elischer * Note: socket can be bound to ANY PSM (zero) thus allowing several 2078878ed226SJulian Elischer * channels with the same PSM between the same pair of BD_ADDR'es. 2079878ed226SJulian Elischer */ 2080878ed226SJulian Elischer 2081878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2082878ed226SJulian Elischer 2083878ed226SJulian Elischer LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) 2084878ed226SJulian Elischer if (psm != 0 && psm == pcb->psm && 2085878ed226SJulian Elischer bcmp(&pcb->src, &sa->l2cap_bdaddr, sizeof(bdaddr_t)) == 0) 2086878ed226SJulian Elischer break; 2087878ed226SJulian Elischer 2088878ed226SJulian Elischer if (pcb == NULL) { 2089878ed226SJulian Elischer /* Set socket address */ 2090878ed226SJulian Elischer pcb = so2l2cap_pcb(so); 2091878ed226SJulian Elischer if (pcb != NULL) { 2092878ed226SJulian Elischer bcopy(&sa->l2cap_bdaddr, &pcb->src, sizeof(pcb->src)); 2093878ed226SJulian Elischer pcb->psm = psm; 2094878ed226SJulian Elischer } else 2095878ed226SJulian Elischer error = EINVAL; 2096878ed226SJulian Elischer } else 2097878ed226SJulian Elischer error = EADDRINUSE; 2098878ed226SJulian Elischer 2099878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2100878ed226SJulian Elischer 2101878ed226SJulian Elischer return (error); 2102878ed226SJulian Elischer } /* ng_btsocket_l2cap_bind */ 2103878ed226SJulian Elischer 2104878ed226SJulian Elischer /* 2105878ed226SJulian Elischer * Connect socket 2106878ed226SJulian Elischer */ 2107878ed226SJulian Elischer 2108878ed226SJulian Elischer int 2109878ed226SJulian Elischer ng_btsocket_l2cap_connect(struct socket *so, struct sockaddr *nam, 2110878ed226SJulian Elischer struct thread *td) 2111878ed226SJulian Elischer { 2112878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2113878ed226SJulian Elischer struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2114878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_t *rt = NULL; 2115878ed226SJulian Elischer int have_src, error = 0; 2116878ed226SJulian Elischer 2117878ed226SJulian Elischer /* Check socket */ 2118878ed226SJulian Elischer if (pcb == NULL) 2119878ed226SJulian Elischer return (EINVAL); 2120878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2121878ed226SJulian Elischer return (EINVAL); 2122878ed226SJulian Elischer if (pcb->state == NG_BTSOCKET_L2CAP_CONNECTING) 2123878ed226SJulian Elischer return (EINPROGRESS); 2124878ed226SJulian Elischer 2125878ed226SJulian Elischer /* Verify address */ 2126878ed226SJulian Elischer if (sa == NULL) 2127878ed226SJulian Elischer return (EINVAL); 2128878ed226SJulian Elischer if (sa->l2cap_family != AF_BLUETOOTH) 2129878ed226SJulian Elischer return (EAFNOSUPPORT); 2130878ed226SJulian Elischer if (sa->l2cap_len != sizeof(*sa)) 2131878ed226SJulian Elischer return (EINVAL); 2132878ed226SJulian Elischer if (sa->l2cap_psm == 0 || 2133878ed226SJulian Elischer bcmp(&sa->l2cap_bdaddr, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 2134878ed226SJulian Elischer return (EDESTADDRREQ); 2135878ed226SJulian Elischer if (pcb->psm != 0 && pcb->psm != le16toh(sa->l2cap_psm)) 2136878ed226SJulian Elischer return (EINVAL); 2137878ed226SJulian Elischer 2138878ed226SJulian Elischer /* 2139878ed226SJulian Elischer * Routing. Socket should be bound to some source address. The source 2140878ed226SJulian Elischer * address can be ANY. Destination address must be set and it must not 2141878ed226SJulian Elischer * be ANY. If source address is ANY then find first rtentry that has 2142878ed226SJulian Elischer * src != dst. 2143878ed226SJulian Elischer */ 2144878ed226SJulian Elischer 2145f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_rt_mtx); 2146f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2147f2bb1caeSJulian Elischer mtx_lock(&pcb->pcb_mtx); 2148f2bb1caeSJulian Elischer 2149f2bb1caeSJulian Elischer /* Send destination address and PSM */ 2150f2bb1caeSJulian Elischer bcopy(&sa->l2cap_bdaddr, &pcb->dst, sizeof(pcb->dst)); 2151f2bb1caeSJulian Elischer pcb->psm = le16toh(sa->l2cap_psm); 2152f2bb1caeSJulian Elischer 2153878ed226SJulian Elischer pcb->rt = NULL; 2154878ed226SJulian Elischer have_src = bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)); 2155878ed226SJulian Elischer 2156878ed226SJulian Elischer LIST_FOREACH(rt, &ng_btsocket_l2cap_rt, next) { 2157878ed226SJulian Elischer if (rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 2158878ed226SJulian Elischer continue; 2159878ed226SJulian Elischer 2160878ed226SJulian Elischer /* Match src and dst */ 2161878ed226SJulian Elischer if (have_src) { 2162878ed226SJulian Elischer if (bcmp(&pcb->src, &rt->src, sizeof(rt->src)) == 0) 2163878ed226SJulian Elischer break; 2164878ed226SJulian Elischer } else { 2165878ed226SJulian Elischer if (bcmp(&pcb->dst, &rt->src, sizeof(rt->src)) != 0) 2166878ed226SJulian Elischer break; 2167878ed226SJulian Elischer } 2168878ed226SJulian Elischer } 2169878ed226SJulian Elischer 2170878ed226SJulian Elischer if (rt != NULL) { 2171878ed226SJulian Elischer pcb->rt = rt; 2172878ed226SJulian Elischer 2173878ed226SJulian Elischer if (!have_src) 2174878ed226SJulian Elischer bcopy(&rt->src, &pcb->src, sizeof(pcb->src)); 2175878ed226SJulian Elischer } else 2176878ed226SJulian Elischer error = EHOSTUNREACH; 2177878ed226SJulian Elischer 2178878ed226SJulian Elischer /* 2179878ed226SJulian Elischer * Send L2CA_Connect request 2180878ed226SJulian Elischer */ 2181878ed226SJulian Elischer 2182878ed226SJulian Elischer if (error == 0) { 2183878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_con_req(pcb); 2184878ed226SJulian Elischer if (error == 0) { 2185878ed226SJulian Elischer pcb->flags |= NG_BTSOCKET_L2CAP_CLIENT; 2186878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CONNECTING; 2187878ed226SJulian Elischer soisconnecting(pcb->so); 2188878ed226SJulian Elischer 2189878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 2190878ed226SJulian Elischer } 2191878ed226SJulian Elischer } 2192878ed226SJulian Elischer 2193f2bb1caeSJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2194f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2195f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 2196f2bb1caeSJulian Elischer 2197878ed226SJulian Elischer return (error); 2198878ed226SJulian Elischer } /* ng_btsocket_l2cap_connect */ 2199878ed226SJulian Elischer 2200878ed226SJulian Elischer /* 2201878ed226SJulian Elischer * Process ioctl's calls on socket 2202878ed226SJulian Elischer */ 2203878ed226SJulian Elischer 2204878ed226SJulian Elischer int 2205878ed226SJulian Elischer ng_btsocket_l2cap_control(struct socket *so, u_long cmd, caddr_t data, 2206878ed226SJulian Elischer struct ifnet *ifp, struct thread *td) 2207878ed226SJulian Elischer { 2208878ed226SJulian Elischer return (EINVAL); 2209878ed226SJulian Elischer } /* ng_btsocket_l2cap_control */ 2210878ed226SJulian Elischer 2211878ed226SJulian Elischer /* 2212878ed226SJulian Elischer * Process getsockopt/setsockopt system calls 2213878ed226SJulian Elischer */ 2214878ed226SJulian Elischer 2215878ed226SJulian Elischer int 2216878ed226SJulian Elischer ng_btsocket_l2cap_ctloutput(struct socket *so, struct sockopt *sopt) 2217878ed226SJulian Elischer { 2218878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2219878ed226SJulian Elischer int error = 0; 2220878ed226SJulian Elischer ng_l2cap_cfg_opt_val_t v; 2221878ed226SJulian Elischer 2222878ed226SJulian Elischer if (pcb == NULL) 2223878ed226SJulian Elischer return (EINVAL); 2224878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2225878ed226SJulian Elischer return (EINVAL); 2226878ed226SJulian Elischer 2227878ed226SJulian Elischer if (sopt->sopt_level != SOL_L2CAP) 2228878ed226SJulian Elischer return (0); 2229878ed226SJulian Elischer 2230878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2231878ed226SJulian Elischer 2232878ed226SJulian Elischer switch (sopt->sopt_dir) { 2233878ed226SJulian Elischer case SOPT_GET: 2234878ed226SJulian Elischer switch (sopt->sopt_name) { 2235878ed226SJulian Elischer case SO_L2CAP_IMTU: /* get incoming MTU */ 2236878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->imtu, 2237878ed226SJulian Elischer sizeof(pcb->imtu)); 2238878ed226SJulian Elischer break; 2239878ed226SJulian Elischer 2240878ed226SJulian Elischer case SO_L2CAP_OMTU: /* get outgoing (peer incoming) MTU */ 2241878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->omtu, 2242878ed226SJulian Elischer sizeof(pcb->omtu)); 2243878ed226SJulian Elischer break; 2244878ed226SJulian Elischer 2245878ed226SJulian Elischer case SO_L2CAP_IFLOW: /* get incoming flow spec. */ 2246878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->iflow, 2247878ed226SJulian Elischer sizeof(pcb->iflow)); 2248878ed226SJulian Elischer break; 2249878ed226SJulian Elischer 2250878ed226SJulian Elischer case SO_L2CAP_OFLOW: /* get outgoing flow spec. */ 2251878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->oflow, 2252878ed226SJulian Elischer sizeof(pcb->oflow)); 2253878ed226SJulian Elischer break; 2254878ed226SJulian Elischer 2255878ed226SJulian Elischer case SO_L2CAP_FLUSH: /* get flush timeout */ 2256878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->flush_timo, 2257878ed226SJulian Elischer sizeof(pcb->flush_timo)); 2258878ed226SJulian Elischer break; 2259878ed226SJulian Elischer 2260878ed226SJulian Elischer default: 2261878ed226SJulian Elischer error = ENOPROTOOPT; 2262878ed226SJulian Elischer break; 2263878ed226SJulian Elischer } 2264878ed226SJulian Elischer break; 2265878ed226SJulian Elischer 2266878ed226SJulian Elischer case SOPT_SET: 2267878ed226SJulian Elischer /* 2268f2bb1caeSJulian Elischer * XXX 2269f2bb1caeSJulian Elischer * We do not allow to change these parameters while socket is 2270f2bb1caeSJulian Elischer * connected or we are in the process of creating a connection. 2271f2bb1caeSJulian Elischer * May be this should indicate re-configuration of the open 2272f2bb1caeSJulian Elischer * channel? 2273878ed226SJulian Elischer */ 2274878ed226SJulian Elischer 2275878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) 2276878ed226SJulian Elischer return (EACCES); 2277878ed226SJulian Elischer 2278878ed226SJulian Elischer switch (sopt->sopt_name) { 2279878ed226SJulian Elischer case SO_L2CAP_IMTU: /* set incoming MTU */ 2280878ed226SJulian Elischer error = sooptcopyin(sopt, &v, sizeof(v), sizeof(v.mtu)); 2281878ed226SJulian Elischer if (error == 0) 2282878ed226SJulian Elischer pcb->imtu = v.mtu; 2283878ed226SJulian Elischer break; 2284878ed226SJulian Elischer 2285878ed226SJulian Elischer case SO_L2CAP_OFLOW: /* set outgoing flow spec. */ 2286878ed226SJulian Elischer error = sooptcopyin(sopt, &v, sizeof(v),sizeof(v.flow)); 2287878ed226SJulian Elischer if (error == 0) 2288878ed226SJulian Elischer bcopy(&v.flow, &pcb->oflow, sizeof(pcb->oflow)); 2289878ed226SJulian Elischer break; 2290878ed226SJulian Elischer 2291878ed226SJulian Elischer case SO_L2CAP_FLUSH: /* set flush timeout */ 2292878ed226SJulian Elischer error = sooptcopyin(sopt, &v, sizeof(v), 2293878ed226SJulian Elischer sizeof(v.flush_timo)); 2294878ed226SJulian Elischer if (error == 0) 2295878ed226SJulian Elischer pcb->flush_timo = v.flush_timo; 2296878ed226SJulian Elischer break; 2297878ed226SJulian Elischer 2298878ed226SJulian Elischer default: 2299878ed226SJulian Elischer error = ENOPROTOOPT; 2300878ed226SJulian Elischer break; 2301878ed226SJulian Elischer } 2302878ed226SJulian Elischer break; 2303878ed226SJulian Elischer 2304878ed226SJulian Elischer default: 2305878ed226SJulian Elischer error = EINVAL; 2306878ed226SJulian Elischer break; 2307878ed226SJulian Elischer } 2308878ed226SJulian Elischer 2309878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2310878ed226SJulian Elischer 2311878ed226SJulian Elischer return (error); 2312878ed226SJulian Elischer } /* ng_btsocket_l2cap_ctloutput */ 2313878ed226SJulian Elischer 2314878ed226SJulian Elischer /* 2315878ed226SJulian Elischer * Detach and destroy socket 2316878ed226SJulian Elischer */ 2317878ed226SJulian Elischer 2318878ed226SJulian Elischer int 2319878ed226SJulian Elischer ng_btsocket_l2cap_detach(struct socket *so) 2320878ed226SJulian Elischer { 2321878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2322878ed226SJulian Elischer 2323878ed226SJulian Elischer if (pcb == NULL) 2324878ed226SJulian Elischer return (EINVAL); 2325878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2326878ed226SJulian Elischer return (EINVAL); 2327878ed226SJulian Elischer 2328f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2329878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2330878ed226SJulian Elischer 2331878ed226SJulian Elischer /* XXX what to do with pending request? */ 2332878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2333878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 2334878ed226SJulian Elischer 2335878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED && 2336878ed226SJulian Elischer pcb->state != NG_BTSOCKET_L2CAP_DISCONNECTING) 2337878ed226SJulian Elischer /* Send disconnect request with "zero" token */ 2338878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2339878ed226SJulian Elischer 2340878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2341878ed226SJulian Elischer 2342f2bb1caeSJulian Elischer LIST_REMOVE(pcb, next); 2343878ed226SJulian Elischer 2344878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2345878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2346878ed226SJulian Elischer 2347878ed226SJulian Elischer mtx_destroy(&pcb->pcb_mtx); 2348878ed226SJulian Elischer bzero(pcb, sizeof(*pcb)); 2349878ed226SJulian Elischer FREE(pcb, M_NETGRAPH_BTSOCKET_L2CAP); 2350878ed226SJulian Elischer 2351f2bb1caeSJulian Elischer soisdisconnected(so); 2352f2bb1caeSJulian Elischer so->so_pcb = NULL; 2353f2bb1caeSJulian Elischer sotryfree(so); 2354f2bb1caeSJulian Elischer 2355878ed226SJulian Elischer return (0); 2356878ed226SJulian Elischer } /* ng_btsocket_l2cap_detach */ 2357878ed226SJulian Elischer 2358878ed226SJulian Elischer /* 2359878ed226SJulian Elischer * Disconnect socket 2360878ed226SJulian Elischer */ 2361878ed226SJulian Elischer 2362878ed226SJulian Elischer int 2363878ed226SJulian Elischer ng_btsocket_l2cap_disconnect(struct socket *so) 2364878ed226SJulian Elischer { 2365878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2366878ed226SJulian Elischer int error = 0; 2367878ed226SJulian Elischer 2368878ed226SJulian Elischer if (pcb == NULL) 2369878ed226SJulian Elischer return (EINVAL); 2370878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2371878ed226SJulian Elischer return (EINVAL); 2372878ed226SJulian Elischer 2373878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2374878ed226SJulian Elischer 2375878ed226SJulian Elischer if (pcb->state == NG_BTSOCKET_L2CAP_DISCONNECTING) { 2376878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2377878ed226SJulian Elischer return (EINPROGRESS); 2378878ed226SJulian Elischer } 2379878ed226SJulian Elischer 2380878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 2381878ed226SJulian Elischer /* XXX FIXME what to do with pending request? */ 2382878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2383878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 2384878ed226SJulian Elischer 2385878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_discon_req(pcb->token, pcb); 2386878ed226SJulian Elischer if (error == 0) { 2387878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_DISCONNECTING; 2388878ed226SJulian Elischer soisdisconnecting(so); 2389878ed226SJulian Elischer 2390878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 2391878ed226SJulian Elischer } 2392878ed226SJulian Elischer 2393878ed226SJulian Elischer /* XXX FIXME what to do if error != 0 */ 2394878ed226SJulian Elischer } 2395878ed226SJulian Elischer 2396878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2397878ed226SJulian Elischer 2398878ed226SJulian Elischer return (error); 2399878ed226SJulian Elischer } /* ng_btsocket_l2cap_disconnect */ 2400878ed226SJulian Elischer 2401878ed226SJulian Elischer /* 2402878ed226SJulian Elischer * Listen on socket 2403878ed226SJulian Elischer */ 2404878ed226SJulian Elischer 2405878ed226SJulian Elischer int 2406878ed226SJulian Elischer ng_btsocket_l2cap_listen(struct socket *so, struct thread *td) 2407878ed226SJulian Elischer { 2408878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2409878ed226SJulian Elischer 2410878ed226SJulian Elischer if (pcb == NULL) 2411878ed226SJulian Elischer return (EINVAL); 2412878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2413878ed226SJulian Elischer return (EINVAL); 2414878ed226SJulian Elischer 2415878ed226SJulian Elischer return ((pcb->psm == 0)? EDESTADDRREQ : 0); 2416878ed226SJulian Elischer } /* ng_btsocket_listen */ 2417878ed226SJulian Elischer 2418878ed226SJulian Elischer /* 2419878ed226SJulian Elischer * Get peer address 2420878ed226SJulian Elischer */ 2421878ed226SJulian Elischer 2422878ed226SJulian Elischer int 2423878ed226SJulian Elischer ng_btsocket_l2cap_peeraddr(struct socket *so, struct sockaddr **nam) 2424878ed226SJulian Elischer { 2425878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2426878ed226SJulian Elischer struct sockaddr_l2cap sa; 2427878ed226SJulian Elischer 2428878ed226SJulian Elischer if (pcb == NULL) 2429878ed226SJulian Elischer return (EINVAL); 2430878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2431878ed226SJulian Elischer return (EINVAL); 2432878ed226SJulian Elischer 2433878ed226SJulian Elischer bcopy(&pcb->dst, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2434878ed226SJulian Elischer sa.l2cap_psm = htole16(pcb->psm); 2435878ed226SJulian Elischer sa.l2cap_len = sizeof(sa); 2436878ed226SJulian Elischer sa.l2cap_family = AF_BLUETOOTH; 2437878ed226SJulian Elischer 2438878ed226SJulian Elischer *nam = dup_sockaddr((struct sockaddr *) &sa, 0); 2439878ed226SJulian Elischer 2440878ed226SJulian Elischer return ((*nam == NULL)? ENOMEM : 0); 2441878ed226SJulian Elischer } /* ng_btsocket_l2cap_peeraddr */ 2442878ed226SJulian Elischer 2443878ed226SJulian Elischer /* 2444878ed226SJulian Elischer * Send data to socket 2445878ed226SJulian Elischer */ 2446878ed226SJulian Elischer 2447878ed226SJulian Elischer int 2448878ed226SJulian Elischer ng_btsocket_l2cap_send(struct socket *so, int flags, struct mbuf *m, 2449878ed226SJulian Elischer struct sockaddr *nam, struct mbuf *control, struct thread *td) 2450878ed226SJulian Elischer { 2451878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2452878ed226SJulian Elischer int error = 0; 2453878ed226SJulian Elischer 2454878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) { 2455878ed226SJulian Elischer error = ENETDOWN; 2456878ed226SJulian Elischer goto drop; 2457878ed226SJulian Elischer } 2458878ed226SJulian Elischer 2459878ed226SJulian Elischer /* Check socket and input */ 2460878ed226SJulian Elischer if (pcb == NULL || m == NULL || control != NULL) { 2461878ed226SJulian Elischer error = EINVAL; 2462878ed226SJulian Elischer goto drop; 2463878ed226SJulian Elischer } 2464878ed226SJulian Elischer 2465878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2466878ed226SJulian Elischer 2467878ed226SJulian Elischer /* Make sure socket is connected */ 2468878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 2469878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2470878ed226SJulian Elischer error = ENOTCONN; 2471878ed226SJulian Elischer goto drop; 2472878ed226SJulian Elischer } 2473878ed226SJulian Elischer 2474878ed226SJulian Elischer /* Check route */ 2475878ed226SJulian Elischer if (pcb->rt == NULL || 2476878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) { 2477878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2478878ed226SJulian Elischer error = ENETDOWN; 2479878ed226SJulian Elischer goto drop; 2480878ed226SJulian Elischer } 2481878ed226SJulian Elischer 2482878ed226SJulian Elischer /* Check packet size agains outgoing (peer's incoming) MTU) */ 2483878ed226SJulian Elischer if (m->m_pkthdr.len > pcb->omtu) { 2484878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 2485878ed226SJulian Elischer "%s: Packet too big, len=%d, omtu=%d\n", __func__, m->m_pkthdr.len, pcb->omtu); 2486878ed226SJulian Elischer 2487878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2488878ed226SJulian Elischer error = EMSGSIZE; 2489878ed226SJulian Elischer goto drop; 2490878ed226SJulian Elischer } 2491878ed226SJulian Elischer 2492878ed226SJulian Elischer /* 2493878ed226SJulian Elischer * First put packet on socket send queue. Then check if we have 2494878ed226SJulian Elischer * pending timeout. If we do not have timeout then we must send 2495878ed226SJulian Elischer * packet and schedule timeout. Otherwise do nothing and wait for 2496878ed226SJulian Elischer * L2CA_WRITE_RSP. 2497878ed226SJulian Elischer */ 2498878ed226SJulian Elischer 2499878ed226SJulian Elischer sbappendrecord(&pcb->so->so_snd, m); 2500878ed226SJulian Elischer m = NULL; 2501878ed226SJulian Elischer 2502878ed226SJulian Elischer if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2503878ed226SJulian Elischer error = ng_btsocket_l2cap_send2(pcb); 2504878ed226SJulian Elischer if (error == 0) 2505878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 2506878ed226SJulian Elischer else 2507878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); /* XXX */ 2508878ed226SJulian Elischer } 2509878ed226SJulian Elischer 2510878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2511878ed226SJulian Elischer drop: 2512878ed226SJulian Elischer NG_FREE_M(m); /* checks for != NULL */ 2513878ed226SJulian Elischer NG_FREE_M(control); 2514878ed226SJulian Elischer 2515878ed226SJulian Elischer return (error); 2516878ed226SJulian Elischer } /* ng_btsocket_l2cap_send */ 2517878ed226SJulian Elischer 2518878ed226SJulian Elischer /* 2519878ed226SJulian Elischer * Send first packet in the socket queue to the L2CAP layer 2520878ed226SJulian Elischer */ 2521878ed226SJulian Elischer 2522878ed226SJulian Elischer static int 2523878ed226SJulian Elischer ng_btsocket_l2cap_send2(ng_btsocket_l2cap_pcb_p pcb) 2524878ed226SJulian Elischer { 2525878ed226SJulian Elischer struct mbuf *m = NULL; 2526878ed226SJulian Elischer ng_l2cap_l2ca_hdr_t *hdr = NULL; 2527878ed226SJulian Elischer int error = 0; 2528878ed226SJulian Elischer 2529878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2530878ed226SJulian Elischer 2531878ed226SJulian Elischer if (pcb->so->so_snd.sb_cc == 0) 2532878ed226SJulian Elischer return (EINVAL); /* XXX */ 2533878ed226SJulian Elischer 2534a163d034SWarner Losh m = m_dup(pcb->so->so_snd.sb_mb, M_DONTWAIT); 2535878ed226SJulian Elischer if (m == NULL) 2536878ed226SJulian Elischer return (ENOBUFS); 2537878ed226SJulian Elischer 2538878ed226SJulian Elischer /* Create L2CA packet header */ 2539f2bb1caeSJulian Elischer M_PREPEND(m, sizeof(*hdr), M_DONTWAIT); 2540878ed226SJulian Elischer if (m != NULL) 2541878ed226SJulian Elischer if (m->m_len < sizeof(*hdr)) 2542878ed226SJulian Elischer m = m_pullup(m, sizeof(*hdr)); 2543878ed226SJulian Elischer 2544878ed226SJulian Elischer if (m == NULL) { 2545878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 2546878ed226SJulian Elischer "%s: Failed to create L2CA packet header\n", __func__); 2547878ed226SJulian Elischer 2548878ed226SJulian Elischer return (ENOBUFS); 2549878ed226SJulian Elischer } 2550878ed226SJulian Elischer 2551878ed226SJulian Elischer hdr = mtod(m, ng_l2cap_l2ca_hdr_t *); 2552878ed226SJulian Elischer hdr->token = pcb->token; 2553878ed226SJulian Elischer hdr->length = m->m_pkthdr.len - sizeof(*hdr); 2554878ed226SJulian Elischer hdr->lcid = pcb->cid; 2555878ed226SJulian Elischer 2556878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 2557878ed226SJulian Elischer "%s: Sending packet: len=%d, length=%d, lcid=%d, token=%d, state=%d\n", 2558878ed226SJulian Elischer __func__, m->m_pkthdr.len, hdr->length, hdr->lcid, 2559878ed226SJulian Elischer hdr->token, pcb->state); 2560878ed226SJulian Elischer 2561878ed226SJulian Elischer /* 2562878ed226SJulian Elischer * If we got here than we have successfuly creates new L2CAP 2563878ed226SJulian Elischer * data packet and now we can send it to the L2CAP layer 2564878ed226SJulian Elischer */ 2565878ed226SJulian Elischer 2566878ed226SJulian Elischer NG_SEND_DATA_ONLY(error, pcb->rt->hook, m); 2567878ed226SJulian Elischer 2568878ed226SJulian Elischer return (error); 2569878ed226SJulian Elischer } /* ng_btsocket_l2cap_send2 */ 2570878ed226SJulian Elischer 2571878ed226SJulian Elischer /* 2572878ed226SJulian Elischer * Get socket address 2573878ed226SJulian Elischer */ 2574878ed226SJulian Elischer 2575878ed226SJulian Elischer int 2576878ed226SJulian Elischer ng_btsocket_l2cap_sockaddr(struct socket *so, struct sockaddr **nam) 2577878ed226SJulian Elischer { 2578878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2579878ed226SJulian Elischer struct sockaddr_l2cap sa; 2580878ed226SJulian Elischer 2581878ed226SJulian Elischer if (pcb == NULL) 2582878ed226SJulian Elischer return (EINVAL); 2583878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2584878ed226SJulian Elischer return (EINVAL); 2585878ed226SJulian Elischer 2586878ed226SJulian Elischer bcopy(&pcb->src, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2587878ed226SJulian Elischer sa.l2cap_psm = htole16(pcb->psm); 2588878ed226SJulian Elischer sa.l2cap_len = sizeof(sa); 2589878ed226SJulian Elischer sa.l2cap_family = AF_BLUETOOTH; 2590878ed226SJulian Elischer 2591878ed226SJulian Elischer *nam = dup_sockaddr((struct sockaddr *) &sa, 0); 2592878ed226SJulian Elischer 2593878ed226SJulian Elischer return ((*nam == NULL)? ENOMEM : 0); 2594878ed226SJulian Elischer } /* ng_btsocket_l2cap_sockaddr */ 2595878ed226SJulian Elischer 2596878ed226SJulian Elischer /***************************************************************************** 2597878ed226SJulian Elischer ***************************************************************************** 2598878ed226SJulian Elischer ** Misc. functions 2599878ed226SJulian Elischer ***************************************************************************** 2600878ed226SJulian Elischer *****************************************************************************/ 2601878ed226SJulian Elischer 2602878ed226SJulian Elischer /* 2603878ed226SJulian Elischer * Look for the socket that listens on given PSM and bdaddr. Returns exact or 2604f2bb1caeSJulian Elischer * close match (if any). Caller must hold ng_btsocket_l2cap_sockets_mtx. 2605878ed226SJulian Elischer */ 2606878ed226SJulian Elischer 2607878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p 2608878ed226SJulian Elischer ng_btsocket_l2cap_pcb_by_addr(bdaddr_p bdaddr, int psm) 2609878ed226SJulian Elischer { 2610878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p p = NULL, p1 = NULL; 2611878ed226SJulian Elischer 2612f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2613878ed226SJulian Elischer 2614878ed226SJulian Elischer LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) { 2615878ed226SJulian Elischer if (p->so == NULL || !(p->so->so_options & SO_ACCEPTCONN) || 2616878ed226SJulian Elischer p->psm != psm) 2617878ed226SJulian Elischer continue; 2618878ed226SJulian Elischer 2619878ed226SJulian Elischer if (bcmp(&p->src, bdaddr, sizeof(p->src)) == 0) 2620878ed226SJulian Elischer break; 2621878ed226SJulian Elischer 2622878ed226SJulian Elischer if (bcmp(&p->src, NG_HCI_BDADDR_ANY, sizeof(p->src)) == 0) 2623878ed226SJulian Elischer p1 = p; 2624878ed226SJulian Elischer } 2625878ed226SJulian Elischer 2626878ed226SJulian Elischer return ((p != NULL)? p : p1); 2627878ed226SJulian Elischer } /* ng_btsocket_l2cap_pcb_by_addr */ 2628878ed226SJulian Elischer 2629878ed226SJulian Elischer /* 2630f2bb1caeSJulian Elischer * Look for the socket that has given token. 2631f2bb1caeSJulian Elischer * Caller must hold ng_btsocket_l2cap_sockets_mtx. 2632878ed226SJulian Elischer */ 2633878ed226SJulian Elischer 2634878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p 2635878ed226SJulian Elischer ng_btsocket_l2cap_pcb_by_token(u_int32_t token) 2636878ed226SJulian Elischer { 2637878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p p = NULL; 2638878ed226SJulian Elischer 2639f2bb1caeSJulian Elischer if (token == 0) 2640f2bb1caeSJulian Elischer return (NULL); 2641f2bb1caeSJulian Elischer 2642f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2643878ed226SJulian Elischer 2644878ed226SJulian Elischer LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2645878ed226SJulian Elischer if (p->token == token) 2646878ed226SJulian Elischer break; 2647878ed226SJulian Elischer 2648878ed226SJulian Elischer return (p); 2649878ed226SJulian Elischer } /* ng_btsocket_l2cap_pcb_by_token */ 2650878ed226SJulian Elischer 2651878ed226SJulian Elischer /* 2652f2bb1caeSJulian Elischer * Look for the socket that assigned to given source address and channel ID. 2653f2bb1caeSJulian Elischer * Caller must hold ng_btsocket_l2cap_sockets_mtx 2654878ed226SJulian Elischer */ 2655878ed226SJulian Elischer 2656878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p 2657878ed226SJulian Elischer ng_btsocket_l2cap_pcb_by_cid(bdaddr_p src, int cid) 2658878ed226SJulian Elischer { 2659878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p p = NULL; 2660878ed226SJulian Elischer 2661f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2662878ed226SJulian Elischer 2663878ed226SJulian Elischer LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2664878ed226SJulian Elischer if (p->cid == cid && bcmp(src, &p->src, sizeof(p->src)) == 0) 2665878ed226SJulian Elischer break; 2666878ed226SJulian Elischer 2667878ed226SJulian Elischer return (p); 2668878ed226SJulian Elischer } /* ng_btsocket_l2cap_pcb_by_cid */ 2669878ed226SJulian Elischer 2670878ed226SJulian Elischer /* 2671878ed226SJulian Elischer * Set timeout on socket 2672878ed226SJulian Elischer */ 2673878ed226SJulian Elischer 2674878ed226SJulian Elischer static void 2675878ed226SJulian Elischer ng_btsocket_l2cap_timeout(ng_btsocket_l2cap_pcb_p pcb) 2676878ed226SJulian Elischer { 2677878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2678878ed226SJulian Elischer 2679878ed226SJulian Elischer if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2680878ed226SJulian Elischer pcb->flags |= NG_BTSOCKET_L2CAP_TIMO; 2681878ed226SJulian Elischer pcb->timo = timeout(ng_btsocket_l2cap_process_timeout, pcb, 2682878ed226SJulian Elischer bluetooth_l2cap_ertx_timeout()); 2683878ed226SJulian Elischer } else 2684878ed226SJulian Elischer KASSERT(0, 2685878ed226SJulian Elischer ("%s: Duplicated socket timeout?!\n", __func__)); 2686878ed226SJulian Elischer } /* ng_btsocket_l2cap_timeout */ 2687878ed226SJulian Elischer 2688878ed226SJulian Elischer /* 2689878ed226SJulian Elischer * Unset timeout on socket 2690878ed226SJulian Elischer */ 2691878ed226SJulian Elischer 2692878ed226SJulian Elischer static void 2693878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(ng_btsocket_l2cap_pcb_p pcb) 2694878ed226SJulian Elischer { 2695878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2696878ed226SJulian Elischer 2697878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) { 2698878ed226SJulian Elischer untimeout(ng_btsocket_l2cap_process_timeout, pcb, pcb->timo); 2699878ed226SJulian Elischer pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2700878ed226SJulian Elischer } else 2701878ed226SJulian Elischer KASSERT(0, 2702878ed226SJulian Elischer ("%s: No socket timeout?!\n", __func__)); 2703878ed226SJulian Elischer } /* ng_btsocket_l2cap_untimeout */ 2704878ed226SJulian Elischer 2705878ed226SJulian Elischer /* 2706878ed226SJulian Elischer * Process timeout on socket 2707878ed226SJulian Elischer */ 2708878ed226SJulian Elischer 2709878ed226SJulian Elischer static void 2710878ed226SJulian Elischer ng_btsocket_l2cap_process_timeout(void *xpcb) 2711878ed226SJulian Elischer { 2712878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = (ng_btsocket_l2cap_pcb_p) xpcb; 2713f2bb1caeSJulian Elischer struct socket *so = NULL; 2714878ed226SJulian Elischer 2715878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2716878ed226SJulian Elischer 2717878ed226SJulian Elischer pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2718878ed226SJulian Elischer pcb->so->so_error = ETIMEDOUT; 2719878ed226SJulian Elischer 2720878ed226SJulian Elischer switch (pcb->state) { 2721878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_CONNECTING: 2722878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_CONFIGURING: 2723878ed226SJulian Elischer /* Send disconnect request with "zero" token */ 2724878ed226SJulian Elischer if (pcb->cid != 0) 2725878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2726878ed226SJulian Elischer 2727878ed226SJulian Elischer /* ... and close the socket */ 2728878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2729878ed226SJulian Elischer soisdisconnected(pcb->so); 2730f2bb1caeSJulian Elischer 2731f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 2732f2bb1caeSJulian Elischer so = pcb->so; 2733878ed226SJulian Elischer break; 2734878ed226SJulian Elischer 2735878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_OPEN: 2736878ed226SJulian Elischer /* Send timeout - drop packet and wakeup sender */ 2737878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); 2738878ed226SJulian Elischer sowwakeup(pcb->so); 2739878ed226SJulian Elischer break; 2740878ed226SJulian Elischer 2741878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_DISCONNECTING: 2742878ed226SJulian Elischer /* Disconnect timeout - disconnect the socket anyway */ 2743878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2744878ed226SJulian Elischer soisdisconnected(pcb->so); 2745f2bb1caeSJulian Elischer 2746f2bb1caeSJulian Elischer if (pcb->so->so_state & SS_NOFDREF) 2747f2bb1caeSJulian Elischer so = pcb->so; 2748878ed226SJulian Elischer break; 2749878ed226SJulian Elischer 2750878ed226SJulian Elischer default: 2751878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 2752878ed226SJulian Elischer "%s: Invalid socket state=%d\n", __func__, pcb->state); 2753878ed226SJulian Elischer break; 2754878ed226SJulian Elischer } 2755878ed226SJulian Elischer 2756878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2757f2bb1caeSJulian Elischer 2758f2bb1caeSJulian Elischer if (so != NULL) 2759f2bb1caeSJulian Elischer ng_btsocket_l2cap_detach(so); 2760878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_timeout */ 2761878ed226SJulian Elischer 2762878ed226SJulian Elischer /* 2763878ed226SJulian Elischer * Translate HCI/L2CAP error code into "errno" code 2764878ed226SJulian Elischer * XXX Note: Some L2CAP and HCI error codes have the same value, but 2765878ed226SJulian Elischer * different meaning 2766878ed226SJulian Elischer */ 2767878ed226SJulian Elischer 2768878ed226SJulian Elischer static int 2769878ed226SJulian Elischer ng_btsocket_l2cap_result2errno(int result) 2770878ed226SJulian Elischer { 2771878ed226SJulian Elischer switch (result) { 2772878ed226SJulian Elischer case 0x00: /* No error */ 2773878ed226SJulian Elischer return (0); 2774878ed226SJulian Elischer 2775878ed226SJulian Elischer case 0x01: /* Unknown HCI command */ 2776878ed226SJulian Elischer return (ENODEV); 2777878ed226SJulian Elischer 2778878ed226SJulian Elischer case 0x02: /* No connection */ 2779878ed226SJulian Elischer return (ENOTCONN); 2780878ed226SJulian Elischer 2781878ed226SJulian Elischer case 0x03: /* Hardware failure */ 2782878ed226SJulian Elischer return (EIO); 2783878ed226SJulian Elischer 2784878ed226SJulian Elischer case 0x04: /* Page timeout */ 2785878ed226SJulian Elischer return (EHOSTDOWN); 2786878ed226SJulian Elischer 2787878ed226SJulian Elischer case 0x05: /* Authentication failure */ 2788878ed226SJulian Elischer case 0x06: /* Key missing */ 2789878ed226SJulian Elischer case 0x18: /* Pairing not allowed */ 2790878ed226SJulian Elischer case 0x21: /* Role change not allowed */ 2791878ed226SJulian Elischer case 0x24: /* LMP PSU not allowed */ 2792878ed226SJulian Elischer case 0x25: /* Encryption mode not acceptable */ 2793878ed226SJulian Elischer case 0x26: /* Unit key used */ 2794878ed226SJulian Elischer return (EACCES); 2795878ed226SJulian Elischer 2796878ed226SJulian Elischer case 0x07: /* Memory full */ 2797878ed226SJulian Elischer return (ENOMEM); 2798878ed226SJulian Elischer 2799878ed226SJulian Elischer case 0x08: /* Connection timeout */ 2800878ed226SJulian Elischer case 0x10: /* Host timeout */ 2801878ed226SJulian Elischer case 0x22: /* LMP response timeout */ 2802878ed226SJulian Elischer case 0xee: /* HCI timeout */ 2803878ed226SJulian Elischer case 0xeeee: /* L2CAP timeout */ 2804878ed226SJulian Elischer return (ETIMEDOUT); 2805878ed226SJulian Elischer 2806878ed226SJulian Elischer case 0x09: /* Max number of connections */ 2807878ed226SJulian Elischer case 0x0a: /* Max number of SCO connections to a unit */ 2808878ed226SJulian Elischer return (EMLINK); 2809878ed226SJulian Elischer 2810878ed226SJulian Elischer case 0x0b: /* ACL connection already exists */ 2811878ed226SJulian Elischer return (EEXIST); 2812878ed226SJulian Elischer 2813878ed226SJulian Elischer case 0x0c: /* Command disallowed */ 2814878ed226SJulian Elischer return (EBUSY); 2815878ed226SJulian Elischer 2816878ed226SJulian Elischer case 0x0d: /* Host rejected due to limited resources */ 2817878ed226SJulian Elischer case 0x0e: /* Host rejected due to securiity reasons */ 2818878ed226SJulian Elischer case 0x0f: /* Host rejected due to remote unit is a personal unit */ 2819878ed226SJulian Elischer case 0x1b: /* SCO offset rejected */ 2820878ed226SJulian Elischer case 0x1c: /* SCO interval rejected */ 2821878ed226SJulian Elischer case 0x1d: /* SCO air mode rejected */ 2822878ed226SJulian Elischer return (ECONNREFUSED); 2823878ed226SJulian Elischer 2824878ed226SJulian Elischer case 0x11: /* Unsupported feature or parameter value */ 2825878ed226SJulian Elischer case 0x19: /* Unknown LMP PDU */ 2826878ed226SJulian Elischer case 0x1a: /* Unsupported remote feature */ 2827878ed226SJulian Elischer case 0x20: /* Unsupported LMP parameter value */ 2828878ed226SJulian Elischer case 0x27: /* QoS is not supported */ 2829878ed226SJulian Elischer case 0x29: /* Paring with unit key not supported */ 2830878ed226SJulian Elischer return (EOPNOTSUPP); 2831878ed226SJulian Elischer 2832878ed226SJulian Elischer case 0x12: /* Invalid HCI command parameter */ 2833878ed226SJulian Elischer case 0x1e: /* Invalid LMP parameters */ 2834878ed226SJulian Elischer return (EINVAL); 2835878ed226SJulian Elischer 2836878ed226SJulian Elischer case 0x13: /* Other end terminated connection: User ended connection */ 2837878ed226SJulian Elischer case 0x14: /* Other end terminated connection: Low resources */ 2838878ed226SJulian Elischer case 0x15: /* Other end terminated connection: About to power off */ 2839878ed226SJulian Elischer return (ECONNRESET); 2840878ed226SJulian Elischer 2841878ed226SJulian Elischer case 0x16: /* Connection terminated by local host */ 2842878ed226SJulian Elischer return (ECONNABORTED); 2843878ed226SJulian Elischer 2844878ed226SJulian Elischer #if 0 /* XXX not yet */ 2845878ed226SJulian Elischer case 0x17: /* Repeated attempts */ 2846878ed226SJulian Elischer case 0x1f: /* Unspecified error */ 2847878ed226SJulian Elischer case 0x23: /* LMP error transaction collision */ 2848878ed226SJulian Elischer case 0x28: /* Instant passed */ 2849878ed226SJulian Elischer #endif 2850878ed226SJulian Elischer } 2851878ed226SJulian Elischer 2852878ed226SJulian Elischer return (ENOSYS); 2853878ed226SJulian Elischer } /* ng_btsocket_l2cap_result2errno */ 2854878ed226SJulian Elischer 2855