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
|
message("Testing bpvec")
test_bpvec_Params <- function()
{
cl <- parallel::makeCluster(2)
doParallel::registerDoParallel(cl)
params <- list(
serial=SerialParam(),
snow=SnowParam(2),
dopar=DoparParam()
)
if (.Platform$OS.type != "windows")
params$mc <- MulticoreParam(2)
x <- rev(1:10)
expected <- sqrt(x)
for (param in names(params)) {
current <- bpvec(x, sqrt, BPPARAM=params[[param]])
checkIdentical(current, expected)
}
## clean up
foreach::registerDoSEQ()
parallel::stopCluster(cl)
closeAllConnections()
TRUE
}
test_bpvec_MulticoreParam_short_jobs <- function() {
## bpvec should return min(length(X), bpnworkers())
if (.Platform$OS.type == "windows")
return(TRUE)
exp <- 1:2
obs <- bpvec(exp, c, AGGREGATE=list, BPPARAM=MulticoreParam(workers=4L))
checkIdentical(2L, length(obs))
checkIdentical(exp, unlist(obs))
## clean up
closeAllConnections()
TRUE
}
test_bpvec_invalid_FUN <- function() {
res <- bptry(bpvec(1:2, class, BPPARAM=SerialParam()))
checkTrue(inherits(res, "bpvec_error"))
}
test_bpvec_named_list <- function() {
X <- list()
Y <- character()
checkIdentical(X, bpvec(X, length))
checkIdentical(X, bpvec(Y, length))
names(X) <- names(Y) <- character()
checkIdentical(X, bpvec(X, length))
checkIdentical(X, bpvec(Y, length))
}
|
