Working without timing

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);