recv_size 75 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c int *recv_size, recv_size 96 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c unsigned *recv_size, recv_size 550 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c int *curr_offlen_ptr=NULL, *count=NULL, *send_size=NULL, *recv_size=NULL; recv_size 633 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_size = (int *)malloc(fh->f_size * sizeof(int)); recv_size 634 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (NULL == recv_size){ recv_size 776 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_size[i] = 0; recv_size 779 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c send_size, start_pos, recv_size, count, recv_size 805 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c start_pos, recv_size, count, recv_size 819 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c free (recv_size); recv_size 829 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c int *send_size, int *start_pos, int *recv_size, recv_size 858 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_size, recv_size 873 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_size[i]); recv_size 880 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_size[i]) nprocs_recv++; recv_size 892 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_size[i]){ recv_size 894 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_size[i], recv_size 905 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c buf_idx[i] += recv_size[i]; recv_size 918 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if(recv_size[i]) recv_buf[i] = recv_size 919 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c (char *) malloc (recv_size[i] * sizeof(char)); recv_size 922 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_size[i]) { recv_size 924 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_size[i], recv_size 983 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c (unsigned *)recv_size, requests, recv_size 1070 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c unsigned *recv_size, recv_size 1132 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_buf_idx[p] < recv_size[p]) { recv_size 1136 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c done_from_proc[p], recv_size[p]-recv_buf_idx[p]); recv_size 1144 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c size = OMPIO_MIN(len,recv_size[p]-recv_buf_idx[p]); recv_size 1165 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_size[i]) recd_from_proc[i] = curr_from_proc[i]; recv_size 80 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *recv_size, recv_size 613 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *curr_offlen_ptr=NULL, *count=NULL, *send_size=NULL, *recv_size=NULL; recv_size 700 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c recv_size = (int *) calloc(fh->f_size,sizeof(int)); recv_size 702 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if ( NULL == recv_size ){ recv_size 748 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for (i=0; i< fh->f_size; i++) count[i] = recv_size[i] = 0; recv_size 787 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c recv_size[i] += (int) (OMPIO_MIN(off + size - req_off, recv_size 804 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c start_pos,recv_size,off,size, recv_size 891 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for (i=0; i<fh->f_size; i++) count[i] = recv_size[i] = 0; recv_size 895 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c start_pos,recv_size,off,size, recv_size 918 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c free (recv_size); recv_size 933 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *recv_size, recv_size 960 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c ret = fh->f_comm->c_coll->coll_alltoall (recv_size, recv_size 975 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (recv_size[i]){ recv_size 998 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (recv_size[i]) { recv_size 1131 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (recv_size[i]) { recv_size 44 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *len_list, int *send_size, int *recv_size, recv_size 58 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *len_list, int *send_size, int *recv_size, recv_size 73 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c unsigned *recv_size, recv_size 522 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int *curr_offlen_ptr, *count, *send_size, *recv_size; recv_size 594 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); recv_size 754 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c send_size, recv_size, count, recv_size 764 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c send_size, recv_size, count, recv_size 803 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c send_size, recv_size, count, recv_size 813 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c send_size, recv_size, count, recv_size 829 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(recv_size); recv_size 838 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *len_list, int *send_size, int *recv_size, recv_size 857 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Alltoall(send_size, 1, MPI_INT, recv_size, 1, MPI_INT, fd->comm); recv_size 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++; recv_size 879 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) { recv_size 880 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Irecv(((char *) buf) + buf_idx[i], recv_size[i], recv_size 883 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c buf_idx[i] += recv_size[i]; recv_size 890 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) recv_buf[i] = recv_size 891 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c (char *) ADIOI_Malloc(recv_size[i]); recv_size 895 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) { recv_size 896 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Irecv(recv_buf[i], recv_size[i], MPI_BYTE, i, recv_size 901 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c myrank, recv_size[i], myrank+i+100*iter); recv_size 947 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c offset_list, len_list, (unsigned*)recv_size, recv_size 962 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) ADIOI_Free(recv_buf[i]); recv_size 1021 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c unsigned *recv_size, recv_size 1086 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_buf_idx[p] < recv_size[p]) { recv_size 1090 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c done_from_proc[p], recv_size[p]-recv_buf_idx[p]); recv_size 1099 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); recv_size 1122 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) recd_from_proc[i] = curr_from_proc[i]; recv_size 1132 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *len_list, int *send_size, int *recv_size, recv_size 1154 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Alltoall(send_size, 1, MPI_INT, recv_size, 1, MPI_INT, fd->comm); recv_size 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; } recv_size 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]; } recv_size 1202 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c DBG_FPRINTF(stderr, "\trecv_size = [%d]%2d,",0,recv_size[0]); recv_size 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] ); } recv_size 1219 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c all_recv_buf, recv_size, rdispls, MPI_BYTE, recv_size 1232 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c offset_list, len_list, (unsigned*)recv_size, recv_size 1241 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) { recv_size 1242 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c memcpy( (char *)buf + buf_idx[i], all_recv_buf + rtail, recv_size[i] ); recv_size 1243 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c buf_idx[i] += recv_size[i]; recv_size 1244 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c rtail += recv_size[i]; recv_size 52 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *recv_size, ADIO_Offset off, int size, recv_size 68 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *len_list, int *send_size, int *recv_size, recv_size 635 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *curr_offlen_ptr, *count, *send_size, req_len, *recv_size; recv_size 735 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c recv_size = (int *) ADIOI_Malloc(nprocs*sizeof(int)); recv_size 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; recv_size 830 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c recv_size[i] += (int)(ADIOI_MIN(off + size - req_off, recv_size 867 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c len_list, send_size, recv_size, off, size, count, recv_size 878 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c len_list, send_size, recv_size, off, size, count, recv_size 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; recv_size 951 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c len_list, send_size, recv_size, off, size, count, recv_size 962 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c len_list, send_size, recv_size, off, size, count, recv_size 979 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(recv_size); recv_size 1005 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *recv_size, ADIO_Offset off, int size, recv_size 1032 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Alltoall(recv_size, 1, MPI_INT, send_size, 1, MPI_INT, fd->comm); recv_size 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++; recv_size 1046 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (recv_size[i]) { recv_size 1145 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (recv_size[i]) { recv_size 1194 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (recv_size[i]) { recv_size 1528 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *len_list, int *send_size, int *recv_size, recv_size 1560 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c MPI_Alltoall(recv_size, 1, MPI_INT, send_size, 1, MPI_INT, fd->comm); recv_size 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++; } recv_size 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]; } recv_size 1615 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c all_recv_buf, recv_size, rdispls, MPI_BYTE, recv_size 1677 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (recv_size[i]) { recv_size 43 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *recv_size, ADIO_Offset off, recv_size 311 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *recv_curr_offlen_ptr, *recv_count, *recv_size; recv_size 398 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); recv_size 471 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_count[i] = recv_size[i] = send_size[i] = 0; recv_size 503 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c recv_size[i] += req_len; recv_size 514 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c len_list, send_size, recv_size, off, real_size, recv_size 600 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Free(recv_size); recv_size 618 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *recv_size, ADIO_Offset off, recv_size 646 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (recv_size[i]) recv_size 655 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (recv_size[i]) { recv_size 704 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c sum_recv += recv_size[i]; recv_size 743 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (recv_size[i]) { recv_size 788 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (recv_size[i]) { recv_size 102 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *recv_size; recv_size 132 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *recv_size; recv_size 163 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c unsigned *recv_size, recv_size 662 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_size = (int *)ADIOI_Malloc(nprocs * sizeof(int)); recv_size 837 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->recv_size = vars->recv_size; recv_size 946 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->recv_size = vars->recv_size; recv_size 986 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->recv_size); recv_size 1007 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *error_code = MPI_Ialltoall(vars->send_size, 1, MPI_INT, vars->recv_size, 1, recv_size 1019 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *recv_size = vars->recv_size; recv_size 1034 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; recv_size 1055 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (recv_size[i]) { recv_size 1056 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Irecv(((char *)vars->buf) + buf_idx[i], recv_size[i], recv_size 1060 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c buf_idx[i] += recv_size[i]; recv_size 1068 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (recv_size[i]) recv_buf[i] = (char *)ADIOI_Malloc(recv_size[i]); recv_size 1072 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (recv_size[i]) { recv_size 1073 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Irecv(recv_buf[i], recv_size[i], MPI_BYTE, i, recv_size 1079 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c myrank, recv_size[i], myrank+i+100*iter); recv_size 1128 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c (unsigned*)vars->recv_size, recv_size 1148 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->recv_size[i]) ADIOI_Free(vars->recv_buf[i]); recv_size 106 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size; recv_size 136 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size; recv_size 706 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->recv_size = (int *)ADIOI_Malloc(nprocs*sizeof(int)); recv_size 757 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *curr_offlen_ptr, *count, req_len, *recv_size; recv_size 777 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c recv_size = vars->recv_size; recv_size 798 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) count[i] = recv_size[i] = 0; recv_size 830 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c recv_size[i] += (int)(ADIOI_MIN(off + size - req_off, recv_size 873 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->recv_size = vars->recv_size; recv_size 956 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size = vars->recv_size; recv_size 959 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) count[i] = recv_size[i] = 0; recv_size 992 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->recv_size = vars->recv_size; recv_size 1039 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->recv_size); recv_size 1064 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Ialltoall(vars->recv_size, 1, MPI_INT, vars->send_size, 1, recv_size 1075 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size = vars->recv_size; recv_size 1093 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (i = 0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; recv_size 1104 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (recv_size[i]) { recv_size 1194 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size = vars->recv_size; recv_size 1225 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (recv_size[i]) { recv_size 1280 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (recv_size[i]) { recv_size 30 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *len_list, int *send_size, int *recv_size, recv_size 45 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c unsigned *recv_size, recv_size 519 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int *curr_offlen_ptr, *count, *send_size, *recv_size; recv_size 589 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recv_size = (int *) ADIOI_Malloc(nprocs * sizeof(int)); recv_size 726 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c send_size, recv_size, count, recv_size 755 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c send_size, recv_size, count, recv_size 767 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(recv_size); recv_size 774 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *len_list, int *send_size, int *recv_size, recv_size 793 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Alltoall(send_size, 1, MPI_INT, recv_size, 1, MPI_INT, fd->comm); recv_size 796 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (i=0; i < nprocs; i++) if (recv_size[i]) nprocs_recv++; recv_size 815 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) { recv_size 816 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Irecv(((char *) buf) + buf_idx[i], recv_size[i], recv_size 819 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c buf_idx[i] += recv_size[i]; recv_size 826 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) recv_buf[i] = recv_size 827 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c (char *) ADIOI_Malloc(recv_size[i]); recv_size 831 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) { recv_size 832 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Irecv(recv_buf[i], recv_size[i], MPI_BYTE, i, recv_size 837 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c myrank, recv_size[i], myrank+i+100*iter); recv_size 883 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c offset_list, len_list, (unsigned*)recv_size, recv_size 898 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) ADIOI_Free(recv_buf[i]); recv_size 957 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c unsigned *recv_size, recv_size 1022 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_buf_idx[p] < recv_size[p]) { recv_size 1026 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c done_from_proc[p], recv_size[p]-recv_buf_idx[p]); recv_size 1035 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); recv_size 1058 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) recd_from_proc[i] = curr_from_proc[i]; recv_size 27 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *recv_size, ADIO_Offset off, int size, recv_size 319 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *curr_offlen_ptr, *count, *send_size, req_len, *recv_size; recv_size 387 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c recv_size = (int *) ADIOI_Malloc(nprocs*sizeof(int)); recv_size 442 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i < nprocs; i++) count[i] = recv_size[i] = 0; recv_size 472 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c recv_size[i] += (int)(ADIOI_MIN(off + size - req_off, recv_size 504 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c len_list, send_size, recv_size, off, size, count, recv_size 529 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) count[i] = recv_size[i] = 0; recv_size 534 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c len_list, send_size, recv_size, off, (int)size, count, recv_size 549 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(recv_size); recv_size 564 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *recv_size, ADIO_Offset off, int size, recv_size 591 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c MPI_Alltoall(recv_size, 1, MPI_INT, send_size, 1, MPI_INT, fd->comm); recv_size 596 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (i=0; i<nprocs; i++) if (recv_size[i]) nprocs_recv++; recv_size 605 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (recv_size[i]) { recv_size 708 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (recv_size[i]) { recv_size 757 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (recv_size[i]) {