R Under development (unstable) (2025-01-29 r87668 ucrt) -- "Unsuffered Consequences" Copyright (C) 2025 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) [16:45:33.321] [local output] makeClusterPSOCK() ... [16:45:33.368] [local output] Workers: [n = 1] '' [16:45:33.378] [local output] Base port: 34237 [16:45:33.379] [local output] Getting setup options for 1 cluster nodes ... [16:45:33.379] [local output] - Node #1 of 1 ... [16:45:33.384] [local output] Rscript port: 34237 [16:45:33.384] [local output] Using 'rshcmd': 'my_ssh' [type='', version=''] [16:45:33.385] [local output] Getting setup options for 1 cluster nodes ... done [16:45:33.385] [local output] Creating node #1 of 1 ... [16:45:33.386] [local output] - setting up node [16:45:33.386] [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:101760:CRANWIN3:CRAN' -e 'options(socketOptions = "no-delay")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=34237 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:101760:CRANWIN3:CRAN' -e 'options(socketOptions = \"no-delay\")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=34237 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential" [16:45:33.388] [local output] Creating node #1 of 1 ... done [16:45:33.388] [local output] Launching of 1 workers completed [16:45:33.389] [local output] Number of nodes in cluster: 1 [16:45:33.389] [local output] Collecting session information from 1 workers [16:45:33.390] [local output] - Worker #1 of 1 [16:45:33.390] [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) [16:45:33.397] [local output] makeClusterPSOCK() ... [16:45:33.407] [local output] Workers: [n = 1] 'localhost' [16:45:33.412] [local output] Base port: 39392 [16:45:33.413] [local output] Getting setup options for 1 cluster nodes ... [16:45:33.413] [local output] - Node #1 of 1 ... [16:45:33.414] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:33.416] [local output] Rscript port: 39392 [16:45:33.416] [local output] Getting setup options for 1 cluster nodes ... done [16:45:33.417] [local output] Creating node #1 of 1 ... [16:45:33.417] [local output] - setting up node [16:45:33.417] [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:101760:CRANWIN3:CRAN" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=39392 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [16:45:33.417] [local output] Creating node #1 of 1 ... done [16:45:33.418] [local output] Launching of 1 workers completed [16:45:33.418] [local output] Number of nodes in cluster: 1 [16:45:33.418] [local output] Collecting session information from 1 workers [16:45:33.418] [local output] - Worker #1 of 1 [16:45:33.419] [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) [16:45:33.420] [local output] makeClusterPSOCK() ... [16:45:33.426] [local output] Workers: [n = 1] 'localhost' [16:45:33.431] [local output] Base port: 26217 [16:45:33.431] [local output] Getting setup options for 1 cluster nodes ... [16:45:33.432] [local output] - Node #1 of 1 ... [16:45:33.433] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:33.435] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80406d237d.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80406d237d.pid\")"' [16:45:33.991] - Possible to infer worker's PID: TRUE [16:45:33.993] [local output] Rscript port: 26217 [16:45:33.994] [local output] Getting setup options for 1 cluster nodes ... done [16:45:33.994] [local output] - Parallel setup requested for some PSOCK nodes [16:45:33.996] [local output] Setting up PSOCK nodes in parallel [16:45:33.996] List of 36 [16:45:33.996] $ worker : chr "localhost" [16:45:33.996] ..- attr(*, "localhost")= logi TRUE [16:45:33.996] $ master : chr "localhost" [16:45:33.996] $ port : int 26217 [16:45:33.996] $ connectTimeout : num 120 [16:45:33.996] $ timeout : num 120 [16:45:33.996] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:33.996] $ homogeneous : logi TRUE [16:45:33.996] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:33.996] $ rscript_envs : NULL [16:45:33.996] $ rscript_libs : NULL [16:45:33.996] $ rscript_startup : NULL [16:45:33.996] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:33.996] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:33.996] $ methods : logi TRUE [16:45:33.996] $ socketOptions : chr "no-delay" [16:45:33.996] $ useXDR : logi FALSE [16:45:33.996] $ outfile : chr "/dev/null" [16:45:33.996] $ renice : int NA [16:45:33.996] $ rshcmd : NULL [16:45:33.996] $ user : chr(0) [16:45:33.996] $ revtunnel : logi FALSE [16:45:33.996] $ rshlogfile : NULL [16:45:33.996] $ rshopts : chr(0) [16:45:33.996] $ rank : int 1 [16:45:33.996] $ manual : logi FALSE [16:45:33.996] $ dryrun : logi FALSE [16:45:33.996] $ quiet : logi FALSE [16:45:33.996] $ setup_strategy : chr "parallel" [16:45:33.996] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:33.996] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80406d237d.pid" [16:45:33.996] $ rshcmd_label : NULL [16:45:33.996] $ rsh_call : NULL [16:45:33.996] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:33.996] $ localMachine : logi TRUE [16:45:33.996] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:33.996] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:33.996] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:33.996] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:33.996] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:33.996] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:33.996] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:33.996] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:33.996] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:33.996] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:33.996] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:33.996] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:33.996] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:33.996] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:33.996] $ arguments :List of 28 [16:45:33.996] ..$ worker : chr "localhost" [16:45:33.996] ..$ master : NULL [16:45:33.996] ..$ port : int 26217 [16:45:33.996] ..$ connectTimeout : num 120 [16:45:33.996] ..$ timeout : num 120 [16:45:33.996] ..$ rscript : NULL [16:45:33.996] ..$ homogeneous : NULL [16:45:33.996] ..$ rscript_args : NULL [16:45:33.996] ..$ rscript_envs : NULL [16:45:33.996] ..$ rscript_libs : NULL [16:45:33.996] ..$ rscript_startup : NULL [16:45:33.996] ..$ rscript_sh : chr "auto" [16:45:33.996] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:33.996] ..$ methods : logi TRUE [16:45:33.996] ..$ socketOptions : chr "no-delay" [16:45:33.996] ..$ useXDR : logi FALSE [16:45:33.996] ..$ outfile : chr "/dev/null" [16:45:33.996] ..$ renice : int NA [16:45:33.996] ..$ rshcmd : NULL [16:45:33.996] ..$ user : NULL [16:45:33.996] ..$ revtunnel : logi NA [16:45:33.996] ..$ rshlogfile : NULL [16:45:33.996] ..$ rshopts : NULL [16:45:33.996] ..$ rank : int 1 [16:45:33.996] ..$ manual : logi FALSE [16:45:33.996] ..$ dryrun : logi FALSE [16:45:33.996] ..$ quiet : logi FALSE [16:45:33.996] ..$ setup_strategy : chr "parallel" [16:45:33.996] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:34.037] [local output] System call to launch all workers: [16:45:34.037] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80406d237d.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26217 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:34.038] [local output] Starting PSOCK main server [16:45:34.042] [local output] Workers launched [16:45:34.043] [local output] Waiting for workers to connect back [16:45:34.043] - [local output] 0 workers out of 1 ready [16:45:34.307] - [local output] 0 workers out of 1 ready [16:45:34.308] - [local output] 1 workers out of 1 ready [16:45:34.308] [local output] Launching of 1 workers completed [16:45:34.309] [local output] Number of nodes in cluster: 1 [16:45:34.309] [local output] Collecting session information from 1 workers [16:45:34.310] [local output] - Worker #1 of 1 [16:45:34.311] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 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 "2025" .. ..$ month : chr "01" .. ..$ day : chr "29" .. ..$ svn rev : chr "87668" .. ..$ language : chr "R" .. ..$ version.string: chr "R Under development (unstable) (2025-01-29 r87668 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/2025_01_30_16_40_16_30529/RtmpMR8mAA/RLIBS_145c012ab362" "D:/RCompile/recent/R/library" ..$ pkgs : NULL ..$ pwd : chr "d:/RCompile/CRANincoming/R-devel/parallelly.Rcheck/tests" ..$ process:List of 1 .. ..$ pid: int 179976 - attr(*, "options")=List of 35 ..$ worker : chr "localhost" .. ..- attr(*, "localhost")= logi TRUE ..$ master : chr "localhost" ..$ port : int 26217 ..$ 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:101760: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 26217 .. ..$ 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) + } [16:45:34.409] [local output] makeClusterPSOCK() ... [16:45:34.419] [local output] Workers: [n = 1] 'localhost' [16:45:34.424] [local output] Base port: 34018 [16:45:34.424] [local output] Getting setup options for 1 cluster nodes ... [16:45:34.425] [local output] - Node #1 of 1 ... [16:45:34.426] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:34.431] [local output] Rscript port: 34018 [16:45:34.432] [local output] Getting setup options for 1 cluster nodes ... done [16:45:34.433] [local output] - Parallel setup requested for some PSOCK nodes [16:45:34.434] [local output] Setting up PSOCK nodes in parallel [16:45:34.434] List of 36 [16:45:34.434] $ worker : chr "localhost" [16:45:34.434] ..- attr(*, "localhost")= logi TRUE [16:45:34.434] $ master : chr "localhost" [16:45:34.434] $ port : int 34018 [16:45:34.434] $ connectTimeout : num 120 [16:45:34.434] $ timeout : num 120 [16:45:34.434] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:34.434] $ homogeneous : logi TRUE [16:45:34.434] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:34.434] $ rscript_envs : NULL [16:45:34.434] $ rscript_libs : NULL [16:45:34.434] $ rscript_startup : NULL [16:45:34.434] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:34.434] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:34.434] $ methods : logi TRUE [16:45:34.434] $ socketOptions : chr "no-delay" [16:45:34.434] $ useXDR : logi TRUE [16:45:34.434] $ outfile : chr "/dev/null" [16:45:34.434] $ renice : int NA [16:45:34.434] $ rshcmd : NULL [16:45:34.434] $ user : chr(0) [16:45:34.434] $ revtunnel : logi FALSE [16:45:34.434] $ rshlogfile : NULL [16:45:34.434] $ rshopts : chr(0) [16:45:34.434] $ rank : int 1 [16:45:34.434] $ manual : logi FALSE [16:45:34.434] $ dryrun : logi FALSE [16:45:34.434] $ quiet : logi FALSE [16:45:34.434] $ setup_strategy : chr "parallel" [16:45:34.434] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:34.434] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d804c8b901.pid" [16:45:34.434] $ rshcmd_label : NULL [16:45:34.434] $ rsh_call : NULL [16:45:34.434] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:34.434] $ localMachine : logi TRUE [16:45:34.434] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:34.434] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:34.434] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:34.434] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:34.434] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:34.434] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:34.434] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:34.434] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:34.434] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:34.434] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:34.434] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:34.434] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:34.434] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:34.434] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:34.434] $ arguments :List of 28 [16:45:34.434] ..$ worker : chr "localhost" [16:45:34.434] ..$ master : NULL [16:45:34.434] ..$ port : int 34018 [16:45:34.434] ..$ connectTimeout : num 120 [16:45:34.434] ..$ timeout : num 120 [16:45:34.434] ..$ rscript : NULL [16:45:34.434] ..$ homogeneous : NULL [16:45:34.434] ..$ rscript_args : NULL [16:45:34.434] ..$ rscript_envs : NULL [16:45:34.434] ..$ rscript_libs : NULL [16:45:34.434] ..$ rscript_startup : NULL [16:45:34.434] ..$ rscript_sh : chr "auto" [16:45:34.434] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:34.434] ..$ methods : logi TRUE [16:45:34.434] ..$ socketOptions : chr "no-delay" [16:45:34.434] ..$ useXDR : logi TRUE [16:45:34.434] ..$ outfile : chr "/dev/null" [16:45:34.434] ..$ renice : int NA [16:45:34.434] ..$ rshcmd : NULL [16:45:34.434] ..$ user : NULL [16:45:34.434] ..$ revtunnel : logi NA [16:45:34.434] ..$ rshlogfile : NULL [16:45:34.434] ..$ rshopts : NULL [16:45:34.434] ..$ rank : int 1 [16:45:34.434] ..$ manual : logi FALSE [16:45:34.434] ..$ dryrun : logi FALSE [16:45:34.434] ..$ quiet : logi FALSE [16:45:34.434] ..$ setup_strategy : chr "parallel" [16:45:34.434] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:34.475] [local output] System call to launch all workers: [16:45:34.475] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d804c8b901.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34018 OUT=/dev/null TIMEOUT=120 XDR=TRUE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:34.475] [local output] Starting PSOCK main server [16:45:34.481] [local output] Workers launched [16:45:34.481] [local output] Waiting for workers to connect back [16:45:34.481] - [local output] 0 workers out of 1 ready [16:45:34.750] - [local output] 0 workers out of 1 ready [16:45:34.751] - [local output] 1 workers out of 1 ready [16:45:34.751] [local output] Launching of 1 workers completed [16:45:34.751] [local output] Number of nodes in cluster: 1 [16:45:34.752] [local output] Collecting session information from 1 workers [16:45:34.754] [local output] - Worker #1 of 1 [16:45:34.754] [local output] makeClusterPSOCK() ... done [16:45:34.762] [local output] makeClusterPSOCK() ... [16:45:34.767] [local output] Workers: [n = 1] 'localhost' [16:45:34.772] [local output] Base port: 22577 [16:45:34.772] [local output] Getting setup options for 1 cluster nodes ... [16:45:34.772] [local output] - Node #1 of 1 ... [16:45:34.773] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:34.775] [local output] Rscript port: 22577 [16:45:34.776] [local output] Getting setup options for 1 cluster nodes ... done [16:45:34.776] [local output] - Parallel setup requested for some PSOCK nodes [16:45:34.777] [local output] Setting up PSOCK nodes in parallel [16:45:34.777] List of 36 [16:45:34.777] $ worker : chr "localhost" [16:45:34.777] ..- attr(*, "localhost")= logi TRUE [16:45:34.777] $ master : chr "localhost" [16:45:34.777] $ port : int 22577 [16:45:34.777] $ connectTimeout : num 120 [16:45:34.777] $ timeout : num 120 [16:45:34.777] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:34.777] $ homogeneous : logi TRUE [16:45:34.777] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:34.777] $ rscript_envs : NULL [16:45:34.777] $ rscript_libs : NULL [16:45:34.777] $ rscript_startup : NULL [16:45:34.777] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:34.777] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:34.777] $ methods : logi TRUE [16:45:34.777] $ socketOptions : chr "no-delay" [16:45:34.777] $ useXDR : logi FALSE [16:45:34.777] $ outfile : chr "/dev/null" [16:45:34.777] $ renice : int NA [16:45:34.777] $ rshcmd : NULL [16:45:34.777] $ user : chr(0) [16:45:34.777] $ revtunnel : logi FALSE [16:45:34.777] $ rshlogfile : NULL [16:45:34.777] $ rshopts : chr(0) [16:45:34.777] $ rank : int 1 [16:45:34.777] $ manual : logi FALSE [16:45:34.777] $ dryrun : logi FALSE [16:45:34.777] $ quiet : logi FALSE [16:45:34.777] $ setup_strategy : chr "parallel" [16:45:34.777] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:34.777] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80c14426c.pid" [16:45:34.777] $ rshcmd_label : NULL [16:45:34.777] $ rsh_call : NULL [16:45:34.777] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:34.777] $ localMachine : logi TRUE [16:45:34.777] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:34.777] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:34.777] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:34.777] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:34.777] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:34.777] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:34.777] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:34.777] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:34.777] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:34.777] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:34.777] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:34.777] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:34.777] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:34.777] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:34.777] $ arguments :List of 28 [16:45:34.777] ..$ worker : chr "localhost" [16:45:34.777] ..$ master : NULL [16:45:34.777] ..$ port : int 22577 [16:45:34.777] ..$ connectTimeout : num 120 [16:45:34.777] ..$ timeout : num 120 [16:45:34.777] ..$ rscript : NULL [16:45:34.777] ..$ homogeneous : NULL [16:45:34.777] ..$ rscript_args : NULL [16:45:34.777] ..$ rscript_envs : NULL [16:45:34.777] ..$ rscript_libs : NULL [16:45:34.777] ..$ rscript_startup : NULL [16:45:34.777] ..$ rscript_sh : chr "auto" [16:45:34.777] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:34.777] ..$ methods : logi TRUE [16:45:34.777] ..$ socketOptions : chr "no-delay" [16:45:34.777] ..$ useXDR : logi FALSE [16:45:34.777] ..$ outfile : chr "/dev/null" [16:45:34.777] ..$ renice : int NA [16:45:34.777] ..$ rshcmd : NULL [16:45:34.777] ..$ user : NULL [16:45:34.777] ..$ revtunnel : logi NA [16:45:34.777] ..$ rshlogfile : NULL [16:45:34.777] ..$ rshopts : NULL [16:45:34.777] ..$ rank : int 1 [16:45:34.777] ..$ manual : logi FALSE [16:45:34.777] ..$ dryrun : logi FALSE [16:45:34.777] ..$ quiet : logi FALSE [16:45:34.777] ..$ setup_strategy : chr "parallel" [16:45:34.777] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:34.813] [local output] System call to launch all workers: [16:45:34.813] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80c14426c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=22577 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:34.813] [local output] Starting PSOCK main server [16:45:34.819] [local output] Workers launched [16:45:34.820] [local output] Waiting for workers to connect back [16:45:34.820] - [local output] 0 workers out of 1 ready [16:45:35.063] - [local output] 0 workers out of 1 ready [16:45:35.063] - [local output] 1 workers out of 1 ready [16:45:35.063] [local output] Launching of 1 workers completed [16:45:35.064] [local output] Number of nodes in cluster: 1 [16:45:35.064] [local output] Collecting session information from 1 workers [16:45:35.065] [local output] - Worker #1 of 1 [16:45:35.065] [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) + } [16:45:35.079] [local output] makeClusterPSOCK() ... [16:45:35.085] [local output] Workers: [n = 1] 'localhost' [16:45:35.089] [local output] Base port: 33169 [16:45:35.090] [local output] Getting setup options for 1 cluster nodes ... [16:45:35.090] [local output] - Node #1 of 1 ... [16:45:35.091] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:35.094] [local output] Rscript port: 33169 [16:45:35.094] [local output] Getting setup options for 1 cluster nodes ... done [16:45:35.095] [local output] - Parallel setup requested for some PSOCK nodes [16:45:35.095] [local output] Setting up PSOCK nodes in parallel [16:45:35.096] List of 36 [16:45:35.096] $ worker : chr "localhost" [16:45:35.096] ..- attr(*, "localhost")= logi TRUE [16:45:35.096] $ master : chr "localhost" [16:45:35.096] $ port : int 33169 [16:45:35.096] $ connectTimeout : num 120 [16:45:35.096] $ timeout : num 120 [16:45:35.096] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:35.096] $ homogeneous : logi TRUE [16:45:35.096] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:35.096] $ rscript_envs : NULL [16:45:35.096] $ rscript_libs : NULL [16:45:35.096] $ rscript_startup : NULL [16:45:35.096] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:35.096] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:35.096] $ methods : logi TRUE [16:45:35.096] $ socketOptions : NULL [16:45:35.096] $ useXDR : logi FALSE [16:45:35.096] $ outfile : chr "/dev/null" [16:45:35.096] $ renice : int NA [16:45:35.096] $ rshcmd : NULL [16:45:35.096] $ user : chr(0) [16:45:35.096] $ revtunnel : logi FALSE [16:45:35.096] $ rshlogfile : NULL [16:45:35.096] $ rshopts : chr(0) [16:45:35.096] $ rank : int 1 [16:45:35.096] $ manual : logi FALSE [16:45:35.096] $ dryrun : logi FALSE [16:45:35.096] $ quiet : logi FALSE [16:45:35.096] $ setup_strategy : chr "parallel" [16:45:35.096] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:35.096] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d802f517bb2.pid" [16:45:35.096] $ rshcmd_label : NULL [16:45:35.096] $ rsh_call : NULL [16:45:35.096] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:35.096] $ localMachine : logi TRUE [16:45:35.096] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:35.096] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:35.096] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:35.096] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:35.096] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:35.096] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:35.096] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:35.096] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:35.096] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:35.096] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:35.096] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:35.096] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:35.096] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:35.096] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:35.096] $ arguments :List of 28 [16:45:35.096] ..$ worker : chr "localhost" [16:45:35.096] ..$ master : NULL [16:45:35.096] ..$ port : int 33169 [16:45:35.096] ..$ connectTimeout : num 120 [16:45:35.096] ..$ timeout : num 120 [16:45:35.096] ..$ rscript : NULL [16:45:35.096] ..$ homogeneous : NULL [16:45:35.096] ..$ rscript_args : NULL [16:45:35.096] ..$ rscript_envs : NULL [16:45:35.096] ..$ rscript_libs : NULL [16:45:35.096] ..$ rscript_startup : NULL [16:45:35.096] ..$ rscript_sh : chr "auto" [16:45:35.096] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:35.096] ..$ methods : logi TRUE [16:45:35.096] ..$ socketOptions : NULL [16:45:35.096] ..$ useXDR : logi FALSE [16:45:35.096] ..$ outfile : chr "/dev/null" [16:45:35.096] ..$ renice : int NA [16:45:35.096] ..$ rshcmd : NULL [16:45:35.096] ..$ user : NULL [16:45:35.096] ..$ revtunnel : logi NA [16:45:35.096] ..$ rshlogfile : NULL [16:45:35.096] ..$ rshopts : NULL [16:45:35.096] ..$ rank : int 1 [16:45:35.096] ..$ manual : logi FALSE [16:45:35.096] ..$ dryrun : logi FALSE [16:45:35.096] ..$ quiet : logi FALSE [16:45:35.096] ..$ setup_strategy : chr "parallel" [16:45:35.096] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:35.125] [local output] System call to launch all workers: [16:45:35.126] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d802f517bb2.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33169 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:35.126] [local output] Starting PSOCK main server [16:45:35.131] [local output] Workers launched [16:45:35.131] [local output] Waiting for workers to connect back [16:45:35.132] - [local output] 0 workers out of 1 ready [16:45:35.378] - [local output] 0 workers out of 1 ready [16:45:35.379] - [local output] 1 workers out of 1 ready [16:45:35.379] [local output] Launching of 1 workers completed [16:45:35.379] [local output] Number of nodes in cluster: 1 [16:45:35.380] [local output] Collecting session information from 1 workers [16:45:35.381] [local output] - Worker #1 of 1 [16:45:35.381] [local output] makeClusterPSOCK() ... done [16:45:35.388] [local output] makeClusterPSOCK() ... [16:45:35.394] [local output] Workers: [n = 1] 'localhost' [16:45:35.398] [local output] Base port: 32909 [16:45:35.398] [local output] Getting setup options for 1 cluster nodes ... [16:45:35.399] [local output] - Node #1 of 1 ... [16:45:35.399] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:35.402] [local output] Rscript port: 32909 [16:45:35.403] [local output] Getting setup options for 1 cluster nodes ... done [16:45:35.404] [local output] - Parallel setup requested for some PSOCK nodes [16:45:35.405] [local output] Setting up PSOCK nodes in parallel [16:45:35.405] List of 36 [16:45:35.405] $ worker : chr "localhost" [16:45:35.405] ..- attr(*, "localhost")= logi TRUE [16:45:35.405] $ master : chr "localhost" [16:45:35.405] $ port : int 32909 [16:45:35.405] $ connectTimeout : num 120 [16:45:35.405] $ timeout : num 120 [16:45:35.405] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:35.405] $ homogeneous : logi TRUE [16:45:35.405] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:35.405] $ rscript_envs : NULL [16:45:35.405] $ rscript_libs : NULL [16:45:35.405] $ rscript_startup : NULL [16:45:35.405] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:35.405] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:35.405] $ methods : logi TRUE [16:45:35.405] $ socketOptions : NULL [16:45:35.405] $ useXDR : logi FALSE [16:45:35.405] $ outfile : chr "/dev/null" [16:45:35.405] $ renice : int NA [16:45:35.405] $ rshcmd : NULL [16:45:35.405] $ user : chr(0) [16:45:35.405] $ revtunnel : logi FALSE [16:45:35.405] $ rshlogfile : NULL [16:45:35.405] $ rshopts : chr(0) [16:45:35.405] $ rank : int 1 [16:45:35.405] $ manual : logi FALSE [16:45:35.405] $ dryrun : logi FALSE [16:45:35.405] $ quiet : logi FALSE [16:45:35.405] $ setup_strategy : chr "parallel" [16:45:35.405] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:35.405] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80559914a5.pid" [16:45:35.405] $ rshcmd_label : NULL [16:45:35.405] $ rsh_call : NULL [16:45:35.405] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:35.405] $ localMachine : logi TRUE [16:45:35.405] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:35.405] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:35.405] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:35.405] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:35.405] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:35.405] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:35.405] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:35.405] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:35.405] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:35.405] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:35.405] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:35.405] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:35.405] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:35.405] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:35.405] $ arguments :List of 28 [16:45:35.405] ..$ worker : chr "localhost" [16:45:35.405] ..$ master : NULL [16:45:35.405] ..$ port : int 32909 [16:45:35.405] ..$ connectTimeout : num 120 [16:45:35.405] ..$ timeout : num 120 [16:45:35.405] ..$ rscript : NULL [16:45:35.405] ..$ homogeneous : NULL [16:45:35.405] ..$ rscript_args : NULL [16:45:35.405] ..$ rscript_envs : NULL [16:45:35.405] ..$ rscript_libs : NULL [16:45:35.405] ..$ rscript_startup : NULL [16:45:35.405] ..$ rscript_sh : chr "auto" [16:45:35.405] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:35.405] ..$ methods : logi TRUE [16:45:35.405] ..$ socketOptions : chr "NULL" [16:45:35.405] ..$ useXDR : logi FALSE [16:45:35.405] ..$ outfile : chr "/dev/null" [16:45:35.405] ..$ renice : int NA [16:45:35.405] ..$ rshcmd : NULL [16:45:35.405] ..$ user : NULL [16:45:35.405] ..$ revtunnel : logi NA [16:45:35.405] ..$ rshlogfile : NULL [16:45:35.405] ..$ rshopts : NULL [16:45:35.405] ..$ rank : int 1 [16:45:35.405] ..$ manual : logi FALSE [16:45:35.405] ..$ dryrun : logi FALSE [16:45:35.405] ..$ quiet : logi FALSE [16:45:35.405] ..$ setup_strategy : chr "parallel" [16:45:35.405] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:35.445] [local output] System call to launch all workers: [16:45:35.445] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80559914a5.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=32909 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:35.445] [local output] Starting PSOCK main server [16:45:35.451] [local output] Workers launched [16:45:35.451] [local output] Waiting for workers to connect back [16:45:35.451] - [local output] 0 workers out of 1 ready [16:45:35.714] - [local output] 0 workers out of 1 ready [16:45:35.714] - [local output] 1 workers out of 1 ready [16:45:35.714] [local output] Launching of 1 workers completed [16:45:35.715] [local output] Number of nodes in cluster: 1 [16:45:35.715] [local output] Collecting session information from 1 workers [16:45:35.716] [local output] - Worker #1 of 1 [16:45:35.716] [local output] makeClusterPSOCK() ... done [16:45:35.721] [local output] makeClusterPSOCK() ... [16:45:35.729] [local output] Workers: [n = 1] 'localhost' [16:45:35.734] [local output] Base port: 38334 [16:45:35.734] [local output] Getting setup options for 1 cluster nodes ... [16:45:35.734] [local output] - Node #1 of 1 ... [16:45:35.735] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:35.737] [local output] Rscript port: 38334 [16:45:35.738] [local output] Getting setup options for 1 cluster nodes ... done [16:45:35.738] [local output] - Parallel setup requested for some PSOCK nodes [16:45:35.739] [local output] Setting up PSOCK nodes in parallel [16:45:35.739] List of 36 [16:45:35.739] $ worker : chr "localhost" [16:45:35.739] ..- attr(*, "localhost")= logi TRUE [16:45:35.739] $ master : chr "localhost" [16:45:35.739] $ port : int 38334 [16:45:35.739] $ connectTimeout : num 120 [16:45:35.739] $ timeout : num 120 [16:45:35.739] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:35.739] $ homogeneous : logi TRUE [16:45:35.739] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:35.739] $ rscript_envs : NULL [16:45:35.739] $ rscript_libs : NULL [16:45:35.739] $ rscript_startup : NULL [16:45:35.739] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:35.739] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:35.739] $ methods : logi TRUE [16:45:35.739] $ socketOptions : chr "no-delay" [16:45:35.739] $ useXDR : logi FALSE [16:45:35.739] $ outfile : chr "/dev/null" [16:45:35.739] $ renice : int NA [16:45:35.739] $ rshcmd : NULL [16:45:35.739] $ user : chr(0) [16:45:35.739] $ revtunnel : logi FALSE [16:45:35.739] $ rshlogfile : NULL [16:45:35.739] $ rshopts : chr(0) [16:45:35.739] $ rank : int 1 [16:45:35.739] $ manual : logi FALSE [16:45:35.739] $ dryrun : logi FALSE [16:45:35.739] $ quiet : logi FALSE [16:45:35.739] $ setup_strategy : chr "parallel" [16:45:35.739] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:35.739] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80551f1973.pid" [16:45:35.739] $ rshcmd_label : NULL [16:45:35.739] $ rsh_call : NULL [16:45:35.739] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:35.739] $ localMachine : logi TRUE [16:45:35.739] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:35.739] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:35.739] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:35.739] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:35.739] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:35.739] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:35.739] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:35.739] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:35.739] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:35.739] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:35.739] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:35.739] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:35.739] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:35.739] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:35.739] $ arguments :List of 28 [16:45:35.739] ..$ worker : chr "localhost" [16:45:35.739] ..$ master : NULL [16:45:35.739] ..$ port : int 38334 [16:45:35.739] ..$ connectTimeout : num 120 [16:45:35.739] ..$ timeout : num 120 [16:45:35.739] ..$ rscript : NULL [16:45:35.739] ..$ homogeneous : NULL [16:45:35.739] ..$ rscript_args : NULL [16:45:35.739] ..$ rscript_envs : NULL [16:45:35.739] ..$ rscript_libs : NULL [16:45:35.739] ..$ rscript_startup : NULL [16:45:35.739] ..$ rscript_sh : chr "auto" [16:45:35.739] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:35.739] ..$ methods : logi TRUE [16:45:35.739] ..$ socketOptions : chr "no-delay" [16:45:35.739] ..$ useXDR : logi FALSE [16:45:35.739] ..$ outfile : chr "/dev/null" [16:45:35.739] ..$ renice : int NA [16:45:35.739] ..$ rshcmd : NULL [16:45:35.739] ..$ user : NULL [16:45:35.739] ..$ revtunnel : logi NA [16:45:35.739] ..$ rshlogfile : NULL [16:45:35.739] ..$ rshopts : NULL [16:45:35.739] ..$ rank : int 1 [16:45:35.739] ..$ manual : logi FALSE [16:45:35.739] ..$ dryrun : logi FALSE [16:45:35.739] ..$ quiet : logi FALSE [16:45:35.739] ..$ setup_strategy : chr "parallel" [16:45:35.739] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:35.774] [local output] System call to launch all workers: [16:45:35.774] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80551f1973.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38334 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:35.774] [local output] Starting PSOCK main server [16:45:35.780] [local output] Workers launched [16:45:35.780] [local output] Waiting for workers to connect back [16:45:35.780] - [local output] 0 workers out of 1 ready [16:45:36.047] - [local output] 0 workers out of 1 ready [16:45:36.048] - [local output] 1 workers out of 1 ready [16:45:36.048] [local output] Launching of 1 workers completed [16:45:36.049] [local output] Number of nodes in cluster: 1 [16:45:36.049] [local output] Collecting session information from 1 workers [16:45:36.050] [local output] - Worker #1 of 1 [16:45:36.051] [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) + } [16:45:36.068] [local output] makeClusterPSOCK() ... [16:45:36.074] [local output] Workers: [n = 1] 'localhost' [16:45:36.079] [local output] Base port: 29155 [16:45:36.079] [local output] Getting setup options for 1 cluster nodes ... [16:45:36.080] [local output] - Node #1 of 1 ... [16:45:36.080] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:36.083] [local output] Rscript port: 29155 [16:45:36.084] [local output] Getting setup options for 1 cluster nodes ... done [16:45:36.084] [local output] - Parallel setup requested for some PSOCK nodes [16:45:36.085] [local output] Setting up PSOCK nodes in parallel [16:45:36.085] List of 36 [16:45:36.085] $ worker : chr "localhost" [16:45:36.085] ..- attr(*, "localhost")= logi TRUE [16:45:36.085] $ master : chr "localhost" [16:45:36.085] $ port : int 29155 [16:45:36.085] $ connectTimeout : num 120 [16:45:36.085] $ timeout : num 120 [16:45:36.085] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:36.085] $ homogeneous : logi TRUE [16:45:36.085] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:36.085] $ rscript_envs : NULL [16:45:36.085] $ rscript_libs : NULL [16:45:36.085] $ rscript_startup : NULL [16:45:36.085] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:36.085] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:36.085] $ methods : logi TRUE [16:45:36.085] $ socketOptions : chr "no-delay" [16:45:36.085] $ useXDR : logi FALSE [16:45:36.085] $ outfile : chr "/dev/null" [16:45:36.085] $ renice : int NA [16:45:36.085] $ rshcmd : NULL [16:45:36.085] $ user : chr(0) [16:45:36.085] $ revtunnel : logi FALSE [16:45:36.085] $ rshlogfile : NULL [16:45:36.085] $ rshopts : chr(0) [16:45:36.085] $ rank : int 1 [16:45:36.085] $ manual : logi FALSE [16:45:36.085] $ dryrun : logi FALSE [16:45:36.085] $ quiet : logi FALSE [16:45:36.085] $ setup_strategy : chr "parallel" [16:45:36.085] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:36.085] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80350e2470.pid" [16:45:36.085] $ rshcmd_label : NULL [16:45:36.085] $ rsh_call : NULL [16:45:36.085] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:36.085] $ localMachine : logi TRUE [16:45:36.085] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:36.085] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:36.085] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:36.085] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:36.085] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:36.085] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:36.085] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:36.085] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:36.085] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:36.085] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:36.085] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:36.085] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:36.085] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:36.085] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:36.085] $ arguments :List of 28 [16:45:36.085] ..$ worker : chr "localhost" [16:45:36.085] ..$ master : NULL [16:45:36.085] ..$ port : int 29155 [16:45:36.085] ..$ connectTimeout : num 120 [16:45:36.085] ..$ timeout : num 120 [16:45:36.085] ..$ rscript : NULL [16:45:36.085] ..$ homogeneous : NULL [16:45:36.085] ..$ rscript_args : NULL [16:45:36.085] ..$ rscript_envs : NULL [16:45:36.085] ..$ rscript_libs : NULL [16:45:36.085] ..$ rscript_startup : NULL [16:45:36.085] ..$ rscript_sh : chr "auto" [16:45:36.085] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:36.085] ..$ methods : logi TRUE [16:45:36.085] ..$ socketOptions : chr "no-delay" [16:45:36.085] ..$ useXDR : logi FALSE [16:45:36.085] ..$ outfile : chr "/dev/null" [16:45:36.085] ..$ renice : int NA [16:45:36.085] ..$ rshcmd : NULL [16:45:36.085] ..$ user : NULL [16:45:36.085] ..$ revtunnel : logi NA [16:45:36.085] ..$ rshlogfile : NULL [16:45:36.085] ..$ rshopts : NULL [16:45:36.085] ..$ rank : int 1 [16:45:36.085] ..$ manual : logi FALSE [16:45:36.085] ..$ dryrun : logi FALSE [16:45:36.085] ..$ quiet : logi FALSE [16:45:36.085] ..$ setup_strategy : chr "parallel" [16:45:36.085] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:36.121] [local output] System call to launch all workers: [16:45:36.122] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80350e2470.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=29155 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:36.122] [local output] Starting PSOCK main server [16:45:36.127] [local output] Workers launched [16:45:36.128] [local output] Waiting for workers to connect back [16:45:36.128] - [local output] 0 workers out of 1 ready [16:45:36.365] - [local output] 0 workers out of 1 ready [16:45:36.366] - [local output] 1 workers out of 1 ready [16:45:36.367] [local output] Launching of 1 workers completed [16:45:36.367] [local output] Number of nodes in cluster: 1 [16:45:36.367] [local output] Collecting session information from 1 workers [16:45:36.368] [local output] - Worker #1 of 1 [16:45:36.369] [local output] makeClusterPSOCK() ... done [16:45:36.375] [local output] makeClusterPSOCK() ... [16:45:36.379] [local output] Workers: [n = 1] 'localhost' [16:45:36.382] [local output] Base port: 23978 [16:45:36.382] [local output] Getting setup options for 1 cluster nodes ... [16:45:36.383] [local output] - Node #1 of 1 ... [16:45:36.383] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:36.385] [local output] Rscript port: 23978 [16:45:36.385] [local output] Getting setup options for 1 cluster nodes ... done [16:45:36.385] [local output] - Parallel setup requested for some PSOCK nodes [16:45:36.386] [local output] Setting up PSOCK nodes in parallel [16:45:36.386] List of 36 [16:45:36.386] $ worker : chr "localhost" [16:45:36.386] ..- attr(*, "localhost")= logi TRUE [16:45:36.386] $ master : chr "localhost" [16:45:36.386] $ port : int 23978 [16:45:36.386] $ connectTimeout : num 120 [16:45:36.386] $ timeout : num 120 [16:45:36.386] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:36.386] $ homogeneous : logi TRUE [16:45:36.386] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:36.386] $ rscript_envs : NULL [16:45:36.386] $ rscript_libs : NULL [16:45:36.386] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [16:45:36.386] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:36.386] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:36.386] $ methods : logi TRUE [16:45:36.386] $ socketOptions : chr "no-delay" [16:45:36.386] $ useXDR : logi FALSE [16:45:36.386] $ outfile : chr "/dev/null" [16:45:36.386] $ renice : int NA [16:45:36.386] $ rshcmd : NULL [16:45:36.386] $ user : chr(0) [16:45:36.386] $ revtunnel : logi FALSE [16:45:36.386] $ rshlogfile : NULL [16:45:36.386] $ rshopts : chr(0) [16:45:36.386] $ rank : int 1 [16:45:36.386] $ manual : logi FALSE [16:45:36.386] $ dryrun : logi FALSE [16:45:36.386] $ quiet : logi FALSE [16:45:36.386] $ setup_strategy : chr "parallel" [16:45:36.386] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:36.386] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80dd8d16.pid" [16:45:36.386] $ rshcmd_label : NULL [16:45:36.386] $ rsh_call : NULL [16:45:36.386] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:36.386] $ localMachine : logi TRUE [16:45:36.386] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:36.386] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:36.386] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:36.386] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:36.386] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:36.386] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:36.386] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:36.386] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:36.386] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:36.386] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:36.386] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:36.386] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:36.386] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:36.386] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:36.386] $ arguments :List of 28 [16:45:36.386] ..$ worker : chr "localhost" [16:45:36.386] ..$ master : NULL [16:45:36.386] ..$ port : int 23978 [16:45:36.386] ..$ connectTimeout : num 120 [16:45:36.386] ..$ timeout : num 120 [16:45:36.386] ..$ rscript : NULL [16:45:36.386] ..$ homogeneous : NULL [16:45:36.386] ..$ rscript_args : NULL [16:45:36.386] ..$ rscript_envs : NULL [16:45:36.386] ..$ rscript_libs : NULL [16:45:36.386] ..$ rscript_startup : chr "options(abc = 42L)" [16:45:36.386] ..$ rscript_sh : chr "auto" [16:45:36.386] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:36.386] ..$ methods : logi TRUE [16:45:36.386] ..$ socketOptions : chr "no-delay" [16:45:36.386] ..$ useXDR : logi FALSE [16:45:36.386] ..$ outfile : chr "/dev/null" [16:45:36.386] ..$ renice : int NA [16:45:36.386] ..$ rshcmd : NULL [16:45:36.386] ..$ user : NULL [16:45:36.386] ..$ revtunnel : logi NA [16:45:36.386] ..$ rshlogfile : NULL [16:45:36.386] ..$ rshopts : NULL [16:45:36.386] ..$ rank : int 1 [16:45:36.386] ..$ manual : logi FALSE [16:45:36.386] ..$ dryrun : logi FALSE [16:45:36.386] ..$ quiet : logi FALSE [16:45:36.386] ..$ setup_strategy : chr "parallel" [16:45:36.386] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:36.414] [local output] System call to launch all workers: [16:45:36.415] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80dd8d16.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=23978 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:36.415] [local output] Starting PSOCK main server [16:45:36.420] [local output] Workers launched [16:45:36.420] [local output] Waiting for workers to connect back [16:45:36.421] - [local output] 0 workers out of 1 ready [16:45:36.714] - [local output] 0 workers out of 1 ready [16:45:36.715] - [local output] 1 workers out of 1 ready [16:45:36.715] [local output] Launching of 1 workers completed [16:45:36.715] [local output] Number of nodes in cluster: 1 [16:45:36.715] [local output] Collecting session information from 1 workers [16:45:36.716] [local output] - Worker #1 of 1 [16:45:36.717] [local output] makeClusterPSOCK() ... done [16:45:36.722] [local output] makeClusterPSOCK() ... [16:45:36.730] [local output] Workers: [n = 1] 'localhost' [16:45:36.734] [local output] Base port: 34249 [16:45:36.734] [local output] Getting setup options for 1 cluster nodes ... [16:45:36.734] [local output] - Node #1 of 1 ... [16:45:36.735] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:36.737] [local output] Rscript port: 34249 [16:45:36.738] [local output] Getting setup options for 1 cluster nodes ... done [16:45:36.738] [local output] - Parallel setup requested for some PSOCK nodes [16:45:36.739] [local output] Setting up PSOCK nodes in parallel [16:45:36.739] List of 36 [16:45:36.739] $ worker : chr "localhost" [16:45:36.739] ..- attr(*, "localhost")= logi TRUE [16:45:36.739] $ master : chr "localhost" [16:45:36.739] $ port : int 34249 [16:45:36.739] $ connectTimeout : num 120 [16:45:36.739] $ timeout : num 120 [16:45:36.739] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:36.739] $ homogeneous : logi TRUE [16:45:36.739] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:36.739] $ rscript_envs : NULL [16:45:36.739] $ rscript_libs : NULL [16:45:36.739] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [16:45:36.739] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:36.739] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:36.739] $ methods : logi TRUE [16:45:36.739] $ socketOptions : chr "no-delay" [16:45:36.739] $ useXDR : logi FALSE [16:45:36.739] $ outfile : chr "/dev/null" [16:45:36.739] $ renice : int NA [16:45:36.739] $ rshcmd : NULL [16:45:36.739] $ user : chr(0) [16:45:36.739] $ revtunnel : logi FALSE [16:45:36.739] $ rshlogfile : NULL [16:45:36.739] $ rshopts : chr(0) [16:45:36.739] $ rank : int 1 [16:45:36.739] $ manual : logi FALSE [16:45:36.739] $ dryrun : logi FALSE [16:45:36.739] $ quiet : logi FALSE [16:45:36.739] $ setup_strategy : chr "parallel" [16:45:36.739] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:36.739] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8043ca84a.pid" [16:45:36.739] $ rshcmd_label : NULL [16:45:36.739] $ rsh_call : NULL [16:45:36.739] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:36.739] $ localMachine : logi TRUE [16:45:36.739] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:36.739] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:36.739] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:36.739] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:36.739] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:36.739] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:36.739] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:36.739] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:36.739] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:36.739] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:36.739] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:36.739] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:36.739] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:36.739] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:36.739] $ arguments :List of 28 [16:45:36.739] ..$ worker : chr "localhost" [16:45:36.739] ..$ master : NULL [16:45:36.739] ..$ port : int 34249 [16:45:36.739] ..$ connectTimeout : num 120 [16:45:36.739] ..$ timeout : num 120 [16:45:36.739] ..$ rscript : NULL [16:45:36.739] ..$ homogeneous : NULL [16:45:36.739] ..$ rscript_args : NULL [16:45:36.739] ..$ rscript_envs : NULL [16:45:36.739] ..$ rscript_libs : NULL [16:45:36.739] ..$ rscript_startup : language options(abc = 42L) [16:45:36.739] ..$ rscript_sh : chr "auto" [16:45:36.739] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:36.739] ..$ methods : logi TRUE [16:45:36.739] ..$ socketOptions : chr "no-delay" [16:45:36.739] ..$ useXDR : logi FALSE [16:45:36.739] ..$ outfile : chr "/dev/null" [16:45:36.739] ..$ renice : int NA [16:45:36.739] ..$ rshcmd : NULL [16:45:36.739] ..$ user : NULL [16:45:36.739] ..$ revtunnel : logi NA [16:45:36.739] ..$ rshlogfile : NULL [16:45:36.739] ..$ rshopts : NULL [16:45:36.739] ..$ rank : int 1 [16:45:36.739] ..$ manual : logi FALSE [16:45:36.739] ..$ dryrun : logi FALSE [16:45:36.739] ..$ quiet : logi FALSE [16:45:36.739] ..$ setup_strategy : chr "parallel" [16:45:36.739] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:36.774] [local output] System call to launch all workers: [16:45:36.775] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8043ca84a.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=34249 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:36.775] [local output] Starting PSOCK main server [16:45:36.780] [local output] Workers launched [16:45:36.781] [local output] Waiting for workers to connect back [16:45:36.781] - [local output] 0 workers out of 1 ready [16:45:37.031] - [local output] 0 workers out of 1 ready [16:45:37.032] - [local output] 1 workers out of 1 ready [16:45:37.032] [local output] Launching of 1 workers completed [16:45:37.032] [local output] Number of nodes in cluster: 1 [16:45:37.033] [local output] Collecting session information from 1 workers [16:45:37.034] [local output] - Worker #1 of 1 [16:45:37.035] [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) + } [16:45:37.086] [local output] makeClusterPSOCK() ... [16:45:37.092] [local output] Workers: [n = 2] 'localhost', 'localhost' [16:45:37.097] [local output] Base port: 23192 [16:45:37.097] [local output] Getting setup options for 2 cluster nodes ... [16:45:37.097] [local output] - Node #1 of 2 ... [16:45:37.098] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:37.100] [local output] Rscript port: 23192 [16:45:37.101] [local output] - Node #2 of 2 ... [16:45:37.101] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:37.103] [local output] Rscript port: 23192 [16:45:37.104] [local output] Getting setup options for 2 cluster nodes ... done [16:45:37.104] [local output] Creating node #1 of 2 ... [16:45:37.105] [local output] - setting up node [16:45:37.105] [local output] - attempt #1 of 3 [16:45:37.105] [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:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d804fe51de1.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=23192 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [16:45:37.111] [local output] - Exit code of system() call: 0 [16:45:37.111] [local output] Waiting for worker #1 on 'localhost' to connect back [16:45:37.359] [local output] Connection with worker #1 on 'localhost' established [16:45:37.359] [local output] Creating node #1 of 2 ... done [16:45:37.360] [local output] Creating node #2 of 2 ... [16:45:37.360] [local output] - setting up node [16:45:37.360] [local output] - attempt #1 of 3 [16:45:37.360] [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:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=2.parallelly.parent=101760.18d8028052a3b.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=23192 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [16:45:37.366] [local output] - Exit code of system() call: 0 [16:45:37.366] [local output] Waiting for worker #2 on 'localhost' to connect back [16:45:37.599] [local output] Connection with worker #2 on 'localhost' established [16:45:37.600] [local output] Creating node #2 of 2 ... done [16:45:37.600] [local output] Launching of 2 workers completed [16:45:37.600] [local output] Number of nodes in cluster: 2 [16:45:37.601] [local output] Collecting session information from 2 workers [16:45:37.603] [local output] - Worker #1 of 2 [16:45:37.605] [local output] - Worker #2 of 2 [16:45:37.605] [local output] makeClusterPSOCK() ... done user system elapsed 0.03 0.02 0.51 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32) [16:45:37.694] [local output] makeClusterPSOCK() ... [16:45:37.700] [local output] Workers: [n = 2] 'localhost', 'localhost' [16:45:37.705] [local output] Base port: 30607 [16:45:37.706] [local output] Getting setup options for 2 cluster nodes ... [16:45:37.706] [local output] - Node #1 of 2 ... [16:45:37.707] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:37.710] [local output] Rscript port: 30607 [16:45:37.710] [local output] - Node #2 of 2 ... [16:45:37.711] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:37.713] [local output] Rscript port: 30607 [16:45:37.714] [local output] Getting setup options for 2 cluster nodes ... done [16:45:37.714] [local output] - Parallel setup requested for some PSOCK nodes [16:45:37.715] [local output] Setting up PSOCK nodes in parallel [16:45:37.715] List of 36 [16:45:37.715] $ worker : chr "localhost" [16:45:37.715] ..- attr(*, "localhost")= logi TRUE [16:45:37.715] $ master : chr "localhost" [16:45:37.715] $ port : int 30607 [16:45:37.715] $ connectTimeout : num 120 [16:45:37.715] $ timeout : num 120 [16:45:37.715] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:37.715] $ homogeneous : logi TRUE [16:45:37.715] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:37.715] $ rscript_envs : NULL [16:45:37.715] $ rscript_libs : NULL [16:45:37.715] $ rscript_startup : NULL [16:45:37.715] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:37.715] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:37.715] $ methods : logi TRUE [16:45:37.715] $ socketOptions : chr "no-delay" [16:45:37.715] $ useXDR : logi FALSE [16:45:37.715] $ outfile : chr "/dev/null" [16:45:37.715] $ renice : int NA [16:45:37.715] $ rshcmd : NULL [16:45:37.715] $ user : chr(0) [16:45:37.715] $ revtunnel : logi FALSE [16:45:37.715] $ rshlogfile : NULL [16:45:37.715] $ rshopts : chr(0) [16:45:37.715] $ rank : int 1 [16:45:37.715] $ manual : logi FALSE [16:45:37.715] $ dryrun : logi FALSE [16:45:37.715] $ quiet : logi FALSE [16:45:37.715] $ setup_strategy : chr "parallel" [16:45:37.715] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:37.715] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d802eb24c0f.pid" [16:45:37.715] $ rshcmd_label : NULL [16:45:37.715] $ rsh_call : NULL [16:45:37.715] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:37.715] $ localMachine : logi TRUE [16:45:37.715] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:37.715] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:37.715] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:37.715] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:37.715] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:37.715] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:37.715] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:37.715] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:37.715] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:37.715] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:37.715] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:37.715] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:37.715] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:37.715] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:37.715] $ arguments :List of 28 [16:45:37.715] ..$ worker : chr "localhost" [16:45:37.715] ..$ master : NULL [16:45:37.715] ..$ port : int 30607 [16:45:37.715] ..$ connectTimeout : num 120 [16:45:37.715] ..$ timeout : num 120 [16:45:37.715] ..$ rscript : NULL [16:45:37.715] ..$ homogeneous : NULL [16:45:37.715] ..$ rscript_args : NULL [16:45:37.715] ..$ rscript_envs : NULL [16:45:37.715] ..$ rscript_libs : NULL [16:45:37.715] ..$ rscript_startup : NULL [16:45:37.715] ..$ rscript_sh : chr "auto" [16:45:37.715] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:37.715] ..$ methods : logi TRUE [16:45:37.715] ..$ socketOptions : chr "no-delay" [16:45:37.715] ..$ useXDR : logi FALSE [16:45:37.715] ..$ outfile : chr "/dev/null" [16:45:37.715] ..$ renice : int NA [16:45:37.715] ..$ rshcmd : NULL [16:45:37.715] ..$ user : NULL [16:45:37.715] ..$ revtunnel : logi NA [16:45:37.715] ..$ rshlogfile : NULL [16:45:37.715] ..$ rshopts : NULL [16:45:37.715] ..$ rank : int 1 [16:45:37.715] ..$ manual : logi FALSE [16:45:37.715] ..$ dryrun : logi FALSE [16:45:37.715] ..$ quiet : logi FALSE [16:45:37.715] ..$ setup_strategy : chr "parallel" [16:45:37.715] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:37.755] [local output] System call to launch all workers: [16:45:37.755] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d802eb24c0f.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30607 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:37.755] [local output] Starting PSOCK main server [16:45:37.765] [local output] Workers launched [16:45:37.766] [local output] Waiting for workers to connect back [16:45:37.766] - [local output] 0 workers out of 2 ready [16:45:38.036] - [local output] 0 workers out of 2 ready [16:45:38.037] - [local output] 1 workers out of 2 ready [16:45:38.044] - [local output] 1 workers out of 2 ready [16:45:38.045] - [local output] 2 workers out of 2 ready [16:45:38.046] [local output] Launching of 2 workers completed [16:45:38.046] [local output] Number of nodes in cluster: 2 [16:45:38.047] [local output] Collecting session information from 2 workers [16:45:38.048] [local output] - Worker #1 of 2 [16:45:38.050] [local output] - Worker #2 of 2 [16:45:38.050] [local output] makeClusterPSOCK() ... done user system elapsed 0.05 0.01 0.34 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 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 [16:45:38.064] [local output] makeClusterPSOCK() ... [16:45:38.070] [local output] Workers: [n = 1] 'localhost' [16:45:38.076] [local output] Base port: 31513 [16:45:38.076] [local output] Getting setup options for 1 cluster nodes ... [16:45:38.076] [local output] - Node #1 of 1 ... [16:45:38.077] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:38.080] [local output] Rscript port: 31513 [16:45:38.081] [local output] Getting setup options for 1 cluster nodes ... done [16:45:38.081] [local output] - Parallel setup requested for some PSOCK nodes [16:45:38.082] [local output] Setting up PSOCK nodes in parallel [16:45:38.082] List of 36 [16:45:38.082] $ worker : chr "localhost" [16:45:38.082] ..- attr(*, "localhost")= logi TRUE [16:45:38.082] $ master : chr "localhost" [16:45:38.082] $ port : int 31513 [16:45:38.082] $ connectTimeout : num 120 [16:45:38.082] $ timeout : num 120 [16:45:38.082] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:38.082] $ homogeneous : logi TRUE [16:45:38.082] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:38.082] $ rscript_envs : NULL [16:45:38.082] $ rscript_libs : NULL [16:45:38.082] $ rscript_startup : NULL [16:45:38.082] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:38.082] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:38.082] $ methods : logi TRUE [16:45:38.082] $ socketOptions : chr "no-delay" [16:45:38.082] $ useXDR : logi FALSE [16:45:38.082] $ outfile : chr "/dev/null" [16:45:38.082] $ renice : int NA [16:45:38.082] $ rshcmd : NULL [16:45:38.082] $ user : chr(0) [16:45:38.082] $ revtunnel : logi FALSE [16:45:38.082] $ rshlogfile : NULL [16:45:38.082] $ rshopts : chr(0) [16:45:38.082] $ rank : int 1 [16:45:38.082] $ manual : logi FALSE [16:45:38.082] $ dryrun : logi FALSE [16:45:38.082] $ quiet : logi FALSE [16:45:38.082] $ setup_strategy : chr "parallel" [16:45:38.082] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:38.082] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8061313d4d.pid" [16:45:38.082] $ rshcmd_label : NULL [16:45:38.082] $ rsh_call : NULL [16:45:38.082] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:38.082] $ localMachine : logi TRUE [16:45:38.082] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:38.082] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:38.082] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:38.082] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:38.082] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:38.082] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:38.082] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:38.082] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:38.082] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:38.082] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:38.082] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:38.082] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:38.082] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:38.082] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:38.082] $ arguments :List of 28 [16:45:38.082] ..$ worker : chr "localhost" [16:45:38.082] ..$ master : NULL [16:45:38.082] ..$ port : int 31513 [16:45:38.082] ..$ connectTimeout : num 120 [16:45:38.082] ..$ timeout : num 120 [16:45:38.082] ..$ rscript : NULL [16:45:38.082] ..$ homogeneous : NULL [16:45:38.082] ..$ rscript_args : NULL [16:45:38.082] ..$ rscript_envs : NULL [16:45:38.082] ..$ rscript_libs : NULL [16:45:38.082] ..$ rscript_startup : NULL [16:45:38.082] ..$ rscript_sh : chr "auto" [16:45:38.082] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:38.082] ..$ methods : logi TRUE [16:45:38.082] ..$ socketOptions : chr "no-delay" [16:45:38.082] ..$ useXDR : logi FALSE [16:45:38.082] ..$ outfile : chr "/dev/null" [16:45:38.082] ..$ renice : int NA [16:45:38.082] ..$ rshcmd : NULL [16:45:38.082] ..$ user : NULL [16:45:38.082] ..$ revtunnel : logi NA [16:45:38.082] ..$ rshlogfile : NULL [16:45:38.082] ..$ rshopts : NULL [16:45:38.082] ..$ rank : int 1 [16:45:38.082] ..$ manual : logi FALSE [16:45:38.082] ..$ dryrun : logi FALSE [16:45:38.082] ..$ quiet : logi FALSE [16:45:38.082] ..$ setup_strategy : chr "parallel" [16:45:38.082] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:38.128] [local output] System call to launch all workers: [16:45:38.128] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8061313d4d.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=31513 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:38.129] [local output] Starting PSOCK main server [16:45:38.143] [local output] Workers launched [16:45:38.144] [local output] Waiting for workers to connect back [16:45:38.144] - [local output] 0 workers out of 1 ready [16:45:38.379] - [local output] 0 workers out of 1 ready [16:45:38.383] - [local output] 1 workers out of 1 ready [16:45:38.383] [local output] Launching of 1 workers completed [16:45:38.384] [local output] Number of nodes in cluster: 1 [16:45:38.384] [local output] Collecting session information from 1 workers [16:45:38.386] [local output] - Worker #1 of 1 [16:45:38.386] [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) [16:45:38.392] [local output] makeClusterPSOCK() ... [16:45:38.399] [local output] Workers: [n = 1] 'localhost' [16:45:38.404] [local output] Base port: 28434 [16:45:38.405] [local output] Getting setup options for 1 cluster nodes ... [16:45:38.405] [local output] - Node #1 of 1 ... [16:45:38.406] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:38.409] [local output] Rscript port: 28434 [16:45:38.410] [local output] Getting setup options for 1 cluster nodes ... done [16:45:38.410] [local output] - Parallel setup requested for some PSOCK nodes [16:45:38.411] [local output] Setting up PSOCK nodes in parallel [16:45:38.411] List of 36 [16:45:38.411] $ worker : chr "localhost" [16:45:38.411] ..- attr(*, "localhost")= logi TRUE [16:45:38.411] $ master : chr "localhost" [16:45:38.411] $ port : int 28434 [16:45:38.411] $ connectTimeout : num 120 [16:45:38.411] $ timeout : num 120 [16:45:38.411] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:38.411] $ homogeneous : logi TRUE [16:45:38.411] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:38.411] $ rscript_envs : NULL [16:45:38.411] $ rscript_libs : NULL [16:45:38.411] $ rscript_startup : NULL [16:45:38.411] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:38.411] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:38.411] $ methods : logi TRUE [16:45:38.411] $ socketOptions : chr "no-delay" [16:45:38.411] $ useXDR : logi FALSE [16:45:38.411] $ outfile : chr "/dev/null" [16:45:38.411] $ renice : int NA [16:45:38.411] $ rshcmd : NULL [16:45:38.411] $ user : chr(0) [16:45:38.411] $ revtunnel : logi FALSE [16:45:38.411] $ rshlogfile : NULL [16:45:38.411] $ rshopts : chr(0) [16:45:38.411] $ rank : int 1 [16:45:38.411] $ manual : logi FALSE [16:45:38.411] $ dryrun : logi FALSE [16:45:38.411] $ quiet : logi FALSE [16:45:38.411] $ setup_strategy : chr "parallel" [16:45:38.411] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:38.411] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d801c894295.pid" [16:45:38.411] $ rshcmd_label : NULL [16:45:38.411] $ rsh_call : NULL [16:45:38.411] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:38.411] $ localMachine : logi TRUE [16:45:38.411] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:38.411] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:38.411] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:38.411] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:38.411] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:38.411] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:38.411] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:38.411] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:38.411] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:38.411] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:38.411] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:38.411] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:38.411] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:38.411] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:38.411] $ arguments :List of 28 [16:45:38.411] ..$ worker : chr "localhost" [16:45:38.411] ..$ master : NULL [16:45:38.411] ..$ port : int 28434 [16:45:38.411] ..$ connectTimeout : num 120 [16:45:38.411] ..$ timeout : num 120 [16:45:38.411] ..$ rscript : NULL [16:45:38.411] ..$ homogeneous : NULL [16:45:38.411] ..$ rscript_args : NULL [16:45:38.411] ..$ rscript_envs : NULL [16:45:38.411] ..$ rscript_libs : NULL [16:45:38.411] ..$ rscript_startup : NULL [16:45:38.411] ..$ rscript_sh : chr "auto" [16:45:38.411] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:38.411] ..$ methods : logi TRUE [16:45:38.411] ..$ socketOptions : chr "no-delay" [16:45:38.411] ..$ useXDR : logi FALSE [16:45:38.411] ..$ outfile : chr "/dev/null" [16:45:38.411] ..$ renice : int NA [16:45:38.411] ..$ rshcmd : NULL [16:45:38.411] ..$ user : NULL [16:45:38.411] ..$ revtunnel : logi NA [16:45:38.411] ..$ rshlogfile : NULL [16:45:38.411] ..$ rshopts : NULL [16:45:38.411] ..$ rank : int 1 [16:45:38.411] ..$ manual : logi FALSE [16:45:38.411] ..$ dryrun : logi FALSE [16:45:38.411] ..$ quiet : logi FALSE [16:45:38.411] ..$ setup_strategy : chr "parallel" [16:45:38.411] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:38.449] [local output] System call to launch all workers: [16:45:38.449] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d801c894295.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=28434 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:38.450] [local output] Starting PSOCK main server [16:45:38.456] [local output] Workers launched [16:45:38.456] [local output] Waiting for workers to connect back [16:45:38.457] - [local output] 0 workers out of 1 ready [16:45:38.704] - [local output] 0 workers out of 1 ready [16:45:38.704] - [local output] 1 workers out of 1 ready [16:45:38.705] [local output] Launching of 1 workers completed [16:45:38.705] [local output] Number of nodes in cluster: 1 [16:45:38.705] [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 = "") [16:45:38.712] [local output] makeClusterPSOCK() ... [16:45:38.718] [local output] Workers: [n = 1] 'localhost' [16:45:38.723] [local output] Base port: 25093 [16:45:38.723] [local output] Getting setup options for 1 cluster nodes ... [16:45:38.723] [local output] - Node #1 of 1 ... [16:45:38.724] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:38.727] [local output] Rscript port: 25093 [16:45:38.728] [local output] Getting setup options for 1 cluster nodes ... done [16:45:38.728] [local output] - Parallel setup requested for some PSOCK nodes [16:45:38.729] [local output] Setting up PSOCK nodes in parallel [16:45:38.729] List of 36 [16:45:38.729] $ worker : chr "localhost" [16:45:38.729] ..- attr(*, "localhost")= logi TRUE [16:45:38.729] $ master : chr "localhost" [16:45:38.729] $ port : int 25093 [16:45:38.729] $ connectTimeout : num 120 [16:45:38.729] $ timeout : num 120 [16:45:38.729] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:38.729] $ homogeneous : logi TRUE [16:45:38.729] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:38.729] $ rscript_envs : NULL [16:45:38.729] $ rscript_libs : NULL [16:45:38.729] $ rscript_startup : NULL [16:45:38.729] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:38.729] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:38.729] $ methods : logi TRUE [16:45:38.729] $ socketOptions : chr "no-delay" [16:45:38.729] $ useXDR : logi FALSE [16:45:38.729] $ outfile : chr "" [16:45:38.729] $ renice : int NA [16:45:38.729] $ rshcmd : NULL [16:45:38.729] $ user : chr(0) [16:45:38.729] $ revtunnel : logi FALSE [16:45:38.729] $ rshlogfile : NULL [16:45:38.729] $ rshopts : chr(0) [16:45:38.729] $ rank : int 1 [16:45:38.729] $ manual : logi FALSE [16:45:38.729] $ dryrun : logi FALSE [16:45:38.729] $ quiet : logi FALSE [16:45:38.729] $ setup_strategy : chr "parallel" [16:45:38.729] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:38.729] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d805855793d.pid" [16:45:38.729] $ rshcmd_label : NULL [16:45:38.729] $ rsh_call : NULL [16:45:38.729] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:38.729] $ localMachine : logi TRUE [16:45:38.729] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:38.729] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:38.729] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:38.729] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:38.729] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:38.729] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:38.729] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:38.729] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:38.729] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:38.729] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:38.729] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:38.729] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:38.729] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:38.729] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:38.729] $ arguments :List of 28 [16:45:38.729] ..$ worker : chr "localhost" [16:45:38.729] ..$ master : NULL [16:45:38.729] ..$ port : int 25093 [16:45:38.729] ..$ connectTimeout : num 120 [16:45:38.729] ..$ timeout : num 120 [16:45:38.729] ..$ rscript : NULL [16:45:38.729] ..$ homogeneous : NULL [16:45:38.729] ..$ rscript_args : NULL [16:45:38.729] ..$ rscript_envs : NULL [16:45:38.729] ..$ rscript_libs : NULL [16:45:38.729] ..$ rscript_startup : NULL [16:45:38.729] ..$ rscript_sh : chr "auto" [16:45:38.729] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:38.729] ..$ methods : logi TRUE [16:45:38.729] ..$ socketOptions : chr "no-delay" [16:45:38.729] ..$ useXDR : logi FALSE [16:45:38.729] ..$ outfile : chr "" [16:45:38.729] ..$ renice : int NA [16:45:38.729] ..$ rshcmd : NULL [16:45:38.729] ..$ user : NULL [16:45:38.729] ..$ revtunnel : logi NA [16:45:38.729] ..$ rshlogfile : NULL [16:45:38.729] ..$ rshopts : NULL [16:45:38.729] ..$ rank : int 1 [16:45:38.729] ..$ manual : logi FALSE [16:45:38.729] ..$ dryrun : logi FALSE [16:45:38.729] ..$ quiet : logi FALSE [16:45:38.729] ..$ setup_strategy : chr "parallel" [16:45:38.729] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:38.761] [local output] System call to launch all workers: [16:45:38.761] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d805855793d.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=25093 OUT= TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:38.761] [local output] Starting PSOCK main server [16:45:38.766] [local output] Workers launched [16:45:38.766] [local output] Waiting for workers to connect back [16:45:38.767] - [local output] 0 workers out of 1 ready starting worker pid=145852 on localhost:25093 at 16:45:39.026 [16:45:39.039] - [local output] 0 workers out of 1 ready [16:45:39.040] - [local output] 1 workers out of 1 ready [16:45:39.040] [local output] Launching of 1 workers completed [16:45:39.040] [local output] Number of nodes in cluster: 1 [16:45:39.041] [local output] Collecting session information from 1 workers [16:45:39.042] [local output] - Worker #1 of 1 [16:45:39.042] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 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) [16:45:39.050] [local output] makeClusterPSOCK() ... [16:45:39.056] [local output] Workers: [n = 1] 'localhost' [16:45:39.060] [local output] Base port: 38722 [16:45:39.061] [local output] Getting setup options for 1 cluster nodes ... [16:45:39.061] [local output] - Node #1 of 1 ... [16:45:39.062] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:39.064] [local output] Rscript port: 38722 [16:45:39.065] [local output] Getting setup options for 1 cluster nodes ... done [16:45:39.065] [local output] - Parallel setup requested for some PSOCK nodes [16:45:39.066] [local output] Setting up PSOCK nodes in parallel [16:45:39.066] List of 36 [16:45:39.066] $ worker : chr "localhost" [16:45:39.066] ..- attr(*, "localhost")= logi TRUE [16:45:39.066] $ master : chr "localhost" [16:45:39.066] $ port : int 38722 [16:45:39.066] $ connectTimeout : num 120 [16:45:39.066] $ timeout : num 120 [16:45:39.066] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:39.066] $ homogeneous : logi TRUE [16:45:39.066] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:39.066] $ rscript_envs : NULL [16:45:39.066] $ rscript_libs : NULL [16:45:39.066] $ rscript_startup : NULL [16:45:39.066] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:39.066] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:39.066] $ methods : logi TRUE [16:45:39.066] $ socketOptions : chr "no-delay" [16:45:39.066] $ useXDR : logi FALSE [16:45:39.066] $ outfile : chr "/dev/null" [16:45:39.066] $ renice : int NA [16:45:39.066] $ rshcmd : NULL [16:45:39.066] $ user : chr(0) [16:45:39.066] $ revtunnel : logi FALSE [16:45:39.066] $ rshlogfile : NULL [16:45:39.066] $ rshopts : chr(0) [16:45:39.066] $ rank : int 1 [16:45:39.066] $ manual : logi FALSE [16:45:39.066] $ dryrun : logi FALSE [16:45:39.066] $ quiet : logi FALSE [16:45:39.066] $ setup_strategy : chr "parallel" [16:45:39.066] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:39.066] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d806a95913.pid" [16:45:39.066] $ rshcmd_label : NULL [16:45:39.066] $ rsh_call : NULL [16:45:39.066] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:39.066] $ localMachine : logi TRUE [16:45:39.066] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:39.066] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:39.066] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:39.066] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:39.066] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:39.066] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:39.066] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:39.066] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:39.066] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:39.066] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:39.066] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:39.066] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:39.066] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:39.066] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:39.066] $ arguments :List of 28 [16:45:39.066] ..$ worker : chr "localhost" [16:45:39.066] ..$ master : NULL [16:45:39.066] ..$ port : int 38722 [16:45:39.066] ..$ connectTimeout : num 120 [16:45:39.066] ..$ timeout : num 120 [16:45:39.066] ..$ rscript : NULL [16:45:39.066] ..$ homogeneous : NULL [16:45:39.066] ..$ rscript_args : NULL [16:45:39.066] ..$ rscript_envs : NULL [16:45:39.066] ..$ rscript_libs : NULL [16:45:39.066] ..$ rscript_startup : NULL [16:45:39.066] ..$ rscript_sh : chr "auto" [16:45:39.066] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:39.066] ..$ methods : logi TRUE [16:45:39.066] ..$ socketOptions : chr "no-delay" [16:45:39.066] ..$ useXDR : logi FALSE [16:45:39.066] ..$ outfile : chr "/dev/null" [16:45:39.066] ..$ renice : int NA [16:45:39.066] ..$ rshcmd : NULL [16:45:39.066] ..$ user : NULL [16:45:39.066] ..$ revtunnel : logi NA [16:45:39.066] ..$ rshlogfile : NULL [16:45:39.066] ..$ rshopts : NULL [16:45:39.066] ..$ rank : int 1 [16:45:39.066] ..$ manual : logi FALSE [16:45:39.066] ..$ dryrun : logi FALSE [16:45:39.066] ..$ quiet : logi FALSE [16:45:39.066] ..$ setup_strategy : chr "parallel" [16:45:39.066] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:39.104] [local output] System call to launch all workers: [16:45:39.104] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d806a95913.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38722 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:39.104] [local output] Starting PSOCK main server [16:45:39.110] [local output] Workers launched [16:45:39.111] [local output] Waiting for workers to connect back [16:45:39.111] - [local output] 0 workers out of 1 ready [16:45:39.330] - [local output] 0 workers out of 1 ready [16:45:39.331] - [local output] 1 workers out of 1 ready [16:45:39.331] [local output] Launching of 1 workers completed [16:45:39.332] [local output] Number of nodes in cluster: 1 [16:45:39.332] [local output] Collecting session information from 1 workers [16:45:39.333] [local output] - Worker #1 of 1 [16:45:39.333] [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' [16:45:39.348] [local output] makeClusterPSOCK() ... [16:45:39.352] [local output] Workers: [n = 1] 'localhost' [16:45:39.356] [local output] Base port: 27040 [16:45:39.357] [local output] Getting setup options for 1 cluster nodes ... [16:45:39.357] [local output] - Node #1 of 1 ... [16:45:39.358] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:39.359] 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/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80659875f6.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80659875f6.pid\")"' [16:45:39.804] - Possible to infer worker's PID: TRUE [16:45:39.805] [local output] Rscript port: 27040 [16:45:39.806] [local output] Getting setup options for 1 cluster nodes ... done [16:45:39.806] [local output] - Parallel setup requested for some PSOCK nodes [16:45:39.807] [local output] Setting up PSOCK nodes in parallel [16:45:39.807] List of 36 [16:45:39.807] $ worker : chr "localhost" [16:45:39.807] ..- attr(*, "localhost")= logi TRUE [16:45:39.807] $ master : chr "localhost" [16:45:39.807] $ port : int 27040 [16:45:39.807] $ connectTimeout : num 120 [16:45:39.807] $ timeout : num 120 [16:45:39.807] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [16:45:39.807] $ homogeneous : logi TRUE [16:45:39.807] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [16:45:39.807] $ rscript_envs : NULL [16:45:39.807] $ rscript_libs : NULL [16:45:39.807] $ rscript_startup : NULL [16:45:39.807] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:39.807] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:39.807] $ methods : logi TRUE [16:45:39.807] $ socketOptions : chr "no-delay" [16:45:39.807] $ useXDR : logi FALSE [16:45:39.807] $ outfile : chr "/dev/null" [16:45:39.807] $ renice : int NA [16:45:39.807] $ rshcmd : NULL [16:45:39.807] $ user : chr(0) [16:45:39.807] $ revtunnel : logi FALSE [16:45:39.807] $ rshlogfile : NULL [16:45:39.807] $ rshopts : chr(0) [16:45:39.807] $ rank : int 1 [16:45:39.807] $ manual : logi FALSE [16:45:39.807] $ dryrun : logi FALSE [16:45:39.807] $ quiet : logi FALSE [16:45:39.807] $ setup_strategy : chr "parallel" [16:45:39.807] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [16:45:39.807] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80659875f6.pid" [16:45:39.807] $ rshcmd_label : NULL [16:45:39.807] $ rsh_call : NULL [16:45:39.807] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [16:45:39.807] $ localMachine : logi TRUE [16:45:39.807] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:39.807] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:39.807] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:39.807] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:39.807] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:39.807] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:39.807] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:39.807] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:39.807] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:39.807] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:39.807] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:39.807] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:39.807] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:39.807] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:39.807] $ arguments :List of 28 [16:45:39.807] ..$ worker : chr "localhost" [16:45:39.807] ..$ master : NULL [16:45:39.807] ..$ port : int 27040 [16:45:39.807] ..$ connectTimeout : num 120 [16:45:39.807] ..$ timeout : num 120 [16:45:39.807] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [16:45:39.807] ..$ homogeneous : NULL [16:45:39.807] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [16:45:39.807] ..$ rscript_envs : NULL [16:45:39.807] ..$ rscript_libs : NULL [16:45:39.807] ..$ rscript_startup : NULL [16:45:39.807] ..$ rscript_sh : chr "auto" [16:45:39.807] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:39.807] ..$ methods : logi TRUE [16:45:39.807] ..$ socketOptions : chr "no-delay" [16:45:39.807] ..$ useXDR : logi FALSE [16:45:39.807] ..$ outfile : chr "/dev/null" [16:45:39.807] ..$ renice : int NA [16:45:39.807] ..$ rshcmd : NULL [16:45:39.807] ..$ user : NULL [16:45:39.807] ..$ revtunnel : logi NA [16:45:39.807] ..$ rshlogfile : NULL [16:45:39.807] ..$ rshopts : NULL [16:45:39.807] ..$ rank : int 1 [16:45:39.807] ..$ manual : logi FALSE [16:45:39.807] ..$ dryrun : logi FALSE [16:45:39.807] ..$ quiet : logi FALSE [16:45:39.807] ..$ setup_strategy : chr "parallel" [16:45:39.807] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:39.845] [local output] System call to launch all workers: [16:45:39.845] [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:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80659875f6.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=27040 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:39.846] [local output] Starting PSOCK main server [16:45:39.852] [local output] Workers launched [16:45:39.853] [local output] Waiting for workers to connect back [16:45:39.853] - [local output] 0 workers out of 1 ready [16:45:40.134] - [local output] 0 workers out of 1 ready [16:45:40.135] - [local output] 1 workers out of 1 ready [16:45:40.135] [local output] Launching of 1 workers completed [16:45:40.135] [local output] Number of nodes in cluster: 1 [16:45:40.136] [local output] Collecting session information from 1 workers [16:45:40.137] [local output] - Worker #1 of 1 [16:45:40.137] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [16:45:40.144] [local output] makeClusterPSOCK() ... [16:45:40.149] [local output] Workers: [n = 1] 'localhost' [16:45:40.153] [local output] Base port: 30004 [16:45:40.153] [local output] Getting setup options for 1 cluster nodes ... [16:45:40.154] [local output] - Node #1 of 1 ... [16:45:40.154] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:40.157] [local output] Rscript port: 30004 [16:45:40.157] [local output] Getting setup options for 1 cluster nodes ... done [16:45:40.158] [local output] - Parallel setup requested for some PSOCK nodes [16:45:40.158] [local output] Setting up PSOCK nodes in parallel [16:45:40.158] List of 36 [16:45:40.158] $ worker : chr "localhost" [16:45:40.158] ..- attr(*, "localhost")= logi TRUE [16:45:40.158] $ master : chr "localhost" [16:45:40.158] $ port : int 30004 [16:45:40.158] $ connectTimeout : num 120 [16:45:40.158] $ timeout : num 120 [16:45:40.158] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [16:45:40.158] $ homogeneous : logi TRUE [16:45:40.158] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [16:45:40.158] $ rscript_envs : NULL [16:45:40.158] $ rscript_libs : NULL [16:45:40.158] $ rscript_startup : NULL [16:45:40.158] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:40.158] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:40.158] $ methods : logi TRUE [16:45:40.158] $ socketOptions : chr "no-delay" [16:45:40.158] $ useXDR : logi FALSE [16:45:40.158] $ outfile : chr "/dev/null" [16:45:40.158] $ renice : int NA [16:45:40.158] $ rshcmd : NULL [16:45:40.158] $ user : chr(0) [16:45:40.158] $ revtunnel : logi FALSE [16:45:40.158] $ rshlogfile : NULL [16:45:40.158] $ rshopts : chr(0) [16:45:40.158] $ rank : int 1 [16:45:40.158] $ manual : logi FALSE [16:45:40.158] $ dryrun : logi FALSE [16:45:40.158] $ quiet : logi FALSE [16:45:40.158] $ setup_strategy : chr "parallel" [16:45:40.158] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [16:45:40.158] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8045146897.pid" [16:45:40.158] $ rshcmd_label : NULL [16:45:40.158] $ rsh_call : NULL [16:45:40.158] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [16:45:40.158] $ localMachine : logi TRUE [16:45:40.158] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:40.158] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:40.158] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:40.158] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:40.158] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:40.158] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:40.158] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:40.158] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:40.158] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:40.158] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:40.158] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:40.158] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:40.158] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:40.158] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:40.158] $ arguments :List of 28 [16:45:40.158] ..$ worker : chr "localhost" [16:45:40.158] ..$ master : NULL [16:45:40.158] ..$ port : int 30004 [16:45:40.158] ..$ connectTimeout : num 120 [16:45:40.158] ..$ timeout : num 120 [16:45:40.158] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [16:45:40.158] ..$ homogeneous : NULL [16:45:40.158] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [16:45:40.158] ..$ rscript_envs : NULL [16:45:40.158] ..$ rscript_libs : NULL [16:45:40.158] ..$ rscript_startup : NULL [16:45:40.158] ..$ rscript_sh : chr "auto" [16:45:40.158] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:40.158] ..$ methods : logi TRUE [16:45:40.158] ..$ socketOptions : chr "no-delay" [16:45:40.158] ..$ useXDR : logi FALSE [16:45:40.158] ..$ outfile : chr "/dev/null" [16:45:40.158] ..$ renice : int NA [16:45:40.158] ..$ rshcmd : NULL [16:45:40.158] ..$ user : NULL [16:45:40.158] ..$ revtunnel : logi NA [16:45:40.158] ..$ rshlogfile : NULL [16:45:40.158] ..$ rshopts : NULL [16:45:40.158] ..$ rank : int 1 [16:45:40.158] ..$ manual : logi FALSE [16:45:40.158] ..$ dryrun : logi FALSE [16:45:40.158] ..$ quiet : logi FALSE [16:45:40.158] ..$ setup_strategy : chr "parallel" [16:45:40.158] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:40.185] [local output] System call to launch all workers: [16:45:40.185] [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:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8045146897.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=30004 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:40.185] [local output] Starting PSOCK main server [16:45:40.190] [local output] Workers launched [16:45:40.190] [local output] Waiting for workers to connect back [16:45:40.190] - [local output] 0 workers out of 1 ready [16:45:40.430] - [local output] 0 workers out of 1 ready [16:45:40.431] - [local output] 1 workers out of 1 ready [16:45:40.431] [local output] Launching of 1 workers completed [16:45:40.431] [local output] Number of nodes in cluster: 1 [16:45:40.432] [local output] Collecting session information from 1 workers [16:45:40.433] [local output] - Worker #1 of 1 [16:45:40.433] [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' [16:45:40.452] [local output] makeClusterPSOCK() ... [16:45:40.456] [local output] Workers: [n = 1] 'localhost' [16:45:40.459] [local output] Base port: 38157 [16:45:40.459] [local output] Getting setup options for 1 cluster nodes ... [16:45:40.460] [local output] - Node #1 of 1 ... [16:45:40.460] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:40.462] 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/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8071767481.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8071767481.pid\")"' [16:45:40.788] - Possible to infer worker's PID: TRUE [16:45:40.790] [local output] Rscript port: 38157 [16:45:40.791] [local output] Getting setup options for 1 cluster nodes ... done [16:45:40.791] [local output] - Parallel setup requested for some PSOCK nodes [16:45:40.792] [local output] Setting up PSOCK nodes in parallel [16:45:40.792] List of 36 [16:45:40.792] $ worker : chr "localhost" [16:45:40.792] ..- attr(*, "localhost")= logi TRUE [16:45:40.792] $ master : chr "localhost" [16:45:40.792] $ port : int 38157 [16:45:40.792] $ connectTimeout : num 120 [16:45:40.792] $ timeout : num 120 [16:45:40.792] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [16:45:40.792] $ homogeneous : logi TRUE [16:45:40.792] $ rscript_args : chr "--default-packages=utils,tools -e \"#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN\" -e \"try(suppressWarnings("| __truncated__ [16:45:40.792] $ rscript_envs : NULL [16:45:40.792] $ rscript_libs : NULL [16:45:40.792] $ rscript_startup : NULL [16:45:40.792] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:40.792] $ default_packages: chr [1:2] "utils" "tools" [16:45:40.792] $ methods : logi TRUE [16:45:40.792] $ socketOptions : chr "no-delay" [16:45:40.792] $ useXDR : logi FALSE [16:45:40.792] $ outfile : chr "/dev/null" [16:45:40.792] $ renice : int NA [16:45:40.792] $ rshcmd : NULL [16:45:40.792] $ user : chr(0) [16:45:40.792] $ revtunnel : logi FALSE [16:45:40.792] $ rshlogfile : NULL [16:45:40.792] $ rshopts : chr(0) [16:45:40.792] $ rank : int 1 [16:45:40.792] $ manual : logi FALSE [16:45:40.792] $ dryrun : logi FALSE [16:45:40.792] $ quiet : logi FALSE [16:45:40.792] $ setup_strategy : chr "parallel" [16:45:40.792] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [16:45:40.792] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8071767481.pid" [16:45:40.792] $ rshcmd_label : NULL [16:45:40.792] $ rsh_call : NULL [16:45:40.792] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [16:45:40.792] $ localMachine : logi TRUE [16:45:40.792] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:40.792] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:40.792] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:40.792] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:40.792] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:40.792] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:40.792] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:40.792] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:40.792] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:40.792] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:40.792] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:40.792] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:40.792] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:40.792] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:40.792] $ arguments :List of 28 [16:45:40.792] ..$ worker : chr "localhost" [16:45:40.792] ..$ master : NULL [16:45:40.792] ..$ port : int 38157 [16:45:40.792] ..$ connectTimeout : num 120 [16:45:40.792] ..$ timeout : num 120 [16:45:40.792] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [16:45:40.792] ..$ homogeneous : NULL [16:45:40.792] ..$ rscript_args : NULL [16:45:40.792] ..$ rscript_envs : NULL [16:45:40.792] ..$ rscript_libs : NULL [16:45:40.792] ..$ rscript_startup : NULL [16:45:40.792] ..$ rscript_sh : chr "auto" [16:45:40.792] ..$ default_packages: chr [1:2] "utils" "tools" [16:45:40.792] ..$ methods : logi TRUE [16:45:40.792] ..$ socketOptions : chr "no-delay" [16:45:40.792] ..$ useXDR : logi FALSE [16:45:40.792] ..$ outfile : chr "/dev/null" [16:45:40.792] ..$ renice : int NA [16:45:40.792] ..$ rshcmd : NULL [16:45:40.792] ..$ user : NULL [16:45:40.792] ..$ revtunnel : logi NA [16:45:40.792] ..$ rshlogfile : NULL [16:45:40.792] ..$ rshopts : NULL [16:45:40.792] ..$ rank : int 1 [16:45:40.792] ..$ manual : logi FALSE [16:45:40.792] ..$ dryrun : logi FALSE [16:45:40.792] ..$ quiet : logi FALSE [16:45:40.792] ..$ setup_strategy : chr "parallel" [16:45:40.792] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:40.824] [local output] System call to launch all workers: [16:45:40.825] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=utils,tools -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8071767481.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38157 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:40.825] [local output] Starting PSOCK main server [16:45:40.830] [local output] Workers launched [16:45:40.831] [local output] Waiting for workers to connect back [16:45:40.831] - [local output] 0 workers out of 1 ready [16:45:40.956] - [local output] 0 workers out of 1 ready [16:45:40.957] - [local output] 1 workers out of 1 ready [16:45:40.957] [local output] Launching of 1 workers completed [16:45:40.957] [local output] Number of nodes in cluster: 1 [16:45:40.958] [local output] Collecting session information from 1 workers [16:45:40.959] [local output] - Worker #1 of 1 [16:45:40.959] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [16:45:40.965] [local output] makeClusterPSOCK() ... [16:45:40.969] [local output] Workers: [n = 1] 'localhost' [16:45:40.972] [local output] Base port: 33763 [16:45:40.972] [local output] Getting setup options for 1 cluster nodes ... [16:45:40.972] [local output] - Node #1 of 1 ... [16:45:40.973] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:40.975] [local output] Rscript port: 33763 [16:45:40.975] [local output] Getting setup options for 1 cluster nodes ... done [16:45:40.976] [local output] - Parallel setup requested for some PSOCK nodes [16:45:40.976] [local output] Setting up PSOCK nodes in parallel [16:45:40.976] List of 36 [16:45:40.976] $ worker : chr "localhost" [16:45:40.976] ..- attr(*, "localhost")= logi TRUE [16:45:40.976] $ master : chr "localhost" [16:45:40.976] $ port : int 33763 [16:45:40.976] $ connectTimeout : num 120 [16:45:40.976] $ timeout : num 120 [16:45:40.976] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [16:45:40.976] $ homogeneous : logi TRUE [16:45:40.976] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN\" -e "| __truncated__ [16:45:40.976] $ rscript_envs : NULL [16:45:40.976] $ rscript_libs : NULL [16:45:40.976] $ rscript_startup : NULL [16:45:40.976] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:40.976] $ default_packages: chr [1:2] "utils" "tools" [16:45:40.976] $ methods : logi TRUE [16:45:40.976] $ socketOptions : chr "no-delay" [16:45:40.976] $ useXDR : logi FALSE [16:45:40.976] $ outfile : chr "/dev/null" [16:45:40.976] $ renice : int NA [16:45:40.976] $ rshcmd : NULL [16:45:40.976] $ user : chr(0) [16:45:40.976] $ revtunnel : logi FALSE [16:45:40.976] $ rshlogfile : NULL [16:45:40.976] $ rshopts : chr(0) [16:45:40.976] $ rank : int 1 [16:45:40.976] $ manual : logi FALSE [16:45:40.976] $ dryrun : logi FALSE [16:45:40.976] $ quiet : logi FALSE [16:45:40.976] $ setup_strategy : chr "parallel" [16:45:40.976] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [16:45:40.976] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80d777f57.pid" [16:45:40.976] $ rshcmd_label : NULL [16:45:40.976] $ rsh_call : NULL [16:45:40.976] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [16:45:40.976] $ localMachine : logi TRUE [16:45:40.976] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:40.976] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:40.976] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:40.976] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:40.976] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:40.976] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:40.976] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:40.976] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:40.976] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:40.976] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:40.976] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:40.976] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:40.976] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:40.976] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:40.976] $ arguments :List of 28 [16:45:40.976] ..$ worker : chr "localhost" [16:45:40.976] ..$ master : NULL [16:45:40.976] ..$ port : int 33763 [16:45:40.976] ..$ connectTimeout : num 120 [16:45:40.976] ..$ timeout : num 120 [16:45:40.976] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [16:45:40.976] ..$ homogeneous : NULL [16:45:40.976] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [16:45:40.976] ..$ rscript_envs : NULL [16:45:40.976] ..$ rscript_libs : NULL [16:45:40.976] ..$ rscript_startup : NULL [16:45:40.976] ..$ rscript_sh : chr "auto" [16:45:40.976] ..$ default_packages: chr [1:2] "utils" "tools" [16:45:40.976] ..$ methods : logi TRUE [16:45:40.976] ..$ socketOptions : chr "no-delay" [16:45:40.976] ..$ useXDR : logi FALSE [16:45:40.976] ..$ outfile : chr "/dev/null" [16:45:40.976] ..$ renice : int NA [16:45:40.976] ..$ rshcmd : NULL [16:45:40.976] ..$ user : NULL [16:45:40.976] ..$ revtunnel : logi NA [16:45:40.976] ..$ rshlogfile : NULL [16:45:40.976] ..$ rshopts : NULL [16:45:40.976] ..$ rank : int 1 [16:45:40.976] ..$ manual : logi FALSE [16:45:40.976] ..$ dryrun : logi FALSE [16:45:40.976] ..$ quiet : logi FALSE [16:45:40.976] ..$ setup_strategy : chr "parallel" [16:45:40.976] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:41.007] [local output] System call to launch all workers: [16:45:41.008] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80d777f57.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=33763 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:41.008] [local output] Starting PSOCK main server [16:45:41.013] [local output] Workers launched [16:45:41.013] [local output] Waiting for workers to connect back [16:45:41.014] - [local output] 0 workers out of 1 ready [16:45:41.120] - [local output] 0 workers out of 1 ready [16:45:41.121] - [local output] 1 workers out of 1 ready [16:45:41.121] [local output] Launching of 1 workers completed [16:45:41.122] [local output] Number of nodes in cluster: 1 [16:45:41.122] [local output] Collecting session information from 1 workers [16:45:41.123] [local output] - Worker #1 of 1 [16:45:41.123] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [16:45:41.130] [local output] makeClusterPSOCK() ... [16:45:41.135] [local output] Workers: [n = 1] 'localhost' [16:45:41.140] [local output] Base port: 31559 [16:45:41.140] [local output] Getting setup options for 1 cluster nodes ... [16:45:41.140] [local output] - Node #1 of 1 ... [16:45:41.141] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:41.144] [local output] Rscript port: 31559 [16:45:41.145] [local output] Getting setup options for 1 cluster nodes ... done [16:45:41.145] [local output] - Parallel setup requested for some PSOCK nodes [16:45:41.146] [local output] Setting up PSOCK nodes in parallel [16:45:41.146] List of 36 [16:45:41.146] $ worker : chr "localhost" [16:45:41.146] ..- attr(*, "localhost")= logi TRUE [16:45:41.146] $ master : chr "localhost" [16:45:41.146] $ port : int 31559 [16:45:41.146] $ connectTimeout : num 120 [16:45:41.146] $ timeout : num 120 [16:45:41.146] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [16:45:41.146] $ homogeneous : logi TRUE [16:45:41.146] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN\" -e "| __truncated__ [16:45:41.146] $ rscript_envs : NULL [16:45:41.146] $ rscript_libs : NULL [16:45:41.146] $ rscript_startup : NULL [16:45:41.146] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:41.146] $ default_packages: chr [1:2] "utils" "tools" [16:45:41.146] $ methods : logi TRUE [16:45:41.146] $ socketOptions : chr "no-delay" [16:45:41.146] $ useXDR : logi FALSE [16:45:41.146] $ outfile : chr "/dev/null" [16:45:41.146] $ renice : int NA [16:45:41.146] $ rshcmd : NULL [16:45:41.146] $ user : chr(0) [16:45:41.146] $ revtunnel : logi FALSE [16:45:41.146] $ rshlogfile : NULL [16:45:41.146] $ rshopts : chr(0) [16:45:41.146] $ rank : int 1 [16:45:41.146] $ manual : logi FALSE [16:45:41.146] $ dryrun : logi FALSE [16:45:41.146] $ quiet : logi FALSE [16:45:41.146] $ setup_strategy : chr "parallel" [16:45:41.146] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [16:45:41.146] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8041f02d5d.pid" [16:45:41.146] $ rshcmd_label : NULL [16:45:41.146] $ rsh_call : NULL [16:45:41.146] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [16:45:41.146] $ localMachine : logi TRUE [16:45:41.146] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:41.146] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:41.146] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:41.146] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:41.146] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:41.146] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:41.146] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:41.146] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:41.146] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:41.146] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:41.146] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:41.146] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:41.146] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:41.146] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:41.146] $ arguments :List of 28 [16:45:41.146] ..$ worker : chr "localhost" [16:45:41.146] ..$ master : NULL [16:45:41.146] ..$ port : int 31559 [16:45:41.146] ..$ connectTimeout : num 120 [16:45:41.146] ..$ timeout : num 120 [16:45:41.146] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [16:45:41.146] ..$ homogeneous : NULL [16:45:41.146] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [16:45:41.146] ..$ rscript_envs : NULL [16:45:41.146] ..$ rscript_libs : NULL [16:45:41.146] ..$ rscript_startup : NULL [16:45:41.146] ..$ rscript_sh : chr "auto" [16:45:41.146] ..$ default_packages: chr [1:2] "utils" "tools" [16:45:41.146] ..$ methods : logi TRUE [16:45:41.146] ..$ socketOptions : chr "no-delay" [16:45:41.146] ..$ useXDR : logi FALSE [16:45:41.146] ..$ outfile : chr "/dev/null" [16:45:41.146] ..$ renice : int NA [16:45:41.146] ..$ rshcmd : NULL [16:45:41.146] ..$ user : NULL [16:45:41.146] ..$ revtunnel : logi NA [16:45:41.146] ..$ rshlogfile : NULL [16:45:41.146] ..$ rshopts : NULL [16:45:41.146] ..$ rank : int 1 [16:45:41.146] ..$ manual : logi FALSE [16:45:41.146] ..$ dryrun : logi FALSE [16:45:41.146] ..$ quiet : logi FALSE [16:45:41.146] ..$ setup_strategy : chr "parallel" [16:45:41.146] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:41.183] [local output] System call to launch all workers: [16:45:41.184] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d8041f02d5d.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=31559 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:41.184] [local output] Starting PSOCK main server [16:45:41.190] [local output] Workers launched [16:45:41.190] [local output] Waiting for workers to connect back [16:45:41.191] - [local output] 0 workers out of 1 ready [16:45:41.326] - [local output] 0 workers out of 1 ready [16:45:41.327] - [local output] 1 workers out of 1 ready [16:45:41.327] [local output] Launching of 1 workers completed [16:45:41.328] [local output] Number of nodes in cluster: 1 [16:45:41.328] [local output] Collecting session information from 1 workers [16:45:41.329] [local output] - Worker #1 of 1 [16:45:41.330] [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' [16:45:41.353] [local output] makeClusterPSOCK() ... [16:45:41.359] [local output] Workers: [n = 1] 'localhost' [16:45:41.364] [local output] Base port: 26200 [16:45:41.364] [local output] Getting setup options for 1 cluster nodes ... [16:45:41.364] [local output] - Node #1 of 1 ... [16:45:41.365] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:41.368] [local output] Rscript port: 26200 [16:45:41.369] [local output] Getting setup options for 1 cluster nodes ... done [16:45:41.369] [local output] - Parallel setup requested for some PSOCK nodes [16:45:41.369] [local output] Setting up PSOCK nodes in parallel [16:45:41.370] List of 36 [16:45:41.370] $ worker : chr "localhost" [16:45:41.370] ..- attr(*, "localhost")= logi TRUE [16:45:41.370] $ master : chr "localhost" [16:45:41.370] $ port : int 26200 [16:45:41.370] $ connectTimeout : num 120 [16:45:41.370] $ timeout : num 120 [16:45:41.370] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [16:45:41.370] $ homogeneous : logi TRUE [16:45:41.370] $ rscript_args : chr "--default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:10"| __truncated__ [16:45:41.370] $ rscript_envs : NULL [16:45:41.370] $ rscript_libs : NULL [16:45:41.370] $ rscript_startup : NULL [16:45:41.370] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:41.370] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [16:45:41.370] $ methods : logi TRUE [16:45:41.370] $ socketOptions : chr "no-delay" [16:45:41.370] $ useXDR : logi FALSE [16:45:41.370] $ outfile : chr "/dev/null" [16:45:41.370] $ renice : int NA [16:45:41.370] $ rshcmd : NULL [16:45:41.370] $ user : chr(0) [16:45:41.370] $ revtunnel : logi FALSE [16:45:41.370] $ rshlogfile : NULL [16:45:41.370] $ rshopts : chr(0) [16:45:41.370] $ rank : int 1 [16:45:41.370] $ manual : logi FALSE [16:45:41.370] $ dryrun : logi FALSE [16:45:41.370] $ quiet : logi FALSE [16:45:41.370] $ setup_strategy : chr "parallel" [16:45:41.370] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [16:45:41.370] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d807bef773a.pid" [16:45:41.370] $ rshcmd_label : NULL [16:45:41.370] $ rsh_call : NULL [16:45:41.370] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [16:45:41.370] $ localMachine : logi TRUE [16:45:41.370] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:41.370] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:41.370] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:41.370] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:41.370] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:41.370] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:41.370] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:41.370] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:41.370] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:41.370] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:41.370] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:41.370] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:41.370] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:41.370] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:41.370] $ arguments :List of 28 [16:45:41.370] ..$ worker : chr "localhost" [16:45:41.370] ..$ master : NULL [16:45:41.370] ..$ port : int 26200 [16:45:41.370] ..$ connectTimeout : num 120 [16:45:41.370] ..$ timeout : num 120 [16:45:41.370] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [16:45:41.370] ..$ homogeneous : NULL [16:45:41.370] ..$ rscript_args : NULL [16:45:41.370] ..$ rscript_envs : NULL [16:45:41.370] ..$ rscript_libs : NULL [16:45:41.370] ..$ rscript_startup : NULL [16:45:41.370] ..$ rscript_sh : chr "auto" [16:45:41.370] ..$ default_packages: chr [1:2] "parallelly" "*" [16:45:41.370] ..$ methods : logi TRUE [16:45:41.370] ..$ socketOptions : chr "no-delay" [16:45:41.370] ..$ useXDR : logi FALSE [16:45:41.370] ..$ outfile : chr "/dev/null" [16:45:41.370] ..$ renice : int NA [16:45:41.370] ..$ rshcmd : NULL [16:45:41.370] ..$ user : NULL [16:45:41.370] ..$ revtunnel : logi NA [16:45:41.370] ..$ rshlogfile : NULL [16:45:41.370] ..$ rshopts : NULL [16:45:41.370] ..$ rank : int 1 [16:45:41.370] ..$ manual : logi FALSE [16:45:41.370] ..$ dryrun : logi FALSE [16:45:41.370] ..$ quiet : logi FALSE [16:45:41.370] ..$ setup_strategy : chr "parallel" [16:45:41.370] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:41.408] [local output] System call to launch all workers: [16:45:41.409] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d807bef773a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26200 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:41.409] [local output] Starting PSOCK main server [16:45:41.415] [local output] Workers launched [16:45:41.415] [local output] Waiting for workers to connect back [16:45:41.416] - [local output] 0 workers out of 1 ready [16:45:41.776] - [local output] 0 workers out of 1 ready [16:45:41.777] - [local output] 1 workers out of 1 ready [16:45:41.778] [local output] Launching of 1 workers completed [16:45:41.778] [local output] Number of nodes in cluster: 1 [16:45:41.778] [local output] Collecting session information from 1 workers [16:45:41.780] [local output] - Worker #1 of 1 [16:45:41.780] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [16:45:41.786] [local output] makeClusterPSOCK() ... [16:45:41.793] [local output] Workers: [n = 1] 'localhost' [16:45:41.798] [local output] Base port: 34886 [16:45:41.799] [local output] Getting setup options for 1 cluster nodes ... [16:45:41.799] [local output] - Node #1 of 1 ... [16:45:41.800] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:41.803] [local output] Rscript port: 34886 [16:45:41.804] [local output] Getting setup options for 1 cluster nodes ... done [16:45:41.804] [local output] - Parallel setup requested for some PSOCK nodes [16:45:41.805] [local output] Setting up PSOCK nodes in parallel [16:45:41.805] List of 36 [16:45:41.805] $ worker : chr "localhost" [16:45:41.805] ..- attr(*, "localhost")= logi TRUE [16:45:41.805] $ master : chr "localhost" [16:45:41.805] $ port : int 34886 [16:45:41.805] $ connectTimeout : num 120 [16:45:41.805] $ timeout : num 120 [16:45:41.805] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [16:45:41.805] $ homogeneous : logi TRUE [16:45:41.805] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [16:45:41.805] $ rscript_envs : NULL [16:45:41.805] $ rscript_libs : NULL [16:45:41.805] $ rscript_startup : NULL [16:45:41.805] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:41.805] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [16:45:41.805] $ methods : logi TRUE [16:45:41.805] $ socketOptions : chr "no-delay" [16:45:41.805] $ useXDR : logi FALSE [16:45:41.805] $ outfile : chr "/dev/null" [16:45:41.805] $ renice : int NA [16:45:41.805] $ rshcmd : NULL [16:45:41.805] $ user : chr(0) [16:45:41.805] $ revtunnel : logi FALSE [16:45:41.805] $ rshlogfile : NULL [16:45:41.805] $ rshopts : chr(0) [16:45:41.805] $ rank : int 1 [16:45:41.805] $ manual : logi FALSE [16:45:41.805] $ dryrun : logi FALSE [16:45:41.805] $ quiet : logi FALSE [16:45:41.805] $ setup_strategy : chr "parallel" [16:45:41.805] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [16:45:41.805] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80510a4cfd.pid" [16:45:41.805] $ rshcmd_label : NULL [16:45:41.805] $ rsh_call : NULL [16:45:41.805] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [16:45:41.805] $ localMachine : logi TRUE [16:45:41.805] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:41.805] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:41.805] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:41.805] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:41.805] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:41.805] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:41.805] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:41.805] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:41.805] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:41.805] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:41.805] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:41.805] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:41.805] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:41.805] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:41.805] $ arguments :List of 28 [16:45:41.805] ..$ worker : chr "localhost" [16:45:41.805] ..$ master : NULL [16:45:41.805] ..$ port : int 34886 [16:45:41.805] ..$ connectTimeout : num 120 [16:45:41.805] ..$ timeout : num 120 [16:45:41.805] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [16:45:41.805] ..$ homogeneous : NULL [16:45:41.805] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [16:45:41.805] ..$ rscript_envs : NULL [16:45:41.805] ..$ rscript_libs : NULL [16:45:41.805] ..$ rscript_startup : NULL [16:45:41.805] ..$ rscript_sh : chr "auto" [16:45:41.805] ..$ default_packages: chr [1:2] "parallelly" "*" [16:45:41.805] ..$ methods : logi TRUE [16:45:41.805] ..$ socketOptions : chr "no-delay" [16:45:41.805] ..$ useXDR : logi FALSE [16:45:41.805] ..$ outfile : chr "/dev/null" [16:45:41.805] ..$ renice : int NA [16:45:41.805] ..$ rshcmd : NULL [16:45:41.805] ..$ user : NULL [16:45:41.805] ..$ revtunnel : logi NA [16:45:41.805] ..$ rshlogfile : NULL [16:45:41.805] ..$ rshopts : NULL [16:45:41.805] ..$ rank : int 1 [16:45:41.805] ..$ manual : logi FALSE [16:45:41.805] ..$ dryrun : logi FALSE [16:45:41.805] ..$ quiet : logi FALSE [16:45:41.805] ..$ setup_strategy : chr "parallel" [16:45:41.805] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:41.849] [local output] System call to launch all workers: [16:45:41.849] [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:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80510a4cfd.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=34886 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:41.850] [local output] Starting PSOCK main server [16:45:41.856] [local output] Workers launched [16:45:41.857] [local output] Waiting for workers to connect back [16:45:41.857] - [local output] 0 workers out of 1 ready [16:45:42.207] - [local output] 0 workers out of 1 ready [16:45:42.208] - [local output] 1 workers out of 1 ready [16:45:42.208] [local output] Launching of 1 workers completed [16:45:42.209] [local output] Number of nodes in cluster: 1 [16:45:42.209] [local output] Collecting session information from 1 workers [16:45:42.211] [local output] - Worker #1 of 1 [16:45:42.211] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [16:45:42.219] [local output] makeClusterPSOCK() ... [16:45:42.226] [local output] Workers: [n = 1] 'localhost' [16:45:42.230] [local output] Base port: 26741 [16:45:42.230] [local output] Getting setup options for 1 cluster nodes ... [16:45:42.231] [local output] - Node #1 of 1 ... [16:45:42.231] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:42.233] [local output] Rscript port: 26741 [16:45:42.234] [local output] Getting setup options for 1 cluster nodes ... done [16:45:42.234] [local output] - Parallel setup requested for some PSOCK nodes [16:45:42.235] [local output] Setting up PSOCK nodes in parallel [16:45:42.235] List of 36 [16:45:42.235] $ worker : chr "localhost" [16:45:42.235] ..- attr(*, "localhost")= logi TRUE [16:45:42.235] $ master : chr "localhost" [16:45:42.235] $ port : int 26741 [16:45:42.235] $ connectTimeout : num 120 [16:45:42.235] $ timeout : num 120 [16:45:42.235] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [16:45:42.235] $ homogeneous : logi TRUE [16:45:42.235] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [16:45:42.235] $ rscript_envs : NULL [16:45:42.235] $ rscript_libs : NULL [16:45:42.235] $ rscript_startup : NULL [16:45:42.235] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:42.235] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [16:45:42.235] $ methods : logi TRUE [16:45:42.235] $ socketOptions : chr "no-delay" [16:45:42.235] $ useXDR : logi FALSE [16:45:42.235] $ outfile : chr "/dev/null" [16:45:42.235] $ renice : int NA [16:45:42.235] $ rshcmd : NULL [16:45:42.235] $ user : chr(0) [16:45:42.235] $ revtunnel : logi FALSE [16:45:42.235] $ rshlogfile : NULL [16:45:42.235] $ rshopts : chr(0) [16:45:42.235] $ rank : int 1 [16:45:42.235] $ manual : logi FALSE [16:45:42.235] $ dryrun : logi FALSE [16:45:42.235] $ quiet : logi FALSE [16:45:42.235] $ setup_strategy : chr "parallel" [16:45:42.235] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [16:45:42.235] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d807df36a5d.pid" [16:45:42.235] $ rshcmd_label : NULL [16:45:42.235] $ rsh_call : NULL [16:45:42.235] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [16:45:42.235] $ localMachine : logi TRUE [16:45:42.235] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:42.235] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:42.235] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:42.235] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:42.235] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:42.235] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:42.235] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:42.235] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:42.235] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:42.235] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:42.235] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:42.235] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:42.235] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:42.235] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:42.235] $ arguments :List of 28 [16:45:42.235] ..$ worker : chr "localhost" [16:45:42.235] ..$ master : NULL [16:45:42.235] ..$ port : int 26741 [16:45:42.235] ..$ connectTimeout : num 120 [16:45:42.235] ..$ timeout : num 120 [16:45:42.235] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [16:45:42.235] ..$ homogeneous : NULL [16:45:42.235] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [16:45:42.235] ..$ rscript_envs : NULL [16:45:42.235] ..$ rscript_libs : NULL [16:45:42.235] ..$ rscript_startup : NULL [16:45:42.235] ..$ rscript_sh : chr "auto" [16:45:42.235] ..$ default_packages: chr [1:2] "parallelly" "*" [16:45:42.235] ..$ methods : logi TRUE [16:45:42.235] ..$ socketOptions : chr "no-delay" [16:45:42.235] ..$ useXDR : logi FALSE [16:45:42.235] ..$ outfile : chr "/dev/null" [16:45:42.235] ..$ renice : int NA [16:45:42.235] ..$ rshcmd : NULL [16:45:42.235] ..$ user : NULL [16:45:42.235] ..$ revtunnel : logi NA [16:45:42.235] ..$ rshlogfile : NULL [16:45:42.235] ..$ rshopts : NULL [16:45:42.235] ..$ rank : int 1 [16:45:42.235] ..$ manual : logi FALSE [16:45:42.235] ..$ dryrun : logi FALSE [16:45:42.235] ..$ quiet : logi FALSE [16:45:42.235] ..$ setup_strategy : chr "parallel" [16:45:42.235] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:42.271] [local output] System call to launch all workers: [16:45:42.271] [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:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d807df36a5d.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=26741 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [16:45:42.271] [local output] Starting PSOCK main server [16:45:42.276] [local output] Workers launched [16:45:42.276] [local output] Waiting for workers to connect back [16:45:42.276] - [local output] 0 workers out of 1 ready [16:45:42.591] - [local output] 0 workers out of 1 ready [16:45:42.592] - [local output] 1 workers out of 1 ready [16:45:42.592] [local output] Launching of 1 workers completed [16:45:42.592] [local output] Number of nodes in cluster: 1 [16:45:42.593] [local output] Collecting session information from 1 workers [16:45:42.594] [local output] - Worker #1 of 1 [16:45:42.594] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > res <- tryCatch({ + cl <- makeClusterPSOCK(1:2) + }, error = identity) [16:45:42.601] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(0L) + }, error = identity) [16:45:42.602] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, rshcmd = character(0L)) + }, error = identity) [16:45:42.603] [local output] makeClusterPSOCK() ... [16:45:42.608] [local output] Workers: [n = 1] 'localhost' [16:45:42.613] [local output] Base port: 28114 [16:45:42.613] [local output] Getting setup options for 1 cluster nodes ... [16:45:42.614] [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) [16:45:42.615] [local output] makeClusterPSOCK() ... [16:45:42.619] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = NA_integer_) + }, error = identity) [16:45:42.620] [local output] makeClusterPSOCK() ... [16:45:42.624] [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) + } [16:45:42.629] [local output] makeClusterPSOCK() ... [16:45:42.634] [local output] Workers: [n = 1] 'localhost' [16:45:42.639] [local output] Base port: 22232 [16:45:42.639] [local output] Getting setup options for 1 cluster nodes ... [16:45:42.639] [local output] - Node #1 of 1 ... [16:45:42.640] [local output] localMachine=TRUE => revtunnel=FALSE [16:45:42.643] [local output] Rscript port: 22232 [16:45:42.644] [local output] Getting setup options for 1 cluster nodes ... done [16:45:42.644] [local output] - Parallel setup requested for some PSOCK nodes [16:45:42.645] [local output] Setting up PSOCK nodes in parallel [16:45:42.645] List of 36 [16:45:42.645] $ worker : chr "localhost" [16:45:42.645] ..- attr(*, "localhost")= logi TRUE [16:45:42.645] $ master : chr "localhost" [16:45:42.645] $ port : int 22232 [16:45:42.645] $ connectTimeout : num 0.1 [16:45:42.645] $ timeout : num 7 [16:45:42.645] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [16:45:42.645] $ homogeneous : logi TRUE [16:45:42.645] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:101760:CRANWI"| __truncated__ [16:45:42.645] $ rscript_envs : NULL [16:45:42.645] $ rscript_libs : NULL [16:45:42.645] $ rscript_startup : chr [1:2] "-e" "\"invisible({Sys.sleep(6)})\"" [16:45:42.645] $ rscript_sh : chr [1:2] "cmd" "cmd" [16:45:42.645] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:42.645] $ methods : logi TRUE [16:45:42.645] $ socketOptions : chr "no-delay" [16:45:42.645] $ useXDR : logi FALSE [16:45:42.645] $ outfile : chr "/dev/null" [16:45:42.645] $ renice : int NA [16:45:42.645] $ rshcmd : NULL [16:45:42.645] $ user : chr(0) [16:45:42.645] $ revtunnel : logi FALSE [16:45:42.645] $ rshlogfile : NULL [16:45:42.645] $ rshopts : chr(0) [16:45:42.645] $ rank : int 1 [16:45:42.645] $ manual : logi FALSE [16:45:42.645] $ dryrun : logi FALSE [16:45:42.645] $ quiet : logi FALSE [16:45:42.645] $ setup_strategy : chr "parallel" [16:45:42.645] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:42.645] $ pidfile : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80334d4045.pid" [16:45:42.645] $ rshcmd_label : NULL [16:45:42.645] $ rsh_call : NULL [16:45:42.645] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [16:45:42.645] $ localMachine : logi TRUE [16:45:42.645] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [16:45:42.645] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [16:45:42.645] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [16:45:42.645] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [16:45:42.645] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [16:45:42.645] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [16:45:42.645] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [16:45:42.645] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [16:45:42.645] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [16:45:42.645] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [16:45:42.645] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [16:45:42.645] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [16:45:42.645] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [16:45:42.645] "parallel"), action = c("launch", "options"), verbose = FALSE) [16:45:42.645] $ arguments :List of 28 [16:45:42.645] ..$ worker : chr "localhost" [16:45:42.645] ..$ master : NULL [16:45:42.645] ..$ port : int 22232 [16:45:42.645] ..$ connectTimeout : num 0.1 [16:45:42.645] ..$ timeout : num 7 [16:45:42.645] ..$ rscript : NULL [16:45:42.645] ..$ homogeneous : NULL [16:45:42.645] ..$ rscript_args : NULL [16:45:42.645] ..$ rscript_envs : NULL [16:45:42.645] ..$ rscript_libs : NULL [16:45:42.645] ..$ rscript_startup : language Sys.sleep(6) [16:45:42.645] ..$ rscript_sh : chr "auto" [16:45:42.645] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [16:45:42.645] ..$ methods : logi TRUE [16:45:42.645] ..$ socketOptions : chr "no-delay" [16:45:42.645] ..$ useXDR : logi FALSE [16:45:42.645] ..$ outfile : chr "/dev/null" [16:45:42.645] ..$ renice : int NA [16:45:42.645] ..$ rshcmd : NULL [16:45:42.645] ..$ user : NULL [16:45:42.645] ..$ revtunnel : logi NA [16:45:42.645] ..$ rshlogfile : NULL [16:45:42.645] ..$ rshopts : NULL [16:45:42.645] ..$ rank : int 1 [16:45:42.645] ..$ manual : logi FALSE [16:45:42.645] ..$ dryrun : logi FALSE [16:45:42.645] ..$ quiet : logi FALSE [16:45:42.645] ..$ setup_strategy : chr "parallel" [16:45:42.645] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [16:45:42.678] [local output] System call to launch all workers: [16:45:42.679] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:101760:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpodMsfR/worker.rank=1.parallelly.parent=101760.18d80334d4045.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=22232 OUT=/dev/null TIMEOUT=7 XDR=FALSE SETUPTIMEOUT=0.1 SETUPSTRATEGY=parallel [16:45:42.679] [local output] Starting PSOCK main server [16:45:42.684] [local output] Workers launched [16:45:42.685] [local output] Waiting for workers to connect back [16:45:42.685] - [local output] 0 workers out of 1 ready [16:45:42.882] - [local output] 0 workers out of 1 ready [16:45:43.085] - [local output] 0 workers out of 1 ready [16:45:43.288] - [local output] 0 workers out of 1 ready [16:45:43.491] - [local output] 0 workers out of 1 ready [16:45:43.694] - [local output] 0 workers out of 1 ready [16:45:43.897] - [local output] 0 workers out of 1 ready [16:45:44.100] - [local output] 0 workers out of 1 ready [16:45:44.303] - [local output] 0 workers out of 1 ready [16:45:44.507] - [local output] 0 workers out of 1 ready [16:45:44.710] - [local output] 0 workers out of 1 ready [16:45:44.913] - [local output] 0 workers out of 1 ready [16:45:45.116] - [local output] 0 workers out of 1 ready [16:45:45.319] - [local output] 0 workers out of 1 ready [16:45:45.522] - [local output] 0 workers out of 1 ready [16:45:45.725] - [local output] 0 workers out of 1 ready [16:45:45.928] - [local output] 0 workers out of 1 ready [16:45:46.132] - [local output] 0 workers out of 1 ready [16:45:46.335] - [local output] 0 workers out of 1 ready [16:45:46.538] - [local output] 0 workers out of 1 ready [16:45:46.741] - [local output] 0 workers out of 1 ready [16:45:46.944] - [local output] 0 workers out of 1 ready [16:45:47.147] - [local output] 0 workers out of 1 ready [16:45:47.350] - [local output] 0 workers out of 1 ready [16:45:47.553] - [local output] 0 workers out of 1 ready [16:45:47.757] - [local output] 0 workers out of 1 ready [16:45:47.960] - [local output] 0 workers out of 1 ready > > message("*** makeClusterPSOCK() ... DONE") *** makeClusterPSOCK() ... DONE > > source("incl/end.R") > > proc.time() user system elapsed 1.96 0.20 20.57