Home
last modified time | relevance | path

Searched refs:lntmsg (Results 1 – 5 of 5) sorted by relevance

/drivers/staging/lustre/lnet/lnet/
Dlo.c35 lolnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in lolnd_send() argument
37 LASSERT(!lntmsg->msg_routing); in lolnd_send()
38 LASSERT(!lntmsg->msg_target_is_router); in lolnd_send()
40 return lnet_parse(ni, &lntmsg->msg_hdr, ni->ni_nid, lntmsg, 0); in lolnd_send()
44 lolnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, in lolnd_recv() argument
49 if (lntmsg) { /* not discarding */ in lolnd_recv()
63 lnet_finalize(ni, lntmsg, 0); in lolnd_recv()
/drivers/staging/lustre/lnet/klnds/o2iblnd/
Do2iblnd_cb.c56 lnet_msg_t *lntmsg[2]; in kiblnd_tx_done() local
71 lntmsg[0] = tx->tx_lntmsg[0]; tx->tx_lntmsg[0] = NULL; in kiblnd_tx_done()
72 lntmsg[1] = tx->tx_lntmsg[1]; tx->tx_lntmsg[1] = NULL; in kiblnd_tx_done()
89 if (!lntmsg[i]) in kiblnd_tx_done()
92 lnet_finalize(ni, lntmsg[i], rc); in kiblnd_tx_done()
1491 kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in kiblnd_send() argument
1493 lnet_hdr_t *hdr = &lntmsg->msg_hdr; in kiblnd_send()
1494 int type = lntmsg->msg_type; in kiblnd_send()
1495 lnet_process_id_t target = lntmsg->msg_target; in kiblnd_send()
1496 int target_is_router = lntmsg->msg_target_is_router; in kiblnd_send()
[all …]
Do2iblnd.h1038 int kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
1039 int kiblnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, int delayed,
/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd_cb.c935 ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in ksocknal_send() argument
938 int type = lntmsg->msg_type; in ksocknal_send()
939 lnet_process_id_t target = lntmsg->msg_target; in ksocknal_send()
940 unsigned int payload_niov = lntmsg->msg_niov; in ksocknal_send()
941 struct kvec *payload_iov = lntmsg->msg_iov; in ksocknal_send()
942 lnet_kiov_t *payload_kiov = lntmsg->msg_kiov; in ksocknal_send()
943 unsigned int payload_offset = lntmsg->msg_offset; in ksocknal_send()
944 unsigned int payload_nob = lntmsg->msg_len; in ksocknal_send()
969 if (lntmsg->msg_vmflush) in ksocknal_send()
975 if (lntmsg->msg_vmflush) in ksocknal_send()
[all …]
Dsocklnd.h615 int ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
616 int ksocknal_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg,