curr_to_proc 91 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 112 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *curr_to_proc, curr_to_proc 616 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *send_buf_idx=NULL, *curr_to_proc=NULL, *done_to_proc=NULL; curr_to_proc 721 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c curr_to_proc = (int *) malloc(fh->f_size*sizeof(int)); curr_to_proc 723 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if ( NULL == curr_to_proc ){ curr_to_proc 810 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c send_buf_idx, curr_to_proc, curr_to_proc 901 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c send_buf_idx, curr_to_proc, curr_to_proc 922 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c free (curr_to_proc); curr_to_proc 944 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 1193 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c curr_to_proc, done_to_proc, curr_to_proc 1301 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int *curr_to_proc, curr_to_proc 1314 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c send_buf_idx[i] = curr_to_proc[i] = 0; curr_to_proc 1346 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (curr_to_proc[p]+len > done_to_proc[p]) { curr_to_proc 1347 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (done_to_proc[p] > curr_to_proc[p]) { curr_to_proc 1348 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c size = OMPIO_MIN(curr_to_proc[p] + len - curr_to_proc 1350 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c buf_incr = done_to_proc[p] - curr_to_proc[p]; curr_to_proc 1352 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c buf_incr = curr_to_proc[p] + len - done_to_proc[p]; curr_to_proc 1353 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c curr_to_proc[p] = done_to_proc[p] + size; curr_to_proc 1359 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c curr_to_proc[p] += size; curr_to_proc 1380 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c curr_to_proc[p] += len; curr_to_proc 1395 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c sent_to_proc[i] = curr_to_proc[i]; curr_to_proc 60 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 78 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, /* 3 */ curr_to_proc 90 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 101 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 637 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, *curr_to_proc, *done_to_proc; curr_to_proc 743 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); curr_to_proc 872 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, send_buf_idx, curr_to_proc, curr_to_proc 883 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, send_buf_idx, curr_to_proc, curr_to_proc 957 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc, done_to_proc, &hole, m, curr_to_proc 968 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc, done_to_proc, &hole, m, curr_to_proc 983 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(curr_to_proc); curr_to_proc 1015 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 1184 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf_idx, curr_to_proc, done_to_proc, iter, curr_to_proc 1303 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 1322 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf_idx[i] = curr_to_proc[i] = 0; curr_to_proc 1356 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (curr_to_proc[p]+len > done_to_proc[p]) { curr_to_proc 1357 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (done_to_proc[p] > curr_to_proc[p]) { curr_to_proc 1358 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c size = ADIOI_MIN(curr_to_proc[p] + len - curr_to_proc 1360 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c buf_incr = done_to_proc[p] - curr_to_proc[p]; curr_to_proc 1362 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Assert((curr_to_proc[p] + len - done_to_proc[p]) == (unsigned)(curr_to_proc[p] + len - done_to_proc[p])); curr_to_proc 1363 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c buf_incr = curr_to_proc[p] + len - done_to_proc[p]; curr_to_proc 1365 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc[p] = done_to_proc[p] + size; curr_to_proc 1371 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Assert((curr_to_proc[p] + size) == (unsigned)((ADIO_Offset)curr_to_proc[p] + size)); curr_to_proc 1372 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc[p] += size; curr_to_proc 1382 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Assert((curr_to_proc[p] + len) == (unsigned)((ADIO_Offset)curr_to_proc[p] + len)); curr_to_proc 1383 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc[p] += len; curr_to_proc 1397 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (send_size[i]) sent_to_proc[i] = curr_to_proc[i]; curr_to_proc 1538 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, /* 3 */ curr_to_proc 1604 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf_idx, curr_to_proc, done_to_proc, iter, curr_to_proc 1716 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 1735 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c send_buf_idx[i] = curr_to_proc[i] = 0; curr_to_proc 1769 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (curr_to_proc[p]+len > done_to_proc[p]) { curr_to_proc 1770 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (done_to_proc[p] > curr_to_proc[p]) { curr_to_proc 1771 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c size = ADIOI_MIN(curr_to_proc[p] + len - curr_to_proc 1773 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c buf_incr = done_to_proc[p] - curr_to_proc[p]; curr_to_proc 1775 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Assert((curr_to_proc[p] + len - done_to_proc[p]) == (unsigned)(curr_to_proc[p] + len - done_to_proc[p])); curr_to_proc 1776 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c buf_incr = curr_to_proc[p] + len - done_to_proc[p]; curr_to_proc 1778 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc[p] = done_to_proc[p] + size; curr_to_proc 1784 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Assert((curr_to_proc[p] + size) == (unsigned)((ADIO_Offset)curr_to_proc[p] + size)); curr_to_proc 1785 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc[p] += size; curr_to_proc 1798 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Assert((curr_to_proc[p] + len) == (unsigned)((ADIO_Offset)curr_to_proc[p] + len)); curr_to_proc 1799 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c curr_to_proc[p] += (int)len; curr_to_proc 1813 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (send_size[i]) sent_to_proc[i] = curr_to_proc[i]; curr_to_proc 35 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *curr_to_proc, curr_to_proc 52 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *curr_to_proc, curr_to_proc 314 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *send_buf_idx, *curr_to_proc, *done_to_proc; curr_to_proc 406 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c curr_to_proc = (int *) ADIOI_Malloc(nprocs * sizeof(int)); curr_to_proc 519 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c curr_to_proc, done_to_proc, &hole, m, curr_to_proc 604 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Free(curr_to_proc); curr_to_proc 627 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *curr_to_proc, int *done_to_proc, curr_to_proc 778 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_buf_idx, curr_to_proc, done_to_proc, curr_to_proc 896 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int *curr_to_proc, curr_to_proc 914 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c send_buf_idx[i] = curr_to_proc[i] = 0; curr_to_proc 941 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (curr_to_proc[p] + len > done_to_proc[p]) { curr_to_proc 942 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (done_to_proc[p] > curr_to_proc[p]) { curr_to_proc 943 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c size = (int) ADIOI_MIN(curr_to_proc[p] + len - curr_to_proc 947 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c buf_incr = done_to_proc[p] - curr_to_proc[p]; curr_to_proc 949 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Assert((curr_to_proc[p] + len - done_to_proc[p]) == (unsigned)(curr_to_proc[p] + len - done_to_proc[p])); curr_to_proc 950 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c buf_incr = (int) (curr_to_proc[p] + len - curr_to_proc 953 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c curr_to_proc[p] = done_to_proc[p] + size; curr_to_proc 959 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Assert((curr_to_proc[p] + size) == (unsigned)((ADIO_Offset)curr_to_proc[p] + size)); curr_to_proc 960 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c curr_to_proc[p] += size; curr_to_proc 970 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Assert((curr_to_proc[p] + len) == (unsigned)((ADIO_Offset)curr_to_proc[p] + len)); curr_to_proc 971 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c curr_to_proc[p] += (int) len; curr_to_proc 985 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c sent_to_proc[i] = curr_to_proc[i]; curr_to_proc 111 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *curr_to_proc; curr_to_proc 153 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *curr_to_proc; curr_to_proc 184 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 714 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->curr_to_proc = (int *)ADIOI_Malloc(nprocs*sizeof(int)); curr_to_proc 890 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->curr_to_proc = vars->curr_to_proc; curr_to_proc 1009 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->curr_to_proc = vars->curr_to_proc; curr_to_proc 1043 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->curr_to_proc); curr_to_proc 1266 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_buf_idx, vars->curr_to_proc, curr_to_proc 35 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 46 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 321 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *send_buf_idx, *curr_to_proc, *done_to_proc; curr_to_proc 395 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_to_proc = (int *) ADIOI_Malloc(nprocs*sizeof(int)); curr_to_proc 509 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req, send_buf_idx, curr_to_proc, curr_to_proc 540 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_to_proc, done_to_proc, &hole, m, curr_to_proc 553 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(curr_to_proc); curr_to_proc 574 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 747 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c send_buf_idx, curr_to_proc, done_to_proc, iter, curr_to_proc 869 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int *send_buf_idx, int *curr_to_proc, curr_to_proc 888 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c send_buf_idx[i] = curr_to_proc[i] = 0; curr_to_proc 922 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (curr_to_proc[p]+len > done_to_proc[p]) { curr_to_proc 923 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (done_to_proc[p] > curr_to_proc[p]) { curr_to_proc 924 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c size = ADIOI_MIN(curr_to_proc[p] + len - curr_to_proc 926 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c buf_incr = done_to_proc[p] - curr_to_proc[p]; curr_to_proc 928 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Assert((curr_to_proc[p] + len - done_to_proc[p]) == (unsigned)(curr_to_proc[p] + len - done_to_proc[p])); curr_to_proc 929 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c buf_incr = curr_to_proc[p] + len - done_to_proc[p]; curr_to_proc 932 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_to_proc[p] = done_to_proc[p] + (int)size; curr_to_proc 938 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Assert((curr_to_proc[p] + size) == (unsigned)((ADIO_Offset)curr_to_proc[p] + size)); curr_to_proc 939 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_to_proc[p] += size; curr_to_proc 949 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Assert((curr_to_proc[p] + len) == (unsigned)((ADIO_Offset)curr_to_proc[p] + len)); curr_to_proc 950 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c curr_to_proc[p] += len; curr_to_proc 964 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (send_size[i]) sent_to_proc[i] = curr_to_proc[i];