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
welcome simgrid::smpi::Request
[simgrid.git]
/
src
/
smpi
/
colls
/
barrier-mvapich2-pair.cpp
diff --git
a/src/smpi/colls/barrier-mvapich2-pair.cpp
b/src/smpi/colls/barrier-mvapich2-pair.cpp
index
9683162
..
67b3f7b
100644
(file)
--- a/
src/smpi/colls/barrier-mvapich2-pair.cpp
+++ b/
src/smpi/colls/barrier-mvapich2-pair.cpp
@@
-67,14
+67,14
@@
int smpi_coll_tuned_barrier_mvapich2_pair(MPI_Comm comm)
if (rank < surfeit) {
/* get the fanin letter from the upper "half" process: */
dst = N2_prev + rank;
if (rank < surfeit) {
/* get the fanin letter from the upper "half" process: */
dst = N2_prev + rank;
-
smpi_mpi_
recv(NULL, 0, MPI_BYTE, dst, COLL_TAG_BARRIER,
+
Request::
recv(NULL, 0, MPI_BYTE, dst, COLL_TAG_BARRIER,
comm, MPI_STATUS_IGNORE);
}
/* combine on embedded N2_prev power-of-two processes */
for (d = 1; d < N2_prev; d <<= 1) {
dst = (rank ^ d);
comm, MPI_STATUS_IGNORE);
}
/* combine on embedded N2_prev power-of-two processes */
for (d = 1; d < N2_prev; d <<= 1) {
dst = (rank ^ d);
-
smpi_mpi_
sendrecv(NULL, 0, MPI_BYTE, dst, COLL_TAG_BARRIER, NULL,
+
Request::
sendrecv(NULL, 0, MPI_BYTE, dst, COLL_TAG_BARRIER, NULL,
0, MPI_BYTE, dst, COLL_TAG_BARRIER, comm,
MPI_STATUS_IGNORE);
}
0, MPI_BYTE, dst, COLL_TAG_BARRIER, comm,
MPI_STATUS_IGNORE);
}
@@
-82,13
+82,13
@@
int smpi_coll_tuned_barrier_mvapich2_pair(MPI_Comm comm)
/* fanout data to nodes above N2_prev... */
if (rank < surfeit) {
dst = N2_prev + rank;
/* fanout data to nodes above N2_prev... */
if (rank < surfeit) {
dst = N2_prev + rank;
-
smpi_mpi_
send(NULL, 0, MPI_BYTE, dst, COLL_TAG_BARRIER,
+
Request::
send(NULL, 0, MPI_BYTE, dst, COLL_TAG_BARRIER,
comm);
}
} else {
/* fanin data to power of 2 subset */
src = rank - N2_prev;
comm);
}
} else {
/* fanin data to power of 2 subset */
src = rank - N2_prev;
-
smpi_mpi_
sendrecv(NULL, 0, MPI_BYTE, src, COLL_TAG_BARRIER,
+
Request::
sendrecv(NULL, 0, MPI_BYTE, src, COLL_TAG_BARRIER,
NULL, 0, MPI_BYTE, src, COLL_TAG_BARRIER,
comm, MPI_STATUS_IGNORE);
}
NULL, 0, MPI_BYTE, src, COLL_TAG_BARRIER,
comm, MPI_STATUS_IGNORE);
}