Merge remote-tracking branch 'origin/develop' into monotonic_timer

1 files changed, 403 insertions, 0 deletions

diff --git a/test/use_append_chunk_mirror.c b/test/use_append_chunk_mirror.c
new file mode 100644
index 0000000..6ee01c0
--- /dev/null
+++ b/test/use_append_chunk_mirror.c
@@ -0,0 +1,403 @@
+/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
+ * Copyright by The HDF Group.                                               *
+ * All rights reserved.                                                      *
+ *                                                                           *
+ * This file is part of HDF5.  The full HDF5 copyright notice, including     *
+ * terms governing use, modification, and redistribution, is contained in    *
+ * the COPYING file, which can be found at the root of the source code       *
+ * distribution tree, or in https://support.hdfgroup.org/ftp/HDF5/releases.  *
+ * If you do not have access to either file, you may request a copy from     *
+ * help@hdfgroup.org.                                                        *
+ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
+
+/* HACKED VERSION
+ * Demonstrate SWMR with a mirrored file.
+ *
+ * Must be built with SERVER_IP as the IP address of the target system
+ * with a running mirror server, and SERVER_PORT as the primary server port.
+ *
+ * In addition to the local file, 'shinano.h5' will be created on the remote
+ * system, mirroring the local file. The file location will be local to
+ * Server's/Writer's invocation directory.
+ *
+ * Template for demonstration purposes:
+ *
+ * # Launch mirror server on remote machine (in foreground to easily stop)
+ * REMOTE(1)$ ./mirror_server /path/to/mirror_worker
+ *
+ * # Launch chunk writer with plenty of chunks.
+ * LOCAL(1)$ ./use_append_chunk_mirror -l w -n 10000
+ *
+ * # Wait one second for files to be created.
+ *
+ * # Launch chunk readers on both files.
+ * LOCAL(2)$ ./use_append_chunk_mirror -l r -n 10000
+ * REMOTE(2)$ ./use_append_chunk_mirror -l r -n 10000 -f shinano.h5
+ *
+ * # Hard-stop the server.
+ * REMOTE(1)$ ^C
+ * # alt, softer shutdown using echo and nc
+ * echo "SHUTDOWN" | nc localhost 3000
+ */
+
+/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
+ * Use Case 1.7 Appending a single chunk
+ * Description:
+ *     Appending a single chunk of raw data to a dataset along an unlimited
+ *     dimension within a pre-created file and reading the new data back.
+ * Goal:
+ *     Read data appended by the Writer to a pre-existing dataset in a
+ *     file. The dataset has one or more unlimited dimensions. The data is
+ *     appended by a hyperslab that is contained in one chunk (for example,
+ *     appending 2-dim planes along the slowest changing dimension in the
+ *     3-dim dataset).
+ * Level:
+ *     User Level
+ * Guarantees:
+ *     o Readers will see the modified dimension sizes after the Writer
+ *       finishes HDF5 metadata updates and issues H5Fflush or H5Oflush calls.
+ *     o Readers will see newly appended data after the Writer finishes
+ *       the flush operation.
+ *
+ * Preconditions:
+ *     o Readers are not allowed to modify the file.
+ *     o All datasets that are modified by the Writer exist when the Writer
+ *       opens the file.
+ *     o All datasets that are modified by the Writer exist when a Reader
+ *       opens the file.
+ *     o Data is written by a hyperslab contained in one chunk.
+ *
+ * Main Success Scenario:
+ *     1. An application creates a file with required objects (groups,
+ *        datasets, and attributes).
+ *     2. The Writer application opens the file and datasets in the file
+ *        and starts adding data along the unlimited dimension using a hyperslab
+ *        selection that corresponds to an HDF5 chunk.
+ *     3. A Reader opens the file and a dataset in a file, and queries
+ *        the sizes of the dataset; if the extent of the dataset has changed,
+ *        reads the appended data back.
+ *
+ * Discussion points:
+ *     1. Since the new data is written to the file, and metadata update
+ *        operation of adding pointer to the newly written chunk is atomic and
+ *        happens after the chunk is on the disk, only two things may happen
+ *        to the Reader:
+ *         o The Reader will not see new data.
+ *         o The Reader will see all new data written by Writer.
+ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
+
+/* Created: Jacob Smith, 2019 */
+
+#include "use.h"
+
+/* This test uses many POSIX things that are not available on
+ * Windows. We're using a check for fork(2) here as a proxy for
+ * all POSIX/Unix/Linux things until this test can be made
+ * more platform-independent.
+ */
+#ifdef H5_HAVE_FORK
+
+#ifdef H5_HAVE_MIRROR_VFD
+
+#define THIS_PROGNAME "use_append_chunk_mirror"
+
+#define CONNECT_WITH_JELLY 0
+
+#if CONNECT_WITH_JELLY
+#define SERVER_IP "10.10.10.248" /* hard-coded IP address */
+#else
+#define SERVER_IP "127.0.0.1"    /* localhost */
+#endif /* CONNECT_WITH_JELLY */
+#define SERVER_PORT 3000         /* hard-coded port number */
+#define MIRROR_FILE_NAME "shinano.h5" /* hard-coded duplicate/mirror filename */
+
+static options_t UC_opts; /* Use Case Options */
+
+/* Setup parameters for the use case.
+ * Return: 0 succeed; -1 fail.
+ */
+int
+setup_parameters(int argc, char * const argv[], options_t * opts)
+{
+    /* use case defaults */
+    HDmemset(opts, 0, sizeof(options_t));
+    opts->chunksize = Chunksize_DFT;
+    opts->use_swmr = TRUE;
+    opts->iterations = 1;
+    opts->chunkplanes = 1;
+    opts->progname = THIS_PROGNAME;
+
+    if (parse_option(argc, argv, opts) < 0)
+        return(-1);
+
+    opts->chunkdims[0] = opts->chunkplanes;
+    opts->chunkdims[1] = opts->chunkdims[2] = opts->chunksize;
+
+    opts->dims[0] = 0;
+    opts->max_dims[0] = H5S_UNLIMITED;
+    opts->dims[1] = opts->dims[2] = opts->max_dims[1] = opts->max_dims[2] = opts->chunksize;
+
+    if (opts->nplanes == 0)
+        opts->nplanes = (hsize_t)opts->chunksize;
+
+    show_parameters(opts);
+    return(0);
+} /* setup_parameters() */
+
+
+/* Overall Algorithm:
+ * Parse options from user;
+ * Generate/pre-created test files needed and close it;
+ * fork: child process becomes the reader process;
+ *       while parent process continues as the writer process;
+ * both run till ending conditions are met.
+ */
+int
+main(int argc, char *argv[])
+{
+    pid_t childpid=0;
+    pid_t mypid, tmppid;
+    int child_status;
+    int child_wait_option=0;
+    int ret_value = 0;
+    int child_ret_value;
+    hbool_t send_wait = FALSE;
+    hid_t fid = -1;     /* File ID */
+    H5FD_mirror_fapl_t mirr_fa;
+    H5FD_splitter_vfd_config_t split_fa;
+    hid_t mirr_fapl_id = H5I_INVALID_HID;
+
+    if (setup_parameters(argc, argv, &UC_opts) < 0) {
+        Hgoto_error(1);
+    }
+
+    mirr_fa.magic          = H5FD_MIRROR_FAPL_MAGIC;
+    mirr_fa.version        = H5FD_MIRROR_CURR_FAPL_T_VERSION;
+    mirr_fa.handshake_port = SERVER_PORT;
+    HDstrncpy(mirr_fa.remote_ip, SERVER_IP, H5FD_MIRROR_MAX_IP_LEN);
+
+
+    split_fa.wo_fapl_id       = H5I_INVALID_HID;
+    split_fa.rw_fapl_id       = H5I_INVALID_HID;
+    split_fa.magic            = H5FD_SPLITTER_MAGIC;
+    split_fa.version          = H5FD_CURR_SPLITTER_VFD_CONFIG_VERSION;
+    split_fa.log_file_path[0] = '\0'; /* none */
+    split_fa.ignore_wo_errs   = FALSE;
+    HDstrncpy(split_fa.wo_path, MIRROR_FILE_NAME, H5FD_SPLITTER_PATH_MAX);
+
+    /* Determine the need to send/wait message file*/
+    if (UC_opts.launch == UC_READWRITE) {
+        HDunlink(WRITER_MESSAGE);
+        send_wait = TRUE;
+    }
+
+    /* ==============================================================*/
+    /* UC_READWRITE: create datafile, launch both reader and writer. */
+    /* UC_WRITER:    create datafile, skip reader, launch writer.    */
+    /* UC_READER:    skip create, launch reader, exit.               */
+    /* ==============================================================*/
+    /* =========== */
+    /* Create file */
+    /* =========== */
+    if (UC_opts.launch != UC_READER) {
+        HDprintf("Creating skeleton data file for test...\n");
+
+        /* Prepare mirror child driver */
+        mirr_fapl_id = H5Pcreate(H5P_FILE_ACCESS);
+        if (mirr_fapl_id == H5I_INVALID_HID) {
+            HDfprintf(stderr, "can't create creation mirror FAPL\n");
+            Hgoto_error(1);
+        }
+        if (H5Pset_fapl_mirror(mirr_fapl_id, &mirr_fa) < 0) {
+            HDfprintf(stderr, "can't set creation mirror FAPL\n");
+            H5Eprint2(H5E_DEFAULT, stdout);
+            Hgoto_error(1);
+        }
+
+        /* Prepare parent "splitter" driver in UC_opts */
+        split_fa.wo_fapl_id       = mirr_fapl_id;
+        split_fa.rw_fapl_id       = H5P_DEFAULT;
+        UC_opts.fapl_id = H5Pcreate(H5P_FILE_ACCESS);
+        if (UC_opts.fapl_id == H5I_INVALID_HID) {
+            HDfprintf(stderr, "can't create creation FAPL\n");
+            Hgoto_error(1);
+        }
+        if (H5Pset_fapl_splitter(UC_opts.fapl_id, &split_fa) < 0) {
+            HDfprintf(stderr, "can't set creation FAPL\n");
+            H5Eprint2(H5E_DEFAULT, stdout);
+            Hgoto_error(1);
+        }
+
+        if (H5Pset_libver_bounds(UC_opts.fapl_id, H5F_LIBVER_LATEST, H5F_LIBVER_LATEST) < 0) {
+            HDfprintf(stderr, "can't set creation FAPL libver bounds\n");
+            Hgoto_error(1);
+        }
+
+        /* Create file */
+        if (create_uc_file(&UC_opts) < 0) {
+            HDfprintf(stderr, "***encounter error\n");
+            Hgoto_error(1);
+        } else {
+            HDprintf("File created.\n");
+        }
+
+        /* Close FAPLs to prevent issues with forking later */
+        if (H5Pclose(UC_opts.fapl_id) < 0) {
+            HDfprintf(stderr, "can't close creation FAPL\n");
+            Hgoto_error(1);
+        }
+        UC_opts.fapl_id = H5I_INVALID_HID;
+        if (H5Pclose(mirr_fapl_id) < 0) {
+            HDfprintf(stderr, "can't close creation mirror FAPL\n");
+            Hgoto_error(1);
+        }
+        mirr_fapl_id = H5I_INVALID_HID;
+    }
+
+    /* ============ */
+    /* Fork process */
+    /* ============ */
+    if (UC_opts.launch == UC_READWRITE) {
+        if ((childpid = HDfork()) < 0) {
+            HDperror("fork");
+            Hgoto_error(1);
+        }
+    }
+    mypid = HDgetpid();
+
+    /* ============= */
+    /* launch reader */
+    /* ============= */
+    if (UC_opts.launch != UC_WRITER) {
+        /* child process -- launch the reader */
+        /* reader only opens the one file -- separate reader needed for mirrored file 'shinano.h5' */
+        if (0 == childpid) {
+            HDprintf("%d: launch reader process\n", mypid);
+
+            UC_opts.fapl_id = H5P_DEFAULT;
+            if (read_uc_file(send_wait, &UC_opts) < 0) {
+                HDfprintf(stderr, "read_uc_file encountered error (%d)\n", mypid);
+                HDexit(1);
+            }
+
+            HDexit(0);
+        }
+    }
+
+    /* ============= */
+    /* launch writer */
+    /* ============= */
+    /* this process continues to launch the writer */
+    HDprintf("%d: continue as the writer process\n", mypid);
+
+    /* Prepare mirror child driver */
+    mirr_fapl_id = H5Pcreate(H5P_FILE_ACCESS);
+    if (mirr_fapl_id == H5I_INVALID_HID) {
+        HDfprintf(stderr, "can't create creation mirror FAPL\n");
+        Hgoto_error(1);
+    }
+    if (H5Pset_fapl_mirror(mirr_fapl_id, &mirr_fa) < 0) {
+        HDfprintf(stderr, "can't set creation mirror FAPL\n");
+        H5Eprint2(H5E_DEFAULT, stdout);
+        Hgoto_error(1);
+    }
+
+    /* Prepare parent "splitter" driver in UC_opts */
+    split_fa.wo_fapl_id       = mirr_fapl_id;
+    split_fa.rw_fapl_id       = H5P_DEFAULT;
+    UC_opts.fapl_id = H5Pcreate(H5P_FILE_ACCESS);
+    if (UC_opts.fapl_id == H5I_INVALID_HID) {
+        HDfprintf(stderr, "can't create creation FAPL\n");
+        Hgoto_error(1);
+    }
+    if (H5Pset_fapl_splitter(UC_opts.fapl_id, &split_fa) < 0) {
+        HDfprintf(stderr, "can't set creation FAPL\n");
+        H5Eprint2(H5E_DEFAULT, stdout);
+        Hgoto_error(1);
+    }
+
+    if (UC_opts.use_swmr) {
+        if (H5Pset_libver_bounds(UC_opts.fapl_id, H5F_LIBVER_LATEST, H5F_LIBVER_LATEST) < 0) {
+            HDfprintf(stderr, "can't set write FAPL libver bounds\n");
+            Hgoto_error(1);
+        }
+    }
+
+    if ((fid = H5Fopen(UC_opts.filename, H5F_ACC_RDWR | (UC_opts.use_swmr ? H5F_ACC_SWMR_WRITE : 0), UC_opts.fapl_id)) < 0) {
+        HDfprintf(stderr, "H5Fopen failed\n");
+        Hgoto_error(1);
+    }
+
+    if (write_uc_file(send_wait, fid, &UC_opts) < 0) {
+        HDfprintf(stderr, "write_uc_file encountered error\n");
+        Hgoto_error(1);
+    }
+
+    if (H5Fclose(fid) < 0) {
+        HDfprintf(stderr, "Failed to close write\n");
+        Hgoto_error(1);
+    }
+
+    if (H5Pclose(UC_opts.fapl_id) < 0) {
+        HDfprintf(stderr, "can't close write FAPL\n");
+        Hgoto_error(1);
+    }
+
+    if (H5Pclose(mirr_fapl_id) < 0) {
+        HDfprintf(stderr, "can't close write mirror FAPL\n");
+        Hgoto_error(1);
+    }
+
+    /* ================================================ */
+    /* If readwrite, collect exit code of child process */
+    /* ================================================ */
+    if (UC_opts.launch == UC_READWRITE) {
+        if ((tmppid = HDwaitpid(childpid, &child_status, child_wait_option)) < 0) {
+            HDperror("waitpid");
+            Hgoto_error(1);
+        }
+
+        if (WIFEXITED(child_status)) {
+            if ((child_ret_value = WEXITSTATUS(child_status)) != 0) {
+                HDprintf("%d: child process exited with non-zero code (%d)\n",
+                        mypid, child_ret_value);
+                Hgoto_error(2);
+            }
+        } else {
+            HDprintf("%d: child process terminated abnormally\n", mypid);
+            Hgoto_error(2);
+        }
+    }
+
+done:
+    if (ret_value != 0) {
+        HDprintf("Error(s) encountered\n");
+    } else {
+        HDprintf("All passed\n");
+    }
+
+    return(ret_value);
+}
+
+#else /* H5_HAVE_MIRROR_VFD */
+
+int
+main(void)
+{
+    HDfprintf(stderr, "Mirror VFD is not built. Skipping.\n");
+    return EXIT_SUCCESS;
+} /* end main() */
+
+#endif /* H5_HAVE_MIRROR_VFD */
+
+#else /* H5_HAVE_FORK */
+
+int
+main(void)
+{
+    HDfprintf(stderr, "Non-POSIX platform. Skipping.\n");
+    return EXIT_SUCCESS;
+} /* end main() */
+
+#endif /* H5_HAVE_FORK */
+