tipc: add neighbor monitoring framework

[karo-tx-linux.git] / net / tipc / node.c

diff --git a/net/tipc/node.c b/net/tipc/node.c
index e01e2c71b5a16fde975b6e87bd134ae57cd57326..a3fc0a3f4077f2aa249fe786fb4362b9c2c4d2a0 100644 (file)
--- a/net/tipc/node.c
+++ b/net/tipc/node.c
@@ -40,6 +40,7 @@
 #include "name_distr.h"
 #include "socket.h"
 #include "bcast.h"
+#include "monitor.h"
 #include "discover.h"
 #include "netlink.h"
 
@@ -205,17 +206,6 @@ u16 tipc_node_get_capabilities(struct net *net, u32 addr)
        return caps;
 }
 
-/*
- * A trivial power-of-two bitmask technique is used for speed, since this
- * operation is done for every incoming TIPC packet. The number of hash table
- * entries has been chosen so that no hash chain exceeds 8 nodes and will
- * usually be much smaller (typically only a single node).
- */
-static unsigned int tipc_hashfn(u32 addr)
-{
-       return addr & (NODE_HTABLE_SIZE - 1);
-}
-
 static void tipc_node_kref_release(struct kref *kref)
 {
        struct tipc_node *n = container_of(kref, struct tipc_node, kref);
@@ -279,6 +269,7 @@ static void tipc_node_write_unlock(struct tipc_node *n)
        u32 addr = 0;
        u32 flags = n->action_flags;
        u32 link_id = 0;
+       u32 bearer_id;
        struct list_head *publ_list;
 
        if (likely(!flags)) {
@@ -288,6 +279,7 @@ static void tipc_node_write_unlock(struct tipc_node *n)
 
        addr = n->addr;
        link_id = n->link_id;
+       bearer_id = link_id & 0xffff;
        publ_list = &n->publ_list;
 
        n->action_flags &= ~(TIPC_NOTIFY_NODE_DOWN | TIPC_NOTIFY_NODE_UP |
@@ -301,13 +293,16 @@ static void tipc_node_write_unlock(struct tipc_node *n)
        if (flags & TIPC_NOTIFY_NODE_UP)
                tipc_named_node_up(net, addr);
 
-       if (flags & TIPC_NOTIFY_LINK_UP)
+       if (flags & TIPC_NOTIFY_LINK_UP) {
+               tipc_mon_peer_up(net, addr, bearer_id);
                tipc_nametbl_publish(net, TIPC_LINK_STATE, addr, addr,
                                     TIPC_NODE_SCOPE, link_id, addr);
-
-       if (flags & TIPC_NOTIFY_LINK_DOWN)
+       }
+       if (flags & TIPC_NOTIFY_LINK_DOWN) {
+               tipc_mon_peer_down(net, addr, bearer_id);
                tipc_nametbl_withdraw(net, TIPC_LINK_STATE, addr,
                                      link_id, addr);
+       }
 }
 
 struct tipc_node *tipc_node_create(struct net *net, u32 addr, u16 capabilities)
@@ -378,14 +373,13 @@ static void tipc_node_calculate_timer(struct tipc_node *n, struct tipc_link *l)
 {
        unsigned long tol = tipc_link_tolerance(l);
        unsigned long intv = ((tol / 4) > 500) ? 500 : tol / 4;
-       unsigned long keepalive_intv = msecs_to_jiffies(intv);
 
        /* Link with lowest tolerance determines timer interval */
-       if (keepalive_intv < n->keepalive_intv)
-               n->keepalive_intv = keepalive_intv;
+       if (intv < n->keepalive_intv)
+               n->keepalive_intv = intv;
 
-       /* Ensure link's abort limit corresponds to current interval */
-       tipc_link_set_abort_limit(l, tol / jiffies_to_msecs(n->keepalive_intv));
+       /* Ensure link's abort limit corresponds to current tolerance */
+       tipc_link_set_abort_limit(l, tol / n->keepalive_intv);
 }
 
 static void tipc_node_delete(struct tipc_node *node)
@@ -526,7 +520,7 @@ static void tipc_node_timeout(unsigned long data)
                if (rc & TIPC_LINK_DOWN_EVT)
                        tipc_node_link_down(n, bearer_id, false);
        }
-       mod_timer(&n->timer, jiffies + n->keepalive_intv);
+       mod_timer(&n->timer, jiffies + msecs_to_jiffies(n->keepalive_intv));
 }
 
 /**
@@ -692,6 +686,7 @@ static void tipc_node_link_down(struct tipc_node *n, int bearer_id, bool delete)
        struct tipc_link *l = le->link;
        struct tipc_media_addr *maddr;
        struct sk_buff_head xmitq;
+       int old_bearer_id = bearer_id;
 
        if (!l)
                return;
@@ -711,6 +706,8 @@ static void tipc_node_link_down(struct tipc_node *n, int bearer_id, bool delete)
                tipc_link_fsm_evt(l, LINK_RESET_EVT);
        }
        tipc_node_write_unlock(n);
+       if (delete)
+               tipc_mon_remove_peer(n->net, n->addr, old_bearer_id);
        tipc_bearer_xmit(n->net, bearer_id, &xmitq, maddr);
        tipc_sk_rcv(n->net, &le->inputq);
 }
@@ -735,6 +732,7 @@ void tipc_node_check_dest(struct net *net, u32 onode,
        bool accept_addr = false;
        bool reset = true;
        char *if_name;
+       unsigned long intv;
 
        *dupl_addr = false;
        *respond = false;
@@ -840,9 +838,11 @@ void tipc_node_check_dest(struct net *net, u32 onode,
                le->link = l;
                n->link_cnt++;
                tipc_node_calculate_timer(n, l);
-               if (n->link_cnt == 1)
-                       if (!mod_timer(&n->timer, jiffies + n->keepalive_intv))
+               if (n->link_cnt == 1) {
+                       intv = jiffies + msecs_to_jiffies(n->keepalive_intv);
+                       if (!mod_timer(&n->timer, intv))
                                tipc_node_get(n);
+               }
        }
        memcpy(&le->maddr, maddr, sizeof(*maddr));
 exit:
@@ -950,7 +950,7 @@ static void tipc_node_fsm_evt(struct tipc_node *n, int evt)
                        state = SELF_UP_PEER_UP;
                        break;
                case SELF_LOST_CONTACT_EVT:
-                       state = SELF_DOWN_PEER_LEAVING;
+                       state = SELF_DOWN_PEER_DOWN;
                        break;
                case SELF_ESTABL_CONTACT_EVT:
                case PEER_LOST_CONTACT_EVT:
@@ -969,7 +969,7 @@ static void tipc_node_fsm_evt(struct tipc_node *n, int evt)
                        state = SELF_UP_PEER_UP;
                        break;
                case PEER_LOST_CONTACT_EVT:
-                       state = SELF_LEAVING_PEER_DOWN;
+                       state = SELF_DOWN_PEER_DOWN;
                        break;
                case SELF_LOST_CONTACT_EVT:
                case PEER_ESTABL_CONTACT_EVT: