Skip to content

L
linux
Commit 4c99a189 authored by David S. Miller's avatar David S. Miller
Browse files
Options

[NETLINK]: Remove buggy and useless rcv queue wakeup tests.

parent 817a3f7f
Show whitespace changes
Inline Side-by-side
Showing with 8 additions and 12 deletions
net/netlink/af_netlink.c
View file @ 4c99a189
...@@ -706,12 +706,10 @@ static int netlink_recvmsg(struct kiocb *iocb, struct socket *sock, ...@@ -706,12 +706,10 @@ static int netlink_recvmsg(struct kiocb *iocb, struct socket *sock,
netlink_dump(sk); netlink_dump(sk);
out: out:
if (skb_queue_len(&sk->receive_queue) <= sk->rcvbuf/2) {
if (skb_queue_len(&sk->receive_queue) == 0) if (skb_queue_len(&sk->receive_queue) == 0)
clear_bit(0, &nlk->state); clear_bit(0, &nlk->state);
if (!test_bit(0, &nlk->state)) if (!test_bit(0, &nlk->state))
wake_up_interruptible(&nlk->wait); wake_up_interruptible(&nlk->wait);
}
return err ? : copied; return err ? : copied;
} }
...@@ -722,12 +720,10 @@ void netlink_data_ready(struct sock *sk, int len) ...@@ -722,12 +720,10 @@ void netlink_data_ready(struct sock *sk, int len)
if (nlk->data_ready) if (nlk->data_ready)
nlk->data_ready(sk, len); nlk->data_ready(sk, len);
if (skb_queue_len(&sk->receive_queue) <= sk->rcvbuf/2) {
if (skb_queue_len(&sk->receive_queue) == 0) if (skb_queue_len(&sk->receive_queue) == 0)
clear_bit(0, &nlk->state); clear_bit(0, &nlk->state);
if (!test_bit(0, &nlk->state)) if (!test_bit(0, &nlk->state))
wake_up_interruptible(&nlk->wait); wake_up_interruptible(&nlk->wait);
}
} }
/* /*
......
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
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7