Home
last modified time | relevance | path

Searched refs:win_ptr (Results 1 – 25 of 159) sorted by relevance

1234567

/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/
H A Dch3u_rma_sync.c420 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 Dmpid_rma.c74 (*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 Dch3u_rma_progress.c66 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 Dmpidi_rma.c133 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 Dch3u_rma_ops.c61 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 Dch3u_handle_send_req.c48 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 Dch3u_rma_reqops.c11 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 Dch3_rma_shm.c19 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 Dch3_win_fns.c104 (*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 Dch3_win_fns.c65 (*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 Dch3_rma_shm.c23 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 Dmpid_rma_oplist.h115 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 Dmpidrma.h29 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 Dmpid_rma_shm.h262 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 Dmpid_rma.c83 (*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 Dch3u_rma_ops.c90 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 Dch3u_rma_sync.c196 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 Dch3u_rma_acc_ops.c43 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 Dch3u_win_fns.c52 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 Dwin_get_attr.c31 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 Dwin_get_attr.c34 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 Dwin_call_errhandler.c56 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 Dwin_call_errhandler.c53 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 Dwin_free.c54 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 Dwin_free.c49 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()

1234567