A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
openmpi recently changed its decision for alltoallv algo
[simgrid.git]
/
src
/
smpi
/
colls
/
bcast-scatter-LR-allgather.c
diff --git
a/src/smpi/colls/bcast-scatter-LR-allgather.c
b/src/smpi/colls/bcast-scatter-LR-allgather.c
index
759f979
..
ebd5539
100644
(file)
--- a/
src/smpi/colls/bcast-scatter-LR-allgather.c
+++ b/
src/smpi/colls/bcast-scatter-LR-allgather.c
@@
-1,4
+1,4
@@
-#include "colls.h"
+#include "colls
_private
.h"
/*****************************************************************************
/*****************************************************************************
@@
-73,9
+73,9
@@
smpi_coll_tuned_bcast_scatter_LR_allgather(void *buff, int count,
int scatter_size, left, right, next_src, *recv_counts, *disps;
int tag = 1;
int scatter_size, left, right, next_src, *recv_counts, *disps;
int tag = 1;
-
MPI_Comm_rank(comm, &rank
);
-
MPI_Comm_size(comm, &num_procs
);
-
MPI_Type_extent(data_type, &extent
);
+
rank = smpi_comm_rank(comm
);
+
num_procs = smpi_comm_size(comm
);
+
extent = smpi_datatype_get_extent(data_type
);
nbytes = extent * count;
nbytes = extent * count;
@@
-97,9
+97,9
@@
smpi_coll_tuned_bcast_scatter_LR_allgather(void *buff, int count,
curr_size = 0; // this process doesn't receive any data
// because of uneven division
else {
curr_size = 0; // this process doesn't receive any data
// because of uneven division
else {
-
MPI_R
ecv((char *) buff + relative_rank * scatter_size, recv_size,
+
smpi_mpi_r
ecv((char *) buff + relative_rank * scatter_size, recv_size,
MPI_BYTE, src, tag, comm, &status);
MPI_BYTE, src, tag, comm, &status);
-
MPI_Get_count(&status, MPI_BYTE, &curr_size
);
+
curr_size = smpi_mpi_get_count(&status, MPI_BYTE
);
}
break;
}
}
break;
}
@@
-121,7
+121,7
@@
smpi_coll_tuned_bcast_scatter_LR_allgather(void *buff, int count,
dst = rank + mask;
if (dst >= num_procs)
dst -= num_procs;
dst = rank + mask;
if (dst >= num_procs)
dst -= num_procs;
-
MPI_S
end((char *) buff + scatter_size * (relative_rank + mask),
+
smpi_mpi_s
end((char *) buff + scatter_size * (relative_rank + mask),
send_size, MPI_BYTE, dst, tag, comm);
curr_size -= send_size;
send_size, MPI_BYTE, dst, tag, comm);
curr_size -= send_size;
@@
-153,7
+153,7
@@
smpi_coll_tuned_bcast_scatter_LR_allgather(void *buff, int count,
next_src = left;
for (i = 1; i < num_procs; i++) {
next_src = left;
for (i = 1; i < num_procs; i++) {
-
MPI_S
endrecv((char *) buff + disps[(src - root + num_procs) % num_procs],
+
smpi_mpi_s
endrecv((char *) buff + disps[(src - root + num_procs) % num_procs],
recv_counts[(src - root + num_procs) % num_procs],
MPI_BYTE, right, tag,
(char *) buff +
recv_counts[(src - root + num_procs) % num_procs],
MPI_BYTE, right, tag,
(char *) buff +