ranks_in_win_grp 42 ompi/mca/osc/ucx/osc_ucx_active_target.c static inline void ompi_osc_ucx_handle_incoming_post(ompi_osc_ucx_module_t *module, volatile uint64_t *post_ptr, int ranks_in_win_grp[], int grp_size) { ranks_in_win_grp 49 ompi/mca/osc/ucx/osc_ucx_active_target.c if (post_rank == ranks_in_win_grp[i]) { ranks_in_win_grp 89 ompi/mca/osc/ucx/osc_ucx_active_target.c int i, size, *ranks_in_grp = NULL, *ranks_in_win_grp = NULL; ranks_in_win_grp 105 ompi/mca/osc/ucx/osc_ucx_active_target.c ranks_in_win_grp = malloc(sizeof(int) * ompi_comm_size(module->comm)); ranks_in_win_grp 117 ompi/mca/osc/ucx/osc_ucx_active_target.c win_group, ranks_in_win_grp); ranks_in_win_grp 128 ompi/mca/osc/ucx/osc_ucx_active_target.c if (pending_post->rank == ranks_in_win_grp[i]) { ranks_in_win_grp 144 ompi/mca/osc/ucx/osc_ucx_active_target.c ompi_osc_ucx_handle_incoming_post(module, &(module->state.post_state[i]), ranks_in_win_grp, size); ranks_in_win_grp 155 ompi/mca/osc/ucx/osc_ucx_active_target.c module->start_grp_ranks = ranks_in_win_grp; ranks_in_win_grp 215 ompi/mca/osc/ucx/osc_ucx_active_target.c int *ranks_in_grp = NULL, *ranks_in_win_grp = NULL; ranks_in_win_grp 220 ompi/mca/osc/ucx/osc_ucx_active_target.c ranks_in_win_grp = malloc(sizeof(int) * ompi_comm_size(module->comm)); ranks_in_win_grp 232 ompi/mca/osc/ucx/osc_ucx_active_target.c win_group, ranks_in_win_grp); ranks_in_win_grp 238 ompi/mca/osc/ucx/osc_ucx_active_target.c uint64_t remote_addr = module->state_addrs[ranks_in_win_grp[i]] + OSC_UCX_STATE_POST_INDEX_OFFSET; // write to state.post_index on remote side ranks_in_win_grp 243 ompi/mca/osc/ucx/osc_ucx_active_target.c 1, ranks_in_win_grp[i], &result, ranks_in_win_grp 251 ompi/mca/osc/ucx/osc_ucx_active_target.c remote_addr = module->state_addrs[ranks_in_win_grp[i]] + OSC_UCX_STATE_POST_STATE_OFFSET + sizeof(uint64_t) * curr_idx; ranks_in_win_grp 281 ompi/mca/osc/ucx/osc_ucx_active_target.c free(ranks_in_win_grp);