}
int PMPI_Send_init(void *buf, int count, MPI_Datatype datatype, int dst,
- int tag, MPI_Comm comm, MPI_Request * request)
+ int tag, MPI_Comm comm, MPI_Request * request)
{
int retval = 0;
retval = MPI_SUCCESS;
}
smpi_bench_begin();
- if(retval!=MPI_SUCCESS)*request=MPI_REQUEST_NULL;
+ if (retval != MPI_SUCCESS && request)
+ *request = MPI_REQUEST_NULL;
return retval;
}
int PMPI_Recv_init(void *buf, int count, MPI_Datatype datatype, int src,
- int tag, MPI_Comm comm, MPI_Request * request)
+ int tag, MPI_Comm comm, MPI_Request * request)
{
int retval = 0;
} else if (comm == MPI_COMM_NULL) {
retval = MPI_ERR_COMM;
} else if (src == MPI_PROC_NULL) {
- retval = MPI_SUCCESS;
+ retval = MPI_SUCCESS;
} else {
*request = smpi_mpi_recv_init(buf, count, datatype, src, tag, comm);
retval = MPI_SUCCESS;
}
smpi_bench_begin();
- if(retval!=MPI_SUCCESS)*request=MPI_REQUEST_NULL;
+ if (retval != MPI_SUCCESS && request)
+ *request = MPI_REQUEST_NULL;
return retval;
}
-int PMPI_Ssend_init(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm, MPI_Request* request) {
+int PMPI_Ssend_init(void* buf, int count, MPI_Datatype datatype,
+ int dst, int tag, MPI_Comm comm, MPI_Request* request)
+{
int retval = 0;
- smpi_bench_end();
- if (request == NULL) {
- retval = MPI_ERR_ARG;
- } else if (comm == MPI_COMM_NULL) {
- retval = MPI_ERR_COMM;
- } else if (dst == MPI_PROC_NULL) {
- retval = MPI_SUCCESS;
- } else {
- *request = smpi_mpi_ssend_init(buf, count, datatype, dst, tag, comm);
- retval = MPI_SUCCESS;
- }
- smpi_bench_begin();
- if(retval!=MPI_SUCCESS)*request=MPI_REQUEST_NULL;
- return retval;
+ smpi_bench_end();
+ if (request == NULL) {
+ retval = MPI_ERR_ARG;
+ } else if (comm == MPI_COMM_NULL) {
+ retval = MPI_ERR_COMM;
+ } else if (dst == MPI_PROC_NULL) {
+ retval = MPI_SUCCESS;
+ } else {
+ *request = smpi_mpi_ssend_init(buf, count, datatype, dst, tag, comm);
+ retval = MPI_SUCCESS;
+ }
+ smpi_bench_begin();
+ if (retval != MPI_SUCCESS && request)
+ *request = MPI_REQUEST_NULL;
+ return retval;
}
int PMPI_Start(MPI_Request * request)
}
int PMPI_Irecv(void *buf, int count, MPI_Datatype datatype, int src,
- int tag, MPI_Comm comm, MPI_Request * request)
+ int tag, MPI_Comm comm, MPI_Request * request)
{
int retval = 0;
} else {
#ifdef HAVE_TRACING
- int rank = comm != MPI_COMM_NULL ? smpi_process_index() : -1;
- int src_traced = smpi_group_index(smpi_comm_group(comm), src);
- TRACE_smpi_ptp_in(rank, src_traced, rank, __FUNCTION__, count*smpi_datatype_size(datatype));
+ int rank = comm != MPI_COMM_NULL ? smpi_process_index() : -1;
+ int src_traced = smpi_group_index(smpi_comm_group(comm), src);
+ TRACE_smpi_ptp_in(rank, src_traced, rank, __FUNCTION__, count*smpi_datatype_size(datatype));
#endif
*request = smpi_mpi_irecv(buf, count, datatype, src, tag, comm);
retval = MPI_SUCCESS;
#ifdef HAVE_TRACING
- TRACE_smpi_ptp_out(rank, src_traced, rank, __FUNCTION__);
- (*request)->recv = 1;
+ TRACE_smpi_ptp_out(rank, src_traced, rank, __FUNCTION__);
+ (*request)->recv = 1;
#endif
}
smpi_bench_begin();
- if(retval!=MPI_SUCCESS)*request=MPI_REQUEST_NULL;
+ if (retval != MPI_SUCCESS && request)
+ *request = MPI_REQUEST_NULL;
return retval;
}
int PMPI_Isend(void *buf, int count, MPI_Datatype datatype, int dst,
- int tag, MPI_Comm comm, MPI_Request * request)
+ int tag, MPI_Comm comm, MPI_Request * request)
{
int retval = 0;
} else {
#ifdef HAVE_TRACING
- int rank = comm != MPI_COMM_NULL ? smpi_process_index() : -1;
- TRACE_smpi_computing_out(rank);
- int dst_traced = smpi_group_index(smpi_comm_group(comm), dst);
- TRACE_smpi_ptp_in(rank, rank, dst_traced, __FUNCTION__, count*smpi_datatype_size(datatype));
- TRACE_smpi_send(rank, rank, dst_traced, count*smpi_datatype_size(datatype));
+ int rank = comm != MPI_COMM_NULL ? smpi_process_index() : -1;
+ TRACE_smpi_computing_out(rank);
+ int dst_traced = smpi_group_index(smpi_comm_group(comm), dst);
+ TRACE_smpi_ptp_in(rank, rank, dst_traced, __FUNCTION__, count*smpi_datatype_size(datatype));
+ TRACE_smpi_send(rank, rank, dst_traced, count*smpi_datatype_size(datatype));
#endif
*request = smpi_mpi_isend(buf, count, datatype, dst, tag, comm);
retval = MPI_SUCCESS;
#ifdef HAVE_TRACING
- TRACE_smpi_ptp_out(rank, rank, dst_traced, __FUNCTION__);
- (*request)->send = 1;
- TRACE_smpi_computing_in(rank);
+ TRACE_smpi_ptp_out(rank, rank, dst_traced, __FUNCTION__);
+ (*request)->send = 1;
+ TRACE_smpi_computing_in(rank);
#endif
}
smpi_bench_begin();
- if(retval!=MPI_SUCCESS)*request=MPI_REQUEST_NULL;
+ if (retval != MPI_SUCCESS && request)
+ *request = MPI_REQUEST_NULL;
return retval;
}
-int PMPI_Issend(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm, MPI_Request* request) {
+int PMPI_Issend(void* buf, int count, MPI_Datatype datatype,
+ int dst, int tag, MPI_Comm comm, MPI_Request* request)
+{
int retval = 0;
smpi_bench_end();
} else {
#ifdef HAVE_TRACING
- int rank = comm != MPI_COMM_NULL ? smpi_process_index() : -1;
- TRACE_smpi_computing_out(rank);
- int dst_traced = smpi_group_index(smpi_comm_group(comm), dst);
- TRACE_smpi_ptp_in(rank, rank, dst_traced, __FUNCTION__, count*smpi_datatype_size(datatype));
- TRACE_smpi_send(rank, rank, dst_traced, count*smpi_datatype_size(datatype));
+ int rank = comm != MPI_COMM_NULL ? smpi_process_index() : -1;
+ TRACE_smpi_computing_out(rank);
+ int dst_traced = smpi_group_index(smpi_comm_group(comm), dst);
+ TRACE_smpi_ptp_in(rank, rank, dst_traced, __FUNCTION__, count*smpi_datatype_size(datatype));
+ TRACE_smpi_send(rank, rank, dst_traced, count*smpi_datatype_size(datatype));
#endif
*request = smpi_mpi_issend(buf, count, datatype, dst, tag, comm);
retval = MPI_SUCCESS;
#ifdef HAVE_TRACING
- TRACE_smpi_ptp_out(rank, rank, dst_traced, __FUNCTION__);
- (*request)->send = 1;
- TRACE_smpi_computing_in(rank);
+ TRACE_smpi_ptp_out(rank, rank, dst_traced, __FUNCTION__);
+ (*request)->send = 1;
+ TRACE_smpi_computing_in(rank);
#endif
}
smpi_bench_begin();
- if(retval!=MPI_SUCCESS)*request=MPI_REQUEST_NULL;
+ if (retval != MPI_SUCCESS && request)
+ *request = MPI_REQUEST_NULL;
return retval;
}
int retval = 0;
smpi_bench_end();
- if (*request == MPI_REQUEST_NULL || flag == NULL) {
+ if (request == NULL || flag == NULL) {
retval = MPI_ERR_ARG;
} else if (*request == MPI_REQUEST_NULL) {
*flag= TRUE;
+ smpi_empty_status(status);
retval = MPI_ERR_REQUEST;
} else {
*flag = smpi_mpi_test(request, status);
smpi_bench_end();
+ smpi_empty_status(status);
+
if (request == NULL) {
retval = MPI_ERR_ARG;
} else if (*request == MPI_REQUEST_NULL) {
} else {
#ifdef HAVE_TRACING
- int rank = request && (*request)->comm != MPI_COMM_NULL
+ int rank = request && (*request)->comm != MPI_COMM_NULL
? smpi_process_index()
: -1;
- TRACE_smpi_computing_out(rank);
+ TRACE_smpi_computing_out(rank);
- int src_traced = (*request)->src;
- int dst_traced = (*request)->dst;
- MPI_Comm comm = (*request)->comm;
- int is_wait_for_receive = (*request)->recv;
- TRACE_smpi_ptp_in(rank, src_traced, dst_traced, __FUNCTION__,-1);
+ int src_traced = (*request)->src;
+ int dst_traced = (*request)->dst;
+ MPI_Comm comm = (*request)->comm;
+ int is_wait_for_receive = (*request)->recv;
+ TRACE_smpi_ptp_in(rank, src_traced, dst_traced, __FUNCTION__,-1);
#endif
smpi_mpi_wait(request, status);
retval = MPI_SUCCESS;
#ifdef HAVE_TRACING
- //the src may not have been known at the beginning of the recv (MPI_ANY_SOURCE)
- TRACE_smpi_ptp_out(rank, src_traced, dst_traced, __FUNCTION__);
- if (is_wait_for_receive) {
- if(src_traced==MPI_ANY_SOURCE)
- src_traced = (status!=MPI_STATUS_IGNORE) ?
- smpi_group_rank(smpi_comm_group(comm), status->MPI_SOURCE) :
- src_traced;
- TRACE_smpi_recv(rank, src_traced, dst_traced);
- }
- TRACE_smpi_computing_in(rank);
+ //the src may not have been known at the beginning of the recv (MPI_ANY_SOURCE)
+ TRACE_smpi_ptp_out(rank, src_traced, dst_traced, __FUNCTION__);
+ if (is_wait_for_receive) {
+ if(src_traced==MPI_ANY_SOURCE)
+ src_traced = (status!=MPI_STATUS_IGNORE) ?
+ smpi_group_rank(smpi_comm_group(comm), status->MPI_SOURCE) :
+ src_traced;
+ TRACE_smpi_recv(rank, src_traced, dst_traced);
+ }
+ TRACE_smpi_computing_in(rank);
#endif
}