Running ‘000.sessionDetails.R’ [6s/9s]
  Running ‘ClusterRegistry.R’ [2s/63s]
  Running ‘Future-class.R’ [1s/23s]
  Running ‘FutureError.R’ [1s/1s]
  Running ‘FutureGlobals.R’ [0s/1s]
  Running ‘FutureRegistry.R’ [1s/2s]
  Running ‘as.cluster.R’ [1s/21s]
  Running ‘availableCores.R’ [0s/1s]
  Running ‘availableWorkers.R’ [1s/1s]
  Running ‘backtrace.R’ [1s/2s]
  Running ‘cluster-missing-future-pkg.R’ [1s/3s]
  Running ‘cluster.R’ [6s/133s]
  Running ‘constant.R’ [0s/1s]
  Running ‘demo.R’ [8s/33s]
  Running ‘dotdotdot.R’ [1s/19s]
  Running ‘early-signaling.R’ [2s/45s]
  Running ‘future,labels.R’ [1s/1s]
  Running ‘future.R’ [1s/1s]
  Running ‘futureAssign.R’ [2s/24s]
  Running ‘futureAssign_OP.R’ [2s/22s]
  Running ‘futureAssign_OP_with_environment.R’ [1s/1s]
  Running ‘futureAssign_OP_with_listenv.R’ [1s/1s]
  Running ‘futureCall.R’ [3s/33s]
  Running ‘futureOf.R’ [1s/1s]
  Running ‘futureOf_with_environment.R’ [1s/1s]
  Running ‘futureOf_with_listenv.R’ [1s/1s]
  Running ‘futures.R’ [15s/165s]
  Running ‘globals,NSE.R’ [1s/1s]
  Running ‘globals,formulas.R’ [3s/27s]
  Running ‘globals,manual.R’ [2s/3s]
  Running ‘globals,resolve.R’ [1s/20s]
  Running ‘globals,subassignment.R’ [2s/24s]
  Running ‘globals,toolarge.R’ [1s/21s]
  Running ‘globals,tricky.R’ [6s/29s]
  Running ‘globals,tricky_recursive.R’ [1s/1s]
  Running ‘globalsOf,tweaks.R’ [1s/1s]
  Running ‘immediateCondition.R’ [1s/2s]
  Running ‘invalid-owner.R’ [1s/20s]
  Running ‘makeClusterPSOCK.R’ [1s/11s]
  Running ‘mandelbrot.R’ [1s/1s]
  Running ‘mpi.R’ [0s/1s]
  Running ‘multicore.R’ [1s/2s]
  Running ‘multiprocess.R’ [1s/3s]
  Running ‘multisession.R’ [3s/60s]
  Running ‘nbrOfWorkers.R’ [4s/77s]
  Running ‘nested_futures,mc.cores.R’ [5s/139s]
  Running ‘nested_futures.R’ [1s/1s]
  Running ‘non-exportable,connections.R’ [1s/19s]
  Running ‘objectSize.R’ [1s/1s]
  Running ‘plan.R’ [5s/18s]
  Running ‘relaying.R’ [1s/3s]
  Running ‘remote.R’ [1s/19s]
  Running ‘requestCore.R’ [1s/3s]
  Running ‘requestNode.R’ [1s/33s]
  Running ‘resolve.R’ [2s/4s]
  Running ‘resolved-non-blocking-test.R’ [1s/10s]
  Running ‘rng.R’ [5s/27s]
  Running ‘sequential.R’ [1s/1s]
  Running ‘sessionDetails.R’ [1s/1s]
  Running ‘startup.R’ [2s/40s]
  Running ‘stdout.R’ [2s/24s]
  Running ‘transparent.R’ [1s/1s]
  Running ‘tweak.R’ [1s/2s]
  Running ‘utils.R’ [6s/10s]
  Running ‘uuid.R’ [1s/2s]
  Running ‘whichIndex.R’ [1s/1s]
Running the tests in ‘tests/resolved-non-blocking-test.R’ failed.
Complete output:
  > source("incl/start.R")
  [21:08:19.023] plan(): Setting new future strategy stack:
  [21:08:19.024] List of future strategies:
  [21:08:19.024] 1. sequential:
  [21:08:19.024]    - args: function (expr, envir = parent.frame(), substitute = TRUE, lazy = FALSE, seed = NULL, globals = TRUE, local = TRUE, earlySignal = FALSE, label = NULL, ...)
  [21:08:19.024]    - tweaked: FALSE
  [21:08:19.024]    - call: future::plan("sequential")
  [21:08:19.026] plan(): nbrOfWorkers() = 1
  > options(future.debug = FALSE)
  > 
  > message("*** resolved() - assert non-blocking while launching lazy futures ...")
  *** resolved() - assert non-blocking while launching lazy futures ...
  > 
  > for (cores in 1:availCores) {
  +   message(sprintf("Testing with %d cores ...", cores))
  +   options(mc.cores = cores)
  + 
  +   strategies <- supportedStrategies(cores, excl = c("multiprocess"))
  +   print(strategies)
  +   
  +   for (strategy in strategies) {
  +     message(sprintf("- plan('%s') with cores=%d ...", strategy, cores))
  +     plan(strategy)
  + 
  +     ## This test requires that all workers are free when tests start
  +     resetWorkers(plan())
  +   
  +     message("Creating lazy futures:")
  +     xs <- as.list(1:3)
  +     fs <- lapply(xs, FUN = function(kk) {
  +       future({
  +         Sys.sleep(kk)
  +         kk
  +       }, lazy = TRUE)
  +     })
  +     vs <- vector("list", length = length(fs))
  +     ss <- vapply(fs, FUN = function(f) f$state, NA_character_)
  +     print(ss)
  +     stopifnot(all(ss == "created"))
  +     rs <- rep(NA, times = length(fs))
  +     
  +     for (ff in seq_along(fs)) {
  +       for (kk in ff:length(fs)) {
  +         message(sprintf("Checking if future #%d is resolved:", kk))
  +         rs[[kk]] <- resolved(fs[[kk]])
  +         ss <- vapply(fs, FUN = function(f) f$state, NA_character_)
  +         print(ss)
  +         if (inherits(fs[[kk]], "UniprocessFuture")) {
  +           stopifnot(rs[[kk]])
  +           stopifnot(ss[[kk]] == "finished")
  +         } else if (inherits(fs[[kk]], "MultiprocessFuture")) {
  +           if (nbrOfWorkers() + ff - 1L >= kk) {
  +             stopifnot(ss[[kk]] == "running")
  +           } else {
  +             stopifnot(ss[[kk]] == "created")
  +           }
  +           stopifnot(!rs[[kk]])
  +         }
  +       } ## for (kk ...)
  +     
  +       message(sprintf("Waiting for future #%d to finish ... ", ff), appendLF = FALSE)
  +       vs[[ff]] <- value(fs[[ff]])
  +       message("done")
  +     
  +       rs[[ff]] <- resolved(fs[[ff]])
  +       stopifnot(rs[ff])
  +     
  +       ss <- vapply(fs, FUN = function(f) f$state, NA_character_)
  +       stopifnot(ss[ff] == "finished")
  +       nbrOfFinished <- sum(ss == "finished")
  +       if (inherits(fs[[kk]], "UniprocessFuture")) {
  +         stopifnot(nbrOfFinished == length(fs))
  +       } else {
  +         stopifnot(nbrOfFinished == ff)
  +       }
  +     } ## for (ff ...)
  +     
  +     ss <- vapply(fs, FUN = function(f) f$state, NA_character_)
  +     print(ss)
  +     stopifnot(all(ss == "finished"))
  +     
  +     message("Collecting values:")
  +     vs <- values(fs)
  +     str(vs)
  +     stopifnot(identical(vs, xs))
  +   
  +     message(sprintf("- plan('%s') with cores=%d ... DONE", strategy, cores))
  +   } ## for (strategy ...)
  + 
  +   message(sprintf("Testing with %d cores ... DONE", cores))
  + } ## for (cores ...)
  Testing with 1 cores ...
  [1] "sequential" "cluster"   
  - plan('sequential') with cores=1 ...
  Creating lazy futures:
  [1] "created" "created" "created"
  Checking if future #1 is resolved:
  [1] "finished" "created"  "created" 
  Checking if future #2 is resolved:
  [1] "finished" "finished" "created" 
  Checking if future #3 is resolved:
  [1] "finished" "finished" "finished"
  Waiting for future #1 to finish ... done
  Checking if future #2 is resolved:
  [1] "finished" "finished" "finished"
  Checking if future #3 is resolved:
  [1] "finished" "finished" "finished"
  Waiting for future #2 to finish ... done
  Checking if future #3 is resolved:
  [1] "finished" "finished" "finished"
  Waiting for future #3 to finish ... done
  [1] "finished" "finished" "finished"
  Collecting values:
  List of 3
   $ : int 1
   $ : int 2
   $ : int 3
  - plan('sequential') with cores=1 ... DONE
  - plan('cluster') with cores=1 ...
  Warning in socketConnection("localhost", port = port, server = TRUE, blocking = TRUE,  :
    port 36962 cannot be opened
  Error in socketConnection("localhost", port = port, server = TRUE, blocking = TRUE,  : 
    Failed to launch and connect to R worker on local machine 'localhost' from local machine 'gimli2'.
   * The error produced by socketConnection() was: 'cannot open the connection'
   * In addition, socketConnection() produced 1 warning(s):
     - Warning #1: 'port 36962 cannot be opened' (which suggests that this port is either already occupied by another process or blocked by the firewall on your local machine)
   * The localhost socket connection that failed to connect to the R worker used port 36962 using a communication timeout of 120 seconds and a connection timeout of 120 seconds.
   * Worker launch call: '/home/hornik/tmp/R.check/r-devel-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e '#label=future/tests/resolved-non-blocking-test.R:gimli2:hornik:3016' -e 'try(suppressWarnings(cat(Sys.getpid(),file="/home/hornik/tmp/scratch/Rtmpz6KxGt/future.parent=3016.bc8240d852.pid")), silent = TRUE)' -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=36962 OUT=/dev/null TIMEOUT=120 XDR=TRUE.
   * Worker (PID 7610) was successfully killed: TRUE
   * Troubleshooting suggestions:
     - Suggestion #1: Set 'verbose=TRUE' to see more details.
     - Suggestion #2: Set 'outfile=NULL' to see output from worker.
  Calls: plan ... tryCatchList -> tryCatchOne -> <Anonymous> -> <Anonymous>
  Execution halted