Home
last modified time | relevance | path

Searched refs:cas_pkt (Results 1 – 5 of 5) sorted by relevance

/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/
H A Dch3u_handle_recv_req.c1521 MPIDI_CH3_Pkt_cas_t *cas_pkt = &((target_lock_entry->pkt).cas); in perform_cas_in_lock_queue() local
1527 MPIR_Assert(MPIR_DATATYPE_IS_PREDEFINED(cas_pkt->datatype)); in perform_cas_in_lock_queue()
1533 cas_resp_pkt->request_handle = cas_pkt->request_handle; in perform_cas_in_lock_queue()
1536 if (cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_SHARED || in perform_cas_in_lock_queue()
1537 cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_EXCLUSIVE) in perform_cas_in_lock_queue()
1539 if ((cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_FLUSH) || in perform_cas_in_lock_queue()
1540 (cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_UNLOCK)) in perform_cas_in_lock_queue()
1544 MPIR_Datatype_get_size_macro(cas_pkt->datatype, len); in perform_cas_in_lock_queue()
1554 if (MPIR_Compare_equal(&cas_pkt->compare_data, cas_pkt->addr, cas_pkt->datatype)) { in perform_cas_in_lock_queue()
1555 MPIR_Memcpy(cas_pkt->addr, &cas_pkt->origin_data, len); in perform_cas_in_lock_queue()
[all …]
H A Dch3u_rma_pkthandler.c1082 MPIDI_CH3_Pkt_cas_t *cas_pkt = &pkt->cas; in MPIDI_CH3_PktHandler_CAS() local
1096 MPIR_Assert(cas_pkt->target_win_handle != MPI_WIN_NULL); in MPIDI_CH3_PktHandler_CAS()
1097 MPIR_Win_get_ptr(cas_pkt->target_win_handle, win_ptr); in MPIDI_CH3_PktHandler_CAS()
1115 cas_resp_pkt->request_handle = cas_pkt->request_handle; in MPIDI_CH3_PktHandler_CAS()
1118 if (cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_SHARED || in MPIDI_CH3_PktHandler_CAS()
1121 if ((cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_FLUSH) || in MPIDI_CH3_PktHandler_CAS()
1122 (cas_pkt->pkt_flags & MPIDI_CH3_PKT_FLAG_RMA_UNLOCK)) in MPIDI_CH3_PktHandler_CAS()
1126 MPIR_Datatype_get_size_macro(cas_pkt->datatype, len); in MPIDI_CH3_PktHandler_CAS()
1136 if (MPIR_Compare_equal(&cas_pkt->compare_data, cas_pkt->addr, cas_pkt->datatype)) { in MPIDI_CH3_PktHandler_CAS()
1137 MPIR_Memcpy(cas_pkt->addr, &cas_pkt->origin_data, len); in MPIDI_CH3_PktHandler_CAS()
[all …]
H A Dch3u_rma_ops.c926 MPIDI_CH3_Pkt_cas_t *cas_pkt = NULL; in MPID_Compare_and_swap() local
950 cas_pkt = &(op_ptr->pkt.cas); in MPID_Compare_and_swap()
951 MPIDI_Pkt_init(cas_pkt, MPIDI_CH3_PKT_CAS_IMMED); in MPID_Compare_and_swap()
952 cas_pkt->addr = (char *) win_ptr->basic_info_table[target_rank].base_addr + in MPID_Compare_and_swap()
954 cas_pkt->datatype = datatype; in MPID_Compare_and_swap()
955 cas_pkt->target_win_handle = win_ptr->basic_info_table[target_rank].win_handle; in MPID_Compare_and_swap()
956 cas_pkt->pkt_flags = MPIDI_CH3_PKT_FLAG_NONE; in MPID_Compare_and_swap()
963 src = (void *) origin_addr, dest = (void *) (&(cas_pkt->origin_data)); in MPID_Compare_and_swap()
967 src = (void *) compare_addr, dest = (void *) (&(cas_pkt->compare_data)); in MPID_Compare_and_swap()
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/src/
H A Dch3u_rma_sync.c874 MPIDI_CH3_Pkt_cas_t *cas_pkt = &upkt.cas; in MPIDI_CH3I_Send_immed_rmw_msg() local
883 MPIDI_Pkt_init(cas_pkt, MPIDI_CH3_PKT_CAS); in MPIDI_CH3I_Send_immed_rmw_msg()
888 cas_pkt->datatype = rma_op->target_datatype; in MPIDI_CH3I_Send_immed_rmw_msg()
889 cas_pkt->target_win_handle = target_win_handle; in MPIDI_CH3I_Send_immed_rmw_msg()
890 cas_pkt->request_handle = resp_req->handle; in MPIDI_CH3I_Send_immed_rmw_msg()
897 mpi_errno = MPIDI_CH3_iStartMsg(vc, cas_pkt, sizeof(*cas_pkt), &rmw_req); in MPIDI_CH3I_Send_immed_rmw_msg()
3196 MPIDI_CH3_Pkt_cas_t *cas_pkt = &pkt->cas; in MPIDI_CH3_PktHandler_CAS() local
3216 MPID_Datatype_get_size_macro(cas_pkt->datatype, len); in MPIDI_CH3_PktHandler_CAS()
3232 if (MPIR_Compare_equal(&cas_pkt->compare_data, cas_pkt->addr, cas_pkt->datatype)) { in MPIDI_CH3_PktHandler_CAS()
3233 MPIU_Memcpy(cas_pkt->addr, &cas_pkt->origin_data, len); in MPIDI_CH3_PktHandler_CAS()
[all …]
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/
H A Dmpid_rma_issue.h890 MPIDI_CH3_Pkt_cas_t *cas_pkt = &rma_op->pkt.cas; in issue_cas_op() local
916 cas_pkt->request_handle = curr_req->handle; in issue_cas_op()
917 cas_pkt->pkt_flags |= pkt_flags; in issue_cas_op()
921 mpi_errno = MPIDI_CH3_iStartMsg(vc, cas_pkt, sizeof(*cas_pkt), &rmw_req); in issue_cas_op()