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
Simplify (and maybe correct) script.
[simgrid.git]
/
src
/
smpi
/
colls
/
smpi_default_selector.cpp
diff --git
a/src/smpi/colls/smpi_default_selector.cpp
b/src/smpi/colls/smpi_default_selector.cpp
index 4b00cd1839798c94bd01bc61f3aa52a0ab3650fc..4ca403e633b58f89512accbb14ec7d2bf8232b57 100644
(file)
--- a/
src/smpi/colls/smpi_default_selector.cpp
+++ b/
src/smpi/colls/smpi_default_selector.cpp
@@
-26,7
+26,7
@@
int gather__default(const void *sendbuf, int sendcount, MPI_Datatype sendtype,
void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm)
{
MPI_Request request;
void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm)
{
MPI_Request request;
-
C
olls::igather(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, root, comm, &request, 0);
+
c
olls::igather(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, root, comm, &request, 0);
return Request::wait(&request, MPI_STATUS_IGNORE);
}
return Request::wait(&request, MPI_STATUS_IGNORE);
}
@@
-47,7
+47,7
@@
int reduce_scatter__default(const void *sendbuf, void *recvbuf, const int *recvc
int ret = reduce__default(sendbuf, tmpbuf, count, datatype, op, 0, comm);
if(ret==MPI_SUCCESS)
int ret = reduce__default(sendbuf, tmpbuf, count, datatype, op, 0, comm);
if(ret==MPI_SUCCESS)
- ret =
C
olls::scatterv(tmpbuf, recvcounts, displs, datatype, recvbuf, recvcounts[rank], datatype, 0, comm);
+ ret =
c
olls::scatterv(tmpbuf, recvcounts, displs, datatype, recvbuf, recvcounts[rank], datatype, 0, comm);
delete[] displs;
smpi_free_tmp_buffer(tmpbuf);
return ret;
delete[] displs;
smpi_free_tmp_buffer(tmpbuf);
return ret;
@@
-58,7
+58,7
@@
int allgather__default(const void *sendbuf, int sendcount, MPI_Datatype sendtype
void *recvbuf,int recvcount, MPI_Datatype recvtype, MPI_Comm comm)
{
MPI_Request request;
void *recvbuf,int recvcount, MPI_Datatype recvtype, MPI_Comm comm)
{
MPI_Request request;
-
C
olls::iallgather(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm, &request);
+
c
olls::iallgather(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm, &request);
return Request::wait(&request, MPI_STATUS_IGNORE);
}
return Request::wait(&request, MPI_STATUS_IGNORE);
}
@@
-66,7
+66,7
@@
int allgatherv__default(const void *sendbuf, int sendcount, MPI_Datatype sendtyp
const int *recvcounts, const int *displs, MPI_Datatype recvtype, MPI_Comm comm)
{
MPI_Request request;
const int *recvcounts, const int *displs, MPI_Datatype recvtype, MPI_Comm comm)
{
MPI_Request request;
-
C
olls::iallgatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, displs, recvtype, comm, &request, 0);
+
c
olls::iallgatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, displs, recvtype, comm, &request, 0);
MPI_Request* requests = request->get_nbc_requests();
int count = request->get_nbc_requests_size();
Request::waitall(count, requests, MPI_STATUS_IGNORE);
MPI_Request* requests = request->get_nbc_requests();
int count = request->get_nbc_requests_size();
Request::waitall(count, requests, MPI_STATUS_IGNORE);
@@
-82,7
+82,7
@@
int scatter__default(const void *sendbuf, int sendcount, MPI_Datatype sendtype,
void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm)
{
MPI_Request request;
void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm)
{
MPI_Request request;
-
C
olls::iscatter(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, root, comm, &request, 0);
+
c
olls::iscatter(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, root, comm, &request, 0);
return Request::wait(&request, MPI_STATUS_IGNORE);
}
return Request::wait(&request, MPI_STATUS_IGNORE);
}
@@
-94,7
+94,7
@@
int reduce__default(const void *sendbuf, void *recvbuf, int count, MPI_Datatype
return reduce__ompi_basic_linear(sendbuf, recvbuf, count, datatype, op, root, comm);
}
MPI_Request request;
return reduce__ompi_basic_linear(sendbuf, recvbuf, count, datatype, op, root, comm);
}
MPI_Request request;
-
C
olls::ireduce(sendbuf, recvbuf, count, datatype, op, root, comm, &request, 0);
+
c
olls::ireduce(sendbuf, recvbuf, count, datatype, op, root, comm, &request, 0);
return Request::wait(&request, MPI_STATUS_IGNORE);
}
return Request::wait(&request, MPI_STATUS_IGNORE);
}
@@
-119,7
+119,8
@@
int alltoallv__default(const void *sendbuf, const int *sendcounts, const int *se
void *recvbuf, const int *recvcounts, const int *recvdisps, MPI_Datatype recvtype, MPI_Comm comm)
{
MPI_Request request;
void *recvbuf, const int *recvcounts, const int *recvdisps, MPI_Datatype recvtype, MPI_Comm comm)
{
MPI_Request request;
- Colls::ialltoallv(sendbuf, sendcounts, senddisps, sendtype, recvbuf, recvcounts, recvdisps, recvtype, comm, &request, 0);
+ colls::ialltoallv(sendbuf, sendcounts, senddisps, sendtype, recvbuf, recvcounts, recvdisps, recvtype, comm, &request,
+ 0);
return Request::wait(&request, MPI_STATUS_IGNORE);
}
return Request::wait(&request, MPI_STATUS_IGNORE);
}