mgmt.c 34.1 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
/*
   BlueZ - Bluetooth protocol stack for Linux
   Copyright (C) 2010  Nokia Corporation

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License version 2 as
   published by the Free Software Foundation;

   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
   OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
   FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
   IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
   CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
   WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
   ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
   OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.

   ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
   COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
   SOFTWARE IS DISCLAIMED.
*/

/* Bluetooth HCI Management interface */

25
#include <linux/uaccess.h>
26 27 28 29 30 31
#include <asm/unaligned.h>

#include <net/bluetooth/bluetooth.h>
#include <net/bluetooth/hci_core.h>
#include <net/bluetooth/mgmt.h>

32 33 34
#define MGMT_VERSION	0
#define MGMT_REVISION	1

35 36 37 38 39 40
struct pending_cmd {
	struct list_head list;
	__u16 opcode;
	int index;
	void *cmd;
	struct sock *sk;
41
	void *user_data;
42 43 44 45
};

LIST_HEAD(cmd_list);

46
static int cmd_status(struct sock *sk, u16 index, u16 cmd, u8 status)
47 48 49 50 51
{
	struct sk_buff *skb;
	struct mgmt_hdr *hdr;
	struct mgmt_ev_cmd_status *ev;

52
	BT_DBG("sock %p, index %u, cmd %u, status %u", sk, index, cmd, status);
53 54 55 56 57 58 59 60

	skb = alloc_skb(sizeof(*hdr) + sizeof(*ev), GFP_ATOMIC);
	if (!skb)
		return -ENOMEM;

	hdr = (void *) skb_put(skb, sizeof(*hdr));

	hdr->opcode = cpu_to_le16(MGMT_EV_CMD_STATUS);
61
	hdr->index = cpu_to_le16(index);
62 63 64 65 66 67 68 69 70 71 72 73
	hdr->len = cpu_to_le16(sizeof(*ev));

	ev = (void *) skb_put(skb, sizeof(*ev));
	ev->status = status;
	put_unaligned_le16(cmd, &ev->opcode);

	if (sock_queue_rcv_skb(sk, skb) < 0)
		kfree_skb(skb);

	return 0;
}

74 75
static int cmd_complete(struct sock *sk, u16 index, u16 cmd, void *rp,
								size_t rp_len)
76 77 78 79 80 81 82
{
	struct sk_buff *skb;
	struct mgmt_hdr *hdr;
	struct mgmt_ev_cmd_complete *ev;

	BT_DBG("sock %p", sk);

83
	skb = alloc_skb(sizeof(*hdr) + sizeof(*ev) + rp_len, GFP_ATOMIC);
84 85 86 87 88
	if (!skb)
		return -ENOMEM;

	hdr = (void *) skb_put(skb, sizeof(*hdr));

89
	hdr->opcode = cpu_to_le16(MGMT_EV_CMD_COMPLETE);
90
	hdr->index = cpu_to_le16(index);
91
	hdr->len = cpu_to_le16(sizeof(*ev) + rp_len);
92

93 94
	ev = (void *) skb_put(skb, sizeof(*ev) + rp_len);
	put_unaligned_le16(cmd, &ev->opcode);
95 96 97

	if (rp)
		memcpy(ev->data, rp, rp_len);
98 99 100 101 102 103 104

	if (sock_queue_rcv_skb(sk, skb) < 0)
		kfree_skb(skb);

	return 0;
}

105 106 107 108 109 110 111 112 113
static int read_version(struct sock *sk)
{
	struct mgmt_rp_read_version rp;

	BT_DBG("sock %p", sk);

	rp.version = MGMT_VERSION;
	put_unaligned_le16(MGMT_REVISION, &rp.revision);

114 115
	return cmd_complete(sk, MGMT_INDEX_NONE, MGMT_OP_READ_VERSION, &rp,
								sizeof(rp));
116 117
}

118 119 120 121
static int read_index_list(struct sock *sk)
{
	struct mgmt_rp_read_index_list *rp;
	struct list_head *p;
122
	size_t rp_len;
123
	u16 count;
124
	int i, err;
125 126 127 128 129 130 131 132 133 134

	BT_DBG("sock %p", sk);

	read_lock(&hci_dev_list_lock);

	count = 0;
	list_for_each(p, &hci_dev_list) {
		count++;
	}

135 136 137
	rp_len = sizeof(*rp) + (2 * count);
	rp = kmalloc(rp_len, GFP_ATOMIC);
	if (!rp) {
138
		read_unlock(&hci_dev_list_lock);
139
		return -ENOMEM;
140
	}
141 142 143 144 145 146

	put_unaligned_le16(count, &rp->num_controllers);

	i = 0;
	list_for_each(p, &hci_dev_list) {
		struct hci_dev *d = list_entry(p, struct hci_dev, list);
147 148 149

		hci_del_off_timer(d);

150 151
		set_bit(HCI_MGMT, &d->flags);

152 153 154
		if (test_bit(HCI_SETUP, &d->flags))
			continue;

155 156 157 158 159 160
		put_unaligned_le16(d->id, &rp->index[i++]);
		BT_DBG("Added hci%u", d->id);
	}

	read_unlock(&hci_dev_list_lock);

161 162
	err = cmd_complete(sk, MGMT_INDEX_NONE, MGMT_OP_READ_INDEX_LIST, rp,
									rp_len);
163

164 165 166
	kfree(rp);

	return err;
167 168
}

169
static int read_controller_info(struct sock *sk, u16 index)
170
{
171
	struct mgmt_rp_read_info rp;
172
	struct hci_dev *hdev;
173

174
	BT_DBG("sock %p hci%u", sk, index);
175

176
	hdev = hci_dev_get(index);
177
	if (!hdev)
178
		return cmd_status(sk, index, MGMT_OP_READ_INFO, ENODEV);
179

180 181
	hci_del_off_timer(hdev);

182 183
	hci_dev_lock_bh(hdev);

184 185
	set_bit(HCI_MGMT, &hdev->flags);

186
	rp.type = hdev->dev_type;
187

188 189 190 191
	rp.powered = test_bit(HCI_UP, &hdev->flags);
	rp.connectable = test_bit(HCI_PSCAN, &hdev->flags);
	rp.discoverable = test_bit(HCI_ISCAN, &hdev->flags);
	rp.pairable = test_bit(HCI_PSCAN, &hdev->flags);
192 193

	if (test_bit(HCI_AUTH, &hdev->flags))
194
		rp.sec_mode = 3;
195
	else if (hdev->ssp_mode > 0)
196
		rp.sec_mode = 4;
197
	else
198
		rp.sec_mode = 2;
199

200 201 202 203 204 205
	bacpy(&rp.bdaddr, &hdev->bdaddr);
	memcpy(rp.features, hdev->features, 8);
	memcpy(rp.dev_class, hdev->dev_class, 3);
	put_unaligned_le16(hdev->manufacturer, &rp.manufacturer);
	rp.hci_ver = hdev->hci_ver;
	put_unaligned_le16(hdev->hci_rev, &rp.hci_rev);
206 207 208

	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);
209

210
	return cmd_complete(sk, index, MGMT_OP_READ_INFO, &rp, sizeof(rp));
211 212
}

213 214 215 216 217 218 219
static void mgmt_pending_free(struct pending_cmd *cmd)
{
	sock_put(cmd->sk);
	kfree(cmd->cmd);
	kfree(cmd);
}

220 221
static struct pending_cmd *mgmt_pending_add(struct sock *sk, u16 opcode,
						u16 index, void *data, u16 len)
222 223 224 225 226
{
	struct pending_cmd *cmd;

	cmd = kmalloc(sizeof(*cmd), GFP_ATOMIC);
	if (!cmd)
227
		return NULL;
228 229 230 231 232 233 234

	cmd->opcode = opcode;
	cmd->index = index;

	cmd->cmd = kmalloc(len, GFP_ATOMIC);
	if (!cmd->cmd) {
		kfree(cmd);
235
		return NULL;
236 237 238 239 240 241 242 243 244
	}

	memcpy(cmd->cmd, data, len);

	cmd->sk = sk;
	sock_hold(sk);

	list_add(&cmd->list, &cmd_list);

245
	return cmd;
246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289
}

static void mgmt_pending_foreach(u16 opcode, int index,
				void (*cb)(struct pending_cmd *cmd, void *data),
				void *data)
{
	struct list_head *p, *n;

	list_for_each_safe(p, n, &cmd_list) {
		struct pending_cmd *cmd;

		cmd = list_entry(p, struct pending_cmd, list);

		if (cmd->opcode != opcode)
			continue;

		if (index >= 0 && cmd->index != index)
			continue;

		cb(cmd, data);
	}
}

static struct pending_cmd *mgmt_pending_find(u16 opcode, int index)
{
	struct list_head *p;

	list_for_each(p, &cmd_list) {
		struct pending_cmd *cmd;

		cmd = list_entry(p, struct pending_cmd, list);

		if (cmd->opcode != opcode)
			continue;

		if (index >= 0 && cmd->index != index)
			continue;

		return cmd;
	}

	return NULL;
}

290
static void mgmt_pending_remove(struct pending_cmd *cmd)
291 292 293 294 295
{
	list_del(&cmd->list);
	mgmt_pending_free(cmd);
}

296
static int set_powered(struct sock *sk, u16 index, unsigned char *data, u16 len)
297
{
298
	struct mgmt_mode *cp;
299
	struct hci_dev *hdev;
300 301
	struct pending_cmd *cmd;
	int err, up;
302 303 304

	cp = (void *) data;

305
	BT_DBG("request for hci%u", index);
306

307 308 309
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_POWERED, EINVAL);

310
	hdev = hci_dev_get(index);
311
	if (!hdev)
312
		return cmd_status(sk, index, MGMT_OP_SET_POWERED, ENODEV);
313 314 315 316

	hci_dev_lock_bh(hdev);

	up = test_bit(HCI_UP, &hdev->flags);
317
	if ((cp->val && up) || (!cp->val && !up)) {
318
		err = cmd_status(sk, index, MGMT_OP_SET_POWERED, EALREADY);
319 320 321
		goto failed;
	}

322 323
	if (mgmt_pending_find(MGMT_OP_SET_POWERED, index)) {
		err = cmd_status(sk, index, MGMT_OP_SET_POWERED, EBUSY);
324 325 326
		goto failed;
	}

327
	cmd = mgmt_pending_add(sk, MGMT_OP_SET_POWERED, index, data, len);
328 329
	if (!cmd) {
		err = -ENOMEM;
330
		goto failed;
331
	}
332

333
	if (cp->val)
334 335 336 337
		queue_work(hdev->workqueue, &hdev->power_on);
	else
		queue_work(hdev->workqueue, &hdev->power_off);

338
	err = 0;
339 340 341 342

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);
343
	return err;
344 345
}

346 347
static int set_discoverable(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
348
{
349
	struct mgmt_mode *cp;
350
	struct hci_dev *hdev;
351
	struct pending_cmd *cmd;
352 353 354 355 356
	u8 scan;
	int err;

	cp = (void *) data;

357
	BT_DBG("request for hci%u", index);
358

359 360 361
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_DISCOVERABLE, EINVAL);

362
	hdev = hci_dev_get(index);
363
	if (!hdev)
364
		return cmd_status(sk, index, MGMT_OP_SET_DISCOVERABLE, ENODEV);
365 366 367 368

	hci_dev_lock_bh(hdev);

	if (!test_bit(HCI_UP, &hdev->flags)) {
369
		err = cmd_status(sk, index, MGMT_OP_SET_DISCOVERABLE, ENETDOWN);
370 371 372
		goto failed;
	}

373 374 375
	if (mgmt_pending_find(MGMT_OP_SET_DISCOVERABLE, index) ||
			mgmt_pending_find(MGMT_OP_SET_CONNECTABLE, index)) {
		err = cmd_status(sk, index, MGMT_OP_SET_DISCOVERABLE, EBUSY);
376 377 378
		goto failed;
	}

379
	if (cp->val == test_bit(HCI_ISCAN, &hdev->flags) &&
380
					test_bit(HCI_PSCAN, &hdev->flags)) {
381
		err = cmd_status(sk, index, MGMT_OP_SET_DISCOVERABLE, EALREADY);
382 383 384
		goto failed;
	}

385
	cmd = mgmt_pending_add(sk, MGMT_OP_SET_DISCOVERABLE, index, data, len);
386 387
	if (!cmd) {
		err = -ENOMEM;
388
		goto failed;
389
	}
390 391 392

	scan = SCAN_PAGE;

393
	if (cp->val)
394 395 396 397
		scan |= SCAN_INQUIRY;

	err = hci_send_cmd(hdev, HCI_OP_WRITE_SCAN_ENABLE, 1, &scan);
	if (err < 0)
398
		mgmt_pending_remove(cmd);
399 400 401 402 403 404 405 406

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

407 408
static int set_connectable(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
409
{
410
	struct mgmt_mode *cp;
411
	struct hci_dev *hdev;
412
	struct pending_cmd *cmd;
413 414 415 416 417
	u8 scan;
	int err;

	cp = (void *) data;

418
	BT_DBG("request for hci%u", index);
419

420 421 422
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_CONNECTABLE, EINVAL);

423
	hdev = hci_dev_get(index);
424
	if (!hdev)
425
		return cmd_status(sk, index, MGMT_OP_SET_CONNECTABLE, ENODEV);
426 427 428 429

	hci_dev_lock_bh(hdev);

	if (!test_bit(HCI_UP, &hdev->flags)) {
430
		err = cmd_status(sk, index, MGMT_OP_SET_CONNECTABLE, ENETDOWN);
431 432 433
		goto failed;
	}

434 435 436
	if (mgmt_pending_find(MGMT_OP_SET_DISCOVERABLE, index) ||
			mgmt_pending_find(MGMT_OP_SET_CONNECTABLE, index)) {
		err = cmd_status(sk, index, MGMT_OP_SET_CONNECTABLE, EBUSY);
437 438 439
		goto failed;
	}

440
	if (cp->val == test_bit(HCI_PSCAN, &hdev->flags)) {
441
		err = cmd_status(sk, index, MGMT_OP_SET_CONNECTABLE, EALREADY);
442 443 444
		goto failed;
	}

445
	cmd = mgmt_pending_add(sk, MGMT_OP_SET_CONNECTABLE, index, data, len);
446 447
	if (!cmd) {
		err = -ENOMEM;
448
		goto failed;
449
	}
450

451
	if (cp->val)
452 453 454 455 456 457
		scan = SCAN_PAGE;
	else
		scan = 0;

	err = hci_send_cmd(hdev, HCI_OP_WRITE_SCAN_ENABLE, 1, &scan);
	if (err < 0)
458
		mgmt_pending_remove(cmd);
459 460 461 462 463 464 465 466

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

467 468
static int mgmt_event(u16 event, u16 index, void *data, u16 data_len,
							struct sock *skip_sk)
469 470 471 472 473 474 475 476 477 478 479 480
{
	struct sk_buff *skb;
	struct mgmt_hdr *hdr;

	skb = alloc_skb(sizeof(*hdr) + data_len, GFP_ATOMIC);
	if (!skb)
		return -ENOMEM;

	bt_cb(skb)->channel = HCI_CHANNEL_CONTROL;

	hdr = (void *) skb_put(skb, sizeof(*hdr));
	hdr->opcode = cpu_to_le16(event);
481
	hdr->index = cpu_to_le16(index);
482 483
	hdr->len = cpu_to_le16(data_len);

484 485
	if (data)
		memcpy(skb_put(skb, data_len), data, data_len);
486 487 488 489 490 491 492

	hci_send_to_sock(NULL, skb, skip_sk);
	kfree_skb(skb);

	return 0;
}

493 494
static int send_mode_rsp(struct sock *sk, u16 opcode, u16 index, u8 val)
{
495
	struct mgmt_mode rp;
496

497
	rp.val = val;
498

499
	return cmd_complete(sk, index, opcode, &rp, sizeof(rp));
500 501
}

502 503
static int set_pairable(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
504 505 506 507 508 509 510
{
	struct mgmt_mode *cp, ev;
	struct hci_dev *hdev;
	int err;

	cp = (void *) data;

511
	BT_DBG("request for hci%u", index);
512

513 514 515
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_PAIRABLE, EINVAL);

516
	hdev = hci_dev_get(index);
517
	if (!hdev)
518
		return cmd_status(sk, index, MGMT_OP_SET_PAIRABLE, ENODEV);
519 520 521 522 523 524 525 526

	hci_dev_lock_bh(hdev);

	if (cp->val)
		set_bit(HCI_PAIRABLE, &hdev->flags);
	else
		clear_bit(HCI_PAIRABLE, &hdev->flags);

527
	err = send_mode_rsp(sk, MGMT_OP_SET_PAIRABLE, index, cp->val);
528 529 530 531 532
	if (err < 0)
		goto failed;

	ev.val = cp->val;

533
	err = mgmt_event(MGMT_EV_PAIRABLE, index, &ev, sizeof(ev), sk);
534 535 536 537 538 539 540 541

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574
static u8 get_service_classes(struct hci_dev *hdev)
{
	struct list_head *p;
	u8 val = 0;

	list_for_each(p, &hdev->uuids) {
		struct bt_uuid *uuid = list_entry(p, struct bt_uuid, list);

		val |= uuid->svc_hint;
	}

	return val;
}

static int update_class(struct hci_dev *hdev)
{
	u8 cod[3];

	BT_DBG("%s", hdev->name);

	if (test_bit(HCI_SERVICE_CACHE, &hdev->flags))
		return 0;

	cod[0] = hdev->minor_class;
	cod[1] = hdev->major_class;
	cod[2] = get_service_classes(hdev);

	if (memcmp(cod, hdev->dev_class, 3) == 0)
		return 0;

	return hci_send_cmd(hdev, HCI_OP_WRITE_CLASS_OF_DEV, sizeof(cod), cod);
}

575
static int add_uuid(struct sock *sk, u16 index, unsigned char *data, u16 len)
576 577 578 579 580 581 582 583
{
	struct mgmt_cp_add_uuid *cp;
	struct hci_dev *hdev;
	struct bt_uuid *uuid;
	int err;

	cp = (void *) data;

584
	BT_DBG("request for hci%u", index);
585

586 587 588
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_ADD_UUID, EINVAL);

589
	hdev = hci_dev_get(index);
590
	if (!hdev)
591
		return cmd_status(sk, index, MGMT_OP_ADD_UUID, ENODEV);
592 593 594 595 596 597 598 599 600 601

	hci_dev_lock_bh(hdev);

	uuid = kmalloc(sizeof(*uuid), GFP_ATOMIC);
	if (!uuid) {
		err = -ENOMEM;
		goto failed;
	}

	memcpy(uuid->uuid, cp->uuid, 16);
602
	uuid->svc_hint = cp->svc_hint;
603 604 605

	list_add(&uuid->list, &hdev->uuids);

606 607 608 609
	err = update_class(hdev);
	if (err < 0)
		goto failed;

610
	err = cmd_complete(sk, index, MGMT_OP_ADD_UUID, NULL, 0);
611 612 613 614 615 616 617 618

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

619
static int remove_uuid(struct sock *sk, u16 index, unsigned char *data, u16 len)
620 621
{
	struct list_head *p, *n;
622
	struct mgmt_cp_remove_uuid *cp;
623 624 625 626 627 628
	struct hci_dev *hdev;
	u8 bt_uuid_any[] = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
	int err, found;

	cp = (void *) data;

629
	BT_DBG("request for hci%u", index);
630

631 632 633
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_REMOVE_UUID, EINVAL);

634
	hdev = hci_dev_get(index);
635
	if (!hdev)
636
		return cmd_status(sk, index, MGMT_OP_REMOVE_UUID, ENODEV);
637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657

	hci_dev_lock_bh(hdev);

	if (memcmp(cp->uuid, bt_uuid_any, 16) == 0) {
		err = hci_uuids_clear(hdev);
		goto unlock;
	}

	found = 0;

	list_for_each_safe(p, n, &hdev->uuids) {
		struct bt_uuid *match = list_entry(p, struct bt_uuid, list);

		if (memcmp(match->uuid, cp->uuid, 16) != 0)
			continue;

		list_del(&match->list);
		found++;
	}

	if (found == 0) {
658
		err = cmd_status(sk, index, MGMT_OP_REMOVE_UUID, ENOENT);
659 660 661
		goto unlock;
	}

662 663 664 665
	err = update_class(hdev);
	if (err < 0)
		goto unlock;

666
	err = cmd_complete(sk, index, MGMT_OP_REMOVE_UUID, NULL, 0);
667 668 669 670 671 672 673 674

unlock:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

675 676
static int set_dev_class(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
677 678 679 680 681 682 683
{
	struct hci_dev *hdev;
	struct mgmt_cp_set_dev_class *cp;
	int err;

	cp = (void *) data;

684
	BT_DBG("request for hci%u", index);
685

686 687 688
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_DEV_CLASS, EINVAL);

689
	hdev = hci_dev_get(index);
690
	if (!hdev)
691
		return cmd_status(sk, index, MGMT_OP_SET_DEV_CLASS, ENODEV);
692 693 694 695 696 697 698 699 700

	hci_dev_lock_bh(hdev);

	hdev->major_class = cp->major;
	hdev->minor_class = cp->minor;

	err = update_class(hdev);

	if (err == 0)
701
		err = cmd_complete(sk, index, MGMT_OP_SET_DEV_CLASS, NULL, 0);
702 703 704 705 706 707 708

	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

709 710
static int set_service_cache(struct sock *sk, u16 index,  unsigned char *data,
									u16 len)
711 712 713 714 715 716 717
{
	struct hci_dev *hdev;
	struct mgmt_cp_set_service_cache *cp;
	int err;

	cp = (void *) data;

718 719 720 721
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_SERVICE_CACHE,
									EINVAL);

722
	hdev = hci_dev_get(index);
723
	if (!hdev)
724
		return cmd_status(sk, index, MGMT_OP_SET_SERVICE_CACHE, ENODEV);
725 726 727

	hci_dev_lock_bh(hdev);

728
	BT_DBG("hci%u enable %d", index, cp->enable);
729 730 731 732 733 734 735 736 737 738

	if (cp->enable) {
		set_bit(HCI_SERVICE_CACHE, &hdev->flags);
		err = 0;
	} else {
		clear_bit(HCI_SERVICE_CACHE, &hdev->flags);
		err = update_class(hdev);
	}

	if (err == 0)
739 740
		err = cmd_complete(sk, index, MGMT_OP_SET_SERVICE_CACHE, NULL,
									0);
741 742 743 744 745 746 747

	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

748
static int load_keys(struct sock *sk, u16 index, unsigned char *data, u16 len)
749 750 751
{
	struct hci_dev *hdev;
	struct mgmt_cp_load_keys *cp;
752
	u16 key_count, expected_len;
753 754 755
	int i;

	cp = (void *) data;
756 757 758 759

	if (len < sizeof(*cp))
		return -EINVAL;

760 761 762 763 764 765 766 767 768
	key_count = get_unaligned_le16(&cp->key_count);

	expected_len = sizeof(*cp) + key_count * sizeof(struct mgmt_key_info);
	if (expected_len != len) {
		BT_ERR("load_keys: expected %u bytes, got %u bytes",
							len, expected_len);
		return -EINVAL;
	}

769
	hdev = hci_dev_get(index);
770
	if (!hdev)
771
		return cmd_status(sk, index, MGMT_OP_LOAD_KEYS, ENODEV);
772

773
	BT_DBG("hci%u debug_keys %u key_count %u", index, cp->debug_keys,
774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799
								key_count);

	hci_dev_lock_bh(hdev);

	hci_link_keys_clear(hdev);

	set_bit(HCI_LINK_KEYS, &hdev->flags);

	if (cp->debug_keys)
		set_bit(HCI_DEBUG_KEYS, &hdev->flags);
	else
		clear_bit(HCI_DEBUG_KEYS, &hdev->flags);

	for (i = 0; i < key_count; i++) {
		struct mgmt_key_info *key = &cp->keys[i];

		hci_add_link_key(hdev, 0, &key->bdaddr, key->val, key->type,
								key->pin_len);
	}

	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return 0;
}

800
static int remove_key(struct sock *sk, u16 index, unsigned char *data, u16 len)
801 802 803 804 805 806 807 808
{
	struct hci_dev *hdev;
	struct mgmt_cp_remove_key *cp;
	struct hci_conn *conn;
	int err;

	cp = (void *) data;

809 810 811
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_REMOVE_KEY, EINVAL);

812
	hdev = hci_dev_get(index);
813
	if (!hdev)
814
		return cmd_status(sk, index, MGMT_OP_REMOVE_KEY, ENODEV);
815 816 817 818 819

	hci_dev_lock_bh(hdev);

	err = hci_remove_link_key(hdev, &cp->bdaddr);
	if (err < 0) {
820
		err = cmd_status(sk, index, MGMT_OP_REMOVE_KEY, -err);
821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844
		goto unlock;
	}

	err = 0;

	if (!test_bit(HCI_UP, &hdev->flags) || !cp->disconnect)
		goto unlock;

	conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, &cp->bdaddr);
	if (conn) {
		struct hci_cp_disconnect dc;

		put_unaligned_le16(conn->handle, &dc.handle);
		dc.reason = 0x13; /* Remote User Terminated Connection */
		err = hci_send_cmd(hdev, HCI_OP_DISCONNECT, 0, NULL);
	}

unlock:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

845
static int disconnect(struct sock *sk, u16 index, unsigned char *data, u16 len)
846 847 848 849
{
	struct hci_dev *hdev;
	struct mgmt_cp_disconnect *cp;
	struct hci_cp_disconnect dc;
850
	struct pending_cmd *cmd;
851 852 853 854 855 856 857
	struct hci_conn *conn;
	int err;

	BT_DBG("");

	cp = (void *) data;

858 859 860
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_DISCONNECT, EINVAL);

861
	hdev = hci_dev_get(index);
862
	if (!hdev)
863
		return cmd_status(sk, index, MGMT_OP_DISCONNECT, ENODEV);
864 865 866 867

	hci_dev_lock_bh(hdev);

	if (!test_bit(HCI_UP, &hdev->flags)) {
868
		err = cmd_status(sk, index, MGMT_OP_DISCONNECT, ENETDOWN);
869 870 871
		goto failed;
	}

872 873
	if (mgmt_pending_find(MGMT_OP_DISCONNECT, index)) {
		err = cmd_status(sk, index, MGMT_OP_DISCONNECT, EBUSY);
874 875 876 877 878
		goto failed;
	}

	conn = hci_conn_hash_lookup_ba(hdev, ACL_LINK, &cp->bdaddr);
	if (!conn) {
879
		err = cmd_status(sk, index, MGMT_OP_DISCONNECT, ENOTCONN);
880 881 882
		goto failed;
	}

883
	cmd = mgmt_pending_add(sk, MGMT_OP_DISCONNECT, index, data, len);
884 885
	if (!cmd) {
		err = -ENOMEM;
886
		goto failed;
887
	}
888 889 890 891 892 893

	put_unaligned_le16(conn->handle, &dc.handle);
	dc.reason = 0x13; /* Remote User Terminated Connection */

	err = hci_send_cmd(hdev, HCI_OP_DISCONNECT, sizeof(dc), &dc);
	if (err < 0)
894
		mgmt_pending_remove(cmd);
895 896 897 898 899 900 901 902

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

903 904
static int get_connections(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
905 906 907 908 909
{
	struct mgmt_cp_get_connections *cp;
	struct mgmt_rp_get_connections *rp;
	struct hci_dev *hdev;
	struct list_head *p;
910
	size_t rp_len;
911
	u16 count;
912 913 914 915 916 917
	int i, err;

	BT_DBG("");

	cp = (void *) data;

918
	hdev = hci_dev_get(index);
919
	if (!hdev)
920
		return cmd_status(sk, index, MGMT_OP_GET_CONNECTIONS, ENODEV);
921 922 923 924 925 926 927 928

	hci_dev_lock_bh(hdev);

	count = 0;
	list_for_each(p, &hdev->conn_hash.list) {
		count++;
	}

929 930 931
	rp_len = sizeof(*rp) + (count * sizeof(bdaddr_t));
	rp = kmalloc(rp_len, GFP_ATOMIC);
	if (!rp) {
932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948
		err = -ENOMEM;
		goto unlock;
	}

	put_unaligned_le16(count, &rp->conn_count);

	read_lock(&hci_dev_list_lock);

	i = 0;
	list_for_each(p, &hdev->conn_hash.list) {
		struct hci_conn *c = list_entry(p, struct hci_conn, list);

		bacpy(&rp->conn[i++], &c->dst);
	}

	read_unlock(&hci_dev_list_lock);

949
	err = cmd_complete(sk, index, MGMT_OP_GET_CONNECTIONS, rp, rp_len);
950 951

unlock:
952
	kfree(rp);
953 954 955 956 957
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);
	return err;
}

958 959
static int pin_code_reply(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
960 961 962 963
{
	struct hci_dev *hdev;
	struct mgmt_cp_pin_code_reply *cp;
	struct hci_cp_pin_code_reply reply;
964
	struct pending_cmd *cmd;
965 966 967 968 969 970
	int err;

	BT_DBG("");

	cp = (void *) data;

971 972 973
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_PIN_CODE_REPLY, EINVAL);

974
	hdev = hci_dev_get(index);
975
	if (!hdev)
976
		return cmd_status(sk, index, MGMT_OP_PIN_CODE_REPLY, ENODEV);
977 978 979 980

	hci_dev_lock_bh(hdev);

	if (!test_bit(HCI_UP, &hdev->flags)) {
981
		err = cmd_status(sk, index, MGMT_OP_PIN_CODE_REPLY, ENETDOWN);
982 983 984
		goto failed;
	}

985
	cmd = mgmt_pending_add(sk, MGMT_OP_PIN_CODE_REPLY, index, data, len);
986 987
	if (!cmd) {
		err = -ENOMEM;
988
		goto failed;
989
	}
990 991 992 993 994 995 996

	bacpy(&reply.bdaddr, &cp->bdaddr);
	reply.pin_len = cp->pin_len;
	memcpy(reply.pin_code, cp->pin_code, 16);

	err = hci_send_cmd(hdev, HCI_OP_PIN_CODE_REPLY, sizeof(reply), &reply);
	if (err < 0)
997
		mgmt_pending_remove(cmd);
998 999 1000 1001 1002 1003 1004 1005

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

1006 1007
static int pin_code_neg_reply(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
1008 1009 1010
{
	struct hci_dev *hdev;
	struct mgmt_cp_pin_code_neg_reply *cp;
1011
	struct pending_cmd *cmd;
1012 1013 1014 1015 1016 1017
	int err;

	BT_DBG("");

	cp = (void *) data;

1018 1019 1020 1021
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_PIN_CODE_NEG_REPLY,
									EINVAL);

1022
	hdev = hci_dev_get(index);
1023
	if (!hdev)
1024 1025
		return cmd_status(sk, index, MGMT_OP_PIN_CODE_NEG_REPLY,
									ENODEV);
1026 1027 1028 1029

	hci_dev_lock_bh(hdev);

	if (!test_bit(HCI_UP, &hdev->flags)) {
1030 1031
		err = cmd_status(sk, index, MGMT_OP_PIN_CODE_NEG_REPLY,
								ENETDOWN);
1032 1033 1034
		goto failed;
	}

1035
	cmd = mgmt_pending_add(sk, MGMT_OP_PIN_CODE_NEG_REPLY, index,
1036
								data, len);
1037 1038
	if (!cmd) {
		err = -ENOMEM;
1039
		goto failed;
1040
	}
1041 1042 1043 1044

	err = hci_send_cmd(hdev, HCI_OP_PIN_CODE_NEG_REPLY, sizeof(bdaddr_t),
								&cp->bdaddr);
	if (err < 0)
1045
		mgmt_pending_remove(cmd);
1046 1047 1048 1049 1050 1051 1052 1053

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

1054 1055
static int set_io_capability(struct sock *sk, u16 index, unsigned char *data,
									u16 len)
1056 1057 1058 1059 1060 1061 1062 1063
{
	struct hci_dev *hdev;
	struct mgmt_cp_set_io_capability *cp;

	BT_DBG("");

	cp = (void *) data;

1064 1065 1066 1067
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_SET_IO_CAPABILITY,
									EINVAL);

1068
	hdev = hci_dev_get(index);
1069
	if (!hdev)
1070
		return cmd_status(sk, index, MGMT_OP_SET_IO_CAPABILITY, ENODEV);
1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081

	hci_dev_lock_bh(hdev);

	hdev->io_capability = cp->io_capability;

	BT_DBG("%s IO capability set to 0x%02x", hdev->name,
						hdev->io_capability);

	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

1082
	return cmd_complete(sk, index, MGMT_OP_SET_IO_CAPABILITY, NULL, 0);
1083 1084
}

1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117
static inline struct pending_cmd *find_pairing(struct hci_conn *conn)
{
	struct hci_dev *hdev = conn->hdev;
	struct list_head *p;

	list_for_each(p, &cmd_list) {
		struct pending_cmd *cmd;

		cmd = list_entry(p, struct pending_cmd, list);

		if (cmd->opcode != MGMT_OP_PAIR_DEVICE)
			continue;

		if (cmd->index != hdev->id)
			continue;

		if (cmd->user_data != conn)
			continue;

		return cmd;
	}

	return NULL;
}

static void pairing_complete(struct pending_cmd *cmd, u8 status)
{
	struct mgmt_rp_pair_device rp;
	struct hci_conn *conn = cmd->user_data;

	bacpy(&rp.bdaddr, &conn->dst);
	rp.status = status;

1118
	cmd_complete(cmd->sk, cmd->index, MGMT_OP_PAIR_DEVICE, &rp, sizeof(rp));
1119 1120 1121 1122 1123 1124 1125 1126

	/* So we don't get further callbacks for this connection */
	conn->connect_cfm_cb = NULL;
	conn->security_cfm_cb = NULL;
	conn->disconn_cfm_cb = NULL;

	hci_conn_put(conn);

1127
	mgmt_pending_remove(cmd);
1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144
}

static void pairing_complete_cb(struct hci_conn *conn, u8 status)
{
	struct pending_cmd *cmd;

	BT_DBG("status %u", status);

	cmd = find_pairing(conn);
	if (!cmd) {
		BT_DBG("Unable to find a pending command");
		return;
	}

	pairing_complete(cmd, status);
}

1145
static int pair_device(struct sock *sk, u16 index, unsigned char *data, u16 len)
1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157
{
	struct hci_dev *hdev;
	struct mgmt_cp_pair_device *cp;
	struct pending_cmd *cmd;
	u8 sec_level, auth_type;
	struct hci_conn *conn;
	int err;

	BT_DBG("");

	cp = (void *) data;

1158 1159 1160
	if (len != sizeof(*cp))
		return cmd_status(sk, index, MGMT_OP_PAIR_DEVICE, EINVAL);

1161
	hdev = hci_dev_get(index);
1162
	if (!hdev)
1163
		return cmd_status(sk, index, MGMT_OP_PAIR_DEVICE, ENODEV);
1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175

	hci_dev_lock_bh(hdev);

	if (cp->io_cap == 0x03) {
		sec_level = BT_SECURITY_MEDIUM;
		auth_type = HCI_AT_DEDICATED_BONDING;
	} else {
		sec_level = BT_SECURITY_HIGH;
		auth_type = HCI_AT_DEDICATED_BONDING_MITM;
	}

	conn = hci_connect(hdev, ACL_LINK, &cp->bdaddr, sec_level, auth_type);
1176 1177
	if (IS_ERR(conn)) {
		err = PTR_ERR(conn);
1178 1179 1180 1181 1182
		goto unlock;
	}

	if (conn->connect_cfm_cb) {
		hci_conn_put(conn);
1183
		err = cmd_status(sk, index, MGMT_OP_PAIR_DEVICE, EBUSY);
1184 1185 1186
		goto unlock;
	}

1187
	cmd = mgmt_pending_add(sk, MGMT_OP_PAIR_DEVICE, index, data, len);
1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212
	if (!cmd) {
		err = -ENOMEM;
		hci_conn_put(conn);
		goto unlock;
	}

	conn->connect_cfm_cb = pairing_complete_cb;
	conn->security_cfm_cb = pairing_complete_cb;
	conn->disconn_cfm_cb = pairing_complete_cb;
	conn->io_capability = cp->io_cap;
	cmd->user_data = conn;

	if (conn->state == BT_CONNECTED &&
				hci_conn_security(conn, sec_level, auth_type))
		pairing_complete(cmd, 0);

	err = 0;

unlock:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

1213 1214
static int user_confirm_reply(struct sock *sk, u16 index, unsigned char *data,
							u16 len, int success)
1215 1216
{
	struct mgmt_cp_user_confirm_reply *cp = (void *) data;
1217
	u16 mgmt_op, hci_op;
1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231
	struct pending_cmd *cmd;
	struct hci_dev *hdev;
	int err;

	BT_DBG("");

	if (success) {
		mgmt_op = MGMT_OP_USER_CONFIRM_REPLY;
		hci_op = HCI_OP_USER_CONFIRM_REPLY;
	} else {
		mgmt_op = MGMT_OP_USER_CONFIRM_NEG_REPLY;
		hci_op = HCI_OP_USER_CONFIRM_NEG_REPLY;
	}

1232 1233 1234
	if (len != sizeof(*cp))
		return cmd_status(sk, index, mgmt_op, EINVAL);

1235
	hdev = hci_dev_get(index);
1236
	if (!hdev)
1237
		return cmd_status(sk, index, mgmt_op, ENODEV);
1238 1239

	if (!test_bit(HCI_UP, &hdev->flags)) {
1240
		err = cmd_status(sk, index, mgmt_op, ENETDOWN);
1241 1242 1243
		goto failed;
	}

1244
	cmd = mgmt_pending_add(sk, mgmt_op, index, data, len);
1245 1246 1247 1248 1249 1250
	if (!cmd) {
		err = -ENOMEM;
		goto failed;
	}

	err = hci_send_cmd(hdev, hci_op, sizeof(cp->bdaddr), &cp->bdaddr);
1251 1252
	if (err < 0)
		mgmt_pending_remove(cmd);
1253 1254 1255 1256 1257 1258 1259 1260

failed:
	hci_dev_unlock_bh(hdev);
	hci_dev_put(hdev);

	return err;
}

1261 1262 1263 1264
int mgmt_control(struct sock *sk, struct msghdr *msg, size_t msglen)
{
	unsigned char *buf;
	struct mgmt_hdr *hdr;
1265
	u16 opcode, index, len;
1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283
	int err;

	BT_DBG("got %zu bytes", msglen);

	if (msglen < sizeof(*hdr))
		return -EINVAL;

	buf = kmalloc(msglen, GFP_ATOMIC);
	if (!buf)
		return -ENOMEM;

	if (memcpy_fromiovec(buf, msg->msg_iov, msglen)) {
		err = -EFAULT;
		goto done;
	}

	hdr = (struct mgmt_hdr *) buf;
	opcode = get_unaligned_le16(&hdr->opcode);
1284
	index = get_unaligned_le16(&hdr->index);
1285 1286 1287 1288 1289 1290 1291 1292
	len = get_unaligned_le16(&hdr->len);

	if (len != msglen - sizeof(*hdr)) {
		err = -EINVAL;
		goto done;
	}

	switch (opcode) {
1293 1294 1295
	case MGMT_OP_READ_VERSION:
		err = read_version(sk);
		break;
1296 1297 1298
	case MGMT_OP_READ_INDEX_LIST:
		err = read_index_list(sk);
		break;
1299
	case MGMT_OP_READ_INFO:
1300
		err = read_controller_info(sk, index);
1301
		break;
1302
	case MGMT_OP_SET_POWERED:
1303
		err = set_powered(sk, index, buf + sizeof(*hdr), len);
1304
		break;
1305
	case MGMT_OP_SET_DISCOVERABLE:
1306
		err = set_discoverable(sk, index, buf + sizeof(*hdr), len);
1307
		break;
1308
	case MGMT_OP_SET_CONNECTABLE:
1309
		err = set_connectable(sk, index, buf + sizeof(*hdr), len);
1310
		break;
1311
	case MGMT_OP_SET_PAIRABLE:
1312
		err = set_pairable(sk, index, buf + sizeof(*hdr), len);
1313
		break;
1314
	case MGMT_OP_ADD_UUID:
1315
		err = add_uuid(sk, index, buf + sizeof(*hdr), len);
1316 1317
		break;
	case MGMT_OP_REMOVE_UUID:
1318
		err = remove_uuid(sk, index, buf + sizeof(*hdr), len);
1319
		break;
1320
	case MGMT_OP_SET_DEV_CLASS:
1321
		err = set_dev_class(sk, index, buf + sizeof(*hdr), len);
1322 1323
		break;
	case MGMT_OP_SET_SERVICE_CACHE:
1324
		err = set_service_cache(sk, index, buf + sizeof(*hdr), len);
1325
		break;
1326
	case MGMT_OP_LOAD_KEYS:
1327
		err = load_keys(sk, index, buf + sizeof(*hdr), len);
1328 1329
		break;
	case MGMT_OP_REMOVE_KEY:
1330
		err = remove_key(sk, index, buf + sizeof(*hdr), len);
1331
		break;
1332
	case MGMT_OP_DISCONNECT:
1333
		err = disconnect(sk, index, buf + sizeof(*hdr), len);
1334
		break;
1335
	case MGMT_OP_GET_CONNECTIONS:
1336
		err = get_connections(sk, index, buf + sizeof(*hdr), len);
1337
		break;
1338
	case MGMT_OP_PIN_CODE_REPLY:
1339
		err = pin_code_reply(sk, index, buf + sizeof(*hdr), len);
1340 1341
		break;
	case MGMT_OP_PIN_CODE_NEG_REPLY:
1342
		err = pin_code_neg_reply(sk, index, buf + sizeof(*hdr), len);
1343
		break;
1344
	case MGMT_OP_SET_IO_CAPABILITY:
1345
		err = set_io_capability(sk, index, buf + sizeof(*hdr), len);
1346
		break;
1347
	case MGMT_OP_PAIR_DEVICE:
1348
		err = pair_device(sk, index, buf + sizeof(*hdr), len);
1349
		break;
1350
	case MGMT_OP_USER_CONFIRM_REPLY:
1351
		err = user_confirm_reply(sk, index, buf + sizeof(*hdr), len, 1);
1352 1353
		break;
	case MGMT_OP_USER_CONFIRM_NEG_REPLY:
1354
		err = user_confirm_reply(sk, index, buf + sizeof(*hdr), len, 0);
1355
		break;
1356 1357
	default:
		BT_DBG("Unknown op %u", opcode);
1358
		err = cmd_status(sk, index, opcode, 0x01);
1359 1360 1361
		break;
	}

1362 1363 1364
	if (err < 0)
		goto done;

1365 1366 1367 1368 1369 1370
	err = msglen;

done:
	kfree(buf);
	return err;
}
1371 1372 1373

int mgmt_index_added(u16 index)
{
1374
	return mgmt_event(MGMT_EV_INDEX_ADDED, index, NULL, 0, NULL);
1375 1376 1377 1378
}

int mgmt_index_removed(u16 index)
{
1379
	return mgmt_event(MGMT_EV_INDEX_REMOVED, index, NULL, 0, NULL);
1380 1381
}

1382
struct cmd_lookup {
1383
	u8 val;
1384 1385 1386
	struct sock *sk;
};

1387
static void mode_rsp(struct pending_cmd *cmd, void *data)
1388
{
1389
	struct mgmt_mode *cp = cmd->cmd;
1390
	struct cmd_lookup *match = data;
1391

1392
	if (cp->val != match->val)
1393 1394
		return;

1395
	send_mode_rsp(cmd->sk, cmd->opcode, cmd->index, cp->val);
1396 1397 1398 1399 1400 1401 1402 1403 1404

	list_del(&cmd->list);

	if (match->sk == NULL) {
		match->sk = cmd->sk;
		sock_hold(match->sk);
	}

	mgmt_pending_free(cmd);
1405
}
1406 1407 1408

int mgmt_powered(u16 index, u8 powered)
{
1409
	struct mgmt_mode ev;
1410
	struct cmd_lookup match = { powered, NULL };
1411
	int ret;
1412

1413
	mgmt_pending_foreach(MGMT_OP_SET_POWERED, index, mode_rsp, &match);
1414

1415
	ev.val = powered;
1416

1417
	ret = mgmt_event(MGMT_EV_POWERED, index, &ev, sizeof(ev), match.sk);
1418 1419 1420 1421 1422

	if (match.sk)
		sock_put(match.sk);

	return ret;
1423
}
1424 1425 1426

int mgmt_discoverable(u16 index, u8 discoverable)
{
1427
	struct mgmt_mode ev;
1428 1429 1430 1431
	struct cmd_lookup match = { discoverable, NULL };
	int ret;

	mgmt_pending_foreach(MGMT_OP_SET_DISCOVERABLE, index,
1432 1433 1434
							mode_rsp, &match);

	ev.val = discoverable;
1435

1436 1437
	ret = mgmt_event(MGMT_EV_DISCOVERABLE, index, &ev, sizeof(ev),
								match.sk);
1438 1439 1440 1441 1442 1443

	if (match.sk)
		sock_put(match.sk);

	return ret;
}
1444 1445 1446

int mgmt_connectable(u16 index, u8 connectable)
{
1447
	struct mgmt_mode ev;
1448 1449 1450
	struct cmd_lookup match = { connectable, NULL };
	int ret;

1451
	mgmt_pending_foreach(MGMT_OP_SET_CONNECTABLE, index, mode_rsp, &match);
1452

1453
	ev.val = connectable;
1454

1455
	ret = mgmt_event(MGMT_EV_CONNECTABLE, index, &ev, sizeof(ev), match.sk);
1456 1457 1458 1459 1460 1461

	if (match.sk)
		sock_put(match.sk);

	return ret;
}
1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474

int mgmt_new_key(u16 index, struct link_key *key, u8 old_key_type)
{
	struct mgmt_ev_new_key ev;

	memset(&ev, 0, sizeof(ev));

	bacpy(&ev.key.bdaddr, &key->bdaddr);
	ev.key.type = key->type;
	memcpy(ev.key.val, key->val, 16);
	ev.key.pin_len = key->pin_len;
	ev.old_key_type = old_key_type;

1475
	return mgmt_event(MGMT_EV_NEW_KEY, index, &ev, sizeof(ev), NULL);
1476
}
1477 1478 1479 1480 1481 1482 1483

int mgmt_connected(u16 index, bdaddr_t *bdaddr)
{
	struct mgmt_ev_connected ev;

	bacpy(&ev.bdaddr, bdaddr);

1484
	return mgmt_event(MGMT_EV_CONNECTED, index, &ev, sizeof(ev), NULL);
1485 1486
}

1487 1488 1489 1490
static void disconnect_rsp(struct pending_cmd *cmd, void *data)
{
	struct mgmt_cp_disconnect *cp = cmd->cmd;
	struct sock **sk = data;
1491
	struct mgmt_rp_disconnect rp;
1492

1493
	bacpy(&rp.bdaddr, &cp->bdaddr);
1494

1495
	cmd_complete(cmd->sk, cmd->index, MGMT_OP_DISCONNECT, &rp, sizeof(rp));
1496 1497 1498 1499

	*sk = cmd->sk;
	sock_hold(*sk);

1500
	mgmt_pending_remove(cmd);
1501 1502
}

1503 1504 1505
int mgmt_disconnected(u16 index, bdaddr_t *bdaddr)
{
	struct mgmt_ev_disconnected ev;
1506 1507 1508 1509
	struct sock *sk = NULL;
	int err;

	mgmt_pending_foreach(MGMT_OP_DISCONNECT, index, disconnect_rsp, &sk);
1510 1511 1512

	bacpy(&ev.bdaddr, bdaddr);

1513
	err = mgmt_event(MGMT_EV_DISCONNECTED, index, &ev, sizeof(ev), sk);
1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529

	if (sk)
		sock_put(sk);

	return err;
}

int mgmt_disconnect_failed(u16 index)
{
	struct pending_cmd *cmd;
	int err;

	cmd = mgmt_pending_find(MGMT_OP_DISCONNECT, index);
	if (!cmd)
		return -ENOENT;

1530
	err = cmd_status(cmd->sk, index, MGMT_OP_DISCONNECT, EIO);
1531

1532
	mgmt_pending_remove(cmd);
1533 1534

	return err;
1535
}
1536 1537 1538 1539 1540 1541 1542 1543

int mgmt_connect_failed(u16 index, bdaddr_t *bdaddr, u8 status)
{
	struct mgmt_ev_connect_failed ev;

	bacpy(&ev.bdaddr, bdaddr);
	ev.status = status;

1544
	return mgmt_event(MGMT_EV_CONNECT_FAILED, index, &ev, sizeof(ev), NULL);
1545
}
1546 1547 1548 1549 1550 1551 1552

int mgmt_pin_code_request(u16 index, bdaddr_t *bdaddr)
{
	struct mgmt_ev_pin_code_request ev;

	bacpy(&ev.bdaddr, bdaddr);

1553 1554
	return mgmt_event(MGMT_EV_PIN_CODE_REQUEST, index, &ev, sizeof(ev),
									NULL);
1555 1556 1557 1558 1559
}

int mgmt_pin_code_reply_complete(u16 index, bdaddr_t *bdaddr, u8 status)
{
	struct pending_cmd *cmd;
1560
	struct mgmt_rp_pin_code_reply rp;
1561 1562 1563 1564 1565 1566
	int err;

	cmd = mgmt_pending_find(MGMT_OP_PIN_CODE_REPLY, index);
	if (!cmd)
		return -ENOENT;

1567 1568 1569
	bacpy(&rp.bdaddr, bdaddr);
	rp.status = status;

1570 1571
	err = cmd_complete(cmd->sk, index, MGMT_OP_PIN_CODE_REPLY, &rp,
								sizeof(rp));
1572

1573
	mgmt_pending_remove(cmd);
1574 1575 1576 1577 1578 1579 1580

	return err;
}

int mgmt_pin_code_neg_reply_complete(u16 index, bdaddr_t *bdaddr, u8 status)
{
	struct pending_cmd *cmd;
1581
	struct mgmt_rp_pin_code_reply rp;
1582 1583 1584 1585 1586 1587
	int err;

	cmd = mgmt_pending_find(MGMT_OP_PIN_CODE_NEG_REPLY, index);
	if (!cmd)
		return -ENOENT;

1588 1589 1590
	bacpy(&rp.bdaddr, bdaddr);
	rp.status = status;

1591 1592
	err = cmd_complete(cmd->sk, index, MGMT_OP_PIN_CODE_NEG_REPLY, &rp,
								sizeof(rp));
1593

1594
	mgmt_pending_remove(cmd);
1595 1596 1597

	return err;
}
1598 1599 1600 1601 1602 1603 1604 1605 1606 1607

int mgmt_user_confirm_request(u16 index, bdaddr_t *bdaddr, __le32 value)
{
	struct mgmt_ev_user_confirm_request ev;

	BT_DBG("hci%u", index);

	bacpy(&ev.bdaddr, bdaddr);
	put_unaligned_le32(value, &ev.value);

1608 1609
	return mgmt_event(MGMT_EV_USER_CONFIRM_REQUEST, index, &ev, sizeof(ev),
									NULL);
1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624
}

static int confirm_reply_complete(u16 index, bdaddr_t *bdaddr, u8 status,
								u8 opcode)
{
	struct pending_cmd *cmd;
	struct mgmt_rp_user_confirm_reply rp;
	int err;

	cmd = mgmt_pending_find(opcode, index);
	if (!cmd)
		return -ENOENT;

	bacpy(&rp.bdaddr, bdaddr);
	rp.status = status;
1625
	err = cmd_complete(cmd->sk, index, opcode, &rp, sizeof(rp));
1626

1627
	mgmt_pending_remove(cmd);
1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643

	return err;
}

int mgmt_user_confirm_reply_complete(u16 index, bdaddr_t *bdaddr, u8 status)
{
	return confirm_reply_complete(index, bdaddr, status,
						MGMT_OP_USER_CONFIRM_REPLY);
}

int mgmt_user_confirm_neg_reply_complete(u16 index, bdaddr_t *bdaddr,
								u8 status)
{
	return confirm_reply_complete(index, bdaddr, status,
					MGMT_OP_USER_CONFIRM_NEG_REPLY);
}
1644 1645 1646 1647 1648 1649 1650 1651

int mgmt_auth_failed(u16 index, bdaddr_t *bdaddr, u8 status)
{
	struct mgmt_ev_auth_failed ev;

	bacpy(&ev.bdaddr, bdaddr);
	ev.status = status;

1652
	return mgmt_event(MGMT_EV_AUTH_FAILED, index, &ev, sizeof(ev), NULL);
1653
}