/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/ |
H A D | ch3u_rma_sync.c | 420 MPIR_Win *win_ptr = NULL; in fence_barrier_complete() local 426 MPIR_Assert(win_ptr != NULL); in fence_barrier_complete() 429 win_ptr->sync_request_cnt--; in fence_barrier_complete() 759 MPIR_Win *win_ptr = NULL; in start_req_complete() local 765 MPIR_Assert(win_ptr != NULL); in start_req_complete() 767 win_ptr->sync_request_cnt--; in start_req_complete() 811 mpi_errno = fill_ranks_in_win_grp(win_ptr, group_ptr, win_ptr->start_ranks_in_win_grp); in MPID_Win_start() 1095 win_ptr->lock_epoch_count++; in MPID_Win_lock() 1167 if (win_ptr->shm_allocated) { in MPID_Win_unlock() 1216 win_ptr->lock_epoch_count--; in MPID_Win_unlock() [all …]
|
H A D | mpid_rma.c | 74 (*win_ptr)->base = base; in MPID_Win_create() 95 win_ptr); in MPID_Win_allocate() 121 (*win_ptr)->base = MPI_BOTTOM; in MPID_Win_create_dynamic() 235 (*win_ptr)->size = size; in win_init() 238 (*win_ptr)->model = model; in win_init() 239 (*win_ptr)->attributes = NULL; in win_init() 259 (*win_ptr)->active = FALSE; in win_init() 260 (*win_ptr)->next = NULL; in win_init() 261 (*win_ptr)->prev = NULL; in win_init() 288 DL_APPEND((*win_ptr)->op_pool_head, &((*win_ptr)->op_pool_start[i])); in win_init() [all …]
|
H A D | ch3u_rma_progress.c | 66 int rank = win_ptr->comm_ptr->rank; in check_and_switch_target_state() 306 win_ptr->outstanding_acks++; in issue_ops_target() 373 start_slot = win_ptr->comm_ptr->rank % win_ptr->num_slots; in issue_ops_win() 376 if (i < win_ptr->num_slots) in issue_ops_win() 379 idx = i - win_ptr->num_slots; in issue_ops_win() 466 MPIDI_Comm_get_vc(win_ptr->comm_ptr, win_ptr->comm_ptr->rank, &orig_vc); in MPIDI_CH3I_RMA_Cleanup_target_aggressive() 544 if (!WIN_READY(win_ptr)) { in MPIDI_CH3I_RMA_Make_progress_target() 594 if (!WIN_READY(win_ptr)) { in MPIDI_CH3I_RMA_Make_progress_win() 614 MPIR_Win *win_ptr; in MPIDI_CH3I_RMA_Make_progress_global() local 622 for (win_ptr = MPIDI_RMA_Win_active_list_head; win_ptr; win_ptr = win_ptr->next) { in MPIDI_CH3I_RMA_Make_progress_global() [all …]
|
H A D | mpidi_rma.c | 133 int MPID_Win_free(MPIR_Win ** win_ptr) in MPID_Win_free() argument 162 (*win_ptr)->current_target_lock_data_bytes != 0 || (*win_ptr)->sync_request_cnt != 0) { in MPID_Win_free() 177 MPIR_Assert((*win_ptr)->active == FALSE); in MPID_Win_free() 186 comm_ptr = (*win_ptr)->comm_ptr; in MPID_Win_free() 190 MPL_free((*win_ptr)->basic_info_table); in MPID_Win_free() 191 MPL_free((*win_ptr)->op_pool_start); in MPID_Win_free() 192 MPL_free((*win_ptr)->target_pool_start); in MPID_Win_free() 193 MPL_free((*win_ptr)->slots); in MPID_Win_free() 201 if ((*win_ptr)->shm_allocated == FALSE && (*win_ptr)->size > 0) { in MPID_Win_free() 202 MPL_free((*win_ptr)->base); in MPID_Win_free() [all …]
|
H A D | ch3u_rma_ops.c | 61 rank = win_ptr->comm_ptr->rank; in MPIDI_CH3I_Put() 64 win_ptr->create_flavor != MPI_WIN_FLAVOR_SHARED) { in MPIDI_CH3I_Put() 162 put_pkt->source_win_handle = win_ptr->handle; in MPIDI_CH3I_Put() 223 rank = win_ptr->comm_ptr->rank; in MPIDI_CH3I_Get() 377 rank = win_ptr->comm_ptr->rank; in MPIDI_CH3I_Accumulate() 575 rank = win_ptr->comm_ptr->rank; in MPIDI_CH3I_Get_accumulate() 794 win_ptr, NULL); in MPID_Put() 817 win_ptr, NULL); in MPID_Get() 856 MPIR_Win * win_ptr) in MPID_Get_accumulate() argument 895 rank = win_ptr->comm_ptr->rank; in MPID_Compare_and_swap() [all …]
|
H A D | ch3u_handle_send_req.c | 48 MPIR_Win *win_ptr; in MPIDI_CH3_ReqHandler_GetSendComplete() local 73 win_ptr->at_completion_counter--; in MPIDI_CH3_ReqHandler_GetSendComplete() 74 MPIR_Assert(win_ptr->at_completion_counter >= 0); in MPIDI_CH3_ReqHandler_GetSendComplete() 99 MPIR_Win *win_ptr; in MPIDI_CH3_ReqHandler_GaccumSendComplete() local 132 win_ptr->at_completion_counter--; in MPIDI_CH3_ReqHandler_GaccumSendComplete() 133 MPIR_Assert(win_ptr->at_completion_counter >= 0); in MPIDI_CH3_ReqHandler_GaccumSendComplete() 160 MPIR_Win *win_ptr; in MPIDI_CH3_ReqHandler_CASSendComplete() local 193 win_ptr->at_completion_counter--; in MPIDI_CH3_ReqHandler_CASSendComplete() 194 MPIR_Assert(win_ptr->at_completion_counter >= 0); in MPIDI_CH3_ReqHandler_CASSendComplete() 220 MPIR_Win *win_ptr; in MPIDI_CH3_ReqHandler_FOPSendComplete() local [all …]
|
H A D | ch3u_rma_reqops.c | 11 int target_count, MPI_Datatype target_datatype, MPIR_Win * win_ptr, in MPID_Rput() argument 25 MPIR_ERR_CHKANDJUMP(win_ptr->states.access_state != MPIDI_RMA_PER_TARGET && in MPID_Rput() 26 win_ptr->states.access_state != MPIDI_RMA_LOCK_ALL_CALLED && in MPID_Rput() 27 win_ptr->states.access_state != MPIDI_RMA_LOCK_ALL_ISSUED && in MPID_Rput() 28 win_ptr->states.access_state != MPIDI_RMA_LOCK_ALL_GRANTED, in MPID_Rput() 65 int target_count, MPI_Datatype target_datatype, MPIR_Win * win_ptr, in MPID_Rget() argument 79 MPIR_ERR_CHKANDJUMP(win_ptr->states.access_state != MPIDI_RMA_PER_TARGET && in MPID_Rget() 133 MPIR_ERR_CHKANDJUMP(win_ptr->states.access_state != MPIDI_RMA_PER_TARGET && in MPID_Raccumulate() 153 target_datatype, op, win_ptr, ureq); in MPID_Raccumulate() 175 MPIR_Win * win_ptr, MPIR_Request ** request) in MPID_Rget_accumulate() argument [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/src/ |
H A D | ch3_rma_shm.c | 19 if (win_ptr->comm_ptr->node_comm == NULL) { in MPIDI_CH3_SHM_Win_shared_query() 25 comm_size = win_ptr->comm_ptr->local_size; in MPIDI_CH3_SHM_Win_shared_query() 67 int MPIDI_CH3_SHM_Win_free(MPIR_Win ** win_ptr) in MPIDI_CH3_SHM_Win_free() argument 74 if ((*win_ptr)->comm_ptr->node_comm == NULL) { in MPIDI_CH3_SHM_Win_free() 79 if ((*win_ptr)->shm_allocated) { in MPIDI_CH3_SHM_Win_free() 81 MPL_free((*win_ptr)->shm_base_addrs); in MPIDI_CH3_SHM_Win_free() 86 (*win_ptr)->shm_segment_len > 0) { in MPIDI_CH3_SHM_Win_free() 103 (*win_ptr)->shm_mutex && (*win_ptr)->shm_segment_len > 0) { in MPIDI_CH3_SHM_Win_free() 114 MPIDI_CH3I_SHM_MUTEX_DESTROY(*win_ptr); in MPIDI_CH3_SHM_Win_free() 127 if ((*win_ptr)->info_shm_base_addr != NULL) { in MPIDI_CH3_SHM_Win_free() [all …]
|
H A D | ch3_win_fns.c | 104 (*win_ptr)->shm_base_addr = NULL; in MPIDI_CH3I_Win_init() 105 (*win_ptr)->shm_segment_len = 0; in MPIDI_CH3I_Win_init() 107 (*win_ptr)->shm_mutex = NULL; in MPIDI_CH3I_Win_init() 286 (*win_ptr)->shm_allocated = TRUE; in MPIDI_CH3I_Win_detect_shm() 400 (*win_ptr)->basic_info_table = (MPIDI_Win_basic_info_t *) ((*win_ptr)->info_shm_base_addr); in MPIDI_CH3I_Win_gather_info() 495 (*win_ptr)->shm_segment_len = 0; in MPIDI_CH3I_Win_allocate_shm() 506 (*win_ptr)->base = NULL; in MPIDI_CH3I_Win_allocate_shm() 562 MPL_shm_seg_attach((*win_ptr)->shm_segment_handle, (*win_ptr)->shm_segment_len, in MPIDI_CH3I_Win_allocate_shm() 642 ((*win_ptr)->shm_base_addrs)[0] = (*win_ptr)->shm_base_addr; in MPIDI_CH3I_Win_allocate_shm() 666 (*win_ptr)->base = (*win_ptr)->shm_base_addrs[node_rank]; in MPIDI_CH3I_Win_allocate_shm() [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/src/ |
H A D | ch3_win_fns.c | 65 (*win_ptr)->shm_allocated = TRUE; in MPIDI_CH3I_Win_allocate_shared() 112 (*win_ptr)->shm_segment_len = 0; in MPIDI_CH3I_Win_allocate_shared() 121 (*win_ptr)->shm_segment_len += MPIDI_CH3_ROUND_UP_PAGESIZE((*win_ptr)->sizes[i]); in MPIDI_CH3I_Win_allocate_shared() 123 (*win_ptr)->shm_segment_len += (*win_ptr)->sizes[i]; in MPIDI_CH3I_Win_allocate_shared() 133 …mpi_errno = MPIU_SHMW_Seg_create_and_attach((*win_ptr)->shm_segment_handle, (*win_ptr)->shm_segmen… in MPIDI_CH3I_Win_allocate_shared() 166 … mpi_errno = MPIU_SHMW_Seg_attach((*win_ptr)->shm_segment_handle, (*win_ptr)->shm_segment_len, in MPIDI_CH3I_Win_allocate_shared() 178 (*win_ptr)->shm_base_addrs[0] = (*win_ptr)->shm_base_addr; in MPIDI_CH3I_Win_allocate_shared() 180 if ((*win_ptr)->sizes[i]) { in MPIDI_CH3I_Win_allocate_shared() 184 (*win_ptr)->shm_base_addrs[i] = cur_base + (*win_ptr)->sizes[i-1]; in MPIDI_CH3I_Win_allocate_shared() 193 (*win_ptr)->base = (*win_ptr)->shm_base_addrs[rank]; in MPIDI_CH3I_Win_allocate_shared() [all …]
|
H A D | ch3_rma_shm.c | 23 comm_size = win_ptr->comm_ptr->local_size; in MPIDI_CH3_SHM_Win_shared_query() 25 if (win_ptr->create_flavor != MPIX_WIN_FLAVOR_SHARED) { in MPIDI_CH3_SHM_Win_shared_query() 39 if (win_ptr->sizes[i] > 0) { in MPIDI_CH3_SHM_Win_shared_query() 40 *size = win_ptr->sizes[i]; in MPIDI_CH3_SHM_Win_shared_query() 41 *((void**) baseptr) = win_ptr->shm_base_addrs[i]; in MPIDI_CH3_SHM_Win_shared_query() 47 *size = win_ptr->sizes[target_rank]; in MPIDI_CH3_SHM_Win_shared_query() 64 int MPIDI_CH3_SHM_Win_free(MPID_Win **win_ptr) in MPIDI_CH3_SHM_Win_free() argument 72 if ((*win_ptr)->shm_allocated) { in MPIDI_CH3_SHM_Win_free() 74 MPIU_Free((*win_ptr)->shm_base_addrs); in MPIDI_CH3_SHM_Win_free() 76 …mpi_errno = MPIU_SHMW_Seg_detach((*win_ptr)->shm_segment_handle, (char **)&(*win_ptr)->shm_base_ad… in MPIDI_CH3_SHM_Win_free() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/ |
H A D | mpid_rma_oplist.h | 115 if (win_ptr->active == FALSE) { in MPIDI_CH3I_Win_set_active() 116 win_ptr->active = TRUE; in MPIDI_CH3I_Win_set_active() 138 if (win_ptr->active == TRUE) { in MPIDI_CH3I_Win_set_inactive() 139 win_ptr->active = FALSE; in MPIDI_CH3I_Win_set_inactive() 162 if (win_ptr->op_pool_head == NULL) { in MPIDI_CH3I_Win_op_alloc() 172 e = win_ptr->op_pool_head; in MPIDI_CH3I_Win_op_alloc() 173 DL_DELETE(win_ptr->op_pool_head, e); in MPIDI_CH3I_Win_op_alloc() 203 DL_PREPEND(win_ptr->op_pool_head, e); in MPIDI_CH3I_Win_op_free() 216 if (win_ptr->target_pool_head == NULL) { in MPIDI_CH3I_Win_target_alloc() 226 e = win_ptr->target_pool_head; in MPIDI_CH3I_Win_target_alloc() [all …]
|
H A D | mpidrma.h | 29 lock_pkt->source_win_handle = win_ptr->handle; in send_lock_msg() 521 MPIDI_Comm_get_vc(win_ptr->comm_ptr, win_ptr->comm_ptr->rank, &orig_vc); in handle_lock_ack() 526 win_ptr->outstanding_locks--; in handle_lock_ack() 539 win_ptr->outstanding_locks--; in handle_lock_ack() 565 MPIDI_CH3I_Win_set_active(win_ptr); in handle_lock_ack() 747 mpi_errno = handle_lock_ack(win_ptr, win_ptr->comm_ptr->rank, in acquire_local_lock() 771 mpi_errno = handle_lock_ack(win_ptr, win_ptr->comm_ptr->rank, in acquire_local_lock() 777 MPIDI_Comm_get_vc_set_active(win_ptr->comm_ptr, win_ptr->comm_ptr->rank, &my_vc); in acquire_local_lock() 805 win_ptr->outstanding_acks--; in MPIDI_CH3I_RMA_Handle_ack() 1026 win_ptr->at_completion_counter--; in finish_op_on_target() [all …]
|
H A D | mpid_rma_shm.h | 262 base = win_ptr->base; in MPIDI_CH3I_Shm_put_op() 263 disp_unit = win_ptr->disp_unit; in MPIDI_CH3I_Shm_put_op() 307 base = win_ptr->base; in MPIDI_CH3I_Shm_acc_op() 308 disp_unit = win_ptr->disp_unit; in MPIDI_CH3I_Shm_acc_op() 425 base = win_ptr->base; in MPIDI_CH3I_Shm_get_acc_op() 426 disp_unit = win_ptr->disp_unit; in MPIDI_CH3I_Shm_get_acc_op() 530 base = win_ptr->base; in MPIDI_CH3I_Shm_get_op() 531 disp_unit = win_ptr->disp_unit; in MPIDI_CH3I_Shm_get_op() 571 base = win_ptr->base; in MPIDI_CH3I_Shm_cas_op() 572 disp_unit = win_ptr->disp_unit; in MPIDI_CH3I_Shm_cas_op() [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/src/ |
H A D | mpid_rma.c | 83 (*win_ptr)->base = base; in MPID_Win_create() 134 comm_ptr, win_ptr); in MPID_Win_create_dynamic() 138 (*win_ptr)->base = MPI_BOTTOM; in MPID_Win_create_dynamic() 253 MPIU_Object_set_ref(*win_ptr, 1); in win_init() 255 (*win_ptr)->fence_cnt = 0; in win_init() 264 (*win_ptr)->start_assert = 0; in win_init() 269 (*win_ptr)->my_counter = 0; in win_init() 276 (*win_ptr)->lock_granted = 0; in win_init() 278 (*win_ptr)->shared_lock_ref_cnt = 0; in win_init() 281 (*win_ptr)->my_pt_rma_puts_accs = 0; in win_init() [all …]
|
H A D | ch3u_rma_ops.c | 90 MPIU_Free((*win_ptr)->sizes); in MPIDI_Win_free() 96 if ((*win_ptr)->create_flavor == MPIX_WIN_FLAVOR_ALLOCATE && (*win_ptr)->size > 0) { in MPIDI_Win_free() 97 MPIU_Free((*win_ptr)->base); in MPIDI_Win_free() 141 rank = win_ptr->myrank; in MPIDI_Put() 147 (char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Put() 159 if (win_ptr->rma_ops_list_tail) in MPIDI_Put() 237 rank = win_ptr->myrank; in MPIDI_Get() 333 rank = win_ptr->myrank; in MPIDI_Accumulate() 347 (char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Accumulate() 364 (*uop)((void *) origin_addr, (char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Accumulate() [all …]
|
H A D | ch3u_rma_sync.c | 196 comm_ptr = win_ptr->comm_ptr; in MPIDI_Win_fence() 246 win_ptr->my_counter = win_ptr->my_counter - comm_size + in MPIDI_Win_fence() 363 if (win_ptr->my_counter) in MPIDI_Win_fence() 384 win_ptr->fence_cnt = 0; in MPIDI_Win_fence() 722 MPID_Win *win_ptr, in MPIDI_CH3I_Send_contig_acc_msg() argument 1382 rank = win_ptr->myrank; in MPIDI_Win_complete() 1887 win_ptr->lock_granted = 0; in MPIDI_Win_unlock() 2651 MPID_Win *win_ptr; in MPIDI_CH3_PktHandler_Put() local 3086 MPID_Win *win_ptr; in MPIDI_CH3_PktHandler_Accumulate_Immed() local 3154 win_ptr->my_counter -= 1; in MPIDI_CH3_PktHandler_Accumulate_Immed() [all …]
|
H A D | ch3u_rma_acc_ops.c | 43 rank = win_ptr->myrank; in MPIDI_Get_accumulate() 53 mpi_errno = MPIR_Localcopy((char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Get_accumulate() 60 (char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Get_accumulate() 77 (*uop)((void *) origin_addr, (char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Get_accumulate() 115 (*uop)(tmp_buf, (char *) win_ptr->base + win_ptr->disp_unit * in MPIDI_Get_accumulate() 191 rank = win_ptr->myrank; in MPIDI_Compare_and_swap() 198 void *dest_addr = (char *) win_ptr->base + win_ptr->disp_unit * target_disp; in MPIDI_Compare_and_swap() 216 if (win_ptr->rma_ops_list_tail) in MPIDI_Compare_and_swap() 274 rank = win_ptr->myrank; in MPIDI_Fetch_and_op() 280 void *dest_addr = (char *) win_ptr->base + win_ptr->disp_unit * target_disp; in MPIDI_Fetch_and_op() [all …]
|
H A D | ch3u_win_fns.c | 52 comm_size = (*win_ptr)->comm_ptr->local_size; in MPIDI_CH3U_Win_create_gather() 53 rank = (*win_ptr)->comm_ptr->rank; in MPIDI_CH3U_Win_create_gather() 58 MPIU_CHKPMEM_MALLOC((*win_ptr)->base_addrs, void **, in MPIDI_CH3U_Win_create_gather() 68 MPIU_CHKPMEM_MALLOC((*win_ptr)->all_win_handles, MPI_Win *, in MPIDI_CH3U_Win_create_gather() 72 MPIU_CHKPMEM_MALLOC((*win_ptr)->pt_rma_puts_accs, int *, in MPIDI_CH3U_Win_create_gather() 88 tmp_buf[4*rank+3] = (MPI_Aint) (*win_ptr)->handle; in MPIDI_CH3U_Win_create_gather() 100 (*win_ptr)->base_addrs[i] = MPIU_AintToPtr(tmp_buf[k++]); in MPIDI_CH3U_Win_create_gather() 101 (*win_ptr)->sizes[i] = tmp_buf[k++]; in MPIDI_CH3U_Win_create_gather() 102 (*win_ptr)->disp_units[i] = (int) tmp_buf[k++]; in MPIDI_CH3U_Win_create_gather() 103 (*win_ptr)->all_win_handles[i] = (MPI_Win) tmp_buf[k++]; in MPIDI_CH3U_Win_create_gather() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpi/attr/ |
H A D | win_get_attr.c | 31 MPIR_Win *win_ptr = NULL; in MPII_Win_get_attr() local 52 MPIR_Win_get_ptr(win, win_ptr); in MPII_Win_get_attr() 93 *attr_val_p = win_ptr->base; in MPII_Win_get_attr() 96 win_ptr->copySize = win_ptr->size; in MPII_Win_get_attr() 100 win_ptr->copyDispUnit = win_ptr->disp_unit; in MPII_Win_get_attr() 104 win_ptr->copyCreateFlavor = win_ptr->create_flavor; in MPII_Win_get_attr() 108 win_ptr->copyModel = win_ptr->model; in MPII_Win_get_attr() 120 *attr_int = win_ptr->size; in MPII_Win_get_attr() 131 *attr_int = win_ptr->model; in MPII_Win_get_attr() 233 MPIR_Win *win_ptr = NULL; in MPI_Win_get_attr() local [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpi/attr/ |
H A D | win_get_attr.c | 34 MPID_Win *win_ptr = NULL; in MPIR_WinGetAttr() local 65 MPID_Win_get_ptr( win, win_ptr ); in MPIR_WinGetAttr() 106 *attr_val_p = win_ptr->base; in MPIR_WinGetAttr() 109 win_ptr->copySize = win_ptr->size; in MPIR_WinGetAttr() 113 win_ptr->copyDispUnit = win_ptr->disp_unit; in MPIR_WinGetAttr() 117 win_ptr->copyCreateFlavor = win_ptr->create_flavor; in MPIR_WinGetAttr() 121 win_ptr->copyModel = win_ptr->model; in MPIR_WinGetAttr() 133 *attr_int = win_ptr->size; in MPIR_WinGetAttr() 138 *attr_int = win_ptr->disp_unit; in MPIR_WinGetAttr() 144 *attr_int = win_ptr->model; in MPIR_WinGetAttr() [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpi/errhan/ |
H A D | win_call_errhandler.c | 56 MPID_Win *win_ptr = NULL; in MPI_Win_call_errhandler() local 79 MPID_Win_get_ptr( win, win_ptr ); in MPI_Win_call_errhandler() 87 MPID_Win_valid_ptr( win_ptr, mpi_errno ); in MPI_Win_call_errhandler() 97 MPIU_THREAD_CS_ENTER(MPI_OBJ, win_ptr); in MPI_Win_call_errhandler() 100 if (!win_ptr->errhandler || in MPI_Win_call_errhandler() 101 win_ptr->errhandler->handle == MPI_ERRORS_ARE_FATAL) { in MPI_Win_call_errhandler() 121 switch (win_ptr->errhandler->language) { in MPI_Win_call_errhandler() 124 &win_ptr->handle, &errorcode ); in MPI_Win_call_errhandler() 128 MPIR_Process.cxx_call_errfn( 2, &win_ptr->handle, in MPI_Win_call_errhandler() 141 MPI_Fint winhandle=win_ptr->handle; in MPI_Win_call_errhandler() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpi/errhan/ |
H A D | win_call_errhandler.c | 53 MPIR_Win *win_ptr = NULL; in MPI_Win_call_errhandler() local 73 MPIR_Win_get_ptr(win, win_ptr); in MPI_Win_call_errhandler() 81 MPIR_Win_valid_ptr(win_ptr, mpi_errno); in MPI_Win_call_errhandler() 92 MPID_THREAD_CS_ENTER(POBJ, MPIR_THREAD_POBJ_WIN_MUTEX(win_ptr)); in MPI_Win_call_errhandler() 95 if (!win_ptr->errhandler || win_ptr->errhandler->handle == MPI_ERRORS_ARE_FATAL) { in MPI_Win_call_errhandler() 100 if (win_ptr->errhandler->handle == MPI_ERRORS_RETURN) { in MPI_Win_call_errhandler() 115 switch (win_ptr->errhandler->language) { in MPI_Win_call_errhandler() 117 (*win_ptr->errhandler->errfn.C_Win_Handler_function) (&win_ptr->handle, &errorcode); in MPI_Win_call_errhandler() 121 MPIR_Process.cxx_call_errfn(2, &win_ptr->handle, in MPI_Win_call_errhandler() 135 MPI_Fint winhandle = win_ptr->handle; in MPI_Win_call_errhandler() [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpi/rma/ |
H A D | win_free.c | 54 MPID_Win *win_ptr = NULL; in MPI_Win_free() local 74 MPID_Win_get_ptr( *win, win_ptr ); in MPI_Win_free() 82 MPID_Win_valid_ptr( win_ptr, mpi_errno ); in MPI_Win_free() 89 "**winfreewhilelocked %d", win_ptr->lockRank); in MPI_Win_free() 101 if (MPIR_Process.attr_free && win_ptr->attributes) in MPI_Win_free() 103 mpi_errno = MPIR_Process.attr_free( win_ptr->handle, in MPI_Win_free() 104 &win_ptr->attributes ); in MPI_Win_free() 114 if (win_ptr->errhandler && in MPI_Win_free() 115 ! (HANDLE_GET_KIND(win_ptr->errhandler->handle) == in MPI_Win_free() 118 MPIR_Errhandler_release_ref( win_ptr->errhandler,&in_use); in MPI_Win_free() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpi/rma/ |
H A D | win_free.c | 49 MPIR_Win *win_ptr = NULL; in MPI_Win_free() local 69 MPIR_Win_get_ptr(*win, win_ptr); in MPI_Win_free() 77 MPIR_Win_valid_ptr(win_ptr, mpi_errno); in MPI_Win_free() 91 if (MPIR_Process.attr_free && win_ptr->attributes) { in MPI_Win_free() 92 mpi_errno = MPIR_Process.attr_free(win_ptr->handle, &win_ptr->attributes); in MPI_Win_free() 102 if (win_ptr->errhandler && !(HANDLE_IS_BUILTIN(win_ptr->errhandler->handle))) { in MPI_Win_free() 104 MPIR_Errhandler_release_ref(win_ptr->errhandler, &in_use); in MPI_Win_free() 106 MPIR_Handle_obj_free(&MPIR_Errhandler_mem, win_ptr->errhandler); in MPI_Win_free() 110 mpi_errno = MPID_Win_free(&win_ptr); in MPI_Win_free() 131 mpi_errno = MPIR_Err_return_win(win_ptr, __func__, mpi_errno); in MPI_Win_free()
|