nprocs 77 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c size_t nprocs, nprocs 91 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c for(i = 0; i < (int) nprocs; i++) { nprocs 149 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c size_t nprocs, nprocs 155 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c for(i=0; i<nprocs; i++) { nprocs 190 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h size_t nprocs, nprocs 209 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h size_t nprocs, nprocs 33 ompi/datatype/ompi_datatype_create_darray.c block(const int *gsize_array, int dim, int ndims, int nprocs, nprocs 44 ompi/datatype/ompi_datatype_create_darray.c blksize = (global_size + nprocs - 1) / nprocs; nprocs 94 ompi/datatype/ompi_datatype_create_darray.c cyclic(const int *gsize_array, int dim, int ndims, int nprocs, nprocs 115 ompi/datatype/ompi_datatype_create_darray.c local_size = ((end_index - st_index + 1)/(nprocs*blksize))*blksize; nprocs 116 ompi/datatype/ompi_datatype_create_darray.c rem = (end_index - st_index + 1) % (nprocs*blksize); nprocs 123 ompi/datatype/ompi_datatype_create_darray.c stride = nprocs*blksize*orig_extent; nprocs 233 ompi/datatype/ompi_datatype_create_darray.c int nprocs, tmp_rank; nprocs 249 ompi/datatype/ompi_datatype_create_darray.c nprocs = psize_array[i]; tmp_rank = coords[i]; nprocs 251 ompi/datatype/ompi_datatype_create_darray.c nprocs = 1; tmp_rank = 0; nprocs 254 ompi/datatype/ompi_datatype_create_darray.c rc = block(gsize_array, i, ndims, nprocs, tmp_rank, nprocs 460 ompi/mca/bml/bml.h size_t nprocs, nprocs 496 ompi/mca/bml/bml.h size_t nprocs, nprocs 456 ompi/mca/bml/r2/bml_r2.c static int mca_bml_r2_add_procs( size_t nprocs, nprocs 465 ompi/mca/bml/r2/bml_r2.c if(0 == nprocs) { nprocs 476 ompi/mca/bml/r2/bml_r2.c for (size_t p_index = 0 ; p_index < nprocs ; ++p_index) { nprocs 484 ompi/mca/bml/r2/bml_r2.c new_procs = (struct ompi_proc_t **)malloc(nprocs * sizeof(struct ompi_proc_t *)); nprocs 499 ompi/mca/bml/r2/bml_r2.c nprocs = n_new_procs; nprocs 503 ompi/mca/bml/r2/bml_r2.c malloc(nprocs * sizeof(struct mca_btl_base_endpoint_t*)); nprocs 519 ompi/mca/bml/r2/bml_r2.c memset(btl_endpoints, 0, nprocs *sizeof(struct mca_btl_base_endpoint_t*)); nprocs 605 ompi/mca/bml/r2/bml_r2.c static int mca_bml_r2_del_procs(size_t nprocs, nprocs 608 ompi/mca/bml/r2/bml_r2.c for (size_t p = 0 ; p < nprocs ; ++p) { nprocs 438 ompi/mca/common/monitoring/common_monitoring.c size_t nprocs) nprocs 466 ompi/mca/common/monitoring/common_monitoring.c for( i = 0; i < nprocs; i++ ) { nprocs 51 ompi/mca/common/monitoring/common_monitoring.h OMPI_DECLSPEC int mca_common_monitoring_add_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 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* ); nprocs 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* ); nprocs 114 ompi/mca/crcp/base/base.h size_t nprocs, nprocs 122 ompi/mca/crcp/base/base.h size_t nprocs, nprocs 136 ompi/mca/crcp/base/crcp_base_fns.c size_t nprocs, nprocs 144 ompi/mca/crcp/base/crcp_base_fns.c size_t nprocs, nprocs 278 ompi/mca/crcp/base/crcp_base_fns.c size_t nprocs, nprocs 290 ompi/mca/crcp/base/crcp_base_fns.c size_t nprocs, nprocs 48 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c size_t nprocs, nprocs 60 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c size_t nprocs, nprocs 41 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h size_t nprocs, nprocs 49 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h size_t nprocs, nprocs 1426 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c size_t nprocs, nprocs 1448 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for( i = 0; i < nprocs; ++i) { nprocs 1464 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c size_t nprocs, nprocs 1479 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for( i = 0; i < nprocs; ++i) { nprocs 52 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h ( struct ompi_proc_t **procs, size_t nprocs, nprocs 55 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h ( struct ompi_proc_t **procs, size_t nprocs, nprocs 115 ompi/mca/crcp/crcp.h ( struct ompi_proc_t **procs, size_t nprocs , ompi_crcp_base_pml_state_t*); nprocs 117 ompi/mca/crcp/crcp.h ( struct ompi_proc_t **procs, size_t nprocs , ompi_crcp_base_pml_state_t*); nprocs 201 ompi/mca/crcp/crcp.h size_t nprocs, nprocs 209 ompi/mca/crcp/crcp.h size_t nprocs, nprocs 129 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int nprocs, nprocs 1412 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int nprocs, nprocs 1432 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for (i=0; i<nprocs; i++) nprocs 192 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c int nprocs, nprocs 225 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=1; i<nprocs; i++) { nprocs 458 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c int nprocs, nprocs 475 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c *count_my_req_per_proc_ptr = (int *) ADIOI_Calloc(nprocs,sizeof(int)); nprocs 482 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c buf_idx = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 489 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i < nprocs; i++) buf_idx[i] = -1; nprocs 531 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIOI_Malloc(nprocs*sizeof(ADIOI_Access)); nprocs 535 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i < nprocs; i++) { nprocs 605 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) { nprocs 646 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c int nprocs, int myrank, nprocs 675 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c count_others_req_per_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 688 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIOI_Malloc(nprocs*sizeof(ADIOI_Access)); nprocs 691 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c scounts = ADIOI_Malloc(nprocs*sizeof(int)); nprocs 692 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c sdispls = ADIOI_Malloc(nprocs*sizeof(int)); nprocs 693 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rcounts = ADIOI_Malloc(nprocs*sizeof(int)); nprocs 694 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rdispls = ADIOI_Malloc(nprocs*sizeof(int)); nprocs 702 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) { nprocs 738 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) nprocs 756 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) nprocs 772 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) nprocs 783 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) nprocs 796 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<nprocs; i++) nprocs 31 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.h int nprocs, nprocs 55 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.h int nprocs, nprocs 81 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.h int nprocs, int myrank, nprocs 70 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_hints.c int flag, intval, nprocs=0, nprocs_is_valid = 0; nprocs 109 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_hints.c MPI_Comm_size(fd->comm, &nprocs); nprocs 111 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_hints.c ADIOI_Snprintf(value, MPI_MAX_INFO_VAL+1, "%d", nprocs); nprocs 34 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c datatype, int nprocs, nprocs 47 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *recd_from_proc, int nprocs, nprocs 61 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *recd_from_proc, int nprocs, nprocs 75 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *recd_from_proc, int nprocs, nprocs 110 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int i, filetype_is_contig, nprocs, nprocs_for_coll, myrank; nprocs 140 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 175 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c st_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 176 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c end_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 183 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c count_sizes = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 190 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c gpfs_offsets0 = (ADIO_Offset *) ADIOI_Malloc(3*nprocs*sizeof(ADIO_Offset)); nprocs 191 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c gpfs_offsets = (ADIO_Offset *) ADIOI_Malloc(3*nprocs*sizeof(ADIO_Offset)); nprocs 192 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 200 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Allreduce( gpfs_offsets0, gpfs_offsets, nprocs*3, ADIO_OFFSET, MPI_MAX, fd->comm ); nprocs 201 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 208 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c gpfs_offsets0 = (ADIO_Offset *) ADIOI_Malloc(2*nprocs*sizeof(ADIO_Offset)); nprocs 209 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c gpfs_offsets = (ADIO_Offset *) ADIOI_Malloc(2*nprocs*sizeof(ADIO_Offset)); nprocs 210 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 217 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Allreduce( gpfs_offsets0, gpfs_offsets, nprocs*2, ADIO_OFFSET, MPI_MAX, fd->comm ); nprocs 219 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 240 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=1; i<nprocs; i++) nprocs 306 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { nprocs 321 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_GPFS_Calc_file_domains(fd, st_offsets, end_offsets, nprocs, nprocs 335 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Calc_file_domains(st_offsets, end_offsets, nprocs, nprocs 350 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_REPORT( 0, fd, myrank, nprocs) nprocs 369 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (x=0;x<(nprocs-1);x++) { nprocs 380 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_REPORT( 0, fd, myrank, nprocs) nprocs 408 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs, &count_my_req_procs, nprocs 414 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs, &count_my_req_procs, nprocs 430 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs, myrank, &count_others_req_procs, nprocs 436 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs, myrank, &count_others_req_procs, nprocs 445 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { nprocs 457 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Read_and_exch(fd, buf, datatype, nprocs, myrank, nprocs 465 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_REPORT( 0, fd, myrank, nprocs) nprocs 470 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { nprocs 501 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c datatype, int nprocs, nprocs 545 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) { nprocs 554 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 579 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c curr_offlen_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 582 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c count = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 586 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c partial_send = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 591 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c send_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 594 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 598 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recd_from_proc = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 602 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c start_pos = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 667 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) count[i] = send_size[i] = 0; nprocs 670 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { nprocs 725 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) nprocs 755 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c start_pos, partial_send, recd_from_proc, nprocs, nprocs 765 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c start_pos, partial_send, recd_from_proc, nprocs, nprocs 794 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) count[i] = send_size[i] = 0; nprocs 804 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c start_pos, partial_send, recd_from_proc, nprocs, nprocs 814 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c start_pos, partial_send, recd_from_proc, nprocs, nprocs 840 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *recd_from_proc, int nprocs, nprocs 860 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; nprocs 863 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) if (send_size[i]) nprocs_send++; nprocs 878 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 888 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char*)); nprocs 889 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 894 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 909 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { nprocs 949 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs, contig_access_count, nprocs 961 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 1023 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *recd_from_proc, int nprocs, nprocs 1049 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c curr_from_proc = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); nprocs 1050 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c done_from_proc = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); nprocs 1051 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); nprocs 1053 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) { nprocs 1121 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 1134 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *recd_from_proc, int nprocs, nprocs 1157 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) if (recv_size[i]) { nprocs_recv++; break; } nprocs 1160 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) if (send_size[i]) { nprocs_send++; break; } nprocs 1163 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c rdispls = (int *) ADIOI_Malloc( nprocs * sizeof(int) ); nprocs 1165 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { rdispls[i] = rtail; rtail += recv_size[i]; } nprocs 1169 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char *)); nprocs 1170 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { recv_buf[i] = all_recv_buf + rdispls[i]; } nprocs 1173 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c sdispls = (int *) ADIOI_Malloc( nprocs * sizeof(int) ); nprocs 1175 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { sdispls[i] = stail; stail += send_size[i]; } nprocs 1179 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) nprocs 1201 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=1; i<nprocs; i++) if(send_size[i-1]!=send_size[i]){ DBG_FPRINTF(stderr, "\t\t[%d]%2d,", i,send_size[i] ); } nprocs 1203 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=1; i<nprocs; i++) if(recv_size[i-1]!=recv_size[i]){ DBG_FPRINTF(stderr, "\t\t[%d]%2d,", i,recv_size[i] ); } nprocs 1205 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=1; i<nprocs; i++) if(sdispls[i-1]!=sdispls[i]){ DBG_FPRINTF(stderr, "\t\t[%d]%2d,", i,sdispls [i] ); } nprocs 1207 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=1; i<nprocs; i++) if(rdispls[i-1]!=rdispls[i]){ DBG_FPRINTF(stderr, "\t\t[%d]%2d,", i,rdispls [i] ); } nprocs 1235 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs, contig_access_count, nprocs 1240 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i < nprocs; i++) nprocs 243 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_tuning.c void ad_gpfs_timing_crw_report( int rw, ADIO_File fd, int myrank, int nprocs ) nprocs 96 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_tuning.h void ad_gpfs_timing_crw_report( int rw, ADIO_File fd, int myrank, int nprocs ); nprocs 43 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c datatype, int nprocs, int myrank, ADIOI_Access nprocs 54 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *sent_to_proc, int nprocs, nprocs 71 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *sent_to_proc, int nprocs, int myrank, nprocs 86 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int myrank, nprocs 97 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int myrank, nprocs 106 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int nprocs_recv, int total_elements); nprocs 128 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int i, filetype_is_contig, nprocs, nprocs_for_coll, myrank; nprocs 145 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 176 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c st_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 177 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c end_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 185 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c count_sizes = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 192 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c gpfs_offsets0 = (ADIO_Offset *) ADIOI_Malloc(3*nprocs*sizeof(ADIO_Offset)); nprocs 193 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c gpfs_offsets = (ADIO_Offset *) ADIOI_Malloc(3*nprocs*sizeof(ADIO_Offset)); nprocs 194 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 202 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Allreduce( gpfs_offsets0, gpfs_offsets, nprocs*3, ADIO_OFFSET, MPI_MAX, fd->comm ); nprocs 203 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 210 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c gpfs_offsets0 = (ADIO_Offset *) ADIOI_Malloc(2*nprocs*sizeof(ADIO_Offset)); nprocs 211 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c gpfs_offsets = (ADIO_Offset *) ADIOI_Malloc(2*nprocs*sizeof(ADIO_Offset)); nprocs 212 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 219 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Allreduce( gpfs_offsets0, gpfs_offsets, nprocs*2, ADIO_OFFSET, MPI_MAX, fd->comm ); nprocs 221 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (ii=0; ii<nprocs; ii++) { nprocs 242 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=1; i<nprocs; i++) nprocs 294 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { nprocs 312 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_GPFS_Calc_file_domains(fd, st_offsets, end_offsets, nprocs, nprocs 326 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Calc_file_domains(st_offsets, end_offsets, nprocs, nprocs 348 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c GPFSMPIO_T_CIO_REPORT( 1, fd, myrank, nprocs) nprocs 375 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c GPFSMPIO_T_CIO_REPORT( 1, fd, myrank, nprocs) nprocs 392 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0;i<(nprocs-1);i++) { nprocs 402 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c GPFSMPIO_T_CIO_REPORT( 1, fd, myrank, nprocs) nprocs 421 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, &count_my_req_procs, nprocs 427 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, &count_my_req_procs, nprocs 443 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, myrank, nprocs 448 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, myrank, nprocs 454 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) { nprocs 463 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Exch_and_write(fd, buf, datatype, nprocs, myrank, nprocs 471 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c GPFSMPIO_T_CIO_REPORT( 1, fd, myrank, nprocs) nprocs 476 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { nprocs 570 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int i, nprocs, rank; nprocs 573 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 576 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c rank_to_ionode = ADIOI_Calloc(nprocs, sizeof(int)); nprocs 612 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c datatype, int nprocs, nprocs 667 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) { nprocs 675 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) nprocs 719 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_offlen_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 722 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c count = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 726 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c partial_recv = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 731 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_size = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 735 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c recv_size = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 738 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 742 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf_idx = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 743 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 744 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c done_to_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 747 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c start_pos = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 800 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) count[i] = recv_size[i] = 0; nprocs 804 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) { nprocs 869 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 880 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 892 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) nprocs 943 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) count[i] = recv_size[i] = 0; nprocs 953 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 964 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 1008 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *sent_to_proc, int nprocs, nprocs 1037 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) if (recv_size[i]) nprocs_recv++; nprocs 1043 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c tmp_len = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 1045 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { nprocs 1068 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) sum += count[i]; nprocs 1074 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, nprocs_recv, sum); nprocs 1077 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) nprocs 1129 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) if (send_size[i]) nprocs_send++; nprocs 1144 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { nprocs 1162 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) nprocs 1173 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf = (char **) ADIOI_Malloc(nprocs*sizeof(char*)); nprocs 1174 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) nprocs 1181 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 1192 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { nprocs 1240 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) nprocs 1299 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int myrank, nprocs 1321 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) { nprocs 1396 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) nprocs 1404 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int nprocs_recv, int total_elements) nprocs 1418 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) nprocs 1531 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *sent_to_proc, int nprocs, int myrank, nprocs 1566 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) if (recv_size[i]) { nprocs_recv++; } nprocs 1568 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) if (send_size[i]) { nprocs_send++; } nprocs 1571 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c rdispls = (int *) ADIOI_Malloc( nprocs * sizeof(int) ); nprocs 1573 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { rdispls[i] = rtail; rtail += recv_size[i]; } nprocs 1579 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sdispls = (int *) ADIOI_Malloc( nprocs * sizeof(int) ); nprocs 1581 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) { sdispls[i] = stail; stail += send_size[i]; } nprocs 1586 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) nprocs 1595 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf = (char **) ADIOI_Malloc( nprocs * sizeof(char *) ); nprocs 1596 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) nprocs 1601 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 1629 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) sum += count[i]; nprocs 1634 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, nprocs_recv, sum); nprocs 1674 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c tmp_len = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 1675 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs; i++) nprocs 1712 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int myrank, nprocs 1734 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) { nprocs 1812 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i < nprocs; i++) nprocs 31 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_delete.c int myrank, nprocs; nprocs 37 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_delete.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 37 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_fcntl.c int myrank, nprocs; nprocs 41 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_fcntl.c MPI_Comm_size(fd->comm, &nprocs); nprocs 53 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_open.c int myrank, nprocs, keyfound; nprocs 58 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_open.c MPI_Comm_size(fd->comm, &nprocs); nprocs 109 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c int myrank, nprocs; nprocs 123 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c MPI_Comm_size(fd->comm, &nprocs); nprocs 196 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c int myrank,nprocs; nprocs 220 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c MPI_Comm_size(fd->comm,&nprocs); nprocs 234 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c myrank,nprocs,myname); nprocs 277 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c myrank,nprocs,myname,extent,count*btype_size); nprocs 403 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c int myrank, nprocs; nprocs 413 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_read.c MPI_Comm_size(fd->comm, &nprocs); nprocs 57 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_resize.c int myrank, nprocs; nprocs 64 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_resize.c MPI_Comm_size(fd->comm, &nprocs); nprocs 115 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c int myrank, nprocs; nprocs 129 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c MPI_Comm_size(fd->comm, &nprocs); nprocs 209 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c int myrank,nprocs; nprocs 221 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c MPI_Comm_size(fd->comm,&nprocs); nprocs 234 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname); nprocs 274 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname,extent,count*btype_size); nprocs 284 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname,count*btype_size,extent,(long long)start); nprocs 379 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c int myrank, nprocs; nprocs 389 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c MPI_Comm_size(fd->comm, &nprocs); nprocs 397 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c int myrank, nprocs; nprocs 404 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c MPI_Comm_size(fd->comm, &nprocs); nprocs 415 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname); nprocs 427 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname); nprocs 447 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname); nprocs 464 ompi/mca/io/romio321/romio/adio/ad_gridftp/ad_gridftp_write.c myrank,nprocs,myname); nprocs 28 ompi/mca/io/romio321/romio/adio/ad_gridftp/globus_routines.c int myrank,nprocs; nprocs 32 ompi/mca/io/romio321/romio/adio/ad_gridftp/globus_routines.c MPI_Comm_size(MPI_COMM_WORLD,&nprocs); nprocs 35 ompi/mca/io/romio321/romio/adio/ad_gridftp/globus_routines.c myrank,nprocs,routine,globus_object_printable_to_string(err),caller); nprocs 81 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre.h ADIO_Offset *len_list, int nprocs); nprocs 87 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre.h int *striping_info, int nprocs, nprocs 139 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c int *striping_info, int nprocs, nprocs 152 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c *count_my_req_per_proc_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 160 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c buf_idx = (int **) ADIOI_Malloc(nprocs * sizeof(int*)); nprocs 202 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c for (i = 0; i < nprocs; i++) { nprocs 209 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c *my_req_ptr = (ADIOI_Access *) ADIOI_Malloc(nprocs * sizeof(ADIOI_Access)); nprocs 213 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c for (i = 0; i < nprocs; i++) { nprocs 277 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c for (i = 0; i < nprocs; i++) { nprocs 294 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c ADIO_Offset *len_list, int nprocs) nprocs 16 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Datatype datatype, int nprocs, nprocs 31 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *sent_to_proc, int nprocs, nprocs 46 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *sent_to_proc, int nprocs, nprocs 60 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int nprocs, int nprocs_recv, int total_elements); nprocs 82 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int i, filetype_is_contig, nprocs, myrank, do_collect = 0; nprocs 91 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 113 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c st_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs * sizeof(ADIO_Offset)); nprocs 114 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c end_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs * sizeof(ADIO_Offset)); nprocs 120 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 1; i < nprocs; i++) nprocs 135 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c len_list, nprocs); nprocs 177 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c striping_info, nprocs, &count_my_req_procs, nprocs 190 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c my_req, nprocs, myrank, &count_others_req_procs, nprocs 195 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_LUSTRE_Exch_and_write(fd, buf, datatype, nprocs, myrank, nprocs 241 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 250 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 257 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 287 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Datatype datatype, int nprocs, nprocs 338 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 345 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 378 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 386 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_curr_offlen_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 387 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_curr_offlen_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 390 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_count = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 394 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 398 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 401 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c sent_to_proc = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 405 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_buf_idx = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 406 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c curr_to_proc = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 407 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c done_to_proc = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 410 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c this_buf_idx = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 412 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_start_pos = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 470 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 479 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 516 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 527 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 621 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *sent_to_proc, int nprocs, nprocs 645 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 654 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 672 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 685 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c nprocs, nprocs_recv, *srt_num); nprocs 703 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 726 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 742 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 758 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 769 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char *)); nprocs 770 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 776 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c sent_to_proc, nprocs, myrank, nprocs 786 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 830 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 891 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *sent_to_proc, int nprocs, nprocs 913 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) { nprocs 983 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs; i++) nprocs 13 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_close.c int myrank, nprocs; nprocs 18 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_close.c MPI_Comm_size(fd->comm, &nprocs); nprocs 21 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_close.c nprocs, fd->filename); nprocs 13 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_delete.c int myrank, nprocs; nprocs 17 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_delete.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_delete.c myrank, nprocs, filename); nprocs 14 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_done.c int myrank, nprocs; nprocs 18 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_done.c MPI_Comm_size( MPI_COMM_WORLD, &nprocs ); nprocs 21 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_done.c myrank, nprocs); nprocs 29 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_done.c int myrank, nprocs; nprocs 33 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_done.c MPI_Comm_size( MPI_COMM_WORLD, &nprocs ); nprocs 37 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_done.c myrank, nprocs); nprocs 15 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_fcntl.c int myrank, nprocs; nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_fcntl.c MPI_Comm_size(fd->comm, &nprocs); nprocs 23 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_fcntl.c myrank, nprocs, fd->filename); nprocs 13 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_flush.c int myrank, nprocs; nprocs 17 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_flush.c MPI_Comm_size(fd->comm, &nprocs); nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_flush.c myrank, nprocs, fd->filename); nprocs 15 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_getsh.c int myrank, nprocs; nprocs 19 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_getsh.c MPI_Comm_size(fd->comm, &nprocs); nprocs 22 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_getsh.c myrank, nprocs, fd->filename); nprocs 15 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_hints.c int myrank, nprocs; nprocs 19 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_hints.c MPI_Comm_size(fd->comm, &nprocs); nprocs 22 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_hints.c myrank, nprocs, fd->filename); nprocs 24 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_hints.c myrank, nprocs); nprocs 21 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c int myrank, nprocs; nprocs 26 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c MPI_Comm_size(fd->comm, &nprocs); nprocs 30 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c myrank, nprocs, fd->filename); nprocs 32 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c myrank, nprocs); nprocs 47 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c int myrank, nprocs; nprocs 50 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c MPI_Comm_size(fd->comm, &nprocs); nprocs 54 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c myrank, nprocs, fd->filename); nprocs 56 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iread.c myrank, nprocs); nprocs 24 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c int myrank, nprocs; nprocs 30 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c MPI_Comm_size(fd->comm, &nprocs); nprocs 33 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c myrank, nprocs, fd->filename); nprocs 35 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c myrank, nprocs); nprocs 50 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c int myrank, nprocs; nprocs 55 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c MPI_Comm_size(fd->comm, &nprocs); nprocs 60 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c myrank, nprocs, fd->filename); nprocs 62 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_iwrite.c myrank, nprocs); nprocs 13 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_open.c int myrank, nprocs; nprocs 19 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_open.c MPI_Comm_size(fd->comm, &nprocs); nprocs 22 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_open.c nprocs, fd->filename); nprocs 16 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_rdcoll.c int myrank, nprocs; nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_rdcoll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 23 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_rdcoll.c myrank, nprocs, fd->filename); nprocs 25 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_rdcoll.c myrank, nprocs); nprocs 15 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c int myrank, nprocs; nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c MPI_Comm_size(fd->comm, &nprocs); nprocs 24 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c nprocs, fd->filename); nprocs 36 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c myrank, nprocs, buf, (long long) offset, nprocs 49 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c int myrank, nprocs; nprocs 53 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c MPI_Comm_size(fd->comm, &nprocs); nprocs 56 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c nprocs, fd->filename); nprocs 58 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_read.c nprocs); nprocs 13 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_resize.c int myrank, nprocs; nprocs 17 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_resize.c MPI_Comm_size(fd->comm, &nprocs); nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_resize.c myrank, nprocs, fd->filename); nprocs 24 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_seek.c int myrank, nprocs; nprocs 37 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_seek.c MPI_Comm_size(fd->comm, &nprocs); nprocs 40 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_seek.c myrank, nprocs, fd->filename); nprocs 14 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_setsh.c int myrank, nprocs; nprocs 18 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_setsh.c MPI_Comm_size(fd->comm, &nprocs); nprocs 21 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_setsh.c myrank, nprocs, fd->filename); nprocs 14 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wait.c int myrank, nprocs; nprocs 18 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wait.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 21 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wait.c myrank, nprocs); nprocs 29 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wait.c int myrank, nprocs; nprocs 33 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wait.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 36 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wait.c myrank, nprocs); nprocs 16 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wrcoll.c int myrank, nprocs; nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wrcoll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 23 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wrcoll.c myrank, nprocs, fd->filename); nprocs 25 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_wrcoll.c myrank, nprocs); nprocs 15 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c int myrank, nprocs; nprocs 20 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c MPI_Comm_size(fd->comm, &nprocs); nprocs 24 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c nprocs, fd->filename); nprocs 26 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c myrank, nprocs, buf, (long long) offset, nprocs 34 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c nprocs, (long long) fd->fp_ind); nprocs 50 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c int myrank, nprocs; nprocs 54 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c MPI_Comm_size(fd->comm, &nprocs); nprocs 57 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c myrank, nprocs, fd->filename); nprocs 59 ompi/mca/io/romio321/romio/adio/ad_testfs/ad_testfs_write.c myrank, nprocs); nprocs 128 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c *end_offsets, int nprocs, int nprocs_for_coll, nprocs 156 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=1; i<nprocs; i++) { nprocs 258 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int nprocs, nprocs 275 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c *count_my_req_per_proc_ptr = (int *) ADIOI_Calloc(nprocs,sizeof(int)); nprocs 282 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c buf_idx = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 289 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i < nprocs; i++) buf_idx[i] = -1; nprocs 330 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Malloc(nprocs*sizeof(ADIOI_Access)); nprocs 334 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i < nprocs; i++) { nprocs 402 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i<nprocs; i++) { nprocs 427 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int nprocs, int myrank, nprocs 449 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c count_others_req_per_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 455 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Malloc(nprocs*sizeof(ADIOI_Access)); nprocs 459 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i<nprocs; i++) { nprocs 480 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i<nprocs; i++) { nprocs 491 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i < nprocs; i++) { nprocs 533 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c (int *)ADIOI_Malloc(vars->nprocs * sizeof(int)); nprocs 553 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int nprocs = vars->nprocs; nprocs 570 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c *others_req_ptr = (ADIOI_Access *)ADIOI_Malloc(nprocs*sizeof(ADIOI_Access)); nprocs 574 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i = 0; i < nprocs; i++) { nprocs 597 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i = 0; i < nprocs; i++) { nprocs 608 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c for (i=0; i < nprocs; i++) { nprocs 207 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c int nprocs, nprocs 217 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 450 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c int ADIOI_Build_agg_reqs(ADIO_File fd, int rw_type, int nprocs, nprocs 481 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c memset(client_comm_sz_arr, 0, nprocs*sizeof(ADIO_Offset)); nprocs 484 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c ADIOI_Malloc(nprocs*sizeof(ADIO_Offset))) == NULL) nprocs 491 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if ((client_ol_ct_arr = (int *) ADIOI_Calloc(nprocs, sizeof(int))) == NULL) nprocs 498 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c (int *) ADIOI_Calloc(nprocs, sizeof(int))) == NULL) nprocs 513 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c memset(client_comm_next_off_arr, -1, nprocs*sizeof(ADIO_Offset)); nprocs 518 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c ADIOI_Heap_create(&offset_heap, nprocs); nprocs 521 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (j=0; j<nprocs; j++) { nprocs 708 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c ADIOI_Malloc(nprocs*sizeof(MPI_Aint *))) == NULL) nprocs 715 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c nprocs*sizeof(int *))) == NULL) nprocs 722 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (j = 0; j < nprocs; j++) nprocs 766 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 778 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 786 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 799 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 803 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if (i != nprocs - 1) nprocs 813 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 843 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 888 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c int nprocs, nprocs 919 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 933 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c nprocs*sizeof(ADIO_Offset))) == NULL) nprocs 941 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c ADIOI_Malloc(nprocs*sizeof(ADIO_Offset))) == NULL) nprocs 947 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if ((agg_ol_ct_arr = (int *) ADIOI_Calloc(nprocs, sizeof(int))) nprocs 954 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if ((agg_ol_cur_ct_arr = (int *) ADIOI_Calloc(nprocs, sizeof(int))) nprocs 962 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 976 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c memset(agg_comm_cur_sz_arr, 0, nprocs*sizeof(ADIO_Offset)); nprocs 977 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c memset(agg_mem_next_off_arr, -1, nprocs*sizeof(ADIO_Offset)); nprocs 983 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (j = 0; j < nprocs; j++) nprocs 1132 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c ADIOI_Malloc(nprocs*sizeof(MPI_Aint *))) == NULL) nprocs 1138 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if ((agg_blk_arr = (int **) ADIOI_Malloc(nprocs*sizeof(int *))) nprocs 1146 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (j = 0; j < nprocs; j++) nprocs 1169 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 1185 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 1202 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c for (i = 0; i < nprocs; i++) nprocs 109 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c void ADIOI_Exch_file_views(int myrank, int nprocs, int file_ptr_type, nprocs 178 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c recv_count_arr = ADIOI_Calloc(nprocs, sizeof(amount_and_extra_data_t)); nprocs 179 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c send_count_arr = ADIOI_Calloc(nprocs, sizeof(amount_and_extra_data_t)); nprocs 186 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c recv_count_arr = ADIOI_Calloc(nprocs, nprocs 188 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c recv_req_arr = ADIOI_Malloc (nprocs * sizeof(MPI_Request)); nprocs 189 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i=0; i < nprocs; i++) nprocs 296 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c statuses = (MPI_Status *) ADIOI_Malloc(1 + nprocs * sizeof(MPI_Status)); nprocs 298 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c MPI_Waitall(nprocs, recv_req_arr, statuses); nprocs 308 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) nprocs 314 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) nprocs 328 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) nprocs 343 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) nprocs 389 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) { nprocs 405 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) { nprocs 456 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c nprocs, nprocs 460 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c nprocs, nprocs 469 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) nprocs 495 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < nprocs; i++) nprocs 11 ompi/mca/io/romio321/romio/adio/common/ad_darray.c static int MPIOI_Type_block(int *array_of_gsizes, int dim, int ndims, int nprocs, nprocs 15 ompi/mca/io/romio321/romio/adio/common/ad_darray.c static int MPIOI_Type_cyclic(int *array_of_gsizes, int dim, int ndims, int nprocs, nprocs 147 ompi/mca/io/romio321/romio/adio/common/ad_darray.c static int MPIOI_Type_block(int *array_of_gsizes, int dim, int ndims, int nprocs, nprocs 160 ompi/mca/io/romio321/romio/adio/common/ad_darray.c blksize = (global_size + nprocs - 1)/nprocs; nprocs 169 ompi/mca/io/romio321/romio/adio/common/ad_darray.c if (blksize * nprocs < global_size) { nprocs 209 ompi/mca/io/romio321/romio/adio/common/ad_darray.c static int MPIOI_Type_cyclic(int *array_of_gsizes, int dim, int ndims, int nprocs, nprocs 234 ompi/mca/io/romio321/romio/adio/common/ad_darray.c local_size = ((end_index - st_index + 1)/(nprocs*blksize))*blksize; nprocs 235 ompi/mca/io/romio321/romio/adio/common/ad_darray.c rem = (end_index - st_index + 1) % (nprocs*blksize); nprocs 242 ompi/mca/io/romio321/romio/adio/common/ad_darray.c stride = (MPI_Aint)nprocs*(MPI_Aint)blksize*orig_extent; nprocs 22 ompi/mca/io/romio321/romio/adio/common/ad_hints.c int flag, nprocs=0, len; nprocs 38 ompi/mca/io/romio321/romio/adio/common/ad_hints.c MPI_Comm_size(fd->comm, &nprocs); nprocs 75 ompi/mca/io/romio321/romio/adio/common/ad_hints.c ADIOI_Snprintf(value, MPI_MAX_INFO_VAL+1, "%d", nprocs); nprocs 77 ompi/mca/io/romio321/romio/adio/common/ad_hints.c fd->hints->cb_nodes = nprocs; nprocs 214 ompi/mca/io/romio321/romio/adio/common/ad_hints.c if ((fd->hints->cb_nodes <= 0) || (fd->hints->cb_nodes > nprocs)) { nprocs 218 ompi/mca/io/romio321/romio/adio/common/ad_hints.c ADIOI_Snprintf(value, MPI_MAX_INFO_VAL+1, "%d", nprocs); nprocs 220 ompi/mca/io/romio321/romio/adio/common/ad_hints.c fd->hints->cb_nodes = nprocs; nprocs 21 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c static void Exch_data_amounts (ADIO_File fd, int nprocs, nprocs 54 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c int interleave_count = 0, i, nprocs, myrank, nprocs_for_coll; nprocs 96 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c MPI_Comm_size (fd->comm, &nprocs); nprocs 130 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Malloc (2*nprocs*sizeof(ADIO_Offset)); nprocs 137 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=1; i<nprocs; i++) { nprocs 207 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (1, nprocs * sizeof(view_state)); nprocs 209 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (1, nprocs * sizeof(view_state)); nprocs 211 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (1, nprocs * sizeof(ADIO_Offset)); nprocs 215 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (1, nprocs * sizeof(view_state)); nprocs 224 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (1, nprocs * sizeof(MPI_Datatype)); nprocs 226 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i < nprocs; i++) nprocs 229 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Exch_file_views (myrank, nprocs, file_ptr_type, fd, count, nprocs 235 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (1, nprocs * sizeof(ADIO_Offset)); nprocs 237 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Malloc (nprocs * sizeof(MPI_Datatype)); nprocs 239 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Build_agg_reqs (fd, rdwr, nprocs, nprocs 246 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i <nprocs; i++) { nprocs 279 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c alltoallw_disps = (int *) ADIOI_Calloc (nprocs, sizeof(int)); nprocs 281 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (2*nprocs, sizeof(int)); nprocs 282 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c agg_alltoallw_counts = &alltoallw_counts[nprocs]; nprocs 287 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c post_aggregator_comm(fd->comm, rdwr, nprocs, cb_buf, nprocs 294 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c Exch_data_amounts (fd, nprocs, client_comm_sz_arr, agg_comm_sz_arr, nprocs 300 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) { nprocs 305 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) { nprocs 360 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i < nprocs; i++) { nprocs 364 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c if (i != nprocs - 1) nprocs 370 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i < nprocs; i++) { nprocs 378 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c if (i != nprocs - 1) nprocs 387 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c post_aggregator_comm(fd->comm, rdwr, nprocs, cb_buf, nprocs 435 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i < nprocs; i++) { nprocs 439 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c if (i != nprocs - 1) nprocs 444 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i < nprocs; i++) { nprocs 452 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c if (i != nprocs - 1) nprocs 512 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Build_client_reqs(fd, nprocs, my_mem_view_state_arr, nprocs 562 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) { nprocs 568 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) { nprocs 575 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Build_agg_reqs (fd, rdwr, nprocs, nprocs 582 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i <nprocs; i++) { nprocs 615 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c post_aggregator_comm(fd->comm, rdwr, nprocs, cb_buf, nprocs 623 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c Exch_data_amounts (fd, nprocs, client_comm_sz_arr, agg_comm_sz_arr, nprocs 658 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) { nprocs 667 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i<nprocs; i++) nprocs 982 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c static void Exch_data_amounts (ADIO_File fd, int nprocs, nprocs 1002 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) nprocs 1009 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<nprocs; i++) { nprocs 1034 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c send_requests = ADIOI_Malloc (nprocs * sizeof(MPI_Request)); nprocs 1037 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i < nprocs; i++) { nprocs 1062 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c send_statuses = ADIOI_Malloc (nprocs * sizeof (MPI_Status)); nprocs 1063 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c MPI_Waitall (nprocs, send_requests, send_statuses); nprocs 44 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs; nprocs 77 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs; nprocs 137 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs; nprocs 165 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *recd_from_proc, int nprocs, nprocs 214 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs, myrank; nprocs 254 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 256 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs = nprocs; nprocs 287 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->st_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 288 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->end_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 309 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; nprocs 315 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 1; i < nprocs; i++) nprocs 339 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs; nprocs 402 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs = vars->nprocs; nprocs 420 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Calc_file_domains(vars->st_offsets, vars->end_offsets, nprocs, nprocs 441 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs, &vars->count_my_req_procs, nprocs 460 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->nprocs = vars->nprocs; nprocs 475 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; nprocs 482 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) { nprocs 499 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->nprocs = vars->nprocs; nprocs 522 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; nprocs 528 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) { nprocs 579 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; nprocs 609 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) { nprocs 618 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) nprocs 647 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->curr_offlen_ptr = (int *)ADIOI_Calloc(nprocs, sizeof(int)); nprocs 650 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->count = (int *)ADIOI_Malloc(nprocs * sizeof(int)); nprocs 654 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->partial_send = (int *)ADIOI_Calloc(nprocs, sizeof(int)); nprocs 659 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->send_size = (int *)ADIOI_Malloc(nprocs * sizeof(int)); nprocs 662 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_size = (int *)ADIOI_Malloc(nprocs * sizeof(int)); nprocs 666 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recd_from_proc = (int *)ADIOI_Calloc(nprocs, sizeof(int)); nprocs 670 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->start_pos = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 693 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs; nprocs 713 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs = vars->nprocs; nprocs 768 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) count[i] = send_size[i] = 0; nprocs 771 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) { nprocs 824 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) nprocs 842 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->nprocs = vars->nprocs; nprocs 913 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; nprocs 918 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) count[i] = send_size[i] = 0; nprocs 951 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->nprocs = vars->nprocs; nprocs 1023 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; nprocs 1034 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; nprocs 1038 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) if (send_size[i]) nprocs_send++; nprocs 1054 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) nprocs 1065 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char*)); nprocs 1067 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) nprocs 1071 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) nprocs 1087 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) { nprocs 1130 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs, vars->contig_access_count, nprocs 1147 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < vars->nprocs; i++) nprocs 42 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs; nprocs 78 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs; nprocs 143 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs; nprocs 180 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs, int myrank, nprocs 189 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs, int nprocs_recv, int total_elements); nprocs 237 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs, myrank; nprocs 277 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 279 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs = nprocs; nprocs 305 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->st_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 306 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->end_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 327 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 333 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 1; i < nprocs; i++) nprocs 357 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs; nprocs 422 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs = vars->nprocs; nprocs 428 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Calc_file_domains(vars->st_offsets, vars->end_offsets, nprocs, nprocs 440 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs, &vars->count_my_req_procs, nprocs 458 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->nprocs = vars->nprocs; nprocs 473 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 477 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 493 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->nprocs = vars->nprocs; nprocs 556 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 574 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 627 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 659 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 667 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) nprocs 690 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->curr_offlen_ptr = (int *)ADIOI_Calloc(nprocs, sizeof(int)); nprocs 693 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->count = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 697 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->partial_recv = (int *)ADIOI_Calloc(nprocs, sizeof(int)); nprocs 702 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_size = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 706 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->recv_size = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 709 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->sent_to_proc = (int *)ADIOI_Calloc(nprocs, sizeof(int)); nprocs 713 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_buf_idx = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 714 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->curr_to_proc = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 715 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->done_to_proc = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 718 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->start_pos = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 751 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs; nprocs 770 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs = vars->nprocs; nprocs 798 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) count[i] = recv_size[i] = 0; nprocs 804 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 880 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->nprocs = vars->nprocs; nprocs 906 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 913 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) nprocs 954 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 959 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) count[i] = recv_size[i] = 0; nprocs 999 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->nprocs = vars->nprocs; nprocs 1081 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 1093 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; nprocs 1101 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c tmp_len = (int *)ADIOI_Malloc(nprocs*sizeof(int)); nprocs 1103 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 1126 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) sum += count[i]; nprocs 1134 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs, nprocs_recv, sum); nprocs 1138 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) nprocs 1195 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 1208 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) if (send_size[i]) nprocs_send++; nprocs 1224 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 1242 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) nprocs 1253 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c send_buf = (char **)ADIOI_Malloc(nprocs*sizeof(char*)); nprocs 1255 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) nprocs 1262 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->sent_to_proc, nprocs, myrank, nprocs 1279 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) { nprocs 1330 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; nprocs 1341 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) nprocs 20 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c datatype, int nprocs, nprocs 33 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int *recd_from_proc, int nprocs, nprocs 47 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int *recd_from_proc, int nprocs, nprocs 74 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int i, filetype_is_contig, nprocs, nprocs_for_coll, myrank; nprocs 94 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 124 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c st_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 125 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c end_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 133 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=1; i<nprocs; i++) nprocs 188 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Calc_file_domains(st_offsets, end_offsets, nprocs, nprocs 208 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c nprocs, &count_my_req_procs, nprocs 221 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c nprocs, myrank, &count_others_req_procs, nprocs 228 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) { nprocs 240 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Read_and_exch(fd, buf, datatype, nprocs, myrank, nprocs 248 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) { nprocs 498 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c datatype, int nprocs, nprocs 540 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) { nprocs 549 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) nprocs 574 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c curr_offlen_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 577 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c count = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 581 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c partial_send = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 586 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c send_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 589 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recv_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); nprocs 593 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recd_from_proc = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 597 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c start_pos = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 655 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) count[i] = send_size[i] = 0; nprocs 658 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) { nprocs 713 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) nprocs 727 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c start_pos, partial_send, recd_from_proc, nprocs, nprocs 751 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) count[i] = send_size[i] = 0; nprocs 756 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c start_pos, partial_send, recd_from_proc, nprocs, nprocs 776 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int *recd_from_proc, int nprocs, nprocs 796 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; nprocs 799 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) if (send_size[i]) nprocs_send++; nprocs 814 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) nprocs 824 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char*)); nprocs 825 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) nprocs 830 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) nprocs 845 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i<nprocs; i++) { nprocs 885 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c nprocs, contig_access_count, nprocs 897 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) nprocs 959 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int *recd_from_proc, int nprocs, nprocs 985 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c curr_from_proc = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); nprocs 986 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c done_from_proc = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); nprocs 987 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); nprocs 989 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) { nprocs 1057 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) nprocs 17 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c datatype, int nprocs, int myrank, nprocs 29 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *sent_to_proc, int nprocs, nprocs 42 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int nprocs, int myrank, nprocs 51 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int nprocs, int nprocs_recv, int total_elements); nprocs 73 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int i, filetype_is_contig, nprocs, nprocs_for_coll, myrank; nprocs 91 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c MPI_Comm_size(fd->comm, &nprocs); nprocs 116 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c st_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 117 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c end_offsets = (ADIO_Offset *) ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); nprocs 125 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=1; i<nprocs; i++) nprocs 169 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Calc_file_domains(st_offsets, end_offsets, nprocs, nprocs 181 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs, &count_my_req_procs, nprocs 194 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs, myrank, nprocs 198 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) { nprocs 208 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Exch_and_write(fd, (char *) buf, datatype, nprocs, myrank, nprocs 255 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) { nprocs 296 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c datatype, int nprocs, nprocs 343 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) { nprocs 351 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) nprocs 371 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_offlen_ptr = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 374 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c count = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 378 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c partial_recv = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 383 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c send_size = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 387 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c recv_size = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 390 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c sent_to_proc = (int *) ADIOI_Calloc(nprocs, sizeof(int)); nprocs 394 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c send_buf_idx = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 395 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_to_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 396 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c done_to_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 399 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c start_pos = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 442 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) count[i] = recv_size[i] = 0; nprocs 446 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) { nprocs 506 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c sent_to_proc, nprocs, myrank, nprocs 515 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) nprocs 529 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) count[i] = recv_size[i] = 0; nprocs 536 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c sent_to_proc, nprocs, myrank, nprocs 567 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *sent_to_proc, int nprocs, nprocs 596 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) if (recv_size[i]) nprocs_recv++; nprocs 602 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c tmp_len = (int *) ADIOI_Malloc(nprocs*sizeof(int)); nprocs 604 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) { nprocs 627 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) sum += count[i]; nprocs 635 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs, nprocs_recv, sum); nprocs 639 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) nprocs 692 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) if (send_size[i]) nprocs_send++; nprocs 707 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) { nprocs 725 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) nprocs 736 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c send_buf = (char **) ADIOI_Malloc(nprocs*sizeof(char*)); nprocs 737 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) nprocs 744 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c sent_to_proc, nprocs, myrank, nprocs 755 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) { nprocs 803 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) nprocs 865 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int nprocs, int myrank, nprocs 887 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) { nprocs 963 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) nprocs 971 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int nprocs, int nprocs_recv, int total_elements) nprocs 985 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) nprocs 44 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c int rank,nprocs; nprocs 71 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c MPI_Comm_size(fd->comm, &nprocs); nprocs 114 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c rank, nprocs, off, nprocs 140 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c rank, nprocs, off, nprocs 173 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c rank, nprocs, off, nprocs 274 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c rank, nprocs, off, fwr_size); nprocs 325 ompi/mca/io/romio321/romio/adio/common/ad_write_nolock.c rank, nprocs, off, size); nprocs 231 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int nprocs,myrank; nprocs 232 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Comm_size(fd->comm, &nprocs); nprocs 242 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_OneSidedSetup(fd, nprocs); nprocs 781 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<nprocs;i++) nprocs 1085 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<nprocs;i++) { nprocs 1263 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int nprocs,myrank; nprocs 1264 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Comm_size(fd->comm, &nprocs); nprocs 1274 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_OneSidedSetup(fd, nprocs); nprocs 35 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int nprocs,myrank; nprocs 36 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Comm_size(fd->comm, &nprocs); nprocs 95 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<nprocs;i++) nprocs 107 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<nprocs;i++) { nprocs 153 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset numberOfRounds = (ADIO_Offset)((((ADIO_Offset)(end_offsets[nprocs-1]-st_offsets[0]))/((ADIO_Offset)((ADIO_Offset)coll_bufsize*(ADIO_Offset)naggs)))) + 1; nprocs 510 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int nprocs,myrank; nprocs 511 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Comm_size(fd->comm, &nprocs); nprocs 569 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<nprocs;i++) nprocs 587 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<nprocs;i++) { nprocs 620 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset numberOfRounds = (ADIO_Offset)((((ADIO_Offset)(end_offsets[nprocs-1]-st_offsets[0]))/((ADIO_Offset)((ADIO_Offset)coll_bufsize*(ADIO_Offset)naggs)))) + 1; nprocs 476 ompi/mca/io/romio321/romio/adio/include/adioi.h *end_offsets, int nprocs, int nprocs_for_coll, nprocs 494 ompi/mca/io/romio321/romio/adio/include/adioi.h int nprocs, nprocs 502 ompi/mca/io/romio321/romio/adio/include/adioi.h int nprocs, int myrank, nprocs 557 ompi/mca/io/romio321/romio/adio/include/adioi.h int nprocs; nprocs 661 ompi/mca/io/romio321/romio/adio/include/adioi.h void ADIOI_Exch_file_views(int myrank, int nprocs, int file_ptr_type, nprocs 668 ompi/mca/io/romio321/romio/adio/include/adioi.h int nprocs, nprocs 671 ompi/mca/io/romio321/romio/adio/include/adioi.h int ADIOI_Build_agg_reqs(ADIO_File fd, int rw_type, int nprocs, nprocs 678 ompi/mca/io/romio321/romio/adio/include/adioi.h int nprocs, nprocs 48 ompi/mca/io/romio321/romio/mpi-io/read_ord.c int error_code, nprocs, myrank; nprocs 76 ompi/mca/io/romio321/romio/mpi-io/read_ord.c MPI_Comm_size(adio_fh->comm, &nprocs); nprocs 85 ompi/mca/io/romio321/romio/mpi-io/read_ord.c if (dest >= nprocs) dest = MPI_PROC_NULL; nprocs 45 ompi/mca/io/romio321/romio/mpi-io/read_ordb.c int error_code, nprocs, myrank; nprocs 84 ompi/mca/io/romio321/romio/mpi-io/read_ordb.c MPI_Comm_size(adio_fh->comm, &nprocs); nprocs 92 ompi/mca/io/romio321/romio/mpi-io/read_ordb.c if (dest >= nprocs) dest = MPI_PROC_NULL; nprocs 49 ompi/mca/io/romio321/romio/mpi-io/write_ord.c int error_code, nprocs, myrank; nprocs 79 ompi/mca/io/romio321/romio/mpi-io/write_ord.c MPI_Comm_size(adio_fh->comm, &nprocs); nprocs 87 ompi/mca/io/romio321/romio/mpi-io/write_ord.c if (dest >= nprocs) dest = MPI_PROC_NULL; nprocs 45 ompi/mca/io/romio321/romio/mpi-io/write_ordb.c int error_code, nprocs, myrank; nprocs 85 ompi/mca/io/romio321/romio/mpi-io/write_ordb.c MPI_Comm_size(adio_fh->comm, &nprocs); nprocs 93 ompi/mca/io/romio321/romio/mpi-io/write_ordb.c if (dest >= nprocs) dest = MPI_PROC_NULL; nprocs 21 ompi/mca/io/romio321/romio/test/atomicity.c int *writebuf, *readbuf, i, mynod, nprocs, len, err; nprocs 31 ompi/mca/io/romio321/romio/test/atomicity.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 25 ompi/mca/io/romio321/romio/test/coll_perf.c int order, nprocs, len, *buf, mynod; nprocs 36 ompi/mca/io/romio321/romio/test/coll_perf.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 80 ompi/mca/io/romio321/romio/test/coll_perf.c MPI_Dims_create(nprocs, ndims, array_of_psizes); nprocs 82 ompi/mca/io/romio321/romio/test/coll_perf.c MPI_Type_create_darray(nprocs, mynod, ndims, array_of_gsizes, nprocs 36 ompi/mca/io/romio321/romio/test/coll_test.c int order, nprocs, j, len; nprocs 50 ompi/mca/io/romio321/romio/test/coll_test.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 95 ompi/mca/io/romio321/romio/test/coll_test.c MPI_Dims_create(nprocs, ndims, array_of_psizes); nprocs 97 ompi/mca/io/romio321/romio/test/coll_test.c MPI_Type_create_darray(nprocs, mynod, ndims, array_of_gsizes, nprocs 74 ompi/mca/io/romio321/romio/test/creat_excl.c int nprocs, mynod, errcode; nprocs 81 ompi/mca/io/romio321/romio/test/creat_excl.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 67 ompi/mca/io/romio321/romio/test/file_info.c int i, len, nkeys, flag, mynod, default_striping_factor=0, nprocs, errs = 0; nprocs 77 ompi/mca/io/romio321/romio/test/file_info.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 242 ompi/mca/io/romio321/romio/test/file_info.c sprintf(value, "%d", nprocs/2); nprocs 19 ompi/mca/io/romio321/romio/test/i_noncontig.c int *buf, i, mynod, nprocs, len, b[3]; nprocs 29 ompi/mca/io/romio321/romio/test/i_noncontig.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 32 ompi/mca/io/romio321/romio/test/i_noncontig.c if (nprocs != 2) { nprocs 24 ompi/mca/io/romio321/romio/test/large_array.c int order, nprocs, len, flag, err; nprocs 36 ompi/mca/io/romio321/romio/test/large_array.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 79 ompi/mca/io/romio321/romio/test/large_array.c MPI_Dims_create(nprocs, ndims, array_of_psizes); nprocs 93 ompi/mca/io/romio321/romio/test/large_array.c MPI_Type_create_darray(nprocs, mynod, ndims, array_of_gsizes, nprocs 18 ompi/mca/io/romio321/romio/test/noncontig.c int *buf, i, mynod, nprocs, len, b[3]; nprocs 28 ompi/mca/io/romio321/romio/test/noncontig.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 31 ompi/mca/io/romio321/romio/test/noncontig.c if (nprocs != 2) { nprocs 18 ompi/mca/io/romio321/romio/test/noncontig_coll.c int *buf, i, mynod, nprocs, len, b[3]; nprocs 27 ompi/mca/io/romio321/romio/test/noncontig_coll.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 30 ompi/mca/io/romio321/romio/test/noncontig_coll.c if (nprocs != 2) { nprocs 25 ompi/mca/io/romio321/romio/test/noncontig_coll2.c int test_file(char *filename, int mynod, int nprocs, char * cb_hosts, nprocs 255 ompi/mca/io/romio321/romio/test/noncontig_coll2.c int i, mynod, nprocs, len, errs=0, sum_errs=0, verbose=0; nprocs 263 ompi/mca/io/romio321/romio/test/noncontig_coll2.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 319 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errs += test_file(filename, mynod, nprocs, NULL, "collective w/o hinting", verbose); nprocs 323 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errs += test_file(filename, mynod, nprocs, cb_config_string, "collective w/ hinting: default order", verbose); nprocs 327 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errs += test_file(filename, mynod, nprocs, cb_config_string, "collective w/ hinting: reverse order", verbose); nprocs 331 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errs += test_file(filename, mynod, nprocs, cb_config_string,"collective w/ hinting: permutation1", verbose); nprocs 335 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errs += test_file(filename, mynod, nprocs, cb_config_string, "collective w/ hinting: permutation2", verbose); nprocs 351 ompi/mca/io/romio321/romio/test/noncontig_coll2.c int test_file(char *filename, int mynod, int nprocs, char * cb_hosts, const char *msg, int verbose) nprocs 358 ompi/mca/io/romio321/romio/test/noncontig_coll2.c int SIZE = (STARTING_SIZE/nprocs)*nprocs; nprocs 377 ompi/mca/io/romio321/romio/test/noncontig_coll2.c MPI_Type_vector(SIZE/nprocs, 1, nprocs, MPI_INT, &typevec); nprocs 438 ompi/mca/io/romio321/romio/test/noncontig_coll2.c if ( ((i-mynod)%nprocs) && buf[i] != -1) { nprocs 443 ompi/mca/io/romio321/romio/test/noncontig_coll2.c if ( !((i-mynod)%nprocs) && buf[i] != SEEDER(mynod,i,SIZE) ) { nprocs 463 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errcode = MPI_File_write_at_all(fh, mynod*(SIZE/nprocs)*sizeof(int), nprocs 472 ompi/mca/io/romio321/romio/test/noncontig_coll2.c errcode = MPI_File_read_at_all(fh, mynod*(SIZE/nprocs)*sizeof(int), nprocs 485 ompi/mca/io/romio321/romio/test/noncontig_coll2.c if ( ((i-mynod)%nprocs) && buf[i] != -1) { nprocs 490 ompi/mca/io/romio321/romio/test/noncontig_coll2.c if ( !((i-mynod)%nprocs) && buf[i] != SEEDER(mynod,i,SIZE)) { nprocs 29 ompi/mca/io/romio321/romio/test/ordered_fp.c int *buf, i, rank, nprocs, len, sum; nprocs 70 ompi/mca/io/romio321/romio/test/ordered_fp.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 119 ompi/mca/io/romio321/romio/test/ordered_fp.c if (global_sum != (((COUNT*nprocs - 1)*(COUNT*nprocs))/2)) { nprocs 122 ompi/mca/io/romio321/romio/test/ordered_fp.c sum, global_sum,(((COUNT*nprocs - 1)*(COUNT*nprocs))/2)); nprocs 137 ompi/mca/io/romio321/romio/test/ordered_fp.c nprocs, COUNT*sizeof(int), wr_sumtime, rd_sumtime); nprocs 18 ompi/mca/io/romio321/romio/test/perf.c int *buf, i, j, mynod, nprocs, ntimes=5, len, err, flag; nprocs 26 ompi/mca/io/romio321/romio/test/perf.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 95 ompi/mca/io/romio321/romio/test/perf.c read_bw = (SIZE*nprocs)/(min_read_tim*1024.0*1024.0); nprocs 96 ompi/mca/io/romio321/romio/test/perf.c write_bw = (SIZE*nprocs)/(min_write_tim*1024.0*1024.0); nprocs 149 ompi/mca/io/romio321/romio/test/perf.c read_bw = (SIZE*nprocs)/(min_read_tim*1024.0*1024.0); nprocs 150 ompi/mca/io/romio321/romio/test/perf.c write_bw = (SIZE*nprocs)/(min_write_tim*1024.0*1024.0); nprocs 28 ompi/mca/io/romio321/romio/test/shared_fp.c int *buf, i, rank, nprocs, len, sum, global_sum; nprocs 65 ompi/mca/io/romio321/romio/test/shared_fp.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 101 ompi/mca/io/romio321/romio/test/shared_fp.c if (global_sum != (((COUNT*nprocs - 1)*(COUNT*nprocs))/2)) { nprocs 104 ompi/mca/io/romio321/romio/test/shared_fp.c sum, global_sum,(((COUNT*nprocs - 1)*(COUNT*nprocs))/2)); nprocs 25 ompi/mca/io/romio321/romio/test/split_coll.c int order, nprocs, j, len; nprocs 37 ompi/mca/io/romio321/romio/test/split_coll.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 82 ompi/mca/io/romio321/romio/test/split_coll.c MPI_Dims_create(nprocs, ndims, array_of_psizes); nprocs 84 ompi/mca/io/romio321/romio/test/split_coll.c MPI_Type_create_darray(nprocs, mynod, ndims, array_of_gsizes, nprocs 158 ompi/mca/mtl/mtl.h size_t nprocs, nprocs 180 ompi/mca/mtl/mtl.h size_t nprocs, nprocs 45 ompi/mca/mtl/ofi/mtl_ofi.c size_t nprocs, nprocs 63 ompi/mca/mtl/ofi/mtl_ofi.c OPAL_UNLIKELY(((int) (nprocs + ompi_mtl_ofi.num_peers) > num_peers_limit))) { nprocs 76 ompi/mca/mtl/ofi/mtl_ofi.c ep_names = malloc(nprocs * namelen); nprocs 85 ompi/mca/mtl/ofi/mtl_ofi.c fi_addrs = malloc(nprocs * sizeof(fi_addr_t)); nprocs 94 ompi/mca/mtl/ofi/mtl_ofi.c for (i = 0; i < nprocs; ++i) { nprocs 113 ompi/mca/mtl/ofi/mtl_ofi.c count = fi_av_insert(ompi_mtl_ofi.av, ep_names, nprocs, fi_addrs, 0, NULL); nprocs 114 ompi/mca/mtl/ofi/mtl_ofi.c if ((count < 0) || (nprocs != (size_t)count)) { nprocs 125 ompi/mca/mtl/ofi/mtl_ofi.c for (i = 0; i < nprocs; ++i) { nprocs 144 ompi/mca/mtl/ofi/mtl_ofi.c ompi_mtl_ofi.num_peers += nprocs; nprocs 160 ompi/mca/mtl/ofi/mtl_ofi.c size_t nprocs, nprocs 167 ompi/mca/mtl/ofi/mtl_ofi.c for (i = 0 ; i < nprocs ; ++i) { nprocs 52 ompi/mca/mtl/ofi/mtl_ofi.h size_t nprocs, nprocs 17 ompi/mca/mtl/ofi/mtl_ofi_endpoint.h size_t nprocs, nprocs 248 ompi/mca/mtl/portals4/mtl_portals4.c create_maptable(size_t nprocs, nprocs 255 ompi/mca/mtl/portals4/mtl_portals4.c maptable = malloc(sizeof(ptl_process_t) * nprocs); nprocs 263 ompi/mca/mtl/portals4/mtl_portals4.c for (i=0;i<nprocs;i++) { nprocs 288 ompi/mca/mtl/portals4/mtl_portals4.c ret = PtlSetMap(ompi_mtl_portals4.ni_h, nprocs, maptable); nprocs 393 ompi/mca/mtl/portals4/mtl_portals4.c add_endpoints(size_t nprocs, nprocs 400 ompi/mca/mtl/portals4/mtl_portals4.c for (i = 0 ; i < nprocs ; ++i) { nprocs 455 ompi/mca/mtl/portals4/mtl_portals4.c size_t nprocs, nprocs 464 ompi/mca/mtl/portals4/mtl_portals4.c ret = add_endpoints(nprocs, nprocs 475 ompi/mca/mtl/portals4/mtl_portals4.c ret = create_maptable(nprocs, procs); nprocs 507 ompi/mca/mtl/portals4/mtl_portals4.c nprocs, nprocs 526 ompi/mca/mtl/portals4/mtl_portals4.c size_t nprocs, nprocs 534 ompi/mca/mtl/portals4/mtl_portals4.c for (i = 0 ; i < nprocs ; ++i) { nprocs 259 ompi/mca/mtl/portals4/mtl_portals4.h size_t nprocs, nprocs 263 ompi/mca/mtl/portals4/mtl_portals4.h size_t nprocs, nprocs 257 ompi/mca/mtl/psm/mtl_psm.c size_t nprocs, nprocs 274 ompi/mca/mtl/psm/mtl_psm.c errs_out = (psm_error_t *) malloc(nprocs * sizeof(psm_error_t)); nprocs 278 ompi/mca/mtl/psm/mtl_psm.c epids_in = (psm_epid_t *) malloc(nprocs * sizeof(psm_epid_t)); nprocs 282 ompi/mca/mtl/psm/mtl_psm.c mask_in = (int *) malloc(nprocs * sizeof(int)); nprocs 286 ompi/mca/mtl/psm/mtl_psm.c epaddrs_out = (psm_epaddr_t *) malloc(nprocs * sizeof(psm_epaddr_t)); nprocs 293 ompi/mca/mtl/psm/mtl_psm.c for (i = 0; i < (int) nprocs; i++) { nprocs 310 ompi/mca/mtl/psm/mtl_psm.c timeout_in_secs = max(ompi_mtl_psm.connect_timeout, 0.5 * nprocs); nprocs 315 ompi/mca/mtl/psm/mtl_psm.c nprocs, nprocs 327 ompi/mca/mtl/psm/mtl_psm.c for (i = 0; i < (int) nprocs; i++) { nprocs 338 ompi/mca/mtl/psm/mtl_psm.c for (j = 0; j < (int) nprocs; j++) { nprocs 357 ompi/mca/mtl/psm/mtl_psm.c for (i = 0; i < (int) nprocs; i++) { nprocs 391 ompi/mca/mtl/psm/mtl_psm.c size_t nprocs, nprocs 39 ompi/mca/mtl/psm/mtl_psm.h size_t nprocs, nprocs 43 ompi/mca/mtl/psm/mtl_psm.h size_t nprocs, nprocs 245 ompi/mca/mtl/psm2/mtl_psm2.c size_t nprocs, nprocs 262 ompi/mca/mtl/psm2/mtl_psm2.c errs_out = (psm2_error_t *) malloc(nprocs * sizeof(psm2_error_t)); nprocs 266 ompi/mca/mtl/psm2/mtl_psm2.c epids_in = (psm2_epid_t *) malloc(nprocs * sizeof(psm2_epid_t)); nprocs 270 ompi/mca/mtl/psm2/mtl_psm2.c mask_in = (int *) malloc(nprocs * sizeof(int)); nprocs 274 ompi/mca/mtl/psm2/mtl_psm2.c epaddrs_out = (psm2_epaddr_t *) malloc(nprocs * sizeof(psm2_epaddr_t)); nprocs 281 ompi/mca/mtl/psm2/mtl_psm2.c for (i = 0; i < (int) nprocs; i++) { nprocs 297 ompi/mca/mtl/psm2/mtl_psm2.c timeout_in_secs = max(ompi_mtl_psm2.connect_timeout, 0.5 * nprocs); nprocs 302 ompi/mca/mtl/psm2/mtl_psm2.c nprocs, nprocs 314 ompi/mca/mtl/psm2/mtl_psm2.c for (i = 0; i < (int) nprocs; i++) { nprocs 325 ompi/mca/mtl/psm2/mtl_psm2.c for (j = 0; j < (int) nprocs; j++) { nprocs 344 ompi/mca/mtl/psm2/mtl_psm2.c for (i = 0; i < (int) nprocs; i++) { nprocs 378 ompi/mca/mtl/psm2/mtl_psm2.c size_t nprocs, nprocs 42 ompi/mca/mtl/psm2/mtl_psm2.h size_t nprocs, nprocs 46 ompi/mca/mtl/psm2/mtl_psm2.h size_t nprocs, nprocs 61 ompi/mca/pml/base/base.h size_t nprocs); nprocs 322 ompi/mca/pml/base/pml_base_select.c size_t nprocs) nprocs 115 ompi/mca/pml/cm/pml_cm.c mca_pml_cm_add_procs(struct ompi_proc_t** procs, size_t nprocs) nprocs 120 ompi/mca/pml/cm/pml_cm.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 130 ompi/mca/pml/cm/pml_cm.c nprocs))) { nprocs 134 ompi/mca/pml/cm/pml_cm.c ret = OMPI_MTL_CALL(add_procs(ompi_mtl, nprocs, procs)); nprocs 140 ompi/mca/pml/cm/pml_cm.c mca_pml_cm_del_procs(struct ompi_proc_t** procs, size_t nprocs) nprocs 144 ompi/mca/pml/cm/pml_cm.c ret = OMPI_MTL_CALL(del_procs(ompi_mtl, nprocs, procs)); nprocs 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); nprocs 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); nprocs 88 ompi/mca/pml/crcpw/pml_crcpw.h int mca_pml_crcpw_add_procs( struct ompi_proc_t **procs, size_t nprocs ); nprocs 89 ompi/mca/pml/crcpw/pml_crcpw.h int mca_pml_crcpw_del_procs( struct ompi_proc_t **procs, size_t nprocs ); nprocs 209 ompi/mca/pml/crcpw/pml_crcpw_module.c int mca_pml_crcpw_add_procs(ompi_proc_t** procs, size_t nprocs) nprocs 220 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_add_procs(procs, nprocs, pml_state); nprocs 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) ) ) { nprocs 235 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_add_procs(procs, nprocs, pml_state); nprocs 247 ompi/mca/pml/crcpw/pml_crcpw_module.c int mca_pml_crcpw_del_procs(ompi_proc_t** procs, size_t nprocs) nprocs 258 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_del_procs(procs, nprocs, pml_state); nprocs 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) ) ) { nprocs 273 ompi/mca/pml/crcpw/pml_crcpw_module.c pml_state = ompi_crcp.pml_del_procs(procs, nprocs, pml_state); nprocs 70 ompi/mca/pml/example/pml_example.c int mca_pml_example_add_procs(ompi_proc_t** procs, size_t nprocs) nprocs 75 ompi/mca/pml/example/pml_example.c int mca_pml_example_del_procs(ompi_proc_t** procs, size_t nprocs) nprocs 50 ompi/mca/pml/example/pml_example.h extern int mca_pml_example_add_procs( struct ompi_proc_t **procs, size_t nprocs ); nprocs 51 ompi/mca/pml/example/pml_example.h extern int mca_pml_example_del_procs( struct ompi_proc_t **procs, size_t nprocs ); nprocs 42 ompi/mca/pml/monitoring/pml_monitoring.h extern int mca_pml_monitoring_add_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 44 ompi/mca/pml/monitoring/pml_monitoring.h extern int mca_pml_monitoring_del_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 60 ompi/mca/pml/monitoring/pml_monitoring_component.c size_t nprocs) nprocs 62 ompi/mca/pml/monitoring/pml_monitoring_component.c int ret = mca_common_monitoring_add_procs(procs, nprocs); nprocs 64 ompi/mca/pml/monitoring/pml_monitoring_component.c ret = pml_selected_module.pml_add_procs(procs, nprocs); nprocs 72 ompi/mca/pml/monitoring/pml_monitoring_component.c size_t nprocs) nprocs 74 ompi/mca/pml/monitoring/pml_monitoring_component.c return pml_selected_module.pml_del_procs(procs, nprocs); nprocs 306 ompi/mca/pml/ob1/pml_ob1.c int mca_pml_ob1_add_procs(ompi_proc_t** procs, size_t nprocs) nprocs 312 ompi/mca/pml/ob1/pml_ob1.c if(nprocs == 0) nprocs 316 ompi/mca/pml/ob1/pml_ob1.c rc = opal_bitmap_init(&reachable, (int)nprocs); nprocs 330 ompi/mca/pml/ob1/pml_ob1.c nprocs))) { nprocs 335 ompi/mca/pml/ob1/pml_ob1.c rc = mca_bml.bml_add_procs( nprocs, nprocs 470 ompi/mca/pml/ob1/pml_ob1.c int mca_pml_ob1_del_procs(ompi_proc_t** procs, size_t nprocs) nprocs 472 ompi/mca/pml/ob1/pml_ob1.c return mca_bml.bml_del_procs(nprocs, procs); nprocs 106 ompi/mca/pml/ob1/pml_ob1.h size_t nprocs nprocs 111 ompi/mca/pml/ob1/pml_ob1.h size_t nprocs nprocs 134 ompi/mca/pml/pml.h typedef int (*mca_pml_base_module_add_procs_fn_t)(struct ompi_proc_t **procs, size_t nprocs); nprocs 148 ompi/mca/pml/pml.h typedef int (*mca_pml_base_module_del_procs_fn_t)(struct ompi_proc_t **procs, size_t nprocs); nprocs 404 ompi/mca/pml/ucx/pml_ucx.c int mca_pml_ucx_add_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 413 ompi/mca/pml/ucx/pml_ucx.c nprocs))) { nprocs 417 ompi/mca/pml/ucx/pml_ucx.c for (i = 0; i < nprocs; ++i) { nprocs 418 ompi/mca/pml/ucx/pml_ucx.c proc = procs[(i + OMPI_PROC_MY_NAME->vpid) % nprocs]; nprocs 453 ompi/mca/pml/ucx/pml_ucx.c int mca_pml_ucx_del_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 460 ompi/mca/pml/ucx/pml_ucx.c del_procs = malloc(sizeof(*del_procs) * nprocs); nprocs 465 ompi/mca/pml/ucx/pml_ucx.c for (i = 0; i < nprocs; ++i) { nprocs 474 ompi/mca/pml/ucx/pml_ucx.c ret = opal_common_ucx_del_procs(del_procs, nprocs, OMPI_PROC_MY_NAME->vpid, nprocs 70 ompi/mca/pml/ucx/pml_ucx.h int mca_pml_ucx_add_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 71 ompi/mca/pml/ucx/pml_ucx.h int mca_pml_ucx_del_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 222 ompi/mca/pml/yalla/pml_yalla.c int mca_pml_yalla_add_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 233 ompi/mca/pml/yalla/pml_yalla.c nprocs))) { nprocs 237 ompi/mca/pml/yalla/pml_yalla.c for (i = 0; i < nprocs; ++i) { nprocs 265 ompi/mca/pml/yalla/pml_yalla.c int mca_pml_yalla_del_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 275 ompi/mca/pml/yalla/pml_yalla.c for (i = 0; i < nprocs; ++i) { nprocs 89 ompi/mca/pml/yalla/pml_yalla.h int mca_pml_yalla_add_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 90 ompi/mca/pml/yalla/pml_yalla.h int mca_pml_yalla_del_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 58 ompi/mca/topo/base/topo_base_cart_create.c int nprocs = 1, i, new_rank, num_procs, ret; nprocs 72 ompi/mca/topo/base/topo_base_cart_create.c nprocs *= dims[i]; nprocs 76 ompi/mca/topo/base/topo_base_cart_create.c if (num_procs < nprocs) { nprocs 81 ompi/mca/topo/base/topo_base_cart_create.c if (nprocs < num_procs) { nprocs 82 ompi/mca/topo/base/topo_base_cart_create.c num_procs = nprocs; nprocs 85 ompi/mca/topo/base/topo_base_cart_create.c if (new_rank > (nprocs-1)) { nprocs 121 ompi/mca/topo/base/topo_base_cart_create.c int nprocs = num_procs, rank = new_rank; nprocs 124 ompi/mca/topo/base/topo_base_cart_create.c nprocs /= cart->dims[i]; nprocs 125 ompi/mca/topo/base/topo_base_cart_create.c cart->coords[i] = rank / nprocs; nprocs 126 ompi/mca/topo/base/topo_base_cart_create.c rank %= nprocs; nprocs 45 ompi/mca/topo/base/topo_base_cart_map.c int nprocs, rank, size, i; nprocs 50 ompi/mca/topo/base/topo_base_cart_map.c nprocs = 1; nprocs 55 ompi/mca/topo/base/topo_base_cart_map.c nprocs *= dims[i]; nprocs 61 ompi/mca/topo/base/topo_base_cart_map.c if (nprocs > size) { nprocs 68 ompi/mca/topo/base/topo_base_cart_map.c *newrank = ((rank < 0) || (rank >= nprocs)) ? MPI_UNDEFINED : rank; nprocs 144 ompi/mca/topo/base/topo_base_cart_sub.c int nprocs = temp_comm->c_local_group->grp_proc_count, nprocs 148 ompi/mca/topo/base/topo_base_cart_sub.c nprocs /= cart->dims[i]; nprocs 149 ompi/mca/topo/base/topo_base_cart_sub.c cart->coords[i] = rank / nprocs; nprocs 150 ompi/mca/topo/base/topo_base_cart_sub.c rank %= nprocs; nprocs 44 ompi/mca/topo/base/topo_base_graph_get.c int nprocs = ompi_comm_size(comm); nprocs 50 ompi/mca/topo/base/topo_base_graph_get.c for (i = 0; (i < nprocs) && (i < maxindex); ++i, ++p) { nprocs 57 ompi/mca/topo/base/topo_base_graph_get.c (i < comm->c_topo->mtc.graph->index[nprocs-1]) && (i < maxedges); nprocs 48 ompi/mca/topo/example/topo_example_cart_map.c int nprocs; nprocs 57 ompi/mca/topo/example/topo_example_cart_map.c nprocs = 1; nprocs 62 ompi/mca/topo/example/topo_example_cart_map.c nprocs *= *p; nprocs 68 ompi/mca/topo/example/topo_example_cart_map.c if (nprocs > size) { nprocs 76 ompi/mca/topo/example/topo_example_cart_map.c *newrank = ((rank < 0) || (rank >= nprocs)) ? MPI_UNDEFINED : rank; nprocs 30 ompi/mca/vprotocol/example/vprotocol_example.h OMPI_DECLSPEC int mca_vprotocol_example_add_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 31 ompi/mca/vprotocol/example/vprotocol_example.h OMPI_DECLSPEC int mca_vprotocol_example_del_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 15 ompi/mca/vprotocol/example/vprotocol_example_proc.c int mca_vprotocol_example_add_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 17 ompi/mca/vprotocol/example/vprotocol_example_proc.c V_OUTPUT_VERBOSE(30, "adding %ld procs", (long) nprocs); nprocs 18 ompi/mca/vprotocol/example/vprotocol_example_proc.c return mca_pml_v.host_pml.pml_add_procs(procs, nprocs); nprocs 21 ompi/mca/vprotocol/example/vprotocol_example_proc.c int mca_vprotocol_example_del_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 23 ompi/mca/vprotocol/example/vprotocol_example_proc.c V_OUTPUT_VERBOSE(30, "removing %ld procs", (long) nprocs); nprocs 24 ompi/mca/vprotocol/example/vprotocol_example_proc.c return mca_pml_v.host_pml.pml_del_procs(procs, nprocs); nprocs 61 ompi/mca/vprotocol/pessimist/vprotocol_pessimist.h int mca_vprotocol_pessimist_add_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 62 ompi/mca/vprotocol/pessimist/vprotocol_pessimist.h int mca_vprotocol_pessimist_del_procs(struct ompi_proc_t **procs, size_t nprocs); nprocs 14 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c int mca_vprotocol_pessimist_add_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 19 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c return mca_pml_v.host_pml.pml_add_procs(procs, nprocs); nprocs 22 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c int mca_vprotocol_pessimist_del_procs(struct ompi_proc_t **procs, size_t nprocs) nprocs 25 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_proc.c return mca_pml_v.host_pml.pml_del_procs(procs, nprocs); nprocs 75 ompi/runtime/ompi_mpi_abort.c int nprocs; nprocs 78 ompi/runtime/ompi_mpi_abort.c nprocs = ompi_comm_size(comm); nprocs 81 ompi/runtime/ompi_mpi_abort.c nprocs += ompi_comm_remote_size(comm); nprocs 83 ompi/runtime/ompi_mpi_abort.c procs = (ompi_process_name_t*) calloc(nprocs, sizeof(ompi_process_name_t)); nprocs 95 ompi/runtime/ompi_mpi_abort.c --nprocs; nprocs 97 ompi/runtime/ompi_mpi_abort.c assert(count <= nprocs); nprocs 105 ompi/runtime/ompi_mpi_abort.c assert(count <= nprocs); nprocs 110 ompi/runtime/ompi_mpi_abort.c if (nprocs > 0) { nprocs 111 ompi/runtime/ompi_mpi_abort.c ompi_rte_abort_peers(procs, nprocs, errcode); nprocs 109 ompi/runtime/ompi_mpi_finalize.c size_t nprocs; nprocs 336 ompi/runtime/ompi_mpi_finalize.c nprocs = 0; nprocs 337 ompi/runtime/ompi_mpi_finalize.c procs = ompi_proc_get_allocated (&nprocs); nprocs 338 ompi/runtime/ompi_mpi_finalize.c MCA_PML_CALL(del_procs(procs, nprocs)); nprocs 379 ompi/runtime/ompi_mpi_init.c size_t nprocs; nprocs 845 ompi/runtime/ompi_mpi_init.c if (NULL == (procs = ompi_proc_world (&nprocs))) { nprocs 852 ompi/runtime/ompi_mpi_init.c if (NULL == (procs = ompi_proc_get_allocated (&nprocs))) { nprocs 857 ompi/runtime/ompi_mpi_init.c ret = MCA_PML_CALL(add_procs(procs, nprocs)); nprocs 880 ompi/runtime/ompi_mpi_init.c nprocs, nprocs 679 opal/mca/btl/btl.h size_t nprocs, nprocs 700 opal/mca/btl/btl.h size_t nprocs, nprocs 39 opal/mca/btl/ofi/btl_ofi_module.c size_t nprocs, opal_proc_t **opal_procs, nprocs 53 opal/mca/btl/ofi/btl_ofi_module.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 105 opal/mca/btl/ofi/btl_ofi_module.c static int mca_btl_ofi_del_procs (mca_btl_base_module_t *btl, size_t nprocs, nprocs 112 opal/mca/btl/ofi/btl_ofi_module.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 321 opal/mca/btl/portals4/btl_portals4.c size_t nprocs, nprocs 328 opal/mca/btl/portals4/btl_portals4.c maptable = malloc(sizeof(ptl_process_t) * nprocs); nprocs 336 opal/mca/btl/portals4/btl_portals4.c for (uint32_t i = 0 ; i < nprocs ; i++) { nprocs 365 opal/mca/btl/portals4/btl_portals4.c nprocs, nprocs 384 opal/mca/btl/portals4/btl_portals4.c size_t nprocs, nprocs 395 opal/mca/btl/portals4/btl_portals4.c (int) nprocs, nprocs 403 opal/mca/btl/portals4/btl_portals4.c for (i = 0 ; i < nprocs ; ++i) { nprocs 435 opal/mca/btl/portals4/btl_portals4.c ret = create_maptable(portals4_btl, nprocs, procs, btl_peer_data); nprocs 460 opal/mca/btl/portals4/btl_portals4.c size_t nprocs, nprocs 468 opal/mca/btl/portals4/btl_portals4.c "mca_btl_portals4_del_procs: Removing %d procs (%d)", (int) nprocs, nprocs 473 opal/mca/btl/portals4/btl_portals4.c for (i = 0 ; i < nprocs ; ++i) { nprocs 190 opal/mca/btl/portals4/btl_portals4.h size_t nprocs, nprocs 196 opal/mca/btl/portals4/btl_portals4.h size_t nprocs, nprocs 49 opal/mca/btl/self/btl_self.c static int mca_btl_self_add_procs (struct mca_btl_base_module_t *btl, size_t nprocs, nprocs 54 opal/mca/btl/self/btl_self.c for (int i = 0; i < (int)nprocs; i++ ) { nprocs 75 opal/mca/btl/self/btl_self.c static int mca_btl_self_del_procs (struct mca_btl_base_module_t *btl, size_t nprocs, nprocs 526 opal/mca/btl/smcuda/btl_smcuda.c size_t nprocs, nprocs 552 opal/mca/btl/smcuda/btl_smcuda.c for (proc = 0; proc < (int32_t)nprocs; proc++) { nprocs 607 opal/mca/btl/smcuda/btl_smcuda.c for(proc = 0; proc < (int32_t)nprocs; proc++) { nprocs 720 opal/mca/btl/smcuda/btl_smcuda.c size_t nprocs, nprocs 724 opal/mca/btl/smcuda/btl_smcuda.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 383 opal/mca/btl/smcuda/btl_smcuda.h size_t nprocs, nprocs 401 opal/mca/btl/smcuda/btl_smcuda.h size_t nprocs, nprocs 64 opal/mca/btl/tcp/btl_tcp.c size_t nprocs, nprocs 77 opal/mca/btl/tcp/btl_tcp.c for(i = 0; i < (int) nprocs; i++) { nprocs 146 opal/mca/btl/tcp/btl_tcp.c size_t nprocs, nprocs 154 opal/mca/btl/tcp/btl_tcp.c for( i = 0; i < nprocs; i++ ) { nprocs 229 opal/mca/btl/tcp/btl_tcp.h size_t nprocs, nprocs 248 opal/mca/btl/tcp/btl_tcp.h size_t nprocs, nprocs 61 opal/mca/btl/template/btl_template.c size_t nprocs, nprocs 69 opal/mca/btl/template/btl_template.c for(i = 0; i < (int) nprocs; i++) { nprocs 122 opal/mca/btl/template/btl_template.c size_t nprocs, nprocs 148 opal/mca/btl/template/btl_template.h size_t nprocs, nprocs 167 opal/mca/btl/template/btl_template.h size_t nprocs, nprocs 68 opal/mca/btl/uct/btl_uct_module.c size_t nprocs, opal_proc_t **opal_procs, nprocs 107 opal/mca/btl/uct/btl_uct_module.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 120 opal/mca/btl/uct/btl_uct_module.c static int mca_btl_uct_del_procs (mca_btl_base_module_t *btl, size_t nprocs, nprocs 127 opal/mca/btl/uct/btl_uct_module.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 356 opal/mca/btl/ugni/btl_ugni.h size_t nprocs, nprocs 374 opal/mca/btl/ugni/btl_ugni.h size_t nprocs, nprocs 29 opal/mca/btl/ugni/btl_ugni_add_procs.c static int mca_btl_ugni_smsg_setup (int nprocs); nprocs 31 opal/mca/btl/ugni/btl_ugni_add_procs.c int mca_btl_ugni_add_procs (struct mca_btl_base_module_t* btl, size_t nprocs, nprocs 61 opal/mca/btl/ugni/btl_ugni_add_procs.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 169 opal/mca/btl/ugni/btl_ugni_add_procs.c size_t nprocs, struct opal_proc_t **procs, nprocs 175 opal/mca/btl/ugni/btl_ugni_add_procs.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 300 opal/mca/btl/ugni/btl_ugni_add_procs.c uint32_t nprocs, *u32; nprocs 311 opal/mca/btl/ugni/btl_ugni_add_procs.c u32 = &nprocs; nprocs 316 opal/mca/btl/ugni/btl_ugni_add_procs.c nprocs = 512; nprocs 319 opal/mca/btl/ugni/btl_ugni_add_procs.c rc = mca_btl_ugni_smsg_setup (nprocs); nprocs 431 opal/mca/btl/ugni/btl_ugni_add_procs.c if (nprocs/mbox_increment > (unsigned int) ugni_module->reg_max / 8) { nprocs 432 opal/mca/btl/ugni/btl_ugni_add_procs.c mbox_increment = nprocs / (ugni_module->reg_max >> 3); nprocs 489 opal/mca/btl/ugni/btl_ugni_add_procs.c static int mca_btl_ugni_smsg_setup (int nprocs) nprocs 497 opal/mca/btl/ugni/btl_ugni_add_procs.c if (nprocs <= 512) { nprocs 499 opal/mca/btl/ugni/btl_ugni_add_procs.c } else if (nprocs <= 1024) { nprocs 501 opal/mca/btl/ugni/btl_ugni_add_procs.c } else if (nprocs <= 8192) { nprocs 503 opal/mca/btl/ugni/btl_ugni_add_procs.c } else if (nprocs <= 16384) { nprocs 443 opal/mca/btl/usnic/btl_usnic_module.c size_t nprocs, nprocs 466 opal/mca/btl/usnic/btl_usnic_module.c size_t num_av_inserts = nprocs * USNIC_NUM_CHANNELS; nprocs 483 opal/mca/btl/usnic/btl_usnic_module.c if (block_len > (nprocs - block_offset)) { nprocs 484 opal/mca/btl/usnic/btl_usnic_module.c block_len = nprocs - block_offset; nprocs 530 opal/mca/btl/usnic/btl_usnic_module.c size_t nprocs, nprocs 540 opal/mca/btl/usnic/btl_usnic_module.c rc = add_procs_create_endpoints(module, nprocs, procs, endpoints); nprocs 547 opal/mca/btl/usnic/btl_usnic_module.c for (size_t i = 0; NULL != reachable && i < nprocs; ++i) { nprocs 584 opal/mca/btl/usnic/btl_usnic_module.c for (size_t i = 0; i < nprocs; ++i) { nprocs 601 opal/mca/btl/usnic/btl_usnic_module.c size_t nprocs, nprocs 612 opal/mca/btl/usnic/btl_usnic_module.c for (i = 0; i < nprocs; i++) { nprocs 40 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, nprocs 59 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, nprocs 252 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, nprocs 285 opal/mca/btl/vader/btl_vader_module.c for (int32_t proc = 0, local_rank = 0 ; proc < (int32_t) nprocs ; ++proc) { nprocs 324 opal/mca/btl/vader/btl_vader_module.c size_t nprocs, struct opal_proc_t **procs, nprocs 327 opal/mca/btl/vader/btl_vader_module.c for (size_t i = 0 ; i < nprocs ; ++i) { nprocs 30 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c unsigned nprocs; nprocs 66 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c nprocs = _nprocs; nprocs 69 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c hwloc_debug("%u procs\n", nprocs); nprocs 112 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c logical_per_package = nprocs / npackages; nprocs 116 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c if (nprocs == npackages * logical_per_package nprocs 264 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c for (j = 0; j < (nprocs / cacheconfig[i]); j++) { nprocs 340 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-darwin.c hwloc_setup_pu_level(topology, nprocs); nprocs 530 opal/mca/pmix/ext1x/pmix1x.c p->nprocs = 0; nprocs 548 opal/mca/pmix/ext1x/pmix1x.c PMIX_PROC_FREE(p->procs, p->nprocs); nprocs 59 opal/mca/pmix/ext1x/pmix1x.h size_t nprocs; nprocs 55 opal/mca/pmix/ext1x/pmix1x_client.c pmix_proc_t procs[], size_t nprocs, nprocs 70 opal/mca/pmix/ext1x/pmix1x_client.c for (n=0; n < nprocs; n++) { nprocs 397 opal/mca/pmix/ext1x/pmix1x_client.c op->nprocs = cnt; nprocs 1140 opal/mca/pmix/ext1x/pmix1x_client.c op->nprocs = cnt; nprocs 1144 opal/mca/pmix/ext1x/pmix1x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1163 opal/mca/pmix/ext1x/pmix1x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1227 opal/mca/pmix/ext1x/pmix1x_client.c op->nprocs = cnt; nprocs 1231 opal/mca/pmix/ext1x/pmix1x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1250 opal/mca/pmix/ext1x/pmix1x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1261 opal/mca/pmix/ext1x/pmix1x_client.c size_t nprocs, n; nprocs 1283 opal/mca/pmix/ext1x/pmix1x_client.c ret = PMIx_Resolve_peers(nodename, nspace, &array, &nprocs); nprocs 1286 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL != array && 0 < nprocs) { nprocs 1287 opal/mca/pmix/ext1x/pmix1x_client.c for (n=0; n < nprocs; n++) { nprocs 1316 opal/mca/pmix/ext1x/pmix1x_client.c PMIX_PROC_FREE(array, nprocs); nprocs 54 opal/mca/pmix/ext1x/pmix1x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 56 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 76 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 79 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 172 opal/mca/pmix/ext1x/pmix1x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 197 opal/mca/pmix/ext1x/pmix1x_server_north.c for (n=0; n < nprocs; n++) { nprocs 247 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 268 opal/mca/pmix/ext1x/pmix1x_server_north.c for (n=0; n < nprocs; n++) { nprocs 625 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 645 opal/mca/pmix/ext1x/pmix1x_server_north.c for (n=0; n < nprocs; n++) { nprocs 680 opal/mca/pmix/ext1x/pmix1x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 700 opal/mca/pmix/ext1x/pmix1x_server_north.c for (n=0; n < nprocs; n++) { nprocs 70 opal/mca/pmix/ext1x/pmix1x_server_south.c pmix_proc_t procs[], size_t nprocs, nprocs 85 opal/mca/pmix/ext1x/pmix1x_server_south.c for (n=0; n < nprocs; n++) { nprocs 1431 opal/mca/pmix/ext2x/ext2x.c p->nprocs = 0; nprocs 1463 opal/mca/pmix/ext2x/ext2x.c PMIX_PROC_FREE(p->procs, p->nprocs); nprocs 95 opal/mca/pmix/ext2x/ext2x.h size_t nprocs; nprocs 550 opal/mca/pmix/ext2x/ext2x_client.c op->nprocs = cnt; nprocs 559 opal/mca/pmix/ext2x/ext2x_client.c rc = PMIx_Fence_nb(op->procs, op->nprocs, op->info, op->ninfo, opcbfunc, op); nprocs 1311 opal/mca/pmix/ext2x/ext2x_client.c size_t nprocs; nprocs 1321 opal/mca/pmix/ext2x/ext2x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { nprocs 1333 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(p, nprocs); nprocs 1337 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1347 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Connect(p, nprocs, NULL, 0); nprocs 1348 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1381 opal/mca/pmix/ext2x/ext2x_client.c op->nprocs = opal_list_get_size(procs); nprocs 1385 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1399 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1409 opal/mca/pmix/ext2x/ext2x_client.c size_t nprocs; nprocs 1419 opal/mca/pmix/ext2x/ext2x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { nprocs 1431 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(p, nprocs); nprocs 1435 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1445 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Disconnect(p, nprocs, NULL, 0); nprocs 1446 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1479 opal/mca/pmix/ext2x/ext2x_client.c op->nprocs = opal_list_get_size(procs); nprocs 1483 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1497 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1511 opal/mca/pmix/ext2x/ext2x_client.c size_t nprocs, n; nprocs 1531 opal/mca/pmix/ext2x/ext2x_client.c ret = PMIx_Resolve_peers(nodename, nspace, &array, &nprocs); nprocs 1533 opal/mca/pmix/ext2x/ext2x_client.c if (NULL != array && 0 < nprocs) { nprocs 1535 opal/mca/pmix/ext2x/ext2x_client.c for (n=0; n < nprocs; n++) { nprocs 1558 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_FREE(array, nprocs); nprocs 1639 opal/mca/pmix/ext2x/ext2x_client.c op->nprocs = opal_list_get_size(targets); nprocs 1643 opal/mca/pmix/ext2x/ext2x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1668 opal/mca/pmix/ext2x/ext2x_client.c rc = PMIx_Job_control_nb(op->procs,op->nprocs, op->info, op->ninfo, infocbfunc, op); nprocs 56 opal/mca/pmix/ext2x/ext2x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 58 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 78 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 81 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 217 opal/mca/pmix/ext2x/ext2x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 247 opal/mca/pmix/ext2x/ext2x_server_north.c for (n=0; n < nprocs; n++) { nprocs 303 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 326 opal/mca/pmix/ext2x/ext2x_server_north.c for (n=0; n < nprocs; n++) { nprocs 700 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 720 opal/mca/pmix/ext2x/ext2x_server_north.c for (n=0; n < nprocs; n++) { nprocs 751 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 771 opal/mca/pmix/ext2x/ext2x_server_north.c for (n=0; n < nprocs; n++) { nprocs 1750 opal/mca/pmix/ext3x/ext3x.c p->nprocs = 0; nprocs 1782 opal/mca/pmix/ext3x/ext3x.c PMIX_PROC_FREE(p->procs, p->nprocs); nprocs 89 opal/mca/pmix/ext3x/ext3x.h size_t nprocs; nprocs 551 opal/mca/pmix/ext3x/ext3x_client.c op->nprocs = cnt; nprocs 560 opal/mca/pmix/ext3x/ext3x_client.c rc = PMIx_Fence_nb(op->procs, op->nprocs, op->info, op->ninfo, opcbfunc, op); nprocs 1312 opal/mca/pmix/ext3x/ext3x_client.c size_t nprocs; nprocs 1322 opal/mca/pmix/ext3x/ext3x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { nprocs 1334 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(p, nprocs); nprocs 1338 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1348 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Connect(p, nprocs, NULL, 0); nprocs 1349 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1382 opal/mca/pmix/ext3x/ext3x_client.c op->nprocs = opal_list_get_size(procs); nprocs 1386 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1400 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1409 opal/mca/pmix/ext3x/ext3x_client.c size_t nprocs, n; nprocs 1419 opal/mca/pmix/ext3x/ext3x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { nprocs 1431 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(p, nprocs); nprocs 1435 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1445 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Disconnect(p, nprocs, NULL, 0); nprocs 1446 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1479 opal/mca/pmix/ext3x/ext3x_client.c op->nprocs = opal_list_get_size(procs); nprocs 1483 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1497 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1511 opal/mca/pmix/ext3x/ext3x_client.c size_t nprocs, n; nprocs 1531 opal/mca/pmix/ext3x/ext3x_client.c ret = PMIx_Resolve_peers(nodename, nspace, &array, &nprocs); nprocs 1533 opal/mca/pmix/ext3x/ext3x_client.c if (NULL != array && 0 < nprocs) { nprocs 1535 opal/mca/pmix/ext3x/ext3x_client.c for (n=0; n < nprocs; n++) { nprocs 1558 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_FREE(array, nprocs); nprocs 1639 opal/mca/pmix/ext3x/ext3x_client.c op->nprocs = opal_list_get_size(targets); nprocs 1643 opal/mca/pmix/ext3x/ext3x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1668 opal/mca/pmix/ext3x/ext3x_client.c rc = PMIx_Job_control_nb(op->procs,op->nprocs, op->info, op->ninfo, infocbfunc, op); nprocs 56 opal/mca/pmix/ext3x/ext3x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 58 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 78 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 81 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 115 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, nprocs 228 opal/mca/pmix/ext3x/ext3x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 258 opal/mca/pmix/ext3x/ext3x_server_north.c for (n=0; n < nprocs; n++) { nprocs 318 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 341 opal/mca/pmix/ext3x/ext3x_server_north.c for (n=0; n < nprocs; n++) { nprocs 715 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 735 opal/mca/pmix/ext3x/ext3x_server_north.c for (n=0; n < nprocs; n++) { nprocs 766 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 786 opal/mca/pmix/ext3x/ext3x_server_north.c for (n=0; n < nprocs; n++) { nprocs 1318 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, nprocs 159 opal/mca/pmix/pmix4x/pmix/examples/alloc.c uint32_t nprocs; nprocs 184 opal/mca/pmix/pmix4x/pmix/examples/alloc.c nprocs = val->data.uint32; nprocs 186 opal/mca/pmix/pmix4x/pmix/examples/alloc.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 172 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c uint32_t nprocs; nprocs 196 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c nprocs = val->data.uint32; nprocs 198 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c if (nprocs < 4) { nprocs 204 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 241 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c nprocs = 3; nprocs 242 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_CREATE(procs, nprocs); nprocs 246 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c rc = PMIx_Group_invite("ourgroup", procs, nprocs, NULL, 0, &results, &nresults); nprocs 251 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c PMIX_PROC_FREE(procs, nprocs); nprocs 130 opal/mca/pmix/pmix4x/pmix/examples/client.c uint32_t nprocs, n; nprocs 214 opal/mca/pmix/pmix4x/pmix/examples/client.c nprocs = val->data.uint32; nprocs 216 opal/mca/pmix/pmix4x/pmix/examples/client.c fprintf(stderr, "Client %s:%d num procs %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 271 opal/mca/pmix/pmix4x/pmix/examples/client.c for (n=0; n < nprocs; n++) { nprocs 83 opal/mca/pmix/pmix4x/pmix/examples/client2.c uint32_t nprocs, n, k; nprocs 127 opal/mca/pmix/pmix4x/pmix/examples/client2.c nprocs = val->data.uint32; nprocs 129 opal/mca/pmix/pmix4x/pmix/examples/client2.c fprintf(stderr, "Client %s:%d job size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 168 opal/mca/pmix/pmix4x/pmix/examples/client2.c for (n=0; n < nprocs; n++) { nprocs 38 opal/mca/pmix/pmix4x/pmix/examples/dmodex.c static uint32_t nprocs; nprocs 113 opal/mca/pmix/pmix4x/pmix/examples/dmodex.c nprocs = val->data.uint32; nprocs 115 opal/mca/pmix/pmix4x/pmix/examples/dmodex.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 177 opal/mca/pmix/pmix4x/pmix/examples/dmodex.c for (n=0; n <= nprocs; n++) { nprocs 48 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c uint32_t nprocs; nprocs 79 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c nprocs = val->data.uint32; nprocs 81 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 156 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c if ((nprocs+ntmp) != npeers) { nprocs 157 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c fprintf(stderr, "Client ns %s rank %d: PMIx_Resolve_peers returned incorrect npeers: %d vs %d\n", myproc.nspace, myproc.rank, (int)(nprocs+ntmp), (int)npeers); nprocs 171 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c if (nprocs != npeers) { nprocs 172 opal/mca/pmix/pmix4x/pmix/examples/dynamic.c fprintf(stderr, "Client ns %s rank %d: PMIx_Resolve_peers returned incorrect npeers: %d vs %d\n", myproc.nspace, myproc.rank, nprocs, (int)npeers); nprocs 115 opal/mca/pmix/pmix4x/pmix/examples/fault.c uint32_t nprocs; nprocs 137 opal/mca/pmix/pmix4x/pmix/examples/fault.c nprocs = val->data.uint32; nprocs 139 opal/mca/pmix/pmix4x/pmix/examples/fault.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 115 opal/mca/pmix/pmix4x/pmix/examples/group.c uint32_t nprocs; nprocs 136 opal/mca/pmix/pmix4x/pmix/examples/group.c nprocs = val->data.uint32; nprocs 138 opal/mca/pmix/pmix4x/pmix/examples/group.c if (nprocs < 4) { nprocs 144 opal/mca/pmix/pmix4x/pmix/examples/group.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 169 opal/mca/pmix/pmix4x/pmix/examples/group.c nprocs = 3; nprocs 170 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_CREATE(procs, nprocs); nprocs 175 opal/mca/pmix/pmix4x/pmix/examples/group.c rc = PMIx_Group_construct("ourgroup", procs, nprocs, &info, 1, &results, &nresults); nprocs 189 opal/mca/pmix/pmix4x/pmix/examples/group.c PMIX_PROC_FREE(procs, nprocs); nprocs 101 opal/mca/pmix/pmix4x/pmix/examples/jctrl.c uint32_t nprocs, n; nprocs 142 opal/mca/pmix/pmix4x/pmix/examples/jctrl.c nprocs = val->data.uint32; nprocs 144 opal/mca/pmix/pmix4x/pmix/examples/jctrl.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 41 opal/mca/pmix/pmix4x/pmix/examples/pub.c uint32_t nprocs; nprocs 60 opal/mca/pmix/pmix4x/pmix/examples/pub.c nprocs = val->data.uint32; nprocs 62 opal/mca/pmix/pmix4x/pmix/examples/pub.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 41 opal/mca/pmix/pmix4x/pmix/examples/pubi.c uint32_t nprocs; nprocs 61 opal/mca/pmix/pmix4x/pmix/examples/pubi.c nprocs = val->data.uint32; nprocs 63 opal/mca/pmix/pmix4x/pmix/examples/pubi.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 57 opal/mca/pmix/pmix4x/pmix/examples/server.c pmix_proc_t procs[], size_t nprocs, nprocs 59 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 79 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 82 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 185 opal/mca/pmix/pmix4x/pmix/examples/server.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 215 opal/mca/pmix/pmix4x/pmix/examples/server.c int rc, nprocs=1, n, k; nprocs 276 opal/mca/pmix/pmix4x/pmix/examples/server.c nprocs = strtol(argv[n+1], NULL, 10); nprocs 293 opal/mca/pmix/pmix4x/pmix/examples/server.c for (n=0; n < nprocs; n++) { nprocs 302 opal/mca/pmix/pmix4x/pmix/examples/server.c set_namespace(nprocs, tmp, "foobar", opcbfunc, x); nprocs 308 opal/mca/pmix/pmix4x/pmix/examples/server.c wakeup = nprocs; nprocs 331 opal/mca/pmix/pmix4x/pmix/examples/server.c for (n = 0; n < nprocs; n++) { nprocs 418 opal/mca/pmix/pmix4x/pmix/examples/server.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 451 opal/mca/pmix/pmix4x/pmix/examples/server.c x->info[i].value.data.uint32 = nprocs; nprocs 461 opal/mca/pmix/pmix4x/pmix/examples/server.c x->info[i].value.data.uint32 = nprocs; nprocs 483 opal/mca/pmix/pmix4x/pmix/examples/server.c x->info[i].value.data.uint32 = nprocs; nprocs 485 opal/mca/pmix/pmix4x/pmix/examples/server.c PMIx_server_register_nspace(nspace, nprocs, x->info, x->ninfo, nprocs 542 opal/mca/pmix/pmix4x/pmix/examples/server.c pmix_proc_t procs[], size_t nprocs, nprocs 584 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 747 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 764 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 125 opal/mca/pmix/pmix4x/pmix/include/pmix.h pmix_proc_t procs[], size_t nprocs); nprocs 177 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Fence(const pmix_proc_t procs[], size_t nprocs, nprocs 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, nprocs 370 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Connect(const pmix_proc_t procs[], size_t nprocs, nprocs 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, nprocs 383 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Disconnect(const pmix_proc_t procs[], size_t nprocs, nprocs 386 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Disconnect_nb(const pmix_proc_t ranges[], size_t nprocs, nprocs 399 opal/mca/pmix/pmix4x/pmix/include/pmix.h pmix_proc_t **procs, size_t *nprocs); nprocs 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, nprocs 795 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, nprocs 800 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, nprocs 849 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, nprocs 854 opal/mca/pmix/pmix4x/pmix/include/pmix.h const pmix_proc_t procs[], size_t nprocs, nprocs 102 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h pmix_proc_t procs[], size_t nprocs, nprocs 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, nprocs 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, nprocs 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, nprocs 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, nprocs 517 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h const pmix_proc_t procs[], size_t nprocs, nprocs 877 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_proc_t procs[], size_t nprocs) nprocs 928 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c bfr, &nprocs, 1, PMIX_SIZE); nprocs 935 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (0 < nprocs) { nprocs 937 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c bfr, procs, nprocs, PMIX_PROC); nprocs 1233 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c &cb->procs, &cb->nprocs); nprocs 1242 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_proc_t **procs, size_t *nprocs) nprocs 1283 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c *nprocs = cb->nprocs; nprocs 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, nprocs 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))) { nprocs 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, nprocs 138 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (NULL == procs || 0 >= nprocs) { nprocs 153 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, &nprocs, 1, PMIX_SIZE); nprocs 159 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, procs, nprocs, PMIX_PROC); nprocs 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, nprocs 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))) { nprocs 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, nprocs 256 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c for (cnt = 0; cnt < nprocs; cnt++) { nprocs 275 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (NULL == procs || 0 >= nprocs) { nprocs 290 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, &nprocs, 1, PMIX_SIZE); nprocs 296 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, procs, nprocs, PMIX_PROC); nprocs 60 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c const pmix_proc_t *procs, size_t nprocs, nprocs 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, nprocs 96 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (PMIX_SUCCESS != (rc = PMIx_Fence_nb(procs, nprocs, info, ninfo, nprocs 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, nprocs 143 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (NULL == procs && 0 != nprocs) { nprocs 155 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c nrg = nprocs; nprocs 204 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c const pmix_proc_t *procs, size_t nprocs, nprocs 219 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c msg, &nprocs, 1, PMIX_SIZE); nprocs 226 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c msg, procs, nprocs, PMIX_PROC); nprocs 122 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, nprocs 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))) { nprocs 172 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, nprocs 202 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == procs || 0 >= nprocs) { nprocs 246 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, &nprocs, 1, PMIX_SIZE); nprocs 252 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, procs, nprocs, PMIX_PROC); nprocs 574 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, nprocs 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); nprocs 628 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DATA_ARRAY_CREATE(cb.info[n].value.data.darray, nprocs, PMIX_PROC); nprocs 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)); nprocs 661 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c const pmix_proc_t procs[], size_t nprocs, nprocs 703 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c for (n=0; n < nprocs; n++) { nprocs 755 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DATA_ARRAY_CREATE(cb->info[n].value.data.darray, nprocs, PMIX_PROC); nprocs 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)); nprocs 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, nprocs 147 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c msg, &nprocs, 1, PMIX_SIZE); nprocs 153 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c msg, procs, nprocs, PMIX_PROC); nprocs 53 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h size_t nprocs; nprocs 980 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rngtrk.nprocs = 0; nprocs 1013 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rngtrk.nprocs = 1; nprocs 1016 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c rngtrk.nprocs = cd->ntargets; nprocs 1196 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c for (n=0; n < rng->nprocs; n++) { nprocs 1204 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c for (n=0; n < rng->nprocs; n++) { nprocs 1213 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c for (n=0; n < rng->nprocs; n++) { nprocs 1348 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c p->rng.nprocs = 0; nprocs 474 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c size_t nprocs = 0; nprocs 525 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c nprocs = cd->info[n].value.data.darray->size; nprocs 581 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != parray && 0 < nprocs) { nprocs 582 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c evhdlr->rng.nprocs = nprocs; nprocs 583 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_PROC_CREATE(evhdlr->rng.procs, nprocs); nprocs 590 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c memcpy(evhdlr->rng.procs, parray, nprocs * sizeof(pmix_proc_t)); nprocs 666 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != parray && 0 < nprocs) { nprocs 667 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c evhdlr->rng.nprocs = nprocs; nprocs 668 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_PROC_CREATE(evhdlr->rng.procs, nprocs); nprocs 675 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c memcpy(evhdlr->rng.procs, parray, nprocs * sizeof(pmix_proc_t)); nprocs 104 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c p->nprocs = 0; nprocs 304 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c p->nprocs = 0; nprocs 178 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_rank_t nprocs; // num procs in this nspace nprocs 402 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h size_t nprocs; nprocs 1515 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ssize_t nprocs = 0; nprocs 1529 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c nprocs = (ssize_t)val->data.uint32; nprocs 1531 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c return nprocs; nprocs 1943 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c uint32_t nprocs; nprocs 1994 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c nprocs = (size_t) _nprocs; nprocs 1997 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c nprocs = 1; nprocs 2068 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c while (nprocs--) { nprocs 2781 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c for (rank=0; rank < ns->nprocs; rank++) { nprocs 226 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c if (rel_rank < nm->ns->nprocs) { nprocs 230 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c rel_rank -= nm->ns->nprocs; nprocs 549 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c nptr->nprocs = info[n].value.data.uint32; nprocs 645 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c for (rank=0; rank < ns->nprocs; rank++) { nprocs 301 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c size_t nprocs; nprocs 333 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c pmix_preg.resolve_peers(nodes[n], nptr->nspace, &procs, &nprocs); nprocs 337 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c for (m=0; m < nprocs; m++) { nprocs 90 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/base.h pmix_proc_t **procs, size_t *nprocs); nprocs 99 opal/mca/pmix/pmix4x/pmix/src/mca/preg/base/preg_base_stubs.c pmix_proc_t **procs, size_t *nprocs) nprocs 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)) { nprocs 54 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_proc_t **procs, size_t *nprocs); nprocs 522 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_proc_t **procs, size_t *nprocs) nprocs 603 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c *nprocs = np; nprocs 83 opal/mca/pmix/pmix4x/pmix/src/mca/preg/preg.h pmix_proc_t **procs, size_t *nprocs); nprocs 1814 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cd->nprocs = 1; nprocs 3203 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_PROC_FREE(cd->procs, cd->nprocs); nprocs 91 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t nprocs; nprocs 111 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, &nprocs, &cnt, PMIX_SIZE); nprocs 118 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 < nprocs) { nprocs 119 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); nprocs 126 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = nprocs; nprocs 141 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs, nprocs, cbfunc, cbdata); nprocs 145 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 312 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t nprocs, pmix_cmd_t type) nprocs 319 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c "get_tracker called with %d procs", (int)nprocs); nprocs 343 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (nprocs != trk->npcs) { nprocs 350 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (i=0; i < nprocs; i++) { nprocs 387 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t nprocs, pmix_cmd_t type) nprocs 397 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c "new_tracker called with %d procs", (int)nprocs); nprocs 407 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c (NULL == id) ? "NO-ID" : id, (int)nprocs); nprocs 422 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(trk->pcs, nprocs); nprocs 428 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memcpy(trk->pcs, procs, nprocs * sizeof(pmix_proc_t)); nprocs 429 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->npcs = nprocs; nprocs 434 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (i=0; i < nprocs; i++) { nprocs 659 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rel_rank += nm->ns->nprocs; nprocs 785 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t nprocs; nprocs 809 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, cd->peer, buf, &nprocs, &cnt, PMIX_SIZE); nprocs 815 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->peer->info->pname.nspace, cd->peer->info->pname.rank, (int)nprocs); nprocs 818 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (nprocs < 1) { nprocs 823 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); nprocs 828 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = nprocs; nprocs 836 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nmbrs = nprocs; nprocs 841 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (n=0; n < nprocs; n++) { nprocs 882 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 884 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nprocs = nmbrs; nprocs 897 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 918 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_FENCENB_CMD))) { nprocs 920 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_FENCENB_CMD))) { nprocs 1017 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 1570 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t nprocs, ninfo; nprocs 1580 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, cd->peer, buf, &nprocs, &cnt, PMIX_SIZE); nprocs 1590 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (nprocs < 1) { nprocs 1597 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); nprocs 1602 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = nprocs; nprocs 1630 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_DISCONNECTNB_CMD))) { nprocs 1632 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_DISCONNECTNB_CMD))) { nprocs 1703 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t nprocs, ninfo, n; nprocs 1718 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, cd->peer, buf, &nprocs, &cnt, PMIX_SIZE); nprocs 1728 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (nprocs < 1) { nprocs 1735 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); nprocs 1740 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = nprocs; nprocs 1775 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_CONNECTNB_CMD))) { nprocs 1777 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_CONNECTNB_CMD))) { nprocs 1831 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 1854 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rngtrk.nprocs = 0; nprocs 1880 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c scd->procs, scd->nprocs)) { nprocs 1886 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rngtrk.nprocs = 1; nprocs 1889 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rngtrk.nprocs = cd->ntargets; nprocs 2251 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c scd->nprocs = naffected; nprocs 2278 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c scd->nprocs = naffected; nprocs 3396 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, &cd->nprocs, &cnt, PMIX_SIZE); nprocs 3402 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 < cd->nprocs) { nprocs 3403 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(cd->procs, cd->nprocs); nprocs 3404 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = cd->nprocs; nprocs 3440 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (n=0; n < cd->nprocs; n++) { nprocs 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, nprocs 3556 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(cd->procs, cd->nprocs); nprocs 3593 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, &cd->nprocs, &cnt, PMIX_SIZE); nprocs 3598 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 < cd->nprocs) { nprocs 3599 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(cd->procs, cd->nprocs); nprocs 3604 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = cd->nprocs; nprocs 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, nprocs 3889 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c size_t n, ninfo, nprocs, n2; nprocs 3936 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_BFROPS_UNPACK(rc, peer, buf, &nprocs, &cnt, PMIX_SIZE); nprocs 3941 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 == nprocs) { nprocs 3944 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); nprocs 3949 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cnt = nprocs; nprocs 3953 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 3961 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (n=0; n < nprocs; n++) { nprocs 3996 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 3997 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nprocs = pmix_list_get_size(&mbrs); nprocs 3998 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(procs, nprocs); nprocs 4007 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp->nmbrs = nprocs; nprocs 4009 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(procs, nprocs); nprocs 4435 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c p->nprocs = 0; nprocs 4458 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_FREE(p->procs, p->nprocs); nprocs 53 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h size_t nprocs; nprocs 285 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_proc_t procs[], size_t nprocs, nprocs 32 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c void cli_init(int nprocs) nprocs 37 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli_info = malloc( sizeof(cli_info_t) * nprocs); nprocs 38 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli_info_cnt = nprocs; nprocs 47 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c for (n=0; n < nprocs; n++) { nprocs 57 opal/mca/pmix/pmix4x/pmix/test/cli_stages.h void cli_init(int nprocs); nprocs 110 opal/mca/pmix/pmix4x/pmix/test/pmix_test.c base_rank += (params.nprocs % params.nservers) > (uint32_t)i ? nprocs 111 opal/mca/pmix/pmix4x/pmix/test/pmix_test.c params.nprocs / params.nservers + 1 : nprocs 112 opal/mca/pmix/pmix4x/pmix/test/pmix_test.c params.nprocs / params.nservers; nprocs 115 opal/mca/pmix/pmix4x/pmix/test/pmix_test.c ns_nprocs = params.nprocs; nprocs 116 opal/mca/pmix/pmix4x/pmix/test/pmix_test.c launched += server_launch_clients(params.lsize, params.nprocs, base_rank, nprocs 123 opal/mca/pmix/pmix4x/pmix/test/pmix_test.c if (params.nprocs < (uint32_t)(launched+ns_nprocs)) { nprocs 110 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_proc_t procs[], size_t nprocs, nprocs 122 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 303 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 314 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 25 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_proc_t procs[], size_t nprocs, nprocs 27 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 47 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 50 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.h pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 54 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c pmix_proc_t procs[], size_t nprocs, nprocs 56 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 76 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 79 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 217 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 295 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c int rc, nprocs=1, n; nprocs 321 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c nprocs = strtol(argv[n+1], NULL, 10); nprocs 400 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c for (n=0; n < nprocs; n++) { nprocs 408 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c set_namespace(nprocs, tmp, "foobar", opcbfunc, x); nprocs 414 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c wakeup = nprocs; nprocs 442 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c PMIX_INFO_LOAD(&iarray[2], PMIX_ALLOC_NETWORK_ENDPTS, &nprocs, PMIX_SIZE); nprocs 464 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c for (n = 0; n < nprocs; n++) { nprocs 551 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 563 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c x->ninfo = 7 + nprocs; nprocs 568 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c x->info[0].value.data.uint32 = nprocs; nprocs 576 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c x->info[2].value.data.uint32 = nprocs; nprocs 594 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c x->info[6].value.data.uint32 = nprocs; nprocs 596 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c for (n=0; n < nprocs; n++) { nprocs 611 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c PMIx_server_register_nspace(nspace, nprocs, x->info, x->ninfo, nprocs 672 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c pmix_proc_t procs[], size_t nprocs, nprocs 714 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 897 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 916 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 118 opal/mca/pmix/pmix4x/pmix/test/simple/quietclient.c uint32_t nprocs, n; nprocs 175 opal/mca/pmix/pmix4x/pmix/test/simple/quietclient.c nprocs = val->data.uint32; nprocs 226 opal/mca/pmix/pmix4x/pmix/test/simple/quietclient.c for (n=0; n < nprocs; n++) { nprocs 132 opal/mca/pmix/pmix4x/pmix/test/simple/simpclient.c uint32_t nprocs, n; nprocs 207 opal/mca/pmix/pmix4x/pmix/test/simple/simpclient.c nprocs = val->data.uint32; nprocs 209 opal/mca/pmix/pmix4x/pmix/test/simple/simpclient.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 259 opal/mca/pmix/pmix4x/pmix/test/simple/simpclient.c for (n=0; n < nprocs; n++) { nprocs 89 opal/mca/pmix/pmix4x/pmix/test/simple/simpdie.c uint32_t nprocs; nprocs 107 opal/mca/pmix/pmix4x/pmix/test/simple/simpdie.c nprocs = val->data.uint32; nprocs 109 opal/mca/pmix/pmix4x/pmix/test/simple/simpdie.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 126 opal/mca/pmix/pmix4x/pmix/test/simple/simpdie.c if (4 < nprocs) { nprocs 38 opal/mca/pmix/pmix4x/pmix/test/simple/simpdmodex.c static uint32_t nprocs; nprocs 123 opal/mca/pmix/pmix4x/pmix/test/simple/simpdmodex.c nprocs = val->data.uint32; nprocs 125 opal/mca/pmix/pmix4x/pmix/test/simple/simpdmodex.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 179 opal/mca/pmix/pmix4x/pmix/test/simple/simpdmodex.c for (n=0; n < nprocs; n++) { nprocs 48 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c uint32_t nprocs; nprocs 72 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c nprocs = val->data.uint32; nprocs 74 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 149 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c if ((nprocs+ntmp) != npeers) { nprocs 150 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c pmix_output(0, "Client ns %s rank %d: PMIx_Resolve_peers returned incorrect npeers: %d vs %d", myproc.nspace, myproc.rank, (int)(nprocs+ntmp), (int)npeers); nprocs 164 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c if (nprocs != npeers) { nprocs 165 opal/mca/pmix/pmix4x/pmix/test/simple/simpdyn.c pmix_output(0, "Client ns %s rank %d: PMIx_Resolve_peers returned incorrect npeers: %d vs %d", myproc.nspace, myproc.rank, nprocs, (int)npeers); nprocs 77 opal/mca/pmix/pmix4x/pmix/test/simple/simpft.c uint32_t nprocs; nprocs 93 opal/mca/pmix/pmix4x/pmix/test/simple/simpft.c nprocs = val->data.uint32; nprocs 95 opal/mca/pmix/pmix4x/pmix/test/simple/simpft.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 102 opal/mca/pmix/pmix4x/pmix/test/simple/simpjctrl.c uint32_t nprocs, n; nprocs 141 opal/mca/pmix/pmix4x/pmix/test/simple/simpjctrl.c nprocs = val->data.uint32; nprocs 143 opal/mca/pmix/pmix4x/pmix/test/simple/simpjctrl.c fprintf(stderr, "Client %s:%d universe size %d\n", myproc.nspace, myproc.rank, nprocs); nprocs 124 opal/mca/pmix/pmix4x/pmix/test/simple/simplegacy.c uint32_t nprocs, n; nprocs 151 opal/mca/pmix/pmix4x/pmix/test/simple/simplegacy.c nprocs = val->data .uint32; nprocs 153 opal/mca/pmix/pmix4x/pmix/test/simple/simplegacy.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 212 opal/mca/pmix/pmix4x/pmix/test/simple/simplegacy.c for (n=0; n < nprocs; n++) { nprocs 45 opal/mca/pmix/pmix4x/pmix/test/simple/simppub.c uint32_t nprocs; nprocs 64 opal/mca/pmix/pmix4x/pmix/test/simple/simppub.c nprocs = val->data.uint32; nprocs 66 opal/mca/pmix/pmix4x/pmix/test/simple/simppub.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 60 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_proc_t procs[], size_t nprocs, nprocs 62 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 82 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 85 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 202 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 335 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c int rc, nprocs=1, n, k; nprocs 365 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c nprocs = strtol(argv[n+1], NULL, 10); nprocs 416 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c if (cross_version && nprocs < 2) { nprocs 521 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c for (n=0; n < nprocs; n++) { nprocs 529 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c set_namespace(nprocs, tmp, "foobar", opcbfunc, x); nprocs 535 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c wakeup = nprocs; nprocs 562 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c for (n = 0; n < nprocs; n++) { nprocs 700 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 712 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c x->info[0].value.data.uint32 = nprocs; nprocs 720 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c x->info[2].value.data.uint32 = nprocs; nprocs 738 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c x->info[6].value.data.uint32 = nprocs; nprocs 740 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c PMIx_server_register_nspace(nspace, nprocs, x->info, x->ninfo, nprocs 800 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_proc_t procs[], size_t nprocs, nprocs 851 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 1057 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 1072 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 76 opal/mca/pmix/pmix4x/pmix/test/simple/simptimeout.c uint32_t nprocs, n; nprocs 114 opal/mca/pmix/pmix4x/pmix/test/simple/simptimeout.c nprocs = val->data.uint32; nprocs 116 opal/mca/pmix/pmix4x/pmix/test/simple/simptimeout.c pmix_output(0, "Client %s:%d universe size %d", myproc.nspace, myproc.rank, nprocs); nprocs 60 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c pmix_proc_t procs[], size_t nprocs, nprocs 62 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 82 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 85 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 186 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 216 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c int rc, nprocs=1, n, k; nprocs 241 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c nprocs = strtol(argv[n+1], NULL, 10); nprocs 314 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c for (n=0; n < nprocs; n++) { nprocs 324 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c set_namespace(nprocs, tmp, nspace, opcbfunc, x); nprocs 331 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c wakeup = nprocs; nprocs 343 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c for (n = 0; n < nprocs; n++) { nprocs 401 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c for (n = 0; n < nprocs; n++) { nprocs 444 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static void set_namespace(int nprocs, char *ranks, char *nspace, nprocs 456 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c x->info[0].value.data.uint32 = nprocs; nprocs 464 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c x->info[2].value.data.uint32 = nprocs; nprocs 482 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c x->info[6].value.data.uint32 = nprocs; nprocs 484 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c PMIx_server_register_nspace(nspace, nprocs, x->info, x->ninfo, nprocs 541 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c pmix_proc_t procs[], size_t nprocs, nprocs 577 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 735 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 753 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 55 opal/mca/pmix/pmix4x/pmix/test/test_common.c params->nprocs = strtol(argv[i], NULL, 10); nprocs 57 opal/mca/pmix/pmix4x/pmix/test/test_common.c params->ns_size = params->nprocs; nprocs 108 opal/mca/pmix/pmix4x/pmix/test/test_common.h uint32_t nprocs; nprocs 137 opal/mca/pmix/pmix4x/pmix/test/test_common.h params.nprocs = 1; \ nprocs 314 opal/mca/pmix/pmix4x/pmix/test/test_common.h #define FENCE(blocking, data_ex, pcs, nprocs) do { \ nprocs 325 opal/mca/pmix/pmix4x/pmix/test/test_common.h rc = PMIx_Fence(pcs, nprocs, info, ninfo); \ nprocs 329 opal/mca/pmix/pmix4x/pmix/test/test_common.h rc = PMIx_Fence_nb(pcs, nprocs, NULL, 0, release_cb, &in_progress); \ nprocs 22 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c size_t nprocs, nranks, i; nprocs 24 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c rc = PMIx_Resolve_peers(NODE_NAME, nspace, &procs, &nprocs); nprocs 29 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c if (NULL == procs || 0 == nprocs) { nprocs 36 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIX_PROC_FREE(procs, nprocs); nprocs 39 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c if (nprocs != nranks) { nprocs 40 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Resolve peers returned incorect result: returned %lu processes, expected %lu", my_nspace, my_rank, nprocs, nranks)); nprocs 41 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIX_PROC_FREE(procs, nprocs); nprocs 45 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c for (i = 0; i < nprocs; i++) { nprocs 53 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c PMIX_PROC_FREE(procs, nprocs); nprocs 96 opal/mca/pmix/pmix4x/pmix/test/test_server.c static void fill_seq_ranks_array(size_t nprocs, int base_rank, char **ranks) nprocs 100 opal/mca/pmix/pmix4x/pmix/test/test_server.c if (0 >= nprocs) { nprocs 103 opal/mca/pmix/pmix4x/pmix/test/test_server.c max_ranks_len = nprocs * (MAX_DIGIT_LEN+1); nprocs 105 opal/mca/pmix/pmix4x/pmix/test/test_server.c for (i = 0; i < nprocs; i++) { nprocs 107 opal/mca/pmix/pmix4x/pmix/test/test_server.c if (i != nprocs-1) { nprocs 788 opal/mca/pmix/pmix4x/pmix/test/test_server.c params->lsize = (params->nprocs % params->nservers) > (uint32_t)my_server_id ? nprocs 789 opal/mca/pmix/pmix4x/pmix/test/test_server.c params->nprocs / params->nservers + 1 : nprocs 790 opal/mca/pmix/pmix4x/pmix/test/test_server.c params->nprocs / params->nservers; nprocs 1737 opal/mca/pmix/pmix4x/pmix4x.c p->nprocs = 0; nprocs 1769 opal/mca/pmix/pmix4x/pmix4x.c PMIX_PROC_FREE(p->procs, p->nprocs); nprocs 89 opal/mca/pmix/pmix4x/pmix4x.h size_t nprocs; nprocs 550 opal/mca/pmix/pmix4x/pmix4x_client.c op->nprocs = cnt; nprocs 559 opal/mca/pmix/pmix4x/pmix4x_client.c rc = PMIx_Fence_nb(op->procs, op->nprocs, op->info, op->ninfo, opcbfunc, op); nprocs 1311 opal/mca/pmix/pmix4x/pmix4x_client.c size_t nprocs; nprocs 1321 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { nprocs 1333 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(p, nprocs); nprocs 1337 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1347 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Connect(p, nprocs, NULL, 0); nprocs 1348 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1381 opal/mca/pmix/pmix4x/pmix4x_client.c op->nprocs = opal_list_get_size(procs); nprocs 1385 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1399 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Connect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1408 opal/mca/pmix/pmix4x/pmix4x_client.c size_t nprocs, n; nprocs 1418 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL == procs || 0 == (nprocs = opal_list_get_size(procs))) { nprocs 1430 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(p, nprocs); nprocs 1434 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1444 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Disconnect(p, nprocs, NULL, 0); nprocs 1445 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_FREE(p, nprocs); nprocs 1478 opal/mca/pmix/pmix4x/pmix4x_client.c op->nprocs = opal_list_get_size(procs); nprocs 1482 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1496 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Disconnect_nb(op->procs, op->nprocs, NULL, 0, opcbfunc, op); nprocs 1510 opal/mca/pmix/pmix4x/pmix4x_client.c size_t nprocs, n; nprocs 1530 opal/mca/pmix/pmix4x/pmix4x_client.c ret = PMIx_Resolve_peers(nodename, nspace, &array, &nprocs); nprocs 1532 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL != array && 0 < nprocs) { nprocs 1534 opal/mca/pmix/pmix4x/pmix4x_client.c for (n=0; n < nprocs; n++) { nprocs 1557 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_FREE(array, nprocs); nprocs 1638 opal/mca/pmix/pmix4x/pmix4x_client.c op->nprocs = opal_list_get_size(targets); nprocs 1642 opal/mca/pmix/pmix4x/pmix4x_client.c PMIX_PROC_CREATE(op->procs, op->nprocs); nprocs 1667 opal/mca/pmix/pmix4x/pmix4x_client.c rc = PMIx_Job_control_nb(op->procs,op->nprocs, op->info, op->ninfo, infocbfunc, op); nprocs 55 opal/mca/pmix/pmix4x/pmix4x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 57 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 77 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 80 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 114 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, nprocs 227 opal/mca/pmix/pmix4x/pmix4x_server_north.c pmix_proc_t procs[], size_t nprocs, nprocs 257 opal/mca/pmix/pmix4x/pmix4x_server_north.c for (n=0; n < nprocs; n++) { nprocs 317 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_fencenb_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 340 opal/mca/pmix/pmix4x/pmix4x_server_north.c for (n=0; n < nprocs; n++) { nprocs 714 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_connect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 734 opal/mca/pmix/pmix4x/pmix4x_server_north.c for (n=0; n < nprocs; n++) { nprocs 765 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_disconnect_fn(const pmix_proc_t procs[], size_t nprocs, nprocs 785 opal/mca/pmix/pmix4x/pmix4x_server_north.c for (n=0; n < nprocs; n++) { nprocs 1317 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_iof_pull(const pmix_proc_t procs[], size_t nprocs, nprocs 46 orte/mca/grpcomm/direct/grpcomm_direct.c size_t nprocs, nprocs 108 orte/mca/grpcomm/direct/grpcomm_direct.c size_t nprocs, nprocs 112 orte/mca/grpcomm/grpcomm.h size_t nprocs, nprocs 56 orte/mca/rmaps/base/rmaps_base_map_job.c orte_vpid_t nprocs; nprocs 101 orte/mca/rmaps/base/rmaps_base_map_job.c nprocs = 0; nprocs 122 orte/mca/rmaps/base/rmaps_base_map_job.c nprocs += app->num_procs; nprocs 129 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_JOBID_PRINT(jdata->jobid), (int)nprocs); nprocs 143 orte/mca/rmaps/base/rmaps_base_map_job.c if (nprocs <= 2) { nprocs 266 orte/mca/rmaps/base/rmaps_base_map_job.c if (nprocs <= 2) { nprocs 295 orte/mca/rmaps/base/rmaps_base_map_job.c } else if (nprocs <= 2) { nprocs 445 orte/mca/rmaps/ppr/rmaps_ppr.c int nprocs; nprocs 503 orte/mca/rmaps/ppr/rmaps_ppr.c nprocs = 0; nprocs 518 orte/mca/rmaps/ppr/rmaps_ppr.c nprocs++; nprocs 523 orte/mca/rmaps/ppr/rmaps_ppr.c nprocs, limit); nprocs 526 orte/mca/rmaps/ppr/rmaps_ppr.c while (limit < nprocs) { nprocs 552 orte/mca/rmaps/ppr/rmaps_ppr.c for (k=0; k < top->arity && limit < nprocs; k++) { nprocs 601 orte/mca/rmaps/ppr/rmaps_ppr.c nprocs--; nprocs 44 orte/mca/rmaps/round_robin/rmaps_rr.h orte_vpid_t nprocs); nprocs 49 orte/mca/rmaps/round_robin/rmaps_rr.h orte_vpid_t nprocs); nprocs 475 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c int nprocs, start; nprocs 548 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = 1; nprocs 550 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = orte_rmaps_base_n_pernode; nprocs 553 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = orte_rmaps_base_n_persocket * nobjs; nprocs 555 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = orte_rmaps_base_n_persocket * opal_hwloc_base_get_nbobjs_by_type(node->topology->topo, HWLOC_OBJ_PACKAGE, 0, OPAL_HWLOC_AVAILABLE); nprocs 558 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = node->slots - node->slots_inuse; nprocs 561 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c "mca:rmaps:rr: calculated nprocs %d", nprocs); nprocs 562 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (nprocs < 1) { nprocs 567 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = 1; nprocs 585 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c "mca:rmaps:rr: assigning nprocs %d", nprocs); nprocs 588 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c for (i=0; i < (int)nobjs && nmapped < nprocs && nprocs_mapped < (int)app->num_procs; i++) { nprocs 609 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c } while (nmapped < nprocs && nprocs_mapped < (int)app->num_procs); nprocs 665 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c int nprocs, nxtra_objs; nprocs 750 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = 1; nprocs 752 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = orte_rmaps_base_n_pernode; nprocs 755 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = orte_rmaps_base_n_persocket * nobjs; nprocs 757 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = orte_rmaps_base_n_persocket * opal_hwloc_base_get_nbobjs_by_type(node->topology->topo, HWLOC_OBJ_PACKAGE, 0, OPAL_HWLOC_AVAILABLE); nprocs 760 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs = navg; nprocs 763 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c nprocs++; nprocs 767 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c for (j=0; j < nprocs && nprocs_mapped < app->num_procs; j++) { nprocs 6 orte/test/mpi/bcast_loop.c int myid, nprocs, tag; nprocs 14 orte/test/mpi/bcast_loop.c MPI_Comm_size(MPI_COMM_WORLD, &nprocs); nprocs 30 orte/test/system/get_limits.c int nfds_needed = calculate_nfds_needed (nprocs); nprocs 521 oshmem/mca/memheap/base/memheap_base_mkey.c int nprocs, my_pe; nprocs 537 oshmem/mca/memheap/base/memheap_base_mkey.c nprocs = oshmem_num_procs(); nprocs 543 oshmem/mca/memheap/base/memheap_base_mkey.c rcv_size = (int *)malloc(nprocs * sizeof(int)); nprocs 550 oshmem/mca/memheap/base/memheap_base_mkey.c rcv_offsets = (int *)malloc(nprocs * sizeof(int)); nprocs 557 oshmem/mca/memheap/base/memheap_base_mkey.c rcv_n_transports = (int *)malloc(nprocs * sizeof(int)); nprocs 603 oshmem/mca/memheap/base/memheap_base_mkey.c for (i = 1; i < nprocs; i++) { nprocs 607 oshmem/mca/memheap/base/memheap_base_mkey.c buffer_size = rcv_offsets[nprocs - 1] + rcv_size[nprocs - 1]; nprocs 627 oshmem/mca/memheap/base/memheap_base_mkey.c for (i = 0; i < nprocs; i++) { nprocs 76 oshmem/mca/memheap/base/memheap_base_register.c int nprocs, my_pe; nprocs 78 oshmem/mca/memheap/base/memheap_base_register.c nprocs = oshmem_num_procs(); nprocs 84 oshmem/mca/memheap/base/memheap_base_register.c for (j = 0; j < nprocs; j++) { nprocs 110 oshmem/mca/memheap/base/memheap_base_register.c int nprocs; nprocs 112 oshmem/mca/memheap/base/memheap_base_register.c nprocs = oshmem_num_procs(); nprocs 115 oshmem/mca/memheap/base/memheap_base_register.c s->mkeys_cache = (sshmem_mkey_t **) calloc(nprocs, nprocs 63 oshmem/mca/spml/base/base.h size_t nprocs); nprocs 286 oshmem/mca/spml/ikrit/spml_ikrit.c int mca_spml_ikrit_del_procs(ompi_proc_t** procs, size_t nprocs) nprocs 300 oshmem/mca/spml/ikrit/spml_ikrit.c for (n = 0; n < nprocs; n++) { nprocs 301 oshmem/mca/spml/ikrit/spml_ikrit.c i = (my_rank + n) % nprocs; nprocs 314 oshmem/mca/spml/ikrit/spml_ikrit.c int mca_spml_ikrit_add_procs(ompi_proc_t** procs, size_t nprocs) nprocs 328 oshmem/mca/spml/ikrit/spml_ikrit.c ep_info = calloc(sizeof(spml_ikrit_mxm_ep_conn_info_t), nprocs); nprocs 335 oshmem/mca/spml/ikrit/spml_ikrit.c ep_hw_rdma_info = calloc(sizeof(spml_ikrit_mxm_ep_conn_info_t), nprocs); nprocs 342 oshmem/mca/spml/ikrit/spml_ikrit.c mca_spml_ikrit.mxm_peers = (mxm_peer_t *) calloc(nprocs , sizeof(mxm_peer_t)); nprocs 375 oshmem/mca/spml/ikrit/spml_ikrit.c for (n = 0; n < nprocs; ++n) { nprocs 379 oshmem/mca/spml/ikrit/spml_ikrit.c i = (my_rank + n) % nprocs; nprocs 412 oshmem/mca/spml/ikrit/spml_ikrit.c for (i = 0; i < nprocs; i++) { nprocs 189 oshmem/mca/spml/ikrit/spml_ikrit.h extern int mca_spml_ikrit_add_procs(ompi_proc_t** procs, size_t nprocs); nprocs 190 oshmem/mca/spml/ikrit/spml_ikrit.h extern int mca_spml_ikrit_del_procs(ompi_proc_t** procs, size_t nprocs); nprocs 197 oshmem/mca/spml/spml.h size_t nprocs); nprocs 199 oshmem/mca/spml/spml.h size_t nprocs); nprocs 101 oshmem/mca/spml/ucx/spml_ucx.c int mca_spml_ucx_del_procs(ompi_proc_t** procs, size_t nprocs) nprocs 113 oshmem/mca/spml/ucx/spml_ucx.c del_procs = malloc(sizeof(*del_procs) * nprocs); nprocs 118 oshmem/mca/spml/ucx/spml_ucx.c for (i = 0; i < nprocs; ++i) { nprocs 126 oshmem/mca/spml/ucx/spml_ucx.c ret = opal_common_ucx_del_procs(del_procs, nprocs, oshmem_my_proc_id(), nprocs 143 oshmem/mca/spml/ucx/spml_ucx.c void *local_data, int local_size, int nprocs, nprocs 153 oshmem/mca/spml/ucx/spml_ucx.c rcv_offsets = malloc(nprocs * sizeof(*rcv_offsets)); nprocs 159 oshmem/mca/spml/ucx/spml_ucx.c rcv_sizes = malloc(nprocs * sizeof(*rcv_sizes)); nprocs 171 oshmem/mca/spml/ucx/spml_ucx.c for (i = 1; i < nprocs; i++) { nprocs 175 oshmem/mca/spml/ucx/spml_ucx.c rcv_buf = malloc(rcv_offsets[nprocs - 1] + rcv_sizes[nprocs - 1]); nprocs 216 oshmem/mca/spml/ucx/spml_ucx.c int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs) nprocs 230 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx_ctx_default.ucp_peers = (ucp_peer_t *) calloc(nprocs, sizeof(*(mca_spml_ucx_ctx_default.ucp_peers))); nprocs 241 oshmem/mca/spml/ucx/spml_ucx.c rc = oshmem_shmem_xchng(wk_local_addr, wk_addr_len, nprocs, nprocs 249 oshmem/mca/spml/ucx/spml_ucx.c mca_spml_ucx.remote_addrs_tbl = (char **)calloc(nprocs, sizeof(char *)); nprocs 250 oshmem/mca/spml/ucx/spml_ucx.c memset(mca_spml_ucx.remote_addrs_tbl, 0, nprocs * sizeof(char *)); nprocs 253 oshmem/mca/spml/ucx/spml_ucx.c for (n = 0; n < nprocs; ++n) { nprocs 254 oshmem/mca/spml/ucx/spml_ucx.c i = (my_rank + n) % nprocs; nprocs 263 oshmem/mca/spml/ucx/spml_ucx.c SPML_UCX_ERROR("ucp_ep_create(proc=%zu/%zu) failed: %s", n, nprocs, nprocs 289 oshmem/mca/spml/ucx/spml_ucx.c for (i = 0; i < nprocs; ++i) { nprocs 554 oshmem/mca/spml/ucx/spml_ucx.c size_t i, nprocs = oshmem_num_procs(); nprocs 579 oshmem/mca/spml/ucx/spml_ucx.c ucx_ctx->ucp_peers = (ucp_peer_t *) calloc(nprocs, sizeof(*(ucx_ctx->ucp_peers))); nprocs 584 oshmem/mca/spml/ucx/spml_ucx.c for (i = 0; i < nprocs; i++) { nprocs 590 oshmem/mca/spml/ucx/spml_ucx.c SPML_ERROR("ucp_ep_create(proc=%d/%d) failed: %s", i, nprocs, nprocs 616 oshmem/mca/spml/ucx/spml_ucx.c for (i = 0; i < nprocs; i++) { nprocs 164 oshmem/mca/spml/ucx/spml_ucx.h extern int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs); nprocs 165 oshmem/mca/spml/ucx/spml_ucx.h extern int mca_spml_ucx_del_procs(ompi_proc_t** procs, size_t nprocs); nprocs 311 oshmem/mca/spml/ucx/spml_ucx_component.c int i, j, nprocs = oshmem_num_procs(); nprocs 314 oshmem/mca/spml/ucx/spml_ucx_component.c del_procs = malloc(sizeof(*del_procs) * nprocs); nprocs 316 oshmem/mca/spml/ucx/spml_ucx_component.c for (i = 0; i < nprocs; ++i) { nprocs 328 oshmem/mca/spml/ucx/spml_ucx_component.c opal_common_ucx_del_procs_nofence(del_procs, nprocs, oshmem_my_proc_id(),