- xbt_assert0(ref, "Cannot match recv against null reference");
- xbt_assert0(req, "Cannot match recv against null request");
+ xbt_assert(ref, "Cannot match recv against null reference");
+ xbt_assert(req, "Cannot match recv against null request");
return req->comm == ref->comm
&& (ref->src == MPI_ANY_SOURCE || req->src == ref->src)
&& (ref->tag == MPI_ANY_TAG || req->tag == ref->tag);
return req->comm == ref->comm
&& (ref->src == MPI_ANY_SOURCE || req->src == ref->src)
&& (ref->tag == MPI_ANY_TAG || req->tag == ref->tag);
- xbt_assert0(ref, "Cannot match send against null reference");
- xbt_assert0(req, "Cannot match send against null request");
+ xbt_assert(ref, "Cannot match send against null reference");
+ xbt_assert(req, "Cannot match send against null request");
return req->comm == ref->comm
&& (req->src == MPI_ANY_SOURCE || req->src == ref->src)
&& (req->tag == MPI_ANY_TAG || req->tag == ref->tag);
return req->comm == ref->comm
&& (req->src == MPI_ANY_SOURCE || req->src == ref->src)
&& (req->tag == MPI_ANY_TAG || req->tag == ref->tag);
"Cannot (re)start a non-finished communication");
if(request->flags & RECV) {
print_request("New recv", request);
"Cannot (re)start a non-finished communication");
if(request->flags & RECV) {
print_request("New recv", request);
status->MPI_SOURCE = req->src;
status->MPI_TAG = req->tag;
status->MPI_ERROR = MPI_SUCCESS;
status->MPI_SOURCE = req->src;
status->MPI_TAG = req->tag;
status->MPI_ERROR = MPI_SUCCESS;
print_request("Finishing", req);
if(req->flags & NON_PERSISTENT) {
smpi_mpi_request_free(request);
print_request("Finishing", req);
if(req->flags & NON_PERSISTENT) {
smpi_mpi_request_free(request);
comms = xbt_dynar_new(sizeof(smx_action_t), NULL);
map = xbt_new(int, count);
size = 0;
comms = xbt_dynar_new(sizeof(smx_action_t), NULL);
map = xbt_new(int, count);
size = 0;
for(i = 0; i < count; i++) {
if(requests[i] != MPI_REQUEST_NULL) {
print_request(" ", requests[i]);
for(i = 0; i < count; i++) {
if(requests[i] != MPI_REQUEST_NULL) {
print_request(" ", requests[i]);
- int rank, size, other, index, sendsize, recvsize;
+ int rank, size, other, index, sendsize;
MPI_Request *requests;
rank = smpi_comm_rank(comm);
size = smpi_comm_size(comm);
sendsize = smpi_datatype_size(sendtype);
MPI_Request *requests;
rank = smpi_comm_rank(comm);
size = smpi_comm_size(comm);
sendsize = smpi_datatype_size(sendtype);
// Local copy from self
memcpy(&((char *) recvbuf)[displs[rank]], sendbuf,
sendcount * sendsize * sizeof(char));
// Local copy from self
memcpy(&((char *) recvbuf)[displs[rank]], sendbuf,
sendcount * sendsize * sizeof(char));
- int rank, size, dst, index, sendsize, recvsize;
+ int rank, size, dst, index, recvsize;
smpi_mpi_recv(recvbuf, recvcount, recvtype, root, system_tag, comm,
MPI_STATUS_IGNORE);
} else {
smpi_mpi_recv(recvbuf, recvcount, recvtype, root, system_tag, comm,
MPI_STATUS_IGNORE);
} else {
recvsize = smpi_datatype_size(recvtype);
// Local copy from root
memcpy(recvbuf, &((char *) sendbuf)[displs[root]],
recvsize = smpi_datatype_size(recvtype);
// Local copy from root
memcpy(recvbuf, &((char *) sendbuf)[displs[root]],