|
@@ -1684,10 +1684,6 @@ static int fanout_add(struct sock *sk, u16 id, u16 type_flags)
|
|
|
|
|
|
mutex_lock(&fanout_mutex);
|
|
|
|
|
|
- err = -EINVAL;
|
|
|
- if (!po->running)
|
|
|
- goto out;
|
|
|
-
|
|
|
err = -EALREADY;
|
|
|
if (po->fanout)
|
|
|
goto out;
|
|
@@ -1749,7 +1745,10 @@ static int fanout_add(struct sock *sk, u16 id, u16 type_flags)
|
|
|
list_add(&match->list, &fanout_list);
|
|
|
}
|
|
|
err = -EINVAL;
|
|
|
- if (match->type == type &&
|
|
|
+
|
|
|
+ spin_lock(&po->bind_lock);
|
|
|
+ if (po->running &&
|
|
|
+ match->type == type &&
|
|
|
match->prot_hook.type == po->prot_hook.type &&
|
|
|
match->prot_hook.dev == po->prot_hook.dev) {
|
|
|
err = -ENOSPC;
|
|
@@ -1761,6 +1760,13 @@ static int fanout_add(struct sock *sk, u16 id, u16 type_flags)
|
|
|
err = 0;
|
|
|
}
|
|
|
}
|
|
|
+ spin_unlock(&po->bind_lock);
|
|
|
+
|
|
|
+ if (err && !refcount_read(&match->sk_ref)) {
|
|
|
+ list_del(&match->list);
|
|
|
+ kfree(match);
|
|
|
+ }
|
|
|
+
|
|
|
out:
|
|
|
if (err && rollover) {
|
|
|
kfree(rollover);
|