/* * ng_btsocket_l2cap_raw.c */ /*- * Copyright (c) 2001-2002 Maksim Yevmenkin * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * * $Id: ng_btsocket_l2cap_raw.c,v 1.12 2003/09/14 23:29:06 max Exp $ * $FreeBSD: src/sys/netgraph/bluetooth/socket/ng_btsocket_l2cap_raw.c,v 1.20 2006/11/06 13:42:04 rwatson Exp $ */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include /* MALLOC define */ #ifdef NG_SEPARATE_MALLOC MALLOC_DEFINE(M_NETGRAPH_BTSOCKET_L2CAP_RAW, "netgraph_btsocks_l2cap_raw", "Netgraph Bluetooth raw L2CAP sockets"); #else #define M_NETGRAPH_BTSOCKET_L2CAP_RAW M_NETGRAPH #endif /* NG_SEPARATE_MALLOC */ /* Netgraph node methods */ static ng_constructor_t ng_btsocket_l2cap_raw_node_constructor; static ng_rcvmsg_t ng_btsocket_l2cap_raw_node_rcvmsg; static ng_shutdown_t ng_btsocket_l2cap_raw_node_shutdown; static ng_newhook_t ng_btsocket_l2cap_raw_node_newhook; static ng_connect_t ng_btsocket_l2cap_raw_node_connect; static ng_rcvdata_t ng_btsocket_l2cap_raw_node_rcvdata; static ng_disconnect_t ng_btsocket_l2cap_raw_node_disconnect; static void ng_btsocket_l2cap_raw_input (void *, int); static void ng_btsocket_l2cap_raw_rtclean (void *, int); static void ng_btsocket_l2cap_raw_get_token (u_int32_t *); static int ng_btsocket_l2cap_raw_send_ngmsg (hook_p, int, void *, int); static int ng_btsocket_l2cap_raw_send_sync_ngmsg (ng_btsocket_l2cap_raw_pcb_p, int, void *, int); #define ng_btsocket_l2cap_raw_wakeup_input_task() \ taskqueue_enqueue(taskqueue_swi, &ng_btsocket_l2cap_raw_queue_task) #define ng_btsocket_l2cap_raw_wakeup_route_task() \ taskqueue_enqueue(taskqueue_swi, &ng_btsocket_l2cap_raw_rt_task) /* Netgraph type descriptor */ static struct ng_type typestruct = { .version = NG_ABI_VERSION, .name = NG_BTSOCKET_L2CAP_RAW_NODE_TYPE, .constructor = ng_btsocket_l2cap_raw_node_constructor, .rcvmsg = ng_btsocket_l2cap_raw_node_rcvmsg, .shutdown = ng_btsocket_l2cap_raw_node_shutdown, .newhook = ng_btsocket_l2cap_raw_node_newhook, .connect = ng_btsocket_l2cap_raw_node_connect, .rcvdata = ng_btsocket_l2cap_raw_node_rcvdata, .disconnect = ng_btsocket_l2cap_raw_node_disconnect, }; /* Globals */ extern int ifqmaxlen; static u_int32_t ng_btsocket_l2cap_raw_debug_level; static u_int32_t ng_btsocket_l2cap_raw_ioctl_timeout; static node_p ng_btsocket_l2cap_raw_node; static struct ng_bt_itemq ng_btsocket_l2cap_raw_queue; static struct lock ng_btsocket_l2cap_raw_queue_lock; static struct task ng_btsocket_l2cap_raw_queue_task; static LIST_HEAD(, ng_btsocket_l2cap_raw_pcb) ng_btsocket_l2cap_raw_sockets; static struct lock ng_btsocket_l2cap_raw_sockets_lock; static u_int32_t ng_btsocket_l2cap_raw_token; static struct lock ng_btsocket_l2cap_raw_token_lock; static LIST_HEAD(, ng_btsocket_l2cap_rtentry) ng_btsocket_l2cap_raw_rt; static struct lock ng_btsocket_l2cap_raw_rt_lock; static struct task ng_btsocket_l2cap_raw_rt_task; /* Sysctl tree */ SYSCTL_DECL(_net_bluetooth_l2cap_sockets); SYSCTL_NODE(_net_bluetooth_l2cap_sockets, OID_AUTO, raw, CTLFLAG_RW, 0, "Bluetooth raw L2CAP sockets family"); SYSCTL_INT(_net_bluetooth_l2cap_sockets_raw, OID_AUTO, debug_level, CTLFLAG_RW, &ng_btsocket_l2cap_raw_debug_level, NG_BTSOCKET_WARN_LEVEL, "Bluetooth raw L2CAP sockets debug level"); SYSCTL_INT(_net_bluetooth_l2cap_sockets_raw, OID_AUTO, ioctl_timeout, CTLFLAG_RW, &ng_btsocket_l2cap_raw_ioctl_timeout, 5, "Bluetooth raw L2CAP sockets ioctl timeout"); SYSCTL_INT(_net_bluetooth_l2cap_sockets_raw, OID_AUTO, queue_len, CTLFLAG_RD, &ng_btsocket_l2cap_raw_queue.len, 0, "Bluetooth raw L2CAP sockets input queue length"); SYSCTL_INT(_net_bluetooth_l2cap_sockets_raw, OID_AUTO, queue_maxlen, CTLFLAG_RD, &ng_btsocket_l2cap_raw_queue.maxlen, 0, "Bluetooth raw L2CAP sockets input queue max. length"); SYSCTL_INT(_net_bluetooth_l2cap_sockets_raw, OID_AUTO, queue_drops, CTLFLAG_RD, &ng_btsocket_l2cap_raw_queue.drops, 0, "Bluetooth raw L2CAP sockets input queue drops"); /* Debug */ #define NG_BTSOCKET_L2CAP_RAW_INFO \ if (ng_btsocket_l2cap_raw_debug_level >= NG_BTSOCKET_INFO_LEVEL) \ kprintf #define NG_BTSOCKET_L2CAP_RAW_WARN \ if (ng_btsocket_l2cap_raw_debug_level >= NG_BTSOCKET_WARN_LEVEL) \ kprintf #define NG_BTSOCKET_L2CAP_RAW_ERR \ if (ng_btsocket_l2cap_raw_debug_level >= NG_BTSOCKET_ERR_LEVEL) \ kprintf #define NG_BTSOCKET_L2CAP_RAW_ALERT \ if (ng_btsocket_l2cap_raw_debug_level >= NG_BTSOCKET_ALERT_LEVEL) \ kprintf /***************************************************************************** ***************************************************************************** ** Netgraph node interface ***************************************************************************** *****************************************************************************/ /* * Netgraph node constructor. Do not allow to create node of this type. */ static int ng_btsocket_l2cap_raw_node_constructor(node_p node) { return (EINVAL); } /* ng_btsocket_l2cap_raw_node_constructor */ /* * Do local shutdown processing. Let old node go and create new fresh one. */ static int ng_btsocket_l2cap_raw_node_shutdown(node_p node) { int error = 0; NG_NODE_UNREF(node); /* Create new node */ error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_raw_node); if (error != 0) { NG_BTSOCKET_L2CAP_RAW_ALERT( "%s: Could not create Netgraph node, error=%d\n", __func__, error); ng_btsocket_l2cap_raw_node = NULL; return (error); } error = ng_name_node(ng_btsocket_l2cap_raw_node, NG_BTSOCKET_L2CAP_RAW_NODE_TYPE); if (error != 0) { NG_BTSOCKET_L2CAP_RAW_ALERT( "%s: Could not name Netgraph node, error=%d\n", __func__, error); NG_NODE_UNREF(ng_btsocket_l2cap_raw_node); ng_btsocket_l2cap_raw_node = NULL; return (error); } return (0); } /* ng_btsocket_l2cap_raw_node_shutdown */ /* * We allow any hook to be connected to the node. */ static int ng_btsocket_l2cap_raw_node_newhook(node_p node, hook_p hook, char const *name) { return (0); } /* ng_btsocket_l2cap_raw_node_newhook */ /* * Just say "YEP, that's OK by me!" */ static int ng_btsocket_l2cap_raw_node_connect(hook_p hook) { NG_HOOK_SET_PRIVATE(hook, NULL); NG_HOOK_REF(hook); /* Keep extra reference to the hook */ return (0); } /* ng_btsocket_l2cap_raw_node_connect */ /* * Hook disconnection. Schedule route cleanup task */ static int ng_btsocket_l2cap_raw_node_disconnect(hook_p hook) { /* * If hook has private information than we must have this hook in * the routing table and must schedule cleaning for the routing table. * Otherwise hook was connected but we never got "hook_info" message, * so we have never added this hook to the routing table and it save * to just delete it. */ if (NG_HOOK_PRIVATE(hook) != NULL) return (ng_btsocket_l2cap_raw_wakeup_route_task()); NG_HOOK_UNREF(hook); /* Remove extra reference */ return (0); } /* ng_btsocket_l2cap_raw_node_disconnect */ /* * Process incoming messages */ static int ng_btsocket_l2cap_raw_node_rcvmsg(node_p node, item_p item, hook_p hook) { struct ng_mesg *msg = NGI_MSG(item); /* item still has message */ int error = 0; if (msg != NULL && msg->header.typecookie == NGM_L2CAP_COOKIE) { /* * NGM_L2CAP_NODE_HOOK_INFO is special message initiated by * L2CAP layer. Ignore all other messages if they are not * replies or token is zero */ if (msg->header.cmd != NGM_L2CAP_NODE_HOOK_INFO) { if (msg->header.token == 0 || !(msg->header.flags & NGF_RESP)) { NG_FREE_ITEM(item); return (0); } } lockmgr(&ng_btsocket_l2cap_raw_queue_lock, LK_EXCLUSIVE); if (NG_BT_ITEMQ_FULL(&ng_btsocket_l2cap_raw_queue)) { NG_BTSOCKET_L2CAP_RAW_ERR( "%s: Input queue is full\n", __func__); NG_BT_ITEMQ_DROP(&ng_btsocket_l2cap_raw_queue); NG_FREE_ITEM(item); error = ENOBUFS; } else { if (hook != NULL) { NG_HOOK_REF(hook); NGI_SET_HOOK(item, hook); } ng_ref_item(item); NG_BT_ITEMQ_ENQUEUE(&ng_btsocket_l2cap_raw_queue, item); error = ng_btsocket_l2cap_raw_wakeup_input_task(); } lockmgr(&ng_btsocket_l2cap_raw_queue_lock, LK_RELEASE); } else { NG_FREE_ITEM(item); error = EINVAL; } return (error); } /* ng_btsocket_l2cap_raw_node_rcvmsg */ /* * Receive data on a hook */ static int ng_btsocket_l2cap_raw_node_rcvdata(hook_p hook, item_p item) { NG_FREE_ITEM(item); return (EINVAL); } /* ng_btsocket_l2cap_raw_node_rcvdata */ /***************************************************************************** ***************************************************************************** ** Socket interface ***************************************************************************** *****************************************************************************/ /* * L2CAP sockets input routine */ static void ng_btsocket_l2cap_raw_input(void *context, int pending) { item_p item = NULL; hook_p hook = NULL; struct ng_mesg *msg = NULL; for (;;) { lockmgr(&ng_btsocket_l2cap_raw_queue_lock, LK_EXCLUSIVE); NG_BT_ITEMQ_DEQUEUE(&ng_btsocket_l2cap_raw_queue, item); lockmgr(&ng_btsocket_l2cap_raw_queue_lock, LK_RELEASE); if (item == NULL) break; KASSERT((item->el_flags & NGQF_TYPE) == NGQF_MESG, ("%s: invalid item type=%ld\n", __func__, (item->el_flags & NGQF_TYPE))); NGI_GET_MSG(item, msg); NGI_GET_HOOK(item, hook); NG_FREE_ITEM(item); ng_unref_item(item, 0); switch (msg->header.cmd) { case NGM_L2CAP_NODE_HOOK_INFO: { ng_btsocket_l2cap_rtentry_t *rt = NULL; if (hook == NULL || NG_HOOK_NOT_VALID(hook) || msg->header.arglen != sizeof(bdaddr_t)) break; if (bcmp(msg->data, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) break; rt = (ng_btsocket_l2cap_rtentry_t *) NG_HOOK_PRIVATE(hook); if (rt == NULL) { rt = kmalloc(sizeof(*rt), M_NETGRAPH_BTSOCKET_L2CAP_RAW, M_WAITOK | M_NULLOK | M_ZERO); if (rt == NULL) break; NG_HOOK_SET_PRIVATE(hook, rt); lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_EXCLUSIVE); LIST_INSERT_HEAD(&ng_btsocket_l2cap_raw_rt, rt, next); } else lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_EXCLUSIVE); bcopy(msg->data, &rt->src, sizeof(rt->src)); rt->hook = hook; NG_BTSOCKET_L2CAP_RAW_INFO( "%s: Updating hook \"%s\", src bdaddr=%x:%x:%x:%x:%x:%x\n", __func__, NG_HOOK_NAME(hook), rt->src.b[5], rt->src.b[4], rt->src.b[3], rt->src.b[2], rt->src.b[1], rt->src.b[0]); lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_RELEASE); } break; case NGM_L2CAP_NODE_GET_FLAGS: case NGM_L2CAP_NODE_GET_DEBUG: case NGM_L2CAP_NODE_GET_CON_LIST: case NGM_L2CAP_NODE_GET_CHAN_LIST: case NGM_L2CAP_NODE_GET_AUTO_DISCON_TIMO: case NGM_L2CAP_L2CA_PING: case NGM_L2CAP_L2CA_GET_INFO: { ng_btsocket_l2cap_raw_pcb_p pcb = NULL; lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_EXCLUSIVE); LIST_FOREACH(pcb,&ng_btsocket_l2cap_raw_sockets,next) { lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); if (pcb->token == msg->header.token) { pcb->msg = msg; msg = NULL; wakeup(&pcb->msg); lockmgr(&pcb->pcb_lock, LK_RELEASE); break; } lockmgr(&pcb->pcb_lock, LK_RELEASE); } lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_RELEASE); } break; default: NG_BTSOCKET_L2CAP_RAW_WARN( "%s: Unknown message, cmd=%d\n", __func__, msg->header.cmd); break; } if (hook != NULL) NG_HOOK_UNREF(hook); /* remove extra reference */ NG_FREE_MSG(msg); /* Checks for msg != NULL */ } } /* ng_btsocket_l2cap_raw_input */ /* * Route cleanup task. Gets scheduled when hook is disconnected. Here we * will find all sockets that use "invalid" hook and disconnect them. */ static void ng_btsocket_l2cap_raw_rtclean(void *context, int pending) { ng_btsocket_l2cap_raw_pcb_p pcb = NULL; ng_btsocket_l2cap_rtentry_p rt = NULL; /* * First disconnect all sockets that use "invalid" hook */ lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_EXCLUSIVE); LIST_FOREACH(pcb, &ng_btsocket_l2cap_raw_sockets, next) { lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); if (pcb->rt != NULL && pcb->rt->hook != NULL && NG_HOOK_NOT_VALID(pcb->rt->hook)) { if (pcb->so != NULL && pcb->so->so_state & SS_ISCONNECTED) soisdisconnected(pcb->so); pcb->rt = NULL; } lockmgr(&pcb->pcb_lock, LK_RELEASE); } lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_RELEASE); /* * Now cleanup routing table */ lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_EXCLUSIVE); for (rt = LIST_FIRST(&ng_btsocket_l2cap_raw_rt); rt != NULL; ) { ng_btsocket_l2cap_rtentry_p rt_next = LIST_NEXT(rt, next); if (rt->hook != NULL && NG_HOOK_NOT_VALID(rt->hook)) { LIST_REMOVE(rt, next); NG_HOOK_SET_PRIVATE(rt->hook, NULL); NG_HOOK_UNREF(rt->hook); /* Remove extra reference */ bzero(rt, sizeof(*rt)); kfree(rt, M_NETGRAPH_BTSOCKET_L2CAP_RAW); } rt = rt_next; } lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_RELEASE); } /* ng_btsocket_l2cap_raw_rtclean */ /* * Initialize everything */ void ng_btsocket_l2cap_raw_init(void) { int error = 0; ng_btsocket_l2cap_raw_node = NULL; ng_btsocket_l2cap_raw_debug_level = NG_BTSOCKET_WARN_LEVEL; ng_btsocket_l2cap_raw_ioctl_timeout = 5; /* Register Netgraph node type */ error = ng_newtype(&typestruct); if (error != 0) { NG_BTSOCKET_L2CAP_RAW_ALERT( "%s: Could not register Netgraph node type, error=%d\n", __func__, error); return; } /* Create Netgrapg node */ error = ng_make_node_common(&typestruct, &ng_btsocket_l2cap_raw_node); if (error != 0) { NG_BTSOCKET_L2CAP_RAW_ALERT( "%s: Could not create Netgraph node, error=%d\n", __func__, error); ng_btsocket_l2cap_raw_node = NULL; return; } error = ng_name_node(ng_btsocket_l2cap_raw_node, NG_BTSOCKET_L2CAP_RAW_NODE_TYPE); if (error != 0) { NG_BTSOCKET_L2CAP_RAW_ALERT( "%s: Could not name Netgraph node, error=%d\n", __func__, error); NG_NODE_UNREF(ng_btsocket_l2cap_raw_node); ng_btsocket_l2cap_raw_node = NULL; return; } /* Create input queue */ NG_BT_ITEMQ_INIT(&ng_btsocket_l2cap_raw_queue, ifqmaxlen); lockinit(&ng_btsocket_l2cap_raw_queue_lock, "btsocks_l2cap_raw_queue_lock", 0, 0); TASK_INIT(&ng_btsocket_l2cap_raw_queue_task, 0, ng_btsocket_l2cap_raw_input, NULL); /* Create list of sockets */ LIST_INIT(&ng_btsocket_l2cap_raw_sockets); lockinit(&ng_btsocket_l2cap_raw_sockets_lock, "btsocks_l2cap_raw_sockets_lock", 0, 0); /* Tokens */ ng_btsocket_l2cap_raw_token = 0; lockinit(&ng_btsocket_l2cap_raw_token_lock, "btsocks_l2cap_raw_token_lock", 0, 0); /* Routing table */ LIST_INIT(&ng_btsocket_l2cap_raw_rt); lockinit(&ng_btsocket_l2cap_raw_rt_lock, "btsocks_l2cap_raw_rt_lock", 0, 0); TASK_INIT(&ng_btsocket_l2cap_raw_rt_task, 0, ng_btsocket_l2cap_raw_rtclean, NULL); } /* ng_btsocket_l2cap_raw_init */ /* * Abort connection on socket */ void ng_btsocket_l2cap_raw_abort(netmsg_t msg) { (void)ng_btsocket_l2cap_raw_disconnect(msg); } /* ng_btsocket_l2cap_raw_abort */ #if 0 /* XXX */ void ng_btsocket_l2cap_raw_close(struct socket *so) { (void)ng_btsocket_l2cap_raw_disconnect(so); } /* ng_btsocket_l2cap_raw_close */ #endif /* * Create and attach new socket */ void ng_btsocket_l2cap_raw_attach(netmsg_t msg) { struct socket *so = msg->attach.base.nm_so; ng_btsocket_l2cap_raw_pcb_p pcb = so2l2cap_raw_pcb(so); int error = 0; if (pcb != NULL) { error = EISCONN; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EPROTONOSUPPORT; goto out; } if (so->so_type != SOCK_RAW) { error = ESOCKTNOSUPPORT; goto out; } /* Reserve send and receive space if it is not reserved yet */ error = soreserve(so, NG_BTSOCKET_L2CAP_RAW_SENDSPACE, NG_BTSOCKET_L2CAP_RAW_RECVSPACE, NULL); if (error != 0) goto out; /* Allocate the PCB */ pcb = kmalloc(sizeof(*pcb), M_NETGRAPH_BTSOCKET_L2CAP_RAW, M_WAITOK | M_NULLOK | M_ZERO); if (pcb == NULL) { error = ENOMEM; goto out; } /* Link the PCB and the socket */ so->so_pcb = (caddr_t) pcb; pcb->so = so; if (curproc == NULL || caps_priv_check_self(SYSCAP_NONET_BT_RAW) == 0) { pcb->flags |= NG_BTSOCKET_L2CAP_RAW_PRIVILEGED; } lockinit(&pcb->pcb_lock, "btsocks_l2cap_raw_pcb_lock", 0, 0); /* Add the PCB to the list */ lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_EXCLUSIVE); LIST_INSERT_HEAD(&ng_btsocket_l2cap_raw_sockets, pcb, next); lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_RELEASE); out: lwkt_replymsg(&msg->attach.base.lmsg, error); } /* ng_btsocket_l2cap_raw_attach */ /* * Bind socket */ void ng_btsocket_l2cap_raw_bind(netmsg_t msg) { struct socket *so = msg->bind.base.nm_so; struct sockaddr *nam = msg->bind.nm_nam; ng_btsocket_l2cap_raw_pcb_t *pcb = so2l2cap_raw_pcb(so); struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; ng_btsocket_l2cap_rtentry_t *rt = NULL; int error = 0; if (pcb == NULL) { error = EINVAL; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EINVAL; goto out; } if (sa == NULL) { error = EINVAL; goto out; } if (sa->l2cap_family != AF_BLUETOOTH) { error = EAFNOSUPPORT; goto out; } if (sa->l2cap_len != sizeof(*sa)) { error = EINVAL; goto out; } if (bcmp(&sa->l2cap_bdaddr, NG_HCI_BDADDR_ANY, sizeof(sa->l2cap_bdaddr)) != 0) { lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_EXCLUSIVE); LIST_FOREACH(rt, &ng_btsocket_l2cap_raw_rt, next) { if (rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) continue; if (bcmp(&sa->l2cap_bdaddr, &rt->src, sizeof(rt->src)) == 0) break; } lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_RELEASE); if (rt == NULL) { error = ENETDOWN; goto out; } } else rt = NULL; lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); bcopy(&sa->l2cap_bdaddr, &pcb->src, sizeof(pcb->src)); pcb->rt = rt; lockmgr(&pcb->pcb_lock, LK_RELEASE); out: lwkt_replymsg(&msg->bind.base.lmsg, error); } /* ng_btsocket_l2cap_raw_bind */ /* * Connect socket */ void ng_btsocket_l2cap_raw_connect(netmsg_t msg) { struct socket *so = msg->connect.base.nm_so; struct sockaddr *nam = msg->connect.nm_nam; ng_btsocket_l2cap_raw_pcb_t *pcb = so2l2cap_raw_pcb(so); struct sockaddr_l2cap *sa = (struct sockaddr_l2cap *) nam; ng_btsocket_l2cap_rtentry_t *rt = NULL; int error = 0; if (pcb == NULL) { error = EINVAL; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EINVAL; goto out; } if (sa == NULL) { error = EINVAL; goto out; } if (sa->l2cap_family != AF_BLUETOOTH) { error = EAFNOSUPPORT; goto out; } if (sa->l2cap_len != sizeof(*sa)) { error = EINVAL; goto out; } if (bcmp(&sa->l2cap_bdaddr, NG_HCI_BDADDR_ANY, sizeof(bdaddr_t)) == 0) { error = EINVAL; goto out; } lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); bcopy(&sa->l2cap_bdaddr, &pcb->dst, sizeof(pcb->dst)); if (bcmp(&pcb->src, &pcb->dst, sizeof(pcb->src)) == 0) { lockmgr(&pcb->pcb_lock, LK_RELEASE); error = EADDRNOTAVAIL; goto out; } /* * If there is route already - use it */ if (pcb->rt != NULL) { soisconnected(so); lockmgr(&pcb->pcb_lock, LK_RELEASE); goto out; } /* * Find the first hook that does not match specified destination address */ lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_EXCLUSIVE); LIST_FOREACH(rt, &ng_btsocket_l2cap_raw_rt, next) { if (rt->hook == NULL || NG_HOOK_NOT_VALID(rt->hook)) continue; if (bcmp(&pcb->dst, &rt->src, sizeof(rt->src)) != 0) break; } if (rt != NULL) { soisconnected(so); pcb->rt = rt; bcopy(&rt->src, &pcb->src, sizeof(pcb->src)); } else error = ENETDOWN; lockmgr(&ng_btsocket_l2cap_raw_rt_lock, LK_RELEASE); lockmgr(&pcb->pcb_lock, LK_RELEASE); out: lwkt_replymsg(&msg->connect.base.lmsg, error); } /* ng_btsocket_l2cap_raw_connect */ /* * Process ioctl's calls on socket */ void ng_btsocket_l2cap_raw_control(netmsg_t msg) { struct socket *so = msg->control.base.nm_so; u_long cmd = msg->control.nm_cmd; caddr_t data = msg->control.nm_data; ng_btsocket_l2cap_raw_pcb_p pcb = so2l2cap_raw_pcb(so); struct ng_mesg *ngmsg = NULL; int error = 0; if (pcb == NULL) { error = EINVAL; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EINVAL; goto out; } lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); /* Check if we route info */ if (pcb->rt == NULL) { lockmgr(&pcb->pcb_lock, LK_RELEASE); error = EHOSTUNREACH; goto out; } /* Check if we have pending ioctl() */ if (pcb->token != 0) { lockmgr(&pcb->pcb_lock, LK_RELEASE); error = EBUSY; goto out; } switch (cmd) { case SIOC_L2CAP_NODE_GET_FLAGS: { struct ng_btsocket_l2cap_raw_node_flags *p = (struct ng_btsocket_l2cap_raw_node_flags *) data; error = ng_btsocket_l2cap_raw_send_sync_ngmsg(pcb, NGM_L2CAP_NODE_GET_FLAGS, &p->flags, sizeof(p->flags)); } break; case SIOC_L2CAP_NODE_GET_DEBUG: { struct ng_btsocket_l2cap_raw_node_debug *p = (struct ng_btsocket_l2cap_raw_node_debug *) data; error = ng_btsocket_l2cap_raw_send_sync_ngmsg(pcb, NGM_L2CAP_NODE_GET_DEBUG, &p->debug, sizeof(p->debug)); } break; case SIOC_L2CAP_NODE_SET_DEBUG: { struct ng_btsocket_l2cap_raw_node_debug *p = (struct ng_btsocket_l2cap_raw_node_debug *) data; if (pcb->flags & NG_BTSOCKET_L2CAP_RAW_PRIVILEGED) error = ng_btsocket_l2cap_raw_send_ngmsg(pcb->rt->hook, NGM_L2CAP_NODE_SET_DEBUG, &p->debug, sizeof(p->debug)); else error = EPERM; } break; case SIOC_L2CAP_NODE_GET_CON_LIST: { struct ng_btsocket_l2cap_raw_con_list *p = (struct ng_btsocket_l2cap_raw_con_list *) data; ng_l2cap_node_con_list_ep *p1 = NULL; ng_l2cap_node_con_ep *p2 = NULL; if (p->num_connections == 0 || p->num_connections > NG_L2CAP_MAX_CON_NUM || p->connections == NULL) { error = EINVAL; break; } NG_MKMESSAGE(ngmsg, NGM_L2CAP_COOKIE, NGM_L2CAP_NODE_GET_CON_LIST, 0, M_WAITOK | M_NULLOK); if (ngmsg == NULL) { error = ENOMEM; break; } ng_btsocket_l2cap_raw_get_token(&ngmsg->header.token); pcb->token = ngmsg->header.token; pcb->msg = NULL; NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_raw_node, ngmsg, pcb->rt->hook, 0); if (error != 0) { pcb->token = 0; break; } error = lksleep(&pcb->msg, &pcb->pcb_lock, PCATCH, "l2ctl", ng_btsocket_l2cap_raw_ioctl_timeout * hz); pcb->token = 0; if (error != 0) break; if (pcb->msg != NULL && pcb->msg->header.cmd == NGM_L2CAP_NODE_GET_CON_LIST) { /* Return data back to user space */ p1 = (ng_l2cap_node_con_list_ep *)(pcb->msg->data); p2 = (ng_l2cap_node_con_ep *)(p1 + 1); p->num_connections = min(p->num_connections, p1->num_connections); if (p->num_connections > 0) error = copyout((caddr_t) p2, (caddr_t) p->connections, p->num_connections * sizeof(*p2)); } else error = EINVAL; NG_FREE_MSG(pcb->msg); /* checks for != NULL */ } break; case SIOC_L2CAP_NODE_GET_CHAN_LIST: { struct ng_btsocket_l2cap_raw_chan_list *p = (struct ng_btsocket_l2cap_raw_chan_list *) data; ng_l2cap_node_chan_list_ep *p1 = NULL; ng_l2cap_node_chan_ep *p2 = NULL; if (p->num_channels == 0 || p->num_channels > NG_L2CAP_MAX_CHAN_NUM || p->channels == NULL) { error = EINVAL; break; } NG_MKMESSAGE(ngmsg, NGM_L2CAP_COOKIE, NGM_L2CAP_NODE_GET_CHAN_LIST, 0, M_WAITOK | M_NULLOK); if (ngmsg == NULL) { error = ENOMEM; break; } ng_btsocket_l2cap_raw_get_token(&ngmsg->header.token); pcb->token = ngmsg->header.token; pcb->msg = NULL; NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_raw_node, ngmsg, pcb->rt->hook, 0); if (error != 0) { pcb->token = 0; break; } error = lksleep(&pcb->msg, &pcb->pcb_lock, PCATCH, "l2ctl", ng_btsocket_l2cap_raw_ioctl_timeout * hz); pcb->token = 0; if (error != 0) break; if (pcb->msg != NULL && pcb->msg->header.cmd == NGM_L2CAP_NODE_GET_CHAN_LIST) { /* Return data back to user space */ p1 = (ng_l2cap_node_chan_list_ep *)(pcb->msg->data); p2 = (ng_l2cap_node_chan_ep *)(p1 + 1); p->num_channels = min(p->num_channels, p1->num_channels); if (p->num_channels > 0) error = copyout((caddr_t) p2, (caddr_t) p->channels, p->num_channels * sizeof(*p2)); } else error = EINVAL; NG_FREE_MSG(pcb->msg); /* checks for != NULL */ } break; case SIOC_L2CAP_L2CA_PING: { struct ng_btsocket_l2cap_raw_ping *p = (struct ng_btsocket_l2cap_raw_ping *) data; ng_l2cap_l2ca_ping_ip *ip = NULL; ng_l2cap_l2ca_ping_op *op = NULL; if (!(pcb->flags & NG_BTSOCKET_L2CAP_RAW_PRIVILEGED)) { error = EPERM; break; } if ((p->echo_size != 0 && p->echo_data == NULL) || p->echo_size > NG_L2CAP_MAX_ECHO_SIZE) { error = EINVAL; break; } NG_MKMESSAGE(ngmsg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_PING, sizeof(*ip) + p->echo_size, M_WAITOK | M_NULLOK); if (ngmsg == NULL) { error = ENOMEM; break; } ng_btsocket_l2cap_raw_get_token(&ngmsg->header.token); pcb->token = ngmsg->header.token; pcb->msg = NULL; ip = (ng_l2cap_l2ca_ping_ip *)(ngmsg->data); bcopy(&pcb->dst, &ip->bdaddr, sizeof(ip->bdaddr)); ip->echo_size = p->echo_size; if (ip->echo_size > 0) { error = copyin(p->echo_data, ip + 1, p->echo_size); if (error != 0) { NG_FREE_MSG(ngmsg); pcb->token = 0; break; } } NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_raw_node, ngmsg, pcb->rt->hook, 0); if (error != 0) { pcb->token = 0; break; } error = lksleep(&pcb->msg, &pcb->pcb_lock, PCATCH, "l2ctl", bluetooth_l2cap_rtx_timeout()); pcb->token = 0; if (error != 0) break; if (pcb->msg != NULL && pcb->msg->header.cmd == NGM_L2CAP_L2CA_PING) { /* Return data back to the user space */ op = (ng_l2cap_l2ca_ping_op *)(pcb->msg->data); p->result = op->result; p->echo_size = min(p->echo_size, op->echo_size); if (p->echo_size > 0) error = copyout(op + 1, p->echo_data, p->echo_size); } else error = EINVAL; NG_FREE_MSG(pcb->msg); /* checks for != NULL */ } break; case SIOC_L2CAP_L2CA_GET_INFO: { struct ng_btsocket_l2cap_raw_get_info *p = (struct ng_btsocket_l2cap_raw_get_info *) data; ng_l2cap_l2ca_get_info_ip *ip = NULL; ng_l2cap_l2ca_get_info_op *op = NULL; if (!(pcb->flags & NG_BTSOCKET_L2CAP_RAW_PRIVILEGED)) { error = EPERM; break; } if (p->info_size != 0 && p->info_data == NULL) { error = EINVAL; break; } NG_MKMESSAGE(ngmsg, NGM_L2CAP_COOKIE, NGM_L2CAP_L2CA_GET_INFO, sizeof(*ip) + p->info_size, M_WAITOK | M_NULLOK); if (ngmsg == NULL) { error = ENOMEM; break; } ng_btsocket_l2cap_raw_get_token(&ngmsg->header.token); pcb->token = ngmsg->header.token; pcb->msg = NULL; ip = (ng_l2cap_l2ca_get_info_ip *)(ngmsg->data); bcopy(&pcb->dst, &ip->bdaddr, sizeof(ip->bdaddr)); ip->info_type = p->info_type; NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_raw_node, ngmsg, pcb->rt->hook, 0); if (error != 0) { pcb->token = 0; break; } error = lksleep(&pcb->msg, &pcb->pcb_lock, PCATCH, "l2ctl", bluetooth_l2cap_rtx_timeout()); pcb->token = 0; if (error != 0) break; if (pcb->msg != NULL && pcb->msg->header.cmd == NGM_L2CAP_L2CA_GET_INFO) { /* Return data back to the user space */ op = (ng_l2cap_l2ca_get_info_op *)(pcb->msg->data); p->result = op->result; p->info_size = min(p->info_size, op->info_size); if (p->info_size > 0) error = copyout(op + 1, p->info_data, p->info_size); } else error = EINVAL; NG_FREE_MSG(pcb->msg); /* checks for != NULL */ } break; case SIOC_L2CAP_NODE_GET_AUTO_DISCON_TIMO: { struct ng_btsocket_l2cap_raw_auto_discon_timo *p = (struct ng_btsocket_l2cap_raw_auto_discon_timo *) data; error = ng_btsocket_l2cap_raw_send_sync_ngmsg(pcb, NGM_L2CAP_NODE_GET_AUTO_DISCON_TIMO, &p->timeout, sizeof(p->timeout)); } break; case SIOC_L2CAP_NODE_SET_AUTO_DISCON_TIMO: { struct ng_btsocket_l2cap_raw_auto_discon_timo *p = (struct ng_btsocket_l2cap_raw_auto_discon_timo *) data; if (pcb->flags & NG_BTSOCKET_L2CAP_RAW_PRIVILEGED) error = ng_btsocket_l2cap_raw_send_ngmsg(pcb->rt->hook, NGM_L2CAP_NODE_SET_AUTO_DISCON_TIMO, &p->timeout, sizeof(p->timeout)); else error = EPERM; } break; default: error = EINVAL; break; } lockmgr(&pcb->pcb_lock, LK_RELEASE); out: lwkt_replymsg(&msg->control.base.lmsg, error); } /* ng_btsocket_l2cap_raw_control */ /* * Detach and destroy socket */ void ng_btsocket_l2cap_raw_detach(netmsg_t msg) { struct socket *so = msg->detach.base.nm_so; ng_btsocket_l2cap_raw_pcb_p pcb = so2l2cap_raw_pcb(so); int error = 0; KASSERT(pcb != NULL, ("nt_btsocket_l2cap_raw_detach: pcb == NULL")); if (ng_btsocket_l2cap_raw_node == NULL) goto out; lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_EXCLUSIVE); lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); LIST_REMOVE(pcb, next); lockmgr(&pcb->pcb_lock, LK_RELEASE); lockmgr(&ng_btsocket_l2cap_raw_sockets_lock, LK_RELEASE); lockuninit(&pcb->pcb_lock); bzero(pcb, sizeof(*pcb)); kfree(pcb, M_NETGRAPH_BTSOCKET_L2CAP_RAW); so->so_pcb = NULL; out: lwkt_replymsg(&msg->detach.base.lmsg, error); } /* ng_btsocket_l2cap_raw_detach */ /* * Disconnect socket */ void ng_btsocket_l2cap_raw_disconnect(netmsg_t msg) { struct socket *so = msg->disconnect.base.nm_so; ng_btsocket_l2cap_raw_pcb_p pcb = so2l2cap_raw_pcb(so); int error = 0; if (pcb == NULL) { error = EINVAL; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EINVAL; goto out; } lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); pcb->rt = NULL; soisdisconnected(so); lockmgr(&pcb->pcb_lock, LK_RELEASE); out: lwkt_replymsg(&msg->disconnect.base.lmsg, error); } /* ng_btsocket_l2cap_raw_disconnect */ /* * Get peer address */ void ng_btsocket_l2cap_raw_peeraddr(netmsg_t msg) { struct socket *so = msg->peeraddr.base.nm_so; struct sockaddr **nam = msg->peeraddr.nm_nam; ng_btsocket_l2cap_raw_pcb_p pcb = so2l2cap_raw_pcb(so); struct sockaddr_l2cap sa; int error = 0; if (pcb == NULL) { error = EINVAL; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EINVAL; goto out; } lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); bcopy(&pcb->dst, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); lockmgr(&pcb->pcb_lock, LK_RELEASE); sa.l2cap_psm = 0; sa.l2cap_len = sizeof(sa); sa.l2cap_family = AF_BLUETOOTH; *nam = dup_sockaddr((struct sockaddr *) &sa); if (*nam == NULL) error = ENOMEM; out: lwkt_replymsg(&msg->peeraddr.base.lmsg, error); } /* ng_btsocket_l2cap_raw_peeraddr */ /* * Send data to socket */ void ng_btsocket_l2cap_raw_send(netmsg_t msg) { struct mbuf *control = msg->send.nm_control; struct mbuf *m = msg->send.nm_m; NG_FREE_M(m); /* Checks for m != NULL */ NG_FREE_M(control); lwkt_replymsg(&msg->send.base.lmsg, EOPNOTSUPP); } /* ng_btsocket_l2cap_raw_send */ /* * Get socket address */ void ng_btsocket_l2cap_raw_sockaddr(netmsg_t msg) { struct socket *so = msg->sockaddr.base.nm_so; struct sockaddr **nam = msg->sockaddr.nm_nam; ng_btsocket_l2cap_raw_pcb_p pcb = so2l2cap_raw_pcb(so); struct sockaddr_l2cap sa; int error = 0; if (pcb == NULL) { error = EINVAL; goto out; } if (ng_btsocket_l2cap_raw_node == NULL) { error = EINVAL; goto out; } lockmgr(&pcb->pcb_lock, LK_EXCLUSIVE); bcopy(&pcb->src, &sa.l2cap_bdaddr, sizeof(sa.l2cap_bdaddr)); lockmgr(&pcb->pcb_lock, LK_RELEASE); sa.l2cap_psm = 0; sa.l2cap_len = sizeof(sa); sa.l2cap_family = AF_BLUETOOTH; *nam = dup_sockaddr((struct sockaddr *) &sa); if (*nam == NULL) error = ENOMEM; out: lwkt_replymsg(&msg->sockaddr.base.lmsg, error); } /* ng_btsocket_l2cap_raw_sockaddr */ /* * Get next token */ static void ng_btsocket_l2cap_raw_get_token(u_int32_t *token) { lockmgr(&ng_btsocket_l2cap_raw_token_lock, LK_EXCLUSIVE); if (++ ng_btsocket_l2cap_raw_token == 0) ng_btsocket_l2cap_raw_token = 1; *token = ng_btsocket_l2cap_raw_token; lockmgr(&ng_btsocket_l2cap_raw_token_lock, LK_RELEASE); } /* ng_btsocket_l2cap_raw_get_token */ /* * Send Netgraph message to the node - do not expect reply */ static int ng_btsocket_l2cap_raw_send_ngmsg(hook_p hook, int cmd, void *arg, int arglen) { struct ng_mesg *msg = NULL; int error = 0; NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, cmd, arglen, M_WAITOK | M_NULLOK); if (msg == NULL) return (ENOMEM); if (arg != NULL && arglen > 0) bcopy(arg, msg->data, arglen); NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_raw_node, msg, hook, 0); return (error); } /* ng_btsocket_l2cap_raw_send_ngmsg */ /* * Send Netgraph message to the node (no data) and wait for reply */ static int ng_btsocket_l2cap_raw_send_sync_ngmsg(ng_btsocket_l2cap_raw_pcb_p pcb, int cmd, void *rsp, int rsplen) { struct ng_mesg *msg = NULL; int error = 0; KKASSERT(lockowned(&pcb->pcb_lock) != 0); NG_MKMESSAGE(msg, NGM_L2CAP_COOKIE, cmd, 0, M_WAITOK | M_NULLOK); if (msg == NULL) return (ENOMEM); ng_btsocket_l2cap_raw_get_token(&msg->header.token); pcb->token = msg->header.token; pcb->msg = NULL; NG_SEND_MSG_HOOK(error, ng_btsocket_l2cap_raw_node, msg, pcb->rt->hook, 0); if (error != 0) { pcb->token = 0; return (error); } error = lksleep(&pcb->msg, &pcb->pcb_lock, PCATCH, "l2ctl", ng_btsocket_l2cap_raw_ioctl_timeout * hz); pcb->token = 0; if (error != 0) return (error); if (pcb->msg != NULL && pcb->msg->header.cmd == cmd) bcopy(pcb->msg->data, rsp, rsplen); else error = EINVAL; NG_FREE_MSG(pcb->msg); /* checks for != NULL */ return (0); } /* ng_btsocket_l2cap_raw_send_sync_ngmsg */