nprocs_send 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_send 882 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c nprocs_send = 0; nprocs_send 884 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (send_size[i]) nprocs_send++; nprocs_send 887 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c malloc((nprocs_send+nprocs_recv+1) * sizeof(MPI_Request)); nprocs_send 991 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c ret = ompi_request_wait_all(nprocs_send, nprocs_send 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_send 1114 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c nprocs_send = 0; nprocs_send 1115 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for (i=0; i <fh->f_size; i++) if (send_size[i]) nprocs_send++; nprocs_send 1118 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c printf("%d : nprocs_send : %d\n", fh->f_rank,nprocs_send); nprocs_send 1122 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 1170 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c else if(nprocs_send && (!(fh->f_flags & OMPIO_CONTIGUOUS_MEMORY))){ nprocs_send 1203 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c ret = ompi_request_wait_all (nprocs_send+nprocs_recv, nprocs_send 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_send 862 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs_send = 0; nprocs_send 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_send 866 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 931 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_send 955 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Waitall(nprocs_send, requests+nprocs_recv, statuses+nprocs_recv); nprocs_send 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_send 1159 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs_send = 0; nprocs_send 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_send 1209 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (nprocs_send) { nprocs_send 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_send 1128 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs_send = 0; nprocs_send 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_send 1134 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Malloc((nprocs_send+1)*sizeof(MPI_Request)); nprocs_send 1139 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 1171 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c else if (nprocs_send) { nprocs_send 1207 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+1) * \ nprocs_send 1212 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_send 1221 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c while (!i) MPI_Testall(nprocs_send, send_req, &i, statuses); nprocs_send 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_send 1229 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Waitall(nprocs_send, send_req, statuses); nprocs_send 1231 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Waitall(nprocs_send+nprocs_recv, requests, statuses); nprocs_send 1239 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (!buftype_is_contig && nprocs_send) { nprocs_send 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_send 1567 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs_send = 0; nprocs_send 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_send 634 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int i, j, nprocs_recv, nprocs_send, err; nprocs_send 725 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c nprocs_send = 0; nprocs_send 728 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c nprocs_send++; nprocs_send 732 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c requests = (MPI_Request *) ADIOI_Malloc((nprocs_send + 1) * nprocs_send 736 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c requests = (MPI_Request *) ADIOI_Malloc((nprocs_send + nprocs_recv + 1)* nprocs_send 767 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (nprocs_send) { nprocs_send 803 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send + 1) * nprocs_send 806 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send + nprocs_recv + 1) * nprocs_send 815 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Testall(nprocs_send, send_req, &i, statuses); nprocs_send 818 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Testall(nprocs_send + nprocs_recv, requests, &i, statuses); nprocs_send 823 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Waitall(nprocs_send, send_req, statuses); nprocs_send 825 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c MPI_Waitall(nprocs_send + nprocs_recv, requests, statuses); nprocs_send 829 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (!buftype_is_contig && nprocs_send) { nprocs_send 152 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs_send; nprocs_send 1029 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int i, j, k = 0, tmp = 0, nprocs_recv, nprocs_send; nprocs_send 1037 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs_send = 0; nprocs_send 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_send 1039 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_send = nprocs_send; nprocs_send 1042 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 1284 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c errcode = MPI_Testall(red_vars->nprocs_send, nprocs_send 162 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_send; nprocs_send 1204 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_send; nprocs_send 1207 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs_send = 0; nprocs_send 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_send 1209 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_send = nprocs_send; nprocs_send 1214 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Malloc((nprocs_send+1)*sizeof(MPI_Request)); nprocs_send 1219 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 1251 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c else if (nprocs_send) { nprocs_send 1299 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_send = vars->nprocs_send; nprocs_send 1310 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Testall(nprocs_send, vars->send_req, &i, MPI_STATUSES_IGNORE); nprocs_send 1313 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Testall(nprocs_send+nprocs_recv, vars->requests, &i, nprocs_send 1340 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (!vars->buftype_is_contig && vars->nprocs_send) { nprocs_send 1504 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c errcode = MPI_Testall(wed_vars->nprocs_send, wed_vars->send_req, nprocs_send 1507 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c errcode = MPI_Testall(wed_vars->nprocs_send + nprocs_send 784 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int i, j, k=0, tmp=0, nprocs_recv, nprocs_send; nprocs_send 798 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c nprocs_send = 0; nprocs_send 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_send 802 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 867 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_send 891 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Waitall(nprocs_send, requests+nprocs_recv, statuses+nprocs_recv); nprocs_send 579 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int i, j, k, *tmp_len, nprocs_recv, nprocs_send, err; nprocs_send 691 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs_send = 0; nprocs_send 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_send 697 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Malloc((nprocs_send+1)*sizeof(MPI_Request)); nprocs_send 702 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Malloc((nprocs_send+nprocs_recv+1)*sizeof(MPI_Request)); nprocs_send 734 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c else if (nprocs_send) { nprocs_send 770 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+1) * \ nprocs_send 775 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c statuses = (MPI_Status *) ADIOI_Malloc((nprocs_send+nprocs_recv+1) * \ nprocs_send 784 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c while (!i) MPI_Testall(nprocs_send, send_req, &i, statuses); nprocs_send 787 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c while (!i) MPI_Testall(nprocs_send+nprocs_recv, requests, &i, statuses); nprocs_send 792 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c MPI_Waitall(nprocs_send, send_req, statuses); nprocs_send 794 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c MPI_Waitall(nprocs_send+nprocs_recv, requests, statuses); nprocs_send 802 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (!buftype_is_contig && nprocs_send) {