Whamcloud - gitweb
LU-10391 lnet: alter lnd_notify_peer_down() to take lnet_nid 08/43608/10
authorMr NeilBrown <neilb@suse.de>
Mon, 6 Jul 2020 01:47:56 +0000 (11:47 +1000)
committerOleg Drokin <green@whamcloud.com>
Wed, 26 Jan 2022 05:13:10 +0000 (05:13 +0000)
The lnd_notify_peer_down() interface now takes a large nid.

Test-Parameters: trivial
Test-Parameters: serverversion=2.12 serverdistro=el7.9 testlist=runtests
Test-Parameters: clientversion=2.12 testlist=runtests
Signed-off-by: Mr NeilBrown <neilb@suse.de>
Change-Id: I9926caf0508ff257e9e64d5537597addbce657d7
Reviewed-on: https://review.whamcloud.com/43608
Reviewed-by: James Simmons <jsimmons@infradead.org>
Reviewed-by: Serguei Smirnov <ssmirnov@whamcloud.com>
Tested-by: jenkins <devops@whamcloud.com>
Tested-by: Maloo <maloo@whamcloud.com>
Reviewed-by: Oleg Drokin <green@whamcloud.com>
lnet/include/lnet/lib-types.h
lnet/klnds/socklnd/socklnd.c
lnet/lnet/router.c

index 8f53d63..0df6857 100644 (file)
@@ -327,7 +327,7 @@ struct lnet_lnd {
                              struct lnet_msg *msg, void **new_privatep);
 
        /* notification of peer down */
-       void (*lnd_notify_peer_down)(lnet_nid_t peer);
+       void (*lnd_notify_peer_down)(struct lnet_nid *peer);
 
        /* accept a new connection */
        int (*lnd_accept)(struct lnet_ni *ni, struct socket *sock);
index c2b0a96..011c1bb 100644 (file)
@@ -1652,24 +1652,25 @@ ksocknal_close_matching_conns(struct lnet_processid *id, __u32 ipaddr)
 }
 
 void
-ksocknal_notify_gw_down(lnet_nid_t gw_nid)
+ksocknal_notify_gw_down(struct lnet_nid *gw_nid)
 {
        /* The router is telling me she's been notified of a change in
         * gateway state....
         */
        struct lnet_processid id = {
                .pid    = LNET_PID_ANY,
+               .nid    = *gw_nid,
        };
 
-       CDEBUG(D_NET, "gw %s down\n", libcfs_nid2str(gw_nid));
+       CDEBUG(D_NET, "gw %s down\n", libcfs_nidstr(gw_nid));
 
-       lnet_nid4_to_nid(gw_nid, &id.nid);
        /* If the gateway crashed, close all open connections... */
        ksocknal_close_matching_conns(&id, 0);
        return;
 
        /* We can only establish new connections
-        * if we have autroutes, and these connect on demand. */
+        * if we have autroutes, and these connect on demand.
+        */
 }
 
 static void
index 5929b41..52a5502 100644 (file)
@@ -1703,7 +1703,7 @@ lnet_rtrpools_disable(void)
 }
 
 static inline void
-lnet_notify_peer_down(struct lnet_ni *ni, lnet_nid_t nid)
+lnet_notify_peer_down(struct lnet_ni *ni, struct lnet_nid *nid)
 {
        if (ni->ni_net->net_lnd->lnd_notify_peer_down != NULL)
                (ni->ni_net->net_lnd->lnd_notify_peer_down)(nid);
@@ -1817,7 +1817,7 @@ lnet_notify(struct lnet_ni *ni, lnet_nid_t nid, bool alive, bool reset,
        lnet_net_unlock(0);
 
        if (ni != NULL && !alive)
-               lnet_notify_peer_down(ni, lnet_nid_to_nid4(&lpni->lpni_nid));
+               lnet_notify_peer_down(ni, &lpni->lpni_nid);
 
        cpt = lpni->lpni_cpt;
        lnet_net_lock(cpt);