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 D | offload.c | 179 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 D | mrail_cq.c | 135 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 D | mrail_ep.c | 351 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 D | mrail.h | 178 struct mrail_rndv_hdr rndv_hdr; member
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxm/src/ |
H A D | rxm_cq.c | 426 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 D | rxm_ep.c | 991 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 D | rxm.h | 450 struct rxm_rndv_hdr *rndv_hdr; member
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ |
H A D | test_tag.cc | 23 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()
|