[svn-r5469] Purpose:

    Feature Addition
Description:
    Added feature which prints out the parameters and the MPI_Info object
    for a run for each process.

    Added some functions for the GPFS system. They are ifdef'ed out right
    now (well, they need to ahve the non-existant H5_HAVE_GPFS macro set)
    and aren't in use just yet. But the stub functions are there.
Platforms tested:
    Linux

1 files changed, 93 insertions, 5 deletions

diff --git a/perform/pio_engine.c b/perform/pio_engine.c
index 65d8d2d..49104bc 100644
--- a/perform/pio_engine.c
+++ b/perform/pio_engine.c
@@ -24,6 +24,10 @@
 #   include <mpio.h>
 #endif  /* !MPI_FILE_NULL */
 
+#ifdef H5_HAVE_GPFS
+#   include <gpfs_fcntl.h>
+#endif  /* H5_HAVE_GPFS */
+
 #include "pio_perf.h"
 #include "pio_timer.h"
 
@@ -71,10 +75,8 @@ enum {
 
 /* Global variables */
 static int	clean_file_g = -1;	/*whether to cleanup temporary test     */
-                                /*files. -1 is not defined;             */
-                                /*0 is no cleanup; 1 is do cleanup      */
-
-
+                                        /*files. -1 is not defined;             */
+                                        /*0 is no cleanup; 1 is do cleanup      */
 
 /*
  * In a parallel machine, the filesystem suitable for compiling is
@@ -92,7 +94,7 @@ static int	clean_file_g = -1;	/*whether to cleanup temporary test     */
 #endif  /* !HDF5_PARAPREFIX */
 
 #ifndef MIN
-#define MIN(a,b) (a < b ? a : b)
+#   define MIN(a,b) ((a) < (b) ? (a) : (b))
 #endif  /* !MIN */
 
 /* the different types of file descriptors we can expect */
@@ -114,6 +116,10 @@ static herr_t do_fopen(parameters *param, char *fname, file_descr *fd /*out*/,
 static herr_t do_fclose(iotype iot, file_descr *fd);
 static void do_cleanupfile(iotype iot, char *fname);
 
+/* GPFS-specific functions */
+static void start_data_shipping(int handle, int num_insts);
+static void stop_data_shipping(int handle);
+
 /*
  * Function:    do_pio
  * Purpose:     PIO Engine where Parallel IO are executed.
@@ -1166,6 +1172,88 @@ do_cleanupfile(iotype iot, char *fname)
     }
 }
 
+#ifdef H5_HAVE_GPFS
+
+/*
+ * Function:    start_data_shipping
+ * Purpose:     Start up data shipping. The second parameter is the total
+ *              number of open instances on all nodes that will be
+ *              operating on the file. Must be called for every such
+ *              instance with the same value of NUM_INSTS.
+ * Return:      Nothing
+ * Programmer:  Bill Wendling, 28. May 2002
+ * Modifications:
+ */
+static void
+start_data_shipping(int handle, int num_insts)
+{
+    struct {
+        gpfsFcntlHeader_t hdr;
+        gpfsDataShipStart_t start;
+    } ds_start;
+
+    ds_start.hdr.totalLength = sizeof(ds_start);
+    ds_start.hdr.fcntlVersion = GPFS_FCNTL_CURRENT_VERSION;
+    ds_start.hdr.fcntlReserved = 0;
+    ds_start.start.structLen = sizeof(gpfsDataShipStart_t);
+    ds_start.start.structType = GPFS_DATA_SHIP_START;
+    ds_start.start.numInstances = num_insts;
+    ds_start.start.reserved = 0;
+
+    if (gpfs_fcntl(handle, &ds_start) != 0) {
+        fprintf(stderr,
+                "gpfs_fcntl DS start directive failed. errno=%d errorOffset=%d\n",
+                errno, ds_start.hdr.errorOffset);
+        exit(EXIT_FAILURE);
+    }
+}
+
+/*
+ * Function:    stop_data_shipping
+ * Purpose:     Shut down data shipping. Must be called for every handle
+ *              for which start_data_shipping was called.
+ * Return:      Nothing
+ * Programmer:  Bill Wendling, 28. May 2002
+ * Modifications:
+ */
+static void
+stop_data_shipping(int handle)
+{
+    struct {
+        gpfsFcntlHeader_t hdr;
+        gpfsDataShipStop_t stop;
+    } ds_stop;
+
+    ds_stop.hdr.totalLength = sizeof(ds_stop);
+    ds_stop.hdr.fcntlVersion = GPFS_FCNTL_CURRENT_VERSION;
+    ds_stop.hdr.fcntlReserved = 0;
+    ds_stop.stop.structLen = sizeof(ds_stop.stop);
+    ds_stop.stop.structType = GPFS_DATA_SHIP_STOP;
+
+    if (gpfs_fcntl(handle, &ds_stop) != 0)
+        fprintf(stderr,
+                "gpfs_fcntl DS stop directive failed. errno=%d errorOffset=%d\n",
+                errno, ds_stop.hdr.errorOffset);
+}
+
+#else
+
+/* H5_HAVE_GPFS isn't defined */
+
+static void
+start_data_shipping(int handle, int num_insts)
+{
+    return;
+}
+
+static void
+stop_data_shipping(int handle)
+{
+    return;
+}
+
+#endif  /* H5_HAVE_GPFS */
+
 #ifndef TIME_MPI
 #define TIME_MPI
 #endif