ng_btsocket_l2cap.c revision 121054
1107120Sjulian/* 2107120Sjulian * ng_btsocket_l2cap.c 3107120Sjulian * 4107120Sjulian * Copyright (c) 2001-2002 Maksim Yevmenkin <m_evmenkin@yahoo.com> 5107120Sjulian * All rights reserved. 6107120Sjulian * 7107120Sjulian * Redistribution and use in source and binary forms, with or without 8107120Sjulian * modification, are permitted provided that the following conditions 9107120Sjulian * are met: 10107120Sjulian * 1. Redistributions of source code must retain the above copyright 11107120Sjulian * notice, this list of conditions and the following disclaimer. 12107120Sjulian * 2. Redistributions in binary form must reproduce the above copyright 13107120Sjulian * notice, this list of conditions and the following disclaimer in the 14107120Sjulian * documentation and/or other materials provided with the distribution. 15107120Sjulian * 16107120Sjulian * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 17107120Sjulian * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 18107120Sjulian * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 19107120Sjulian * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 20107120Sjulian * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 21107120Sjulian * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 22107120Sjulian * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 23107120Sjulian * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 24107120Sjulian * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 25107120Sjulian * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 26107120Sjulian * SUCH DAMAGE. 27107120Sjulian * 28121054Semax * $Id: ng_btsocket_l2cap.c,v 1.16 2003/09/14 23:29:06 max Exp $ 29107120Sjulian * $FreeBSD: head/sys/netgraph/bluetooth/socket/ng_btsocket_l2cap.c 121054 2003-10-12 22:04:24Z emax $ 30107120Sjulian */ 31107120Sjulian 32107120Sjulian#include <sys/param.h> 33107120Sjulian#include <sys/systm.h> 34121054Semax#include <sys/bitstring.h> 35107120Sjulian#include <sys/domain.h> 36107120Sjulian#include <sys/endian.h> 37107120Sjulian#include <sys/errno.h> 38107120Sjulian#include <sys/filedesc.h> 39107120Sjulian#include <sys/ioccom.h> 40107120Sjulian#include <sys/kernel.h> 41107120Sjulian#include <sys/lock.h> 42107120Sjulian#include <sys/malloc.h> 43107120Sjulian#include <sys/mbuf.h> 44107120Sjulian#include <sys/mutex.h> 45107120Sjulian#include <sys/protosw.h> 46107120Sjulian#include <sys/queue.h> 47107120Sjulian#include <sys/socket.h> 48107120Sjulian#include <sys/socketvar.h> 49107120Sjulian#include <sys/sysctl.h> 50107120Sjulian#include <sys/taskqueue.h> 51107120Sjulian#include <netgraph/ng_message.h> 52107120Sjulian#include <netgraph/netgraph.h> 53107120Sjulian#include "ng_bluetooth.h" 54107120Sjulian#include "ng_hci.h" 55107120Sjulian#include "ng_l2cap.h" 56107120Sjulian#include "ng_btsocket.h" 57107120Sjulian#include "ng_btsocket_l2cap.h" 58107120Sjulian 59107120Sjulian/* MALLOC define */ 60107120Sjulian#ifdef NG_SEPARATE_MALLOC 61107120SjulianMALLOC_DEFINE(M_NETGRAPH_BTSOCKET_L2CAP, "netgraph_btsocks_l2cap", 62107120Sjulian "Netgraph Bluetooth L2CAP sockets"); 63107120Sjulian#else 64107120Sjulian#define M_NETGRAPH_BTSOCKET_L2CAP M_NETGRAPH 65107120Sjulian#endif /* NG_SEPARATE_MALLOC */ 66107120Sjulian 67107120Sjulian/* Netgraph node methods */ 68107120Sjulianstatic ng_constructor_t ng_btsocket_l2cap_node_constructor; 69107120Sjulianstatic ng_rcvmsg_t ng_btsocket_l2cap_node_rcvmsg; 70107120Sjulianstatic ng_shutdown_t ng_btsocket_l2cap_node_shutdown; 71107120Sjulianstatic ng_newhook_t ng_btsocket_l2cap_node_newhook; 72107120Sjulianstatic ng_connect_t ng_btsocket_l2cap_node_connect; 73107120Sjulianstatic ng_rcvdata_t ng_btsocket_l2cap_node_rcvdata; 74107120Sjulianstatic ng_disconnect_t ng_btsocket_l2cap_node_disconnect; 75107120Sjulian 76107120Sjulianstatic void ng_btsocket_l2cap_input (void *, int); 77107120Sjulianstatic void ng_btsocket_l2cap_rtclean (void *, int); 78107120Sjulian 79107120Sjulian/* Netgraph type descriptor */ 80107120Sjulianstatic struct ng_type typestruct = { 81107120Sjulian NG_ABI_VERSION, 82107120Sjulian NG_BTSOCKET_L2CAP_NODE_TYPE, /* typename */ 83107120Sjulian NULL, /* modevent */ 84107120Sjulian ng_btsocket_l2cap_node_constructor, /* constructor */ 85107120Sjulian ng_btsocket_l2cap_node_rcvmsg, /* control message */ 86107120Sjulian ng_btsocket_l2cap_node_shutdown, /* destructor */ 87107120Sjulian ng_btsocket_l2cap_node_newhook, /* new hook */ 88107120Sjulian NULL, /* find hook */ 89107120Sjulian ng_btsocket_l2cap_node_connect, /* connect hook */ 90107120Sjulian ng_btsocket_l2cap_node_rcvdata, /* data */ 91107120Sjulian ng_btsocket_l2cap_node_disconnect, /* disconnect hook */ 92107120Sjulian NULL /* node command list */ 93107120Sjulian}; 94107120Sjulian 95107120Sjulian/* Globals */ 96107120Sjulianextern int ifqmaxlen; 97107120Sjulianstatic u_int32_t ng_btsocket_l2cap_debug_level; 98107120Sjulianstatic node_p ng_btsocket_l2cap_node; 99107120Sjulianstatic struct ng_bt_itemq ng_btsocket_l2cap_queue; 100107120Sjulianstatic struct mtx ng_btsocket_l2cap_queue_mtx; 101107120Sjulianstatic struct task ng_btsocket_l2cap_queue_task; 102107120Sjulianstatic LIST_HEAD(, ng_btsocket_l2cap_pcb) ng_btsocket_l2cap_sockets; 103107120Sjulianstatic struct mtx ng_btsocket_l2cap_sockets_mtx; 104107120Sjulianstatic LIST_HEAD(, ng_btsocket_l2cap_rtentry) ng_btsocket_l2cap_rt; 105107120Sjulianstatic struct mtx ng_btsocket_l2cap_rt_mtx; 106107120Sjulianstatic struct task ng_btsocket_l2cap_rt_task; 107107120Sjulian 108107120Sjulian/* Sysctl tree */ 109107120SjulianSYSCTL_DECL(_net_bluetooth_l2cap_sockets); 110107120SjulianSYSCTL_NODE(_net_bluetooth_l2cap_sockets, OID_AUTO, seq, CTLFLAG_RW, 111107120Sjulian 0, "Bluetooth SEQPACKET L2CAP sockets family"); 112107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, debug_level, 113107120Sjulian CTLFLAG_RW, 114107120Sjulian &ng_btsocket_l2cap_debug_level, NG_BTSOCKET_WARN_LEVEL, 115107120Sjulian "Bluetooth SEQPACKET L2CAP sockets debug level"); 116107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_len, 117107120Sjulian CTLFLAG_RD, 118107120Sjulian &ng_btsocket_l2cap_queue.len, 0, 119107120Sjulian "Bluetooth SEQPACKET L2CAP sockets input queue length"); 120107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_maxlen, 121107120Sjulian CTLFLAG_RD, 122107120Sjulian &ng_btsocket_l2cap_queue.maxlen, 0, 123107120Sjulian "Bluetooth SEQPACKET L2CAP sockets input queue max. length"); 124107120SjulianSYSCTL_INT(_net_bluetooth_l2cap_sockets_seq, OID_AUTO, queue_drops, 125107120Sjulian CTLFLAG_RD, 126107120Sjulian &ng_btsocket_l2cap_queue.drops, 0, 127107120Sjulian "Bluetooth SEQPACKET L2CAP sockets input queue drops"); 128107120Sjulian 129107120Sjulian/* Debug */ 130107120Sjulian#define NG_BTSOCKET_L2CAP_INFO \ 131107120Sjulian if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_INFO_LEVEL) \ 132107120Sjulian printf 133107120Sjulian 134107120Sjulian#define NG_BTSOCKET_L2CAP_WARN \ 135107120Sjulian if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_WARN_LEVEL) \ 136107120Sjulian printf 137107120Sjulian 138107120Sjulian#define NG_BTSOCKET_L2CAP_ERR \ 139107120Sjulian if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ERR_LEVEL) \ 140107120Sjulian printf 141107120Sjulian 142107120Sjulian#define NG_BTSOCKET_L2CAP_ALERT \ 143107120Sjulian if (ng_btsocket_l2cap_debug_level >= NG_BTSOCKET_ALERT_LEVEL) \ 144107120Sjulian printf 145107120Sjulian 146107120Sjulian/* 147107120Sjulian * Netgraph message processing routines 148107120Sjulian */ 149107120Sjulian 150107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_con_req_rsp 151114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 152107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_con_rsp_rsp 153114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 154107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_con_ind 155114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 156107120Sjulian 157107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_cfg_req_rsp 158114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 159107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp 160114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 161107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_cfg_ind 162114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 163107120Sjulian 164107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_discon_rsp 165114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 166107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_discon_ind 167114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 168107120Sjulian 169107120Sjulianstatic int ng_btsocket_l2cap_process_l2ca_write_rsp 170114878Sjulian (struct ng_mesg *, ng_btsocket_l2cap_rtentry_p, struct socket **); 171107120Sjulian 172107120Sjulian/* 173107120Sjulian * Send L2CA_xxx messages to the lower layer 174107120Sjulian */ 175107120Sjulian 176107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_con_req 177107120Sjulian (ng_btsocket_l2cap_pcb_p); 178107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_con_rsp_req 179107120Sjulian (u_int32_t, ng_btsocket_l2cap_rtentry_p, bdaddr_p, int, int, int); 180107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_cfg_req 181107120Sjulian (ng_btsocket_l2cap_pcb_p); 182107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_cfg_rsp 183107120Sjulian (ng_btsocket_l2cap_pcb_p); 184107120Sjulianstatic int ng_btsocket_l2cap_send_l2ca_discon_req 185107120Sjulian (u_int32_t, ng_btsocket_l2cap_pcb_p); 186107120Sjulian 187107120Sjulianstatic int ng_btsocket_l2cap_send2 188107120Sjulian (ng_btsocket_l2cap_pcb_p); 189107120Sjulian 190107120Sjulian/* 191107120Sjulian * Timeout processing routines 192107120Sjulian */ 193107120Sjulian 194107120Sjulianstatic void ng_btsocket_l2cap_timeout (ng_btsocket_l2cap_pcb_p); 195107120Sjulianstatic void ng_btsocket_l2cap_untimeout (ng_btsocket_l2cap_pcb_p); 196107120Sjulianstatic void ng_btsocket_l2cap_process_timeout (void *); 197107120Sjulian 198107120Sjulian/* 199107120Sjulian * Other stuff 200107120Sjulian */ 201107120Sjulian 202107120Sjulianstatic ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_addr(bdaddr_p, int); 203107120Sjulianstatic ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_token(u_int32_t); 204107120Sjulianstatic ng_btsocket_l2cap_pcb_p ng_btsocket_l2cap_pcb_by_cid (bdaddr_p, int); 205107120Sjulianstatic int ng_btsocket_l2cap_result2errno(int); 206107120Sjulian 207114878Sjulian#define ng_btsocket_l2cap_wakeup_input_task() \ 208114878Sjulian taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_queue_task) 209114878Sjulian 210114878Sjulian#define ng_btsocket_l2cap_wakeup_route_task() \ 211114878Sjulian taskqueue_enqueue(taskqueue_swi_giant, &ng_btsocket_l2cap_rt_task) 212114878Sjulian 213107120Sjulian/***************************************************************************** 214107120Sjulian ***************************************************************************** 215107120Sjulian ** Netgraph node interface 216107120Sjulian ***************************************************************************** 217107120Sjulian *****************************************************************************/ 218107120Sjulian 219107120Sjulian/* 220107120Sjulian * Netgraph node constructor. Do not allow to create node of this type. 221107120Sjulian */ 222107120Sjulian 223107120Sjulianstatic int 224107120Sjulianng_btsocket_l2cap_node_constructor(node_p node) 225107120Sjulian{ 226107120Sjulian return (EINVAL); 227107120Sjulian} /* ng_btsocket_l2cap_node_constructor */ 228107120Sjulian 229107120Sjulian/* 230107120Sjulian * Do local shutdown processing. Let old node go and create new fresh one. 231107120Sjulian */ 232107120Sjulian 233107120Sjulianstatic int 234107120Sjulianng_btsocket_l2cap_node_shutdown(node_p node) 235107120Sjulian{ 236107120Sjulian int error = 0; 237107120Sjulian 238107120Sjulian NG_NODE_UNREF(node); 239107120Sjulian 240107120Sjulian /* Create new node */ 241107120Sjulian error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 242107120Sjulian if (error != 0) { 243107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 244107120Sjulian"%s: Could not create Netgraph node, error=%d\n", __func__, error); 245107120Sjulian 246107120Sjulian ng_btsocket_l2cap_node = NULL; 247107120Sjulian 248107120Sjulian return (error); 249107120Sjulian } 250107120Sjulian 251107120Sjulian error = ng_name_node(ng_btsocket_l2cap_node, 252107120Sjulian NG_BTSOCKET_L2CAP_NODE_TYPE); 253107120Sjulian if (error != NULL) { 254107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 255107120Sjulian"%s: Could not name Netgraph node, error=%d\n", __func__, error); 256107120Sjulian 257107120Sjulian NG_NODE_UNREF(ng_btsocket_l2cap_node); 258107120Sjulian ng_btsocket_l2cap_node = NULL; 259107120Sjulian 260107120Sjulian return (error); 261107120Sjulian } 262107120Sjulian 263107120Sjulian return (0); 264107120Sjulian} /* ng_btsocket_l2cap_node_shutdown */ 265107120Sjulian 266107120Sjulian/* 267107120Sjulian * We allow any hook to be connected to the node. 268107120Sjulian */ 269107120Sjulian 270107120Sjulianstatic int 271107120Sjulianng_btsocket_l2cap_node_newhook(node_p node, hook_p hook, char const *name) 272107120Sjulian{ 273107120Sjulian return (0); 274107120Sjulian} /* ng_btsocket_l2cap_node_newhook */ 275107120Sjulian 276107120Sjulian/* 277107120Sjulian * Just say "YEP, that's OK by me!" 278107120Sjulian */ 279107120Sjulian 280107120Sjulianstatic int 281107120Sjulianng_btsocket_l2cap_node_connect(hook_p hook) 282107120Sjulian{ 283107120Sjulian NG_HOOK_SET_PRIVATE(hook, NULL); 284107120Sjulian NG_HOOK_REF(hook); /* Keep extra reference to the hook */ 285107120Sjulian 286107120Sjulian#if 0 287107120Sjulian NG_HOOK_FORCE_QUEUE(NG_HOOK_PEER(hook)); 288107120Sjulian NG_HOOK_FORCE_QUEUE(hook); 289107120Sjulian#endif 290107120Sjulian 291107120Sjulian return (0); 292107120Sjulian} /* ng_btsocket_l2cap_node_connect */ 293107120Sjulian 294107120Sjulian/* 295107120Sjulian * Hook disconnection. Schedule route cleanup task 296107120Sjulian */ 297107120Sjulian 298107120Sjulianstatic int 299107120Sjulianng_btsocket_l2cap_node_disconnect(hook_p hook) 300107120Sjulian{ 301107120Sjulian /* 302107120Sjulian * If hook has private information than we must have this hook in 303107120Sjulian * the routing table and must schedule cleaning for the routing table. 304107120Sjulian * Otherwise hook was connected but we never got "hook_info" message, 305107120Sjulian * so we have never added this hook to the routing table and it save 306107120Sjulian * to just delete it. 307107120Sjulian */ 308107120Sjulian 309107120Sjulian if (NG_HOOK_PRIVATE(hook) != NULL) 310114878Sjulian return (ng_btsocket_l2cap_wakeup_route_task()); 311107120Sjulian 312107120Sjulian NG_HOOK_UNREF(hook); /* Remove extra reference */ 313107120Sjulian 314107120Sjulian return (0); 315107120Sjulian} /* ng_btsocket_l2cap_node_disconnect */ 316107120Sjulian 317107120Sjulian/* 318107120Sjulian * Process incoming messages 319107120Sjulian */ 320107120Sjulian 321107120Sjulianstatic int 322107120Sjulianng_btsocket_l2cap_node_rcvmsg(node_p node, item_p item, hook_p hook) 323107120Sjulian{ 324107120Sjulian struct ng_mesg *msg = NGI_MSG(item); /* item still has message */ 325107120Sjulian int error = 0; 326107120Sjulian 327107120Sjulian if (msg != NULL && msg->header.typecookie == NGM_L2CAP_COOKIE) { 328107120Sjulian mtx_lock(&ng_btsocket_l2cap_queue_mtx); 329107120Sjulian if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 330107120Sjulian NG_BTSOCKET_L2CAP_ERR( 331107120Sjulian"%s: Input queue is full (msg)\n", __func__); 332107120Sjulian 333107120Sjulian NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 334107120Sjulian NG_FREE_ITEM(item); 335107120Sjulian error = ENOBUFS; 336107120Sjulian } else { 337107120Sjulian if (hook != NULL) { 338107120Sjulian NG_HOOK_REF(hook); 339107120Sjulian NGI_SET_HOOK(item, hook); 340107120Sjulian } 341107120Sjulian 342107120Sjulian NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 343114878Sjulian error = ng_btsocket_l2cap_wakeup_input_task(); 344107120Sjulian } 345107120Sjulian mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 346107120Sjulian } else { 347107120Sjulian NG_FREE_ITEM(item); 348107120Sjulian error = EINVAL; 349107120Sjulian } 350107120Sjulian 351107120Sjulian return (error); 352107120Sjulian} /* ng_btsocket_l2cap_node_rcvmsg */ 353107120Sjulian 354107120Sjulian/* 355107120Sjulian * Receive data on a hook 356107120Sjulian */ 357107120Sjulian 358107120Sjulianstatic int 359107120Sjulianng_btsocket_l2cap_node_rcvdata(hook_p hook, item_p item) 360107120Sjulian{ 361107120Sjulian int error = 0; 362107120Sjulian 363107120Sjulian mtx_lock(&ng_btsocket_l2cap_queue_mtx); 364107120Sjulian if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_queue)) { 365107120Sjulian NG_BTSOCKET_L2CAP_ERR( 366107120Sjulian"%s: Input queue is full (data)\n", __func__); 367107120Sjulian 368107120Sjulian NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_queue); 369107120Sjulian NG_FREE_ITEM(item); 370107120Sjulian error = ENOBUFS; 371107120Sjulian } else { 372107120Sjulian NG_HOOK_REF(hook); 373107120Sjulian NGI_SET_HOOK(item, hook); 374107120Sjulian 375107120Sjulian NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_queue, item); 376114878Sjulian error = ng_btsocket_l2cap_wakeup_input_task(); 377107120Sjulian } 378107120Sjulian mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 379107120Sjulian 380107120Sjulian return (error); 381107120Sjulian} /* ng_btsocket_l2cap_node_rcvdata */ 382107120Sjulian 383107120Sjulian/* 384107120Sjulian * Process L2CA_Connect respose. Socket layer must have initiated connection, 385107120Sjulian * so we have to have a socket associated with message token. 386107120Sjulian */ 387107120Sjulian 388107120Sjulianstatic int 389107120Sjulianng_btsocket_l2cap_process_l2ca_con_req_rsp(struct ng_mesg *msg, 390114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 391107120Sjulian{ 392107120Sjulian ng_l2cap_l2ca_con_op *op = NULL; 393107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 394107120Sjulian int error = 0; 395107120Sjulian 396107120Sjulian if (msg->header.arglen != sizeof(*op)) 397107120Sjulian return (EMSGSIZE); 398107120Sjulian 399107120Sjulian op = (ng_l2cap_l2ca_con_op *)(msg->data); 400107120Sjulian 401114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 402114878Sjulian 403107120Sjulian /* Look for the socket with the token */ 404107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 405114878Sjulian if (pcb == NULL) { 406114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 407107120Sjulian return (ENOENT); 408114878Sjulian } 409107120Sjulian 410107120Sjulian mtx_lock(&pcb->pcb_mtx); 411107120Sjulian 412107120Sjulian NG_BTSOCKET_L2CAP_INFO( 413107120Sjulian"%s: Got L2CA_Connect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 414107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, status=%d, " \ 415107120Sjulian"state=%d\n", __func__, msg->header.token, 416107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 417107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 418107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 419107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 420107120Sjulian pcb->psm, op->lcid, op->result, op->status, 421107120Sjulian pcb->state); 422107120Sjulian 423107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 424107120Sjulian mtx_unlock(&pcb->pcb_mtx); 425114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 426114878Sjulian 427107120Sjulian return (ENOENT); 428107120Sjulian } 429107120Sjulian 430107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 431107120Sjulian 432107120Sjulian if (op->result == NG_L2CAP_PENDING) { 433107120Sjulian ng_btsocket_l2cap_timeout(pcb); 434107120Sjulian mtx_unlock(&pcb->pcb_mtx); 435114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 436114878Sjulian 437107120Sjulian return (0); 438107120Sjulian } 439107120Sjulian 440107120Sjulian if (op->result == NG_L2CAP_SUCCESS) { 441107120Sjulian /* 442107120Sjulian * Channel is now open, so update local channel ID and 443107120Sjulian * start configuration process. Source and destination 444107120Sjulian * addresses as well as route must be already set. 445107120Sjulian */ 446107120Sjulian 447107120Sjulian pcb->cid = op->lcid; 448107120Sjulian 449107120Sjulian error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 450107120Sjulian if (error != 0) { 451107120Sjulian /* Send disconnect request with "zero" token */ 452107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 453107120Sjulian 454107120Sjulian /* ... and close the socket */ 455107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 456107120Sjulian soisdisconnected(pcb->so); 457114878Sjulian 458114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 459114878Sjulian *sop = pcb->so; 460107120Sjulian } else { 461107120Sjulian pcb->cfg_state = NG_BTSOCKET_L2CAP_CFG_IN_SENT; 462107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 463107120Sjulian 464107120Sjulian ng_btsocket_l2cap_timeout(pcb); 465107120Sjulian } 466107120Sjulian } else { 467107120Sjulian /* 468107120Sjulian * We have failed to open connection, so convert result 469107120Sjulian * code to "errno" code and disconnect the socket. Channel 470107120Sjulian * already has been closed. 471107120Sjulian */ 472107120Sjulian 473107120Sjulian pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 474107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 475107120Sjulian soisdisconnected(pcb->so); 476114878Sjulian 477114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 478114878Sjulian *sop = pcb->so; 479107120Sjulian } 480107120Sjulian 481107120Sjulian mtx_unlock(&pcb->pcb_mtx); 482114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 483107120Sjulian 484107120Sjulian return (error); 485107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_con_req_rsp */ 486107120Sjulian 487107120Sjulian/* 488107120Sjulian * Process L2CA_ConnectRsp response 489107120Sjulian */ 490107120Sjulian 491107120Sjulianstatic int 492107120Sjulianng_btsocket_l2cap_process_l2ca_con_rsp_rsp(struct ng_mesg *msg, 493114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 494107120Sjulian{ 495107120Sjulian ng_l2cap_l2ca_con_rsp_op *op = NULL; 496107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 497107120Sjulian 498107120Sjulian if (msg->header.arglen != sizeof(*op)) 499107120Sjulian return (EMSGSIZE); 500107120Sjulian 501107120Sjulian op = (ng_l2cap_l2ca_con_rsp_op *)(msg->data); 502107120Sjulian 503114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 504114878Sjulian 505107120Sjulian /* Look for the socket with the token */ 506107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 507114878Sjulian if (pcb == NULL) { 508114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 509107120Sjulian return (ENOENT); 510114878Sjulian } 511107120Sjulian 512107120Sjulian mtx_lock(&pcb->pcb_mtx); 513107120Sjulian 514107120Sjulian NG_BTSOCKET_L2CAP_INFO( 515107120Sjulian"%s: Got L2CA_ConnectRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 516107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 517107120Sjulian __func__, msg->header.token, 518107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 519107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 520107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 521107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 522107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state); 523107120Sjulian 524107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONNECTING) { 525107120Sjulian mtx_unlock(&pcb->pcb_mtx); 526114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 527114878Sjulian 528107120Sjulian return (ENOENT); 529107120Sjulian } 530107120Sjulian 531107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 532107120Sjulian 533107120Sjulian /* Check the result and disconnect the socket on failure */ 534107120Sjulian if (op->result != NG_L2CAP_SUCCESS) { 535107120Sjulian /* Close the socket - channel already closed */ 536107120Sjulian pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 537107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 538107120Sjulian soisdisconnected(pcb->so); 539114878Sjulian 540114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 541114878Sjulian *sop = pcb->so; 542107120Sjulian } else { 543107120Sjulian /* Move to CONFIGURING state and wait for CONFIG_IND */ 544107120Sjulian pcb->cfg_state = 0; 545107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CONFIGURING; 546107120Sjulian ng_btsocket_l2cap_timeout(pcb); 547107120Sjulian } 548107120Sjulian 549107120Sjulian mtx_unlock(&pcb->pcb_mtx); 550114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 551107120Sjulian 552107120Sjulian return (0); 553107120Sjulian} /* ng_btsocket_process_l2ca_con_rsp_rsp */ 554107120Sjulian 555107120Sjulian/* 556107120Sjulian * Process L2CA_Connect indicator. Find socket that listens on address 557107120Sjulian * and PSM. Find exact or closest match. Create new socket and initiate 558107120Sjulian * connection. 559107120Sjulian */ 560107120Sjulian 561107120Sjulianstatic int 562107120Sjulianng_btsocket_l2cap_process_l2ca_con_ind(struct ng_mesg *msg, 563114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 564107120Sjulian{ 565107120Sjulian ng_l2cap_l2ca_con_ind_ip *ip = NULL; 566107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL, *pcb1 = NULL; 567107120Sjulian int error = 0; 568107120Sjulian u_int32_t token = 0; 569107120Sjulian u_int16_t result = 0; 570107120Sjulian 571107120Sjulian if (msg->header.arglen != sizeof(*ip)) 572107120Sjulian return (EMSGSIZE); 573107120Sjulian 574107120Sjulian ip = (ng_l2cap_l2ca_con_ind_ip *)(msg->data); 575107120Sjulian 576107120Sjulian NG_BTSOCKET_L2CAP_INFO( 577107120Sjulian"%s: Got L2CA_Connect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 578107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, ident=%d\n", 579107120Sjulian __func__, 580107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 581107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 582107120Sjulian ip->bdaddr.b[5], ip->bdaddr.b[4], ip->bdaddr.b[3], 583107120Sjulian ip->bdaddr.b[2], ip->bdaddr.b[1], ip->bdaddr.b[0], 584107120Sjulian ip->psm, ip->lcid, ip->ident); 585114878Sjulian 586114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 587107120Sjulian 588107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_addr(&rt->src, ip->psm); 589107120Sjulian if (pcb != NULL) { 590107120Sjulian struct socket *so1 = NULL; 591107120Sjulian 592107120Sjulian mtx_lock(&pcb->pcb_mtx); 593107120Sjulian 594107120Sjulian /* 595107120Sjulian * First check the pending connections queue and if we have 596107120Sjulian * space then create new socket and set proper source address. 597107120Sjulian */ 598107120Sjulian 599107120Sjulian if (pcb->so->so_qlen <= pcb->so->so_qlimit) 600107120Sjulian so1 = sonewconn(pcb->so, 0); 601107120Sjulian 602107120Sjulian if (so1 == NULL) { 603107120Sjulian result = NG_L2CAP_NO_RESOURCES; 604107120Sjulian goto respond; 605107120Sjulian } 606107120Sjulian 607107120Sjulian /* 608107120Sjulian * If we got here than we have created new socket. So complete 609107120Sjulian * connection. If we we listening on specific address then copy 610107120Sjulian * source address from listening socket, otherwise copy source 611107120Sjulian * address from hook's routing information. 612107120Sjulian */ 613107120Sjulian 614107120Sjulian pcb1 = so2l2cap_pcb(so1); 615107120Sjulian KASSERT((pcb1 != NULL), 616107120Sjulian("%s: pcb1 == NULL\n", __func__)); 617107120Sjulian 618114878Sjulian mtx_lock(&pcb1->pcb_mtx); 619107120Sjulian 620107120Sjulian if (bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)) != 0) 621107120Sjulian bcopy(&pcb->src, &pcb1->src, sizeof(pcb1->src)); 622107120Sjulian else 623107120Sjulian bcopy(&rt->src, &pcb1->src, sizeof(pcb1->src)); 624107120Sjulian 625107120Sjulian pcb1->flags &= ~NG_BTSOCKET_L2CAP_CLIENT; 626107120Sjulian 627107120Sjulian bcopy(&ip->bdaddr, &pcb1->dst, sizeof(pcb1->dst)); 628107120Sjulian pcb1->psm = ip->psm; 629107120Sjulian pcb1->cid = ip->lcid; 630107120Sjulian pcb1->rt = rt; 631107120Sjulian 632107120Sjulian /* Copy socket settings */ 633107120Sjulian pcb1->imtu = pcb->imtu; 634107120Sjulian bcopy(&pcb->oflow, &pcb1->oflow, sizeof(pcb1->oflow)); 635107120Sjulian pcb1->flush_timo = pcb->flush_timo; 636107120Sjulian 637107120Sjulian token = pcb1->token; 638107120Sjulian } else 639107120Sjulian /* Nobody listens on requested BDADDR/PSM */ 640107120Sjulian result = NG_L2CAP_PSM_NOT_SUPPORTED; 641107120Sjulian 642107120Sjulianrespond: 643107120Sjulian error = ng_btsocket_l2cap_send_l2ca_con_rsp_req(token, rt, 644107120Sjulian &ip->bdaddr, ip->ident, ip->lcid, result); 645107120Sjulian if (pcb1 != NULL) { 646107120Sjulian if (error != 0) { 647107120Sjulian pcb1->so->so_error = error; 648107120Sjulian pcb1->state = NG_BTSOCKET_L2CAP_CLOSED; 649107120Sjulian soisdisconnected(pcb1->so); 650114878Sjulian 651114878Sjulian if (pcb1->so->so_state & SS_NOFDREF) 652114878Sjulian *sop = pcb1->so; 653107120Sjulian } else { 654107120Sjulian pcb1->state = NG_BTSOCKET_L2CAP_CONNECTING; 655107120Sjulian soisconnecting(pcb1->so); 656107120Sjulian 657107120Sjulian ng_btsocket_l2cap_timeout(pcb1); 658107120Sjulian } 659107120Sjulian 660107120Sjulian mtx_unlock(&pcb1->pcb_mtx); 661107120Sjulian } 662107120Sjulian 663107120Sjulian if (pcb != NULL) 664107120Sjulian mtx_unlock(&pcb->pcb_mtx); 665107120Sjulian 666114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 667114878Sjulian 668107120Sjulian return (error); 669107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_con_ind */ 670107120Sjulian 671107120Sjulian/* 672107120Sjulian * Process L2CA_Config response 673107120Sjulian */ 674107120Sjulian 675107120Sjulianstatic int 676107120Sjulianng_btsocket_l2cap_process_l2ca_cfg_req_rsp(struct ng_mesg *msg, 677114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 678107120Sjulian{ 679107120Sjulian ng_l2cap_l2ca_cfg_op *op = NULL; 680107120Sjulian ng_btsocket_l2cap_pcb_p pcb = NULL; 681107120Sjulian 682107120Sjulian if (msg->header.arglen != sizeof(*op)) 683107120Sjulian return (EMSGSIZE); 684107120Sjulian 685107120Sjulian op = (ng_l2cap_l2ca_cfg_op *)(msg->data); 686107120Sjulian 687114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 688114878Sjulian 689107120Sjulian /* 690107120Sjulian * Socket must have issued a Configure request, so we must have a 691107120Sjulian * socket that wants to be configured. Use Netgraph message token 692107120Sjulian * to find it 693107120Sjulian */ 694107120Sjulian 695107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 696107120Sjulian if (pcb == NULL) { 697107120Sjulian /* 698107120Sjulian * XXX FIXME what to do here? We could not find a 699107120Sjulian * socket with requested token. We even can not send 700107120Sjulian * Disconnect, because we do not know channel ID 701107120Sjulian */ 702107120Sjulian 703114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 704107120Sjulian return (ENOENT); 705107120Sjulian } 706107120Sjulian 707107120Sjulian mtx_lock(&pcb->pcb_mtx); 708107120Sjulian 709107120Sjulian NG_BTSOCKET_L2CAP_INFO( 710107120Sjulian"%s: Got L2CA_Config response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 711107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 712107120Sjulian"cfg_state=%x\n", 713107120Sjulian __func__, msg->header.token, 714107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 715107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 716107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 717107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 718107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 719107120Sjulian 720107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 721107120Sjulian mtx_unlock(&pcb->pcb_mtx); 722114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 723114878Sjulian 724107120Sjulian return (ENOENT); 725107120Sjulian } 726107120Sjulian 727107120Sjulian if (op->result == NG_L2CAP_SUCCESS) { 728107120Sjulian /* 729107120Sjulian * XXX FIXME Actually set flush and link timeout. 730107120Sjulian * Set QoS here if required. Resolve conficts (flush_timo). 731107120Sjulian * Save incoming MTU (peer's outgoing MTU) and outgoing flow 732107120Sjulian * spec. 733107120Sjulian */ 734107120Sjulian 735107120Sjulian pcb->imtu = op->imtu; 736107120Sjulian bcopy(&op->oflow, &pcb->oflow, sizeof(pcb->oflow)); 737107120Sjulian pcb->flush_timo = op->flush_timo; 738107120Sjulian 739107120Sjulian /* 740107120Sjulian * We have configured incoming side, so record it and check 741107120Sjulian * if configuration is complete. If complete then mark socket 742107120Sjulian * as connected, otherwise wait for the peer. 743107120Sjulian */ 744107120Sjulian 745107120Sjulian pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_IN_SENT; 746107120Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN; 747107120Sjulian 748107120Sjulian if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 749107120Sjulian /* Configuration complete - mark socket as open */ 750107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 751107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_OPEN; 752107120Sjulian soisconnected(pcb->so); 753107120Sjulian } 754107120Sjulian } else { 755107120Sjulian /* 756107120Sjulian * Something went wrong. Could be unacceptable parameters, 757107120Sjulian * reject or unknown option. That's too bad, but we will 758107120Sjulian * not negotiate. Send Disconnect and close the channel. 759107120Sjulian */ 760107120Sjulian 761107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 762107120Sjulian 763107120Sjulian switch (op->result) { 764107120Sjulian case NG_L2CAP_UNACCEPTABLE_PARAMS: 765107120Sjulian case NG_L2CAP_UNKNOWN_OPTION: 766107120Sjulian pcb->so->so_error = EINVAL; 767107120Sjulian break; 768107120Sjulian 769107120Sjulian default: 770107120Sjulian pcb->so->so_error = ECONNRESET; 771107120Sjulian break; 772107120Sjulian } 773107120Sjulian 774107120Sjulian /* Send disconnect with "zero" token */ 775107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 776107120Sjulian 777107120Sjulian /* ... and close the socket */ 778107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 779107120Sjulian soisdisconnected(pcb->so); 780114878Sjulian 781114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 782114878Sjulian *sop = pcb->so; 783107120Sjulian } 784107120Sjulian 785107120Sjulian mtx_unlock(&pcb->pcb_mtx); 786114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 787107120Sjulian 788107120Sjulian return (0); 789107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_cfg_req_rsp */ 790107120Sjulian 791107120Sjulian/* 792107120Sjulian * Process L2CA_ConfigRsp response 793107120Sjulian */ 794107120Sjulian 795107120Sjulianstatic int 796107120Sjulianng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(struct ng_mesg *msg, 797114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 798107120Sjulian{ 799107120Sjulian ng_l2cap_l2ca_cfg_rsp_op *op = NULL; 800107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 801107120Sjulian int error = 0; 802107120Sjulian 803107120Sjulian if (msg->header.arglen != sizeof(*op)) 804107120Sjulian return (EMSGSIZE); 805107120Sjulian 806107120Sjulian op = (ng_l2cap_l2ca_cfg_rsp_op *)(msg->data); 807107120Sjulian 808114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 809114878Sjulian 810107120Sjulian /* Look for the socket with the token */ 811107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 812114878Sjulian if (pcb == NULL) { 813114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 814107120Sjulian return (ENOENT); 815114878Sjulian } 816107120Sjulian 817107120Sjulian mtx_lock(&pcb->pcb_mtx); 818107120Sjulian 819107120Sjulian NG_BTSOCKET_L2CAP_INFO( 820107120Sjulian"%s: Got L2CA_ConfigRsp response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 821107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d, " \ 822107120Sjulian"cfg_state=%x\n", 823107120Sjulian __func__, msg->header.token, 824107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 825107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 826107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 827107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 828107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state, pcb->cfg_state); 829107120Sjulian 830107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 831107120Sjulian mtx_unlock(&pcb->pcb_mtx); 832114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 833114878Sjulian 834107120Sjulian return (ENOENT); 835107120Sjulian } 836107120Sjulian 837107120Sjulian /* Check the result and disconnect socket of failure */ 838107120Sjulian if (op->result != NG_L2CAP_SUCCESS) 839107120Sjulian goto disconnect; 840107120Sjulian 841107120Sjulian /* 842107120Sjulian * Now we done with remote side configuration. Configure local 843107120Sjulian * side if we have not done it yet. 844107120Sjulian */ 845107120Sjulian 846107120Sjulian pcb->cfg_state &= ~NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 847107120Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT; 848107120Sjulian 849107120Sjulian if (pcb->cfg_state == NG_BTSOCKET_L2CAP_CFG_BOTH) { 850107120Sjulian /* Configuration complete - mask socket as open */ 851107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 852107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_OPEN; 853107120Sjulian soisconnected(pcb->so); 854107120Sjulian } else { 855107120Sjulian if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_IN_SENT)) { 856107120Sjulian /* Send L2CA_Config request - incoming path */ 857107120Sjulian error = ng_btsocket_l2cap_send_l2ca_cfg_req(pcb); 858107120Sjulian if (error != 0) 859107120Sjulian goto disconnect; 860107120Sjulian 861107120Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_IN_SENT; 862107120Sjulian } 863107120Sjulian } 864107120Sjulian 865107120Sjulian mtx_unlock(&pcb->pcb_mtx); 866114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 867107120Sjulian 868107120Sjulian return (error); 869107120Sjulian 870107120Sjuliandisconnect: 871107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 872107120Sjulian 873107120Sjulian /* Send disconnect with "zero" token */ 874107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 875107120Sjulian 876107120Sjulian /* ... and close the socket */ 877107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 878107120Sjulian soisdisconnected(pcb->so); 879107120Sjulian 880114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 881114878Sjulian *sop = pcb->so; 882114878Sjulian 883107120Sjulian mtx_unlock(&pcb->pcb_mtx); 884114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 885107120Sjulian 886107120Sjulian return (error); 887107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp */ 888107120Sjulian 889107120Sjulian/* 890107120Sjulian * Process L2CA_Config indicator 891107120Sjulian */ 892107120Sjulian 893107120Sjulianstatic int 894107120Sjulianng_btsocket_l2cap_process_l2ca_cfg_ind(struct ng_mesg *msg, 895114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 896107120Sjulian{ 897107120Sjulian ng_l2cap_l2ca_cfg_ind_ip *ip = NULL; 898107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 899107120Sjulian int error = 0; 900107120Sjulian 901107120Sjulian if (msg->header.arglen != sizeof(*ip)) 902107120Sjulian return (EMSGSIZE); 903107120Sjulian 904107120Sjulian ip = (ng_l2cap_l2ca_cfg_ind_ip *)(msg->data); 905107120Sjulian 906114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 907114878Sjulian 908107120Sjulian /* Check for the open socket that has given channel ID */ 909107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid); 910114878Sjulian if (pcb == NULL) { 911114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 912107120Sjulian return (ENOENT); 913114878Sjulian } 914107120Sjulian 915107120Sjulian mtx_lock(&pcb->pcb_mtx); 916107120Sjulian 917107120Sjulian NG_BTSOCKET_L2CAP_INFO( 918107120Sjulian"%s: Got L2CA_Config indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 919107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d, cfg_state=%x\n", 920107120Sjulian __func__, 921107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 922107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 923107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 924107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 925107120Sjulian pcb->psm, pcb->cid, pcb->state, pcb->cfg_state); 926107120Sjulian 927107120Sjulian /* XXX FIXME re-configuration on open socket */ 928107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CONFIGURING) { 929107120Sjulian mtx_unlock(&pcb->pcb_mtx); 930114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 931114878Sjulian 932107120Sjulian return (ENOENT); 933107120Sjulian } 934107120Sjulian 935107120Sjulian /* 936107120Sjulian * XXX FIXME Actually set flush and link timeout. Set QoS here if 937107120Sjulian * required. Resolve conficts (flush_timo). Note outgoing MTU (peer's 938107120Sjulian * incoming MTU) and incoming flow spec. 939107120Sjulian */ 940107120Sjulian 941107120Sjulian pcb->omtu = ip->omtu; 942107120Sjulian bcopy(&ip->iflow, &pcb->iflow, sizeof(pcb->iflow)); 943107120Sjulian pcb->flush_timo = ip->flush_timo; 944107120Sjulian 945107120Sjulian /* 946107120Sjulian * Send L2CA_Config response to our peer and check for the errors, 947107120Sjulian * if any send disconnect to close the channel. 948107120Sjulian */ 949107120Sjulian 950114878Sjulian if (!(pcb->cfg_state & NG_BTSOCKET_L2CAP_CFG_OUT_SENT)) { 951114878Sjulian error = ng_btsocket_l2cap_send_l2ca_cfg_rsp(pcb); 952114878Sjulian if (error != 0) { 953114878Sjulian ng_btsocket_l2cap_untimeout(pcb); 954107120Sjulian 955114878Sjulian pcb->so->so_error = error; 956107120Sjulian 957114878Sjulian /* Send disconnect with "zero" token */ 958114878Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 959107120Sjulian 960114878Sjulian /* ... and close the socket */ 961114878Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 962114878Sjulian soisdisconnected(pcb->so); 963107120Sjulian 964114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 965114878Sjulian *sop = pcb->so; 966114878Sjulian } else 967114878Sjulian pcb->cfg_state |= NG_BTSOCKET_L2CAP_CFG_OUT_SENT; 968107120Sjulian } 969107120Sjulian 970107120Sjulian mtx_unlock(&pcb->pcb_mtx); 971114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 972107120Sjulian 973107120Sjulian return (error); 974107120Sjulian} /* ng_btsocket_l2cap_process_l2cap_cfg_ind */ 975107120Sjulian 976107120Sjulian/* 977107120Sjulian * Process L2CA_Disconnect response 978107120Sjulian */ 979107120Sjulian 980107120Sjulianstatic int 981107120Sjulianng_btsocket_l2cap_process_l2ca_discon_rsp(struct ng_mesg *msg, 982114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 983107120Sjulian{ 984107120Sjulian ng_l2cap_l2ca_discon_op *op = NULL; 985107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 986107120Sjulian 987107120Sjulian /* Check message */ 988107120Sjulian if (msg->header.arglen != sizeof(*op)) 989107120Sjulian return (EMSGSIZE); 990107120Sjulian 991107120Sjulian op = (ng_l2cap_l2ca_discon_op *)(msg->data); 992107120Sjulian 993114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 994114878Sjulian 995107120Sjulian /* 996107120Sjulian * Socket layer must have issued L2CA_Disconnect request, so there 997107120Sjulian * must be a socket that wants to be disconnected. Use Netgraph 998107120Sjulian * message token to find it. 999107120Sjulian */ 1000107120Sjulian 1001107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1002114878Sjulian if (pcb == NULL) { 1003114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1004107120Sjulian return (0); 1005114878Sjulian } 1006107120Sjulian 1007107120Sjulian mtx_lock(&pcb->pcb_mtx); 1008107120Sjulian 1009107120Sjulian /* XXX Close socket no matter what op->result says */ 1010107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 1011107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1012107120Sjulian"%s: Got L2CA_Disconnect response, token=%d, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1013107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, state=%d\n", 1014107120Sjulian __func__, msg->header.token, 1015107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1016107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1017107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1018107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1019107120Sjulian pcb->psm, pcb->cid, op->result, pcb->state); 1020107120Sjulian 1021107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1022107120Sjulian 1023107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1024107120Sjulian soisdisconnected(pcb->so); 1025114878Sjulian 1026114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 1027114878Sjulian *sop = pcb->so; 1028107120Sjulian } 1029107120Sjulian 1030107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1031114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1032107120Sjulian 1033107120Sjulian return (0); 1034107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_discon_rsp */ 1035107120Sjulian 1036107120Sjulian/* 1037107120Sjulian * Process L2CA_Disconnect indicator 1038107120Sjulian */ 1039107120Sjulian 1040107120Sjulianstatic int 1041107120Sjulianng_btsocket_l2cap_process_l2ca_discon_ind(struct ng_mesg *msg, 1042114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 1043107120Sjulian{ 1044107120Sjulian ng_l2cap_l2ca_discon_ind_ip *ip = NULL; 1045107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 1046107120Sjulian 1047107120Sjulian /* Check message */ 1048107120Sjulian if (msg->header.arglen != sizeof(*ip)) 1049107120Sjulian return (EMSGSIZE); 1050107120Sjulian 1051107120Sjulian ip = (ng_l2cap_l2ca_discon_ind_ip *)(msg->data); 1052107120Sjulian 1053114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1054114878Sjulian 1055107120Sjulian /* Look for the socket with given channel ID */ 1056107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, ip->lcid); 1057114878Sjulian if (pcb == NULL) { 1058114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1059107120Sjulian return (0); 1060114878Sjulian } 1061107120Sjulian 1062107120Sjulian /* 1063107120Sjulian * Channel has already been destroyed, so disconnect the socket 1064107120Sjulian * and be done with it. If there was any pending request we can 1065107120Sjulian * not do anything here anyway. 1066107120Sjulian */ 1067107120Sjulian 1068107120Sjulian mtx_lock(&pcb->pcb_mtx); 1069107120Sjulian 1070107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1071107120Sjulian"%s: Got L2CA_Disconnect indicator, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1072107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, state=%d\n", 1073107120Sjulian __func__, 1074107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1075107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1076107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1077107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1078107120Sjulian pcb->psm, pcb->cid, pcb->state); 1079107120Sjulian 1080107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1081107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1082107120Sjulian 1083107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1084107120Sjulian soisdisconnected(pcb->so); 1085107120Sjulian 1086114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 1087114878Sjulian *sop = pcb->so; 1088114878Sjulian 1089107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1090114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1091107120Sjulian 1092107120Sjulian return (0); 1093107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_discon_ind */ 1094107120Sjulian 1095107120Sjulian/* 1096107120Sjulian * Process L2CA_Write response 1097107120Sjulian */ 1098107120Sjulian 1099107120Sjulianstatic int 1100107120Sjulianng_btsocket_l2cap_process_l2ca_write_rsp(struct ng_mesg *msg, 1101114878Sjulian ng_btsocket_l2cap_rtentry_p rt, struct socket **sop) 1102107120Sjulian{ 1103107120Sjulian ng_l2cap_l2ca_write_op *op = NULL; 1104107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 1105107120Sjulian 1106107120Sjulian /* Check message */ 1107107120Sjulian if (msg->header.arglen != sizeof(*op)) 1108107120Sjulian return (EMSGSIZE); 1109107120Sjulian 1110107120Sjulian op = (ng_l2cap_l2ca_write_op *)(msg->data); 1111107120Sjulian 1112114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1113114878Sjulian 1114107120Sjulian /* Look for the socket with given token */ 1115107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_token(msg->header.token); 1116114878Sjulian if (pcb == NULL) { 1117114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1118107120Sjulian return (ENOENT); 1119114878Sjulian } 1120107120Sjulian 1121107120Sjulian mtx_lock(&pcb->pcb_mtx); 1122107120Sjulian 1123107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1124107120Sjulian"%s: Got L2CA_Write response, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1125107120Sjulian"dst bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, lcid=%d, result=%d, length=%d, " \ 1126107120Sjulian"state=%d\n", __func__, 1127107120Sjulian pcb->src.b[5], pcb->src.b[4], pcb->src.b[3], 1128107120Sjulian pcb->src.b[2], pcb->src.b[1], pcb->src.b[0], 1129107120Sjulian pcb->dst.b[5], pcb->dst.b[4], pcb->dst.b[3], 1130107120Sjulian pcb->dst.b[2], pcb->dst.b[1], pcb->dst.b[0], 1131107120Sjulian pcb->psm, pcb->cid, op->result, op->length, 1132107120Sjulian pcb->state); 1133107120Sjulian 1134107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1135107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1136114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1137114878Sjulian 1138107120Sjulian return (ENOENT); 1139107120Sjulian } 1140107120Sjulian 1141107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1142107120Sjulian 1143107120Sjulian /* 1144107120Sjulian * Check if we have more data to send 1145107120Sjulian */ 1146107120Sjulian 1147107120Sjulian sbdroprecord(&pcb->so->so_snd); 1148107120Sjulian if (pcb->so->so_snd.sb_cc > 0) { 1149107120Sjulian if (ng_btsocket_l2cap_send2(pcb) == 0) 1150107120Sjulian ng_btsocket_l2cap_timeout(pcb); 1151107120Sjulian else 1152107120Sjulian sbdroprecord(&pcb->so->so_snd); /* XXX */ 1153107120Sjulian } 1154107120Sjulian 1155107120Sjulian /* 1156107120Sjulian * Now set the result, drop packet from the socket send queue and 1157107120Sjulian * ask for more (wakeup sender) 1158107120Sjulian */ 1159107120Sjulian 1160107120Sjulian pcb->so->so_error = ng_btsocket_l2cap_result2errno(op->result); 1161107120Sjulian sowwakeup(pcb->so); 1162107120Sjulian 1163107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1164114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1165107120Sjulian 1166107120Sjulian return (0); 1167107120Sjulian} /* ng_btsocket_l2cap_process_l2ca_write_rsp */ 1168107120Sjulian 1169107120Sjulian/* 1170107120Sjulian * Send L2CA_Connect request 1171107120Sjulian */ 1172107120Sjulian 1173107120Sjulianstatic int 1174107120Sjulianng_btsocket_l2cap_send_l2ca_con_req(ng_btsocket_l2cap_pcb_p pcb) 1175107120Sjulian{ 1176107120Sjulian struct ng_mesg *msg = NULL; 1177107120Sjulian ng_l2cap_l2ca_con_ip *ip = NULL; 1178107120Sjulian int error = 0; 1179107120Sjulian 1180107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1181107120Sjulian 1182107120Sjulian if (pcb->rt == NULL || 1183107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1184107120Sjulian return (ENETDOWN); 1185107120Sjulian 1186107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON, 1187107120Sjulian sizeof(*ip), M_NOWAIT); 1188107120Sjulian if (msg == NULL) 1189107120Sjulian return (ENOMEM); 1190107120Sjulian 1191107120Sjulian msg->header.token = pcb->token; 1192107120Sjulian 1193107120Sjulian ip = (ng_l2cap_l2ca_con_ip *)(msg->data); 1194107120Sjulian bcopy(&pcb->dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1195107120Sjulian ip->psm = pcb->psm; 1196107120Sjulian 1197107120Sjulian NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1198107120Sjulian 1199107120Sjulian return (error); 1200107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_con_req */ 1201107120Sjulian 1202107120Sjulian/* 1203107120Sjulian * Send L2CA_Connect response 1204107120Sjulian */ 1205107120Sjulian 1206107120Sjulianstatic int 1207107120Sjulianng_btsocket_l2cap_send_l2ca_con_rsp_req(u_int32_t token, 1208107120Sjulian ng_btsocket_l2cap_rtentry_p rt, bdaddr_p dst, int ident, 1209107120Sjulian int lcid, int result) 1210107120Sjulian{ 1211107120Sjulian struct ng_mesg *msg = NULL; 1212107120Sjulian ng_l2cap_l2ca_con_rsp_ip *ip = NULL; 1213107120Sjulian int error = 0; 1214107120Sjulian 1215107120Sjulian if (rt == NULL || rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 1216107120Sjulian return (ENETDOWN); 1217107120Sjulian 1218107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CON_RSP, 1219107120Sjulian sizeof(*ip), M_NOWAIT); 1220107120Sjulian if (msg == NULL) 1221107120Sjulian return (ENOMEM); 1222107120Sjulian 1223107120Sjulian msg->header.token = token; 1224107120Sjulian 1225107120Sjulian ip = (ng_l2cap_l2ca_con_rsp_ip *)(msg->data); 1226107120Sjulian bcopy(dst, &ip->bdaddr, sizeof(ip->bdaddr)); 1227107120Sjulian ip->ident = ident; 1228107120Sjulian ip->lcid = lcid; 1229107120Sjulian ip->result = result; 1230107120Sjulian ip->status = 0; 1231107120Sjulian 1232107120Sjulian NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_node, msg, rt->hook, NULL); 1233107120Sjulian 1234107120Sjulian return (error); 1235107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_con_rsp_req */ 1236107120Sjulian 1237107120Sjulian/* 1238107120Sjulian * Send L2CA_Config request 1239107120Sjulian */ 1240107120Sjulian 1241107120Sjulianstatic int 1242107120Sjulianng_btsocket_l2cap_send_l2ca_cfg_req(ng_btsocket_l2cap_pcb_p pcb) 1243107120Sjulian{ 1244107120Sjulian struct ng_mesg *msg = NULL; 1245107120Sjulian ng_l2cap_l2ca_cfg_ip *ip = NULL; 1246107120Sjulian int error = 0; 1247107120Sjulian 1248107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1249107120Sjulian 1250107120Sjulian if (pcb->rt == NULL || 1251107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1252107120Sjulian return (ENETDOWN); 1253107120Sjulian 1254107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG, 1255107120Sjulian sizeof(*ip), M_NOWAIT); 1256107120Sjulian if (msg == NULL) 1257107120Sjulian return (ENOMEM); 1258107120Sjulian 1259107120Sjulian msg->header.token = pcb->token; 1260107120Sjulian 1261107120Sjulian ip = (ng_l2cap_l2ca_cfg_ip *)(msg->data); 1262107120Sjulian ip->lcid = pcb->cid; 1263107120Sjulian ip->imtu = pcb->imtu; 1264107120Sjulian bcopy(&pcb->oflow, &ip->oflow, sizeof(ip->oflow)); 1265107120Sjulian ip->flush_timo = pcb->flush_timo; 1266107120Sjulian ip->link_timo = pcb->link_timo; 1267107120Sjulian 1268107120Sjulian NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1269107120Sjulian 1270107120Sjulian return (error); 1271107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_cfg_req */ 1272107120Sjulian 1273107120Sjulian/* 1274107120Sjulian * Send L2CA_Config response 1275107120Sjulian */ 1276107120Sjulian 1277107120Sjulianstatic int 1278107120Sjulianng_btsocket_l2cap_send_l2ca_cfg_rsp(ng_btsocket_l2cap_pcb_p pcb) 1279107120Sjulian{ 1280107120Sjulian struct ng_mesg *msg = NULL; 1281107120Sjulian ng_l2cap_l2ca_cfg_rsp_ip *ip = NULL; 1282107120Sjulian int error = 0; 1283107120Sjulian 1284107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1285107120Sjulian 1286107120Sjulian if (pcb->rt == NULL || 1287107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1288107120Sjulian return (ENETDOWN); 1289107120Sjulian 1290107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_CFG_RSP, 1291107120Sjulian sizeof(*ip), M_NOWAIT); 1292107120Sjulian if (msg == NULL) 1293107120Sjulian return (ENOMEM); 1294107120Sjulian 1295107120Sjulian msg->header.token = pcb->token; 1296107120Sjulian 1297107120Sjulian ip = (ng_l2cap_l2ca_cfg_rsp_ip *)(msg->data); 1298107120Sjulian ip->lcid = pcb->cid; 1299107120Sjulian ip->omtu = pcb->omtu; 1300107120Sjulian bcopy(&pcb->iflow, &ip->iflow, sizeof(ip->iflow)); 1301107120Sjulian 1302107120Sjulian NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1303107120Sjulian 1304107120Sjulian return (error); 1305107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_cfg_rsp */ 1306107120Sjulian 1307107120Sjulian/* 1308107120Sjulian * Send L2CA_Disconnect request 1309107120Sjulian */ 1310107120Sjulian 1311107120Sjulianstatic int 1312107120Sjulianng_btsocket_l2cap_send_l2ca_discon_req(u_int32_t token, 1313107120Sjulian ng_btsocket_l2cap_pcb_p pcb) 1314107120Sjulian{ 1315107120Sjulian struct ng_mesg *msg = NULL; 1316107120Sjulian ng_l2cap_l2ca_discon_ip *ip = NULL; 1317107120Sjulian int error = 0; 1318107120Sjulian 1319107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 1320107120Sjulian 1321107120Sjulian if (pcb->rt == NULL || 1322107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) 1323107120Sjulian return (ENETDOWN); 1324107120Sjulian 1325107120Sjulian NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_DISCON, 1326107120Sjulian sizeof(*ip), M_NOWAIT); 1327107120Sjulian if (msg == NULL) 1328107120Sjulian return (ENOMEM); 1329107120Sjulian 1330107120Sjulian msg->header.token = token; 1331107120Sjulian 1332107120Sjulian ip = (ng_l2cap_l2ca_discon_ip *)(msg->data); 1333107120Sjulian ip->lcid = pcb->cid; 1334107120Sjulian 1335107120Sjulian NG_SEND_MSG_HOOK(error,ng_btsocket_l2cap_node,msg,pcb->rt->hook,NULL); 1336107120Sjulian 1337107120Sjulian return (error); 1338107120Sjulian} /* ng_btsocket_l2cap_send_l2ca_discon_req */ 1339107120Sjulian 1340107120Sjulian/***************************************************************************** 1341107120Sjulian ***************************************************************************** 1342107120Sjulian ** Socket interface 1343107120Sjulian ***************************************************************************** 1344107120Sjulian *****************************************************************************/ 1345107120Sjulian 1346107120Sjulian/* 1347107120Sjulian * L2CAP sockets data input routine 1348107120Sjulian */ 1349107120Sjulian 1350107120Sjulianstatic void 1351107120Sjulianng_btsocket_l2cap_data_input(struct mbuf *m, hook_p hook) 1352107120Sjulian{ 1353107120Sjulian ng_l2cap_hdr_t *hdr = NULL; 1354107120Sjulian ng_l2cap_clt_hdr_t *clt_hdr = NULL; 1355107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 1356107120Sjulian ng_btsocket_l2cap_rtentry_t *rt = NULL; 1357107120Sjulian 1358107120Sjulian if (hook == NULL) { 1359107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1360107120Sjulian"%s: Invalid source hook for L2CAP data packet\n", __func__); 1361107120Sjulian goto drop; 1362107120Sjulian } 1363107120Sjulian 1364107120Sjulian rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1365107120Sjulian if (rt == NULL) { 1366107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1367107120Sjulian"%s: Could not find out source bdaddr for L2CAP data packet\n", __func__); 1368107120Sjulian goto drop; 1369107120Sjulian } 1370107120Sjulian 1371107120Sjulian /* Make sure we can access header */ 1372107120Sjulian if (m->m_pkthdr.len < sizeof(*hdr)) { 1373107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1374107120Sjulian"%s: L2CAP data packet too small, len=%d\n", __func__, m->m_pkthdr.len); 1375107120Sjulian goto drop; 1376107120Sjulian } 1377107120Sjulian 1378107120Sjulian if (m->m_len < sizeof(*hdr)) { 1379107120Sjulian m = m_pullup(m, sizeof(*hdr)); 1380107120Sjulian if (m == NULL) 1381107120Sjulian goto drop; 1382107120Sjulian } 1383107120Sjulian 1384107120Sjulian /* Strip L2CAP packet header and verify packet length */ 1385107120Sjulian hdr = mtod(m, ng_l2cap_hdr_t *); 1386107120Sjulian m_adj(m, sizeof(*hdr)); 1387107120Sjulian 1388107120Sjulian if (hdr->length != m->m_pkthdr.len) { 1389107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1390107120Sjulian"%s: Bad L2CAP data packet length, len=%d, length=%d\n", 1391107120Sjulian __func__, m->m_pkthdr.len, hdr->length); 1392107120Sjulian goto drop; 1393107120Sjulian } 1394107120Sjulian 1395107120Sjulian /* 1396107120Sjulian * Now process packet. Two cases: 1397107120Sjulian * 1398107120Sjulian * 1) Normal packet (cid != 2) then find connected socket and append 1399107120Sjulian * mbuf to the socket queue. Wakeup socket. 1400107120Sjulian * 1401107120Sjulian * 2) Broadcast packet (cid == 2) then find all sockets that connected 1402107120Sjulian * to the given PSM and have SO_BROADCAST bit set and append mbuf 1403107120Sjulian * to the socket queue. Wakeup socket. 1404107120Sjulian */ 1405107120Sjulian 1406107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1407114878Sjulian"%s: Received L2CAP data packet: src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1408107120Sjulian"dcid=%d, length=%d\n", 1409107120Sjulian __func__, 1410107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1411107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1412107120Sjulian hdr->dcid, hdr->length); 1413107120Sjulian 1414121054Semax if (hdr->dcid >= NG_L2CAP_FIRST_CID) { 1415114878Sjulian 1416114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1417114878Sjulian 1418107120Sjulian /* Normal packet: find connected socket */ 1419107120Sjulian pcb = ng_btsocket_l2cap_pcb_by_cid(&rt->src, hdr->dcid); 1420114878Sjulian if (pcb == NULL) { 1421114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1422107120Sjulian goto drop; 1423114878Sjulian } 1424107120Sjulian 1425107120Sjulian mtx_lock(&pcb->pcb_mtx); 1426107120Sjulian 1427107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 1428107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1429107120Sjulian"%s: No connected socket found, src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, " \ 1430107120Sjulian"state=%d\n", __func__, 1431107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1432107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1433107120Sjulian hdr->dcid, pcb->state); 1434107120Sjulian 1435107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1436114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1437107120Sjulian goto drop; 1438107120Sjulian } 1439107120Sjulian 1440107120Sjulian /* Check packet size against socket's incoming MTU */ 1441107120Sjulian if (hdr->length > pcb->imtu) { 1442107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1443107120Sjulian"%s: L2CAP data packet too big, src bdaddr=%x:%x:%x:%x:%x:%x, " \ 1444107120Sjulian"dcid=%d, length=%d, imtu=%d\n", 1445107120Sjulian __func__, 1446107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1447107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1448107120Sjulian hdr->dcid, hdr->length, pcb->imtu); 1449107120Sjulian 1450107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1451114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1452107120Sjulian goto drop; 1453107120Sjulian } 1454107120Sjulian 1455107120Sjulian /* Check if we have enough space in socket receive queue */ 1456107120Sjulian if (m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) { 1457107120Sjulian 1458107120Sjulian /* 1459107120Sjulian * This is really bad. Receive queue on socket does 1460107120Sjulian * not have enough space for the packet. We do not 1461107120Sjulian * have any other choice but drop the packet. L2CAP 1462107120Sjulian * does not provide any flow control. 1463107120Sjulian */ 1464107120Sjulian 1465107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1466107120Sjulian"%s: Not enough space in socket receive queue. Dropping L2CAP data packet, " \ 1467107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, dcid=%d, len=%d, space=%ld\n", 1468107120Sjulian __func__, 1469107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1470107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1471107120Sjulian hdr->dcid, m->m_pkthdr.len, 1472107120Sjulian sbspace(&pcb->so->so_rcv)); 1473107120Sjulian 1474107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1475114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1476107120Sjulian goto drop; 1477107120Sjulian } 1478107120Sjulian 1479107120Sjulian /* Append packet to the socket receive queue and wakeup */ 1480107120Sjulian sbappendrecord(&pcb->so->so_rcv, m); 1481107120Sjulian m = NULL; 1482107120Sjulian 1483107120Sjulian sorwakeup(pcb->so); 1484114878Sjulian 1485107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1486114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1487114878Sjulian } else if (hdr->dcid == NG_L2CAP_CLT_CID) { 1488107120Sjulian /* Broadcast packet: give packet to all sockets */ 1489107120Sjulian 1490107120Sjulian /* Check packet size against connectionless MTU */ 1491107120Sjulian if (hdr->length > NG_L2CAP_MTU_DEFAULT) { 1492107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1493107120Sjulian"%s: Connectionless L2CAP data packet too big, " \ 1494107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1495107120Sjulian __func__, 1496107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1497107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1498107120Sjulian hdr->length); 1499107120Sjulian goto drop; 1500107120Sjulian } 1501107120Sjulian 1502107120Sjulian /* Make sure we can access connectionless header */ 1503107120Sjulian if (m->m_pkthdr.len < sizeof(*clt_hdr)) { 1504107120Sjulian NG_BTSOCKET_L2CAP_ERR( 1505107120Sjulian"%s: Can not get L2CAP connectionless packet header, " \ 1506107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, length=%d\n", 1507107120Sjulian __func__, 1508107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1509107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1510107120Sjulian hdr->length); 1511107120Sjulian goto drop; 1512107120Sjulian } 1513107120Sjulian 1514107120Sjulian if (m->m_len < sizeof(*clt_hdr)) { 1515107120Sjulian m = m_pullup(m, sizeof(*clt_hdr)); 1516107120Sjulian if (m == NULL) 1517107120Sjulian goto drop; 1518107120Sjulian } 1519107120Sjulian 1520107120Sjulian /* Strip connectionless header and deliver packet */ 1521107120Sjulian clt_hdr = mtod(m, ng_l2cap_clt_hdr_t *); 1522107120Sjulian m_adj(m, sizeof(*clt_hdr)); 1523107120Sjulian 1524107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1525107120Sjulian"%s: Got L2CAP connectionless data packet, " \ 1526107120Sjulian"src bdaddr=%x:%x:%x:%x:%x:%x, psm=%d, length=%d\n", 1527107120Sjulian __func__, 1528107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1529107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0], 1530107120Sjulian clt_hdr->psm, hdr->length); 1531107120Sjulian 1532107120Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1533107120Sjulian 1534107120Sjulian LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) { 1535107120Sjulian struct mbuf *copy = NULL; 1536107120Sjulian 1537107120Sjulian mtx_lock(&pcb->pcb_mtx); 1538107120Sjulian 1539107120Sjulian if (bcmp(&rt->src, &pcb->src, sizeof(pcb->src)) != 0 || 1540107120Sjulian pcb->psm != clt_hdr->psm || 1541107120Sjulian pcb->state != NG_BTSOCKET_L2CAP_OPEN || 1542107120Sjulian (pcb->so->so_options & SO_BROADCAST) == 0 || 1543107120Sjulian m->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) 1544107120Sjulian goto next; 1545107120Sjulian 1546107120Sjulian /* 1547107120Sjulian * Create a copy of the packet and append it to the 1548107120Sjulian * socket's queue. If m_dup() failed - no big deal 1549107120Sjulian * it is a broadcast traffic after all 1550107120Sjulian */ 1551107120Sjulian 1552111119Simp copy = m_dup(m, M_DONTWAIT); 1553107120Sjulian if (copy != NULL) { 1554107120Sjulian sbappendrecord(&pcb->so->so_rcv, copy); 1555107120Sjulian sorwakeup(pcb->so); 1556107120Sjulian } 1557107120Sjuliannext: 1558107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1559107120Sjulian } 1560114878Sjulian 1561107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1562107120Sjulian } 1563107120Sjuliandrop: 1564107120Sjulian NG_FREE_M(m); /* checks for m != NULL */ 1565107120Sjulian} /* ng_btsocket_l2cap_data_input */ 1566107120Sjulian 1567107120Sjulian/* 1568107120Sjulian * L2CAP sockets default message input routine 1569107120Sjulian */ 1570107120Sjulian 1571107120Sjulianstatic void 1572107120Sjulianng_btsocket_l2cap_default_msg_input(struct ng_mesg *msg, hook_p hook) 1573107120Sjulian{ 1574107120Sjulian switch (msg->header.cmd) { 1575107120Sjulian case NGM_L2CAP_NODE_HOOK_INFO: { 1576107120Sjulian ng_btsocket_l2cap_rtentry_t *rt = NULL; 1577107120Sjulian 1578107120Sjulian if (hook == NULL || msg->header.arglen != sizeof(bdaddr_t)) 1579107120Sjulian break; 1580107120Sjulian 1581107120Sjulian if (bcmp(msg->data, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 1582107120Sjulian break; 1583107120Sjulian 1584114878Sjulian mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1585114878Sjulian 1586107120Sjulian rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); 1587107120Sjulian if (rt == NULL) { 1588107120Sjulian MALLOC(rt, ng_btsocket_l2cap_rtentry_p, sizeof(*rt), 1589107120Sjulian M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT|M_ZERO); 1590114878Sjulian if (rt == NULL) { 1591114878Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1592107120Sjulian break; 1593114878Sjulian } 1594107120Sjulian 1595107120Sjulian LIST_INSERT_HEAD(&ng_btsocket_l2cap_rt, rt, next); 1596107120Sjulian 1597107120Sjulian NG_HOOK_SET_PRIVATE(hook, rt); 1598107120Sjulian } 1599114878Sjulian 1600107120Sjulian bcopy(msg->data, &rt->src, sizeof(rt->src)); 1601107120Sjulian rt->hook = hook; 1602107120Sjulian 1603114878Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1604114878Sjulian 1605107120Sjulian NG_BTSOCKET_L2CAP_INFO( 1606107120Sjulian"%s: Updating hook \"%s\", src bdaddr=%x:%x:%x:%x:%x:%x\n", 1607107120Sjulian __func__, NG_HOOK_NAME(hook), 1608107120Sjulian rt->src.b[5], rt->src.b[4], rt->src.b[3], 1609107120Sjulian rt->src.b[2], rt->src.b[1], rt->src.b[0]); 1610107120Sjulian } break; 1611107120Sjulian 1612107120Sjulian default: 1613107120Sjulian NG_BTSOCKET_L2CAP_WARN( 1614107120Sjulian"%s: Unknown message, cmd=%d\n", __func__, msg->header.cmd); 1615107120Sjulian break; 1616107120Sjulian } 1617107120Sjulian 1618107120Sjulian NG_FREE_MSG(msg); /* Checks for msg != NULL */ 1619107120Sjulian} /* ng_btsocket_l2cap_default_msg_input */ 1620107120Sjulian 1621107120Sjulian/* 1622107120Sjulian * L2CAP sockets L2CA message input routine 1623107120Sjulian */ 1624107120Sjulian 1625107120Sjulianstatic void 1626107120Sjulianng_btsocket_l2cap_l2ca_msg_input(struct ng_mesg *msg, hook_p hook) 1627107120Sjulian{ 1628114878Sjulian ng_btsocket_l2cap_rtentry_p rt = NULL; 1629114878Sjulian struct socket *so = NULL; 1630107120Sjulian 1631107120Sjulian if (hook == NULL) { 1632107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1633107120Sjulian"%s: Invalid source hook for L2CA message\n", __func__); 1634107120Sjulian goto drop; 1635107120Sjulian } 1636107120Sjulian 1637107120Sjulian rt = (ng_btsocket_l2cap_rtentry_p) NG_HOOK_PRIVATE(hook); 1638107120Sjulian if (rt == NULL) { 1639107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1640107120Sjulian"%s: Could not find out source bdaddr for L2CA message\n", __func__); 1641107120Sjulian goto drop; 1642107120Sjulian } 1643107120Sjulian 1644107120Sjulian switch (msg->header.cmd) { 1645107120Sjulian case NGM_L2CAP_L2CA_CON: /* L2CA_Connect response */ 1646114878Sjulian ng_btsocket_l2cap_process_l2ca_con_req_rsp(msg, rt, &so); 1647107120Sjulian break; 1648107120Sjulian 1649107120Sjulian case NGM_L2CAP_L2CA_CON_RSP: /* L2CA_ConnectRsp response */ 1650114878Sjulian ng_btsocket_l2cap_process_l2ca_con_rsp_rsp(msg, rt, &so); 1651107120Sjulian break; 1652107120Sjulian 1653107120Sjulian case NGM_L2CAP_L2CA_CON_IND: /* L2CA_Connect indicator */ 1654114878Sjulian ng_btsocket_l2cap_process_l2ca_con_ind(msg, rt, &so); 1655107120Sjulian break; 1656107120Sjulian 1657107120Sjulian case NGM_L2CAP_L2CA_CFG: /* L2CA_Config response */ 1658114878Sjulian ng_btsocket_l2cap_process_l2ca_cfg_req_rsp(msg, rt, &so); 1659107120Sjulian break; 1660107120Sjulian 1661107120Sjulian case NGM_L2CAP_L2CA_CFG_RSP: /* L2CA_ConfigRsp response */ 1662114878Sjulian ng_btsocket_l2cap_process_l2ca_cfg_rsp_rsp(msg, rt, &so); 1663107120Sjulian break; 1664107120Sjulian 1665107120Sjulian case NGM_L2CAP_L2CA_CFG_IND: /* L2CA_Config indicator */ 1666114878Sjulian ng_btsocket_l2cap_process_l2ca_cfg_ind(msg, rt, &so); 1667107120Sjulian break; 1668107120Sjulian 1669107120Sjulian case NGM_L2CAP_L2CA_DISCON: /* L2CA_Disconnect response */ 1670114878Sjulian ng_btsocket_l2cap_process_l2ca_discon_rsp(msg, rt, &so); 1671107120Sjulian break; 1672107120Sjulian 1673107120Sjulian case NGM_L2CAP_L2CA_DISCON_IND: /* L2CA_Disconnect indicator */ 1674114878Sjulian ng_btsocket_l2cap_process_l2ca_discon_ind(msg, rt, &so); 1675107120Sjulian break; 1676107120Sjulian 1677107120Sjulian case NGM_L2CAP_L2CA_WRITE: /* L2CA_Write response */ 1678114878Sjulian ng_btsocket_l2cap_process_l2ca_write_rsp(msg, rt, &so); 1679107120Sjulian break; 1680107120Sjulian 1681107120Sjulian /* XXX FIXME add other L2CA messages */ 1682107120Sjulian 1683107120Sjulian default: 1684107120Sjulian NG_BTSOCKET_L2CAP_WARN( 1685107120Sjulian"%s: Unknown L2CA message, cmd=%d\n", __func__, msg->header.cmd); 1686107120Sjulian break; 1687107120Sjulian } 1688107120Sjuliandrop: 1689107120Sjulian NG_FREE_MSG(msg); 1690114878Sjulian 1691114878Sjulian if (so != NULL) 1692114878Sjulian ng_btsocket_l2cap_detach(so); 1693107120Sjulian} /* ng_btsocket_l2cap_l2ca_msg_input */ 1694107120Sjulian 1695107120Sjulian/* 1696107120Sjulian * L2CAP sockets input routine 1697107120Sjulian */ 1698107120Sjulian 1699107120Sjulianstatic void 1700107120Sjulianng_btsocket_l2cap_input(void *context, int pending) 1701107120Sjulian{ 1702107120Sjulian item_p item = NULL; 1703107120Sjulian hook_p hook = NULL; 1704107120Sjulian 1705107120Sjulian for (;;) { 1706107120Sjulian mtx_lock(&ng_btsocket_l2cap_queue_mtx); 1707107120Sjulian NG_BT_ITEMQ_DEQUEUE(&ng_btsocket_l2cap_queue, item); 1708107120Sjulian mtx_unlock(&ng_btsocket_l2cap_queue_mtx); 1709107120Sjulian 1710107120Sjulian if (item == NULL) 1711107120Sjulian break; 1712107120Sjulian 1713107120Sjulian NGI_GET_HOOK(item, hook); 1714107120Sjulian if (hook != NULL && NG_HOOK_NOT_VALID(hook)) 1715107120Sjulian goto drop; 1716107120Sjulian 1717107120Sjulian switch(item->el_flags & NGQF_TYPE) { 1718107120Sjulian case NGQF_DATA: { 1719107120Sjulian struct mbuf *m = NULL; 1720107120Sjulian 1721107120Sjulian NGI_GET_M(item, m); 1722107120Sjulian ng_btsocket_l2cap_data_input(m, hook); 1723107120Sjulian } break; 1724107120Sjulian 1725107120Sjulian case NGQF_MESG: { 1726107120Sjulian struct ng_mesg *msg = NULL; 1727107120Sjulian 1728107120Sjulian NGI_GET_MSG(item, msg); 1729107120Sjulian 1730107120Sjulian switch (msg->header.cmd) { 1731107120Sjulian case NGM_L2CAP_L2CA_CON: 1732107120Sjulian case NGM_L2CAP_L2CA_CON_RSP: 1733107120Sjulian case NGM_L2CAP_L2CA_CON_IND: 1734107120Sjulian case NGM_L2CAP_L2CA_CFG: 1735107120Sjulian case NGM_L2CAP_L2CA_CFG_RSP: 1736107120Sjulian case NGM_L2CAP_L2CA_CFG_IND: 1737107120Sjulian case NGM_L2CAP_L2CA_DISCON: 1738107120Sjulian case NGM_L2CAP_L2CA_DISCON_IND: 1739107120Sjulian case NGM_L2CAP_L2CA_WRITE: 1740107120Sjulian /* XXX FIXME add other L2CA messages */ 1741107120Sjulian ng_btsocket_l2cap_l2ca_msg_input(msg, hook); 1742107120Sjulian break; 1743107120Sjulian 1744107120Sjulian default: 1745107120Sjulian ng_btsocket_l2cap_default_msg_input(msg, hook); 1746107120Sjulian break; 1747107120Sjulian } 1748107120Sjulian } break; 1749107120Sjulian 1750107120Sjulian default: 1751107120Sjulian KASSERT(0, 1752107120Sjulian("%s: invalid item type=%ld\n", __func__, (item->el_flags & NGQF_TYPE))); 1753107120Sjulian break; 1754107120Sjulian } 1755107120Sjuliandrop: 1756107120Sjulian if (hook != NULL) 1757107120Sjulian NG_HOOK_UNREF(hook); 1758107120Sjulian 1759107120Sjulian NG_FREE_ITEM(item); 1760107120Sjulian } 1761107120Sjulian} /* ng_btsocket_l2cap_input */ 1762107120Sjulian 1763107120Sjulian/* 1764107120Sjulian * Route cleanup task. Gets scheduled when hook is disconnected. Here we 1765107120Sjulian * will find all sockets that use "invalid" hook and disconnect them. 1766107120Sjulian */ 1767107120Sjulian 1768107120Sjulianstatic void 1769107120Sjulianng_btsocket_l2cap_rtclean(void *context, int pending) 1770107120Sjulian{ 1771114878Sjulian ng_btsocket_l2cap_pcb_p pcb = NULL, pcb_next = NULL; 1772107120Sjulian ng_btsocket_l2cap_rtentry_p rt = NULL; 1773107120Sjulian 1774107120Sjulian mtx_lock(&ng_btsocket_l2cap_rt_mtx); 1775107120Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 1776107120Sjulian 1777107120Sjulian /* 1778107120Sjulian * First disconnect all sockets that use "invalid" hook 1779107120Sjulian */ 1780107120Sjulian 1781114878Sjulian for (pcb = LIST_FIRST(&ng_btsocket_l2cap_sockets); pcb != NULL; ) { 1782107120Sjulian mtx_lock(&pcb->pcb_mtx); 1783114878Sjulian pcb_next = LIST_NEXT(pcb, next); 1784107120Sjulian 1785107120Sjulian if (pcb->rt != NULL && 1786107120Sjulian pcb->rt->hook != NULL && NG_HOOK_NOT_VALID(pcb->rt->hook)) { 1787107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 1788107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 1789107120Sjulian 1790107120Sjulian pcb->so->so_error = ENETDOWN; 1791107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1792107120Sjulian soisdisconnected(pcb->so); 1793107120Sjulian 1794107120Sjulian pcb->token = 0; 1795114878Sjulian pcb->cid = 0; 1796107120Sjulian pcb->rt = NULL; 1797114878Sjulian 1798114878Sjulian if (pcb->so->so_state & SS_NOFDREF) { 1799114878Sjulian struct socket *so = pcb->so; 1800114878Sjulian 1801114878Sjulian LIST_REMOVE(pcb, next); 1802114878Sjulian 1803114878Sjulian mtx_unlock(&pcb->pcb_mtx); 1804114878Sjulian 1805114878Sjulian mtx_destroy(&pcb->pcb_mtx); 1806114878Sjulian bzero(pcb, sizeof(*pcb)); 1807114878Sjulian FREE(pcb, M_NETGRAPH_BTSOCKET_L2CAP); 1808114878Sjulian 1809114878Sjulian soisdisconnected(so); 1810114878Sjulian so->so_pcb = NULL; 1811114878Sjulian sotryfree(so); 1812114878Sjulian 1813114878Sjulian goto next; 1814114878Sjulian } 1815107120Sjulian } 1816107120Sjulian 1817107120Sjulian mtx_unlock(&pcb->pcb_mtx); 1818114878Sjuliannext: 1819114878Sjulian pcb = pcb_next; 1820107120Sjulian } 1821107120Sjulian 1822107120Sjulian /* 1823107120Sjulian * Now cleanup routing table 1824107120Sjulian */ 1825107120Sjulian 1826114878Sjulian for (rt = LIST_FIRST(&ng_btsocket_l2cap_rt); rt != NULL; ) { 1827107120Sjulian ng_btsocket_l2cap_rtentry_p rt_next = LIST_NEXT(rt, next); 1828107120Sjulian 1829107120Sjulian if (rt->hook != NULL && NG_HOOK_NOT_VALID(rt->hook)) { 1830107120Sjulian LIST_REMOVE(rt, next); 1831107120Sjulian 1832107120Sjulian NG_HOOK_SET_PRIVATE(rt->hook, NULL); 1833107120Sjulian NG_HOOK_UNREF(rt->hook); /* Remove extra reference */ 1834107120Sjulian 1835107120Sjulian bzero(rt, sizeof(*rt)); 1836107120Sjulian FREE(rt, M_NETGRAPH_BTSOCKET_L2CAP); 1837107120Sjulian } 1838107120Sjulian 1839107120Sjulian rt = rt_next; 1840107120Sjulian } 1841107120Sjulian 1842107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 1843107120Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 1844107120Sjulian} /* ng_btsocket_l2cap_rtclean */ 1845107120Sjulian 1846107120Sjulian/* 1847107120Sjulian * Initialize everything 1848107120Sjulian */ 1849107120Sjulian 1850107120Sjulianvoid 1851107120Sjulianng_btsocket_l2cap_init(void) 1852107120Sjulian{ 1853107120Sjulian int error = 0; 1854107120Sjulian 1855107120Sjulian ng_btsocket_l2cap_node = NULL; 1856107120Sjulian ng_btsocket_l2cap_debug_level = NG_BTSOCKET_WARN_LEVEL; 1857107120Sjulian 1858107120Sjulian /* Register Netgraph node type */ 1859107120Sjulian error = ng_newtype(&typestruct); 1860107120Sjulian if (error != 0) { 1861107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1862107120Sjulian"%s: Could not register Netgraph node type, error=%d\n", __func__, error); 1863107120Sjulian 1864107120Sjulian return; 1865107120Sjulian } 1866107120Sjulian 1867107120Sjulian /* Create Netgrapg node */ 1868107120Sjulian error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_node); 1869107120Sjulian if (error != 0) { 1870107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1871107120Sjulian"%s: Could not create Netgraph node, error=%d\n", __func__, error); 1872107120Sjulian 1873107120Sjulian ng_btsocket_l2cap_node = NULL; 1874107120Sjulian 1875107120Sjulian return; 1876107120Sjulian } 1877107120Sjulian 1878107120Sjulian error = ng_name_node(ng_btsocket_l2cap_node, 1879107120Sjulian NG_BTSOCKET_L2CAP_NODE_TYPE); 1880107120Sjulian if (error != 0) { 1881107120Sjulian NG_BTSOCKET_L2CAP_ALERT( 1882107120Sjulian"%s: Could not name Netgraph node, error=%d\n", __func__, error); 1883107120Sjulian 1884107120Sjulian NG_NODE_UNREF(ng_btsocket_l2cap_node); 1885107120Sjulian ng_btsocket_l2cap_node = NULL; 1886107120Sjulian 1887107120Sjulian return; 1888107120Sjulian } 1889107120Sjulian 1890107120Sjulian /* Create input queue */ 1891107120Sjulian NG_BT_ITEMQ_INIT(&ng_btsocket_l2cap_queue, ifqmaxlen); 1892107120Sjulian mtx_init(&ng_btsocket_l2cap_queue_mtx, 1893107120Sjulian "btsocks_l2cap_queue_mtx", NULL, MTX_DEF); 1894107120Sjulian TASK_INIT(&ng_btsocket_l2cap_queue_task, 0, 1895107120Sjulian ng_btsocket_l2cap_input, NULL); 1896107120Sjulian 1897107120Sjulian /* Create list of sockets */ 1898107120Sjulian LIST_INIT(&ng_btsocket_l2cap_sockets); 1899107120Sjulian mtx_init(&ng_btsocket_l2cap_sockets_mtx, 1900107120Sjulian "btsocks_l2cap_sockets_mtx", NULL, MTX_DEF); 1901107120Sjulian 1902107120Sjulian /* Routing table */ 1903107120Sjulian LIST_INIT(&ng_btsocket_l2cap_rt); 1904107120Sjulian mtx_init(&ng_btsocket_l2cap_rt_mtx, 1905107120Sjulian "btsocks_l2cap_rt_mtx", NULL, MTX_DEF); 1906107120Sjulian TASK_INIT(&ng_btsocket_l2cap_rt_task, 0, 1907107120Sjulian ng_btsocket_l2cap_rtclean, NULL); 1908107120Sjulian} /* ng_btsocket_l2cap_init */ 1909107120Sjulian 1910107120Sjulian/* 1911107120Sjulian * Abort connection on socket 1912107120Sjulian */ 1913107120Sjulian 1914107120Sjulianint 1915107120Sjulianng_btsocket_l2cap_abort(struct socket *so) 1916107120Sjulian{ 1917107120Sjulian so->so_error = ECONNABORTED; 1918107120Sjulian 1919107120Sjulian return (ng_btsocket_l2cap_detach(so)); 1920107120Sjulian} /* ng_btsocket_l2cap_abort */ 1921107120Sjulian 1922107120Sjulian/* 1923107120Sjulian * Accept connection on socket. Nothing to do here, socket must be connected 1924107120Sjulian * and ready, so just return peer address and be done with it. 1925107120Sjulian */ 1926107120Sjulian 1927107120Sjulianint 1928107120Sjulianng_btsocket_l2cap_accept(struct socket *so, struct sockaddr **nam) 1929107120Sjulian{ 1930107120Sjulian if (ng_btsocket_l2cap_node == NULL) 1931107120Sjulian return (EINVAL); 1932107120Sjulian 1933107120Sjulian return (ng_btsocket_l2cap_peeraddr(so, nam)); 1934107120Sjulian} /* ng_btsocket_l2cap_accept */ 1935107120Sjulian 1936107120Sjulian/* 1937107120Sjulian * Create and attach new socket 1938107120Sjulian */ 1939107120Sjulian 1940107120Sjulianint 1941107120Sjulianng_btsocket_l2cap_attach(struct socket *so, int proto, struct thread *td) 1942107120Sjulian{ 1943114878Sjulian static u_int32_t token = 0; 1944107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 1945107120Sjulian int error; 1946107120Sjulian 1947107120Sjulian /* Check socket and protocol */ 1948107120Sjulian if (ng_btsocket_l2cap_node == NULL) 1949107120Sjulian return (EPROTONOSUPPORT); 1950107120Sjulian if (so->so_type != SOCK_SEQPACKET) 1951107120Sjulian return (ESOCKTNOSUPPORT); 1952107120Sjulian 1953107120Sjulian#if 0 /* XXX sonewconn() calls "pru_attach" with proto == 0 */ 1954107120Sjulian if (proto != 0) 1955107120Sjulian if (proto != BLUETOOTH_PROTO_L2CAP) 1956107120Sjulian return (EPROTONOSUPPORT); 1957107120Sjulian#endif /* XXX */ 1958107120Sjulian 1959107120Sjulian if (pcb != NULL) 1960107120Sjulian return (EISCONN); 1961107120Sjulian 1962107120Sjulian /* Reserve send and receive space if it is not reserved yet */ 1963107120Sjulian if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { 1964107120Sjulian error = soreserve(so, NG_BTSOCKET_L2CAP_SENDSPACE, 1965107120Sjulian NG_BTSOCKET_L2CAP_RECVSPACE); 1966107120Sjulian if (error != 0) 1967107120Sjulian return (error); 1968107120Sjulian } 1969107120Sjulian 1970107120Sjulian /* Allocate the PCB */ 1971107120Sjulian MALLOC(pcb, ng_btsocket_l2cap_pcb_p, sizeof(*pcb), 1972107120Sjulian M_NETGRAPH_BTSOCKET_L2CAP, M_NOWAIT | M_ZERO); 1973107120Sjulian if (pcb == NULL) 1974107120Sjulian return (ENOMEM); 1975107120Sjulian 1976107120Sjulian /* Link the PCB and the socket */ 1977107120Sjulian so->so_pcb = (caddr_t) pcb; 1978107120Sjulian pcb->so = so; 1979107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 1980107120Sjulian 1981107120Sjulian /* Initialize PCB */ 1982107120Sjulian pcb->imtu = pcb->omtu = NG_L2CAP_MTU_DEFAULT; 1983107120Sjulian 1984107120Sjulian /* Default flow */ 1985107120Sjulian pcb->iflow.flags = 0x0; 1986107120Sjulian pcb->iflow.service_type = NG_HCI_SERVICE_TYPE_BEST_EFFORT; 1987107120Sjulian pcb->iflow.token_rate = 0xffffffff; /* maximum */ 1988107120Sjulian pcb->iflow.token_bucket_size = 0xffffffff; /* maximum */ 1989107120Sjulian pcb->iflow.peak_bandwidth = 0x00000000; /* maximum */ 1990107120Sjulian pcb->iflow.latency = 0xffffffff; /* don't care */ 1991107120Sjulian pcb->iflow.delay_variation = 0xffffffff; /* don't care */ 1992107120Sjulian 1993107120Sjulian bcopy(&pcb->iflow, &pcb->oflow, sizeof(pcb->oflow)); 1994107120Sjulian 1995107120Sjulian pcb->flush_timo = NG_L2CAP_FLUSH_TIMO_DEFAULT; 1996107120Sjulian pcb->link_timo = NG_L2CAP_LINK_TIMO_DEFAULT; 1997107120Sjulian 1998107120Sjulian callout_handle_init(&pcb->timo); 1999107120Sjulian 2000114878Sjulian /* 2001114878Sjulian * XXX Mark PCB mutex as DUPOK to prevent "duplicated lock of 2002114878Sjulian * the same type" message. When accepting new L2CAP connection 2003114878Sjulian * ng_btsocket_l2cap_process_l2ca_con_ind() holds both PCB mutexes 2004114878Sjulian * for "old" (accepting) PCB and "new" (created) PCB. 2005114878Sjulian */ 2006114878Sjulian 2007114878Sjulian mtx_init(&pcb->pcb_mtx, "btsocks_l2cap_pcb_mtx", NULL, 2008114878Sjulian MTX_DEF|MTX_DUPOK); 2009114878Sjulian 2010114878Sjulian /* 2011114878Sjulian * Add the PCB to the list 2012114878Sjulian * 2013114878Sjulian * XXX FIXME VERY IMPORTANT! 2014114878Sjulian * 2015114878Sjulian * This is totally FUBAR. We could get here in two cases: 2016114878Sjulian * 2017114878Sjulian * 1) When user calls socket() 2018114878Sjulian * 2) When we need to accept new incomming connection and call 2019114878Sjulian * sonewconn() 2020114878Sjulian * 2021114878Sjulian * In the first case we must aquire ng_btsocket_l2cap_sockets_mtx. 2022114878Sjulian * In the second case we hold ng_btsocket_l2cap_sockets_mtx already. 2023114878Sjulian * So we now need to distinguish between these cases. From reading 2024114878Sjulian * /sys/kern/uipc_socket2.c we can find out that sonewconn() calls 2025114878Sjulian * pru_attach with proto == 0 and td == NULL. For now use this fact 2026114878Sjulian * to figure out if we were called from socket() or from sonewconn(). 2027114878Sjulian */ 2028114878Sjulian 2029114878Sjulian if (td != NULL) 2030114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2031114878Sjulian else 2032114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2033114878Sjulian 2034114878Sjulian /* Set PCB token. Use ng_btsocket_l2cap_sockets_mtx for protection */ 2035114878Sjulian if (++ token == 0) 2036114878Sjulian token ++; 2037114878Sjulian 2038114878Sjulian pcb->token = token; 2039114878Sjulian 2040107120Sjulian LIST_INSERT_HEAD(&ng_btsocket_l2cap_sockets, pcb, next); 2041107120Sjulian 2042114878Sjulian if (td != NULL) 2043114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2044114878Sjulian 2045107120Sjulian return (0); 2046107120Sjulian} /* ng_btsocket_l2cap_attach */ 2047107120Sjulian 2048107120Sjulian/* 2049107120Sjulian * Bind socket 2050107120Sjulian */ 2051107120Sjulian 2052107120Sjulianint 2053107120Sjulianng_btsocket_l2cap_bind(struct socket *so, struct sockaddr *nam, 2054107120Sjulian struct thread *td) 2055107120Sjulian{ 2056107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = NULL; 2057107120Sjulian struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2058107120Sjulian int psm, error = 0; 2059107120Sjulian 2060107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2061107120Sjulian return (EINVAL); 2062107120Sjulian 2063107120Sjulian /* Verify address */ 2064107120Sjulian if (sa == NULL) 2065107120Sjulian return (EINVAL); 2066107120Sjulian if (sa->l2cap_family != AF_BLUETOOTH) 2067107120Sjulian return (EAFNOSUPPORT); 2068107120Sjulian if (sa->l2cap_len != sizeof(*sa)) 2069107120Sjulian return (EINVAL); 2070107120Sjulian 2071107120Sjulian psm = le16toh(sa->l2cap_psm); 2072107120Sjulian 2073107120Sjulian /* 2074107120Sjulian * Check if other socket has this address already (look for exact 2075107120Sjulian * match PSM and bdaddr) and assign socket address if it's available. 2076107120Sjulian * 2077107120Sjulian * Note: socket can be bound to ANY PSM (zero) thus allowing several 2078107120Sjulian * channels with the same PSM between the same pair of BD_ADDR'es. 2079107120Sjulian */ 2080107120Sjulian 2081107120Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2082107120Sjulian 2083107120Sjulian LIST_FOREACH(pcb, &ng_btsocket_l2cap_sockets, next) 2084107120Sjulian if (psm != 0 && psm == pcb->psm && 2085107120Sjulian bcmp(&pcb->src, &sa->l2cap_bdaddr, sizeof(bdaddr_t)) == 0) 2086107120Sjulian break; 2087107120Sjulian 2088107120Sjulian if (pcb == NULL) { 2089107120Sjulian /* Set socket address */ 2090107120Sjulian pcb = so2l2cap_pcb(so); 2091107120Sjulian if (pcb != NULL) { 2092107120Sjulian bcopy(&sa->l2cap_bdaddr, &pcb->src, sizeof(pcb->src)); 2093107120Sjulian pcb->psm = psm; 2094107120Sjulian } else 2095107120Sjulian error = EINVAL; 2096107120Sjulian } else 2097107120Sjulian error = EADDRINUSE; 2098107120Sjulian 2099107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2100107120Sjulian 2101107120Sjulian return (error); 2102107120Sjulian} /* ng_btsocket_l2cap_bind */ 2103107120Sjulian 2104107120Sjulian/* 2105107120Sjulian * Connect socket 2106107120Sjulian */ 2107107120Sjulian 2108107120Sjulianint 2109107120Sjulianng_btsocket_l2cap_connect(struct socket *so, struct sockaddr *nam, 2110107120Sjulian struct thread *td) 2111107120Sjulian{ 2112107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2113107120Sjulian struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; 2114107120Sjulian ng_btsocket_l2cap_rtentry_t *rt = NULL; 2115107120Sjulian int have_src, error = 0; 2116107120Sjulian 2117107120Sjulian /* Check socket */ 2118107120Sjulian if (pcb == NULL) 2119107120Sjulian return (EINVAL); 2120107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2121107120Sjulian return (EINVAL); 2122107120Sjulian if (pcb->state == NG_BTSOCKET_L2CAP_CONNECTING) 2123107120Sjulian return (EINPROGRESS); 2124107120Sjulian 2125107120Sjulian /* Verify address */ 2126107120Sjulian if (sa == NULL) 2127107120Sjulian return (EINVAL); 2128107120Sjulian if (sa->l2cap_family != AF_BLUETOOTH) 2129107120Sjulian return (EAFNOSUPPORT); 2130107120Sjulian if (sa->l2cap_len != sizeof(*sa)) 2131107120Sjulian return (EINVAL); 2132107120Sjulian if (sa->l2cap_psm == 0 || 2133107120Sjulian bcmp(&sa->l2cap_bdaddr, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) 2134107120Sjulian return (EDESTADDRREQ); 2135107120Sjulian if (pcb->psm != 0 && pcb->psm != le16toh(sa->l2cap_psm)) 2136107120Sjulian return (EINVAL); 2137107120Sjulian 2138107120Sjulian /* 2139107120Sjulian * Routing. Socket should be bound to some source address. The source 2140107120Sjulian * address can be ANY. Destination address must be set and it must not 2141107120Sjulian * be ANY. If source address is ANY then find first rtentry that has 2142107120Sjulian * src != dst. 2143107120Sjulian */ 2144107120Sjulian 2145114878Sjulian mtx_lock(&ng_btsocket_l2cap_rt_mtx); 2146114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2147114878Sjulian mtx_lock(&pcb->pcb_mtx); 2148114878Sjulian 2149114878Sjulian /* Send destination address and PSM */ 2150114878Sjulian bcopy(&sa->l2cap_bdaddr, &pcb->dst, sizeof(pcb->dst)); 2151114878Sjulian pcb->psm = le16toh(sa->l2cap_psm); 2152114878Sjulian 2153107120Sjulian pcb->rt = NULL; 2154107120Sjulian have_src = bcmp(&pcb->src, NG_HCI_BDADDR_ANY, sizeof(pcb->src)); 2155107120Sjulian 2156107120Sjulian LIST_FOREACH(rt, &ng_btsocket_l2cap_rt, next) { 2157107120Sjulian if (rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) 2158107120Sjulian continue; 2159107120Sjulian 2160107120Sjulian /* Match src and dst */ 2161107120Sjulian if (have_src) { 2162107120Sjulian if (bcmp(&pcb->src, &rt->src, sizeof(rt->src)) == 0) 2163107120Sjulian break; 2164107120Sjulian } else { 2165107120Sjulian if (bcmp(&pcb->dst, &rt->src, sizeof(rt->src)) != 0) 2166107120Sjulian break; 2167107120Sjulian } 2168107120Sjulian } 2169107120Sjulian 2170107120Sjulian if (rt != NULL) { 2171107120Sjulian pcb->rt = rt; 2172107120Sjulian 2173107120Sjulian if (!have_src) 2174107120Sjulian bcopy(&rt->src, &pcb->src, sizeof(pcb->src)); 2175107120Sjulian } else 2176107120Sjulian error = EHOSTUNREACH; 2177107120Sjulian 2178107120Sjulian /* 2179107120Sjulian * Send L2CA_Connect request 2180107120Sjulian */ 2181107120Sjulian 2182107120Sjulian if (error == 0) { 2183107120Sjulian error = ng_btsocket_l2cap_send_l2ca_con_req(pcb); 2184107120Sjulian if (error == 0) { 2185107120Sjulian pcb->flags |= NG_BTSOCKET_L2CAP_CLIENT; 2186107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CONNECTING; 2187107120Sjulian soisconnecting(pcb->so); 2188107120Sjulian 2189107120Sjulian ng_btsocket_l2cap_timeout(pcb); 2190107120Sjulian } 2191107120Sjulian } 2192107120Sjulian 2193114878Sjulian mtx_unlock(&pcb->pcb_mtx); 2194114878Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2195114878Sjulian mtx_unlock(&ng_btsocket_l2cap_rt_mtx); 2196114878Sjulian 2197107120Sjulian return (error); 2198107120Sjulian} /* ng_btsocket_l2cap_connect */ 2199107120Sjulian 2200107120Sjulian/* 2201107120Sjulian * Process ioctl's calls on socket 2202107120Sjulian */ 2203107120Sjulian 2204107120Sjulianint 2205107120Sjulianng_btsocket_l2cap_control(struct socket *so, u_long cmd, caddr_t data, 2206107120Sjulian struct ifnet *ifp, struct thread *td) 2207107120Sjulian{ 2208107120Sjulian return (EINVAL); 2209107120Sjulian} /* ng_btsocket_l2cap_control */ 2210107120Sjulian 2211107120Sjulian/* 2212107120Sjulian * Process getsockopt/setsockopt system calls 2213107120Sjulian */ 2214107120Sjulian 2215107120Sjulianint 2216107120Sjulianng_btsocket_l2cap_ctloutput(struct socket *so, struct sockopt *sopt) 2217107120Sjulian{ 2218107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2219107120Sjulian int error = 0; 2220107120Sjulian ng_l2cap_cfg_opt_val_t v; 2221107120Sjulian 2222107120Sjulian if (pcb == NULL) 2223107120Sjulian return (EINVAL); 2224107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2225107120Sjulian return (EINVAL); 2226107120Sjulian 2227107120Sjulian if (sopt->sopt_level != SOL_L2CAP) 2228107120Sjulian return (0); 2229107120Sjulian 2230107120Sjulian mtx_lock(&pcb->pcb_mtx); 2231107120Sjulian 2232107120Sjulian switch (sopt->sopt_dir) { 2233107120Sjulian case SOPT_GET: 2234107120Sjulian switch (sopt->sopt_name) { 2235107120Sjulian case SO_L2CAP_IMTU: /* get incoming MTU */ 2236107120Sjulian error = sooptcopyout(sopt, &pcb->imtu, 2237107120Sjulian sizeof(pcb->imtu)); 2238107120Sjulian break; 2239107120Sjulian 2240107120Sjulian case SO_L2CAP_OMTU: /* get outgoing (peer incoming) MTU */ 2241107120Sjulian error = sooptcopyout(sopt, &pcb->omtu, 2242107120Sjulian sizeof(pcb->omtu)); 2243107120Sjulian break; 2244107120Sjulian 2245107120Sjulian case SO_L2CAP_IFLOW: /* get incoming flow spec. */ 2246107120Sjulian error = sooptcopyout(sopt, &pcb->iflow, 2247107120Sjulian sizeof(pcb->iflow)); 2248107120Sjulian break; 2249107120Sjulian 2250107120Sjulian case SO_L2CAP_OFLOW: /* get outgoing flow spec. */ 2251107120Sjulian error = sooptcopyout(sopt, &pcb->oflow, 2252107120Sjulian sizeof(pcb->oflow)); 2253107120Sjulian break; 2254107120Sjulian 2255107120Sjulian case SO_L2CAP_FLUSH: /* get flush timeout */ 2256107120Sjulian error = sooptcopyout(sopt, &pcb->flush_timo, 2257107120Sjulian sizeof(pcb->flush_timo)); 2258107120Sjulian break; 2259107120Sjulian 2260107120Sjulian default: 2261107120Sjulian error = ENOPROTOOPT; 2262107120Sjulian break; 2263107120Sjulian } 2264107120Sjulian break; 2265107120Sjulian 2266107120Sjulian case SOPT_SET: 2267107120Sjulian /* 2268114878Sjulian * XXX 2269114878Sjulian * We do not allow to change these parameters while socket is 2270114878Sjulian * connected or we are in the process of creating a connection. 2271114878Sjulian * May be this should indicate re-configuration of the open 2272114878Sjulian * channel? 2273107120Sjulian */ 2274107120Sjulian 2275107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) 2276107120Sjulian return (EACCES); 2277107120Sjulian 2278107120Sjulian switch (sopt->sopt_name) { 2279107120Sjulian case SO_L2CAP_IMTU: /* set incoming MTU */ 2280107120Sjulian error = sooptcopyin(sopt, &v, sizeof(v), sizeof(v.mtu)); 2281107120Sjulian if (error == 0) 2282107120Sjulian pcb->imtu = v.mtu; 2283107120Sjulian break; 2284107120Sjulian 2285107120Sjulian case SO_L2CAP_OFLOW: /* set outgoing flow spec. */ 2286107120Sjulian error = sooptcopyin(sopt, &v, sizeof(v),sizeof(v.flow)); 2287107120Sjulian if (error == 0) 2288107120Sjulian bcopy(&v.flow, &pcb->oflow, sizeof(pcb->oflow)); 2289107120Sjulian break; 2290107120Sjulian 2291107120Sjulian case SO_L2CAP_FLUSH: /* set flush timeout */ 2292107120Sjulian error = sooptcopyin(sopt, &v, sizeof(v), 2293107120Sjulian sizeof(v.flush_timo)); 2294107120Sjulian if (error == 0) 2295107120Sjulian pcb->flush_timo = v.flush_timo; 2296107120Sjulian break; 2297107120Sjulian 2298107120Sjulian default: 2299107120Sjulian error = ENOPROTOOPT; 2300107120Sjulian break; 2301107120Sjulian } 2302107120Sjulian break; 2303107120Sjulian 2304107120Sjulian default: 2305107120Sjulian error = EINVAL; 2306107120Sjulian break; 2307107120Sjulian } 2308107120Sjulian 2309107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2310107120Sjulian 2311107120Sjulian return (error); 2312107120Sjulian} /* ng_btsocket_l2cap_ctloutput */ 2313107120Sjulian 2314107120Sjulian/* 2315107120Sjulian * Detach and destroy socket 2316107120Sjulian */ 2317107120Sjulian 2318107120Sjulianint 2319107120Sjulianng_btsocket_l2cap_detach(struct socket *so) 2320107120Sjulian{ 2321107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2322107120Sjulian 2323107120Sjulian if (pcb == NULL) 2324107120Sjulian return (EINVAL); 2325107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2326107120Sjulian return (EINVAL); 2327107120Sjulian 2328114878Sjulian mtx_lock(&ng_btsocket_l2cap_sockets_mtx); 2329107120Sjulian mtx_lock(&pcb->pcb_mtx); 2330107120Sjulian 2331107120Sjulian /* XXX what to do with pending request? */ 2332107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2333107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 2334107120Sjulian 2335107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED && 2336107120Sjulian pcb->state != NG_BTSOCKET_L2CAP_DISCONNECTING) 2337107120Sjulian /* Send disconnect request with "zero" token */ 2338107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2339107120Sjulian 2340107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2341107120Sjulian 2342114878Sjulian LIST_REMOVE(pcb, next); 2343107120Sjulian 2344107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2345107120Sjulian mtx_unlock(&ng_btsocket_l2cap_sockets_mtx); 2346107120Sjulian 2347107120Sjulian mtx_destroy(&pcb->pcb_mtx); 2348107120Sjulian bzero(pcb, sizeof(*pcb)); 2349107120Sjulian FREE(pcb, M_NETGRAPH_BTSOCKET_L2CAP); 2350107120Sjulian 2351114878Sjulian soisdisconnected(so); 2352114878Sjulian so->so_pcb = NULL; 2353114878Sjulian sotryfree(so); 2354114878Sjulian 2355107120Sjulian return (0); 2356107120Sjulian} /* ng_btsocket_l2cap_detach */ 2357107120Sjulian 2358107120Sjulian/* 2359107120Sjulian * Disconnect socket 2360107120Sjulian */ 2361107120Sjulian 2362107120Sjulianint 2363107120Sjulianng_btsocket_l2cap_disconnect(struct socket *so) 2364107120Sjulian{ 2365107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2366107120Sjulian int error = 0; 2367107120Sjulian 2368107120Sjulian if (pcb == NULL) 2369107120Sjulian return (EINVAL); 2370107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2371107120Sjulian return (EINVAL); 2372107120Sjulian 2373107120Sjulian mtx_lock(&pcb->pcb_mtx); 2374107120Sjulian 2375107120Sjulian if (pcb->state == NG_BTSOCKET_L2CAP_DISCONNECTING) { 2376107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2377107120Sjulian return (EINPROGRESS); 2378107120Sjulian } 2379107120Sjulian 2380107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_CLOSED) { 2381107120Sjulian /* XXX FIXME what to do with pending request? */ 2382107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) 2383107120Sjulian ng_btsocket_l2cap_untimeout(pcb); 2384107120Sjulian 2385107120Sjulian error = ng_btsocket_l2cap_send_l2ca_discon_req(pcb->token, pcb); 2386107120Sjulian if (error == 0) { 2387107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_DISCONNECTING; 2388107120Sjulian soisdisconnecting(so); 2389107120Sjulian 2390107120Sjulian ng_btsocket_l2cap_timeout(pcb); 2391107120Sjulian } 2392107120Sjulian 2393107120Sjulian /* XXX FIXME what to do if error != 0 */ 2394107120Sjulian } 2395107120Sjulian 2396107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2397107120Sjulian 2398107120Sjulian return (error); 2399107120Sjulian} /* ng_btsocket_l2cap_disconnect */ 2400107120Sjulian 2401107120Sjulian/* 2402107120Sjulian * Listen on socket 2403107120Sjulian */ 2404107120Sjulian 2405107120Sjulianint 2406107120Sjulianng_btsocket_l2cap_listen(struct socket *so, struct thread *td) 2407107120Sjulian{ 2408107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2409107120Sjulian 2410107120Sjulian if (pcb == NULL) 2411107120Sjulian return (EINVAL); 2412107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2413107120Sjulian return (EINVAL); 2414107120Sjulian 2415107120Sjulian return ((pcb->psm == 0)? EDESTADDRREQ : 0); 2416107120Sjulian} /* ng_btsocket_listen */ 2417107120Sjulian 2418107120Sjulian/* 2419107120Sjulian * Get peer address 2420107120Sjulian */ 2421107120Sjulian 2422107120Sjulianint 2423107120Sjulianng_btsocket_l2cap_peeraddr(struct socket *so, struct sockaddr **nam) 2424107120Sjulian{ 2425107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2426107120Sjulian struct sockaddr_l2cap sa; 2427107120Sjulian 2428107120Sjulian if (pcb == NULL) 2429107120Sjulian return (EINVAL); 2430107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2431107120Sjulian return (EINVAL); 2432107120Sjulian 2433107120Sjulian bcopy(&pcb->dst, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2434107120Sjulian sa.l2cap_psm = htole16(pcb->psm); 2435107120Sjulian sa.l2cap_len = sizeof(sa); 2436107120Sjulian sa.l2cap_family = AF_BLUETOOTH; 2437107120Sjulian 2438107120Sjulian *nam = dup_sockaddr((struct sockaddr *) &sa, 0); 2439107120Sjulian 2440107120Sjulian return ((*nam == NULL)? ENOMEM : 0); 2441107120Sjulian} /* ng_btsocket_l2cap_peeraddr */ 2442107120Sjulian 2443107120Sjulian/* 2444107120Sjulian * Send data to socket 2445107120Sjulian */ 2446107120Sjulian 2447107120Sjulianint 2448107120Sjulianng_btsocket_l2cap_send(struct socket *so, int flags, struct mbuf *m, 2449107120Sjulian struct sockaddr *nam, struct mbuf *control, struct thread *td) 2450107120Sjulian{ 2451107120Sjulian ng_btsocket_l2cap_pcb_t *pcb = so2l2cap_pcb(so); 2452107120Sjulian int error = 0; 2453107120Sjulian 2454107120Sjulian if (ng_btsocket_l2cap_node == NULL) { 2455107120Sjulian error = ENETDOWN; 2456107120Sjulian goto drop; 2457107120Sjulian } 2458107120Sjulian 2459107120Sjulian /* Check socket and input */ 2460107120Sjulian if (pcb == NULL || m == NULL || control != NULL) { 2461107120Sjulian error = EINVAL; 2462107120Sjulian goto drop; 2463107120Sjulian } 2464107120Sjulian 2465107120Sjulian mtx_lock(&pcb->pcb_mtx); 2466107120Sjulian 2467107120Sjulian /* Make sure socket is connected */ 2468107120Sjulian if (pcb->state != NG_BTSOCKET_L2CAP_OPEN) { 2469107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2470107120Sjulian error = ENOTCONN; 2471107120Sjulian goto drop; 2472107120Sjulian } 2473107120Sjulian 2474107120Sjulian /* Check route */ 2475107120Sjulian if (pcb->rt == NULL || 2476107120Sjulian pcb->rt->hook == NULL || NG_HOOK_NOT_VALID(pcb->rt->hook)) { 2477107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2478107120Sjulian error = ENETDOWN; 2479107120Sjulian goto drop; 2480107120Sjulian } 2481107120Sjulian 2482107120Sjulian /* Check packet size agains outgoing (peer's incoming) MTU) */ 2483107120Sjulian if (m->m_pkthdr.len > pcb->omtu) { 2484107120Sjulian NG_BTSOCKET_L2CAP_ERR( 2485107120Sjulian"%s: Packet too big, len=%d, omtu=%d\n", __func__, m->m_pkthdr.len, pcb->omtu); 2486107120Sjulian 2487107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2488107120Sjulian error = EMSGSIZE; 2489107120Sjulian goto drop; 2490107120Sjulian } 2491107120Sjulian 2492107120Sjulian /* 2493107120Sjulian * First put packet on socket send queue. Then check if we have 2494107120Sjulian * pending timeout. If we do not have timeout then we must send 2495107120Sjulian * packet and schedule timeout. Otherwise do nothing and wait for 2496107120Sjulian * L2CA_WRITE_RSP. 2497107120Sjulian */ 2498107120Sjulian 2499107120Sjulian sbappendrecord(&pcb->so->so_snd, m); 2500107120Sjulian m = NULL; 2501107120Sjulian 2502107120Sjulian if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2503107120Sjulian error = ng_btsocket_l2cap_send2(pcb); 2504107120Sjulian if (error == 0) 2505107120Sjulian ng_btsocket_l2cap_timeout(pcb); 2506107120Sjulian else 2507107120Sjulian sbdroprecord(&pcb->so->so_snd); /* XXX */ 2508107120Sjulian } 2509107120Sjulian 2510107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2511107120Sjuliandrop: 2512107120Sjulian NG_FREE_M(m); /* checks for != NULL */ 2513107120Sjulian NG_FREE_M(control); 2514107120Sjulian 2515107120Sjulian return (error); 2516107120Sjulian} /* ng_btsocket_l2cap_send */ 2517107120Sjulian 2518107120Sjulian/* 2519107120Sjulian * Send first packet in the socket queue to the L2CAP layer 2520107120Sjulian */ 2521107120Sjulian 2522107120Sjulianstatic int 2523107120Sjulianng_btsocket_l2cap_send2(ng_btsocket_l2cap_pcb_p pcb) 2524107120Sjulian{ 2525107120Sjulian struct mbuf *m = NULL; 2526107120Sjulian ng_l2cap_l2ca_hdr_t *hdr = NULL; 2527107120Sjulian int error = 0; 2528107120Sjulian 2529107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2530107120Sjulian 2531107120Sjulian if (pcb->so->so_snd.sb_cc == 0) 2532107120Sjulian return (EINVAL); /* XXX */ 2533107120Sjulian 2534111119Simp m = m_dup(pcb->so->so_snd.sb_mb, M_DONTWAIT); 2535107120Sjulian if (m == NULL) 2536107120Sjulian return (ENOBUFS); 2537107120Sjulian 2538107120Sjulian /* Create L2CA packet header */ 2539114878Sjulian M_PREPEND(m, sizeof(*hdr), M_DONTWAIT); 2540107120Sjulian if (m != NULL) 2541107120Sjulian if (m->m_len < sizeof(*hdr)) 2542107120Sjulian m = m_pullup(m, sizeof(*hdr)); 2543107120Sjulian 2544107120Sjulian if (m == NULL) { 2545107120Sjulian NG_BTSOCKET_L2CAP_ERR( 2546107120Sjulian"%s: Failed to create L2CA packet header\n", __func__); 2547107120Sjulian 2548107120Sjulian return (ENOBUFS); 2549107120Sjulian } 2550107120Sjulian 2551107120Sjulian hdr = mtod(m, ng_l2cap_l2ca_hdr_t *); 2552107120Sjulian hdr->token = pcb->token; 2553107120Sjulian hdr->length = m->m_pkthdr.len - sizeof(*hdr); 2554107120Sjulian hdr->lcid = pcb->cid; 2555107120Sjulian 2556107120Sjulian NG_BTSOCKET_L2CAP_INFO( 2557107120Sjulian"%s: Sending packet: len=%d, length=%d, lcid=%d, token=%d, state=%d\n", 2558107120Sjulian __func__, m->m_pkthdr.len, hdr->length, hdr->lcid, 2559107120Sjulian hdr->token, pcb->state); 2560107120Sjulian 2561107120Sjulian /* 2562107120Sjulian * If we got here than we have successfuly creates new L2CAP 2563107120Sjulian * data packet and now we can send it to the L2CAP layer 2564107120Sjulian */ 2565107120Sjulian 2566107120Sjulian NG_SEND_DATA_ONLY(error, pcb->rt->hook, m); 2567107120Sjulian 2568107120Sjulian return (error); 2569107120Sjulian} /* ng_btsocket_l2cap_send2 */ 2570107120Sjulian 2571107120Sjulian/* 2572107120Sjulian * Get socket address 2573107120Sjulian */ 2574107120Sjulian 2575107120Sjulianint 2576107120Sjulianng_btsocket_l2cap_sockaddr(struct socket *so, struct sockaddr **nam) 2577107120Sjulian{ 2578107120Sjulian ng_btsocket_l2cap_pcb_p pcb = so2l2cap_pcb(so); 2579107120Sjulian struct sockaddr_l2cap sa; 2580107120Sjulian 2581107120Sjulian if (pcb == NULL) 2582107120Sjulian return (EINVAL); 2583107120Sjulian if (ng_btsocket_l2cap_node == NULL) 2584107120Sjulian return (EINVAL); 2585107120Sjulian 2586107120Sjulian bcopy(&pcb->src, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); 2587107120Sjulian sa.l2cap_psm = htole16(pcb->psm); 2588107120Sjulian sa.l2cap_len = sizeof(sa); 2589107120Sjulian sa.l2cap_family = AF_BLUETOOTH; 2590107120Sjulian 2591107120Sjulian *nam = dup_sockaddr((struct sockaddr *) &sa, 0); 2592107120Sjulian 2593107120Sjulian return ((*nam == NULL)? ENOMEM : 0); 2594107120Sjulian} /* ng_btsocket_l2cap_sockaddr */ 2595107120Sjulian 2596107120Sjulian/***************************************************************************** 2597107120Sjulian ***************************************************************************** 2598107120Sjulian ** Misc. functions 2599107120Sjulian ***************************************************************************** 2600107120Sjulian *****************************************************************************/ 2601107120Sjulian 2602107120Sjulian/* 2603107120Sjulian * Look for the socket that listens on given PSM and bdaddr. Returns exact or 2604114878Sjulian * close match (if any). Caller must hold ng_btsocket_l2cap_sockets_mtx. 2605107120Sjulian */ 2606107120Sjulian 2607107120Sjulianstatic ng_btsocket_l2cap_pcb_p 2608107120Sjulianng_btsocket_l2cap_pcb_by_addr(bdaddr_p bdaddr, int psm) 2609107120Sjulian{ 2610107120Sjulian ng_btsocket_l2cap_pcb_p p = NULL, p1 = NULL; 2611107120Sjulian 2612114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2613107120Sjulian 2614107120Sjulian LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) { 2615107120Sjulian if (p->so == NULL || !(p->so->so_options & SO_ACCEPTCONN) || 2616107120Sjulian p->psm != psm) 2617107120Sjulian continue; 2618107120Sjulian 2619107120Sjulian if (bcmp(&p->src, bdaddr, sizeof(p->src)) == 0) 2620107120Sjulian break; 2621107120Sjulian 2622107120Sjulian if (bcmp(&p->src, NG_HCI_BDADDR_ANY, sizeof(p->src)) == 0) 2623107120Sjulian p1 = p; 2624107120Sjulian } 2625107120Sjulian 2626107120Sjulian return ((p != NULL)? p : p1); 2627107120Sjulian} /* ng_btsocket_l2cap_pcb_by_addr */ 2628107120Sjulian 2629107120Sjulian/* 2630114878Sjulian * Look for the socket that has given token. 2631114878Sjulian * Caller must hold ng_btsocket_l2cap_sockets_mtx. 2632107120Sjulian */ 2633107120Sjulian 2634107120Sjulianstatic ng_btsocket_l2cap_pcb_p 2635107120Sjulianng_btsocket_l2cap_pcb_by_token(u_int32_t token) 2636107120Sjulian{ 2637107120Sjulian ng_btsocket_l2cap_pcb_p p = NULL; 2638107120Sjulian 2639114878Sjulian if (token == 0) 2640114878Sjulian return (NULL); 2641107120Sjulian 2642114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2643107120Sjulian 2644114878Sjulian LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2645114878Sjulian if (p->token == token) 2646114878Sjulian break; 2647107120Sjulian 2648107120Sjulian return (p); 2649107120Sjulian} /* ng_btsocket_l2cap_pcb_by_token */ 2650107120Sjulian 2651107120Sjulian/* 2652114878Sjulian * Look for the socket that assigned to given source address and channel ID. 2653114878Sjulian * Caller must hold ng_btsocket_l2cap_sockets_mtx 2654107120Sjulian */ 2655107120Sjulian 2656107120Sjulianstatic ng_btsocket_l2cap_pcb_p 2657107120Sjulianng_btsocket_l2cap_pcb_by_cid(bdaddr_p src, int cid) 2658107120Sjulian{ 2659107120Sjulian ng_btsocket_l2cap_pcb_p p = NULL; 2660107120Sjulian 2661114878Sjulian mtx_assert(&ng_btsocket_l2cap_sockets_mtx, MA_OWNED); 2662107120Sjulian 2663107120Sjulian LIST_FOREACH(p, &ng_btsocket_l2cap_sockets, next) 2664107120Sjulian if (p->cid == cid && bcmp(src, &p->src, sizeof(p->src)) == 0) 2665107120Sjulian break; 2666107120Sjulian 2667107120Sjulian return (p); 2668107120Sjulian} /* ng_btsocket_l2cap_pcb_by_cid */ 2669107120Sjulian 2670107120Sjulian/* 2671107120Sjulian * Set timeout on socket 2672107120Sjulian */ 2673107120Sjulian 2674107120Sjulianstatic void 2675107120Sjulianng_btsocket_l2cap_timeout(ng_btsocket_l2cap_pcb_p pcb) 2676107120Sjulian{ 2677107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2678107120Sjulian 2679107120Sjulian if (!(pcb->flags & NG_BTSOCKET_L2CAP_TIMO)) { 2680107120Sjulian pcb->flags |= NG_BTSOCKET_L2CAP_TIMO; 2681107120Sjulian pcb->timo = timeout(ng_btsocket_l2cap_process_timeout, pcb, 2682107120Sjulian bluetooth_l2cap_ertx_timeout()); 2683107120Sjulian } else 2684107120Sjulian KASSERT(0, 2685107120Sjulian("%s: Duplicated socket timeout?!\n", __func__)); 2686107120Sjulian} /* ng_btsocket_l2cap_timeout */ 2687107120Sjulian 2688107120Sjulian/* 2689107120Sjulian * Unset timeout on socket 2690107120Sjulian */ 2691107120Sjulian 2692107120Sjulianstatic void 2693107120Sjulianng_btsocket_l2cap_untimeout(ng_btsocket_l2cap_pcb_p pcb) 2694107120Sjulian{ 2695107120Sjulian mtx_assert(&pcb->pcb_mtx, MA_OWNED); 2696107120Sjulian 2697107120Sjulian if (pcb->flags & NG_BTSOCKET_L2CAP_TIMO) { 2698107120Sjulian untimeout(ng_btsocket_l2cap_process_timeout, pcb, pcb->timo); 2699107120Sjulian pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2700107120Sjulian } else 2701107120Sjulian KASSERT(0, 2702107120Sjulian("%s: No socket timeout?!\n", __func__)); 2703107120Sjulian} /* ng_btsocket_l2cap_untimeout */ 2704107120Sjulian 2705107120Sjulian/* 2706107120Sjulian * Process timeout on socket 2707107120Sjulian */ 2708107120Sjulian 2709107120Sjulianstatic void 2710107120Sjulianng_btsocket_l2cap_process_timeout(void *xpcb) 2711107120Sjulian{ 2712114878Sjulian ng_btsocket_l2cap_pcb_p pcb = (ng_btsocket_l2cap_pcb_p) xpcb; 2713114878Sjulian struct socket *so = NULL; 2714107120Sjulian 2715107120Sjulian mtx_lock(&pcb->pcb_mtx); 2716107120Sjulian 2717107120Sjulian pcb->flags &= ~NG_BTSOCKET_L2CAP_TIMO; 2718107120Sjulian pcb->so->so_error = ETIMEDOUT; 2719107120Sjulian 2720107120Sjulian switch (pcb->state) { 2721107120Sjulian case NG_BTSOCKET_L2CAP_CONNECTING: 2722107120Sjulian case NG_BTSOCKET_L2CAP_CONFIGURING: 2723107120Sjulian /* Send disconnect request with "zero" token */ 2724107120Sjulian if (pcb->cid != 0) 2725107120Sjulian ng_btsocket_l2cap_send_l2ca_discon_req(0, pcb); 2726107120Sjulian 2727107120Sjulian /* ... and close the socket */ 2728107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2729107120Sjulian soisdisconnected(pcb->so); 2730114878Sjulian 2731114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 2732114878Sjulian so = pcb->so; 2733107120Sjulian break; 2734107120Sjulian 2735107120Sjulian case NG_BTSOCKET_L2CAP_OPEN: 2736107120Sjulian /* Send timeout - drop packet and wakeup sender */ 2737107120Sjulian sbdroprecord(&pcb->so->so_snd); 2738107120Sjulian sowwakeup(pcb->so); 2739107120Sjulian break; 2740107120Sjulian 2741107120Sjulian case NG_BTSOCKET_L2CAP_DISCONNECTING: 2742107120Sjulian /* Disconnect timeout - disconnect the socket anyway */ 2743107120Sjulian pcb->state = NG_BTSOCKET_L2CAP_CLOSED; 2744107120Sjulian soisdisconnected(pcb->so); 2745114878Sjulian 2746114878Sjulian if (pcb->so->so_state & SS_NOFDREF) 2747114878Sjulian so = pcb->so; 2748107120Sjulian break; 2749107120Sjulian 2750107120Sjulian default: 2751107120Sjulian NG_BTSOCKET_L2CAP_ERR( 2752107120Sjulian"%s: Invalid socket state=%d\n", __func__, pcb->state); 2753107120Sjulian break; 2754107120Sjulian } 2755107120Sjulian 2756107120Sjulian mtx_unlock(&pcb->pcb_mtx); 2757114878Sjulian 2758114878Sjulian if (so != NULL) 2759114878Sjulian ng_btsocket_l2cap_detach(so); 2760107120Sjulian} /* ng_btsocket_l2cap_process_timeout */ 2761107120Sjulian 2762107120Sjulian/* 2763107120Sjulian * Translate HCI/L2CAP error code into "errno" code 2764107120Sjulian * XXX Note: Some L2CAP and HCI error codes have the same value, but 2765107120Sjulian * different meaning 2766107120Sjulian */ 2767107120Sjulian 2768107120Sjulianstatic int 2769107120Sjulianng_btsocket_l2cap_result2errno(int result) 2770107120Sjulian{ 2771107120Sjulian switch (result) { 2772107120Sjulian case 0x00: /* No error */ 2773107120Sjulian return (0); 2774107120Sjulian 2775107120Sjulian case 0x01: /* Unknown HCI command */ 2776107120Sjulian return (ENODEV); 2777107120Sjulian 2778107120Sjulian case 0x02: /* No connection */ 2779107120Sjulian return (ENOTCONN); 2780107120Sjulian 2781107120Sjulian case 0x03: /* Hardware failure */ 2782107120Sjulian return (EIO); 2783107120Sjulian 2784107120Sjulian case 0x04: /* Page timeout */ 2785107120Sjulian return (EHOSTDOWN); 2786107120Sjulian 2787107120Sjulian case 0x05: /* Authentication failure */ 2788107120Sjulian case 0x06: /* Key missing */ 2789107120Sjulian case 0x18: /* Pairing not allowed */ 2790107120Sjulian case 0x21: /* Role change not allowed */ 2791107120Sjulian case 0x24: /* LMP PSU not allowed */ 2792107120Sjulian case 0x25: /* Encryption mode not acceptable */ 2793107120Sjulian case 0x26: /* Unit key used */ 2794107120Sjulian return (EACCES); 2795107120Sjulian 2796107120Sjulian case 0x07: /* Memory full */ 2797107120Sjulian return (ENOMEM); 2798107120Sjulian 2799107120Sjulian case 0x08: /* Connection timeout */ 2800107120Sjulian case 0x10: /* Host timeout */ 2801107120Sjulian case 0x22: /* LMP response timeout */ 2802107120Sjulian case 0xee: /* HCI timeout */ 2803107120Sjulian case 0xeeee: /* L2CAP timeout */ 2804107120Sjulian return (ETIMEDOUT); 2805107120Sjulian 2806107120Sjulian case 0x09: /* Max number of connections */ 2807107120Sjulian case 0x0a: /* Max number of SCO connections to a unit */ 2808107120Sjulian return (EMLINK); 2809107120Sjulian 2810107120Sjulian case 0x0b: /* ACL connection already exists */ 2811107120Sjulian return (EEXIST); 2812107120Sjulian 2813107120Sjulian case 0x0c: /* Command disallowed */ 2814107120Sjulian return (EBUSY); 2815107120Sjulian 2816107120Sjulian case 0x0d: /* Host rejected due to limited resources */ 2817107120Sjulian case 0x0e: /* Host rejected due to securiity reasons */ 2818107120Sjulian case 0x0f: /* Host rejected due to remote unit is a personal unit */ 2819107120Sjulian case 0x1b: /* SCO offset rejected */ 2820107120Sjulian case 0x1c: /* SCO interval rejected */ 2821107120Sjulian case 0x1d: /* SCO air mode rejected */ 2822107120Sjulian return (ECONNREFUSED); 2823107120Sjulian 2824107120Sjulian case 0x11: /* Unsupported feature or parameter value */ 2825107120Sjulian case 0x19: /* Unknown LMP PDU */ 2826107120Sjulian case 0x1a: /* Unsupported remote feature */ 2827107120Sjulian case 0x20: /* Unsupported LMP parameter value */ 2828107120Sjulian case 0x27: /* QoS is not supported */ 2829107120Sjulian case 0x29: /* Paring with unit key not supported */ 2830107120Sjulian return (EOPNOTSUPP); 2831107120Sjulian 2832107120Sjulian case 0x12: /* Invalid HCI command parameter */ 2833107120Sjulian case 0x1e: /* Invalid LMP parameters */ 2834107120Sjulian return (EINVAL); 2835107120Sjulian 2836107120Sjulian case 0x13: /* Other end terminated connection: User ended connection */ 2837107120Sjulian case 0x14: /* Other end terminated connection: Low resources */ 2838107120Sjulian case 0x15: /* Other end terminated connection: About to power off */ 2839107120Sjulian return (ECONNRESET); 2840107120Sjulian 2841107120Sjulian case 0x16: /* Connection terminated by local host */ 2842107120Sjulian return (ECONNABORTED); 2843107120Sjulian 2844107120Sjulian#if 0 /* XXX not yet */ 2845107120Sjulian case 0x17: /* Repeated attempts */ 2846107120Sjulian case 0x1f: /* Unspecified error */ 2847107120Sjulian case 0x23: /* LMP error transaction collision */ 2848107120Sjulian case 0x28: /* Instant passed */ 2849107120Sjulian#endif 2850107120Sjulian } 2851107120Sjulian 2852107120Sjulian return (ENOSYS); 2853107120Sjulian} /* ng_btsocket_l2cap_result2errno */ 2854107120Sjulian 2855