Skip to content

L
linux
Commit 2d408b42 authored by Linus Torvalds's avatar Linus Torvalds
Browse files
Options

Merge branch 'master' of master.kernel.org:/pub/scm/linux/kernel/git/davem/net-2.6 

* 'master' of master.kernel.org:/pub/scm/linux/kernel/git/davem/net-2.6:
  [IRDA]: fix printk format
  [NETPOLL] netconsole: fix soft lockup when removing module
  [NETPOLL]: tx lock deadlock fix
  SCTP: lock_sock_nested in sctp_sock_migrate
  SCTP: Fix sctp_getsockopt_get_peer_addrs
  SCTP: update sctp_getsockopt helpers to allow oversized buffers
parents fde937d8 5f021217
Hide whitespace changes
Inline Side-by-side
Showing with 101 additions and 51 deletions
drivers/net/irda/irport.c
View file @ 2d408b42
...@@ -509,7 +509,7 @@ static void irport_timeout(struct net_device *dev) ...@@ -509,7 +509,7 @@ static void irport_timeout(struct net_device *dev)
IRDA_DEBUG(0, "%s(), iir=%02x, lsr=%02x, iobase=%#x\n", IRDA_DEBUG(0, "%s(), iir=%02x, lsr=%02x, iobase=%#x\n",
__FUNCTION__, iir, lsr, iobase); __FUNCTION__, iir, lsr, iobase);
IRDA_DEBUG(0, "%s(), transmitting=%d, remain=%d, done=%d\n", IRDA_DEBUG(0, "%s(), transmitting=%d, remain=%d, done=%td\n",
__FUNCTION__, self->transmitting, self->tx_buff.len, __FUNCTION__, self->transmitting, self->tx_buff.len,
self->tx_buff.data - self->tx_buff.head); self->tx_buff.data - self->tx_buff.head);
......
net/core/netpoll.c
View file @ 2d408b42
...@@ -72,7 +72,8 @@ static void queue_process(struct work_struct *work) ...@@ -72,7 +72,8 @@ static void queue_process(struct work_struct *work)
netif_tx_unlock(dev); netif_tx_unlock(dev);
local_irq_restore(flags); local_irq_restore(flags);
schedule_delayed_work(&npinfo->tx_work, HZ/10); if (atomic_read(&npinfo->refcnt))
schedule_delayed_work(&npinfo->tx_work, HZ/10);
return; return;
} }
netif_tx_unlock(dev); netif_tx_unlock(dev);
...@@ -250,22 +251,23 @@ static void netpoll_send_skb(struct netpoll *np, struct sk_buff *skb) ...@@ -250,22 +251,23 @@ static void netpoll_send_skb(struct netpoll *np, struct sk_buff *skb)
unsigned long flags; unsigned long flags;
local_irq_save(flags); local_irq_save(flags);
if (netif_tx_trylock(dev)) { /* try until next clock tick */
/* try until next clock tick */ for (tries = jiffies_to_usecs(1)/USEC_PER_POLL;
for (tries = jiffies_to_usecs(1)/USEC_PER_POLL; tries > 0; --tries) {
tries > 0; --tries) { if (netif_tx_trylock(dev)) {
if (!netif_queue_stopped(dev)) if (!netif_queue_stopped(dev))
status = dev->hard_start_xmit(skb, dev); status = dev->hard_start_xmit(skb, dev);
netif_tx_unlock(dev);
if (status == NETDEV_TX_OK) if (status == NETDEV_TX_OK)
break; break;
/* tickle device maybe there is some cleanup */
netpoll_poll(np);
udelay(USEC_PER_POLL);
} }
netif_tx_unlock(dev);
/* tickle device maybe there is some cleanup */
netpoll_poll(np);
udelay(USEC_PER_POLL);
} }
local_irq_restore(flags); local_irq_restore(flags);
} }
...@@ -784,9 +786,15 @@ void netpoll_cleanup(struct netpoll *np) ...@@ -784,9 +786,15 @@ void netpoll_cleanup(struct netpoll *np)
if (atomic_dec_and_test(&npinfo->refcnt)) { if (atomic_dec_and_test(&npinfo->refcnt)) {
skb_queue_purge(&npinfo->arp_tx); skb_queue_purge(&npinfo->arp_tx);
skb_queue_purge(&npinfo->txq); skb_queue_purge(&npinfo->txq);
cancel_rearming_delayed_work(&npinfo->tx_work); cancel_delayed_work(&npinfo->tx_work);
flush_scheduled_work(); flush_scheduled_work();
/* clean after last, unfinished work */
if (!skb_queue_empty(&npinfo->txq)) {
struct sk_buff *skb;
skb = __skb_dequeue(&npinfo->txq);
kfree_skb(skb);
}
kfree(npinfo); kfree(npinfo);
} }
} }
......
net/sctp/socket.c
View file @ 2d408b42
...@@ -3375,12 +3375,13 @@ static int sctp_getsockopt_sctp_status(struct sock *sk, int len, ...@@ -3375,12 +3375,13 @@ static int sctp_getsockopt_sctp_status(struct sock *sk, int len,
sctp_assoc_t associd; sctp_assoc_t associd;
int retval = 0; int retval = 0;
if (len != sizeof(status)) { if (len < sizeof(status)) {
retval = -EINVAL; retval = -EINVAL;
goto out; goto out;
} }
if (copy_from_user(&status, optval, sizeof(status))) { len = sizeof(status);
if (copy_from_user(&status, optval, len)) {
retval = -EFAULT; retval = -EFAULT;
goto out; goto out;
} }
...@@ -3452,12 +3453,13 @@ static int sctp_getsockopt_peer_addr_info(struct sock *sk, int len, ...@@ -3452,12 +3453,13 @@ static int sctp_getsockopt_peer_addr_info(struct sock *sk, int len,
struct sctp_transport *transport; struct sctp_transport *transport;
int retval = 0; int retval = 0;
if (len != sizeof(pinfo)) { if (len < sizeof(pinfo)) {
retval = -EINVAL; retval = -EINVAL;
goto out; goto out;
} }
if (copy_from_user(&pinfo, optval, sizeof(pinfo))) { len = sizeof(pinfo);
if (copy_from_user(&pinfo, optval, len)) {
retval = -EFAULT; retval = -EFAULT;
goto out; goto out;
} }
...@@ -3523,8 +3525,11 @@ static int sctp_getsockopt_disable_fragments(struct sock *sk, int len, ...@@ -3523,8 +3525,11 @@ static int sctp_getsockopt_disable_fragments(struct sock *sk, int len,
static int sctp_getsockopt_events(struct sock *sk, int len, char __user *optval, static int sctp_getsockopt_events(struct sock *sk, int len, char __user *optval,
int __user *optlen) int __user *optlen)
{ {
if (len != sizeof(struct sctp_event_subscribe)) if (len < sizeof(struct sctp_event_subscribe))
return -EINVAL; return -EINVAL;
len = sizeof(struct sctp_event_subscribe);
if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &sctp_sk(sk)->subscribe, len)) if (copy_to_user(optval, &sctp_sk(sk)->subscribe, len))
return -EFAULT; return -EFAULT;
return 0; return 0;
...@@ -3546,9 +3551,12 @@ static int sctp_getsockopt_autoclose(struct sock *sk, int len, char __user *optv ...@@ -3546,9 +3551,12 @@ static int sctp_getsockopt_autoclose(struct sock *sk, int len, char __user *optv
/* Applicable to UDP-style socket only */ /* Applicable to UDP-style socket only */
if (sctp_style(sk, TCP)) if (sctp_style(sk, TCP))
return -EOPNOTSUPP; return -EOPNOTSUPP;
if (len != sizeof(int)) if (len < sizeof(int))
return -EINVAL; return -EINVAL;
if (copy_to_user(optval, &sctp_sk(sk)->autoclose, len)) len = sizeof(int);
if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &sctp_sk(sk)->autoclose, sizeof(int)))
return -EFAULT; return -EFAULT;
return 0; return 0;
} }
...@@ -3599,8 +3607,9 @@ static int sctp_getsockopt_peeloff(struct sock *sk, int len, char __user *optval ...@@ -3599,8 +3607,9 @@ static int sctp_getsockopt_peeloff(struct sock *sk, int len, char __user *optval
int retval = 0; int retval = 0;
struct sctp_association *asoc; struct sctp_association *asoc;
if (len != sizeof(sctp_peeloff_arg_t)) if (len < sizeof(sctp_peeloff_arg_t))
return -EINVAL; return -EINVAL;
len = sizeof(sctp_peeloff_arg_t);
if (copy_from_user(&peeloff, optval, len)) if (copy_from_user(&peeloff, optval, len))
return -EFAULT; return -EFAULT;
...@@ -3628,6 +3637,8 @@ static int sctp_getsockopt_peeloff(struct sock *sk, int len, char __user *optval ...@@ -3628,6 +3637,8 @@ static int sctp_getsockopt_peeloff(struct sock *sk, int len, char __user *optval
/* Return the fd mapped to the new socket. */ /* Return the fd mapped to the new socket. */
peeloff.sd = retval; peeloff.sd = retval;
if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &peeloff, len)) if (copy_to_user(optval, &peeloff, len))
retval = -EFAULT; retval = -EFAULT;
...@@ -3736,9 +3747,9 @@ static int sctp_getsockopt_peer_addr_params(struct sock *sk, int len, ...@@ -3736,9 +3747,9 @@ static int sctp_getsockopt_peer_addr_params(struct sock *sk, int len,
struct sctp_association *asoc = NULL; struct sctp_association *asoc = NULL;
struct sctp_sock *sp = sctp_sk(sk); struct sctp_sock *sp = sctp_sk(sk);
if (len != sizeof(struct sctp_paddrparams)) if (len < sizeof(struct sctp_paddrparams))
return -EINVAL; return -EINVAL;
len = sizeof(struct sctp_paddrparams);
if (copy_from_user(&params, optval, len)) if (copy_from_user(&params, optval, len))
return -EFAULT; return -EFAULT;
...@@ -3837,9 +3848,11 @@ static int sctp_getsockopt_delayed_ack_time(struct sock *sk, int len, ...@@ -3837,9 +3848,11 @@ static int sctp_getsockopt_delayed_ack_time(struct sock *sk, int len,
struct sctp_association *asoc = NULL; struct sctp_association *asoc = NULL;
struct sctp_sock *sp = sctp_sk(sk); struct sctp_sock *sp = sctp_sk(sk);
if (len != sizeof(struct sctp_assoc_value)) if (len < sizeof(struct sctp_assoc_value))
return - EINVAL; return - EINVAL;
len = sizeof(struct sctp_assoc_value);
if (copy_from_user(&params, optval, len)) if (copy_from_user(&params, optval, len))
return -EFAULT; return -EFAULT;
...@@ -3888,8 +3901,11 @@ static int sctp_getsockopt_delayed_ack_time(struct sock *sk, int len, ...@@ -3888,8 +3901,11 @@ static int sctp_getsockopt_delayed_ack_time(struct sock *sk, int len,
*/ */
static int sctp_getsockopt_initmsg(struct sock *sk, int len, char __user *optval, int __user *optlen) static int sctp_getsockopt_initmsg(struct sock *sk, int len, char __user *optval, int __user *optlen)
{ {
if (len != sizeof(struct sctp_initmsg)) if (len < sizeof(struct sctp_initmsg))
return -EINVAL; return -EINVAL;
len = sizeof(struct sctp_initmsg);
if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &sctp_sk(sk)->initmsg, len)) if (copy_to_user(optval, &sctp_sk(sk)->initmsg, len))
return -EFAULT; return -EFAULT;
return 0; return 0;
...@@ -3904,7 +3920,7 @@ static int sctp_getsockopt_peer_addrs_num_old(struct sock *sk, int len, ...@@ -3904,7 +3920,7 @@ static int sctp_getsockopt_peer_addrs_num_old(struct sock *sk, int len,
struct list_head *pos; struct list_head *pos;
int cnt = 0; int cnt = 0;
if (len != sizeof(sctp_assoc_t)) if (len < sizeof(sctp_assoc_t))
return -EINVAL; return -EINVAL;
if (copy_from_user(&id, optval, sizeof(sctp_assoc_t))) if (copy_from_user(&id, optval, sizeof(sctp_assoc_t)))
...@@ -3940,10 +3956,12 @@ static int sctp_getsockopt_peer_addrs_old(struct sock *sk, int len, ...@@ -3940,10 +3956,12 @@ static int sctp_getsockopt_peer_addrs_old(struct sock *sk, int len,
struct sctp_sock *sp = sctp_sk(sk); struct sctp_sock *sp = sctp_sk(sk);
int addrlen; int addrlen;
if (len != sizeof(struct sctp_getaddrs_old)) if (len < sizeof(struct sctp_getaddrs_old))
return -EINVAL; return -EINVAL;
if (copy_from_user(&getaddrs, optval, sizeof(struct sctp_getaddrs_old))) len = sizeof(struct sctp_getaddrs_old);
if (copy_from_user(&getaddrs, optval, len))
return -EFAULT; return -EFAULT;
if (getaddrs.addr_num <= 0) return -EINVAL; if (getaddrs.addr_num <= 0) return -EINVAL;
...@@ -3966,7 +3984,9 @@ static int sctp_getsockopt_peer_addrs_old(struct sock *sk, int len, ...@@ -3966,7 +3984,9 @@ static int sctp_getsockopt_peer_addrs_old(struct sock *sk, int len,
if (cnt >= getaddrs.addr_num) break; if (cnt >= getaddrs.addr_num) break;
} }
getaddrs.addr_num = cnt; getaddrs.addr_num = cnt;
if (copy_to_user(optval, &getaddrs, sizeof(struct sctp_getaddrs_old))) if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &getaddrs, len))
return -EFAULT; return -EFAULT;
return 0; return 0;
...@@ -3999,8 +4019,7 @@ static int sctp_getsockopt_peer_addrs(struct sock *sk, int len, ...@@ -3999,8 +4019,7 @@ static int sctp_getsockopt_peer_addrs(struct sock *sk, int len,
return -EINVAL; return -EINVAL;
to = optval + offsetof(struct sctp_getaddrs,addrs); to = optval + offsetof(struct sctp_getaddrs,addrs);
space_left = len - sizeof(struct sctp_getaddrs) - space_left = len - offsetof(struct sctp_getaddrs,addrs);
offsetof(struct sctp_getaddrs,addrs);
list_for_each(pos, &asoc->peer.transport_addr_list) { list_for_each(pos, &asoc->peer.transport_addr_list) {
from = list_entry(pos, struct sctp_transport, transports); from = list_entry(pos, struct sctp_transport, transports);
...@@ -4037,7 +4056,7 @@ static int sctp_getsockopt_local_addrs_num_old(struct sock *sk, int len, ...@@ -4037,7 +4056,7 @@ static int sctp_getsockopt_local_addrs_num_old(struct sock *sk, int len,
rwlock_t *addr_lock; rwlock_t *addr_lock;
int cnt = 0; int cnt = 0;
if (len != sizeof(sctp_assoc_t)) if (len < sizeof(sctp_assoc_t))
return -EINVAL; return -EINVAL;
if (copy_from_user(&id, optval, sizeof(sctp_assoc_t))) if (copy_from_user(&id, optval, sizeof(sctp_assoc_t)))
...@@ -4179,10 +4198,11 @@ static int sctp_getsockopt_local_addrs_old(struct sock *sk, int len, ...@@ -4179,10 +4198,11 @@ static int sctp_getsockopt_local_addrs_old(struct sock *sk, int len,
void *buf; void *buf;
int bytes_copied = 0; int bytes_copied = 0;
if (len != sizeof(struct sctp_getaddrs_old)) if (len < sizeof(struct sctp_getaddrs_old))
return -EINVAL; return -EINVAL;
if (copy_from_user(&getaddrs, optval, sizeof(struct sctp_getaddrs_old))) len = sizeof(struct sctp_getaddrs_old);
if (copy_from_user(&getaddrs, optval, len))
return -EFAULT; return -EFAULT;
if (getaddrs.addr_num <= 0) return -EINVAL; if (getaddrs.addr_num <= 0) return -EINVAL;
...@@ -4254,7 +4274,7 @@ static int sctp_getsockopt_local_addrs_old(struct sock *sk, int len, ...@@ -4254,7 +4274,7 @@ static int sctp_getsockopt_local_addrs_old(struct sock *sk, int len,
/* copy the leading structure back to user */ /* copy the leading structure back to user */
getaddrs.addr_num = cnt; getaddrs.addr_num = cnt;
if (copy_to_user(optval, &getaddrs, sizeof(struct sctp_getaddrs_old))) if (copy_to_user(optval, &getaddrs, len))
err = -EFAULT; err = -EFAULT;
error: error:
...@@ -4282,7 +4302,7 @@ static int sctp_getsockopt_local_addrs(struct sock *sk, int len, ...@@ -4282,7 +4302,7 @@ static int sctp_getsockopt_local_addrs(struct sock *sk, int len,
void *addrs; void *addrs;
void *buf; void *buf;
if (len <= sizeof(struct sctp_getaddrs)) if (len < sizeof(struct sctp_getaddrs))
return -EINVAL; return -EINVAL;
if (copy_from_user(&getaddrs, optval, sizeof(struct sctp_getaddrs))) if (copy_from_user(&getaddrs, optval, sizeof(struct sctp_getaddrs)))
...@@ -4306,8 +4326,8 @@ static int sctp_getsockopt_local_addrs(struct sock *sk, int len, ...@@ -4306,8 +4326,8 @@ static int sctp_getsockopt_local_addrs(struct sock *sk, int len,
} }
to = optval + offsetof(struct sctp_getaddrs,addrs); to = optval + offsetof(struct sctp_getaddrs,addrs);
space_left = len - sizeof(struct sctp_getaddrs) - space_left = len - offsetof(struct sctp_getaddrs,addrs);
offsetof(struct sctp_getaddrs,addrs);
addrs = kmalloc(space_left, GFP_KERNEL); addrs = kmalloc(space_left, GFP_KERNEL);
if (!addrs) if (!addrs)
return -ENOMEM; return -ENOMEM;
...@@ -4379,10 +4399,12 @@ static int sctp_getsockopt_primary_addr(struct sock *sk, int len, ...@@ -4379,10 +4399,12 @@ static int sctp_getsockopt_primary_addr(struct sock *sk, int len,
struct sctp_association *asoc; struct sctp_association *asoc;
struct sctp_sock *sp = sctp_sk(sk); struct sctp_sock *sp = sctp_sk(sk);
if (len != sizeof(struct sctp_prim)) if (len < sizeof(struct sctp_prim))
return -EINVAL; return -EINVAL;
if (copy_from_user(&prim, optval, sizeof(struct sctp_prim))) len = sizeof(struct sctp_prim);
if (copy_from_user(&prim, optval, len))
return -EFAULT; return -EFAULT;
asoc = sctp_id2assoc(sk, prim.ssp_assoc_id); asoc = sctp_id2assoc(sk, prim.ssp_assoc_id);
...@@ -4398,7 +4420,9 @@ static int sctp_getsockopt_primary_addr(struct sock *sk, int len, ...@@ -4398,7 +4420,9 @@ static int sctp_getsockopt_primary_addr(struct sock *sk, int len,
sctp_get_pf_specific(sk->sk_family)->addr_v4map(sp, sctp_get_pf_specific(sk->sk_family)->addr_v4map(sp,
(union sctp_addr *)&prim.ssp_addr); (union sctp_addr *)&prim.ssp_addr);
if (copy_to_user(optval, &prim, sizeof(struct sctp_prim))) if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &prim, len))
return -EFAULT; return -EFAULT;
return 0; return 0;
...@@ -4415,10 +4439,15 @@ static int sctp_getsockopt_adaptation_layer(struct sock *sk, int len, ...@@ -4415,10 +4439,15 @@ static int sctp_getsockopt_adaptation_layer(struct sock *sk, int len,
{ {
struct sctp_setadaptation adaptation; struct sctp_setadaptation adaptation;
if (len != sizeof(struct sctp_setadaptation)) if (len < sizeof(struct sctp_setadaptation))
return -EINVAL; return -EINVAL;
len = sizeof(struct sctp_setadaptation);
adaptation.ssb_adaptation_ind = sctp_sk(sk)->adaptation_ind; adaptation.ssb_adaptation_ind = sctp_sk(sk)->adaptation_ind;
if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &adaptation, len)) if (copy_to_user(optval, &adaptation, len))
return -EFAULT; return -EFAULT;
...@@ -4452,9 +4481,12 @@ static int sctp_getsockopt_default_send_param(struct sock *sk, ...@@ -4452,9 +4481,12 @@ static int sctp_getsockopt_default_send_param(struct sock *sk,
struct sctp_association *asoc; struct sctp_association *asoc;
struct sctp_sock *sp = sctp_sk(sk); struct sctp_sock *sp = sctp_sk(sk);
if (len != sizeof(struct sctp_sndrcvinfo)) if (len < sizeof(struct sctp_sndrcvinfo))
return -EINVAL; return -EINVAL;
if (copy_from_user(&info, optval, sizeof(struct sctp_sndrcvinfo)))
len = sizeof(struct sctp_sndrcvinfo);
if (copy_from_user(&info, optval, len))
return -EFAULT; return -EFAULT;
asoc = sctp_id2assoc(sk, info.sinfo_assoc_id); asoc = sctp_id2assoc(sk, info.sinfo_assoc_id);
...@@ -4475,7 +4507,9 @@ static int sctp_getsockopt_default_send_param(struct sock *sk, ...@@ -4475,7 +4507,9 @@ static int sctp_getsockopt_default_send_param(struct sock *sk,
info.sinfo_timetolive = sp->default_timetolive; info.sinfo_timetolive = sp->default_timetolive;
} }
if (copy_to_user(optval, &info, sizeof(struct sctp_sndrcvinfo))) if (put_user(len, optlen))
return -EFAULT;
if (copy_to_user(optval, &info, len))
return -EFAULT; return -EFAULT;
return 0; return 0;
...@@ -4526,10 +4560,12 @@ static int sctp_getsockopt_rtoinfo(struct sock *sk, int len, ...@@ -4526,10 +4560,12 @@ static int sctp_getsockopt_rtoinfo(struct sock *sk, int len,
struct sctp_rtoinfo rtoinfo; struct sctp_rtoinfo rtoinfo;
struct sctp_association *asoc; struct sctp_association *asoc;
if (len != sizeof (struct sctp_rtoinfo)) if (len < sizeof (struct sctp_rtoinfo))
return -EINVAL; return -EINVAL;
if (copy_from_user(&rtoinfo, optval, sizeof (struct sctp_rtoinfo))) len = sizeof(struct sctp_rtoinfo);
if (copy_from_user(&rtoinfo, optval, len))
return -EFAULT; return -EFAULT;
asoc = sctp_id2assoc(sk, rtoinfo.srto_assoc_id); asoc = sctp_id2assoc(sk, rtoinfo.srto_assoc_id);
...@@ -4581,11 +4617,12 @@ static int sctp_getsockopt_associnfo(struct sock *sk, int len, ...@@ -4581,11 +4617,12 @@ static int sctp_getsockopt_associnfo(struct sock *sk, int len,
struct list_head *pos; struct list_head *pos;
int cnt = 0; int cnt = 0;
if (len != sizeof (struct sctp_assocparams)) if (len < sizeof (struct sctp_assocparams))
return -EINVAL; return -EINVAL;
if (copy_from_user(&assocparams, optval, len = sizeof(struct sctp_assocparams);
sizeof (struct sctp_assocparams)))
if (copy_from_user(&assocparams, optval, len))
return -EFAULT; return -EFAULT;
asoc = sctp_id2assoc(sk, assocparams.sasoc_assoc_id); asoc = sctp_id2assoc(sk, assocparams.sasoc_assoc_id);
...@@ -4671,9 +4708,11 @@ static int sctp_getsockopt_context(struct sock *sk, int len, ...@@ -4671,9 +4708,11 @@ static int sctp_getsockopt_context(struct sock *sk, int len,
struct sctp_sock *sp; struct sctp_sock *sp;
struct sctp_association *asoc; struct sctp_association *asoc;
if (len != sizeof(struct sctp_assoc_value)) if (len < sizeof(struct sctp_assoc_value))
return -EINVAL; return -EINVAL;
len = sizeof(struct sctp_assoc_value);
if (copy_from_user(&params, optval, len)) if (copy_from_user(&params, optval, len))
return -EFAULT; return -EFAULT;
...@@ -6084,8 +6123,11 @@ static void sctp_sock_migrate(struct sock *oldsk, struct sock *newsk, ...@@ -6084,8 +6123,11 @@ static void sctp_sock_migrate(struct sock *oldsk, struct sock *newsk,
* queued to the backlog. This prevents a potential race between * queued to the backlog. This prevents a potential race between
* backlog processing on the old socket and new-packet processing * backlog processing on the old socket and new-packet processing
* on the new socket. * on the new socket.
*
* The caller has just allocated newsk so we can guarantee that other
* paths won't try to lock it and then oldsk.
*/ */
sctp_lock_sock(newsk); lock_sock_nested(newsk, SINGLE_DEPTH_NESTING);
sctp_assoc_migrate(assoc, newsk); sctp_assoc_migrate(assoc, newsk);
/* If the association on the newsk is already closed before accept() /* If the association on the newsk is already closed before accept()
......
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