Searched refs:lnet_msg_t (Results 1 – 10 of 10) sorted by relevance
| /linux-4.4.14/drivers/staging/lustre/include/linux/lnet/ |
| D | lib-lnet.h | 235 static inline lnet_msg_t *
238 lnet_msg_t *msg; in lnet_msg_alloc()
247 lnet_msg_free(lnet_msg_t *msg) in lnet_msg_free()
455 void lnet_msg_attach_md(lnet_msg_t *msg, lnet_libmd_t *md,
457 void lnet_msg_detach_md(lnet_msg_t *msg, int status);
459 void lnet_build_msg_event(lnet_msg_t *msg, lnet_event_kind_t ev_type);
460 void lnet_msg_commit(lnet_msg_t *msg, int cpt);
461 void lnet_msg_decommit(lnet_msg_t *msg, int cpt, int status);
464 void lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target,
466 int lnet_send(lnet_nid_t nid, lnet_msg_t *msg, lnet_nid_t rtr_nid);
[all …]
|
| D | lib-types.h | 108 } lnet_msg_t; typedef
209 int (*lnd_send)(struct lnet_ni *ni, void *private, lnet_msg_t *msg);
216 int (*lnd_recv)(struct lnet_ni *ni, void *private, lnet_msg_t *msg,
229 lnet_msg_t *msg, void **new_privatep);
|
| /linux-4.4.14/drivers/staging/lustre/lnet/lnet/ |
| D | lib-msg.c | 61 lnet_build_msg_event(lnet_msg_t *msg, lnet_event_kind_t ev_type) in lnet_build_msg_event()
137 lnet_msg_commit(lnet_msg_t *msg, int cpt) in lnet_msg_commit()
170 lnet_msg_decommit_tx(lnet_msg_t *msg, int status) in lnet_msg_decommit_tx()
220 lnet_msg_decommit_rx(lnet_msg_t *msg, int status) in lnet_msg_decommit_rx()
274 lnet_msg_decommit(lnet_msg_t *msg, int cpt, int status) in lnet_msg_decommit()
308 lnet_msg_attach_md(lnet_msg_t *msg, lnet_libmd_t *md, in lnet_msg_attach_md()
336 lnet_msg_detach_md(lnet_msg_t *msg, int status) in lnet_msg_detach_md()
359 lnet_complete_msg_locked(lnet_msg_t *msg, int cpt) in lnet_complete_msg_locked()
435 lnet_finalize(lnet_ni_t *ni, lnet_msg_t *msg, int status) in lnet_finalize()
515 lnet_msg_t, msg_list); in lnet_finalize()
[all …]
|
| D | lo.c | 39 lolnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in lolnd_send()
48 lolnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, in lolnd_recv()
53 lnet_msg_t *sendmsg = private; in lolnd_recv()
|
| D | lib-move.c | 564 lnet_ni_recv(lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in lnet_ni_recv()
602 lnet_setpayloadbuffer(lnet_msg_t *msg) in lnet_setpayloadbuffer()
621 lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target, in lnet_prep_send()
642 lnet_ni_send(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_send()
657 lnet_ni_eager_recv(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_eager_recv()
784 lnet_post_send_locked(lnet_msg_t *msg, int do_send) in lnet_post_send_locked()
869 lnet_msg2bufpool(lnet_msg_t *msg) in lnet_msg2bufpool()
889 lnet_post_routed_recv_locked(lnet_msg_t *msg, int do_recv) in lnet_post_routed_recv_locked()
965 lnet_return_tx_credits_locked(lnet_msg_t *msg) in lnet_return_tx_credits_locked()
968 lnet_msg_t *msg2; in lnet_return_tx_credits_locked()
[all …]
|
| D | lib-ptl.c | 628 lnet_msg_t *tmp; in lnet_ptl_attach_md()
629 lnet_msg_t *msg; in lnet_ptl_attach_md()
|
| /linux-4.4.14/drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.h | 271 lnet_msg_t *tx_lnetmsg; /* lnet message for lnet_finalize()
617 int ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
618 int ksocknal_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg,
|
| D | socklnd_cb.c | 391 lnet_msg_t *lnetmsg = tx->tx_lnetmsg; in ksocknal_tx_done()
921 ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in ksocknal_send()
1311 ksocknal_recv (lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in ksocknal_recv()
|
| /linux-4.4.14/drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| D | o2iblnd.h | 504 lnet_msg_t *tx_lntmsg[2]; /* lnet msgs to finalize on completion */
981 int kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
982 int kiblnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, int delayed,
|
| D | o2iblnd_cb.c | 48 lnet_msg_t *lntmsg[2]; in kiblnd_tx_done()
1417 kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in kiblnd_send()
1587 kiblnd_reply(lnet_ni_t *ni, kib_rx_t *rx, lnet_msg_t *lntmsg) in kiblnd_reply()
1649 kiblnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, int delayed, in kiblnd_recv()
|