1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42
|
source("incl/start.R")
message("*** requestNode() ...")
message("*** requestNode() - exceptions ...")
workers <- makeClusterPSOCK(2L)
print(workers)
res <- tryCatch({
requestNode(function() {}, workers = workers, timeout = -1.0)
}, error = identity)
stopifnot(inherits(res, "error"))
res <- tryCatch({
requestNode(function() {}, workers = workers, alpha = 0)
}, error = identity)
stopifnot(inherits(res, "error"))
parallel::stopCluster(workers)
message("*** requestNode() - exceptions ... DONE")
message("*** requestNode() - timeout ...")
plan(cluster, workers = "localhost")
f <- future({ Sys.sleep(5); 1 })
res <- tryCatch({
requestNode(function() { }, workers = f$workers, timeout = 0.5, delta = 0.1)
}, error = identity)
stopifnot(inherits(res, "error"))
v <- value(f)
print(v)
stopifnot(v == 1L)
message("*** requestNode() - timeout ... DONE")
message("*** requestNode() ... DONE")
source("incl/end.R")
|