[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-Id: <1411573940-14079-14-git-send-email-ahmed@gandi.net>
Date: Wed, 24 Sep 2014 17:52:09 +0200
From: Ahmed Amamou <ahmed@...di.net>
To: netdev@...r.kernel.org
Cc: william@...di.net, f.cachereul@...halink.fr,
Ahmed Amamou <ahmed@...di.net>,
Kamel Haddadou <kamel@...di.net>
Subject: [RFC PATCH 13/24] net: rbridge: Add set_node function
allow daemon to set distant Rbridges information in local database
daemon has to periodically update distant Rbridges informations in local database
create a new node only if change on distant RBridge information are detected
Signed-off-by: Ahmed Amamou <ahmed@...di.net>
Signed-off-by: Kamel Haddadou <kamel@...di.net>
Signed-off-by: François Cachereul <f.cachereul@...halink.fr>
Signed-off-by: William Dauchy <william@...di.net>
---
net/bridge/rbridge/rbr_netlink.c | 78 ++++++++++++++++++++++++++++++++++++++++
1 file changed, 78 insertions(+)
diff --git a/net/bridge/rbridge/rbr_netlink.c b/net/bridge/rbridge/rbr_netlink.c
index 889e6c8..bb893f0 100644
--- a/net/bridge/rbridge/rbr_netlink.c
+++ b/net/bridge/rbridge/rbr_netlink.c
@@ -38,9 +38,87 @@ static struct genl_multicast_group trill_mcgrps[] = {
[TRILL_MCGRP_OFFSET] = {.name = TRILL_MCAST_NAME,},
};
+static int create_node(struct net_bridge_port *p, struct rbr *rbr,
+ struct rbr_nickinfo *rbr_ni_partial,
+ struct genl_info *info)
+{
+ size_t size = 0;
+ size_t old_size = 0;
+ struct rbr_node *old;
+ struct rbr_nickinfo *rbr_ni;
+
+ if (rbr_ni_partial == NULL)
+ return -EINVAL;
+
+ size = RBR_NI_TOTALSIZE(rbr_ni_partial);
+ if (size > PAGE_SIZE - sizeof(struct trill_nl_header)) {
+ pr_warn_ratelimited
+ ("create_node: size > (PAGE_SIZE-nickinfo_offset)\n");
+ return -EINVAL;
+ }
+ rbr_ni = kzalloc(size, GFP_KERNEL);
+ if (!rbr_ni)
+ return -ENOMEM;
+ old = rbr->rbr_nodes[rbr_ni_partial->nick];
+ nla_memcpy(rbr_ni, info->attrs[TRILL_ATTR_BIN], size);
+ if (old)
+ old_size = RBR_NI_TOTALSIZE(old->rbr_ni);
+ /* replace old node by a new one only if nickname information have changed */
+ if (old == NULL || old_size != size ||
+ memcmp(old->rbr_ni, rbr_ni, size)) {
+ struct rbr_node *new;
+
+ new = kzalloc(sizeof(*old), GFP_KERNEL);
+ if (!new) {
+ kfree(rbr_ni);
+ return -ENOMEM;
+ }
+ atomic_set(&new->refs, 1);
+ new->rbr_ni = rbr_ni;
+ /* avoid deleting node while it is been used for routing */
+ rcu_assign_pointer(rbr->rbr_nodes[rbr_ni->nick], new);
+ if (old)
+ rbr_node_put(old);
+ } else {
+ kfree(rbr_ni);
+ }
+
+ return 0;
+}
+
static int trill_cmd_set_nicks_info(struct sk_buff *skb, struct genl_info *info)
{
+ struct trill_nl_header *trnlhdr;
+ struct rbr_nickinfo rbr_ni;
+ struct net_device *source_port = NULL;
+ struct net *net = sock_net(skb->sk);
+ struct net_bridge_port *p = NULL;
+ int err = -EINVAL;
+
+ nla_memcpy(&rbr_ni, info->attrs[TRILL_ATTR_BIN], sizeof(rbr_ni));
+ if (!VALID_NICK(rbr_ni.nick))
+ goto fail;
+
+ trnlhdr = info->userhdr;
+ if (trnlhdr->ifindex)
+ source_port = __dev_get_by_index(net, trnlhdr->ifindex);
+
+ if (!source_port)
+ goto fail;
+
+ p = br_port_get_rcu(source_port);
+ if (!p || !(p->br) || !(p->br->rbr))
+ goto fail;
+
+ err = create_node(p, p->br->rbr, &rbr_ni, info);
+ if (err)
+ goto fail;
+
return 0;
+
+ fail:
+ printk(KERN_WARNING "trill_cmd_set_nicks_info FAILED\n");
+ return err;
}
static int trill_cmd_get_nicks_info(struct sk_buff *skb, struct genl_info *info)
--
1.9.1
--
To unsubscribe from this list: send the line "unsubscribe netdev" in
the body of a message to majordomo@...r.kernel.org
More majordomo info at http://vger.kernel.org/majordomo-info.html
Powered by blists - more mailing lists