Bluetooth: Use wait_event_interruptible for virtual driver
The virtual driver still uses a home grown way of waiting for events and so just replace it with wait_event_interruptible. And while at it remove the useless access_ok() checks. Signed-off-by: Marcel Holtmann <marcel@holtmann.org>
This commit is contained in:
parent
ac28494c51
commit
4db7589f3d
|
@ -179,42 +179,32 @@ static inline ssize_t vhci_put_user(struct vhci_data *data,
|
||||||
static ssize_t vhci_read(struct file *file,
|
static ssize_t vhci_read(struct file *file,
|
||||||
char __user *buf, size_t count, loff_t *pos)
|
char __user *buf, size_t count, loff_t *pos)
|
||||||
{
|
{
|
||||||
DECLARE_WAITQUEUE(wait, current);
|
|
||||||
struct vhci_data *data = file->private_data;
|
struct vhci_data *data = file->private_data;
|
||||||
struct sk_buff *skb;
|
struct sk_buff *skb;
|
||||||
ssize_t ret = 0;
|
ssize_t ret = 0;
|
||||||
|
|
||||||
add_wait_queue(&data->read_wait, &wait);
|
|
||||||
while (count) {
|
while (count) {
|
||||||
set_current_state(TASK_INTERRUPTIBLE);
|
|
||||||
|
|
||||||
skb = skb_dequeue(&data->readq);
|
skb = skb_dequeue(&data->readq);
|
||||||
if (!skb) {
|
if (skb) {
|
||||||
|
ret = vhci_put_user(data, skb, buf, count);
|
||||||
|
if (ret < 0)
|
||||||
|
skb_queue_head(&data->readq, skb);
|
||||||
|
else
|
||||||
|
kfree_skb(skb);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
if (file->f_flags & O_NONBLOCK) {
|
if (file->f_flags & O_NONBLOCK) {
|
||||||
ret = -EAGAIN;
|
ret = -EAGAIN;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (signal_pending(current)) {
|
ret = wait_event_interruptible(data->read_wait,
|
||||||
ret = -ERESTARTSYS;
|
!skb_queue_empty(&data->readq));
|
||||||
|
if (ret < 0)
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
schedule();
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (access_ok(VERIFY_WRITE, buf, count))
|
|
||||||
ret = vhci_put_user(data, skb, buf, count);
|
|
||||||
else
|
|
||||||
ret = -EFAULT;
|
|
||||||
|
|
||||||
kfree_skb(skb);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
set_current_state(TASK_RUNNING);
|
|
||||||
remove_wait_queue(&data->read_wait, &wait);
|
|
||||||
|
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -223,9 +213,6 @@ static ssize_t vhci_write(struct file *file,
|
||||||
{
|
{
|
||||||
struct vhci_data *data = file->private_data;
|
struct vhci_data *data = file->private_data;
|
||||||
|
|
||||||
if (!access_ok(VERIFY_READ, buf, count))
|
|
||||||
return -EFAULT;
|
|
||||||
|
|
||||||
return vhci_get_user(data, buf, count);
|
return vhci_get_user(data, buf, count);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue