1878ed226SJulian Elischer /* 2878ed226SJulian Elischer * ng_btsocket_l2cap.c 3c398230bSWarner Losh */ 4c398230bSWarner Losh 5c398230bSWarner Losh /*- 6878ed226SJulian Elischer * Copyright (c) 2001-2002 Maksim Yevmenkin <m_evmenkin@yahoo.com> 7878ed226SJulian Elischer * All rights reserved. 8878ed226SJulian Elischer * 9878ed226SJulian Elischer * Redistribution and use in source and binary forms, with or without 10878ed226SJulian Elischer * modification, are permitted provided that the following conditions 11878ed226SJulian Elischer * are met: 12878ed226SJulian Elischer * 1. Redistributions of source code must retain the above copyright 13878ed226SJulian Elischer * notice, this list of conditions and the following disclaimer. 14878ed226SJulian Elischer * 2. Redistributions in binary form must reproduce the above copyright 15878ed226SJulian Elischer * notice, this list of conditions and the following disclaimer in the 16878ed226SJulian Elischer * documentation and/or other materials provided with the distribution. 17878ed226SJulian Elischer * 18878ed226SJulian Elischer * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 19878ed226SJulian Elischer * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 20878ed226SJulian Elischer * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 21878ed226SJulian Elischer * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 22878ed226SJulian Elischer * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 23878ed226SJulian Elischer * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 24878ed226SJulian Elischer * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 25878ed226SJulian Elischer * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 26878ed226SJulian Elischer * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 27878ed226SJulian Elischer * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 28878ed226SJulian Elischer * SUCH DAMAGE. 29878ed226SJulian Elischer * 300986ab12SMaksim Yevmenkin * $Id: ng_btsocket_l2cap.c,v 1.16 2003/09/14 23:29:06 max Exp $ 31878ed226SJulian Elischer * $FreeBSD$ 32878ed226SJulian Elischer */ 33878ed226SJulian Elischer 34878ed226SJulian Elischer #include <sys/param.h> 35878ed226SJulian Elischer #include <sys/systm.h> 360986ab12SMaksim Yevmenkin #include <sys/bitstring.h> 37878ed226SJulian Elischer #include <sys/domain.h> 38878ed226SJulian Elischer #include <sys/endian.h> 39878ed226SJulian Elischer #include <sys/errno.h> 40878ed226SJulian Elischer #include <sys/filedesc.h> 41878ed226SJulian Elischer #include <sys/ioccom.h> 42878ed226SJulian Elischer #include <sys/kernel.h> 43878ed226SJulian Elischer #include <sys/lock.h> 44878ed226SJulian Elischer #include <sys/malloc.h> 45878ed226SJulian Elischer #include <sys/mbuf.h> 46878ed226SJulian Elischer #include <sys/mutex.h> 47878ed226SJulian Elischer #include <sys/protosw.h> 48878ed226SJulian Elischer #include <sys/queue.h> 49878ed226SJulian Elischer #include <sys/socket.h> 50878ed226SJulian Elischer #include <sys/socketvar.h> 51878ed226SJulian Elischer #include <sys/sysctl.h> 52878ed226SJulian Elischer #include <sys/taskqueue.h> 531fb51a12SBjoern A. Zeeb 541fb51a12SBjoern A. Zeeb #include <net/vnet.h> 551fb51a12SBjoern A. Zeeb 56878ed226SJulian Elischer #include <netgraph/ng_message.h> 57878ed226SJulian Elischer #include <netgraph/netgraph.h> 58b84b10f9SMaksim Yevmenkin #include <netgraph/bluetooth/include/ng_bluetooth.h> 59b84b10f9SMaksim Yevmenkin #include <netgraph/bluetooth/include/ng_hci.h> 60b84b10f9SMaksim Yevmenkin #include <netgraph/bluetooth/include/ng_l2cap.h> 61b84b10f9SMaksim Yevmenkin #include <netgraph/bluetooth/include/ng_btsocket.h> 62b84b10f9SMaksim Yevmenkin #include <netgraph/bluetooth/include/ng_btsocket_l2cap.h> 63878ed226SJulian Elischer 64878ed226SJulian Elischer /* MALLOC define */ 65878ed226SJulian Elischer #ifdef NG_SEPARATE_MALLOC 66d745c852SEd Schouten static MALLOC_DEFINE(M_NETGRAPH_BTSOCKET_L2CAP, "netgraph_btsocks_l2cap", 67878ed226SJulian Elischer "Netgraph Bluetooth L2CAP sockets"); 68878ed226SJulian Elischer #else 69878ed226SJulian Elischer #define M_NETGRAPH_BTSOCKET_L2CAP M_NETGRAPH 70878ed226SJulian Elischer #endif /* NG_SEPARATE_MALLOC */ 71878ed226SJulian Elischer 72878ed226SJulian Elischer /* Netgraph node methods */ 73878ed226SJulian Elischer static ng_constructor_t ng_btsocket_l2cap_node_constructor; 74878ed226SJulian Elischer static ng_rcvmsg_t ng_btsocket_l2cap_node_rcvmsg; 75878ed226SJulian Elischer static ng_shutdown_t ng_btsocket_l2cap_node_shutdown; 76878ed226SJulian Elischer static ng_newhook_t ng_btsocket_l2cap_node_newhook; 77878ed226SJulian Elischer static ng_connect_t ng_btsocket_l2cap_node_connect; 78878ed226SJulian Elischer static ng_rcvdata_t ng_btsocket_l2cap_node_rcvdata; 79878ed226SJulian Elischer static ng_disconnect_t ng_btsocket_l2cap_node_disconnect; 80878ed226SJulian Elischer 81878ed226SJulian Elischer static void ng_btsocket_l2cap_input (void *, int); 82878ed226SJulian Elischer static void ng_btsocket_l2cap_rtclean (void *, int); 83878ed226SJulian Elischer 84878ed226SJulian Elischer /* Netgraph type descriptor */ 85878ed226SJulian Elischer static struct ng_type typestruct = { 86f8aae777SJulian Elischer .version = NG_ABI_VERSION, 87f8aae777SJulian Elischer .name = NG_BTSOCKET_L2CAP_NODE_TYPE, 88f8aae777SJulian Elischer .constructor = ng_btsocket_l2cap_node_constructor, 89f8aae777SJulian Elischer .rcvmsg = ng_btsocket_l2cap_node_rcvmsg, 90f8aae777SJulian Elischer .shutdown = ng_btsocket_l2cap_node_shutdown, 91f8aae777SJulian Elischer .newhook = ng_btsocket_l2cap_node_newhook, 92f8aae777SJulian Elischer .connect = ng_btsocket_l2cap_node_connect, 93f8aae777SJulian Elischer .rcvdata = ng_btsocket_l2cap_node_rcvdata, 94f8aae777SJulian Elischer .disconnect = ng_btsocket_l2cap_node_disconnect, 95878ed226SJulian Elischer }; 96878ed226SJulian Elischer 97878ed226SJulian Elischer /* Globals */ 98878ed226SJulian Elischer extern int ifqmaxlen; 99878ed226SJulian Elischer static u_int32_t ng_btsocket_l2cap_debug_level; 100878ed226SJulian Elischer static node_p ng_btsocket_l2cap_node; 101878ed226SJulian Elischer static struct ng_bt_itemq ng_btsocket_l2cap_queue; 102878ed226SJulian Elischer static struct mtx ng_btsocket_l2cap_queue_mtx; 103878ed226SJulian Elischer static struct task ng_btsocket_l2cap_queue_task; 104878ed226SJulian Elischer static LIST_HEAD(, ng_btsocket_l2cap_pcb) ng_btsocket_l2cap_sockets; 105878ed226SJulian Elischer static struct mtx ng_btsocket_l2cap_sockets_mtx; 106878ed226SJulian Elischer static LIST_HEAD(, ng_btsocket_l2cap_rtentry) ng_btsocket_l2cap_rt; 107878ed226SJulian Elischer static struct mtx ng_btsocket_l2cap_rt_mtx; 108878ed226SJulian Elischer static struct task ng_btsocket_l2cap_rt_task; 1094fa708efSMaksim Yevmenkin static struct timeval ng_btsocket_l2cap_lasttime; 1104fa708efSMaksim Yevmenkin static int ng_btsocket_l2cap_curpps; 111878ed226SJulian Elischer 112878ed226SJulian Elischer /* Sysctl tree */ 113878ed226SJulian Elischer SYSCTL_DECL(_net_bluetooth_l2cap_sockets); 1146472ac3dSEd Schouten static SYSCTL_NODE(_net_bluetooth_l2cap_sockets, OID_AUTO, seq, CTLFLAG_RW, 115878ed226SJulian Elischer 0, "Bluetooth SEQPACKET L2CAP sockets family"); 116f29fc085SMatthew D Fleming SYSCTL_UINT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, debug_level, 117878ed226SJulian Elischer CTLFLAG_RW, 118878ed226SJulian Elischer &ng_btsocket_l2cap_debug_level, NG_BTSOCKET_WARN_LEVEL, 119878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets debug level"); 120f29fc085SMatthew D Fleming SYSCTL_UINT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_len, 121878ed226SJulian Elischer CTLFLAG_RD, 122878ed226SJulian Elischer &ng_btsocket_l2cap_queue.len, 0, 123878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets input queue length"); 124f29fc085SMatthew D Fleming SYSCTL_UINT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_maxlen, 125878ed226SJulian Elischer CTLFLAG_RD, 126878ed226SJulian Elischer &ng_btsocket_l2cap_queue.maxlen, 0, 127878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets input queue max. length"); 128f29fc085SMatthew D Fleming SYSCTL_UINT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_drops, 129878ed226SJulian Elischer CTLFLAG_RD, 130878ed226SJulian Elischer &ng_btsocket_l2cap_queue.drops, 0, 131878ed226SJulian Elischer "Bluetooth SEQPACKET L2CAP sockets input queue drops"); 132878ed226SJulian Elischer 133878ed226SJulian Elischer /* Debug */ 134878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_INFO \ 1354fa708efSMaksim Yevmenkin if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_INFO_LEVEL && \ 1364fa708efSMaksim Yevmenkin ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 137878ed226SJulian Elischer printf 138878ed226SJulian Elischer 139878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_WARN \ 1404fa708efSMaksim Yevmenkin if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_WARN_LEVEL && \ 1414fa708efSMaksim Yevmenkin ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 142878ed226SJulian Elischer printf 143878ed226SJulian Elischer 144878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_ERR \ 1454fa708efSMaksim Yevmenkin if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ERR_LEVEL && \ 1464fa708efSMaksim Yevmenkin ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 147878ed226SJulian Elischer printf 148878ed226SJulian Elischer 149878ed226SJulian Elischer #define NG_BTSOCKET_L2CAP_ALERT \ 1504fa708efSMaksim Yevmenkin if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ALERT_LEVEL && \ 1514fa708efSMaksim Yevmenkin ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 152878ed226SJulian Elischer printf 153878ed226SJulian Elischer 154878ed226SJulian Elischer /* 155878ed226SJulian Elischer * Netgraph message processing routines 156878ed226SJulian Elischer */ 157878ed226SJulian Elischer 158878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_con_req_rsp 1597c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 160878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_con_rsp_rsp 1617c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 162878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_con_ind 1637c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 164878ed226SJulian Elischer 165878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_cfg_req_rsp 1667c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 167878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp 1687c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 169878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_cfg_ind 1707c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 171878ed226SJulian Elischer 172878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_discon_rsp 1737c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 174878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_discon_ind 1757c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 176878ed226SJulian Elischer 177878ed226SJulian Elischer static int ng_btsocket_l2cap_process_l2ca_write_rsp 1787c380856SMaksim Yevmenkin (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 179878ed226SJulian Elischer 180878ed226SJulian Elischer /* 181878ed226SJulian Elischer * Send L2CA_xxx messages to the lower layer 182878ed226SJulian Elischer */ 183878ed226SJulian Elischer 184878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_con_req 185878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 186878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_con_rsp_req 187fbc48c2bSTakanori Watanabe (u_int32_t, ng_btsocket_l2cap_rtentry_p, bdaddr_p, int, int, int, int); 188878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_cfg_req 189878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 190878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_cfg_rsp 191878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 192878ed226SJulian Elischer static int ng_btsocket_l2cap_send_l2ca_discon_req 193878ed226SJulian Elischer (u_int32_t, ng_btsocket_l2cap_pcb_p); 194878ed226SJulian Elischer 195878ed226SJulian Elischer static int ng_btsocket_l2cap_send2 196878ed226SJulian Elischer (ng_btsocket_l2cap_pcb_p); 197878ed226SJulian Elischer 198878ed226SJulian Elischer /* 199878ed226SJulian Elischer * Timeout processing routines 200878ed226SJulian Elischer */ 201878ed226SJulian Elischer 202878ed226SJulian Elischer static void ng_btsocket_l2cap_timeout (ng_btsocket_l2cap_pcb_p); 203878ed226SJulian Elischer static void ng_btsocket_l2cap_untimeout (ng_btsocket_l2cap_pcb_p); 204878ed226SJulian Elischer static void ng_btsocket_l2cap_process_timeout (void *); 205878ed226SJulian Elischer 206878ed226SJulian Elischer /* 207878ed226SJulian Elischer * Other stuff 208878ed226SJulian Elischer */ 209878ed226SJulian Elischer 210878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_addr(bdaddr_p, int); 211878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_token(u_int32_t); 212fbc48c2bSTakanori Watanabe static ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_cid (bdaddr_p, int,int); 213878ed226SJulian Elischer static int ng_btsocket_l2cap_result2errno(int); 214878ed226SJulian Elischer 215fbc48c2bSTakanori Watanabe static int ng_btsock_l2cap_addrtype_to_linktype(int addrtype); 2163a601a23STakanori Watanabe 217f2bb1caeSJulian Elischer #define ng_btsocket_l2cap_wakeup_input_task() \ 218f2bb1caeSJulian Elischer taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_queue_task) 219f2bb1caeSJulian Elischer 220f2bb1caeSJulian Elischer #define ng_btsocket_l2cap_wakeup_route_task() \ 221f2bb1caeSJulian Elischer taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_rt_task) 222f2bb1caeSJulian Elischer 223fbc48c2bSTakanori Watanabe 224fbc48c2bSTakanori Watanabe 225fbc48c2bSTakanori Watanabe int ng_btsock_l2cap_addrtype_to_linktype(int addrtype) 226fbc48c2bSTakanori Watanabe { 227fbc48c2bSTakanori Watanabe switch(addrtype){ 228fbc48c2bSTakanori Watanabe case BDADDR_LE_PUBLIC: 229fbc48c2bSTakanori Watanabe return NG_HCI_LINK_LE_PUBLIC; 230fbc48c2bSTakanori Watanabe case BDADDR_LE_RANDOM: 231fbc48c2bSTakanori Watanabe return NG_HCI_LINK_LE_RANDOM; 232fbc48c2bSTakanori Watanabe default: 233fbc48c2bSTakanori Watanabe return NG_HCI_LINK_ACL; 234fbc48c2bSTakanori Watanabe } 235fbc48c2bSTakanori Watanabe } 236fbc48c2bSTakanori Watanabe 237fbc48c2bSTakanori Watanabe 238878ed226SJulian Elischer /***************************************************************************** 239878ed226SJulian Elischer ***************************************************************************** 240878ed226SJulian Elischer ** Netgraph node interface 241878ed226SJulian Elischer ***************************************************************************** 242878ed226SJulian Elischer *****************************************************************************/ 243878ed226SJulian Elischer 244878ed226SJulian Elischer /* 245878ed226SJulian Elischer * Netgraph node constructor. Do not allow to create node of this type. 246878ed226SJulian Elischer */ 247878ed226SJulian Elischer 248878ed226SJulian Elischer static int 249878ed226SJulian Elischer ng_btsocket_l2cap_node_constructor(node_p node) 250878ed226SJulian Elischer { 251878ed226SJulian Elischer return (EINVAL); 252878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_constructor */ 253878ed226SJulian Elischer 254878ed226SJulian Elischer /* 255878ed226SJulian Elischer * Do local shutdown processing. Let old node go and create new fresh one. 256878ed226SJulian Elischer */ 257878ed226SJulian Elischer 258878ed226SJulian Elischer static int 259878ed226SJulian Elischer ng_btsocket_l2cap_node_shutdown(node_p node) 260878ed226SJulian Elischer { 261878ed226SJulian Elischer int error = 0; 262878ed226SJulian Elischer 263878ed226SJulian Elischer NG_NODE_UNREF(node); 264878ed226SJulian Elischer 265878ed226SJulian Elischer /* Create new node */ 266878ed226SJulian Elischer error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 267878ed226SJulian Elischer if (error != 0) { 268878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 269878ed226SJulian Elischer "%s: Could not create Netgraph node, error=%d\n", __func__, error); 270878ed226SJulian Elischer 271878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 272878ed226SJulian Elischer 273878ed226SJulian Elischer return (error); 274878ed226SJulian Elischer } 275878ed226SJulian Elischer 276878ed226SJulian Elischer error = ng_name_node(ng_btsocket_l2cap_node, 277878ed226SJulian Elischer NG_BTSOCKET_L2CAP_NODE_TYPE); 278b9fe2d6cSAlfred Perlstein if (error != 0) { 279878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 280878ed226SJulian Elischer "%s: Could not name Netgraph node, error=%d\n", __func__, error); 281878ed226SJulian Elischer 282878ed226SJulian Elischer NG_NODE_UNREF(ng_btsocket_l2cap_node); 283878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 284878ed226SJulian Elischer 285878ed226SJulian Elischer return (error); 286878ed226SJulian Elischer } 287878ed226SJulian Elischer 288878ed226SJulian Elischer return (0); 289878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_shutdown */ 290878ed226SJulian Elischer 291878ed226SJulian Elischer /* 292878ed226SJulian Elischer * We allow any hook to be connected to the node. 293878ed226SJulian Elischer */ 294878ed226SJulian Elischer 295878ed226SJulian Elischer static int 296878ed226SJulian Elischer ng_btsocket_l2cap_node_newhook(node_p node, hook_p hook, char const *name) 297878ed226SJulian Elischer { 298878ed226SJulian Elischer return (0); 299878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_newhook */ 300878ed226SJulian Elischer 301878ed226SJulian Elischer /* 302878ed226SJulian Elischer * Just say "YEP, that's OK by me!" 303878ed226SJulian Elischer */ 304878ed226SJulian Elischer 305878ed226SJulian Elischer static int 306878ed226SJulian Elischer ng_btsocket_l2cap_node_connect(hook_p hook) 307878ed226SJulian Elischer { 308878ed226SJulian Elischer NG_HOOK_SET_PRIVATE(hook, NULL); 309878ed226SJulian Elischer NG_HOOK_REF(hook); /* Keep extra reference to the hook */ 310878ed226SJulian Elischer 311878ed226SJulian Elischer #if 0 312878ed226SJulian Elischer NG_HOOK_FORCE_QUEUE(NG_HOOK_PEER(hook)); 313878ed226SJulian Elischer NG_HOOK_FORCE_QUEUE(hook); 314878ed226SJulian Elischer #endif 315878ed226SJulian Elischer 316878ed226SJulian Elischer return (0); 317878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_connect */ 318878ed226SJulian Elischer 319878ed226SJulian Elischer /* 320878ed226SJulian Elischer * Hook disconnection. Schedule route cleanup task 321878ed226SJulian Elischer */ 322878ed226SJulian Elischer 323878ed226SJulian Elischer static int 324878ed226SJulian Elischer ng_btsocket_l2cap_node_disconnect(hook_p hook) 325878ed226SJulian Elischer { 326878ed226SJulian Elischer /* 327878ed226SJulian Elischer * If hook has private information than we must have this hook in 328878ed226SJulian Elischer * the routing table and must schedule cleaning for the routing table. 329878ed226SJulian Elischer * Otherwise hook was connected but we never got "hook_info" message, 330878ed226SJulian Elischer * so we have never added this hook to the routing table and it save 331878ed226SJulian Elischer * to just delete it. 332878ed226SJulian Elischer */ 333878ed226SJulian Elischer 334878ed226SJulian Elischer if (NG_HOOK_PRIVATE(hook) != NULL) 335f2bb1caeSJulian Elischer return (ng_btsocket_l2cap_wakeup_route_task()); 336878ed226SJulian Elischer 337878ed226SJulian Elischer NG_HOOK_UNREF(hook); /* Remove extra reference */ 338878ed226SJulian Elischer 339878ed226SJulian Elischer return (0); 340878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_disconnect */ 341878ed226SJulian Elischer 342878ed226SJulian Elischer /* 343878ed226SJulian Elischer * Process incoming messages 344878ed226SJulian Elischer */ 345878ed226SJulian Elischer 346878ed226SJulian Elischer static int 347878ed226SJulian Elischer ng_btsocket_l2cap_node_rcvmsg(node_p node, item_p item, hook_p hook) 348878ed226SJulian Elischer { 349878ed226SJulian Elischer struct ng_mesg *msg = NGI_MSG(item); /* item still has message */ 350878ed226SJulian Elischer int error = 0; 351878ed226SJulian Elischer 352878ed226SJulian Elischer if (msg != NULL && msg->header.typecookie == NGM_L2CAP_COOKIE) { 353878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_queue_mtx); 354878ed226SJulian Elischer if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 355878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 356878ed226SJulian Elischer "%s: Input queue is full (msg)\n", __func__); 357878ed226SJulian Elischer 358878ed226SJulian Elischer NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 359878ed226SJulian Elischer NG_FREE_ITEM(item); 360878ed226SJulian Elischer error = ENOBUFS; 361878ed226SJulian Elischer } else { 362878ed226SJulian Elischer if (hook != NULL) { 363878ed226SJulian Elischer NG_HOOK_REF(hook); 364878ed226SJulian Elischer NGI_SET_HOOK(item, hook); 365878ed226SJulian Elischer } 366878ed226SJulian Elischer 367878ed226SJulian Elischer NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 368f2bb1caeSJulian Elischer error = ng_btsocket_l2cap_wakeup_input_task(); 369878ed226SJulian Elischer } 370878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 371878ed226SJulian Elischer } else { 372878ed226SJulian Elischer NG_FREE_ITEM(item); 373878ed226SJulian Elischer error = EINVAL; 374878ed226SJulian Elischer } 375878ed226SJulian Elischer 376878ed226SJulian Elischer return (error); 377878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_rcvmsg */ 378878ed226SJulian Elischer 379878ed226SJulian Elischer /* 380878ed226SJulian Elischer * Receive data on a hook 381878ed226SJulian Elischer */ 382878ed226SJulian Elischer 383878ed226SJulian Elischer static int 384878ed226SJulian Elischer ng_btsocket_l2cap_node_rcvdata(hook_p hook, item_p item) 385878ed226SJulian Elischer { 386878ed226SJulian Elischer int error = 0; 387878ed226SJulian Elischer 388878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_queue_mtx); 389878ed226SJulian Elischer if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 390878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 391878ed226SJulian Elischer "%s: Input queue is full (data)\n", __func__); 392878ed226SJulian Elischer 393878ed226SJulian Elischer NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 394878ed226SJulian Elischer NG_FREE_ITEM(item); 395878ed226SJulian Elischer error = ENOBUFS; 396878ed226SJulian Elischer } else { 397878ed226SJulian Elischer NG_HOOK_REF(hook); 398878ed226SJulian Elischer NGI_SET_HOOK(item, hook); 399878ed226SJulian Elischer 400878ed226SJulian Elischer NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 401f2bb1caeSJulian Elischer error = ng_btsocket_l2cap_wakeup_input_task(); 402878ed226SJulian Elischer } 403878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 404878ed226SJulian Elischer 405878ed226SJulian Elischer return (error); 406878ed226SJulian Elischer } /* ng_btsocket_l2cap_node_rcvdata */ 407878ed226SJulian Elischer 408878ed226SJulian Elischer /* 409878ed226SJulian Elischer * Process L2CA_Connect respose. Socket layer must have initiated connection, 410878ed226SJulian Elischer * so we have to have a socket associated with message token. 411878ed226SJulian Elischer */ 412878ed226SJulian Elischer 413878ed226SJulian Elischer static int 414878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_con_req_rsp(struct ng_mesg *msg, 4157c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 416878ed226SJulian Elischer { 417878ed226SJulian Elischer ng_l2cap_l2ca_con_op *op = NULL; 418878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 419878ed226SJulian Elischer int error = 0; 420878ed226SJulian Elischer 421878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 422878ed226SJulian Elischer return (EMSGSIZE); 423878ed226SJulian Elischer 424878ed226SJulian Elischer op = (ng_l2cap_l2ca_con_op *)(msg->data); 425878ed226SJulian Elischer 426f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 427f2bb1caeSJulian Elischer 428878ed226SJulian Elischer /* Look for the socket with the token */ 429878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 430f2bb1caeSJulian Elischer if (pcb == NULL) { 431f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 432878ed226SJulian Elischer return (ENOENT); 433f2bb1caeSJulian Elischer } 434878ed226SJulian Elischer 435878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 436878ed226SJulian Elischer 437878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 438878ed226SJulian Elischer "%s: Got L2CA_Connect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 439878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, status=%d, " \ 440878ed226SJulian Elischer "state=%d\n", __func__, msg->header.token, 441878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 442878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 443878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 444878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 445878ed226SJulian Elischer pcb->psm, op->lcid, op->result, op->status, 446878ed226SJulian Elischer pcb->state); 447878ed226SJulian Elischer 448878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 449878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 450f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 451f2bb1caeSJulian Elischer 452878ed226SJulian Elischer return (ENOENT); 453878ed226SJulian Elischer } 454878ed226SJulian Elischer 455878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 456878ed226SJulian Elischer 457878ed226SJulian Elischer if (op->result == NG_L2CAP_PENDING) { 458878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 459878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 460f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 461f2bb1caeSJulian Elischer 462878ed226SJulian Elischer return (0); 463878ed226SJulian Elischer } 464878ed226SJulian Elischer 465878ed226SJulian Elischer if (op->result == NG_L2CAP_SUCCESS){ 4663a601a23STakanori Watanabe if((pcb->idtype == NG_L2CAP_L2CA_IDTYPE_ATT)|| 4673a601a23STakanori Watanabe (pcb->idtype == NG_L2CAP_L2CA_IDTYPE_SMP)){ 4683a601a23STakanori Watanabe pcb->encryption = op->encryption; pcb->cid = op->lcid; 4693a601a23STakanori Watanabe if(pcb->need_encrypt && !(pcb->encryption)){ 470483ed395STakanori Watanabe ng_btsocket_l2cap_timeout(pcb); 4713a601a23STakanori Watanabe pcb->state = NG_BTSOCKET_L2CAP_W4_ENC_CHANGE; 4723a601a23STakanori Watanabe }else{ 473fbc48c2bSTakanori Watanabe pcb->state = NG_BTSOCKET_L2CAP_OPEN; 474fbc48c2bSTakanori Watanabe soisconnected(pcb->so); 4753a601a23STakanori Watanabe } 476fbc48c2bSTakanori Watanabe }else{ 477878ed226SJulian Elischer /* 478878ed226SJulian Elischer * Channel is now open, so update local channel ID and 479878ed226SJulian Elischer * start configuration process. Source and destination 480878ed226SJulian Elischer * addresses as well as route must be already set. 481878ed226SJulian Elischer */ 482878ed226SJulian Elischer 483878ed226SJulian Elischer pcb->cid = op->lcid; 4843a601a23STakanori Watanabe pcb->encryption = op->encryption; 485878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 486878ed226SJulian Elischer if (error != 0) { 487878ed226SJulian Elischer /* Send disconnect request with "zero" token */ 488878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 489878ed226SJulian Elischer 490878ed226SJulian Elischer /* ... and close the socket */ 491878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 492878ed226SJulian Elischer soisdisconnected(pcb->so); 493878ed226SJulian Elischer } else { 494878ed226SJulian Elischer pcb->cfg_state = NG_BTSOCKET_L2CAP_CFG_IN_SENT; 495878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 496878ed226SJulian Elischer 497878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 498878ed226SJulian Elischer } 499fbc48c2bSTakanori Watanabe } 500878ed226SJulian Elischer } else { 501878ed226SJulian Elischer /* 502878ed226SJulian Elischer * We have failed to open connection, so convert result 503878ed226SJulian Elischer * code to "errno" code and disconnect the socket. Channel 504878ed226SJulian Elischer * already has been closed. 505878ed226SJulian Elischer */ 506878ed226SJulian Elischer 507878ed226SJulian Elischer pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 508878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 509878ed226SJulian Elischer soisdisconnected(pcb->so); 510878ed226SJulian Elischer } 511878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 512f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 513878ed226SJulian Elischer 514878ed226SJulian Elischer return (error); 515878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_con_req_rsp */ 516878ed226SJulian Elischer 517878ed226SJulian Elischer /* 518878ed226SJulian Elischer * Process L2CA_ConnectRsp response 519878ed226SJulian Elischer */ 520878ed226SJulian Elischer 521878ed226SJulian Elischer static int 522878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_con_rsp_rsp(struct ng_mesg *msg, 5237c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 524878ed226SJulian Elischer { 525878ed226SJulian Elischer ng_l2cap_l2ca_con_rsp_op *op = NULL; 526878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 527878ed226SJulian Elischer 528878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 529878ed226SJulian Elischer return (EMSGSIZE); 530878ed226SJulian Elischer 531878ed226SJulian Elischer op = (ng_l2cap_l2ca_con_rsp_op *)(msg->data); 532878ed226SJulian Elischer 533f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 534f2bb1caeSJulian Elischer 535878ed226SJulian Elischer /* Look for the socket with the token */ 536878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 537f2bb1caeSJulian Elischer if (pcb == NULL) { 538f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 539878ed226SJulian Elischer return (ENOENT); 540f2bb1caeSJulian Elischer } 541878ed226SJulian Elischer 542878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 543878ed226SJulian Elischer 544878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 545878ed226SJulian Elischer "%s: Got L2CA_ConnectRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 546878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 547878ed226SJulian Elischer __func__, msg->header.token, 548878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 549878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 550878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 551878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 552878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state); 553878ed226SJulian Elischer 554878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 555878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 556f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 557f2bb1caeSJulian Elischer 558878ed226SJulian Elischer return (ENOENT); 559878ed226SJulian Elischer } 560878ed226SJulian Elischer 561878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 562878ed226SJulian Elischer 563878ed226SJulian Elischer /* Check the result and disconnect the socket on failure */ 564878ed226SJulian Elischer if (op->result != NG_L2CAP_SUCCESS) { 565878ed226SJulian Elischer /* Close the socket - channel already closed */ 566878ed226SJulian Elischer pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 567878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 568878ed226SJulian Elischer soisdisconnected(pcb->so); 569878ed226SJulian Elischer } else { 570878ed226SJulian Elischer /* Move to CONFIGURING state and wait for CONFIG_IND */ 571878ed226SJulian Elischer pcb->cfg_state = 0; 572878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 573878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 574878ed226SJulian Elischer } 575878ed226SJulian Elischer 576878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 577f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 578878ed226SJulian Elischer 579878ed226SJulian Elischer return (0); 580878ed226SJulian Elischer } /* ng_btsocket_process_l2ca_con_rsp_rsp */ 581878ed226SJulian Elischer 582878ed226SJulian Elischer /* 583878ed226SJulian Elischer * Process L2CA_Connect indicator. Find socket that listens on address 584878ed226SJulian Elischer * and PSM. Find exact or closest match. Create new socket and initiate 585878ed226SJulian Elischer * connection. 586878ed226SJulian Elischer */ 587878ed226SJulian Elischer 588878ed226SJulian Elischer static int 589878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_con_ind(struct ng_mesg *msg, 5907c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 591878ed226SJulian Elischer { 592878ed226SJulian Elischer ng_l2cap_l2ca_con_ind_ip *ip = NULL; 593878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL, *pcb1 = NULL; 594878ed226SJulian Elischer int error = 0; 595878ed226SJulian Elischer u_int32_t token = 0; 596878ed226SJulian Elischer u_int16_t result = 0; 597878ed226SJulian Elischer 598878ed226SJulian Elischer if (msg->header.arglen != sizeof(*ip)) 599878ed226SJulian Elischer return (EMSGSIZE); 600878ed226SJulian Elischer 601878ed226SJulian Elischer ip = (ng_l2cap_l2ca_con_ind_ip *)(msg->data); 602878ed226SJulian Elischer 603878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 604878ed226SJulian Elischer "%s: Got L2CA_Connect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 605878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, ident=%d\n", 606878ed226SJulian Elischer __func__, 607878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 608878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 609878ed226SJulian Elischer ip->bdaddr.b[5], ip->bdaddr.b[4], ip->bdaddr.b[3], 610878ed226SJulian Elischer ip->bdaddr.b[2], ip->bdaddr.b[1], ip->bdaddr.b[0], 611878ed226SJulian Elischer ip->psm, ip->lcid, ip->ident); 612878ed226SJulian Elischer 613f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 614f2bb1caeSJulian Elischer 615878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_addr(&rt->src, ip->psm); 616878ed226SJulian Elischer if (pcb != NULL) { 617779f106aSGleb Smirnoff struct socket *so1; 618878ed226SJulian Elischer 619878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 620878ed226SJulian Elischer 6211fb51a12SBjoern A. Zeeb CURVNET_SET(pcb->so->so_vnet); 622878ed226SJulian Elischer so1 = sonewconn(pcb->so, 0); 6231fb51a12SBjoern A. Zeeb CURVNET_RESTORE(); 624878ed226SJulian Elischer if (so1 == NULL) { 625878ed226SJulian Elischer result = NG_L2CAP_NO_RESOURCES; 626878ed226SJulian Elischer goto respond; 627878ed226SJulian Elischer } 628878ed226SJulian Elischer 629878ed226SJulian Elischer /* 630878ed226SJulian Elischer * If we got here than we have created new socket. So complete 631878ed226SJulian Elischer * connection. If we we listening on specific address then copy 632878ed226SJulian Elischer * source address from listening socket, otherwise copy source 633878ed226SJulian Elischer * address from hook's routing information. 634878ed226SJulian Elischer */ 635878ed226SJulian Elischer 636878ed226SJulian Elischer pcb1 = so2l2cap_pcb(so1); 637878ed226SJulian Elischer KASSERT((pcb1 != NULL), 638878ed226SJulian Elischer ("%s: pcb1 == NULL\n", __func__)); 639878ed226SJulian Elischer 640878ed226SJulian Elischer mtx_lock(&pcb1->pcb_mtx); 641878ed226SJulian Elischer 642878ed226SJulian Elischer if (bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)) != 0) 643878ed226SJulian Elischer bcopy(&pcb->src, &pcb1->src, sizeof(pcb1->src)); 644878ed226SJulian Elischer else 645878ed226SJulian Elischer bcopy(&rt->src, &pcb1->src, sizeof(pcb1->src)); 646878ed226SJulian Elischer 647878ed226SJulian Elischer pcb1->flags &= ~NG_BTSOCKET_L2CAP_CLIENT; 648878ed226SJulian Elischer 649878ed226SJulian Elischer bcopy(&ip->bdaddr, &pcb1->dst, sizeof(pcb1->dst)); 650878ed226SJulian Elischer pcb1->psm = ip->psm; 651878ed226SJulian Elischer pcb1->cid = ip->lcid; 652878ed226SJulian Elischer pcb1->rt = rt; 653878ed226SJulian Elischer 654878ed226SJulian Elischer /* Copy socket settings */ 655878ed226SJulian Elischer pcb1->imtu = pcb->imtu; 656878ed226SJulian Elischer bcopy(&pcb->oflow, &pcb1->oflow, sizeof(pcb1->oflow)); 657878ed226SJulian Elischer pcb1->flush_timo = pcb->flush_timo; 658878ed226SJulian Elischer 659878ed226SJulian Elischer token = pcb1->token; 660878ed226SJulian Elischer } else 661878ed226SJulian Elischer /* Nobody listens on requested BDADDR/PSM */ 662878ed226SJulian Elischer result = NG_L2CAP_PSM_NOT_SUPPORTED; 663878ed226SJulian Elischer 664878ed226SJulian Elischer respond: 665878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_con_rsp_req(token, rt, 666fbc48c2bSTakanori Watanabe &ip->bdaddr, 667fbc48c2bSTakanori Watanabe ip->ident, ip->lcid, 668fbc48c2bSTakanori Watanabe result,ip->linktype); 669878ed226SJulian Elischer if (pcb1 != NULL) { 670878ed226SJulian Elischer if (error != 0) { 671878ed226SJulian Elischer pcb1->so->so_error = error; 672878ed226SJulian Elischer pcb1->state = NG_BTSOCKET_L2CAP_CLOSED; 673878ed226SJulian Elischer soisdisconnected(pcb1->so); 674878ed226SJulian Elischer } else { 675878ed226SJulian Elischer pcb1->state = NG_BTSOCKET_L2CAP_CONNECTING; 676878ed226SJulian Elischer soisconnecting(pcb1->so); 677878ed226SJulian Elischer 678878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb1); 679878ed226SJulian Elischer } 680878ed226SJulian Elischer 681878ed226SJulian Elischer mtx_unlock(&pcb1->pcb_mtx); 682878ed226SJulian Elischer } 683878ed226SJulian Elischer 684878ed226SJulian Elischer if (pcb != NULL) 685878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 686878ed226SJulian Elischer 687f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 688f2bb1caeSJulian Elischer 689878ed226SJulian Elischer return (error); 690878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_con_ind */ 6913a601a23STakanori Watanabe /*Encryption Change*/ 6923a601a23STakanori Watanabe static int ng_btsocket_l2cap_process_l2ca_enc_change(struct ng_mesg *msg, ng_btsocket_l2cap_rtentry_p rt) 6933a601a23STakanori Watanabe { 6943a601a23STakanori Watanabe ng_l2cap_l2ca_enc_chg_op *op = NULL; 6953a601a23STakanori Watanabe ng_btsocket_l2cap_pcb_t *pcb = NULL; 696878ed226SJulian Elischer 6973a601a23STakanori Watanabe 6983a601a23STakanori Watanabe if (msg->header.arglen != sizeof(*op)) 6993a601a23STakanori Watanabe return (EMSGSIZE); 7003a601a23STakanori Watanabe 7013a601a23STakanori Watanabe op = (ng_l2cap_l2ca_enc_chg_op *)(msg->data); 7023a601a23STakanori Watanabe 70374cc817dSMaksim Yevmenkin mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 70474cc817dSMaksim Yevmenkin 7053a601a23STakanori Watanabe pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, op->lcid, 7063a601a23STakanori Watanabe op->idtype); 70774cc817dSMaksim Yevmenkin if (pcb == NULL) { 70874cc817dSMaksim Yevmenkin mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 70974cc817dSMaksim Yevmenkin return (ENOENT); 71074cc817dSMaksim Yevmenkin } 71174cc817dSMaksim Yevmenkin 7123a601a23STakanori Watanabe mtx_lock(&pcb->pcb_mtx); 7133a601a23STakanori Watanabe pcb->encryption = op->result; 7143a601a23STakanori Watanabe 7153a601a23STakanori Watanabe if(pcb->need_encrypt){ 716483ed395STakanori Watanabe ng_btsocket_l2cap_untimeout(pcb); 7173a601a23STakanori Watanabe if(pcb->state != NG_BTSOCKET_L2CAP_W4_ENC_CHANGE){ 7183a601a23STakanori Watanabe NG_BTSOCKET_L2CAP_WARN("%s: Invalid pcb status %d", 7193a601a23STakanori Watanabe __func__, pcb->state); 7203a601a23STakanori Watanabe }else if(pcb->encryption){ 7213a601a23STakanori Watanabe pcb->state = NG_BTSOCKET_L2CAP_OPEN; 7223a601a23STakanori Watanabe soisconnected(pcb->so); 7233a601a23STakanori Watanabe }else{ 7243a601a23STakanori Watanabe pcb->so->so_error = EPERM; 725483ed395STakanori Watanabe ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 7263a601a23STakanori Watanabe pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 7273a601a23STakanori Watanabe soisdisconnected(pcb->so); 7283a601a23STakanori Watanabe } 7293a601a23STakanori Watanabe } 7303a601a23STakanori Watanabe mtx_unlock(&pcb->pcb_mtx); 73174cc817dSMaksim Yevmenkin mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 7323a601a23STakanori Watanabe 7333a601a23STakanori Watanabe return 0; 7343a601a23STakanori Watanabe } 735878ed226SJulian Elischer /* 736878ed226SJulian Elischer * Process L2CA_Config response 737878ed226SJulian Elischer */ 738878ed226SJulian Elischer 739878ed226SJulian Elischer static int 740878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_req_rsp(struct ng_mesg *msg, 7417c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 742878ed226SJulian Elischer { 743878ed226SJulian Elischer ng_l2cap_l2ca_cfg_op *op = NULL; 744878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = NULL; 745878ed226SJulian Elischer 746878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 747878ed226SJulian Elischer return (EMSGSIZE); 748878ed226SJulian Elischer 749878ed226SJulian Elischer op = (ng_l2cap_l2ca_cfg_op *)(msg->data); 750878ed226SJulian Elischer 751f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 752f2bb1caeSJulian Elischer 753878ed226SJulian Elischer /* 754878ed226SJulian Elischer * Socket must have issued a Configure request, so we must have a 755878ed226SJulian Elischer * socket that wants to be configured. Use Netgraph message token 756878ed226SJulian Elischer * to find it 757878ed226SJulian Elischer */ 758878ed226SJulian Elischer 759878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 760878ed226SJulian Elischer if (pcb == NULL) { 761878ed226SJulian Elischer /* 762878ed226SJulian Elischer * XXX FIXME what to do here? We could not find a 763878ed226SJulian Elischer * socket with requested token. We even can not send 764878ed226SJulian Elischer * Disconnect, because we do not know channel ID 765878ed226SJulian Elischer */ 766878ed226SJulian Elischer 767f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 768878ed226SJulian Elischer return (ENOENT); 769878ed226SJulian Elischer } 770878ed226SJulian Elischer 771878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 772878ed226SJulian Elischer 773878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 774878ed226SJulian Elischer "%s: Got L2CA_Config response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 775878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 776878ed226SJulian Elischer "cfg_state=%x\n", 777878ed226SJulian Elischer __func__, msg->header.token, 778878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 779878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 780878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 781878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 782878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 783878ed226SJulian Elischer 784878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 785878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 786f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 787f2bb1caeSJulian Elischer 788878ed226SJulian Elischer return (ENOENT); 789878ed226SJulian Elischer } 790878ed226SJulian Elischer 791878ed226SJulian Elischer if (op->result == NG_L2CAP_SUCCESS) { 792878ed226SJulian Elischer /* 793878ed226SJulian Elischer * XXX FIXME Actually set flush and link timeout. 794878ed226SJulian Elischer * Set QoS here if required. Resolve conficts (flush_timo). 795878ed226SJulian Elischer * Save incoming MTU (peer's outgoing MTU) and outgoing flow 796878ed226SJulian Elischer * spec. 797878ed226SJulian Elischer */ 798878ed226SJulian Elischer 799878ed226SJulian Elischer pcb->imtu = op->imtu; 800878ed226SJulian Elischer bcopy(&op->oflow, &pcb->oflow, sizeof(pcb->oflow)); 801878ed226SJulian Elischer pcb->flush_timo = op->flush_timo; 802878ed226SJulian Elischer 803878ed226SJulian Elischer /* 804878ed226SJulian Elischer * We have configured incoming side, so record it and check 805878ed226SJulian Elischer * if configuration is complete. If complete then mark socket 806878ed226SJulian Elischer * as connected, otherwise wait for the peer. 807878ed226SJulian Elischer */ 808878ed226SJulian Elischer 809878ed226SJulian Elischer pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_IN_SENT; 810878ed226SJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN; 811878ed226SJulian Elischer 812878ed226SJulian Elischer if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 813878ed226SJulian Elischer /* Configuration complete - mark socket as open */ 814878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 815878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_OPEN; 816878ed226SJulian Elischer soisconnected(pcb->so); 817878ed226SJulian Elischer } 818878ed226SJulian Elischer } else { 819878ed226SJulian Elischer /* 820878ed226SJulian Elischer * Something went wrong. Could be unacceptable parameters, 821878ed226SJulian Elischer * reject or unknown option. That's too bad, but we will 822878ed226SJulian Elischer * not negotiate. Send Disconnect and close the channel. 823878ed226SJulian Elischer */ 824878ed226SJulian Elischer 825878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 826878ed226SJulian Elischer 827878ed226SJulian Elischer switch (op->result) { 828878ed226SJulian Elischer case NG_L2CAP_UNACCEPTABLE_PARAMS: 829878ed226SJulian Elischer case NG_L2CAP_UNKNOWN_OPTION: 830878ed226SJulian Elischer pcb->so->so_error = EINVAL; 831878ed226SJulian Elischer break; 832878ed226SJulian Elischer 833878ed226SJulian Elischer default: 834878ed226SJulian Elischer pcb->so->so_error = ECONNRESET; 835878ed226SJulian Elischer break; 836878ed226SJulian Elischer } 837878ed226SJulian Elischer 838878ed226SJulian Elischer /* Send disconnect with "zero" token */ 839878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 840878ed226SJulian Elischer 841878ed226SJulian Elischer /* ... and close the socket */ 842878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 843878ed226SJulian Elischer soisdisconnected(pcb->so); 844878ed226SJulian Elischer } 845878ed226SJulian Elischer 846878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 847f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 848878ed226SJulian Elischer 849878ed226SJulian Elischer return (0); 850878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_cfg_req_rsp */ 851878ed226SJulian Elischer 852878ed226SJulian Elischer /* 853878ed226SJulian Elischer * Process L2CA_ConfigRsp response 854878ed226SJulian Elischer */ 855878ed226SJulian Elischer 856878ed226SJulian Elischer static int 857878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(struct ng_mesg *msg, 8587c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 859878ed226SJulian Elischer { 860878ed226SJulian Elischer ng_l2cap_l2ca_cfg_rsp_op *op = NULL; 861878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 862878ed226SJulian Elischer int error = 0; 863878ed226SJulian Elischer 864878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 865878ed226SJulian Elischer return (EMSGSIZE); 866878ed226SJulian Elischer 867878ed226SJulian Elischer op = (ng_l2cap_l2ca_cfg_rsp_op *)(msg->data); 868878ed226SJulian Elischer 869f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 870f2bb1caeSJulian Elischer 871878ed226SJulian Elischer /* Look for the socket with the token */ 872878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 873f2bb1caeSJulian Elischer if (pcb == NULL) { 874f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 875878ed226SJulian Elischer return (ENOENT); 876f2bb1caeSJulian Elischer } 877878ed226SJulian Elischer 878878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 879878ed226SJulian Elischer 880878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 881878ed226SJulian Elischer "%s: Got L2CA_ConfigRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 882878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 883878ed226SJulian Elischer "cfg_state=%x\n", 884878ed226SJulian Elischer __func__, msg->header.token, 885878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 886878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 887878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 888878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 889878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 890878ed226SJulian Elischer 891878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 892878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 893f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 894f2bb1caeSJulian Elischer 895878ed226SJulian Elischer return (ENOENT); 896878ed226SJulian Elischer } 897878ed226SJulian Elischer 898878ed226SJulian Elischer /* Check the result and disconnect socket of failure */ 899878ed226SJulian Elischer if (op->result != NG_L2CAP_SUCCESS) 900878ed226SJulian Elischer goto disconnect; 901878ed226SJulian Elischer 902878ed226SJulian Elischer /* 903878ed226SJulian Elischer * Now we done with remote side configuration. Configure local 904878ed226SJulian Elischer * side if we have not done it yet. 905878ed226SJulian Elischer */ 906878ed226SJulian Elischer 907878ed226SJulian Elischer pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 908878ed226SJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT; 909878ed226SJulian Elischer 910878ed226SJulian Elischer if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 911878ed226SJulian Elischer /* Configuration complete - mask socket as open */ 912878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 913878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_OPEN; 914878ed226SJulian Elischer soisconnected(pcb->so); 915878ed226SJulian Elischer } else { 916878ed226SJulian Elischer if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_IN_SENT)) { 917878ed226SJulian Elischer /* Send L2CA_Config request - incoming path */ 918878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 919878ed226SJulian Elischer if (error != 0) 920878ed226SJulian Elischer goto disconnect; 921878ed226SJulian Elischer 922878ed226SJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN_SENT; 923878ed226SJulian Elischer } 924878ed226SJulian Elischer } 925878ed226SJulian Elischer 926878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 927f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 928878ed226SJulian Elischer 929878ed226SJulian Elischer return (error); 930878ed226SJulian Elischer 931878ed226SJulian Elischer disconnect: 932878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 933878ed226SJulian Elischer 934878ed226SJulian Elischer /* Send disconnect with "zero" token */ 935878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 936878ed226SJulian Elischer 937878ed226SJulian Elischer /* ... and close the socket */ 938878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 939878ed226SJulian Elischer soisdisconnected(pcb->so); 940878ed226SJulian Elischer 941878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 942f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 943878ed226SJulian Elischer 944878ed226SJulian Elischer return (error); 945878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp */ 946878ed226SJulian Elischer 947878ed226SJulian Elischer /* 948878ed226SJulian Elischer * Process L2CA_Config indicator 949878ed226SJulian Elischer */ 950878ed226SJulian Elischer 951878ed226SJulian Elischer static int 952878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_cfg_ind(struct ng_mesg *msg, 9537c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 954878ed226SJulian Elischer { 955878ed226SJulian Elischer ng_l2cap_l2ca_cfg_ind_ip *ip = NULL; 956878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 957878ed226SJulian Elischer int error = 0; 958878ed226SJulian Elischer 959878ed226SJulian Elischer if (msg->header.arglen != sizeof(*ip)) 960878ed226SJulian Elischer return (EMSGSIZE); 961878ed226SJulian Elischer 962878ed226SJulian Elischer ip = (ng_l2cap_l2ca_cfg_ind_ip *)(msg->data); 963878ed226SJulian Elischer 964f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 965f2bb1caeSJulian Elischer 966878ed226SJulian Elischer /* Check for the open socket that has given channel ID */ 967fbc48c2bSTakanori Watanabe pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid, 968fbc48c2bSTakanori Watanabe NG_L2CAP_L2CA_IDTYPE_BREDR); 969f2bb1caeSJulian Elischer if (pcb == NULL) { 970f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 971878ed226SJulian Elischer return (ENOENT); 972f2bb1caeSJulian Elischer } 973878ed226SJulian Elischer 974878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 975878ed226SJulian Elischer 976878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 977878ed226SJulian Elischer "%s: Got L2CA_Config indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 978878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d, cfg_state=%x\n", 979878ed226SJulian Elischer __func__, 980878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 981878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 982878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 983878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 984878ed226SJulian Elischer pcb->psm, pcb->cid, pcb->state, pcb->cfg_state); 985878ed226SJulian Elischer 986878ed226SJulian Elischer /* XXX FIXME re-configuration on open socket */ 987878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 988878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 989f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 990f2bb1caeSJulian Elischer 991878ed226SJulian Elischer return (ENOENT); 992878ed226SJulian Elischer } 993878ed226SJulian Elischer 994878ed226SJulian Elischer /* 995878ed226SJulian Elischer * XXX FIXME Actually set flush and link timeout. Set QoS here if 996878ed226SJulian Elischer * required. Resolve conficts (flush_timo). Note outgoing MTU (peer's 997878ed226SJulian Elischer * incoming MTU) and incoming flow spec. 998878ed226SJulian Elischer */ 999878ed226SJulian Elischer 1000878ed226SJulian Elischer pcb->omtu = ip->omtu; 1001878ed226SJulian Elischer bcopy(&ip->iflow, &pcb->iflow, sizeof(pcb->iflow)); 1002878ed226SJulian Elischer pcb->flush_timo = ip->flush_timo; 1003878ed226SJulian Elischer 1004878ed226SJulian Elischer /* 1005878ed226SJulian Elischer * Send L2CA_Config response to our peer and check for the errors, 1006878ed226SJulian Elischer * if any send disconnect to close the channel. 1007878ed226SJulian Elischer */ 1008878ed226SJulian Elischer 1009878ed226SJulian Elischer if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_OUT_SENT)) { 1010878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_cfg_rsp(pcb); 1011878ed226SJulian Elischer if (error != 0) { 1012878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1013878ed226SJulian Elischer 1014878ed226SJulian Elischer pcb->so->so_error = error; 1015878ed226SJulian Elischer 1016878ed226SJulian Elischer /* Send disconnect with "zero" token */ 1017878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 1018878ed226SJulian Elischer 1019878ed226SJulian Elischer /* ... and close the socket */ 1020878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1021878ed226SJulian Elischer soisdisconnected(pcb->so); 1022f2bb1caeSJulian Elischer } else 1023f2bb1caeSJulian Elischer pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 1024878ed226SJulian Elischer } 1025878ed226SJulian Elischer 1026878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1027f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1028878ed226SJulian Elischer 1029878ed226SJulian Elischer return (error); 1030878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2cap_cfg_ind */ 1031878ed226SJulian Elischer 1032878ed226SJulian Elischer /* 1033878ed226SJulian Elischer * Process L2CA_Disconnect response 1034878ed226SJulian Elischer */ 1035878ed226SJulian Elischer 1036878ed226SJulian Elischer static int 1037878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_discon_rsp(struct ng_mesg *msg, 10387c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 1039878ed226SJulian Elischer { 1040878ed226SJulian Elischer ng_l2cap_l2ca_discon_op *op = NULL; 1041878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1042878ed226SJulian Elischer 1043878ed226SJulian Elischer /* Check message */ 1044878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 1045878ed226SJulian Elischer return (EMSGSIZE); 1046878ed226SJulian Elischer 1047878ed226SJulian Elischer op = (ng_l2cap_l2ca_discon_op *)(msg->data); 1048878ed226SJulian Elischer 1049f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1050f2bb1caeSJulian Elischer 1051878ed226SJulian Elischer /* 1052878ed226SJulian Elischer * Socket layer must have issued L2CA_Disconnect request, so there 1053878ed226SJulian Elischer * must be a socket that wants to be disconnected. Use Netgraph 1054878ed226SJulian Elischer * message token to find it. 1055878ed226SJulian Elischer */ 1056878ed226SJulian Elischer 1057878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1058f2bb1caeSJulian Elischer if (pcb == NULL) { 1059f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1060878ed226SJulian Elischer return (0); 1061f2bb1caeSJulian Elischer } 1062878ed226SJulian Elischer 1063878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1064878ed226SJulian Elischer 1065878ed226SJulian Elischer /* XXX Close socket no matter what op->result says */ 1066878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 1067878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1068878ed226SJulian Elischer "%s: Got L2CA_Disconnect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1069878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 1070878ed226SJulian Elischer __func__, msg->header.token, 1071878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1072878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1073878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1074878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1075878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, pcb->state); 1076878ed226SJulian Elischer 1077878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1078878ed226SJulian Elischer 1079878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1080878ed226SJulian Elischer soisdisconnected(pcb->so); 1081878ed226SJulian Elischer } 1082878ed226SJulian Elischer 1083878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1084f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1085878ed226SJulian Elischer 1086878ed226SJulian Elischer return (0); 1087878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_discon_rsp */ 1088878ed226SJulian Elischer 1089878ed226SJulian Elischer /* 1090878ed226SJulian Elischer * Process L2CA_Disconnect indicator 1091878ed226SJulian Elischer */ 1092878ed226SJulian Elischer 1093878ed226SJulian Elischer static int 1094878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_discon_ind(struct ng_mesg *msg, 10957c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 1096878ed226SJulian Elischer { 1097878ed226SJulian Elischer ng_l2cap_l2ca_discon_ind_ip *ip = NULL; 1098878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1099878ed226SJulian Elischer 1100878ed226SJulian Elischer /* Check message */ 1101878ed226SJulian Elischer if (msg->header.arglen != sizeof(*ip)) 1102878ed226SJulian Elischer return (EMSGSIZE); 1103878ed226SJulian Elischer 1104878ed226SJulian Elischer ip = (ng_l2cap_l2ca_discon_ind_ip *)(msg->data); 1105878ed226SJulian Elischer 1106f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1107f2bb1caeSJulian Elischer 1108878ed226SJulian Elischer /* Look for the socket with given channel ID */ 1109fbc48c2bSTakanori Watanabe pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid, 1110b32073c4STakanori Watanabe ip->idtype); 1111f2bb1caeSJulian Elischer if (pcb == NULL) { 1112f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1113878ed226SJulian Elischer return (0); 1114f2bb1caeSJulian Elischer } 1115878ed226SJulian Elischer 1116878ed226SJulian Elischer /* 1117878ed226SJulian Elischer * Channel has already been destroyed, so disconnect the socket 1118878ed226SJulian Elischer * and be done with it. If there was any pending request we can 1119878ed226SJulian Elischer * not do anything here anyway. 1120878ed226SJulian Elischer */ 1121878ed226SJulian Elischer 1122878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1123878ed226SJulian Elischer 1124878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1125878ed226SJulian Elischer "%s: Got L2CA_Disconnect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1126878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d\n", 1127878ed226SJulian Elischer __func__, 1128878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1129878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1130878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1131878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1132878ed226SJulian Elischer pcb->psm, pcb->cid, pcb->state); 1133878ed226SJulian Elischer 1134878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1135878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1136878ed226SJulian Elischer 1137878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1138878ed226SJulian Elischer soisdisconnected(pcb->so); 1139878ed226SJulian Elischer 1140878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1141f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1142878ed226SJulian Elischer 1143878ed226SJulian Elischer return (0); 1144878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_discon_ind */ 1145878ed226SJulian Elischer 1146878ed226SJulian Elischer /* 1147878ed226SJulian Elischer * Process L2CA_Write response 1148878ed226SJulian Elischer */ 1149878ed226SJulian Elischer 1150878ed226SJulian Elischer static int 1151878ed226SJulian Elischer ng_btsocket_l2cap_process_l2ca_write_rsp(struct ng_mesg *msg, 11527c380856SMaksim Yevmenkin ng_btsocket_l2cap_rtentry_p rt) 1153878ed226SJulian Elischer { 1154878ed226SJulian Elischer ng_l2cap_l2ca_write_op *op = NULL; 1155878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1156878ed226SJulian Elischer 1157878ed226SJulian Elischer /* Check message */ 1158878ed226SJulian Elischer if (msg->header.arglen != sizeof(*op)) 1159878ed226SJulian Elischer return (EMSGSIZE); 1160878ed226SJulian Elischer 1161878ed226SJulian Elischer op = (ng_l2cap_l2ca_write_op *)(msg->data); 1162878ed226SJulian Elischer 1163f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1164f2bb1caeSJulian Elischer 1165878ed226SJulian Elischer /* Look for the socket with given token */ 1166878ed226SJulian Elischer pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1167f2bb1caeSJulian Elischer if (pcb == NULL) { 1168f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1169878ed226SJulian Elischer return (ENOENT); 1170f2bb1caeSJulian Elischer } 1171878ed226SJulian Elischer 1172878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1173878ed226SJulian Elischer 1174878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1175878ed226SJulian Elischer "%s: Got L2CA_Write response, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1176878ed226SJulian Elischer "dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, length=%d, " \ 1177878ed226SJulian Elischer "state=%d\n", __func__, 1178878ed226SJulian Elischer pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1179878ed226SJulian Elischer pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1180878ed226SJulian Elischer pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1181878ed226SJulian Elischer pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1182878ed226SJulian Elischer pcb->psm, pcb->cid, op->result, op->length, 1183878ed226SJulian Elischer pcb->state); 1184878ed226SJulian Elischer 1185878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1186878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1187f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1188f2bb1caeSJulian Elischer 1189878ed226SJulian Elischer return (ENOENT); 1190878ed226SJulian Elischer } 1191878ed226SJulian Elischer 1192878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1193878ed226SJulian Elischer 1194878ed226SJulian Elischer /* 1195878ed226SJulian Elischer * Check if we have more data to send 1196878ed226SJulian Elischer */ 1197878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); 1198cfa6009eSGleb Smirnoff if (sbavail(&pcb->so->so_snd) > 0) { 1199878ed226SJulian Elischer if (ng_btsocket_l2cap_send2(pcb) == 0) 1200878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 1201878ed226SJulian Elischer else 1202878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); /* XXX */ 1203878ed226SJulian Elischer } 1204878ed226SJulian Elischer 1205878ed226SJulian Elischer /* 1206878ed226SJulian Elischer * Now set the result, drop packet from the socket send queue and 1207878ed226SJulian Elischer * ask for more (wakeup sender) 1208878ed226SJulian Elischer */ 1209878ed226SJulian Elischer 1210878ed226SJulian Elischer pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 1211878ed226SJulian Elischer sowwakeup(pcb->so); 1212878ed226SJulian Elischer 1213878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1214f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1215878ed226SJulian Elischer 1216878ed226SJulian Elischer return (0); 1217878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_l2ca_write_rsp */ 1218878ed226SJulian Elischer 1219878ed226SJulian Elischer /* 1220878ed226SJulian Elischer * Send L2CA_Connect request 1221878ed226SJulian Elischer */ 1222878ed226SJulian Elischer 1223878ed226SJulian Elischer static int 1224878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_con_req(ng_btsocket_l2cap_pcb_p pcb) 1225878ed226SJulian Elischer { 1226878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1227878ed226SJulian Elischer ng_l2cap_l2ca_con_ip *ip = NULL; 1228878ed226SJulian Elischer int error = 0; 1229878ed226SJulian Elischer 1230878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1231878ed226SJulian Elischer 1232878ed226SJulian Elischer if (pcb->rt == NULL || 1233878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1234878ed226SJulian Elischer return (ENETDOWN); 1235878ed226SJulian Elischer 1236878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON, 1237878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1238878ed226SJulian Elischer if (msg == NULL) 1239878ed226SJulian Elischer return (ENOMEM); 1240878ed226SJulian Elischer 1241878ed226SJulian Elischer msg->header.token = pcb->token; 1242878ed226SJulian Elischer 1243878ed226SJulian Elischer ip = (ng_l2cap_l2ca_con_ip *)(msg->data); 1244878ed226SJulian Elischer bcopy(&pcb->dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1245878ed226SJulian Elischer ip->psm = pcb->psm; 1246fbc48c2bSTakanori Watanabe ip->linktype = ng_btsock_l2cap_addrtype_to_linktype(pcb->dsttype); 12473a601a23STakanori Watanabe ip->idtype = pcb->idtype; 1248b9fe2d6cSAlfred Perlstein NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg,pcb->rt->hook, 0); 1249878ed226SJulian Elischer 1250878ed226SJulian Elischer return (error); 1251878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_con_req */ 1252878ed226SJulian Elischer 1253878ed226SJulian Elischer /* 1254878ed226SJulian Elischer * Send L2CA_Connect response 1255878ed226SJulian Elischer */ 1256878ed226SJulian Elischer 1257878ed226SJulian Elischer static int 1258878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_con_rsp_req(u_int32_t token, 1259878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt, bdaddr_p dst, int ident, 1260fbc48c2bSTakanori Watanabe int lcid, int result, int linktype) 1261878ed226SJulian Elischer { 1262878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1263878ed226SJulian Elischer ng_l2cap_l2ca_con_rsp_ip *ip = NULL; 1264878ed226SJulian Elischer int error = 0; 1265878ed226SJulian Elischer 1266878ed226SJulian Elischer if (rt == NULL || rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 1267878ed226SJulian Elischer return (ENETDOWN); 1268878ed226SJulian Elischer 1269878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON_RSP, 1270878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1271878ed226SJulian Elischer if (msg == NULL) 1272878ed226SJulian Elischer return (ENOMEM); 1273878ed226SJulian Elischer 1274878ed226SJulian Elischer msg->header.token = token; 1275878ed226SJulian Elischer 1276878ed226SJulian Elischer ip = (ng_l2cap_l2ca_con_rsp_ip *)(msg->data); 1277878ed226SJulian Elischer bcopy(dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1278878ed226SJulian Elischer ip->ident = ident; 1279878ed226SJulian Elischer ip->lcid = lcid; 1280fbc48c2bSTakanori Watanabe ip->linktype = linktype; 1281878ed226SJulian Elischer ip->result = result; 1282878ed226SJulian Elischer ip->status = 0; 1283878ed226SJulian Elischer 1284b9fe2d6cSAlfred Perlstein NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg, rt->hook, 0); 1285878ed226SJulian Elischer 1286878ed226SJulian Elischer return (error); 1287878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_con_rsp_req */ 1288878ed226SJulian Elischer 1289878ed226SJulian Elischer /* 1290878ed226SJulian Elischer * Send L2CA_Config request 1291878ed226SJulian Elischer */ 1292878ed226SJulian Elischer 1293878ed226SJulian Elischer static int 1294878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_cfg_req(ng_btsocket_l2cap_pcb_p pcb) 1295878ed226SJulian Elischer { 1296878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1297878ed226SJulian Elischer ng_l2cap_l2ca_cfg_ip *ip = NULL; 1298878ed226SJulian Elischer int error = 0; 1299878ed226SJulian Elischer 1300878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1301878ed226SJulian Elischer 1302878ed226SJulian Elischer if (pcb->rt == NULL || 1303878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1304878ed226SJulian Elischer return (ENETDOWN); 1305878ed226SJulian Elischer 1306878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG, 1307878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1308878ed226SJulian Elischer if (msg == NULL) 1309878ed226SJulian Elischer return (ENOMEM); 1310878ed226SJulian Elischer 1311878ed226SJulian Elischer msg->header.token = pcb->token; 1312878ed226SJulian Elischer 1313878ed226SJulian Elischer ip = (ng_l2cap_l2ca_cfg_ip *)(msg->data); 1314878ed226SJulian Elischer ip->lcid = pcb->cid; 1315878ed226SJulian Elischer ip->imtu = pcb->imtu; 1316878ed226SJulian Elischer bcopy(&pcb->oflow, &ip->oflow, sizeof(ip->oflow)); 1317878ed226SJulian Elischer ip->flush_timo = pcb->flush_timo; 1318878ed226SJulian Elischer ip->link_timo = pcb->link_timo; 1319878ed226SJulian Elischer 1320b9fe2d6cSAlfred Perlstein NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg,pcb->rt->hook, 0); 1321878ed226SJulian Elischer 1322878ed226SJulian Elischer return (error); 1323878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_cfg_req */ 1324878ed226SJulian Elischer 1325878ed226SJulian Elischer /* 1326878ed226SJulian Elischer * Send L2CA_Config response 1327878ed226SJulian Elischer */ 1328878ed226SJulian Elischer 1329878ed226SJulian Elischer static int 1330878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_cfg_rsp(ng_btsocket_l2cap_pcb_p pcb) 1331878ed226SJulian Elischer { 1332878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1333878ed226SJulian Elischer ng_l2cap_l2ca_cfg_rsp_ip *ip = NULL; 1334878ed226SJulian Elischer int error = 0; 1335878ed226SJulian Elischer 1336878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1337878ed226SJulian Elischer 1338878ed226SJulian Elischer if (pcb->rt == NULL || 1339878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1340878ed226SJulian Elischer return (ENETDOWN); 1341878ed226SJulian Elischer 1342878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG_RSP, 1343878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1344878ed226SJulian Elischer if (msg == NULL) 1345878ed226SJulian Elischer return (ENOMEM); 1346878ed226SJulian Elischer 1347878ed226SJulian Elischer msg->header.token = pcb->token; 1348878ed226SJulian Elischer 1349878ed226SJulian Elischer ip = (ng_l2cap_l2ca_cfg_rsp_ip *)(msg->data); 1350878ed226SJulian Elischer ip->lcid = pcb->cid; 1351878ed226SJulian Elischer ip->omtu = pcb->omtu; 1352878ed226SJulian Elischer bcopy(&pcb->iflow, &ip->iflow, sizeof(ip->iflow)); 1353878ed226SJulian Elischer 1354b9fe2d6cSAlfred Perlstein NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg, pcb->rt->hook, 0); 1355878ed226SJulian Elischer 1356878ed226SJulian Elischer return (error); 1357878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_cfg_rsp */ 1358878ed226SJulian Elischer 1359878ed226SJulian Elischer /* 1360878ed226SJulian Elischer * Send L2CA_Disconnect request 1361878ed226SJulian Elischer */ 1362878ed226SJulian Elischer 1363878ed226SJulian Elischer static int 1364878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(u_int32_t token, 1365878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb) 1366878ed226SJulian Elischer { 1367878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1368878ed226SJulian Elischer ng_l2cap_l2ca_discon_ip *ip = NULL; 1369878ed226SJulian Elischer int error = 0; 1370878ed226SJulian Elischer 1371878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1372878ed226SJulian Elischer 1373878ed226SJulian Elischer if (pcb->rt == NULL || 1374878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1375878ed226SJulian Elischer return (ENETDOWN); 1376878ed226SJulian Elischer 1377878ed226SJulian Elischer NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_DISCON, 1378878ed226SJulian Elischer sizeof(*ip), M_NOWAIT); 1379878ed226SJulian Elischer if (msg == NULL) 1380878ed226SJulian Elischer return (ENOMEM); 1381878ed226SJulian Elischer 1382878ed226SJulian Elischer msg->header.token = token; 1383878ed226SJulian Elischer 1384878ed226SJulian Elischer ip = (ng_l2cap_l2ca_discon_ip *)(msg->data); 1385878ed226SJulian Elischer ip->lcid = pcb->cid; 13863a601a23STakanori Watanabe ip->idtype = pcb->idtype; 1387878ed226SJulian Elischer 1388b9fe2d6cSAlfred Perlstein NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg,pcb->rt->hook, 0); 1389878ed226SJulian Elischer 1390878ed226SJulian Elischer return (error); 1391878ed226SJulian Elischer } /* ng_btsocket_l2cap_send_l2ca_discon_req */ 1392878ed226SJulian Elischer 1393878ed226SJulian Elischer /***************************************************************************** 1394878ed226SJulian Elischer ***************************************************************************** 1395878ed226SJulian Elischer ** Socket interface 1396878ed226SJulian Elischer ***************************************************************************** 1397878ed226SJulian Elischer *****************************************************************************/ 1398878ed226SJulian Elischer 1399878ed226SJulian Elischer /* 1400878ed226SJulian Elischer * L2CAP sockets data input routine 1401878ed226SJulian Elischer */ 1402878ed226SJulian Elischer 1403878ed226SJulian Elischer static void 1404878ed226SJulian Elischer ng_btsocket_l2cap_data_input(struct mbuf *m, hook_p hook) 1405878ed226SJulian Elischer { 1406878ed226SJulian Elischer ng_l2cap_hdr_t *hdr = NULL; 1407878ed226SJulian Elischer ng_l2cap_clt_hdr_t *clt_hdr = NULL; 1408878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 1409878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_t *rt = NULL; 1410fbc48c2bSTakanori Watanabe uint16_t idtype; 1411878ed226SJulian Elischer 1412878ed226SJulian Elischer if (hook == NULL) { 1413878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1414878ed226SJulian Elischer "%s: Invalid source hook for L2CAP data packet\n", __func__); 1415878ed226SJulian Elischer goto drop; 1416878ed226SJulian Elischer } 1417878ed226SJulian Elischer 1418878ed226SJulian Elischer rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1419878ed226SJulian Elischer if (rt == NULL) { 1420878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1421878ed226SJulian Elischer "%s: Could not find out source bdaddr for L2CAP data packet\n", __func__); 1422878ed226SJulian Elischer goto drop; 1423878ed226SJulian Elischer } 1424878ed226SJulian Elischer 1425fbc48c2bSTakanori Watanabe m = m_pullup(m, sizeof(uint16_t)); 1426fbc48c2bSTakanori Watanabe idtype = *mtod(m, uint16_t *); 1427fbc48c2bSTakanori Watanabe m_adj(m, sizeof(uint16_t)); 1428fbc48c2bSTakanori Watanabe 1429878ed226SJulian Elischer /* Make sure we can access header */ 1430878ed226SJulian Elischer if (m->m_pkthdr.len < sizeof(*hdr)) { 1431878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1432878ed226SJulian Elischer "%s: L2CAP data packet too small, len=%d\n", __func__, m->m_pkthdr.len); 1433878ed226SJulian Elischer goto drop; 1434878ed226SJulian Elischer } 1435878ed226SJulian Elischer 1436878ed226SJulian Elischer if (m->m_len < sizeof(*hdr)) { 1437878ed226SJulian Elischer m = m_pullup(m, sizeof(*hdr)); 1438878ed226SJulian Elischer if (m == NULL) 1439878ed226SJulian Elischer goto drop; 1440878ed226SJulian Elischer } 1441878ed226SJulian Elischer 1442878ed226SJulian Elischer /* Strip L2CAP packet header and verify packet length */ 1443878ed226SJulian Elischer hdr = mtod(m, ng_l2cap_hdr_t *); 1444878ed226SJulian Elischer m_adj(m, sizeof(*hdr)); 1445878ed226SJulian Elischer 1446878ed226SJulian Elischer if (hdr->length != m->m_pkthdr.len) { 1447878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1448878ed226SJulian Elischer "%s: Bad L2CAP data packet length, len=%d, length=%d\n", 1449878ed226SJulian Elischer __func__, m->m_pkthdr.len, hdr->length); 1450878ed226SJulian Elischer goto drop; 1451878ed226SJulian Elischer } 1452878ed226SJulian Elischer 1453878ed226SJulian Elischer /* 1454878ed226SJulian Elischer * Now process packet. Two cases: 1455878ed226SJulian Elischer * 1456878ed226SJulian Elischer * 1) Normal packet (cid != 2) then find connected socket and append 1457878ed226SJulian Elischer * mbuf to the socket queue. Wakeup socket. 1458878ed226SJulian Elischer * 1459878ed226SJulian Elischer * 2) Broadcast packet (cid == 2) then find all sockets that connected 1460878ed226SJulian Elischer * to the given PSM and have SO_BROADCAST bit set and append mbuf 1461878ed226SJulian Elischer * to the socket queue. Wakeup socket. 1462878ed226SJulian Elischer */ 1463878ed226SJulian Elischer 1464878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1465f2bb1caeSJulian Elischer "%s: Received L2CAP data packet: src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1466878ed226SJulian Elischer "dcid=%d, length=%d\n", 1467878ed226SJulian Elischer __func__, 1468878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1469878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1470878ed226SJulian Elischer hdr->dcid, hdr->length); 1471878ed226SJulian Elischer 1472fbc48c2bSTakanori Watanabe if ((hdr->dcid >= NG_L2CAP_FIRST_CID) || 14733a601a23STakanori Watanabe (idtype == NG_L2CAP_L2CA_IDTYPE_ATT)|| 14743a601a23STakanori Watanabe (idtype == NG_L2CAP_L2CA_IDTYPE_SMP) 14753a601a23STakanori Watanabe ){ 1476f2bb1caeSJulian Elischer 1477f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1478f2bb1caeSJulian Elischer 1479878ed226SJulian Elischer /* Normal packet: find connected socket */ 1480fbc48c2bSTakanori Watanabe pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, hdr->dcid,idtype); 1481f2bb1caeSJulian Elischer if (pcb == NULL) { 1482f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1483878ed226SJulian Elischer goto drop; 1484f2bb1caeSJulian Elischer } 1485878ed226SJulian Elischer 1486878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1487878ed226SJulian Elischer 1488878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1489878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1490878ed226SJulian Elischer "%s: No connected socket found, src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, " \ 1491878ed226SJulian Elischer "state=%d\n", __func__, 1492878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1493878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1494878ed226SJulian Elischer hdr->dcid, pcb->state); 1495878ed226SJulian Elischer 1496878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1497f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1498878ed226SJulian Elischer goto drop; 1499878ed226SJulian Elischer } 1500878ed226SJulian Elischer 1501878ed226SJulian Elischer /* Check packet size against socket's incoming MTU */ 1502878ed226SJulian Elischer if (hdr->length > pcb->imtu) { 1503878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1504878ed226SJulian Elischer "%s: L2CAP data packet too big, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1505878ed226SJulian Elischer "dcid=%d, length=%d, imtu=%d\n", 1506878ed226SJulian Elischer __func__, 1507878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1508878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1509878ed226SJulian Elischer hdr->dcid, hdr->length, pcb->imtu); 1510878ed226SJulian Elischer 1511878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1512f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1513878ed226SJulian Elischer goto drop; 1514878ed226SJulian Elischer } 1515878ed226SJulian Elischer 1516878ed226SJulian Elischer /* Check if we have enough space in socket receive queue */ 1517878ed226SJulian Elischer if (m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) { 1518878ed226SJulian Elischer 1519878ed226SJulian Elischer /* 1520878ed226SJulian Elischer * This is really bad. Receive queue on socket does 1521878ed226SJulian Elischer * not have enough space for the packet. We do not 1522878ed226SJulian Elischer * have any other choice but drop the packet. L2CAP 1523878ed226SJulian Elischer * does not provide any flow control. 1524878ed226SJulian Elischer */ 1525878ed226SJulian Elischer 1526878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1527878ed226SJulian Elischer "%s: Not enough space in socket receive queue. Dropping L2CAP data packet, " \ 1528878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, len=%d, space=%ld\n", 1529878ed226SJulian Elischer __func__, 1530878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1531878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1532878ed226SJulian Elischer hdr->dcid, m->m_pkthdr.len, 1533878ed226SJulian Elischer sbspace(&pcb->so->so_rcv)); 1534878ed226SJulian Elischer 1535878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1536f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1537878ed226SJulian Elischer goto drop; 1538878ed226SJulian Elischer } 1539878ed226SJulian Elischer 1540878ed226SJulian Elischer /* Append packet to the socket receive queue and wakeup */ 1541878ed226SJulian Elischer sbappendrecord(&pcb->so->so_rcv, m); 1542878ed226SJulian Elischer m = NULL; 1543878ed226SJulian Elischer 1544878ed226SJulian Elischer sorwakeup(pcb->so); 1545f2bb1caeSJulian Elischer 1546878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1547f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1548878ed226SJulian Elischer } else if (hdr->dcid == NG_L2CAP_CLT_CID) { 1549878ed226SJulian Elischer /* Broadcast packet: give packet to all sockets */ 1550878ed226SJulian Elischer 1551878ed226SJulian Elischer /* Check packet size against connectionless MTU */ 1552878ed226SJulian Elischer if (hdr->length > NG_L2CAP_MTU_DEFAULT) { 1553878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1554878ed226SJulian Elischer "%s: Connectionless L2CAP data packet too big, " \ 1555878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1556878ed226SJulian Elischer __func__, 1557878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1558878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1559878ed226SJulian Elischer hdr->length); 1560878ed226SJulian Elischer goto drop; 1561878ed226SJulian Elischer } 1562878ed226SJulian Elischer 1563878ed226SJulian Elischer /* Make sure we can access connectionless header */ 1564878ed226SJulian Elischer if (m->m_pkthdr.len < sizeof(*clt_hdr)) { 1565878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 1566878ed226SJulian Elischer "%s: Can not get L2CAP connectionless packet header, " \ 1567878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1568878ed226SJulian Elischer __func__, 1569878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1570878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1571878ed226SJulian Elischer hdr->length); 1572878ed226SJulian Elischer goto drop; 1573878ed226SJulian Elischer } 1574878ed226SJulian Elischer 1575878ed226SJulian Elischer if (m->m_len < sizeof(*clt_hdr)) { 1576878ed226SJulian Elischer m = m_pullup(m, sizeof(*clt_hdr)); 1577878ed226SJulian Elischer if (m == NULL) 1578878ed226SJulian Elischer goto drop; 1579878ed226SJulian Elischer } 1580878ed226SJulian Elischer 1581878ed226SJulian Elischer /* Strip connectionless header and deliver packet */ 1582878ed226SJulian Elischer clt_hdr = mtod(m, ng_l2cap_clt_hdr_t *); 1583878ed226SJulian Elischer m_adj(m, sizeof(*clt_hdr)); 1584878ed226SJulian Elischer 1585878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1586878ed226SJulian Elischer "%s: Got L2CAP connectionless data packet, " \ 1587878ed226SJulian Elischer "src bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, length=%d\n", 1588878ed226SJulian Elischer __func__, 1589878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1590878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0], 1591878ed226SJulian Elischer clt_hdr->psm, hdr->length); 1592878ed226SJulian Elischer 1593878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1594878ed226SJulian Elischer 1595878ed226SJulian Elischer LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) { 1596878ed226SJulian Elischer struct mbuf *copy = NULL; 1597878ed226SJulian Elischer 1598878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1599878ed226SJulian Elischer 1600878ed226SJulian Elischer if (bcmp(&rt->src, &pcb->src, sizeof(pcb->src)) != 0 || 1601878ed226SJulian Elischer pcb->psm != clt_hdr->psm || 1602878ed226SJulian Elischer pcb->state != NG_BTSOCKET_L2CAP_OPEN || 1603878ed226SJulian Elischer (pcb->so->so_options & SO_BROADCAST) == 0 || 1604878ed226SJulian Elischer m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) 1605878ed226SJulian Elischer goto next; 1606878ed226SJulian Elischer 1607878ed226SJulian Elischer /* 1608878ed226SJulian Elischer * Create a copy of the packet and append it to the 1609878ed226SJulian Elischer * socket's queue. If m_dup() failed - no big deal 1610878ed226SJulian Elischer * it is a broadcast traffic after all 1611878ed226SJulian Elischer */ 1612878ed226SJulian Elischer 1613eb1b1807SGleb Smirnoff copy = m_dup(m, M_NOWAIT); 1614878ed226SJulian Elischer if (copy != NULL) { 1615878ed226SJulian Elischer sbappendrecord(&pcb->so->so_rcv, copy); 1616878ed226SJulian Elischer sorwakeup(pcb->so); 1617878ed226SJulian Elischer } 1618878ed226SJulian Elischer next: 1619878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1620878ed226SJulian Elischer } 1621878ed226SJulian Elischer 1622878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1623878ed226SJulian Elischer } 1624878ed226SJulian Elischer drop: 1625878ed226SJulian Elischer NG_FREE_M(m); /* checks for m != NULL */ 1626878ed226SJulian Elischer } /* ng_btsocket_l2cap_data_input */ 1627878ed226SJulian Elischer 1628878ed226SJulian Elischer /* 1629878ed226SJulian Elischer * L2CAP sockets default message input routine 1630878ed226SJulian Elischer */ 1631878ed226SJulian Elischer 1632878ed226SJulian Elischer static void 1633878ed226SJulian Elischer ng_btsocket_l2cap_default_msg_input(struct ng_mesg *msg, hook_p hook) 1634878ed226SJulian Elischer { 1635878ed226SJulian Elischer switch (msg->header.cmd) { 1636878ed226SJulian Elischer case NGM_L2CAP_NODE_HOOK_INFO: { 1637878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_t *rt = NULL; 1638fbc48c2bSTakanori Watanabe ng_l2cap_node_hook_info_ep *ep = 1639fbc48c2bSTakanori Watanabe (ng_l2cap_node_hook_info_ep *)msg->data; 1640fbc48c2bSTakanori Watanabe if (hook == NULL || msg->header.arglen != sizeof(*ep)) 1641878ed226SJulian Elischer break; 1642878ed226SJulian Elischer 1643fbc48c2bSTakanori Watanabe if (bcmp(&ep->addr, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 1644878ed226SJulian Elischer break; 1645878ed226SJulian Elischer 1646f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1647f2bb1caeSJulian Elischer 1648878ed226SJulian Elischer rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1649878ed226SJulian Elischer if (rt == NULL) { 16501ede983cSDag-Erling Smørgrav rt = malloc(sizeof(*rt), 1651878ed226SJulian Elischer M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT|M_ZERO); 1652f2bb1caeSJulian Elischer if (rt == NULL) { 1653878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1654f2bb1caeSJulian Elischer break; 1655f2bb1caeSJulian Elischer } 1656f2bb1caeSJulian Elischer 1657f2bb1caeSJulian Elischer LIST_INSERT_HEAD(&ng_btsocket_l2cap_rt, rt, next); 1658878ed226SJulian Elischer 1659878ed226SJulian Elischer NG_HOOK_SET_PRIVATE(hook, rt); 1660878ed226SJulian Elischer } 1661878ed226SJulian Elischer 1662fbc48c2bSTakanori Watanabe bcopy(&ep->addr, &rt->src, sizeof(rt->src)); 1663878ed226SJulian Elischer rt->hook = hook; 1664878ed226SJulian Elischer 1665f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1666f2bb1caeSJulian Elischer 1667878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 1668878ed226SJulian Elischer "%s: Updating hook \"%s\", src bdaddr=%x:%x:%x:%x:%x:%x\n", 1669878ed226SJulian Elischer __func__, NG_HOOK_NAME(hook), 1670878ed226SJulian Elischer rt->src.b[5], rt->src.b[4], rt->src.b[3], 1671878ed226SJulian Elischer rt->src.b[2], rt->src.b[1], rt->src.b[0]); 1672878ed226SJulian Elischer } break; 1673878ed226SJulian Elischer 1674878ed226SJulian Elischer default: 1675878ed226SJulian Elischer NG_BTSOCKET_L2CAP_WARN( 1676878ed226SJulian Elischer "%s: Unknown message, cmd=%d\n", __func__, msg->header.cmd); 1677878ed226SJulian Elischer break; 1678878ed226SJulian Elischer } 1679878ed226SJulian Elischer 1680878ed226SJulian Elischer NG_FREE_MSG(msg); /* Checks for msg != NULL */ 1681878ed226SJulian Elischer } /* ng_btsocket_l2cap_default_msg_input */ 1682878ed226SJulian Elischer 1683878ed226SJulian Elischer /* 1684878ed226SJulian Elischer * L2CAP sockets L2CA message input routine 1685878ed226SJulian Elischer */ 1686878ed226SJulian Elischer 1687878ed226SJulian Elischer static void 1688878ed226SJulian Elischer ng_btsocket_l2cap_l2ca_msg_input(struct ng_mesg *msg, hook_p hook) 1689878ed226SJulian Elischer { 1690878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt = NULL; 1691878ed226SJulian Elischer 1692878ed226SJulian Elischer if (hook == NULL) { 1693878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1694878ed226SJulian Elischer "%s: Invalid source hook for L2CA message\n", __func__); 1695878ed226SJulian Elischer goto drop; 1696878ed226SJulian Elischer } 1697878ed226SJulian Elischer 1698878ed226SJulian Elischer rt = (ng_btsocket_l2cap_rtentry_p) NG_HOOK_PRIVATE(hook); 1699878ed226SJulian Elischer if (rt == NULL) { 1700878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1701878ed226SJulian Elischer "%s: Could not find out source bdaddr for L2CA message\n", __func__); 1702878ed226SJulian Elischer goto drop; 1703878ed226SJulian Elischer } 1704878ed226SJulian Elischer 1705878ed226SJulian Elischer switch (msg->header.cmd) { 1706878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON: /* L2CA_Connect response */ 17077c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_con_req_rsp(msg, rt); 1708878ed226SJulian Elischer break; 1709878ed226SJulian Elischer 1710878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_RSP: /* L2CA_ConnectRsp response */ 17117c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_con_rsp_rsp(msg, rt); 1712878ed226SJulian Elischer break; 1713878ed226SJulian Elischer 1714878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_IND: /* L2CA_Connect indicator */ 17157c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_con_ind(msg, rt); 1716878ed226SJulian Elischer break; 1717878ed226SJulian Elischer 1718878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG: /* L2CA_Config response */ 17197c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_cfg_req_rsp(msg, rt); 1720878ed226SJulian Elischer break; 1721878ed226SJulian Elischer 1722878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_RSP: /* L2CA_ConfigRsp response */ 17237c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(msg, rt); 1724878ed226SJulian Elischer break; 1725878ed226SJulian Elischer 1726878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_IND: /* L2CA_Config indicator */ 17277c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_cfg_ind(msg, rt); 1728878ed226SJulian Elischer break; 1729878ed226SJulian Elischer 1730878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON: /* L2CA_Disconnect response */ 17317c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_discon_rsp(msg, rt); 1732878ed226SJulian Elischer break; 1733878ed226SJulian Elischer 1734878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON_IND: /* L2CA_Disconnect indicator */ 17357c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_discon_ind(msg, rt); 1736878ed226SJulian Elischer break; 1737878ed226SJulian Elischer 1738878ed226SJulian Elischer case NGM_L2CAP_L2CA_WRITE: /* L2CA_Write response */ 17397c380856SMaksim Yevmenkin ng_btsocket_l2cap_process_l2ca_write_rsp(msg, rt); 1740878ed226SJulian Elischer break; 17413a601a23STakanori Watanabe case NGM_L2CAP_L2CA_ENC_CHANGE: 17423a601a23STakanori Watanabe ng_btsocket_l2cap_process_l2ca_enc_change(msg, rt); 1743878ed226SJulian Elischer 17443a601a23STakanori Watanabe break; 1745878ed226SJulian Elischer /* XXX FIXME add other L2CA messages */ 1746878ed226SJulian Elischer 1747878ed226SJulian Elischer default: 1748878ed226SJulian Elischer NG_BTSOCKET_L2CAP_WARN( 1749878ed226SJulian Elischer "%s: Unknown L2CA message, cmd=%d\n", __func__, msg->header.cmd); 1750878ed226SJulian Elischer break; 1751878ed226SJulian Elischer } 1752878ed226SJulian Elischer drop: 1753878ed226SJulian Elischer NG_FREE_MSG(msg); 1754878ed226SJulian Elischer } /* ng_btsocket_l2cap_l2ca_msg_input */ 1755878ed226SJulian Elischer 1756878ed226SJulian Elischer /* 1757878ed226SJulian Elischer * L2CAP sockets input routine 1758878ed226SJulian Elischer */ 1759878ed226SJulian Elischer 1760878ed226SJulian Elischer static void 1761878ed226SJulian Elischer ng_btsocket_l2cap_input(void *context, int pending) 1762878ed226SJulian Elischer { 1763878ed226SJulian Elischer item_p item = NULL; 1764878ed226SJulian Elischer hook_p hook = NULL; 1765878ed226SJulian Elischer 1766878ed226SJulian Elischer for (;;) { 1767878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_queue_mtx); 1768878ed226SJulian Elischer NG_BT_ITEMQ_DEQUEUE(&ng_btsocket_l2cap_queue, item); 1769878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 1770878ed226SJulian Elischer 1771878ed226SJulian Elischer if (item == NULL) 1772878ed226SJulian Elischer break; 1773878ed226SJulian Elischer 1774878ed226SJulian Elischer NGI_GET_HOOK(item, hook); 1775878ed226SJulian Elischer if (hook != NULL && NG_HOOK_NOT_VALID(hook)) 1776878ed226SJulian Elischer goto drop; 1777878ed226SJulian Elischer 1778878ed226SJulian Elischer switch(item->el_flags & NGQF_TYPE) { 1779878ed226SJulian Elischer case NGQF_DATA: { 1780878ed226SJulian Elischer struct mbuf *m = NULL; 1781878ed226SJulian Elischer 1782878ed226SJulian Elischer NGI_GET_M(item, m); 1783878ed226SJulian Elischer ng_btsocket_l2cap_data_input(m, hook); 1784878ed226SJulian Elischer } break; 1785878ed226SJulian Elischer 1786878ed226SJulian Elischer case NGQF_MESG: { 1787878ed226SJulian Elischer struct ng_mesg *msg = NULL; 1788878ed226SJulian Elischer 1789878ed226SJulian Elischer NGI_GET_MSG(item, msg); 1790878ed226SJulian Elischer 1791878ed226SJulian Elischer switch (msg->header.cmd) { 1792878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON: 1793878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_RSP: 1794878ed226SJulian Elischer case NGM_L2CAP_L2CA_CON_IND: 1795878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG: 1796878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_RSP: 1797878ed226SJulian Elischer case NGM_L2CAP_L2CA_CFG_IND: 1798878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON: 1799878ed226SJulian Elischer case NGM_L2CAP_L2CA_DISCON_IND: 1800878ed226SJulian Elischer case NGM_L2CAP_L2CA_WRITE: 18013a601a23STakanori Watanabe case NGM_L2CAP_L2CA_ENC_CHANGE: 1802878ed226SJulian Elischer /* XXX FIXME add other L2CA messages */ 1803878ed226SJulian Elischer ng_btsocket_l2cap_l2ca_msg_input(msg, hook); 1804878ed226SJulian Elischer break; 1805878ed226SJulian Elischer 1806878ed226SJulian Elischer default: 1807878ed226SJulian Elischer ng_btsocket_l2cap_default_msg_input(msg, hook); 1808878ed226SJulian Elischer break; 1809878ed226SJulian Elischer } 1810878ed226SJulian Elischer } break; 1811878ed226SJulian Elischer 1812878ed226SJulian Elischer default: 1813878ed226SJulian Elischer KASSERT(0, 1814878ed226SJulian Elischer ("%s: invalid item type=%ld\n", __func__, (item->el_flags & NGQF_TYPE))); 1815878ed226SJulian Elischer break; 1816878ed226SJulian Elischer } 1817878ed226SJulian Elischer drop: 1818878ed226SJulian Elischer if (hook != NULL) 1819878ed226SJulian Elischer NG_HOOK_UNREF(hook); 1820878ed226SJulian Elischer 1821878ed226SJulian Elischer NG_FREE_ITEM(item); 1822878ed226SJulian Elischer } 1823878ed226SJulian Elischer } /* ng_btsocket_l2cap_input */ 1824878ed226SJulian Elischer 1825878ed226SJulian Elischer /* 1826878ed226SJulian Elischer * Route cleanup task. Gets scheduled when hook is disconnected. Here we 1827878ed226SJulian Elischer * will find all sockets that use "invalid" hook and disconnect them. 1828878ed226SJulian Elischer */ 1829878ed226SJulian Elischer 1830878ed226SJulian Elischer static void 1831878ed226SJulian Elischer ng_btsocket_l2cap_rtclean(void *context, int pending) 1832878ed226SJulian Elischer { 1833f2bb1caeSJulian Elischer ng_btsocket_l2cap_pcb_p pcb = NULL, pcb_next = NULL; 1834878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt = NULL; 1835878ed226SJulian Elischer 1836878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1837878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1838878ed226SJulian Elischer 1839878ed226SJulian Elischer /* 1840878ed226SJulian Elischer * First disconnect all sockets that use "invalid" hook 1841878ed226SJulian Elischer */ 1842878ed226SJulian Elischer 1843f2bb1caeSJulian Elischer for (pcb = LIST_FIRST(&ng_btsocket_l2cap_sockets); pcb != NULL; ) { 1844878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 1845f2bb1caeSJulian Elischer pcb_next = LIST_NEXT(pcb, next); 1846878ed226SJulian Elischer 1847878ed226SJulian Elischer if (pcb->rt != NULL && 1848878ed226SJulian Elischer pcb->rt->hook != NULL && NG_HOOK_NOT_VALID(pcb->rt->hook)) { 1849878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1850878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 1851878ed226SJulian Elischer 1852878ed226SJulian Elischer pcb->so->so_error = ENETDOWN; 1853878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1854878ed226SJulian Elischer soisdisconnected(pcb->so); 1855878ed226SJulian Elischer 1856878ed226SJulian Elischer pcb->token = 0; 1857f2bb1caeSJulian Elischer pcb->cid = 0; 1858878ed226SJulian Elischer pcb->rt = NULL; 1859878ed226SJulian Elischer } 1860878ed226SJulian Elischer 1861878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 1862f2bb1caeSJulian Elischer pcb = pcb_next; 1863878ed226SJulian Elischer } 1864878ed226SJulian Elischer 1865878ed226SJulian Elischer /* 1866878ed226SJulian Elischer * Now cleanup routing table 1867878ed226SJulian Elischer */ 1868878ed226SJulian Elischer 1869f2bb1caeSJulian Elischer for (rt = LIST_FIRST(&ng_btsocket_l2cap_rt); rt != NULL; ) { 1870878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_p rt_next = LIST_NEXT(rt, next); 1871878ed226SJulian Elischer 1872878ed226SJulian Elischer if (rt->hook != NULL && NG_HOOK_NOT_VALID(rt->hook)) { 1873878ed226SJulian Elischer LIST_REMOVE(rt, next); 1874878ed226SJulian Elischer 1875878ed226SJulian Elischer NG_HOOK_SET_PRIVATE(rt->hook, NULL); 1876878ed226SJulian Elischer NG_HOOK_UNREF(rt->hook); /* Remove extra reference */ 1877878ed226SJulian Elischer 1878878ed226SJulian Elischer bzero(rt, sizeof(*rt)); 18791ede983cSDag-Erling Smørgrav free(rt, M_NETGRAPH_BTSOCKET_L2CAP); 1880878ed226SJulian Elischer } 1881878ed226SJulian Elischer 1882878ed226SJulian Elischer rt = rt_next; 1883878ed226SJulian Elischer } 1884878ed226SJulian Elischer 1885878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1886878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1887878ed226SJulian Elischer } /* ng_btsocket_l2cap_rtclean */ 1888878ed226SJulian Elischer 1889878ed226SJulian Elischer /* 1890878ed226SJulian Elischer * Initialize everything 1891878ed226SJulian Elischer */ 1892878ed226SJulian Elischer 1893878ed226SJulian Elischer void 1894878ed226SJulian Elischer ng_btsocket_l2cap_init(void) 1895878ed226SJulian Elischer { 1896878ed226SJulian Elischer int error = 0; 1897878ed226SJulian Elischer 18984a8e4eb5SMikolaj Golub /* Skip initialization of globals for non-default instances. */ 18994a8e4eb5SMikolaj Golub if (!IS_DEFAULT_VNET(curvnet)) 19004a8e4eb5SMikolaj Golub return; 19014a8e4eb5SMikolaj Golub 1902878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 1903878ed226SJulian Elischer ng_btsocket_l2cap_debug_level = NG_BTSOCKET_WARN_LEVEL; 1904878ed226SJulian Elischer 1905878ed226SJulian Elischer /* Register Netgraph node type */ 1906878ed226SJulian Elischer error = ng_newtype(&typestruct); 1907878ed226SJulian Elischer if (error != 0) { 1908878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1909878ed226SJulian Elischer "%s: Could not register Netgraph node type, error=%d\n", __func__, error); 1910878ed226SJulian Elischer 1911878ed226SJulian Elischer return; 1912878ed226SJulian Elischer } 1913878ed226SJulian Elischer 1914878ed226SJulian Elischer /* Create Netgrapg node */ 1915878ed226SJulian Elischer error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 1916878ed226SJulian Elischer if (error != 0) { 1917878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1918878ed226SJulian Elischer "%s: Could not create Netgraph node, error=%d\n", __func__, error); 1919878ed226SJulian Elischer 1920878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 1921878ed226SJulian Elischer 1922878ed226SJulian Elischer return; 1923878ed226SJulian Elischer } 1924878ed226SJulian Elischer 1925878ed226SJulian Elischer error = ng_name_node(ng_btsocket_l2cap_node, 1926878ed226SJulian Elischer NG_BTSOCKET_L2CAP_NODE_TYPE); 1927878ed226SJulian Elischer if (error != 0) { 1928878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ALERT( 1929878ed226SJulian Elischer "%s: Could not name Netgraph node, error=%d\n", __func__, error); 1930878ed226SJulian Elischer 1931878ed226SJulian Elischer NG_NODE_UNREF(ng_btsocket_l2cap_node); 1932878ed226SJulian Elischer ng_btsocket_l2cap_node = NULL; 1933878ed226SJulian Elischer 1934878ed226SJulian Elischer return; 1935878ed226SJulian Elischer } 1936878ed226SJulian Elischer 1937878ed226SJulian Elischer /* Create input queue */ 1938878ed226SJulian Elischer NG_BT_ITEMQ_INIT(&ng_btsocket_l2cap_queue, ifqmaxlen); 1939878ed226SJulian Elischer mtx_init(&ng_btsocket_l2cap_queue_mtx, 1940878ed226SJulian Elischer "btsocks_l2cap_queue_mtx", NULL, MTX_DEF); 1941878ed226SJulian Elischer TASK_INIT(&ng_btsocket_l2cap_queue_task, 0, 1942878ed226SJulian Elischer ng_btsocket_l2cap_input, NULL); 1943878ed226SJulian Elischer 1944878ed226SJulian Elischer /* Create list of sockets */ 1945878ed226SJulian Elischer LIST_INIT(&ng_btsocket_l2cap_sockets); 1946878ed226SJulian Elischer mtx_init(&ng_btsocket_l2cap_sockets_mtx, 1947878ed226SJulian Elischer "btsocks_l2cap_sockets_mtx", NULL, MTX_DEF); 1948878ed226SJulian Elischer 1949878ed226SJulian Elischer /* Routing table */ 1950878ed226SJulian Elischer LIST_INIT(&ng_btsocket_l2cap_rt); 1951878ed226SJulian Elischer mtx_init(&ng_btsocket_l2cap_rt_mtx, 1952878ed226SJulian Elischer "btsocks_l2cap_rt_mtx", NULL, MTX_DEF); 1953878ed226SJulian Elischer TASK_INIT(&ng_btsocket_l2cap_rt_task, 0, 1954878ed226SJulian Elischer ng_btsocket_l2cap_rtclean, NULL); 1955878ed226SJulian Elischer } /* ng_btsocket_l2cap_init */ 1956878ed226SJulian Elischer 1957878ed226SJulian Elischer /* 1958878ed226SJulian Elischer * Abort connection on socket 1959878ed226SJulian Elischer */ 1960878ed226SJulian Elischer 1961ac45e92fSRobert Watson void 1962878ed226SJulian Elischer ng_btsocket_l2cap_abort(struct socket *so) 1963878ed226SJulian Elischer { 1964878ed226SJulian Elischer so->so_error = ECONNABORTED; 1965878ed226SJulian Elischer 1966a152f8a3SRobert Watson (void)ng_btsocket_l2cap_disconnect(so); 1967878ed226SJulian Elischer } /* ng_btsocket_l2cap_abort */ 1968878ed226SJulian Elischer 1969a152f8a3SRobert Watson void 1970a152f8a3SRobert Watson ng_btsocket_l2cap_close(struct socket *so) 1971a152f8a3SRobert Watson { 1972a152f8a3SRobert Watson 1973a152f8a3SRobert Watson (void)ng_btsocket_l2cap_disconnect(so); 1974a152f8a3SRobert Watson } /* ng_btsocket_l2cap_close */ 1975a152f8a3SRobert Watson 1976878ed226SJulian Elischer /* 1977878ed226SJulian Elischer * Accept connection on socket. Nothing to do here, socket must be connected 1978878ed226SJulian Elischer * and ready, so just return peer address and be done with it. 1979878ed226SJulian Elischer */ 1980878ed226SJulian Elischer 1981878ed226SJulian Elischer int 1982878ed226SJulian Elischer ng_btsocket_l2cap_accept(struct socket *so, struct sockaddr **nam) 1983878ed226SJulian Elischer { 1984878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 1985878ed226SJulian Elischer return (EINVAL); 1986878ed226SJulian Elischer 1987878ed226SJulian Elischer return (ng_btsocket_l2cap_peeraddr(so, nam)); 1988878ed226SJulian Elischer } /* ng_btsocket_l2cap_accept */ 1989878ed226SJulian Elischer 1990878ed226SJulian Elischer /* 1991878ed226SJulian Elischer * Create and attach new socket 1992878ed226SJulian Elischer */ 1993878ed226SJulian Elischer 1994878ed226SJulian Elischer int 1995878ed226SJulian Elischer ng_btsocket_l2cap_attach(struct socket *so, int proto, struct thread *td) 1996878ed226SJulian Elischer { 1997f2bb1caeSJulian Elischer static u_int32_t token = 0; 1998878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 1999878ed226SJulian Elischer int error; 2000878ed226SJulian Elischer 2001878ed226SJulian Elischer /* Check socket and protocol */ 2002878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2003878ed226SJulian Elischer return (EPROTONOSUPPORT); 2004878ed226SJulian Elischer if (so->so_type != SOCK_SEQPACKET) 2005878ed226SJulian Elischer return (ESOCKTNOSUPPORT); 2006878ed226SJulian Elischer 2007878ed226SJulian Elischer #if 0 /* XXX sonewconn() calls "pru_attach" with proto == 0 */ 2008878ed226SJulian Elischer if (proto != 0) 2009878ed226SJulian Elischer if (proto != BLUETOOTH_PROTO_L2CAP) 2010878ed226SJulian Elischer return (EPROTONOSUPPORT); 2011878ed226SJulian Elischer #endif /* XXX */ 2012878ed226SJulian Elischer 2013878ed226SJulian Elischer if (pcb != NULL) 2014878ed226SJulian Elischer return (EISCONN); 2015878ed226SJulian Elischer 2016878ed226SJulian Elischer /* Reserve send and receive space if it is not reserved yet */ 2017878ed226SJulian Elischer if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 2018878ed226SJulian Elischer error = soreserve(so, NG_BTSOCKET_L2CAP_SENDSPACE, 2019878ed226SJulian Elischer NG_BTSOCKET_L2CAP_RECVSPACE); 2020878ed226SJulian Elischer if (error != 0) 2021878ed226SJulian Elischer return (error); 2022878ed226SJulian Elischer } 2023878ed226SJulian Elischer 2024878ed226SJulian Elischer /* Allocate the PCB */ 20251ede983cSDag-Erling Smørgrav pcb = malloc(sizeof(*pcb), 2026878ed226SJulian Elischer M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT | M_ZERO); 2027878ed226SJulian Elischer if (pcb == NULL) 2028878ed226SJulian Elischer return (ENOMEM); 2029878ed226SJulian Elischer 2030878ed226SJulian Elischer /* Link the PCB and the socket */ 2031878ed226SJulian Elischer so->so_pcb = (caddr_t) pcb; 2032878ed226SJulian Elischer pcb->so = so; 2033878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2034878ed226SJulian Elischer 2035878ed226SJulian Elischer /* Initialize PCB */ 2036878ed226SJulian Elischer pcb->imtu = pcb->omtu = NG_L2CAP_MTU_DEFAULT; 2037878ed226SJulian Elischer 2038878ed226SJulian Elischer /* Default flow */ 2039878ed226SJulian Elischer pcb->iflow.flags = 0x0; 2040878ed226SJulian Elischer pcb->iflow.service_type = NG_HCI_SERVICE_TYPE_BEST_EFFORT; 2041878ed226SJulian Elischer pcb->iflow.token_rate = 0xffffffff; /* maximum */ 2042878ed226SJulian Elischer pcb->iflow.token_bucket_size = 0xffffffff; /* maximum */ 2043878ed226SJulian Elischer pcb->iflow.peak_bandwidth = 0x00000000; /* maximum */ 2044878ed226SJulian Elischer pcb->iflow.latency = 0xffffffff; /* don't care */ 2045878ed226SJulian Elischer pcb->iflow.delay_variation = 0xffffffff; /* don't care */ 2046878ed226SJulian Elischer 2047878ed226SJulian Elischer bcopy(&pcb->iflow, &pcb->oflow, sizeof(pcb->oflow)); 2048878ed226SJulian Elischer 2049878ed226SJulian Elischer pcb->flush_timo = NG_L2CAP_FLUSH_TIMO_DEFAULT; 2050878ed226SJulian Elischer pcb->link_timo = NG_L2CAP_LINK_TIMO_DEFAULT; 2051878ed226SJulian Elischer 2052f2bb1caeSJulian Elischer /* 2053f2bb1caeSJulian Elischer * XXX Mark PCB mutex as DUPOK to prevent "duplicated lock of 2054f2bb1caeSJulian Elischer * the same type" message. When accepting new L2CAP connection 2055f2bb1caeSJulian Elischer * ng_btsocket_l2cap_process_l2ca_con_ind() holds both PCB mutexes 2056f2bb1caeSJulian Elischer * for "old" (accepting) PCB and "new" (created) PCB. 2057f2bb1caeSJulian Elischer */ 2058f2bb1caeSJulian Elischer 2059f2bb1caeSJulian Elischer mtx_init(&pcb->pcb_mtx, "btsocks_l2cap_pcb_mtx", NULL, 2060f2bb1caeSJulian Elischer MTX_DEF|MTX_DUPOK); 20613d1592efSJohn Baldwin callout_init_mtx(&pcb->timo, &pcb->pcb_mtx, 0); 2062f2bb1caeSJulian Elischer 2063f2bb1caeSJulian Elischer /* 2064f2bb1caeSJulian Elischer * Add the PCB to the list 2065f2bb1caeSJulian Elischer * 2066f2bb1caeSJulian Elischer * XXX FIXME VERY IMPORTANT! 2067f2bb1caeSJulian Elischer * 2068f2bb1caeSJulian Elischer * This is totally FUBAR. We could get here in two cases: 2069f2bb1caeSJulian Elischer * 2070f2bb1caeSJulian Elischer * 1) When user calls socket() 2071053359b7SPedro F. Giffuni * 2) When we need to accept new incoming connection and call 2072f2bb1caeSJulian Elischer * sonewconn() 2073f2bb1caeSJulian Elischer * 2074e1e8f51bSRobert Watson * In the first case we must acquire ng_btsocket_l2cap_sockets_mtx. 2075f2bb1caeSJulian Elischer * In the second case we hold ng_btsocket_l2cap_sockets_mtx already. 2076f2bb1caeSJulian Elischer * So we now need to distinguish between these cases. From reading 20772701afd0SMaxim Konovalov * /sys/kern/uipc_socket.c we can find out that sonewconn() calls 2078f2bb1caeSJulian Elischer * pru_attach with proto == 0 and td == NULL. For now use this fact 2079f2bb1caeSJulian Elischer * to figure out if we were called from socket() or from sonewconn(). 2080f2bb1caeSJulian Elischer */ 2081f2bb1caeSJulian Elischer 2082f2bb1caeSJulian Elischer if (td != NULL) 2083878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2084f2bb1caeSJulian Elischer else 2085f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2086f2bb1caeSJulian Elischer 2087f2bb1caeSJulian Elischer /* Set PCB token. Use ng_btsocket_l2cap_sockets_mtx for protection */ 2088f2bb1caeSJulian Elischer if (++ token == 0) 2089f2bb1caeSJulian Elischer token ++; 2090f2bb1caeSJulian Elischer 2091f2bb1caeSJulian Elischer pcb->token = token; 2092f2bb1caeSJulian Elischer 2093878ed226SJulian Elischer LIST_INSERT_HEAD(&ng_btsocket_l2cap_sockets, pcb, next); 2094f2bb1caeSJulian Elischer 2095f2bb1caeSJulian Elischer if (td != NULL) 2096878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2097878ed226SJulian Elischer 2098878ed226SJulian Elischer return (0); 2099878ed226SJulian Elischer } /* ng_btsocket_l2cap_attach */ 2100878ed226SJulian Elischer 2101878ed226SJulian Elischer /* 2102878ed226SJulian Elischer * Bind socket 2103878ed226SJulian Elischer */ 2104878ed226SJulian Elischer 2105878ed226SJulian Elischer int 2106878ed226SJulian Elischer ng_btsocket_l2cap_bind(struct socket *so, struct sockaddr *nam, 2107878ed226SJulian Elischer struct thread *td) 2108878ed226SJulian Elischer { 2109878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = NULL; 2110878ed226SJulian Elischer struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2111878ed226SJulian Elischer int psm, error = 0; 2112878ed226SJulian Elischer 2113878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2114878ed226SJulian Elischer return (EINVAL); 2115878ed226SJulian Elischer 2116878ed226SJulian Elischer /* Verify address */ 2117878ed226SJulian Elischer if (sa == NULL) 2118878ed226SJulian Elischer return (EINVAL); 2119878ed226SJulian Elischer if (sa->l2cap_family != AF_BLUETOOTH) 2120878ed226SJulian Elischer return (EAFNOSUPPORT); 2121fbc48c2bSTakanori Watanabe /*For the time being, Not support LE binding.*/ 2122fbc48c2bSTakanori Watanabe if ((sa->l2cap_len != sizeof(*sa))&& 2123fbc48c2bSTakanori Watanabe (sa->l2cap_len != sizeof(struct sockaddr_l2cap_compat))) 2124878ed226SJulian Elischer return (EINVAL); 2125878ed226SJulian Elischer 2126878ed226SJulian Elischer psm = le16toh(sa->l2cap_psm); 2127878ed226SJulian Elischer 2128878ed226SJulian Elischer /* 2129878ed226SJulian Elischer * Check if other socket has this address already (look for exact 2130878ed226SJulian Elischer * match PSM and bdaddr) and assign socket address if it's available. 2131878ed226SJulian Elischer * 2132878ed226SJulian Elischer * Note: socket can be bound to ANY PSM (zero) thus allowing several 2133878ed226SJulian Elischer * channels with the same PSM between the same pair of BD_ADDR'es. 2134878ed226SJulian Elischer */ 2135878ed226SJulian Elischer 2136878ed226SJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2137878ed226SJulian Elischer 2138878ed226SJulian Elischer LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) 2139878ed226SJulian Elischer if (psm != 0 && psm == pcb->psm && 2140878ed226SJulian Elischer bcmp(&pcb->src, &sa->l2cap_bdaddr, sizeof(bdaddr_t)) == 0) 2141878ed226SJulian Elischer break; 2142878ed226SJulian Elischer 2143878ed226SJulian Elischer if (pcb == NULL) { 2144878ed226SJulian Elischer /* Set socket address */ 2145878ed226SJulian Elischer pcb = so2l2cap_pcb(so); 2146878ed226SJulian Elischer if (pcb != NULL) { 2147878ed226SJulian Elischer bcopy(&sa->l2cap_bdaddr, &pcb->src, sizeof(pcb->src)); 2148878ed226SJulian Elischer pcb->psm = psm; 2149878ed226SJulian Elischer } else 2150878ed226SJulian Elischer error = EINVAL; 2151878ed226SJulian Elischer } else 2152878ed226SJulian Elischer error = EADDRINUSE; 2153878ed226SJulian Elischer 2154878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2155878ed226SJulian Elischer 2156878ed226SJulian Elischer return (error); 2157878ed226SJulian Elischer } /* ng_btsocket_l2cap_bind */ 2158878ed226SJulian Elischer 2159878ed226SJulian Elischer /* 2160878ed226SJulian Elischer * Connect socket 2161878ed226SJulian Elischer */ 2162878ed226SJulian Elischer 2163878ed226SJulian Elischer int 2164878ed226SJulian Elischer ng_btsocket_l2cap_connect(struct socket *so, struct sockaddr *nam, 2165878ed226SJulian Elischer struct thread *td) 2166878ed226SJulian Elischer { 2167878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2168fbc48c2bSTakanori Watanabe struct sockaddr_l2cap_compat *sal = (struct sockaddr_l2cap_compat *) nam; 2169878ed226SJulian Elischer struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *)nam; 2170fbc48c2bSTakanori Watanabe struct sockaddr_l2cap ba; 2171878ed226SJulian Elischer ng_btsocket_l2cap_rtentry_t *rt = NULL; 2172878ed226SJulian Elischer int have_src, error = 0; 21733a601a23STakanori Watanabe int idtype = NG_L2CAP_L2CA_IDTYPE_BREDR; 2174878ed226SJulian Elischer /* Check socket */ 2175878ed226SJulian Elischer if (pcb == NULL) 2176878ed226SJulian Elischer return (EINVAL); 2177878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2178878ed226SJulian Elischer return (EINVAL); 2179878ed226SJulian Elischer if (pcb->state == NG_BTSOCKET_L2CAP_CONNECTING) 2180878ed226SJulian Elischer return (EINPROGRESS); 2181878ed226SJulian Elischer 2182878ed226SJulian Elischer /* Verify address */ 2183878ed226SJulian Elischer if (sa == NULL) 2184878ed226SJulian Elischer return (EINVAL); 2185878ed226SJulian Elischer if (sa->l2cap_family != AF_BLUETOOTH) 2186878ed226SJulian Elischer return (EAFNOSUPPORT); 2187fbc48c2bSTakanori Watanabe if (sa->l2cap_len == sizeof(*sal)){ 2188fbc48c2bSTakanori Watanabe bcopy(sal, &ba, sizeof(*sal)); 2189fbc48c2bSTakanori Watanabe sa = &ba; 2190fbc48c2bSTakanori Watanabe sa->l2cap_len = sizeof(*sa); 2191fbc48c2bSTakanori Watanabe sa->l2cap_bdaddr_type = BDADDR_BREDR; 2192fbc48c2bSTakanori Watanabe } 2193878ed226SJulian Elischer if (sa->l2cap_len != sizeof(*sa)) 2194878ed226SJulian Elischer return (EINVAL); 2195fbc48c2bSTakanori Watanabe if ((sa->l2cap_psm && sa->l2cap_cid)) 2196fbc48c2bSTakanori Watanabe return EINVAL; 2197fbc48c2bSTakanori Watanabe if (bcmp(&sa->l2cap_bdaddr, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 2198878ed226SJulian Elischer return (EDESTADDRREQ); 2199fbc48c2bSTakanori Watanabe if((sa->l2cap_bdaddr_type == BDADDR_BREDR)&& 2200fbc48c2bSTakanori Watanabe (sa->l2cap_psm == 0)) 2201fbc48c2bSTakanori Watanabe return EDESTADDRREQ; 22023a601a23STakanori Watanabe if(sa->l2cap_bdaddr_type != BDADDR_BREDR){ 22033a601a23STakanori Watanabe if(sa->l2cap_cid == NG_L2CAP_ATT_CID){ 22043a601a23STakanori Watanabe idtype = NG_L2CAP_L2CA_IDTYPE_ATT; 22053a601a23STakanori Watanabe }else if (sa->l2cap_cid == NG_L2CAP_SMP_CID){ 22063a601a23STakanori Watanabe idtype =NG_L2CAP_L2CA_IDTYPE_SMP; 22073a601a23STakanori Watanabe }else{ 22083a601a23STakanori Watanabe //if cid == 0 idtype = NG_L2CAP_L2CA_IDTYPE_LE; 22093a601a23STakanori Watanabe // Not supported yet 2210fbc48c2bSTakanori Watanabe return EINVAL; 2211fbc48c2bSTakanori Watanabe } 22123a601a23STakanori Watanabe } 2213878ed226SJulian Elischer if (pcb->psm != 0 && pcb->psm != le16toh(sa->l2cap_psm)) 2214878ed226SJulian Elischer return (EINVAL); 2215878ed226SJulian Elischer /* 2216878ed226SJulian Elischer * Routing. Socket should be bound to some source address. The source 2217878ed226SJulian Elischer * address can be ANY. Destination address must be set and it must not 2218878ed226SJulian Elischer * be ANY. If source address is ANY then find first rtentry that has 2219878ed226SJulian Elischer * src != dst. 2220878ed226SJulian Elischer */ 2221878ed226SJulian Elischer 2222f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_rt_mtx); 2223f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2224f2bb1caeSJulian Elischer mtx_lock(&pcb->pcb_mtx); 2225f2bb1caeSJulian Elischer 2226f2bb1caeSJulian Elischer /* Send destination address and PSM */ 2227f2bb1caeSJulian Elischer bcopy(&sa->l2cap_bdaddr, &pcb->dst, sizeof(pcb->dst)); 2228f2bb1caeSJulian Elischer pcb->psm = le16toh(sa->l2cap_psm); 2229fbc48c2bSTakanori Watanabe pcb->dsttype = sa->l2cap_bdaddr_type; 22303a601a23STakanori Watanabe pcb->cid = 0; 22313a601a23STakanori Watanabe pcb->idtype = idtype; 2232878ed226SJulian Elischer pcb->rt = NULL; 2233878ed226SJulian Elischer have_src = bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)); 2234878ed226SJulian Elischer 2235878ed226SJulian Elischer LIST_FOREACH(rt, &ng_btsocket_l2cap_rt, next) { 2236878ed226SJulian Elischer if (rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 2237878ed226SJulian Elischer continue; 2238878ed226SJulian Elischer 2239878ed226SJulian Elischer /* Match src and dst */ 2240878ed226SJulian Elischer if (have_src) { 2241878ed226SJulian Elischer if (bcmp(&pcb->src, &rt->src, sizeof(rt->src)) == 0) 2242878ed226SJulian Elischer break; 2243878ed226SJulian Elischer } else { 2244878ed226SJulian Elischer if (bcmp(&pcb->dst, &rt->src, sizeof(rt->src)) != 0) 2245878ed226SJulian Elischer break; 2246878ed226SJulian Elischer } 2247878ed226SJulian Elischer } 2248878ed226SJulian Elischer 2249878ed226SJulian Elischer if (rt != NULL) { 2250878ed226SJulian Elischer pcb->rt = rt; 2251878ed226SJulian Elischer 2252fbc48c2bSTakanori Watanabe if (!have_src){ 2253878ed226SJulian Elischer bcopy(&rt->src, &pcb->src, sizeof(pcb->src)); 2254fbc48c2bSTakanori Watanabe pcb->srctype = 2255fbc48c2bSTakanori Watanabe (sa->l2cap_bdaddr_type == BDADDR_BREDR)? 22563a601a23STakanori Watanabe BDADDR_BREDR : BDADDR_LE_PUBLIC; 2257fbc48c2bSTakanori Watanabe } 2258878ed226SJulian Elischer } else 2259878ed226SJulian Elischer error = EHOSTUNREACH; 2260878ed226SJulian Elischer 2261878ed226SJulian Elischer /* 2262878ed226SJulian Elischer * Send L2CA_Connect request 2263878ed226SJulian Elischer */ 2264878ed226SJulian Elischer 2265878ed226SJulian Elischer if (error == 0) { 2266878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_con_req(pcb); 2267878ed226SJulian Elischer if (error == 0) { 2268878ed226SJulian Elischer pcb->flags |= NG_BTSOCKET_L2CAP_CLIENT; 2269878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CONNECTING; 2270878ed226SJulian Elischer soisconnecting(pcb->so); 2271878ed226SJulian Elischer 2272878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 2273878ed226SJulian Elischer } 2274878ed226SJulian Elischer } 2275878ed226SJulian Elischer 2276f2bb1caeSJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2277f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2278f2bb1caeSJulian Elischer mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 2279f2bb1caeSJulian Elischer 2280878ed226SJulian Elischer return (error); 2281878ed226SJulian Elischer } /* ng_btsocket_l2cap_connect */ 2282878ed226SJulian Elischer 2283878ed226SJulian Elischer /* 2284878ed226SJulian Elischer * Process ioctl's calls on socket 2285878ed226SJulian Elischer */ 2286878ed226SJulian Elischer 2287878ed226SJulian Elischer int 2288878ed226SJulian Elischer ng_btsocket_l2cap_control(struct socket *so, u_long cmd, caddr_t data, 2289878ed226SJulian Elischer struct ifnet *ifp, struct thread *td) 2290878ed226SJulian Elischer { 2291878ed226SJulian Elischer return (EINVAL); 2292878ed226SJulian Elischer } /* ng_btsocket_l2cap_control */ 2293878ed226SJulian Elischer 2294878ed226SJulian Elischer /* 2295878ed226SJulian Elischer * Process getsockopt/setsockopt system calls 2296878ed226SJulian Elischer */ 2297878ed226SJulian Elischer 2298878ed226SJulian Elischer int 2299878ed226SJulian Elischer ng_btsocket_l2cap_ctloutput(struct socket *so, struct sockopt *sopt) 2300878ed226SJulian Elischer { 2301878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2302878ed226SJulian Elischer int error = 0; 2303878ed226SJulian Elischer ng_l2cap_cfg_opt_val_t v; 2304878ed226SJulian Elischer 2305878ed226SJulian Elischer if (pcb == NULL) 2306878ed226SJulian Elischer return (EINVAL); 2307878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2308878ed226SJulian Elischer return (EINVAL); 2309878ed226SJulian Elischer 2310878ed226SJulian Elischer if (sopt->sopt_level != SOL_L2CAP) 2311878ed226SJulian Elischer return (0); 2312878ed226SJulian Elischer 2313878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2314878ed226SJulian Elischer 2315878ed226SJulian Elischer switch (sopt->sopt_dir) { 2316878ed226SJulian Elischer case SOPT_GET: 2317878ed226SJulian Elischer switch (sopt->sopt_name) { 2318878ed226SJulian Elischer case SO_L2CAP_IMTU: /* get incoming MTU */ 2319878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->imtu, 2320878ed226SJulian Elischer sizeof(pcb->imtu)); 2321878ed226SJulian Elischer break; 2322878ed226SJulian Elischer 2323878ed226SJulian Elischer case SO_L2CAP_OMTU: /* get outgoing (peer incoming) MTU */ 2324878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->omtu, 2325878ed226SJulian Elischer sizeof(pcb->omtu)); 2326878ed226SJulian Elischer break; 2327878ed226SJulian Elischer 2328878ed226SJulian Elischer case SO_L2CAP_IFLOW: /* get incoming flow spec. */ 2329878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->iflow, 2330878ed226SJulian Elischer sizeof(pcb->iflow)); 2331878ed226SJulian Elischer break; 2332878ed226SJulian Elischer 2333878ed226SJulian Elischer case SO_L2CAP_OFLOW: /* get outgoing flow spec. */ 2334878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->oflow, 2335878ed226SJulian Elischer sizeof(pcb->oflow)); 2336878ed226SJulian Elischer break; 2337878ed226SJulian Elischer 2338878ed226SJulian Elischer case SO_L2CAP_FLUSH: /* get flush timeout */ 2339878ed226SJulian Elischer error = sooptcopyout(sopt, &pcb->flush_timo, 2340878ed226SJulian Elischer sizeof(pcb->flush_timo)); 2341878ed226SJulian Elischer break; 23423a601a23STakanori Watanabe case SO_L2CAP_ENCRYPTED: /* get encrypt required */ 23433a601a23STakanori Watanabe error = sooptcopyout(sopt, &pcb->need_encrypt, 23443a601a23STakanori Watanabe sizeof(pcb->need_encrypt)); 23453a601a23STakanori Watanabe break; 23463a601a23STakanori Watanabe 2347878ed226SJulian Elischer 2348878ed226SJulian Elischer default: 2349878ed226SJulian Elischer error = ENOPROTOOPT; 2350878ed226SJulian Elischer break; 2351878ed226SJulian Elischer } 2352878ed226SJulian Elischer break; 2353878ed226SJulian Elischer 2354878ed226SJulian Elischer case SOPT_SET: 2355878ed226SJulian Elischer /* 2356f2bb1caeSJulian Elischer * XXX 2357f2bb1caeSJulian Elischer * We do not allow to change these parameters while socket is 2358f2bb1caeSJulian Elischer * connected or we are in the process of creating a connection. 2359f2bb1caeSJulian Elischer * May be this should indicate re-configuration of the open 2360f2bb1caeSJulian Elischer * channel? 2361878ed226SJulian Elischer */ 2362878ed226SJulian Elischer 2363b64b9bb2SMaksim Yevmenkin if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 2364b64b9bb2SMaksim Yevmenkin error = EACCES; 2365b64b9bb2SMaksim Yevmenkin break; 2366b64b9bb2SMaksim Yevmenkin } 2367878ed226SJulian Elischer 2368878ed226SJulian Elischer switch (sopt->sopt_name) { 2369878ed226SJulian Elischer case SO_L2CAP_IMTU: /* set incoming MTU */ 2370878ed226SJulian Elischer error = sooptcopyin(sopt, &v, sizeof(v), sizeof(v.mtu)); 2371878ed226SJulian Elischer if (error == 0) 2372878ed226SJulian Elischer pcb->imtu = v.mtu; 2373878ed226SJulian Elischer break; 2374878ed226SJulian Elischer 2375878ed226SJulian Elischer case SO_L2CAP_OFLOW: /* set outgoing flow spec. */ 2376878ed226SJulian Elischer error = sooptcopyin(sopt, &v, sizeof(v),sizeof(v.flow)); 2377878ed226SJulian Elischer if (error == 0) 2378878ed226SJulian Elischer bcopy(&v.flow, &pcb->oflow, sizeof(pcb->oflow)); 2379878ed226SJulian Elischer break; 2380878ed226SJulian Elischer 2381878ed226SJulian Elischer case SO_L2CAP_FLUSH: /* set flush timeout */ 2382878ed226SJulian Elischer error = sooptcopyin(sopt, &v, sizeof(v), 2383878ed226SJulian Elischer sizeof(v.flush_timo)); 2384878ed226SJulian Elischer if (error == 0) 2385878ed226SJulian Elischer pcb->flush_timo = v.flush_timo; 2386878ed226SJulian Elischer break; 23873a601a23STakanori Watanabe case SO_L2CAP_ENCRYPTED: /*set connect encryption opt*/ 23883a601a23STakanori Watanabe if((pcb->state != NG_BTSOCKET_L2CAP_OPEN) && 23893a601a23STakanori Watanabe (pcb->state != NG_BTSOCKET_L2CAP_W4_ENC_CHANGE)){ 23903a601a23STakanori Watanabe error = sooptcopyin(sopt, &v, sizeof(v), 23913a601a23STakanori Watanabe sizeof(v.encryption)); 23923a601a23STakanori Watanabe if(error == 0) 23933a601a23STakanori Watanabe pcb->need_encrypt = (v.encryption)?1:0; 23943a601a23STakanori Watanabe }else{ 23953a601a23STakanori Watanabe error = EINVAL; 23963a601a23STakanori Watanabe } 23973a601a23STakanori Watanabe break; 2398878ed226SJulian Elischer default: 2399878ed226SJulian Elischer error = ENOPROTOOPT; 2400878ed226SJulian Elischer break; 2401878ed226SJulian Elischer } 2402878ed226SJulian Elischer break; 2403878ed226SJulian Elischer 2404878ed226SJulian Elischer default: 2405878ed226SJulian Elischer error = EINVAL; 2406878ed226SJulian Elischer break; 2407878ed226SJulian Elischer } 2408878ed226SJulian Elischer 2409878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2410878ed226SJulian Elischer 2411878ed226SJulian Elischer return (error); 2412878ed226SJulian Elischer } /* ng_btsocket_l2cap_ctloutput */ 2413878ed226SJulian Elischer 2414878ed226SJulian Elischer /* 2415878ed226SJulian Elischer * Detach and destroy socket 2416878ed226SJulian Elischer */ 2417878ed226SJulian Elischer 2418bc725eafSRobert Watson void 2419878ed226SJulian Elischer ng_btsocket_l2cap_detach(struct socket *so) 2420878ed226SJulian Elischer { 2421878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2422878ed226SJulian Elischer 2423bc725eafSRobert Watson KASSERT(pcb != NULL, ("ng_btsocket_l2cap_detach: pcb == NULL")); 2424bc725eafSRobert Watson 2425878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2426bc725eafSRobert Watson return; 2427878ed226SJulian Elischer 2428f2bb1caeSJulian Elischer mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2429878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2430878ed226SJulian Elischer 2431878ed226SJulian Elischer /* XXX what to do with pending request? */ 2432878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2433878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 2434878ed226SJulian Elischer 2435878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED && 2436878ed226SJulian Elischer pcb->state != NG_BTSOCKET_L2CAP_DISCONNECTING) 2437878ed226SJulian Elischer /* Send disconnect request with "zero" token */ 2438878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2439878ed226SJulian Elischer 2440878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2441878ed226SJulian Elischer 2442f2bb1caeSJulian Elischer LIST_REMOVE(pcb, next); 2443878ed226SJulian Elischer 2444878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2445878ed226SJulian Elischer mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2446878ed226SJulian Elischer 2447878ed226SJulian Elischer mtx_destroy(&pcb->pcb_mtx); 2448878ed226SJulian Elischer bzero(pcb, sizeof(*pcb)); 24491ede983cSDag-Erling Smørgrav free(pcb, M_NETGRAPH_BTSOCKET_L2CAP); 2450878ed226SJulian Elischer 2451f2bb1caeSJulian Elischer soisdisconnected(so); 2452f2bb1caeSJulian Elischer so->so_pcb = NULL; 2453878ed226SJulian Elischer } /* ng_btsocket_l2cap_detach */ 2454878ed226SJulian Elischer 2455878ed226SJulian Elischer /* 2456878ed226SJulian Elischer * Disconnect socket 2457878ed226SJulian Elischer */ 2458878ed226SJulian Elischer 2459878ed226SJulian Elischer int 2460878ed226SJulian Elischer ng_btsocket_l2cap_disconnect(struct socket *so) 2461878ed226SJulian Elischer { 2462878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2463878ed226SJulian Elischer int error = 0; 2464878ed226SJulian Elischer 2465878ed226SJulian Elischer if (pcb == NULL) 2466878ed226SJulian Elischer return (EINVAL); 2467878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2468878ed226SJulian Elischer return (EINVAL); 2469878ed226SJulian Elischer 2470878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2471878ed226SJulian Elischer 2472878ed226SJulian Elischer if (pcb->state == NG_BTSOCKET_L2CAP_DISCONNECTING) { 2473878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2474878ed226SJulian Elischer return (EINPROGRESS); 2475878ed226SJulian Elischer } 2476878ed226SJulian Elischer 2477878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 2478878ed226SJulian Elischer /* XXX FIXME what to do with pending request? */ 2479878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2480878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(pcb); 2481878ed226SJulian Elischer 2482878ed226SJulian Elischer error = ng_btsocket_l2cap_send_l2ca_discon_req(pcb->token, pcb); 2483878ed226SJulian Elischer if (error == 0) { 2484878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_DISCONNECTING; 2485878ed226SJulian Elischer soisdisconnecting(so); 2486878ed226SJulian Elischer 2487878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 2488878ed226SJulian Elischer } 2489878ed226SJulian Elischer 2490878ed226SJulian Elischer /* XXX FIXME what to do if error != 0 */ 2491878ed226SJulian Elischer } 2492878ed226SJulian Elischer 2493878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2494878ed226SJulian Elischer 2495878ed226SJulian Elischer return (error); 2496878ed226SJulian Elischer } /* ng_btsocket_l2cap_disconnect */ 2497878ed226SJulian Elischer 2498878ed226SJulian Elischer /* 2499878ed226SJulian Elischer * Listen on socket 2500878ed226SJulian Elischer */ 2501878ed226SJulian Elischer 2502878ed226SJulian Elischer int 2503d374e81eSRobert Watson ng_btsocket_l2cap_listen(struct socket *so, int backlog, struct thread *td) 2504878ed226SJulian Elischer { 2505878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 25060daccb9cSRobert Watson int error; 2507878ed226SJulian Elischer 25080daccb9cSRobert Watson SOCK_LOCK(so); 25090daccb9cSRobert Watson error = solisten_proto_check(so); 25100daccb9cSRobert Watson if (error != 0) 25110daccb9cSRobert Watson goto out; 25120daccb9cSRobert Watson if (pcb == NULL) { 25130daccb9cSRobert Watson error = EINVAL; 25140daccb9cSRobert Watson goto out; 25150daccb9cSRobert Watson } 25160daccb9cSRobert Watson if (ng_btsocket_l2cap_node == NULL) { 25170daccb9cSRobert Watson error = EINVAL; 25180daccb9cSRobert Watson goto out; 25190daccb9cSRobert Watson } 25200daccb9cSRobert Watson if (pcb->psm == 0) { 2521d46210e6SMaksim Yevmenkin error = EADDRNOTAVAIL; 25220daccb9cSRobert Watson goto out; 25230daccb9cSRobert Watson } 2524d374e81eSRobert Watson solisten_proto(so, backlog); 25250daccb9cSRobert Watson out: 25260daccb9cSRobert Watson SOCK_UNLOCK(so); 25270daccb9cSRobert Watson return (error); 2528878ed226SJulian Elischer } /* ng_btsocket_listen */ 2529878ed226SJulian Elischer 2530878ed226SJulian Elischer /* 2531878ed226SJulian Elischer * Get peer address 2532878ed226SJulian Elischer */ 2533878ed226SJulian Elischer 2534878ed226SJulian Elischer int 2535878ed226SJulian Elischer ng_btsocket_l2cap_peeraddr(struct socket *so, struct sockaddr **nam) 2536878ed226SJulian Elischer { 2537878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2538878ed226SJulian Elischer struct sockaddr_l2cap sa; 2539878ed226SJulian Elischer 2540878ed226SJulian Elischer if (pcb == NULL) 2541878ed226SJulian Elischer return (EINVAL); 2542878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2543878ed226SJulian Elischer return (EINVAL); 2544878ed226SJulian Elischer 2545878ed226SJulian Elischer bcopy(&pcb->dst, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2546878ed226SJulian Elischer sa.l2cap_psm = htole16(pcb->psm); 2547878ed226SJulian Elischer sa.l2cap_len = sizeof(sa); 2548878ed226SJulian Elischer sa.l2cap_family = AF_BLUETOOTH; 25493a601a23STakanori Watanabe switch(pcb->idtype){ 25503a601a23STakanori Watanabe case NG_L2CAP_L2CA_IDTYPE_ATT: 25513a601a23STakanori Watanabe sa.l2cap_cid = NG_L2CAP_ATT_CID; 25523a601a23STakanori Watanabe break; 25533a601a23STakanori Watanabe case NG_L2CAP_L2CA_IDTYPE_SMP: 25543a601a23STakanori Watanabe sa.l2cap_cid = NG_L2CAP_SMP_CID; 25553a601a23STakanori Watanabe break; 25563a601a23STakanori Watanabe default: 2557fbc48c2bSTakanori Watanabe sa.l2cap_cid = 0; 25583a601a23STakanori Watanabe break; 25593a601a23STakanori Watanabe } 2560fbc48c2bSTakanori Watanabe sa.l2cap_bdaddr_type = pcb->dsttype; 2561746e5bf0SRobert Watson *nam = sodupsockaddr((struct sockaddr *) &sa, M_NOWAIT); 2562878ed226SJulian Elischer 2563878ed226SJulian Elischer return ((*nam == NULL)? ENOMEM : 0); 2564878ed226SJulian Elischer } /* ng_btsocket_l2cap_peeraddr */ 2565878ed226SJulian Elischer 2566878ed226SJulian Elischer /* 2567878ed226SJulian Elischer * Send data to socket 2568878ed226SJulian Elischer */ 2569878ed226SJulian Elischer 2570878ed226SJulian Elischer int 2571878ed226SJulian Elischer ng_btsocket_l2cap_send(struct socket *so, int flags, struct mbuf *m, 2572878ed226SJulian Elischer struct sockaddr *nam, struct mbuf *control, struct thread *td) 2573878ed226SJulian Elischer { 2574878ed226SJulian Elischer ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2575878ed226SJulian Elischer int error = 0; 2576878ed226SJulian Elischer 2577878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) { 2578878ed226SJulian Elischer error = ENETDOWN; 2579878ed226SJulian Elischer goto drop; 2580878ed226SJulian Elischer } 2581878ed226SJulian Elischer 2582878ed226SJulian Elischer /* Check socket and input */ 2583878ed226SJulian Elischer if (pcb == NULL || m == NULL || control != NULL) { 2584878ed226SJulian Elischer error = EINVAL; 2585878ed226SJulian Elischer goto drop; 2586878ed226SJulian Elischer } 2587878ed226SJulian Elischer 2588878ed226SJulian Elischer mtx_lock(&pcb->pcb_mtx); 2589878ed226SJulian Elischer 2590878ed226SJulian Elischer /* Make sure socket is connected */ 2591878ed226SJulian Elischer if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 2592878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2593878ed226SJulian Elischer error = ENOTCONN; 2594878ed226SJulian Elischer goto drop; 2595878ed226SJulian Elischer } 2596878ed226SJulian Elischer 2597878ed226SJulian Elischer /* Check route */ 2598878ed226SJulian Elischer if (pcb->rt == NULL || 2599878ed226SJulian Elischer pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) { 2600878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2601878ed226SJulian Elischer error = ENETDOWN; 2602878ed226SJulian Elischer goto drop; 2603878ed226SJulian Elischer } 2604878ed226SJulian Elischer 2605053359b7SPedro F. Giffuni /* Check packet size against outgoing (peer's incoming) MTU) */ 2606878ed226SJulian Elischer if (m->m_pkthdr.len > pcb->omtu) { 2607878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 2608878ed226SJulian Elischer "%s: Packet too big, len=%d, omtu=%d\n", __func__, m->m_pkthdr.len, pcb->omtu); 2609878ed226SJulian Elischer 2610878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2611878ed226SJulian Elischer error = EMSGSIZE; 2612878ed226SJulian Elischer goto drop; 2613878ed226SJulian Elischer } 2614878ed226SJulian Elischer 2615878ed226SJulian Elischer /* 2616878ed226SJulian Elischer * First put packet on socket send queue. Then check if we have 2617878ed226SJulian Elischer * pending timeout. If we do not have timeout then we must send 2618878ed226SJulian Elischer * packet and schedule timeout. Otherwise do nothing and wait for 2619878ed226SJulian Elischer * L2CA_WRITE_RSP. 2620878ed226SJulian Elischer */ 2621878ed226SJulian Elischer 2622878ed226SJulian Elischer sbappendrecord(&pcb->so->so_snd, m); 2623878ed226SJulian Elischer m = NULL; 2624878ed226SJulian Elischer 2625878ed226SJulian Elischer if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2626878ed226SJulian Elischer error = ng_btsocket_l2cap_send2(pcb); 2627878ed226SJulian Elischer if (error == 0) 2628878ed226SJulian Elischer ng_btsocket_l2cap_timeout(pcb); 2629878ed226SJulian Elischer else 2630878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); /* XXX */ 2631878ed226SJulian Elischer } 2632878ed226SJulian Elischer 2633878ed226SJulian Elischer mtx_unlock(&pcb->pcb_mtx); 2634878ed226SJulian Elischer drop: 2635878ed226SJulian Elischer NG_FREE_M(m); /* checks for != NULL */ 2636878ed226SJulian Elischer NG_FREE_M(control); 2637878ed226SJulian Elischer 2638878ed226SJulian Elischer return (error); 2639878ed226SJulian Elischer } /* ng_btsocket_l2cap_send */ 2640878ed226SJulian Elischer 2641878ed226SJulian Elischer /* 2642878ed226SJulian Elischer * Send first packet in the socket queue to the L2CAP layer 2643878ed226SJulian Elischer */ 2644878ed226SJulian Elischer 2645878ed226SJulian Elischer static int 2646878ed226SJulian Elischer ng_btsocket_l2cap_send2(ng_btsocket_l2cap_pcb_p pcb) 2647878ed226SJulian Elischer { 2648878ed226SJulian Elischer struct mbuf *m = NULL; 2649878ed226SJulian Elischer ng_l2cap_l2ca_hdr_t *hdr = NULL; 2650878ed226SJulian Elischer int error = 0; 2651878ed226SJulian Elischer 2652878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2653878ed226SJulian Elischer 2654cfa6009eSGleb Smirnoff if (sbavail(&pcb->so->so_snd) == 0) 2655878ed226SJulian Elischer return (EINVAL); /* XXX */ 2656878ed226SJulian Elischer 2657eb1b1807SGleb Smirnoff m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); 2658878ed226SJulian Elischer if (m == NULL) 2659878ed226SJulian Elischer return (ENOBUFS); 2660878ed226SJulian Elischer 2661878ed226SJulian Elischer /* Create L2CA packet header */ 2662eb1b1807SGleb Smirnoff M_PREPEND(m, sizeof(*hdr), M_NOWAIT); 2663878ed226SJulian Elischer if (m != NULL) 2664878ed226SJulian Elischer if (m->m_len < sizeof(*hdr)) 2665878ed226SJulian Elischer m = m_pullup(m, sizeof(*hdr)); 2666878ed226SJulian Elischer 2667878ed226SJulian Elischer if (m == NULL) { 2668878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 2669878ed226SJulian Elischer "%s: Failed to create L2CA packet header\n", __func__); 2670878ed226SJulian Elischer 2671878ed226SJulian Elischer return (ENOBUFS); 2672878ed226SJulian Elischer } 2673878ed226SJulian Elischer 2674878ed226SJulian Elischer hdr = mtod(m, ng_l2cap_l2ca_hdr_t *); 2675878ed226SJulian Elischer hdr->token = pcb->token; 2676878ed226SJulian Elischer hdr->length = m->m_pkthdr.len - sizeof(*hdr); 2677878ed226SJulian Elischer hdr->lcid = pcb->cid; 26783a601a23STakanori Watanabe hdr->idtype = pcb->idtype; 2679878ed226SJulian Elischer NG_BTSOCKET_L2CAP_INFO( 2680878ed226SJulian Elischer "%s: Sending packet: len=%d, length=%d, lcid=%d, token=%d, state=%d\n", 2681878ed226SJulian Elischer __func__, m->m_pkthdr.len, hdr->length, hdr->lcid, 2682878ed226SJulian Elischer hdr->token, pcb->state); 2683878ed226SJulian Elischer 2684878ed226SJulian Elischer /* 2685053359b7SPedro F. Giffuni * If we got here than we have successfully creates new L2CAP 2686878ed226SJulian Elischer * data packet and now we can send it to the L2CAP layer 2687878ed226SJulian Elischer */ 2688878ed226SJulian Elischer 2689878ed226SJulian Elischer NG_SEND_DATA_ONLY(error, pcb->rt->hook, m); 2690878ed226SJulian Elischer 2691878ed226SJulian Elischer return (error); 2692878ed226SJulian Elischer } /* ng_btsocket_l2cap_send2 */ 2693878ed226SJulian Elischer 2694878ed226SJulian Elischer /* 2695878ed226SJulian Elischer * Get socket address 2696878ed226SJulian Elischer */ 2697878ed226SJulian Elischer 2698878ed226SJulian Elischer int 2699878ed226SJulian Elischer ng_btsocket_l2cap_sockaddr(struct socket *so, struct sockaddr **nam) 2700878ed226SJulian Elischer { 2701878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2702878ed226SJulian Elischer struct sockaddr_l2cap sa; 2703878ed226SJulian Elischer 2704878ed226SJulian Elischer if (pcb == NULL) 2705878ed226SJulian Elischer return (EINVAL); 2706878ed226SJulian Elischer if (ng_btsocket_l2cap_node == NULL) 2707878ed226SJulian Elischer return (EINVAL); 2708878ed226SJulian Elischer 2709878ed226SJulian Elischer bcopy(&pcb->src, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2710878ed226SJulian Elischer sa.l2cap_psm = htole16(pcb->psm); 2711878ed226SJulian Elischer sa.l2cap_len = sizeof(sa); 2712878ed226SJulian Elischer sa.l2cap_family = AF_BLUETOOTH; 2713fbc48c2bSTakanori Watanabe sa.l2cap_cid = 0; 2714fbc48c2bSTakanori Watanabe sa.l2cap_bdaddr_type = pcb->srctype; 2715878ed226SJulian Elischer 2716746e5bf0SRobert Watson *nam = sodupsockaddr((struct sockaddr *) &sa, M_NOWAIT); 2717878ed226SJulian Elischer 2718878ed226SJulian Elischer return ((*nam == NULL)? ENOMEM : 0); 2719878ed226SJulian Elischer } /* ng_btsocket_l2cap_sockaddr */ 2720878ed226SJulian Elischer 2721878ed226SJulian Elischer /***************************************************************************** 2722878ed226SJulian Elischer ***************************************************************************** 2723878ed226SJulian Elischer ** Misc. functions 2724878ed226SJulian Elischer ***************************************************************************** 2725878ed226SJulian Elischer *****************************************************************************/ 2726878ed226SJulian Elischer 2727878ed226SJulian Elischer /* 2728878ed226SJulian Elischer * Look for the socket that listens on given PSM and bdaddr. Returns exact or 2729f2bb1caeSJulian Elischer * close match (if any). Caller must hold ng_btsocket_l2cap_sockets_mtx. 2730878ed226SJulian Elischer */ 2731878ed226SJulian Elischer 2732878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p 2733878ed226SJulian Elischer ng_btsocket_l2cap_pcb_by_addr(bdaddr_p bdaddr, int psm) 2734878ed226SJulian Elischer { 2735878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p p = NULL, p1 = NULL; 2736878ed226SJulian Elischer 2737f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2738878ed226SJulian Elischer 2739878ed226SJulian Elischer LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) { 2740878ed226SJulian Elischer if (p->so == NULL || !(p->so->so_options & SO_ACCEPTCONN) || 2741878ed226SJulian Elischer p->psm != psm) 2742878ed226SJulian Elischer continue; 2743878ed226SJulian Elischer 2744878ed226SJulian Elischer if (bcmp(&p->src, bdaddr, sizeof(p->src)) == 0) 2745878ed226SJulian Elischer break; 2746878ed226SJulian Elischer 2747878ed226SJulian Elischer if (bcmp(&p->src, NG_HCI_BDADDR_ANY, sizeof(p->src)) == 0) 2748878ed226SJulian Elischer p1 = p; 2749878ed226SJulian Elischer } 2750878ed226SJulian Elischer 2751878ed226SJulian Elischer return ((p != NULL)? p : p1); 2752878ed226SJulian Elischer } /* ng_btsocket_l2cap_pcb_by_addr */ 2753878ed226SJulian Elischer 2754878ed226SJulian Elischer /* 2755f2bb1caeSJulian Elischer * Look for the socket that has given token. 2756f2bb1caeSJulian Elischer * Caller must hold ng_btsocket_l2cap_sockets_mtx. 2757878ed226SJulian Elischer */ 2758878ed226SJulian Elischer 2759878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p 2760878ed226SJulian Elischer ng_btsocket_l2cap_pcb_by_token(u_int32_t token) 2761878ed226SJulian Elischer { 2762878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p p = NULL; 2763878ed226SJulian Elischer 2764f2bb1caeSJulian Elischer if (token == 0) 2765f2bb1caeSJulian Elischer return (NULL); 2766f2bb1caeSJulian Elischer 2767f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2768878ed226SJulian Elischer 2769878ed226SJulian Elischer LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2770878ed226SJulian Elischer if (p->token == token) 2771878ed226SJulian Elischer break; 2772878ed226SJulian Elischer 2773878ed226SJulian Elischer return (p); 2774878ed226SJulian Elischer } /* ng_btsocket_l2cap_pcb_by_token */ 2775878ed226SJulian Elischer 2776878ed226SJulian Elischer /* 2777f2bb1caeSJulian Elischer * Look for the socket that assigned to given source address and channel ID. 2778f2bb1caeSJulian Elischer * Caller must hold ng_btsocket_l2cap_sockets_mtx 2779878ed226SJulian Elischer */ 2780878ed226SJulian Elischer 2781878ed226SJulian Elischer static ng_btsocket_l2cap_pcb_p 2782fbc48c2bSTakanori Watanabe ng_btsocket_l2cap_pcb_by_cid(bdaddr_p src, int cid, int idtype) 2783878ed226SJulian Elischer { 2784878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p p = NULL; 2785878ed226SJulian Elischer 2786f2bb1caeSJulian Elischer mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2787878ed226SJulian Elischer 2788fbc48c2bSTakanori Watanabe LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next){ 2789fbc48c2bSTakanori Watanabe if (p->cid == cid && 2790fbc48c2bSTakanori Watanabe bcmp(src, &p->src, sizeof(p->src)) == 0&& 27913a601a23STakanori Watanabe p->idtype == idtype) 2792878ed226SJulian Elischer break; 2793878ed226SJulian Elischer 2794fbc48c2bSTakanori Watanabe } 2795878ed226SJulian Elischer return (p); 2796878ed226SJulian Elischer } /* ng_btsocket_l2cap_pcb_by_cid */ 2797878ed226SJulian Elischer 2798878ed226SJulian Elischer /* 2799878ed226SJulian Elischer * Set timeout on socket 2800878ed226SJulian Elischer */ 2801878ed226SJulian Elischer 2802878ed226SJulian Elischer static void 2803878ed226SJulian Elischer ng_btsocket_l2cap_timeout(ng_btsocket_l2cap_pcb_p pcb) 2804878ed226SJulian Elischer { 2805878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2806878ed226SJulian Elischer 2807878ed226SJulian Elischer if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2808878ed226SJulian Elischer pcb->flags |= NG_BTSOCKET_L2CAP_TIMO; 28093d1592efSJohn Baldwin callout_reset(&pcb->timo, bluetooth_l2cap_ertx_timeout(), 28103d1592efSJohn Baldwin ng_btsocket_l2cap_process_timeout, pcb); 2811878ed226SJulian Elischer } else 2812878ed226SJulian Elischer KASSERT(0, 2813878ed226SJulian Elischer ("%s: Duplicated socket timeout?!\n", __func__)); 2814878ed226SJulian Elischer } /* ng_btsocket_l2cap_timeout */ 2815878ed226SJulian Elischer 2816878ed226SJulian Elischer /* 2817878ed226SJulian Elischer * Unset timeout on socket 2818878ed226SJulian Elischer */ 2819878ed226SJulian Elischer 2820878ed226SJulian Elischer static void 2821878ed226SJulian Elischer ng_btsocket_l2cap_untimeout(ng_btsocket_l2cap_pcb_p pcb) 2822878ed226SJulian Elischer { 2823878ed226SJulian Elischer mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2824878ed226SJulian Elischer 2825878ed226SJulian Elischer if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) { 28263d1592efSJohn Baldwin callout_stop(&pcb->timo); 2827878ed226SJulian Elischer pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2828878ed226SJulian Elischer } else 2829878ed226SJulian Elischer KASSERT(0, 2830878ed226SJulian Elischer ("%s: No socket timeout?!\n", __func__)); 2831878ed226SJulian Elischer } /* ng_btsocket_l2cap_untimeout */ 2832878ed226SJulian Elischer 2833878ed226SJulian Elischer /* 2834878ed226SJulian Elischer * Process timeout on socket 2835878ed226SJulian Elischer */ 2836878ed226SJulian Elischer 2837878ed226SJulian Elischer static void 2838878ed226SJulian Elischer ng_btsocket_l2cap_process_timeout(void *xpcb) 2839878ed226SJulian Elischer { 2840878ed226SJulian Elischer ng_btsocket_l2cap_pcb_p pcb = (ng_btsocket_l2cap_pcb_p) xpcb; 2841878ed226SJulian Elischer 28423d1592efSJohn Baldwin mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2843878ed226SJulian Elischer 2844878ed226SJulian Elischer pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2845878ed226SJulian Elischer pcb->so->so_error = ETIMEDOUT; 2846878ed226SJulian Elischer 2847878ed226SJulian Elischer switch (pcb->state) { 2848878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_CONNECTING: 2849878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_CONFIGURING: 2850483ed395STakanori Watanabe case NG_BTSOCKET_L2CAP_W4_ENC_CHANGE: 2851878ed226SJulian Elischer /* Send disconnect request with "zero" token */ 2852878ed226SJulian Elischer if (pcb->cid != 0) 2853878ed226SJulian Elischer ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2854878ed226SJulian Elischer 2855878ed226SJulian Elischer /* ... and close the socket */ 2856878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2857878ed226SJulian Elischer soisdisconnected(pcb->so); 2858878ed226SJulian Elischer break; 2859878ed226SJulian Elischer 2860878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_OPEN: 2861878ed226SJulian Elischer /* Send timeout - drop packet and wakeup sender */ 2862878ed226SJulian Elischer sbdroprecord(&pcb->so->so_snd); 2863878ed226SJulian Elischer sowwakeup(pcb->so); 2864878ed226SJulian Elischer break; 2865878ed226SJulian Elischer 2866878ed226SJulian Elischer case NG_BTSOCKET_L2CAP_DISCONNECTING: 2867878ed226SJulian Elischer /* Disconnect timeout - disconnect the socket anyway */ 2868878ed226SJulian Elischer pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2869878ed226SJulian Elischer soisdisconnected(pcb->so); 2870878ed226SJulian Elischer break; 2871878ed226SJulian Elischer 2872878ed226SJulian Elischer default: 2873878ed226SJulian Elischer NG_BTSOCKET_L2CAP_ERR( 2874878ed226SJulian Elischer "%s: Invalid socket state=%d\n", __func__, pcb->state); 2875878ed226SJulian Elischer break; 2876878ed226SJulian Elischer } 2877878ed226SJulian Elischer } /* ng_btsocket_l2cap_process_timeout */ 2878878ed226SJulian Elischer 2879878ed226SJulian Elischer /* 2880878ed226SJulian Elischer * Translate HCI/L2CAP error code into "errno" code 2881878ed226SJulian Elischer * XXX Note: Some L2CAP and HCI error codes have the same value, but 2882878ed226SJulian Elischer * different meaning 2883878ed226SJulian Elischer */ 2884878ed226SJulian Elischer 2885878ed226SJulian Elischer static int 2886878ed226SJulian Elischer ng_btsocket_l2cap_result2errno(int result) 2887878ed226SJulian Elischer { 2888878ed226SJulian Elischer switch (result) { 2889878ed226SJulian Elischer case 0x00: /* No error */ 2890878ed226SJulian Elischer return (0); 2891878ed226SJulian Elischer 2892878ed226SJulian Elischer case 0x01: /* Unknown HCI command */ 2893878ed226SJulian Elischer return (ENODEV); 2894878ed226SJulian Elischer 2895878ed226SJulian Elischer case 0x02: /* No connection */ 2896878ed226SJulian Elischer return (ENOTCONN); 2897878ed226SJulian Elischer 2898878ed226SJulian Elischer case 0x03: /* Hardware failure */ 2899878ed226SJulian Elischer return (EIO); 2900878ed226SJulian Elischer 2901878ed226SJulian Elischer case 0x04: /* Page timeout */ 2902878ed226SJulian Elischer return (EHOSTDOWN); 2903878ed226SJulian Elischer 2904878ed226SJulian Elischer case 0x05: /* Authentication failure */ 2905878ed226SJulian Elischer case 0x06: /* Key missing */ 2906878ed226SJulian Elischer case 0x18: /* Pairing not allowed */ 2907878ed226SJulian Elischer case 0x21: /* Role change not allowed */ 2908878ed226SJulian Elischer case 0x24: /* LMP PSU not allowed */ 2909878ed226SJulian Elischer case 0x25: /* Encryption mode not acceptable */ 2910878ed226SJulian Elischer case 0x26: /* Unit key used */ 2911878ed226SJulian Elischer return (EACCES); 2912878ed226SJulian Elischer 2913878ed226SJulian Elischer case 0x07: /* Memory full */ 2914878ed226SJulian Elischer return (ENOMEM); 2915878ed226SJulian Elischer 2916878ed226SJulian Elischer case 0x08: /* Connection timeout */ 2917878ed226SJulian Elischer case 0x10: /* Host timeout */ 2918878ed226SJulian Elischer case 0x22: /* LMP response timeout */ 2919878ed226SJulian Elischer case 0xee: /* HCI timeout */ 2920878ed226SJulian Elischer case 0xeeee: /* L2CAP timeout */ 2921878ed226SJulian Elischer return (ETIMEDOUT); 2922878ed226SJulian Elischer 2923878ed226SJulian Elischer case 0x09: /* Max number of connections */ 2924878ed226SJulian Elischer case 0x0a: /* Max number of SCO connections to a unit */ 2925878ed226SJulian Elischer return (EMLINK); 2926878ed226SJulian Elischer 2927878ed226SJulian Elischer case 0x0b: /* ACL connection already exists */ 2928878ed226SJulian Elischer return (EEXIST); 2929878ed226SJulian Elischer 2930878ed226SJulian Elischer case 0x0c: /* Command disallowed */ 2931878ed226SJulian Elischer return (EBUSY); 2932878ed226SJulian Elischer 2933878ed226SJulian Elischer case 0x0d: /* Host rejected due to limited resources */ 2934878ed226SJulian Elischer case 0x0e: /* Host rejected due to securiity reasons */ 2935878ed226SJulian Elischer case 0x0f: /* Host rejected due to remote unit is a personal unit */ 2936878ed226SJulian Elischer case 0x1b: /* SCO offset rejected */ 2937878ed226SJulian Elischer case 0x1c: /* SCO interval rejected */ 2938878ed226SJulian Elischer case 0x1d: /* SCO air mode rejected */ 2939878ed226SJulian Elischer return (ECONNREFUSED); 2940878ed226SJulian Elischer 2941878ed226SJulian Elischer case 0x11: /* Unsupported feature or parameter value */ 2942878ed226SJulian Elischer case 0x19: /* Unknown LMP PDU */ 2943878ed226SJulian Elischer case 0x1a: /* Unsupported remote feature */ 2944878ed226SJulian Elischer case 0x20: /* Unsupported LMP parameter value */ 2945878ed226SJulian Elischer case 0x27: /* QoS is not supported */ 2946878ed226SJulian Elischer case 0x29: /* Paring with unit key not supported */ 2947878ed226SJulian Elischer return (EOPNOTSUPP); 2948878ed226SJulian Elischer 2949878ed226SJulian Elischer case 0x12: /* Invalid HCI command parameter */ 2950878ed226SJulian Elischer case 0x1e: /* Invalid LMP parameters */ 2951878ed226SJulian Elischer return (EINVAL); 2952878ed226SJulian Elischer 2953878ed226SJulian Elischer case 0x13: /* Other end terminated connection: User ended connection */ 2954878ed226SJulian Elischer case 0x14: /* Other end terminated connection: Low resources */ 2955878ed226SJulian Elischer case 0x15: /* Other end terminated connection: About to power off */ 2956878ed226SJulian Elischer return (ECONNRESET); 2957878ed226SJulian Elischer 2958878ed226SJulian Elischer case 0x16: /* Connection terminated by local host */ 2959878ed226SJulian Elischer return (ECONNABORTED); 2960878ed226SJulian Elischer 2961878ed226SJulian Elischer #if 0 /* XXX not yet */ 2962878ed226SJulian Elischer case 0x17: /* Repeated attempts */ 2963878ed226SJulian Elischer case 0x1f: /* Unspecified error */ 2964878ed226SJulian Elischer case 0x23: /* LMP error transaction collision */ 2965878ed226SJulian Elischer case 0x28: /* Instant passed */ 2966878ed226SJulian Elischer #endif 2967878ed226SJulian Elischer } 2968878ed226SJulian Elischer 2969878ed226SJulian Elischer return (ENOSYS); 2970878ed226SJulian Elischer } /* ng_btsocket_l2cap_result2errno */ 2971878ed226SJulian Elischer 2972