Running ‘000.sessionDetails.R’ [1s/2s]
  Running ‘BatchJobsFuture,gc.R’ [5s/6s]
  Running ‘BatchJobsFuture.R’ [5s/6s]
  Running ‘BatchJobsFutureError.R’ [7s/17s]
  Running ‘DEPRECATED.resources.R’ [3s/4s]
  Running ‘batchjobs_custom.R’ [7s/8s]
  Running ‘batchjobs_interactive.R’ [5s/6s]
  Running ‘batchjobs_job.delay.R’ [15s/21s]
  Running ‘batchjobs_local.R’ [15s/18s]
  Running ‘batchjobs_multicore.R’ [28s/33s]
  Running ‘batchjobs_template.R’ [1s/1s]
  Running ‘demo.R’ [18s/23s]
  Running ‘dotdotdot.R’ [7s/8s]
  Running ‘future,labels.R’ [12s/14s]
  Running ‘globals,formulas.R’ [21s/26s]
  Running ‘globals,manual.R’ [15s/18s]
  Running ‘globals,subassignment.R’ [15s/17s]
  Running ‘globals,tricky.R’ [21s/23s]
  Running ‘nbrOfWorkers.R’ [1s/2s]
  Running ‘plan.R’ [6s/7s]
  Running ‘utils.R’ [1s/2s]
  Running ‘zzz,future_lapply.R’ [23s/30s]
Running the tests in ‘tests/zzz,future_lapply.R’ failed.
Complete output:
  > source("incl/start.R")
  Loading required package: future
  plan(): nbrOfWorkers() = 1
  > library("listenv")
  > future_lapply <- future.apply::future_lapply
  > 
  > strategies <- c("sequential", "multisession",
  +                 "batchjobs_interactive", "batchjobs_local")
  > 
  > message("*** future_lapply() ...")
  *** future_lapply() ...
  > 
  > message("- future_lapply(x, FUN=vector, ...) ...")
  - future_lapply(x, FUN=vector, ...) ...
  > 
  > x <- list(a="integer", b="numeric", c="character", c="list")
  > str(list(x=x))
  List of 1
   $ x:List of 4
    ..$ a: chr "integer"
    ..$ b: chr "numeric"
    ..$ c: chr "character"
    ..$ c: chr "list"
  > 
  > y0 <- lapply(x, FUN=vector, length=2L)
  > str(list(y0=y0))
  List of 1
   $ y0:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  > 
  > for (scheduling in list(FALSE, TRUE)) {
  +   for (strategy in strategies) {
  +     message(sprintf("- plan('%s') ...", strategy))
  +     plan(strategy)
  +     y <- future_lapply(x, FUN=vector, length=2L, future.scheduling = scheduling)
  +     str(list(y=y))
  +     stopifnot(identical(y, y0))
  +   }
  + }
  - plan('sequential') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957ac358b8> 
    ..$ ...          :<environment: 0x55957ac358b8> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = NULL, 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
   length: 3 (resolved future 1)
   length: 2 (resolved future 2)
   length: 1 (resolved future 3)
   length: 0 (resolved future 4)
  resolve() on list ... DONE
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('multisession') ...
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ...
  multisession:
  - args: function (expr, envir = parent.frame(), substitute = TRUE, lazy = FALSE, seed = NULL, globals = TRUE, persistent = FALSE, workers = availableCores(), gc = FALSE, earlySignal = FALSE, label = NULL, ...)
  - tweaked: FALSE
  - call: plan(strategy)
  Workers: [n = 2] 'localhost', 'localhost'
  Base port: 11694
  Creating node 1 of 2 ...
  - setting up node
  Starting worker #1 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11694 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #1 on 'localhost' to connect back
  Connection with worker #1 on 'localhost' established
  - assigning connection UUID
  - collecting session information
  Creating node 1 of 2 ... done
  Creating node 2 of 2 ...
  - setting up node
  Starting worker #2 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11694 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #2 on 'localhost' to connect back
  Connection with worker #2 on 'localhost' established
  - assigning connection UUID
  - collecting session information
  Creating node 2 of 2 ... done
  getGlobalsAndPackages() ...
  Not searching for globals
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local(NA)
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  MultisessionFuture started
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ... DONE
  plan(): nbrOfWorkers() = 2
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957961d658> 
    ..$ ...          :<environment: 0x55957961d658> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ... DONE
  Exporting '...future.elements_ii' (112 bytes) to cluster node #1 ...
  Exporting '...future.elements_ii' (112 bytes) to cluster node #1 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ... DONE
  MultisessionFuture started
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ... DONE
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ...
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ... DONE
  MultisessionFuture started
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Poll #1 (0): usedNodes() = 2, workers = 2
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ... DONE
  Exporting '...future.elements_ii' (120 bytes) to cluster node #1 ...
  Exporting '...future.elements_ii' (120 bytes) to cluster node #1 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ... DONE
  MultisessionFuture started
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Poll #1 (0): usedNodes() = 2, workers = 2
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ... DONE
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ...
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ... DONE
  MultisessionFuture started
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
   length: 3 (resolved future 1)
   length: 2 (resolved future 2)
   length: 1 (resolved future 3)
   length: 0 (resolved future 4)
  resolve() on list ... DONE
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('batchjobs_interactive') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x559579e0cb80> 
    ..$ ...          :<environment: 0x559579e0cb80> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1724562350-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1724562350-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1724562350-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 265193171 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1724562350-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_984514502-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_984514502-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_984514502-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 235395086 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_984514502-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1004055402-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1004055402-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1004055402-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 310002295 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1004055402-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_157928067-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_157928067-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_157928067-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 752994575 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_157928067-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
  Syncing registry ...
   length: 3 (resolved future 1)
  Syncing registry ...
   length: 2 (resolved future 2)
  Syncing registry ...
   length: 1 (resolved future 3)
  Syncing registry ...
   length: 0 (resolved future 4)
  resolve() on list ... DONE
  Polling...
  Poll #1 (0): status = finished, started, submitted, t_avg, t_max, t_min
  Results:
  List of 5
   $ value    :List of 1
    ..$ : int [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted', 't_avg', 't_max', 't_min'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1724562350-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : num [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_984514502-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : chr [1:2] "" ""
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1004055402-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ :List of 2
    .. ..$ : NULL
    .. ..$ : NULL
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_157928067-files'
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('batchjobs_local') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957b713380> 
    ..$ ...          :<environment: 0x55957b713380> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_366952933-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_366952933-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_366952933-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 309898433 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_366952933-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1075893564-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1075893564-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1075893564-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 550589651 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1075893564-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1250659561-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1250659561-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1250659561-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 180988030 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1250659561-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_861476769-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_861476769-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_861476769-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 323365420 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_861476769-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
  Syncing registry ...
   length: 3 (resolved future 1)
  Syncing registry ...
   length: 2 (resolved future 2)
  Syncing registry ...
   length: 1 (resolved future 3)
  Syncing registry ...
   length: 0 (resolved future 4)
  resolve() on list ... DONE
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : int [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_366952933-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : num [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1075893564-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : chr [1:2] "" ""
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1250659561-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ :List of 2
    .. ..$ : NULL
    .. ..$ : NULL
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_861476769-files'
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('sequential') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957d60e078> 
    ..$ ...          :<environment: 0x55957d60e078> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 1
  Number of futures (= number of chunks): 1
  Launching 1 futures (chunks) ...
  Chunk #1 of 1 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - Adjusted option 'future.globals.maxSize': 5.24288e+08 -> 4 * 5.24288e+08 = 2.09715e+09 (bytes)
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.63 KiB (2696 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = 2097152000, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #1 of 1 ... DONE
  Launching 1 futures (chunks) ... DONE
  Resolving 1 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 1
  
   length: 0 (resolved future 1)
  resolve() on list ... DONE
   - Number of value chunks collected: 1
  Resolving 1 futures (chunks) ... DONE
  Reducing values from 1 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 1 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('multisession') ...
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ...
  multisession:
  - args: function (expr, envir = parent.frame(), substitute = TRUE, lazy = FALSE, seed = NULL, globals = TRUE, persistent = FALSE, workers = availableCores(), gc = FALSE, earlySignal = FALSE, label = NULL, ...)
  - tweaked: FALSE
  - call: plan(strategy)
  Workers: [n = 2] 'localhost', 'localhost'
  Base port: 11175
  Creating node 1 of 2 ...
  - setting up node
  Starting worker #1 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11175 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #1 on 'localhost' to connect back
  Connection with worker #1 on 'localhost' established
  - assigning connection UUID
  - collecting session information
  Creating node 1 of 2 ... done
  Creating node 2 of 2 ...
  - setting up node
  Starting worker #2 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11175 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #2 on 'localhost' to connect back
  Connection with worker #2 on 'localhost' established
  - assigning connection UUID
  - collecting session information
  Creating node 2 of 2 ... done
  getGlobalsAndPackages() ...
  Not searching for globals
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local(NA)
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  MultisessionFuture started
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ... DONE
  plan(): nbrOfWorkers() = 2
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957bea3970> 
    ..$ ...          :<environment: 0x55957bea3970> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 2
  Number of futures (= number of chunks): 2
  Launching 2 futures (chunks) ...
  Chunk #1 of 2 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - Adjusted option 'future.globals.maxSize': 5.24288e+08 -> 2 * 5.24288e+08 = 1.04858e+09 (bytes)
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.41 KiB (2464 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = 1048576000, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Exporting 5 global objects (2.41 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ... DONE
  Exporting '...future.elements_ii' (224 bytes) to cluster node #1 ...
  Exporting '...future.elements_ii' (224 bytes) to cluster node #1 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ... DONE
  Exporting 5 global objects (2.41 KiB) to cluster node #1 ... DONE
  MultisessionFuture started
  Chunk #1 of 2 ... DONE
  Chunk #2 of 2 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - Adjusted option 'future.globals.maxSize': 5.24288e+08 -> 2 * 5.24288e+08 = 1.04858e+09 (bytes)
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.41 KiB (2472 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = 1048576000, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Exporting 5 global objects (2.41 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ... DONE
  Exporting '...future.elements_ii' (232 bytes) to cluster node #2 ...
  Exporting '...future.elements_ii' (232 bytes) to cluster node #2 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ... DONE
  Exporting 5 global objects (2.41 KiB) to cluster node #2 ... DONE
  MultisessionFuture started
  Chunk #2 of 2 ... DONE
  Launching 2 futures (chunks) ... DONE
  Resolving 2 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 2
  
   length: 1 (resolved future 1)
   length: 0 (resolved future 2)
  resolve() on list ... DONE
   - Number of value chunks collected: 2
  Resolving 2 futures (chunks) ... DONE
  Reducing values from 2 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 2 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('batchjobs_interactive') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957820d488> 
    ..$ ...          :<environment: 0x55957820d488> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 1
  Number of futures (= number of chunks): 1
  Launching 1 futures (chunks) ...
  Chunk #1 of 1 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - Adjusted option 'future.globals.maxSize': 5.24288e+08 -> 4 * 5.24288e+08 = 2.09715e+09 (bytes)
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.63 KiB (2696 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_646170014-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_646170014-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_646170014-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 1068346637 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = 2097152000, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_646170014-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #1 of 1 ... DONE
  Launching 1 futures (chunks) ... DONE
  Resolving 1 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 1
  
  Syncing registry ...
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 4
    ..$ : int [1:2] 0 0
    ..$ : num [1:2] 0 0
    ..$ : chr [1:2] "" ""
    ..$ :List of 2
    .. ..$ : NULL
    .. ..$ : NULL
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_646170014-files'
   - Number of value chunks collected: 1
  Resolving 1 futures (chunks) ... DONE
  Reducing values from 1 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 1 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('batchjobs_local') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x559577e68a40> 
    ..$ ...          :<environment: 0x559577e68a40> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 1
  Number of futures (= number of chunks): 1
  Launching 1 futures (chunks) ...
  Chunk #1 of 1 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - Adjusted option 'future.globals.maxSize': 5.24288e+08 -> 4 * 5.24288e+08 = 2.09715e+09 (bytes)
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.63 KiB (2696 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_800719424-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_800719424-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_800719424-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 992937621 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = 2097152000, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_800719424-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #1 of 1 ... DONE
  Launching 1 futures (chunks) ... DONE
  Resolving 1 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 1
  
  Syncing registry ...
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 4
    ..$ : int [1:2] 0 0
    ..$ : num [1:2] 0 0
    ..$ : chr [1:2] "" ""
    ..$ :List of 2
    .. ..$ : NULL
    .. ..$ : NULL
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_800719424-files'
   - Number of value chunks collected: 1
  Resolving 1 futures (chunks) ... DONE
  Reducing values from 1 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 1 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  > 
  > 
  > message("- future_lapply(x, FUN=base::vector, ...) ...")
  - future_lapply(x, FUN=base::vector, ...) ...
  > 
  > x <- list(a="integer", b="numeric", c="character", c="list")
  > str(list(x=x))
  List of 1
   $ x:List of 4
    ..$ a: chr "integer"
    ..$ b: chr "numeric"
    ..$ c: chr "character"
    ..$ c: chr "list"
  > 
  > y0 <- lapply(x, FUN=base::vector, length=2L)
  > str(list(y0=y0))
  List of 1
   $ y0:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  > 
  > for (scheduling in list(FALSE, TRUE)) {
  +   for (strategy in strategies) {
  +     message(sprintf("- plan('%s') ...", strategy))
  +     plan(strategy)
  +     y <- future_lapply(x, FUN=base::vector, length=2L, future.scheduling = scheduling)
  +     str(list(y=y))
  +     stopifnot(identical(y, y0))
  +   }
  + }
  - plan('sequential') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957b170fa8> 
    ..$ ...          :<environment: 0x55957b170fa8> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
   length: 3 (resolved future 1)
   length: 2 (resolved future 2)
   length: 1 (resolved future 3)
   length: 0 (resolved future 4)
  resolve() on list ... DONE
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('multisession') ...
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ...
  multisession:
  - args: function (expr, envir = parent.frame(), substitute = TRUE, lazy = FALSE, seed = NULL, globals = TRUE, persistent = FALSE, workers = availableCores(), gc = FALSE, earlySignal = FALSE, label = NULL, ...)
  - tweaked: FALSE
  - call: plan(strategy)
  Workers: [n = 2] 'localhost', 'localhost'
  Base port: 11062
  Creating node 1 of 2 ...
  - setting up node
  Starting worker #1 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11062 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #1 on 'localhost' to connect back
  Connection with worker #1 on 'localhost' established
  - assigning connection UUID
  - collecting session information
  Creating node 1 of 2 ... done
  Creating node 2 of 2 ...
  - setting up node
  Starting worker #2 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11062 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #2 on 'localhost' to connect back
  Connection with worker #2 on 'localhost' established
  - assigning connection UUID
  - collecting session information
  Creating node 2 of 2 ... done
  getGlobalsAndPackages() ...
  Not searching for globals
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local(NA)
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  MultisessionFuture started
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ... DONE
  plan(): nbrOfWorkers() = 2
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957cff47f8> 
    ..$ ...          :<environment: 0x55957cff47f8> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ... DONE
  Exporting '...future.elements_ii' (112 bytes) to cluster node #1 ...
  Exporting '...future.elements_ii' (112 bytes) to cluster node #1 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ... DONE
  MultisessionFuture started
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ... DONE
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ...
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ... DONE
  MultisessionFuture started
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Poll #1 (0): usedNodes() = 2, workers = 2
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #1 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #1 ... DONE
  Exporting '...future.elements_ii' (120 bytes) to cluster node #1 ...
  Exporting '...future.elements_ii' (120 bytes) to cluster node #1 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #1 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #1 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #1 ... DONE
  MultisessionFuture started
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  {
                    has_future <- requireNamespace("future", quietly = TRUE)
                    version <- if (has_future) 
                      packageVersion("future")
                    else NULL
                    if (!has_future || version < "1.8.0") {
                      info <- c(r_version = gsub("R version ", 
                        "", R.version$version.string), platform = sprintf("%s (%s-bit)", 
                        R.version$platform, 8 * .Machine$sizeof.pointer), 
                        os = paste(Sys.info()[c("sysname", "release", 
                          "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                      info <- sprintf("%s: %s", names(info), info)
                      info <- paste(info, collapse = "; ")
                      if (!has_future) {
                        msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                          info)
                      }
                      else {
                        msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                          info, version)
                      }
                      stop(msg)
                    }
                  }
                  ...future.mc.cores.old <- getOption("mc.cores")
                  options(mc.cores = 1L)
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  {
                    options(mc.cores = ...future.mc.cores.old)
                  }
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, persistent = FALSE, workers = availableCores(), 
                    gc = FALSE, earlySignal = FALSE, label = NULL, 
                    ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    if (is.function(workers)) 
                      workers <- workers()
                    workers <- as.integer(workers)
                    stop_if_not(length(workers) == 1, is.finite(workers), 
                      workers >= 1)
                    if (workers == 1L) {
                      return(sequential(expr, envir = envir, substitute = FALSE, 
                        lazy = TRUE, seed = seed, globals = globals, 
                        local = TRUE, label = label))
                    }
                    workers <- ClusterRegistry("start", workers = workers)
                    future <- MultisessionFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, persistent = persistent, 
                      workers = workers, gc = gc, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Poll #1 (0): usedNodes() = 2, workers = 2
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ...
  Exporting '...future.FUN' (2.13 KiB) to cluster node #2 ... DONE
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ...
  Exporting 'future.call.arguments' (56 bytes) to cluster node #2 ... DONE
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ...
  Exporting '...future.elements_ii' (112 bytes) to cluster node #2 ... DONE
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ...
  Exporting '...future.seeds_ii' (0 bytes) to cluster node #2 ... DONE
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ...
  Exporting '...future.globals.maxSize' (0 bytes) to cluster node #2 ... DONE
  Exporting 5 global objects (2.30 KiB) to cluster node #2 ... DONE
  MultisessionFuture started
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
   length: 3 (resolved future 1)
   length: 2 (resolved future 2)
   length: 1 (resolved future 3)
   length: 0 (resolved future 4)
  resolve() on list ... DONE
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('batchjobs_interactive') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957afdd710> 
    ..$ ...          :<environment: 0x55957afdd710> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_539818840-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_539818840-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_539818840-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 217208825 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_539818840-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_729162722-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_729162722-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_729162722-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 906927341 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_729162722-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1931380588-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1931380588-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1931380588-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 234973856 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1931380588-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1117978119-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1117978119-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1117978119-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 611254327 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsInteractive()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Interactive"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1117978119-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Interactive.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
  Syncing registry ...
   length: 3 (resolved future 1)
  Syncing registry ...
   length: 2 (resolved future 2)
  Syncing registry ...
   length: 1 (resolved future 3)
  Syncing registry ...
   length: 0 (resolved future 4)
  resolve() on list ... DONE
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : int [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_539818840-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : num [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_729162722-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : chr [1:2] "" ""
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1931380588-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ :List of 2
    .. ..$ : NULL
    .. ..$ : NULL
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1117978119-files'
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('batchjobs_local') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957b957a78> 
    ..$ ...          :<environment: 0x55957b957a78> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 4
  Number of futures (= number of chunks): 4
  Launching 4 futures (chunks) ...
  Chunk #1 of 4 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_2022749604-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_2022749604-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_2022749604-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 628447923 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_2022749604-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #1 of 4 ... DONE
  Chunk #2 of 4 ...
   - Finding globals in 'X' for chunk #2 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #2 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1260708894-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1260708894-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1260708894-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 943782695 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1260708894-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #2 of 4 ... DONE
  Chunk #3 of 4 ...
   - Finding globals in 'X' for chunk #3 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #3 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2360 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1029362867-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1029362867-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1029362867-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 209618761 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1029362867-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #3 of 4 ... DONE
  Chunk #4 of 4 ...
   - Finding globals in 'X' for chunk #4 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #4 ... DONE
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.30 KiB (2352 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Creating dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1841456320-files
  Saving registry: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1841456320-files/registry.RData
  Job registry:  BatchJobs 
    Number of jobs:  0 
    Files dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1841456320-files 
    Work dir: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests 
    Multiple result files: FALSE 
    Seed: 16554860 
    Required packages: BatchJobs 
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = NULL, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              do.call(function(...) {
                  ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
                  if (!identical(...future.globals.maxSize.org, 
                    ...future.globals.maxSize)) {
                    oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                    on.exit(options(oopts), add = TRUE)
                  }
                  lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                    ...future.X_jj <- ...future.elements_ii[[jj]]
                    ...future.FUN(...future.X_jj, ...)
                  })
              }, args = future.call.arguments)
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, globals = TRUE, label = "BatchJobs", 
                    workers = 1L, job.delay = FALSE, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    cf <- makeClusterFunctionsLocal()
                    future <- BatchJobsFuture(expr = expr, envir = envir, 
                      substitute = FALSE, globals = globals, label = label, 
                      cluster.functions = cf, workers = workers, 
                      job.delay = job.delay, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    future
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  Adding 1 jobs to DB.
  Created BatchJobsFuture future #1
  Setting BatchJobs configuration:
  List of 1
   $ cluster.functions:List of 5
    ..$ name             : chr "Local"
    ..$ submitJob        :function (conf, reg, job.name, rscript, log.file, job.dir, resources, arrayjobs)  
    ..$ killJob          :function (conf, reg, batch.job.id)  
    ..$ listJobs         :function (conf, reg)  
    ..$ getArrayEnvirName:function ()  
    ..- attr(*, "class")= chr "ClusterFunctions"
  Saving conf: /home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1841456320-files/conf.RData
  Submitting 1 chunks / 1 jobs.
  Cluster functions: Local.
  Auto-mailer settings: start=none, done=none, error=none.
  
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+                                                |   0% (00:00:00)
  SubmitJobs |+++++++++++++++++++++++++++++++++++++++++++++++++| 100% (00:00:00)
  Sending 1 submit messages...
  Might take some time, do not interrupt this!
  Launched future #1
  Chunk #4 of 4 ... DONE
  Launching 4 futures (chunks) ... DONE
  Resolving 4 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 4
  
  Syncing registry ...
   length: 3 (resolved future 1)
  Syncing registry ...
   length: 2 (resolved future 2)
  Syncing registry ...
   length: 1 (resolved future 3)
  Syncing registry ...
   length: 0 (resolved future 4)
  resolve() on list ... DONE
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : int [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_2022749604-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : num [1:2] 0 0
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1260708894-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted
  Results:
  List of 5
   $ value    :List of 1
    ..$ : chr [1:2] "" ""
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1029362867-files'
  Polling...
  Poll #1 (0): status = finished, started, submitted, t_avg, t_max, t_min
  Results:
  List of 5
   $ value    :List of 1
    ..$ :List of 2
    .. ..$ : NULL
    .. ..$ : NULL
   $ condition: NULL
   $ calls    : NULL
   $ version  : chr "1.8"
   $ stdout   : chr ""
   - attr(*, "class")= chr "FutureResult"
  delete(): Option 'future.delete='<NULL>'
  delete(): status = 'finished', 'started', 'submitted', 't_avg', 't_max', 't_min'
  delete(): BatchJobs registry deleted: '/home/hornik/tmp/R.check/r-patched-gcc/Work/PKGS/future.BatchJobs.Rcheck/tests/.future/20190103_085452-JtLGqs/BatchJobs_1841456320-files'
   - Number of value chunks collected: 4
  Resolving 4 futures (chunks) ... DONE
  Reducing values from 4 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 4 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('sequential') ...
  plan(): nbrOfWorkers() = 1
  future_lapply() ...
  Finding globals ...
  getGlobalsAndPackages() ...
  Searching for globals...
  - globals found: [2] 'FUN', '.Internal'
  Searching for globals ... DONE
  Resolving globals: FALSE
  The total size of the 1 globals is 2.13 KiB (2184 bytes)
  - globals: [1] 'FUN'
  
  getGlobalsAndPackages() ... DONE
   - globals found: [1] 'FUN'
  
  Finding globals ... DONE
  Getting '...' globals ...
  resolve() on list ...
   recursive: 0
   length: 1
   elements: '...'
   length: 0 (resolved future 1)
  resolve() on list ... DONE
  Getting '...' globals ... DONE
  Globals to be used in all futures:
  List of 2
   $ ...future.FUN:function (mode = "logical", length = 0L)  
   $ ...          :List of 1
    ..$ length: int 2
    ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
   - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
   - attr(*, "where")=List of 2
    ..$ ...future.FUN:<environment: 0x55957d1cd720> 
    ..$ ...          :<environment: 0x55957d1cd720> 
   - attr(*, "resolved")= logi FALSE
   - attr(*, "total_size")= num 2240
  Packages to be attached in all futures:
   chr(0) 
  Number of chunks: 1
  Number of futures (= number of chunks): 1
  Launching 1 futures (chunks) ...
  Chunk #1 of 1 ...
   - Finding globals in 'X' for chunk #1 ...
  getGlobalsAndPackages() ...
  Searching for globals...
  
  Searching for globals ... DONE
  - globals: [0] <none>
  getGlobalsAndPackages() ... DONE
  
  
   - Finding globals in 'X' for chunk #1 ... DONE
   - Adjusted option 'future.globals.maxSize': 5.24288e+08 -> 4 * 5.24288e+08 = 2.09715e+09 (bytes)
   - seeds: <none>
  getGlobalsAndPackages() ...
  - globals passed as-is: [5] '...future.FUN', '...', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  Resolving globals: FALSE
  Tweak future expression to call with '...' arguments ...
  Tweak future expression to call with '...' arguments ... DONE
  The total size of the 5 globals is 2.63 KiB (2696 bytes)
  - globals: [5] '...future.FUN', 'future.call.arguments', '...future.elements_ii', '...future.seeds_ii', '...future.globals.maxSize'
  
  getGlobalsAndPackages() ... DONE
  Packages needed by future strategies (n = 0): <none>
  Packages needed by the future expression (n = 0): <none>
  {
      {
          ...future.oldOptions <- options(future.startup.loadScript = FALSE, 
              future.globals.onMissing = "ignore", future.globals.maxSize = 2097152000, 
              future.globals.method = NULL, future.globals.onMissing = "ignore", 
              future.globals.onReference = NULL, future.globals.resolve = NULL, 
              future.resolve.recursive = NULL, width = 80L)
          {
              {
                  has_future <- requireNamespace("future", quietly = TRUE)
                  version <- if (has_future) 
                    packageVersion("future")
                  else NULL
                  if (!has_future || version < "1.8.0") {
                    info <- c(r_version = gsub("R version ", "", 
                      R.version$version.string), platform = sprintf("%s (%s-bit)", 
                      R.version$platform, 8 * .Machine$sizeof.pointer), 
                      os = paste(Sys.info()[c("sysname", "release", 
                        "version")], collapse = " "), hostname = Sys.info()[["nodename"]])
                    info <- sprintf("%s: %s", names(info), info)
                    info <- paste(info, collapse = "; ")
                    if (!has_future) {
                      msg <- sprintf("Package 'future' is not installed on worker (%s)", 
                        info)
                    }
                    else {
                      msg <- sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s", 
                        info, version)
                    }
                    stop(msg)
                  }
              }
              future::plan("default", .cleanup = FALSE, .init = FALSE)
          }
      }
      if (is.na(TRUE)) {
      }
      else {
          if (TRUE) {
              ...future.stdout <- rawConnection(raw(0L), open = "w")
          }
          else {
              ...future.stdout <- file(switch(.Platform$OS.type, 
                  windows = "NUL", "/dev/null"), open = "w")
          }
          sink(...future.stdout, type = "output", split = FALSE)
          on.exit(if (!is.null(...future.stdout)) {
              sink(type = "output", split = FALSE)
              close(...future.stdout)
          }, add = TRUE)
      }
      ...future.result <- tryCatch({
          ...future.value <- local({
              ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
              if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
                  oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
                  on.exit(options(oopts), add = TRUE)
              }
              lapply(seq_along(...future.elements_ii), FUN = function(jj) {
                  ...future.X_jj <- ...future.elements_ii[[jj]]
                  ...future.FUN(...future.X_jj, ...)
              })
          })
          future::FutureResult(value = ...future.value, version = "1.8")
      }, error = function(cond) {
          calls <- sys.calls()
          structure(list(value = NULL, condition = cond, calls = calls, 
              version = "1.8"), class = "FutureResult")
      }, finally = {
          {
              {
                  NULL
                  future::plan(list(function (expr, envir = parent.frame(), 
                    substitute = TRUE, lazy = FALSE, seed = NULL, 
                    globals = TRUE, local = TRUE, earlySignal = FALSE, 
                    label = NULL, ...) 
                  {
                    if (substitute) 
                      expr <- substitute(expr)
                    local <- as.logical(local)
                    future <- SequentialFuture(expr = expr, envir = envir, 
                      substitute = FALSE, lazy = lazy, seed = seed, 
                      globals = globals, local = local, earlySignal = earlySignal, 
                      label = label, ...)
                    if (!future$lazy) 
                      future <- run(future)
                    invisible(future)
                  }), .cleanup = FALSE, .init = FALSE)
              }
              options(...future.oldOptions)
          }
      })
      if (is.na(TRUE)) {
      }
      else {
          sink(type = "output", split = FALSE)
          if (TRUE) {
              ...future.result$stdout <- rawToChar(rawConnectionValue(...future.stdout))
          }
          else {
              ...future.result["stdout"] <- list(NULL)
          }
          close(...future.stdout)
          ...future.stdout <- NULL
      }
      ...future.result
  }
  plan(): nbrOfWorkers() = 1
  SequentialFuture started (and completed)
  Chunk #1 of 1 ... DONE
  Launching 1 futures (chunks) ... DONE
  Resolving 1 futures (chunks) ...
  resolve() on list ...
   recursive: 0
   length: 1
  
   length: 0 (resolved future 1)
  resolve() on list ... DONE
   - Number of value chunks collected: 1
  Resolving 1 futures (chunks) ... DONE
  Reducing values from 1 chunks ...
   - Number of values collected after concatenation: 4
   - Number of values expected: 4
  Reducing values from 1 chunks ... DONE
  future_lapply() ... DONE
  List of 1
   $ y:List of 4
    ..$ a: int [1:2] 0 0
    ..$ b: num [1:2] 0 0
    ..$ c: chr [1:2] "" ""
    ..$ c:List of 2
    .. ..$ : NULL
    .. ..$ : NULL
  - plan('multisession') ...
  plan(): plan_init() of 'multisession', 'cluster', 'multiprocess', 'future', 'function' ...
  multisession:
  - args: function (expr, envir = parent.frame(), substitute = TRUE, lazy = FALSE, seed = NULL, globals = TRUE, persistent = FALSE, workers = availableCores(), gc = FALSE, earlySignal = FALSE, label = NULL, ...)
  - tweaked: FALSE
  - call: plan(strategy)
  Workers: [n = 2] 'localhost', 'localhost'
  Base port: 11321
  Creating node 1 of 2 ...
  - setting up node
  Starting worker #1 on 'localhost': '/home/hornik/tmp/R.check/r-patched-gcc/Work/build/bin/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=localhost PORT=11321 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE
  Waiting for worker #1 on 'localhost' to connect back
  Warning in socketConnection("localhost", port = port, server = TRUE, blocking = TRUE,  :
    port 11321 cannot be opened
  Error in socketConnection("localhost", port = port, server = TRUE, blocking = TRUE,  : 
    cannot open the connection
  Calls: plan ... makeClusterPSOCK -> makeNode -> <Anonymous> -> socketConnection
  Execution halted