diff options
author | Jon Maloy <jon.maloy@ericsson.com> | 2018-02-14 13:34:39 +0100 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2018-02-14 15:22:24 -0500 |
commit | 37c64cf63ba1f9c071b37a2129ae9860fd423d6c (patch) | |
tree | 9c4837a85252baa3e662757ae90f04caca2cd110 /net/tipc/node.c | |
parent | a92ac140fc30f5e8fc407d75de44e0bce7f59ab6 (diff) | |
download | linux-stable-37c64cf63ba1f9c071b37a2129ae9860fd423d6c.tar.gz linux-stable-37c64cf63ba1f9c071b37a2129ae9860fd423d6c.tar.bz2 linux-stable-37c64cf63ba1f9c071b37a2129ae9860fd423d6c.zip |
tipc: apply bearer link tolerance on running links
Currently, the default link tolerance set in struct tipc_bearer only
has effect on links going up after that moment. I.e., a user has to
reset all the node's links across that bearer to have the new value
applied. This is too limiting and disturbing on a running cluster to
be useful.
We now change this so that also already existing links are updated
dynamically, without any need for a reset, when the bearer value is
changed. We leverage the already existing per-link functionality
for this to achieve the wanted effect.
Acked-by: Ying Xue <ying.xue@windriver.com>
Signed-off-by: Jon Maloy <jon.maloy@ericsson.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/tipc/node.c')
-rw-r--r-- | net/tipc/node.c | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/net/tipc/node.c b/net/tipc/node.c index 9036d8756e73..389193d7cf67 100644 --- a/net/tipc/node.c +++ b/net/tipc/node.c @@ -1618,6 +1618,30 @@ discard: kfree_skb(skb); } +void tipc_node_apply_tolerance(struct net *net, struct tipc_bearer *b) +{ + struct tipc_net *tn = tipc_net(net); + int bearer_id = b->identity; + struct sk_buff_head xmitq; + struct tipc_link_entry *e; + struct tipc_node *n; + + __skb_queue_head_init(&xmitq); + + rcu_read_lock(); + + list_for_each_entry_rcu(n, &tn->node_list, list) { + tipc_node_write_lock(n); + e = &n->links[bearer_id]; + if (e->link) + tipc_link_set_tolerance(e->link, b->tolerance, &xmitq); + tipc_node_write_unlock(n); + tipc_bearer_xmit(net, bearer_id, &xmitq, &e->maddr); + } + + rcu_read_unlock(); +} + int tipc_nl_peer_rm(struct sk_buff *skb, struct genl_info *info) { struct net *net = sock_net(skb->sk); |