| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/common/ |
| H A D | ad_read_coll.c | 937 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
938 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
977 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
990 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
993 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1025 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1029 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1038 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1065 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/io/romio321/romio/adio/common/ |
| H A D | ad_read_coll.c | 934 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
935 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
974 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
987 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
990 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1022 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1026 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1035 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1062 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/common/ |
| H A D | ad_read_coll.c | 940 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
941 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
980 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
993 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
996 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1028 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1032 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1041 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1068 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/fcoll/two_phase/ |
| H A D | fcoll_two_phase_file_read_all.c | 1038 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
1039 recv_buf_idx[p] += size_in_buf; \
1081 unsigned *curr_from_proc=NULL, *done_from_proc=NULL, *recv_buf_idx=NULL; in two_phase_fill_user_buffer() local
1085 recv_buf_idx = (unsigned *) malloc (fh->f_size * sizeof(unsigned)); in two_phase_fill_user_buffer()
1088 recv_buf_idx[i] = curr_from_proc[i] = 0; in two_phase_fill_user_buffer()
1127 if (recv_buf_idx[p] < recv_size[p]) { in two_phase_fill_user_buffer()
1131 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in two_phase_fill_user_buffer()
1139 size = OMPIO_MIN(len,recv_size[p]-recv_buf_idx[p]); in two_phase_fill_user_buffer()
1164 free(recv_buf_idx); in two_phase_fill_user_buffer()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/fcoll/two_phase/ |
| H A D | fcoll_two_phase_file_read_all.c | 1043 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
1044 recv_buf_idx[p] += size_in_buf; \
1086 unsigned *curr_from_proc=NULL, *done_from_proc=NULL, *recv_buf_idx=NULL; in two_phase_fill_user_buffer() local
1090 recv_buf_idx = (unsigned *) malloc (fh->f_size * sizeof(unsigned)); in two_phase_fill_user_buffer()
1093 recv_buf_idx[i] = curr_from_proc[i] = 0; in two_phase_fill_user_buffer()
1132 if (recv_buf_idx[p] < recv_size[p]) { in two_phase_fill_user_buffer()
1136 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in two_phase_fill_user_buffer()
1144 size = OMPIO_MIN(len,recv_size[p]-recv_buf_idx[p]); in two_phase_fill_user_buffer()
1169 free(recv_buf_idx); in two_phase_fill_user_buffer()
|
| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/ad_bg/ |
| H A D | ad_bg_rdcoll.c | 893 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
894 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
933 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
946 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
949 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
981 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
985 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
994 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1021 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/ad_bgl/ |
| H A D | ad_bgl_rdcoll.c | 891 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
892 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
931 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
944 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
947 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
979 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
983 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
992 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1019 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/ad_gpfs/ |
| H A D | ad_gpfs_rdcoll.c | 914 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
915 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
954 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
967 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
970 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1002 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1006 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1015 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1042 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/ad_gpfs/ |
| H A D | ad_gpfs_rdcoll.c | 956 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
957 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
995 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
1008 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
1011 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1037 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1041 done_from_proc[p], recv_size[p] - recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1048 size = MPL_MIN(len, recv_size[p] - recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1073 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/io/romio321/romio/adio/ad_gpfs/ |
| H A D | ad_gpfs_rdcoll.c | 998 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
999 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
1038 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
1051 recv_buf_idx = (unsigned *) ADIOI_Malloc(nprocs * sizeof(unsigned)); in ADIOI_Fill_user_buffer()
1054 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1086 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1090 done_from_proc[p], recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1099 size = ADIOI_MIN(len,recv_size[p]-recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1126 ADIOI_Free(recv_buf_idx); in ADIOI_Fill_user_buffer()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/common/ |
| H A D | ad_read_coll.c | 924 &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \
925 recv_buf_idx[p] += size_in_buf; /* already tested (size_t)size_in_buf*/ \
963 unsigned *curr_from_proc, *done_from_proc, *recv_buf_idx; in ADIOI_Fill_user_buffer() local
976 recv_buf_idx = done_from_proc + nprocs; in ADIOI_Fill_user_buffer()
979 recv_buf_idx[i] = curr_from_proc[i] = 0; in ADIOI_Fill_user_buffer()
1005 if (recv_buf_idx[p] < recv_size[p]) { in ADIOI_Fill_user_buffer()
1009 done_from_proc[p], recv_size[p] - recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
1016 size = MPL_MIN(len, recv_size[p] - recv_buf_idx[p]); in ADIOI_Fill_user_buffer()
|