tipc: introduce new capability flag for cluster

As a preparation for introducing a smooth switching between replicast
and broadcast method for multicast message, We have to introduce a new
capability flag TIPC_MCAST_RBCTL to handle this new feature.

During a cluster upgrade a node can come back with this new capabilities
which also must be reflected in the cluster capabilities field.
The new feature is only applicable if all node in the cluster supports
this new capability.

Acked-by: Jon Maloy <jon.maloy@ericsson.com>
Signed-off-by: Hoang Le <hoang.h.le@dektech.com.au>
Signed-off-by: David S. Miller <davem@davemloft.net>

1 files changed, 18 insertions, 0 deletions

diff --git a/net/tipc/node.c b/net/tipc/node.c
index 2dc4919ab23c..2717893e9dbe 100644
--- a/net/tipc/node.c
+++ b/net/tipc/node.c
@@ -383,6 +383,11 @@ static struct tipc_node *tipc_node_create(struct net *net, u32 addr,
                                 tipc_link_update_caps(l, capabilities);
                 }
                 write_unlock_bh(&n->lock);
+                /* Calculate cluster capabilities */
+                tn->capabilities = TIPC_NODE_CAPABILITIES;
+                list_for_each_entry_rcu(temp_node, &tn->node_list, list) {
+                        tn->capabilities &= temp_node->capabilities;
+                }
                 goto exit;
         }
         n = kzalloc(sizeof(*n), GFP_ATOMIC);
@@ -433,6 +438,11 @@ static struct tipc_node *tipc_node_create(struct net *net, u32 addr,
                         break;
         }
         list_add_tail_rcu(&n->list, &temp_node->list);
+        /* Calculate cluster capabilities */
+        tn->capabilities = TIPC_NODE_CAPABILITIES;
+        list_for_each_entry_rcu(temp_node, &tn->node_list, list) {
+                tn->capabilities &= temp_node->capabilities;
+        }
         trace_tipc_node_create(n, true, " ");
 exit:
         spin_unlock_bh(&tn->node_list_lock);
@@ -589,6 +599,7 @@ static void  tipc_node_clear_links(struct tipc_node *node)
  */
 static bool tipc_node_cleanup(struct tipc_node *peer)
 {
+        struct tipc_node *temp_node;
         struct tipc_net *tn = tipc_net(peer->net);
         bool deleted = false;
 
@@ -604,6 +615,13 @@ static bool tipc_node_cleanup(struct tipc_node *peer)
                 deleted = true;
         }
         tipc_node_write_unlock(peer);
+
+        /* Calculate cluster capabilities */
+        tn->capabilities = TIPC_NODE_CAPABILITIES;
+        list_for_each_entry_rcu(temp_node, &tn->node_list, list) {
+                tn->capabilities &= temp_node->capabilities;
+        }
+
         spin_unlock_bh(&tn->node_list_lock);
         return deleted;
 }