PNETCDF_PROFILING: print profiling timings by world rank 0 only

Author: wkliao

src/drivers/pncio/pncio_close.c

@@ -38,12 +38,12 @@ int PNCIO_File_close(PNCIO_File *fh)
         NCI_Free(fh->io_buf);
 
 #if defined(PNETCDF_PROFILING) && (PNETCDF_PROFILING == 1)
-    int i, rank;
+    int i, world_rank;
     double timing[NMEASURES*2], max_t[NMEASURES*2], pread_t;
     MPI_Count max_ntimes, counter[NMEASURES*2], max_c[NMEASURES*2];
 
     /* print two-phase I/O timing breakdown */
-    MPI_Comm_rank(fh->comm, &rank);
+    MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
     for (i=0; i<NMEASURES; i++) {
         timing[i]  = fh->write_timing[i];
         counter[i] = fh->write_counter[i];
@@ -56,7 +56,7 @@ int PNCIO_File_close(PNCIO_File *fh)
     pread_t = max_t[NMEASURES+2];
     max_ntimes = max_c[0];
 
-    if (rank == 0 && max_ntimes > 0) {
+    if (world_rank == 0 && max_ntimes > 0) {
         printf("%s: TWO-PHASE write init %5.2f pwrite %5.2f pread %5.2f post %5.2f hsort %5.2f comm %5.2f collw %5.2f\n",
         __func__, max_t[1], max_t[2], pread_t, max_t[4], max_t[5], max_t[3], max_t[0]);
         printf("%s: TWO-PHASE write ntimes %lld check_hole %lld (total_num %lld nrecv %lld) no check %lld (total_num %lld nrecv %lld)\n",
@@ -65,7 +65,7 @@ int PNCIO_File_close(PNCIO_File *fh)
 
     max_ntimes = max_c[NMEASURES];
 
-    if (rank == 0 && max_ntimes > 0)
+    if (world_rank == 0 && max_ntimes > 0)
         printf("%s: TWO-PHASE read  init %5.2f pread  %5.2f post %5.2f wait %5.2f collr %5.2f ntimes %lld\n",
         __func__, max_t[NMEASURES+1], max_t[NMEASURES+2], max_t[NMEASURES+4], max_t[NMEASURES+3], max_t[NMEASURES+0], max_ntimes);
 #endif

src/drivers/pncio/pncio_lustre_open.c

@@ -791,7 +791,8 @@ first_ost_id = -1;
     MPI_Comm_rank(fd->comm, &rank);
 
 #if defined(PNETCDF_PROFILING) && (PNETCDF_PROFILING == 1)
-static int wkl=0; if (wkl == 0 && rank == 0) { printf("\nxxxx %s at %d: %s ---- %s\n",__func__,__LINE__,(fd->file_system == PNCIO_LUSTRE)?"PNCIO_LUSTRE":"PNCIO_UFS",fd->filename); wkl++; fflush(stdout);}
+int world_rank; MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
+static int wkl=0; if (wkl == 0 && world_rank == 0) { printf("\nxxxx %s at %d: %s ---- %s\n",__func__,__LINE__,(fd->file_system == PNCIO_LUSTRE)?"PNCIO_LUSTRE":"PNCIO_UFS",fd->filename); wkl++; fflush(stdout);}
 #endif
 
 #if defined(HAVE_LUSTRE) || defined(MIMIC_LUSTRE)
@@ -1066,7 +1067,8 @@ first_ost_id = -1;
     MPI_Comm_rank(fd->comm, &rank);
 
 #if defined(PNETCDF_PROFILING) && (PNETCDF_PROFILING == 1)
-static int wkl=0; if (wkl == 0 && rank == 0) { printf("\nxxxx %s at %d: %s ---- %s\n",__func__,__LINE__,(fd->file_system == PNCIO_LUSTRE)?"PNCIO_LUSTRE":"PNCIO_UFS",fd->filename); wkl++; fflush(stdout);}
+int world_rank; MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
+static int wkl=0; if (wkl == 0 && world_rank == 0) { printf("\nxxxx %s at %d: %s ---- %s\n",__func__,__LINE__,(fd->file_system == PNCIO_LUSTRE)?"PNCIO_LUSTRE":"PNCIO_UFS",fd->filename); wkl++; fflush(stdout);}
 #endif
 
     old_mask = umask(022);

src/drivers/pncio/pncio_open.c

@@ -117,7 +117,8 @@ GEN_create(PNCIO_File *fd,
     MPI_Comm_rank(fd->comm, &rank);
 
 #if defined(PNETCDF_PROFILING) && (PNETCDF_PROFILING == 1)
-if (rank == 0) { printf("\nxxxx %s at %d: ---- %s\n",__func__,__LINE__,fd->filename); fflush(stdout);}
+int world_rank; MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
+if (world_rank == 0) { printf("\nxxxx %s at %d: ---- %s\n",__func__,__LINE__,fd->filename); fflush(stdout);}
 #endif
 
     amode = O_CREAT;
@@ -178,7 +179,8 @@ GEN_open(PNCIO_File *fd)
     MPI_Comm_rank(fd->comm, &rank);
 
 #if defined(PNETCDF_PROFILING) && (PNETCDF_PROFILING == 1)
-if (rank == 0) { printf("\nxxxx %s at %d: ---- %s\n",__func__,__LINE__,fd->filename); fflush(stdout);}
+int world_rank; MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
+if (world_rank == 0) { printf("\nxxxx %s at %d: ---- %s\n",__func__,__LINE__,fd->filename); fflush(stdout);}
 #endif
 
     old_mask = umask(022);