Searched refs:lnet_msg_t (Results 1 – 10 of 10) sorted by relevance
| /linux-4.1.27/drivers/staging/lustre/include/linux/lnet/ |
| D | lib-lnet.h | 320 static inline lnet_msg_t *
325 lnet_msg_t *msg; in lnet_msg_alloc()
330 msg = (lnet_msg_t *)lnet_freelist_alloc(&msc->msc_freelist); in lnet_msg_alloc()
341 lnet_msg_free_locked(lnet_msg_t *msg) in lnet_msg_free_locked()
352 lnet_msg_free(lnet_msg_t *msg) in lnet_msg_free()
438 static inline lnet_msg_t *
442 lnet_msg_t *msg; in lnet_msg_alloc()
451 lnet_msg_free(lnet_msg_t *msg) in lnet_msg_free()
666 void lnet_msg_attach_md(lnet_msg_t *msg, lnet_libmd_t *md,
668 void lnet_msg_detach_md(lnet_msg_t *msg, int status);
[all …]
|
| D | lib-types.h | 225 } lnet_msg_t; typedef
340 int (*lnd_send)(struct lnet_ni *ni, void *private, lnet_msg_t *msg);
347 int (*lnd_recv)(struct lnet_ni *ni, void *private, lnet_msg_t *msg,
358 int (*lnd_eager_recv)(struct lnet_ni *ni, void *private, lnet_msg_t *msg,
|
| /linux-4.1.27/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 | 565 lnet_ni_recv(lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in lnet_ni_recv()
603 lnet_setpayloadbuffer(lnet_msg_t *msg) in lnet_setpayloadbuffer()
622 lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target, in lnet_prep_send()
643 lnet_ni_send(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_send()
658 lnet_ni_eager_recv(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_eager_recv()
786 lnet_post_send_locked(lnet_msg_t *msg, int do_send) in lnet_post_send_locked()
872 lnet_msg2bufpool(lnet_msg_t *msg) in lnet_msg2bufpool()
892 lnet_post_routed_recv_locked(lnet_msg_t *msg, int do_recv) in lnet_post_routed_recv_locked()
968 lnet_return_tx_credits_locked(lnet_msg_t *msg) in lnet_return_tx_credits_locked()
971 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.1.27/drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.h | 224 lnet_msg_t *tx_lnetmsg; /* lnet message for lnet_finalize() */
517 int ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
518 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()
923 ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in ksocknal_send()
1313 ksocknal_recv (lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in ksocknal_recv()
|
| /linux-4.1.27/drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| D | o2iblnd.h | 540 lnet_msg_t *tx_lntmsg[2]; /* lnet msgs to finalize on completion */
1027 int kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
1028 int kiblnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, int delayed,
|
| D | o2iblnd_cb.c | 46 lnet_msg_t *lntmsg[2]; in kiblnd_tx_done()
1457 kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in kiblnd_send()
1628 kiblnd_reply(lnet_ni_t *ni, kib_rx_t *rx, lnet_msg_t *lntmsg) in kiblnd_reply()
1690 kiblnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, int delayed, in kiblnd_recv()
|