| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxd/src/ |
| H A D | rxd_msg.c | 82 rxd_progress_op(ep, rx_entry, unexp_msg->pkt_entry, unexp_msg->base_hdr, in rxd_progress_unexp_msg()
83 unexp_msg->sar_hdr, unexp_msg->tag_hdr, in rxd_progress_unexp_msg()
84 unexp_msg->data_hdr, NULL, NULL, &unexp_msg->msg, in rxd_progress_unexp_msg()
85 unexp_msg->msg_size); in rxd_progress_unexp_msg()
97 if (!unexp_msg->sar_hdr || num_segs == unexp_msg->sar_hdr->num_segs - 1) in rxd_progress_unexp_msg()
118 if (!unexp_msg) in rxd_progress_unexp_list()
121 total_size = unexp_msg->sar_hdr ? unexp_msg->sar_hdr->size : in rxd_progress_unexp_list()
144 seq += unexp_msg->sar_hdr ? unexp_msg->sar_hdr->num_segs : 1; in rxd_ep_discard_recv()
171 if (!unexp_msg) { in rxd_peek_recv()
189 unexp_msg->sar_hdr ? unexp_msg->sar_hdr->size : in rxd_peek_recv()
[all …]
|
| H A D | rxd_cq.c | 396 struct rxd_unexp_msg *unexp_msg; in rxd_init_unexp() local
398 unexp_msg = calloc(1, sizeof(*unexp_msg)); in rxd_init_unexp()
399 if (!unexp_msg) in rxd_init_unexp()
403 unexp_msg->base_hdr = base_hdr; in rxd_init_unexp()
404 unexp_msg->sar_hdr = sar_hdr; in rxd_init_unexp()
405 unexp_msg->tag_hdr = tag_hdr; in rxd_init_unexp()
406 unexp_msg->data_hdr = data_hdr; in rxd_init_unexp()
407 unexp_msg->msg_size = msg_size; in rxd_init_unexp()
408 unexp_msg->msg = msg; in rxd_init_unexp()
412 return unexp_msg; in rxd_init_unexp()
[all …]
|
| H A D | rxd.h | 376 static inline void rxd_free_unexp_msg(struct rxd_unexp_msg *unexp_msg) in rxd_free_unexp_msg() argument
378 ofi_buf_free(unexp_msg->pkt_entry); in rxd_free_unexp_msg()
379 dlist_remove(&unexp_msg->entry); in rxd_free_unexp_msg()
380 free(unexp_msg); in rxd_free_unexp_msg()
508 void rxd_cleanup_unexp_msg(struct rxd_unexp_msg *unexp_msg);
|
| H A D | rxd_ep.c | 631 void rxd_cleanup_unexp_msg(struct rxd_unexp_msg *unexp_msg) in rxd_cleanup_unexp_msg() argument
634 while (!dlist_empty(&unexp_msg->pkt_list)) { in rxd_cleanup_unexp_msg()
635 dlist_pop_front(&unexp_msg->pkt_list, struct rxd_pkt_entry, in rxd_cleanup_unexp_msg()
640 rxd_free_unexp_msg(unexp_msg); in rxd_cleanup_unexp_msg()
645 struct rxd_unexp_msg *unexp_msg; in rxd_cleanup_unexp_msg_list() local
649 unexp_msg, entry); in rxd_cleanup_unexp_msg_list()
650 rxd_cleanup_unexp_msg(unexp_msg); in rxd_cleanup_unexp_msg_list()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/shm/src/ |
| H A D | smr_ep.c | 215 struct smr_unexp_msg *unexp_msg; in smr_match_unexp_msg() local
217 unexp_msg = container_of(item, struct smr_unexp_msg, entry); in smr_match_unexp_msg()
218 assert(unexp_msg->cmd.msg.hdr.op == ofi_op_msg); in smr_match_unexp_msg()
219 return smr_match_addr(unexp_msg->cmd.msg.hdr.addr, attr->addr); in smr_match_unexp_msg()
225 struct smr_unexp_msg *unexp_msg; in smr_match_unexp_tagged() local
227 unexp_msg = container_of(item, struct smr_unexp_msg, entry); in smr_match_unexp_tagged()
228 if (unexp_msg->cmd.msg.hdr.op == ofi_op_msg) in smr_match_unexp_tagged()
229 return smr_match_addr(unexp_msg->cmd.msg.hdr.addr, attr->addr); in smr_match_unexp_tagged()
231 assert(unexp_msg->cmd.msg.hdr.op == ofi_op_tagged); in smr_match_unexp_tagged()
232 return smr_match_addr(unexp_msg->cmd.msg.hdr.addr, attr->addr) && in smr_match_unexp_tagged()
[all …]
|
| H A D | smr_progress.c | 915 struct smr_unexp_msg *unexp_msg; in smr_progress_unexp_queue() local
932 unexp_msg = container_of(dlist_entry, struct smr_unexp_msg, entry); in smr_progress_unexp_queue()
933 ret = smr_progress_msg_common(ep, &unexp_msg->cmd, entry); in smr_progress_unexp_queue()
934 freestack_push(ep->unexp_fs, unexp_msg); in smr_progress_unexp_queue()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxm/src/ |
| H A D | rxm_ep.c | 87 struct rxm_unexp_msg *unexp_msg = in rxm_match_unexp_msg() local
95 struct rxm_unexp_msg *unexp_msg = in rxm_match_unexp_msg_tag() local
103 struct rxm_unexp_msg *unexp_msg = in rxm_match_unexp_msg_tag_addr() local
688 unexp_msg.entry, entry) { in rxm_handle_unexp_sar()
704 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_handle_unexp_sar()
719 rx_buf->unexp_msg.addr, rx_buf->unexp_msg.tag); in rxm_ep_discard_recv()
747 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_ep_peek_recv()
754 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_ep_peek_recv()
828 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_ep_post_mrecv()
880 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_ep_post_recv()
[all …]
|
| H A D | rxm_conn.c | 860 unexp_msg.entry, tmp_entry) { in rxm_conn_reprocess_directed_recvs()
861 if (rx_buf->unexp_msg.addr == rx_buf->conn->handle.fi_addr) in rxm_conn_reprocess_directed_recvs()
864 assert(rx_buf->unexp_msg.addr == FI_ADDR_NOTAVAIL); in rxm_conn_reprocess_directed_recvs()
866 rx_buf->unexp_msg.addr = rx_buf->conn->handle.fi_addr; in rxm_conn_reprocess_directed_recvs()
867 match_attr.addr = rx_buf->unexp_msg.addr; in rxm_conn_reprocess_directed_recvs()
868 match_attr.tag = rx_buf->unexp_msg.tag; in rxm_conn_reprocess_directed_recvs()
876 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_conn_reprocess_directed_recvs()
|
| H A D | rxm_cq.c | 76 dlist_insert_tail(&rx_buf->unexp_msg.entry, in rxm_finish_buf_recv()
331 container_of(item, struct rxm_rx_buf, unexp_msg.entry); in rxm_rx_buf_match_msg_id()
397 unexp_msg.entry, entry) { in rxm_cq_handle_seg_data()
398 if (!rxm_rx_buf_match_msg_id(&rx_buf->unexp_msg.entry, &msg_id)) in rxm_cq_handle_seg_data()
400 dlist_remove(&rx_buf->unexp_msg.entry); in rxm_cq_handle_seg_data()
599 rx_buf->unexp_msg.addr = match_attr->addr; in rxm_cq_match_rx_buf()
600 rx_buf->unexp_msg.tag = match_attr->tag; in rxm_cq_match_rx_buf()
603 dlist_insert_tail(&rx_buf->unexp_msg.entry, in rxm_cq_match_rx_buf()
|
| H A D | rxm.h | 442 struct rxm_unexp_msg unexp_msg; member
|