LU-10391 lnet: change src_nid arg to lnet_parse() to 16byte

[fs/lustre-release.git] / lnet / klnds / o2iblnd / o2iblnd_cb.c

diff --git a/lnet/klnds/o2iblnd/o2iblnd_cb.c b/lnet/klnds/o2iblnd/o2iblnd_cb.c
index 78a772b..e96110d 100644 (file)
--- a/lnet/klnds/o2iblnd/o2iblnd_cb.c
+++ b/lnet/klnds/o2iblnd/o2iblnd_cb.c
@@ -333,6 +333,7 @@ kiblnd_handle_rx(struct kib_rx *rx)
        int rc2;
        int post_credit;
        struct lnet_hdr hdr;
        int rc2;
        int post_credit;
        struct lnet_hdr hdr;

+       struct lnet_nid srcnid;

 
         LASSERT (conn->ibc_state >= IBLND_CONN_ESTABLISHED);
 
 
         LASSERT (conn->ibc_state >= IBLND_CONN_ESTABLISHED);
 


@@ -393,7 +394,8 @@ kiblnd_handle_rx(struct kib_rx *rx)
        case IBLND_MSG_IMMEDIATE:
                post_credit = IBLND_POSTRX_DONT_POST;
                lnet_hdr_from_nid4(&hdr, &msg->ibm_u.immediate.ibim_hdr);
        case IBLND_MSG_IMMEDIATE:
                post_credit = IBLND_POSTRX_DONT_POST;
                lnet_hdr_from_nid4(&hdr, &msg->ibm_u.immediate.ibim_hdr);

-               rc = lnet_parse(ni, &hdr, msg->ibm_srcnid, rx, 0);
+               lnet_nid4_to_nid(msg->ibm_srcnid, &srcnid);
+               rc = lnet_parse(ni, &hdr, &srcnid, rx, 0);

                if (rc < 0)                     /* repost on error */
                        post_credit = IBLND_POSTRX_PEER_CREDIT;
                break;
                if (rc < 0)                     /* repost on error */
                        post_credit = IBLND_POSTRX_PEER_CREDIT;
                break;


@@ -401,7 +403,8 @@ kiblnd_handle_rx(struct kib_rx *rx)
        case IBLND_MSG_PUT_REQ:
                post_credit = IBLND_POSTRX_DONT_POST;
                lnet_hdr_from_nid4(&hdr, &msg->ibm_u.putreq.ibprm_hdr);
        case IBLND_MSG_PUT_REQ:
                post_credit = IBLND_POSTRX_DONT_POST;
                lnet_hdr_from_nid4(&hdr, &msg->ibm_u.putreq.ibprm_hdr);

-               rc = lnet_parse(ni, &hdr, msg->ibm_srcnid, rx, 1);
+               lnet_nid4_to_nid(msg->ibm_srcnid, &srcnid);
+               rc = lnet_parse(ni, &hdr, &srcnid, rx, 1);

                if (rc < 0)                     /* repost on error */
                        post_credit = IBLND_POSTRX_PEER_CREDIT;
                break;
                if (rc < 0)                     /* repost on error */
                        post_credit = IBLND_POSTRX_PEER_CREDIT;
                break;


@@ -463,7 +466,8 @@ kiblnd_handle_rx(struct kib_rx *rx)
        case IBLND_MSG_GET_REQ:
                post_credit = IBLND_POSTRX_DONT_POST;
                lnet_hdr_from_nid4(&hdr, &msg->ibm_u.get.ibgm_hdr);
        case IBLND_MSG_GET_REQ:
                post_credit = IBLND_POSTRX_DONT_POST;
                lnet_hdr_from_nid4(&hdr, &msg->ibm_u.get.ibgm_hdr);

-               rc = lnet_parse(ni, &hdr, msg->ibm_srcnid, rx, 1);
+               lnet_nid4_to_nid(msg->ibm_srcnid, &srcnid);
+               rc = lnet_parse(ni, &hdr, &srcnid, rx, 1);

                if (rc < 0)                     /* repost on error */
                        post_credit = IBLND_POSTRX_PEER_CREDIT;
                break;
                if (rc < 0)                     /* repost on error */
                        post_credit = IBLND_POSTRX_PEER_CREDIT;
                break;