@@ -461,12 +461,8 @@
}
static void
-lnet_handle_local_failure(struct lnet_msg *msg)
+lnet_handle_local_failure(struct lnet_ni *local_ni)
{
- struct lnet_ni *local_ni;
-
- local_ni = msg->msg_txni;
-
/* the lnet_net_lock(0) is used to protect the addref on the ni
* and the recovery queue.
*/
@@ -652,7 +648,7 @@
case LNET_MSG_STATUS_LOCAL_ABORTED:
case LNET_MSG_STATUS_LOCAL_NO_ROUTE:
case LNET_MSG_STATUS_LOCAL_TIMEOUT:
- lnet_handle_local_failure(msg);
+ lnet_handle_local_failure(msg->msg_txni);
/* add to the re-send queue */
goto resend;
@@ -660,7 +656,7 @@
* finalize the message
*/
case LNET_MSG_STATUS_LOCAL_ERROR:
- lnet_handle_local_failure(msg);
+ lnet_handle_local_failure(msg->msg_txni);
return -1;
/* TODO: since the remote dropped the message we can