/usr/lib/R/site-library/BiocParallel/unitTests/test_bplapply.R is in r-bioc-biocparallel 0.6.1-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 | library(doParallel) # FIXME: unload?
.fork_not_windows <- function(expected, expr)
{
err <- NULL
obs <- tryCatch(expr, error=function(e) {
if (!all(grepl("fork clusters are not supported on Windows",
conditionMessage(e))))
err <<- conditionMessage(e)
expected
})
if (!is.null(err))
print(as.character(err))
checkTrue(is.null(err))
checkIdentical(expected, obs)
}
test_bplapply_Params <- function()
{
params <- list(serial=SerialParam(),
mc=MulticoreParam(2),
snow0=SnowParam(2, "FORK"),
snow1=SnowParam(2, "PSOCK"),
dopar=DoparParam(),
batchjobs=BatchJobsParam())
dop <- registerDoParallel(cores=2)
x <- 1:10
expected <- lapply(x, sqrt)
for (ptype in names(params)) {
.fork_not_windows(expected,
bplapply(x, sqrt, BPPARAM=params[[ptype]]))
}
# test empty input
for (ptype in names(params)) {
.fork_not_windows(list(),
bplapply(list(), identity, BPPARAM=params[[ptype]]))
}
closeAllConnections()
TRUE
}
test_bplapply_symbols <- function()
{
params <- list(serial=SerialParam(),
mc=MulticoreParam(2),
snow0=SnowParam(2, "FORK"),
snow1=SnowParam(2, "PSOCK"),
dopar=DoparParam(),
batchjobs=BatchJobsParam())
dop <- registerDoParallel(cores=2)
X <- list(as.symbol(".XYZ"))
expected <- lapply(X, as.character)
for (ptype in names(params)) {
.fork_not_windows(expected,
bplapply(X, as.character, BPPARAM=params[[ptype]]))
}
closeAllConnections()
TRUE
}
|