[base] while loop with timeout

small test for directory without any *.pvd files

R/sim_utils.R

@@ -246,13 +246,23 @@ ogs6_read_output_files <- function(ogs6_obj){
     pvd_paths <- list.files(ogs6_obj$sim_path,
                             "\\.pvd$",
                             full.names = TRUE)
-
-    ogs6_obj$pvds <- lapply(pvd_paths, function(x){OGS6_pvd$new(pvd_path = x)})
+    # Wait for eventual file writing processes to finish
+    t0 <- Sys.time()
+    while(((length(pvd_paths) == 0) | any(file.size(pvd_paths) <= 64)) &
+          difftime(Sys.time(), t0, units = "secs") < 2) {
+        Sys.sleep(0.01)
+        warning("waiting for pvd file ...")
+    }
+    if (((length(pvd_paths) == 0) | any(file.size(pvd_paths) <= 64)))  {
+        stop("Output file not written out correctly.
+                    Unable to import *.pvd")
+    } else {
+        ogs6_obj$pvds <- lapply(pvd_paths, function(x){OGS6_pvd$new(pvd_path = x)})
+    }
 
     return(invisible())
 }
 
-
 #===== Test benchmarks =====
 
 

tests/testthat/test-sim_utils.R

@@ -81,6 +81,20 @@ test_that("ogs6_export_sim_files works", {
     unlink(test_path, recursive = TRUE)
 })
 
+test_that("Nonexistent *.pvd file yields an appropriate error", {
+    sim_path <- paste0(tmp_dir, "/run_simulation_test")
+    dir.create(sim_path)
+
+    # create empty ogs6 object
+    ogs6_obj <- OGS6$new(sim_name = "sim", sim_path = sim_path)
+    expect_error(ogs6_read_output_files(ogs6_obj))
+
+    unlink(sim_path, recursive = TRUE)
+})
+
+
+
+
 
 #===== Test benchmarks =====