TESTS: Add value() tests for cancel()

Author: HenrikBengtsson

DESCRIPTION

@@ -1,6 +1,6 @@
 Package: future.tests
 Title: Test Suite for 'Future API' Backends
-Version: 0.9.0-9004
+Version: 0.9.0-9005
 Authors@R: c(
   person("Henrik", "Bengtsson", role = c("aut", "cre", "cph"), email = "[email protected]"),
   person(family = "The R Consortium", comment = "Project was awarded an Infrastructure Steering Committee (ISC) grant in 2017", role = "fnd"))

inst/test-db/cancel.R

@@ -1,10 +1,51 @@
 make_test(title = "cancel()", args = list(lazy = c(FALSE, TRUE), interrupt = c(FALSE, TRUE)), tags = c("cancel"), {
   f0 <- future(NULL)
   v <- value(f0)
+  print(class(f0))
+
+  delay <- if (interrupt) 0.0 else 0.5
+  f <- future({
+    Sys.sleep(delay)
+    42L
+  }, lazy = lazy)
+
+  cat(sprintf("state = %s\n", sQuote(f[["state"]])))
+  if (lazy) {
+    stopifnot(f[["state"]] %in% "created")
+  } else {
+    stopifnot(f[["state"]] %in% c("submitted", "running", "finished"))
+  }
+  
+  cat(sprintf("interrupt = %s\n", sQuote(interrupt)))
+  f <- cancel(f, interrupt = interrupt)
+  cat(sprintf("state = %s\n", sQuote(f[["state"]])))
+  if (lazy) {
+    stopifnot(f[["state"]] %in% "created")
+  } else {
+    stopifnot(f[["state"]] %in% c("canceled", "finished"))
+  }
+
+  ## A canceled future may be resolved or not, which
+  ## depends on future been interrupted or not
+  r <- resolved(f)
+  cat(sprintf("resolved = %s\n", sQuote(r)))
+
+  v <- tryCatch({
+    value(f)
+  }, FutureInterruptError = identity)
+  print(v)
+})
+
+
+make_test(title = "cancel() and value()", args = list(lazy = c(FALSE, TRUE), interrupt = c(FALSE, TRUE)), tags = c("cancel", "value", "devel"), {
+  f0 <- future(NULL)
+  v <- value(f0)
+  print(class(f0))
 
+  delay <- if (interrupt) 0.0 else 0.5
   f <- future({
-    Sys.sleep(0.5)
-    list(a = 1, b = 42L)
+    Sys.sleep(delay)
+    42L
   }, lazy = lazy)
 
   cat(sprintf("state = %s\n", sQuote(f[["state"]])))
@@ -27,4 +68,31 @@ make_test(title = "cancel()", args = list(lazy = c(FALSE, TRUE), interrupt = c(F
   ## depends on future been interrupted or not
   r <- resolved(f)
   cat(sprintf("resolved = %s\n", sQuote(r)))
+
+  v <- tryCatch({
+    value(f)
+  }, FutureInterruptError = identity)
+  print(v)
+
+  ## Did we require an interrupt and does the backend support it?
+  interrupt2 <- interrupt && plan("backend")[["interrupts"]]
+  if (interrupt2) {
+    if (lazy || inherits(f0, c("UniprocessFuture", "BatchtoolsUniprocessFuture"))) {
+      stopifnot(
+        !inherits(v, "FutureInterruptError"),
+        v == 42L
+      )
+    } else {
+      stopifnot(inherits(v, "FutureInterruptError"))
+    }
+  } else {
+    if (lazy) {
+      stopifnot(!inherits(v, "FutureInterruptError"))
+    } else {
+      stopifnot(
+        !inherits(v, "FutureInterruptError"),
+        v == 42L
+      )
+    }
+  }
 })