R Under development (unstable) (2024-02-13 r85898 ucrt) -- "Unsuffered Consequences" Copyright (C) 2024 The R Foundation for Statistical Computing Platform: x86_64-w64-mingw32/x64 R is free software and comes with ABSOLUTELY NO WARRANTY. You are welcome to redistribute it under certain conditions. Type 'license()' or 'licence()' for distribution details. R is a collaborative project with many contributors. Type 'contributors()' for more information and 'citation()' on how to cite R or R packages in publications. Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for an HTML browser interface to help. Type 'q()' to quit R. > source("incl/start.R") > > is_fqdn <- parallelly:::is_fqdn > is_ip_number <- parallelly:::is_ip_number > is_localhost <- parallelly:::is_localhost > find_rshcmd <- parallelly:::find_rshcmd > > message("*** makeClusterPSOCK() ...") *** makeClusterPSOCK() ... > > message("- makeClusterPSOCK() - internal utility functions") - makeClusterPSOCK() - internal utility functions > > stopifnot( + is_fqdn("a.b"), + is_fqdn("a.b.c"), + !is_fqdn("a") + ) > > stopifnot( + is_ip_number("1.2.3.4"), + !is_ip_number("a"), + !is_ip_number("1.2.3"), + !is_ip_number("1.2.3.256"), + !is_ip_number("1.2.3.-1"), + !is_ip_number("1.2.3.a") + ) > > ## Reset internal cache > stopifnot(is.na(is_localhost(worker = NULL, hostname = NULL))) > stopifnot( + is_localhost("localhost"), + is_localhost("127.0.0.1"), + is_localhost(Sys.info()[["nodename"]]), + is_localhost(Sys.info()[["nodename"]]), ## cache hit + !is_localhost("not.a.localhost.hostname") + ) > > cmd <- find_rshcmd(must_work = FALSE) > print(cmd) $ssh ssh "d:\\rtools43\\usr\\bin\\ssh.exe" attr(,"type") [1] "ssh" attr(,"version") [1] "OpenSSH_9.6p1, OpenSSL 3.2.1 30 Jan 2024" $`putty-plink` plink "C:\\PROGRA~1\\PuTTY\\plink.exe" "-ssh" attr(,"type") [1] "putty-plink" attr(,"version") [1] "plink: Release 0.78; 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: 4ff82ab29a22936b78510c68f544a99e677efed3" > > > message("- makeClusterPSOCK()") - makeClusterPSOCK() > > cl <- makeClusterPSOCK("", user = "johndoe", master = NULL, revtunnel = FALSE, rshcmd = "my_ssh", renice = TRUE, manual = TRUE, dryrun = TRUE) [22:51:58.805] [local output] makeClusterPSOCK() ... [22:51:58.835] [local output] Workers: [n = 1] '' [22:51:58.842] [local output] Base port: 38999 [22:51:58.842] [local output] Getting setup options for 1 cluster nodes ... [22:51:58.843] [local output] - Node 1 of 1 ... [22:51:58.845] [local output] Rscript port: 38999 [22:51:58.845] [local output] Using 'rshcmd': 'my_ssh' [type='', version=''] [22:51:58.845] [local output] Getting setup options for 1 cluster nodes ... done [22:51:58.846] [local output] Creating node 1 of 1 ... [22:51:58.846] [local output] - setting up node [22:51:58.846] [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:76512:CRANWIN3:CRAN' -e 'options(socketOptions = "no-delay")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=38999 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:76512:CRANWIN3:CRAN' -e 'options(socketOptions = \"no-delay\")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=38999 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential" [22:51:58.847] [local output] Creating node 1 of 1 ... done [22:51:58.847] [local output] Launching of workers completed [22:51:58.847] [local output] Collecting session information from workers [22:51:58.848] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 0 nodes where > > cl <- makeClusterPSOCK(1L, port = "random", dryrun = TRUE) [22:51:58.849] [local output] makeClusterPSOCK() ... [22:51:58.853] [local output] Workers: [n = 1] 'localhost' [22:51:58.856] [local output] Base port: 21754 [22:51:58.856] [local output] Getting setup options for 1 cluster nodes ... [22:51:58.856] [local output] - Node 1 of 1 ... [22:51:58.857] [local output] localMachine=TRUE => revtunnel=FALSE [22:51:58.858] [local output] Rscript port: 21754 [22:51:58.858] [local output] Getting setup options for 1 cluster nodes ... done [22:51:58.858] [local output] Creating node 1 of 1 ... [22:51:58.859] [local output] - setting up node [22:51:58.859] [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:76512:CRANWIN3:CRAN" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=21754 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [22:51:58.859] [local output] Creating node 1 of 1 ... done [22:51:58.859] [local output] Launching of workers completed [22:51:58.860] [local output] Collecting session information from workers [22:51:58.860] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 0 nodes where > > cl <- makeClusterPSOCK(1L) [22:51:58.860] [local output] makeClusterPSOCK() ... [22:51:58.862] [local output] Workers: [n = 1] 'localhost' [22:51:58.865] [local output] Base port: 28641 [22:51:58.865] [local output] Getting setup options for 1 cluster nodes ... [22:51:58.865] [local output] - Node 1 of 1 ... [22:51:58.866] [local output] localMachine=TRUE => revtunnel=FALSE [22:51:58.867] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06860514f.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06860514f.pid\")"' [22:51:59.303] - Possible to infer worker's PID: TRUE [22:51:59.304] [local output] Rscript port: 28641 [22:51:59.304] [local output] Getting setup options for 1 cluster nodes ... done [22:51:59.304] [local output] - Parallel setup requested for some PSOCK nodes [22:51:59.305] [local output] Setting up PSOCK nodes in parallel [22:51:59.305] List of 36 [22:51:59.305] $ worker : chr "localhost" [22:51:59.305] ..- attr(*, "localhost")= logi TRUE [22:51:59.305] $ master : chr "localhost" [22:51:59.305] $ port : int 28641 [22:51:59.305] $ connectTimeout : num 120 [22:51:59.305] $ timeout : num 120 [22:51:59.305] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:51:59.305] $ homogeneous : logi TRUE [22:51:59.305] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:51:59.305] $ rscript_envs : NULL [22:51:59.305] $ rscript_libs : NULL [22:51:59.305] $ rscript_startup : NULL [22:51:59.305] $ rscript_sh : chr "cmd" [22:51:59.305] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.305] $ methods : logi TRUE [22:51:59.305] $ socketOptions : chr "no-delay" [22:51:59.305] $ useXDR : logi FALSE [22:51:59.305] $ outfile : chr "/dev/null" [22:51:59.305] $ renice : int NA [22:51:59.305] $ rshcmd : NULL [22:51:59.305] $ user : chr(0) [22:51:59.305] $ revtunnel : logi FALSE [22:51:59.305] $ rshlogfile : NULL [22:51:59.305] $ rshopts : chr(0) [22:51:59.305] $ rank : int 1 [22:51:59.305] $ manual : logi FALSE [22:51:59.305] $ dryrun : logi FALSE [22:51:59.305] $ quiet : logi FALSE [22:51:59.305] $ setup_strategy : chr "parallel" [22:51:59.305] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.305] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06860514f.pid" [22:51:59.305] $ rshcmd_label : NULL [22:51:59.305] $ rsh_call : NULL [22:51:59.305] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.305] $ localMachine : logi TRUE [22:51:59.305] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:51:59.305] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:51:59.305] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:51:59.305] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:51:59.305] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:51:59.305] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:51:59.305] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:51:59.305] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:51:59.305] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:51:59.305] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:51:59.305] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:51:59.305] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:51:59.305] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:51:59.305] $ arguments :List of 28 [22:51:59.305] ..$ worker : chr "localhost" [22:51:59.305] ..$ master : NULL [22:51:59.305] ..$ port : int 28641 [22:51:59.305] ..$ connectTimeout : num 120 [22:51:59.305] ..$ timeout : num 120 [22:51:59.305] ..$ rscript : NULL [22:51:59.305] ..$ homogeneous : NULL [22:51:59.305] ..$ rscript_args : NULL [22:51:59.305] ..$ rscript_envs : NULL [22:51:59.305] ..$ rscript_libs : NULL [22:51:59.305] ..$ rscript_startup : NULL [22:51:59.305] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:51:59.305] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.305] ..$ methods : logi TRUE [22:51:59.305] ..$ socketOptions : chr "no-delay" [22:51:59.305] ..$ useXDR : logi FALSE [22:51:59.305] ..$ outfile : chr "/dev/null" [22:51:59.305] ..$ renice : int NA [22:51:59.305] ..$ rshcmd : NULL [22:51:59.305] ..$ user : NULL [22:51:59.305] ..$ revtunnel : logi NA [22:51:59.305] ..$ rshlogfile : NULL [22:51:59.305] ..$ rshopts : NULL [22:51:59.305] ..$ rank : int 1 [22:51:59.305] ..$ manual : logi FALSE [22:51:59.305] ..$ dryrun : logi FALSE [22:51:59.305] ..$ quiet : logi FALSE [22:51:59.305] ..$ setup_strategy : chr "parallel" [22:51:59.305] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:51:59.330] [local output] System call to launch all workers: [22:51:59.330] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06860514f.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=28641 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:51:59.330] [local output] Starting PSOCK main server [22:51:59.335] [local output] Workers launched [22:51:59.335] [local output] Waiting for workers to connect back [22:51:59.335] - [local output] 0 workers out of 1 ready [22:51:59.506] - [local output] 0 workers out of 1 ready [22:51:59.507] - [local output] 1 workers out of 1 ready [22:51:59.507] [local output] Launching of workers completed [22:51:59.507] [local output] Collecting session information from workers [22:51:59.508] [local output] - Worker #1 of 1 [22:51:59.508] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-02-13 r85898 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 "4.0" .. ..$ year : chr "2024" .. ..$ month : chr "02" .. ..$ day : chr "13" .. ..$ svn rev : chr "85898" .. ..$ language : chr "R" .. ..$ version.string: chr "R Under development (unstable) (2024-02-13 r85898 ucrt)" .. ..$ nickname : chr "Unsuffered Consequences" .. ..$ os.type : chr "windows" ..$ system :List of 8 .. ..$ 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" ..$ libs : chr [1:2] "D:/temp/RtmpYBp677/RLIBS_14f384576978" "D:/RCompile/recent/R/library" ..$ pkgs : NULL ..$ pwd : chr "d:/RCompile/CRANincoming/R-devel/parallelly.Rcheck/tests" ..$ process:List of 1 .. ..$ pid: int 18116 - attr(*, "options")=List of 35 ..$ worker : chr "localhost" .. ..- attr(*, "localhost")= logi TRUE ..$ master : chr "localhost" ..$ port : int 28641 ..$ 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:76512:CRANWIN"| __truncated__ ..$ rscript_envs : NULL ..$ rscript_libs : NULL ..$ rscript_startup : NULL ..$ rscript_sh : chr "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"), 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 28641 .. ..$ 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 [1:3] "auto" "cmd" "sh" .. ..$ 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) + } [22:51:59.566] [local output] makeClusterPSOCK() ... [22:51:59.569] [local output] Workers: [n = 1] 'localhost' [22:51:59.572] [local output] Base port: 21439 [22:51:59.572] [local output] Getting setup options for 1 cluster nodes ... [22:51:59.572] [local output] - Node 1 of 1 ... [22:51:59.572] [local output] localMachine=TRUE => revtunnel=FALSE [22:51:59.574] [local output] Rscript port: 21439 [22:51:59.574] [local output] Getting setup options for 1 cluster nodes ... done [22:51:59.574] [local output] - Parallel setup requested for some PSOCK nodes [22:51:59.575] [local output] Setting up PSOCK nodes in parallel [22:51:59.575] List of 36 [22:51:59.575] $ worker : chr "localhost" [22:51:59.575] ..- attr(*, "localhost")= logi TRUE [22:51:59.575] $ master : chr "localhost" [22:51:59.575] $ port : int 21439 [22:51:59.575] $ connectTimeout : num 120 [22:51:59.575] $ timeout : num 120 [22:51:59.575] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:51:59.575] $ homogeneous : logi TRUE [22:51:59.575] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:51:59.575] $ rscript_envs : NULL [22:51:59.575] $ rscript_libs : NULL [22:51:59.575] $ rscript_startup : NULL [22:51:59.575] $ rscript_sh : chr "cmd" [22:51:59.575] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.575] $ methods : logi TRUE [22:51:59.575] $ socketOptions : chr "no-delay" [22:51:59.575] $ useXDR : logi TRUE [22:51:59.575] $ outfile : chr "/dev/null" [22:51:59.575] $ renice : int NA [22:51:59.575] $ rshcmd : NULL [22:51:59.575] $ user : chr(0) [22:51:59.575] $ revtunnel : logi FALSE [22:51:59.575] $ rshlogfile : NULL [22:51:59.575] $ rshopts : chr(0) [22:51:59.575] $ rank : int 1 [22:51:59.575] $ manual : logi FALSE [22:51:59.575] $ dryrun : logi FALSE [22:51:59.575] $ quiet : logi FALSE [22:51:59.575] $ setup_strategy : chr "parallel" [22:51:59.575] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.575] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae061ef87c.pid" [22:51:59.575] $ rshcmd_label : NULL [22:51:59.575] $ rsh_call : NULL [22:51:59.575] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.575] $ localMachine : logi TRUE [22:51:59.575] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:51:59.575] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:51:59.575] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:51:59.575] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:51:59.575] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:51:59.575] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:51:59.575] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:51:59.575] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:51:59.575] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:51:59.575] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:51:59.575] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:51:59.575] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:51:59.575] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:51:59.575] $ arguments :List of 28 [22:51:59.575] ..$ worker : chr "localhost" [22:51:59.575] ..$ master : NULL [22:51:59.575] ..$ port : int 21439 [22:51:59.575] ..$ connectTimeout : num 120 [22:51:59.575] ..$ timeout : num 120 [22:51:59.575] ..$ rscript : NULL [22:51:59.575] ..$ homogeneous : NULL [22:51:59.575] ..$ rscript_args : NULL [22:51:59.575] ..$ rscript_envs : NULL [22:51:59.575] ..$ rscript_libs : NULL [22:51:59.575] ..$ rscript_startup : NULL [22:51:59.575] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:51:59.575] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.575] ..$ methods : logi TRUE [22:51:59.575] ..$ socketOptions : chr "no-delay" [22:51:59.575] ..$ useXDR : logi TRUE [22:51:59.575] ..$ outfile : chr "/dev/null" [22:51:59.575] ..$ renice : int NA [22:51:59.575] ..$ rshcmd : NULL [22:51:59.575] ..$ user : NULL [22:51:59.575] ..$ revtunnel : logi NA [22:51:59.575] ..$ rshlogfile : NULL [22:51:59.575] ..$ rshopts : NULL [22:51:59.575] ..$ rank : int 1 [22:51:59.575] ..$ manual : logi FALSE [22:51:59.575] ..$ dryrun : logi FALSE [22:51:59.575] ..$ quiet : logi FALSE [22:51:59.575] ..$ setup_strategy : chr "parallel" [22:51:59.575] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:51:59.597] [local output] System call to launch all workers: [22:51:59.597] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae061ef87c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=21439 OUT=/dev/null TIMEOUT=120 XDR=TRUE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:51:59.597] [local output] Starting PSOCK main server [22:51:59.603] [local output] Workers launched [22:51:59.603] [local output] Waiting for workers to connect back [22:51:59.603] - [local output] 0 workers out of 1 ready [22:51:59.774] - [local output] 0 workers out of 1 ready [22:51:59.774] - [local output] 1 workers out of 1 ready [22:51:59.775] [local output] Launching of workers completed [22:51:59.775] [local output] Collecting session information from workers [22:51:59.775] [local output] - Worker #1 of 1 [22:51:59.776] [local output] makeClusterPSOCK() ... done [22:51:59.776] [local output] makeClusterPSOCK() ... [22:51:59.779] [local output] Workers: [n = 1] 'localhost' [22:51:59.781] [local output] Base port: 39219 [22:51:59.781] [local output] Getting setup options for 1 cluster nodes ... [22:51:59.782] [local output] - Node 1 of 1 ... [22:51:59.782] [local output] localMachine=TRUE => revtunnel=FALSE [22:51:59.783] [local output] Rscript port: 39219 [22:51:59.784] [local output] Getting setup options for 1 cluster nodes ... done [22:51:59.784] [local output] - Parallel setup requested for some PSOCK nodes [22:51:59.784] [local output] Setting up PSOCK nodes in parallel [22:51:59.785] List of 36 [22:51:59.785] $ worker : chr "localhost" [22:51:59.785] ..- attr(*, "localhost")= logi TRUE [22:51:59.785] $ master : chr "localhost" [22:51:59.785] $ port : int 39219 [22:51:59.785] $ connectTimeout : num 120 [22:51:59.785] $ timeout : num 120 [22:51:59.785] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:51:59.785] $ homogeneous : logi TRUE [22:51:59.785] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:51:59.785] $ rscript_envs : NULL [22:51:59.785] $ rscript_libs : NULL [22:51:59.785] $ rscript_startup : NULL [22:51:59.785] $ rscript_sh : chr "cmd" [22:51:59.785] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.785] $ methods : logi TRUE [22:51:59.785] $ socketOptions : chr "no-delay" [22:51:59.785] $ useXDR : logi FALSE [22:51:59.785] $ outfile : chr "/dev/null" [22:51:59.785] $ renice : int NA [22:51:59.785] $ rshcmd : NULL [22:51:59.785] $ user : chr(0) [22:51:59.785] $ revtunnel : logi FALSE [22:51:59.785] $ rshlogfile : NULL [22:51:59.785] $ rshopts : chr(0) [22:51:59.785] $ rank : int 1 [22:51:59.785] $ manual : logi FALSE [22:51:59.785] $ dryrun : logi FALSE [22:51:59.785] $ quiet : logi FALSE [22:51:59.785] $ setup_strategy : chr "parallel" [22:51:59.785] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.785] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae017ce7fc9.pid" [22:51:59.785] $ rshcmd_label : NULL [22:51:59.785] $ rsh_call : NULL [22:51:59.785] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.785] $ localMachine : logi TRUE [22:51:59.785] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:51:59.785] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:51:59.785] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:51:59.785] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:51:59.785] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:51:59.785] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:51:59.785] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:51:59.785] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:51:59.785] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:51:59.785] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:51:59.785] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:51:59.785] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:51:59.785] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:51:59.785] $ arguments :List of 28 [22:51:59.785] ..$ worker : chr "localhost" [22:51:59.785] ..$ master : NULL [22:51:59.785] ..$ port : int 39219 [22:51:59.785] ..$ connectTimeout : num 120 [22:51:59.785] ..$ timeout : num 120 [22:51:59.785] ..$ rscript : NULL [22:51:59.785] ..$ homogeneous : NULL [22:51:59.785] ..$ rscript_args : NULL [22:51:59.785] ..$ rscript_envs : NULL [22:51:59.785] ..$ rscript_libs : NULL [22:51:59.785] ..$ rscript_startup : NULL [22:51:59.785] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:51:59.785] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.785] ..$ methods : logi TRUE [22:51:59.785] ..$ socketOptions : chr "no-delay" [22:51:59.785] ..$ useXDR : logi FALSE [22:51:59.785] ..$ outfile : chr "/dev/null" [22:51:59.785] ..$ renice : int NA [22:51:59.785] ..$ rshcmd : NULL [22:51:59.785] ..$ user : NULL [22:51:59.785] ..$ revtunnel : logi NA [22:51:59.785] ..$ rshlogfile : NULL [22:51:59.785] ..$ rshopts : NULL [22:51:59.785] ..$ rank : int 1 [22:51:59.785] ..$ manual : logi FALSE [22:51:59.785] ..$ dryrun : logi FALSE [22:51:59.785] ..$ quiet : logi FALSE [22:51:59.785] ..$ setup_strategy : chr "parallel" [22:51:59.785] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:51:59.807] [local output] System call to launch all workers: [22:51:59.807] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae017ce7fc9.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=39219 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:51:59.807] [local output] Starting PSOCK main server [22:51:59.812] [local output] Workers launched [22:51:59.812] [local output] Waiting for workers to connect back [22:51:59.812] - [local output] 0 workers out of 1 ready [22:51:59.982] - [local output] 0 workers out of 1 ready [22:51:59.982] - [local output] 1 workers out of 1 ready [22:51:59.982] [local output] Launching of workers completed [22:51:59.982] [local output] Collecting session information from workers [22:51:59.983] [local output] - Worker #1 of 1 [22:51:59.983] [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) + } [22:51:59.988] [local output] makeClusterPSOCK() ... [22:51:59.991] [local output] Workers: [n = 1] 'localhost' [22:51:59.993] [local output] Base port: 20468 [22:51:59.993] [local output] Getting setup options for 1 cluster nodes ... [22:51:59.994] [local output] - Node 1 of 1 ... [22:51:59.994] [local output] localMachine=TRUE => revtunnel=FALSE [22:51:59.995] [local output] Rscript port: 20468 [22:51:59.996] [local output] Getting setup options for 1 cluster nodes ... done [22:51:59.996] [local output] - Parallel setup requested for some PSOCK nodes [22:51:59.996] [local output] Setting up PSOCK nodes in parallel [22:51:59.997] List of 36 [22:51:59.997] $ worker : chr "localhost" [22:51:59.997] ..- attr(*, "localhost")= logi TRUE [22:51:59.997] $ master : chr "localhost" [22:51:59.997] $ port : int 20468 [22:51:59.997] $ connectTimeout : num 120 [22:51:59.997] $ timeout : num 120 [22:51:59.997] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:51:59.997] $ homogeneous : logi TRUE [22:51:59.997] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:51:59.997] $ rscript_envs : NULL [22:51:59.997] $ rscript_libs : NULL [22:51:59.997] $ rscript_startup : NULL [22:51:59.997] $ rscript_sh : chr "cmd" [22:51:59.997] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.997] $ methods : logi TRUE [22:51:59.997] $ socketOptions : NULL [22:51:59.997] $ useXDR : logi FALSE [22:51:59.997] $ outfile : chr "/dev/null" [22:51:59.997] $ renice : int NA [22:51:59.997] $ rshcmd : NULL [22:51:59.997] $ user : chr(0) [22:51:59.997] $ revtunnel : logi FALSE [22:51:59.997] $ rshlogfile : NULL [22:51:59.997] $ rshopts : chr(0) [22:51:59.997] $ rank : int 1 [22:51:59.997] $ manual : logi FALSE [22:51:59.997] $ dryrun : logi FALSE [22:51:59.997] $ quiet : logi FALSE [22:51:59.997] $ setup_strategy : chr "parallel" [22:51:59.997] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.997] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae057d632fc.pid" [22:51:59.997] $ rshcmd_label : NULL [22:51:59.997] $ rsh_call : NULL [22:51:59.997] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:51:59.997] $ localMachine : logi TRUE [22:51:59.997] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:51:59.997] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:51:59.997] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:51:59.997] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:51:59.997] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:51:59.997] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:51:59.997] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:51:59.997] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:51:59.997] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:51:59.997] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:51:59.997] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:51:59.997] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:51:59.997] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:51:59.997] $ arguments :List of 28 [22:51:59.997] ..$ worker : chr "localhost" [22:51:59.997] ..$ master : NULL [22:51:59.997] ..$ port : int 20468 [22:51:59.997] ..$ connectTimeout : num 120 [22:51:59.997] ..$ timeout : num 120 [22:51:59.997] ..$ rscript : NULL [22:51:59.997] ..$ homogeneous : NULL [22:51:59.997] ..$ rscript_args : NULL [22:51:59.997] ..$ rscript_envs : NULL [22:51:59.997] ..$ rscript_libs : NULL [22:51:59.997] ..$ rscript_startup : NULL [22:51:59.997] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:51:59.997] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:51:59.997] ..$ methods : logi TRUE [22:51:59.997] ..$ socketOptions : NULL [22:51:59.997] ..$ useXDR : logi FALSE [22:51:59.997] ..$ outfile : chr "/dev/null" [22:51:59.997] ..$ renice : int NA [22:51:59.997] ..$ rshcmd : NULL [22:51:59.997] ..$ user : NULL [22:51:59.997] ..$ revtunnel : logi NA [22:51:59.997] ..$ rshlogfile : NULL [22:51:59.997] ..$ rshopts : NULL [22:51:59.997] ..$ rank : int 1 [22:51:59.997] ..$ manual : logi FALSE [22:51:59.997] ..$ dryrun : logi FALSE [22:51:59.997] ..$ quiet : logi FALSE [22:51:59.997] ..$ setup_strategy : chr "parallel" [22:51:59.997] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:00.019] [local output] System call to launch all workers: [22:52:00.019] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae057d632fc.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20468 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:00.019] [local output] Starting PSOCK main server [22:52:00.023] [local output] Workers launched [22:52:00.024] [local output] Waiting for workers to connect back [22:52:00.024] - [local output] 0 workers out of 1 ready [22:52:00.189] - [local output] 0 workers out of 1 ready [22:52:00.190] - [local output] 1 workers out of 1 ready [22:52:00.190] [local output] Launching of workers completed [22:52:00.190] [local output] Collecting session information from workers [22:52:00.191] [local output] - Worker #1 of 1 [22:52:00.191] [local output] makeClusterPSOCK() ... done [22:52:00.191] [local output] makeClusterPSOCK() ... [22:52:00.194] [local output] Workers: [n = 1] 'localhost' [22:52:00.197] [local output] Base port: 23065 [22:52:00.197] [local output] Getting setup options for 1 cluster nodes ... [22:52:00.197] [local output] - Node 1 of 1 ... [22:52:00.197] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:00.199] [local output] Rscript port: 23065 [22:52:00.199] [local output] Getting setup options for 1 cluster nodes ... done [22:52:00.199] [local output] - Parallel setup requested for some PSOCK nodes [22:52:00.200] [local output] Setting up PSOCK nodes in parallel [22:52:00.200] List of 36 [22:52:00.200] $ worker : chr "localhost" [22:52:00.200] ..- attr(*, "localhost")= logi TRUE [22:52:00.200] $ master : chr "localhost" [22:52:00.200] $ port : int 23065 [22:52:00.200] $ connectTimeout : num 120 [22:52:00.200] $ timeout : num 120 [22:52:00.200] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:00.200] $ homogeneous : logi TRUE [22:52:00.200] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:00.200] $ rscript_envs : NULL [22:52:00.200] $ rscript_libs : NULL [22:52:00.200] $ rscript_startup : NULL [22:52:00.200] $ rscript_sh : chr "cmd" [22:52:00.200] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.200] $ methods : logi TRUE [22:52:00.200] $ socketOptions : NULL [22:52:00.200] $ useXDR : logi FALSE [22:52:00.200] $ outfile : chr "/dev/null" [22:52:00.200] $ renice : int NA [22:52:00.200] $ rshcmd : NULL [22:52:00.200] $ user : chr(0) [22:52:00.200] $ revtunnel : logi FALSE [22:52:00.200] $ rshlogfile : NULL [22:52:00.200] $ rshopts : chr(0) [22:52:00.200] $ rank : int 1 [22:52:00.200] $ manual : logi FALSE [22:52:00.200] $ dryrun : logi FALSE [22:52:00.200] $ quiet : logi FALSE [22:52:00.200] $ setup_strategy : chr "parallel" [22:52:00.200] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.200] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae05f7497.pid" [22:52:00.200] $ rshcmd_label : NULL [22:52:00.200] $ rsh_call : NULL [22:52:00.200] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.200] $ localMachine : logi TRUE [22:52:00.200] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:00.200] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:00.200] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:00.200] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:00.200] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:00.200] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:00.200] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:00.200] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:00.200] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:00.200] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:00.200] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:00.200] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:00.200] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:00.200] $ arguments :List of 28 [22:52:00.200] ..$ worker : chr "localhost" [22:52:00.200] ..$ master : NULL [22:52:00.200] ..$ port : int 23065 [22:52:00.200] ..$ connectTimeout : num 120 [22:52:00.200] ..$ timeout : num 120 [22:52:00.200] ..$ rscript : NULL [22:52:00.200] ..$ homogeneous : NULL [22:52:00.200] ..$ rscript_args : NULL [22:52:00.200] ..$ rscript_envs : NULL [22:52:00.200] ..$ rscript_libs : NULL [22:52:00.200] ..$ rscript_startup : NULL [22:52:00.200] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:00.200] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.200] ..$ methods : logi TRUE [22:52:00.200] ..$ socketOptions : chr "NULL" [22:52:00.200] ..$ useXDR : logi FALSE [22:52:00.200] ..$ outfile : chr "/dev/null" [22:52:00.200] ..$ renice : int NA [22:52:00.200] ..$ rshcmd : NULL [22:52:00.200] ..$ user : NULL [22:52:00.200] ..$ revtunnel : logi NA [22:52:00.200] ..$ rshlogfile : NULL [22:52:00.200] ..$ rshopts : NULL [22:52:00.200] ..$ rank : int 1 [22:52:00.200] ..$ manual : logi FALSE [22:52:00.200] ..$ dryrun : logi FALSE [22:52:00.200] ..$ quiet : logi FALSE [22:52:00.200] ..$ setup_strategy : chr "parallel" [22:52:00.200] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:00.221] [local output] System call to launch all workers: [22:52:00.222] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae05f7497.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=23065 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:00.222] [local output] Starting PSOCK main server [22:52:00.226] [local output] Workers launched [22:52:00.226] [local output] Waiting for workers to connect back [22:52:00.226] - [local output] 0 workers out of 1 ready [22:52:00.396] - [local output] 0 workers out of 1 ready [22:52:00.396] - [local output] 1 workers out of 1 ready [22:52:00.396] [local output] Launching of workers completed [22:52:00.397] [local output] Collecting session information from workers [22:52:00.397] [local output] - Worker #1 of 1 [22:52:00.397] [local output] makeClusterPSOCK() ... done [22:52:00.398] [local output] makeClusterPSOCK() ... [22:52:00.401] [local output] Workers: [n = 1] 'localhost' [22:52:00.403] [local output] Base port: 37649 [22:52:00.404] [local output] Getting setup options for 1 cluster nodes ... [22:52:00.404] [local output] - Node 1 of 1 ... [22:52:00.404] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:00.406] [local output] Rscript port: 37649 [22:52:00.406] [local output] Getting setup options for 1 cluster nodes ... done [22:52:00.406] [local output] - Parallel setup requested for some PSOCK nodes [22:52:00.407] [local output] Setting up PSOCK nodes in parallel [22:52:00.407] List of 36 [22:52:00.407] $ worker : chr "localhost" [22:52:00.407] ..- attr(*, "localhost")= logi TRUE [22:52:00.407] $ master : chr "localhost" [22:52:00.407] $ port : int 37649 [22:52:00.407] $ connectTimeout : num 120 [22:52:00.407] $ timeout : num 120 [22:52:00.407] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:00.407] $ homogeneous : logi TRUE [22:52:00.407] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:00.407] $ rscript_envs : NULL [22:52:00.407] $ rscript_libs : NULL [22:52:00.407] $ rscript_startup : NULL [22:52:00.407] $ rscript_sh : chr "cmd" [22:52:00.407] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.407] $ methods : logi TRUE [22:52:00.407] $ socketOptions : chr "no-delay" [22:52:00.407] $ useXDR : logi FALSE [22:52:00.407] $ outfile : chr "/dev/null" [22:52:00.407] $ renice : int NA [22:52:00.407] $ rshcmd : NULL [22:52:00.407] $ user : chr(0) [22:52:00.407] $ revtunnel : logi FALSE [22:52:00.407] $ rshlogfile : NULL [22:52:00.407] $ rshopts : chr(0) [22:52:00.407] $ rank : int 1 [22:52:00.407] $ manual : logi FALSE [22:52:00.407] $ dryrun : logi FALSE [22:52:00.407] $ quiet : logi FALSE [22:52:00.407] $ setup_strategy : chr "parallel" [22:52:00.407] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.407] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0372a3cfc.pid" [22:52:00.407] $ rshcmd_label : NULL [22:52:00.407] $ rsh_call : NULL [22:52:00.407] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.407] $ localMachine : logi TRUE [22:52:00.407] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:00.407] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:00.407] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:00.407] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:00.407] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:00.407] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:00.407] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:00.407] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:00.407] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:00.407] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:00.407] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:00.407] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:00.407] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:00.407] $ arguments :List of 28 [22:52:00.407] ..$ worker : chr "localhost" [22:52:00.407] ..$ master : NULL [22:52:00.407] ..$ port : int 37649 [22:52:00.407] ..$ connectTimeout : num 120 [22:52:00.407] ..$ timeout : num 120 [22:52:00.407] ..$ rscript : NULL [22:52:00.407] ..$ homogeneous : NULL [22:52:00.407] ..$ rscript_args : NULL [22:52:00.407] ..$ rscript_envs : NULL [22:52:00.407] ..$ rscript_libs : NULL [22:52:00.407] ..$ rscript_startup : NULL [22:52:00.407] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:00.407] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.407] ..$ methods : logi TRUE [22:52:00.407] ..$ socketOptions : chr "no-delay" [22:52:00.407] ..$ useXDR : logi FALSE [22:52:00.407] ..$ outfile : chr "/dev/null" [22:52:00.407] ..$ renice : int NA [22:52:00.407] ..$ rshcmd : NULL [22:52:00.407] ..$ user : NULL [22:52:00.407] ..$ revtunnel : logi NA [22:52:00.407] ..$ rshlogfile : NULL [22:52:00.407] ..$ rshopts : NULL [22:52:00.407] ..$ rank : int 1 [22:52:00.407] ..$ manual : logi FALSE [22:52:00.407] ..$ dryrun : logi FALSE [22:52:00.407] ..$ quiet : logi FALSE [22:52:00.407] ..$ setup_strategy : chr "parallel" [22:52:00.407] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:00.430] [local output] System call to launch all workers: [22:52:00.430] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0372a3cfc.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=37649 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:00.430] [local output] Starting PSOCK main server [22:52:00.434] [local output] Workers launched [22:52:00.434] [local output] Waiting for workers to connect back [22:52:00.435] - [local output] 0 workers out of 1 ready [22:52:00.609] - [local output] 0 workers out of 1 ready [22:52:00.610] - [local output] 1 workers out of 1 ready [22:52:00.610] [local output] Launching of workers completed [22:52:00.610] [local output] Collecting session information from workers [22:52:00.611] [local output] - Worker #1 of 1 [22:52:00.611] [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) + } [22:52:00.619] [local output] makeClusterPSOCK() ... [22:52:00.622] [local output] Workers: [n = 1] 'localhost' [22:52:00.625] [local output] Base port: 36261 [22:52:00.625] [local output] Getting setup options for 1 cluster nodes ... [22:52:00.625] [local output] - Node 1 of 1 ... [22:52:00.625] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:00.627] [local output] Rscript port: 36261 [22:52:00.627] [local output] Getting setup options for 1 cluster nodes ... done [22:52:00.627] [local output] - Parallel setup requested for some PSOCK nodes [22:52:00.628] [local output] Setting up PSOCK nodes in parallel [22:52:00.628] List of 36 [22:52:00.628] $ worker : chr "localhost" [22:52:00.628] ..- attr(*, "localhost")= logi TRUE [22:52:00.628] $ master : chr "localhost" [22:52:00.628] $ port : int 36261 [22:52:00.628] $ connectTimeout : num 120 [22:52:00.628] $ timeout : num 120 [22:52:00.628] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:00.628] $ homogeneous : logi TRUE [22:52:00.628] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:00.628] $ rscript_envs : NULL [22:52:00.628] $ rscript_libs : NULL [22:52:00.628] $ rscript_startup : NULL [22:52:00.628] $ rscript_sh : chr "cmd" [22:52:00.628] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.628] $ methods : logi TRUE [22:52:00.628] $ socketOptions : chr "no-delay" [22:52:00.628] $ useXDR : logi FALSE [22:52:00.628] $ outfile : chr "/dev/null" [22:52:00.628] $ renice : int NA [22:52:00.628] $ rshcmd : NULL [22:52:00.628] $ user : chr(0) [22:52:00.628] $ revtunnel : logi FALSE [22:52:00.628] $ rshlogfile : NULL [22:52:00.628] $ rshopts : chr(0) [22:52:00.628] $ rank : int 1 [22:52:00.628] $ manual : logi FALSE [22:52:00.628] $ dryrun : logi FALSE [22:52:00.628] $ quiet : logi FALSE [22:52:00.628] $ setup_strategy : chr "parallel" [22:52:00.628] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.628] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae078a64d5.pid" [22:52:00.628] $ rshcmd_label : NULL [22:52:00.628] $ rsh_call : NULL [22:52:00.628] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.628] $ localMachine : logi TRUE [22:52:00.628] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:00.628] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:00.628] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:00.628] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:00.628] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:00.628] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:00.628] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:00.628] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:00.628] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:00.628] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:00.628] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:00.628] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:00.628] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:00.628] $ arguments :List of 28 [22:52:00.628] ..$ worker : chr "localhost" [22:52:00.628] ..$ master : NULL [22:52:00.628] ..$ port : int 36261 [22:52:00.628] ..$ connectTimeout : num 120 [22:52:00.628] ..$ timeout : num 120 [22:52:00.628] ..$ rscript : NULL [22:52:00.628] ..$ homogeneous : NULL [22:52:00.628] ..$ rscript_args : NULL [22:52:00.628] ..$ rscript_envs : NULL [22:52:00.628] ..$ rscript_libs : NULL [22:52:00.628] ..$ rscript_startup : NULL [22:52:00.628] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:00.628] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.628] ..$ methods : logi TRUE [22:52:00.628] ..$ socketOptions : chr "no-delay" [22:52:00.628] ..$ useXDR : logi FALSE [22:52:00.628] ..$ outfile : chr "/dev/null" [22:52:00.628] ..$ renice : int NA [22:52:00.628] ..$ rshcmd : NULL [22:52:00.628] ..$ user : NULL [22:52:00.628] ..$ revtunnel : logi NA [22:52:00.628] ..$ rshlogfile : NULL [22:52:00.628] ..$ rshopts : NULL [22:52:00.628] ..$ rank : int 1 [22:52:00.628] ..$ manual : logi FALSE [22:52:00.628] ..$ dryrun : logi FALSE [22:52:00.628] ..$ quiet : logi FALSE [22:52:00.628] ..$ setup_strategy : chr "parallel" [22:52:00.628] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:00.651] [local output] System call to launch all workers: [22:52:00.651] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae078a64d5.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36261 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:00.651] [local output] Starting PSOCK main server [22:52:00.655] [local output] Workers launched [22:52:00.656] [local output] Waiting for workers to connect back [22:52:00.656] - [local output] 0 workers out of 1 ready [22:52:00.825] - [local output] 0 workers out of 1 ready [22:52:00.826] - [local output] 1 workers out of 1 ready [22:52:00.826] [local output] Launching of workers completed [22:52:00.826] [local output] Collecting session information from workers [22:52:00.827] [local output] - Worker #1 of 1 [22:52:00.827] [local output] makeClusterPSOCK() ... done [22:52:00.827] [local output] makeClusterPSOCK() ... [22:52:00.830] [local output] Workers: [n = 1] 'localhost' [22:52:00.833] [local output] Base port: 31886 [22:52:00.833] [local output] Getting setup options for 1 cluster nodes ... [22:52:00.833] [local output] - Node 1 of 1 ... [22:52:00.833] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:00.835] [local output] Rscript port: 31886 [22:52:00.835] [local output] Getting setup options for 1 cluster nodes ... done [22:52:00.835] [local output] - Parallel setup requested for some PSOCK nodes [22:52:00.836] [local output] Setting up PSOCK nodes in parallel [22:52:00.836] List of 36 [22:52:00.836] $ worker : chr "localhost" [22:52:00.836] ..- attr(*, "localhost")= logi TRUE [22:52:00.836] $ master : chr "localhost" [22:52:00.836] $ port : int 31886 [22:52:00.836] $ connectTimeout : num 120 [22:52:00.836] $ timeout : num 120 [22:52:00.836] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:00.836] $ homogeneous : logi TRUE [22:52:00.836] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:00.836] $ rscript_envs : NULL [22:52:00.836] $ rscript_libs : NULL [22:52:00.836] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [22:52:00.836] $ rscript_sh : chr "cmd" [22:52:00.836] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.836] $ methods : logi TRUE [22:52:00.836] $ socketOptions : chr "no-delay" [22:52:00.836] $ useXDR : logi FALSE [22:52:00.836] $ outfile : chr "/dev/null" [22:52:00.836] $ renice : int NA [22:52:00.836] $ rshcmd : NULL [22:52:00.836] $ user : chr(0) [22:52:00.836] $ revtunnel : logi FALSE [22:52:00.836] $ rshlogfile : NULL [22:52:00.836] $ rshopts : chr(0) [22:52:00.836] $ rank : int 1 [22:52:00.836] $ manual : logi FALSE [22:52:00.836] $ dryrun : logi FALSE [22:52:00.836] $ quiet : logi FALSE [22:52:00.836] $ setup_strategy : chr "parallel" [22:52:00.836] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.836] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae017575eb3.pid" [22:52:00.836] $ rshcmd_label : NULL [22:52:00.836] $ rsh_call : NULL [22:52:00.836] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:00.836] $ localMachine : logi TRUE [22:52:00.836] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:00.836] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:00.836] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:00.836] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:00.836] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:00.836] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:00.836] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:00.836] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:00.836] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:00.836] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:00.836] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:00.836] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:00.836] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:00.836] $ arguments :List of 28 [22:52:00.836] ..$ worker : chr "localhost" [22:52:00.836] ..$ master : NULL [22:52:00.836] ..$ port : int 31886 [22:52:00.836] ..$ connectTimeout : num 120 [22:52:00.836] ..$ timeout : num 120 [22:52:00.836] ..$ rscript : NULL [22:52:00.836] ..$ homogeneous : NULL [22:52:00.836] ..$ rscript_args : NULL [22:52:00.836] ..$ rscript_envs : NULL [22:52:00.836] ..$ rscript_libs : NULL [22:52:00.836] ..$ rscript_startup : chr "options(abc = 42L)" [22:52:00.836] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:00.836] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:00.836] ..$ methods : logi TRUE [22:52:00.836] ..$ socketOptions : chr "no-delay" [22:52:00.836] ..$ useXDR : logi FALSE [22:52:00.836] ..$ outfile : chr "/dev/null" [22:52:00.836] ..$ renice : int NA [22:52:00.836] ..$ rshcmd : NULL [22:52:00.836] ..$ user : NULL [22:52:00.836] ..$ revtunnel : logi NA [22:52:00.836] ..$ rshlogfile : NULL [22:52:00.836] ..$ rshopts : NULL [22:52:00.836] ..$ rank : int 1 [22:52:00.836] ..$ manual : logi FALSE [22:52:00.836] ..$ dryrun : logi FALSE [22:52:00.836] ..$ quiet : logi FALSE [22:52:00.836] ..$ setup_strategy : chr "parallel" [22:52:00.836] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:00.858] [local output] System call to launch all workers: [22:52:00.859] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae017575eb3.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=31886 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:00.859] [local output] Starting PSOCK main server [22:52:00.863] [local output] Workers launched [22:52:00.863] [local output] Waiting for workers to connect back [22:52:00.863] - [local output] 0 workers out of 1 ready [22:52:01.030] - [local output] 0 workers out of 1 ready [22:52:01.031] - [local output] 1 workers out of 1 ready [22:52:01.031] [local output] Launching of workers completed [22:52:01.031] [local output] Collecting session information from workers [22:52:01.032] [local output] - Worker #1 of 1 [22:52:01.032] [local output] makeClusterPSOCK() ... done [22:52:01.032] [local output] makeClusterPSOCK() ... [22:52:01.035] [local output] Workers: [n = 1] 'localhost' [22:52:01.037] [local output] Base port: 24321 [22:52:01.038] [local output] Getting setup options for 1 cluster nodes ... [22:52:01.038] [local output] - Node 1 of 1 ... [22:52:01.038] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:01.040] [local output] Rscript port: 24321 [22:52:01.040] [local output] Getting setup options for 1 cluster nodes ... done [22:52:01.040] [local output] - Parallel setup requested for some PSOCK nodes [22:52:01.041] [local output] Setting up PSOCK nodes in parallel [22:52:01.041] List of 36 [22:52:01.041] $ worker : chr "localhost" [22:52:01.041] ..- attr(*, "localhost")= logi TRUE [22:52:01.041] $ master : chr "localhost" [22:52:01.041] $ port : int 24321 [22:52:01.041] $ connectTimeout : num 120 [22:52:01.041] $ timeout : num 120 [22:52:01.041] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:01.041] $ homogeneous : logi TRUE [22:52:01.041] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:01.041] $ rscript_envs : NULL [22:52:01.041] $ rscript_libs : NULL [22:52:01.041] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [22:52:01.041] $ rscript_sh : chr "cmd" [22:52:01.041] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:01.041] $ methods : logi TRUE [22:52:01.041] $ socketOptions : chr "no-delay" [22:52:01.041] $ useXDR : logi FALSE [22:52:01.041] $ outfile : chr "/dev/null" [22:52:01.041] $ renice : int NA [22:52:01.041] $ rshcmd : NULL [22:52:01.041] $ user : chr(0) [22:52:01.041] $ revtunnel : logi FALSE [22:52:01.041] $ rshlogfile : NULL [22:52:01.041] $ rshopts : chr(0) [22:52:01.041] $ rank : int 1 [22:52:01.041] $ manual : logi FALSE [22:52:01.041] $ dryrun : logi FALSE [22:52:01.041] $ quiet : logi FALSE [22:52:01.041] $ setup_strategy : chr "parallel" [22:52:01.041] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:01.041] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae07b8c63f5.pid" [22:52:01.041] $ rshcmd_label : NULL [22:52:01.041] $ rsh_call : NULL [22:52:01.041] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:01.041] $ localMachine : logi TRUE [22:52:01.041] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:01.041] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:01.041] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:01.041] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:01.041] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:01.041] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:01.041] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:01.041] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:01.041] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:01.041] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:01.041] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:01.041] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:01.041] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:01.041] $ arguments :List of 28 [22:52:01.041] ..$ worker : chr "localhost" [22:52:01.041] ..$ master : NULL [22:52:01.041] ..$ port : int 24321 [22:52:01.041] ..$ connectTimeout : num 120 [22:52:01.041] ..$ timeout : num 120 [22:52:01.041] ..$ rscript : NULL [22:52:01.041] ..$ homogeneous : NULL [22:52:01.041] ..$ rscript_args : NULL [22:52:01.041] ..$ rscript_envs : NULL [22:52:01.041] ..$ rscript_libs : NULL [22:52:01.041] ..$ rscript_startup : language options(abc = 42L) [22:52:01.041] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:01.041] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:01.041] ..$ methods : logi TRUE [22:52:01.041] ..$ socketOptions : chr "no-delay" [22:52:01.041] ..$ useXDR : logi FALSE [22:52:01.041] ..$ outfile : chr "/dev/null" [22:52:01.041] ..$ renice : int NA [22:52:01.041] ..$ rshcmd : NULL [22:52:01.041] ..$ user : NULL [22:52:01.041] ..$ revtunnel : logi NA [22:52:01.041] ..$ rshlogfile : NULL [22:52:01.041] ..$ rshopts : NULL [22:52:01.041] ..$ rank : int 1 [22:52:01.041] ..$ manual : logi FALSE [22:52:01.041] ..$ dryrun : logi FALSE [22:52:01.041] ..$ quiet : logi FALSE [22:52:01.041] ..$ setup_strategy : chr "parallel" [22:52:01.041] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:01.063] [local output] System call to launch all workers: [22:52:01.063] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae07b8c63f5.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=24321 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:01.063] [local output] Starting PSOCK main server [22:52:01.067] [local output] Workers launched [22:52:01.067] [local output] Waiting for workers to connect back [22:52:01.067] - [local output] 0 workers out of 1 ready [22:52:01.233] - [local output] 0 workers out of 1 ready [22:52:01.233] - [local output] 1 workers out of 1 ready [22:52:01.234] [local output] Launching of workers completed [22:52:01.234] [local output] Collecting session information from workers [22:52:01.234] [local output] - Worker #1 of 1 [22:52:01.235] [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) + } [22:52:01.265] [local output] makeClusterPSOCK() ... [22:52:01.267] [local output] Workers: [n = 2] 'localhost', 'localhost' [22:52:01.270] [local output] Base port: 33168 [22:52:01.270] [local output] Getting setup options for 2 cluster nodes ... [22:52:01.270] [local output] - Node 1 of 2 ... [22:52:01.271] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:01.272] [local output] Rscript port: 33168 [22:52:01.273] [local output] - Node 2 of 2 ... [22:52:01.273] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:01.274] [local output] Rscript port: 33168 [22:52:01.274] [local output] Getting setup options for 2 cluster nodes ... done [22:52:01.275] [local output] Creating node 1 of 2 ... [22:52:01.275] [local output] - setting up node [22:52:01.275] [local output] - attempt #1 of 3 [22:52:01.275] [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:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06cf048ec.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33168 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [22:52:01.280] [local output] - Exit code of system() call: 0 [22:52:01.280] [local output] Waiting for worker #1 on 'localhost' to connect back [22:52:01.451] [local output] Connection with worker #1 on 'localhost' established [22:52:01.451] [local output] Creating node 1 of 2 ... done [22:52:01.451] [local output] Creating node 2 of 2 ... [22:52:01.451] [local output] - setting up node [22:52:01.452] [local output] - attempt #1 of 3 [22:52:01.452] [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:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=2.parallelly.parent=76512.12ae031033f0c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33168 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [22:52:01.456] [local output] - Exit code of system() call: 0 [22:52:01.456] [local output] Waiting for worker #2 on 'localhost' to connect back [22:52:01.633] [local output] Connection with worker #2 on 'localhost' established [22:52:01.633] [local output] Creating node 2 of 2 ... done [22:52:01.633] [local output] Launching of workers completed [22:52:01.634] [local output] Collecting session information from workers [22:52:01.635] [local output] - Worker #1 of 2 [22:52:01.635] [local output] - Worker #2 of 2 [22:52:01.635] [local output] makeClusterPSOCK() ... done user system elapsed 0.02 0.00 0.37 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-02-13 r85898 ucrt), platform x86_64-w64-mingw32) [22:52:01.663] [local output] makeClusterPSOCK() ... [22:52:01.666] [local output] Workers: [n = 2] 'localhost', 'localhost' [22:52:01.668] [local output] Base port: 20728 [22:52:01.669] [local output] Getting setup options for 2 cluster nodes ... [22:52:01.669] [local output] - Node 1 of 2 ... [22:52:01.669] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:01.671] [local output] Rscript port: 20728 [22:52:01.671] [local output] - Node 2 of 2 ... [22:52:01.672] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:01.673] [local output] Rscript port: 20728 [22:52:01.673] [local output] Getting setup options for 2 cluster nodes ... done [22:52:01.673] [local output] - Parallel setup requested for some PSOCK nodes [22:52:01.674] [local output] Setting up PSOCK nodes in parallel [22:52:01.674] List of 36 [22:52:01.674] $ worker : chr "localhost" [22:52:01.674] ..- attr(*, "localhost")= logi TRUE [22:52:01.674] $ master : chr "localhost" [22:52:01.674] $ port : int 20728 [22:52:01.674] $ connectTimeout : num 120 [22:52:01.674] $ timeout : num 120 [22:52:01.674] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:01.674] $ homogeneous : logi TRUE [22:52:01.674] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:01.674] $ rscript_envs : NULL [22:52:01.674] $ rscript_libs : NULL [22:52:01.674] $ rscript_startup : NULL [22:52:01.674] $ rscript_sh : chr "cmd" [22:52:01.674] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:01.674] $ methods : logi TRUE [22:52:01.674] $ socketOptions : chr "no-delay" [22:52:01.674] $ useXDR : logi FALSE [22:52:01.674] $ outfile : chr "/dev/null" [22:52:01.674] $ renice : int NA [22:52:01.674] $ rshcmd : NULL [22:52:01.674] $ user : chr(0) [22:52:01.674] $ revtunnel : logi FALSE [22:52:01.674] $ rshlogfile : NULL [22:52:01.674] $ rshopts : chr(0) [22:52:01.674] $ rank : int 1 [22:52:01.674] $ manual : logi FALSE [22:52:01.674] $ dryrun : logi FALSE [22:52:01.674] $ quiet : logi FALSE [22:52:01.674] $ setup_strategy : chr "parallel" [22:52:01.674] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:01.674] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae044297586.pid" [22:52:01.674] $ rshcmd_label : NULL [22:52:01.674] $ rsh_call : NULL [22:52:01.674] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:01.674] $ localMachine : logi TRUE [22:52:01.674] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:01.674] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:01.674] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:01.674] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:01.674] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:01.674] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:01.674] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:01.674] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:01.674] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:01.674] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:01.674] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:01.674] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:01.674] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:01.674] $ arguments :List of 28 [22:52:01.674] ..$ worker : chr "localhost" [22:52:01.674] ..$ master : NULL [22:52:01.674] ..$ port : int 20728 [22:52:01.674] ..$ connectTimeout : num 120 [22:52:01.674] ..$ timeout : num 120 [22:52:01.674] ..$ rscript : NULL [22:52:01.674] ..$ homogeneous : NULL [22:52:01.674] ..$ rscript_args : NULL [22:52:01.674] ..$ rscript_envs : NULL [22:52:01.674] ..$ rscript_libs : NULL [22:52:01.674] ..$ rscript_startup : NULL [22:52:01.674] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:01.674] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:01.674] ..$ methods : logi TRUE [22:52:01.674] ..$ socketOptions : chr "no-delay" [22:52:01.674] ..$ useXDR : logi FALSE [22:52:01.674] ..$ outfile : chr "/dev/null" [22:52:01.674] ..$ renice : int NA [22:52:01.674] ..$ rshcmd : NULL [22:52:01.674] ..$ user : NULL [22:52:01.674] ..$ revtunnel : logi NA [22:52:01.674] ..$ rshlogfile : NULL [22:52:01.674] ..$ rshopts : NULL [22:52:01.674] ..$ rank : int 1 [22:52:01.674] ..$ manual : logi FALSE [22:52:01.674] ..$ dryrun : logi FALSE [22:52:01.674] ..$ quiet : logi FALSE [22:52:01.674] ..$ setup_strategy : chr "parallel" [22:52:01.674] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:01.694] [local output] System call to launch all workers: [22:52:01.695] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae044297586.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20728 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:01.695] [local output] Starting PSOCK main server [22:52:01.701] [local output] Workers launched [22:52:01.701] [local output] Waiting for workers to connect back [22:52:01.702] - [local output] 0 workers out of 2 ready [22:52:01.867] - [local output] 0 workers out of 2 ready [22:52:01.868] - [local output] 1 workers out of 2 ready [22:52:01.896] - [local output] 1 workers out of 2 ready [22:52:01.896] - [local output] 2 workers out of 2 ready [22:52:01.897] [local output] Launching of workers completed [22:52:01.897] [local output] Collecting session information from workers [22:52:01.898] [local output] - Worker #1 of 2 [22:52:01.898] [local output] - Worker #2 of 2 [22:52:01.899] [local output] makeClusterPSOCK() ... done user system elapsed 0.04 0.00 0.23 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-02-13 r85898 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 [22:52:01.901] [local output] makeClusterPSOCK() ... [22:52:01.904] [local output] Workers: [n = 1] 'localhost' [22:52:01.907] [local output] Base port: 39641 [22:52:01.907] [local output] Getting setup options for 1 cluster nodes ... [22:52:01.907] [local output] - Node 1 of 1 ... [22:52:01.908] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:01.909] [local output] Rscript port: 39641 [22:52:01.909] [local output] Getting setup options for 1 cluster nodes ... done [22:52:01.910] [local output] - Parallel setup requested for some PSOCK nodes [22:52:01.910] [local output] Setting up PSOCK nodes in parallel [22:52:01.910] List of 36 [22:52:01.910] $ worker : chr "localhost" [22:52:01.910] ..- attr(*, "localhost")= logi TRUE [22:52:01.910] $ master : chr "localhost" [22:52:01.910] $ port : int 39641 [22:52:01.910] $ connectTimeout : num 120 [22:52:01.910] $ timeout : num 120 [22:52:01.910] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:01.910] $ homogeneous : logi TRUE [22:52:01.910] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:01.910] $ rscript_envs : NULL [22:52:01.910] $ rscript_libs : NULL [22:52:01.910] $ rscript_startup : NULL [22:52:01.910] $ rscript_sh : chr "cmd" [22:52:01.910] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:01.910] $ methods : logi TRUE [22:52:01.910] $ socketOptions : chr "no-delay" [22:52:01.910] $ useXDR : logi FALSE [22:52:01.910] $ outfile : chr "/dev/null" [22:52:01.910] $ renice : int NA [22:52:01.910] $ rshcmd : NULL [22:52:01.910] $ user : chr(0) [22:52:01.910] $ revtunnel : logi FALSE [22:52:01.910] $ rshlogfile : NULL [22:52:01.910] $ rshopts : chr(0) [22:52:01.910] $ rank : int 1 [22:52:01.910] $ manual : logi FALSE [22:52:01.910] $ dryrun : logi FALSE [22:52:01.910] $ quiet : logi FALSE [22:52:01.910] $ setup_strategy : chr "parallel" [22:52:01.910] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:01.910] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0b5d47f4.pid" [22:52:01.910] $ rshcmd_label : NULL [22:52:01.910] $ rsh_call : NULL [22:52:01.910] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:01.910] $ localMachine : logi TRUE [22:52:01.910] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:01.910] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:01.910] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:01.910] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:01.910] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:01.910] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:01.910] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:01.910] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:01.910] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:01.910] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:01.910] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:01.910] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:01.910] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:01.910] $ arguments :List of 28 [22:52:01.910] ..$ worker : chr "localhost" [22:52:01.910] ..$ master : NULL [22:52:01.910] ..$ port : int 39641 [22:52:01.910] ..$ connectTimeout : num 120 [22:52:01.910] ..$ timeout : num 120 [22:52:01.910] ..$ rscript : NULL [22:52:01.910] ..$ homogeneous : NULL [22:52:01.910] ..$ rscript_args : NULL [22:52:01.910] ..$ rscript_envs : NULL [22:52:01.910] ..$ rscript_libs : NULL [22:52:01.910] ..$ rscript_startup : NULL [22:52:01.910] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:01.910] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:01.910] ..$ methods : logi TRUE [22:52:01.910] ..$ socketOptions : chr "no-delay" [22:52:01.910] ..$ useXDR : logi FALSE [22:52:01.910] ..$ outfile : chr "/dev/null" [22:52:01.910] ..$ renice : int NA [22:52:01.910] ..$ rshcmd : NULL [22:52:01.910] ..$ user : NULL [22:52:01.910] ..$ revtunnel : logi NA [22:52:01.910] ..$ rshlogfile : NULL [22:52:01.910] ..$ rshopts : NULL [22:52:01.910] ..$ rank : int 1 [22:52:01.910] ..$ manual : logi FALSE [22:52:01.910] ..$ dryrun : logi FALSE [22:52:01.910] ..$ quiet : logi FALSE [22:52:01.910] ..$ setup_strategy : chr "parallel" [22:52:01.910] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:01.936] [local output] System call to launch all workers: [22:52:01.936] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0b5d47f4.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=39641 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:01.936] [local output] Starting PSOCK main server [22:52:01.940] [local output] Workers launched [22:52:01.941] [local output] Waiting for workers to connect back [22:52:01.941] - [local output] 0 workers out of 1 ready [22:52:02.105] - [local output] 0 workers out of 1 ready [22:52:02.105] - [local output] 1 workers out of 1 ready [22:52:02.106] [local output] Launching of workers completed [22:52:02.106] [local output] Collecting session information from workers [22:52:02.106] [local output] - Worker #1 of 1 [22:52:02.107] [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) [22:52:02.107] [local output] makeClusterPSOCK() ... [22:52:02.110] [local output] Workers: [n = 1] 'localhost' [22:52:02.113] [local output] Base port: 37333 [22:52:02.113] [local output] Getting setup options for 1 cluster nodes ... [22:52:02.113] [local output] - Node 1 of 1 ... [22:52:02.114] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:02.115] [local output] Rscript port: 37333 [22:52:02.115] [local output] Getting setup options for 1 cluster nodes ... done [22:52:02.116] [local output] - Parallel setup requested for some PSOCK nodes [22:52:02.116] [local output] Setting up PSOCK nodes in parallel [22:52:02.116] List of 36 [22:52:02.116] $ worker : chr "localhost" [22:52:02.116] ..- attr(*, "localhost")= logi TRUE [22:52:02.116] $ master : chr "localhost" [22:52:02.116] $ port : int 37333 [22:52:02.116] $ connectTimeout : num 120 [22:52:02.116] $ timeout : num 120 [22:52:02.116] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:02.116] $ homogeneous : logi TRUE [22:52:02.116] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:02.116] $ rscript_envs : NULL [22:52:02.116] $ rscript_libs : NULL [22:52:02.116] $ rscript_startup : NULL [22:52:02.116] $ rscript_sh : chr "cmd" [22:52:02.116] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:02.116] $ methods : logi TRUE [22:52:02.116] $ socketOptions : chr "no-delay" [22:52:02.116] $ useXDR : logi FALSE [22:52:02.116] $ outfile : chr "/dev/null" [22:52:02.116] $ renice : int NA [22:52:02.116] $ rshcmd : NULL [22:52:02.116] $ user : chr(0) [22:52:02.116] $ revtunnel : logi FALSE [22:52:02.116] $ rshlogfile : NULL [22:52:02.116] $ rshopts : chr(0) [22:52:02.116] $ rank : int 1 [22:52:02.116] $ manual : logi FALSE [22:52:02.116] $ dryrun : logi FALSE [22:52:02.116] $ quiet : logi FALSE [22:52:02.116] $ setup_strategy : chr "parallel" [22:52:02.116] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:02.116] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae047394678.pid" [22:52:02.116] $ rshcmd_label : NULL [22:52:02.116] $ rsh_call : NULL [22:52:02.116] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:02.116] $ localMachine : logi TRUE [22:52:02.116] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:02.116] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:02.116] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:02.116] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:02.116] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:02.116] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:02.116] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:02.116] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:02.116] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:02.116] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:02.116] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:02.116] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:02.116] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:02.116] $ arguments :List of 28 [22:52:02.116] ..$ worker : chr "localhost" [22:52:02.116] ..$ master : NULL [22:52:02.116] ..$ port : int 37333 [22:52:02.116] ..$ connectTimeout : num 120 [22:52:02.116] ..$ timeout : num 120 [22:52:02.116] ..$ rscript : NULL [22:52:02.116] ..$ homogeneous : NULL [22:52:02.116] ..$ rscript_args : NULL [22:52:02.116] ..$ rscript_envs : NULL [22:52:02.116] ..$ rscript_libs : NULL [22:52:02.116] ..$ rscript_startup : NULL [22:52:02.116] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:02.116] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:02.116] ..$ methods : logi TRUE [22:52:02.116] ..$ socketOptions : chr "no-delay" [22:52:02.116] ..$ useXDR : logi FALSE [22:52:02.116] ..$ outfile : chr "/dev/null" [22:52:02.116] ..$ renice : int NA [22:52:02.116] ..$ rshcmd : NULL [22:52:02.116] ..$ user : NULL [22:52:02.116] ..$ revtunnel : logi NA [22:52:02.116] ..$ rshlogfile : NULL [22:52:02.116] ..$ rshopts : NULL [22:52:02.116] ..$ rank : int 1 [22:52:02.116] ..$ manual : logi FALSE [22:52:02.116] ..$ dryrun : logi FALSE [22:52:02.116] ..$ quiet : logi FALSE [22:52:02.116] ..$ setup_strategy : chr "parallel" [22:52:02.116] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:02.139] [local output] System call to launch all workers: [22:52:02.140] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae047394678.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=37333 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:02.140] [local output] Starting PSOCK main server [22:52:02.144] [local output] Workers launched [22:52:02.144] [local output] Waiting for workers to connect back [22:52:02.144] - [local output] 0 workers out of 1 ready [22:52:02.312] - [local output] 0 workers out of 1 ready [22:52:02.312] - [local output] 1 workers out of 1 ready [22:52:02.313] [local output] Launching of workers completed [22:52:02.313] [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 = "") [22:52:02.314] [local output] makeClusterPSOCK() ... [22:52:02.316] [local output] Workers: [n = 1] 'localhost' [22:52:02.319] [local output] Base port: 33682 [22:52:02.319] [local output] Getting setup options for 1 cluster nodes ... [22:52:02.319] [local output] - Node 1 of 1 ... [22:52:02.320] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:02.321] [local output] Rscript port: 33682 [22:52:02.321] [local output] Getting setup options for 1 cluster nodes ... done [22:52:02.322] [local output] - Parallel setup requested for some PSOCK nodes [22:52:02.322] [local output] Setting up PSOCK nodes in parallel [22:52:02.322] List of 36 [22:52:02.322] $ worker : chr "localhost" [22:52:02.322] ..- attr(*, "localhost")= logi TRUE [22:52:02.322] $ master : chr "localhost" [22:52:02.322] $ port : int 33682 [22:52:02.322] $ connectTimeout : num 120 [22:52:02.322] $ timeout : num 120 [22:52:02.322] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:02.322] $ homogeneous : logi TRUE [22:52:02.322] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:02.322] $ rscript_envs : NULL [22:52:02.322] $ rscript_libs : NULL [22:52:02.322] $ rscript_startup : NULL [22:52:02.322] $ rscript_sh : chr "cmd" [22:52:02.322] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:02.322] $ methods : logi TRUE [22:52:02.322] $ socketOptions : chr "no-delay" [22:52:02.322] $ useXDR : logi FALSE [22:52:02.322] $ outfile : chr "" [22:52:02.322] $ renice : int NA [22:52:02.322] $ rshcmd : NULL [22:52:02.322] $ user : chr(0) [22:52:02.322] $ revtunnel : logi FALSE [22:52:02.322] $ rshlogfile : NULL [22:52:02.322] $ rshopts : chr(0) [22:52:02.322] $ rank : int 1 [22:52:02.322] $ manual : logi FALSE [22:52:02.322] $ dryrun : logi FALSE [22:52:02.322] $ quiet : logi FALSE [22:52:02.322] $ setup_strategy : chr "parallel" [22:52:02.322] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:02.322] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06d8a7dbd.pid" [22:52:02.322] $ rshcmd_label : NULL [22:52:02.322] $ rsh_call : NULL [22:52:02.322] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:02.322] $ localMachine : logi TRUE [22:52:02.322] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:02.322] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:02.322] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:02.322] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:02.322] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:02.322] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:02.322] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:02.322] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:02.322] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:02.322] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:02.322] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:02.322] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:02.322] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:02.322] $ arguments :List of 28 [22:52:02.322] ..$ worker : chr "localhost" [22:52:02.322] ..$ master : NULL [22:52:02.322] ..$ port : int 33682 [22:52:02.322] ..$ connectTimeout : num 120 [22:52:02.322] ..$ timeout : num 120 [22:52:02.322] ..$ rscript : NULL [22:52:02.322] ..$ homogeneous : NULL [22:52:02.322] ..$ rscript_args : NULL [22:52:02.322] ..$ rscript_envs : NULL [22:52:02.322] ..$ rscript_libs : NULL [22:52:02.322] ..$ rscript_startup : NULL [22:52:02.322] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:02.322] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:02.322] ..$ methods : logi TRUE [22:52:02.322] ..$ socketOptions : chr "no-delay" [22:52:02.322] ..$ useXDR : logi FALSE [22:52:02.322] ..$ outfile : chr "" [22:52:02.322] ..$ renice : int NA [22:52:02.322] ..$ rshcmd : NULL [22:52:02.322] ..$ user : NULL [22:52:02.322] ..$ revtunnel : logi NA [22:52:02.322] ..$ rshlogfile : NULL [22:52:02.322] ..$ rshopts : NULL [22:52:02.322] ..$ rank : int 1 [22:52:02.322] ..$ manual : logi FALSE [22:52:02.322] ..$ dryrun : logi FALSE [22:52:02.322] ..$ quiet : logi FALSE [22:52:02.322] ..$ setup_strategy : chr "parallel" [22:52:02.322] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:02.343] [local output] System call to launch all workers: [22:52:02.343] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06d8a7dbd.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33682 OUT= TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:02.344] [local output] Starting PSOCK main server [22:52:02.348] [local output] Workers launched [22:52:02.348] [local output] Waiting for workers to connect back [22:52:02.348] - [local output] 0 workers out of 1 ready starting worker pid=47140 on localhost:33682 at 22:52:02.514 [22:52:02.523] - [local output] 0 workers out of 1 ready [22:52:02.523] - [local output] 1 workers out of 1 ready [22:52:02.523] [local output] Launching of workers completed [22:52:02.524] [local output] Collecting session information from workers [22:52:02.524] [local output] - Worker #1 of 1 [22:52:02.524] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-02-13 r85898 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) [22:52:02.526] [local output] makeClusterPSOCK() ... [22:52:02.529] [local output] Workers: [n = 1] 'localhost' [22:52:02.531] [local output] Base port: 36209 [22:52:02.531] [local output] Getting setup options for 1 cluster nodes ... [22:52:02.532] [local output] - Node 1 of 1 ... [22:52:02.532] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:02.533] [local output] Rscript port: 36209 [22:52:02.534] [local output] Getting setup options for 1 cluster nodes ... done [22:52:02.534] [local output] - Parallel setup requested for some PSOCK nodes [22:52:02.534] [local output] Setting up PSOCK nodes in parallel [22:52:02.535] List of 36 [22:52:02.535] $ worker : chr "localhost" [22:52:02.535] ..- attr(*, "localhost")= logi TRUE [22:52:02.535] $ master : chr "localhost" [22:52:02.535] $ port : int 36209 [22:52:02.535] $ connectTimeout : num 120 [22:52:02.535] $ timeout : num 120 [22:52:02.535] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:02.535] $ homogeneous : logi TRUE [22:52:02.535] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:02.535] $ rscript_envs : NULL [22:52:02.535] $ rscript_libs : NULL [22:52:02.535] $ rscript_startup : NULL [22:52:02.535] $ rscript_sh : chr "cmd" [22:52:02.535] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:02.535] $ methods : logi TRUE [22:52:02.535] $ socketOptions : chr "no-delay" [22:52:02.535] $ useXDR : logi FALSE [22:52:02.535] $ outfile : chr "/dev/null" [22:52:02.535] $ renice : int NA [22:52:02.535] $ rshcmd : NULL [22:52:02.535] $ user : chr(0) [22:52:02.535] $ revtunnel : logi FALSE [22:52:02.535] $ rshlogfile : NULL [22:52:02.535] $ rshopts : chr(0) [22:52:02.535] $ rank : int 1 [22:52:02.535] $ manual : logi FALSE [22:52:02.535] $ dryrun : logi FALSE [22:52:02.535] $ quiet : logi FALSE [22:52:02.535] $ setup_strategy : chr "parallel" [22:52:02.535] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:02.535] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06d237b9b.pid" [22:52:02.535] $ rshcmd_label : NULL [22:52:02.535] $ rsh_call : NULL [22:52:02.535] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:02.535] $ localMachine : logi TRUE [22:52:02.535] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:02.535] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:02.535] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:02.535] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:02.535] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:02.535] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:02.535] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:02.535] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:02.535] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:02.535] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:02.535] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:02.535] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:02.535] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:02.535] $ arguments :List of 28 [22:52:02.535] ..$ worker : chr "localhost" [22:52:02.535] ..$ master : NULL [22:52:02.535] ..$ port : int 36209 [22:52:02.535] ..$ connectTimeout : num 120 [22:52:02.535] ..$ timeout : num 120 [22:52:02.535] ..$ rscript : NULL [22:52:02.535] ..$ homogeneous : NULL [22:52:02.535] ..$ rscript_args : NULL [22:52:02.535] ..$ rscript_envs : NULL [22:52:02.535] ..$ rscript_libs : NULL [22:52:02.535] ..$ rscript_startup : NULL [22:52:02.535] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:02.535] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:02.535] ..$ methods : logi TRUE [22:52:02.535] ..$ socketOptions : chr "no-delay" [22:52:02.535] ..$ useXDR : logi FALSE [22:52:02.535] ..$ outfile : chr "/dev/null" [22:52:02.535] ..$ renice : int NA [22:52:02.535] ..$ rshcmd : NULL [22:52:02.535] ..$ user : NULL [22:52:02.535] ..$ revtunnel : logi NA [22:52:02.535] ..$ rshlogfile : NULL [22:52:02.535] ..$ rshopts : NULL [22:52:02.535] ..$ rank : int 1 [22:52:02.535] ..$ manual : logi FALSE [22:52:02.535] ..$ dryrun : logi FALSE [22:52:02.535] ..$ quiet : logi FALSE [22:52:02.535] ..$ setup_strategy : chr "parallel" [22:52:02.535] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:02.557] [local output] System call to launch all workers: [22:52:02.557] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06d237b9b.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36209 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:02.557] [local output] Starting PSOCK main server [22:52:02.561] [local output] Workers launched [22:52:02.562] [local output] Waiting for workers to connect back [22:52:02.562] - [local output] 0 workers out of 1 ready [22:52:02.737] - [local output] 0 workers out of 1 ready [22:52:02.738] - [local output] 1 workers out of 1 ready [22:52:02.738] [local output] Launching of workers completed [22:52:02.738] [local output] Collecting session information from workers [22:52:02.739] [local output] - Worker #1 of 1 [22:52:02.739] [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' [22:52:02.745] [local output] makeClusterPSOCK() ... [22:52:02.747] [local output] Workers: [n = 1] 'localhost' [22:52:02.750] [local output] Base port: 33102 [22:52:02.750] [local output] Getting setup options for 1 cluster nodes ... [22:52:02.750] [local output] - Node 1 of 1 ... [22:52:02.751] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:02.752] 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/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae03cd06efc.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae03cd06efc.pid\")"' [22:52:03.085] - Possible to infer worker's PID: TRUE [22:52:03.086] [local output] Rscript port: 33102 [22:52:03.086] [local output] Getting setup options for 1 cluster nodes ... done [22:52:03.086] [local output] - Parallel setup requested for some PSOCK nodes [22:52:03.087] [local output] Setting up PSOCK nodes in parallel [22:52:03.087] List of 36 [22:52:03.087] $ worker : chr "localhost" [22:52:03.087] ..- attr(*, "localhost")= logi TRUE [22:52:03.087] $ master : chr "localhost" [22:52:03.087] $ port : int 33102 [22:52:03.087] $ connectTimeout : num 120 [22:52:03.087] $ timeout : num 120 [22:52:03.087] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [22:52:03.087] $ homogeneous : logi TRUE [22:52:03.087] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [22:52:03.087] $ rscript_envs : NULL [22:52:03.087] $ rscript_libs : NULL [22:52:03.087] $ rscript_startup : NULL [22:52:03.087] $ rscript_sh : chr "cmd" [22:52:03.087] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:03.087] $ methods : logi TRUE [22:52:03.087] $ socketOptions : chr "no-delay" [22:52:03.087] $ useXDR : logi FALSE [22:52:03.087] $ outfile : chr "/dev/null" [22:52:03.087] $ renice : int NA [22:52:03.087] $ rshcmd : NULL [22:52:03.087] $ user : chr(0) [22:52:03.087] $ revtunnel : logi FALSE [22:52:03.087] $ rshlogfile : NULL [22:52:03.087] $ rshopts : chr(0) [22:52:03.087] $ rank : int 1 [22:52:03.087] $ manual : logi FALSE [22:52:03.087] $ dryrun : logi FALSE [22:52:03.087] $ quiet : logi FALSE [22:52:03.087] $ setup_strategy : chr "parallel" [22:52:03.087] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [22:52:03.087] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae03cd06efc.pid" [22:52:03.087] $ rshcmd_label : NULL [22:52:03.087] $ rsh_call : NULL [22:52:03.087] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [22:52:03.087] $ localMachine : logi TRUE [22:52:03.087] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:03.087] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:03.087] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:03.087] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:03.087] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:03.087] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:03.087] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:03.087] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:03.087] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:03.087] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:03.087] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:03.087] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:03.087] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:03.087] $ arguments :List of 28 [22:52:03.087] ..$ worker : chr "localhost" [22:52:03.087] ..$ master : NULL [22:52:03.087] ..$ port : int 33102 [22:52:03.087] ..$ connectTimeout : num 120 [22:52:03.087] ..$ timeout : num 120 [22:52:03.087] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [22:52:03.087] ..$ homogeneous : NULL [22:52:03.087] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [22:52:03.087] ..$ rscript_envs : NULL [22:52:03.087] ..$ rscript_libs : NULL [22:52:03.087] ..$ rscript_startup : NULL [22:52:03.087] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:03.087] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:03.087] ..$ methods : logi TRUE [22:52:03.087] ..$ socketOptions : chr "no-delay" [22:52:03.087] ..$ useXDR : logi FALSE [22:52:03.087] ..$ outfile : chr "/dev/null" [22:52:03.087] ..$ renice : int NA [22:52:03.087] ..$ rshcmd : NULL [22:52:03.087] ..$ user : NULL [22:52:03.087] ..$ revtunnel : logi NA [22:52:03.087] ..$ rshlogfile : NULL [22:52:03.087] ..$ rshopts : NULL [22:52:03.087] ..$ rank : int 1 [22:52:03.087] ..$ manual : logi FALSE [22:52:03.087] ..$ dryrun : logi FALSE [22:52:03.087] ..$ quiet : logi FALSE [22:52:03.087] ..$ setup_strategy : chr "parallel" [22:52:03.087] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:03.108] [local output] System call to launch all workers: [22:52:03.108] [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:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae03cd06efc.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=33102 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:03.108] [local output] Starting PSOCK main server [22:52:03.113] [local output] Workers launched [22:52:03.113] [local output] Waiting for workers to connect back [22:52:03.113] - [local output] 0 workers out of 1 ready [22:52:03.287] - [local output] 0 workers out of 1 ready [22:52:03.287] - [local output] 1 workers out of 1 ready [22:52:03.287] [local output] Launching of workers completed [22:52:03.288] [local output] Collecting session information from workers [22:52:03.288] [local output] - Worker #1 of 1 [22:52:03.289] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [22:52:03.289] [local output] makeClusterPSOCK() ... [22:52:03.292] [local output] Workers: [n = 1] 'localhost' [22:52:03.294] [local output] Base port: 38930 [22:52:03.294] [local output] Getting setup options for 1 cluster nodes ... [22:52:03.295] [local output] - Node 1 of 1 ... [22:52:03.295] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:03.297] [local output] Rscript port: 38930 [22:52:03.297] [local output] Getting setup options for 1 cluster nodes ... done [22:52:03.297] [local output] - Parallel setup requested for some PSOCK nodes [22:52:03.298] [local output] Setting up PSOCK nodes in parallel [22:52:03.298] List of 36 [22:52:03.298] $ worker : chr "localhost" [22:52:03.298] ..- attr(*, "localhost")= logi TRUE [22:52:03.298] $ master : chr "localhost" [22:52:03.298] $ port : int 38930 [22:52:03.298] $ connectTimeout : num 120 [22:52:03.298] $ timeout : num 120 [22:52:03.298] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [22:52:03.298] $ homogeneous : logi TRUE [22:52:03.298] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [22:52:03.298] $ rscript_envs : NULL [22:52:03.298] $ rscript_libs : NULL [22:52:03.298] $ rscript_startup : NULL [22:52:03.298] $ rscript_sh : chr "cmd" [22:52:03.298] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:03.298] $ methods : logi TRUE [22:52:03.298] $ socketOptions : chr "no-delay" [22:52:03.298] $ useXDR : logi FALSE [22:52:03.298] $ outfile : chr "/dev/null" [22:52:03.298] $ renice : int NA [22:52:03.298] $ rshcmd : NULL [22:52:03.298] $ user : chr(0) [22:52:03.298] $ revtunnel : logi FALSE [22:52:03.298] $ rshlogfile : NULL [22:52:03.298] $ rshopts : chr(0) [22:52:03.298] $ rank : int 1 [22:52:03.298] $ manual : logi FALSE [22:52:03.298] $ dryrun : logi FALSE [22:52:03.298] $ quiet : logi FALSE [22:52:03.298] $ setup_strategy : chr "parallel" [22:52:03.298] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [22:52:03.298] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae04d8d2141.pid" [22:52:03.298] $ rshcmd_label : NULL [22:52:03.298] $ rsh_call : NULL [22:52:03.298] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [22:52:03.298] $ localMachine : logi TRUE [22:52:03.298] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:03.298] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:03.298] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:03.298] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:03.298] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:03.298] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:03.298] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:03.298] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:03.298] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:03.298] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:03.298] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:03.298] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:03.298] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:03.298] $ arguments :List of 28 [22:52:03.298] ..$ worker : chr "localhost" [22:52:03.298] ..$ master : NULL [22:52:03.298] ..$ port : int 38930 [22:52:03.298] ..$ connectTimeout : num 120 [22:52:03.298] ..$ timeout : num 120 [22:52:03.298] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [22:52:03.298] ..$ homogeneous : NULL [22:52:03.298] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [22:52:03.298] ..$ rscript_envs : NULL [22:52:03.298] ..$ rscript_libs : NULL [22:52:03.298] ..$ rscript_startup : NULL [22:52:03.298] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:03.298] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:03.298] ..$ methods : logi TRUE [22:52:03.298] ..$ socketOptions : chr "no-delay" [22:52:03.298] ..$ useXDR : logi FALSE [22:52:03.298] ..$ outfile : chr "/dev/null" [22:52:03.298] ..$ renice : int NA [22:52:03.298] ..$ rshcmd : NULL [22:52:03.298] ..$ user : NULL [22:52:03.298] ..$ revtunnel : logi NA [22:52:03.298] ..$ rshlogfile : NULL [22:52:03.298] ..$ rshopts : NULL [22:52:03.298] ..$ rank : int 1 [22:52:03.298] ..$ manual : logi FALSE [22:52:03.298] ..$ dryrun : logi FALSE [22:52:03.298] ..$ quiet : logi FALSE [22:52:03.298] ..$ setup_strategy : chr "parallel" [22:52:03.298] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:03.320] [local output] System call to launch all workers: [22:52:03.320] [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:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae04d8d2141.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=38930 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:03.320] [local output] Starting PSOCK main server [22:52:03.324] [local output] Workers launched [22:52:03.324] [local output] Waiting for workers to connect back [22:52:03.324] - [local output] 0 workers out of 1 ready [22:52:03.497] - [local output] 0 workers out of 1 ready [22:52:03.497] - [local output] 1 workers out of 1 ready [22:52:03.497] [local output] Launching of workers completed [22:52:03.497] [local output] Collecting session information from workers [22:52:03.498] [local output] - Worker #1 of 1 [22:52:03.498] [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' [22:52:03.510] [local output] makeClusterPSOCK() ... [22:52:03.513] [local output] Workers: [n = 1] 'localhost' [22:52:03.515] [local output] Base port: 34452 [22:52:03.516] [local output] Getting setup options for 1 cluster nodes ... [22:52:03.516] [local output] - Node 1 of 1 ... [22:52:03.516] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:03.517] 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/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06cf61ee1.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06cf61ee1.pid\")"' [22:52:03.741] - Possible to infer worker's PID: TRUE [22:52:03.742] [local output] Rscript port: 34452 [22:52:03.742] [local output] Getting setup options for 1 cluster nodes ... done [22:52:03.742] [local output] - Parallel setup requested for some PSOCK nodes [22:52:03.743] [local output] Setting up PSOCK nodes in parallel [22:52:03.743] List of 36 [22:52:03.743] $ worker : chr "localhost" [22:52:03.743] ..- attr(*, "localhost")= logi TRUE [22:52:03.743] $ master : chr "localhost" [22:52:03.743] $ port : int 34452 [22:52:03.743] $ connectTimeout : num 120 [22:52:03.743] $ timeout : num 120 [22:52:03.743] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [22:52:03.743] $ homogeneous : logi TRUE [22:52:03.743] $ rscript_args : chr "--default-packages=utils,tools -e \"#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN\" -e \"try(suppressWarnings(c"| __truncated__ [22:52:03.743] $ rscript_envs : NULL [22:52:03.743] $ rscript_libs : NULL [22:52:03.743] $ rscript_startup : NULL [22:52:03.743] $ rscript_sh : chr "cmd" [22:52:03.743] $ default_packages: chr [1:2] "utils" "tools" [22:52:03.743] $ methods : logi TRUE [22:52:03.743] $ socketOptions : chr "no-delay" [22:52:03.743] $ useXDR : logi FALSE [22:52:03.743] $ outfile : chr "/dev/null" [22:52:03.743] $ renice : int NA [22:52:03.743] $ rshcmd : NULL [22:52:03.743] $ user : chr(0) [22:52:03.743] $ revtunnel : logi FALSE [22:52:03.743] $ rshlogfile : NULL [22:52:03.743] $ rshopts : chr(0) [22:52:03.743] $ rank : int 1 [22:52:03.743] $ manual : logi FALSE [22:52:03.743] $ dryrun : logi FALSE [22:52:03.743] $ quiet : logi FALSE [22:52:03.743] $ setup_strategy : chr "parallel" [22:52:03.743] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [22:52:03.743] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06cf61ee1.pid" [22:52:03.743] $ rshcmd_label : NULL [22:52:03.743] $ rsh_call : NULL [22:52:03.743] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [22:52:03.743] $ localMachine : logi TRUE [22:52:03.743] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:03.743] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:03.743] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:03.743] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:03.743] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:03.743] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:03.743] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:03.743] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:03.743] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:03.743] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:03.743] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:03.743] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:03.743] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:03.743] $ arguments :List of 28 [22:52:03.743] ..$ worker : chr "localhost" [22:52:03.743] ..$ master : NULL [22:52:03.743] ..$ port : int 34452 [22:52:03.743] ..$ connectTimeout : num 120 [22:52:03.743] ..$ timeout : num 120 [22:52:03.743] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [22:52:03.743] ..$ homogeneous : NULL [22:52:03.743] ..$ rscript_args : NULL [22:52:03.743] ..$ rscript_envs : NULL [22:52:03.743] ..$ rscript_libs : NULL [22:52:03.743] ..$ rscript_startup : NULL [22:52:03.743] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:03.743] ..$ default_packages: chr [1:2] "utils" "tools" [22:52:03.743] ..$ methods : logi TRUE [22:52:03.743] ..$ socketOptions : chr "no-delay" [22:52:03.743] ..$ useXDR : logi FALSE [22:52:03.743] ..$ outfile : chr "/dev/null" [22:52:03.743] ..$ renice : int NA [22:52:03.743] ..$ rshcmd : NULL [22:52:03.743] ..$ user : NULL [22:52:03.743] ..$ revtunnel : logi NA [22:52:03.743] ..$ rshlogfile : NULL [22:52:03.743] ..$ rshopts : NULL [22:52:03.743] ..$ rank : int 1 [22:52:03.743] ..$ manual : logi FALSE [22:52:03.743] ..$ dryrun : logi FALSE [22:52:03.743] ..$ quiet : logi FALSE [22:52:03.743] ..$ setup_strategy : chr "parallel" [22:52:03.743] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:03.763] [local output] System call to launch all workers: [22:52:03.763] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=utils,tools -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae06cf61ee1.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34452 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:03.764] [local output] Starting PSOCK main server [22:52:03.767] [local output] Workers launched [22:52:03.768] [local output] Waiting for workers to connect back [22:52:03.768] - [local output] 0 workers out of 1 ready [22:52:03.847] - [local output] 0 workers out of 1 ready [22:52:03.847] - [local output] 1 workers out of 1 ready [22:52:03.847] [local output] Launching of workers completed [22:52:03.847] [local output] Collecting session information from workers [22:52:03.848] [local output] - Worker #1 of 1 [22:52:03.848] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [22:52:03.849] [local output] makeClusterPSOCK() ... [22:52:03.851] [local output] Workers: [n = 1] 'localhost' [22:52:03.854] [local output] Base port: 30621 [22:52:03.854] [local output] Getting setup options for 1 cluster nodes ... [22:52:03.854] [local output] - Node 1 of 1 ... [22:52:03.855] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:03.856] [local output] Rscript port: 30621 [22:52:03.857] [local output] Getting setup options for 1 cluster nodes ... done [22:52:03.857] [local output] - Parallel setup requested for some PSOCK nodes [22:52:03.857] [local output] Setting up PSOCK nodes in parallel [22:52:03.857] List of 36 [22:52:03.857] $ worker : chr "localhost" [22:52:03.857] ..- attr(*, "localhost")= logi TRUE [22:52:03.857] $ master : chr "localhost" [22:52:03.857] $ port : int 30621 [22:52:03.857] $ connectTimeout : num 120 [22:52:03.857] $ timeout : num 120 [22:52:03.857] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [22:52:03.857] $ homogeneous : logi TRUE [22:52:03.857] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN\" -e \"| __truncated__ [22:52:03.857] $ rscript_envs : NULL [22:52:03.857] $ rscript_libs : NULL [22:52:03.857] $ rscript_startup : NULL [22:52:03.857] $ rscript_sh : chr "cmd" [22:52:03.857] $ default_packages: chr [1:2] "utils" "tools" [22:52:03.857] $ methods : logi TRUE [22:52:03.857] $ socketOptions : chr "no-delay" [22:52:03.857] $ useXDR : logi FALSE [22:52:03.857] $ outfile : chr "/dev/null" [22:52:03.857] $ renice : int NA [22:52:03.857] $ rshcmd : NULL [22:52:03.857] $ user : chr(0) [22:52:03.857] $ revtunnel : logi FALSE [22:52:03.857] $ rshlogfile : NULL [22:52:03.857] $ rshopts : chr(0) [22:52:03.857] $ rank : int 1 [22:52:03.857] $ manual : logi FALSE [22:52:03.857] $ dryrun : logi FALSE [22:52:03.857] $ quiet : logi FALSE [22:52:03.857] $ setup_strategy : chr "parallel" [22:52:03.857] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [22:52:03.857] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae02bff5353.pid" [22:52:03.857] $ rshcmd_label : NULL [22:52:03.857] $ rsh_call : NULL [22:52:03.857] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [22:52:03.857] $ localMachine : logi TRUE [22:52:03.857] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:03.857] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:03.857] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:03.857] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:03.857] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:03.857] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:03.857] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:03.857] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:03.857] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:03.857] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:03.857] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:03.857] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:03.857] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:03.857] $ arguments :List of 28 [22:52:03.857] ..$ worker : chr "localhost" [22:52:03.857] ..$ master : NULL [22:52:03.857] ..$ port : int 30621 [22:52:03.857] ..$ connectTimeout : num 120 [22:52:03.857] ..$ timeout : num 120 [22:52:03.857] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [22:52:03.857] ..$ homogeneous : NULL [22:52:03.857] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [22:52:03.857] ..$ rscript_envs : NULL [22:52:03.857] ..$ rscript_libs : NULL [22:52:03.857] ..$ rscript_startup : NULL [22:52:03.857] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:03.857] ..$ default_packages: chr [1:2] "utils" "tools" [22:52:03.857] ..$ methods : logi TRUE [22:52:03.857] ..$ socketOptions : chr "no-delay" [22:52:03.857] ..$ useXDR : logi FALSE [22:52:03.857] ..$ outfile : chr "/dev/null" [22:52:03.857] ..$ renice : int NA [22:52:03.857] ..$ rshcmd : NULL [22:52:03.857] ..$ user : NULL [22:52:03.857] ..$ revtunnel : logi NA [22:52:03.857] ..$ rshlogfile : NULL [22:52:03.857] ..$ rshopts : NULL [22:52:03.857] ..$ rank : int 1 [22:52:03.857] ..$ manual : logi FALSE [22:52:03.857] ..$ dryrun : logi FALSE [22:52:03.857] ..$ quiet : logi FALSE [22:52:03.857] ..$ setup_strategy : chr "parallel" [22:52:03.857] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:03.878] [local output] System call to launch all workers: [22:52:03.879] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae02bff5353.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=30621 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:03.879] [local output] Starting PSOCK main server [22:52:03.882] [local output] Workers launched [22:52:03.882] [local output] Waiting for workers to connect back [22:52:03.883] - [local output] 0 workers out of 1 ready [22:52:03.964] - [local output] 0 workers out of 1 ready [22:52:03.964] - [local output] 1 workers out of 1 ready [22:52:03.965] [local output] Launching of workers completed [22:52:03.965] [local output] Collecting session information from workers [22:52:03.966] [local output] - Worker #1 of 1 [22:52:03.966] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [22:52:03.967] [local output] makeClusterPSOCK() ... [22:52:03.969] [local output] Workers: [n = 1] 'localhost' [22:52:03.971] [local output] Base port: 29082 [22:52:03.972] [local output] Getting setup options for 1 cluster nodes ... [22:52:03.972] [local output] - Node 1 of 1 ... [22:52:03.972] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:03.974] [local output] Rscript port: 29082 [22:52:03.974] [local output] Getting setup options for 1 cluster nodes ... done [22:52:03.974] [local output] - Parallel setup requested for some PSOCK nodes [22:52:03.975] [local output] Setting up PSOCK nodes in parallel [22:52:03.975] List of 36 [22:52:03.975] $ worker : chr "localhost" [22:52:03.975] ..- attr(*, "localhost")= logi TRUE [22:52:03.975] $ master : chr "localhost" [22:52:03.975] $ port : int 29082 [22:52:03.975] $ connectTimeout : num 120 [22:52:03.975] $ timeout : num 120 [22:52:03.975] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [22:52:03.975] $ homogeneous : logi TRUE [22:52:03.975] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN\" -e \"| __truncated__ [22:52:03.975] $ rscript_envs : NULL [22:52:03.975] $ rscript_libs : NULL [22:52:03.975] $ rscript_startup : NULL [22:52:03.975] $ rscript_sh : chr "cmd" [22:52:03.975] $ default_packages: chr [1:2] "utils" "tools" [22:52:03.975] $ methods : logi TRUE [22:52:03.975] $ socketOptions : chr "no-delay" [22:52:03.975] $ useXDR : logi FALSE [22:52:03.975] $ outfile : chr "/dev/null" [22:52:03.975] $ renice : int NA [22:52:03.975] $ rshcmd : NULL [22:52:03.975] $ user : chr(0) [22:52:03.975] $ revtunnel : logi FALSE [22:52:03.975] $ rshlogfile : NULL [22:52:03.975] $ rshopts : chr(0) [22:52:03.975] $ rank : int 1 [22:52:03.975] $ manual : logi FALSE [22:52:03.975] $ dryrun : logi FALSE [22:52:03.975] $ quiet : logi FALSE [22:52:03.975] $ setup_strategy : chr "parallel" [22:52:03.975] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [22:52:03.975] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae01de51c2f.pid" [22:52:03.975] $ rshcmd_label : NULL [22:52:03.975] $ rsh_call : NULL [22:52:03.975] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [22:52:03.975] $ localMachine : logi TRUE [22:52:03.975] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:03.975] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:03.975] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:03.975] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:03.975] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:03.975] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:03.975] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:03.975] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:03.975] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:03.975] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:03.975] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:03.975] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:03.975] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:03.975] $ arguments :List of 28 [22:52:03.975] ..$ worker : chr "localhost" [22:52:03.975] ..$ master : NULL [22:52:03.975] ..$ port : int 29082 [22:52:03.975] ..$ connectTimeout : num 120 [22:52:03.975] ..$ timeout : num 120 [22:52:03.975] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [22:52:03.975] ..$ homogeneous : NULL [22:52:03.975] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [22:52:03.975] ..$ rscript_envs : NULL [22:52:03.975] ..$ rscript_libs : NULL [22:52:03.975] ..$ rscript_startup : NULL [22:52:03.975] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:03.975] ..$ default_packages: chr [1:2] "utils" "tools" [22:52:03.975] ..$ methods : logi TRUE [22:52:03.975] ..$ socketOptions : chr "no-delay" [22:52:03.975] ..$ useXDR : logi FALSE [22:52:03.975] ..$ outfile : chr "/dev/null" [22:52:03.975] ..$ renice : int NA [22:52:03.975] ..$ rshcmd : NULL [22:52:03.975] ..$ user : NULL [22:52:03.975] ..$ revtunnel : logi NA [22:52:03.975] ..$ rshlogfile : NULL [22:52:03.975] ..$ rshopts : NULL [22:52:03.975] ..$ rank : int 1 [22:52:03.975] ..$ manual : logi FALSE [22:52:03.975] ..$ dryrun : logi FALSE [22:52:03.975] ..$ quiet : logi FALSE [22:52:03.975] ..$ setup_strategy : chr "parallel" [22:52:03.975] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:03.997] [local output] System call to launch all workers: [22:52:03.997] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae01de51c2f.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=29082 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:03.997] [local output] Starting PSOCK main server [22:52:04.001] [local output] Workers launched [22:52:04.001] [local output] Waiting for workers to connect back [22:52:04.001] - [local output] 0 workers out of 1 ready [22:52:04.089] - [local output] 0 workers out of 1 ready [22:52:04.089] - [local output] 1 workers out of 1 ready [22:52:04.089] [local output] Launching of workers completed [22:52:04.089] [local output] Collecting session information from workers [22:52:04.090] [local output] - Worker #1 of 1 [22:52:04.090] [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' [22:52:04.101] [local output] makeClusterPSOCK() ... [22:52:04.104] [local output] Workers: [n = 1] 'localhost' [22:52:04.106] [local output] Base port: 36207 [22:52:04.107] [local output] Getting setup options for 1 cluster nodes ... [22:52:04.107] [local output] - Node 1 of 1 ... [22:52:04.107] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:04.109] [local output] Rscript port: 36207 [22:52:04.109] [local output] Getting setup options for 1 cluster nodes ... done [22:52:04.109] [local output] - Parallel setup requested for some PSOCK nodes [22:52:04.110] [local output] Setting up PSOCK nodes in parallel [22:52:04.110] List of 36 [22:52:04.110] $ worker : chr "localhost" [22:52:04.110] ..- attr(*, "localhost")= logi TRUE [22:52:04.110] $ master : chr "localhost" [22:52:04.110] $ port : int 36207 [22:52:04.110] $ connectTimeout : num 120 [22:52:04.110] $ timeout : num 120 [22:52:04.110] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [22:52:04.110] $ homogeneous : logi TRUE [22:52:04.110] $ rscript_args : chr "--default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76"| __truncated__ [22:52:04.110] $ rscript_envs : NULL [22:52:04.110] $ rscript_libs : NULL [22:52:04.110] $ rscript_startup : NULL [22:52:04.110] $ rscript_sh : chr "cmd" [22:52:04.110] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [22:52:04.110] $ methods : logi TRUE [22:52:04.110] $ socketOptions : chr "no-delay" [22:52:04.110] $ useXDR : logi FALSE [22:52:04.110] $ outfile : chr "/dev/null" [22:52:04.110] $ renice : int NA [22:52:04.110] $ rshcmd : NULL [22:52:04.110] $ user : chr(0) [22:52:04.110] $ revtunnel : logi FALSE [22:52:04.110] $ rshlogfile : NULL [22:52:04.110] $ rshopts : chr(0) [22:52:04.110] $ rank : int 1 [22:52:04.110] $ manual : logi FALSE [22:52:04.110] $ dryrun : logi FALSE [22:52:04.110] $ quiet : logi FALSE [22:52:04.110] $ setup_strategy : chr "parallel" [22:52:04.110] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [22:52:04.110] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae03651790.pid" [22:52:04.110] $ rshcmd_label : NULL [22:52:04.110] $ rsh_call : NULL [22:52:04.110] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [22:52:04.110] $ localMachine : logi TRUE [22:52:04.110] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:04.110] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:04.110] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:04.110] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:04.110] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:04.110] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:04.110] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:04.110] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:04.110] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:04.110] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:04.110] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:04.110] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:04.110] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:04.110] $ arguments :List of 28 [22:52:04.110] ..$ worker : chr "localhost" [22:52:04.110] ..$ master : NULL [22:52:04.110] ..$ port : int 36207 [22:52:04.110] ..$ connectTimeout : num 120 [22:52:04.110] ..$ timeout : num 120 [22:52:04.110] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [22:52:04.110] ..$ homogeneous : NULL [22:52:04.110] ..$ rscript_args : NULL [22:52:04.110] ..$ rscript_envs : NULL [22:52:04.110] ..$ rscript_libs : NULL [22:52:04.110] ..$ rscript_startup : NULL [22:52:04.110] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:04.110] ..$ default_packages: chr [1:2] "parallelly" "*" [22:52:04.110] ..$ methods : logi TRUE [22:52:04.110] ..$ socketOptions : chr "no-delay" [22:52:04.110] ..$ useXDR : logi FALSE [22:52:04.110] ..$ outfile : chr "/dev/null" [22:52:04.110] ..$ renice : int NA [22:52:04.110] ..$ rshcmd : NULL [22:52:04.110] ..$ user : NULL [22:52:04.110] ..$ revtunnel : logi NA [22:52:04.110] ..$ rshlogfile : NULL [22:52:04.110] ..$ rshopts : NULL [22:52:04.110] ..$ rank : int 1 [22:52:04.110] ..$ manual : logi FALSE [22:52:04.110] ..$ dryrun : logi FALSE [22:52:04.110] ..$ quiet : logi FALSE [22:52:04.110] ..$ setup_strategy : chr "parallel" [22:52:04.110] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:04.131] [local output] System call to launch all workers: [22:52:04.131] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae03651790.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36207 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:04.131] [local output] Starting PSOCK main server [22:52:04.136] [local output] Workers launched [22:52:04.136] [local output] Waiting for workers to connect back [22:52:04.136] - [local output] 0 workers out of 1 ready [22:52:04.338] - [local output] 0 workers out of 1 ready [22:52:04.338] - [local output] 1 workers out of 1 ready [22:52:04.338] [local output] Launching of workers completed [22:52:04.339] [local output] Collecting session information from workers [22:52:04.339] [local output] - Worker #1 of 1 [22:52:04.339] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [22:52:04.340] [local output] makeClusterPSOCK() ... [22:52:04.343] [local output] Workers: [n = 1] 'localhost' [22:52:04.345] [local output] Base port: 30790 [22:52:04.346] [local output] Getting setup options for 1 cluster nodes ... [22:52:04.346] [local output] - Node 1 of 1 ... [22:52:04.346] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:04.348] [local output] Rscript port: 30790 [22:52:04.348] [local output] Getting setup options for 1 cluster nodes ... done [22:52:04.349] [local output] - Parallel setup requested for some PSOCK nodes [22:52:04.349] [local output] Setting up PSOCK nodes in parallel [22:52:04.349] List of 36 [22:52:04.349] $ worker : chr "localhost" [22:52:04.349] ..- attr(*, "localhost")= logi TRUE [22:52:04.349] $ master : chr "localhost" [22:52:04.349] $ port : int 30790 [22:52:04.349] $ connectTimeout : num 120 [22:52:04.349] $ timeout : num 120 [22:52:04.349] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [22:52:04.349] $ homogeneous : logi TRUE [22:52:04.349] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [22:52:04.349] $ rscript_envs : NULL [22:52:04.349] $ rscript_libs : NULL [22:52:04.349] $ rscript_startup : NULL [22:52:04.349] $ rscript_sh : chr "cmd" [22:52:04.349] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [22:52:04.349] $ methods : logi TRUE [22:52:04.349] $ socketOptions : chr "no-delay" [22:52:04.349] $ useXDR : logi FALSE [22:52:04.349] $ outfile : chr "/dev/null" [22:52:04.349] $ renice : int NA [22:52:04.349] $ rshcmd : NULL [22:52:04.349] $ user : chr(0) [22:52:04.349] $ revtunnel : logi FALSE [22:52:04.349] $ rshlogfile : NULL [22:52:04.349] $ rshopts : chr(0) [22:52:04.349] $ rank : int 1 [22:52:04.349] $ manual : logi FALSE [22:52:04.349] $ dryrun : logi FALSE [22:52:04.349] $ quiet : logi FALSE [22:52:04.349] $ setup_strategy : chr "parallel" [22:52:04.349] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [22:52:04.349] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0362b31bc.pid" [22:52:04.349] $ rshcmd_label : NULL [22:52:04.349] $ rsh_call : NULL [22:52:04.349] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [22:52:04.349] $ localMachine : logi TRUE [22:52:04.349] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:04.349] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:04.349] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:04.349] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:04.349] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:04.349] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:04.349] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:04.349] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:04.349] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:04.349] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:04.349] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:04.349] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:04.349] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:04.349] $ arguments :List of 28 [22:52:04.349] ..$ worker : chr "localhost" [22:52:04.349] ..$ master : NULL [22:52:04.349] ..$ port : int 30790 [22:52:04.349] ..$ connectTimeout : num 120 [22:52:04.349] ..$ timeout : num 120 [22:52:04.349] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [22:52:04.349] ..$ homogeneous : NULL [22:52:04.349] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [22:52:04.349] ..$ rscript_envs : NULL [22:52:04.349] ..$ rscript_libs : NULL [22:52:04.349] ..$ rscript_startup : NULL [22:52:04.349] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:04.349] ..$ default_packages: chr [1:2] "parallelly" "*" [22:52:04.349] ..$ methods : logi TRUE [22:52:04.349] ..$ socketOptions : chr "no-delay" [22:52:04.349] ..$ useXDR : logi FALSE [22:52:04.349] ..$ outfile : chr "/dev/null" [22:52:04.349] ..$ renice : int NA [22:52:04.349] ..$ rshcmd : NULL [22:52:04.349] ..$ user : NULL [22:52:04.349] ..$ revtunnel : logi NA [22:52:04.349] ..$ rshlogfile : NULL [22:52:04.349] ..$ rshopts : NULL [22:52:04.349] ..$ rank : int 1 [22:52:04.349] ..$ manual : logi FALSE [22:52:04.349] ..$ dryrun : logi FALSE [22:52:04.349] ..$ quiet : logi FALSE [22:52:04.349] ..$ setup_strategy : chr "parallel" [22:52:04.349] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:04.372] [local output] System call to launch all workers: [22:52:04.373] [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:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0362b31bc.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=30790 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:04.373] [local output] Starting PSOCK main server [22:52:04.377] [local output] Workers launched [22:52:04.377] [local output] Waiting for workers to connect back [22:52:04.377] - [local output] 0 workers out of 1 ready [22:52:04.587] - [local output] 0 workers out of 1 ready [22:52:04.587] - [local output] 1 workers out of 1 ready [22:52:04.587] [local output] Launching of workers completed [22:52:04.587] [local output] Collecting session information from workers [22:52:04.588] [local output] - Worker #1 of 1 [22:52:04.588] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [22:52:04.589] [local output] makeClusterPSOCK() ... [22:52:04.591] [local output] Workers: [n = 1] 'localhost' [22:52:04.594] [local output] Base port: 36749 [22:52:04.594] [local output] Getting setup options for 1 cluster nodes ... [22:52:04.595] [local output] - Node 1 of 1 ... [22:52:04.595] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:04.597] [local output] Rscript port: 36749 [22:52:04.597] [local output] Getting setup options for 1 cluster nodes ... done [22:52:04.597] [local output] - Parallel setup requested for some PSOCK nodes [22:52:04.598] [local output] Setting up PSOCK nodes in parallel [22:52:04.598] List of 36 [22:52:04.598] $ worker : chr "localhost" [22:52:04.598] ..- attr(*, "localhost")= logi TRUE [22:52:04.598] $ master : chr "localhost" [22:52:04.598] $ port : int 36749 [22:52:04.598] $ connectTimeout : num 120 [22:52:04.598] $ timeout : num 120 [22:52:04.598] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [22:52:04.598] $ homogeneous : logi TRUE [22:52:04.598] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [22:52:04.598] $ rscript_envs : NULL [22:52:04.598] $ rscript_libs : NULL [22:52:04.598] $ rscript_startup : NULL [22:52:04.598] $ rscript_sh : chr "cmd" [22:52:04.598] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [22:52:04.598] $ methods : logi TRUE [22:52:04.598] $ socketOptions : chr "no-delay" [22:52:04.598] $ useXDR : logi FALSE [22:52:04.598] $ outfile : chr "/dev/null" [22:52:04.598] $ renice : int NA [22:52:04.598] $ rshcmd : NULL [22:52:04.598] $ user : chr(0) [22:52:04.598] $ revtunnel : logi FALSE [22:52:04.598] $ rshlogfile : NULL [22:52:04.598] $ rshopts : chr(0) [22:52:04.598] $ rank : int 1 [22:52:04.598] $ manual : logi FALSE [22:52:04.598] $ dryrun : logi FALSE [22:52:04.598] $ quiet : logi FALSE [22:52:04.598] $ setup_strategy : chr "parallel" [22:52:04.598] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [22:52:04.598] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0688d3607.pid" [22:52:04.598] $ rshcmd_label : NULL [22:52:04.598] $ rsh_call : NULL [22:52:04.598] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [22:52:04.598] $ localMachine : logi TRUE [22:52:04.598] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:04.598] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:04.598] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:04.598] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:04.598] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:04.598] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:04.598] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:04.598] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:04.598] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:04.598] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:04.598] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:04.598] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:04.598] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:04.598] $ arguments :List of 28 [22:52:04.598] ..$ worker : chr "localhost" [22:52:04.598] ..$ master : NULL [22:52:04.598] ..$ port : int 36749 [22:52:04.598] ..$ connectTimeout : num 120 [22:52:04.598] ..$ timeout : num 120 [22:52:04.598] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [22:52:04.598] ..$ homogeneous : NULL [22:52:04.598] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [22:52:04.598] ..$ rscript_envs : NULL [22:52:04.598] ..$ rscript_libs : NULL [22:52:04.598] ..$ rscript_startup : NULL [22:52:04.598] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:04.598] ..$ default_packages: chr [1:2] "parallelly" "*" [22:52:04.598] ..$ methods : logi TRUE [22:52:04.598] ..$ socketOptions : chr "no-delay" [22:52:04.598] ..$ useXDR : logi FALSE [22:52:04.598] ..$ outfile : chr "/dev/null" [22:52:04.598] ..$ renice : int NA [22:52:04.598] ..$ rshcmd : NULL [22:52:04.598] ..$ user : NULL [22:52:04.598] ..$ revtunnel : logi NA [22:52:04.598] ..$ rshlogfile : NULL [22:52:04.598] ..$ rshopts : NULL [22:52:04.598] ..$ rank : int 1 [22:52:04.598] ..$ manual : logi FALSE [22:52:04.598] ..$ dryrun : logi FALSE [22:52:04.598] ..$ quiet : logi FALSE [22:52:04.598] ..$ setup_strategy : chr "parallel" [22:52:04.598] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:04.619] [local output] System call to launch all workers: [22:52:04.619] [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:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0688d3607.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=36749 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [22:52:04.620] [local output] Starting PSOCK main server [22:52:04.624] [local output] Workers launched [22:52:04.624] [local output] Waiting for workers to connect back [22:52:04.624] - [local output] 0 workers out of 1 ready [22:52:04.832] - [local output] 0 workers out of 1 ready [22:52:04.833] - [local output] 1 workers out of 1 ready [22:52:04.833] [local output] Launching of workers completed [22:52:04.833] [local output] Collecting session information from workers [22:52:04.834] [local output] - Worker #1 of 1 [22:52:04.834] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > res <- tryCatch({ + cl <- makeClusterPSOCK(1:2) + }, error = identity) [22:52:04.835] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(0L) + }, error = identity) [22:52:04.836] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, rshcmd = character(0L)) + }, error = identity) [22:52:04.836] [local output] makeClusterPSOCK() ... [22:52:04.839] [local output] Workers: [n = 1] 'localhost' [22:52:04.842] [local output] Base port: 25580 [22:52:04.842] [local output] Getting setup options for 1 cluster nodes ... [22:52:04.842] [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) [22:52:04.843] [local output] makeClusterPSOCK() ... [22:52:04.845] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = NA_integer_) + }, error = identity) [22:52:04.846] [local output] makeClusterPSOCK() ... [22:52:04.848] [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/HenrikBengtsson/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) + } [22:52:04.851] [local output] makeClusterPSOCK() ... [22:52:04.853] [local output] Workers: [n = 1] 'localhost' [22:52:04.856] [local output] Base port: 25931 [22:52:04.856] [local output] Getting setup options for 1 cluster nodes ... [22:52:04.856] [local output] - Node 1 of 1 ... [22:52:04.856] [local output] localMachine=TRUE => revtunnel=FALSE [22:52:04.858] [local output] Rscript port: 25931 [22:52:04.858] [local output] Getting setup options for 1 cluster nodes ... done [22:52:04.859] [local output] - Parallel setup requested for some PSOCK nodes [22:52:04.859] [local output] Setting up PSOCK nodes in parallel [22:52:04.859] List of 36 [22:52:04.859] $ worker : chr "localhost" [22:52:04.859] ..- attr(*, "localhost")= logi TRUE [22:52:04.859] $ master : chr "localhost" [22:52:04.859] $ port : int 25931 [22:52:04.859] $ connectTimeout : num 0.1 [22:52:04.859] $ timeout : num 7 [22:52:04.859] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [22:52:04.859] $ homogeneous : logi TRUE [22:52:04.859] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:76512:CRANWIN"| __truncated__ [22:52:04.859] $ rscript_envs : NULL [22:52:04.859] $ rscript_libs : NULL [22:52:04.859] $ rscript_startup : chr [1:2] "-e" "\"invisible({Sys.sleep(6)})\"" [22:52:04.859] $ rscript_sh : chr "cmd" [22:52:04.859] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:04.859] $ methods : logi TRUE [22:52:04.859] $ socketOptions : chr "no-delay" [22:52:04.859] $ useXDR : logi FALSE [22:52:04.859] $ outfile : chr "/dev/null" [22:52:04.859] $ renice : int NA [22:52:04.859] $ rshcmd : NULL [22:52:04.859] $ user : chr(0) [22:52:04.859] $ revtunnel : logi FALSE [22:52:04.859] $ rshlogfile : NULL [22:52:04.859] $ rshopts : chr(0) [22:52:04.859] $ rank : int 1 [22:52:04.859] $ manual : logi FALSE [22:52:04.859] $ dryrun : logi FALSE [22:52:04.859] $ quiet : logi FALSE [22:52:04.859] $ setup_strategy : chr "parallel" [22:52:04.859] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:04.859] $ pidfile : chr "D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0d7966f4.pid" [22:52:04.859] $ rshcmd_label : NULL [22:52:04.859] $ rsh_call : NULL [22:52:04.859] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [22:52:04.859] $ localMachine : logi TRUE [22:52:04.859] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [22:52:04.859] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [22:52:04.859] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [22:52:04.859] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [22:52:04.859] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [22:52:04.859] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [22:52:04.859] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [22:52:04.859] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [22:52:04.859] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [22:52:04.859] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [22:52:04.859] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [22:52:04.859] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [22:52:04.859] "parallel"), action = c("launch", "options"), verbose = FALSE) [22:52:04.859] $ arguments :List of 28 [22:52:04.859] ..$ worker : chr "localhost" [22:52:04.859] ..$ master : NULL [22:52:04.859] ..$ port : int 25931 [22:52:04.859] ..$ connectTimeout : num 0.1 [22:52:04.859] ..$ timeout : num 7 [22:52:04.859] ..$ rscript : NULL [22:52:04.859] ..$ homogeneous : NULL [22:52:04.859] ..$ rscript_args : NULL [22:52:04.859] ..$ rscript_envs : NULL [22:52:04.859] ..$ rscript_libs : NULL [22:52:04.859] ..$ rscript_startup : language Sys.sleep(6) [22:52:04.859] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [22:52:04.859] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [22:52:04.859] ..$ methods : logi TRUE [22:52:04.859] ..$ socketOptions : chr "no-delay" [22:52:04.859] ..$ useXDR : logi FALSE [22:52:04.859] ..$ outfile : chr "/dev/null" [22:52:04.859] ..$ renice : int NA [22:52:04.859] ..$ rshcmd : NULL [22:52:04.859] ..$ user : NULL [22:52:04.859] ..$ revtunnel : logi NA [22:52:04.859] ..$ rshlogfile : NULL [22:52:04.859] ..$ rshopts : NULL [22:52:04.859] ..$ rank : int 1 [22:52:04.859] ..$ manual : logi FALSE [22:52:04.859] ..$ dryrun : logi FALSE [22:52:04.859] ..$ quiet : logi FALSE [22:52:04.859] ..$ setup_strategy : chr "parallel" [22:52:04.859] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [22:52:04.882] [local output] System call to launch all workers: [22:52:04.882] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:76512:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpu4bHya/worker.rank=1.parallelly.parent=76512.12ae0d7966f4.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=25931 OUT=/dev/null TIMEOUT=7 XDR=FALSE SETUPTIMEOUT=0.1 SETUPSTRATEGY=parallel [22:52:04.882] [local output] Starting PSOCK main server [22:52:04.887] [local output] Workers launched [22:52:04.887] [local output] Waiting for workers to connect back [22:52:04.887] - [local output] 0 workers out of 1 ready [22:52:05.085] - [local output] 0 workers out of 1 ready [22:52:05.288] - [local output] 0 workers out of 1 ready [22:52:05.491] - [local output] 0 workers out of 1 ready [22:52:05.696] - [local output] 0 workers out of 1 ready [22:52:05.900] - [local output] 0 workers out of 1 ready [22:52:06.104] - [local output] 0 workers out of 1 ready [22:52:06.307] - [local output] 0 workers out of 1 ready [22:52:06.510] - [local output] 0 workers out of 1 ready [22:52:06.717] - [local output] 0 workers out of 1 ready [22:52:06.921] - [local output] 0 workers out of 1 ready [22:52:07.124] - [local output] 0 workers out of 1 ready [22:52:07.327] - [local output] 0 workers out of 1 ready [22:52:07.535] - [local output] 0 workers out of 1 ready [22:52:07.738] - [local output] 0 workers out of 1 ready [22:52:07.942] - [local output] 0 workers out of 1 ready [22:52:08.145] - [local output] 0 workers out of 1 ready [22:52:08.348] - [local output] 0 workers out of 1 ready [22:52:08.551] - [local output] 0 workers out of 1 ready [22:52:08.755] - [local output] 0 workers out of 1 ready [22:52:08.962] - [local output] 0 workers out of 1 ready [22:52:09.165] - [local output] 0 workers out of 1 ready [22:52:09.368] - [local output] 0 workers out of 1 ready [22:52:09.571] - [local output] 0 workers out of 1 ready [22:52:09.785] - [local output] 0 workers out of 1 ready [22:52:09.988] - [local output] 0 workers out of 1 ready > > message("*** makeClusterPSOCK() ... DONE") *** makeClusterPSOCK() ... DONE > > source("incl/end.R") > > proc.time() user system elapsed 1.17 0.04 16.87