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
Have replay always use shared buffers instead of allocating new ones, even inside...
[simgrid.git]
/
src
/
smpi
/
colls
/
reduce-mvapich-two-level.c
diff --git
a/src/smpi/colls/reduce-mvapich-two-level.c
b/src/smpi/colls/reduce-mvapich-two-level.c
index
8014a14
..
306bec9
100644
(file)
--- a/
src/smpi/colls/reduce-mvapich-two-level.c
+++ b/
src/smpi/colls/reduce-mvapich-two-level.c
@@
-123,7
+123,7
@@
int smpi_coll_tuned_reduce_mvapich2_two_level( void *sendbuf,
if (stride <= MV2_INTRA_SHMEM_REDUCE_MSG &&
is_commutative == 1) {
if (local_rank == 0 ) {
if (stride <= MV2_INTRA_SHMEM_REDUCE_MSG &&
is_commutative == 1) {
if (local_rank == 0 ) {
- tmp_buf=(void *)
xbt_malloc
( count *
+ tmp_buf=(void *)
smpi_get_tmp_sendbuffer
( count *
(MAX(extent, true_extent)));
tmp_buf = (void *) ((char *) tmp_buf - true_lb);
}
(MAX(extent, true_extent)));
tmp_buf = (void *) ((char *) tmp_buf - true_lb);
}
@@
-191,7
+191,7
@@
int smpi_coll_tuned_reduce_mvapich2_two_level( void *sendbuf,
}
leader_comm_size = smpi_comm_size(leader_comm);
leader_comm_rank = smpi_comm_rank(leader_comm);
}
leader_comm_size = smpi_comm_size(leader_comm);
leader_comm_rank = smpi_comm_rank(leader_comm);
- tmp_buf=(void *)
xbt_malloc
(count *
+ tmp_buf=(void *)
smpi_get_tmp_sendbuffer
(count *
(MAX(extent, true_extent)));
tmp_buf = (void *) ((char *) tmp_buf - true_lb);
}
(MAX(extent, true_extent)));
tmp_buf = (void *) ((char *) tmp_buf - true_lb);
}
@@
-251,7
+251,7
@@
int smpi_coll_tuned_reduce_mvapich2_two_level( void *sendbuf,
out_buf = recvbuf;
} else {
out_buf = recvbuf;
} else {
- in_buf = (char *)
xbt_malloc
(count*
+ in_buf = (char *)
smpi_get_tmp_sendbuffer
(count*
smpi_datatype_get_extent(datatype));
smpi_datatype_copy(tmp_buf, count, datatype,
in_buf, count, datatype);
smpi_datatype_get_extent(datatype));
smpi_datatype_copy(tmp_buf, count, datatype,
in_buf, count, datatype);
@@
-259,7
+259,7
@@
int smpi_coll_tuned_reduce_mvapich2_two_level( void *sendbuf,
out_buf = recvbuf;
}
} else {
out_buf = recvbuf;
}
} else {
- in_buf = (char *)
xbt_malloc
(count*
+ in_buf = (char *)
smpi_get_tmp_sendbuffer
(count*
smpi_datatype_get_extent(datatype));
smpi_datatype_copy(tmp_buf, count, datatype,
in_buf, count, datatype);
smpi_datatype_get_extent(datatype));
smpi_datatype_copy(tmp_buf, count, datatype,
in_buf, count, datatype);