Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge branch 'pikachuyann/simgrid-stoprofiles'
[simgrid.git] / teshsuite / smpi / mpich3-test / comm / dup.c
index c9a06e6..7129ef6 100644 (file)
@@ -8,71 +8,68 @@
 #include <stdio.h>
 #include "mpitest.h"
 
-int main( int argc, char **argv )
+int main(int argc, char **argv)
 {
     int errs = 0;
     int rank, size, wrank, wsize, dest, a, b;
     MPI_Comm newcomm;
     MPI_Status status;
 
-    MTest_Init( &argc, &argv );
+    MTest_Init(&argc, &argv);
 
     /* Can we run comm dup at all? */
-    MPI_Comm_dup( MPI_COMM_WORLD, &newcomm );
+    MPI_Comm_dup(MPI_COMM_WORLD, &newcomm);
 
     /* Check basic properties */
-    MPI_Comm_size( MPI_COMM_WORLD, &wsize );
-    MPI_Comm_rank( MPI_COMM_WORLD, &wrank );
-    MPI_Comm_size( newcomm, &size );
-    MPI_Comm_rank( newcomm, &rank );
-    
+    MPI_Comm_size(MPI_COMM_WORLD, &wsize);
+    MPI_Comm_rank(MPI_COMM_WORLD, &wrank);
+    MPI_Comm_size(newcomm, &size);
+    MPI_Comm_rank(newcomm, &rank);
+
     if (size != wsize || rank != wrank) {
-       errs++;
-       fprintf( stderr, "Size (%d) or rank (%d) wrong\n", size, rank );
-       fflush( stderr );
+        errs++;
+        fprintf(stderr, "Size (%d) or rank (%d) wrong\n", size, rank);
+        fflush(stderr);
     }
 
     /* Can we communicate with this new communicator? */
+    dest = MPI_PROC_NULL;
     if (rank == 0) {
-       dest = size - 1;
-       a = rank;
-       b = -1;
-       MPI_Sendrecv( &a, 1, MPI_INT, dest, 0,
-                     &b, 1, MPI_INT, dest, 0, newcomm, &status );
-       if (b != dest) {
-           errs++;
-           fprintf( stderr, "Received %d expected %d on %d\n", b, dest, rank );
-           fflush( stderr );
-       }
-       if (status.MPI_SOURCE != dest) {
-           errs++;
-           fprintf( stderr, "Source not set correctly in status on %d\n", 
-                    rank );
-           fflush( stderr );
-       }
+        dest = size - 1;
+        a = rank;
+        b = -1;
+        MPI_Sendrecv(&a, 1, MPI_INT, dest, 0, &b, 1, MPI_INT, dest, 0, newcomm, &status);
+        if (b != dest) {
+            errs++;
+            fprintf(stderr, "Received %d expected %d on %d\n", b, dest, rank);
+            fflush(stderr);
+        }
+        if (status.MPI_SOURCE != dest) {
+            errs++;
+            fprintf(stderr, "Source not set correctly in status on %d\n", rank);
+            fflush(stderr);
+        }
     }
-    else if (rank == size-1) { 
-       dest = 0;
-       a = rank;
-       b = -1;
-       MPI_Sendrecv( &a, 1, MPI_INT, dest, 0,
-                     &b, 1, MPI_INT, dest, 0, newcomm, &status );
-       if (b != dest) {
-           errs++;
-           fprintf( stderr, "Received %d expected %d on %d\n", b, dest, rank );
-           fflush( stderr );
-       }
-       if (status.MPI_SOURCE != dest) {
-           errs++;
-           fprintf( stderr, "Source not set correctly in status on %d\n", 
-                    rank );
-           fflush( stderr );
-       }
+    else if (rank == size - 1) {
+        dest = 0;
+        a = rank;
+        b = -1;
+        MPI_Sendrecv(&a, 1, MPI_INT, dest, 0, &b, 1, MPI_INT, dest, 0, newcomm, &status);
+        if (b != dest) {
+            errs++;
+            fprintf(stderr, "Received %d expected %d on %d\n", b, dest, rank);
+            fflush(stderr);
+        }
+        if (status.MPI_SOURCE != dest) {
+            errs++;
+            fprintf(stderr, "Source not set correctly in status on %d\n", rank);
+            fflush(stderr);
+        }
     }
 
-    MPI_Comm_free( &newcomm );
+    MPI_Comm_free(&newcomm);
 
-    MTest_Finalize( errs );
+    MTest_Finalize(errs);
 
     MPI_Finalize();