Commit f2d64f6a authored by Ulisses Furquim's avatar Ulisses Furquim Committed by Gustavo F. Padovan

Bluetooth: Remove global mutex hci_task_lock

The hci_task_lock mutex (previously a lock) was supposed to protect the
register/unregister of HCI protocols against RX/TX tasks. This will not
be needed anymore because SCO and L2CAP will always be compiled.

Moreover, with the recent move of RX/TX to workqueues per device the
global hci_task_lock was causing starvation between different HCI
devices.
Signed-off-by: default avatarUlisses Furquim <ulisses@profusion.mobi>
Acked-by: default avatarMarcel Holtmann <marcel@holtmann.org>
Signed-off-by: default avatarGustavo F. Padovan <padovan@profusion.mobi>
parent fa0fb93f
...@@ -61,8 +61,6 @@ static void hci_rx_work(struct work_struct *work); ...@@ -61,8 +61,6 @@ static void hci_rx_work(struct work_struct *work);
static void hci_cmd_work(struct work_struct *work); static void hci_cmd_work(struct work_struct *work);
static void hci_tx_work(struct work_struct *work); static void hci_tx_work(struct work_struct *work);
static DEFINE_MUTEX(hci_task_lock);
/* HCI device list */ /* HCI device list */
LIST_HEAD(hci_dev_list); LIST_HEAD(hci_dev_list);
DEFINE_RWLOCK(hci_dev_list_lock); DEFINE_RWLOCK(hci_dev_list_lock);
...@@ -1832,8 +1830,7 @@ EXPORT_SYMBOL(hci_recv_stream_fragment); ...@@ -1832,8 +1830,7 @@ EXPORT_SYMBOL(hci_recv_stream_fragment);
/* ---- Interface to upper protocols ---- */ /* ---- Interface to upper protocols ---- */
/* Register/Unregister protocols. /* Register/Unregister protocols. */
* hci_task_lock is used to ensure that no tasks are running. */
int hci_register_proto(struct hci_proto *hp) int hci_register_proto(struct hci_proto *hp)
{ {
int err = 0; int err = 0;
...@@ -1843,15 +1840,11 @@ int hci_register_proto(struct hci_proto *hp) ...@@ -1843,15 +1840,11 @@ int hci_register_proto(struct hci_proto *hp)
if (hp->id >= HCI_MAX_PROTO) if (hp->id >= HCI_MAX_PROTO)
return -EINVAL; return -EINVAL;
mutex_lock(&hci_task_lock);
if (!hci_proto[hp->id]) if (!hci_proto[hp->id])
hci_proto[hp->id] = hp; hci_proto[hp->id] = hp;
else else
err = -EEXIST; err = -EEXIST;
mutex_unlock(&hci_task_lock);
return err; return err;
} }
EXPORT_SYMBOL(hci_register_proto); EXPORT_SYMBOL(hci_register_proto);
...@@ -1865,15 +1858,11 @@ int hci_unregister_proto(struct hci_proto *hp) ...@@ -1865,15 +1858,11 @@ int hci_unregister_proto(struct hci_proto *hp)
if (hp->id >= HCI_MAX_PROTO) if (hp->id >= HCI_MAX_PROTO)
return -EINVAL; return -EINVAL;
mutex_lock(&hci_task_lock);
if (hci_proto[hp->id]) if (hci_proto[hp->id])
hci_proto[hp->id] = NULL; hci_proto[hp->id] = NULL;
else else
err = -ENOENT; err = -ENOENT;
mutex_unlock(&hci_task_lock);
return err; return err;
} }
EXPORT_SYMBOL(hci_unregister_proto); EXPORT_SYMBOL(hci_unregister_proto);
...@@ -2439,8 +2428,6 @@ static void hci_tx_work(struct work_struct *work) ...@@ -2439,8 +2428,6 @@ static void hci_tx_work(struct work_struct *work)
struct hci_dev *hdev = container_of(work, struct hci_dev, tx_work); struct hci_dev *hdev = container_of(work, struct hci_dev, tx_work);
struct sk_buff *skb; struct sk_buff *skb;
mutex_lock(&hci_task_lock);
BT_DBG("%s acl %d sco %d le %d", hdev->name, hdev->acl_cnt, BT_DBG("%s acl %d sco %d le %d", hdev->name, hdev->acl_cnt,
hdev->sco_cnt, hdev->le_cnt); hdev->sco_cnt, hdev->le_cnt);
...@@ -2457,8 +2444,6 @@ static void hci_tx_work(struct work_struct *work) ...@@ -2457,8 +2444,6 @@ static void hci_tx_work(struct work_struct *work)
/* Send next queued raw (unknown type) packet */ /* Send next queued raw (unknown type) packet */
while ((skb = skb_dequeue(&hdev->raw_q))) while ((skb = skb_dequeue(&hdev->raw_q)))
hci_send_frame(skb); hci_send_frame(skb);
mutex_unlock(&hci_task_lock);
} }
/* ----- HCI RX task (incoming data processing) ----- */ /* ----- HCI RX task (incoming data processing) ----- */
...@@ -2546,8 +2531,6 @@ static void hci_rx_work(struct work_struct *work) ...@@ -2546,8 +2531,6 @@ static void hci_rx_work(struct work_struct *work)
BT_DBG("%s", hdev->name); BT_DBG("%s", hdev->name);
mutex_lock(&hci_task_lock);
while ((skb = skb_dequeue(&hdev->rx_q))) { while ((skb = skb_dequeue(&hdev->rx_q))) {
if (atomic_read(&hdev->promisc)) { if (atomic_read(&hdev->promisc)) {
/* Send copy to the sockets */ /* Send copy to the sockets */
...@@ -2591,8 +2574,6 @@ static void hci_rx_work(struct work_struct *work) ...@@ -2591,8 +2574,6 @@ static void hci_rx_work(struct work_struct *work)
break; break;
} }
} }
mutex_unlock(&hci_task_lock);
} }
static void hci_cmd_work(struct work_struct *work) static void hci_cmd_work(struct work_struct *work)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment