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") > > is_fqdn <- parallelly:::is_fqdn > is_ip_number <- parallelly:::is_ip_number > is_localhost <- parallelly:::is_localhost > find_rshcmd <- parallelly:::find_rshcmd > > message("*** makeClusterPSOCK() ...") *** makeClusterPSOCK() ... > > message("- makeClusterPSOCK() - internal utility functions") - makeClusterPSOCK() - internal utility functions > > stopifnot( + is_fqdn("a.b"), + is_fqdn("a.b.c"), + !is_fqdn("a") + ) > > stopifnot( + is_ip_number("1.2.3.4"), + !is_ip_number("a"), + !is_ip_number("1.2.3"), + !is_ip_number("1.2.3.256"), + !is_ip_number("1.2.3.-1"), + !is_ip_number("1.2.3.a") + ) > > ## Reset internal cache > stopifnot(is.na(is_localhost(worker = NULL, hostname = NULL))) > stopifnot( + is_localhost("localhost"), + is_localhost("127.0.0.1"), + is_localhost(Sys.info()[["nodename"]]), + is_localhost(Sys.info()[["nodename"]]), ## cache hit + !is_localhost("not.a.localhost.hostname") + ) > > cmd <- find_rshcmd(must_work = FALSE) > print(cmd) $ssh ssh "d:\\rtools44\\usr\\bin\\ssh.exe" attr(,"type") [1] "ssh" attr(,"version") [1] "OpenSSH_9.9p1, OpenSSL 3.3.2 3 Sep 2024" $`putty-plink` plink "C:\\PROGRA~1\\PuTTY\\plink.exe" "-ssh" attr(,"type") [1] "putty-plink" attr(,"version") [1] "plink: Release 0.81; Build platform: 64-bit x86 Windows; Compiler: clang 14.0.0 , emulating Visual Studio 2022 (17.2), _MSC_VER=1932, _MSC_FULL_VER=193231329; Source commit: a8601a72a918dfc2a8e8536a77139d7f37700044" > > > message("- makeClusterPSOCK()") - makeClusterPSOCK() > > cl <- makeClusterPSOCK("", user = "johndoe", master = NULL, revtunnel = FALSE, rshcmd = "my_ssh", renice = TRUE, manual = TRUE, dryrun = TRUE) [13:31:54.405] [local output] makeClusterPSOCK() ... [13:31:54.450] [local output] Workers: [n = 1] '' [13:31:54.459] [local output] Base port: 30847 [13:31:54.459] [local output] Getting setup options for 1 cluster nodes ... [13:31:54.460] [local output] - Node #1 of 1 ... [13:31:54.463] [local output] Rscript port: 30847 [13:31:54.464] [local output] Using 'rshcmd': 'my_ssh' [type='', version=''] [13:31:54.464] [local output] Getting setup options for 1 cluster nodes ... done [13:31:54.465] [local output] Creating node #1 of 1 ... [13:31:54.465] [local output] - setting up node [13:31:54.465] [local output] - attempt #1 of 3 ---------------------------------------------------------------------- Manually, (i) login into external machine '': 'my_ssh' -l johndoe and (ii) start worker #1 from there: nice --adjustment=1 'D:/RCompile/recent/R/bin/x64/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e '#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN' -e 'options(socketOptions = "no-delay")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=30847 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential Alternatively, start worker #1 from the local machine by combining both steps in a single call: 'my_ssh' -l johndoe "nice --adjustment=1 'D:/RCompile/recent/R/bin/x64/Rscript' --default-packages=datasets,utils,grDevices,graphics,stats,methods -e '#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN' -e 'options(socketOptions = \"no-delay\")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=30847 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential" [13:31:54.466] [local output] Creating node #1 of 1 ... done [13:31:54.466] [local output] Launching of 1 workers completed [13:31:54.467] [local output] Number of nodes in cluster: 1 [13:31:54.467] [local output] Collecting session information from 1 workers [13:31:54.467] [local output] - Worker #1 of 1 [13:31:54.468] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'NA' (R version and platform not queried) > > cl <- makeClusterPSOCK(1L, port = "random", dryrun = TRUE) [13:31:54.471] [local output] makeClusterPSOCK() ... [13:31:54.478] [local output] Workers: [n = 1] 'localhost' [13:31:54.482] [local output] Base port: 29279 [13:31:54.483] [local output] Getting setup options for 1 cluster nodes ... [13:31:54.483] [local output] - Node #1 of 1 ... [13:31:54.484] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:54.486] [local output] Rscript port: 29279 [13:31:54.487] [local output] Getting setup options for 1 cluster nodes ... done [13:31:54.488] [local output] Creating node #1 of 1 ... [13:31:54.488] [local output] - setting up node [13:31:54.488] [local output] - attempt #1 of 3 ---------------------------------------------------------------------- Manually, start worker #1 on local machine 'localhost' with: "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=29279 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [13:31:54.489] [local output] Creating node #1 of 1 ... done [13:31:54.489] [local output] Launching of 1 workers completed [13:31:54.489] [local output] Number of nodes in cluster: 1 [13:31:54.490] [local output] Collecting session information from 1 workers [13:31:54.490] [local output] - Worker #1 of 1 [13:31:54.491] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'NA' (R version and platform not queried) > > cl <- makeClusterPSOCK(1L) [13:31:54.492] [local output] makeClusterPSOCK() ... [13:31:54.496] [local output] Workers: [n = 1] 'localhost' [13:31:54.501] [local output] Base port: 39992 [13:31:54.501] [local output] Getting setup options for 1 cluster nodes ... [13:31:54.501] [local output] - Node #1 of 1 ... [13:31:54.502] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:54.504] 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/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84bba10cd.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84bba10cd.pid\")"' [13:31:55.060] - Possible to infer worker's PID: TRUE [13:31:55.062] [local output] Rscript port: 39992 [13:31:55.063] [local output] Getting setup options for 1 cluster nodes ... done [13:31:55.063] [local output] - Parallel setup requested for some PSOCK nodes [13:31:55.064] [local output] Setting up PSOCK nodes in parallel [13:31:55.065] List of 36 [13:31:55.065] $ worker : chr "localhost" [13:31:55.065] ..- attr(*, "localhost")= logi TRUE [13:31:55.065] $ master : chr "localhost" [13:31:55.065] $ port : int 39992 [13:31:55.065] $ connectTimeout : num 120 [13:31:55.065] $ timeout : num 120 [13:31:55.065] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:55.065] $ homogeneous : logi TRUE [13:31:55.065] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:55.065] $ rscript_envs : NULL [13:31:55.065] $ rscript_libs : NULL [13:31:55.065] $ rscript_startup : NULL [13:31:55.065] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:55.065] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:55.065] $ methods : logi TRUE [13:31:55.065] $ socketOptions : chr "no-delay" [13:31:55.065] $ useXDR : logi FALSE [13:31:55.065] $ outfile : chr "/dev/null" [13:31:55.065] $ renice : int NA [13:31:55.065] $ rshcmd : NULL [13:31:55.065] $ user : chr(0) [13:31:55.065] $ revtunnel : logi FALSE [13:31:55.065] $ rshlogfile : NULL [13:31:55.065] $ rshopts : chr(0) [13:31:55.065] $ rank : int 1 [13:31:55.065] $ manual : logi FALSE [13:31:55.065] $ dryrun : logi FALSE [13:31:55.065] $ quiet : logi FALSE [13:31:55.065] $ setup_strategy : chr "parallel" [13:31:55.065] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:55.065] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84bba10cd.pid" [13:31:55.065] $ rshcmd_label : NULL [13:31:55.065] $ rsh_call : NULL [13:31:55.065] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:55.065] $ localMachine : logi TRUE [13:31:55.065] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:55.065] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:55.065] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:55.065] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:55.065] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:55.065] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:55.065] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:55.065] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:55.065] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:55.065] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:55.065] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:55.065] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:55.065] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:55.065] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:55.065] $ arguments :List of 28 [13:31:55.065] ..$ worker : chr "localhost" [13:31:55.065] ..$ master : NULL [13:31:55.065] ..$ port : int 39992 [13:31:55.065] ..$ connectTimeout : num 120 [13:31:55.065] ..$ timeout : num 120 [13:31:55.065] ..$ rscript : NULL [13:31:55.065] ..$ homogeneous : NULL [13:31:55.065] ..$ rscript_args : NULL [13:31:55.065] ..$ rscript_envs : NULL [13:31:55.065] ..$ rscript_libs : NULL [13:31:55.065] ..$ rscript_startup : NULL [13:31:55.065] ..$ rscript_sh : chr "auto" [13:31:55.065] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:55.065] ..$ methods : logi TRUE [13:31:55.065] ..$ socketOptions : chr "no-delay" [13:31:55.065] ..$ useXDR : logi FALSE [13:31:55.065] ..$ outfile : chr "/dev/null" [13:31:55.065] ..$ renice : int NA [13:31:55.065] ..$ rshcmd : NULL [13:31:55.065] ..$ user : NULL [13:31:55.065] ..$ revtunnel : logi NA [13:31:55.065] ..$ rshlogfile : NULL [13:31:55.065] ..$ rshopts : NULL [13:31:55.065] ..$ rank : int 1 [13:31:55.065] ..$ manual : logi FALSE [13:31:55.065] ..$ dryrun : logi FALSE [13:31:55.065] ..$ quiet : logi FALSE [13:31:55.065] ..$ setup_strategy : chr "parallel" [13:31:55.065] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:55.117] [local output] System call to launch all workers: [13:31:55.117] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84bba10cd.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=39992 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:55.117] [local output] Starting PSOCK main server [13:31:55.124] [local output] Workers launched [13:31:55.124] [local output] Waiting for workers to connect back [13:31:55.125] - [local output] 0 workers out of 1 ready [13:31:55.425] - [local output] 0 workers out of 1 ready [13:31:55.425] - [local output] 1 workers out of 1 ready [13:31:55.426] [local output] Launching of 1 workers completed [13:31:55.426] [local output] Number of nodes in cluster: 1 [13:31:55.426] [local output] Collecting session information from 1 workers [13:31:55.428] [local output] - Worker #1 of 1 [13:31:55.428] [local output] makeClusterPSOCK() ... done > print(cl) 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) > node <- cl[[1]] > utils::str(node) List of 4 $ con : 'sockconn' int 4 ..- attr(*, "conn_id")= $ host : chr "localhost" ..- attr(*, "localhost")= logi TRUE $ rank : int 0 $ session_info:List of 6 ..$ r :List of 16 .. ..$ platform : chr "x86_64-w64-mingw32" .. ..$ arch : chr "x86_64" .. ..$ os : chr "mingw32" .. ..$ crt : chr "ucrt" .. ..$ system : chr "x86_64, mingw32" .. ..$ status : chr "Under development (unstable)" .. ..$ major : chr "4" .. ..$ minor : chr "5.0" .. ..$ year : chr "2024" .. ..$ month : chr "12" .. ..$ day : chr "03" .. ..$ svn rev : chr "87418" .. ..$ language : chr "R" .. ..$ version.string: chr "R Under development (unstable) (2024-12-03 r87418 ucrt)" .. ..$ nickname : chr "Unsuffered Consequences" .. ..$ os.type : chr "windows" ..$ system :List of 9 .. ..$ sysname : chr "Windows" .. ..$ release : chr "Server x64" .. ..$ version : chr "build 20348" .. ..$ nodename : chr "CRANWIN3" .. ..$ machine : chr "x86-64" .. ..$ login : chr "CRAN" .. ..$ user : chr "CRAN" .. ..$ effective_user: chr "CRAN" .. ..$ udomain : chr "CRANWIN3" ..$ libs : chr [1:2] "D:/temp/2024_12_04_13_25_01_31804/RtmpspCktY/RLIBS_22e4463563ce8" "D:/RCompile/recent/R/library" ..$ pkgs : NULL ..$ pwd : chr "d:/RCompile/CRANincoming/R-devel/parallelly.Rcheck/tests" ..$ process:List of 1 .. ..$ pid: int 16328 - attr(*, "options")=List of 35 ..$ worker : chr "localhost" .. ..- attr(*, "localhost")= logi TRUE ..$ master : chr "localhost" ..$ port : int 39992 ..$ connectTimeout : num 120 ..$ timeout : num 120 ..$ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" ..$ homogeneous : logi TRUE ..$ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ ..$ rscript_envs : NULL ..$ rscript_libs : NULL ..$ rscript_startup : NULL ..$ rscript_sh : chr [1:2] "cmd" "cmd" ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... ..$ methods : logi TRUE ..$ socketOptions : chr "no-delay" ..$ useXDR : logi FALSE ..$ outfile : chr "/dev/null" ..$ renice : int NA ..$ rshcmd : NULL ..$ user : chr(0) ..$ revtunnel : logi FALSE ..$ rshlogfile : NULL ..$ rshopts : chr(0) ..$ rank : int 0 ..$ manual : logi FALSE ..$ dryrun : logi FALSE ..$ quiet : logi FALSE ..$ setup_strategy : chr "parallel" ..$ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ ..$ rshcmd_label : NULL ..$ rsh_call : NULL ..$ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ ..$ localMachine : logi TRUE ..$ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", "cmd", "sh", "none"), default_packages = c("datasets", "utils", "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", "parallel"), action = c("launch", "options"), verbose = FALSE) ..$ arguments :List of 28 .. ..$ worker : chr "localhost" .. ..$ master : NULL .. ..$ port : int 39992 .. ..$ connectTimeout : num 120 .. ..$ timeout : num 120 .. ..$ rscript : NULL .. ..$ homogeneous : NULL .. ..$ rscript_args : NULL .. ..$ rscript_envs : NULL .. ..$ rscript_libs : NULL .. ..$ rscript_startup : NULL .. ..$ rscript_sh : chr "auto" .. ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... .. ..$ methods : logi TRUE .. ..$ socketOptions : chr "no-delay" .. ..$ useXDR : logi FALSE .. ..$ outfile : chr "/dev/null" .. ..$ renice : int NA .. ..$ rshcmd : NULL .. ..$ user : NULL .. ..$ revtunnel : logi NA .. ..$ rshlogfile : NULL .. ..$ rshopts : NULL .. ..$ rank : int 1 .. ..$ manual : logi FALSE .. ..$ dryrun : logi FALSE .. ..$ quiet : logi FALSE .. ..$ setup_strategy : chr "parallel" ..- attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" - attr(*, "class")= chr [1:2] "RichSOCKnode" "SOCK0node" > stopifnot(isTRUE(attr(node[["host"]], "localhost"))) > parallel::stopCluster(cl) > > > message("- makeClusterPSOCK() - useXDR = TRUE/FALSE") - makeClusterPSOCK() - useXDR = TRUE/FALSE > > for (xdr in c(TRUE, FALSE)) { + cl <- makeClusterPSOCK(1L, useXDR = xdr) + node <- cl[[1]] + stopifnot( + is.list(node), + inherits(node, if (xdr) "SOCKnode" else "SOCK0node"), + "session_info" %in% names(node) + ) + si <- node[["session_info"]] + stopifnot(is.list(si)) + parallel::stopCluster(cl) + } [13:31:55.521] [local output] makeClusterPSOCK() ... [13:31:55.527] [local output] Workers: [n = 1] 'localhost' [13:31:55.532] [local output] Base port: 33038 [13:31:55.532] [local output] Getting setup options for 1 cluster nodes ... [13:31:55.532] [local output] - Node #1 of 1 ... [13:31:55.533] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:55.536] [local output] Rscript port: 33038 [13:31:55.536] [local output] Getting setup options for 1 cluster nodes ... done [13:31:55.537] [local output] - Parallel setup requested for some PSOCK nodes [13:31:55.537] [local output] Setting up PSOCK nodes in parallel [13:31:55.538] List of 36 [13:31:55.538] $ worker : chr "localhost" [13:31:55.538] ..- attr(*, "localhost")= logi TRUE [13:31:55.538] $ master : chr "localhost" [13:31:55.538] $ port : int 33038 [13:31:55.538] $ connectTimeout : num 120 [13:31:55.538] $ timeout : num 120 [13:31:55.538] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:55.538] $ homogeneous : logi TRUE [13:31:55.538] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:55.538] $ rscript_envs : NULL [13:31:55.538] $ rscript_libs : NULL [13:31:55.538] $ rscript_startup : NULL [13:31:55.538] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:55.538] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:55.538] $ methods : logi TRUE [13:31:55.538] $ socketOptions : chr "no-delay" [13:31:55.538] $ useXDR : logi TRUE [13:31:55.538] $ outfile : chr "/dev/null" [13:31:55.538] $ renice : int NA [13:31:55.538] $ rshcmd : NULL [13:31:55.538] $ user : chr(0) [13:31:55.538] $ revtunnel : logi FALSE [13:31:55.538] $ rshlogfile : NULL [13:31:55.538] $ rshopts : chr(0) [13:31:55.538] $ rank : int 1 [13:31:55.538] $ manual : logi FALSE [13:31:55.538] $ dryrun : logi FALSE [13:31:55.538] $ quiet : logi FALSE [13:31:55.538] $ setup_strategy : chr "parallel" [13:31:55.538] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:55.538] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef81dfc1256.pid" [13:31:55.538] $ rshcmd_label : NULL [13:31:55.538] $ rsh_call : NULL [13:31:55.538] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:55.538] $ localMachine : logi TRUE [13:31:55.538] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:55.538] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:55.538] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:55.538] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:55.538] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:55.538] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:55.538] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:55.538] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:55.538] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:55.538] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:55.538] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:55.538] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:55.538] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:55.538] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:55.538] $ arguments :List of 28 [13:31:55.538] ..$ worker : chr "localhost" [13:31:55.538] ..$ master : NULL [13:31:55.538] ..$ port : int 33038 [13:31:55.538] ..$ connectTimeout : num 120 [13:31:55.538] ..$ timeout : num 120 [13:31:55.538] ..$ rscript : NULL [13:31:55.538] ..$ homogeneous : NULL [13:31:55.538] ..$ rscript_args : NULL [13:31:55.538] ..$ rscript_envs : NULL [13:31:55.538] ..$ rscript_libs : NULL [13:31:55.538] ..$ rscript_startup : NULL [13:31:55.538] ..$ rscript_sh : chr "auto" [13:31:55.538] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:55.538] ..$ methods : logi TRUE [13:31:55.538] ..$ socketOptions : chr "no-delay" [13:31:55.538] ..$ useXDR : logi TRUE [13:31:55.538] ..$ outfile : chr "/dev/null" [13:31:55.538] ..$ renice : int NA [13:31:55.538] ..$ rshcmd : NULL [13:31:55.538] ..$ user : NULL [13:31:55.538] ..$ revtunnel : logi NA [13:31:55.538] ..$ rshlogfile : NULL [13:31:55.538] ..$ rshopts : NULL [13:31:55.538] ..$ rank : int 1 [13:31:55.538] ..$ manual : logi FALSE [13:31:55.538] ..$ dryrun : logi FALSE [13:31:55.538] ..$ quiet : logi FALSE [13:31:55.538] ..$ setup_strategy : chr "parallel" [13:31:55.538] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:55.577] [local output] System call to launch all workers: [13:31:55.577] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef81dfc1256.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33038 OUT=/dev/null TIMEOUT=120 XDR=TRUE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:55.578] [local output] Starting PSOCK main server [13:31:55.584] [local output] Workers launched [13:31:55.584] [local output] Waiting for workers to connect back [13:31:55.585] - [local output] 0 workers out of 1 ready [13:31:55.861] - [local output] 0 workers out of 1 ready [13:31:55.861] - [local output] 1 workers out of 1 ready [13:31:55.861] [local output] Launching of 1 workers completed [13:31:55.861] [local output] Number of nodes in cluster: 1 [13:31:55.862] [local output] Collecting session information from 1 workers [13:31:55.863] [local output] - Worker #1 of 1 [13:31:55.863] [local output] makeClusterPSOCK() ... done [13:31:55.875] [local output] makeClusterPSOCK() ... [13:31:55.880] [local output] Workers: [n = 1] 'localhost' [13:31:55.884] [local output] Base port: 30350 [13:31:55.884] [local output] Getting setup options for 1 cluster nodes ... [13:31:55.887] [local output] - Node #1 of 1 ... [13:31:55.887] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:55.890] [local output] Rscript port: 30350 [13:31:55.890] [local output] Getting setup options for 1 cluster nodes ... done [13:31:55.890] [local output] - Parallel setup requested for some PSOCK nodes [13:31:55.891] [local output] Setting up PSOCK nodes in parallel [13:31:55.891] List of 36 [13:31:55.891] $ worker : chr "localhost" [13:31:55.891] ..- attr(*, "localhost")= logi TRUE [13:31:55.891] $ master : chr "localhost" [13:31:55.891] $ port : int 30350 [13:31:55.891] $ connectTimeout : num 120 [13:31:55.891] $ timeout : num 120 [13:31:55.891] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:55.891] $ homogeneous : logi TRUE [13:31:55.891] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:55.891] $ rscript_envs : NULL [13:31:55.891] $ rscript_libs : NULL [13:31:55.891] $ rscript_startup : NULL [13:31:55.891] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:55.891] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:55.891] $ methods : logi TRUE [13:31:55.891] $ socketOptions : chr "no-delay" [13:31:55.891] $ useXDR : logi FALSE [13:31:55.891] $ outfile : chr "/dev/null" [13:31:55.891] $ renice : int NA [13:31:55.891] $ rshcmd : NULL [13:31:55.891] $ user : chr(0) [13:31:55.891] $ revtunnel : logi FALSE [13:31:55.891] $ rshlogfile : NULL [13:31:55.891] $ rshopts : chr(0) [13:31:55.891] $ rank : int 1 [13:31:55.891] $ manual : logi FALSE [13:31:55.891] $ dryrun : logi FALSE [13:31:55.891] $ quiet : logi FALSE [13:31:55.891] $ setup_strategy : chr "parallel" [13:31:55.891] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:55.891] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef865444a59.pid" [13:31:55.891] $ rshcmd_label : NULL [13:31:55.891] $ rsh_call : NULL [13:31:55.891] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:55.891] $ localMachine : logi TRUE [13:31:55.891] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:55.891] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:55.891] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:55.891] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:55.891] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:55.891] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:55.891] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:55.891] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:55.891] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:55.891] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:55.891] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:55.891] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:55.891] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:55.891] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:55.891] $ arguments :List of 28 [13:31:55.891] ..$ worker : chr "localhost" [13:31:55.891] ..$ master : NULL [13:31:55.891] ..$ port : int 30350 [13:31:55.891] ..$ connectTimeout : num 120 [13:31:55.891] ..$ timeout : num 120 [13:31:55.891] ..$ rscript : NULL [13:31:55.891] ..$ homogeneous : NULL [13:31:55.891] ..$ rscript_args : NULL [13:31:55.891] ..$ rscript_envs : NULL [13:31:55.891] ..$ rscript_libs : NULL [13:31:55.891] ..$ rscript_startup : NULL [13:31:55.891] ..$ rscript_sh : chr "auto" [13:31:55.891] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:55.891] ..$ methods : logi TRUE [13:31:55.891] ..$ socketOptions : chr "no-delay" [13:31:55.891] ..$ useXDR : logi FALSE [13:31:55.891] ..$ outfile : chr "/dev/null" [13:31:55.891] ..$ renice : int NA [13:31:55.891] ..$ rshcmd : NULL [13:31:55.891] ..$ user : NULL [13:31:55.891] ..$ revtunnel : logi NA [13:31:55.891] ..$ rshlogfile : NULL [13:31:55.891] ..$ rshopts : NULL [13:31:55.891] ..$ rank : int 1 [13:31:55.891] ..$ manual : logi FALSE [13:31:55.891] ..$ dryrun : logi FALSE [13:31:55.891] ..$ quiet : logi FALSE [13:31:55.891] ..$ setup_strategy : chr "parallel" [13:31:55.891] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:55.919] [local output] System call to launch all workers: [13:31:55.920] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef865444a59.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30350 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:55.920] [local output] Starting PSOCK main server [13:31:55.926] [local output] Workers launched [13:31:55.927] [local output] Waiting for workers to connect back [13:31:55.927] - [local output] 0 workers out of 1 ready [13:31:56.195] - [local output] 0 workers out of 1 ready [13:31:56.198] - [local output] 1 workers out of 1 ready [13:31:56.199] [local output] Launching of 1 workers completed [13:31:56.199] [local output] Number of nodes in cluster: 1 [13:31:56.199] [local output] Collecting session information from 1 workers [13:31:56.201] [local output] - Worker #1 of 1 [13:31:56.201] [local output] makeClusterPSOCK() ... done > > message("- makeClusterPSOCK() - argument 'socketOptions'") - makeClusterPSOCK() - argument 'socketOptions' > > for (value in list(NULL, "NULL", "no-delay")) { + cl <- makeClusterPSOCK(1L, socketOptions = value) + y <- parallel::clusterEvalQ(cl, 42L)[[1]] + stopifnot(identical(y, 42L)) + parallel::stopCluster(cl) + } [13:31:56.218] [local output] makeClusterPSOCK() ... [13:31:56.223] [local output] Workers: [n = 1] 'localhost' [13:31:56.227] [local output] Base port: 21277 [13:31:56.228] [local output] Getting setup options for 1 cluster nodes ... [13:31:56.228] [local output] - Node #1 of 1 ... [13:31:56.229] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:56.231] [local output] Rscript port: 21277 [13:31:56.231] [local output] Getting setup options for 1 cluster nodes ... done [13:31:56.232] [local output] - Parallel setup requested for some PSOCK nodes [13:31:56.232] [local output] Setting up PSOCK nodes in parallel [13:31:56.232] List of 36 [13:31:56.232] $ worker : chr "localhost" [13:31:56.232] ..- attr(*, "localhost")= logi TRUE [13:31:56.232] $ master : chr "localhost" [13:31:56.232] $ port : int 21277 [13:31:56.232] $ connectTimeout : num 120 [13:31:56.232] $ timeout : num 120 [13:31:56.232] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:56.232] $ homogeneous : logi TRUE [13:31:56.232] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:56.232] $ rscript_envs : NULL [13:31:56.232] $ rscript_libs : NULL [13:31:56.232] $ rscript_startup : NULL [13:31:56.232] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:56.232] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:56.232] $ methods : logi TRUE [13:31:56.232] $ socketOptions : NULL [13:31:56.232] $ useXDR : logi FALSE [13:31:56.232] $ outfile : chr "/dev/null" [13:31:56.232] $ renice : int NA [13:31:56.232] $ rshcmd : NULL [13:31:56.232] $ user : chr(0) [13:31:56.232] $ revtunnel : logi FALSE [13:31:56.232] $ rshlogfile : NULL [13:31:56.232] $ rshopts : chr(0) [13:31:56.232] $ rank : int 1 [13:31:56.232] $ manual : logi FALSE [13:31:56.232] $ dryrun : logi FALSE [13:31:56.232] $ quiet : logi FALSE [13:31:56.232] $ setup_strategy : chr "parallel" [13:31:56.232] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:56.232] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef813f62dbc.pid" [13:31:56.232] $ rshcmd_label : NULL [13:31:56.232] $ rsh_call : NULL [13:31:56.232] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:56.232] $ localMachine : logi TRUE [13:31:56.232] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:56.232] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:56.232] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:56.232] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:56.232] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:56.232] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:56.232] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:56.232] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:56.232] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:56.232] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:56.232] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:56.232] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:56.232] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:56.232] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:56.232] $ arguments :List of 28 [13:31:56.232] ..$ worker : chr "localhost" [13:31:56.232] ..$ master : NULL [13:31:56.232] ..$ port : int 21277 [13:31:56.232] ..$ connectTimeout : num 120 [13:31:56.232] ..$ timeout : num 120 [13:31:56.232] ..$ rscript : NULL [13:31:56.232] ..$ homogeneous : NULL [13:31:56.232] ..$ rscript_args : NULL [13:31:56.232] ..$ rscript_envs : NULL [13:31:56.232] ..$ rscript_libs : NULL [13:31:56.232] ..$ rscript_startup : NULL [13:31:56.232] ..$ rscript_sh : chr "auto" [13:31:56.232] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:56.232] ..$ methods : logi TRUE [13:31:56.232] ..$ socketOptions : NULL [13:31:56.232] ..$ useXDR : logi FALSE [13:31:56.232] ..$ outfile : chr "/dev/null" [13:31:56.232] ..$ renice : int NA [13:31:56.232] ..$ rshcmd : NULL [13:31:56.232] ..$ user : NULL [13:31:56.232] ..$ revtunnel : logi NA [13:31:56.232] ..$ rshlogfile : NULL [13:31:56.232] ..$ rshopts : NULL [13:31:56.232] ..$ rank : int 1 [13:31:56.232] ..$ manual : logi FALSE [13:31:56.232] ..$ dryrun : logi FALSE [13:31:56.232] ..$ quiet : logi FALSE [13:31:56.232] ..$ setup_strategy : chr "parallel" [13:31:56.232] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:56.263] [local output] System call to launch all workers: [13:31:56.264] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef813f62dbc.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=21277 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:56.264] [local output] Starting PSOCK main server [13:31:56.270] [local output] Workers launched [13:31:56.270] [local output] Waiting for workers to connect back [13:31:56.270] - [local output] 0 workers out of 1 ready [13:31:56.533] - [local output] 0 workers out of 1 ready [13:31:56.533] - [local output] 1 workers out of 1 ready [13:31:56.534] [local output] Launching of 1 workers completed [13:31:56.534] [local output] Number of nodes in cluster: 1 [13:31:56.534] [local output] Collecting session information from 1 workers [13:31:56.536] [local output] - Worker #1 of 1 [13:31:56.536] [local output] makeClusterPSOCK() ... done [13:31:56.547] [local output] makeClusterPSOCK() ... [13:31:56.552] [local output] Workers: [n = 1] 'localhost' [13:31:56.555] [local output] Base port: 20622 [13:31:56.555] [local output] Getting setup options for 1 cluster nodes ... [13:31:56.556] [local output] - Node #1 of 1 ... [13:31:56.556] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:56.558] [local output] Rscript port: 20622 [13:31:56.558] [local output] Getting setup options for 1 cluster nodes ... done [13:31:56.558] [local output] - Parallel setup requested for some PSOCK nodes [13:31:56.559] [local output] Setting up PSOCK nodes in parallel [13:31:56.559] List of 36 [13:31:56.559] $ worker : chr "localhost" [13:31:56.559] ..- attr(*, "localhost")= logi TRUE [13:31:56.559] $ master : chr "localhost" [13:31:56.559] $ port : int 20622 [13:31:56.559] $ connectTimeout : num 120 [13:31:56.559] $ timeout : num 120 [13:31:56.559] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:56.559] $ homogeneous : logi TRUE [13:31:56.559] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:56.559] $ rscript_envs : NULL [13:31:56.559] $ rscript_libs : NULL [13:31:56.559] $ rscript_startup : NULL [13:31:56.559] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:56.559] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:56.559] $ methods : logi TRUE [13:31:56.559] $ socketOptions : NULL [13:31:56.559] $ useXDR : logi FALSE [13:31:56.559] $ outfile : chr "/dev/null" [13:31:56.559] $ renice : int NA [13:31:56.559] $ rshcmd : NULL [13:31:56.559] $ user : chr(0) [13:31:56.559] $ revtunnel : logi FALSE [13:31:56.559] $ rshlogfile : NULL [13:31:56.559] $ rshopts : chr(0) [13:31:56.559] $ rank : int 1 [13:31:56.559] $ manual : logi FALSE [13:31:56.559] $ dryrun : logi FALSE [13:31:56.559] $ quiet : logi FALSE [13:31:56.559] $ setup_strategy : chr "parallel" [13:31:56.559] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:56.559] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef844e27d1b.pid" [13:31:56.559] $ rshcmd_label : NULL [13:31:56.559] $ rsh_call : NULL [13:31:56.559] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:56.559] $ localMachine : logi TRUE [13:31:56.559] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:56.559] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:56.559] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:56.559] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:56.559] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:56.559] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:56.559] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:56.559] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:56.559] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:56.559] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:56.559] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:56.559] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:56.559] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:56.559] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:56.559] $ arguments :List of 28 [13:31:56.559] ..$ worker : chr "localhost" [13:31:56.559] ..$ master : NULL [13:31:56.559] ..$ port : int 20622 [13:31:56.559] ..$ connectTimeout : num 120 [13:31:56.559] ..$ timeout : num 120 [13:31:56.559] ..$ rscript : NULL [13:31:56.559] ..$ homogeneous : NULL [13:31:56.559] ..$ rscript_args : NULL [13:31:56.559] ..$ rscript_envs : NULL [13:31:56.559] ..$ rscript_libs : NULL [13:31:56.559] ..$ rscript_startup : NULL [13:31:56.559] ..$ rscript_sh : chr "auto" [13:31:56.559] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:56.559] ..$ methods : logi TRUE [13:31:56.559] ..$ socketOptions : chr "NULL" [13:31:56.559] ..$ useXDR : logi FALSE [13:31:56.559] ..$ outfile : chr "/dev/null" [13:31:56.559] ..$ renice : int NA [13:31:56.559] ..$ rshcmd : NULL [13:31:56.559] ..$ user : NULL [13:31:56.559] ..$ revtunnel : logi NA [13:31:56.559] ..$ rshlogfile : NULL [13:31:56.559] ..$ rshopts : NULL [13:31:56.559] ..$ rank : int 1 [13:31:56.559] ..$ manual : logi FALSE [13:31:56.559] ..$ dryrun : logi FALSE [13:31:56.559] ..$ quiet : logi FALSE [13:31:56.559] ..$ setup_strategy : chr "parallel" [13:31:56.559] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:56.588] [local output] System call to launch all workers: [13:31:56.588] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef844e27d1b.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20622 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:56.588] [local output] Starting PSOCK main server [13:31:56.593] [local output] Workers launched [13:31:56.593] [local output] Waiting for workers to connect back [13:31:56.594] - [local output] 0 workers out of 1 ready [13:31:56.861] - [local output] 0 workers out of 1 ready [13:31:56.862] - [local output] 1 workers out of 1 ready [13:31:56.862] [local output] Launching of 1 workers completed [13:31:56.863] [local output] Number of nodes in cluster: 1 [13:31:56.863] [local output] Collecting session information from 1 workers [13:31:56.865] [local output] - Worker #1 of 1 [13:31:56.865] [local output] makeClusterPSOCK() ... done [13:31:56.884] [local output] makeClusterPSOCK() ... [13:31:56.889] [local output] Workers: [n = 1] 'localhost' [13:31:56.893] [local output] Base port: 26634 [13:31:56.894] [local output] Getting setup options for 1 cluster nodes ... [13:31:56.894] [local output] - Node #1 of 1 ... [13:31:56.895] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:56.897] [local output] Rscript port: 26634 [13:31:56.898] [local output] Getting setup options for 1 cluster nodes ... done [13:31:56.898] [local output] - Parallel setup requested for some PSOCK nodes [13:31:56.899] [local output] Setting up PSOCK nodes in parallel [13:31:56.899] List of 36 [13:31:56.899] $ worker : chr "localhost" [13:31:56.899] ..- attr(*, "localhost")= logi TRUE [13:31:56.899] $ master : chr "localhost" [13:31:56.899] $ port : int 26634 [13:31:56.899] $ connectTimeout : num 120 [13:31:56.899] $ timeout : num 120 [13:31:56.899] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:56.899] $ homogeneous : logi TRUE [13:31:56.899] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:56.899] $ rscript_envs : NULL [13:31:56.899] $ rscript_libs : NULL [13:31:56.899] $ rscript_startup : NULL [13:31:56.899] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:56.899] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:56.899] $ methods : logi TRUE [13:31:56.899] $ socketOptions : chr "no-delay" [13:31:56.899] $ useXDR : logi FALSE [13:31:56.899] $ outfile : chr "/dev/null" [13:31:56.899] $ renice : int NA [13:31:56.899] $ rshcmd : NULL [13:31:56.899] $ user : chr(0) [13:31:56.899] $ revtunnel : logi FALSE [13:31:56.899] $ rshlogfile : NULL [13:31:56.899] $ rshopts : chr(0) [13:31:56.899] $ rank : int 1 [13:31:56.899] $ manual : logi FALSE [13:31:56.899] $ dryrun : logi FALSE [13:31:56.899] $ quiet : logi FALSE [13:31:56.899] $ setup_strategy : chr "parallel" [13:31:56.899] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:56.899] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef8416c4261.pid" [13:31:56.899] $ rshcmd_label : NULL [13:31:56.899] $ rsh_call : NULL [13:31:56.899] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:56.899] $ localMachine : logi TRUE [13:31:56.899] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:56.899] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:56.899] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:56.899] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:56.899] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:56.899] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:56.899] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:56.899] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:56.899] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:56.899] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:56.899] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:56.899] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:56.899] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:56.899] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:56.899] $ arguments :List of 28 [13:31:56.899] ..$ worker : chr "localhost" [13:31:56.899] ..$ master : NULL [13:31:56.899] ..$ port : int 26634 [13:31:56.899] ..$ connectTimeout : num 120 [13:31:56.899] ..$ timeout : num 120 [13:31:56.899] ..$ rscript : NULL [13:31:56.899] ..$ homogeneous : NULL [13:31:56.899] ..$ rscript_args : NULL [13:31:56.899] ..$ rscript_envs : NULL [13:31:56.899] ..$ rscript_libs : NULL [13:31:56.899] ..$ rscript_startup : NULL [13:31:56.899] ..$ rscript_sh : chr "auto" [13:31:56.899] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:56.899] ..$ methods : logi TRUE [13:31:56.899] ..$ socketOptions : chr "no-delay" [13:31:56.899] ..$ useXDR : logi FALSE [13:31:56.899] ..$ outfile : chr "/dev/null" [13:31:56.899] ..$ renice : int NA [13:31:56.899] ..$ rshcmd : NULL [13:31:56.899] ..$ user : NULL [13:31:56.899] ..$ revtunnel : logi NA [13:31:56.899] ..$ rshlogfile : NULL [13:31:56.899] ..$ rshopts : NULL [13:31:56.899] ..$ rank : int 1 [13:31:56.899] ..$ manual : logi FALSE [13:31:56.899] ..$ dryrun : logi FALSE [13:31:56.899] ..$ quiet : logi FALSE [13:31:56.899] ..$ setup_strategy : chr "parallel" [13:31:56.899] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:56.930] [local output] System call to launch all workers: [13:31:56.930] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef8416c4261.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26634 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:56.930] [local output] Starting PSOCK main server [13:31:56.935] [local output] Workers launched [13:31:56.935] [local output] Waiting for workers to connect back [13:31:56.936] - [local output] 0 workers out of 1 ready [13:31:57.214] - [local output] 0 workers out of 1 ready [13:31:57.215] - [local output] 1 workers out of 1 ready [13:31:57.215] [local output] Launching of 1 workers completed [13:31:57.216] [local output] Number of nodes in cluster: 1 [13:31:57.216] [local output] Collecting session information from 1 workers [13:31:57.217] [local output] - Worker #1 of 1 [13:31:57.218] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - argument 'rscript_startup'") - makeClusterPSOCK() - argument 'rscript_startup' > > for (value in list(NULL, "options(abc = 42L)", quote(options(abc = 42L)))) { + cl <- makeClusterPSOCK(1L, rscript_startup = value) + y <- parallel::clusterEvalQ(cl, getOption("abc", NA_integer_))[[1]] + stopifnot(is.integer(y), length(y) == 1L) + if (!is.null(value)) stopifnot(identical(y, 42L)) + parallel::stopCluster(cl) + } [13:31:57.242] [local output] makeClusterPSOCK() ... [13:31:57.250] [local output] Workers: [n = 1] 'localhost' [13:31:57.255] [local output] Base port: 32436 [13:31:57.255] [local output] Getting setup options for 1 cluster nodes ... [13:31:57.255] [local output] - Node #1 of 1 ... [13:31:57.256] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:57.259] [local output] Rscript port: 32436 [13:31:57.259] [local output] Getting setup options for 1 cluster nodes ... done [13:31:57.259] [local output] - Parallel setup requested for some PSOCK nodes [13:31:57.260] [local output] Setting up PSOCK nodes in parallel [13:31:57.260] List of 36 [13:31:57.260] $ worker : chr "localhost" [13:31:57.260] ..- attr(*, "localhost")= logi TRUE [13:31:57.260] $ master : chr "localhost" [13:31:57.260] $ port : int 32436 [13:31:57.260] $ connectTimeout : num 120 [13:31:57.260] $ timeout : num 120 [13:31:57.260] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:57.260] $ homogeneous : logi TRUE [13:31:57.260] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:57.260] $ rscript_envs : NULL [13:31:57.260] $ rscript_libs : NULL [13:31:57.260] $ rscript_startup : NULL [13:31:57.260] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:57.260] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:57.260] $ methods : logi TRUE [13:31:57.260] $ socketOptions : chr "no-delay" [13:31:57.260] $ useXDR : logi FALSE [13:31:57.260] $ outfile : chr "/dev/null" [13:31:57.260] $ renice : int NA [13:31:57.260] $ rshcmd : NULL [13:31:57.260] $ user : chr(0) [13:31:57.260] $ revtunnel : logi FALSE [13:31:57.260] $ rshlogfile : NULL [13:31:57.260] $ rshopts : chr(0) [13:31:57.260] $ rank : int 1 [13:31:57.260] $ manual : logi FALSE [13:31:57.260] $ dryrun : logi FALSE [13:31:57.260] $ quiet : logi FALSE [13:31:57.260] $ setup_strategy : chr "parallel" [13:31:57.260] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:57.260] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef832ea4c95.pid" [13:31:57.260] $ rshcmd_label : NULL [13:31:57.260] $ rsh_call : NULL [13:31:57.260] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:57.260] $ localMachine : logi TRUE [13:31:57.260] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:57.260] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:57.260] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:57.260] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:57.260] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:57.260] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:57.260] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:57.260] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:57.260] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:57.260] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:57.260] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:57.260] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:57.260] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:57.260] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:57.260] $ arguments :List of 28 [13:31:57.260] ..$ worker : chr "localhost" [13:31:57.260] ..$ master : NULL [13:31:57.260] ..$ port : int 32436 [13:31:57.260] ..$ connectTimeout : num 120 [13:31:57.260] ..$ timeout : num 120 [13:31:57.260] ..$ rscript : NULL [13:31:57.260] ..$ homogeneous : NULL [13:31:57.260] ..$ rscript_args : NULL [13:31:57.260] ..$ rscript_envs : NULL [13:31:57.260] ..$ rscript_libs : NULL [13:31:57.260] ..$ rscript_startup : NULL [13:31:57.260] ..$ rscript_sh : chr "auto" [13:31:57.260] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:57.260] ..$ methods : logi TRUE [13:31:57.260] ..$ socketOptions : chr "no-delay" [13:31:57.260] ..$ useXDR : logi FALSE [13:31:57.260] ..$ outfile : chr "/dev/null" [13:31:57.260] ..$ renice : int NA [13:31:57.260] ..$ rshcmd : NULL [13:31:57.260] ..$ user : NULL [13:31:57.260] ..$ revtunnel : logi NA [13:31:57.260] ..$ rshlogfile : NULL [13:31:57.260] ..$ rshopts : NULL [13:31:57.260] ..$ rank : int 1 [13:31:57.260] ..$ manual : logi FALSE [13:31:57.260] ..$ dryrun : logi FALSE [13:31:57.260] ..$ quiet : logi FALSE [13:31:57.260] ..$ setup_strategy : chr "parallel" [13:31:57.260] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:57.303] [local output] System call to launch all workers: [13:31:57.303] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef832ea4c95.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=32436 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:57.304] [local output] Starting PSOCK main server [13:31:57.310] [local output] Workers launched [13:31:57.311] [local output] Waiting for workers to connect back [13:31:57.311] - [local output] 0 workers out of 1 ready [13:31:57.583] - [local output] 0 workers out of 1 ready [13:31:57.584] - [local output] 1 workers out of 1 ready [13:31:57.584] [local output] Launching of 1 workers completed [13:31:57.585] [local output] Number of nodes in cluster: 1 [13:31:57.585] [local output] Collecting session information from 1 workers [13:31:57.586] [local output] - Worker #1 of 1 [13:31:57.587] [local output] makeClusterPSOCK() ... done [13:31:57.601] [local output] makeClusterPSOCK() ... [13:31:57.606] [local output] Workers: [n = 1] 'localhost' [13:31:57.611] [local output] Base port: 23615 [13:31:57.611] [local output] Getting setup options for 1 cluster nodes ... [13:31:57.612] [local output] - Node #1 of 1 ... [13:31:57.612] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:57.615] [local output] Rscript port: 23615 [13:31:57.616] [local output] Getting setup options for 1 cluster nodes ... done [13:31:57.616] [local output] - Parallel setup requested for some PSOCK nodes [13:31:57.617] [local output] Setting up PSOCK nodes in parallel [13:31:57.617] List of 36 [13:31:57.617] $ worker : chr "localhost" [13:31:57.617] ..- attr(*, "localhost")= logi TRUE [13:31:57.617] $ master : chr "localhost" [13:31:57.617] $ port : int 23615 [13:31:57.617] $ connectTimeout : num 120 [13:31:57.617] $ timeout : num 120 [13:31:57.617] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:57.617] $ homogeneous : logi TRUE [13:31:57.617] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:57.617] $ rscript_envs : NULL [13:31:57.617] $ rscript_libs : NULL [13:31:57.617] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [13:31:57.617] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:57.617] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:57.617] $ methods : logi TRUE [13:31:57.617] $ socketOptions : chr "no-delay" [13:31:57.617] $ useXDR : logi FALSE [13:31:57.617] $ outfile : chr "/dev/null" [13:31:57.617] $ renice : int NA [13:31:57.617] $ rshcmd : NULL [13:31:57.617] $ user : chr(0) [13:31:57.617] $ revtunnel : logi FALSE [13:31:57.617] $ rshlogfile : NULL [13:31:57.617] $ rshopts : chr(0) [13:31:57.617] $ rank : int 1 [13:31:57.617] $ manual : logi FALSE [13:31:57.617] $ dryrun : logi FALSE [13:31:57.617] $ quiet : logi FALSE [13:31:57.617] $ setup_strategy : chr "parallel" [13:31:57.617] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:57.617] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef834e1df7.pid" [13:31:57.617] $ rshcmd_label : NULL [13:31:57.617] $ rsh_call : NULL [13:31:57.617] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:57.617] $ localMachine : logi TRUE [13:31:57.617] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:57.617] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:57.617] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:57.617] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:57.617] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:57.617] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:57.617] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:57.617] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:57.617] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:57.617] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:57.617] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:57.617] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:57.617] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:57.617] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:57.617] $ arguments :List of 28 [13:31:57.617] ..$ worker : chr "localhost" [13:31:57.617] ..$ master : NULL [13:31:57.617] ..$ port : int 23615 [13:31:57.617] ..$ connectTimeout : num 120 [13:31:57.617] ..$ timeout : num 120 [13:31:57.617] ..$ rscript : NULL [13:31:57.617] ..$ homogeneous : NULL [13:31:57.617] ..$ rscript_args : NULL [13:31:57.617] ..$ rscript_envs : NULL [13:31:57.617] ..$ rscript_libs : NULL [13:31:57.617] ..$ rscript_startup : chr "options(abc = 42L)" [13:31:57.617] ..$ rscript_sh : chr "auto" [13:31:57.617] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:57.617] ..$ methods : logi TRUE [13:31:57.617] ..$ socketOptions : chr "no-delay" [13:31:57.617] ..$ useXDR : logi FALSE [13:31:57.617] ..$ outfile : chr "/dev/null" [13:31:57.617] ..$ renice : int NA [13:31:57.617] ..$ rshcmd : NULL [13:31:57.617] ..$ user : NULL [13:31:57.617] ..$ revtunnel : logi NA [13:31:57.617] ..$ rshlogfile : NULL [13:31:57.617] ..$ rshopts : NULL [13:31:57.617] ..$ rank : int 1 [13:31:57.617] ..$ manual : logi FALSE [13:31:57.617] ..$ dryrun : logi FALSE [13:31:57.617] ..$ quiet : logi FALSE [13:31:57.617] ..$ setup_strategy : chr "parallel" [13:31:57.617] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:57.654] [local output] System call to launch all workers: [13:31:57.655] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef834e1df7.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "invisible({options(abc = 42L)})" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=23615 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:57.655] [local output] Starting PSOCK main server [13:31:57.661] [local output] Workers launched [13:31:57.661] [local output] Waiting for workers to connect back [13:31:57.661] - [local output] 0 workers out of 1 ready [13:31:57.953] - [local output] 0 workers out of 1 ready [13:31:57.954] - [local output] 1 workers out of 1 ready [13:31:57.954] [local output] Launching of 1 workers completed [13:31:57.954] [local output] Number of nodes in cluster: 1 [13:31:57.954] [local output] Collecting session information from 1 workers [13:31:57.955] [local output] - Worker #1 of 1 [13:31:57.956] [local output] makeClusterPSOCK() ... done [13:31:57.963] [local output] makeClusterPSOCK() ... [13:31:57.967] [local output] Workers: [n = 1] 'localhost' [13:31:57.971] [local output] Base port: 33148 [13:31:57.971] [local output] Getting setup options for 1 cluster nodes ... [13:31:57.972] [local output] - Node #1 of 1 ... [13:31:57.972] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:57.974] [local output] Rscript port: 33148 [13:31:57.975] [local output] Getting setup options for 1 cluster nodes ... done [13:31:57.975] [local output] - Parallel setup requested for some PSOCK nodes [13:31:57.975] [local output] Setting up PSOCK nodes in parallel [13:31:57.975] List of 36 [13:31:57.975] $ worker : chr "localhost" [13:31:57.975] ..- attr(*, "localhost")= logi TRUE [13:31:57.975] $ master : chr "localhost" [13:31:57.975] $ port : int 33148 [13:31:57.975] $ connectTimeout : num 120 [13:31:57.975] $ timeout : num 120 [13:31:57.975] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:57.975] $ homogeneous : logi TRUE [13:31:57.975] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:57.975] $ rscript_envs : NULL [13:31:57.975] $ rscript_libs : NULL [13:31:57.975] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [13:31:57.975] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:57.975] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:57.975] $ methods : logi TRUE [13:31:57.975] $ socketOptions : chr "no-delay" [13:31:57.975] $ useXDR : logi FALSE [13:31:57.975] $ outfile : chr "/dev/null" [13:31:57.975] $ renice : int NA [13:31:57.975] $ rshcmd : NULL [13:31:57.975] $ user : chr(0) [13:31:57.975] $ revtunnel : logi FALSE [13:31:57.975] $ rshlogfile : NULL [13:31:57.975] $ rshopts : chr(0) [13:31:57.975] $ rank : int 1 [13:31:57.975] $ manual : logi FALSE [13:31:57.975] $ dryrun : logi FALSE [13:31:57.975] $ quiet : logi FALSE [13:31:57.975] $ setup_strategy : chr "parallel" [13:31:57.975] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:57.975] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef831054c.pid" [13:31:57.975] $ rshcmd_label : NULL [13:31:57.975] $ rsh_call : NULL [13:31:57.975] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:57.975] $ localMachine : logi TRUE [13:31:57.975] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:57.975] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:57.975] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:57.975] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:57.975] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:57.975] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:57.975] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:57.975] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:57.975] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:57.975] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:57.975] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:57.975] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:57.975] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:57.975] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:57.975] $ arguments :List of 28 [13:31:57.975] ..$ worker : chr "localhost" [13:31:57.975] ..$ master : NULL [13:31:57.975] ..$ port : int 33148 [13:31:57.975] ..$ connectTimeout : num 120 [13:31:57.975] ..$ timeout : num 120 [13:31:57.975] ..$ rscript : NULL [13:31:57.975] ..$ homogeneous : NULL [13:31:57.975] ..$ rscript_args : NULL [13:31:57.975] ..$ rscript_envs : NULL [13:31:57.975] ..$ rscript_libs : NULL [13:31:57.975] ..$ rscript_startup : language options(abc = 42L) [13:31:57.975] ..$ rscript_sh : chr "auto" [13:31:57.975] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:57.975] ..$ methods : logi TRUE [13:31:57.975] ..$ socketOptions : chr "no-delay" [13:31:57.975] ..$ useXDR : logi FALSE [13:31:57.975] ..$ outfile : chr "/dev/null" [13:31:57.975] ..$ renice : int NA [13:31:57.975] ..$ rshcmd : NULL [13:31:57.975] ..$ user : NULL [13:31:57.975] ..$ revtunnel : logi NA [13:31:57.975] ..$ rshlogfile : NULL [13:31:57.975] ..$ rshopts : NULL [13:31:57.975] ..$ rank : int 1 [13:31:57.975] ..$ manual : logi FALSE [13:31:57.975] ..$ dryrun : logi FALSE [13:31:57.975] ..$ quiet : logi FALSE [13:31:57.975] ..$ setup_strategy : chr "parallel" [13:31:57.975] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:58.002] [local output] System call to launch all workers: [13:31:58.002] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef831054c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "invisible({options(abc = 42L)})" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33148 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:58.003] [local output] Starting PSOCK main server [13:31:58.009] [local output] Workers launched [13:31:58.009] [local output] Waiting for workers to connect back [13:31:58.009] - [local output] 0 workers out of 1 ready [13:31:58.296] - [local output] 0 workers out of 1 ready [13:31:58.297] - [local output] 1 workers out of 1 ready [13:31:58.297] [local output] Launching of 1 workers completed [13:31:58.297] [local output] Number of nodes in cluster: 1 [13:31:58.298] [local output] Collecting session information from 1 workers [13:31:58.299] [local output] - Worker #1 of 1 [13:31:58.299] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - setup_strategy = TRUE/FALSE") - makeClusterPSOCK() - setup_strategy = TRUE/FALSE > > for (setup_strategy in c("sequential", "parallel")) { + dt <- system.time({ + cl <- makeClusterPSOCK(2L, setup_strategy = setup_strategy) + }) + print(dt) + print(cl) + parallel::stopCluster(cl) + } [13:31:58.356] [local output] makeClusterPSOCK() ... [13:31:58.362] [local output] Workers: [n = 2] 'localhost', 'localhost' [13:31:58.366] [local output] Base port: 35413 [13:31:58.367] [local output] Getting setup options for 2 cluster nodes ... [13:31:58.367] [local output] - Node #1 of 2 ... [13:31:58.368] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:58.371] [local output] Rscript port: 35413 [13:31:58.372] [local output] - Node #2 of 2 ... [13:31:58.373] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:58.376] [local output] Rscript port: 35413 [13:31:58.377] [local output] Getting setup options for 2 cluster nodes ... done [13:31:58.377] [local output] Creating node #1 of 2 ... [13:31:58.377] [local output] - setting up node [13:31:58.378] [local output] - attempt #1 of 3 [13:31:58.378] [local output] Starting worker #1 on 'localhost': "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef81a1f3376.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=35413 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [13:31:58.384] [local output] - Exit code of system() call: 0 [13:31:58.385] [local output] Waiting for worker #1 on 'localhost' to connect back [13:31:58.729] [local output] Connection with worker #1 on 'localhost' established [13:31:58.730] [local output] Creating node #1 of 2 ... done [13:31:58.730] [local output] Creating node #2 of 2 ... [13:31:58.730] [local output] - setting up node [13:31:58.731] [local output] - attempt #1 of 3 [13:31:58.731] [local output] Starting worker #2 on 'localhost': "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=2.parallelly.parent=171768.29ef870924289.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=35413 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [13:31:58.738] [local output] - Exit code of system() call: 0 [13:31:58.738] [local output] Waiting for worker #2 on 'localhost' to connect back [13:31:59.010] [local output] Connection with worker #2 on 'localhost' established [13:31:59.010] [local output] Creating node #2 of 2 ... done [13:31:59.010] [local output] Launching of 2 workers completed [13:31:59.011] [local output] Number of nodes in cluster: 2 [13:31:59.011] [local output] Collecting session information from 2 workers [13:31:59.013] [local output] - Worker #1 of 2 [13:31:59.014] [local output] - Worker #2 of 2 [13:31:59.015] [local output] makeClusterPSOCK() ... done user system elapsed 0.03 0.02 0.67 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) [13:31:59.066] [local output] makeClusterPSOCK() ... [13:31:59.072] [local output] Workers: [n = 2] 'localhost', 'localhost' [13:31:59.077] [local output] Base port: 35575 [13:31:59.077] [local output] Getting setup options for 2 cluster nodes ... [13:31:59.077] [local output] - Node #1 of 2 ... [13:31:59.078] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:59.081] [local output] Rscript port: 35575 [13:31:59.081] [local output] - Node #2 of 2 ... [13:31:59.082] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:59.084] [local output] Rscript port: 35575 [13:31:59.085] [local output] Getting setup options for 2 cluster nodes ... done [13:31:59.085] [local output] - Parallel setup requested for some PSOCK nodes [13:31:59.086] [local output] Setting up PSOCK nodes in parallel [13:31:59.086] List of 36 [13:31:59.086] $ worker : chr "localhost" [13:31:59.086] ..- attr(*, "localhost")= logi TRUE [13:31:59.086] $ master : chr "localhost" [13:31:59.086] $ port : int 35575 [13:31:59.086] $ connectTimeout : num 120 [13:31:59.086] $ timeout : num 120 [13:31:59.086] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:59.086] $ homogeneous : logi TRUE [13:31:59.086] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:59.086] $ rscript_envs : NULL [13:31:59.086] $ rscript_libs : NULL [13:31:59.086] $ rscript_startup : NULL [13:31:59.086] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:59.086] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:59.086] $ methods : logi TRUE [13:31:59.086] $ socketOptions : chr "no-delay" [13:31:59.086] $ useXDR : logi FALSE [13:31:59.086] $ outfile : chr "/dev/null" [13:31:59.086] $ renice : int NA [13:31:59.086] $ rshcmd : NULL [13:31:59.086] $ user : chr(0) [13:31:59.086] $ revtunnel : logi FALSE [13:31:59.086] $ rshlogfile : NULL [13:31:59.086] $ rshopts : chr(0) [13:31:59.086] $ rank : int 1 [13:31:59.086] $ manual : logi FALSE [13:31:59.086] $ dryrun : logi FALSE [13:31:59.086] $ quiet : logi FALSE [13:31:59.086] $ setup_strategy : chr "parallel" [13:31:59.086] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:59.086] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef85a75997.pid" [13:31:59.086] $ rshcmd_label : NULL [13:31:59.086] $ rsh_call : NULL [13:31:59.086] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:59.086] $ localMachine : logi TRUE [13:31:59.086] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:59.086] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:59.086] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:59.086] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:59.086] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:59.086] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:59.086] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:59.086] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:59.086] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:59.086] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:59.086] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:59.086] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:59.086] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:59.086] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:59.086] $ arguments :List of 28 [13:31:59.086] ..$ worker : chr "localhost" [13:31:59.086] ..$ master : NULL [13:31:59.086] ..$ port : int 35575 [13:31:59.086] ..$ connectTimeout : num 120 [13:31:59.086] ..$ timeout : num 120 [13:31:59.086] ..$ rscript : NULL [13:31:59.086] ..$ homogeneous : NULL [13:31:59.086] ..$ rscript_args : NULL [13:31:59.086] ..$ rscript_envs : NULL [13:31:59.086] ..$ rscript_libs : NULL [13:31:59.086] ..$ rscript_startup : NULL [13:31:59.086] ..$ rscript_sh : chr "auto" [13:31:59.086] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:59.086] ..$ methods : logi TRUE [13:31:59.086] ..$ socketOptions : chr "no-delay" [13:31:59.086] ..$ useXDR : logi FALSE [13:31:59.086] ..$ outfile : chr "/dev/null" [13:31:59.086] ..$ renice : int NA [13:31:59.086] ..$ rshcmd : NULL [13:31:59.086] ..$ user : NULL [13:31:59.086] ..$ revtunnel : logi NA [13:31:59.086] ..$ rshlogfile : NULL [13:31:59.086] ..$ rshopts : NULL [13:31:59.086] ..$ rank : int 1 [13:31:59.086] ..$ manual : logi FALSE [13:31:59.086] ..$ dryrun : logi FALSE [13:31:59.086] ..$ quiet : logi FALSE [13:31:59.086] ..$ setup_strategy : chr "parallel" [13:31:59.086] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:59.109] [local output] System call to launch all workers: [13:31:59.109] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef85a75997.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=35575 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:59.110] [local output] Starting PSOCK main server [13:31:59.118] [local output] Workers launched [13:31:59.118] [local output] Waiting for workers to connect back [13:31:59.119] - [local output] 0 workers out of 2 ready [13:31:59.414] - [local output] 0 workers out of 2 ready [13:31:59.414] - [local output] 1 workers out of 2 ready [13:31:59.436] - [local output] 1 workers out of 2 ready [13:31:59.437] - [local output] 2 workers out of 2 ready [13:31:59.437] [local output] Launching of 2 workers completed [13:31:59.438] [local output] Number of nodes in cluster: 2 [13:31:59.438] [local output] Collecting session information from 2 workers [13:31:59.440] [local output] - Worker #1 of 2 [13:31:59.441] [local output] - Worker #2 of 2 [13:31:59.442] [local output] makeClusterPSOCK() ... done user system elapsed 0.05 0.00 0.38 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) > > > message("- makeClusterPSOCK() - with and w/out validation") - makeClusterPSOCK() - with and w/out validation > > cl <- makeClusterPSOCK(1L, validate = TRUE) ## default [13:31:59.459] [local output] makeClusterPSOCK() ... [13:31:59.465] [local output] Workers: [n = 1] 'localhost' [13:31:59.470] [local output] Base port: 21940 [13:31:59.470] [local output] Getting setup options for 1 cluster nodes ... [13:31:59.470] [local output] - Node #1 of 1 ... [13:31:59.471] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:59.474] [local output] Rscript port: 21940 [13:31:59.475] [local output] Getting setup options for 1 cluster nodes ... done [13:31:59.475] [local output] - Parallel setup requested for some PSOCK nodes [13:31:59.475] [local output] Setting up PSOCK nodes in parallel [13:31:59.476] List of 36 [13:31:59.476] $ worker : chr "localhost" [13:31:59.476] ..- attr(*, "localhost")= logi TRUE [13:31:59.476] $ master : chr "localhost" [13:31:59.476] $ port : int 21940 [13:31:59.476] $ connectTimeout : num 120 [13:31:59.476] $ timeout : num 120 [13:31:59.476] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:59.476] $ homogeneous : logi TRUE [13:31:59.476] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:59.476] $ rscript_envs : NULL [13:31:59.476] $ rscript_libs : NULL [13:31:59.476] $ rscript_startup : NULL [13:31:59.476] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:59.476] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:59.476] $ methods : logi TRUE [13:31:59.476] $ socketOptions : chr "no-delay" [13:31:59.476] $ useXDR : logi FALSE [13:31:59.476] $ outfile : chr "/dev/null" [13:31:59.476] $ renice : int NA [13:31:59.476] $ rshcmd : NULL [13:31:59.476] $ user : chr(0) [13:31:59.476] $ revtunnel : logi FALSE [13:31:59.476] $ rshlogfile : NULL [13:31:59.476] $ rshopts : chr(0) [13:31:59.476] $ rank : int 1 [13:31:59.476] $ manual : logi FALSE [13:31:59.476] $ dryrun : logi FALSE [13:31:59.476] $ quiet : logi FALSE [13:31:59.476] $ setup_strategy : chr "parallel" [13:31:59.476] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:59.476] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef82d7c395a.pid" [13:31:59.476] $ rshcmd_label : NULL [13:31:59.476] $ rsh_call : NULL [13:31:59.476] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:59.476] $ localMachine : logi TRUE [13:31:59.476] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:59.476] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:59.476] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:59.476] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:59.476] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:59.476] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:59.476] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:59.476] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:59.476] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:59.476] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:59.476] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:59.476] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:59.476] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:59.476] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:59.476] $ arguments :List of 28 [13:31:59.476] ..$ worker : chr "localhost" [13:31:59.476] ..$ master : NULL [13:31:59.476] ..$ port : int 21940 [13:31:59.476] ..$ connectTimeout : num 120 [13:31:59.476] ..$ timeout : num 120 [13:31:59.476] ..$ rscript : NULL [13:31:59.476] ..$ homogeneous : NULL [13:31:59.476] ..$ rscript_args : NULL [13:31:59.476] ..$ rscript_envs : NULL [13:31:59.476] ..$ rscript_libs : NULL [13:31:59.476] ..$ rscript_startup : NULL [13:31:59.476] ..$ rscript_sh : chr "auto" [13:31:59.476] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:59.476] ..$ methods : logi TRUE [13:31:59.476] ..$ socketOptions : chr "no-delay" [13:31:59.476] ..$ useXDR : logi FALSE [13:31:59.476] ..$ outfile : chr "/dev/null" [13:31:59.476] ..$ renice : int NA [13:31:59.476] ..$ rshcmd : NULL [13:31:59.476] ..$ user : NULL [13:31:59.476] ..$ revtunnel : logi NA [13:31:59.476] ..$ rshlogfile : NULL [13:31:59.476] ..$ rshopts : NULL [13:31:59.476] ..$ rank : int 1 [13:31:59.476] ..$ manual : logi FALSE [13:31:59.476] ..$ dryrun : logi FALSE [13:31:59.476] ..$ quiet : logi FALSE [13:31:59.476] ..$ setup_strategy : chr "parallel" [13:31:59.476] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:59.516] [local output] System call to launch all workers: [13:31:59.517] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef82d7c395a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=21940 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:59.517] [local output] Starting PSOCK main server [13:31:59.523] [local output] Workers launched [13:31:59.523] [local output] Waiting for workers to connect back [13:31:59.524] - [local output] 0 workers out of 1 ready [13:31:59.830] - [local output] 0 workers out of 1 ready [13:31:59.830] - [local output] 1 workers out of 1 ready [13:31:59.831] [local output] Launching of 1 workers completed [13:31:59.831] [local output] Number of nodes in cluster: 1 [13:31:59.832] [local output] Collecting session information from 1 workers [13:31:59.833] [local output] - Worker #1 of 1 [13:31:59.833] [local output] makeClusterPSOCK() ... done > node <- cl[[1]] > stopifnot( + is.list(node), + inherits(node, if (useXDR) "SOCKnode" else "SOCK0node"), + "session_info" %in% names(node) + ) > si <- node[["session_info"]] > stopifnot(is.list(si)) > parallel::stopCluster(cl) > > cl <- makeClusterPSOCK(1L, validate = FALSE) [13:31:59.847] [local output] makeClusterPSOCK() ... [13:31:59.853] [local output] Workers: [n = 1] 'localhost' [13:31:59.858] [local output] Base port: 26730 [13:31:59.858] [local output] Getting setup options for 1 cluster nodes ... [13:31:59.858] [local output] - Node #1 of 1 ... [13:31:59.859] [local output] localMachine=TRUE => revtunnel=FALSE [13:31:59.861] [local output] Rscript port: 26730 [13:31:59.862] [local output] Getting setup options for 1 cluster nodes ... done [13:31:59.862] [local output] - Parallel setup requested for some PSOCK nodes [13:31:59.863] [local output] Setting up PSOCK nodes in parallel [13:31:59.863] List of 36 [13:31:59.863] $ worker : chr "localhost" [13:31:59.863] ..- attr(*, "localhost")= logi TRUE [13:31:59.863] $ master : chr "localhost" [13:31:59.863] $ port : int 26730 [13:31:59.863] $ connectTimeout : num 120 [13:31:59.863] $ timeout : num 120 [13:31:59.863] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:31:59.863] $ homogeneous : logi TRUE [13:31:59.863] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:31:59.863] $ rscript_envs : NULL [13:31:59.863] $ rscript_libs : NULL [13:31:59.863] $ rscript_startup : NULL [13:31:59.863] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:31:59.863] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:59.863] $ methods : logi TRUE [13:31:59.863] $ socketOptions : chr "no-delay" [13:31:59.863] $ useXDR : logi FALSE [13:31:59.863] $ outfile : chr "/dev/null" [13:31:59.863] $ renice : int NA [13:31:59.863] $ rshcmd : NULL [13:31:59.863] $ user : chr(0) [13:31:59.863] $ revtunnel : logi FALSE [13:31:59.863] $ rshlogfile : NULL [13:31:59.863] $ rshopts : chr(0) [13:31:59.863] $ rank : int 1 [13:31:59.863] $ manual : logi FALSE [13:31:59.863] $ dryrun : logi FALSE [13:31:59.863] $ quiet : logi FALSE [13:31:59.863] $ setup_strategy : chr "parallel" [13:31:59.863] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:59.863] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef85acb34c4.pid" [13:31:59.863] $ rshcmd_label : NULL [13:31:59.863] $ rsh_call : NULL [13:31:59.863] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:31:59.863] $ localMachine : logi TRUE [13:31:59.863] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:31:59.863] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:31:59.863] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:31:59.863] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:31:59.863] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:31:59.863] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:31:59.863] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:31:59.863] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:31:59.863] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:31:59.863] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:31:59.863] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:31:59.863] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:31:59.863] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:31:59.863] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:31:59.863] $ arguments :List of 28 [13:31:59.863] ..$ worker : chr "localhost" [13:31:59.863] ..$ master : NULL [13:31:59.863] ..$ port : int 26730 [13:31:59.863] ..$ connectTimeout : num 120 [13:31:59.863] ..$ timeout : num 120 [13:31:59.863] ..$ rscript : NULL [13:31:59.863] ..$ homogeneous : NULL [13:31:59.863] ..$ rscript_args : NULL [13:31:59.863] ..$ rscript_envs : NULL [13:31:59.863] ..$ rscript_libs : NULL [13:31:59.863] ..$ rscript_startup : NULL [13:31:59.863] ..$ rscript_sh : chr "auto" [13:31:59.863] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:31:59.863] ..$ methods : logi TRUE [13:31:59.863] ..$ socketOptions : chr "no-delay" [13:31:59.863] ..$ useXDR : logi FALSE [13:31:59.863] ..$ outfile : chr "/dev/null" [13:31:59.863] ..$ renice : int NA [13:31:59.863] ..$ rshcmd : NULL [13:31:59.863] ..$ user : NULL [13:31:59.863] ..$ revtunnel : logi NA [13:31:59.863] ..$ rshlogfile : NULL [13:31:59.863] ..$ rshopts : NULL [13:31:59.863] ..$ rank : int 1 [13:31:59.863] ..$ manual : logi FALSE [13:31:59.863] ..$ dryrun : logi FALSE [13:31:59.863] ..$ quiet : logi FALSE [13:31:59.863] ..$ setup_strategy : chr "parallel" [13:31:59.863] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:31:59.897] [local output] System call to launch all workers: [13:31:59.897] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef85acb34c4.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26730 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:31:59.897] [local output] Starting PSOCK main server [13:31:59.902] [local output] Workers launched [13:31:59.903] [local output] Waiting for workers to connect back [13:31:59.903] - [local output] 0 workers out of 1 ready [13:32:00.182] - [local output] 0 workers out of 1 ready [13:32:00.182] - [local output] 1 workers out of 1 ready [13:32:00.183] [local output] Launching of 1 workers completed [13:32:00.183] [local output] Number of nodes in cluster: 1 [13:32:00.183] [local output] makeClusterPSOCK() ... done > node <- cl[[1]] > stopifnot( + is.list(node), + inherits(node, if (useXDR) "SOCKnode" else "SOCK0node"), + ! "session_info" %in% names(node) + ) > parallel::stopCluster(cl) > > > message("- makeClusterPSOCK() - w/out 'parallelly' on worker") - makeClusterPSOCK() - w/out 'parallelly' on worker > > ovalue <- Sys.getenv("R_LIBS_USER") > Sys.setenv(R_LIBS_USER = tempdir()) > cl <- makeClusterPSOCK(1L, outfile = "") [13:32:00.196] [local output] makeClusterPSOCK() ... [13:32:00.201] [local output] Workers: [n = 1] 'localhost' [13:32:00.205] [local output] Base port: 34111 [13:32:00.206] [local output] Getting setup options for 1 cluster nodes ... [13:32:00.206] [local output] - Node #1 of 1 ... [13:32:00.207] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:00.209] [local output] Rscript port: 34111 [13:32:00.209] [local output] Getting setup options for 1 cluster nodes ... done [13:32:00.209] [local output] - Parallel setup requested for some PSOCK nodes [13:32:00.210] [local output] Setting up PSOCK nodes in parallel [13:32:00.210] List of 36 [13:32:00.210] $ worker : chr "localhost" [13:32:00.210] ..- attr(*, "localhost")= logi TRUE [13:32:00.210] $ master : chr "localhost" [13:32:00.210] $ port : int 34111 [13:32:00.210] $ connectTimeout : num 120 [13:32:00.210] $ timeout : num 120 [13:32:00.210] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:32:00.210] $ homogeneous : logi TRUE [13:32:00.210] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:32:00.210] $ rscript_envs : NULL [13:32:00.210] $ rscript_libs : NULL [13:32:00.210] $ rscript_startup : NULL [13:32:00.210] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:00.210] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:00.210] $ methods : logi TRUE [13:32:00.210] $ socketOptions : chr "no-delay" [13:32:00.210] $ useXDR : logi FALSE [13:32:00.210] $ outfile : chr "" [13:32:00.210] $ renice : int NA [13:32:00.210] $ rshcmd : NULL [13:32:00.210] $ user : chr(0) [13:32:00.210] $ revtunnel : logi FALSE [13:32:00.210] $ rshlogfile : NULL [13:32:00.210] $ rshopts : chr(0) [13:32:00.210] $ rank : int 1 [13:32:00.210] $ manual : logi FALSE [13:32:00.210] $ dryrun : logi FALSE [13:32:00.210] $ quiet : logi FALSE [13:32:00.210] $ setup_strategy : chr "parallel" [13:32:00.210] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:32:00.210] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef861737c81.pid" [13:32:00.210] $ rshcmd_label : NULL [13:32:00.210] $ rsh_call : NULL [13:32:00.210] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:32:00.210] $ localMachine : logi TRUE [13:32:00.210] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:00.210] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:00.210] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:00.210] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:00.210] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:00.210] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:00.210] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:00.210] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:00.210] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:00.210] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:00.210] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:00.210] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:00.210] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:00.210] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:00.210] $ arguments :List of 28 [13:32:00.210] ..$ worker : chr "localhost" [13:32:00.210] ..$ master : NULL [13:32:00.210] ..$ port : int 34111 [13:32:00.210] ..$ connectTimeout : num 120 [13:32:00.210] ..$ timeout : num 120 [13:32:00.210] ..$ rscript : NULL [13:32:00.210] ..$ homogeneous : NULL [13:32:00.210] ..$ rscript_args : NULL [13:32:00.210] ..$ rscript_envs : NULL [13:32:00.210] ..$ rscript_libs : NULL [13:32:00.210] ..$ rscript_startup : NULL [13:32:00.210] ..$ rscript_sh : chr "auto" [13:32:00.210] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:00.210] ..$ methods : logi TRUE [13:32:00.210] ..$ socketOptions : chr "no-delay" [13:32:00.210] ..$ useXDR : logi FALSE [13:32:00.210] ..$ outfile : chr "" [13:32:00.210] ..$ renice : int NA [13:32:00.210] ..$ rshcmd : NULL [13:32:00.210] ..$ user : NULL [13:32:00.210] ..$ revtunnel : logi NA [13:32:00.210] ..$ rshlogfile : NULL [13:32:00.210] ..$ rshopts : NULL [13:32:00.210] ..$ rank : int 1 [13:32:00.210] ..$ manual : logi FALSE [13:32:00.210] ..$ dryrun : logi FALSE [13:32:00.210] ..$ quiet : logi FALSE [13:32:00.210] ..$ setup_strategy : chr "parallel" [13:32:00.210] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:00.233] [local output] System call to launch all workers: [13:32:00.233] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef861737c81.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34111 OUT= TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:00.233] [local output] Starting PSOCK main server [13:32:00.238] [local output] Workers launched [13:32:00.238] [local output] Waiting for workers to connect back [13:32:00.239] - [local output] 0 workers out of 1 ready starting worker pid=45712 on localhost:34111 at 13:32:00.525 [13:32:00.536] - [local output] 0 workers out of 1 ready [13:32:00.537] - [local output] 1 workers out of 1 ready [13:32:00.537] [local output] Launching of 1 workers completed [13:32:00.537] [local output] Number of nodes in cluster: 1 [13:32:00.538] [local output] Collecting session information from 1 workers [13:32:00.539] [local output] - Worker #1 of 1 [13:32:00.539] [local output] makeClusterPSOCK() ... done > print(cl) 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) > parallel::stopCluster(cl) > Sys.setenv(R_LIBS_USER = ovalue) > > > message("- makeClusterPSOCK() - assert 'parallelly' is not loaded") - makeClusterPSOCK() - assert 'parallelly' is not loaded > > cl <- makeClusterPSOCK(1L) [13:32:00.551] [local output] makeClusterPSOCK() ... [13:32:00.555] [local output] Workers: [n = 1] 'localhost' [13:32:00.559] [local output] Base port: 37992 [13:32:00.559] [local output] Getting setup options for 1 cluster nodes ... [13:32:00.559] [local output] - Node #1 of 1 ... [13:32:00.560] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:00.562] [local output] Rscript port: 37992 [13:32:00.562] [local output] Getting setup options for 1 cluster nodes ... done [13:32:00.563] [local output] - Parallel setup requested for some PSOCK nodes [13:32:00.563] [local output] Setting up PSOCK nodes in parallel [13:32:00.563] List of 36 [13:32:00.563] $ worker : chr "localhost" [13:32:00.563] ..- attr(*, "localhost")= logi TRUE [13:32:00.563] $ master : chr "localhost" [13:32:00.563] $ port : int 37992 [13:32:00.563] $ connectTimeout : num 120 [13:32:00.563] $ timeout : num 120 [13:32:00.563] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:32:00.563] $ homogeneous : logi TRUE [13:32:00.563] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:32:00.563] $ rscript_envs : NULL [13:32:00.563] $ rscript_libs : NULL [13:32:00.563] $ rscript_startup : NULL [13:32:00.563] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:00.563] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:00.563] $ methods : logi TRUE [13:32:00.563] $ socketOptions : chr "no-delay" [13:32:00.563] $ useXDR : logi FALSE [13:32:00.563] $ outfile : chr "/dev/null" [13:32:00.563] $ renice : int NA [13:32:00.563] $ rshcmd : NULL [13:32:00.563] $ user : chr(0) [13:32:00.563] $ revtunnel : logi FALSE [13:32:00.563] $ rshlogfile : NULL [13:32:00.563] $ rshopts : chr(0) [13:32:00.563] $ rank : int 1 [13:32:00.563] $ manual : logi FALSE [13:32:00.563] $ dryrun : logi FALSE [13:32:00.563] $ quiet : logi FALSE [13:32:00.563] $ setup_strategy : chr "parallel" [13:32:00.563] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:32:00.563] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef85ddb686a.pid" [13:32:00.563] $ rshcmd_label : NULL [13:32:00.563] $ rsh_call : NULL [13:32:00.563] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:32:00.563] $ localMachine : logi TRUE [13:32:00.563] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:00.563] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:00.563] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:00.563] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:00.563] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:00.563] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:00.563] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:00.563] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:00.563] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:00.563] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:00.563] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:00.563] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:00.563] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:00.563] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:00.563] $ arguments :List of 28 [13:32:00.563] ..$ worker : chr "localhost" [13:32:00.563] ..$ master : NULL [13:32:00.563] ..$ port : int 37992 [13:32:00.563] ..$ connectTimeout : num 120 [13:32:00.563] ..$ timeout : num 120 [13:32:00.563] ..$ rscript : NULL [13:32:00.563] ..$ homogeneous : NULL [13:32:00.563] ..$ rscript_args : NULL [13:32:00.563] ..$ rscript_envs : NULL [13:32:00.563] ..$ rscript_libs : NULL [13:32:00.563] ..$ rscript_startup : NULL [13:32:00.563] ..$ rscript_sh : chr "auto" [13:32:00.563] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:00.563] ..$ methods : logi TRUE [13:32:00.563] ..$ socketOptions : chr "no-delay" [13:32:00.563] ..$ useXDR : logi FALSE [13:32:00.563] ..$ outfile : chr "/dev/null" [13:32:00.563] ..$ renice : int NA [13:32:00.563] ..$ rshcmd : NULL [13:32:00.563] ..$ user : NULL [13:32:00.563] ..$ revtunnel : logi NA [13:32:00.563] ..$ rshlogfile : NULL [13:32:00.563] ..$ rshopts : NULL [13:32:00.563] ..$ rank : int 1 [13:32:00.563] ..$ manual : logi FALSE [13:32:00.563] ..$ dryrun : logi FALSE [13:32:00.563] ..$ quiet : logi FALSE [13:32:00.563] ..$ setup_strategy : chr "parallel" [13:32:00.563] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:00.598] [local output] System call to launch all workers: [13:32:00.598] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef85ddb686a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=37992 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:00.599] [local output] Starting PSOCK main server [13:32:00.604] [local output] Workers launched [13:32:00.605] [local output] Waiting for workers to connect back [13:32:00.605] - [local output] 0 workers out of 1 ready [13:32:00.904] - [local output] 0 workers out of 1 ready [13:32:00.905] - [local output] 1 workers out of 1 ready [13:32:00.906] [local output] Launching of 1 workers completed [13:32:00.906] [local output] Number of nodes in cluster: 1 [13:32:00.907] [local output] Collecting session information from 1 workers [13:32:00.908] [local output] - Worker #1 of 1 [13:32:00.908] [local output] makeClusterPSOCK() ... done > ns <- parallel::clusterCall(cl, function() { loadedNamespaces() }) > print(ns) [[1]] [1] "compiler" "graphics" "parallel" "utils" "grDevices" "stats" [7] "datasets" "methods" "base" > stopifnot(!is.element("parallelly", ns)) > parallel::stopCluster(cl) > > > message("- makeClusterPSOCK() - launch via the R executable") - makeClusterPSOCK() - launch via the R executable > > if (.Platform$OS.type == "windows") { + ## R and R.exe fails on MS Windows, cf. R-devel thread "MS Windows: R does + ## not escape quotes in CLI options the same way as Rterm and Rscript" + ## on 2021-12-15. + rscripts <- file.path(R.home("bin"), c("Rterm", "Rterm.exe")) + } else { + rscripts <- file.path(R.home("bin"), "R") + } > > for (rscript in rscripts) { + message(" Launcher: ", sQuote(rscript)) + rscript_args <- c("--no-echo", "--no-restore", "*", "--args") + cl <- tryCatch({ + makeClusterPSOCK(1L, rscript = rscript, rscript_args = rscript_args) + }, warning = identity) + stopifnot(inherits(cl, "cluster")) + parallel::stopCluster(cl) + } Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [13:32:00.924] [local output] makeClusterPSOCK() ... [13:32:00.928] [local output] Workers: [n = 1] 'localhost' [13:32:00.932] [local output] Base port: 31929 [13:32:00.932] [local output] Getting setup options for 1 cluster nodes ... [13:32:00.932] [local output] - Node #1 of 1 ... [13:32:00.933] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:00.934] Testing if worker's PID can be inferred: '"D:\RCompile\recent\R\bin\x64\Rterm.exe" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84a2d4c12.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84a2d4c12.pid\")"' [13:32:01.373] - Possible to infer worker's PID: TRUE [13:32:01.374] [local output] Rscript port: 31929 [13:32:01.375] [local output] Getting setup options for 1 cluster nodes ... done [13:32:01.375] [local output] - Parallel setup requested for some PSOCK nodes [13:32:01.376] [local output] Setting up PSOCK nodes in parallel [13:32:01.376] List of 36 [13:32:01.376] $ worker : chr "localhost" [13:32:01.376] ..- attr(*, "localhost")= logi TRUE [13:32:01.376] $ master : chr "localhost" [13:32:01.376] $ port : int 31929 [13:32:01.376] $ connectTimeout : num 120 [13:32:01.376] $ timeout : num 120 [13:32:01.376] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [13:32:01.376] $ homogeneous : logi TRUE [13:32:01.376] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [13:32:01.376] $ rscript_envs : NULL [13:32:01.376] $ rscript_libs : NULL [13:32:01.376] $ rscript_startup : NULL [13:32:01.376] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:01.376] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:01.376] $ methods : logi TRUE [13:32:01.376] $ socketOptions : chr "no-delay" [13:32:01.376] $ useXDR : logi FALSE [13:32:01.376] $ outfile : chr "/dev/null" [13:32:01.376] $ renice : int NA [13:32:01.376] $ rshcmd : NULL [13:32:01.376] $ user : chr(0) [13:32:01.376] $ revtunnel : logi FALSE [13:32:01.376] $ rshlogfile : NULL [13:32:01.376] $ rshopts : chr(0) [13:32:01.376] $ rank : int 1 [13:32:01.376] $ manual : logi FALSE [13:32:01.376] $ dryrun : logi FALSE [13:32:01.376] $ quiet : logi FALSE [13:32:01.376] $ setup_strategy : chr "parallel" [13:32:01.376] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [13:32:01.376] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84a2d4c12.pid" [13:32:01.376] $ rshcmd_label : NULL [13:32:01.376] $ rsh_call : NULL [13:32:01.376] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [13:32:01.376] $ localMachine : logi TRUE [13:32:01.376] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:01.376] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:01.376] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:01.376] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:01.376] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:01.376] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:01.376] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:01.376] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:01.376] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:01.376] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:01.376] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:01.376] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:01.376] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:01.376] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:01.376] $ arguments :List of 28 [13:32:01.376] ..$ worker : chr "localhost" [13:32:01.376] ..$ master : NULL [13:32:01.376] ..$ port : int 31929 [13:32:01.376] ..$ connectTimeout : num 120 [13:32:01.376] ..$ timeout : num 120 [13:32:01.376] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [13:32:01.376] ..$ homogeneous : NULL [13:32:01.376] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [13:32:01.376] ..$ rscript_envs : NULL [13:32:01.376] ..$ rscript_libs : NULL [13:32:01.376] ..$ rscript_startup : NULL [13:32:01.376] ..$ rscript_sh : chr "auto" [13:32:01.376] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:01.376] ..$ methods : logi TRUE [13:32:01.376] ..$ socketOptions : chr "no-delay" [13:32:01.376] ..$ useXDR : logi FALSE [13:32:01.376] ..$ outfile : chr "/dev/null" [13:32:01.376] ..$ renice : int NA [13:32:01.376] ..$ rshcmd : NULL [13:32:01.376] ..$ user : NULL [13:32:01.376] ..$ revtunnel : logi NA [13:32:01.376] ..$ rshlogfile : NULL [13:32:01.376] ..$ rshopts : NULL [13:32:01.376] ..$ rank : int 1 [13:32:01.376] ..$ manual : logi FALSE [13:32:01.376] ..$ dryrun : logi FALSE [13:32:01.376] ..$ quiet : logi FALSE [13:32:01.376] ..$ setup_strategy : chr "parallel" [13:32:01.376] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:01.410] [local output] System call to launch all workers: [13:32:01.411] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef84a2d4c12.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=31929 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:01.411] [local output] Starting PSOCK main server [13:32:01.417] [local output] Workers launched [13:32:01.417] [local output] Waiting for workers to connect back [13:32:01.417] - [local output] 0 workers out of 1 ready [13:32:01.728] - [local output] 0 workers out of 1 ready [13:32:01.729] - [local output] 1 workers out of 1 ready [13:32:01.729] [local output] Launching of 1 workers completed [13:32:01.730] [local output] Number of nodes in cluster: 1 [13:32:01.730] [local output] Collecting session information from 1 workers [13:32:01.731] [local output] - Worker #1 of 1 [13:32:01.732] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [13:32:01.740] [local output] makeClusterPSOCK() ... [13:32:01.745] [local output] Workers: [n = 1] 'localhost' [13:32:01.750] [local output] Base port: 30306 [13:32:01.750] [local output] Getting setup options for 1 cluster nodes ... [13:32:01.750] [local output] - Node #1 of 1 ... [13:32:01.751] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:01.753] [local output] Rscript port: 30306 [13:32:01.754] [local output] Getting setup options for 1 cluster nodes ... done [13:32:01.754] [local output] - Parallel setup requested for some PSOCK nodes [13:32:01.755] [local output] Setting up PSOCK nodes in parallel [13:32:01.755] List of 36 [13:32:01.755] $ worker : chr "localhost" [13:32:01.755] ..- attr(*, "localhost")= logi TRUE [13:32:01.755] $ master : chr "localhost" [13:32:01.755] $ port : int 30306 [13:32:01.755] $ connectTimeout : num 120 [13:32:01.755] $ timeout : num 120 [13:32:01.755] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [13:32:01.755] $ homogeneous : logi TRUE [13:32:01.755] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [13:32:01.755] $ rscript_envs : NULL [13:32:01.755] $ rscript_libs : NULL [13:32:01.755] $ rscript_startup : NULL [13:32:01.755] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:01.755] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:01.755] $ methods : logi TRUE [13:32:01.755] $ socketOptions : chr "no-delay" [13:32:01.755] $ useXDR : logi FALSE [13:32:01.755] $ outfile : chr "/dev/null" [13:32:01.755] $ renice : int NA [13:32:01.755] $ rshcmd : NULL [13:32:01.755] $ user : chr(0) [13:32:01.755] $ revtunnel : logi FALSE [13:32:01.755] $ rshlogfile : NULL [13:32:01.755] $ rshopts : chr(0) [13:32:01.755] $ rank : int 1 [13:32:01.755] $ manual : logi FALSE [13:32:01.755] $ dryrun : logi FALSE [13:32:01.755] $ quiet : logi FALSE [13:32:01.755] $ setup_strategy : chr "parallel" [13:32:01.755] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [13:32:01.755] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef86eb7359f.pid" [13:32:01.755] $ rshcmd_label : NULL [13:32:01.755] $ rsh_call : NULL [13:32:01.755] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [13:32:01.755] $ localMachine : logi TRUE [13:32:01.755] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:01.755] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:01.755] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:01.755] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:01.755] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:01.755] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:01.755] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:01.755] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:01.755] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:01.755] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:01.755] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:01.755] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:01.755] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:01.755] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:01.755] $ arguments :List of 28 [13:32:01.755] ..$ worker : chr "localhost" [13:32:01.755] ..$ master : NULL [13:32:01.755] ..$ port : int 30306 [13:32:01.755] ..$ connectTimeout : num 120 [13:32:01.755] ..$ timeout : num 120 [13:32:01.755] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [13:32:01.755] ..$ homogeneous : NULL [13:32:01.755] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [13:32:01.755] ..$ rscript_envs : NULL [13:32:01.755] ..$ rscript_libs : NULL [13:32:01.755] ..$ rscript_startup : NULL [13:32:01.755] ..$ rscript_sh : chr "auto" [13:32:01.755] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:01.755] ..$ methods : logi TRUE [13:32:01.755] ..$ socketOptions : chr "no-delay" [13:32:01.755] ..$ useXDR : logi FALSE [13:32:01.755] ..$ outfile : chr "/dev/null" [13:32:01.755] ..$ renice : int NA [13:32:01.755] ..$ rshcmd : NULL [13:32:01.755] ..$ user : NULL [13:32:01.755] ..$ revtunnel : logi NA [13:32:01.755] ..$ rshlogfile : NULL [13:32:01.755] ..$ rshopts : NULL [13:32:01.755] ..$ rank : int 1 [13:32:01.755] ..$ manual : logi FALSE [13:32:01.755] ..$ dryrun : logi FALSE [13:32:01.755] ..$ quiet : logi FALSE [13:32:01.755] ..$ setup_strategy : chr "parallel" [13:32:01.755] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:01.790] [local output] System call to launch all workers: [13:32:01.791] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef86eb7359f.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=30306 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:01.791] [local output] Starting PSOCK main server [13:32:01.797] [local output] Workers launched [13:32:01.797] [local output] Waiting for workers to connect back [13:32:01.798] - [local output] 0 workers out of 1 ready [13:32:02.109] - [local output] 0 workers out of 1 ready [13:32:02.110] - [local output] 1 workers out of 1 ready [13:32:02.110] [local output] Launching of 1 workers completed [13:32:02.110] [local output] Number of nodes in cluster: 1 [13:32:02.111] [local output] Collecting session information from 1 workers [13:32:02.112] [local output] - Worker #1 of 1 [13:32:02.113] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - default packages") - makeClusterPSOCK() - default packages > > if (.Platform$OS.type == "windows") { + ## R and R.exe fails on MS Windows, cf. R-devel thread "MS Windows: R does + ## not escape quotes in CLI options the same way as Rterm and Rscript" + ## on 2021-12-15. + rscripts <- file.path(R.home("bin"), c("Rscript", "Rterm", "Rterm.exe")) + } else { + rscripts <- file.path(R.home("bin"), c("Rscript", "R")) + } > default_packages <- c("utils", "tools") > for (rscript in rscripts) { + message(" Launcher: ", sQuote(rscript)) + if (tools::file_path_sans_ext(basename(rscript)) %in% c("R", "Rterm")) { + rscript_args <- c("--no-echo", "--no-restore", "*", "--args") + } else { + rscript_args <- NULL + } + cl <- tryCatch({ + makeClusterPSOCK(1L, rscript = rscript, rscript_args = rscript_args, default_packages = default_packages) + }, warning = identity) + stopifnot(inherits(cl, "cluster")) + pkgs <- parallel::clusterEvalQ(cl, { getOption("defaultPackages") })[[1]] + stopifnot(identical(pkgs, default_packages)) + parallel::stopCluster(cl) + } Launcher: 'D:/RCompile/recent/R/bin/x64/Rscript' [13:32:02.153] [local output] makeClusterPSOCK() ... [13:32:02.158] [local output] Workers: [n = 1] 'localhost' [13:32:02.162] [local output] Base port: 27621 [13:32:02.163] [local output] Getting setup options for 1 cluster nodes ... [13:32:02.163] [local output] - Node #1 of 1 ... [13:32:02.164] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:02.165] Testing if worker's PID can be inferred: '"D:\RCompile\recent\R\bin\x64\Rscript.exe" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef83192ed9.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef83192ed9.pid\")"' [13:32:02.388] - Possible to infer worker's PID: TRUE [13:32:02.390] [local output] Rscript port: 27621 [13:32:02.390] [local output] Getting setup options for 1 cluster nodes ... done [13:32:02.391] [local output] - Parallel setup requested for some PSOCK nodes [13:32:02.391] [local output] Setting up PSOCK nodes in parallel [13:32:02.392] List of 36 [13:32:02.392] $ worker : chr "localhost" [13:32:02.392] ..- attr(*, "localhost")= logi TRUE [13:32:02.392] $ master : chr "localhost" [13:32:02.392] $ port : int 27621 [13:32:02.392] $ connectTimeout : num 120 [13:32:02.392] $ timeout : num 120 [13:32:02.392] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [13:32:02.392] $ homogeneous : logi TRUE [13:32:02.392] $ rscript_args : chr "--default-packages=utils,tools -e \"#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN\" -e \"try(suppressWarnings("| __truncated__ [13:32:02.392] $ rscript_envs : NULL [13:32:02.392] $ rscript_libs : NULL [13:32:02.392] $ rscript_startup : NULL [13:32:02.392] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:02.392] $ default_packages: chr [1:2] "utils" "tools" [13:32:02.392] $ methods : logi TRUE [13:32:02.392] $ socketOptions : chr "no-delay" [13:32:02.392] $ useXDR : logi FALSE [13:32:02.392] $ outfile : chr "/dev/null" [13:32:02.392] $ renice : int NA [13:32:02.392] $ rshcmd : NULL [13:32:02.392] $ user : chr(0) [13:32:02.392] $ revtunnel : logi FALSE [13:32:02.392] $ rshlogfile : NULL [13:32:02.392] $ rshopts : chr(0) [13:32:02.392] $ rank : int 1 [13:32:02.392] $ manual : logi FALSE [13:32:02.392] $ dryrun : logi FALSE [13:32:02.392] $ quiet : logi FALSE [13:32:02.392] $ setup_strategy : chr "parallel" [13:32:02.392] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [13:32:02.392] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef83192ed9.pid" [13:32:02.392] $ rshcmd_label : NULL [13:32:02.392] $ rsh_call : NULL [13:32:02.392] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [13:32:02.392] $ localMachine : logi TRUE [13:32:02.392] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:02.392] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:02.392] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:02.392] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:02.392] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:02.392] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:02.392] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:02.392] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:02.392] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:02.392] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:02.392] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:02.392] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:02.392] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:02.392] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:02.392] $ arguments :List of 28 [13:32:02.392] ..$ worker : chr "localhost" [13:32:02.392] ..$ master : NULL [13:32:02.392] ..$ port : int 27621 [13:32:02.392] ..$ connectTimeout : num 120 [13:32:02.392] ..$ timeout : num 120 [13:32:02.392] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [13:32:02.392] ..$ homogeneous : NULL [13:32:02.392] ..$ rscript_args : NULL [13:32:02.392] ..$ rscript_envs : NULL [13:32:02.392] ..$ rscript_libs : NULL [13:32:02.392] ..$ rscript_startup : NULL [13:32:02.392] ..$ rscript_sh : chr "auto" [13:32:02.392] ..$ default_packages: chr [1:2] "utils" "tools" [13:32:02.392] ..$ methods : logi TRUE [13:32:02.392] ..$ socketOptions : chr "no-delay" [13:32:02.392] ..$ useXDR : logi FALSE [13:32:02.392] ..$ outfile : chr "/dev/null" [13:32:02.392] ..$ renice : int NA [13:32:02.392] ..$ rshcmd : NULL [13:32:02.392] ..$ user : NULL [13:32:02.392] ..$ revtunnel : logi NA [13:32:02.392] ..$ rshlogfile : NULL [13:32:02.392] ..$ rshopts : NULL [13:32:02.392] ..$ rank : int 1 [13:32:02.392] ..$ manual : logi FALSE [13:32:02.392] ..$ dryrun : logi FALSE [13:32:02.392] ..$ quiet : logi FALSE [13:32:02.392] ..$ setup_strategy : chr "parallel" [13:32:02.392] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:02.425] [local output] System call to launch all workers: [13:32:02.425] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=utils,tools -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef83192ed9.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=27621 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:02.426] [local output] Starting PSOCK main server [13:32:02.432] [local output] Workers launched [13:32:02.432] [local output] Waiting for workers to connect back [13:32:02.432] - [local output] 0 workers out of 1 ready [13:32:02.592] - [local output] 0 workers out of 1 ready [13:32:02.592] - [local output] 1 workers out of 1 ready [13:32:02.593] [local output] Launching of 1 workers completed [13:32:02.593] [local output] Number of nodes in cluster: 1 [13:32:02.593] [local output] Collecting session information from 1 workers [13:32:02.595] [local output] - Worker #1 of 1 [13:32:02.596] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [13:32:02.613] [local output] makeClusterPSOCK() ... [13:32:02.619] [local output] Workers: [n = 1] 'localhost' [13:32:02.624] [local output] Base port: 33792 [13:32:02.625] [local output] Getting setup options for 1 cluster nodes ... [13:32:02.625] [local output] - Node #1 of 1 ... [13:32:02.626] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:02.628] [local output] Rscript port: 33792 [13:32:02.629] [local output] Getting setup options for 1 cluster nodes ... done [13:32:02.629] [local output] - Parallel setup requested for some PSOCK nodes [13:32:02.630] [local output] Setting up PSOCK nodes in parallel [13:32:02.630] List of 36 [13:32:02.630] $ worker : chr "localhost" [13:32:02.630] ..- attr(*, "localhost")= logi TRUE [13:32:02.630] $ master : chr "localhost" [13:32:02.630] $ port : int 33792 [13:32:02.630] $ connectTimeout : num 120 [13:32:02.630] $ timeout : num 120 [13:32:02.630] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [13:32:02.630] $ homogeneous : logi TRUE [13:32:02.630] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN\" -e "| __truncated__ [13:32:02.630] $ rscript_envs : NULL [13:32:02.630] $ rscript_libs : NULL [13:32:02.630] $ rscript_startup : NULL [13:32:02.630] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:02.630] $ default_packages: chr [1:2] "utils" "tools" [13:32:02.630] $ methods : logi TRUE [13:32:02.630] $ socketOptions : chr "no-delay" [13:32:02.630] $ useXDR : logi FALSE [13:32:02.630] $ outfile : chr "/dev/null" [13:32:02.630] $ renice : int NA [13:32:02.630] $ rshcmd : NULL [13:32:02.630] $ user : chr(0) [13:32:02.630] $ revtunnel : logi FALSE [13:32:02.630] $ rshlogfile : NULL [13:32:02.630] $ rshopts : chr(0) [13:32:02.630] $ rank : int 1 [13:32:02.630] $ manual : logi FALSE [13:32:02.630] $ dryrun : logi FALSE [13:32:02.630] $ quiet : logi FALSE [13:32:02.630] $ setup_strategy : chr "parallel" [13:32:02.630] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [13:32:02.630] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef89815481.pid" [13:32:02.630] $ rshcmd_label : NULL [13:32:02.630] $ rsh_call : NULL [13:32:02.630] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [13:32:02.630] $ localMachine : logi TRUE [13:32:02.630] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:02.630] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:02.630] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:02.630] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:02.630] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:02.630] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:02.630] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:02.630] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:02.630] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:02.630] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:02.630] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:02.630] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:02.630] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:02.630] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:02.630] $ arguments :List of 28 [13:32:02.630] ..$ worker : chr "localhost" [13:32:02.630] ..$ master : NULL [13:32:02.630] ..$ port : int 33792 [13:32:02.630] ..$ connectTimeout : num 120 [13:32:02.630] ..$ timeout : num 120 [13:32:02.630] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [13:32:02.630] ..$ homogeneous : NULL [13:32:02.630] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [13:32:02.630] ..$ rscript_envs : NULL [13:32:02.630] ..$ rscript_libs : NULL [13:32:02.630] ..$ rscript_startup : NULL [13:32:02.630] ..$ rscript_sh : chr "auto" [13:32:02.630] ..$ default_packages: chr [1:2] "utils" "tools" [13:32:02.630] ..$ methods : logi TRUE [13:32:02.630] ..$ socketOptions : chr "no-delay" [13:32:02.630] ..$ useXDR : logi FALSE [13:32:02.630] ..$ outfile : chr "/dev/null" [13:32:02.630] ..$ renice : int NA [13:32:02.630] ..$ rshcmd : NULL [13:32:02.630] ..$ user : NULL [13:32:02.630] ..$ revtunnel : logi NA [13:32:02.630] ..$ rshlogfile : NULL [13:32:02.630] ..$ rshopts : NULL [13:32:02.630] ..$ rank : int 1 [13:32:02.630] ..$ manual : logi FALSE [13:32:02.630] ..$ dryrun : logi FALSE [13:32:02.630] ..$ quiet : logi FALSE [13:32:02.630] ..$ setup_strategy : chr "parallel" [13:32:02.630] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:02.666] [local output] System call to launch all workers: [13:32:02.666] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef89815481.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=33792 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:02.666] [local output] Starting PSOCK main server [13:32:02.673] [local output] Workers launched [13:32:02.674] [local output] Waiting for workers to connect back [13:32:02.674] - [local output] 0 workers out of 1 ready [13:32:02.846] - [local output] 0 workers out of 1 ready [13:32:02.847] - [local output] 1 workers out of 1 ready [13:32:02.847] [local output] Launching of 1 workers completed [13:32:02.847] [local output] Number of nodes in cluster: 1 [13:32:02.848] [local output] Collecting session information from 1 workers [13:32:02.849] [local output] - Worker #1 of 1 [13:32:02.850] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [13:32:02.860] [local output] makeClusterPSOCK() ... [13:32:02.868] [local output] Workers: [n = 1] 'localhost' [13:32:02.872] [local output] Base port: 27629 [13:32:02.872] [local output] Getting setup options for 1 cluster nodes ... [13:32:02.872] [local output] - Node #1 of 1 ... [13:32:02.873] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:02.876] [local output] Rscript port: 27629 [13:32:02.877] [local output] Getting setup options for 1 cluster nodes ... done [13:32:02.877] [local output] - Parallel setup requested for some PSOCK nodes [13:32:02.877] [local output] Setting up PSOCK nodes in parallel [13:32:02.878] List of 36 [13:32:02.878] $ worker : chr "localhost" [13:32:02.878] ..- attr(*, "localhost")= logi TRUE [13:32:02.878] $ master : chr "localhost" [13:32:02.878] $ port : int 27629 [13:32:02.878] $ connectTimeout : num 120 [13:32:02.878] $ timeout : num 120 [13:32:02.878] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [13:32:02.878] $ homogeneous : logi TRUE [13:32:02.878] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN\" -e "| __truncated__ [13:32:02.878] $ rscript_envs : NULL [13:32:02.878] $ rscript_libs : NULL [13:32:02.878] $ rscript_startup : NULL [13:32:02.878] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:02.878] $ default_packages: chr [1:2] "utils" "tools" [13:32:02.878] $ methods : logi TRUE [13:32:02.878] $ socketOptions : chr "no-delay" [13:32:02.878] $ useXDR : logi FALSE [13:32:02.878] $ outfile : chr "/dev/null" [13:32:02.878] $ renice : int NA [13:32:02.878] $ rshcmd : NULL [13:32:02.878] $ user : chr(0) [13:32:02.878] $ revtunnel : logi FALSE [13:32:02.878] $ rshlogfile : NULL [13:32:02.878] $ rshopts : chr(0) [13:32:02.878] $ rank : int 1 [13:32:02.878] $ manual : logi FALSE [13:32:02.878] $ dryrun : logi FALSE [13:32:02.878] $ quiet : logi FALSE [13:32:02.878] $ setup_strategy : chr "parallel" [13:32:02.878] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [13:32:02.878] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef8181b57e4.pid" [13:32:02.878] $ rshcmd_label : NULL [13:32:02.878] $ rsh_call : NULL [13:32:02.878] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [13:32:02.878] $ localMachine : logi TRUE [13:32:02.878] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:02.878] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:02.878] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:02.878] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:02.878] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:02.878] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:02.878] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:02.878] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:02.878] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:02.878] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:02.878] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:02.878] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:02.878] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:02.878] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:02.878] $ arguments :List of 28 [13:32:02.878] ..$ worker : chr "localhost" [13:32:02.878] ..$ master : NULL [13:32:02.878] ..$ port : int 27629 [13:32:02.878] ..$ connectTimeout : num 120 [13:32:02.878] ..$ timeout : num 120 [13:32:02.878] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [13:32:02.878] ..$ homogeneous : NULL [13:32:02.878] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [13:32:02.878] ..$ rscript_envs : NULL [13:32:02.878] ..$ rscript_libs : NULL [13:32:02.878] ..$ rscript_startup : NULL [13:32:02.878] ..$ rscript_sh : chr "auto" [13:32:02.878] ..$ default_packages: chr [1:2] "utils" "tools" [13:32:02.878] ..$ methods : logi TRUE [13:32:02.878] ..$ socketOptions : chr "no-delay" [13:32:02.878] ..$ useXDR : logi FALSE [13:32:02.878] ..$ outfile : chr "/dev/null" [13:32:02.878] ..$ renice : int NA [13:32:02.878] ..$ rshcmd : NULL [13:32:02.878] ..$ user : NULL [13:32:02.878] ..$ revtunnel : logi NA [13:32:02.878] ..$ rshlogfile : NULL [13:32:02.878] ..$ rshopts : NULL [13:32:02.878] ..$ rank : int 1 [13:32:02.878] ..$ manual : logi FALSE [13:32:02.878] ..$ dryrun : logi FALSE [13:32:02.878] ..$ quiet : logi FALSE [13:32:02.878] ..$ setup_strategy : chr "parallel" [13:32:02.878] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:02.917] [local output] System call to launch all workers: [13:32:02.918] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef8181b57e4.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=27629 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:02.918] [local output] Starting PSOCK main server [13:32:02.925] [local output] Workers launched [13:32:02.925] [local output] Waiting for workers to connect back [13:32:02.926] - [local output] 0 workers out of 1 ready [13:32:03.071] - [local output] 0 workers out of 1 ready [13:32:03.072] - [local output] 1 workers out of 1 ready [13:32:03.072] [local output] Launching of 1 workers completed [13:32:03.072] [local output] Number of nodes in cluster: 1 [13:32:03.073] [local output] Collecting session information from 1 workers [13:32:03.074] [local output] - Worker #1 of 1 [13:32:03.074] [local output] makeClusterPSOCK() ... done > > if (.Platform$OS.type == "windows") { + ## R and R.exe fails on MS Windows, cf. R-devel thread "MS Windows: R does + ## not escape quotes in CLI options the same way as Rterm and Rscript" + ## on 2021-12-15. + rscripts <- file.path(R.home("bin"), c("Rscript", "Rterm", "Rterm.exe")) + } else { + rscripts <- file.path(R.home("bin"), c("Rscript", "R")) + } > default_packages <- c("parallelly", "*") > truth <- unique(c("parallelly", getOption("defaultPackages"))) > for (rscript in rscripts) { + message(" Launcher: ", sQuote(rscript)) + if (tools::file_path_sans_ext(basename(rscript)) %in% c("R", "Rterm")) { + rscript_args <- c("--no-echo", "--no-restore", "*", "--args") + } else { + rscript_args <- NULL + } + cl <- tryCatch({ + makeClusterPSOCK(1L, rscript = rscript, rscript_args = rscript_args, default_packages = default_packages) + }, warning = identity) + stopifnot(inherits(cl, "cluster")) + pkgs <- parallel::clusterEvalQ(cl, { getOption("defaultPackages") })[[1]] + stopifnot(identical(pkgs, truth)) + parallel::stopCluster(cl) + } Launcher: 'D:/RCompile/recent/R/bin/x64/Rscript' [13:32:03.101] [local output] makeClusterPSOCK() ... [13:32:03.106] [local output] Workers: [n = 1] 'localhost' [13:32:03.111] [local output] Base port: 27412 [13:32:03.111] [local output] Getting setup options for 1 cluster nodes ... [13:32:03.112] [local output] - Node #1 of 1 ... [13:32:03.112] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:03.115] [local output] Rscript port: 27412 [13:32:03.115] [local output] Getting setup options for 1 cluster nodes ... done [13:32:03.116] [local output] - Parallel setup requested for some PSOCK nodes [13:32:03.116] [local output] Setting up PSOCK nodes in parallel [13:32:03.117] List of 36 [13:32:03.117] $ worker : chr "localhost" [13:32:03.117] ..- attr(*, "localhost")= logi TRUE [13:32:03.117] $ master : chr "localhost" [13:32:03.117] $ port : int 27412 [13:32:03.117] $ connectTimeout : num 120 [13:32:03.117] $ timeout : num 120 [13:32:03.117] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [13:32:03.117] $ homogeneous : logi TRUE [13:32:03.117] $ rscript_args : chr "--default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:17"| __truncated__ [13:32:03.117] $ rscript_envs : NULL [13:32:03.117] $ rscript_libs : NULL [13:32:03.117] $ rscript_startup : NULL [13:32:03.117] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:03.117] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [13:32:03.117] $ methods : logi TRUE [13:32:03.117] $ socketOptions : chr "no-delay" [13:32:03.117] $ useXDR : logi FALSE [13:32:03.117] $ outfile : chr "/dev/null" [13:32:03.117] $ renice : int NA [13:32:03.117] $ rshcmd : NULL [13:32:03.117] $ user : chr(0) [13:32:03.117] $ revtunnel : logi FALSE [13:32:03.117] $ rshlogfile : NULL [13:32:03.117] $ rshopts : chr(0) [13:32:03.117] $ rank : int 1 [13:32:03.117] $ manual : logi FALSE [13:32:03.117] $ dryrun : logi FALSE [13:32:03.117] $ quiet : logi FALSE [13:32:03.117] $ setup_strategy : chr "parallel" [13:32:03.117] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [13:32:03.117] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef82f2d3eb0.pid" [13:32:03.117] $ rshcmd_label : NULL [13:32:03.117] $ rsh_call : NULL [13:32:03.117] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [13:32:03.117] $ localMachine : logi TRUE [13:32:03.117] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:03.117] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:03.117] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:03.117] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:03.117] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:03.117] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:03.117] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:03.117] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:03.117] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:03.117] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:03.117] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:03.117] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:03.117] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:03.117] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:03.117] $ arguments :List of 28 [13:32:03.117] ..$ worker : chr "localhost" [13:32:03.117] ..$ master : NULL [13:32:03.117] ..$ port : int 27412 [13:32:03.117] ..$ connectTimeout : num 120 [13:32:03.117] ..$ timeout : num 120 [13:32:03.117] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [13:32:03.117] ..$ homogeneous : NULL [13:32:03.117] ..$ rscript_args : NULL [13:32:03.117] ..$ rscript_envs : NULL [13:32:03.117] ..$ rscript_libs : NULL [13:32:03.117] ..$ rscript_startup : NULL [13:32:03.117] ..$ rscript_sh : chr "auto" [13:32:03.117] ..$ default_packages: chr [1:2] "parallelly" "*" [13:32:03.117] ..$ methods : logi TRUE [13:32:03.117] ..$ socketOptions : chr "no-delay" [13:32:03.117] ..$ useXDR : logi FALSE [13:32:03.117] ..$ outfile : chr "/dev/null" [13:32:03.117] ..$ renice : int NA [13:32:03.117] ..$ rshcmd : NULL [13:32:03.117] ..$ user : NULL [13:32:03.117] ..$ revtunnel : logi NA [13:32:03.117] ..$ rshlogfile : NULL [13:32:03.117] ..$ rshopts : NULL [13:32:03.117] ..$ rank : int 1 [13:32:03.117] ..$ manual : logi FALSE [13:32:03.117] ..$ dryrun : logi FALSE [13:32:03.117] ..$ quiet : logi FALSE [13:32:03.117] ..$ setup_strategy : chr "parallel" [13:32:03.117] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:03.151] [local output] System call to launch all workers: [13:32:03.151] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef82f2d3eb0.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=27412 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:03.151] [local output] Starting PSOCK main server [13:32:03.157] [local output] Workers launched [13:32:03.157] [local output] Waiting for workers to connect back [13:32:03.157] - [local output] 0 workers out of 1 ready [13:32:03.505] - [local output] 0 workers out of 1 ready [13:32:03.506] - [local output] 1 workers out of 1 ready [13:32:03.506] [local output] Launching of 1 workers completed [13:32:03.507] [local output] Number of nodes in cluster: 1 [13:32:03.507] [local output] Collecting session information from 1 workers [13:32:03.508] [local output] - Worker #1 of 1 [13:32:03.509] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [13:32:03.523] [local output] makeClusterPSOCK() ... [13:32:03.528] [local output] Workers: [n = 1] 'localhost' [13:32:03.536] [local output] Base port: 33125 [13:32:03.536] [local output] Getting setup options for 1 cluster nodes ... [13:32:03.536] [local output] - Node #1 of 1 ... [13:32:03.537] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:03.540] [local output] Rscript port: 33125 [13:32:03.540] [local output] Getting setup options for 1 cluster nodes ... done [13:32:03.540] [local output] - Parallel setup requested for some PSOCK nodes [13:32:03.541] [local output] Setting up PSOCK nodes in parallel [13:32:03.541] List of 36 [13:32:03.541] $ worker : chr "localhost" [13:32:03.541] ..- attr(*, "localhost")= logi TRUE [13:32:03.541] $ master : chr "localhost" [13:32:03.541] $ port : int 33125 [13:32:03.541] $ connectTimeout : num 120 [13:32:03.541] $ timeout : num 120 [13:32:03.541] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [13:32:03.541] $ homogeneous : logi TRUE [13:32:03.541] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [13:32:03.541] $ rscript_envs : NULL [13:32:03.541] $ rscript_libs : NULL [13:32:03.541] $ rscript_startup : NULL [13:32:03.541] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:03.541] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [13:32:03.541] $ methods : logi TRUE [13:32:03.541] $ socketOptions : chr "no-delay" [13:32:03.541] $ useXDR : logi FALSE [13:32:03.541] $ outfile : chr "/dev/null" [13:32:03.541] $ renice : int NA [13:32:03.541] $ rshcmd : NULL [13:32:03.541] $ user : chr(0) [13:32:03.541] $ revtunnel : logi FALSE [13:32:03.541] $ rshlogfile : NULL [13:32:03.541] $ rshopts : chr(0) [13:32:03.541] $ rank : int 1 [13:32:03.541] $ manual : logi FALSE [13:32:03.541] $ dryrun : logi FALSE [13:32:03.541] $ quiet : logi FALSE [13:32:03.541] $ setup_strategy : chr "parallel" [13:32:03.541] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [13:32:03.541] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef8455a3505.pid" [13:32:03.541] $ rshcmd_label : NULL [13:32:03.541] $ rsh_call : NULL [13:32:03.541] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [13:32:03.541] $ localMachine : logi TRUE [13:32:03.541] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:03.541] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:03.541] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:03.541] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:03.541] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:03.541] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:03.541] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:03.541] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:03.541] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:03.541] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:03.541] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:03.541] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:03.541] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:03.541] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:03.541] $ arguments :List of 28 [13:32:03.541] ..$ worker : chr "localhost" [13:32:03.541] ..$ master : NULL [13:32:03.541] ..$ port : int 33125 [13:32:03.541] ..$ connectTimeout : num 120 [13:32:03.541] ..$ timeout : num 120 [13:32:03.541] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [13:32:03.541] ..$ homogeneous : NULL [13:32:03.541] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [13:32:03.541] ..$ rscript_envs : NULL [13:32:03.541] ..$ rscript_libs : NULL [13:32:03.541] ..$ rscript_startup : NULL [13:32:03.541] ..$ rscript_sh : chr "auto" [13:32:03.541] ..$ default_packages: chr [1:2] "parallelly" "*" [13:32:03.541] ..$ methods : logi TRUE [13:32:03.541] ..$ socketOptions : chr "no-delay" [13:32:03.541] ..$ useXDR : logi FALSE [13:32:03.541] ..$ outfile : chr "/dev/null" [13:32:03.541] ..$ renice : int NA [13:32:03.541] ..$ rshcmd : NULL [13:32:03.541] ..$ user : NULL [13:32:03.541] ..$ revtunnel : logi NA [13:32:03.541] ..$ rshlogfile : NULL [13:32:03.541] ..$ rshopts : NULL [13:32:03.541] ..$ rank : int 1 [13:32:03.541] ..$ manual : logi FALSE [13:32:03.541] ..$ dryrun : logi FALSE [13:32:03.541] ..$ quiet : logi FALSE [13:32:03.541] ..$ setup_strategy : chr "parallel" [13:32:03.541] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:03.575] [local output] System call to launch all workers: [13:32:03.576] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef8455a3505.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=33125 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:03.576] [local output] Starting PSOCK main server [13:32:03.582] [local output] Workers launched [13:32:03.582] [local output] Waiting for workers to connect back [13:32:03.583] - [local output] 0 workers out of 1 ready [13:32:03.946] - [local output] 0 workers out of 1 ready [13:32:03.946] - [local output] 1 workers out of 1 ready [13:32:03.947] [local output] Launching of 1 workers completed [13:32:03.947] [local output] Number of nodes in cluster: 1 [13:32:03.947] [local output] Collecting session information from 1 workers [13:32:03.949] [local output] - Worker #1 of 1 [13:32:03.949] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [13:32:03.966] [local output] makeClusterPSOCK() ... [13:32:03.971] [local output] Workers: [n = 1] 'localhost' [13:32:03.975] [local output] Base port: 25123 [13:32:03.975] [local output] Getting setup options for 1 cluster nodes ... [13:32:03.975] [local output] - Node #1 of 1 ... [13:32:03.976] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:03.979] [local output] Rscript port: 25123 [13:32:03.979] [local output] Getting setup options for 1 cluster nodes ... done [13:32:03.979] [local output] - Parallel setup requested for some PSOCK nodes [13:32:03.980] [local output] Setting up PSOCK nodes in parallel [13:32:03.980] List of 36 [13:32:03.980] $ worker : chr "localhost" [13:32:03.980] ..- attr(*, "localhost")= logi TRUE [13:32:03.980] $ master : chr "localhost" [13:32:03.980] $ port : int 25123 [13:32:03.980] $ connectTimeout : num 120 [13:32:03.980] $ timeout : num 120 [13:32:03.980] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [13:32:03.980] $ homogeneous : logi TRUE [13:32:03.980] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [13:32:03.980] $ rscript_envs : NULL [13:32:03.980] $ rscript_libs : NULL [13:32:03.980] $ rscript_startup : NULL [13:32:03.980] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:03.980] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [13:32:03.980] $ methods : logi TRUE [13:32:03.980] $ socketOptions : chr "no-delay" [13:32:03.980] $ useXDR : logi FALSE [13:32:03.980] $ outfile : chr "/dev/null" [13:32:03.980] $ renice : int NA [13:32:03.980] $ rshcmd : NULL [13:32:03.980] $ user : chr(0) [13:32:03.980] $ revtunnel : logi FALSE [13:32:03.980] $ rshlogfile : NULL [13:32:03.980] $ rshopts : chr(0) [13:32:03.980] $ rank : int 1 [13:32:03.980] $ manual : logi FALSE [13:32:03.980] $ dryrun : logi FALSE [13:32:03.980] $ quiet : logi FALSE [13:32:03.980] $ setup_strategy : chr "parallel" [13:32:03.980] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [13:32:03.980] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef81e045cf.pid" [13:32:03.980] $ rshcmd_label : NULL [13:32:03.980] $ rsh_call : NULL [13:32:03.980] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [13:32:03.980] $ localMachine : logi TRUE [13:32:03.980] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:03.980] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:03.980] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:03.980] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:03.980] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:03.980] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:03.980] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:03.980] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:03.980] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:03.980] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:03.980] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:03.980] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:03.980] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:03.980] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:03.980] $ arguments :List of 28 [13:32:03.980] ..$ worker : chr "localhost" [13:32:03.980] ..$ master : NULL [13:32:03.980] ..$ port : int 25123 [13:32:03.980] ..$ connectTimeout : num 120 [13:32:03.980] ..$ timeout : num 120 [13:32:03.980] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [13:32:03.980] ..$ homogeneous : NULL [13:32:03.980] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [13:32:03.980] ..$ rscript_envs : NULL [13:32:03.980] ..$ rscript_libs : NULL [13:32:03.980] ..$ rscript_startup : NULL [13:32:03.980] ..$ rscript_sh : chr "auto" [13:32:03.980] ..$ default_packages: chr [1:2] "parallelly" "*" [13:32:03.980] ..$ methods : logi TRUE [13:32:03.980] ..$ socketOptions : chr "no-delay" [13:32:03.980] ..$ useXDR : logi FALSE [13:32:03.980] ..$ outfile : chr "/dev/null" [13:32:03.980] ..$ renice : int NA [13:32:03.980] ..$ rshcmd : NULL [13:32:03.980] ..$ user : NULL [13:32:03.980] ..$ revtunnel : logi NA [13:32:03.980] ..$ rshlogfile : NULL [13:32:03.980] ..$ rshopts : NULL [13:32:03.980] ..$ rank : int 1 [13:32:03.980] ..$ manual : logi FALSE [13:32:03.980] ..$ dryrun : logi FALSE [13:32:03.980] ..$ quiet : logi FALSE [13:32:03.980] ..$ setup_strategy : chr "parallel" [13:32:03.980] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:04.007] [local output] System call to launch all workers: [13:32:04.007] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef81e045cf.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=25123 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [13:32:04.008] [local output] Starting PSOCK main server [13:32:04.013] [local output] Workers launched [13:32:04.014] [local output] Waiting for workers to connect back [13:32:04.014] - [local output] 0 workers out of 1 ready [13:32:04.359] - [local output] 0 workers out of 1 ready [13:32:04.360] - [local output] 1 workers out of 1 ready [13:32:04.360] [local output] Launching of 1 workers completed [13:32:04.361] [local output] Number of nodes in cluster: 1 [13:32:04.361] [local output] Collecting session information from 1 workers [13:32:04.362] [local output] - Worker #1 of 1 [13:32:04.362] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > res <- tryCatch({ + cl <- makeClusterPSOCK(1:2) + }, error = identity) [13:32:04.372] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(0L) + }, error = identity) [13:32:04.375] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, rshcmd = character(0L)) + }, error = identity) [13:32:04.376] [local output] makeClusterPSOCK() ... [13:32:04.380] [local output] Workers: [n = 1] 'localhost' [13:32:04.384] [local output] Base port: 35537 [13:32:04.384] [local output] Getting setup options for 1 cluster nodes ... [13:32:04.384] [local output] - Node #1 of 1 ... > print(res) = 1L' is not TRUE> > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = integer(0L)) + }, error = identity) [13:32:04.385] [local output] makeClusterPSOCK() ... [13:32:04.389] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = NA_integer_) + }, error = identity) [13:32:04.389] [local output] makeClusterPSOCK() ... [13:32:04.393] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > ## Non-existing hostname > res <- tryCatch({ + cl <- makeNodePSOCK("not.a.localhost.hostname", revtunnel = TRUE) + }, error = identity) > print(res) > stopifnot(inherits(res, "error")) > > ## Invalid port > res <- tryCatch({ + cl <- makeNodePSOCK("localhost", port = NA_integer_) + }, error = identity) > print(res) > stopifnot(inherits(res, "error")) > > ## Don't test on CRAN > if (fullTest || covr_testing) { + ## Occupied/blocked port + res <- tryCatch( + cl <- parallelly::makeClusterPSOCK("localhost", port = 80L, tries = 1L), + error = identity) + print(res) + ## Skip error assertion in case this actually works on some machine. + ## But where it fails, we are testing the port-failure exception code. + } > > > ## https://github.com/futureverse/parallelly/issues/95 > if (getRversion() >= "4.0.0") { + res <- tryCatch({ + parallelly::makeClusterPSOCK(1L, rscript_startup = quote(Sys.sleep(6.0)), + connectTimeout = 0.1, timeout = 7.0) + }, error = identity) + print(res) + stopifnot( + inherits(res, "error"), + grepl("^Cluster setup failed", conditionMessage(res)) + ) + + ## Make sure to wait for background process to timeout before continuing, + ## when on MS Windows + if (.Platform$OS.type == "windows") Sys.sleep(5.0) + } [13:32:04.397] [local output] makeClusterPSOCK() ... [13:32:04.400] [local output] Workers: [n = 1] 'localhost' [13:32:04.404] [local output] Base port: 34709 [13:32:04.405] [local output] Getting setup options for 1 cluster nodes ... [13:32:04.405] [local output] - Node #1 of 1 ... [13:32:04.405] [local output] localMachine=TRUE => revtunnel=FALSE [13:32:04.407] [local output] Rscript port: 34709 [13:32:04.408] [local output] Getting setup options for 1 cluster nodes ... done [13:32:04.408] [local output] - Parallel setup requested for some PSOCK nodes [13:32:04.409] [local output] Setting up PSOCK nodes in parallel [13:32:04.409] List of 36 [13:32:04.409] $ worker : chr "localhost" [13:32:04.409] ..- attr(*, "localhost")= logi TRUE [13:32:04.409] $ master : chr "localhost" [13:32:04.409] $ port : int 34709 [13:32:04.409] $ connectTimeout : num 0.1 [13:32:04.409] $ timeout : num 7 [13:32:04.409] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [13:32:04.409] $ homogeneous : logi TRUE [13:32:04.409] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:171768:CRANWI"| __truncated__ [13:32:04.409] $ rscript_envs : NULL [13:32:04.409] $ rscript_libs : NULL [13:32:04.409] $ rscript_startup : chr [1:2] "-e" "\"invisible({Sys.sleep(6)})\"" [13:32:04.409] $ rscript_sh : chr [1:2] "cmd" "cmd" [13:32:04.409] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:04.409] $ methods : logi TRUE [13:32:04.409] $ socketOptions : chr "no-delay" [13:32:04.409] $ useXDR : logi FALSE [13:32:04.409] $ outfile : chr "/dev/null" [13:32:04.409] $ renice : int NA [13:32:04.409] $ rshcmd : NULL [13:32:04.409] $ user : chr(0) [13:32:04.409] $ revtunnel : logi FALSE [13:32:04.409] $ rshlogfile : NULL [13:32:04.409] $ rshopts : chr(0) [13:32:04.409] $ rank : int 1 [13:32:04.409] $ manual : logi FALSE [13:32:04.409] $ dryrun : logi FALSE [13:32:04.409] $ quiet : logi FALSE [13:32:04.409] $ setup_strategy : chr "parallel" [13:32:04.409] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:32:04.409] $ pidfile : chr "D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef82870d54.pid" [13:32:04.409] $ rshcmd_label : NULL [13:32:04.409] $ rsh_call : NULL [13:32:04.409] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [13:32:04.409] $ localMachine : logi TRUE [13:32:04.409] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [13:32:04.409] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [13:32:04.409] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [13:32:04.409] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [13:32:04.409] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [13:32:04.409] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [13:32:04.409] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [13:32:04.409] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [13:32:04.409] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [13:32:04.409] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [13:32:04.409] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [13:32:04.409] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [13:32:04.409] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [13:32:04.409] "parallel"), action = c("launch", "options"), verbose = FALSE) [13:32:04.409] $ arguments :List of 28 [13:32:04.409] ..$ worker : chr "localhost" [13:32:04.409] ..$ master : NULL [13:32:04.409] ..$ port : int 34709 [13:32:04.409] ..$ connectTimeout : num 0.1 [13:32:04.409] ..$ timeout : num 7 [13:32:04.409] ..$ rscript : NULL [13:32:04.409] ..$ homogeneous : NULL [13:32:04.409] ..$ rscript_args : NULL [13:32:04.409] ..$ rscript_envs : NULL [13:32:04.409] ..$ rscript_libs : NULL [13:32:04.409] ..$ rscript_startup : language Sys.sleep(6) [13:32:04.409] ..$ rscript_sh : chr "auto" [13:32:04.409] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [13:32:04.409] ..$ methods : logi TRUE [13:32:04.409] ..$ socketOptions : chr "no-delay" [13:32:04.409] ..$ useXDR : logi FALSE [13:32:04.409] ..$ outfile : chr "/dev/null" [13:32:04.409] ..$ renice : int NA [13:32:04.409] ..$ rshcmd : NULL [13:32:04.409] ..$ user : NULL [13:32:04.409] ..$ revtunnel : logi NA [13:32:04.409] ..$ rshlogfile : NULL [13:32:04.409] ..$ rshopts : NULL [13:32:04.409] ..$ rank : int 1 [13:32:04.409] ..$ manual : logi FALSE [13:32:04.409] ..$ dryrun : logi FALSE [13:32:04.409] ..$ quiet : logi FALSE [13:32:04.409] ..$ setup_strategy : chr "parallel" [13:32:04.409] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [13:32:04.440] [local output] System call to launch all workers: [13:32:04.440] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:171768:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_04_13_25_01_31804/Rtmp8ST0K8/worker.rank=1.parallelly.parent=171768.29ef82870d54.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "invisible({Sys.sleep(6)})" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34709 OUT=/dev/null TIMEOUT=7 XDR=FALSE SETUPTIMEOUT=0.1 SETUPSTRATEGY=parallel [13:32:04.440] [local output] Starting PSOCK main server [13:32:04.446] [local output] Workers launched [13:32:04.447] [local output] Waiting for workers to connect back [13:32:04.447] - [local output] 0 workers out of 1 ready [13:32:04.638] - [local output] 0 workers out of 1 ready [13:32:04.841] - [local output] 0 workers out of 1 ready [13:32:05.044] - [local output] 0 workers out of 1 ready [13:32:05.247] - [local output] 0 workers out of 1 ready [13:32:05.450] - [local output] 0 workers out of 1 ready [13:32:05.654] - [local output] 0 workers out of 1 ready [13:32:05.857] - [local output] 0 workers out of 1 ready [13:32:06.060] - [local output] 0 workers out of 1 ready [13:32:06.263] - [local output] 0 workers out of 1 ready [13:32:06.466] - [local output] 0 workers out of 1 ready [13:32:06.669] - [local output] 0 workers out of 1 ready [13:32:06.872] - [local output] 0 workers out of 1 ready [13:32:07.076] - [local output] 0 workers out of 1 ready [13:32:07.279] - [local output] 0 workers out of 1 ready [13:32:07.482] - [local output] 0 workers out of 1 ready [13:32:07.685] - [local output] 0 workers out of 1 ready [13:32:07.888] - [local output] 0 workers out of 1 ready [13:32:08.091] - [local output] 0 workers out of 1 ready [13:32:08.294] - [local output] 0 workers out of 1 ready [13:32:08.497] - [local output] 0 workers out of 1 ready [13:32:08.701] - [local output] 0 workers out of 1 ready [13:32:08.904] - [local output] 0 workers out of 1 ready [13:32:09.107] - [local output] 0 workers out of 1 ready [13:32:09.310] - [local output] 0 workers out of 1 ready [13:32:09.513] - [local output] 0 workers out of 1 ready [13:32:09.716] - [local output] 0 workers out of 1 ready > > message("*** makeClusterPSOCK() ... DONE") *** makeClusterPSOCK() ... DONE > > source("incl/end.R") > > proc.time() user system elapsed 1.76 0.17 21.23