Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
kill all trailling whitespaces
[simgrid.git] / teshsuite / smpi / isp / umpire / partial-recv-exhaustive.c
index 03bcddd..0759c7a 100644 (file)
@@ -45,42 +45,42 @@ main (int argc, char **argv)
   printf ("(%d) is alive on %s\n", rank, processor_name);
   fflush (stdout);
 
-  MPI_Buffer_attach (bbuf, sizeof(int) * 
+  MPI_Buffer_attach (bbuf, sizeof(int) *
                     (BUF_SIZE + MPI_BSEND_OVERHEAD) * 2 * NUM_BSEND_TYPES);
 
   if (rank == 0) {
     /* set up persistent sends... */
     send_t_number = NUM_SEND_TYPES - NUM_PERSISTENT_SEND_TYPES;
 
-    MPI_Send_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT, 
+    MPI_Send_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                    1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
-    MPI_Send_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE], 
-                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+    MPI_Send_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
+                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                    comm, &aReq[send_t_number * 2 + 1]);
 
     send_t_number++;
 
-    MPI_Bsend_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT, 
+    MPI_Bsend_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                    1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
-    MPI_Bsend_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE], 
-                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+    MPI_Bsend_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
+                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                    comm, &aReq[send_t_number * 2 + 1]);
 
 
     send_t_number++;
 
-    MPI_Rsend_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT, 
+    MPI_Rsend_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                    1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
-    MPI_Rsend_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE], 
-                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+    MPI_Rsend_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
+                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                    comm, &aReq[send_t_number * 2 + 1]);
 
     send_t_number++;
 
-    MPI_Ssend_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT, 
+    MPI_Ssend_init (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                    1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
-    MPI_Ssend_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE], 
-                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+    MPI_Ssend_init (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
+                   BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                    comm, &aReq[send_t_number * 2 + 1]);
   }
 
@@ -88,8 +88,8 @@ main (int argc, char **argv)
     if ((m == 1) && (rank == 1)) {
       /* set up the persistent receives... */
       for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
-       MPI_Recv_init (&buf[j * BUF_SIZE], 
-                      BUF_SIZE + (j % 2) * SLOP, 
+       MPI_Recv_init (&buf[j * BUF_SIZE],
+                      BUF_SIZE + (j % 2) * SLOP,
                       MPI_INT, 0, j, comm, &aReq[j]);
       }
     }
@@ -115,11 +115,11 @@ main (int argc, char **argv)
        if (rank == 0) {
          /* set up transient sends... */
          send_t_number = 0;
-    
+
          MPI_Isend (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                     1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
          MPI_Isend (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
-                    BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+                    BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                     comm, &aReq[send_t_number * 2 + 1]);
 
          send_t_number++;
@@ -127,18 +127,18 @@ main (int argc, char **argv)
          MPI_Ibsend (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                      1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
          MPI_Ibsend (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
-                     BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+                     BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                      comm, &aReq[send_t_number * 2 + 1]);
 
          send_t_number++;
 
          /* Barrier to ensure receives are posted for rsends... */
          MPI_Barrier(MPI_COMM_WORLD);
-         
+       
          MPI_Irsend (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                    1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
          MPI_Irsend (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
-                     BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+                     BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                      comm, &aReq[send_t_number * 2 + 1]);
 
          send_t_number++;
@@ -146,17 +146,17 @@ main (int argc, char **argv)
          MPI_Issend (&buf[send_t_number * 2 * BUF_SIZE], BUF_SIZE, MPI_INT,
                      1, send_t_number * 2, comm, &aReq[send_t_number * 2]);
          MPI_Issend (&buf[(send_t_number * 2 + 1) * BUF_SIZE],
-                     BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1, 
+                     BUF_SIZE, MPI_INT, 1, send_t_number * 2 + 1,
                      comm, &aReq[send_t_number * 2 + 1]);
 
          /* just to be paranoid */
          send_t_number++;
-         assert (send_t_number == 
+         assert (send_t_number ==
                  NUM_SEND_TYPES - NUM_PERSISTENT_SEND_TYPES);
 
          /* start the persistent sends... */
          if (k % 2) {
-           MPI_Startall (NUM_PERSISTENT_SEND_TYPES * 2, 
+           MPI_Startall (NUM_PERSISTENT_SEND_TYPES * 2,
                          &aReq[2 * send_t_number]);
          }
          else {
@@ -173,7 +173,7 @@ main (int argc, char **argv)
              MPI_Wait (&aReq[j], &aStatus[j]);
            }
            break;
-         
+       
          case 1:
            /* use MPI_Waitall */
            MPI_Waitall (NUM_SEND_TYPES * 2, aReq, aStatus);
@@ -184,14 +184,14 @@ main (int argc, char **argv)
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              MPI_Waitany (NUM_SEND_TYPES * 2, aReq, &index, aStatus);
            }
-           
+       
            break;
        
          case 3:
            /* use MPI_Waitsome */
            total = 0;
            while (total < NUM_SEND_TYPES * 2) {
-             MPI_Waitsome (NUM_SEND_TYPES * 2, aReq, 
+             MPI_Waitsome (NUM_SEND_TYPES * 2, aReq,
                            &outcount, indices, aStatus);
 
              total += outcount;
@@ -203,12 +203,12 @@ main (int argc, char **argv)
            /* use MPI_Test */
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              flag = 0;
-           
+       
              while (!flag) {
                MPI_Test (&aReq[j], &flag, &aStatus[j]);
              }
            }
-         
+       
            break;
        
          case 5:
@@ -217,7 +217,7 @@ main (int argc, char **argv)
            while (!flag) {
              MPI_Testall (NUM_SEND_TYPES * 2, aReq, &flag, aStatus);
            }
-         
+       
            break;
        
          case 6:
@@ -225,7 +225,7 @@ main (int argc, char **argv)
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              flag = 0;
              while (!flag) {
-               MPI_Testany (NUM_SEND_TYPES * 2, aReq, 
+               MPI_Testany (NUM_SEND_TYPES * 2, aReq,
                             &index, &flag, aStatus);
              }
            }
@@ -239,7 +239,7 @@ main (int argc, char **argv)
              outcount = 0;
 
              while (!outcount) {
-               MPI_Testsome (NUM_SEND_TYPES * 2, aReq, 
+               MPI_Testsome (NUM_SEND_TYPES * 2, aReq,
                              &outcount, indices, aStatus);
              }
 
@@ -257,8 +257,8 @@ main (int argc, char **argv)
          /* start receives for all of the sends */
          if (m == 0) {
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
-             MPI_Irecv (&buf[j * BUF_SIZE], 
-                        BUF_SIZE + (j % 2) * SLOP, 
+             MPI_Irecv (&buf[j * BUF_SIZE],
+                        BUF_SIZE + (j % 2) * SLOP,
                         MPI_INT, 0, j, comm, &aReq[j]);
            }
          }
@@ -279,13 +279,13 @@ main (int argc, char **argv)
        
          /* complete all of the receives... */
          switch (l/2) {
-         case 0: 
+         case 0:
            /* use MPI_Wait */
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              MPI_Wait (&aReq[j], &aStatus[j]);
            }
            break;
-           
+       
          case 1:
            /* use MPI_Waitall */
            MPI_Waitall (NUM_SEND_TYPES * 2, aReq, aStatus);
@@ -296,54 +296,54 @@ main (int argc, char **argv)
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              MPI_Waitany (NUM_SEND_TYPES * 2, aReq, &index, aStatus);
            }
-           
+       
            break;
        
          case 3:
            /* use MPI_Waitsome */
            total = 0;
            while (total < NUM_SEND_TYPES * 2) {
-             MPI_Waitsome (NUM_SEND_TYPES * 2, aReq, 
+             MPI_Waitsome (NUM_SEND_TYPES * 2, aReq,
                            &outcount, indices, aStatus);
 
              total += outcount;
            }
 
            break;
-           
+       
          case 4:
            /* use MPI_Test */
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              flag = 0;
-             
+       
              while (!flag) {
                MPI_Test (&aReq[j], &flag, &aStatus[j]);
              }
            }
-           
+       
            break;
-           
+       
          case 5:
            /* use MPI_Testall */
            flag = 0;
            while (!flag) {
              MPI_Testall (NUM_SEND_TYPES * 2, aReq, &flag, aStatus);
            }
-           
+       
            break;
-           
+       
          case 6:
            /* use MPI_Testany */
            for (j = 0; j < NUM_SEND_TYPES * 2; j++) {
              flag = 0;
              while (!flag) {
-               MPI_Testany (NUM_SEND_TYPES * 2, aReq, 
+               MPI_Testany (NUM_SEND_TYPES * 2, aReq,
                             &index, &flag, aStatus);
              }
            }
-           
+       
            break;
-           
+       
          case 7:
            /* use MPI_Testsome */
            total = 0;
@@ -351,15 +351,15 @@ main (int argc, char **argv)
              outcount = 0;
 
              while (!outcount) {
-               MPI_Testsome (NUM_SEND_TYPES * 2, aReq, 
+               MPI_Testsome (NUM_SEND_TYPES * 2, aReq,
                              &outcount, indices, aStatus);
              }
-             
+       
              total += outcount;
            }
-           
+       
            break;
-           
+       
          default:
            assert (0);
            break;
@@ -392,7 +392,7 @@ main (int argc, char **argv)
 
   MPI_Buffer_detach (bbuf, &at_size);
 
-  assert (at_size == 
+  assert (at_size ==
          sizeof(int) * (BUF_SIZE + MPI_BSEND_OVERHEAD) * 2 * NUM_BSEND_TYPES);
 
   MPI_Finalize ();