Home
last modified time | relevance | path

Searched refs:rndv_hdr (Results 1 – 8 of 8) sorted by relevance

/dports/net/mpich/mpich-3.4.3/modules/ucx/src/ucp/tag/
H A Doffload.c179 const ucp_tag_offload_unexp_rndv_hdr_t *rndv_hdr; variable
187 ucs_assert(hdr_length == sizeof(*rndv_hdr));
188 rndv_hdr = hdr;
191 md_index = rndv_hdr->md_index;
200 dummy_rts->sreq.ep_ptr = rndv_hdr->ep_ptr;
201 dummy_rts->sreq.reqptr = rndv_hdr->reqptr;
591 ucp_tag_offload_unexp_rndv_hdr_t rndv_hdr = { in ucp_tag_offload_rndv_zcopy() local
599 UCS_STATIC_ASSERT(sizeof(ucp_rsc_index_t) <= sizeof(rndv_hdr.md_index)); in ucp_tag_offload_rndv_zcopy()
607 req->send.msg_proto.tag.tag, &rndv_hdr, in ucp_tag_offload_rndv_zcopy()
608 sizeof(rndv_hdr), iov, iovcnt, 0, in ucp_tag_offload_rndv_zcopy()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/mrail/src/
H A Dmrail_cq.c135 struct mrail_rndv_hdr *rndv_hdr; in mrail_cq_process_rndv_req() local
146 rndv_hdr = (struct mrail_rndv_hdr *)&mrail_pkt[1]; in mrail_cq_process_rndv_req()
147 rndv_req = (struct mrail_rndv_req *)&rndv_hdr[1]; in mrail_cq_process_rndv_req()
148 recv->rndv.context = (void *)rndv_hdr->context; in mrail_cq_process_rndv_req()
201 struct mrail_rndv_hdr *rndv_hdr; in mrail_cq_process_rndv_ack() local
206 rndv_hdr = (struct mrail_rndv_hdr *)&mrail_pkt[1]; in mrail_cq_process_rndv_ack()
207 tx_buf = (struct mrail_tx_buf *)rndv_hdr->context; in mrail_cq_process_rndv_ack()
H A Dmrail_ep.c351 size_t rndv_pkt_size = sizeof(tx_buf->hdr) + sizeof(tx_buf->rndv_hdr); in mrail_send_rndv_ack_blocking()
366 tx_buf->rndv_hdr.context = (uint64_t)context; in mrail_send_rndv_ack_blocking()
418 tx_buf->rndv_hdr.context = (uint64_t)tx_buf; in mrail_prepare_rndv_req()
472 iov_dest[0].iov_len = sizeof(tx_buf->hdr) + sizeof(tx_buf->rndv_hdr); in mrail_prepare_rndv_req()
H A Dmrail.h178 struct mrail_rndv_hdr rndv_hdr; member
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxm/src/
H A Drxm_cq.c426 rx_buf->rndv_hdr->iov[index].addr; in rxm_cq_rndv_read_prepare_deferred()
428 rx_buf->rndv_hdr->iov[index].key; in rxm_cq_rndv_read_prepare_deferred()
469 rx_buf->rndv_hdr = (struct rxm_rndv_hdr *)rx_buf->pkt.data; in rxm_cq_handle_rndv()
494 assert(rx_buf->rndv_hdr->count && in rxm_cq_handle_rndv()
495 (rx_buf->rndv_hdr->count <= RXM_IOV_LIMIT)); in rxm_cq_handle_rndv()
499 for (i = 0; i < rx_buf->rndv_hdr->count; i++) { in rxm_cq_handle_rndv()
500 size_t copy_len = MIN(rx_buf->rndv_hdr->iov[i].len, in rxm_cq_handle_rndv()
515 rx_buf->rndv_hdr->iov[i].addr, in rxm_cq_handle_rndv()
516 rx_buf->rndv_hdr->iov[i].key, rx_buf); in rxm_cq_handle_rndv()
1130 if (++rx_buf->rndv_rma_index < rx_buf->rndv_hdr->count) in rxm_cq_handle_comp()
H A Drxm_ep.c991 struct rxm_rndv_hdr *rndv_hdr = (struct rxm_rndv_hdr *)buf; in rxm_rndv_hdr_init() local
995 rndv_hdr->iov[i].addr = RXM_MR_VIRT_ADDR(rxm_ep->msg_info) ? in rxm_rndv_hdr_init()
997 rndv_hdr->iov[i].len = (uint64_t)iov[i].iov_len; in rxm_rndv_hdr_init()
998 rndv_hdr->iov[i].key = fi_mr_key(mr[i]); in rxm_rndv_hdr_init()
1000 rndv_hdr->count = (uint8_t)count; in rxm_rndv_hdr_init()
H A Drxm.h450 struct rxm_rndv_hdr *rndv_hdr; member
/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/
H A Dtest_tag.cc23 struct rndv_hdr { struct in test_tag
153 rndv_hdr hdr = {{ctx.imm_data, in tag_rndv_zcopy()
181 rndv_hdr hdr = {{ctx.imm_data, in tag_rndv_request()
416 rndv_hdr *rhdr = const_cast<rndv_hdr*>(static_cast<const rndv_hdr*>(header)); in unexp_rndv()