mac80211: don't probe if we have probe response

[safe/jmp/linux-2.6] / net / phonet / af_phonet.c

diff --git a/net/phonet/af_phonet.c b/net/phonet/af_phonet.c
index cc2eef1..526d027 100644 (file)
--- a/net/phonet/af_phonet.c
+++ b/net/phonet/af_phonet.c
@@ -35,7 +35,6 @@
 
 /* Transport protocol registration */
 static struct phonet_protocol *proto_tab[PHONET_NPROTO] __read_mostly;
-static DEFINE_SPINLOCK(proto_tab_lock);
 
 static struct phonet_protocol *phonet_proto_get(int protocol)
 {
@@ -44,11 +43,11 @@ static struct phonet_protocol *phonet_proto_get(int protocol)
        if (protocol >= PHONET_NPROTO)
                return NULL;
 
-       spin_lock(&proto_tab_lock);
-       pp = proto_tab[protocol];
+       rcu_read_lock();
+       pp = rcu_dereference(proto_tab[protocol]);
        if (pp && !try_module_get(pp->prot->owner))
                pp = NULL;
-       spin_unlock(&proto_tab_lock);
+       rcu_read_unlock();
 
        return pp;
 }
@@ -60,7 +59,8 @@ static inline void phonet_proto_put(struct phonet_protocol *pp)
 
 /* protocol family functions */
 
-static int pn_socket_create(struct net *net, struct socket *sock, int protocol)
+static int pn_socket_create(struct net *net, struct socket *sock, int protocol,
+                           int kern)
 {
        struct sock *sk;
        struct pn_sock *pn;
@@ -394,6 +394,38 @@ static int phonet_rcv(struct sk_buff *skb, struct net_device *dev,
                        send_obj_unreachable(skb);
                        send_reset_indications(skb);
                }
+       } else if (unlikely(skb->pkt_type == PACKET_LOOPBACK))
+               goto out; /* Race between address deletion and loopback */
+       else {
+               /* Phonet packet routing */
+               struct net_device *out_dev;
+
+               out_dev = phonet_route_output(net, pn_sockaddr_get_addr(&sa));
+               if (!out_dev) {
+                       LIMIT_NETDEBUG(KERN_WARNING"No Phonet route to %02X\n",
+                                       pn_sockaddr_get_addr(&sa));
+                       goto out;
+               }
+
+               __skb_push(skb, sizeof(struct phonethdr));
+               skb->dev = out_dev;
+               if (out_dev == dev) {
+                       LIMIT_NETDEBUG(KERN_ERR"Phonet loop to %02X on %s\n",
+                                       pn_sockaddr_get_addr(&sa), dev->name);
+                       goto out_dev;
+               }
+               /* Some drivers (e.g. TUN) do not allocate HW header space */
+               if (skb_cow_head(skb, out_dev->hard_header_len))
+                       goto out_dev;
+
+               if (dev_hard_header(skb, out_dev, ETH_P_PHONET, NULL, NULL,
+                                       skb->len) < 0)
+                       goto out_dev;
+               dev_queue_xmit(skb);
+               dev_put(out_dev);
+               return NET_RX_SUCCESS;
+out_dev:
+               dev_put(out_dev);
        }
 
 out:
@@ -406,6 +438,8 @@ static struct packet_type phonet_packet_type __read_mostly = {
        .func = phonet_rcv,
 };
 
+static DEFINE_MUTEX(proto_tab_lock);
+
 int __init_or_module phonet_proto_register(int protocol,
                                                struct phonet_protocol *pp)
 {
@@ -418,12 +452,12 @@ int __init_or_module phonet_proto_register(int protocol,
        if (err)
                return err;
 
-       spin_lock(&proto_tab_lock);
+       mutex_lock(&proto_tab_lock);
        if (proto_tab[protocol])
                err = -EBUSY;
        else
-               proto_tab[protocol] = pp;
-       spin_unlock(&proto_tab_lock);
+               rcu_assign_pointer(proto_tab[protocol], pp);
+       mutex_unlock(&proto_tab_lock);
 
        return err;
 }
@@ -431,10 +465,11 @@ EXPORT_SYMBOL(phonet_proto_register);
 
 void phonet_proto_unregister(int protocol, struct phonet_protocol *pp)
 {
-       spin_lock(&proto_tab_lock);
+       mutex_lock(&proto_tab_lock);
        BUG_ON(proto_tab[protocol] != pp);
-       proto_tab[protocol] = NULL;
-       spin_unlock(&proto_tab_lock);
+       rcu_assign_pointer(proto_tab[protocol], NULL);
+       mutex_unlock(&proto_tab_lock);
+       synchronize_rcu();
        proto_unregister(pp->prot);
 }
 EXPORT_SYMBOL(phonet_proto_unregister);
@@ -448,6 +483,7 @@ static int __init phonet_init(void)
        if (err)
                return err;
 
+       pn_sock_init();
        err = sock_register(&phonet_proto_family);
        if (err) {
                printk(KERN_ALERT