Linux Audio

Check our new training course

Loading...
v3.5.6
   1/*
   2   RFCOMM implementation for Linux Bluetooth stack (BlueZ).
   3   Copyright (C) 2002 Maxim Krasnyansky <maxk@qualcomm.com>
   4   Copyright (C) 2002 Marcel Holtmann <marcel@holtmann.org>
   5
   6   This program is free software; you can redistribute it and/or modify
   7   it under the terms of the GNU General Public License version 2 as
   8   published by the Free Software Foundation;
   9
  10   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
  11   OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  12   FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
  13   IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
  14   CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
  15   WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  16   ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  17   OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  18
  19   ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
  20   COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
  21   SOFTWARE IS DISCLAIMED.
  22*/
  23
  24/*
  25 * RFCOMM TTY.
  26 */
  27
  28#include <linux/module.h>
  29
  30#include <linux/tty.h>
  31#include <linux/tty_driver.h>
  32#include <linux/tty_flip.h>
  33
  34#include <linux/capability.h>
  35#include <linux/slab.h>
  36#include <linux/skbuff.h>
  37#include <linux/workqueue.h>
  38
  39#include <net/bluetooth/bluetooth.h>
  40#include <net/bluetooth/hci_core.h>
  41#include <net/bluetooth/rfcomm.h>
  42
  43#define RFCOMM_TTY_MAGIC 0x6d02		/* magic number for rfcomm struct */
  44#define RFCOMM_TTY_PORTS RFCOMM_MAX_DEV	/* whole lotta rfcomm devices */
  45#define RFCOMM_TTY_MAJOR 216		/* device node major id of the usb/bluetooth.c driver */
  46#define RFCOMM_TTY_MINOR 0
  47
  48static struct tty_driver *rfcomm_tty_driver;
  49
  50struct rfcomm_dev {
  51	struct tty_port		port;
  52	struct list_head	list;
 
  53
  54	char			name[12];
  55	int			id;
  56	unsigned long		flags;
 
  57	int			err;
  58
  59	bdaddr_t		src;
  60	bdaddr_t		dst;
  61	u8			channel;
  62
  63	uint			modem_status;
  64
  65	struct rfcomm_dlc	*dlc;
 
  66	wait_queue_head_t       wait;
 
  67
  68	struct device		*tty_dev;
  69
  70	atomic_t		wmem_alloc;
  71
  72	struct sk_buff_head	pending;
  73};
  74
  75static LIST_HEAD(rfcomm_dev_list);
  76static DEFINE_SPINLOCK(rfcomm_dev_lock);
  77
  78static void rfcomm_dev_data_ready(struct rfcomm_dlc *dlc, struct sk_buff *skb);
  79static void rfcomm_dev_state_change(struct rfcomm_dlc *dlc, int err);
  80static void rfcomm_dev_modem_status(struct rfcomm_dlc *dlc, u8 v24_sig);
  81
  82/* ---- Device functions ---- */
  83
  84/*
  85 * The reason this isn't actually a race, as you no doubt have a little voice
  86 * screaming at you in your head, is that the refcount should never actually
  87 * reach zero unless the device has already been taken off the list, in
  88 * rfcomm_dev_del(). And if that's not true, we'll hit the BUG() in
  89 * rfcomm_dev_destruct() anyway.
  90 */
  91static void rfcomm_dev_destruct(struct tty_port *port)
  92{
  93	struct rfcomm_dev *dev = container_of(port, struct rfcomm_dev, port);
  94	struct rfcomm_dlc *dlc = dev->dlc;
  95
  96	BT_DBG("dev %p dlc %p", dev, dlc);
  97
  98	/* Refcount should only hit zero when called from rfcomm_dev_del()
  99	   which will have taken us off the list. Everything else are
 100	   refcounting bugs. */
 101	BUG_ON(!list_empty(&dev->list));
 102
 103	rfcomm_dlc_lock(dlc);
 104	/* Detach DLC if it's owned by this dev */
 105	if (dlc->owner == dev)
 106		dlc->owner = NULL;
 107	rfcomm_dlc_unlock(dlc);
 108
 109	rfcomm_dlc_put(dlc);
 110
 111	tty_unregister_device(rfcomm_tty_driver, dev->id);
 112
 113	kfree(dev);
 114
 115	/* It's safe to call module_put() here because socket still
 116	   holds reference to this module. */
 117	module_put(THIS_MODULE);
 118}
 119
 120static const struct tty_port_operations rfcomm_port_ops = {
 121	.destruct = rfcomm_dev_destruct,
 122};
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 123
 124static struct rfcomm_dev *__rfcomm_dev_get(int id)
 125{
 126	struct rfcomm_dev *dev;
 
 127
 128	list_for_each_entry(dev, &rfcomm_dev_list, list)
 
 129		if (dev->id == id)
 130			return dev;
 
 131
 132	return NULL;
 133}
 134
 135static inline struct rfcomm_dev *rfcomm_dev_get(int id)
 136{
 137	struct rfcomm_dev *dev;
 138
 139	spin_lock(&rfcomm_dev_lock);
 140
 141	dev = __rfcomm_dev_get(id);
 142
 143	if (dev) {
 144		if (test_bit(RFCOMM_TTY_RELEASED, &dev->flags))
 145			dev = NULL;
 146		else
 147			tty_port_get(&dev->port);
 148	}
 149
 150	spin_unlock(&rfcomm_dev_lock);
 151
 152	return dev;
 153}
 154
 155static struct device *rfcomm_get_device(struct rfcomm_dev *dev)
 156{
 157	struct hci_dev *hdev;
 158	struct hci_conn *conn;
 159
 160	hdev = hci_get_route(&dev->dst, &dev->src);
 161	if (!hdev)
 162		return NULL;
 163
 164	conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, &dev->dst);
 165
 166	hci_dev_put(hdev);
 167
 168	return conn ? &conn->dev : NULL;
 169}
 170
 171static ssize_t show_address(struct device *tty_dev, struct device_attribute *attr, char *buf)
 172{
 173	struct rfcomm_dev *dev = dev_get_drvdata(tty_dev);
 174	return sprintf(buf, "%s\n", batostr(&dev->dst));
 175}
 176
 177static ssize_t show_channel(struct device *tty_dev, struct device_attribute *attr, char *buf)
 178{
 179	struct rfcomm_dev *dev = dev_get_drvdata(tty_dev);
 180	return sprintf(buf, "%d\n", dev->channel);
 181}
 182
 183static DEVICE_ATTR(address, S_IRUGO, show_address, NULL);
 184static DEVICE_ATTR(channel, S_IRUGO, show_channel, NULL);
 185
 186static int rfcomm_dev_add(struct rfcomm_dev_req *req, struct rfcomm_dlc *dlc)
 187{
 188	struct rfcomm_dev *dev, *entry;
 189	struct list_head *head = &rfcomm_dev_list;
 190	int err = 0;
 191
 192	BT_DBG("id %d channel %d", req->dev_id, req->channel);
 193
 194	dev = kzalloc(sizeof(struct rfcomm_dev), GFP_KERNEL);
 195	if (!dev)
 196		return -ENOMEM;
 197
 198	spin_lock(&rfcomm_dev_lock);
 199
 200	if (req->dev_id < 0) {
 201		dev->id = 0;
 202
 203		list_for_each_entry(entry, &rfcomm_dev_list, list) {
 204			if (entry->id != dev->id)
 205				break;
 206
 207			dev->id++;
 208			head = &entry->list;
 209		}
 210	} else {
 211		dev->id = req->dev_id;
 212
 213		list_for_each_entry(entry, &rfcomm_dev_list, list) {
 
 
 214			if (entry->id == dev->id) {
 215				err = -EADDRINUSE;
 216				goto out;
 217			}
 218
 219			if (entry->id > dev->id - 1)
 220				break;
 221
 222			head = &entry->list;
 223		}
 224	}
 225
 226	if ((dev->id < 0) || (dev->id > RFCOMM_MAX_DEV - 1)) {
 227		err = -ENFILE;
 228		goto out;
 229	}
 230
 231	sprintf(dev->name, "rfcomm%d", dev->id);
 232
 233	list_add(&dev->list, head);
 
 234
 235	bacpy(&dev->src, &req->src);
 236	bacpy(&dev->dst, &req->dst);
 237	dev->channel = req->channel;
 238
 239	dev->flags = req->flags &
 240		((1 << RFCOMM_RELEASE_ONHUP) | (1 << RFCOMM_REUSE_DLC));
 241
 242	tty_port_init(&dev->port);
 243	dev->port.ops = &rfcomm_port_ops;
 244	init_waitqueue_head(&dev->wait);
 
 245
 246	skb_queue_head_init(&dev->pending);
 247
 248	rfcomm_dlc_lock(dlc);
 249
 250	if (req->flags & (1 << RFCOMM_REUSE_DLC)) {
 251		struct sock *sk = dlc->owner;
 252		struct sk_buff *skb;
 253
 254		BUG_ON(!sk);
 255
 256		rfcomm_dlc_throttle(dlc);
 257
 258		while ((skb = skb_dequeue(&sk->sk_receive_queue))) {
 259			skb_orphan(skb);
 260			skb_queue_tail(&dev->pending, skb);
 261			atomic_sub(skb->len, &sk->sk_rmem_alloc);
 262		}
 263	}
 264
 265	dlc->data_ready   = rfcomm_dev_data_ready;
 266	dlc->state_change = rfcomm_dev_state_change;
 267	dlc->modem_status = rfcomm_dev_modem_status;
 268
 269	dlc->owner = dev;
 270	dev->dlc   = dlc;
 271
 272	rfcomm_dev_modem_status(dlc, dlc->remote_v24_sig);
 273
 274	rfcomm_dlc_unlock(dlc);
 275
 276	/* It's safe to call __module_get() here because socket already
 277	   holds reference to this module. */
 278	__module_get(THIS_MODULE);
 279
 280out:
 281	spin_unlock(&rfcomm_dev_lock);
 282
 283	if (err < 0)
 284		goto free;
 285
 286	dev->tty_dev = tty_register_device(rfcomm_tty_driver, dev->id, NULL);
 287
 288	if (IS_ERR(dev->tty_dev)) {
 289		err = PTR_ERR(dev->tty_dev);
 290		list_del(&dev->list);
 291		goto free;
 292	}
 293
 294	dev_set_drvdata(dev->tty_dev, dev);
 295
 296	if (device_create_file(dev->tty_dev, &dev_attr_address) < 0)
 297		BT_ERR("Failed to create address attribute");
 298
 299	if (device_create_file(dev->tty_dev, &dev_attr_channel) < 0)
 300		BT_ERR("Failed to create channel attribute");
 301
 302	return dev->id;
 303
 304free:
 305	kfree(dev);
 306	return err;
 307}
 308
 309static void rfcomm_dev_del(struct rfcomm_dev *dev)
 310{
 311	unsigned long flags;
 312	BT_DBG("dev %p", dev);
 313
 314	BUG_ON(test_and_set_bit(RFCOMM_TTY_RELEASED, &dev->flags));
 315
 316	spin_lock_irqsave(&dev->port.lock, flags);
 317	if (dev->port.count > 0) {
 318		spin_unlock_irqrestore(&dev->port.lock, flags);
 319		return;
 320	}
 321	spin_unlock_irqrestore(&dev->port.lock, flags);
 322
 323	spin_lock(&rfcomm_dev_lock);
 324	list_del_init(&dev->list);
 325	spin_unlock(&rfcomm_dev_lock);
 326
 327	tty_port_put(&dev->port);
 328}
 329
 330/* ---- Send buffer ---- */
 331static inline unsigned int rfcomm_room(struct rfcomm_dlc *dlc)
 332{
 333	/* We can't let it be zero, because we don't get a callback
 334	   when tx_credits becomes nonzero, hence we'd never wake up */
 335	return dlc->mtu * (dlc->tx_credits?:1);
 336}
 337
 338static void rfcomm_wfree(struct sk_buff *skb)
 339{
 340	struct rfcomm_dev *dev = (void *) skb->sk;
 341	struct tty_struct *tty = dev->port.tty;
 342	atomic_sub(skb->truesize, &dev->wmem_alloc);
 343	if (test_bit(RFCOMM_TTY_ATTACHED, &dev->flags) && tty)
 344		tty_wakeup(tty);
 345	tty_port_put(&dev->port);
 346}
 347
 348static inline void rfcomm_set_owner_w(struct sk_buff *skb, struct rfcomm_dev *dev)
 349{
 350	tty_port_get(&dev->port);
 351	atomic_add(skb->truesize, &dev->wmem_alloc);
 352	skb->sk = (void *) dev;
 353	skb->destructor = rfcomm_wfree;
 354}
 355
 356static struct sk_buff *rfcomm_wmalloc(struct rfcomm_dev *dev, unsigned long size, gfp_t priority)
 357{
 358	if (atomic_read(&dev->wmem_alloc) < rfcomm_room(dev->dlc)) {
 359		struct sk_buff *skb = alloc_skb(size, priority);
 360		if (skb) {
 361			rfcomm_set_owner_w(skb, dev);
 362			return skb;
 363		}
 364	}
 365	return NULL;
 366}
 367
 368/* ---- Device IOCTLs ---- */
 369
 370#define NOCAP_FLAGS ((1 << RFCOMM_REUSE_DLC) | (1 << RFCOMM_RELEASE_ONHUP))
 371
 372static int rfcomm_create_dev(struct sock *sk, void __user *arg)
 373{
 374	struct rfcomm_dev_req req;
 375	struct rfcomm_dlc *dlc;
 376	int id;
 377
 378	if (copy_from_user(&req, arg, sizeof(req)))
 379		return -EFAULT;
 380
 381	BT_DBG("sk %p dev_id %d flags 0x%x", sk, req.dev_id, req.flags);
 382
 383	if (req.flags != NOCAP_FLAGS && !capable(CAP_NET_ADMIN))
 384		return -EPERM;
 385
 386	if (req.flags & (1 << RFCOMM_REUSE_DLC)) {
 387		/* Socket must be connected */
 388		if (sk->sk_state != BT_CONNECTED)
 389			return -EBADFD;
 390
 391		dlc = rfcomm_pi(sk)->dlc;
 392		rfcomm_dlc_hold(dlc);
 393	} else {
 394		dlc = rfcomm_dlc_alloc(GFP_KERNEL);
 395		if (!dlc)
 396			return -ENOMEM;
 397	}
 398
 399	id = rfcomm_dev_add(&req, dlc);
 400	if (id < 0) {
 401		rfcomm_dlc_put(dlc);
 402		return id;
 403	}
 404
 405	if (req.flags & (1 << RFCOMM_REUSE_DLC)) {
 406		/* DLC is now used by device.
 407		 * Socket must be disconnected */
 408		sk->sk_state = BT_CLOSED;
 409	}
 410
 411	return id;
 412}
 413
 414static int rfcomm_release_dev(void __user *arg)
 415{
 416	struct rfcomm_dev_req req;
 417	struct rfcomm_dev *dev;
 418
 419	if (copy_from_user(&req, arg, sizeof(req)))
 420		return -EFAULT;
 421
 422	BT_DBG("dev_id %d flags 0x%x", req.dev_id, req.flags);
 423
 424	dev = rfcomm_dev_get(req.dev_id);
 425	if (!dev)
 426		return -ENODEV;
 427
 428	if (dev->flags != NOCAP_FLAGS && !capable(CAP_NET_ADMIN)) {
 429		tty_port_put(&dev->port);
 430		return -EPERM;
 431	}
 432
 433	if (req.flags & (1 << RFCOMM_HANGUP_NOW))
 434		rfcomm_dlc_close(dev->dlc, 0);
 435
 436	/* Shut down TTY synchronously before freeing rfcomm_dev */
 437	if (dev->port.tty)
 438		tty_vhangup(dev->port.tty);
 439
 440	if (!test_bit(RFCOMM_RELEASE_ONHUP, &dev->flags))
 441		rfcomm_dev_del(dev);
 442	tty_port_put(&dev->port);
 443	return 0;
 444}
 445
 446static int rfcomm_get_dev_list(void __user *arg)
 447{
 448	struct rfcomm_dev *dev;
 449	struct rfcomm_dev_list_req *dl;
 450	struct rfcomm_dev_info *di;
 
 451	int n = 0, size, err;
 452	u16 dev_num;
 453
 454	BT_DBG("");
 455
 456	if (get_user(dev_num, (u16 __user *) arg))
 457		return -EFAULT;
 458
 459	if (!dev_num || dev_num > (PAGE_SIZE * 4) / sizeof(*di))
 460		return -EINVAL;
 461
 462	size = sizeof(*dl) + dev_num * sizeof(*di);
 463
 464	dl = kzalloc(size, GFP_KERNEL);
 465	if (!dl)
 466		return -ENOMEM;
 467
 468	di = dl->dev_info;
 469
 470	spin_lock(&rfcomm_dev_lock);
 471
 472	list_for_each_entry(dev, &rfcomm_dev_list, list) {
 
 473		if (test_bit(RFCOMM_TTY_RELEASED, &dev->flags))
 474			continue;
 475		(di + n)->id      = dev->id;
 476		(di + n)->flags   = dev->flags;
 477		(di + n)->state   = dev->dlc->state;
 478		(di + n)->channel = dev->channel;
 479		bacpy(&(di + n)->src, &dev->src);
 480		bacpy(&(di + n)->dst, &dev->dst);
 481		if (++n >= dev_num)
 482			break;
 483	}
 484
 485	spin_unlock(&rfcomm_dev_lock);
 486
 487	dl->dev_num = n;
 488	size = sizeof(*dl) + n * sizeof(*di);
 489
 490	err = copy_to_user(arg, dl, size);
 491	kfree(dl);
 492
 493	return err ? -EFAULT : 0;
 494}
 495
 496static int rfcomm_get_dev_info(void __user *arg)
 497{
 498	struct rfcomm_dev *dev;
 499	struct rfcomm_dev_info di;
 500	int err = 0;
 501
 502	BT_DBG("");
 503
 504	if (copy_from_user(&di, arg, sizeof(di)))
 505		return -EFAULT;
 506
 507	dev = rfcomm_dev_get(di.id);
 508	if (!dev)
 509		return -ENODEV;
 510
 511	di.flags   = dev->flags;
 512	di.channel = dev->channel;
 513	di.state   = dev->dlc->state;
 514	bacpy(&di.src, &dev->src);
 515	bacpy(&di.dst, &dev->dst);
 516
 517	if (copy_to_user(arg, &di, sizeof(di)))
 518		err = -EFAULT;
 519
 520	tty_port_put(&dev->port);
 521	return err;
 522}
 523
 524int rfcomm_dev_ioctl(struct sock *sk, unsigned int cmd, void __user *arg)
 525{
 526	BT_DBG("cmd %d arg %p", cmd, arg);
 527
 528	switch (cmd) {
 529	case RFCOMMCREATEDEV:
 530		return rfcomm_create_dev(sk, arg);
 531
 532	case RFCOMMRELEASEDEV:
 533		return rfcomm_release_dev(arg);
 534
 535	case RFCOMMGETDEVLIST:
 536		return rfcomm_get_dev_list(arg);
 537
 538	case RFCOMMGETDEVINFO:
 539		return rfcomm_get_dev_info(arg);
 540	}
 541
 542	return -EINVAL;
 543}
 544
 545/* ---- DLC callbacks ---- */
 546static void rfcomm_dev_data_ready(struct rfcomm_dlc *dlc, struct sk_buff *skb)
 547{
 548	struct rfcomm_dev *dev = dlc->owner;
 549	struct tty_struct *tty;
 550
 551	if (!dev) {
 552		kfree_skb(skb);
 553		return;
 554	}
 555
 556	tty = dev->port.tty;
 557	if (!tty || !skb_queue_empty(&dev->pending)) {
 558		skb_queue_tail(&dev->pending, skb);
 559		return;
 560	}
 561
 562	BT_DBG("dlc %p tty %p len %d", dlc, tty, skb->len);
 563
 564	tty_insert_flip_string(tty, skb->data, skb->len);
 565	tty_flip_buffer_push(tty);
 566
 567	kfree_skb(skb);
 568}
 569
 570static void rfcomm_dev_state_change(struct rfcomm_dlc *dlc, int err)
 571{
 572	struct rfcomm_dev *dev = dlc->owner;
 573	if (!dev)
 574		return;
 575
 576	BT_DBG("dlc %p dev %p err %d", dlc, dev, err);
 577
 578	dev->err = err;
 579	wake_up_interruptible(&dev->wait);
 580
 581	if (dlc->state == BT_CLOSED) {
 582		if (!dev->port.tty) {
 583			if (test_bit(RFCOMM_RELEASE_ONHUP, &dev->flags)) {
 584				/* Drop DLC lock here to avoid deadlock
 585				 * 1. rfcomm_dev_get will take rfcomm_dev_lock
 586				 *    but in rfcomm_dev_add there's lock order:
 587				 *    rfcomm_dev_lock -> dlc lock
 588				 * 2. tty_port_put will deadlock if it's
 589				 *    the last reference
 590				 */
 591				rfcomm_dlc_unlock(dlc);
 592				if (rfcomm_dev_get(dev->id) == NULL) {
 593					rfcomm_dlc_lock(dlc);
 594					return;
 595				}
 596
 597				rfcomm_dev_del(dev);
 598				tty_port_put(&dev->port);
 599				rfcomm_dlc_lock(dlc);
 600			}
 601		} else
 602			tty_hangup(dev->port.tty);
 603	}
 604}
 605
 606static void rfcomm_dev_modem_status(struct rfcomm_dlc *dlc, u8 v24_sig)
 607{
 608	struct rfcomm_dev *dev = dlc->owner;
 609	if (!dev)
 610		return;
 611
 612	BT_DBG("dlc %p dev %p v24_sig 0x%02x", dlc, dev, v24_sig);
 613
 614	if ((dev->modem_status & TIOCM_CD) && !(v24_sig & RFCOMM_V24_DV)) {
 615		if (dev->port.tty && !C_CLOCAL(dev->port.tty))
 616			tty_hangup(dev->port.tty);
 617	}
 618
 619	dev->modem_status =
 620		((v24_sig & RFCOMM_V24_RTC) ? (TIOCM_DSR | TIOCM_DTR) : 0) |
 621		((v24_sig & RFCOMM_V24_RTR) ? (TIOCM_RTS | TIOCM_CTS) : 0) |
 622		((v24_sig & RFCOMM_V24_IC)  ? TIOCM_RI : 0) |
 623		((v24_sig & RFCOMM_V24_DV)  ? TIOCM_CD : 0);
 624}
 625
 626/* ---- TTY functions ---- */
 
 
 
 
 
 
 
 
 
 
 
 627static void rfcomm_tty_copy_pending(struct rfcomm_dev *dev)
 628{
 629	struct tty_struct *tty = dev->port.tty;
 630	struct sk_buff *skb;
 631	int inserted = 0;
 632
 633	if (!tty)
 634		return;
 635
 636	BT_DBG("dev %p tty %p", dev, tty);
 637
 638	rfcomm_dlc_lock(dev->dlc);
 639
 640	while ((skb = skb_dequeue(&dev->pending))) {
 641		inserted += tty_insert_flip_string(tty, skb->data, skb->len);
 642		kfree_skb(skb);
 643	}
 644
 645	rfcomm_dlc_unlock(dev->dlc);
 646
 647	if (inserted > 0)
 648		tty_flip_buffer_push(tty);
 649}
 650
 651static int rfcomm_tty_open(struct tty_struct *tty, struct file *filp)
 652{
 653	DECLARE_WAITQUEUE(wait, current);
 654	struct rfcomm_dev *dev;
 655	struct rfcomm_dlc *dlc;
 656	unsigned long flags;
 657	int err, id;
 658
 659	id = tty->index;
 660
 661	BT_DBG("tty %p id %d", tty, id);
 662
 663	/* We don't leak this refcount. For reasons which are not entirely
 664	   clear, the TTY layer will call our ->close() method even if the
 665	   open fails. We decrease the refcount there, and decreasing it
 666	   here too would cause breakage. */
 667	dev = rfcomm_dev_get(id);
 668	if (!dev)
 669		return -ENODEV;
 670
 671	BT_DBG("dev %p dst %s channel %d opened %d", dev, batostr(&dev->dst),
 672				dev->channel, dev->port.count);
 673
 674	spin_lock_irqsave(&dev->port.lock, flags);
 675	if (++dev->port.count > 1) {
 676		spin_unlock_irqrestore(&dev->port.lock, flags);
 677		return 0;
 678	}
 679	spin_unlock_irqrestore(&dev->port.lock, flags);
 680
 681	dlc = dev->dlc;
 682
 683	/* Attach TTY and open DLC */
 684
 685	rfcomm_dlc_lock(dlc);
 686	tty->driver_data = dev;
 687	dev->port.tty = tty;
 688	rfcomm_dlc_unlock(dlc);
 689	set_bit(RFCOMM_TTY_ATTACHED, &dev->flags);
 690
 691	err = rfcomm_dlc_open(dlc, &dev->src, &dev->dst, dev->channel);
 692	if (err < 0)
 693		return err;
 694
 695	/* Wait for DLC to connect */
 696	add_wait_queue(&dev->wait, &wait);
 697	while (1) {
 698		set_current_state(TASK_INTERRUPTIBLE);
 699
 700		if (dlc->state == BT_CLOSED) {
 701			err = -dev->err;
 702			break;
 703		}
 704
 705		if (dlc->state == BT_CONNECTED)
 706			break;
 707
 708		if (signal_pending(current)) {
 709			err = -EINTR;
 710			break;
 711		}
 712
 713		tty_unlock();
 714		schedule();
 715		tty_lock();
 716	}
 717	set_current_state(TASK_RUNNING);
 718	remove_wait_queue(&dev->wait, &wait);
 719
 720	if (err == 0)
 721		device_move(dev->tty_dev, rfcomm_get_device(dev),
 722			    DPM_ORDER_DEV_AFTER_PARENT);
 723
 724	rfcomm_tty_copy_pending(dev);
 725
 726	rfcomm_dlc_unthrottle(dev->dlc);
 727
 728	return err;
 729}
 730
 731static void rfcomm_tty_close(struct tty_struct *tty, struct file *filp)
 732{
 733	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 734	unsigned long flags;
 735
 736	if (!dev)
 737		return;
 738
 739	BT_DBG("tty %p dev %p dlc %p opened %d", tty, dev, dev->dlc,
 740						dev->port.count);
 741
 742	spin_lock_irqsave(&dev->port.lock, flags);
 743	if (!--dev->port.count) {
 744		spin_unlock_irqrestore(&dev->port.lock, flags);
 745		if (dev->tty_dev->parent)
 746			device_move(dev->tty_dev, NULL, DPM_ORDER_DEV_LAST);
 747
 748		/* Close DLC and dettach TTY */
 749		rfcomm_dlc_close(dev->dlc, 0);
 750
 751		clear_bit(RFCOMM_TTY_ATTACHED, &dev->flags);
 
 752
 753		rfcomm_dlc_lock(dev->dlc);
 754		tty->driver_data = NULL;
 755		dev->port.tty = NULL;
 756		rfcomm_dlc_unlock(dev->dlc);
 757
 758		if (test_bit(RFCOMM_TTY_RELEASED, &dev->flags)) {
 759			spin_lock(&rfcomm_dev_lock);
 760			list_del_init(&dev->list);
 761			spin_unlock(&rfcomm_dev_lock);
 762
 763			tty_port_put(&dev->port);
 764		}
 765	} else
 766		spin_unlock_irqrestore(&dev->port.lock, flags);
 767
 768	tty_port_put(&dev->port);
 769}
 770
 771static int rfcomm_tty_write(struct tty_struct *tty, const unsigned char *buf, int count)
 772{
 773	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 774	struct rfcomm_dlc *dlc = dev->dlc;
 775	struct sk_buff *skb;
 776	int err = 0, sent = 0, size;
 777
 778	BT_DBG("tty %p count %d", tty, count);
 779
 780	while (count) {
 781		size = min_t(uint, count, dlc->mtu);
 782
 783		skb = rfcomm_wmalloc(dev, size + RFCOMM_SKB_RESERVE, GFP_ATOMIC);
 784
 785		if (!skb)
 786			break;
 787
 788		skb_reserve(skb, RFCOMM_SKB_HEAD_RESERVE);
 789
 790		memcpy(skb_put(skb, size), buf + sent, size);
 791
 792		err = rfcomm_dlc_send(dlc, skb);
 793		if (err < 0) {
 794			kfree_skb(skb);
 795			break;
 796		}
 797
 798		sent  += size;
 799		count -= size;
 800	}
 801
 802	return sent ? sent : err;
 803}
 804
 805static int rfcomm_tty_write_room(struct tty_struct *tty)
 806{
 807	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 808	int room;
 809
 810	BT_DBG("tty %p", tty);
 811
 812	if (!dev || !dev->dlc)
 813		return 0;
 814
 815	room = rfcomm_room(dev->dlc) - atomic_read(&dev->wmem_alloc);
 816	if (room < 0)
 817		room = 0;
 818
 819	return room;
 820}
 821
 822static int rfcomm_tty_ioctl(struct tty_struct *tty, unsigned int cmd, unsigned long arg)
 823{
 824	BT_DBG("tty %p cmd 0x%02x", tty, cmd);
 825
 826	switch (cmd) {
 827	case TCGETS:
 828		BT_DBG("TCGETS is not supported");
 829		return -ENOIOCTLCMD;
 830
 831	case TCSETS:
 832		BT_DBG("TCSETS is not supported");
 833		return -ENOIOCTLCMD;
 834
 835	case TIOCMIWAIT:
 836		BT_DBG("TIOCMIWAIT");
 837		break;
 838
 839	case TIOCGSERIAL:
 840		BT_ERR("TIOCGSERIAL is not supported");
 841		return -ENOIOCTLCMD;
 842
 843	case TIOCSSERIAL:
 844		BT_ERR("TIOCSSERIAL is not supported");
 845		return -ENOIOCTLCMD;
 846
 847	case TIOCSERGSTRUCT:
 848		BT_ERR("TIOCSERGSTRUCT is not supported");
 849		return -ENOIOCTLCMD;
 850
 851	case TIOCSERGETLSR:
 852		BT_ERR("TIOCSERGETLSR is not supported");
 853		return -ENOIOCTLCMD;
 854
 855	case TIOCSERCONFIG:
 856		BT_ERR("TIOCSERCONFIG is not supported");
 857		return -ENOIOCTLCMD;
 858
 859	default:
 860		return -ENOIOCTLCMD;	/* ioctls which we must ignore */
 861
 862	}
 863
 864	return -ENOIOCTLCMD;
 865}
 866
 867static void rfcomm_tty_set_termios(struct tty_struct *tty, struct ktermios *old)
 868{
 869	struct ktermios *new = tty->termios;
 870	int old_baud_rate = tty_termios_baud_rate(old);
 871	int new_baud_rate = tty_termios_baud_rate(new);
 872
 873	u8 baud, data_bits, stop_bits, parity, x_on, x_off;
 874	u16 changes = 0;
 875
 876	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 877
 878	BT_DBG("tty %p termios %p", tty, old);
 879
 880	if (!dev || !dev->dlc || !dev->dlc->session)
 881		return;
 882
 883	/* Handle turning off CRTSCTS */
 884	if ((old->c_cflag & CRTSCTS) && !(new->c_cflag & CRTSCTS))
 885		BT_DBG("Turning off CRTSCTS unsupported");
 886
 887	/* Parity on/off and when on, odd/even */
 888	if (((old->c_cflag & PARENB) != (new->c_cflag & PARENB)) ||
 889			((old->c_cflag & PARODD) != (new->c_cflag & PARODD))) {
 890		changes |= RFCOMM_RPN_PM_PARITY;
 891		BT_DBG("Parity change detected.");
 892	}
 893
 894	/* Mark and space parity are not supported! */
 895	if (new->c_cflag & PARENB) {
 896		if (new->c_cflag & PARODD) {
 897			BT_DBG("Parity is ODD");
 898			parity = RFCOMM_RPN_PARITY_ODD;
 899		} else {
 900			BT_DBG("Parity is EVEN");
 901			parity = RFCOMM_RPN_PARITY_EVEN;
 902		}
 903	} else {
 904		BT_DBG("Parity is OFF");
 905		parity = RFCOMM_RPN_PARITY_NONE;
 906	}
 907
 908	/* Setting the x_on / x_off characters */
 909	if (old->c_cc[VSTOP] != new->c_cc[VSTOP]) {
 910		BT_DBG("XOFF custom");
 911		x_on = new->c_cc[VSTOP];
 912		changes |= RFCOMM_RPN_PM_XON;
 913	} else {
 914		BT_DBG("XOFF default");
 915		x_on = RFCOMM_RPN_XON_CHAR;
 916	}
 917
 918	if (old->c_cc[VSTART] != new->c_cc[VSTART]) {
 919		BT_DBG("XON custom");
 920		x_off = new->c_cc[VSTART];
 921		changes |= RFCOMM_RPN_PM_XOFF;
 922	} else {
 923		BT_DBG("XON default");
 924		x_off = RFCOMM_RPN_XOFF_CHAR;
 925	}
 926
 927	/* Handle setting of stop bits */
 928	if ((old->c_cflag & CSTOPB) != (new->c_cflag & CSTOPB))
 929		changes |= RFCOMM_RPN_PM_STOP;
 930
 931	/* POSIX does not support 1.5 stop bits and RFCOMM does not
 932	 * support 2 stop bits. So a request for 2 stop bits gets
 933	 * translated to 1.5 stop bits */
 934	if (new->c_cflag & CSTOPB)
 935		stop_bits = RFCOMM_RPN_STOP_15;
 936	else
 937		stop_bits = RFCOMM_RPN_STOP_1;
 938
 939	/* Handle number of data bits [5-8] */
 940	if ((old->c_cflag & CSIZE) != (new->c_cflag & CSIZE))
 941		changes |= RFCOMM_RPN_PM_DATA;
 942
 943	switch (new->c_cflag & CSIZE) {
 944	case CS5:
 945		data_bits = RFCOMM_RPN_DATA_5;
 946		break;
 947	case CS6:
 948		data_bits = RFCOMM_RPN_DATA_6;
 949		break;
 950	case CS7:
 951		data_bits = RFCOMM_RPN_DATA_7;
 952		break;
 953	case CS8:
 954		data_bits = RFCOMM_RPN_DATA_8;
 955		break;
 956	default:
 957		data_bits = RFCOMM_RPN_DATA_8;
 958		break;
 959	}
 960
 961	/* Handle baudrate settings */
 962	if (old_baud_rate != new_baud_rate)
 963		changes |= RFCOMM_RPN_PM_BITRATE;
 964
 965	switch (new_baud_rate) {
 966	case 2400:
 967		baud = RFCOMM_RPN_BR_2400;
 968		break;
 969	case 4800:
 970		baud = RFCOMM_RPN_BR_4800;
 971		break;
 972	case 7200:
 973		baud = RFCOMM_RPN_BR_7200;
 974		break;
 975	case 9600:
 976		baud = RFCOMM_RPN_BR_9600;
 977		break;
 978	case 19200:
 979		baud = RFCOMM_RPN_BR_19200;
 980		break;
 981	case 38400:
 982		baud = RFCOMM_RPN_BR_38400;
 983		break;
 984	case 57600:
 985		baud = RFCOMM_RPN_BR_57600;
 986		break;
 987	case 115200:
 988		baud = RFCOMM_RPN_BR_115200;
 989		break;
 990	case 230400:
 991		baud = RFCOMM_RPN_BR_230400;
 992		break;
 993	default:
 994		/* 9600 is standard accordinag to the RFCOMM specification */
 995		baud = RFCOMM_RPN_BR_9600;
 996		break;
 997
 998	}
 999
1000	if (changes)
1001		rfcomm_send_rpn(dev->dlc->session, 1, dev->dlc->dlci, baud,
1002				data_bits, stop_bits, parity,
1003				RFCOMM_RPN_FLOW_NONE, x_on, x_off, changes);
1004}
1005
1006static void rfcomm_tty_throttle(struct tty_struct *tty)
1007{
1008	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1009
1010	BT_DBG("tty %p dev %p", tty, dev);
1011
1012	rfcomm_dlc_throttle(dev->dlc);
1013}
1014
1015static void rfcomm_tty_unthrottle(struct tty_struct *tty)
1016{
1017	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1018
1019	BT_DBG("tty %p dev %p", tty, dev);
1020
1021	rfcomm_dlc_unthrottle(dev->dlc);
1022}
1023
1024static int rfcomm_tty_chars_in_buffer(struct tty_struct *tty)
1025{
1026	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1027
1028	BT_DBG("tty %p dev %p", tty, dev);
1029
1030	if (!dev || !dev->dlc)
1031		return 0;
1032
1033	if (!skb_queue_empty(&dev->dlc->tx_queue))
1034		return dev->dlc->mtu;
1035
1036	return 0;
1037}
1038
1039static void rfcomm_tty_flush_buffer(struct tty_struct *tty)
1040{
1041	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1042
1043	BT_DBG("tty %p dev %p", tty, dev);
1044
1045	if (!dev || !dev->dlc)
1046		return;
1047
1048	skb_queue_purge(&dev->dlc->tx_queue);
1049	tty_wakeup(tty);
1050}
1051
1052static void rfcomm_tty_send_xchar(struct tty_struct *tty, char ch)
1053{
1054	BT_DBG("tty %p ch %c", tty, ch);
1055}
1056
1057static void rfcomm_tty_wait_until_sent(struct tty_struct *tty, int timeout)
1058{
1059	BT_DBG("tty %p timeout %d", tty, timeout);
1060}
1061
1062static void rfcomm_tty_hangup(struct tty_struct *tty)
1063{
1064	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1065
1066	BT_DBG("tty %p dev %p", tty, dev);
1067
1068	if (!dev)
1069		return;
1070
1071	rfcomm_tty_flush_buffer(tty);
1072
1073	if (test_bit(RFCOMM_RELEASE_ONHUP, &dev->flags)) {
1074		if (rfcomm_dev_get(dev->id) == NULL)
1075			return;
1076		rfcomm_dev_del(dev);
1077		tty_port_put(&dev->port);
1078	}
1079}
1080
1081static int rfcomm_tty_tiocmget(struct tty_struct *tty)
1082{
1083	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1084
1085	BT_DBG("tty %p dev %p", tty, dev);
1086
1087	return dev->modem_status;
1088}
1089
1090static int rfcomm_tty_tiocmset(struct tty_struct *tty, unsigned int set, unsigned int clear)
1091{
1092	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1093	struct rfcomm_dlc *dlc = dev->dlc;
1094	u8 v24_sig;
1095
1096	BT_DBG("tty %p dev %p set 0x%02x clear 0x%02x", tty, dev, set, clear);
1097
1098	rfcomm_dlc_get_modem_status(dlc, &v24_sig);
1099
1100	if (set & TIOCM_DSR || set & TIOCM_DTR)
1101		v24_sig |= RFCOMM_V24_RTC;
1102	if (set & TIOCM_RTS || set & TIOCM_CTS)
1103		v24_sig |= RFCOMM_V24_RTR;
1104	if (set & TIOCM_RI)
1105		v24_sig |= RFCOMM_V24_IC;
1106	if (set & TIOCM_CD)
1107		v24_sig |= RFCOMM_V24_DV;
1108
1109	if (clear & TIOCM_DSR || clear & TIOCM_DTR)
1110		v24_sig &= ~RFCOMM_V24_RTC;
1111	if (clear & TIOCM_RTS || clear & TIOCM_CTS)
1112		v24_sig &= ~RFCOMM_V24_RTR;
1113	if (clear & TIOCM_RI)
1114		v24_sig &= ~RFCOMM_V24_IC;
1115	if (clear & TIOCM_CD)
1116		v24_sig &= ~RFCOMM_V24_DV;
1117
1118	rfcomm_dlc_set_modem_status(dlc, v24_sig);
1119
1120	return 0;
1121}
1122
1123/* ---- TTY structure ---- */
1124
1125static const struct tty_operations rfcomm_ops = {
1126	.open			= rfcomm_tty_open,
1127	.close			= rfcomm_tty_close,
1128	.write			= rfcomm_tty_write,
1129	.write_room		= rfcomm_tty_write_room,
1130	.chars_in_buffer	= rfcomm_tty_chars_in_buffer,
1131	.flush_buffer		= rfcomm_tty_flush_buffer,
1132	.ioctl			= rfcomm_tty_ioctl,
1133	.throttle		= rfcomm_tty_throttle,
1134	.unthrottle		= rfcomm_tty_unthrottle,
1135	.set_termios		= rfcomm_tty_set_termios,
1136	.send_xchar		= rfcomm_tty_send_xchar,
1137	.hangup			= rfcomm_tty_hangup,
1138	.wait_until_sent	= rfcomm_tty_wait_until_sent,
1139	.tiocmget		= rfcomm_tty_tiocmget,
1140	.tiocmset		= rfcomm_tty_tiocmset,
1141};
1142
1143int __init rfcomm_init_ttys(void)
1144{
1145	int error;
1146
1147	rfcomm_tty_driver = alloc_tty_driver(RFCOMM_TTY_PORTS);
1148	if (!rfcomm_tty_driver)
1149		return -ENOMEM;
1150
 
1151	rfcomm_tty_driver->driver_name	= "rfcomm";
1152	rfcomm_tty_driver->name		= "rfcomm";
1153	rfcomm_tty_driver->major	= RFCOMM_TTY_MAJOR;
1154	rfcomm_tty_driver->minor_start	= RFCOMM_TTY_MINOR;
1155	rfcomm_tty_driver->type		= TTY_DRIVER_TYPE_SERIAL;
1156	rfcomm_tty_driver->subtype	= SERIAL_TYPE_NORMAL;
1157	rfcomm_tty_driver->flags	= TTY_DRIVER_REAL_RAW | TTY_DRIVER_DYNAMIC_DEV;
1158	rfcomm_tty_driver->init_termios	= tty_std_termios;
1159	rfcomm_tty_driver->init_termios.c_cflag	= B9600 | CS8 | CREAD | HUPCL | CLOCAL;
1160	rfcomm_tty_driver->init_termios.c_lflag &= ~ICANON;
1161	tty_set_operations(rfcomm_tty_driver, &rfcomm_ops);
1162
1163	error = tty_register_driver(rfcomm_tty_driver);
1164	if (error) {
1165		BT_ERR("Can't register RFCOMM TTY driver");
1166		put_tty_driver(rfcomm_tty_driver);
1167		return error;
1168	}
1169
1170	BT_INFO("RFCOMM TTY layer initialized");
1171
1172	return 0;
1173}
1174
1175void rfcomm_cleanup_ttys(void)
1176{
1177	tty_unregister_driver(rfcomm_tty_driver);
1178	put_tty_driver(rfcomm_tty_driver);
1179}
v3.1
   1/*
   2   RFCOMM implementation for Linux Bluetooth stack (BlueZ).
   3   Copyright (C) 2002 Maxim Krasnyansky <maxk@qualcomm.com>
   4   Copyright (C) 2002 Marcel Holtmann <marcel@holtmann.org>
   5
   6   This program is free software; you can redistribute it and/or modify
   7   it under the terms of the GNU General Public License version 2 as
   8   published by the Free Software Foundation;
   9
  10   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
  11   OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  12   FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
  13   IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
  14   CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
  15   WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  16   ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  17   OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  18
  19   ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
  20   COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
  21   SOFTWARE IS DISCLAIMED.
  22*/
  23
  24/*
  25 * RFCOMM TTY.
  26 */
  27
  28#include <linux/module.h>
  29
  30#include <linux/tty.h>
  31#include <linux/tty_driver.h>
  32#include <linux/tty_flip.h>
  33
  34#include <linux/capability.h>
  35#include <linux/slab.h>
  36#include <linux/skbuff.h>
 
  37
  38#include <net/bluetooth/bluetooth.h>
  39#include <net/bluetooth/hci_core.h>
  40#include <net/bluetooth/rfcomm.h>
  41
  42#define RFCOMM_TTY_MAGIC 0x6d02		/* magic number for rfcomm struct */
  43#define RFCOMM_TTY_PORTS RFCOMM_MAX_DEV	/* whole lotta rfcomm devices */
  44#define RFCOMM_TTY_MAJOR 216		/* device node major id of the usb/bluetooth.c driver */
  45#define RFCOMM_TTY_MINOR 0
  46
  47static struct tty_driver *rfcomm_tty_driver;
  48
  49struct rfcomm_dev {
 
  50	struct list_head	list;
  51	atomic_t		refcnt;
  52
  53	char			name[12];
  54	int			id;
  55	unsigned long		flags;
  56	atomic_t		opened;
  57	int			err;
  58
  59	bdaddr_t		src;
  60	bdaddr_t		dst;
  61	u8			channel;
  62
  63	uint			modem_status;
  64
  65	struct rfcomm_dlc	*dlc;
  66	struct tty_struct	*tty;
  67	wait_queue_head_t       wait;
  68	struct tasklet_struct   wakeup_task;
  69
  70	struct device		*tty_dev;
  71
  72	atomic_t		wmem_alloc;
  73
  74	struct sk_buff_head	pending;
  75};
  76
  77static LIST_HEAD(rfcomm_dev_list);
  78static DEFINE_RWLOCK(rfcomm_dev_lock);
  79
  80static void rfcomm_dev_data_ready(struct rfcomm_dlc *dlc, struct sk_buff *skb);
  81static void rfcomm_dev_state_change(struct rfcomm_dlc *dlc, int err);
  82static void rfcomm_dev_modem_status(struct rfcomm_dlc *dlc, u8 v24_sig);
  83
  84static void rfcomm_tty_wakeup(unsigned long arg);
  85
  86/* ---- Device functions ---- */
  87static void rfcomm_dev_destruct(struct rfcomm_dev *dev)
 
 
 
 
 
 
  88{
 
  89	struct rfcomm_dlc *dlc = dev->dlc;
  90
  91	BT_DBG("dev %p dlc %p", dev, dlc);
  92
  93	/* Refcount should only hit zero when called from rfcomm_dev_del()
  94	   which will have taken us off the list. Everything else are
  95	   refcounting bugs. */
  96	BUG_ON(!list_empty(&dev->list));
  97
  98	rfcomm_dlc_lock(dlc);
  99	/* Detach DLC if it's owned by this dev */
 100	if (dlc->owner == dev)
 101		dlc->owner = NULL;
 102	rfcomm_dlc_unlock(dlc);
 103
 104	rfcomm_dlc_put(dlc);
 105
 106	tty_unregister_device(rfcomm_tty_driver, dev->id);
 107
 108	kfree(dev);
 109
 110	/* It's safe to call module_put() here because socket still
 111	   holds reference to this module. */
 112	module_put(THIS_MODULE);
 113}
 114
 115static inline void rfcomm_dev_hold(struct rfcomm_dev *dev)
 116{
 117	atomic_inc(&dev->refcnt);
 118}
 119
 120static inline void rfcomm_dev_put(struct rfcomm_dev *dev)
 121{
 122	/* The reason this isn't actually a race, as you no
 123	   doubt have a little voice screaming at you in your
 124	   head, is that the refcount should never actually
 125	   reach zero unless the device has already been taken
 126	   off the list, in rfcomm_dev_del(). And if that's not
 127	   true, we'll hit the BUG() in rfcomm_dev_destruct()
 128	   anyway. */
 129	if (atomic_dec_and_test(&dev->refcnt))
 130		rfcomm_dev_destruct(dev);
 131}
 132
 133static struct rfcomm_dev *__rfcomm_dev_get(int id)
 134{
 135	struct rfcomm_dev *dev;
 136	struct list_head  *p;
 137
 138	list_for_each(p, &rfcomm_dev_list) {
 139		dev = list_entry(p, struct rfcomm_dev, list);
 140		if (dev->id == id)
 141			return dev;
 142	}
 143
 144	return NULL;
 145}
 146
 147static inline struct rfcomm_dev *rfcomm_dev_get(int id)
 148{
 149	struct rfcomm_dev *dev;
 150
 151	read_lock(&rfcomm_dev_lock);
 152
 153	dev = __rfcomm_dev_get(id);
 154
 155	if (dev) {
 156		if (test_bit(RFCOMM_TTY_RELEASED, &dev->flags))
 157			dev = NULL;
 158		else
 159			rfcomm_dev_hold(dev);
 160	}
 161
 162	read_unlock(&rfcomm_dev_lock);
 163
 164	return dev;
 165}
 166
 167static struct device *rfcomm_get_device(struct rfcomm_dev *dev)
 168{
 169	struct hci_dev *hdev;
 170	struct hci_conn *conn;
 171
 172	hdev = hci_get_route(&dev->dst, &dev->src);
 173	if (!hdev)
 174		return NULL;
 175
 176	conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, &dev->dst);
 177
 178	hci_dev_put(hdev);
 179
 180	return conn ? &conn->dev : NULL;
 181}
 182
 183static ssize_t show_address(struct device *tty_dev, struct device_attribute *attr, char *buf)
 184{
 185	struct rfcomm_dev *dev = dev_get_drvdata(tty_dev);
 186	return sprintf(buf, "%s\n", batostr(&dev->dst));
 187}
 188
 189static ssize_t show_channel(struct device *tty_dev, struct device_attribute *attr, char *buf)
 190{
 191	struct rfcomm_dev *dev = dev_get_drvdata(tty_dev);
 192	return sprintf(buf, "%d\n", dev->channel);
 193}
 194
 195static DEVICE_ATTR(address, S_IRUGO, show_address, NULL);
 196static DEVICE_ATTR(channel, S_IRUGO, show_channel, NULL);
 197
 198static int rfcomm_dev_add(struct rfcomm_dev_req *req, struct rfcomm_dlc *dlc)
 199{
 200	struct rfcomm_dev *dev;
 201	struct list_head *head = &rfcomm_dev_list, *p;
 202	int err = 0;
 203
 204	BT_DBG("id %d channel %d", req->dev_id, req->channel);
 205
 206	dev = kzalloc(sizeof(struct rfcomm_dev), GFP_KERNEL);
 207	if (!dev)
 208		return -ENOMEM;
 209
 210	write_lock_bh(&rfcomm_dev_lock);
 211
 212	if (req->dev_id < 0) {
 213		dev->id = 0;
 214
 215		list_for_each(p, &rfcomm_dev_list) {
 216			if (list_entry(p, struct rfcomm_dev, list)->id != dev->id)
 217				break;
 218
 219			dev->id++;
 220			head = p;
 221		}
 222	} else {
 223		dev->id = req->dev_id;
 224
 225		list_for_each(p, &rfcomm_dev_list) {
 226			struct rfcomm_dev *entry = list_entry(p, struct rfcomm_dev, list);
 227
 228			if (entry->id == dev->id) {
 229				err = -EADDRINUSE;
 230				goto out;
 231			}
 232
 233			if (entry->id > dev->id - 1)
 234				break;
 235
 236			head = p;
 237		}
 238	}
 239
 240	if ((dev->id < 0) || (dev->id > RFCOMM_MAX_DEV - 1)) {
 241		err = -ENFILE;
 242		goto out;
 243	}
 244
 245	sprintf(dev->name, "rfcomm%d", dev->id);
 246
 247	list_add(&dev->list, head);
 248	atomic_set(&dev->refcnt, 1);
 249
 250	bacpy(&dev->src, &req->src);
 251	bacpy(&dev->dst, &req->dst);
 252	dev->channel = req->channel;
 253
 254	dev->flags = req->flags &
 255		((1 << RFCOMM_RELEASE_ONHUP) | (1 << RFCOMM_REUSE_DLC));
 256
 257	atomic_set(&dev->opened, 0);
 258
 259	init_waitqueue_head(&dev->wait);
 260	tasklet_init(&dev->wakeup_task, rfcomm_tty_wakeup, (unsigned long) dev);
 261
 262	skb_queue_head_init(&dev->pending);
 263
 264	rfcomm_dlc_lock(dlc);
 265
 266	if (req->flags & (1 << RFCOMM_REUSE_DLC)) {
 267		struct sock *sk = dlc->owner;
 268		struct sk_buff *skb;
 269
 270		BUG_ON(!sk);
 271
 272		rfcomm_dlc_throttle(dlc);
 273
 274		while ((skb = skb_dequeue(&sk->sk_receive_queue))) {
 275			skb_orphan(skb);
 276			skb_queue_tail(&dev->pending, skb);
 277			atomic_sub(skb->len, &sk->sk_rmem_alloc);
 278		}
 279	}
 280
 281	dlc->data_ready   = rfcomm_dev_data_ready;
 282	dlc->state_change = rfcomm_dev_state_change;
 283	dlc->modem_status = rfcomm_dev_modem_status;
 284
 285	dlc->owner = dev;
 286	dev->dlc   = dlc;
 287
 288	rfcomm_dev_modem_status(dlc, dlc->remote_v24_sig);
 289
 290	rfcomm_dlc_unlock(dlc);
 291
 292	/* It's safe to call __module_get() here because socket already
 293	   holds reference to this module. */
 294	__module_get(THIS_MODULE);
 295
 296out:
 297	write_unlock_bh(&rfcomm_dev_lock);
 298
 299	if (err < 0)
 300		goto free;
 301
 302	dev->tty_dev = tty_register_device(rfcomm_tty_driver, dev->id, NULL);
 303
 304	if (IS_ERR(dev->tty_dev)) {
 305		err = PTR_ERR(dev->tty_dev);
 306		list_del(&dev->list);
 307		goto free;
 308	}
 309
 310	dev_set_drvdata(dev->tty_dev, dev);
 311
 312	if (device_create_file(dev->tty_dev, &dev_attr_address) < 0)
 313		BT_ERR("Failed to create address attribute");
 314
 315	if (device_create_file(dev->tty_dev, &dev_attr_channel) < 0)
 316		BT_ERR("Failed to create channel attribute");
 317
 318	return dev->id;
 319
 320free:
 321	kfree(dev);
 322	return err;
 323}
 324
 325static void rfcomm_dev_del(struct rfcomm_dev *dev)
 326{
 
 327	BT_DBG("dev %p", dev);
 328
 329	BUG_ON(test_and_set_bit(RFCOMM_TTY_RELEASED, &dev->flags));
 330
 331	if (atomic_read(&dev->opened) > 0)
 
 
 332		return;
 
 
 333
 334	write_lock_bh(&rfcomm_dev_lock);
 335	list_del_init(&dev->list);
 336	write_unlock_bh(&rfcomm_dev_lock);
 337
 338	rfcomm_dev_put(dev);
 339}
 340
 341/* ---- Send buffer ---- */
 342static inline unsigned int rfcomm_room(struct rfcomm_dlc *dlc)
 343{
 344	/* We can't let it be zero, because we don't get a callback
 345	   when tx_credits becomes nonzero, hence we'd never wake up */
 346	return dlc->mtu * (dlc->tx_credits?:1);
 347}
 348
 349static void rfcomm_wfree(struct sk_buff *skb)
 350{
 351	struct rfcomm_dev *dev = (void *) skb->sk;
 
 352	atomic_sub(skb->truesize, &dev->wmem_alloc);
 353	if (test_bit(RFCOMM_TTY_ATTACHED, &dev->flags))
 354		tasklet_schedule(&dev->wakeup_task);
 355	rfcomm_dev_put(dev);
 356}
 357
 358static inline void rfcomm_set_owner_w(struct sk_buff *skb, struct rfcomm_dev *dev)
 359{
 360	rfcomm_dev_hold(dev);
 361	atomic_add(skb->truesize, &dev->wmem_alloc);
 362	skb->sk = (void *) dev;
 363	skb->destructor = rfcomm_wfree;
 364}
 365
 366static struct sk_buff *rfcomm_wmalloc(struct rfcomm_dev *dev, unsigned long size, gfp_t priority)
 367{
 368	if (atomic_read(&dev->wmem_alloc) < rfcomm_room(dev->dlc)) {
 369		struct sk_buff *skb = alloc_skb(size, priority);
 370		if (skb) {
 371			rfcomm_set_owner_w(skb, dev);
 372			return skb;
 373		}
 374	}
 375	return NULL;
 376}
 377
 378/* ---- Device IOCTLs ---- */
 379
 380#define NOCAP_FLAGS ((1 << RFCOMM_REUSE_DLC) | (1 << RFCOMM_RELEASE_ONHUP))
 381
 382static int rfcomm_create_dev(struct sock *sk, void __user *arg)
 383{
 384	struct rfcomm_dev_req req;
 385	struct rfcomm_dlc *dlc;
 386	int id;
 387
 388	if (copy_from_user(&req, arg, sizeof(req)))
 389		return -EFAULT;
 390
 391	BT_DBG("sk %p dev_id %d flags 0x%x", sk, req.dev_id, req.flags);
 392
 393	if (req.flags != NOCAP_FLAGS && !capable(CAP_NET_ADMIN))
 394		return -EPERM;
 395
 396	if (req.flags & (1 << RFCOMM_REUSE_DLC)) {
 397		/* Socket must be connected */
 398		if (sk->sk_state != BT_CONNECTED)
 399			return -EBADFD;
 400
 401		dlc = rfcomm_pi(sk)->dlc;
 402		rfcomm_dlc_hold(dlc);
 403	} else {
 404		dlc = rfcomm_dlc_alloc(GFP_KERNEL);
 405		if (!dlc)
 406			return -ENOMEM;
 407	}
 408
 409	id = rfcomm_dev_add(&req, dlc);
 410	if (id < 0) {
 411		rfcomm_dlc_put(dlc);
 412		return id;
 413	}
 414
 415	if (req.flags & (1 << RFCOMM_REUSE_DLC)) {
 416		/* DLC is now used by device.
 417		 * Socket must be disconnected */
 418		sk->sk_state = BT_CLOSED;
 419	}
 420
 421	return id;
 422}
 423
 424static int rfcomm_release_dev(void __user *arg)
 425{
 426	struct rfcomm_dev_req req;
 427	struct rfcomm_dev *dev;
 428
 429	if (copy_from_user(&req, arg, sizeof(req)))
 430		return -EFAULT;
 431
 432	BT_DBG("dev_id %d flags 0x%x", req.dev_id, req.flags);
 433
 434	dev = rfcomm_dev_get(req.dev_id);
 435	if (!dev)
 436		return -ENODEV;
 437
 438	if (dev->flags != NOCAP_FLAGS && !capable(CAP_NET_ADMIN)) {
 439		rfcomm_dev_put(dev);
 440		return -EPERM;
 441	}
 442
 443	if (req.flags & (1 << RFCOMM_HANGUP_NOW))
 444		rfcomm_dlc_close(dev->dlc, 0);
 445
 446	/* Shut down TTY synchronously before freeing rfcomm_dev */
 447	if (dev->tty)
 448		tty_vhangup(dev->tty);
 449
 450	if (!test_bit(RFCOMM_RELEASE_ONHUP, &dev->flags))
 451		rfcomm_dev_del(dev);
 452	rfcomm_dev_put(dev);
 453	return 0;
 454}
 455
 456static int rfcomm_get_dev_list(void __user *arg)
 457{
 
 458	struct rfcomm_dev_list_req *dl;
 459	struct rfcomm_dev_info *di;
 460	struct list_head *p;
 461	int n = 0, size, err;
 462	u16 dev_num;
 463
 464	BT_DBG("");
 465
 466	if (get_user(dev_num, (u16 __user *) arg))
 467		return -EFAULT;
 468
 469	if (!dev_num || dev_num > (PAGE_SIZE * 4) / sizeof(*di))
 470		return -EINVAL;
 471
 472	size = sizeof(*dl) + dev_num * sizeof(*di);
 473
 474	dl = kmalloc(size, GFP_KERNEL);
 475	if (!dl)
 476		return -ENOMEM;
 477
 478	di = dl->dev_info;
 479
 480	read_lock_bh(&rfcomm_dev_lock);
 481
 482	list_for_each(p, &rfcomm_dev_list) {
 483		struct rfcomm_dev *dev = list_entry(p, struct rfcomm_dev, list);
 484		if (test_bit(RFCOMM_TTY_RELEASED, &dev->flags))
 485			continue;
 486		(di + n)->id      = dev->id;
 487		(di + n)->flags   = dev->flags;
 488		(di + n)->state   = dev->dlc->state;
 489		(di + n)->channel = dev->channel;
 490		bacpy(&(di + n)->src, &dev->src);
 491		bacpy(&(di + n)->dst, &dev->dst);
 492		if (++n >= dev_num)
 493			break;
 494	}
 495
 496	read_unlock_bh(&rfcomm_dev_lock);
 497
 498	dl->dev_num = n;
 499	size = sizeof(*dl) + n * sizeof(*di);
 500
 501	err = copy_to_user(arg, dl, size);
 502	kfree(dl);
 503
 504	return err ? -EFAULT : 0;
 505}
 506
 507static int rfcomm_get_dev_info(void __user *arg)
 508{
 509	struct rfcomm_dev *dev;
 510	struct rfcomm_dev_info di;
 511	int err = 0;
 512
 513	BT_DBG("");
 514
 515	if (copy_from_user(&di, arg, sizeof(di)))
 516		return -EFAULT;
 517
 518	dev = rfcomm_dev_get(di.id);
 519	if (!dev)
 520		return -ENODEV;
 521
 522	di.flags   = dev->flags;
 523	di.channel = dev->channel;
 524	di.state   = dev->dlc->state;
 525	bacpy(&di.src, &dev->src);
 526	bacpy(&di.dst, &dev->dst);
 527
 528	if (copy_to_user(arg, &di, sizeof(di)))
 529		err = -EFAULT;
 530
 531	rfcomm_dev_put(dev);
 532	return err;
 533}
 534
 535int rfcomm_dev_ioctl(struct sock *sk, unsigned int cmd, void __user *arg)
 536{
 537	BT_DBG("cmd %d arg %p", cmd, arg);
 538
 539	switch (cmd) {
 540	case RFCOMMCREATEDEV:
 541		return rfcomm_create_dev(sk, arg);
 542
 543	case RFCOMMRELEASEDEV:
 544		return rfcomm_release_dev(arg);
 545
 546	case RFCOMMGETDEVLIST:
 547		return rfcomm_get_dev_list(arg);
 548
 549	case RFCOMMGETDEVINFO:
 550		return rfcomm_get_dev_info(arg);
 551	}
 552
 553	return -EINVAL;
 554}
 555
 556/* ---- DLC callbacks ---- */
 557static void rfcomm_dev_data_ready(struct rfcomm_dlc *dlc, struct sk_buff *skb)
 558{
 559	struct rfcomm_dev *dev = dlc->owner;
 560	struct tty_struct *tty;
 561
 562	if (!dev) {
 563		kfree_skb(skb);
 564		return;
 565	}
 566
 567	tty = dev->tty;
 568	if (!tty || !skb_queue_empty(&dev->pending)) {
 569		skb_queue_tail(&dev->pending, skb);
 570		return;
 571	}
 572
 573	BT_DBG("dlc %p tty %p len %d", dlc, tty, skb->len);
 574
 575	tty_insert_flip_string(tty, skb->data, skb->len);
 576	tty_flip_buffer_push(tty);
 577
 578	kfree_skb(skb);
 579}
 580
 581static void rfcomm_dev_state_change(struct rfcomm_dlc *dlc, int err)
 582{
 583	struct rfcomm_dev *dev = dlc->owner;
 584	if (!dev)
 585		return;
 586
 587	BT_DBG("dlc %p dev %p err %d", dlc, dev, err);
 588
 589	dev->err = err;
 590	wake_up_interruptible(&dev->wait);
 591
 592	if (dlc->state == BT_CLOSED) {
 593		if (!dev->tty) {
 594			if (test_bit(RFCOMM_RELEASE_ONHUP, &dev->flags)) {
 595				/* Drop DLC lock here to avoid deadlock
 596				 * 1. rfcomm_dev_get will take rfcomm_dev_lock
 597				 *    but in rfcomm_dev_add there's lock order:
 598				 *    rfcomm_dev_lock -> dlc lock
 599				 * 2. rfcomm_dev_put will deadlock if it's
 600				 *    the last reference
 601				 */
 602				rfcomm_dlc_unlock(dlc);
 603				if (rfcomm_dev_get(dev->id) == NULL) {
 604					rfcomm_dlc_lock(dlc);
 605					return;
 606				}
 607
 608				rfcomm_dev_del(dev);
 609				rfcomm_dev_put(dev);
 610				rfcomm_dlc_lock(dlc);
 611			}
 612		} else
 613			tty_hangup(dev->tty);
 614	}
 615}
 616
 617static void rfcomm_dev_modem_status(struct rfcomm_dlc *dlc, u8 v24_sig)
 618{
 619	struct rfcomm_dev *dev = dlc->owner;
 620	if (!dev)
 621		return;
 622
 623	BT_DBG("dlc %p dev %p v24_sig 0x%02x", dlc, dev, v24_sig);
 624
 625	if ((dev->modem_status & TIOCM_CD) && !(v24_sig & RFCOMM_V24_DV)) {
 626		if (dev->tty && !C_CLOCAL(dev->tty))
 627			tty_hangup(dev->tty);
 628	}
 629
 630	dev->modem_status =
 631		((v24_sig & RFCOMM_V24_RTC) ? (TIOCM_DSR | TIOCM_DTR) : 0) |
 632		((v24_sig & RFCOMM_V24_RTR) ? (TIOCM_RTS | TIOCM_CTS) : 0) |
 633		((v24_sig & RFCOMM_V24_IC)  ? TIOCM_RI : 0) |
 634		((v24_sig & RFCOMM_V24_DV)  ? TIOCM_CD : 0);
 635}
 636
 637/* ---- TTY functions ---- */
 638static void rfcomm_tty_wakeup(unsigned long arg)
 639{
 640	struct rfcomm_dev *dev = (void *) arg;
 641	struct tty_struct *tty = dev->tty;
 642	if (!tty)
 643		return;
 644
 645	BT_DBG("dev %p tty %p", dev, tty);
 646	tty_wakeup(tty);
 647}
 648
 649static void rfcomm_tty_copy_pending(struct rfcomm_dev *dev)
 650{
 651	struct tty_struct *tty = dev->tty;
 652	struct sk_buff *skb;
 653	int inserted = 0;
 654
 655	if (!tty)
 656		return;
 657
 658	BT_DBG("dev %p tty %p", dev, tty);
 659
 660	rfcomm_dlc_lock(dev->dlc);
 661
 662	while ((skb = skb_dequeue(&dev->pending))) {
 663		inserted += tty_insert_flip_string(tty, skb->data, skb->len);
 664		kfree_skb(skb);
 665	}
 666
 667	rfcomm_dlc_unlock(dev->dlc);
 668
 669	if (inserted > 0)
 670		tty_flip_buffer_push(tty);
 671}
 672
 673static int rfcomm_tty_open(struct tty_struct *tty, struct file *filp)
 674{
 675	DECLARE_WAITQUEUE(wait, current);
 676	struct rfcomm_dev *dev;
 677	struct rfcomm_dlc *dlc;
 
 678	int err, id;
 679
 680	id = tty->index;
 681
 682	BT_DBG("tty %p id %d", tty, id);
 683
 684	/* We don't leak this refcount. For reasons which are not entirely
 685	   clear, the TTY layer will call our ->close() method even if the
 686	   open fails. We decrease the refcount there, and decreasing it
 687	   here too would cause breakage. */
 688	dev = rfcomm_dev_get(id);
 689	if (!dev)
 690		return -ENODEV;
 691
 692	BT_DBG("dev %p dst %s channel %d opened %d", dev, batostr(&dev->dst),
 693				dev->channel, atomic_read(&dev->opened));
 694
 695	if (atomic_inc_return(&dev->opened) > 1)
 
 
 696		return 0;
 
 
 697
 698	dlc = dev->dlc;
 699
 700	/* Attach TTY and open DLC */
 701
 702	rfcomm_dlc_lock(dlc);
 703	tty->driver_data = dev;
 704	dev->tty = tty;
 705	rfcomm_dlc_unlock(dlc);
 706	set_bit(RFCOMM_TTY_ATTACHED, &dev->flags);
 707
 708	err = rfcomm_dlc_open(dlc, &dev->src, &dev->dst, dev->channel);
 709	if (err < 0)
 710		return err;
 711
 712	/* Wait for DLC to connect */
 713	add_wait_queue(&dev->wait, &wait);
 714	while (1) {
 715		set_current_state(TASK_INTERRUPTIBLE);
 716
 717		if (dlc->state == BT_CLOSED) {
 718			err = -dev->err;
 719			break;
 720		}
 721
 722		if (dlc->state == BT_CONNECTED)
 723			break;
 724
 725		if (signal_pending(current)) {
 726			err = -EINTR;
 727			break;
 728		}
 729
 730		tty_unlock();
 731		schedule();
 732		tty_lock();
 733	}
 734	set_current_state(TASK_RUNNING);
 735	remove_wait_queue(&dev->wait, &wait);
 736
 737	if (err == 0)
 738		device_move(dev->tty_dev, rfcomm_get_device(dev),
 739			    DPM_ORDER_DEV_AFTER_PARENT);
 740
 741	rfcomm_tty_copy_pending(dev);
 742
 743	rfcomm_dlc_unthrottle(dev->dlc);
 744
 745	return err;
 746}
 747
 748static void rfcomm_tty_close(struct tty_struct *tty, struct file *filp)
 749{
 750	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 
 
 751	if (!dev)
 752		return;
 753
 754	BT_DBG("tty %p dev %p dlc %p opened %d", tty, dev, dev->dlc,
 755						atomic_read(&dev->opened));
 756
 757	if (atomic_dec_and_test(&dev->opened)) {
 
 
 758		if (dev->tty_dev->parent)
 759			device_move(dev->tty_dev, NULL, DPM_ORDER_DEV_LAST);
 760
 761		/* Close DLC and dettach TTY */
 762		rfcomm_dlc_close(dev->dlc, 0);
 763
 764		clear_bit(RFCOMM_TTY_ATTACHED, &dev->flags);
 765		tasklet_kill(&dev->wakeup_task);
 766
 767		rfcomm_dlc_lock(dev->dlc);
 768		tty->driver_data = NULL;
 769		dev->tty = NULL;
 770		rfcomm_dlc_unlock(dev->dlc);
 771
 772		if (test_bit(RFCOMM_TTY_RELEASED, &dev->flags)) {
 773			write_lock_bh(&rfcomm_dev_lock);
 774			list_del_init(&dev->list);
 775			write_unlock_bh(&rfcomm_dev_lock);
 776
 777			rfcomm_dev_put(dev);
 778		}
 779	}
 
 780
 781	rfcomm_dev_put(dev);
 782}
 783
 784static int rfcomm_tty_write(struct tty_struct *tty, const unsigned char *buf, int count)
 785{
 786	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 787	struct rfcomm_dlc *dlc = dev->dlc;
 788	struct sk_buff *skb;
 789	int err = 0, sent = 0, size;
 790
 791	BT_DBG("tty %p count %d", tty, count);
 792
 793	while (count) {
 794		size = min_t(uint, count, dlc->mtu);
 795
 796		skb = rfcomm_wmalloc(dev, size + RFCOMM_SKB_RESERVE, GFP_ATOMIC);
 797
 798		if (!skb)
 799			break;
 800
 801		skb_reserve(skb, RFCOMM_SKB_HEAD_RESERVE);
 802
 803		memcpy(skb_put(skb, size), buf + sent, size);
 804
 805		err = rfcomm_dlc_send(dlc, skb);
 806		if (err < 0) {
 807			kfree_skb(skb);
 808			break;
 809		}
 810
 811		sent  += size;
 812		count -= size;
 813	}
 814
 815	return sent ? sent : err;
 816}
 817
 818static int rfcomm_tty_write_room(struct tty_struct *tty)
 819{
 820	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 821	int room;
 822
 823	BT_DBG("tty %p", tty);
 824
 825	if (!dev || !dev->dlc)
 826		return 0;
 827
 828	room = rfcomm_room(dev->dlc) - atomic_read(&dev->wmem_alloc);
 829	if (room < 0)
 830		room = 0;
 831
 832	return room;
 833}
 834
 835static int rfcomm_tty_ioctl(struct tty_struct *tty, unsigned int cmd, unsigned long arg)
 836{
 837	BT_DBG("tty %p cmd 0x%02x", tty, cmd);
 838
 839	switch (cmd) {
 840	case TCGETS:
 841		BT_DBG("TCGETS is not supported");
 842		return -ENOIOCTLCMD;
 843
 844	case TCSETS:
 845		BT_DBG("TCSETS is not supported");
 846		return -ENOIOCTLCMD;
 847
 848	case TIOCMIWAIT:
 849		BT_DBG("TIOCMIWAIT");
 850		break;
 851
 852	case TIOCGSERIAL:
 853		BT_ERR("TIOCGSERIAL is not supported");
 854		return -ENOIOCTLCMD;
 855
 856	case TIOCSSERIAL:
 857		BT_ERR("TIOCSSERIAL is not supported");
 858		return -ENOIOCTLCMD;
 859
 860	case TIOCSERGSTRUCT:
 861		BT_ERR("TIOCSERGSTRUCT is not supported");
 862		return -ENOIOCTLCMD;
 863
 864	case TIOCSERGETLSR:
 865		BT_ERR("TIOCSERGETLSR is not supported");
 866		return -ENOIOCTLCMD;
 867
 868	case TIOCSERCONFIG:
 869		BT_ERR("TIOCSERCONFIG is not supported");
 870		return -ENOIOCTLCMD;
 871
 872	default:
 873		return -ENOIOCTLCMD;	/* ioctls which we must ignore */
 874
 875	}
 876
 877	return -ENOIOCTLCMD;
 878}
 879
 880static void rfcomm_tty_set_termios(struct tty_struct *tty, struct ktermios *old)
 881{
 882	struct ktermios *new = tty->termios;
 883	int old_baud_rate = tty_termios_baud_rate(old);
 884	int new_baud_rate = tty_termios_baud_rate(new);
 885
 886	u8 baud, data_bits, stop_bits, parity, x_on, x_off;
 887	u16 changes = 0;
 888
 889	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
 890
 891	BT_DBG("tty %p termios %p", tty, old);
 892
 893	if (!dev || !dev->dlc || !dev->dlc->session)
 894		return;
 895
 896	/* Handle turning off CRTSCTS */
 897	if ((old->c_cflag & CRTSCTS) && !(new->c_cflag & CRTSCTS))
 898		BT_DBG("Turning off CRTSCTS unsupported");
 899
 900	/* Parity on/off and when on, odd/even */
 901	if (((old->c_cflag & PARENB) != (new->c_cflag & PARENB)) ||
 902			((old->c_cflag & PARODD) != (new->c_cflag & PARODD))) {
 903		changes |= RFCOMM_RPN_PM_PARITY;
 904		BT_DBG("Parity change detected.");
 905	}
 906
 907	/* Mark and space parity are not supported! */
 908	if (new->c_cflag & PARENB) {
 909		if (new->c_cflag & PARODD) {
 910			BT_DBG("Parity is ODD");
 911			parity = RFCOMM_RPN_PARITY_ODD;
 912		} else {
 913			BT_DBG("Parity is EVEN");
 914			parity = RFCOMM_RPN_PARITY_EVEN;
 915		}
 916	} else {
 917		BT_DBG("Parity is OFF");
 918		parity = RFCOMM_RPN_PARITY_NONE;
 919	}
 920
 921	/* Setting the x_on / x_off characters */
 922	if (old->c_cc[VSTOP] != new->c_cc[VSTOP]) {
 923		BT_DBG("XOFF custom");
 924		x_on = new->c_cc[VSTOP];
 925		changes |= RFCOMM_RPN_PM_XON;
 926	} else {
 927		BT_DBG("XOFF default");
 928		x_on = RFCOMM_RPN_XON_CHAR;
 929	}
 930
 931	if (old->c_cc[VSTART] != new->c_cc[VSTART]) {
 932		BT_DBG("XON custom");
 933		x_off = new->c_cc[VSTART];
 934		changes |= RFCOMM_RPN_PM_XOFF;
 935	} else {
 936		BT_DBG("XON default");
 937		x_off = RFCOMM_RPN_XOFF_CHAR;
 938	}
 939
 940	/* Handle setting of stop bits */
 941	if ((old->c_cflag & CSTOPB) != (new->c_cflag & CSTOPB))
 942		changes |= RFCOMM_RPN_PM_STOP;
 943
 944	/* POSIX does not support 1.5 stop bits and RFCOMM does not
 945	 * support 2 stop bits. So a request for 2 stop bits gets
 946	 * translated to 1.5 stop bits */
 947	if (new->c_cflag & CSTOPB)
 948		stop_bits = RFCOMM_RPN_STOP_15;
 949	else
 950		stop_bits = RFCOMM_RPN_STOP_1;
 951
 952	/* Handle number of data bits [5-8] */
 953	if ((old->c_cflag & CSIZE) != (new->c_cflag & CSIZE))
 954		changes |= RFCOMM_RPN_PM_DATA;
 955
 956	switch (new->c_cflag & CSIZE) {
 957	case CS5:
 958		data_bits = RFCOMM_RPN_DATA_5;
 959		break;
 960	case CS6:
 961		data_bits = RFCOMM_RPN_DATA_6;
 962		break;
 963	case CS7:
 964		data_bits = RFCOMM_RPN_DATA_7;
 965		break;
 966	case CS8:
 967		data_bits = RFCOMM_RPN_DATA_8;
 968		break;
 969	default:
 970		data_bits = RFCOMM_RPN_DATA_8;
 971		break;
 972	}
 973
 974	/* Handle baudrate settings */
 975	if (old_baud_rate != new_baud_rate)
 976		changes |= RFCOMM_RPN_PM_BITRATE;
 977
 978	switch (new_baud_rate) {
 979	case 2400:
 980		baud = RFCOMM_RPN_BR_2400;
 981		break;
 982	case 4800:
 983		baud = RFCOMM_RPN_BR_4800;
 984		break;
 985	case 7200:
 986		baud = RFCOMM_RPN_BR_7200;
 987		break;
 988	case 9600:
 989		baud = RFCOMM_RPN_BR_9600;
 990		break;
 991	case 19200:
 992		baud = RFCOMM_RPN_BR_19200;
 993		break;
 994	case 38400:
 995		baud = RFCOMM_RPN_BR_38400;
 996		break;
 997	case 57600:
 998		baud = RFCOMM_RPN_BR_57600;
 999		break;
1000	case 115200:
1001		baud = RFCOMM_RPN_BR_115200;
1002		break;
1003	case 230400:
1004		baud = RFCOMM_RPN_BR_230400;
1005		break;
1006	default:
1007		/* 9600 is standard accordinag to the RFCOMM specification */
1008		baud = RFCOMM_RPN_BR_9600;
1009		break;
1010
1011	}
1012
1013	if (changes)
1014		rfcomm_send_rpn(dev->dlc->session, 1, dev->dlc->dlci, baud,
1015				data_bits, stop_bits, parity,
1016				RFCOMM_RPN_FLOW_NONE, x_on, x_off, changes);
1017}
1018
1019static void rfcomm_tty_throttle(struct tty_struct *tty)
1020{
1021	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1022
1023	BT_DBG("tty %p dev %p", tty, dev);
1024
1025	rfcomm_dlc_throttle(dev->dlc);
1026}
1027
1028static void rfcomm_tty_unthrottle(struct tty_struct *tty)
1029{
1030	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1031
1032	BT_DBG("tty %p dev %p", tty, dev);
1033
1034	rfcomm_dlc_unthrottle(dev->dlc);
1035}
1036
1037static int rfcomm_tty_chars_in_buffer(struct tty_struct *tty)
1038{
1039	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1040
1041	BT_DBG("tty %p dev %p", tty, dev);
1042
1043	if (!dev || !dev->dlc)
1044		return 0;
1045
1046	if (!skb_queue_empty(&dev->dlc->tx_queue))
1047		return dev->dlc->mtu;
1048
1049	return 0;
1050}
1051
1052static void rfcomm_tty_flush_buffer(struct tty_struct *tty)
1053{
1054	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1055
1056	BT_DBG("tty %p dev %p", tty, dev);
1057
1058	if (!dev || !dev->dlc)
1059		return;
1060
1061	skb_queue_purge(&dev->dlc->tx_queue);
1062	tty_wakeup(tty);
1063}
1064
1065static void rfcomm_tty_send_xchar(struct tty_struct *tty, char ch)
1066{
1067	BT_DBG("tty %p ch %c", tty, ch);
1068}
1069
1070static void rfcomm_tty_wait_until_sent(struct tty_struct *tty, int timeout)
1071{
1072	BT_DBG("tty %p timeout %d", tty, timeout);
1073}
1074
1075static void rfcomm_tty_hangup(struct tty_struct *tty)
1076{
1077	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1078
1079	BT_DBG("tty %p dev %p", tty, dev);
1080
1081	if (!dev)
1082		return;
1083
1084	rfcomm_tty_flush_buffer(tty);
1085
1086	if (test_bit(RFCOMM_RELEASE_ONHUP, &dev->flags)) {
1087		if (rfcomm_dev_get(dev->id) == NULL)
1088			return;
1089		rfcomm_dev_del(dev);
1090		rfcomm_dev_put(dev);
1091	}
1092}
1093
1094static int rfcomm_tty_tiocmget(struct tty_struct *tty)
1095{
1096	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1097
1098	BT_DBG("tty %p dev %p", tty, dev);
1099
1100	return dev->modem_status;
1101}
1102
1103static int rfcomm_tty_tiocmset(struct tty_struct *tty, unsigned int set, unsigned int clear)
1104{
1105	struct rfcomm_dev *dev = (struct rfcomm_dev *) tty->driver_data;
1106	struct rfcomm_dlc *dlc = dev->dlc;
1107	u8 v24_sig;
1108
1109	BT_DBG("tty %p dev %p set 0x%02x clear 0x%02x", tty, dev, set, clear);
1110
1111	rfcomm_dlc_get_modem_status(dlc, &v24_sig);
1112
1113	if (set & TIOCM_DSR || set & TIOCM_DTR)
1114		v24_sig |= RFCOMM_V24_RTC;
1115	if (set & TIOCM_RTS || set & TIOCM_CTS)
1116		v24_sig |= RFCOMM_V24_RTR;
1117	if (set & TIOCM_RI)
1118		v24_sig |= RFCOMM_V24_IC;
1119	if (set & TIOCM_CD)
1120		v24_sig |= RFCOMM_V24_DV;
1121
1122	if (clear & TIOCM_DSR || clear & TIOCM_DTR)
1123		v24_sig &= ~RFCOMM_V24_RTC;
1124	if (clear & TIOCM_RTS || clear & TIOCM_CTS)
1125		v24_sig &= ~RFCOMM_V24_RTR;
1126	if (clear & TIOCM_RI)
1127		v24_sig &= ~RFCOMM_V24_IC;
1128	if (clear & TIOCM_CD)
1129		v24_sig &= ~RFCOMM_V24_DV;
1130
1131	rfcomm_dlc_set_modem_status(dlc, v24_sig);
1132
1133	return 0;
1134}
1135
1136/* ---- TTY structure ---- */
1137
1138static const struct tty_operations rfcomm_ops = {
1139	.open			= rfcomm_tty_open,
1140	.close			= rfcomm_tty_close,
1141	.write			= rfcomm_tty_write,
1142	.write_room		= rfcomm_tty_write_room,
1143	.chars_in_buffer	= rfcomm_tty_chars_in_buffer,
1144	.flush_buffer		= rfcomm_tty_flush_buffer,
1145	.ioctl			= rfcomm_tty_ioctl,
1146	.throttle		= rfcomm_tty_throttle,
1147	.unthrottle		= rfcomm_tty_unthrottle,
1148	.set_termios		= rfcomm_tty_set_termios,
1149	.send_xchar		= rfcomm_tty_send_xchar,
1150	.hangup			= rfcomm_tty_hangup,
1151	.wait_until_sent	= rfcomm_tty_wait_until_sent,
1152	.tiocmget		= rfcomm_tty_tiocmget,
1153	.tiocmset		= rfcomm_tty_tiocmset,
1154};
1155
1156int __init rfcomm_init_ttys(void)
1157{
 
 
1158	rfcomm_tty_driver = alloc_tty_driver(RFCOMM_TTY_PORTS);
1159	if (!rfcomm_tty_driver)
1160		return -1;
1161
1162	rfcomm_tty_driver->owner	= THIS_MODULE;
1163	rfcomm_tty_driver->driver_name	= "rfcomm";
1164	rfcomm_tty_driver->name		= "rfcomm";
1165	rfcomm_tty_driver->major	= RFCOMM_TTY_MAJOR;
1166	rfcomm_tty_driver->minor_start	= RFCOMM_TTY_MINOR;
1167	rfcomm_tty_driver->type		= TTY_DRIVER_TYPE_SERIAL;
1168	rfcomm_tty_driver->subtype	= SERIAL_TYPE_NORMAL;
1169	rfcomm_tty_driver->flags	= TTY_DRIVER_REAL_RAW | TTY_DRIVER_DYNAMIC_DEV;
1170	rfcomm_tty_driver->init_termios	= tty_std_termios;
1171	rfcomm_tty_driver->init_termios.c_cflag	= B9600 | CS8 | CREAD | HUPCL | CLOCAL;
1172	rfcomm_tty_driver->init_termios.c_lflag &= ~ICANON;
1173	tty_set_operations(rfcomm_tty_driver, &rfcomm_ops);
1174
1175	if (tty_register_driver(rfcomm_tty_driver)) {
 
1176		BT_ERR("Can't register RFCOMM TTY driver");
1177		put_tty_driver(rfcomm_tty_driver);
1178		return -1;
1179	}
1180
1181	BT_INFO("RFCOMM TTY layer initialized");
1182
1183	return 0;
1184}
1185
1186void rfcomm_cleanup_ttys(void)
1187{
1188	tty_unregister_driver(rfcomm_tty_driver);
1189	put_tty_driver(rfcomm_tty_driver);
1190}