ng_btsocket_l2cap.c revision 184205
1107120Sjulian/* 2107120Sjulian * ng_btsocket_l2cap.c 3139823Simp */ 4139823Simp 5139823Simp/*- 6107120Sjulian * Copyright (c) 2001-2002 Maksim Yevmenkin <m_evmenkin@yahoo.com> 7107120Sjulian * All rights reserved. 8107120Sjulian * 9107120Sjulian * Redistribution and use in source and binary forms, with or without 10107120Sjulian * modification, are permitted provided that the following conditions 11107120Sjulian * are met: 12107120Sjulian * 1. Redistributions of source code must retain the above copyright 13107120Sjulian * notice, this list of conditions and the following disclaimer. 14107120Sjulian * 2. Redistributions in binary form must reproduce the above copyright 15107120Sjulian * notice, this list of conditions and the following disclaimer in the 16107120Sjulian * documentation and/or other materials provided with the distribution. 17107120Sjulian * 18107120Sjulian * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 19107120Sjulian * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 20107120Sjulian * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 21107120Sjulian * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 22107120Sjulian * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 23107120Sjulian * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 24107120Sjulian * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 25107120Sjulian * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 26107120Sjulian * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 27107120Sjulian * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 28107120Sjulian * SUCH DAMAGE. 29107120Sjulian * 30121054Semax * $Id: ng_btsocket_l2cap.c,v 1.16 2003/09/14 23:29:06 max Exp $ 31107120Sjulian * $FreeBSD: head/sys/netgraph/bluetooth/socket/ng_btsocket_l2cap.c 184205 2008-10-23 15:53:51Z des $ 32107120Sjulian */ 33107120Sjulian 34107120Sjulian#include <sys/param.h> 35107120Sjulian#include <sys/systm.h> 36121054Semax#include <sys/bitstring.h> 37107120Sjulian#include <sys/domain.h> 38107120Sjulian#include <sys/endian.h> 39107120Sjulian#include <sys/errno.h> 40107120Sjulian#include <sys/filedesc.h> 41107120Sjulian#include <sys/ioccom.h> 42107120Sjulian#include <sys/kernel.h> 43107120Sjulian#include <sys/lock.h> 44107120Sjulian#include <sys/malloc.h> 45107120Sjulian#include <sys/mbuf.h> 46107120Sjulian#include <sys/mutex.h> 47107120Sjulian#include <sys/protosw.h> 48107120Sjulian#include <sys/queue.h> 49107120Sjulian#include <sys/socket.h> 50107120Sjulian#include <sys/socketvar.h> 51107120Sjulian#include <sys/sysctl.h> 52107120Sjulian#include <sys/taskqueue.h> 53107120Sjulian#include <netgraph/ng_message.h> 54107120Sjulian#include <netgraph/netgraph.h> 55128688Semax#include <netgraph/bluetooth/include/ng_bluetooth.h> 56128688Semax#include <netgraph/bluetooth/include/ng_hci.h> 57128688Semax#include <netgraph/bluetooth/include/ng_l2cap.h> 58128688Semax#include <netgraph/bluetooth/include/ng_btsocket.h> 59128688Semax#include <netgraph/bluetooth/include/ng_btsocket_l2cap.h> 60107120Sjulian 61107120Sjulian/* MALLOC define */ 62107120Sjulian#ifdef NG_SEPARATE_MALLOC 63107120SjulianMALLOC_DEFINE(M_NETGRAPH_BTSOCKET_L2CAP, "netgraph_btsocks_l2cap", 64107120Sjulian "Netgraph Bluetooth L2CAP sockets"); 65107120Sjulian#else 66107120Sjulian#define M_NETGRAPH_BTSOCKET_L2CAP M_NETGRAPH 67107120Sjulian#endif /* NG_SEPARATE_MALLOC */ 68107120Sjulian 69107120Sjulian/* Netgraph node methods */ 70107120Sjulianstatic ng_constructor_t ng_btsocket_l2cap_node_constructor; 71107120Sjulianstatic ng_rcvmsg_t ng_btsocket_l2cap_node_rcvmsg; 72107120Sjulianstatic ng_shutdown_t ng_btsocket_l2cap_node_shutdown; 73107120Sjulianstatic ng_newhook_t ng_btsocket_l2cap_node_newhook; 74107120Sjulianstatic ng_connect_t ng_btsocket_l2cap_node_connect; 75107120Sjulianstatic ng_rcvdata_t ng_btsocket_l2cap_node_rcvdata; 76107120Sjulianstatic ng_disconnect_t ng_btsocket_l2cap_node_disconnect; 77107120Sjulian 78107120Sjulianstatic void ng_btsocket_l2cap_input (void *, int); 79107120Sjulianstatic void ng_btsocket_l2cap_rtclean (void *, int); 80107120Sjulian 81107120Sjulian/* Netgraph type descriptor */ 82107120Sjulianstatic struct ng_type typestruct = { 83129823Sjulian .version = NG_ABI_VERSION, 84129823Sjulian .name = NG_BTSOCKET_L2CAP_NODE_TYPE, 85129823Sjulian .constructor = ng_btsocket_l2cap_node_constructor, 86129823Sjulian .rcvmsg = ng_btsocket_l2cap_node_rcvmsg, 87129823Sjulian .shutdown = ng_btsocket_l2cap_node_shutdown, 88129823Sjulian .newhook = ng_btsocket_l2cap_node_newhook, 89129823Sjulian .connect = ng_btsocket_l2cap_node_connect, 90129823Sjulian .rcvdata = ng_btsocket_l2cap_node_rcvdata, 91129823Sjulian .disconnect = ng_btsocket_l2cap_node_disconnect, 92107120Sjulian}; 93107120Sjulian 94107120Sjulian/* Globals */ 95107120Sjulianextern int ifqmaxlen; 96107120Sjulianstatic u_int32_t ng_btsocket_l2cap_debug_level; 97107120Sjulianstatic node_p ng_btsocket_l2cap_node; 98107120Sjulianstatic struct ng_bt_itemq ng_btsocket_l2cap_queue; 99107120Sjulianstatic struct mtx ng_btsocket_l2cap_queue_mtx; 100107120Sjulianstatic struct task ng_btsocket_l2cap_queue_task; 101107120Sjulianstatic LIST_HEAD(, ng_btsocket_l2cap_pcb) ng_btsocket_l2cap_sockets; 102107120Sjulianstatic struct mtx ng_btsocket_l2cap_sockets_mtx; 103107120Sjulianstatic LIST_HEAD(, ng_btsocket_l2cap_rtentry) ng_btsocket_l2cap_rt; 104107120Sjulianstatic struct mtx ng_btsocket_l2cap_rt_mtx; 105107120Sjulianstatic struct task ng_btsocket_l2cap_rt_task; 106181093Semaxstatic struct timeval ng_btsocket_l2cap_lasttime; 107181093Semaxstatic int ng_btsocket_l2cap_curpps; 108107120Sjulian 109107120Sjulian/* Sysctl tree */ 110107120SjulianSYSCTL_DECL(_net_bluetooth_l2cap_sockets); 111107120SjulianSYSCTL_NODE(_net_bluetooth_l2cap_sockets, OID_AUTO, seq, CTLFLAG_RW, 112107120Sjulian 0, "Bluetooth SEQPACKET L2CAP sockets family"); 113107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, debug_level, 114107120Sjulian CTLFLAG_RW, 115107120Sjulian &ng_btsocket_l2cap_debug_level, NG_BTSOCKET_WARN_LEVEL, 116107120Sjulian "Bluetooth SEQPACKET L2CAP sockets debug level"); 117107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_len, 118107120Sjulian CTLFLAG_RD, 119107120Sjulian &ng_btsocket_l2cap_queue.len, 0, 120107120Sjulian "Bluetooth SEQPACKET L2CAP sockets input queue length"); 121107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_maxlen, 122107120Sjulian CTLFLAG_RD, 123107120Sjulian &ng_btsocket_l2cap_queue.maxlen, 0, 124107120Sjulian "Bluetooth SEQPACKET L2CAP sockets input queue max. length"); 125107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_drops, 126107120Sjulian CTLFLAG_RD, 127107120Sjulian &ng_btsocket_l2cap_queue.drops, 0, 128107120Sjulian "Bluetooth SEQPACKET L2CAP sockets input queue drops"); 129107120Sjulian 130107120Sjulian/* Debug */ 131107120Sjulian#define NG_BTSOCKET_L2CAP_INFO \ 132181093Semax if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_INFO_LEVEL && \ 133181093Semax ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 134107120Sjulian printf 135107120Sjulian 136107120Sjulian#define NG_BTSOCKET_L2CAP_WARN \ 137181093Semax if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_WARN_LEVEL && \ 138181093Semax ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 139107120Sjulian printf 140107120Sjulian 141107120Sjulian#define NG_BTSOCKET_L2CAP_ERR \ 142181093Semax if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ERR_LEVEL && \ 143181093Semax ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 144107120Sjulian printf 145107120Sjulian 146107120Sjulian#define NG_BTSOCKET_L2CAP_ALERT \ 147181093Semax if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ALERT_LEVEL && \ 148181093Semax ppsratecheck(&ng_btsocket_l2cap_lasttime, &ng_btsocket_l2cap_curpps, 1)) \ 149107120Sjulian printf 150107120Sjulian 151107120Sjulian/* 152107120Sjulian * Netgraph message processing routines 153107120Sjulian */ 154107120Sjulian 155107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_con_req_rsp 156161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 157107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_con_rsp_rsp 158161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 159107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_con_ind 160161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 161107120Sjulian 162107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_cfg_req_rsp 163161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 164107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp 165161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 166107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_cfg_ind 167161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 168107120Sjulian 169107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_discon_rsp 170161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 171107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_discon_ind 172161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 173107120Sjulian 174107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_write_rsp 175161623Semax (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p); 176107120Sjulian 177107120Sjulian/* 178107120Sjulian * Send L2CA_xxx messages to the lower layer 179107120Sjulian */ 180107120Sjulian 181107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_con_req 182107120Sjulian (ng_btsocket_l2cap_pcb_p); 183107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_con_rsp_req 184107120Sjulian (u_int32_t, ng_btsocket_l2cap_rtentry_p, bdaddr_p, int, int, int); 185107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_cfg_req 186107120Sjulian (ng_btsocket_l2cap_pcb_p); 187107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_cfg_rsp 188107120Sjulian (ng_btsocket_l2cap_pcb_p); 189107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_discon_req 190107120Sjulian (u_int32_t, ng_btsocket_l2cap_pcb_p); 191107120Sjulian 192107120Sjulianstatic int ng_btsocket_l2cap_send2 193107120Sjulian (ng_btsocket_l2cap_pcb_p); 194107120Sjulian 195107120Sjulian/* 196107120Sjulian * Timeout processing routines 197107120Sjulian */ 198107120Sjulian 199107120Sjulianstatic void ng_btsocket_l2cap_timeout (ng_btsocket_l2cap_pcb_p); 200107120Sjulianstatic void ng_btsocket_l2cap_untimeout (ng_btsocket_l2cap_pcb_p); 201107120Sjulianstatic void ng_btsocket_l2cap_process_timeout (void *); 202107120Sjulian 203107120Sjulian/* 204107120Sjulian * Other stuff 205107120Sjulian */ 206107120Sjulian 207107120Sjulianstatic ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_addr(bdaddr_p, int); 208107120Sjulianstatic ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_token(u_int32_t); 209107120Sjulianstatic ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_cid (bdaddr_p, int); 210107120Sjulianstatic int ng_btsocket_l2cap_result2errno(int); 211107120Sjulian 212114878Sjulian#define ng_btsocket_l2cap_wakeup_input_task() \ 213114878Sjulian taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_queue_task) 214114878Sjulian 215114878Sjulian#define ng_btsocket_l2cap_wakeup_route_task() \ 216114878Sjulian taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_rt_task) 217114878Sjulian 218107120Sjulian/***************************************************************************** 219107120Sjulian ***************************************************************************** 220107120Sjulian ** Netgraph node interface 221107120Sjulian ***************************************************************************** 222107120Sjulian *****************************************************************************/ 223107120Sjulian 224107120Sjulian/* 225107120Sjulian * Netgraph node constructor. Do not allow to create node of this type. 226107120Sjulian */ 227107120Sjulian 228107120Sjulianstatic int 229107120Sjulianng_btsocket_l2cap_node_constructor(node_p node) 230107120Sjulian{ 231107120Sjulian return (EINVAL); 232107120Sjulian} /* ng_btsocket_l2cap_node_constructor */ 233107120Sjulian 234107120Sjulian/* 235107120Sjulian * Do local shutdown processing. Let old node go and create new fresh one. 236107120Sjulian */ 237107120Sjulian 238107120Sjulianstatic int 239107120Sjulianng_btsocket_l2cap_node_shutdown(node_p node) 240107120Sjulian{ 241107120Sjulian int error = 0; 242107120Sjulian 243107120Sjulian NG_NODE_UNREF(node); 244107120Sjulian 245107120Sjulian /* Create new node */ 246107120Sjulian error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 247107120Sjulian if (error != 0) { 248107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 249107120Sjulian"%s: Could not create Netgraph node, error=%d\n", __func__, error); 250107120Sjulian 251107120Sjulian ng_btsocket_l2cap_node = NULL; 252107120Sjulian 253107120Sjulian return (error); 254107120Sjulian } 255107120Sjulian 256107120Sjulian error = ng_name_node(ng_btsocket_l2cap_node, 257107120Sjulian NG_BTSOCKET_L2CAP_NODE_TYPE); 258123812Salfred if (error != 0) { 259107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 260107120Sjulian"%s: Could not name Netgraph node, error=%d\n", __func__, error); 261107120Sjulian 262107120Sjulian NG_NODE_UNREF(ng_btsocket_l2cap_node); 263107120Sjulian ng_btsocket_l2cap_node = NULL; 264107120Sjulian 265107120Sjulian return (error); 266107120Sjulian } 267107120Sjulian 268107120Sjulian return (0); 269107120Sjulian} /* ng_btsocket_l2cap_node_shutdown */ 270107120Sjulian 271107120Sjulian/* 272107120Sjulian * We allow any hook to be connected to the node. 273107120Sjulian */ 274107120Sjulian 275107120Sjulianstatic int 276107120Sjulianng_btsocket_l2cap_node_newhook(node_p node, hook_p hook, char const *name) 277107120Sjulian{ 278107120Sjulian return (0); 279107120Sjulian} /* ng_btsocket_l2cap_node_newhook */ 280107120Sjulian 281107120Sjulian/* 282107120Sjulian * Just say "YEP, that's OK by me!" 283107120Sjulian */ 284107120Sjulian 285107120Sjulianstatic int 286107120Sjulianng_btsocket_l2cap_node_connect(hook_p hook) 287107120Sjulian{ 288107120Sjulian NG_HOOK_SET_PRIVATE(hook, NULL); 289107120Sjulian NG_HOOK_REF(hook); /* Keep extra reference to the hook */ 290107120Sjulian 291107120Sjulian#if 0 292107120Sjulian NG_HOOK_FORCE_QUEUE(NG_HOOK_PEER(hook)); 293107120Sjulian NG_HOOK_FORCE_QUEUE(hook); 294107120Sjulian#endif 295107120Sjulian 296107120Sjulian return (0); 297107120Sjulian} /* ng_btsocket_l2cap_node_connect */ 298107120Sjulian 299107120Sjulian/* 300107120Sjulian * Hook disconnection. Schedule route cleanup task 301107120Sjulian */ 302107120Sjulian 303107120Sjulianstatic int 304107120Sjulianng_btsocket_l2cap_node_disconnect(hook_p hook) 305107120Sjulian{ 306107120Sjulian /* 307107120Sjulian * If hook has private information than we must have this hook in 308107120Sjulian * the routing table and must schedule cleaning for the routing table. 309107120Sjulian * Otherwise hook was connected but we never got "hook_info" message, 310107120Sjulian * so we have never added this hook to the routing table and it save 311107120Sjulian * to just delete it. 312107120Sjulian */ 313107120Sjulian 314107120Sjulian if (NG_HOOK_PRIVATE(hook) != NULL) 315114878Sjulian return (ng_btsocket_l2cap_wakeup_route_task()); 316107120Sjulian 317107120Sjulian NG_HOOK_UNREF(hook); /* Remove extra reference */ 318107120Sjulian 319107120Sjulian return (0); 320107120Sjulian} /* ng_btsocket_l2cap_node_disconnect */ 321107120Sjulian 322107120Sjulian/* 323107120Sjulian * Process incoming messages 324107120Sjulian */ 325107120Sjulian 326107120Sjulianstatic int 327107120Sjulianng_btsocket_l2cap_node_rcvmsg(node_p node, item_p item, hook_p hook) 328107120Sjulian{ 329107120Sjulian struct ng_mesg *msg = NGI_MSG(item); /* item still has message */ 330107120Sjulian int error = 0; 331107120Sjulian 332107120Sjulian if (msg != NULL && msg->header.typecookie == NGM_L2CAP_COOKIE) { 333107120Sjulian mtx_lock(&ng_btsocket_l2cap_queue_mtx); 334107120Sjulian if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 335107120Sjulian NG_BTSOCKET_L2CAP_ERR( 336107120Sjulian"%s: Input queue is full (msg)\n", __func__); 337107120Sjulian 338107120Sjulian NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 339107120Sjulian NG_FREE_ITEM(item); 340107120Sjulian error = ENOBUFS; 341107120Sjulian } else { 342107120Sjulian if (hook != NULL) { 343107120Sjulian NG_HOOK_REF(hook); 344107120Sjulian NGI_SET_HOOK(item, hook); 345107120Sjulian } 346107120Sjulian 347107120Sjulian NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 348114878Sjulian error = ng_btsocket_l2cap_wakeup_input_task(); 349107120Sjulian } 350107120Sjulian mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 351107120Sjulian } else { 352107120Sjulian NG_FREE_ITEM(item); 353107120Sjulian error = EINVAL; 354107120Sjulian } 355107120Sjulian 356107120Sjulian return (error); 357107120Sjulian} /* ng_btsocket_l2cap_node_rcvmsg */ 358107120Sjulian 359107120Sjulian/* 360107120Sjulian * Receive data on a hook 361107120Sjulian */ 362107120Sjulian 363107120Sjulianstatic int 364107120Sjulianng_btsocket_l2cap_node_rcvdata(hook_p hook, item_p item) 365107120Sjulian{ 366107120Sjulian int error = 0; 367107120Sjulian 368107120Sjulian mtx_lock(&ng_btsocket_l2cap_queue_mtx); 369107120Sjulian if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 370107120Sjulian NG_BTSOCKET_L2CAP_ERR( 371107120Sjulian"%s: Input queue is full (data)\n", __func__); 372107120Sjulian 373107120Sjulian NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 374107120Sjulian NG_FREE_ITEM(item); 375107120Sjulian error = ENOBUFS; 376107120Sjulian } else { 377107120Sjulian NG_HOOK_REF(hook); 378107120Sjulian NGI_SET_HOOK(item, hook); 379107120Sjulian 380107120Sjulian NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 381114878Sjulian error = ng_btsocket_l2cap_wakeup_input_task(); 382107120Sjulian } 383107120Sjulian mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 384107120Sjulian 385107120Sjulian return (error); 386107120Sjulian} /* ng_btsocket_l2cap_node_rcvdata */ 387107120Sjulian 388107120Sjulian/* 389107120Sjulian * Process L2CA_Connect respose. Socket layer must have initiated connection, 390107120Sjulian * so we have to have a socket associated with message token. 391107120Sjulian */ 392107120Sjulian 393107120Sjulianstatic int 394107120Sjulianng_btsocket_l2cap_process_l2ca_con_req_rsp(struct ng_mesg *msg, 395161623Semax ng_btsocket_l2cap_rtentry_p rt) 396107120Sjulian{ 397107120Sjulian ng_l2cap_l2ca_con_op *op = NULL; 398107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 399107120Sjulian int error = 0; 400107120Sjulian 401107120Sjulian if (msg->header.arglen != sizeof(*op)) 402107120Sjulian return (EMSGSIZE); 403107120Sjulian 404107120Sjulian op = (ng_l2cap_l2ca_con_op *)(msg->data); 405107120Sjulian 406114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 407114878Sjulian 408107120Sjulian /* Look for the socket with the token */ 409107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 410114878Sjulian if (pcb == NULL) { 411114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 412107120Sjulian return (ENOENT); 413114878Sjulian } 414107120Sjulian 415107120Sjulian mtx_lock(&pcb->pcb_mtx); 416107120Sjulian 417107120Sjulian NG_BTSOCKET_L2CAP_INFO( 418107120Sjulian"%s: Got L2CA_Connect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 419107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, status=%d, " \ 420107120Sjulian"state=%d\n", __func__, msg->header.token, 421107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 422107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 423107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 424107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 425107120Sjulian pcb->psm, op->lcid, op->result, op->status, 426107120Sjulian pcb->state); 427107120Sjulian 428107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 429107120Sjulian mtx_unlock(&pcb->pcb_mtx); 430114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 431114878Sjulian 432107120Sjulian return (ENOENT); 433107120Sjulian } 434107120Sjulian 435107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 436107120Sjulian 437107120Sjulian if (op->result == NG_L2CAP_PENDING) { 438107120Sjulian ng_btsocket_l2cap_timeout(pcb); 439107120Sjulian mtx_unlock(&pcb->pcb_mtx); 440114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 441114878Sjulian 442107120Sjulian return (0); 443107120Sjulian } 444107120Sjulian 445107120Sjulian if (op->result == NG_L2CAP_SUCCESS) { 446107120Sjulian /* 447107120Sjulian * Channel is now open, so update local channel ID and 448107120Sjulian * start configuration process. Source and destination 449107120Sjulian * addresses as well as route must be already set. 450107120Sjulian */ 451107120Sjulian 452107120Sjulian pcb->cid = op->lcid; 453107120Sjulian 454107120Sjulian error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 455107120Sjulian if (error != 0) { 456107120Sjulian /* Send disconnect request with "zero" token */ 457107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 458107120Sjulian 459107120Sjulian /* ... and close the socket */ 460107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 461107120Sjulian soisdisconnected(pcb->so); 462107120Sjulian } else { 463107120Sjulian pcb->cfg_state = NG_BTSOCKET_L2CAP_CFG_IN_SENT; 464107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 465107120Sjulian 466107120Sjulian ng_btsocket_l2cap_timeout(pcb); 467107120Sjulian } 468107120Sjulian } else { 469107120Sjulian /* 470107120Sjulian * We have failed to open connection, so convert result 471107120Sjulian * code to "errno" code and disconnect the socket. Channel 472107120Sjulian * already has been closed. 473107120Sjulian */ 474107120Sjulian 475107120Sjulian pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 476107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 477107120Sjulian soisdisconnected(pcb->so); 478107120Sjulian } 479107120Sjulian 480107120Sjulian mtx_unlock(&pcb->pcb_mtx); 481114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 482107120Sjulian 483107120Sjulian return (error); 484107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_con_req_rsp */ 485107120Sjulian 486107120Sjulian/* 487107120Sjulian * Process L2CA_ConnectRsp response 488107120Sjulian */ 489107120Sjulian 490107120Sjulianstatic int 491107120Sjulianng_btsocket_l2cap_process_l2ca_con_rsp_rsp(struct ng_mesg *msg, 492161623Semax ng_btsocket_l2cap_rtentry_p rt) 493107120Sjulian{ 494107120Sjulian ng_l2cap_l2ca_con_rsp_op *op = NULL; 495107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 496107120Sjulian 497107120Sjulian if (msg->header.arglen != sizeof(*op)) 498107120Sjulian return (EMSGSIZE); 499107120Sjulian 500107120Sjulian op = (ng_l2cap_l2ca_con_rsp_op *)(msg->data); 501107120Sjulian 502114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 503114878Sjulian 504107120Sjulian /* Look for the socket with the token */ 505107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 506114878Sjulian if (pcb == NULL) { 507114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 508107120Sjulian return (ENOENT); 509114878Sjulian } 510107120Sjulian 511107120Sjulian mtx_lock(&pcb->pcb_mtx); 512107120Sjulian 513107120Sjulian NG_BTSOCKET_L2CAP_INFO( 514107120Sjulian"%s: Got L2CA_ConnectRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 515107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 516107120Sjulian __func__, msg->header.token, 517107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 518107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 519107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 520107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 521107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state); 522107120Sjulian 523107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 524107120Sjulian mtx_unlock(&pcb->pcb_mtx); 525114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 526114878Sjulian 527107120Sjulian return (ENOENT); 528107120Sjulian } 529107120Sjulian 530107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 531107120Sjulian 532107120Sjulian /* Check the result and disconnect the socket on failure */ 533107120Sjulian if (op->result != NG_L2CAP_SUCCESS) { 534107120Sjulian /* Close the socket - channel already closed */ 535107120Sjulian pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 536107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 537107120Sjulian soisdisconnected(pcb->so); 538107120Sjulian } else { 539107120Sjulian /* Move to CONFIGURING state and wait for CONFIG_IND */ 540107120Sjulian pcb->cfg_state = 0; 541107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 542107120Sjulian ng_btsocket_l2cap_timeout(pcb); 543107120Sjulian } 544107120Sjulian 545107120Sjulian mtx_unlock(&pcb->pcb_mtx); 546114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 547107120Sjulian 548107120Sjulian return (0); 549107120Sjulian} /* ng_btsocket_process_l2ca_con_rsp_rsp */ 550107120Sjulian 551107120Sjulian/* 552107120Sjulian * Process L2CA_Connect indicator. Find socket that listens on address 553107120Sjulian * and PSM. Find exact or closest match. Create new socket and initiate 554107120Sjulian * connection. 555107120Sjulian */ 556107120Sjulian 557107120Sjulianstatic int 558107120Sjulianng_btsocket_l2cap_process_l2ca_con_ind(struct ng_mesg *msg, 559161623Semax ng_btsocket_l2cap_rtentry_p rt) 560107120Sjulian{ 561107120Sjulian ng_l2cap_l2ca_con_ind_ip *ip = NULL; 562107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL, *pcb1 = NULL; 563107120Sjulian int error = 0; 564107120Sjulian u_int32_t token = 0; 565107120Sjulian u_int16_t result = 0; 566107120Sjulian 567107120Sjulian if (msg->header.arglen != sizeof(*ip)) 568107120Sjulian return (EMSGSIZE); 569107120Sjulian 570107120Sjulian ip = (ng_l2cap_l2ca_con_ind_ip *)(msg->data); 571107120Sjulian 572107120Sjulian NG_BTSOCKET_L2CAP_INFO( 573107120Sjulian"%s: Got L2CA_Connect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 574107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, ident=%d\n", 575107120Sjulian __func__, 576107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 577107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 578107120Sjulian ip->bdaddr.b[5], ip->bdaddr.b[4], ip->bdaddr.b[3], 579107120Sjulian ip->bdaddr.b[2], ip->bdaddr.b[1], ip->bdaddr.b[0], 580107120Sjulian ip->psm, ip->lcid, ip->ident); 581114878Sjulian 582114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 583107120Sjulian 584107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_addr(&rt->src, ip->psm); 585107120Sjulian if (pcb != NULL) { 586107120Sjulian struct socket *so1 = NULL; 587107120Sjulian 588107120Sjulian mtx_lock(&pcb->pcb_mtx); 589107120Sjulian 590107120Sjulian /* 591107120Sjulian * First check the pending connections queue and if we have 592107120Sjulian * space then create new socket and set proper source address. 593107120Sjulian */ 594107120Sjulian 595107120Sjulian if (pcb->so->so_qlen <= pcb->so->so_qlimit) 596107120Sjulian so1 = sonewconn(pcb->so, 0); 597107120Sjulian 598107120Sjulian if (so1 == NULL) { 599107120Sjulian result = NG_L2CAP_NO_RESOURCES; 600107120Sjulian goto respond; 601107120Sjulian } 602107120Sjulian 603107120Sjulian /* 604107120Sjulian * If we got here than we have created new socket. So complete 605107120Sjulian * connection. If we we listening on specific address then copy 606107120Sjulian * source address from listening socket, otherwise copy source 607107120Sjulian * address from hook's routing information. 608107120Sjulian */ 609107120Sjulian 610107120Sjulian pcb1 = so2l2cap_pcb(so1); 611107120Sjulian KASSERT((pcb1 != NULL), 612107120Sjulian("%s: pcb1 == NULL\n", __func__)); 613107120Sjulian 614114878Sjulian mtx_lock(&pcb1->pcb_mtx); 615107120Sjulian 616107120Sjulian if (bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)) != 0) 617107120Sjulian bcopy(&pcb->src, &pcb1->src, sizeof(pcb1->src)); 618107120Sjulian else 619107120Sjulian bcopy(&rt->src, &pcb1->src, sizeof(pcb1->src)); 620107120Sjulian 621107120Sjulian pcb1->flags &= ~NG_BTSOCKET_L2CAP_CLIENT; 622107120Sjulian 623107120Sjulian bcopy(&ip->bdaddr, &pcb1->dst, sizeof(pcb1->dst)); 624107120Sjulian pcb1->psm = ip->psm; 625107120Sjulian pcb1->cid = ip->lcid; 626107120Sjulian pcb1->rt = rt; 627107120Sjulian 628107120Sjulian /* Copy socket settings */ 629107120Sjulian pcb1->imtu = pcb->imtu; 630107120Sjulian bcopy(&pcb->oflow, &pcb1->oflow, sizeof(pcb1->oflow)); 631107120Sjulian pcb1->flush_timo = pcb->flush_timo; 632107120Sjulian 633107120Sjulian token = pcb1->token; 634107120Sjulian } else 635107120Sjulian /* Nobody listens on requested BDADDR/PSM */ 636107120Sjulian result = NG_L2CAP_PSM_NOT_SUPPORTED; 637107120Sjulian 638107120Sjulianrespond: 639107120Sjulian error = ng_btsocket_l2cap_send_l2ca_con_rsp_req(token, rt, 640107120Sjulian &ip->bdaddr, ip->ident, ip->lcid, result); 641107120Sjulian if (pcb1 != NULL) { 642107120Sjulian if (error != 0) { 643107120Sjulian pcb1->so->so_error = error; 644107120Sjulian pcb1->state = NG_BTSOCKET_L2CAP_CLOSED; 645107120Sjulian soisdisconnected(pcb1->so); 646107120Sjulian } else { 647107120Sjulian pcb1->state = NG_BTSOCKET_L2CAP_CONNECTING; 648107120Sjulian soisconnecting(pcb1->so); 649107120Sjulian 650107120Sjulian ng_btsocket_l2cap_timeout(pcb1); 651107120Sjulian } 652107120Sjulian 653107120Sjulian mtx_unlock(&pcb1->pcb_mtx); 654107120Sjulian } 655107120Sjulian 656107120Sjulian if (pcb != NULL) 657107120Sjulian mtx_unlock(&pcb->pcb_mtx); 658107120Sjulian 659114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 660114878Sjulian 661107120Sjulian return (error); 662107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_con_ind */ 663107120Sjulian 664107120Sjulian/* 665107120Sjulian * Process L2CA_Config response 666107120Sjulian */ 667107120Sjulian 668107120Sjulianstatic int 669107120Sjulianng_btsocket_l2cap_process_l2ca_cfg_req_rsp(struct ng_mesg *msg, 670161623Semax ng_btsocket_l2cap_rtentry_p rt) 671107120Sjulian{ 672107120Sjulian ng_l2cap_l2ca_cfg_op *op = NULL; 673107120Sjulian ng_btsocket_l2cap_pcb_p pcb = NULL; 674107120Sjulian 675107120Sjulian if (msg->header.arglen != sizeof(*op)) 676107120Sjulian return (EMSGSIZE); 677107120Sjulian 678107120Sjulian op = (ng_l2cap_l2ca_cfg_op *)(msg->data); 679107120Sjulian 680114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 681114878Sjulian 682107120Sjulian /* 683107120Sjulian * Socket must have issued a Configure request, so we must have a 684107120Sjulian * socket that wants to be configured. Use Netgraph message token 685107120Sjulian * to find it 686107120Sjulian */ 687107120Sjulian 688107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 689107120Sjulian if (pcb == NULL) { 690107120Sjulian /* 691107120Sjulian * XXX FIXME what to do here? We could not find a 692107120Sjulian * socket with requested token. We even can not send 693107120Sjulian * Disconnect, because we do not know channel ID 694107120Sjulian */ 695107120Sjulian 696114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 697107120Sjulian return (ENOENT); 698107120Sjulian } 699107120Sjulian 700107120Sjulian mtx_lock(&pcb->pcb_mtx); 701107120Sjulian 702107120Sjulian NG_BTSOCKET_L2CAP_INFO( 703107120Sjulian"%s: Got L2CA_Config response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 704107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 705107120Sjulian"cfg_state=%x\n", 706107120Sjulian __func__, msg->header.token, 707107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 708107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 709107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 710107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 711107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 712107120Sjulian 713107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 714107120Sjulian mtx_unlock(&pcb->pcb_mtx); 715114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 716114878Sjulian 717107120Sjulian return (ENOENT); 718107120Sjulian } 719107120Sjulian 720107120Sjulian if (op->result == NG_L2CAP_SUCCESS) { 721107120Sjulian /* 722107120Sjulian * XXX FIXME Actually set flush and link timeout. 723107120Sjulian * Set QoS here if required. Resolve conficts (flush_timo). 724107120Sjulian * Save incoming MTU (peer's outgoing MTU) and outgoing flow 725107120Sjulian * spec. 726107120Sjulian */ 727107120Sjulian 728107120Sjulian pcb->imtu = op->imtu; 729107120Sjulian bcopy(&op->oflow, &pcb->oflow, sizeof(pcb->oflow)); 730107120Sjulian pcb->flush_timo = op->flush_timo; 731107120Sjulian 732107120Sjulian /* 733107120Sjulian * We have configured incoming side, so record it and check 734107120Sjulian * if configuration is complete. If complete then mark socket 735107120Sjulian * as connected, otherwise wait for the peer. 736107120Sjulian */ 737107120Sjulian 738107120Sjulian pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_IN_SENT; 739107120Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN; 740107120Sjulian 741107120Sjulian if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 742107120Sjulian /* Configuration complete - mark socket as open */ 743107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 744107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_OPEN; 745107120Sjulian soisconnected(pcb->so); 746107120Sjulian } 747107120Sjulian } else { 748107120Sjulian /* 749107120Sjulian * Something went wrong. Could be unacceptable parameters, 750107120Sjulian * reject or unknown option. That's too bad, but we will 751107120Sjulian * not negotiate. Send Disconnect and close the channel. 752107120Sjulian */ 753107120Sjulian 754107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 755107120Sjulian 756107120Sjulian switch (op->result) { 757107120Sjulian case NG_L2CAP_UNACCEPTABLE_PARAMS: 758107120Sjulian case NG_L2CAP_UNKNOWN_OPTION: 759107120Sjulian pcb->so->so_error = EINVAL; 760107120Sjulian break; 761107120Sjulian 762107120Sjulian default: 763107120Sjulian pcb->so->so_error = ECONNRESET; 764107120Sjulian break; 765107120Sjulian } 766107120Sjulian 767107120Sjulian /* Send disconnect with "zero" token */ 768107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 769107120Sjulian 770107120Sjulian /* ... and close the socket */ 771107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 772107120Sjulian soisdisconnected(pcb->so); 773107120Sjulian } 774107120Sjulian 775107120Sjulian mtx_unlock(&pcb->pcb_mtx); 776114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 777107120Sjulian 778107120Sjulian return (0); 779107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_cfg_req_rsp */ 780107120Sjulian 781107120Sjulian/* 782107120Sjulian * Process L2CA_ConfigRsp response 783107120Sjulian */ 784107120Sjulian 785107120Sjulianstatic int 786107120Sjulianng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(struct ng_mesg *msg, 787161623Semax ng_btsocket_l2cap_rtentry_p rt) 788107120Sjulian{ 789107120Sjulian ng_l2cap_l2ca_cfg_rsp_op *op = NULL; 790107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 791107120Sjulian int error = 0; 792107120Sjulian 793107120Sjulian if (msg->header.arglen != sizeof(*op)) 794107120Sjulian return (EMSGSIZE); 795107120Sjulian 796107120Sjulian op = (ng_l2cap_l2ca_cfg_rsp_op *)(msg->data); 797107120Sjulian 798114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 799114878Sjulian 800107120Sjulian /* Look for the socket with the token */ 801107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 802114878Sjulian if (pcb == NULL) { 803114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 804107120Sjulian return (ENOENT); 805114878Sjulian } 806107120Sjulian 807107120Sjulian mtx_lock(&pcb->pcb_mtx); 808107120Sjulian 809107120Sjulian NG_BTSOCKET_L2CAP_INFO( 810107120Sjulian"%s: Got L2CA_ConfigRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 811107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 812107120Sjulian"cfg_state=%x\n", 813107120Sjulian __func__, msg->header.token, 814107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 815107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 816107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 817107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 818107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 819107120Sjulian 820107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 821107120Sjulian mtx_unlock(&pcb->pcb_mtx); 822114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 823114878Sjulian 824107120Sjulian return (ENOENT); 825107120Sjulian } 826107120Sjulian 827107120Sjulian /* Check the result and disconnect socket of failure */ 828107120Sjulian if (op->result != NG_L2CAP_SUCCESS) 829107120Sjulian goto disconnect; 830107120Sjulian 831107120Sjulian /* 832107120Sjulian * Now we done with remote side configuration. Configure local 833107120Sjulian * side if we have not done it yet. 834107120Sjulian */ 835107120Sjulian 836107120Sjulian pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 837107120Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT; 838107120Sjulian 839107120Sjulian if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 840107120Sjulian /* Configuration complete - mask socket as open */ 841107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 842107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_OPEN; 843107120Sjulian soisconnected(pcb->so); 844107120Sjulian } else { 845107120Sjulian if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_IN_SENT)) { 846107120Sjulian /* Send L2CA_Config request - incoming path */ 847107120Sjulian error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 848107120Sjulian if (error != 0) 849107120Sjulian goto disconnect; 850107120Sjulian 851107120Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN_SENT; 852107120Sjulian } 853107120Sjulian } 854107120Sjulian 855107120Sjulian mtx_unlock(&pcb->pcb_mtx); 856114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 857107120Sjulian 858107120Sjulian return (error); 859107120Sjulian 860107120Sjuliandisconnect: 861107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 862107120Sjulian 863107120Sjulian /* Send disconnect with "zero" token */ 864107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 865107120Sjulian 866107120Sjulian /* ... and close the socket */ 867107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 868107120Sjulian soisdisconnected(pcb->so); 869107120Sjulian 870107120Sjulian mtx_unlock(&pcb->pcb_mtx); 871114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 872107120Sjulian 873107120Sjulian return (error); 874107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp */ 875107120Sjulian 876107120Sjulian/* 877107120Sjulian * Process L2CA_Config indicator 878107120Sjulian */ 879107120Sjulian 880107120Sjulianstatic int 881107120Sjulianng_btsocket_l2cap_process_l2ca_cfg_ind(struct ng_mesg *msg, 882161623Semax ng_btsocket_l2cap_rtentry_p rt) 883107120Sjulian{ 884107120Sjulian ng_l2cap_l2ca_cfg_ind_ip *ip = NULL; 885107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 886107120Sjulian int error = 0; 887107120Sjulian 888107120Sjulian if (msg->header.arglen != sizeof(*ip)) 889107120Sjulian return (EMSGSIZE); 890107120Sjulian 891107120Sjulian ip = (ng_l2cap_l2ca_cfg_ind_ip *)(msg->data); 892107120Sjulian 893114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 894114878Sjulian 895107120Sjulian /* Check for the open socket that has given channel ID */ 896107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid); 897114878Sjulian if (pcb == NULL) { 898114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 899107120Sjulian return (ENOENT); 900114878Sjulian } 901107120Sjulian 902107120Sjulian mtx_lock(&pcb->pcb_mtx); 903107120Sjulian 904107120Sjulian NG_BTSOCKET_L2CAP_INFO( 905107120Sjulian"%s: Got L2CA_Config indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 906107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d, cfg_state=%x\n", 907107120Sjulian __func__, 908107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 909107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 910107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 911107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 912107120Sjulian pcb->psm, pcb->cid, pcb->state, pcb->cfg_state); 913107120Sjulian 914107120Sjulian /* XXX FIXME re-configuration on open socket */ 915107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 916107120Sjulian mtx_unlock(&pcb->pcb_mtx); 917114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 918114878Sjulian 919107120Sjulian return (ENOENT); 920107120Sjulian } 921107120Sjulian 922107120Sjulian /* 923107120Sjulian * XXX FIXME Actually set flush and link timeout. Set QoS here if 924107120Sjulian * required. Resolve conficts (flush_timo). Note outgoing MTU (peer's 925107120Sjulian * incoming MTU) and incoming flow spec. 926107120Sjulian */ 927107120Sjulian 928107120Sjulian pcb->omtu = ip->omtu; 929107120Sjulian bcopy(&ip->iflow, &pcb->iflow, sizeof(pcb->iflow)); 930107120Sjulian pcb->flush_timo = ip->flush_timo; 931107120Sjulian 932107120Sjulian /* 933107120Sjulian * Send L2CA_Config response to our peer and check for the errors, 934107120Sjulian * if any send disconnect to close the channel. 935107120Sjulian */ 936107120Sjulian 937114878Sjulian if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_OUT_SENT)) { 938114878Sjulian error = ng_btsocket_l2cap_send_l2ca_cfg_rsp(pcb); 939114878Sjulian if (error != 0) { 940114878Sjulian ng_btsocket_l2cap_untimeout(pcb); 941107120Sjulian 942114878Sjulian pcb->so->so_error = error; 943107120Sjulian 944114878Sjulian /* Send disconnect with "zero" token */ 945114878Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 946107120Sjulian 947114878Sjulian /* ... and close the socket */ 948114878Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 949114878Sjulian soisdisconnected(pcb->so); 950114878Sjulian } else 951114878Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 952107120Sjulian } 953107120Sjulian 954107120Sjulian mtx_unlock(&pcb->pcb_mtx); 955114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 956107120Sjulian 957107120Sjulian return (error); 958107120Sjulian} /* ng_btsocket_l2cap_process_l2cap_cfg_ind */ 959107120Sjulian 960107120Sjulian/* 961107120Sjulian * Process L2CA_Disconnect response 962107120Sjulian */ 963107120Sjulian 964107120Sjulianstatic int 965107120Sjulianng_btsocket_l2cap_process_l2ca_discon_rsp(struct ng_mesg *msg, 966161623Semax ng_btsocket_l2cap_rtentry_p rt) 967107120Sjulian{ 968107120Sjulian ng_l2cap_l2ca_discon_op *op = NULL; 969107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 970107120Sjulian 971107120Sjulian /* Check message */ 972107120Sjulian if (msg->header.arglen != sizeof(*op)) 973107120Sjulian return (EMSGSIZE); 974107120Sjulian 975107120Sjulian op = (ng_l2cap_l2ca_discon_op *)(msg->data); 976107120Sjulian 977114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 978114878Sjulian 979107120Sjulian /* 980107120Sjulian * Socket layer must have issued L2CA_Disconnect request, so there 981107120Sjulian * must be a socket that wants to be disconnected. Use Netgraph 982107120Sjulian * message token to find it. 983107120Sjulian */ 984107120Sjulian 985107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 986114878Sjulian if (pcb == NULL) { 987114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 988107120Sjulian return (0); 989114878Sjulian } 990107120Sjulian 991107120Sjulian mtx_lock(&pcb->pcb_mtx); 992107120Sjulian 993107120Sjulian /* XXX Close socket no matter what op->result says */ 994107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 995107120Sjulian NG_BTSOCKET_L2CAP_INFO( 996107120Sjulian"%s: Got L2CA_Disconnect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 997107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 998107120Sjulian __func__, msg->header.token, 999107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1000107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1001107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1002107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1003107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state); 1004107120Sjulian 1005107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1006107120Sjulian 1007107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1008107120Sjulian soisdisconnected(pcb->so); 1009107120Sjulian } 1010107120Sjulian 1011107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1012114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1013107120Sjulian 1014107120Sjulian return (0); 1015107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_discon_rsp */ 1016107120Sjulian 1017107120Sjulian/* 1018107120Sjulian * Process L2CA_Disconnect indicator 1019107120Sjulian */ 1020107120Sjulian 1021107120Sjulianstatic int 1022107120Sjulianng_btsocket_l2cap_process_l2ca_discon_ind(struct ng_mesg *msg, 1023161623Semax ng_btsocket_l2cap_rtentry_p rt) 1024107120Sjulian{ 1025107120Sjulian ng_l2cap_l2ca_discon_ind_ip *ip = NULL; 1026107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 1027107120Sjulian 1028107120Sjulian /* Check message */ 1029107120Sjulian if (msg->header.arglen != sizeof(*ip)) 1030107120Sjulian return (EMSGSIZE); 1031107120Sjulian 1032107120Sjulian ip = (ng_l2cap_l2ca_discon_ind_ip *)(msg->data); 1033107120Sjulian 1034114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1035114878Sjulian 1036107120Sjulian /* Look for the socket with given channel ID */ 1037107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid); 1038114878Sjulian if (pcb == NULL) { 1039114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1040107120Sjulian return (0); 1041114878Sjulian } 1042107120Sjulian 1043107120Sjulian /* 1044107120Sjulian * Channel has already been destroyed, so disconnect the socket 1045107120Sjulian * and be done with it. If there was any pending request we can 1046107120Sjulian * not do anything here anyway. 1047107120Sjulian */ 1048107120Sjulian 1049107120Sjulian mtx_lock(&pcb->pcb_mtx); 1050107120Sjulian 1051107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1052107120Sjulian"%s: Got L2CA_Disconnect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1053107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d\n", 1054107120Sjulian __func__, 1055107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1056107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1057107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1058107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1059107120Sjulian pcb->psm, pcb->cid, pcb->state); 1060107120Sjulian 1061107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1062107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1063107120Sjulian 1064107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1065107120Sjulian soisdisconnected(pcb->so); 1066107120Sjulian 1067107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1068114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1069107120Sjulian 1070107120Sjulian return (0); 1071107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_discon_ind */ 1072107120Sjulian 1073107120Sjulian/* 1074107120Sjulian * Process L2CA_Write response 1075107120Sjulian */ 1076107120Sjulian 1077107120Sjulianstatic int 1078107120Sjulianng_btsocket_l2cap_process_l2ca_write_rsp(struct ng_mesg *msg, 1079161623Semax ng_btsocket_l2cap_rtentry_p rt) 1080107120Sjulian{ 1081107120Sjulian ng_l2cap_l2ca_write_op *op = NULL; 1082107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 1083107120Sjulian 1084107120Sjulian /* Check message */ 1085107120Sjulian if (msg->header.arglen != sizeof(*op)) 1086107120Sjulian return (EMSGSIZE); 1087107120Sjulian 1088107120Sjulian op = (ng_l2cap_l2ca_write_op *)(msg->data); 1089107120Sjulian 1090114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1091114878Sjulian 1092107120Sjulian /* Look for the socket with given token */ 1093107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1094114878Sjulian if (pcb == NULL) { 1095114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1096107120Sjulian return (ENOENT); 1097114878Sjulian } 1098107120Sjulian 1099107120Sjulian mtx_lock(&pcb->pcb_mtx); 1100107120Sjulian 1101107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1102107120Sjulian"%s: Got L2CA_Write response, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1103107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, length=%d, " \ 1104107120Sjulian"state=%d\n", __func__, 1105107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1106107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1107107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1108107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1109107120Sjulian pcb->psm, pcb->cid, op->result, op->length, 1110107120Sjulian pcb->state); 1111107120Sjulian 1112107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1113107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1114114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1115114878Sjulian 1116107120Sjulian return (ENOENT); 1117107120Sjulian } 1118107120Sjulian 1119107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1120107120Sjulian 1121107120Sjulian /* 1122107120Sjulian * Check if we have more data to send 1123107120Sjulian */ 1124107120Sjulian 1125107120Sjulian sbdroprecord(&pcb->so->so_snd); 1126107120Sjulian if (pcb->so->so_snd.sb_cc > 0) { 1127107120Sjulian if (ng_btsocket_l2cap_send2(pcb) == 0) 1128107120Sjulian ng_btsocket_l2cap_timeout(pcb); 1129107120Sjulian else 1130107120Sjulian sbdroprecord(&pcb->so->so_snd); /* XXX */ 1131107120Sjulian } 1132107120Sjulian 1133107120Sjulian /* 1134107120Sjulian * Now set the result, drop packet from the socket send queue and 1135107120Sjulian * ask for more (wakeup sender) 1136107120Sjulian */ 1137107120Sjulian 1138107120Sjulian pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 1139107120Sjulian sowwakeup(pcb->so); 1140107120Sjulian 1141107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1142114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1143107120Sjulian 1144107120Sjulian return (0); 1145107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_write_rsp */ 1146107120Sjulian 1147107120Sjulian/* 1148107120Sjulian * Send L2CA_Connect request 1149107120Sjulian */ 1150107120Sjulian 1151107120Sjulianstatic int 1152107120Sjulianng_btsocket_l2cap_send_l2ca_con_req(ng_btsocket_l2cap_pcb_p pcb) 1153107120Sjulian{ 1154107120Sjulian struct ng_mesg *msg = NULL; 1155107120Sjulian ng_l2cap_l2ca_con_ip *ip = NULL; 1156107120Sjulian int error = 0; 1157107120Sjulian 1158107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1159107120Sjulian 1160107120Sjulian if (pcb->rt == NULL || 1161107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1162107120Sjulian return (ENETDOWN); 1163107120Sjulian 1164107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON, 1165107120Sjulian sizeof(*ip), M_NOWAIT); 1166107120Sjulian if (msg == NULL) 1167107120Sjulian return (ENOMEM); 1168107120Sjulian 1169107120Sjulian msg->header.token = pcb->token; 1170107120Sjulian 1171107120Sjulian ip = (ng_l2cap_l2ca_con_ip *)(msg->data); 1172107120Sjulian bcopy(&pcb->dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1173107120Sjulian ip->psm = pcb->psm; 1174107120Sjulian 1175123812Salfred NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg,pcb->rt->hook, 0); 1176107120Sjulian 1177107120Sjulian return (error); 1178107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_con_req */ 1179107120Sjulian 1180107120Sjulian/* 1181107120Sjulian * Send L2CA_Connect response 1182107120Sjulian */ 1183107120Sjulian 1184107120Sjulianstatic int 1185107120Sjulianng_btsocket_l2cap_send_l2ca_con_rsp_req(u_int32_t token, 1186107120Sjulian ng_btsocket_l2cap_rtentry_p rt, bdaddr_p dst, int ident, 1187107120Sjulian int lcid, int result) 1188107120Sjulian{ 1189107120Sjulian struct ng_mesg *msg = NULL; 1190107120Sjulian ng_l2cap_l2ca_con_rsp_ip *ip = NULL; 1191107120Sjulian int error = 0; 1192107120Sjulian 1193107120Sjulian if (rt == NULL || rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 1194107120Sjulian return (ENETDOWN); 1195107120Sjulian 1196107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON_RSP, 1197107120Sjulian sizeof(*ip), M_NOWAIT); 1198107120Sjulian if (msg == NULL) 1199107120Sjulian return (ENOMEM); 1200107120Sjulian 1201107120Sjulian msg->header.token = token; 1202107120Sjulian 1203107120Sjulian ip = (ng_l2cap_l2ca_con_rsp_ip *)(msg->data); 1204107120Sjulian bcopy(dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1205107120Sjulian ip->ident = ident; 1206107120Sjulian ip->lcid = lcid; 1207107120Sjulian ip->result = result; 1208107120Sjulian ip->status = 0; 1209107120Sjulian 1210123812Salfred NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg, rt->hook, 0); 1211107120Sjulian 1212107120Sjulian return (error); 1213107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_con_rsp_req */ 1214107120Sjulian 1215107120Sjulian/* 1216107120Sjulian * Send L2CA_Config request 1217107120Sjulian */ 1218107120Sjulian 1219107120Sjulianstatic int 1220107120Sjulianng_btsocket_l2cap_send_l2ca_cfg_req(ng_btsocket_l2cap_pcb_p pcb) 1221107120Sjulian{ 1222107120Sjulian struct ng_mesg *msg = NULL; 1223107120Sjulian ng_l2cap_l2ca_cfg_ip *ip = NULL; 1224107120Sjulian int error = 0; 1225107120Sjulian 1226107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1227107120Sjulian 1228107120Sjulian if (pcb->rt == NULL || 1229107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1230107120Sjulian return (ENETDOWN); 1231107120Sjulian 1232107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG, 1233107120Sjulian sizeof(*ip), M_NOWAIT); 1234107120Sjulian if (msg == NULL) 1235107120Sjulian return (ENOMEM); 1236107120Sjulian 1237107120Sjulian msg->header.token = pcb->token; 1238107120Sjulian 1239107120Sjulian ip = (ng_l2cap_l2ca_cfg_ip *)(msg->data); 1240107120Sjulian ip->lcid = pcb->cid; 1241107120Sjulian ip->imtu = pcb->imtu; 1242107120Sjulian bcopy(&pcb->oflow, &ip->oflow, sizeof(ip->oflow)); 1243107120Sjulian ip->flush_timo = pcb->flush_timo; 1244107120Sjulian ip->link_timo = pcb->link_timo; 1245107120Sjulian 1246123812Salfred NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg,pcb->rt->hook, 0); 1247107120Sjulian 1248107120Sjulian return (error); 1249107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_cfg_req */ 1250107120Sjulian 1251107120Sjulian/* 1252107120Sjulian * Send L2CA_Config response 1253107120Sjulian */ 1254107120Sjulian 1255107120Sjulianstatic int 1256107120Sjulianng_btsocket_l2cap_send_l2ca_cfg_rsp(ng_btsocket_l2cap_pcb_p pcb) 1257107120Sjulian{ 1258107120Sjulian struct ng_mesg *msg = NULL; 1259107120Sjulian ng_l2cap_l2ca_cfg_rsp_ip *ip = NULL; 1260107120Sjulian int error = 0; 1261107120Sjulian 1262107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1263107120Sjulian 1264107120Sjulian if (pcb->rt == NULL || 1265107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1266107120Sjulian return (ENETDOWN); 1267107120Sjulian 1268107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG_RSP, 1269107120Sjulian sizeof(*ip), M_NOWAIT); 1270107120Sjulian if (msg == NULL) 1271107120Sjulian return (ENOMEM); 1272107120Sjulian 1273107120Sjulian msg->header.token = pcb->token; 1274107120Sjulian 1275107120Sjulian ip = (ng_l2cap_l2ca_cfg_rsp_ip *)(msg->data); 1276107120Sjulian ip->lcid = pcb->cid; 1277107120Sjulian ip->omtu = pcb->omtu; 1278107120Sjulian bcopy(&pcb->iflow, &ip->iflow, sizeof(ip->iflow)); 1279107120Sjulian 1280123812Salfred NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg, pcb->rt->hook, 0); 1281107120Sjulian 1282107120Sjulian return (error); 1283107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_cfg_rsp */ 1284107120Sjulian 1285107120Sjulian/* 1286107120Sjulian * Send L2CA_Disconnect request 1287107120Sjulian */ 1288107120Sjulian 1289107120Sjulianstatic int 1290107120Sjulianng_btsocket_l2cap_send_l2ca_discon_req(u_int32_t token, 1291107120Sjulian ng_btsocket_l2cap_pcb_p pcb) 1292107120Sjulian{ 1293107120Sjulian struct ng_mesg *msg = NULL; 1294107120Sjulian ng_l2cap_l2ca_discon_ip *ip = NULL; 1295107120Sjulian int error = 0; 1296107120Sjulian 1297107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1298107120Sjulian 1299107120Sjulian if (pcb->rt == NULL || 1300107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1301107120Sjulian return (ENETDOWN); 1302107120Sjulian 1303107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_DISCON, 1304107120Sjulian sizeof(*ip), M_NOWAIT); 1305107120Sjulian if (msg == NULL) 1306107120Sjulian return (ENOMEM); 1307107120Sjulian 1308107120Sjulian msg->header.token = token; 1309107120Sjulian 1310107120Sjulian ip = (ng_l2cap_l2ca_discon_ip *)(msg->data); 1311107120Sjulian ip->lcid = pcb->cid; 1312107120Sjulian 1313123812Salfred NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg,pcb->rt->hook, 0); 1314107120Sjulian 1315107120Sjulian return (error); 1316107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_discon_req */ 1317107120Sjulian 1318107120Sjulian/***************************************************************************** 1319107120Sjulian ***************************************************************************** 1320107120Sjulian ** Socket interface 1321107120Sjulian ***************************************************************************** 1322107120Sjulian *****************************************************************************/ 1323107120Sjulian 1324107120Sjulian/* 1325107120Sjulian * L2CAP sockets data input routine 1326107120Sjulian */ 1327107120Sjulian 1328107120Sjulianstatic void 1329107120Sjulianng_btsocket_l2cap_data_input(struct mbuf *m, hook_p hook) 1330107120Sjulian{ 1331107120Sjulian ng_l2cap_hdr_t *hdr = NULL; 1332107120Sjulian ng_l2cap_clt_hdr_t *clt_hdr = NULL; 1333107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 1334107120Sjulian ng_btsocket_l2cap_rtentry_t *rt = NULL; 1335107120Sjulian 1336107120Sjulian if (hook == NULL) { 1337107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1338107120Sjulian"%s: Invalid source hook for L2CAP data packet\n", __func__); 1339107120Sjulian goto drop; 1340107120Sjulian } 1341107120Sjulian 1342107120Sjulian rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1343107120Sjulian if (rt == NULL) { 1344107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1345107120Sjulian"%s: Could not find out source bdaddr for L2CAP data packet\n", __func__); 1346107120Sjulian goto drop; 1347107120Sjulian } 1348107120Sjulian 1349107120Sjulian /* Make sure we can access header */ 1350107120Sjulian if (m->m_pkthdr.len < sizeof(*hdr)) { 1351107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1352107120Sjulian"%s: L2CAP data packet too small, len=%d\n", __func__, m->m_pkthdr.len); 1353107120Sjulian goto drop; 1354107120Sjulian } 1355107120Sjulian 1356107120Sjulian if (m->m_len < sizeof(*hdr)) { 1357107120Sjulian m = m_pullup(m, sizeof(*hdr)); 1358107120Sjulian if (m == NULL) 1359107120Sjulian goto drop; 1360107120Sjulian } 1361107120Sjulian 1362107120Sjulian /* Strip L2CAP packet header and verify packet length */ 1363107120Sjulian hdr = mtod(m, ng_l2cap_hdr_t *); 1364107120Sjulian m_adj(m, sizeof(*hdr)); 1365107120Sjulian 1366107120Sjulian if (hdr->length != m->m_pkthdr.len) { 1367107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1368107120Sjulian"%s: Bad L2CAP data packet length, len=%d, length=%d\n", 1369107120Sjulian __func__, m->m_pkthdr.len, hdr->length); 1370107120Sjulian goto drop; 1371107120Sjulian } 1372107120Sjulian 1373107120Sjulian /* 1374107120Sjulian * Now process packet. Two cases: 1375107120Sjulian * 1376107120Sjulian * 1) Normal packet (cid != 2) then find connected socket and append 1377107120Sjulian * mbuf to the socket queue. Wakeup socket. 1378107120Sjulian * 1379107120Sjulian * 2) Broadcast packet (cid == 2) then find all sockets that connected 1380107120Sjulian * to the given PSM and have SO_BROADCAST bit set and append mbuf 1381107120Sjulian * to the socket queue. Wakeup socket. 1382107120Sjulian */ 1383107120Sjulian 1384107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1385114878Sjulian"%s: Received L2CAP data packet: src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1386107120Sjulian"dcid=%d, length=%d\n", 1387107120Sjulian __func__, 1388107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1389107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1390107120Sjulian hdr->dcid, hdr->length); 1391107120Sjulian 1392121054Semax if (hdr->dcid >= NG_L2CAP_FIRST_CID) { 1393114878Sjulian 1394114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1395114878Sjulian 1396107120Sjulian /* Normal packet: find connected socket */ 1397107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, hdr->dcid); 1398114878Sjulian if (pcb == NULL) { 1399114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1400107120Sjulian goto drop; 1401114878Sjulian } 1402107120Sjulian 1403107120Sjulian mtx_lock(&pcb->pcb_mtx); 1404107120Sjulian 1405107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1406107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1407107120Sjulian"%s: No connected socket found, src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, " \ 1408107120Sjulian"state=%d\n", __func__, 1409107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1410107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1411107120Sjulian hdr->dcid, pcb->state); 1412107120Sjulian 1413107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1414114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1415107120Sjulian goto drop; 1416107120Sjulian } 1417107120Sjulian 1418107120Sjulian /* Check packet size against socket's incoming MTU */ 1419107120Sjulian if (hdr->length > pcb->imtu) { 1420107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1421107120Sjulian"%s: L2CAP data packet too big, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1422107120Sjulian"dcid=%d, length=%d, imtu=%d\n", 1423107120Sjulian __func__, 1424107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1425107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1426107120Sjulian hdr->dcid, hdr->length, pcb->imtu); 1427107120Sjulian 1428107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1429114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1430107120Sjulian goto drop; 1431107120Sjulian } 1432107120Sjulian 1433107120Sjulian /* Check if we have enough space in socket receive queue */ 1434107120Sjulian if (m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) { 1435107120Sjulian 1436107120Sjulian /* 1437107120Sjulian * This is really bad. Receive queue on socket does 1438107120Sjulian * not have enough space for the packet. We do not 1439107120Sjulian * have any other choice but drop the packet. L2CAP 1440107120Sjulian * does not provide any flow control. 1441107120Sjulian */ 1442107120Sjulian 1443107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1444107120Sjulian"%s: Not enough space in socket receive queue. Dropping L2CAP data packet, " \ 1445107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, len=%d, space=%ld\n", 1446107120Sjulian __func__, 1447107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1448107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1449107120Sjulian hdr->dcid, m->m_pkthdr.len, 1450107120Sjulian sbspace(&pcb->so->so_rcv)); 1451107120Sjulian 1452107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1453114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1454107120Sjulian goto drop; 1455107120Sjulian } 1456107120Sjulian 1457107120Sjulian /* Append packet to the socket receive queue and wakeup */ 1458107120Sjulian sbappendrecord(&pcb->so->so_rcv, m); 1459107120Sjulian m = NULL; 1460107120Sjulian 1461107120Sjulian sorwakeup(pcb->so); 1462114878Sjulian 1463107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1464114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1465114878Sjulian } else if (hdr->dcid == NG_L2CAP_CLT_CID) { 1466107120Sjulian /* Broadcast packet: give packet to all sockets */ 1467107120Sjulian 1468107120Sjulian /* Check packet size against connectionless MTU */ 1469107120Sjulian if (hdr->length > NG_L2CAP_MTU_DEFAULT) { 1470107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1471107120Sjulian"%s: Connectionless L2CAP data packet too big, " \ 1472107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1473107120Sjulian __func__, 1474107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1475107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1476107120Sjulian hdr->length); 1477107120Sjulian goto drop; 1478107120Sjulian } 1479107120Sjulian 1480107120Sjulian /* Make sure we can access connectionless header */ 1481107120Sjulian if (m->m_pkthdr.len < sizeof(*clt_hdr)) { 1482107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1483107120Sjulian"%s: Can not get L2CAP connectionless packet header, " \ 1484107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1485107120Sjulian __func__, 1486107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1487107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1488107120Sjulian hdr->length); 1489107120Sjulian goto drop; 1490107120Sjulian } 1491107120Sjulian 1492107120Sjulian if (m->m_len < sizeof(*clt_hdr)) { 1493107120Sjulian m = m_pullup(m, sizeof(*clt_hdr)); 1494107120Sjulian if (m == NULL) 1495107120Sjulian goto drop; 1496107120Sjulian } 1497107120Sjulian 1498107120Sjulian /* Strip connectionless header and deliver packet */ 1499107120Sjulian clt_hdr = mtod(m, ng_l2cap_clt_hdr_t *); 1500107120Sjulian m_adj(m, sizeof(*clt_hdr)); 1501107120Sjulian 1502107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1503107120Sjulian"%s: Got L2CAP connectionless data packet, " \ 1504107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, length=%d\n", 1505107120Sjulian __func__, 1506107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1507107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1508107120Sjulian clt_hdr->psm, hdr->length); 1509107120Sjulian 1510107120Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1511107120Sjulian 1512107120Sjulian LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) { 1513107120Sjulian struct mbuf *copy = NULL; 1514107120Sjulian 1515107120Sjulian mtx_lock(&pcb->pcb_mtx); 1516107120Sjulian 1517107120Sjulian if (bcmp(&rt->src, &pcb->src, sizeof(pcb->src)) != 0 || 1518107120Sjulian pcb->psm != clt_hdr->psm || 1519107120Sjulian pcb->state != NG_BTSOCKET_L2CAP_OPEN || 1520107120Sjulian (pcb->so->so_options & SO_BROADCAST) == 0 || 1521107120Sjulian m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) 1522107120Sjulian goto next; 1523107120Sjulian 1524107120Sjulian /* 1525107120Sjulian * Create a copy of the packet and append it to the 1526107120Sjulian * socket's queue. If m_dup() failed - no big deal 1527107120Sjulian * it is a broadcast traffic after all 1528107120Sjulian */ 1529107120Sjulian 1530111119Simp copy = m_dup(m, M_DONTWAIT); 1531107120Sjulian if (copy != NULL) { 1532107120Sjulian sbappendrecord(&pcb->so->so_rcv, copy); 1533107120Sjulian sorwakeup(pcb->so); 1534107120Sjulian } 1535107120Sjuliannext: 1536107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1537107120Sjulian } 1538114878Sjulian 1539107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1540107120Sjulian } 1541107120Sjuliandrop: 1542107120Sjulian NG_FREE_M(m); /* checks for m != NULL */ 1543107120Sjulian} /* ng_btsocket_l2cap_data_input */ 1544107120Sjulian 1545107120Sjulian/* 1546107120Sjulian * L2CAP sockets default message input routine 1547107120Sjulian */ 1548107120Sjulian 1549107120Sjulianstatic void 1550107120Sjulianng_btsocket_l2cap_default_msg_input(struct ng_mesg *msg, hook_p hook) 1551107120Sjulian{ 1552107120Sjulian switch (msg->header.cmd) { 1553107120Sjulian case NGM_L2CAP_NODE_HOOK_INFO: { 1554107120Sjulian ng_btsocket_l2cap_rtentry_t *rt = NULL; 1555107120Sjulian 1556107120Sjulian if (hook == NULL || msg->header.arglen != sizeof(bdaddr_t)) 1557107120Sjulian break; 1558107120Sjulian 1559107120Sjulian if (bcmp(msg->data, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 1560107120Sjulian break; 1561107120Sjulian 1562114878Sjulian mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1563114878Sjulian 1564107120Sjulian rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1565107120Sjulian if (rt == NULL) { 1566184205Sdes rt = malloc(sizeof(*rt), 1567107120Sjulian M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT|M_ZERO); 1568114878Sjulian if (rt == NULL) { 1569114878Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1570107120Sjulian break; 1571114878Sjulian } 1572107120Sjulian 1573107120Sjulian LIST_INSERT_HEAD(&ng_btsocket_l2cap_rt, rt, next); 1574107120Sjulian 1575107120Sjulian NG_HOOK_SET_PRIVATE(hook, rt); 1576107120Sjulian } 1577114878Sjulian 1578107120Sjulian bcopy(msg->data, &rt->src, sizeof(rt->src)); 1579107120Sjulian rt->hook = hook; 1580107120Sjulian 1581114878Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1582114878Sjulian 1583107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1584107120Sjulian"%s: Updating hook \"%s\", src bdaddr=%x:%x:%x:%x:%x:%x\n", 1585107120Sjulian __func__, NG_HOOK_NAME(hook), 1586107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1587107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0]); 1588107120Sjulian } break; 1589107120Sjulian 1590107120Sjulian default: 1591107120Sjulian NG_BTSOCKET_L2CAP_WARN( 1592107120Sjulian"%s: Unknown message, cmd=%d\n", __func__, msg->header.cmd); 1593107120Sjulian break; 1594107120Sjulian } 1595107120Sjulian 1596107120Sjulian NG_FREE_MSG(msg); /* Checks for msg != NULL */ 1597107120Sjulian} /* ng_btsocket_l2cap_default_msg_input */ 1598107120Sjulian 1599107120Sjulian/* 1600107120Sjulian * L2CAP sockets L2CA message input routine 1601107120Sjulian */ 1602107120Sjulian 1603107120Sjulianstatic void 1604107120Sjulianng_btsocket_l2cap_l2ca_msg_input(struct ng_mesg *msg, hook_p hook) 1605107120Sjulian{ 1606161623Semax ng_btsocket_l2cap_rtentry_p rt = NULL; 1607107120Sjulian 1608107120Sjulian if (hook == NULL) { 1609107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1610107120Sjulian"%s: Invalid source hook for L2CA message\n", __func__); 1611107120Sjulian goto drop; 1612107120Sjulian } 1613107120Sjulian 1614107120Sjulian rt = (ng_btsocket_l2cap_rtentry_p) NG_HOOK_PRIVATE(hook); 1615107120Sjulian if (rt == NULL) { 1616107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1617107120Sjulian"%s: Could not find out source bdaddr for L2CA message\n", __func__); 1618107120Sjulian goto drop; 1619107120Sjulian } 1620107120Sjulian 1621107120Sjulian switch (msg->header.cmd) { 1622107120Sjulian case NGM_L2CAP_L2CA_CON: /* L2CA_Connect response */ 1623161623Semax ng_btsocket_l2cap_process_l2ca_con_req_rsp(msg, rt); 1624107120Sjulian break; 1625107120Sjulian 1626107120Sjulian case NGM_L2CAP_L2CA_CON_RSP: /* L2CA_ConnectRsp response */ 1627161623Semax ng_btsocket_l2cap_process_l2ca_con_rsp_rsp(msg, rt); 1628107120Sjulian break; 1629107120Sjulian 1630107120Sjulian case NGM_L2CAP_L2CA_CON_IND: /* L2CA_Connect indicator */ 1631161623Semax ng_btsocket_l2cap_process_l2ca_con_ind(msg, rt); 1632107120Sjulian break; 1633107120Sjulian 1634107120Sjulian case NGM_L2CAP_L2CA_CFG: /* L2CA_Config response */ 1635161623Semax ng_btsocket_l2cap_process_l2ca_cfg_req_rsp(msg, rt); 1636107120Sjulian break; 1637107120Sjulian 1638107120Sjulian case NGM_L2CAP_L2CA_CFG_RSP: /* L2CA_ConfigRsp response */ 1639161623Semax ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(msg, rt); 1640107120Sjulian break; 1641107120Sjulian 1642107120Sjulian case NGM_L2CAP_L2CA_CFG_IND: /* L2CA_Config indicator */ 1643161623Semax ng_btsocket_l2cap_process_l2ca_cfg_ind(msg, rt); 1644107120Sjulian break; 1645107120Sjulian 1646107120Sjulian case NGM_L2CAP_L2CA_DISCON: /* L2CA_Disconnect response */ 1647161623Semax ng_btsocket_l2cap_process_l2ca_discon_rsp(msg, rt); 1648107120Sjulian break; 1649107120Sjulian 1650107120Sjulian case NGM_L2CAP_L2CA_DISCON_IND: /* L2CA_Disconnect indicator */ 1651161623Semax ng_btsocket_l2cap_process_l2ca_discon_ind(msg, rt); 1652107120Sjulian break; 1653107120Sjulian 1654107120Sjulian case NGM_L2CAP_L2CA_WRITE: /* L2CA_Write response */ 1655161623Semax ng_btsocket_l2cap_process_l2ca_write_rsp(msg, rt); 1656107120Sjulian break; 1657107120Sjulian 1658107120Sjulian /* XXX FIXME add other L2CA messages */ 1659107120Sjulian 1660107120Sjulian default: 1661107120Sjulian NG_BTSOCKET_L2CAP_WARN( 1662107120Sjulian"%s: Unknown L2CA message, cmd=%d\n", __func__, msg->header.cmd); 1663107120Sjulian break; 1664107120Sjulian } 1665107120Sjuliandrop: 1666107120Sjulian NG_FREE_MSG(msg); 1667107120Sjulian} /* ng_btsocket_l2cap_l2ca_msg_input */ 1668107120Sjulian 1669107120Sjulian/* 1670107120Sjulian * L2CAP sockets input routine 1671107120Sjulian */ 1672107120Sjulian 1673107120Sjulianstatic void 1674107120Sjulianng_btsocket_l2cap_input(void *context, int pending) 1675107120Sjulian{ 1676107120Sjulian item_p item = NULL; 1677107120Sjulian hook_p hook = NULL; 1678107120Sjulian 1679107120Sjulian for (;;) { 1680107120Sjulian mtx_lock(&ng_btsocket_l2cap_queue_mtx); 1681107120Sjulian NG_BT_ITEMQ_DEQUEUE(&ng_btsocket_l2cap_queue, item); 1682107120Sjulian mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 1683107120Sjulian 1684107120Sjulian if (item == NULL) 1685107120Sjulian break; 1686107120Sjulian 1687107120Sjulian NGI_GET_HOOK(item, hook); 1688107120Sjulian if (hook != NULL && NG_HOOK_NOT_VALID(hook)) 1689107120Sjulian goto drop; 1690107120Sjulian 1691107120Sjulian switch(item->el_flags & NGQF_TYPE) { 1692107120Sjulian case NGQF_DATA: { 1693107120Sjulian struct mbuf *m = NULL; 1694107120Sjulian 1695107120Sjulian NGI_GET_M(item, m); 1696107120Sjulian ng_btsocket_l2cap_data_input(m, hook); 1697107120Sjulian } break; 1698107120Sjulian 1699107120Sjulian case NGQF_MESG: { 1700107120Sjulian struct ng_mesg *msg = NULL; 1701107120Sjulian 1702107120Sjulian NGI_GET_MSG(item, msg); 1703107120Sjulian 1704107120Sjulian switch (msg->header.cmd) { 1705107120Sjulian case NGM_L2CAP_L2CA_CON: 1706107120Sjulian case NGM_L2CAP_L2CA_CON_RSP: 1707107120Sjulian case NGM_L2CAP_L2CA_CON_IND: 1708107120Sjulian case NGM_L2CAP_L2CA_CFG: 1709107120Sjulian case NGM_L2CAP_L2CA_CFG_RSP: 1710107120Sjulian case NGM_L2CAP_L2CA_CFG_IND: 1711107120Sjulian case NGM_L2CAP_L2CA_DISCON: 1712107120Sjulian case NGM_L2CAP_L2CA_DISCON_IND: 1713107120Sjulian case NGM_L2CAP_L2CA_WRITE: 1714107120Sjulian /* XXX FIXME add other L2CA messages */ 1715107120Sjulian ng_btsocket_l2cap_l2ca_msg_input(msg, hook); 1716107120Sjulian break; 1717107120Sjulian 1718107120Sjulian default: 1719107120Sjulian ng_btsocket_l2cap_default_msg_input(msg, hook); 1720107120Sjulian break; 1721107120Sjulian } 1722107120Sjulian } break; 1723107120Sjulian 1724107120Sjulian default: 1725107120Sjulian KASSERT(0, 1726107120Sjulian("%s: invalid item type=%ld\n", __func__, (item->el_flags & NGQF_TYPE))); 1727107120Sjulian break; 1728107120Sjulian } 1729107120Sjuliandrop: 1730107120Sjulian if (hook != NULL) 1731107120Sjulian NG_HOOK_UNREF(hook); 1732107120Sjulian 1733107120Sjulian NG_FREE_ITEM(item); 1734107120Sjulian } 1735107120Sjulian} /* ng_btsocket_l2cap_input */ 1736107120Sjulian 1737107120Sjulian/* 1738107120Sjulian * Route cleanup task. Gets scheduled when hook is disconnected. Here we 1739107120Sjulian * will find all sockets that use "invalid" hook and disconnect them. 1740107120Sjulian */ 1741107120Sjulian 1742107120Sjulianstatic void 1743107120Sjulianng_btsocket_l2cap_rtclean(void *context, int pending) 1744107120Sjulian{ 1745114878Sjulian ng_btsocket_l2cap_pcb_p pcb = NULL, pcb_next = NULL; 1746107120Sjulian ng_btsocket_l2cap_rtentry_p rt = NULL; 1747107120Sjulian 1748107120Sjulian mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1749107120Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1750107120Sjulian 1751107120Sjulian /* 1752107120Sjulian * First disconnect all sockets that use "invalid" hook 1753107120Sjulian */ 1754107120Sjulian 1755114878Sjulian for (pcb = LIST_FIRST(&ng_btsocket_l2cap_sockets); pcb != NULL; ) { 1756107120Sjulian mtx_lock(&pcb->pcb_mtx); 1757114878Sjulian pcb_next = LIST_NEXT(pcb, next); 1758107120Sjulian 1759107120Sjulian if (pcb->rt != NULL && 1760107120Sjulian pcb->rt->hook != NULL && NG_HOOK_NOT_VALID(pcb->rt->hook)) { 1761107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1762107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1763107120Sjulian 1764107120Sjulian pcb->so->so_error = ENETDOWN; 1765107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1766107120Sjulian soisdisconnected(pcb->so); 1767107120Sjulian 1768107120Sjulian pcb->token = 0; 1769114878Sjulian pcb->cid = 0; 1770107120Sjulian pcb->rt = NULL; 1771107120Sjulian } 1772107120Sjulian 1773107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1774114878Sjulian pcb = pcb_next; 1775107120Sjulian } 1776107120Sjulian 1777107120Sjulian /* 1778107120Sjulian * Now cleanup routing table 1779107120Sjulian */ 1780107120Sjulian 1781114878Sjulian for (rt = LIST_FIRST(&ng_btsocket_l2cap_rt); rt != NULL; ) { 1782107120Sjulian ng_btsocket_l2cap_rtentry_p rt_next = LIST_NEXT(rt, next); 1783107120Sjulian 1784107120Sjulian if (rt->hook != NULL && NG_HOOK_NOT_VALID(rt->hook)) { 1785107120Sjulian LIST_REMOVE(rt, next); 1786107120Sjulian 1787107120Sjulian NG_HOOK_SET_PRIVATE(rt->hook, NULL); 1788107120Sjulian NG_HOOK_UNREF(rt->hook); /* Remove extra reference */ 1789107120Sjulian 1790107120Sjulian bzero(rt, sizeof(*rt)); 1791184205Sdes free(rt, M_NETGRAPH_BTSOCKET_L2CAP); 1792107120Sjulian } 1793107120Sjulian 1794107120Sjulian rt = rt_next; 1795107120Sjulian } 1796107120Sjulian 1797107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1798107120Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1799107120Sjulian} /* ng_btsocket_l2cap_rtclean */ 1800107120Sjulian 1801107120Sjulian/* 1802107120Sjulian * Initialize everything 1803107120Sjulian */ 1804107120Sjulian 1805107120Sjulianvoid 1806107120Sjulianng_btsocket_l2cap_init(void) 1807107120Sjulian{ 1808107120Sjulian int error = 0; 1809107120Sjulian 1810107120Sjulian ng_btsocket_l2cap_node = NULL; 1811107120Sjulian ng_btsocket_l2cap_debug_level = NG_BTSOCKET_WARN_LEVEL; 1812107120Sjulian 1813107120Sjulian /* Register Netgraph node type */ 1814107120Sjulian error = ng_newtype(&typestruct); 1815107120Sjulian if (error != 0) { 1816107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1817107120Sjulian"%s: Could not register Netgraph node type, error=%d\n", __func__, error); 1818107120Sjulian 1819107120Sjulian return; 1820107120Sjulian } 1821107120Sjulian 1822107120Sjulian /* Create Netgrapg node */ 1823107120Sjulian error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 1824107120Sjulian if (error != 0) { 1825107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1826107120Sjulian"%s: Could not create Netgraph node, error=%d\n", __func__, error); 1827107120Sjulian 1828107120Sjulian ng_btsocket_l2cap_node = NULL; 1829107120Sjulian 1830107120Sjulian return; 1831107120Sjulian } 1832107120Sjulian 1833107120Sjulian error = ng_name_node(ng_btsocket_l2cap_node, 1834107120Sjulian NG_BTSOCKET_L2CAP_NODE_TYPE); 1835107120Sjulian if (error != 0) { 1836107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1837107120Sjulian"%s: Could not name Netgraph node, error=%d\n", __func__, error); 1838107120Sjulian 1839107120Sjulian NG_NODE_UNREF(ng_btsocket_l2cap_node); 1840107120Sjulian ng_btsocket_l2cap_node = NULL; 1841107120Sjulian 1842107120Sjulian return; 1843107120Sjulian } 1844107120Sjulian 1845107120Sjulian /* Create input queue */ 1846107120Sjulian NG_BT_ITEMQ_INIT(&ng_btsocket_l2cap_queue, ifqmaxlen); 1847107120Sjulian mtx_init(&ng_btsocket_l2cap_queue_mtx, 1848107120Sjulian "btsocks_l2cap_queue_mtx", NULL, MTX_DEF); 1849107120Sjulian TASK_INIT(&ng_btsocket_l2cap_queue_task, 0, 1850107120Sjulian ng_btsocket_l2cap_input, NULL); 1851107120Sjulian 1852107120Sjulian /* Create list of sockets */ 1853107120Sjulian LIST_INIT(&ng_btsocket_l2cap_sockets); 1854107120Sjulian mtx_init(&ng_btsocket_l2cap_sockets_mtx, 1855107120Sjulian "btsocks_l2cap_sockets_mtx", NULL, MTX_DEF); 1856107120Sjulian 1857107120Sjulian /* Routing table */ 1858107120Sjulian LIST_INIT(&ng_btsocket_l2cap_rt); 1859107120Sjulian mtx_init(&ng_btsocket_l2cap_rt_mtx, 1860107120Sjulian "btsocks_l2cap_rt_mtx", NULL, MTX_DEF); 1861107120Sjulian TASK_INIT(&ng_btsocket_l2cap_rt_task, 0, 1862107120Sjulian ng_btsocket_l2cap_rtclean, NULL); 1863107120Sjulian} /* ng_btsocket_l2cap_init */ 1864107120Sjulian 1865107120Sjulian/* 1866107120Sjulian * Abort connection on socket 1867107120Sjulian */ 1868107120Sjulian 1869157366Srwatsonvoid 1870107120Sjulianng_btsocket_l2cap_abort(struct socket *so) 1871107120Sjulian{ 1872107120Sjulian so->so_error = ECONNABORTED; 1873107120Sjulian 1874160549Srwatson (void)ng_btsocket_l2cap_disconnect(so); 1875107120Sjulian} /* ng_btsocket_l2cap_abort */ 1876107120Sjulian 1877160549Srwatsonvoid 1878160549Srwatsonng_btsocket_l2cap_close(struct socket *so) 1879160549Srwatson{ 1880160549Srwatson 1881160549Srwatson (void)ng_btsocket_l2cap_disconnect(so); 1882160549Srwatson} /* ng_btsocket_l2cap_close */ 1883160549Srwatson 1884107120Sjulian/* 1885107120Sjulian * Accept connection on socket. Nothing to do here, socket must be connected 1886107120Sjulian * and ready, so just return peer address and be done with it. 1887107120Sjulian */ 1888107120Sjulian 1889107120Sjulianint 1890107120Sjulianng_btsocket_l2cap_accept(struct socket *so, struct sockaddr **nam) 1891107120Sjulian{ 1892107120Sjulian if (ng_btsocket_l2cap_node == NULL) 1893107120Sjulian return (EINVAL); 1894107120Sjulian 1895107120Sjulian return (ng_btsocket_l2cap_peeraddr(so, nam)); 1896107120Sjulian} /* ng_btsocket_l2cap_accept */ 1897107120Sjulian 1898107120Sjulian/* 1899107120Sjulian * Create and attach new socket 1900107120Sjulian */ 1901107120Sjulian 1902107120Sjulianint 1903107120Sjulianng_btsocket_l2cap_attach(struct socket *so, int proto, struct thread *td) 1904107120Sjulian{ 1905114878Sjulian static u_int32_t token = 0; 1906107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 1907107120Sjulian int error; 1908107120Sjulian 1909107120Sjulian /* Check socket and protocol */ 1910107120Sjulian if (ng_btsocket_l2cap_node == NULL) 1911107120Sjulian return (EPROTONOSUPPORT); 1912107120Sjulian if (so->so_type != SOCK_SEQPACKET) 1913107120Sjulian return (ESOCKTNOSUPPORT); 1914107120Sjulian 1915107120Sjulian#if 0 /* XXX sonewconn() calls "pru_attach" with proto == 0 */ 1916107120Sjulian if (proto != 0) 1917107120Sjulian if (proto != BLUETOOTH_PROTO_L2CAP) 1918107120Sjulian return (EPROTONOSUPPORT); 1919107120Sjulian#endif /* XXX */ 1920107120Sjulian 1921107120Sjulian if (pcb != NULL) 1922107120Sjulian return (EISCONN); 1923107120Sjulian 1924107120Sjulian /* Reserve send and receive space if it is not reserved yet */ 1925107120Sjulian if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 1926107120Sjulian error = soreserve(so, NG_BTSOCKET_L2CAP_SENDSPACE, 1927107120Sjulian NG_BTSOCKET_L2CAP_RECVSPACE); 1928107120Sjulian if (error != 0) 1929107120Sjulian return (error); 1930107120Sjulian } 1931107120Sjulian 1932107120Sjulian /* Allocate the PCB */ 1933184205Sdes pcb = malloc(sizeof(*pcb), 1934107120Sjulian M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT | M_ZERO); 1935107120Sjulian if (pcb == NULL) 1936107120Sjulian return (ENOMEM); 1937107120Sjulian 1938107120Sjulian /* Link the PCB and the socket */ 1939107120Sjulian so->so_pcb = (caddr_t) pcb; 1940107120Sjulian pcb->so = so; 1941107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1942107120Sjulian 1943107120Sjulian /* Initialize PCB */ 1944107120Sjulian pcb->imtu = pcb->omtu = NG_L2CAP_MTU_DEFAULT; 1945107120Sjulian 1946107120Sjulian /* Default flow */ 1947107120Sjulian pcb->iflow.flags = 0x0; 1948107120Sjulian pcb->iflow.service_type = NG_HCI_SERVICE_TYPE_BEST_EFFORT; 1949107120Sjulian pcb->iflow.token_rate = 0xffffffff; /* maximum */ 1950107120Sjulian pcb->iflow.token_bucket_size = 0xffffffff; /* maximum */ 1951107120Sjulian pcb->iflow.peak_bandwidth = 0x00000000; /* maximum */ 1952107120Sjulian pcb->iflow.latency = 0xffffffff; /* don't care */ 1953107120Sjulian pcb->iflow.delay_variation = 0xffffffff; /* don't care */ 1954107120Sjulian 1955107120Sjulian bcopy(&pcb->iflow, &pcb->oflow, sizeof(pcb->oflow)); 1956107120Sjulian 1957107120Sjulian pcb->flush_timo = NG_L2CAP_FLUSH_TIMO_DEFAULT; 1958107120Sjulian pcb->link_timo = NG_L2CAP_LINK_TIMO_DEFAULT; 1959107120Sjulian 1960107120Sjulian callout_handle_init(&pcb->timo); 1961107120Sjulian 1962114878Sjulian /* 1963114878Sjulian * XXX Mark PCB mutex as DUPOK to prevent "duplicated lock of 1964114878Sjulian * the same type" message. When accepting new L2CAP connection 1965114878Sjulian * ng_btsocket_l2cap_process_l2ca_con_ind() holds both PCB mutexes 1966114878Sjulian * for "old" (accepting) PCB and "new" (created) PCB. 1967114878Sjulian */ 1968114878Sjulian 1969114878Sjulian mtx_init(&pcb->pcb_mtx, "btsocks_l2cap_pcb_mtx", NULL, 1970114878Sjulian MTX_DEF|MTX_DUPOK); 1971114878Sjulian 1972114878Sjulian /* 1973114878Sjulian * Add the PCB to the list 1974114878Sjulian * 1975114878Sjulian * XXX FIXME VERY IMPORTANT! 1976114878Sjulian * 1977114878Sjulian * This is totally FUBAR. We could get here in two cases: 1978114878Sjulian * 1979114878Sjulian * 1) When user calls socket() 1980114878Sjulian * 2) When we need to accept new incomming connection and call 1981114878Sjulian * sonewconn() 1982114878Sjulian * 1983170035Srwatson * In the first case we must acquire ng_btsocket_l2cap_sockets_mtx. 1984114878Sjulian * In the second case we hold ng_btsocket_l2cap_sockets_mtx already. 1985114878Sjulian * So we now need to distinguish between these cases. From reading 1986167907Smaxim * /sys/kern/uipc_socket.c we can find out that sonewconn() calls 1987114878Sjulian * pru_attach with proto == 0 and td == NULL. For now use this fact 1988114878Sjulian * to figure out if we were called from socket() or from sonewconn(). 1989114878Sjulian */ 1990114878Sjulian 1991114878Sjulian if (td != NULL) 1992114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1993114878Sjulian else 1994114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 1995114878Sjulian 1996114878Sjulian /* Set PCB token. Use ng_btsocket_l2cap_sockets_mtx for protection */ 1997114878Sjulian if (++ token == 0) 1998114878Sjulian token ++; 1999114878Sjulian 2000114878Sjulian pcb->token = token; 2001114878Sjulian 2002107120Sjulian LIST_INSERT_HEAD(&ng_btsocket_l2cap_sockets, pcb, next); 2003107120Sjulian 2004114878Sjulian if (td != NULL) 2005114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2006114878Sjulian 2007107120Sjulian return (0); 2008107120Sjulian} /* ng_btsocket_l2cap_attach */ 2009107120Sjulian 2010107120Sjulian/* 2011107120Sjulian * Bind socket 2012107120Sjulian */ 2013107120Sjulian 2014107120Sjulianint 2015107120Sjulianng_btsocket_l2cap_bind(struct socket *so, struct sockaddr *nam, 2016107120Sjulian struct thread *td) 2017107120Sjulian{ 2018107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 2019107120Sjulian struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2020107120Sjulian int psm, error = 0; 2021107120Sjulian 2022107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2023107120Sjulian return (EINVAL); 2024107120Sjulian 2025107120Sjulian /* Verify address */ 2026107120Sjulian if (sa == NULL) 2027107120Sjulian return (EINVAL); 2028107120Sjulian if (sa->l2cap_family != AF_BLUETOOTH) 2029107120Sjulian return (EAFNOSUPPORT); 2030107120Sjulian if (sa->l2cap_len != sizeof(*sa)) 2031107120Sjulian return (EINVAL); 2032107120Sjulian 2033107120Sjulian psm = le16toh(sa->l2cap_psm); 2034107120Sjulian 2035107120Sjulian /* 2036107120Sjulian * Check if other socket has this address already (look for exact 2037107120Sjulian * match PSM and bdaddr) and assign socket address if it's available. 2038107120Sjulian * 2039107120Sjulian * Note: socket can be bound to ANY PSM (zero) thus allowing several 2040107120Sjulian * channels with the same PSM between the same pair of BD_ADDR'es. 2041107120Sjulian */ 2042107120Sjulian 2043107120Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2044107120Sjulian 2045107120Sjulian LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) 2046107120Sjulian if (psm != 0 && psm == pcb->psm && 2047107120Sjulian bcmp(&pcb->src, &sa->l2cap_bdaddr, sizeof(bdaddr_t)) == 0) 2048107120Sjulian break; 2049107120Sjulian 2050107120Sjulian if (pcb == NULL) { 2051107120Sjulian /* Set socket address */ 2052107120Sjulian pcb = so2l2cap_pcb(so); 2053107120Sjulian if (pcb != NULL) { 2054107120Sjulian bcopy(&sa->l2cap_bdaddr, &pcb->src, sizeof(pcb->src)); 2055107120Sjulian pcb->psm = psm; 2056107120Sjulian } else 2057107120Sjulian error = EINVAL; 2058107120Sjulian } else 2059107120Sjulian error = EADDRINUSE; 2060107120Sjulian 2061107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2062107120Sjulian 2063107120Sjulian return (error); 2064107120Sjulian} /* ng_btsocket_l2cap_bind */ 2065107120Sjulian 2066107120Sjulian/* 2067107120Sjulian * Connect socket 2068107120Sjulian */ 2069107120Sjulian 2070107120Sjulianint 2071107120Sjulianng_btsocket_l2cap_connect(struct socket *so, struct sockaddr *nam, 2072107120Sjulian struct thread *td) 2073107120Sjulian{ 2074107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2075107120Sjulian struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2076107120Sjulian ng_btsocket_l2cap_rtentry_t *rt = NULL; 2077107120Sjulian int have_src, error = 0; 2078107120Sjulian 2079107120Sjulian /* Check socket */ 2080107120Sjulian if (pcb == NULL) 2081107120Sjulian return (EINVAL); 2082107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2083107120Sjulian return (EINVAL); 2084107120Sjulian if (pcb->state == NG_BTSOCKET_L2CAP_CONNECTING) 2085107120Sjulian return (EINPROGRESS); 2086107120Sjulian 2087107120Sjulian /* Verify address */ 2088107120Sjulian if (sa == NULL) 2089107120Sjulian return (EINVAL); 2090107120Sjulian if (sa->l2cap_family != AF_BLUETOOTH) 2091107120Sjulian return (EAFNOSUPPORT); 2092107120Sjulian if (sa->l2cap_len != sizeof(*sa)) 2093107120Sjulian return (EINVAL); 2094107120Sjulian if (sa->l2cap_psm == 0 || 2095107120Sjulian bcmp(&sa->l2cap_bdaddr, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 2096107120Sjulian return (EDESTADDRREQ); 2097107120Sjulian if (pcb->psm != 0 && pcb->psm != le16toh(sa->l2cap_psm)) 2098107120Sjulian return (EINVAL); 2099107120Sjulian 2100107120Sjulian /* 2101107120Sjulian * Routing. Socket should be bound to some source address. The source 2102107120Sjulian * address can be ANY. Destination address must be set and it must not 2103107120Sjulian * be ANY. If source address is ANY then find first rtentry that has 2104107120Sjulian * src != dst. 2105107120Sjulian */ 2106107120Sjulian 2107114878Sjulian mtx_lock(&ng_btsocket_l2cap_rt_mtx); 2108114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2109114878Sjulian mtx_lock(&pcb->pcb_mtx); 2110114878Sjulian 2111114878Sjulian /* Send destination address and PSM */ 2112114878Sjulian bcopy(&sa->l2cap_bdaddr, &pcb->dst, sizeof(pcb->dst)); 2113114878Sjulian pcb->psm = le16toh(sa->l2cap_psm); 2114114878Sjulian 2115107120Sjulian pcb->rt = NULL; 2116107120Sjulian have_src = bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)); 2117107120Sjulian 2118107120Sjulian LIST_FOREACH(rt, &ng_btsocket_l2cap_rt, next) { 2119107120Sjulian if (rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 2120107120Sjulian continue; 2121107120Sjulian 2122107120Sjulian /* Match src and dst */ 2123107120Sjulian if (have_src) { 2124107120Sjulian if (bcmp(&pcb->src, &rt->src, sizeof(rt->src)) == 0) 2125107120Sjulian break; 2126107120Sjulian } else { 2127107120Sjulian if (bcmp(&pcb->dst, &rt->src, sizeof(rt->src)) != 0) 2128107120Sjulian break; 2129107120Sjulian } 2130107120Sjulian } 2131107120Sjulian 2132107120Sjulian if (rt != NULL) { 2133107120Sjulian pcb->rt = rt; 2134107120Sjulian 2135107120Sjulian if (!have_src) 2136107120Sjulian bcopy(&rt->src, &pcb->src, sizeof(pcb->src)); 2137107120Sjulian } else 2138107120Sjulian error = EHOSTUNREACH; 2139107120Sjulian 2140107120Sjulian /* 2141107120Sjulian * Send L2CA_Connect request 2142107120Sjulian */ 2143107120Sjulian 2144107120Sjulian if (error == 0) { 2145107120Sjulian error = ng_btsocket_l2cap_send_l2ca_con_req(pcb); 2146107120Sjulian if (error == 0) { 2147107120Sjulian pcb->flags |= NG_BTSOCKET_L2CAP_CLIENT; 2148107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CONNECTING; 2149107120Sjulian soisconnecting(pcb->so); 2150107120Sjulian 2151107120Sjulian ng_btsocket_l2cap_timeout(pcb); 2152107120Sjulian } 2153107120Sjulian } 2154107120Sjulian 2155114878Sjulian mtx_unlock(&pcb->pcb_mtx); 2156114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2157114878Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 2158114878Sjulian 2159107120Sjulian return (error); 2160107120Sjulian} /* ng_btsocket_l2cap_connect */ 2161107120Sjulian 2162107120Sjulian/* 2163107120Sjulian * Process ioctl's calls on socket 2164107120Sjulian */ 2165107120Sjulian 2166107120Sjulianint 2167107120Sjulianng_btsocket_l2cap_control(struct socket *so, u_long cmd, caddr_t data, 2168107120Sjulian struct ifnet *ifp, struct thread *td) 2169107120Sjulian{ 2170107120Sjulian return (EINVAL); 2171107120Sjulian} /* ng_btsocket_l2cap_control */ 2172107120Sjulian 2173107120Sjulian/* 2174107120Sjulian * Process getsockopt/setsockopt system calls 2175107120Sjulian */ 2176107120Sjulian 2177107120Sjulianint 2178107120Sjulianng_btsocket_l2cap_ctloutput(struct socket *so, struct sockopt *sopt) 2179107120Sjulian{ 2180107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2181107120Sjulian int error = 0; 2182107120Sjulian ng_l2cap_cfg_opt_val_t v; 2183107120Sjulian 2184107120Sjulian if (pcb == NULL) 2185107120Sjulian return (EINVAL); 2186107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2187107120Sjulian return (EINVAL); 2188107120Sjulian 2189107120Sjulian if (sopt->sopt_level != SOL_L2CAP) 2190107120Sjulian return (0); 2191107120Sjulian 2192107120Sjulian mtx_lock(&pcb->pcb_mtx); 2193107120Sjulian 2194107120Sjulian switch (sopt->sopt_dir) { 2195107120Sjulian case SOPT_GET: 2196107120Sjulian switch (sopt->sopt_name) { 2197107120Sjulian case SO_L2CAP_IMTU: /* get incoming MTU */ 2198107120Sjulian error = sooptcopyout(sopt, &pcb->imtu, 2199107120Sjulian sizeof(pcb->imtu)); 2200107120Sjulian break; 2201107120Sjulian 2202107120Sjulian case SO_L2CAP_OMTU: /* get outgoing (peer incoming) MTU */ 2203107120Sjulian error = sooptcopyout(sopt, &pcb->omtu, 2204107120Sjulian sizeof(pcb->omtu)); 2205107120Sjulian break; 2206107120Sjulian 2207107120Sjulian case SO_L2CAP_IFLOW: /* get incoming flow spec. */ 2208107120Sjulian error = sooptcopyout(sopt, &pcb->iflow, 2209107120Sjulian sizeof(pcb->iflow)); 2210107120Sjulian break; 2211107120Sjulian 2212107120Sjulian case SO_L2CAP_OFLOW: /* get outgoing flow spec. */ 2213107120Sjulian error = sooptcopyout(sopt, &pcb->oflow, 2214107120Sjulian sizeof(pcb->oflow)); 2215107120Sjulian break; 2216107120Sjulian 2217107120Sjulian case SO_L2CAP_FLUSH: /* get flush timeout */ 2218107120Sjulian error = sooptcopyout(sopt, &pcb->flush_timo, 2219107120Sjulian sizeof(pcb->flush_timo)); 2220107120Sjulian break; 2221107120Sjulian 2222107120Sjulian default: 2223107120Sjulian error = ENOPROTOOPT; 2224107120Sjulian break; 2225107120Sjulian } 2226107120Sjulian break; 2227107120Sjulian 2228107120Sjulian case SOPT_SET: 2229107120Sjulian /* 2230114878Sjulian * XXX 2231114878Sjulian * We do not allow to change these parameters while socket is 2232114878Sjulian * connected or we are in the process of creating a connection. 2233114878Sjulian * May be this should indicate re-configuration of the open 2234114878Sjulian * channel? 2235107120Sjulian */ 2236107120Sjulian 2237173231Semax if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 2238173231Semax error = EACCES; 2239173231Semax break; 2240173231Semax } 2241107120Sjulian 2242107120Sjulian switch (sopt->sopt_name) { 2243107120Sjulian case SO_L2CAP_IMTU: /* set incoming MTU */ 2244107120Sjulian error = sooptcopyin(sopt, &v, sizeof(v), sizeof(v.mtu)); 2245107120Sjulian if (error == 0) 2246107120Sjulian pcb->imtu = v.mtu; 2247107120Sjulian break; 2248107120Sjulian 2249107120Sjulian case SO_L2CAP_OFLOW: /* set outgoing flow spec. */ 2250107120Sjulian error = sooptcopyin(sopt, &v, sizeof(v),sizeof(v.flow)); 2251107120Sjulian if (error == 0) 2252107120Sjulian bcopy(&v.flow, &pcb->oflow, sizeof(pcb->oflow)); 2253107120Sjulian break; 2254107120Sjulian 2255107120Sjulian case SO_L2CAP_FLUSH: /* set flush timeout */ 2256107120Sjulian error = sooptcopyin(sopt, &v, sizeof(v), 2257107120Sjulian sizeof(v.flush_timo)); 2258107120Sjulian if (error == 0) 2259107120Sjulian pcb->flush_timo = v.flush_timo; 2260107120Sjulian break; 2261107120Sjulian 2262107120Sjulian default: 2263107120Sjulian error = ENOPROTOOPT; 2264107120Sjulian break; 2265107120Sjulian } 2266107120Sjulian break; 2267107120Sjulian 2268107120Sjulian default: 2269107120Sjulian error = EINVAL; 2270107120Sjulian break; 2271107120Sjulian } 2272107120Sjulian 2273107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2274107120Sjulian 2275107120Sjulian return (error); 2276107120Sjulian} /* ng_btsocket_l2cap_ctloutput */ 2277107120Sjulian 2278107120Sjulian/* 2279107120Sjulian * Detach and destroy socket 2280107120Sjulian */ 2281107120Sjulian 2282157370Srwatsonvoid 2283107120Sjulianng_btsocket_l2cap_detach(struct socket *so) 2284107120Sjulian{ 2285107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2286107120Sjulian 2287157370Srwatson KASSERT(pcb != NULL, ("ng_btsocket_l2cap_detach: pcb == NULL")); 2288157370Srwatson 2289107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2290157370Srwatson return; 2291107120Sjulian 2292114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2293107120Sjulian mtx_lock(&pcb->pcb_mtx); 2294107120Sjulian 2295107120Sjulian /* XXX what to do with pending request? */ 2296107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2297107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 2298107120Sjulian 2299107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED && 2300107120Sjulian pcb->state != NG_BTSOCKET_L2CAP_DISCONNECTING) 2301107120Sjulian /* Send disconnect request with "zero" token */ 2302107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2303107120Sjulian 2304107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2305107120Sjulian 2306114878Sjulian LIST_REMOVE(pcb, next); 2307107120Sjulian 2308107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2309107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2310107120Sjulian 2311107120Sjulian mtx_destroy(&pcb->pcb_mtx); 2312107120Sjulian bzero(pcb, sizeof(*pcb)); 2313184205Sdes free(pcb, M_NETGRAPH_BTSOCKET_L2CAP); 2314107120Sjulian 2315114878Sjulian soisdisconnected(so); 2316114878Sjulian so->so_pcb = NULL; 2317107120Sjulian} /* ng_btsocket_l2cap_detach */ 2318107120Sjulian 2319107120Sjulian/* 2320107120Sjulian * Disconnect socket 2321107120Sjulian */ 2322107120Sjulian 2323107120Sjulianint 2324107120Sjulianng_btsocket_l2cap_disconnect(struct socket *so) 2325107120Sjulian{ 2326107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2327107120Sjulian int error = 0; 2328107120Sjulian 2329107120Sjulian if (pcb == NULL) 2330107120Sjulian return (EINVAL); 2331107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2332107120Sjulian return (EINVAL); 2333107120Sjulian 2334107120Sjulian mtx_lock(&pcb->pcb_mtx); 2335107120Sjulian 2336107120Sjulian if (pcb->state == NG_BTSOCKET_L2CAP_DISCONNECTING) { 2337107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2338107120Sjulian return (EINPROGRESS); 2339107120Sjulian } 2340107120Sjulian 2341107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 2342107120Sjulian /* XXX FIXME what to do with pending request? */ 2343107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2344107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 2345107120Sjulian 2346107120Sjulian error = ng_btsocket_l2cap_send_l2ca_discon_req(pcb->token, pcb); 2347107120Sjulian if (error == 0) { 2348107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_DISCONNECTING; 2349107120Sjulian soisdisconnecting(so); 2350107120Sjulian 2351107120Sjulian ng_btsocket_l2cap_timeout(pcb); 2352107120Sjulian } 2353107120Sjulian 2354107120Sjulian /* XXX FIXME what to do if error != 0 */ 2355107120Sjulian } 2356107120Sjulian 2357107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2358107120Sjulian 2359107120Sjulian return (error); 2360107120Sjulian} /* ng_btsocket_l2cap_disconnect */ 2361107120Sjulian 2362107120Sjulian/* 2363107120Sjulian * Listen on socket 2364107120Sjulian */ 2365107120Sjulian 2366107120Sjulianint 2367151888Srwatsonng_btsocket_l2cap_listen(struct socket *so, int backlog, struct thread *td) 2368107120Sjulian{ 2369107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2370142190Srwatson int error; 2371107120Sjulian 2372142190Srwatson SOCK_LOCK(so); 2373142190Srwatson error = solisten_proto_check(so); 2374142190Srwatson if (error != 0) 2375142190Srwatson goto out; 2376142190Srwatson if (pcb == NULL) { 2377142190Srwatson error = EINVAL; 2378142190Srwatson goto out; 2379142190Srwatson } 2380142190Srwatson if (ng_btsocket_l2cap_node == NULL) { 2381142190Srwatson error = EINVAL; 2382142190Srwatson goto out; 2383142190Srwatson } 2384142190Srwatson if (pcb->psm == 0) { 2385171937Semax error = EADDRNOTAVAIL; 2386142190Srwatson goto out; 2387142190Srwatson } 2388151888Srwatson solisten_proto(so, backlog); 2389142190Srwatsonout: 2390142190Srwatson SOCK_UNLOCK(so); 2391142190Srwatson return (error); 2392107120Sjulian} /* ng_btsocket_listen */ 2393107120Sjulian 2394107120Sjulian/* 2395107120Sjulian * Get peer address 2396107120Sjulian */ 2397107120Sjulian 2398107120Sjulianint 2399107120Sjulianng_btsocket_l2cap_peeraddr(struct socket *so, struct sockaddr **nam) 2400107120Sjulian{ 2401107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2402107120Sjulian struct sockaddr_l2cap sa; 2403107120Sjulian 2404107120Sjulian if (pcb == NULL) 2405107120Sjulian return (EINVAL); 2406107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2407107120Sjulian return (EINVAL); 2408107120Sjulian 2409107120Sjulian bcopy(&pcb->dst, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2410107120Sjulian sa.l2cap_psm = htole16(pcb->psm); 2411107120Sjulian sa.l2cap_len = sizeof(sa); 2412107120Sjulian sa.l2cap_family = AF_BLUETOOTH; 2413107120Sjulian 2414126425Srwatson *nam = sodupsockaddr((struct sockaddr *) &sa, M_NOWAIT); 2415107120Sjulian 2416107120Sjulian return ((*nam == NULL)? ENOMEM : 0); 2417107120Sjulian} /* ng_btsocket_l2cap_peeraddr */ 2418107120Sjulian 2419107120Sjulian/* 2420107120Sjulian * Send data to socket 2421107120Sjulian */ 2422107120Sjulian 2423107120Sjulianint 2424107120Sjulianng_btsocket_l2cap_send(struct socket *so, int flags, struct mbuf *m, 2425107120Sjulian struct sockaddr *nam, struct mbuf *control, struct thread *td) 2426107120Sjulian{ 2427107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2428107120Sjulian int error = 0; 2429107120Sjulian 2430107120Sjulian if (ng_btsocket_l2cap_node == NULL) { 2431107120Sjulian error = ENETDOWN; 2432107120Sjulian goto drop; 2433107120Sjulian } 2434107120Sjulian 2435107120Sjulian /* Check socket and input */ 2436107120Sjulian if (pcb == NULL || m == NULL || control != NULL) { 2437107120Sjulian error = EINVAL; 2438107120Sjulian goto drop; 2439107120Sjulian } 2440107120Sjulian 2441107120Sjulian mtx_lock(&pcb->pcb_mtx); 2442107120Sjulian 2443107120Sjulian /* Make sure socket is connected */ 2444107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 2445107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2446107120Sjulian error = ENOTCONN; 2447107120Sjulian goto drop; 2448107120Sjulian } 2449107120Sjulian 2450107120Sjulian /* Check route */ 2451107120Sjulian if (pcb->rt == NULL || 2452107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) { 2453107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2454107120Sjulian error = ENETDOWN; 2455107120Sjulian goto drop; 2456107120Sjulian } 2457107120Sjulian 2458107120Sjulian /* Check packet size agains outgoing (peer's incoming) MTU) */ 2459107120Sjulian if (m->m_pkthdr.len > pcb->omtu) { 2460107120Sjulian NG_BTSOCKET_L2CAP_ERR( 2461107120Sjulian"%s: Packet too big, len=%d, omtu=%d\n", __func__, m->m_pkthdr.len, pcb->omtu); 2462107120Sjulian 2463107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2464107120Sjulian error = EMSGSIZE; 2465107120Sjulian goto drop; 2466107120Sjulian } 2467107120Sjulian 2468107120Sjulian /* 2469107120Sjulian * First put packet on socket send queue. Then check if we have 2470107120Sjulian * pending timeout. If we do not have timeout then we must send 2471107120Sjulian * packet and schedule timeout. Otherwise do nothing and wait for 2472107120Sjulian * L2CA_WRITE_RSP. 2473107120Sjulian */ 2474107120Sjulian 2475107120Sjulian sbappendrecord(&pcb->so->so_snd, m); 2476107120Sjulian m = NULL; 2477107120Sjulian 2478107120Sjulian if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2479107120Sjulian error = ng_btsocket_l2cap_send2(pcb); 2480107120Sjulian if (error == 0) 2481107120Sjulian ng_btsocket_l2cap_timeout(pcb); 2482107120Sjulian else 2483107120Sjulian sbdroprecord(&pcb->so->so_snd); /* XXX */ 2484107120Sjulian } 2485107120Sjulian 2486107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2487107120Sjuliandrop: 2488107120Sjulian NG_FREE_M(m); /* checks for != NULL */ 2489107120Sjulian NG_FREE_M(control); 2490107120Sjulian 2491107120Sjulian return (error); 2492107120Sjulian} /* ng_btsocket_l2cap_send */ 2493107120Sjulian 2494107120Sjulian/* 2495107120Sjulian * Send first packet in the socket queue to the L2CAP layer 2496107120Sjulian */ 2497107120Sjulian 2498107120Sjulianstatic int 2499107120Sjulianng_btsocket_l2cap_send2(ng_btsocket_l2cap_pcb_p pcb) 2500107120Sjulian{ 2501107120Sjulian struct mbuf *m = NULL; 2502107120Sjulian ng_l2cap_l2ca_hdr_t *hdr = NULL; 2503107120Sjulian int error = 0; 2504107120Sjulian 2505107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2506107120Sjulian 2507107120Sjulian if (pcb->so->so_snd.sb_cc == 0) 2508107120Sjulian return (EINVAL); /* XXX */ 2509107120Sjulian 2510111119Simp m = m_dup(pcb->so->so_snd.sb_mb, M_DONTWAIT); 2511107120Sjulian if (m == NULL) 2512107120Sjulian return (ENOBUFS); 2513107120Sjulian 2514107120Sjulian /* Create L2CA packet header */ 2515114878Sjulian M_PREPEND(m, sizeof(*hdr), M_DONTWAIT); 2516107120Sjulian if (m != NULL) 2517107120Sjulian if (m->m_len < sizeof(*hdr)) 2518107120Sjulian m = m_pullup(m, sizeof(*hdr)); 2519107120Sjulian 2520107120Sjulian if (m == NULL) { 2521107120Sjulian NG_BTSOCKET_L2CAP_ERR( 2522107120Sjulian"%s: Failed to create L2CA packet header\n", __func__); 2523107120Sjulian 2524107120Sjulian return (ENOBUFS); 2525107120Sjulian } 2526107120Sjulian 2527107120Sjulian hdr = mtod(m, ng_l2cap_l2ca_hdr_t *); 2528107120Sjulian hdr->token = pcb->token; 2529107120Sjulian hdr->length = m->m_pkthdr.len - sizeof(*hdr); 2530107120Sjulian hdr->lcid = pcb->cid; 2531107120Sjulian 2532107120Sjulian NG_BTSOCKET_L2CAP_INFO( 2533107120Sjulian"%s: Sending packet: len=%d, length=%d, lcid=%d, token=%d, state=%d\n", 2534107120Sjulian __func__, m->m_pkthdr.len, hdr->length, hdr->lcid, 2535107120Sjulian hdr->token, pcb->state); 2536107120Sjulian 2537107120Sjulian /* 2538107120Sjulian * If we got here than we have successfuly creates new L2CAP 2539107120Sjulian * data packet and now we can send it to the L2CAP layer 2540107120Sjulian */ 2541107120Sjulian 2542107120Sjulian NG_SEND_DATA_ONLY(error, pcb->rt->hook, m); 2543107120Sjulian 2544107120Sjulian return (error); 2545107120Sjulian} /* ng_btsocket_l2cap_send2 */ 2546107120Sjulian 2547107120Sjulian/* 2548107120Sjulian * Get socket address 2549107120Sjulian */ 2550107120Sjulian 2551107120Sjulianint 2552107120Sjulianng_btsocket_l2cap_sockaddr(struct socket *so, struct sockaddr **nam) 2553107120Sjulian{ 2554107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2555107120Sjulian struct sockaddr_l2cap sa; 2556107120Sjulian 2557107120Sjulian if (pcb == NULL) 2558107120Sjulian return (EINVAL); 2559107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2560107120Sjulian return (EINVAL); 2561107120Sjulian 2562107120Sjulian bcopy(&pcb->src, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2563107120Sjulian sa.l2cap_psm = htole16(pcb->psm); 2564107120Sjulian sa.l2cap_len = sizeof(sa); 2565107120Sjulian sa.l2cap_family = AF_BLUETOOTH; 2566107120Sjulian 2567126425Srwatson *nam = sodupsockaddr((struct sockaddr *) &sa, M_NOWAIT); 2568107120Sjulian 2569107120Sjulian return ((*nam == NULL)? ENOMEM : 0); 2570107120Sjulian} /* ng_btsocket_l2cap_sockaddr */ 2571107120Sjulian 2572107120Sjulian/***************************************************************************** 2573107120Sjulian ***************************************************************************** 2574107120Sjulian ** Misc. functions 2575107120Sjulian ***************************************************************************** 2576107120Sjulian *****************************************************************************/ 2577107120Sjulian 2578107120Sjulian/* 2579107120Sjulian * Look for the socket that listens on given PSM and bdaddr. Returns exact or 2580114878Sjulian * close match (if any). Caller must hold ng_btsocket_l2cap_sockets_mtx. 2581107120Sjulian */ 2582107120Sjulian 2583107120Sjulianstatic ng_btsocket_l2cap_pcb_p 2584107120Sjulianng_btsocket_l2cap_pcb_by_addr(bdaddr_p bdaddr, int psm) 2585107120Sjulian{ 2586107120Sjulian ng_btsocket_l2cap_pcb_p p = NULL, p1 = NULL; 2587107120Sjulian 2588114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2589107120Sjulian 2590107120Sjulian LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) { 2591107120Sjulian if (p->so == NULL || !(p->so->so_options & SO_ACCEPTCONN) || 2592107120Sjulian p->psm != psm) 2593107120Sjulian continue; 2594107120Sjulian 2595107120Sjulian if (bcmp(&p->src, bdaddr, sizeof(p->src)) == 0) 2596107120Sjulian break; 2597107120Sjulian 2598107120Sjulian if (bcmp(&p->src, NG_HCI_BDADDR_ANY, sizeof(p->src)) == 0) 2599107120Sjulian p1 = p; 2600107120Sjulian } 2601107120Sjulian 2602107120Sjulian return ((p != NULL)? p : p1); 2603107120Sjulian} /* ng_btsocket_l2cap_pcb_by_addr */ 2604107120Sjulian 2605107120Sjulian/* 2606114878Sjulian * Look for the socket that has given token. 2607114878Sjulian * Caller must hold ng_btsocket_l2cap_sockets_mtx. 2608107120Sjulian */ 2609107120Sjulian 2610107120Sjulianstatic ng_btsocket_l2cap_pcb_p 2611107120Sjulianng_btsocket_l2cap_pcb_by_token(u_int32_t token) 2612107120Sjulian{ 2613107120Sjulian ng_btsocket_l2cap_pcb_p p = NULL; 2614107120Sjulian 2615114878Sjulian if (token == 0) 2616114878Sjulian return (NULL); 2617107120Sjulian 2618114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2619107120Sjulian 2620114878Sjulian LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2621114878Sjulian if (p->token == token) 2622114878Sjulian break; 2623107120Sjulian 2624107120Sjulian return (p); 2625107120Sjulian} /* ng_btsocket_l2cap_pcb_by_token */ 2626107120Sjulian 2627107120Sjulian/* 2628114878Sjulian * Look for the socket that assigned to given source address and channel ID. 2629114878Sjulian * Caller must hold ng_btsocket_l2cap_sockets_mtx 2630107120Sjulian */ 2631107120Sjulian 2632107120Sjulianstatic ng_btsocket_l2cap_pcb_p 2633107120Sjulianng_btsocket_l2cap_pcb_by_cid(bdaddr_p src, int cid) 2634107120Sjulian{ 2635107120Sjulian ng_btsocket_l2cap_pcb_p p = NULL; 2636107120Sjulian 2637114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2638107120Sjulian 2639107120Sjulian LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2640107120Sjulian if (p->cid == cid && bcmp(src, &p->src, sizeof(p->src)) == 0) 2641107120Sjulian break; 2642107120Sjulian 2643107120Sjulian return (p); 2644107120Sjulian} /* ng_btsocket_l2cap_pcb_by_cid */ 2645107120Sjulian 2646107120Sjulian/* 2647107120Sjulian * Set timeout on socket 2648107120Sjulian */ 2649107120Sjulian 2650107120Sjulianstatic void 2651107120Sjulianng_btsocket_l2cap_timeout(ng_btsocket_l2cap_pcb_p pcb) 2652107120Sjulian{ 2653107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2654107120Sjulian 2655107120Sjulian if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2656107120Sjulian pcb->flags |= NG_BTSOCKET_L2CAP_TIMO; 2657107120Sjulian pcb->timo = timeout(ng_btsocket_l2cap_process_timeout, pcb, 2658107120Sjulian bluetooth_l2cap_ertx_timeout()); 2659107120Sjulian } else 2660107120Sjulian KASSERT(0, 2661107120Sjulian("%s: Duplicated socket timeout?!\n", __func__)); 2662107120Sjulian} /* ng_btsocket_l2cap_timeout */ 2663107120Sjulian 2664107120Sjulian/* 2665107120Sjulian * Unset timeout on socket 2666107120Sjulian */ 2667107120Sjulian 2668107120Sjulianstatic void 2669107120Sjulianng_btsocket_l2cap_untimeout(ng_btsocket_l2cap_pcb_p pcb) 2670107120Sjulian{ 2671107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2672107120Sjulian 2673107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) { 2674107120Sjulian untimeout(ng_btsocket_l2cap_process_timeout, pcb, pcb->timo); 2675107120Sjulian pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2676107120Sjulian } else 2677107120Sjulian KASSERT(0, 2678107120Sjulian("%s: No socket timeout?!\n", __func__)); 2679107120Sjulian} /* ng_btsocket_l2cap_untimeout */ 2680107120Sjulian 2681107120Sjulian/* 2682107120Sjulian * Process timeout on socket 2683107120Sjulian */ 2684107120Sjulian 2685107120Sjulianstatic void 2686107120Sjulianng_btsocket_l2cap_process_timeout(void *xpcb) 2687107120Sjulian{ 2688161623Semax ng_btsocket_l2cap_pcb_p pcb = (ng_btsocket_l2cap_pcb_p) xpcb; 2689107120Sjulian 2690107120Sjulian mtx_lock(&pcb->pcb_mtx); 2691107120Sjulian 2692107120Sjulian pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2693107120Sjulian pcb->so->so_error = ETIMEDOUT; 2694107120Sjulian 2695107120Sjulian switch (pcb->state) { 2696107120Sjulian case NG_BTSOCKET_L2CAP_CONNECTING: 2697107120Sjulian case NG_BTSOCKET_L2CAP_CONFIGURING: 2698107120Sjulian /* Send disconnect request with "zero" token */ 2699107120Sjulian if (pcb->cid != 0) 2700107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2701107120Sjulian 2702107120Sjulian /* ... and close the socket */ 2703107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2704107120Sjulian soisdisconnected(pcb->so); 2705107120Sjulian break; 2706107120Sjulian 2707107120Sjulian case NG_BTSOCKET_L2CAP_OPEN: 2708107120Sjulian /* Send timeout - drop packet and wakeup sender */ 2709107120Sjulian sbdroprecord(&pcb->so->so_snd); 2710107120Sjulian sowwakeup(pcb->so); 2711107120Sjulian break; 2712107120Sjulian 2713107120Sjulian case NG_BTSOCKET_L2CAP_DISCONNECTING: 2714107120Sjulian /* Disconnect timeout - disconnect the socket anyway */ 2715107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2716107120Sjulian soisdisconnected(pcb->so); 2717107120Sjulian break; 2718107120Sjulian 2719107120Sjulian default: 2720107120Sjulian NG_BTSOCKET_L2CAP_ERR( 2721107120Sjulian"%s: Invalid socket state=%d\n", __func__, pcb->state); 2722107120Sjulian break; 2723107120Sjulian } 2724107120Sjulian 2725107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2726107120Sjulian} /* ng_btsocket_l2cap_process_timeout */ 2727107120Sjulian 2728107120Sjulian/* 2729107120Sjulian * Translate HCI/L2CAP error code into "errno" code 2730107120Sjulian * XXX Note: Some L2CAP and HCI error codes have the same value, but 2731107120Sjulian * different meaning 2732107120Sjulian */ 2733107120Sjulian 2734107120Sjulianstatic int 2735107120Sjulianng_btsocket_l2cap_result2errno(int result) 2736107120Sjulian{ 2737107120Sjulian switch (result) { 2738107120Sjulian case 0x00: /* No error */ 2739107120Sjulian return (0); 2740107120Sjulian 2741107120Sjulian case 0x01: /* Unknown HCI command */ 2742107120Sjulian return (ENODEV); 2743107120Sjulian 2744107120Sjulian case 0x02: /* No connection */ 2745107120Sjulian return (ENOTCONN); 2746107120Sjulian 2747107120Sjulian case 0x03: /* Hardware failure */ 2748107120Sjulian return (EIO); 2749107120Sjulian 2750107120Sjulian case 0x04: /* Page timeout */ 2751107120Sjulian return (EHOSTDOWN); 2752107120Sjulian 2753107120Sjulian case 0x05: /* Authentication failure */ 2754107120Sjulian case 0x06: /* Key missing */ 2755107120Sjulian case 0x18: /* Pairing not allowed */ 2756107120Sjulian case 0x21: /* Role change not allowed */ 2757107120Sjulian case 0x24: /* LMP PSU not allowed */ 2758107120Sjulian case 0x25: /* Encryption mode not acceptable */ 2759107120Sjulian case 0x26: /* Unit key used */ 2760107120Sjulian return (EACCES); 2761107120Sjulian 2762107120Sjulian case 0x07: /* Memory full */ 2763107120Sjulian return (ENOMEM); 2764107120Sjulian 2765107120Sjulian case 0x08: /* Connection timeout */ 2766107120Sjulian case 0x10: /* Host timeout */ 2767107120Sjulian case 0x22: /* LMP response timeout */ 2768107120Sjulian case 0xee: /* HCI timeout */ 2769107120Sjulian case 0xeeee: /* L2CAP timeout */ 2770107120Sjulian return (ETIMEDOUT); 2771107120Sjulian 2772107120Sjulian case 0x09: /* Max number of connections */ 2773107120Sjulian case 0x0a: /* Max number of SCO connections to a unit */ 2774107120Sjulian return (EMLINK); 2775107120Sjulian 2776107120Sjulian case 0x0b: /* ACL connection already exists */ 2777107120Sjulian return (EEXIST); 2778107120Sjulian 2779107120Sjulian case 0x0c: /* Command disallowed */ 2780107120Sjulian return (EBUSY); 2781107120Sjulian 2782107120Sjulian case 0x0d: /* Host rejected due to limited resources */ 2783107120Sjulian case 0x0e: /* Host rejected due to securiity reasons */ 2784107120Sjulian case 0x0f: /* Host rejected due to remote unit is a personal unit */ 2785107120Sjulian case 0x1b: /* SCO offset rejected */ 2786107120Sjulian case 0x1c: /* SCO interval rejected */ 2787107120Sjulian case 0x1d: /* SCO air mode rejected */ 2788107120Sjulian return (ECONNREFUSED); 2789107120Sjulian 2790107120Sjulian case 0x11: /* Unsupported feature or parameter value */ 2791107120Sjulian case 0x19: /* Unknown LMP PDU */ 2792107120Sjulian case 0x1a: /* Unsupported remote feature */ 2793107120Sjulian case 0x20: /* Unsupported LMP parameter value */ 2794107120Sjulian case 0x27: /* QoS is not supported */ 2795107120Sjulian case 0x29: /* Paring with unit key not supported */ 2796107120Sjulian return (EOPNOTSUPP); 2797107120Sjulian 2798107120Sjulian case 0x12: /* Invalid HCI command parameter */ 2799107120Sjulian case 0x1e: /* Invalid LMP parameters */ 2800107120Sjulian return (EINVAL); 2801107120Sjulian 2802107120Sjulian case 0x13: /* Other end terminated connection: User ended connection */ 2803107120Sjulian case 0x14: /* Other end terminated connection: Low resources */ 2804107120Sjulian case 0x15: /* Other end terminated connection: About to power off */ 2805107120Sjulian return (ECONNRESET); 2806107120Sjulian 2807107120Sjulian case 0x16: /* Connection terminated by local host */ 2808107120Sjulian return (ECONNABORTED); 2809107120Sjulian 2810107120Sjulian#if 0 /* XXX not yet */ 2811107120Sjulian case 0x17: /* Repeated attempts */ 2812107120Sjulian case 0x1f: /* Unspecified error */ 2813107120Sjulian case 0x23: /* LMP error transaction collision */ 2814107120Sjulian case 0x28: /* Instant passed */ 2815107120Sjulian#endif 2816107120Sjulian } 2817107120Sjulian 2818107120Sjulian return (ENOSYS); 2819107120Sjulian} /* ng_btsocket_l2cap_result2errno */ 2820107120Sjulian 2821