//TODO: suboptimal implementation
void *recvbuf;
int retval;
- if ((datatype == MPI_DATATYPE_NULL)||(datatype->has_subtype==1)) {
+ if (datatype == MPI_DATATYPE_NULL) {
retval = MPI_ERR_TYPE;
} else if (count < 0) {
retval = MPI_ERR_COUNT;
} else {
- int size = smpi_datatype_size(datatype) * count;
+ int size = smpi_datatype_get_extent(datatype) * count;
recvbuf = xbt_new(char, size);
retval =
MPI_Sendrecv(buf, count, datatype, dst, sendtag, recvbuf, count,
datatype, src, recvtag, comm, status);
if(retval==MPI_SUCCESS){
- memcpy(buf, recvbuf, size * sizeof(char));
+ smpi_datatype_copy(recvbuf, count, datatype, buf, count, datatype);
}
xbt_free(recvbuf);
} else if (op == MPI_OP_NULL) {
retval = MPI_ERR_OP;
} else {
- smpi_mpi_allreduce(sendbuf, recvbuf, count, datatype, op, comm);
+ mpi_coll_allreduce_fun(sendbuf, recvbuf, count, datatype, op, comm);
retval = MPI_SUCCESS;
}
#ifdef HAVE_TRACING
void *recvbuf, int recvcount, MPI_Datatype recvtype,
MPI_Comm comm)
{
- int retval, size, sendsize;
+ int retval;
smpi_bench_end();
#ifdef HAVE_TRACING
|| recvtype == MPI_DATATYPE_NULL) {
retval = MPI_ERR_TYPE;
} else {
- size = smpi_comm_size(comm);
- sendsize = smpi_datatype_size(sendtype) * sendcount;
- if (sendsize < 200 && size > 12) {
- retval =
- smpi_coll_tuned_alltoall_bruck(sendbuf, sendcount, sendtype,
- recvbuf, recvcount, recvtype,
- comm);
- } else if (sendsize < 3000) {
- retval =
- smpi_coll_tuned_alltoall_basic_linear(sendbuf, sendcount,
- sendtype, recvbuf,
- recvcount, recvtype, comm);
- } else {
- retval =
- smpi_coll_tuned_alltoall_pairwise(sendbuf, sendcount, sendtype,
- recvbuf, recvcount, recvtype,
- comm);
- }
+ retval = mpi_coll_alltoall_fun(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm);
}
#ifdef HAVE_TRACING
TRACE_smpi_collective_out(rank, -1, __FUNCTION__);
return not_yet_implemented();
}
+int PMPI_Win_fence( int assert, MPI_Win win){
+ return not_yet_implemented();
+}
+
+int PMPI_Win_free( MPI_Win* win){
+ return not_yet_implemented();
+}
+
+int PMPI_Win_create( void *base, MPI_Aint size, int disp_unit, MPI_Info info, MPI_Comm comm, MPI_Win *win){
+ return not_yet_implemented();
+}
+
+int PMPI_Info_create( MPI_Info *info){
+ return not_yet_implemented();
+}
+
+int PMPI_Info_set( MPI_Info *info, char *key, char *value){
+ return not_yet_implemented();
+}
+
+int PMPI_Info_free( MPI_Info *info){
+ return not_yet_implemented();
+}
+
+int PMPI_Get( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
+ MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Win win){
+ return not_yet_implemented();
+}