procs 150 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c struct ompi_proc_t **procs, procs 191 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct ompi_proc_t **procs, procs 210 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct ompi_proc_t **procs, procs 203 ompi/datatype/ompi_datatype_create_darray.c int tmp_rank = rank, procs = size; procs 208 ompi/datatype/ompi_datatype_create_darray.c procs = procs / psize_array[i]; procs 209 ompi/datatype/ompi_datatype_create_darray.c coords[i] = tmp_rank / procs; procs 210 ompi/datatype/ompi_datatype_create_darray.c tmp_rank = tmp_rank % procs; procs 158 ompi/group/group.h ompi_group_t *ompi_group_allocate_plist_w_procs (ompi_proc_t **procs, int group_size); procs 60 ompi/group/group_init.c ompi_proc_t **procs = calloc (group_size, sizeof (ompi_proc_t *)); procs 63 ompi/group/group_init.c if (NULL == procs) { procs 67 ompi/group/group_init.c new_group = ompi_group_allocate_plist_w_procs (procs, group_size); procs 69 ompi/group/group_init.c free (procs); procs 75 ompi/group/group_init.c ompi_group_t *ompi_group_allocate_plist_w_procs (ompi_proc_t **procs, int group_size) procs 98 ompi/group/group_init.c new_group->grp_proc_pointers = procs; procs 461 ompi/mca/bml/bml.h struct ompi_proc_t** procs, procs 497 ompi/mca/bml/bml.h struct ompi_proc_t** procs procs 457 ompi/mca/bml/r2/bml_r2.c struct ompi_proc_t** procs, procs 477 ompi/mca/bml/r2/bml_r2.c struct ompi_proc_t* proc = procs[p_index]; procs 498 ompi/mca/bml/r2/bml_r2.c procs = new_procs; procs 606 ompi/mca/bml/r2/bml_r2.c struct ompi_proc_t** procs) procs 609 ompi/mca/bml/r2/bml_r2.c ompi_proc_t *proc = procs[p]; procs 773 ompi/mca/bml/r2/bml_r2.c ompi_proc_t** procs; procs 783 ompi/mca/bml/r2/bml_r2.c procs = ompi_proc_all(&num_procs); procs 784 ompi/mca/bml/r2/bml_r2.c if(NULL == procs) procs 798 ompi/mca/bml/r2/bml_r2.c ompi_proc_t* proc = procs[p]; procs 804 ompi/mca/bml/r2/bml_r2.c OBJ_RELEASE(procs[p]); procs 806 ompi/mca/bml/r2/bml_r2.c free(procs); procs 835 ompi/mca/bml/r2/bml_r2.c ompi_proc_t** procs; procs 846 ompi/mca/bml/r2/bml_r2.c procs = ompi_proc_all(&num_procs); procs 847 ompi/mca/bml/r2/bml_r2.c if(NULL == procs) procs 855 ompi/mca/bml/r2/bml_r2.c ompi_proc_t* proc = procs[p]; procs 891 ompi/mca/bml/r2/bml_r2.c OBJ_RELEASE(procs[p]); procs 893 ompi/mca/bml/r2/bml_r2.c free(procs); procs 45 ompi/mca/bml/r2/bml_r2_ft.c ompi_proc_t** procs = NULL; procs 61 ompi/mca/bml/r2/bml_r2_ft.c procs = ompi_proc_all(&num_procs); procs 62 ompi/mca/bml/r2/bml_r2_ft.c if(NULL == procs) { procs 71 ompi/mca/bml/r2/bml_r2_ft.c procs = ompi_proc_all(&num_procs); procs 72 ompi/mca/bml/r2/bml_r2_ft.c if(NULL == procs) { procs 187 ompi/mca/bml/r2/bml_r2_ft.c if( NULL != procs[p]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML]) { procs 188 ompi/mca/bml/r2/bml_r2_ft.c OBJ_RELEASE(procs[p]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML]); procs 189 ompi/mca/bml/r2/bml_r2_ft.c procs[p]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML] = NULL; procs 192 ompi/mca/bml/r2/bml_r2_ft.c OBJ_RELEASE(procs[p]); procs 195 ompi/mca/bml/r2/bml_r2_ft.c if( NULL != procs ) { procs 196 ompi/mca/bml/r2/bml_r2_ft.c free(procs); procs 197 ompi/mca/bml/r2/bml_r2_ft.c procs = NULL; procs 276 ompi/mca/bml/r2/bml_r2_ft.c if( NULL != procs[p]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML]) { procs 277 ompi/mca/bml/r2/bml_r2_ft.c OBJ_RELEASE(procs[p]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML]); procs 278 ompi/mca/bml/r2/bml_r2_ft.c procs[p]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML] = NULL; procs 281 ompi/mca/bml/r2/bml_r2_ft.c OBJ_RELEASE(procs[p]); procs 284 ompi/mca/bml/r2/bml_r2_ft.c if( NULL != procs ) { procs 285 ompi/mca/bml/r2/bml_r2_ft.c free(procs); procs 286 ompi/mca/bml/r2/bml_r2_ft.c procs = NULL; procs 437 ompi/mca/common/monitoring/common_monitoring.c int mca_common_monitoring_add_procs(struct ompi_proc_t **procs, procs 469 ompi/mca/common/monitoring/common_monitoring.c if( ompi_proc_is_sentinel(procs[i]) ) { procs 470 ompi/mca/common/monitoring/common_monitoring.c tmp = ompi_proc_sentinel_to_name((uintptr_t)procs[i]); procs 472 ompi/mca/common/monitoring/common_monitoring.c tmp = procs[i]->super.proc_name; procs 51 ompi/mca/common/monitoring/common_monitoring.h OMPI_DECLSPEC int mca_common_monitoring_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 28 ompi/mca/common/monitoring/common_monitoring_coll.c char*procs; procs 65 ompi/mca/common/monitoring/common_monitoring_coll.c if( (-1 != data->world_rank) && (NULL == data->procs || 0 == strlen(data->procs)) ) { procs 84 ompi/mca/common/monitoring/common_monitoring_coll.c data->procs = realloc(tmp_procs, pos * sizeof(char)); /* Adjust to size required */ procs 149 ompi/mca/common/monitoring/common_monitoring_coll.c free(data->procs); procs 171 ompi/mca/common/monitoring/common_monitoring_coll.c data->p_comm->c_name : "(no-name)", data->procs, procs 356 ompi/mca/common/monitoring/common_monitoring_coll.c coll_data->procs = NULL; procs 75 ompi/mca/crcp/base/base.h ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_add_procs( struct ompi_proc_t **procs, size_t nprocs, ompi_crcp_base_pml_state_t* ); procs 76 ompi/mca/crcp/base/base.h ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_del_procs( struct ompi_proc_t **procs, size_t nprocs, ompi_crcp_base_pml_state_t* ); procs 115 ompi/mca/crcp/base/base.h struct ompi_proc_t** procs, procs 123 ompi/mca/crcp/base/base.h struct ompi_proc_t** procs, procs 135 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_add_procs( struct ompi_proc_t **procs, procs 143 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_del_procs( struct ompi_proc_t **procs, procs 279 ompi/mca/crcp/base/crcp_base_fns.c struct ompi_proc_t** procs, procs 291 ompi/mca/crcp/base/crcp_base_fns.c struct ompi_proc_t** procs, procs 49 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c struct ompi_proc_t** procs, procs 61 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c struct ompi_proc_t** procs, procs 42 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h struct ompi_proc_t** procs, procs 50 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h struct ompi_proc_t** procs, procs 1425 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c struct ompi_proc_t **procs, procs 1451 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c new_peer_ref->proc_name.jobid = OMPI_CAST_RTE_NAME(&procs[i]->super.proc_name)->jobid; procs 1452 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c new_peer_ref->proc_name.vpid = OMPI_CAST_RTE_NAME(&procs[i]->super.proc_name)->vpid; procs 1463 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c struct ompi_proc_t **procs, procs 1480 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c item = (opal_list_item_t*)find_peer(*(ompi_process_name_t*)&procs[i]->super.proc_name); procs 1484 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&procs[i]->super.proc_name)); procs 52 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h ( struct ompi_proc_t **procs, size_t nprocs, procs 55 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h ( struct ompi_proc_t **procs, size_t nprocs, procs 115 ompi/mca/crcp/crcp.h ( struct ompi_proc_t **procs, size_t nprocs , ompi_crcp_base_pml_state_t*); procs 117 ompi/mca/crcp/crcp.h ( struct ompi_proc_t **procs, size_t nprocs , ompi_crcp_base_pml_state_t*); procs 202 ompi/mca/crcp/crcp.h struct ompi_proc_t** procs, procs 210 ompi/mca/crcp/crcp.h struct ompi_proc_t** procs, procs 28 ompi/mca/io/romio321/romio/adio/common/ad_darray.c int procs, tmp_rank, i, tmp_size, blklen, *coords; procs 36 ompi/mca/io/romio321/romio/adio/common/ad_darray.c procs = size; procs 39 ompi/mca/io/romio321/romio/adio/common/ad_darray.c procs = procs/array_of_psizes[i]; procs 40 ompi/mca/io/romio321/romio/adio/common/ad_darray.c coords[i] = tmp_rank/procs; procs 41 ompi/mca/io/romio321/romio/adio/common/ad_darray.c tmp_rank = tmp_rank % procs; procs 18 ompi/mca/io/romio321/romio/adio/common/ad_open.c int rank, int procs, int *error_code); procs 29 ompi/mca/io/romio321/romio/adio/common/ad_open.c int err, rank, procs; procs 86 ompi/mca/io/romio321/romio/adio/common/ad_open.c MPI_Comm_size(comm, &procs); procs 160 ompi/mca/io/romio321/romio/adio/common/ad_open.c build_cb_config_list(fd, orig_comm, comm, rank, procs, error_code); procs 280 ompi/mca/io/romio321/romio/adio/common/ad_open.c int rank, int procs, int *error_code) procs 296 ompi/mca/io/romio321/romio/adio/common/ad_open.c tmp_ranklist = (int *) ADIOI_Malloc(sizeof(int) * procs); procs 57 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c static int ADIOI_OneSidedSetup(ADIO_File fd, int procs) { procs 63 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c fd->io_buf_put_amounts = (int *) ADIOI_Malloc(procs*sizeof(int)); procs 64 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ret =MPI_Win_create(fd->io_buf_put_amounts,procs*sizeof(int),sizeof(int), procs 159 ompi/mca/mtl/mtl.h struct ompi_proc_t** procs); procs 181 ompi/mca/mtl/mtl.h struct ompi_proc_t** procs); procs 46 ompi/mca/mtl/ofi/mtl_ofi.c struct ompi_proc_t** procs) procs 97 ompi/mca/mtl/ofi/mtl_ofi.c procs[i], procs 103 ompi/mca/mtl/ofi/mtl_ofi.c procs[i]->super.proc_hostname, procs 140 ompi/mca/mtl/ofi/mtl_ofi.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL] = endpoint; procs 161 ompi/mca/mtl/ofi/mtl_ofi.c struct ompi_proc_t** procs) procs 168 ompi/mca/mtl/ofi/mtl_ofi.c if (NULL != procs[i] && procs 169 ompi/mca/mtl/ofi/mtl_ofi.c NULL != procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL]) { procs 170 ompi/mca/mtl/ofi/mtl_ofi.c endpoint = procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL]; procs 177 ompi/mca/mtl/ofi/mtl_ofi.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL] = NULL; procs 53 ompi/mca/mtl/ofi/mtl_ofi.h struct ompi_proc_t **procs); procs 18 ompi/mca/mtl/ofi/mtl_ofi_endpoint.h struct ompi_proc_t **procs); procs 249 ompi/mca/mtl/portals4/mtl_portals4.c ompi_proc_t **procs) procs 268 ompi/mca/mtl/portals4/mtl_portals4.c &procs[i]->super.proc_name, (uint8_t**)&modex_id, &size); procs 394 ompi/mca/mtl/portals4/mtl_portals4.c ompi_proc_t **procs) procs 401 ompi/mca/mtl/portals4/mtl_portals4.c if (procs[i]->super.proc_arch != ompi_proc_local()->super.proc_arch) { procs 406 ompi/mca/mtl/portals4/mtl_portals4.c OMPI_NAME_PRINT(&procs[i]->super.proc_name), procs 407 ompi/mca/mtl/portals4/mtl_portals4.c procs[i]->super.proc_arch, ompi_proc_local()->super.proc_arch); procs 411 ompi/mca/mtl/portals4/mtl_portals4.c if (NULL == procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]) { procs 412 ompi/mca/mtl/portals4/mtl_portals4.c ret = create_endpoint(procs[i]); procs 426 ompi/mca/mtl/portals4/mtl_portals4.c &procs[i]->super.proc_name, (uint8_t**)&modex_id, &size); procs 428 ompi/mca/mtl/portals4/mtl_portals4.c ptl_process_t *proc = (ptl_process_t*) procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]; procs 430 ompi/mca/mtl/portals4/mtl_portals4.c if ((size_t)proc->rank != procs[i]->super.proc_name.vpid) { procs 456 ompi/mca/mtl/portals4/mtl_portals4.c struct ompi_proc_t** procs) procs 465 ompi/mca/mtl/portals4/mtl_portals4.c procs); procs 475 ompi/mca/mtl/portals4/mtl_portals4.c ret = create_maptable(nprocs, procs); procs 508 ompi/mca/mtl/portals4/mtl_portals4.c procs); procs 527 ompi/mca/mtl/portals4/mtl_portals4.c struct ompi_proc_t** procs) procs 535 ompi/mca/mtl/portals4/mtl_portals4.c if (NULL != procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]) { procs 536 ompi/mca/mtl/portals4/mtl_portals4.c free(procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]); procs 537 ompi/mca/mtl/portals4/mtl_portals4.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4] = NULL; procs 260 ompi/mca/mtl/portals4/mtl_portals4.h struct ompi_proc_t** procs); procs 264 ompi/mca/mtl/portals4/mtl_portals4.h struct ompi_proc_t** procs); procs 247 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c struct ompi_proc_t **procs) procs 272 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c *((ptl_process_t*) procs[0]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]); procs 275 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c *((ptl_process_t*) procs[(me - 1) / 2]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]); procs 278 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c *((ptl_process_t*) procs[me]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]); procs 288 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c *((ptl_process_t*) procs[tmp]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4]); procs 94 ompi/mca/mtl/portals4/mtl_portals4_flowctl.h struct ompi_proc_t **procs); procs 258 ompi/mca/mtl/psm/mtl_psm.c struct ompi_proc_t** procs) procs 294 ompi/mca/mtl/psm/mtl_psm.c if (NULL != procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL]) { procs 301 ompi/mca/mtl/psm/mtl_psm.c &procs[i]->super.proc_name, (void**)&epid, &size); procs 340 ompi/mca/mtl/psm/mtl_psm.c opal_output(0, " %s", (NULL == procs[j]->super.proc_hostname) ? procs 341 ompi/mca/mtl/psm/mtl_psm.c "unknown" : procs[j]->super.proc_hostname); procs 366 ompi/mca/mtl/psm/mtl_psm.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL] = endpoint; procs 392 ompi/mca/mtl/psm/mtl_psm.c struct ompi_proc_t** procs) procs 40 ompi/mca/mtl/psm/mtl_psm.h struct ompi_proc_t** procs); procs 44 ompi/mca/mtl/psm/mtl_psm.h struct ompi_proc_t** procs); procs 246 ompi/mca/mtl/psm2/mtl_psm2.c struct ompi_proc_t** procs) procs 282 ompi/mca/mtl/psm2/mtl_psm2.c if (NULL != procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL]) { procs 289 ompi/mca/mtl/psm2/mtl_psm2.c &procs[i]->super.proc_name, (void**)&epid, &size); procs 327 ompi/mca/mtl/psm2/mtl_psm2.c opal_output(0, " %s", (NULL == procs[j]->super.proc_hostname) ? procs 328 ompi/mca/mtl/psm2/mtl_psm2.c "unknown" : procs[j]->super.proc_hostname); procs 353 ompi/mca/mtl/psm2/mtl_psm2.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL] = endpoint; procs 379 ompi/mca/mtl/psm2/mtl_psm2.c struct ompi_proc_t** procs) procs 43 ompi/mca/mtl/psm2/mtl_psm2.h struct ompi_proc_t** procs); procs 47 ompi/mca/mtl/psm2/mtl_psm2.h struct ompi_proc_t** procs); procs 60 ompi/mca/pml/base/base.h struct ompi_proc_t **procs, procs 321 ompi/mca/pml/base/pml_base_select.c ompi_proc_t **procs, procs 346 ompi/mca/pml/base/pml_base_select.c &procs[0]->super.proc_name, (void**) &remote_pml, &size); procs 374 ompi/mca/pml/base/pml_base_select.c my_pml, OMPI_NAME_PRINT(&procs[0]->super.proc_name), procs 375 ompi/mca/pml/base/pml_base_select.c (NULL == procs[0]->super.proc_hostname) ? "unknown" : procs[0]->super.proc_hostname, procs 115 ompi/mca/pml/cm/pml_cm.c mca_pml_cm_add_procs(struct ompi_proc_t** procs, size_t nprocs) procs 121 ompi/mca/pml/cm/pml_cm.c if (procs[i]->super.proc_arch != ompi_proc_local()->super.proc_arch) { procs 129 ompi/mca/pml/cm/pml_cm.c procs, procs 134 ompi/mca/pml/cm/pml_cm.c ret = OMPI_MTL_CALL(add_procs(ompi_mtl, nprocs, procs)); procs 140 ompi/mca/pml/cm/pml_cm.c mca_pml_cm_del_procs(struct ompi_proc_t** procs, size_t nprocs) procs 144 ompi/mca/pml/cm/pml_cm.c ret = OMPI_MTL_CALL(del_procs(ompi_mtl, nprocs, procs)); procs 63 ompi/mca/pml/cm/pml_cm.h OMPI_DECLSPEC extern int mca_pml_cm_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 64 ompi/mca/pml/cm/pml_cm.h OMPI_DECLSPEC extern int mca_pml_cm_del_procs(struct ompi_proc_t **procs, size_t nprocs); procs 88 ompi/mca/pml/crcpw/pml_crcpw.h int mca_pml_crcpw_add_procs( struct ompi_proc_t **procs, size_t nprocs ); procs 89 ompi/mca/pml/crcpw/pml_crcpw.h int mca_pml_crcpw_del_procs( struct ompi_proc_t **procs, size_t nprocs ); procs 209 ompi/mca/pml/crcpw/pml_crcpw_module.c int mca_pml_crcpw_add_procs(ompi_proc_t** procs, size_t nprocs) procs 220 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_add_procs(procs, nprocs, pml_state); procs 228 ompi/mca/pml/crcpw/pml_crcpw_module.c if( OMPI_SUCCESS != (ret = mca_pml_crcpw_module.wrapped_pml_module.pml_add_procs(procs, nprocs) ) ) { procs 235 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_add_procs(procs, nprocs, pml_state); procs 247 ompi/mca/pml/crcpw/pml_crcpw_module.c int mca_pml_crcpw_del_procs(ompi_proc_t** procs, size_t nprocs) procs 258 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_del_procs(procs, nprocs, pml_state); procs 266 ompi/mca/pml/crcpw/pml_crcpw_module.c if( OMPI_SUCCESS != (ret = mca_pml_crcpw_module.wrapped_pml_module.pml_del_procs(procs, nprocs) ) ) { procs 273 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_del_procs(procs, nprocs, pml_state); procs 70 ompi/mca/pml/example/pml_example.c int mca_pml_example_add_procs(ompi_proc_t** procs, size_t nprocs) procs 75 ompi/mca/pml/example/pml_example.c int mca_pml_example_del_procs(ompi_proc_t** procs, size_t nprocs) procs 50 ompi/mca/pml/example/pml_example.h extern int mca_pml_example_add_procs( struct ompi_proc_t **procs, size_t nprocs ); procs 51 ompi/mca/pml/example/pml_example.h extern int mca_pml_example_del_procs( struct ompi_proc_t **procs, size_t nprocs ); procs 42 ompi/mca/pml/monitoring/pml_monitoring.h extern int mca_pml_monitoring_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 44 ompi/mca/pml/monitoring/pml_monitoring.h extern int mca_pml_monitoring_del_procs(struct ompi_proc_t **procs, size_t nprocs); procs 59 ompi/mca/pml/monitoring/pml_monitoring_component.c int mca_pml_monitoring_add_procs(struct ompi_proc_t **procs, procs 62 ompi/mca/pml/monitoring/pml_monitoring_component.c int ret = mca_common_monitoring_add_procs(procs, nprocs); procs 64 ompi/mca/pml/monitoring/pml_monitoring_component.c ret = pml_selected_module.pml_add_procs(procs, nprocs); procs 71 ompi/mca/pml/monitoring/pml_monitoring_component.c int mca_pml_monitoring_del_procs(struct ompi_proc_t **procs, procs 74 ompi/mca/pml/monitoring/pml_monitoring_component.c return pml_selected_module.pml_del_procs(procs, nprocs); procs 306 ompi/mca/pml/ob1/pml_ob1.c int mca_pml_ob1_add_procs(ompi_proc_t** procs, size_t nprocs) procs 329 ompi/mca/pml/ob1/pml_ob1.c procs, procs 336 ompi/mca/pml/ob1/pml_ob1.c procs, procs 470 ompi/mca/pml/ob1/pml_ob1.c int mca_pml_ob1_del_procs(ompi_proc_t** procs, size_t nprocs) procs 472 ompi/mca/pml/ob1/pml_ob1.c return mca_bml.bml_del_procs(nprocs, procs); procs 619 ompi/mca/pml/ob1/pml_ob1.c mca_pml_ob1_comm_proc_t* proc = pml_comm->procs[i]; procs 829 ompi/mca/pml/ob1/pml_ob1.c ompi_proc_t** procs = NULL; procs 862 ompi/mca/pml/ob1/pml_ob1.c procs = ompi_proc_all(&num_procs); procs 863 ompi/mca/pml/ob1/pml_ob1.c if(NULL == procs) { procs 879 ompi/mca/pml/ob1/pml_ob1.c OBJ_RELEASE(procs[p]); procs 881 ompi/mca/pml/ob1/pml_ob1.c free (procs); procs 893 ompi/mca/pml/ob1/pml_ob1.c procs = ompi_proc_all(&num_procs); procs 894 ompi/mca/pml/ob1/pml_ob1.c if(NULL == procs) { procs 918 ompi/mca/pml/ob1/pml_ob1.c OBJ_RELEASE(procs[p]); procs 920 ompi/mca/pml/ob1/pml_ob1.c free (procs); procs 971 ompi/mca/pml/ob1/pml_ob1.c if( OMPI_SUCCESS != (ret = mca_pml_ob1_add_procs(procs, num_procs) ) ) { procs 982 ompi/mca/pml/ob1/pml_ob1.c if( NULL != procs ) { procs 984 ompi/mca/pml/ob1/pml_ob1.c OBJ_RELEASE(procs[p]); procs 986 ompi/mca/pml/ob1/pml_ob1.c free(procs); procs 987 ompi/mca/pml/ob1/pml_ob1.c procs = NULL; procs 1018 ompi/mca/pml/ob1/pml_ob1.c if( OMPI_SUCCESS != (ret = mca_pml_ob1_add_procs(procs, num_procs) ) ) { procs 1029 ompi/mca/pml/ob1/pml_ob1.c if( NULL != procs ) { procs 1031 ompi/mca/pml/ob1/pml_ob1.c OBJ_RELEASE(procs[p]); procs 1033 ompi/mca/pml/ob1/pml_ob1.c free(procs); procs 1034 ompi/mca/pml/ob1/pml_ob1.c procs = NULL; procs 105 ompi/mca/pml/ob1/pml_ob1.h struct ompi_proc_t **procs, procs 110 ompi/mca/pml/ob1/pml_ob1.h struct ompi_proc_t **procs, procs 72 ompi/mca/pml/ob1/pml_ob1_comm.c comm->procs = NULL; procs 80 ompi/mca/pml/ob1/pml_ob1_comm.c if (NULL != comm->procs) { procs 82 ompi/mca/pml/ob1/pml_ob1_comm.c if (comm->procs[i]) { procs 83 ompi/mca/pml/ob1/pml_ob1_comm.c OBJ_RELEASE(comm->procs[i]); procs 87 ompi/mca/pml/ob1/pml_ob1_comm.c free(comm->procs); procs 111 ompi/mca/pml/ob1/pml_ob1_comm.c comm->procs = (mca_pml_ob1_comm_proc_t **) calloc(size, sizeof (mca_pml_ob1_comm_proc_t *)); procs 112 ompi/mca/pml/ob1/pml_ob1_comm.c if(NULL == comm->procs) { procs 69 ompi/mca/pml/ob1/pml_ob1_comm.h mca_pml_ob1_comm_proc_t **procs; procs 95 ompi/mca/pml/ob1/pml_ob1_comm.h if (OPAL_UNLIKELY(NULL == pml_comm->procs[rank])) { procs 97 ompi/mca/pml/ob1/pml_ob1_comm.h if (NULL == pml_comm->procs[rank]) { procs 102 ompi/mca/pml/ob1/pml_ob1_comm.h pml_comm->procs[rank] = proc; procs 107 ompi/mca/pml/ob1/pml_ob1_comm.h return pml_comm->procs[rank]; procs 152 ompi/mca/pml/ob1/pml_ob1_component.c pml_proc = pml_comm->procs[i]; procs 178 ompi/mca/pml/ob1/pml_ob1_component.c pml_proc = pml_comm->procs[i]; procs 1170 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_comm_proc_t **procp = comm->procs; procs 134 ompi/mca/pml/pml.h typedef int (*mca_pml_base_module_add_procs_fn_t)(struct ompi_proc_t **procs, size_t nprocs); procs 148 ompi/mca/pml/pml.h typedef int (*mca_pml_base_module_del_procs_fn_t)(struct ompi_proc_t **procs, size_t nprocs); procs 404 ompi/mca/pml/ucx/pml_ucx.c int mca_pml_ucx_add_procs(struct ompi_proc_t **procs, size_t nprocs) procs 412 ompi/mca/pml/ucx/pml_ucx.c procs, procs 418 ompi/mca/pml/ucx/pml_ucx.c proc = procs[(i + OMPI_PROC_MY_NAME->vpid) % nprocs]; procs 453 ompi/mca/pml/ucx/pml_ucx.c int mca_pml_ucx_del_procs(struct ompi_proc_t **procs, size_t nprocs) procs 466 ompi/mca/pml/ucx/pml_ucx.c proc = procs[i]; procs 70 ompi/mca/pml/ucx/pml_ucx.h int mca_pml_ucx_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 71 ompi/mca/pml/ucx/pml_ucx.h int mca_pml_ucx_del_procs(struct ompi_proc_t **procs, size_t nprocs); procs 222 ompi/mca/pml/yalla/pml_yalla.c int mca_pml_yalla_add_procs(struct ompi_proc_t **procs, size_t nprocs) procs 232 ompi/mca/pml/yalla/pml_yalla.c procs, procs 238 ompi/mca/pml/yalla/pml_yalla.c ret = recv_ep_address(procs[i], &address, &addrlen); procs 243 ompi/mca/pml/yalla/pml_yalla.c if (procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PML]) { procs 245 ompi/mca/pml/yalla/pml_yalla.c OPAL_NAME_PRINT(procs[i]->super.proc_name)); procs 250 ompi/mca/pml/yalla/pml_yalla.c OPAL_NAME_PRINT(procs[i]->super.proc_name)); procs 259 ompi/mca/pml/yalla/pml_yalla.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PML] = conn; procs 265 ompi/mca/pml/yalla/pml_yalla.c int mca_pml_yalla_del_procs(struct ompi_proc_t **procs, size_t nprocs) procs 276 ompi/mca/pml/yalla/pml_yalla.c mxm_ep_disconnect(procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PML]); procs 277 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_VERBOSE(2, "disconnected from rank %s", OPAL_NAME_PRINT(procs[i]->super.proc_name)); procs 278 ompi/mca/pml/yalla/pml_yalla.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PML] = NULL; procs 89 ompi/mca/pml/yalla/pml_yalla.h int mca_pml_yalla_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 90 ompi/mca/pml/yalla/pml_yalla.h int mca_pml_yalla_del_procs(struct ompi_proc_t **procs, size_t nprocs); procs 132 ompi/mca/rte/pmix/rte_pmix.h OMPI_DECLSPEC void ompi_rte_abort_peers(opal_process_name_t *procs, procs 856 ompi/mca/rte/pmix/rte_pmix_module.c void ompi_rte_abort_peers(opal_process_name_t *procs, procs 30 ompi/mca/vprotocol/example/vprotocol_example.h OMPI_DECLSPEC int mca_vprotocol_example_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 31 ompi/mca/vprotocol/example/vprotocol_example.h OMPI_DECLSPEC int mca_vprotocol_example_del_procs(struct ompi_proc_t **procs, size_t nprocs); procs 15 ompi/mca/vprotocol/example/vprotocol_example_proc.c int mca_vprotocol_example_add_procs(struct ompi_proc_t **procs, size_t nprocs) procs 18 ompi/mca/vprotocol/example/vprotocol_example_proc.c return mca_pml_v.host_pml.pml_add_procs(procs, nprocs); procs 21 ompi/mca/vprotocol/example/vprotocol_example_proc.c int mca_vprotocol_example_del_procs(struct ompi_proc_t **procs, size_t nprocs) procs 24 ompi/mca/vprotocol/example/vprotocol_example_proc.c return mca_pml_v.host_pml.pml_del_procs(procs, nprocs); procs 61 ompi/mca/vprotocol/pessimist/vprotocol_pessimist.h int mca_vprotocol_pessimist_add_procs(struct ompi_proc_t **procs, size_t nprocs); procs 62 ompi/mca/vprotocol/pessimist/vprotocol_pessimist.h int mca_vprotocol_pessimist_del_procs(struct ompi_proc_t **procs, size_t nprocs); procs 14 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c int mca_vprotocol_pessimist_add_procs(struct ompi_proc_t **procs, size_t nprocs) procs 19 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c return mca_pml_v.host_pml.pml_add_procs(procs, nprocs); procs 22 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c int mca_vprotocol_pessimist_del_procs(struct ompi_proc_t **procs, size_t nprocs) procs 25 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c return mca_pml_v.host_pml.pml_del_procs(procs, nprocs); procs 59 ompi/mpi/c/dims_create.c int *procs; procs 122 ompi/mpi/c/dims_create.c if (MPI_SUCCESS != (err = assignnodes(freedims, nfactors, factors, &procs))) { procs 129 ompi/mpi/c/dims_create.c p = procs; procs 137 ompi/mpi/c/dims_create.c free((char *) procs); procs 51 ompi/mpi/c/intercomm_merge.c ompi_proc_t **procs=NULL; procs 81 ompi/mpi/c/intercomm_merge.c procs = (ompi_proc_t **) malloc ( total_size * sizeof(ompi_proc_t *)); procs 82 ompi/mpi/c/intercomm_merge.c if ( NULL == procs ) { procs 136 ompi/mpi/c/intercomm_merge.c if ( NULL != procs ) { procs 137 ompi/mpi/c/intercomm_merge.c free ( procs ); procs 426 ompi/proc/proc.c ompi_proc_t **procs; procs 448 ompi/proc/proc.c procs = (ompi_proc_t**) malloc(count * sizeof(ompi_proc_t*)); procs 449 ompi/proc/proc.c if (NULL == procs) { procs 472 ompi/proc/proc.c procs[count++] = proc; procs 478 ompi/proc/proc.c return procs; procs 483 ompi/proc/proc.c ompi_proc_t **procs; procs 495 ompi/proc/proc.c procs = (ompi_proc_t **) malloc (count * sizeof(ompi_proc_t*)); procs 496 ompi/proc/proc.c if (NULL == procs) { procs 519 ompi/proc/proc.c procs[i] = (ompi_proc_t*)ompi_proc_for_name (name); procs 524 ompi/proc/proc.c return procs; procs 530 ompi/proc/proc.c ompi_proc_t **procs = procs 535 ompi/proc/proc.c if (NULL == procs) { procs 548 ompi/proc/proc.c procs[count++] = proc; procs 552 ompi/proc/proc.c return procs; procs 558 ompi/proc/proc.c ompi_proc_t **procs = (ompi_proc_t**) malloc(sizeof(ompi_proc_t*)); procs 559 ompi/proc/proc.c if (NULL == procs) { procs 569 ompi/proc/proc.c *procs = ompi_proc_local_proc; procs 571 ompi/proc/proc.c return procs; procs 76 ompi/runtime/ompi_mpi_abort.c ompi_process_name_t *procs; procs 83 ompi/runtime/ompi_mpi_abort.c procs = (ompi_process_name_t*) calloc(nprocs, sizeof(ompi_process_name_t)); procs 84 ompi/runtime/ompi_mpi_abort.c if (NULL == procs) { procs 98 ompi/runtime/ompi_mpi_abort.c procs[count++] = procs 106 ompi/runtime/ompi_mpi_abort.c procs[count++] = procs 111 ompi/runtime/ompi_mpi_abort.c ompi_rte_abort_peers(procs, nprocs, errcode); procs 117 ompi/runtime/ompi_mpi_abort.c free(procs); procs 108 ompi/runtime/ompi_mpi_finalize.c ompi_proc_t** procs; procs 337 ompi/runtime/ompi_mpi_finalize.c procs = ompi_proc_get_allocated (&nprocs); procs 338 ompi/runtime/ompi_mpi_finalize.c MCA_PML_CALL(del_procs(procs, nprocs)); procs 339 ompi/runtime/ompi_mpi_finalize.c free(procs); procs 378 ompi/runtime/ompi_mpi_init.c ompi_proc_t** procs; procs 845 ompi/runtime/ompi_mpi_init.c if (NULL == (procs = ompi_proc_world (&nprocs))) { procs 852 ompi/runtime/ompi_mpi_init.c if (NULL == (procs = ompi_proc_get_allocated (&nprocs))) { procs 857 ompi/runtime/ompi_mpi_init.c ret = MCA_PML_CALL(add_procs(procs, nprocs)); procs 858 ompi/runtime/ompi_mpi_init.c free(procs); procs 680 opal/mca/btl/btl.h struct opal_proc_t** procs, procs 701 opal/mca/btl/btl.h struct opal_proc_t** procs, procs 106 opal/mca/btl/ofi/btl_ofi_module.c opal_proc_t **procs, mca_btl_base_endpoint_t **peers) procs 114 opal/mca/btl/ofi/btl_ofi_module.c rc = opal_hash_table_get_value_uint64 (&ofi_btl->id_to_endpoint, (intptr_t) procs[i], (void **) &ep); procs 128 opal/mca/btl/ofi/btl_ofi_module.c (void) opal_hash_table_remove_value_uint64 (&ofi_btl->id_to_endpoint, (intptr_t) procs[i]); procs 322 opal/mca/btl/portals4/btl_portals4.c opal_proc_t **procs, procs 339 opal/mca/btl/portals4/btl_portals4.c curr_proc = procs[i]; procs 385 opal/mca/btl/portals4/btl_portals4.c struct opal_proc_t **procs, procs 404 opal/mca/btl/portals4/btl_portals4.c struct opal_proc_t *curr_proc = procs[i]; procs 435 opal/mca/btl/portals4/btl_portals4.c ret = create_maptable(portals4_btl, nprocs, procs, btl_peer_data); procs 461 opal/mca/btl/portals4/btl_portals4.c struct opal_proc_t **procs, procs 191 opal/mca/btl/portals4/btl_portals4.h struct opal_proc_t **procs, procs 197 opal/mca/btl/portals4/btl_portals4.h struct opal_proc_t **procs, procs 50 opal/mca/btl/self/btl_self.c struct opal_proc_t **procs, procs 55 opal/mca/btl/self/btl_self.c if( 0 == opal_compare_proc(procs[i]->proc_name, OPAL_PROC_MY_NAME) ) { procs 76 opal/mca/btl/self/btl_self.c struct opal_proc_t **procs, procs 527 opal/mca/btl/smcuda/btl_smcuda.c struct opal_proc_t **procs, procs 555 opal/mca/btl/smcuda/btl_smcuda.c if (procs[proc]->proc_name.jobid != my_proc->proc_name.jobid || procs 556 opal/mca/btl/smcuda/btl_smcuda.c !OPAL_PROC_ON_LOCAL_NODE(procs[proc]->proc_flags)) { procs 561 opal/mca/btl/smcuda/btl_smcuda.c if(my_proc == procs[proc]) { procs 569 opal/mca/btl/smcuda/btl_smcuda.c if(!(peers[proc] = create_sm_endpoint(n_local_procs, procs[proc]))) { procs 574 opal/mca/btl/smcuda/btl_smcuda.c peers[proc]->proc_opal = procs[proc]; procs 721 opal/mca/btl/smcuda/btl_smcuda.c struct opal_proc_t **procs, procs 384 opal/mca/btl/smcuda/btl_smcuda.h struct opal_proc_t **procs, procs 402 opal/mca/btl/smcuda/btl_smcuda.h struct opal_proc_t **procs, procs 65 opal/mca/btl/tcp/btl_tcp.c struct opal_proc_t **procs, procs 79 opal/mca/btl/tcp/btl_tcp.c struct opal_proc_t* opal_proc = procs[i]; procs 147 opal/mca/btl/tcp/btl_tcp.c struct opal_proc_t **procs, procs 230 opal/mca/btl/tcp/btl_tcp.h struct opal_proc_t **procs, procs 249 opal/mca/btl/tcp/btl_tcp.h struct opal_proc_t **procs, procs 123 opal/mca/btl/template/btl_template.c struct opal_proc_t **procs, procs 149 opal/mca/btl/template/btl_template.h struct opal_proc_t **procs, procs 168 opal/mca/btl/template/btl_template.h struct opal_proc_t **procs, procs 121 opal/mca/btl/uct/btl_uct_module.c opal_proc_t **procs, mca_btl_base_endpoint_t **peers) procs 128 opal/mca/btl/uct/btl_uct_module.c if (NULL == procs[i]) { procs 132 opal/mca/btl/uct/btl_uct_module.c rc = opal_hash_table_get_value_uint64 (&uct_module->id_to_endpoint, (intptr_t) procs[i], (void **) &ep); procs 137 opal/mca/btl/uct/btl_uct_module.c (void) opal_hash_table_remove_value_uint64 (&uct_module->id_to_endpoint, (intptr_t) procs[i]); procs 357 opal/mca/btl/ugni/btl_ugni.h struct opal_proc_t **procs, procs 375 opal/mca/btl/ugni/btl_ugni.h struct opal_proc_t **procs, procs 32 opal/mca/btl/ugni/btl_ugni_add_procs.c struct opal_proc_t **procs, procs 62 opal/mca/btl/ugni/btl_ugni_add_procs.c peers[i] = mca_btl_ugni_get_ep (btl, procs[i]); procs 67 opal/mca/btl/ugni/btl_ugni_add_procs.c if (procs[i] == opal_proc_local_get ()) { procs 169 opal/mca/btl/ugni/btl_ugni_add_procs.c size_t nprocs, struct opal_proc_t **procs, procs 176 opal/mca/btl/ugni/btl_ugni_add_procs.c struct opal_proc_t *opal_proc = procs[i]; procs 193 opal/mca/btl/usnic/btl_usnic_map.c opal_btl_usnic_proc_t **procs; procs 201 opal/mca/btl/usnic/btl_usnic_map.c procs = calloc(num_procs, sizeof(opal_btl_usnic_proc_t*)); procs 202 opal/mca/btl/usnic/btl_usnic_map.c if (NULL == procs) { procs 209 opal/mca/btl/usnic/btl_usnic_map.c procs[i] = pitem; procs 212 opal/mca/btl/usnic/btl_usnic_map.c qsort(procs, num_procs, sizeof(opal_btl_usnic_proc_t*), procs 218 opal/mca/btl/usnic/btl_usnic_map.c fprintf(fp, "peer=%d,", procs[i]->proc_opal->proc_name.vpid); procs 219 opal/mca/btl/usnic/btl_usnic_map.c fprintf(fp, "hostname=%s,", opal_get_proc_hostname(procs[i]->proc_opal)); procs 220 opal/mca/btl/usnic/btl_usnic_map.c if (OPAL_SUCCESS != map_output_endpoints(fp, procs[i])) { procs 226 opal/mca/btl/usnic/btl_usnic_map.c free(procs); procs 99 opal/mca/btl/usnic/btl_usnic_module.c opal_proc_t **procs, procs 114 opal/mca/btl/usnic/btl_usnic_module.c struct opal_proc_t* opal_proc = procs[i]; procs 444 opal/mca/btl/usnic/btl_usnic_module.c struct opal_proc_t **procs, procs 491 opal/mca/btl/usnic/btl_usnic_module.c procs, endpoints); procs 531 opal/mca/btl/usnic/btl_usnic_module.c struct opal_proc_t **procs, procs 540 opal/mca/btl/usnic/btl_usnic_module.c rc = add_procs_create_endpoints(module, nprocs, procs, endpoints); procs 602 opal/mca/btl/usnic/btl_usnic_module.c struct opal_proc_t **procs, procs 614 opal/mca/btl/usnic/btl_usnic_module.c opal_btl_usnic_proc_lookup_ompi(procs[i]); procs 40 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, procs 59 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, procs 252 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, procs 288 opal/mca/btl/vader/btl_vader_module.c if (procs[proc]->proc_name.jobid != my_proc->proc_name.jobid || procs 289 opal/mca/btl/vader/btl_vader_module.c !OPAL_PROC_ON_LOCAL_NODE(procs[proc]->proc_flags)) { procs 294 opal/mca/btl/vader/btl_vader_module.c if (my_proc != procs[proc] && NULL != reachability) { procs 304 opal/mca/btl/vader/btl_vader_module.c rc = init_vader_endpoint (peers[proc], procs[proc], local_rank++); procs 324 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, procs 204 opal/mca/common/sm/common_sm.c mca_common_sm_local_proc_reorder(opal_proc_t **procs, procs 213 opal/mca/common/sm/common_sm.c if (NULL == out_num_local_procs || NULL == procs) { procs 222 opal/mca/common/sm/common_sm.c if (OPAL_PROC_ON_LOCAL_NODE(procs[p]->proc_flags)) { procs 225 opal/mca/common/sm/common_sm.c procs[0] = procs[p]; procs 230 opal/mca/common/sm/common_sm.c procs[num_local_procs] = procs[p]; procs 233 opal/mca/common/sm/common_sm.c if( 0 > opal_compare_proc(procs[p]->proc_name, procs[0]->proc_name) ) { procs 234 opal/mca/common/sm/common_sm.c temp_proc = procs[0]; procs 235 opal/mca/common/sm/common_sm.c procs[0] = procs[p]; procs 236 opal/mca/common/sm/common_sm.c procs[num_local_procs] = temp_proc; procs 85 opal/mca/common/sm/common_sm.h mca_common_sm_local_proc_reorder(opal_proc_t **procs, procs 190 opal/mca/common/ucx/common_ucx.c OPAL_DECLSPEC int opal_common_ucx_del_procs_nofence(opal_common_ucx_del_proc_t *procs, size_t count, procs 198 opal/mca/common/ucx/common_ucx.c MCA_COMMON_UCX_ASSERT(procs || !count); procs 212 opal/mca/common/ucx/common_ucx.c if (procs[n].ep == NULL) { procs 216 opal/mca/common/ucx/common_ucx.c MCA_COMMON_UCX_VERBOSE(2, "disconnecting from rank %zu", procs[n].vpid); procs 217 opal/mca/common/ucx/common_ucx.c dreq = ucp_disconnect_nb(procs[n].ep); procs 220 opal/mca/common/ucx/common_ucx.c MCA_COMMON_UCX_ERROR("ucp_disconnect_nb(%zu) failed: %s", procs[n].vpid, procs 241 opal/mca/common/ucx/common_ucx.c OPAL_DECLSPEC int opal_common_ucx_del_procs(opal_common_ucx_del_proc_t *procs, size_t count, procs 244 opal/mca/common/ucx/common_ucx.c opal_common_ucx_del_procs_nofence(procs, count, my_rank, max_disconnect, worker); procs 112 opal/mca/common/ucx/common_ucx.h OPAL_DECLSPEC int opal_common_ucx_del_procs(opal_common_ucx_del_proc_t *procs, size_t count, procs 114 opal/mca/common/ucx/common_ucx.h OPAL_DECLSPEC int opal_common_ucx_del_procs_nofence(opal_common_ucx_del_proc_t *procs, size_t count, procs 41 opal/mca/pmix/cray/pmix_cray.c opal_list_t *procs); procs 46 opal/mca/pmix/cray/pmix_cray.c static int cray_job_connect(opal_list_t *procs); procs 47 opal/mca/pmix/cray/pmix_cray.c static int cray_job_disconnect(opal_list_t *procs); procs 48 opal/mca/pmix/cray/pmix_cray.c static int cray_job_disconnect_nb(opal_list_t *procs, procs 53 opal/mca/pmix/cray/pmix_cray.c opal_list_t *procs); procs 56 opal/mca/pmix/cray/pmix_cray.c static int cray_fence(opal_list_t *procs, int collect_data); procs 57 opal/mca/pmix/cray/pmix_cray.c static int cray_fencenb(opal_list_t *procs, int collect_data, procs 604 opal/mca/pmix/cray/pmix_cray.c opal_list_t *procs) procs 622 opal/mca/pmix/cray/pmix_cray.c static int cray_job_connect(opal_list_t *procs) procs 627 opal/mca/pmix/cray/pmix_cray.c static int cray_job_disconnect(opal_list_t *procs) procs 632 opal/mca/pmix/cray/pmix_cray.c static int cray_job_disconnect_nb(opal_list_t *procs, procs 641 opal/mca/pmix/cray/pmix_cray.c opal_list_t *procs) procs 925 opal/mca/pmix/cray/pmix_cray.c static int cray_fence(opal_list_t *procs, int collect_data) procs 928 opal/mca/pmix/cray/pmix_cray.c cray_fencenb(procs, collect_data, fence_release, (void*)&result); procs 934 opal/mca/pmix/cray/pmix_cray.c static int cray_fencenb(opal_list_t *procs, int collect_data, procs 529 opal/mca/pmix/ext1x/pmix1x.c p->procs = NULL; procs 547 opal/mca/pmix/ext1x/pmix1x.c if (NULL != p->procs) { procs 548 opal/mca/pmix/ext1x/pmix1x.c PMIX_PROC_FREE(p->procs, p->nprocs); procs 566 opal/mca/pmix/ext1x/pmix1x.c OBJ_CONSTRUCT(&p->procs, opal_list_t); procs 580 opal/mca/pmix/ext1x/pmix1x.c OPAL_LIST_DESTRUCT(&p->procs); procs 58 opal/mca/pmix/ext1x/pmix1x.h pmix_proc_t *procs; procs 78 opal/mca/pmix/ext1x/pmix1x.h opal_list_t procs; procs 98 opal/mca/pmix/ext1x/pmix1x.h opal_list_t *procs); procs 100 opal/mca/pmix/ext1x/pmix1x.h OPAL_MODULE_DECLSPEC int pmix1_fence(opal_list_t *procs, int collect_data); procs 101 opal/mca/pmix/ext1x/pmix1x.h OPAL_MODULE_DECLSPEC int pmix1_fencenb(opal_list_t *procs, int collect_data, procs 122 opal/mca/pmix/ext1x/pmix1x.h OPAL_MODULE_DECLSPEC int pmix1_connect(opal_list_t *procs); procs 123 opal/mca/pmix/ext1x/pmix1x.h OPAL_MODULE_DECLSPEC int pmix1_connectnb(opal_list_t *procs, procs 126 opal/mca/pmix/ext1x/pmix1x.h OPAL_MODULE_DECLSPEC int pmix1_disconnect(opal_list_t *procs); procs 127 opal/mca/pmix/ext1x/pmix1x.h OPAL_MODULE_DECLSPEC int pmix1_disconnectnb(opal_list_t *procs, procs 131 opal/mca/pmix/ext1x/pmix1x.h opal_list_t *procs); procs 55 opal/mca/pmix/ext1x/pmix1x_client.c pmix_proc_t procs[], size_t nprocs, procs 72 opal/mca/pmix/ext1x/pmix1x_client.c nm->name.jobid = strtoul(procs[n].nspace, NULL, 10); procs 73 opal/mca/pmix/ext1x/pmix1x_client.c nm->name.vpid = procs[n].rank; procs 174 opal/mca/pmix/ext1x/pmix1x_client.c opal_list_t *procs) procs 187 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 190 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 282 opal/mca/pmix/ext1x/pmix1x_client.c int pmix1_fence(opal_list_t *procs, int collect_data) procs 296 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 299 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 342 opal/mca/pmix/ext1x/pmix1x_client.c int pmix1_fencenb(opal_list_t *procs, int collect_data, procs 358 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 361 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 396 opal/mca/pmix/ext1x/pmix1x_client.c op->procs = parray; procs 1075 opal/mca/pmix/ext1x/pmix1x_client.c int pmix1_connect(opal_list_t *procs) procs 1084 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL == procs || 0 == (cnt = opal_list_get_size(procs))) { procs 1092 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1121 opal/mca/pmix/ext1x/pmix1x_client.c int pmix1_connectnb(opal_list_t *procs, procs 1132 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL == procs || 0 == (cnt = opal_list_get_size(procs))) { procs 1144 opal/mca/pmix/ext1x/pmix1x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1146 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1151 opal/mca/pmix/ext1x/pmix1x_client.c (void)opal_string_copy(op->procs[n].nspace, job->nspace, PMIX_MAX_NSLEN); procs 1156 opal/mca/pmix/ext1x/pmix1x_client.c op->procs[n].rank = PMIX_RANK_WILDCARD; procs 1158 opal/mca/pmix/ext1x/pmix1x_client.c op->procs[n].rank = ptr->name.vpid; procs 1163 opal/mca/pmix/ext1x/pmix1x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1168 opal/mca/pmix/ext1x/pmix1x_client.c int pmix1_disconnect(opal_list_t *procs) procs 1177 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL == procs || 0 == (cnt = opal_list_get_size(procs))) { procs 1185 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1208 opal/mca/pmix/ext1x/pmix1x_client.c int pmix1_disconnectnb(opal_list_t *procs, procs 1219 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL == procs || 0 == (cnt = opal_list_get_size(procs))) { procs 1231 opal/mca/pmix/ext1x/pmix1x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1233 opal/mca/pmix/ext1x/pmix1x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1238 opal/mca/pmix/ext1x/pmix1x_client.c (void)opal_string_copy(op->procs[n].nspace, job->nspace, PMIX_MAX_NSLEN); procs 1243 opal/mca/pmix/ext1x/pmix1x_client.c op->procs[n].rank = PMIX_RANK_WILDCARD; procs 1245 opal/mca/pmix/ext1x/pmix1x_client.c op->procs[n].rank = ptr->name.vpid; procs 1250 opal/mca/pmix/ext1x/pmix1x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1257 opal/mca/pmix/ext1x/pmix1x_client.c opal_list_t *procs) procs 1289 opal/mca/pmix/ext1x/pmix1x_client.c opal_list_append(procs, &nm->super); procs 54 opal/mca/pmix/ext1x/pmix1x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 56 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 76 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 79 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 172 opal/mca/pmix/ext1x/pmix1x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 199 opal/mca/pmix/ext1x/pmix1x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 200 opal/mca/pmix/ext1x/pmix1x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 204 opal/mca/pmix/ext1x/pmix1x_server_north.c if (PMIX_RANK_WILDCARD == procs[n].rank) { procs 207 opal/mca/pmix/ext1x/pmix1x_server_north.c nm->name.vpid = procs[n].rank; procs 213 opal/mca/pmix/ext1x/pmix1x_server_north.c &opalcaddy->procs, opal_opcbfunc, opalcaddy); procs 247 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 270 opal/mca/pmix/ext1x/pmix1x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 271 opal/mca/pmix/ext1x/pmix1x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 275 opal/mca/pmix/ext1x/pmix1x_server_north.c if (PMIX_RANK_WILDCARD == procs[n].rank) { procs 278 opal/mca/pmix/ext1x/pmix1x_server_north.c nm->name.vpid = procs[n].rank; procs 294 opal/mca/pmix/ext1x/pmix1x_server_north.c rc = host_module->fence_nb(&opalcaddy->procs, &opalcaddy->info, procs 625 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 647 opal/mca/pmix/ext1x/pmix1x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 648 opal/mca/pmix/ext1x/pmix1x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 652 opal/mca/pmix/ext1x/pmix1x_server_north.c if (PMIX_RANK_WILDCARD == procs[n].rank) { procs 655 opal/mca/pmix/ext1x/pmix1x_server_north.c nm->name.vpid = procs[n].rank; procs 671 opal/mca/pmix/ext1x/pmix1x_server_north.c rc = host_module->connect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 680 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 702 opal/mca/pmix/ext1x/pmix1x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 703 opal/mca/pmix/ext1x/pmix1x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 707 opal/mca/pmix/ext1x/pmix1x_server_north.c if (PMIX_RANK_WILDCARD == procs[n].rank) { procs 710 opal/mca/pmix/ext1x/pmix1x_server_north.c nm->name.vpid = procs[n].rank; procs 726 opal/mca/pmix/ext1x/pmix1x_server_north.c rc = host_module->disconnect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 70 opal/mca/pmix/ext1x/pmix1x_server_south.c pmix_proc_t procs[], size_t nprocs, procs 87 opal/mca/pmix/ext1x/pmix1x_server_south.c nm->name.jobid = strtoul(procs[n].nspace, NULL, 10); procs 88 opal/mca/pmix/ext1x/pmix1x_server_south.c nm->name.vpid = procs[n].rank; procs 1430 opal/mca/pmix/ext2x/ext2x.c p->procs = NULL; procs 1462 opal/mca/pmix/ext2x/ext2x.c if (NULL != p->procs) { procs 1463 opal/mca/pmix/ext2x/ext2x.c PMIX_PROC_FREE(p->procs, p->nprocs); procs 1490 opal/mca/pmix/ext2x/ext2x.c OBJ_CONSTRUCT(&p->procs, opal_list_t); procs 1506 opal/mca/pmix/ext2x/ext2x.c OPAL_LIST_DESTRUCT(&p->procs); procs 94 opal/mca/pmix/ext2x/ext2x.h pmix_proc_t *procs; procs 124 opal/mca/pmix/ext2x/ext2x.h opal_list_t procs; procs 225 opal/mca/pmix/ext2x/ext2x.h opal_list_t *procs); procs 227 opal/mca/pmix/ext2x/ext2x.h OPAL_MODULE_DECLSPEC int ext2x_fence(opal_list_t *procs, int collect_data); procs 228 opal/mca/pmix/ext2x/ext2x.h OPAL_MODULE_DECLSPEC int ext2x_fencenb(opal_list_t *procs, int collect_data, procs 249 opal/mca/pmix/ext2x/ext2x.h OPAL_MODULE_DECLSPEC int ext2x_connect(opal_list_t *procs); procs 250 opal/mca/pmix/ext2x/ext2x.h OPAL_MODULE_DECLSPEC int ext2x_connectnb(opal_list_t *procs, procs 253 opal/mca/pmix/ext2x/ext2x.h OPAL_MODULE_DECLSPEC int ext2x_disconnect(opal_list_t *procs); procs 254 opal/mca/pmix/ext2x/ext2x.h OPAL_MODULE_DECLSPEC int ext2x_disconnectnb(opal_list_t *procs, procs 258 opal/mca/pmix/ext2x/ext2x.h opal_list_t *procs); procs 337 opal/mca/pmix/ext2x/ext2x_client.c opal_list_t *procs) procs 357 opal/mca/pmix/ext2x/ext2x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 360 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 449 opal/mca/pmix/ext2x/ext2x_client.c int ext2x_fence(opal_list_t *procs, int collect_data) procs 469 opal/mca/pmix/ext2x/ext2x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 472 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 508 opal/mca/pmix/ext2x/ext2x_client.c int ext2x_fencenb(opal_list_t *procs, int collect_data, procs 529 opal/mca/pmix/ext2x/ext2x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 532 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 549 opal/mca/pmix/ext2x/ext2x_client.c op->procs = parray; procs 559 opal/mca/pmix/ext2x/ext2x_client.c rc = PMIx_Fence_nb(op->procs, op->nprocs, op->info, op->ninfo, opcbfunc, op); procs 1308 opal/mca/pmix/ext2x/ext2x_client.c int ext2x_connect(opal_list_t *procs) procs 1321 opal/mca/pmix/ext2x/ext2x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { procs 1335 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1353 opal/mca/pmix/ext2x/ext2x_client.c int ext2x_connectnb(opal_list_t *procs, procs 1367 opal/mca/pmix/ext2x/ext2x_client.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 1381 opal/mca/pmix/ext2x/ext2x_client.c op->nprocs = opal_list_get_size(procs); procs 1385 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1387 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1393 opal/mca/pmix/ext2x/ext2x_client.c (void)opal_string_copy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1394 opal/mca/pmix/ext2x/ext2x_client.c op->procs[n].rank = ext2x_convert_opalrank(ptr->name.vpid); procs 1399 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1406 opal/mca/pmix/ext2x/ext2x_client.c int ext2x_disconnect(opal_list_t *procs) procs 1419 opal/mca/pmix/ext2x/ext2x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { procs 1433 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1451 opal/mca/pmix/ext2x/ext2x_client.c int ext2x_disconnectnb(opal_list_t *procs, procs 1465 opal/mca/pmix/ext2x/ext2x_client.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 1479 opal/mca/pmix/ext2x/ext2x_client.c op->nprocs = opal_list_get_size(procs); procs 1483 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1485 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1491 opal/mca/pmix/ext2x/ext2x_client.c (void)opal_string_copy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1492 opal/mca/pmix/ext2x/ext2x_client.c op->procs[n].rank = ext2x_convert_opalrank(ptr->name.vpid); procs 1497 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1506 opal/mca/pmix/ext2x/ext2x_client.c opal_list_t *procs) procs 1537 opal/mca/pmix/ext2x/ext2x_client.c opal_list_append(procs, &nm->super); procs 1643 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1651 opal/mca/pmix/ext2x/ext2x_client.c (void)opal_string_copy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1652 opal/mca/pmix/ext2x/ext2x_client.c op->procs[n].rank = ext2x_convert_opalrank(ptr->name.vpid); procs 1668 opal/mca/pmix/ext2x/ext2x_client.c rc = PMIx_Job_control_nb(op->procs,op->nprocs, op->info, op->ninfo, infocbfunc, op); procs 56 opal/mca/pmix/ext2x/ext2x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 58 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 78 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 81 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 217 opal/mca/pmix/ext2x/ext2x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 249 opal/mca/pmix/ext2x/ext2x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 250 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 254 opal/mca/pmix/ext2x/ext2x_server_north.c nm->name.vpid = ext2x_convert_rank(procs[n].rank); procs 259 opal/mca/pmix/ext2x/ext2x_server_north.c &opalcaddy->procs, opal_opcbfunc, opalcaddy); procs 303 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 328 opal/mca/pmix/ext2x/ext2x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 329 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 333 opal/mca/pmix/ext2x/ext2x_server_north.c nm->name.vpid = ext2x_convert_rank(procs[n].rank); procs 348 opal/mca/pmix/ext2x/ext2x_server_north.c rc = host_module->fence_nb(&opalcaddy->procs, &opalcaddy->info, procs 700 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 722 opal/mca/pmix/ext2x/ext2x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 723 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 727 opal/mca/pmix/ext2x/ext2x_server_north.c nm->name.vpid = ext2x_convert_rank(procs[n].rank); procs 742 opal/mca/pmix/ext2x/ext2x_server_north.c rc = host_module->connect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 751 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 773 opal/mca/pmix/ext2x/ext2x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 774 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 778 opal/mca/pmix/ext2x/ext2x_server_north.c nm->name.vpid = ext2x_convert_rank(procs[n].rank); procs 793 opal/mca/pmix/ext2x/ext2x_server_north.c rc = host_module->disconnect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 1235 opal/mca/pmix/ext2x/ext2x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 1256 opal/mca/pmix/ext2x/ext2x_server_north.c &opalcaddy->procs, procs 1749 opal/mca/pmix/ext3x/ext3x.c p->procs = NULL; procs 1781 opal/mca/pmix/ext3x/ext3x.c if (NULL != p->procs) { procs 1782 opal/mca/pmix/ext3x/ext3x.c PMIX_PROC_FREE(p->procs, p->nprocs); procs 1809 opal/mca/pmix/ext3x/ext3x.c OBJ_CONSTRUCT(&p->procs, opal_list_t); procs 1825 opal/mca/pmix/ext3x/ext3x.c OPAL_LIST_DESTRUCT(&p->procs); procs 88 opal/mca/pmix/ext3x/ext3x.h pmix_proc_t *procs; procs 119 opal/mca/pmix/ext3x/ext3x.h opal_list_t procs; procs 220 opal/mca/pmix/ext3x/ext3x.h opal_list_t *procs); procs 222 opal/mca/pmix/ext3x/ext3x.h OPAL_MODULE_DECLSPEC int ext3x_fence(opal_list_t *procs, int collect_data); procs 223 opal/mca/pmix/ext3x/ext3x.h OPAL_MODULE_DECLSPEC int ext3x_fencenb(opal_list_t *procs, int collect_data, procs 244 opal/mca/pmix/ext3x/ext3x.h OPAL_MODULE_DECLSPEC int ext3x_connect(opal_list_t *procs); procs 245 opal/mca/pmix/ext3x/ext3x.h OPAL_MODULE_DECLSPEC int ext3x_connectnb(opal_list_t *procs, procs 248 opal/mca/pmix/ext3x/ext3x.h OPAL_MODULE_DECLSPEC int ext3x_disconnect(opal_list_t *procs); procs 249 opal/mca/pmix/ext3x/ext3x.h OPAL_MODULE_DECLSPEC int ext3x_disconnectnb(opal_list_t *procs, procs 253 opal/mca/pmix/ext3x/ext3x.h opal_list_t *procs); procs 337 opal/mca/pmix/ext3x/ext3x_client.c opal_list_t *procs) procs 357 opal/mca/pmix/ext3x/ext3x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 360 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 450 opal/mca/pmix/ext3x/ext3x_client.c int ext3x_fence(opal_list_t *procs, int collect_data) procs 470 opal/mca/pmix/ext3x/ext3x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 473 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 509 opal/mca/pmix/ext3x/ext3x_client.c int ext3x_fencenb(opal_list_t *procs, int collect_data, procs 530 opal/mca/pmix/ext3x/ext3x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 533 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 550 opal/mca/pmix/ext3x/ext3x_client.c op->procs = parray; procs 560 opal/mca/pmix/ext3x/ext3x_client.c rc = PMIx_Fence_nb(op->procs, op->nprocs, op->info, op->ninfo, opcbfunc, op); procs 1309 opal/mca/pmix/ext3x/ext3x_client.c int ext3x_connect(opal_list_t *procs) procs 1322 opal/mca/pmix/ext3x/ext3x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { procs 1336 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1354 opal/mca/pmix/ext3x/ext3x_client.c int ext3x_connectnb(opal_list_t *procs, procs 1368 opal/mca/pmix/ext3x/ext3x_client.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 1382 opal/mca/pmix/ext3x/ext3x_client.c op->nprocs = opal_list_get_size(procs); procs 1386 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1388 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1394 opal/mca/pmix/ext3x/ext3x_client.c (void)opal_string_copy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1395 opal/mca/pmix/ext3x/ext3x_client.c op->procs[n].rank = ext3x_convert_opalrank(ptr->name.vpid); procs 1400 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1407 opal/mca/pmix/ext3x/ext3x_client.c int ext3x_disconnect(opal_list_t *procs) procs 1419 opal/mca/pmix/ext3x/ext3x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { procs 1433 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1451 opal/mca/pmix/ext3x/ext3x_client.c int ext3x_disconnectnb(opal_list_t *procs, procs 1465 opal/mca/pmix/ext3x/ext3x_client.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 1479 opal/mca/pmix/ext3x/ext3x_client.c op->nprocs = opal_list_get_size(procs); procs 1483 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1485 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1491 opal/mca/pmix/ext3x/ext3x_client.c (void)opal_string_copy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1492 opal/mca/pmix/ext3x/ext3x_client.c op->procs[n].rank = ext3x_convert_opalrank(ptr->name.vpid); procs 1497 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1506 opal/mca/pmix/ext3x/ext3x_client.c opal_list_t *procs) procs 1537 opal/mca/pmix/ext3x/ext3x_client.c opal_list_append(procs, &nm->super); procs 1643 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1651 opal/mca/pmix/ext3x/ext3x_client.c (void)opal_string_copy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1652 opal/mca/pmix/ext3x/ext3x_client.c op->procs[n].rank = ext3x_convert_opalrank(ptr->name.vpid); procs 1668 opal/mca/pmix/ext3x/ext3x_client.c rc = PMIx_Job_control_nb(op->procs,op->nprocs, op->info, op->ninfo, infocbfunc, op); procs 56 opal/mca/pmix/ext3x/ext3x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 58 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 78 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 81 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 115 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, procs 228 opal/mca/pmix/ext3x/ext3x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 260 opal/mca/pmix/ext3x/ext3x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 261 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 265 opal/mca/pmix/ext3x/ext3x_server_north.c nm->name.vpid = ext3x_convert_rank(procs[n].rank); procs 270 opal/mca/pmix/ext3x/ext3x_server_north.c &opalcaddy->procs, opal_opcbfunc, opalcaddy); procs 318 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 343 opal/mca/pmix/ext3x/ext3x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 344 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 348 opal/mca/pmix/ext3x/ext3x_server_north.c nm->name.vpid = ext3x_convert_rank(procs[n].rank); procs 363 opal/mca/pmix/ext3x/ext3x_server_north.c rc = host_module->fence_nb(&opalcaddy->procs, &opalcaddy->info, procs 715 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 737 opal/mca/pmix/ext3x/ext3x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 738 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 742 opal/mca/pmix/ext3x/ext3x_server_north.c nm->name.vpid = ext3x_convert_rank(procs[n].rank); procs 757 opal/mca/pmix/ext3x/ext3x_server_north.c rc = host_module->connect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 766 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 788 opal/mca/pmix/ext3x/ext3x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 789 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 793 opal/mca/pmix/ext3x/ext3x_server_north.c nm->name.vpid = ext3x_convert_rank(procs[n].rank); procs 808 opal/mca/pmix/ext3x/ext3x_server_north.c rc = host_module->disconnect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 1287 opal/mca/pmix/ext3x/ext3x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 1308 opal/mca/pmix/ext3x/ext3x_server_north.c &opalcaddy->procs, procs 1318 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, procs 42 opal/mca/pmix/flux/pmix_flux.c opal_list_t *procs); procs 44 opal/mca/pmix/flux/pmix_flux.c static int flux_fence(opal_list_t *procs, int collect_data); procs 54 opal/mca/pmix/flux/pmix_flux.c static int flux_job_connect(opal_list_t *procs); procs 55 opal/mca/pmix/flux/pmix_flux.c static int flux_job_disconnect(opal_list_t *procs); procs 605 opal/mca/pmix/flux/pmix_flux.c opal_list_t *procs) procs 678 opal/mca/pmix/flux/pmix_flux.c static int flux_fence(opal_list_t *procs, int collect_data) procs 734 opal/mca/pmix/flux/pmix_flux.c static int flux_job_connect(opal_list_t *procs) procs 739 opal/mca/pmix/flux/pmix_flux.c static int flux_job_disconnect(opal_list_t *procs) procs 45 opal/mca/pmix/isolated/pmix_isolated.c opal_list_t *procs); procs 50 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_job_connect(opal_list_t *procs); procs 51 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_job_disconnect(opal_list_t *procs); procs 52 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_job_disconnect_nb(opal_list_t *procs, procs 57 opal/mca/pmix/isolated/pmix_isolated.c opal_list_t *procs); procs 60 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_fence(opal_list_t *procs, int collect_data); procs 61 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_fence_nb(opal_list_t *procs, int collect_data, procs 299 opal/mca/pmix/isolated/pmix_isolated.c opal_list_t *procs) procs 316 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_job_connect(opal_list_t *procs) procs 321 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_job_disconnect(opal_list_t *procs) procs 326 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_job_disconnect_nb(opal_list_t *procs, procs 335 opal/mca/pmix/isolated/pmix_isolated.c opal_list_t *procs) procs 375 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_fence(opal_list_t *procs, int collect_data) procs 383 opal/mca/pmix/isolated/pmix_isolated.c static int isolated_fence_nb(opal_list_t *procs, int collect_data, procs 360 opal/mca/pmix/pmix.h opal_list_t *procs); procs 384 opal/mca/pmix/pmix.h typedef int (*opal_pmix_base_module_fence_fn_t)(opal_list_t *procs, int collect_data); procs 389 opal/mca/pmix/pmix.h typedef int (*opal_pmix_base_module_fence_nb_fn_t)(opal_list_t *procs, int collect_data, procs 533 opal/mca/pmix/pmix.h typedef int (*opal_pmix_base_module_connect_fn_t)(opal_list_t *procs); procs 535 opal/mca/pmix/pmix.h typedef int (*opal_pmix_base_module_connect_nb_fn_t)(opal_list_t *procs, procs 545 opal/mca/pmix/pmix.h typedef int (*opal_pmix_base_module_disconnect_fn_t)(opal_list_t *procs); procs 547 opal/mca/pmix/pmix.h typedef int (*opal_pmix_base_module_disconnect_nb_fn_t)(opal_list_t *procs, procs 558 opal/mca/pmix/pmix.h opal_list_t *procs); procs 171 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c pmix_proc_t proc, *procs; procs 242 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_CREATE(procs, nprocs); procs 243 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_LOAD(&procs[0], myproc.nspace, 0); procs 244 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_LOAD(&procs[1], myproc.nspace, 2); procs 245 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_LOAD(&procs[2], myproc.nspace, 3); procs 246 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c rc = PMIx_Group_invite("ourgroup", procs, nprocs, NULL, 0, &results, &nresults); procs 251 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_FREE(procs, nprocs); procs 114 opal/mca/pmix/pmix4x/pmix/examples/group.c pmix_proc_t proc, *procs; procs 170 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_CREATE(procs, nprocs); procs 171 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_LOAD(&procs[0], myproc.nspace, 0); procs 172 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_LOAD(&procs[1], myproc.nspace, 2); procs 173 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_LOAD(&procs[2], myproc.nspace, 3); procs 175 opal/mca/pmix/pmix4x/pmix/examples/group.c rc = PMIx_Group_construct("ourgroup", procs, nprocs, &info, 1, &results, &nresults); procs 189 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_FREE(procs, nprocs); procs 57 opal/mca/pmix/pmix4x/pmix/examples/server.c pmix_proc_t procs[], size_t nprocs, procs 59 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 79 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 82 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 542 opal/mca/pmix/pmix4x/pmix/examples/server.c pmix_proc_t procs[], size_t nprocs, procs 548 opal/mca/pmix/pmix4x/pmix/examples/server.c if (NULL != procs) { procs 549 opal/mca/pmix/pmix4x/pmix/examples/server.c pmix_output(0, "SERVER: ABORT on %s:%d", procs[0].nspace, procs[0].rank); procs 584 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 747 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 764 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 125 opal/mca/pmix/pmix4x/pmix/include/pmix.h pmix_proc_t procs[], size_t nprocs); procs 177 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Fence(const pmix_proc_t procs[], size_t nprocs, procs 182 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Fence_nb(const pmix_proc_t procs[], size_t nprocs, procs 370 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Connect(const pmix_proc_t procs[], size_t nprocs, procs 373 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Connect_nb(const pmix_proc_t procs[], size_t nprocs, procs 383 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Disconnect(const pmix_proc_t procs[], size_t nprocs, procs 399 opal/mca/pmix/pmix4x/pmix/include/pmix.h pmix_proc_t **procs, size_t *nprocs); procs 669 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_IOF_pull(const pmix_proc_t procs[], size_t nprocs, procs 795 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, procs 800 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, procs 849 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, procs 854 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, procs 102 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h pmix_proc_t procs[], size_t nprocs, procs 122 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h typedef pmix_status_t (*pmix_server_fencenb_fn_t)(const pmix_proc_t procs[], size_t nprocs, procs 215 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h typedef pmix_status_t (*pmix_server_connect_fn_t)(const pmix_proc_t procs[], size_t nprocs, procs 232 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h typedef pmix_status_t (*pmix_server_disconnect_fn_t)(const pmix_proc_t procs[], size_t nprocs, procs 454 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h typedef pmix_status_t (*pmix_server_iof_fn_t)(const pmix_proc_t procs[], size_t nprocs, procs 517 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h const pmix_proc_t procs[], size_t nprocs, procs 877 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_proc_t procs[], size_t nprocs) procs 937 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c bfr, procs, nprocs, PMIX_PROC); procs 1233 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c &cb->procs, &cb->nprocs); procs 1242 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_proc_t **procs, size_t *nprocs) procs 1282 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c *procs = cb->procs; procs 66 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_EXPORT pmix_status_t PMIx_Connect(const pmix_proc_t procs[], size_t nprocs, procs 95 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (PMIX_SUCCESS != (rc = PMIx_Connect_nb(procs, nprocs, info, ninfo, op_cbfunc, cb))) { procs 111 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_EXPORT pmix_status_t PMIx_Connect_nb(const pmix_proc_t procs[], size_t nprocs, procs 138 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (NULL == procs || 0 >= nprocs) { procs 159 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, procs, nprocs, PMIX_PROC); procs 201 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_EXPORT pmix_status_t PMIx_Disconnect(const pmix_proc_t procs[], size_t nprocs, procs 225 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (PMIX_SUCCESS != (rc = PMIx_Disconnect_nb(procs, nprocs, info, ninfo, op_cbfunc, cb))) { procs 241 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_EXPORT pmix_status_t PMIx_Disconnect_nb(const pmix_proc_t procs[], size_t nprocs, procs 257 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (0 != strcmp(pmix_globals.myid.nspace, procs[cnt].nspace)) { procs 258 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_GDS_DEL_NSPACE(rc, procs[cnt].nspace); procs 275 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (NULL == procs || 0 >= nprocs) { procs 296 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, procs, nprocs, PMIX_PROC); procs 60 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c const pmix_proc_t *procs, size_t nprocs, procs 67 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_EXPORT pmix_status_t PMIx_Fence(const pmix_proc_t procs[], size_t nprocs, procs 96 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (PMIX_SUCCESS != (rc = PMIx_Fence_nb(procs, nprocs, info, ninfo, procs 114 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_EXPORT pmix_status_t PMIx_Fence_nb(const pmix_proc_t procs[], size_t nprocs, procs 143 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (NULL == procs && 0 != nprocs) { procs 148 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (NULL == procs) { procs 154 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c rgs = (pmix_proc_t*)procs; procs 204 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c const pmix_proc_t *procs, size_t nprocs, procs 226 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c msg, procs, nprocs, PMIX_PROC); procs 122 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, procs 152 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_construct_nb(grp, procs, nprocs, info, ninfo, info_cbfunc, cb))) { procs 172 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, procs 202 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == procs || 0 >= nprocs) { procs 252 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, procs, nprocs, PMIX_PROC); procs 574 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, procs 596 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == grp || NULL == procs) { procs 602 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = PMIx_Group_invite_nb(grp, procs, nprocs, info, ninfo, info_cbfunc, (void*)&cb); procs 634 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c memcpy(cb.info[n].value.data.darray->array, procs, nprocs * sizeof(pmix_proc_t)); procs 661 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, procs 690 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == grp || NULL == procs) { procs 704 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_RANK_WILDCARD == procs[n].rank) { procs 766 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c memcpy(cb->info[n].value.data.darray->array, procs, nprocs * sizeof(pmix_proc_t)); procs 74 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_EXPORT pmix_status_t PMIx_IOF_pull(const pmix_proc_t procs[], size_t nprocs, procs 153 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c msg, procs, nprocs, PMIX_PROC); procs 52 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_proc_t *procs; procs 979 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rngtrk.procs = NULL; procs 1012 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rngtrk.procs = &cd->source; procs 1015 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rngtrk.procs = cd->targets; procs 1197 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (PMIX_CHECK_NSPACE(rng->procs[n].nspace, proc->nspace)) { procs 1205 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (PMIX_CHECK_PROCID(&rng->procs[n], proc)) { procs 1214 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (0 != strncmp(rng->procs[n].nspace, proc->nspace, PMIX_MAX_NSLEN)) { procs 1217 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (PMIX_RANK_WILDCARD == rng->procs[n].rank || procs 1218 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rng->procs[n].rank == proc->rank) { procs 1347 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c p->rng.procs = NULL; procs 1364 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != p->rng.procs) { procs 1365 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c free(p->rng.procs); procs 583 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_PROC_CREATE(evhdlr->rng.procs, nprocs); procs 584 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == evhdlr->rng.procs) { procs 590 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c memcpy(evhdlr->rng.procs, parray, nprocs * sizeof(pmix_proc_t)); procs 668 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_PROC_CREATE(evhdlr->rng.procs, nprocs); procs 669 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == evhdlr->rng.procs) { procs 675 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c memcpy(evhdlr->rng.procs, parray, nprocs * sizeof(pmix_proc_t)); procs 303 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c p->procs = NULL; procs 401 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_proc_t *procs; procs 215 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c char **procs; procs 329 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c procs = pmix_argv_split(ppn[n], ','); procs 330 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c for (m=0; NULL != procs[m]; m++) { procs 337 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c rank = strtol(procs[m], NULL, 10); procs 341 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_argv_free(procs); procs 346 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_argv_free(procs); procs 375 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c char **nodes=NULL, **procs=NULL; procs 437 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL != procs) { procs 438 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = store_map(ht, nodes, procs))) { procs 445 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_preg.parse_procs(info[n].value.data.string, &procs))) { procs 452 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = store_map(ht, nodes, procs))) { procs 585 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL != procs) { procs 586 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_argv_free(procs); procs 782 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c char **procs = NULL; procs 988 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c procs = pmix_argv_split(kv.value->data.string, ','); procs 989 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c for (j=0; NULL != procs[j]; j++) { procs 998 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c rank = strtol(procs[j], NULL, 10); procs 1004 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_argv_free(procs); procs 1009 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_argv_free(procs); procs 600 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/base/pnet_base_fns.c char **nodes, **procs, **ranks; procs 618 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/base/pnet_base_fns.c if (PMIX_SUCCESS != (rc = pmix_preg.parse_procs(pregex, &procs))) { procs 687 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/base/pnet_base_fns.c ranks = pmix_argv_split(procs[n], ','); procs 698 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/base/pnet_base_fns.c pmix_argv_free(procs); procs 300 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c pmix_proc_t *procs; procs 333 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c pmix_preg.resolve_peers(nodes[n], nptr->nspace, &procs, &nprocs); procs 334 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c if (NULL == procs) { procs 338 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c pmix_output(0, "pnet:test setup_local_network NODE %s: peer %s:%d", nodes[n], procs[m].nspace, procs[m].rank); procs 341 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c free(procs); procs 87 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/base.h char ***procs); procs 90 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/base.h pmix_proc_t **procs, size_t *nprocs); procs 82 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/preg_base_stubs.c char ***procs) procs 88 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/preg_base_stubs.c if (PMIX_SUCCESS == active->module->parse_procs(regexp, procs)) { procs 99 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/preg_base_stubs.c pmix_proc_t **procs, size_t *nprocs) procs 105 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/preg_base_stubs.c if (PMIX_SUCCESS == active->module->resolve_peers(nodename, nspace, procs, nprocs)) { procs 51 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c char ***procs); procs 54 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_proc_t **procs, size_t *nprocs); procs 75 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c static pmix_status_t pmix_regex_extract_ppn(char *regexp, char ***procs); procs 479 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c char ***procs) procs 485 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c *procs = NULL; procs 509 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (PMIX_SUCCESS != (rc = pmix_regex_extract_ppn(ptr, procs))) { procs 522 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_proc_t **procs, size_t *nprocs) procs 602 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c *procs = p; procs 977 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c static pmix_status_t pmix_regex_extract_ppn(char *regexp, char ***procs) procs 1013 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_argv_append_nosize(procs, t); procs 79 opal/mca/pmix/pmix4x/pmix/src/mca/preg/preg.h char ***procs); procs 83 opal/mca/pmix/pmix4x/pmix/src/mca/preg/preg.h pmix_proc_t **procs, size_t *nprocs); procs 1707 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_NAME_PRINT(cd->procs), cd->channels); procs 1717 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (!PMIX_CHECK_PROCID(cd->procs, &req->pname)) { procs 1726 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (PMIX_CHECK_PROCID(cd->procs, &req->peer->info->pname)) { procs 1737 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_BFROPS_PACK(rc, req->peer, msg, cd->procs, 1, PMIX_PROC); procs 1777 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c memcpy(&iof->source, cd->procs, sizeof(pmix_proc_t)); procs 1809 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_PROC_CREATE(cd->procs, 1); procs 1810 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (NULL == cd->procs) { procs 1815 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_strncpy(cd->procs[0].nspace, source->nspace, PMIX_MAX_NSLEN); procs 1816 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cd->procs[0].rank = source->rank; procs 3202 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (NULL != cd->procs) { procs 3203 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_PROC_FREE(cd->procs, cd->nprocs); procs 92 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_proc_t *procs = NULL; procs 119 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); procs 120 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs) { procs 127 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, procs, &cnt, PMIX_PROC); procs 141 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs, nprocs, cbfunc, cbdata); procs 145 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 311 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static pmix_server_trkr_t* get_tracker(char *id, pmix_proc_t *procs, procs 322 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs && NULL == id) { procs 354 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 == strcmp(procs[i].nspace, trk->pcs[j].nspace) && procs 355 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs[i].rank == trk->pcs[j].rank) { procs 386 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static pmix_server_trkr_t* new_tracker(char *id, pmix_proc_t *procs, procs 400 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs) { procs 420 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != procs) { procs 428 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memcpy(trk->pcs, procs, nprocs * sizeof(pmix_proc_t)); procs 436 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_strncpy(trk->pcs[i].nspace, procs[i].nspace, PMIX_MAX_NSLEN); procs 437 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->pcs[i].rank = procs[i].rank; procs 445 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 == strcmp(procs[i].nspace, ns->nspace)) { procs 454 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs[i].nspace); procs 477 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs[i].nspace); procs 484 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (procs[i].rank == info->pname.rank || procs 485 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RANK_WILDCARD == procs[i].rank) { procs 491 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_RANK_WILDCARD != procs[i].rank) { procs 786 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_proc_t *procs=NULL, *newprocs; procs 823 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); procs 824 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs) { procs 829 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, cd->peer, buf, procs, &cnt, PMIX_PROC); procs 842 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_CHECK_NSPACE(procs[n].nspace, grp->grpid)) { procs 847 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c gcd->rank = procs[n].rank; procs 850 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_RANK_WILDCARD == procs[n].rank) { procs 865 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memcpy(&newprocs[n], &procs[idx], sizeof(pmix_proc_t)); procs 882 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 883 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs = newprocs; procs 897 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 918 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_FENCENB_CMD))) { procs 920 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_FENCENB_CMD))) { procs 1017 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 1572 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_proc_t *procs = NULL; procs 1597 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); procs 1598 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs) { procs 1603 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, cd->peer, buf, procs, &cnt, PMIX_PROC); procs 1630 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_DISCONNECTNB_CMD))) { procs 1632 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_DISCONNECTNB_CMD))) { procs 1701 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_proc_t *procs = NULL; procs 1735 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); procs 1736 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs) { procs 1741 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, cd->peer, buf, procs, &cnt, PMIX_PROC); procs 1775 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_CONNECTNB_CMD))) { procs 1777 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_CONNECTNB_CMD))) { procs 1830 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != procs) { procs 1831 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 1853 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rngtrk.procs = NULL; procs 1880 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c scd->procs, scd->nprocs)) { procs 1885 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rngtrk.procs = &cd->source; procs 1888 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rngtrk.procs = cd->targets; procs 2250 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c scd->procs = affected; procs 2277 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c scd->procs = affected; procs 3403 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(cd->procs, cd->nprocs); procs 3405 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, cd->procs, &cnt, PMIX_PROC); procs 3448 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 == strncmp(cd->procs[n].nspace, req->pname.nspace, PMIX_MAX_NSLEN) && procs 3449 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c (PMIX_RANK_WILDCARD == req->pname.rank || cd->procs[n].rank == req->pname.rank)) { procs 3470 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c req->pname.nspace = strdup(cd->procs[n].nspace); procs 3471 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c req->pname.rank = cd->procs[n].rank; procs 3534 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_SUCCESS != (rc = pmix_host_server.iof_pull(cd->procs, cd->nprocs, procs 3555 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != cd->procs) { procs 3556 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(cd->procs, cd->nprocs); procs 3599 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(cd->procs, cd->nprocs); procs 3600 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == cd->procs) { procs 3605 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, cd->procs, &cnt, PMIX_PROC); procs 3653 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_SUCCESS != (rc = pmix_host_server.push_stdin(&source, cd->procs, cd->nprocs, procs 3886 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_proc_t *procs; procs 3944 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); procs 3945 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == procs) { procs 3950 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, procs, &cnt, PMIX_PROC); procs 3953 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 3962 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_RANK_LOCAL_PEERS == procs[n].rank) { procs 3969 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_CHECK_NSPACE(procs[n].nspace, pr->info->pname.nspace)) { procs 3975 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c } else if (PMIX_RANK_LOCAL_NODE == procs[n].rank) { procs 3990 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nm->pname->nspace = strdup(procs[n].nspace); procs 3991 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nm->pname->rank = procs[n].rank; procs 3996 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 3998 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); procs 4001 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LOAD_PROCID(&procs[n], nm->pname->nspace, nm->pname->rank); procs 4006 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp->members = procs; procs 4009 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); procs 4434 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c p->procs = NULL; procs 4458 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(p->procs, p->nprocs); procs 52 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_proc_t *procs; procs 285 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_proc_t procs[], size_t nprocs, procs 585 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c vpid = (pmix_proc_t*)job->procs->addr[v]; procs 661 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c vpid = (pmix_proc_t*)job->procs->addr[v]; procs 756 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c pmix_proc_t **procs; procs 777 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c &procs))) { procs 780 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c job->procs->addr = (void**)procs; procs 781 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c job->procs->size = cnt; procs 838 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c for (j=0; j < jobs[i]->procs->size; j++) { procs 839 opal/mca/pmix/pmix4x/pmix/src/tools/pps/pps.c if (NULL == (proc = (pmix_proc_t*)pmix_pointer_array_get_item(jobs[i]->procs, j))) { procs 49 opal/mca/pmix/pmix4x/pmix/test/pmix_regex.c char **nodes, **procs; procs 84 opal/mca/pmix/pmix4x/pmix/test/pmix_regex.c rc = pmix_preg.parse_procs(regex, &procs); procs 87 opal/mca/pmix/pmix4x/pmix/test/pmix_regex.c regex = pmix_argv_join(procs, ';'); procs 88 opal/mca/pmix/pmix4x/pmix/test/pmix_regex.c pmix_argv_free(procs); procs 110 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_proc_t procs[], size_t nprocs, procs 122 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 128 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c procs[0].nspace, procs[0].rank)); procs 303 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 314 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 25 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_proc_t procs[], size_t nprocs, procs 27 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 47 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 50 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 54 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c pmix_proc_t procs[], size_t nprocs, procs 56 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 76 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 79 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 672 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c pmix_proc_t procs[], size_t nprocs, procs 678 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c if (NULL != procs) { procs 679 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c pmix_output(0, "SERVER: ABORT on %s:%d", procs[0].nspace, procs[0].rank); procs 714 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 897 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 916 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 60 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_proc_t procs[], size_t nprocs, procs 62 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 82 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 85 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 800 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_proc_t procs[], size_t nprocs, procs 806 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c if (NULL != procs) { procs 807 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_output(0, "SERVER: ABORT on %s:%d", procs[0].nspace, procs[0].rank); procs 851 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 1057 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 1072 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 60 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c pmix_proc_t procs[], size_t nprocs, procs 62 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 82 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 85 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 541 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c pmix_proc_t procs[], size_t nprocs, procs 577 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 735 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 753 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 21 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c pmix_proc_t *procs; procs 24 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c rc = PMIx_Resolve_peers(NODE_NAME, nspace, &procs, &nprocs); procs 29 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c if (NULL == procs || 0 == nprocs) { procs 36 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIX_PROC_FREE(procs, nprocs); procs 41 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIX_PROC_FREE(procs, nprocs); procs 46 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c if (procs[i].rank != ranks[i].rank) { procs 48 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c my_nspace, my_rank, procs[i].nspace, procs[i].rank, ranks[i].rank)); procs 53 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIX_PROC_FREE(procs, nprocs); procs 63 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c pmix_proc_t procs[2]; procs 91 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c (void)strncpy(procs[0].nspace, nspace, PMIX_MAX_NSLEN); procs 92 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c (void)strncpy(procs[1].nspace, my_nspace, PMIX_MAX_NSLEN); procs 94 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c (void)strncpy(procs[1].nspace, nspace, PMIX_MAX_NSLEN); procs 95 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c (void)strncpy(procs[0].nspace, my_nspace, PMIX_MAX_NSLEN); procs 97 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c procs[0].rank = PMIX_RANK_WILDCARD; procs 98 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c procs[1].rank = PMIX_RANK_WILDCARD; procs 101 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c rc = PMIx_Connect(procs, 2, NULL, 0); procs 114 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIx_Disconnect(procs, 2, NULL, 0); procs 119 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c rc = PMIx_Disconnect(procs, 2, NULL, 0); procs 1736 opal/mca/pmix/pmix4x/pmix4x.c p->procs = NULL; procs 1768 opal/mca/pmix/pmix4x/pmix4x.c if (NULL != p->procs) { procs 1769 opal/mca/pmix/pmix4x/pmix4x.c PMIX_PROC_FREE(p->procs, p->nprocs); procs 1796 opal/mca/pmix/pmix4x/pmix4x.c OBJ_CONSTRUCT(&p->procs, opal_list_t); procs 1812 opal/mca/pmix/pmix4x/pmix4x.c OPAL_LIST_DESTRUCT(&p->procs); procs 88 opal/mca/pmix/pmix4x/pmix4x.h pmix_proc_t *procs; procs 119 opal/mca/pmix/pmix4x/pmix4x.h opal_list_t procs; procs 220 opal/mca/pmix/pmix4x/pmix4x.h opal_list_t *procs); procs 222 opal/mca/pmix/pmix4x/pmix4x.h OPAL_MODULE_DECLSPEC int pmix4x_fence(opal_list_t *procs, int collect_data); procs 223 opal/mca/pmix/pmix4x/pmix4x.h OPAL_MODULE_DECLSPEC int pmix4x_fencenb(opal_list_t *procs, int collect_data, procs 244 opal/mca/pmix/pmix4x/pmix4x.h OPAL_MODULE_DECLSPEC int pmix4x_connect(opal_list_t *procs); procs 245 opal/mca/pmix/pmix4x/pmix4x.h OPAL_MODULE_DECLSPEC int pmix4x_connectnb(opal_list_t *procs, procs 248 opal/mca/pmix/pmix4x/pmix4x.h OPAL_MODULE_DECLSPEC int pmix4x_disconnect(opal_list_t *procs); procs 249 opal/mca/pmix/pmix4x/pmix4x.h OPAL_MODULE_DECLSPEC int pmix4x_disconnectnb(opal_list_t *procs, procs 253 opal/mca/pmix/pmix4x/pmix4x.h opal_list_t *procs); procs 336 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_t *procs) procs 356 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 359 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 449 opal/mca/pmix/pmix4x/pmix4x_client.c int pmix4x_fence(opal_list_t *procs, int collect_data) procs 469 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 472 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 508 opal/mca/pmix/pmix4x/pmix4x_client.c int pmix4x_fencenb(opal_list_t *procs, int collect_data, procs 529 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL != procs && 0 < (cnt = opal_list_get_size(procs))) { procs 532 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 549 opal/mca/pmix/pmix4x/pmix4x_client.c op->procs = parray; procs 559 opal/mca/pmix/pmix4x/pmix4x_client.c rc = PMIx_Fence_nb(op->procs, op->nprocs, op->info, op->ninfo, opcbfunc, op); procs 1308 opal/mca/pmix/pmix4x/pmix4x_client.c int pmix4x_connect(opal_list_t *procs) procs 1321 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { procs 1335 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1353 opal/mca/pmix/pmix4x/pmix4x_client.c int pmix4x_connectnb(opal_list_t *procs, procs 1367 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 1381 opal/mca/pmix/pmix4x/pmix4x_client.c op->nprocs = opal_list_get_size(procs); procs 1385 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1387 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1393 opal/mca/pmix/pmix4x/pmix4x_client.c (void)strncpy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1394 opal/mca/pmix/pmix4x/pmix4x_client.c op->procs[n].rank = pmix4x_convert_opalrank(ptr->name.vpid); procs 1399 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1406 opal/mca/pmix/pmix4x/pmix4x_client.c int pmix4x_disconnect(opal_list_t *procs) procs 1418 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { procs 1432 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1450 opal/mca/pmix/pmix4x/pmix4x_client.c int pmix4x_disconnectnb(opal_list_t *procs, procs 1464 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 1478 opal/mca/pmix/pmix4x/pmix4x_client.c op->nprocs = opal_list_get_size(procs); procs 1482 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1484 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH(ptr, procs, opal_namelist_t) { procs 1490 opal/mca/pmix/pmix4x/pmix4x_client.c (void)strncpy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1491 opal/mca/pmix/pmix4x/pmix4x_client.c op->procs[n].rank = pmix4x_convert_opalrank(ptr->name.vpid); procs 1496 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); procs 1505 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_t *procs) procs 1536 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_append(procs, &nm->super); procs 1642 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); procs 1650 opal/mca/pmix/pmix4x/pmix4x_client.c (void)strncpy(op->procs[n].nspace, nsptr, PMIX_MAX_NSLEN); procs 1651 opal/mca/pmix/pmix4x/pmix4x_client.c op->procs[n].rank = pmix4x_convert_opalrank(ptr->name.vpid); procs 1667 opal/mca/pmix/pmix4x/pmix4x_client.c rc = PMIx_Job_control_nb(op->procs,op->nprocs, op->info, op->ninfo, infocbfunc, op); procs 55 opal/mca/pmix/pmix4x/pmix4x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 57 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 77 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 80 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 114 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, procs 227 opal/mca/pmix/pmix4x/pmix4x_server_north.c pmix_proc_t procs[], size_t nprocs, procs 259 opal/mca/pmix/pmix4x/pmix4x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 260 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 264 opal/mca/pmix/pmix4x/pmix4x_server_north.c nm->name.vpid = pmix4x_convert_rank(procs[n].rank); procs 269 opal/mca/pmix/pmix4x/pmix4x_server_north.c &opalcaddy->procs, opal_opcbfunc, opalcaddy); procs 317 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, procs 342 opal/mca/pmix/pmix4x/pmix4x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 343 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 347 opal/mca/pmix/pmix4x/pmix4x_server_north.c nm->name.vpid = pmix4x_convert_rank(procs[n].rank); procs 362 opal/mca/pmix/pmix4x/pmix4x_server_north.c rc = host_module->fence_nb(&opalcaddy->procs, &opalcaddy->info, procs 714 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, procs 736 opal/mca/pmix/pmix4x/pmix4x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 737 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 741 opal/mca/pmix/pmix4x/pmix4x_server_north.c nm->name.vpid = pmix4x_convert_rank(procs[n].rank); procs 756 opal/mca/pmix/pmix4x/pmix4x_server_north.c rc = host_module->connect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 765 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, procs 787 opal/mca/pmix/pmix4x/pmix4x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 788 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&nm->name.jobid, procs[n].nspace))) { procs 792 opal/mca/pmix/pmix4x/pmix4x_server_north.c nm->name.vpid = pmix4x_convert_rank(procs[n].rank); procs 807 opal/mca/pmix/pmix4x/pmix4x_server_north.c rc = host_module->disconnect(&opalcaddy->procs, &opalcaddy->info, opal_opcbfunc, opalcaddy); procs 1286 opal/mca/pmix/pmix4x/pmix4x_server_north.c opal_list_append(&opalcaddy->procs, &nm->super); procs 1307 opal/mca/pmix/pmix4x/pmix4x_server_north.c &opalcaddy->procs, procs 1317 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, procs 70 opal/mca/pmix/pmix_server.h typedef int (*opal_pmix_server_fencenb_fn_t)(opal_list_t *procs, opal_list_t *info, procs 147 opal/mca/pmix/pmix_server.h typedef int (*opal_pmix_server_connect_fn_t)(opal_list_t *procs, opal_list_t *info, procs 160 opal/mca/pmix/pmix_server.h typedef int (*opal_pmix_server_disconnect_fn_t)(opal_list_t *procs, opal_list_t *info, procs 40 opal/mca/pmix/s1/pmix_s1.c opal_list_t *procs); procs 42 opal/mca/pmix/s1/pmix_s1.c static int s1_fencenb(opal_list_t *procs, int collect_data, procs 44 opal/mca/pmix/s1/pmix_s1.c static int s1_fence(opal_list_t *procs, int collect_data); procs 54 opal/mca/pmix/s1/pmix_s1.c static int s1_job_connect(opal_list_t *procs); procs 55 opal/mca/pmix/s1/pmix_s1.c static int s1_job_disconnect(opal_list_t *procs); procs 468 opal/mca/pmix/s1/pmix_s1.c opal_list_t *procs) procs 618 opal/mca/pmix/s1/pmix_s1.c static int s1_fencenb(opal_list_t *procs, int collect_data, procs 654 opal/mca/pmix/s1/pmix_s1.c static int s1_fence(opal_list_t *procs, int collect_data) procs 657 opal/mca/pmix/s1/pmix_s1.c s1_fencenb(procs, collect_data, fence_release, (void*)&result); procs 702 opal/mca/pmix/s1/pmix_s1.c static int s1_job_connect(opal_list_t *procs) procs 707 opal/mca/pmix/s1/pmix_s1.c static int s1_job_disconnect(opal_list_t *procs) procs 43 opal/mca/pmix/s2/pmix_s2.c opal_list_t *procs); procs 45 opal/mca/pmix/s2/pmix_s2.c static int s2_fencenb(opal_list_t *procs, int collect_data, procs 47 opal/mca/pmix/s2/pmix_s2.c static int s2_fence(opal_list_t *procs, int collect_data); procs 57 opal/mca/pmix/s2/pmix_s2.c static int s2_job_connect(opal_list_t *procs); procs 58 opal/mca/pmix/s2/pmix_s2.c static int s2_job_disconnect(opal_list_t *procs); procs 453 opal/mca/pmix/s2/pmix_s2.c opal_list_t *procs) procs 476 opal/mca/pmix/s2/pmix_s2.c static int s2_job_connect(opal_list_t *procs) procs 483 opal/mca/pmix/s2/pmix_s2.c if (NULL == procs || 1 < opal_list_get_size(procs)) { procs 486 opal/mca/pmix/s2/pmix_s2.c nm = (opal_namelist_t*)opal_list_get_first(procs); procs 500 opal/mca/pmix/s2/pmix_s2.c static int s2_job_disconnect(opal_list_t *procs) procs 506 opal/mca/pmix/s2/pmix_s2.c if (NULL == procs || 1 < opal_list_get_size(procs)) { procs 509 opal/mca/pmix/s2/pmix_s2.c nm = (opal_namelist_t*)opal_list_get_first(procs); procs 637 opal/mca/pmix/s2/pmix_s2.c static int s2_fencenb(opal_list_t *procs, int collect_data, procs 673 opal/mca/pmix/s2/pmix_s2.c static int s2_fence(opal_list_t *procs, int collect_data) procs 676 opal/mca/pmix/s2/pmix_s2.c s2_fencenb(procs, collect_data, fence_release, (void*)&result); procs 142 orte/mca/errmgr/base/errmgr_base_fns.c int orte_errmgr_base_abort_peers(orte_process_name_t *procs, procs 67 orte/mca/errmgr/base/errmgr_private.h ORTE_DECLSPEC int orte_errmgr_base_abort_peers(orte_process_name_t *procs, procs 52 orte/mca/errmgr/default_app/errmgr_default_app.c static int abort_peers(orte_process_name_t *procs, procs 193 orte/mca/errmgr/default_app/errmgr_default_app.c static int abort_peers(orte_process_name_t *procs, procs 381 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); procs 404 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == (child = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { procs 457 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == (child = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { procs 50 orte/mca/errmgr/default_tool/errmgr_default_tool.c static int abort_peers(orte_process_name_t *procs, procs 116 orte/mca/errmgr/default_tool/errmgr_default_tool.c static int abort_peers(orte_process_name_t *procs, procs 118 orte/mca/errmgr/errmgr.h typedef int (*orte_errmgr_base_module_abort_peers_fn_t)(orte_process_name_t *procs, procs 344 orte/mca/ess/base/ess_base_std_orted.c opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc); procs 469 orte/mca/ess/hnp/ess_hnp_module.c opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc); procs 193 orte/mca/filem/base/filem_base_receive.c proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, name.vpid); procs 407 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, sig->signature[n].vpid))) { procs 542 orte/mca/grpcomm/direct/grpcomm_direct.c if (NULL == (rec = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, nm->name.vpid))) { procs 112 orte/mca/iof/hnp/iof_hnp.c OBJ_CONSTRUCT(&mca_iof_hnp_component.procs, opal_list_t); procs 153 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 163 orte/mca/iof/hnp/iof_hnp.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); procs 214 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(pptr, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 252 orte/mca/iof/hnp/iof_hnp.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, dst_name->vpid))) { procs 362 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 372 orte/mca/iof/hnp/iof_hnp.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); procs 393 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 432 orte/mca/iof/hnp/iof_hnp.c opal_list_remove_item(&mca_iof_hnp_component.procs, &proct->super); procs 446 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH_SAFE(proct, next, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 448 orte/mca/iof/hnp/iof_hnp.c opal_list_remove_item(&mca_iof_hnp_component.procs, &proct->super); procs 499 orte/mca/iof/hnp/iof_hnp.c while (NULL != (proct = (orte_iof_proc_t*)opal_list_remove_first(&mca_iof_hnp_component.procs))) { procs 513 orte/mca/iof/hnp/iof_hnp.c OBJ_DESTRUCT(&mca_iof_hnp_component.procs); procs 64 orte/mca/iof/hnp/iof_hnp.h opal_list_t procs; procs 132 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 142 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); procs 184 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 225 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { procs 235 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); procs 116 orte/mca/iof/orted/iof_orted.c OBJ_CONSTRUCT(&mca_iof_orted_component.procs, opal_list_t); procs 153 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { procs 165 orte/mca/iof/orted/iof_orted.c opal_list_append(&mca_iof_orted_component.procs, &proct->super); procs 255 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { procs 265 orte/mca/iof/orted/iof_orted.c opal_list_append(&mca_iof_orted_component.procs, &proct->super); procs 286 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { procs 325 orte/mca/iof/orted/iof_orted.c opal_list_remove_item(&mca_iof_orted_component.procs, &proct->super); procs 340 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH_SAFE(proct, next, &mca_iof_orted_component.procs, orte_iof_proc_t) { procs 342 orte/mca/iof/orted/iof_orted.c opal_list_remove_item(&mca_iof_orted_component.procs, &proct->super); procs 354 orte/mca/iof/orted/iof_orted.c while (NULL != (proct = (orte_iof_proc_t*)opal_list_remove_first(&mca_iof_orted_component.procs))) { procs 368 orte/mca/iof/orted/iof_orted.c OBJ_DESTRUCT(&mca_iof_orted_component.procs); procs 65 orte/mca/iof/orted/iof_orted.h opal_list_t procs; procs 134 orte/mca/iof/orted/iof_orted_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { procs 142 orte/mca/odls/alps/odls_alps_module.c static int orte_odls_alps_kill_local_procs(opal_pointer_array_t *procs); procs 200 orte/mca/odls/alps/odls_alps_module.c int orte_odls_alps_kill_local_procs(opal_pointer_array_t *procs) procs 204 orte/mca/odls/alps/odls_alps_module.c if (ORTE_SUCCESS != (rc = orte_odls_base_default_kill_local_procs(procs, procs 247 orte/mca/odls/base/odls_base_default_fns.c for (v=1; v < jptr->procs->size; v++) { procs 248 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (dmn = (orte_proc_t*)opal_pointer_array_get_item(jptr->procs, v))) { procs 351 orte/mca/odls/base/odls_base_default_fns.c for (n=0; n < jptr->procs->size; n++) { procs 352 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jptr->procs, n))) { procs 521 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, v))) { procs 525 orte/mca/odls/base/odls_base_default_fns.c opal_pointer_array_set_item(jdata->procs, v, pptr); procs 535 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (dmn = (orte_proc_t*)opal_pointer_array_get_item(daemons->procs, dmnvpid))) { procs 682 orte/mca/odls/base/odls_base_default_fns.c for (n=0; n < jdata->procs->size; n++) { procs 683 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, n))) { procs 705 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (dmn = (orte_proc_t*)opal_pointer_array_get_item(daemons->procs, pptr->parent))) { procs 721 orte/mca/odls/base/odls_base_default_fns.c opal_pointer_array_add(pptr->node->procs, pptr); procs 1764 orte/mca/odls/base/odls_base_default_fns.c int orte_odls_base_default_kill_local_procs(opal_pointer_array_t *procs, procs 1778 orte/mca/odls/base/odls_base_default_fns.c if (NULL == procs) { procs 1794 orte/mca/odls/base/odls_base_default_fns.c procptr = procs; procs 151 orte/mca/odls/base/odls_private.h orte_odls_base_default_kill_local_procs(opal_pointer_array_t *procs, procs 141 orte/mca/odls/default/odls_default_module.c static int orte_odls_default_kill_local_procs(opal_pointer_array_t *procs); procs 202 orte/mca/odls/default/odls_default_module.c int orte_odls_default_kill_local_procs(opal_pointer_array_t *procs) procs 206 orte/mca/odls/default/odls_default_module.c if (ORTE_SUCCESS != (rc = orte_odls_base_default_kill_local_procs(procs, procs 70 orte/mca/odls/odls.h typedef int (*orte_odls_base_module_kill_local_processes_fn_t)(opal_pointer_array_t *procs); procs 161 orte/mca/odls/pspawn/odls_pspawn.c static int orte_odls_pspawn_kill_local_procs(opal_pointer_array_t *procs); procs 211 orte/mca/odls/pspawn/odls_pspawn.c int orte_odls_pspawn_kill_local_procs(opal_pointer_array_t *procs) procs 215 orte/mca/odls/pspawn/odls_pspawn.c if (ORTE_SUCCESS != (rc = orte_odls_base_default_kill_local_procs(procs, procs 897 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (daemon = (orte_proc_t*)opal_pointer_array_get_item(jdatorted->procs, sender->vpid))) { procs 1121 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (daemon = (orte_proc_t*)opal_pointer_array_get_item(jdatorted->procs, dname.vpid))) { procs 1452 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (daemon = (orte_proc_t*)opal_pointer_array_get_item(jdatorted->procs, vpid))) { procs 2265 orte/mca/plm/base/plm_base_launch_support.c if (0 > (rc = opal_pointer_array_set_item(daemons->procs, proc->name.vpid, (void*)proc))) { procs 2293 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < node->procs->size; i++) { procs 2294 orte/mca/plm/base/plm_base_launch_support.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 129 orte/mca/plm/base/plm_base_orted_cmds.c opal_pointer_array_t procs; procs 138 orte/mca/plm/base/plm_base_orted_cmds.c OBJ_CONSTRUCT(&procs, opal_pointer_array_t); procs 139 orte/mca/plm/base/plm_base_orted_cmds.c opal_pointer_array_init(&procs, 1, 1, 1); procs 143 orte/mca/plm/base/plm_base_orted_cmds.c opal_pointer_array_add(&procs, &proc); procs 144 orte/mca/plm/base/plm_base_orted_cmds.c if (ORTE_SUCCESS != (rc = orte_plm_base_orted_kill_local_procs(&procs))) { procs 147 orte/mca/plm/base/plm_base_orted_cmds.c OBJ_DESTRUCT(&procs); procs 152 orte/mca/plm/base/plm_base_orted_cmds.c int orte_plm_base_orted_kill_local_procs(opal_pointer_array_t *procs) procs 174 orte/mca/plm/base/plm_base_orted_cmds.c if (NULL != procs) { procs 175 orte/mca/plm/base/plm_base_orted_cmds.c for (v=0; v < procs->size; v++) { procs 176 orte/mca/plm/base/plm_base_orted_cmds.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(procs, v))) { procs 231 orte/mca/plm/base/plm_base_receive.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(parent->procs, sender->vpid))) { procs 341 orte/mca/plm/base/plm_base_receive.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, vpid))) { procs 102 orte/mca/plm/base/plm_private.h ORTE_DECLSPEC int orte_plm_base_orted_kill_local_procs(opal_pointer_array_t *procs); procs 95 orte/mca/plm/plm.h typedef int (*orte_plm_base_module_terminate_procs_fn_t)(opal_pointer_array_t *procs); procs 1341 orte/mca/plm/rsh/plm_rsh_module.c for (i=0; i < jdata->procs->size; i++) { procs 1342 orte/mca/plm/rsh/plm_rsh_module.c if (NULL == (proc = opal_pointer_array_get_item(jdata->procs, i))) { procs 209 orte/mca/ras/base/ras_base_node.c opal_pointer_array_set_item(djob->procs, daemon->name.vpid, daemon); procs 76 orte/mca/rmaps/base/rmaps_base_binding.c for (j=0; j < node->procs->size; j++) { procs 77 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 116 orte/mca/rmaps/base/rmaps_base_binding.c for (j=0; j < jdata->procs->size; j++) { procs 117 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, j))) { procs 150 orte/mca/rmaps/base/rmaps_base_binding.c for (j=0; j < node->procs->size; j++) { procs 151 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 386 orte/mca/rmaps/base/rmaps_base_binding.c for (j=0; j < node->procs->size; j++) { procs 387 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 594 orte/mca/rmaps/base/rmaps_base_binding.c for (j=0; j < node->procs->size; j++) { procs 595 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 525 orte/mca/rmaps/base/rmaps_base_map_job.c for (j=0; j < node->procs->size; j++) { procs 526 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 552 orte/mca/rmaps/base/rmaps_base_map_job.c p0 = (orte_proc_t*)opal_pointer_array_get_item(node->procs, 0); procs 557 orte/mca/rmaps/base/rmaps_base_map_job.c for (j=1; j < node->procs->size; j++) { procs 558 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 120 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < node->procs->size && cnt < app->num_procs; j++) { procs 121 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 161 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { procs 165 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { procs 241 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < node->procs->size && cnt < app->num_procs; j++) { procs 242 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 282 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { procs 286 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { procs 407 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; np < node->num_procs && j < node->procs->size && cnt < app->num_procs; j++) { procs 408 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 457 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { procs 461 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { procs 637 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < node->procs->size; j++) { procs 638 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 654 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { procs 658 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { procs 696 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < node->procs->size; j++) { procs 697 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 719 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { procs 723 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { procs 770 orte/mca/rmaps/base/rmaps_base_ranking.c for (k=0; k < node->procs->size; k++) { procs 772 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == opal_pointer_array_get_item(node->procs, k)) { procs 780 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < node->procs->size; j++) { procs 782 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 823 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < jdata->procs->size; j++) { procs 824 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, j))) { procs 867 orte/mca/rmaps/base/rmaps_base_ranking.c for (k=0; k < newnode->procs->size; k++) { procs 869 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t *) opal_pointer_array_get_item(newnode->procs, k))) { procs 881 orte/mca/rmaps/base/rmaps_base_ranking.c for (k=0; k < newnode->procs->size; k++) { procs 883 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t *) opal_pointer_array_get_item(newnode->procs, k))) { procs 540 orte/mca/rmaps/base/rmaps_base_support_fns.c if (0 > (rc = opal_pointer_array_add(node->procs, (void*)proc))) { procs 68 orte/mca/rmaps/base/rmaps_private.h ORTE_DECLSPEC int orte_rmaps_base_rearrange_map(orte_app_context_t *app, orte_job_map_t *map, opal_list_t *procs); procs 515 orte/mca/rmaps/mindist/rmaps_mindist_module.c for (k = j; k < node->procs->size && 0 < npus; k++) { procs 516 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, k))) { procs 504 orte/mca/rmaps/ppr/rmaps_ppr.c for (n=0; n < node->procs->size; n++) { procs 505 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, n))) { procs 556 orte/mca/rmaps/ppr/rmaps_ppr.c for (n=0; n < node->procs->size; n++) { procs 557 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, n))) { procs 595 orte/mca/rmaps/ppr/rmaps_ppr.c opal_pointer_array_set_item(node->procs, idxmax, NULL); procs 696 orte/mca/rmaps/ppr/rmaps_ppr.c for (j=0; j < node->procs->size; j++) { procs 697 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 719 orte/mca/rmaps/ppr/rmaps_ppr.c for (j=0; j < node->procs->size && cnt < ppr && nprocs_mapped < app->num_procs; j++) { procs 720 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 350 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, procs 136 orte/mca/rmaps/resilient/rmaps_resilient.c for (i=0; i < jdata->procs->size; i++) { procs 138 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 264 orte/mca/rmaps/resilient/rmaps_resilient.c opal_pointer_array_add(nd->procs, (void*)proc); procs 595 orte/mca/rmaps/resilient/rmaps_resilient.c for (j=0; j < node->procs->size; j++) { procs 596 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 65 orte/mca/rmaps/round_robin/rmaps_rr_assign.c for (i=0; i < node->procs->size; i++) { procs 66 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 137 orte/mca/rmaps/round_robin/rmaps_rr_assign.c for (j=0; j < node->procs->size; j++) { procs 138 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 501 orte/mca/rmaps/seq/rmaps_seq.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { procs 54 orte/mca/routed/base/routed_base_fns.c for (i=1; i < daemons->procs->size; i++) { procs 55 orte/mca/routed/base/routed_base_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(daemons->procs, i))) { procs 127 orte/mca/routed/base/routed_base_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, vpid))) { procs 305 orte/mca/routed/direct/routed_direct.c for (i=1; i < jdata->procs->size; i++) { procs 306 orte/mca/routed/direct/routed_direct.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 590 orte/mca/snapc/full/snapc_full_global.c orte_proc_t **procs = NULL; procs 611 orte/mca/snapc/full/snapc_full_global.c procs = (orte_proc_t**)cur_node->procs->addr; procs 658 orte/mca/snapc/full/snapc_full_global.c p, ORTE_NAME_PRINT(&(procs[p]->name)), ORTE_NAME_PRINT(&(cur_node->daemon->name)) )); procs 662 orte/mca/snapc/full/snapc_full_global.c app_snapshot->process_name.jobid = procs[p]->name.jobid; procs 663 orte/mca/snapc/full/snapc_full_global.c app_snapshot->process_name.vpid = procs[p]->name.vpid; procs 685 orte/mca/snapc/full/snapc_full_global.c orte_proc_t **procs = NULL; procs 784 orte/mca/snapc/full/snapc_full_global.c procs = (orte_proc_t**)cur_node->procs->addr; procs 815 orte/mca/snapc/full/snapc_full_global.c if( NULL == procs[p] ) { procs 821 orte/mca/snapc/full/snapc_full_global.c p, ORTE_NAME_PRINT(&(procs[p]->name)), ORTE_NAME_PRINT(&(cur_node->daemon->name)) )); procs 825 orte/mca/snapc/full/snapc_full_global.c app_snapshot->process_name.jobid = procs[p]->name.jobid; procs 826 orte/mca/snapc/full/snapc_full_global.c app_snapshot->process_name.vpid = procs[p]->name.vpid; procs 850 orte/mca/snapc/full/snapc_full_global.c if( NULL == procs[p] ) { procs 856 orte/mca/snapc/full/snapc_full_global.c p, ORTE_NAME_PRINT(&(procs[p]->name)), ORTE_NAME_PRINT(&(cur_node->daemon->name)) )); procs 860 orte/mca/snapc/full/snapc_full_global.c app_snapshot->process_name.jobid = procs[p]->name.jobid; procs 861 orte/mca/snapc/full/snapc_full_global.c app_snapshot->process_name.vpid = procs[p]->name.vpid; procs 415 orte/mca/state/base/state_base_fns.c for (i=0; i < node->procs->size; i++) { procs 416 orte/mca/state/base/state_base_fns.c if (NULL == (p = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 421 orte/mca/state/base/state_base_fns.c opal_pointer_array_set_item(node->procs, i, NULL); procs 653 orte/mca/state/base/state_base_fns.c pdata = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); procs 890 orte/mca/state/base/state_base_fns.c for (i = 0; i < node->procs->size; i++) { procs 891 orte/mca/state/base/state_base_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 905 orte/mca/state/base/state_base_fns.c opal_pointer_array_set_item(node->procs, i, NULL); procs 284 orte/mca/state/orted/state_orted.c pdata = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); procs 470 orte/mca/state/orted/state_orted.c for (i = 0; i < node->procs->size; i++) { procs 471 orte/mca/state/orted/state_orted.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 487 orte/mca/state/orted/state_orted.c opal_pointer_array_set_item(node->procs, i, NULL); procs 604 orte/orted/orted_comm.c for (i = 0; i < node->procs->size; i++) { procs 605 orte/orted/orted_comm.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 615 orte/orted/orted_comm.c opal_pointer_array_set_item(node->procs, i, NULL); procs 1003 orte/orted/orted_comm.c for (i=0; i < jdata->procs->size; i++) { procs 1004 orte/orted/orted_comm.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 1040 orte/orted/orted_comm.c for (i=0; i < jdata->procs->size; i++) { procs 1041 orte/orted/orted_comm.c if (NULL != opal_pointer_array_get_item(jdata->procs, i)) { procs 1052 orte/orted/orted_comm.c for (i=0; i < jdata->procs->size; i++) { procs 1053 orte/orted/orted_comm.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 581 orte/orted/orted_main.c opal_pointer_array_add(jdata->procs, proc); procs 589 orte/orted/orted_main.c opal_pointer_array_add(node->procs, proc); procs 2588 orte/orted/orted_submit.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, j))) { procs 3202 orte/orted/orted_submit.c for (i=0; i < jdata->procs->size; i++) { procs 3203 orte/orted/orted_submit.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 3369 orte/orted/orted_submit.c if (NULL != (dmn = (orte_proc_t*)opal_pointer_array_get_item(dmns->procs, 1))) { procs 530 orte/orted/pmix/pmix_server.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, name.vpid))) { procs 669 orte/orted/pmix/pmix_server.c p->procs = NULL; procs 655 orte/orted/pmix/pmix_server_dyn.c opal_pointer_array_set_item(jdata->procs, pname.vpid, proc); procs 680 orte/orted/pmix/pmix_server_dyn.c ORTE_PMIX_OPERATION(cd->procs, cd->info, _cnct, cd->cbfunc, cd->cbdata); procs 682 orte/orted/pmix/pmix_server_dyn.c cd->procs = NULL; procs 715 orte/orted/pmix/pmix_server_dyn.c OPAL_LIST_FOREACH(nm, cd->procs, orte_namelist_t) { procs 766 orte/orted/pmix/pmix_server_dyn.c int pmix_server_connect_fn(opal_list_t *procs, opal_list_t *info, procs 772 orte/orted/pmix/pmix_server_dyn.c (int)opal_list_get_size(procs)); procs 775 orte/orted/pmix/pmix_server_dyn.c if (NULL == procs || 0 == opal_list_get_size(procs)) { procs 779 orte/orted/pmix/pmix_server_dyn.c ORTE_PMIX_OPERATION(procs, info, _cnct, cbfunc, cbdata); procs 798 orte/orted/pmix/pmix_server_dyn.c int pmix_server_disconnect_fn(opal_list_t *procs, opal_list_t *info, procs 807 orte/orted/pmix/pmix_server_dyn.c (int)opal_list_get_size(procs)); procs 818 orte/orted/pmix/pmix_server_dyn.c if (ORTE_SUCCESS != (rc = pmix_server_fencenb_fn(procs, info, NULL, 0, procs 81 orte/orted/pmix/pmix_server_fence.c int pmix_server_fencenb_fn(opal_list_t *procs, opal_list_t *info, procs 96 orte/orted/pmix/pmix_server_fence.c if (NULL != procs) { procs 98 orte/orted/pmix/pmix_server_fence.c cd->sig->sz = opal_list_get_size(procs); procs 102 orte/orted/pmix/pmix_server_fence.c OPAL_LIST_FOREACH(nm, procs, opal_namelist_t) { procs 215 orte/orted/pmix/pmix_server_fence.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, req->target.vpid))) { procs 73 orte/orted/pmix/pmix_server_gen.c for (i=0; i < jdata->procs->size; i++) { procs 74 orte/orted/pmix/pmix_server_gen.c if (NULL == (ptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 124 orte/orted/pmix/pmix_server_gen.c for (i=0; i < jdata->procs->size; i++) { procs 125 orte/orted/pmix/pmix_server_gen.c if (NULL == (ptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 183 orte/orted/pmix/pmix_server_gen.c for (i=0; i < jdata->procs->size; i++) { procs 184 orte/orted/pmix/pmix_server_gen.c if (NULL == (ptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 737 orte/orted/pmix/pmix_server_gen.c for (k=0; k < jdata->procs->size; k++) { procs 738 orte/orted/pmix/pmix_server_gen.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, k))) { procs 786 orte/orted/pmix/pmix_server_gen.c for (k=0; k < jdata->procs->size; k++) { procs 787 orte/orted/pmix/pmix_server_gen.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, k))) { procs 993 orte/orted/pmix/pmix_server_gen.c opal_pointer_array_add(jdata->procs, proc); procs 1004 orte/orted/pmix/pmix_server_gen.c opal_pointer_array_add(node->procs, proc); procs 96 orte/orted/pmix/pmix_server_internal.h opal_list_t *procs; procs 148 orte/orted/pmix/pmix_server_internal.h _cd->procs = (p); \ procs 168 orte/orted/pmix/pmix_server_internal.h _cd->procs = (pl); \ procs 187 orte/orted/pmix/pmix_server_internal.h extern int pmix_server_fencenb_fn(opal_list_t *procs, opal_list_t *info, procs 204 orte/orted/pmix/pmix_server_internal.h extern int pmix_server_connect_fn(opal_list_t *procs, opal_list_t *info, procs 206 orte/orted/pmix/pmix_server_internal.h extern int pmix_server_disconnect_fn(opal_list_t *procs, opal_list_t *info, procs 66 orte/orted/pmix/pmix_server_register_fns.c char **list, **procs, **micro, *tmp, *regex; procs 128 orte/orted/pmix/pmix_server_register_fns.c procs = NULL; procs 135 orte/orted/pmix/pmix_server_register_fns.c for (k=0; k < node->procs->size; k++) { procs 136 orte/orted/pmix/pmix_server_register_fns.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(node->procs, k))) { procs 146 orte/orted/pmix/pmix_server_register_fns.c opal_argv_append_nosize(&procs, tmp); procs 171 orte/orted/pmix/pmix_server_register_fns.c if (NULL != procs) { procs 172 orte/orted/pmix/pmix_server_register_fns.c tmp = opal_argv_join(procs, ';'); procs 173 orte/orted/pmix/pmix_server_register_fns.c opal_argv_free(procs); procs 174 orte/orted/pmix/pmix_server_register_fns.c procs = NULL; procs 195 orte/orted/pmix/pmix_server_register_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(dmns->procs, ORTE_PROC_MY_NAME->vpid))) { procs 310 orte/orted/pmix/pmix_server_register_fns.c for (i=0; i < mynode->procs->size; i++) { procs 311 orte/orted/pmix/pmix_server_register_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(mynode->procs, i))) { procs 356 orte/orted/pmix/pmix_server_register_fns.c for (i=0; i < node->procs->size; i++) { procs 357 orte/orted/pmix/pmix_server_register_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 535 orte/orted/pmix/pmix_server_register_fns.c for (i=0; i < jdata->procs->size; i++) { procs 536 orte/orted/pmix/pmix_server_register_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 188 orte/runtime/data_type_support/orte_dt_packing_fns.c for (j=0; j < jobs[i]->procs->size; j++) { procs 189 orte/runtime/data_type_support/orte_dt_packing_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jobs[i]->procs, j))) { procs 343 orte/runtime/data_type_support/orte_dt_packing_fns.c orte_proc_t **procs; procs 347 orte/runtime/data_type_support/orte_dt_packing_fns.c procs = (orte_proc_t**) src; procs 352 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->name)), 1, ORTE_NAME))) { procs 359 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->parent)), 1, ORTE_VPID))) { procs 366 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->local_rank)), 1, ORTE_LOCAL_RANK))) { procs 373 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->node_rank)), 1, ORTE_NODE_RANK))) { procs 380 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->state)), 1, ORTE_PROC_STATE))) { procs 387 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->app_idx)), 1, ORTE_STD_CNTR))) { procs 394 orte/runtime/data_type_support/orte_dt_packing_fns.c (void*)(&(procs[i]->app_rank)), 1, OPAL_UINT32))) { procs 401 orte/runtime/data_type_support/orte_dt_packing_fns.c OPAL_LIST_FOREACH(kv, &procs[i]->attributes, orte_attribute_t) { procs 410 orte/runtime/data_type_support/orte_dt_packing_fns.c OPAL_LIST_FOREACH(kv, &procs[i]->attributes, orte_attribute_t) { procs 231 orte/runtime/data_type_support/orte_dt_print_fns.c for (i=0; i < src->procs->size; i++) { procs 232 orte/runtime/data_type_support/orte_dt_print_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(src->procs, i))) { procs 419 orte/runtime/data_type_support/orte_dt_print_fns.c for (i=0; i < src->procs->size; i++) { procs 420 orte/runtime/data_type_support/orte_dt_print_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(src->procs, i))) { procs 650 orte/runtime/data_type_support/orte_dt_print_fns.c for (j=0; j < node->procs->size; j++) { procs 651 orte/runtime/data_type_support/orte_dt_print_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, j))) { procs 200 orte/runtime/data_type_support/orte_dt_unpacking_fns.c opal_pointer_array_add(jobs[i]->procs, proc); procs 358 orte/runtime/data_type_support/orte_dt_unpacking_fns.c orte_proc_t **procs; procs 361 orte/runtime/data_type_support/orte_dt_unpacking_fns.c procs = (orte_proc_t**) dest; procs 365 orte/runtime/data_type_support/orte_dt_unpacking_fns.c procs[i] = OBJ_NEW(orte_proc_t); procs 366 orte/runtime/data_type_support/orte_dt_unpacking_fns.c if (NULL == procs[i]) { procs 374 orte/runtime/data_type_support/orte_dt_unpacking_fns.c &(procs[i]->name), &n, ORTE_NAME))) { procs 382 orte/runtime/data_type_support/orte_dt_unpacking_fns.c (&(procs[i]->parent)), &n, ORTE_VPID))) { procs 390 orte/runtime/data_type_support/orte_dt_unpacking_fns.c (&(procs[i]->local_rank)), &n, ORTE_LOCAL_RANK))) { procs 398 orte/runtime/data_type_support/orte_dt_unpacking_fns.c (&(procs[i]->node_rank)), &n, ORTE_NODE_RANK))) { procs 406 orte/runtime/data_type_support/orte_dt_unpacking_fns.c (&(procs[i]->state)), &n, ORTE_PROC_STATE))) { procs 414 orte/runtime/data_type_support/orte_dt_unpacking_fns.c (&(procs[i]->app_idx)), &n, ORTE_STD_CNTR))) { procs 422 orte/runtime/data_type_support/orte_dt_unpacking_fns.c (&(procs[i]->app_rank)), &n, OPAL_UINT32))) { procs 442 orte/runtime/data_type_support/orte_dt_unpacking_fns.c opal_list_append(&procs[i]->attributes, &kv->super); procs 431 orte/runtime/orte_globals.c proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); procs 443 orte/runtime/orte_globals.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { procs 532 orte/runtime/orte_globals.c for (i=0; i < jdata->procs->size; i++) { procs 533 orte/runtime/orte_globals.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { procs 556 orte/runtime/orte_globals.c OBJ_CONSTRUCT(&app_context->procs, opal_pointer_array_t); procs 557 orte/runtime/orte_globals.c opal_pointer_array_init(&app_context->procs, procs 580 orte/runtime/orte_globals.c for (i=0; i < app_context->procs.size; i++) { procs 581 orte/runtime/orte_globals.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(&app_context->procs, i))) { procs 585 orte/runtime/orte_globals.c OBJ_DESTRUCT(&app_context->procs); procs 625 orte/runtime/orte_globals.c job->procs = OBJ_NEW(opal_pointer_array_t); procs 626 orte/runtime/orte_globals.c opal_pointer_array_init(job->procs, procs 701 orte/runtime/orte_globals.c for (n=0; n < job->procs->size; n++) { procs 702 orte/runtime/orte_globals.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(job->procs, n))) { procs 707 orte/runtime/orte_globals.c OBJ_RELEASE(job->procs); procs 733 orte/runtime/orte_globals.c node->procs = OBJ_NEW(opal_pointer_array_t); procs 734 orte/runtime/orte_globals.c opal_pointer_array_init(node->procs, procs 766 orte/runtime/orte_globals.c for (i=0; i < node->procs->size; i++) { procs 767 orte/runtime/orte_globals.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { procs 768 orte/runtime/orte_globals.c opal_pointer_array_set_item(node->procs, i, NULL); procs 772 orte/runtime/orte_globals.c OBJ_RELEASE(node->procs); procs 241 orte/runtime/orte_globals.h opal_pointer_array_t procs; procs 278 orte/runtime/orte_globals.h opal_pointer_array_t *procs; procs 334 orte/runtime/orte_globals.h opal_pointer_array_t *procs; procs 362 orte/runtime/orte_quit.c for (i=0; i < job->procs->size; i++) { procs 363 orte/runtime/orte_quit.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(job->procs, i))) { procs 65 orte/test/mpi/pmix.c ompi_proc_t **procs, *thisproc; procs 93 orte/test/mpi/pmix.c procs = ompi_proc_world ( &numprocs ); procs 97 orte/test/mpi/pmix.c thisproc = procs[i]; procs 127 orte/test/mpi/pmix.c free(procs); procs 405 orte/util/nidmap.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(daemons->procs, vpid))) { procs 412 orte/util/nidmap.c opal_pointer_array_set_item(daemons->procs, proc->name.vpid, proc); procs 1064 orte/util/nidmap.c for (k=0; k < nptr->procs->size; k++) { procs 1065 orte/util/nidmap.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(nptr->procs, k))) { procs 1228 orte/util/nidmap.c opal_pointer_array_add(node->procs, proc); procs 62 oshmem/mca/spml/base/base.h ompi_proc_t **procs, procs 286 oshmem/mca/spml/ikrit/spml_ikrit.c int mca_spml_ikrit_del_procs(ompi_proc_t** procs, size_t nprocs) procs 314 oshmem/mca/spml/ikrit/spml_ikrit.c int mca_spml_ikrit_add_procs(ompi_proc_t** procs, size_t nprocs) procs 413 oshmem/mca/spml/ikrit/spml_ikrit.c if (procs[i]->super.proc_name.jobid != proc_self->super.proc_name.jobid || procs 414 oshmem/mca/spml/ikrit/spml_ikrit.c !OPAL_PROC_ON_LOCAL_NODE(procs[i]->super.proc_flags)) { procs 417 oshmem/mca/spml/ikrit/spml_ikrit.c if (procs[i] == proc_self) procs 189 oshmem/mca/spml/ikrit/spml_ikrit.h extern int mca_spml_ikrit_add_procs(ompi_proc_t** procs, size_t nprocs); procs 190 oshmem/mca/spml/ikrit/spml_ikrit.h extern int mca_spml_ikrit_del_procs(ompi_proc_t** procs, size_t nprocs); procs 196 oshmem/mca/spml/spml.h typedef int (*mca_spml_base_module_add_procs_fn_t)(ompi_proc_t** procs, procs 198 oshmem/mca/spml/spml.h typedef int (*mca_spml_base_module_del_procs_fn_t)(ompi_proc_t** procs, procs 101 oshmem/mca/spml/ucx/spml_ucx.c int mca_spml_ucx_del_procs(ompi_proc_t** procs, size_t nprocs) procs 216 oshmem/mca/spml/ucx/spml_ucx.c int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs) procs 268 oshmem/mca/spml/ucx/spml_ucx.c OSHMEM_PROC_DATA(procs[i])->num_transports = 1; procs 269 oshmem/mca/spml/ucx/spml_ucx.c OSHMEM_PROC_DATA(procs[i])->transport_ids = spml_ucx_transport_ids; procs 164 oshmem/mca/spml/ucx/spml_ucx.h extern int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs); procs 165 oshmem/mca/spml/ucx/spml_ucx.h extern int mca_spml_ucx_del_procs(ompi_proc_t** procs, size_t nprocs);