Whamcloud - gitweb
git://git.whamcloud.com
/
fs
/
lustre-release.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
LU-9094 lnet: remove ni from lnet_finalize
[fs/lustre-release.git]
/
lnet
/
lnet
/
lib-move.c
diff --git
a/lnet/lnet/lib-move.c
b/lnet/lnet/lib-move.c
index
988c549
..
5f4045e
100644
(file)
--- a/
lnet/lnet/lib-move.c
+++ b/
lnet/lnet/lib-move.c
@@
-594,7
+594,7
@@
lnet_ni_recv(struct lnet_ni *ni, void *private, struct lnet_msg *msg,
niov, iov, kiov, offset, mlen,
rlen);
if (rc < 0)
niov, iov, kiov, offset, mlen,
rlen);
if (rc < 0)
- lnet_finalize(
ni,
msg, rc);
+ lnet_finalize(msg, rc);
}
static void
}
static void
@@
-648,7
+648,7
@@
lnet_ni_send(struct lnet_ni *ni, struct lnet_msg *msg)
rc = (ni->ni_net->net_lnd->lnd_send)(ni, priv, msg);
if (rc < 0)
rc = (ni->ni_net->net_lnd->lnd_send)(ni, priv, msg);
if (rc < 0)
- lnet_finalize(
ni,
msg, rc);
+ lnet_finalize(msg, rc);
}
static int
}
static int
@@
-829,7
+829,7
@@
lnet_post_send_locked(struct lnet_msg *msg, int do_send)
CNETERR("Dropping message for %s: peer not alive\n",
libcfs_id2str(msg->msg_target));
if (do_send)
CNETERR("Dropping message for %s: peer not alive\n",
libcfs_id2str(msg->msg_target));
if (do_send)
- lnet_finalize(
ni,
msg, -EHOSTUNREACH);
+ lnet_finalize(msg, -EHOSTUNREACH);
lnet_net_lock(cpt);
return -EHOSTUNREACH;
lnet_net_lock(cpt);
return -EHOSTUNREACH;
@@
-843,7
+843,7
@@
lnet_post_send_locked(struct lnet_msg *msg, int do_send)
"called on the MD/ME.\n",
libcfs_id2str(msg->msg_target));
if (do_send)
"called on the MD/ME.\n",
libcfs_id2str(msg->msg_target));
if (do_send)
- lnet_finalize(
ni,
msg, -ECANCELED);
+ lnet_finalize(msg, -ECANCELED);
lnet_net_lock(cpt);
return -ECANCELED;
lnet_net_lock(cpt);
return -ECANCELED;
@@
-1107,7
+1107,7
@@
lnet_drop_routed_msgs_locked(struct list_head *list, int cpt)
lnet_ni_recv(msg->msg_rxni, msg->msg_private, NULL,
0, 0, 0, msg->msg_hdr.payload_length);
list_del_init(&msg->msg_list);
lnet_ni_recv(msg->msg_rxni, msg->msg_private, NULL,
0, 0, 0, msg->msg_hdr.payload_length);
list_del_init(&msg->msg_list);
- lnet_finalize(
NULL,
msg, -ECANCELED);
+ lnet_finalize(msg, -ECANCELED);
}
lnet_net_lock(cpt);
}
lnet_net_lock(cpt);
@@
-2092,7
+2092,7
@@
lnet_parse_get(struct lnet_ni *ni, struct lnet_msg *msg, int rdma_get)
libcfs_nid2str(ni->ni_nid),
libcfs_id2str(info.mi_id), rc);
libcfs_nid2str(ni->ni_nid),
libcfs_id2str(info.mi_id), rc);
- lnet_finalize(
ni,
msg, rc);
+ lnet_finalize(msg, rc);
}
return 0;
}
return 0;
@@
-2589,7
+2589,7
@@
lnet_parse(struct lnet_ni *ni, struct lnet_hdr *hdr, lnet_nid_t from_nid,
free_drop:
LASSERT(msg->msg_md == NULL);
free_drop:
LASSERT(msg->msg_md == NULL);
- lnet_finalize(
ni,
msg, rc);
+ lnet_finalize(msg, rc);
drop:
lnet_drop_message(ni, cpt, private, payload_length);
drop:
lnet_drop_message(ni, cpt, private, payload_length);
@@
-2634,7
+2634,7
@@
lnet_drop_delayed_msg_list(struct list_head *head, char *reason)
* but we still should give error code so lnet_msg_decommit()
* can skip counters operations and other checks.
*/
* but we still should give error code so lnet_msg_decommit()
* can skip counters operations and other checks.
*/
- lnet_finalize(msg
->msg_rxni, msg
, -ENOENT);
+ lnet_finalize(msg, -ENOENT);
}
}
}
}
@@
-2792,7
+2792,7
@@
LNetPut(lnet_nid_t self, struct lnet_handle_md mdh, enum lnet_ack_req ack,
if (rc != 0) {
CNETERR("Error sending PUT to %s: %d\n",
libcfs_id2str(target), rc);
if (rc != 0) {
CNETERR("Error sending PUT to %s: %d\n",
libcfs_id2str(target), rc);
- lnet_finalize(
NULL,
msg, rc);
+ lnet_finalize(msg, rc);
}
/* completion will be signalled by an event */
}
/* completion will be signalled by an event */
@@
-2988,7
+2988,7
@@
LNetGet(lnet_nid_t self, struct lnet_handle_md mdh,
if (rc < 0) {
CNETERR("Error sending GET to %s: %d\n",
libcfs_id2str(target), rc);
if (rc < 0) {
CNETERR("Error sending GET to %s: %d\n",
libcfs_id2str(target), rc);
- lnet_finalize(
NULL,
msg, rc);
+ lnet_finalize(msg, rc);
}
/* completion will be signalled by an event */
}
/* completion will be signalled by an event */