diff --git a/mpistalls.c b/mpistalls.c index 14b89b8d34d96976ff39ff291782852f63f705e9..b97d037f02edb9dc96c11857268feef4c17ef88f 100644 --- a/mpistalls.c +++ b/mpistalls.c @@ -44,7 +44,6 @@ static int volatile todo_send = 0; * times. */ static void *inject_thread(void *arg) { message("%d: injection thread starts", *((int *)arg)); - //atomic_inc(&injecting); while (ind_req < nr_reqs) { struct mpiuse_log_entry *log = reqs_queue[ind_req]; @@ -65,7 +64,7 @@ static void *inject_thread(void *arg) { atomic_inc(&todo_send); } else { - err = MPI_Irecv(log->data, log->size, MPI_BYTE, log->rank, + err = MPI_Irecv(log->data, log->size, MPI_BYTE, log->otherrank, log->tag, subtypeMPI_comms[log->subtype], &log->req); /* Add a new recv request. */ @@ -106,7 +105,7 @@ static void *send_thread(void *arg) { } if (res) { /* Done, clean up. */ - message("MPI_Test successful"); + //message("MPI_Test successful"); free(log->data); sends_queue[k] = NULL; atomic_dec(&todo_send); @@ -139,7 +138,7 @@ static void *recv_thread(void *arg) { } if (res) { /* Done, clean up. */ - message("MPI_Test successful"); + //message("MPI_Test successful"); free(log->data); recvs_queue[k] = NULL; atomic_dec(&todo_recv);