R Under development (unstable) (2024-12-03 r87418 ucrt) -- "Unsuffered Consequences" Copyright (C) 2024 The R Foundation for Statistical Computing Platform: x86_64-w64-mingw32/x64 R is free software and comes with ABSOLUTELY NO WARRANTY. You are welcome to redistribute it under certain conditions. Type 'license()' or 'licence()' for distribution details. R is a collaborative project with many contributors. Type 'contributors()' for more information and 'citation()' on how to cite R or R packages in publications. Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for an HTML browser interface to help. Type 'q()' to quit R. > source("incl/start.R") > stopCluster <- parallel::stopCluster > > message("*** cluster operations ...") *** cluster operations ... > > local({ + cl0 <- makeClusterPSOCK(1L) + on.exit(stopCluster(cl0)) + cl <- cl0 + print(cl) + + message("*** cluster operations - as.cluster() ...") + cl1 <- as.cluster(cl) + print(cl1) + stopifnot(inherits(cl1, "cluster"), identical(cl1, cl)) + + node <- cl[[1]] + print(node) + cl2 <- as.cluster(node) + stopifnot(inherits(cl2, "cluster"), length(cl2) == 1L, + identical(cl2[[1]], node)) + + node <- cl[[1]] + print(node) + stopifnot(inherits(node, if (useXDR) "SOCKnode" else "SOCK0node")) + nodes <- list(node, node) + cl3 <- as.cluster(node) + print(cl3) + stopifnot(inherits(cl3, "cluster"), length(cl3) == 1L, + identical(cl3[[1]], node)) + + cl4 <- as.cluster(nodes) + print(cl4) + stopifnot(inherits(cl4, "cluster"), length(cl4) == 2L, + identical(cl4[[1]], node), identical(cl4[[2]], node)) + + message("*** cluster operations - as.cluster() ... DONE") + + message("*** cluster operations - c(...) ...") + cl2 <- makeClusterPSOCK("localhost") + on.exit(stopCluster(cl2), add = TRUE) + print(cl2) + + cl <- c(cl1, cl2) + print(cl) + + stopifnot(inherits(cl, "cluster"), length(cl) == 2L) + stopifnot(identical(cl[1], cl1), + identical(cl[2], cl2[1])) + message("*** cluster operations - c(...) ... DONE") + }) [13:31:26.856] [local output] makeClusterPSOCK() ... [13:31:26.919] [local output] Workers: [n = 1] 'localhost' [13:31:26.928] [local output] Base port: 36885 [13:31:26.929] [local output] Getting setup options for 1 cluster nodes ... [13:31:26.929] [local output] - Node #1 of 1 ... [13:31:26.929] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:26.931] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp2B5pxu/worker.rank=1.parallelly.parent=39708.9b1c212b4a36.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_04_13_25_01_31804/Rtmp2B5pxu/worker.rank=1.parallelly.parent=39708.9b1c212b4a36.pid\")"' [13:31:27.481] - Possible to infer worker's PID: TRUE [13:31:27.483] [local output] Rscript port: 36885 [13:31:27.483] [local output] Getting setup options for 1 cluster nodes ... done [13:31:27.484] [local output] - Parallel setup requested for some PSOCK nodes [13:31:27.485] [local output] Setting up PSOCK nodes in parallel [13:31:27.485] List of 36 [13:31:27.485] $ worker : chr "localhost" [13:31:27.485] ..- attr(*, "localhost")= logi TRUE [13:31:27.485] $ master : chr "localhost" [13:31:27.485] $ port : int 36885 [13:31:27.485] $ connectTimeout : num 120 [13:31:27.485] $ timeout : num 120 [13:31:27.485] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:27.485] $ homogeneous : logi TRUE [13:31:27.485] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=as.cluster.R:39708:CRANWIN3:CRAN"| __truncated__ [13:31:27.485] $ rscript_envs : NULL [13:31:27.485] $ rscript_libs : NULL [13:31:27.485] $ rscript_startup : NULL [13:31:27.485] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:27.485] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:27.485] $ methods : logi TRUE [13:31:27.485] $ socketOptions : chr "no-delay" [13:31:27.485] $ useXDR : logi FALSE [13:31:27.485] $ outfile : chr "/dev/null" [13:31:27.485] $ renice : int NA [13:31:27.485] $ rshcmd : NULL [13:31:27.485] $ user : chr(0) [13:31:27.485] $ revtunnel : logi FALSE [13:31:27.485] $ rshlogfile : NULL [13:31:27.485] $ rshopts : chr(0) [13:31:27.485] $ rank : int 1 [13:31:27.485] $ manual : logi FALSE [13:31:27.485] $ dryrun : logi FALSE [13:31:27.485] $ quiet : logi FALSE [13:31:27.485] $ setup_strategy : chr "parallel" [13:31:27.485] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:27.485] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp2B5pxu/worker.rank=1.parallelly.parent=39708.9b1c212b4a36.pid" [13:31:27.485] $ rshcmd_label : NULL [13:31:27.485] $ rsh_call : NULL [13:31:27.485] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:27.485] $ localMachine : logi TRUE [13:31:27.485] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:27.485] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:27.485] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:27.485] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:27.485] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:27.485] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:27.485] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:27.485] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:27.485] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:27.485] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:27.485] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:27.485] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:27.485] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:27.485] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:27.485] $ arguments :List of 28 [13:31:27.485] ..$ worker : chr "localhost" [13:31:27.485] ..$ master : NULL [13:31:27.485] ..$ port : int 36885 [13:31:27.485] ..$ connectTimeout : num 120 [13:31:27.485] ..$ timeout : num 120 [13:31:27.485] ..$ rscript : NULL [13:31:27.485] ..$ homogeneous : NULL [13:31:27.485] ..$ rscript_args : NULL [13:31:27.485] ..$ rscript_envs : NULL [13:31:27.485] ..$ rscript_libs : NULL [13:31:27.485] ..$ rscript_startup : NULL [13:31:27.485] ..$ rscript_sh : chr "auto" [13:31:27.485] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:27.485] ..$ methods : logi TRUE [13:31:27.485] ..$ socketOptions : chr "no-delay" [13:31:27.485] ..$ useXDR : logi FALSE [13:31:27.485] ..$ outfile : chr "/dev/null" [13:31:27.485] ..$ renice : int NA [13:31:27.485] ..$ rshcmd : NULL [13:31:27.485] ..$ user : NULL [13:31:27.485] ..$ revtunnel : logi NA [13:31:27.485] ..$ rshlogfile : NULL [13:31:27.485] ..$ rshopts : NULL [13:31:27.485] ..$ rank : int 1 [13:31:27.485] ..$ manual : logi FALSE [13:31:27.485] ..$ dryrun : logi FALSE [13:31:27.485] ..$ quiet : logi FALSE [13:31:27.485] ..$ setup_strategy : chr "parallel" [13:31:27.485] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:27.521] [local output] System call to launch all workers: [13:31:27.521] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=as.cluster.R:39708:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp2B5pxu/worker.rank=1.parallelly.parent=39708.9b1c212b4a36.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36885 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:27.522] [local output] Starting PSOCK main server [13:31:27.528] [local output] Workers launched [13:31:27.529] [local output] Waiting for workers to connect back [13:31:27.529] - [local output] 0 workers out of 1 ready [13:31:27.805] - [local output] 0 workers out of 1 ready [13:31:27.806] - [local output] 1 workers out of 1 ready [13:31:27.806] [local output] Launching of 1 workers completed [13:31:27.806] [local output] Number of nodes in cluster: 1 [13:31:27.807] [local output] Collecting session information from 1 workers [13:31:27.808] [local output] - Worker #1 of 1 [13:31:27.808] [local output] makeClusterPSOCK() ... done Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-12-03 r87418 ucrt), platform x86_64-w64-mingw32) *** cluster operations - as.cluster() ... Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-12-03 r87418 ucrt), platform x86_64-w64-mingw32) RichSOCKnode of a socket cluster on local host 'localhost' with pid 144860 (R Under development (unstable) (2024-12-03 r87418 ucrt), x86_64-w64-mingw32) using socket connection #4 ('<-CRANwin3.fb05.statistik.uni-dortmund.de:36885') RichSOCKnode of a socket cluster on local host 'localhost' with pid 144860 (R Under development (unstable) (2024-12-03 r87418 ucrt), x86_64-w64-mingw32) using socket connection #4 ('<-CRANwin3.fb05.statistik.uni-dortmund.de:36885') Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-12-03 r87418 ucrt), platform x86_64-w64-mingw32) Warning: The combined cluster contains 1 duplicated nodes Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-12-03 r87418 ucrt), platform x86_64-w64-mingw32) *** cluster operations - as.cluster() ... DONE *** cluster operations - c(...) ... [13:31:27.822] [local output] makeClusterPSOCK() ... [13:31:27.822] [local output] Workers: [n = 1] 'localhost' [13:31:27.826] [local output] Base port: 27631 [13:31:27.827] [local output] Getting setup options for 1 cluster nodes ... [13:31:27.827] [local output] - Node #1 of 1 ... [13:31:27.828] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:27.830] [local output] Rscript port: 27631 [13:31:27.831] [local output] Getting setup options for 1 cluster nodes ... done [13:31:27.831] [local output] - Parallel setup requested for some PSOCK nodes [13:31:27.832] [local output] Setting up PSOCK nodes in parallel [13:31:27.832] List of 36 [13:31:27.832] $ worker : chr "localhost" [13:31:27.832] ..- attr(*, "localhost")= logi TRUE [13:31:27.832] $ master : chr "localhost" [13:31:27.832] $ port : int 27631 [13:31:27.832] $ connectTimeout : num 120 [13:31:27.832] $ timeout : num 120 [13:31:27.832] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:27.832] $ homogeneous : logi TRUE [13:31:27.832] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=as.cluster.R:39708:CRANWIN3:CRAN"| __truncated__ [13:31:27.832] $ rscript_envs : NULL [13:31:27.832] $ rscript_libs : NULL [13:31:27.832] $ rscript_startup : NULL [13:31:27.832] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:27.832] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:27.832] $ methods : logi TRUE [13:31:27.832] $ socketOptions : chr "no-delay" [13:31:27.832] $ useXDR : logi FALSE [13:31:27.832] $ outfile : chr "/dev/null" [13:31:27.832] $ renice : int NA [13:31:27.832] $ rshcmd : NULL [13:31:27.832] $ user : chr(0) [13:31:27.832] $ revtunnel : logi FALSE [13:31:27.832] $ rshlogfile : NULL [13:31:27.832] $ rshopts : chr(0) [13:31:27.832] $ rank : int 1 [13:31:27.832] $ manual : logi FALSE [13:31:27.832] $ dryrun : logi FALSE [13:31:27.832] $ quiet : logi FALSE [13:31:27.832] $ setup_strategy : chr "parallel" [13:31:27.832] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:27.832] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp2B5pxu/worker.rank=1.parallelly.parent=39708.9b1c63a65548.pid" [13:31:27.832] $ rshcmd_label : NULL [13:31:27.832] $ rsh_call : NULL [13:31:27.832] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:27.832] $ localMachine : logi TRUE [13:31:27.832] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:27.832] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:27.832] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:27.832] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:27.832] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:27.832] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:27.832] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:27.832] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:27.832] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:27.832] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:27.832] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:27.832] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:27.832] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:27.832] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:27.832] $ arguments :List of 28 [13:31:27.832] ..$ worker : chr "localhost" [13:31:27.832] ..$ master : NULL [13:31:27.832] ..$ port : int 27631 [13:31:27.832] ..$ connectTimeout : num 120 [13:31:27.832] ..$ timeout : num 120 [13:31:27.832] ..$ rscript : NULL [13:31:27.832] ..$ homogeneous : NULL [13:31:27.832] ..$ rscript_args : NULL [13:31:27.832] ..$ rscript_envs : NULL [13:31:27.832] ..$ rscript_libs : NULL [13:31:27.832] ..$ rscript_startup : NULL [13:31:27.832] ..$ rscript_sh : chr "auto" [13:31:27.832] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:27.832] ..$ methods : logi TRUE [13:31:27.832] ..$ socketOptions : chr "no-delay" [13:31:27.832] ..$ useXDR : logi FALSE [13:31:27.832] ..$ outfile : chr "/dev/null" [13:31:27.832] ..$ renice : int NA [13:31:27.832] ..$ rshcmd : NULL [13:31:27.832] ..$ user : NULL [13:31:27.832] ..$ revtunnel : logi NA [13:31:27.832] ..$ rshlogfile : NULL [13:31:27.832] ..$ rshopts : NULL [13:31:27.832] ..$ rank : int 1 [13:31:27.832] ..$ manual : logi FALSE [13:31:27.832] ..$ dryrun : logi FALSE [13:31:27.832] ..$ quiet : logi FALSE [13:31:27.832] ..$ setup_strategy : chr "parallel" [13:31:27.832] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:27.865] [local output] System call to launch all workers: [13:31:27.865] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=as.cluster.R:39708:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp2B5pxu/worker.rank=1.parallelly.parent=39708.9b1c63a65548.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=27631 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:27.865] [local output] Starting PSOCK main server [13:31:27.871] [local output] Workers launched [13:31:27.872] [local output] Waiting for workers to connect back [13:31:27.872] - [local output] 0 workers out of 1 ready [13:31:28.177] - [local output] 0 workers out of 1 ready [13:31:28.177] - [local output] 1 workers out of 1 ready [13:31:28.178] [local output] Launching of 1 workers completed [13:31:28.178] [local output] Number of nodes in cluster: 1 [13:31:28.178] [local output] Collecting session information from 1 workers [13:31:28.180] [local output] - Worker #1 of 1 [13:31:28.180] [local output] makeClusterPSOCK() ... done Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-12-03 r87418 ucrt), platform x86_64-w64-mingw32) Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-12-03 r87418 ucrt), platform x86_64-w64-mingw32) *** cluster operations - c(...) ... DONE > > > message("*** cluster operations - makeClusterPSOCK(remotes) ...") *** cluster operations - makeClusterPSOCK(remotes) ... > > remotes <- Sys.getenv("R_PARALLELLY_TESTS_REMOTES", "") > remotes <- gsub(" ", "", unlist(strsplit(remotes, split = ","))) > remotes <- remotes[nzchar(remotes)] > if (length(remotes) > 0) { + message("Remotes: ", paste(sQuote(remotes), collapse = ", ")) + local({ + cl <- makeClusterPSOCK(remotes, verbose = TRUE) + on.exit(stopCluster(cl)) + print(cl) + }) + } > > message("*** cluster operations - makeClusterPSOCK(remotes) ... DONE") *** cluster operations - makeClusterPSOCK(remotes) ... DONE > > message("*** cluster operations ... DONE") *** cluster operations ... DONE > > source("incl/end.R") > > proc.time() user system elapsed 0.40 0.14 1.70