sctp: not disable bh in the whole sctp_get_port_local()
[ Upstream commit 3106ecb43a05dc3e009779764b9da245a5d082de ]
With disabling bh in the whole sctp_get_port_local(), when
snum == 0 and too many ports have been used, the do-while
loop will take the cpu for a long time and cause cpu stuck:
[ ] watchdog: BUG: soft lockup - CPU#11 stuck for 22s!
[ ] RIP: 0010:native_queued_spin_lock_slowpath+0x4de/0x940
[ ] Call Trace:
[ ] _raw_spin_lock+0xc1/0xd0
[ ] sctp_get_port_local+0x527/0x650 [sctp]
[ ] sctp_do_bind+0x208/0x5e0 [sctp]
[ ] sctp_autobind+0x165/0x1e0 [sctp]
[ ] sctp_connect_new_asoc+0x355/0x480 [sctp]
[ ] __sctp_connect+0x360/0xb10 [sctp]
There's no need to disable bh in the whole function of
sctp_get_port_local. So fix this cpu stuck by removing
local_bh_disable() called at the beginning, and using
spin_lock_bh() instead.
The same thing was actually done for inet_csk_get_port() in
Commit ea8add2b1903 ("tcp/dccp: better use of ephemeral
ports in bind()").
Thanks to Marcelo for pointing the buggy code out.
v1->v2:
- use cond_resched() to yield cpu to other tasks if needed,
as Eric noticed.
Fixes: 1da177e4c3
("Linux-2.6.12-rc2")
Reported-by: Ying Xu <yinxu@redhat.com>
Signed-off-by: Xin Long <lucien.xin@gmail.com>
Acked-by: Marcelo Ricardo Leitner <marcelo.leitner@gmail.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
This commit is contained in:
parent
0fe26a0f4b
commit
32a8e4e2d1
1 changed files with 6 additions and 10 deletions
|
@ -6206,8 +6206,6 @@ static long sctp_get_port_local(struct sock *sk, union sctp_addr *addr)
|
||||||
|
|
||||||
pr_debug("%s: begins, snum:%d\n", __func__, snum);
|
pr_debug("%s: begins, snum:%d\n", __func__, snum);
|
||||||
|
|
||||||
local_bh_disable();
|
|
||||||
|
|
||||||
if (snum == 0) {
|
if (snum == 0) {
|
||||||
/* Search for an available port. */
|
/* Search for an available port. */
|
||||||
int low, high, remaining, index;
|
int low, high, remaining, index;
|
||||||
|
@ -6226,20 +6224,21 @@ static long sctp_get_port_local(struct sock *sk, union sctp_addr *addr)
|
||||||
continue;
|
continue;
|
||||||
index = sctp_phashfn(sock_net(sk), rover);
|
index = sctp_phashfn(sock_net(sk), rover);
|
||||||
head = &sctp_port_hashtable[index];
|
head = &sctp_port_hashtable[index];
|
||||||
spin_lock(&head->lock);
|
spin_lock_bh(&head->lock);
|
||||||
sctp_for_each_hentry(pp, &head->chain)
|
sctp_for_each_hentry(pp, &head->chain)
|
||||||
if ((pp->port == rover) &&
|
if ((pp->port == rover) &&
|
||||||
net_eq(sock_net(sk), pp->net))
|
net_eq(sock_net(sk), pp->net))
|
||||||
goto next;
|
goto next;
|
||||||
break;
|
break;
|
||||||
next:
|
next:
|
||||||
spin_unlock(&head->lock);
|
spin_unlock_bh(&head->lock);
|
||||||
|
cond_resched();
|
||||||
} while (--remaining > 0);
|
} while (--remaining > 0);
|
||||||
|
|
||||||
/* Exhausted local port range during search? */
|
/* Exhausted local port range during search? */
|
||||||
ret = 1;
|
ret = 1;
|
||||||
if (remaining <= 0)
|
if (remaining <= 0)
|
||||||
goto fail;
|
return ret;
|
||||||
|
|
||||||
/* OK, here is the one we will use. HEAD (the port
|
/* OK, here is the one we will use. HEAD (the port
|
||||||
* hash table list entry) is non-NULL and we hold it's
|
* hash table list entry) is non-NULL and we hold it's
|
||||||
|
@ -6254,7 +6253,7 @@ static long sctp_get_port_local(struct sock *sk, union sctp_addr *addr)
|
||||||
* port iterator, pp being NULL.
|
* port iterator, pp being NULL.
|
||||||
*/
|
*/
|
||||||
head = &sctp_port_hashtable[sctp_phashfn(sock_net(sk), snum)];
|
head = &sctp_port_hashtable[sctp_phashfn(sock_net(sk), snum)];
|
||||||
spin_lock(&head->lock);
|
spin_lock_bh(&head->lock);
|
||||||
sctp_for_each_hentry(pp, &head->chain) {
|
sctp_for_each_hentry(pp, &head->chain) {
|
||||||
if ((pp->port == snum) && net_eq(pp->net, sock_net(sk)))
|
if ((pp->port == snum) && net_eq(pp->net, sock_net(sk)))
|
||||||
goto pp_found;
|
goto pp_found;
|
||||||
|
@ -6338,10 +6337,7 @@ success:
|
||||||
ret = 0;
|
ret = 0;
|
||||||
|
|
||||||
fail_unlock:
|
fail_unlock:
|
||||||
spin_unlock(&head->lock);
|
spin_unlock_bh(&head->lock);
|
||||||
|
|
||||||
fail:
|
|
||||||
local_bh_enable();
|
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue