nprocs_recv 843 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c int i=0, j=0, k=0, tmp=0, nprocs_recv=0, nprocs_send=0; nprocs_recv 878 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c nprocs_recv = 0; nprocs_recv 880 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_size[i]) nprocs_recv++; nprocs_recv 887 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c malloc((nprocs_send+nprocs_recv+1) * sizeof(MPI_Request)); nprocs_recv 961 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c requests+nprocs_recv+j)); nprocs_recv 970 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (nprocs_recv) { nprocs_recv 972 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c ret = ompi_request_wait_all(nprocs_recv, nprocs_recv 992 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c requests+nprocs_recv, nprocs_recv 130 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int nprocs_recv, nprocs_recv 950 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *tmp_len=NULL, sum, *srt_len=NULL, nprocs_recv, nprocs_send, k,i,j; nprocs_recv 973 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c nprocs_recv = 0; nprocs_recv 976 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c nprocs_recv++; nprocs_recv 982 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c calloc (( nprocs_recv + 1 ), sizeof(ompi_datatype_t *)); nprocs_recv 1032 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c two_phase_heap_merge(others_req, count, srt_off, srt_len, start_pos, fh->f_size,fh->f_rank, nprocs_recv, sum); nprocs_recv 1066 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (nprocs_recv){ nprocs_recv 1122 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 1146 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c send_req = requests + nprocs_recv; nprocs_recv 1203 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c ret = ompi_request_wait_all (nprocs_send+nprocs_recv, nprocs_recv 1215 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for (i=0; i<nprocs_recv; i++) { nprocs_recv 1414 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int nprocs_recv, nprocs_recv 1429 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c a = (heap_struct *) malloc((nprocs_recv+1)*sizeof(heap_struct)); nprocs_recv 1440 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c heapsize = nprocs_recv; nprocs_recv 848 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int i, j, k=0, tmp=0, nprocs_recv, nprocs_send; nprocs_recv 859 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs_recv = 0; nprocs_recv 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_recv 866 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 924 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c fd->comm, requests+nprocs_recv+j); nprocs_recv 931 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_recv 936 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (nprocs_recv) { nprocs_recv 939 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c while (!j) MPI_Testall(nprocs_recv, requests, &j, statuses); nprocs_recv 941 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Waitall(nprocs_recv, requests, statuses); nprocs_recv 955 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Waitall(nprocs_send, requests+nprocs_recv, statuses+nprocs_recv); nprocs_recv 1142 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int i, j, k=0, tmp=0, nprocs_recv, nprocs_send; nprocs_recv 1156 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs_recv = 0; nprocs_recv 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_recv 1229 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (nprocs_recv) { nprocs_recv 106 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int nprocs_recv, int total_elements); nprocs_recv 1020 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int i, j, k, *tmp_len, nprocs_recv, nprocs_send, err; nprocs_recv 1036 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs_recv = 0; nprocs_recv 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_recv 1040 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Malloc((nprocs_recv+1)*sizeof(MPI_Datatype)); nprocs_recv 1074 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, nprocs_recv, sum); nprocs_recv 1109 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (nprocs_recv) { nprocs_recv 1139 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 1151 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_req = requests + nprocs_recv; nprocs_recv 1202 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<nprocs_recv; i++) MPI_Type_free(recv_types+i); nprocs_recv 1212 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_recv 1224 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c while (!i) MPI_Testall(nprocs_send+nprocs_recv, requests, &i, statuses); nprocs_recv 1231 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Waitall(nprocs_send+nprocs_recv, requests, statuses); nprocs_recv 1404 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int nprocs, int nprocs_recv, int total_elements) nprocs_recv 1415 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c a = (heap_struct *) ADIOI_Malloc((nprocs_recv+1)*sizeof(heap_struct)); nprocs_recv 1429 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c heapsize = nprocs_recv; nprocs_recv 1543 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int i, j, k=0, nprocs_recv, nprocs_send, *tmp_len, err; nprocs_recv 1565 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs_recv = 0; nprocs_recv 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_recv 1634 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs, nprocs_recv, sum); nprocs_recv 1656 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (nprocs_recv) { nprocs_recv 60 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int nprocs, int nprocs_recv, int total_elements); nprocs_recv 634 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int i, j, nprocs_recv, nprocs_send, err; nprocs_recv 644 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c nprocs_recv = 0; nprocs_recv 647 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c nprocs_recv++; nprocs_recv 649 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_types = (MPI_Datatype *) ADIOI_Malloc((nprocs_recv + 1) * nprocs_recv 685 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c nprocs, nprocs_recv, *srt_num); nprocs_recv 709 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (data_sieving == ADIOI_HINT_ENABLE && nprocs_recv && *hole) { nprocs_recv 736 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c requests = (MPI_Request *) ADIOI_Malloc((nprocs_send + nprocs_recv + 1)* nprocs_recv 749 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_req = requests + nprocs_recv; nprocs_recv 796 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (i = 0; i < nprocs_recv; i++) nprocs_recv 806 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send + nprocs_recv + 1) * nprocs_recv 818 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Testall(nprocs_send + nprocs_recv, requests, &i, statuses); nprocs_recv 825 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Waitall(nprocs_send + nprocs_recv, requests, statuses); nprocs_recv 151 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs_recv; nprocs_recv 1029 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int i, j, k = 0, tmp = 0, nprocs_recv, nprocs_send; nprocs_recv 1033 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs_recv = 0; nprocs_recv 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_recv 1035 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_recv = nprocs_recv; nprocs_recv 1042 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 1102 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->comm, vars->req2 + nprocs_recv + j); nprocs_recv 1110 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (nprocs_recv) { nprocs_recv 1123 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->nprocs_recv) { nprocs_recv 1275 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c errcode = MPI_Testall(red_vars->nprocs_recv, red_vars->req2, &flag, nprocs_recv 1285 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->req2 + red_vars->nprocs_recv, nprocs_recv 161 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_recv; nprocs_recv 189 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs, int nprocs_recv, int total_elements); nprocs_recv 1085 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int i, j, k, *tmp_len, nprocs_recv; nprocs_recv 1092 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs_recv = 0; nprocs_recv 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_recv 1094 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_recv = nprocs_recv; nprocs_recv 1097 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Malloc((nprocs_recv+1)*sizeof(MPI_Datatype)); nprocs_recv 1134 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs, nprocs_recv, sum); nprocs_recv 1174 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (nprocs_recv) { nprocs_recv 1200 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_recv = vars->nprocs_recv; nprocs_recv 1219 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 1231 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_req = vars->requests + nprocs_recv; nprocs_recv 1274 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Malloc((nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 1300 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_recv = vars->nprocs_recv; nprocs_recv 1304 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs_recv; i++) MPI_Type_free(recv_types+i); nprocs_recv 1313 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Testall(nprocs_send+nprocs_recv, vars->requests, &i, nprocs_recv 1493 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c errcode = MPI_Testall(wed_vars->nprocs_recv, wed_vars->req3, nprocs_recv 1508 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->nprocs_recv, nprocs_recv 784 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int i, j, k=0, tmp=0, nprocs_recv, nprocs_send; nprocs_recv 795 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c nprocs_recv = 0; nprocs_recv 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_recv 802 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 860 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c fd->comm, requests+nprocs_recv+j); nprocs_recv 867 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_recv 872 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (nprocs_recv) { nprocs_recv 875 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c while (!j) MPI_Testall(nprocs_recv, requests, &j, statuses); nprocs_recv 877 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Waitall(nprocs_recv, requests, statuses); nprocs_recv 891 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Waitall(nprocs_send, requests+nprocs_recv, statuses+nprocs_recv); nprocs_recv 51 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int nprocs, int nprocs_recv, int total_elements); nprocs_recv 579 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int i, j, k, *tmp_len, nprocs_recv, nprocs_send, err; nprocs_recv 595 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs_recv = 0; nprocs_recv 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_recv 599 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Malloc((nprocs_recv+1)*sizeof(MPI_Datatype)); nprocs_recv 635 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs, nprocs_recv, sum); nprocs_recv 675 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (nprocs_recv) { nprocs_recv 702 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_recv 714 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c send_req = requests + nprocs_recv; nprocs_recv 765 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs_recv; i++) MPI_Type_free(recv_types+i); nprocs_recv 775 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_recv 787 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c while (!i) MPI_Testall(nprocs_send+nprocs_recv, requests, &i, statuses); nprocs_recv 794 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c MPI_Waitall(nprocs_send+nprocs_recv, requests, statuses); nprocs_recv 971 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int nprocs, int nprocs_recv, int total_elements) nprocs_recv 982 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c a = (heap_struct *) ADIOI_Malloc((nprocs_recv+1)*sizeof(heap_struct)); nprocs_recv 996 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c heapsize = nprocs_recv;