ksocknal_free_tx(tx);
if (lnetmsg != NULL) { /* KSOCK_MSG_NOOP go without lnetmsg */
- if (rc)
- CERROR("tx failure rc = %d, hstatus = %d\n", rc,
- hstatus);
lnetmsg->msg_health_status = hstatus;
lnet_finalize(lnetmsg, rc);
}
le64_to_cpu(lhdr->src_nid) != id->nid);
}
- lnet_finalize(conn->ksnc_cookie, rc);
+ if (rc && conn->ksnc_lnet_msg)
+ conn->ksnc_lnet_msg->msg_health_status =
+ LNET_MSG_STATUS_REMOTE_ERROR;
+ lnet_finalize(conn->ksnc_lnet_msg, rc);
if (rc != 0) {
ksocknal_new_packet(conn, 0);
LASSERT (mlen <= rlen);
LASSERT (niov <= LNET_MAX_IOV);
- conn->ksnc_cookie = msg;
- conn->ksnc_rx_nob_wanted = mlen;
- conn->ksnc_rx_nob_left = rlen;
+ conn->ksnc_lnet_msg = msg;
+ conn->ksnc_rx_nob_wanted = mlen;
+ conn->ksnc_rx_nob_left = rlen;
if (mlen == 0 || iov != NULL) {
conn->ksnc_rx_nkiov = 0;