Modify DAOS-M plugin to call daos_pool_connect at plugin initialization

time, using a communicator passed to the initialization function. Add public functions H5VLdaosm_init and H5VLdaosm_term. Apps no longer need to call daos_init and daos_fini. Updated examples. Other minor fixes/cleanup.

1 files changed, 9 insertions, 4 deletions

diff --git a/examples/h5dsm_ttconv.c b/examples/h5dsm_ttconv.c
index 1fb2af4..6aa927e 100644
--- a/examples/h5dsm_ttconv.c
+++ b/examples/h5dsm_ttconv.c
@@ -32,7 +32,6 @@ int main(int argc, char *argv[]) {
     int i;
 
     (void)MPI_Init(&argc, &argv);
-    (void)daos_init();
 
     /* Seed random number generator */
     srand(time(NULL));
@@ -44,10 +43,14 @@ int main(int argc, char *argv[]) {
     if(0 != uuid_parse(argv[1], pool_uuid))
         ERROR;
 
+    /* Initialize VOL */
+    if(H5VLdaosm_init(MPI_COMM_WORLD, pool_uuid, pool_grp) < 0)
+        ERROR;
+
     /* Set up FAPL */
     if((fapl = H5Pcreate(H5P_FILE_ACCESS)) < 0)
         ERROR;
-    if(H5Pset_fapl_daosm(fapl, MPI_COMM_WORLD, MPI_INFO_NULL, pool_uuid, pool_grp) < 0)
+    if(H5Pset_fapl_daosm(fapl, MPI_COMM_WORLD, MPI_INFO_NULL) < 0)
         ERROR;
 
     /* Create file */
@@ -885,9 +888,11 @@ int main(int argc, char *argv[]) {
     if(H5Pclose(fapl) < 0)
         ERROR;
 
+    if(H5VLdaosm_term() < 0)
+        ERROR;
+
     printf("Success\n");
 
-    (void)daos_fini();
     (void)MPI_Finalize();
     return 0;
 
@@ -913,9 +918,9 @@ error:
         H5Tclose(mem_type_c);
         H5Sclose(space);
         H5Pclose(fapl);
+        H5VLdaosm_term();
     } H5E_END_TRY;
 
-    (void)daos_fini();
     (void)MPI_Finalize();
     return 1;
 }