curr_from_proc 1086 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c unsigned *curr_from_proc=NULL, *done_from_proc=NULL, *recv_buf_idx=NULL; curr_from_proc 1088 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c curr_from_proc = (unsigned *) malloc (fh->f_size * sizeof(unsigned)); curr_from_proc 1093 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_buf_idx[i] = curr_from_proc[i] = 0; curr_from_proc 1133 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (curr_from_proc[p]+len > done_from_proc[p]) { curr_from_proc 1134 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (done_from_proc[p] > curr_from_proc[p]) { curr_from_proc 1135 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c size = OMPIO_MIN(curr_from_proc[p] + len - curr_from_proc 1137 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c buf_incr = done_from_proc[p] - curr_from_proc[p]; curr_from_proc 1139 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c buf_incr = curr_from_proc[p]+len-done_from_proc[p]; curr_from_proc 1140 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c curr_from_proc[p] = done_from_proc[p] + size; curr_from_proc 1146 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c curr_from_proc[p] += (unsigned) size; curr_from_proc 1151 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c curr_from_proc[p] += (unsigned) len; curr_from_proc 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]; curr_from_proc 1167 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c free(curr_from_proc); curr_from_proc 1038 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; curr_from_proc 1049 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c curr_from_proc = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); curr_from_proc 1054 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_buf_idx[i] = curr_from_proc[i] = 0; curr_from_proc 1087 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (curr_from_proc[p]+len > done_from_proc[p]) { curr_from_proc 1088 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (done_from_proc[p] > curr_from_proc[p]) { curr_from_proc 1089 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c size = ADIOI_MIN(curr_from_proc[p] + len - curr_from_proc 1091 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c buf_incr = done_from_proc[p] - curr_from_proc[p]; curr_from_proc 1093 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c buf_incr = curr_from_proc[p]+len-done_from_proc[p]; curr_from_proc 1095 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c curr_from_proc[p] = done_from_proc[p] + size; curr_from_proc 1101 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Assert((curr_from_proc[p] + size) == (unsigned)((ADIO_Offset)curr_from_proc[p] + size)); curr_from_proc 1102 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c curr_from_proc[p] += (unsigned) size; curr_from_proc 1107 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Assert((curr_from_proc[p] + len) == (unsigned)((ADIO_Offset)curr_from_proc[p] + len)); curr_from_proc 1108 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c curr_from_proc[p] += (unsigned) len; curr_from_proc 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]; curr_from_proc 1124 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(curr_from_proc); curr_from_proc 974 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; curr_from_proc 985 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c curr_from_proc = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); curr_from_proc 990 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recv_buf_idx[i] = curr_from_proc[i] = 0; curr_from_proc 1023 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (curr_from_proc[p]+len > done_from_proc[p]) { curr_from_proc 1024 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (done_from_proc[p] > curr_from_proc[p]) { curr_from_proc 1025 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c size = ADIOI_MIN(curr_from_proc[p] + len - curr_from_proc 1027 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c buf_incr = done_from_proc[p] - curr_from_proc[p]; curr_from_proc 1029 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c buf_incr = curr_from_proc[p]+len-done_from_proc[p]; curr_from_proc 1031 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c curr_from_proc[p] = done_from_proc[p] + size; curr_from_proc 1037 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Assert((curr_from_proc[p] + size) == (unsigned)((ADIO_Offset)curr_from_proc[p] + size)); curr_from_proc 1038 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c curr_from_proc[p] += (unsigned) size; curr_from_proc 1043 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Assert((curr_from_proc[p] + len) == (unsigned)((ADIO_Offset)curr_from_proc[p] + len)); curr_from_proc 1044 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c curr_from_proc[p] += (unsigned) len; curr_from_proc 1058 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) recd_from_proc[i] = curr_from_proc[i]; curr_from_proc 1060 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(curr_from_proc);