#include "mc/mc.h"
#include "xbt/replay.h"
#include <errno.h>
+#include "simix/smx_private.h"
#include "surf/surf.h"
} else {
int receiver = smpi_group_index(smpi_comm_group(request->comm), request->dst);
- if(receiver == MPI_UNDEFINED) {
- XBT_WARN("Trying to send a message to a wrong rank");
- return;
- }
+/* if(receiver == MPI_UNDEFINED) {*/
+/* XBT_WARN("Trying to send a message to a wrong rank");*/
+/* return;*/
+/* }*/
print_request("New send", request);
if (request->size < xbt_cfg_get_int(_surf_cfg_set, "smpi/async_small_thres")) { // eager mode
mailbox = smpi_process_remote_mailbox_small(receiver);
if(request->action){
MPI_Request req = (MPI_Request)SIMIX_comm_get_src_data(request->action);
- *flag=true;
+ *flag = 1;
if(status != MPI_STATUS_IGNORE) {
status->MPI_SOURCE = req->src;
status->MPI_TAG = req->tag;
status->count = req->size;
}
}
- else *flag=false;
+ else *flag = 0;
smpi_mpi_request_free(&request);
return;
}
for(c = 0; c < count; c++) {
- if(MC_IS_ENABLED) {
+ if(MC_is_active()) {
smpi_mpi_wait(&requests[c], pstat);
index = c;
} else {