R Under development (unstable) (2024-02-28 r85999 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) [07:11:57.009] [local output] makeClusterPSOCK() ... [07:11:57.038] [local output] Workers: [n = 1] '' [07:11:57.045] [local output] Base port: 33060 [07:11:57.045] [local output] Getting setup options for 1 cluster nodes ... [07:11:57.045] [local output] - Node 1 of 1 ... [07:11:57.047] [local output] Rscript port: 33060 [07:11:57.048] [local output] Using 'rshcmd': 'my_ssh' [type='', version=''] [07:11:57.048] [local output] Getting setup options for 1 cluster nodes ... done [07:11:57.048] [local output] Creating node 1 of 1 ... [07:11:57.049] [local output] - setting up node [07:11:57.049] [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:125464:CRANWIN3:CRAN' -e 'options(socketOptions = "no-delay")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=33060 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:125464:CRANWIN3:CRAN' -e 'options(socketOptions = \"no-delay\")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=33060 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential" [07:11:57.050] [local output] Creating node 1 of 1 ... done [07:11:57.050] [local output] Launching of workers completed [07:11:57.050] [local output] Collecting session information from workers [07:11:57.051] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 0 nodes where > > cl <- makeClusterPSOCK(1L, port = "random", dryrun = TRUE) [07:11:57.052] [local output] makeClusterPSOCK() ... [07:11:57.056] [local output] Workers: [n = 1] 'localhost' [07:11:57.059] [local output] Base port: 28700 [07:11:57.059] [local output] Getting setup options for 1 cluster nodes ... [07:11:57.059] [local output] - Node 1 of 1 ... [07:11:57.060] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:57.061] [local output] Rscript port: 28700 [07:11:57.061] [local output] Getting setup options for 1 cluster nodes ... done [07:11:57.061] [local output] Creating node 1 of 1 ... [07:11:57.062] [local output] - setting up node [07:11:57.062] [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:125464:CRANWIN3:CRAN" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=28700 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [07:11:57.062] [local output] Creating node 1 of 1 ... done [07:11:57.062] [local output] Launching of workers completed [07:11:57.062] [local output] Collecting session information from workers [07:11:57.063] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 0 nodes where > > cl <- makeClusterPSOCK(1L) [07:11:57.063] [local output] makeClusterPSOCK() ... [07:11:57.065] [local output] Workers: [n = 1] 'localhost' [07:11:57.068] [local output] Base port: 25695 [07:11:57.068] [local output] Getting setup options for 1 cluster nodes ... [07:11:57.068] [local output] - Node 1 of 1 ... [07:11:57.069] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:57.070] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1874db56e.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1874db56e.pid\")"' [07:11:57.398] - Possible to infer worker's PID: TRUE [07:11:57.398] [local output] Rscript port: 25695 [07:11:57.399] [local output] Getting setup options for 1 cluster nodes ... done [07:11:57.399] [local output] - Parallel setup requested for some PSOCK nodes [07:11:57.400] [local output] Setting up PSOCK nodes in parallel [07:11:57.400] List of 36 [07:11:57.400] $ worker : chr "localhost" [07:11:57.400] ..- attr(*, "localhost")= logi TRUE [07:11:57.400] $ master : chr "localhost" [07:11:57.400] $ port : int 25695 [07:11:57.400] $ connectTimeout : num 120 [07:11:57.400] $ timeout : num 120 [07:11:57.400] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:57.400] $ homogeneous : logi TRUE [07:11:57.400] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:57.400] $ rscript_envs : NULL [07:11:57.400] $ rscript_libs : NULL [07:11:57.400] $ rscript_startup : NULL [07:11:57.400] $ rscript_sh : chr "cmd" [07:11:57.400] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:57.400] $ methods : logi TRUE [07:11:57.400] $ socketOptions : chr "no-delay" [07:11:57.400] $ useXDR : logi FALSE [07:11:57.400] $ outfile : chr "/dev/null" [07:11:57.400] $ renice : int NA [07:11:57.400] $ rshcmd : NULL [07:11:57.400] $ user : chr(0) [07:11:57.400] $ revtunnel : logi FALSE [07:11:57.400] $ rshlogfile : NULL [07:11:57.400] $ rshopts : chr(0) [07:11:57.400] $ rank : int 1 [07:11:57.400] $ manual : logi FALSE [07:11:57.400] $ dryrun : logi FALSE [07:11:57.400] $ quiet : logi FALSE [07:11:57.400] $ setup_strategy : chr "parallel" [07:11:57.400] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:57.400] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1874db56e.pid" [07:11:57.400] $ rshcmd_label : NULL [07:11:57.400] $ rsh_call : NULL [07:11:57.400] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:57.400] $ localMachine : logi TRUE [07:11:57.400] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:57.400] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:57.400] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:57.400] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:57.400] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:57.400] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:57.400] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:57.400] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:57.400] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:57.400] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:57.400] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:57.400] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:57.400] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:57.400] $ arguments :List of 28 [07:11:57.400] ..$ worker : chr "localhost" [07:11:57.400] ..$ master : NULL [07:11:57.400] ..$ port : int 25695 [07:11:57.400] ..$ connectTimeout : num 120 [07:11:57.400] ..$ timeout : num 120 [07:11:57.400] ..$ rscript : NULL [07:11:57.400] ..$ homogeneous : NULL [07:11:57.400] ..$ rscript_args : NULL [07:11:57.400] ..$ rscript_envs : NULL [07:11:57.400] ..$ rscript_libs : NULL [07:11:57.400] ..$ rscript_startup : NULL [07:11:57.400] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:57.400] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:57.400] ..$ methods : logi TRUE [07:11:57.400] ..$ socketOptions : chr "no-delay" [07:11:57.400] ..$ useXDR : logi FALSE [07:11:57.400] ..$ outfile : chr "/dev/null" [07:11:57.400] ..$ renice : int NA [07:11:57.400] ..$ rshcmd : NULL [07:11:57.400] ..$ user : NULL [07:11:57.400] ..$ revtunnel : logi NA [07:11:57.400] ..$ rshlogfile : NULL [07:11:57.400] ..$ rshopts : NULL [07:11:57.400] ..$ rank : int 1 [07:11:57.400] ..$ manual : logi FALSE [07:11:57.400] ..$ dryrun : logi FALSE [07:11:57.400] ..$ quiet : logi FALSE [07:11:57.400] ..$ setup_strategy : chr "parallel" [07:11:57.400] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:57.424] [local output] System call to launch all workers: [07:11:57.424] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1874db56e.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=25695 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:57.425] [local output] Starting PSOCK main server [07:11:57.429] [local output] Workers launched [07:11:57.429] [local output] Waiting for workers to connect back [07:11:57.429] - [local output] 0 workers out of 1 ready [07:11:57.597] - [local output] 0 workers out of 1 ready [07:11:57.597] - [local output] 1 workers out of 1 ready [07:11:57.597] [local output] Launching of workers completed [07:11:57.598] [local output] Collecting session information from workers [07:11:57.599] [local output] - Worker #1 of 1 [07:11:57.599] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-02-28 r85999 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 "28" .. ..$ svn rev : chr "85999" .. ..$ language : chr "R" .. ..$ version.string: chr "R Under development (unstable) (2024-02-28 r85999 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/RtmpUXrlWn/RLIBS_10dd87604425a" "D:/RCompile/recent/R/library" ..$ pkgs : NULL ..$ pwd : chr "d:/RCompile/CRANincoming/R-devel/parallelly.Rcheck/tests" ..$ process:List of 1 .. ..$ pid: int 131416 - attr(*, "options")=List of 35 ..$ worker : chr "localhost" .. ..- attr(*, "localhost")= logi TRUE ..$ master : chr "localhost" ..$ port : int 25695 ..$ 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:125464:CRANWI"| __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 25695 .. ..$ 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) + } [07:11:57.677] [local output] makeClusterPSOCK() ... [07:11:57.680] [local output] Workers: [n = 1] 'localhost' [07:11:57.682] [local output] Base port: 24167 [07:11:57.683] [local output] Getting setup options for 1 cluster nodes ... [07:11:57.683] [local output] - Node 1 of 1 ... [07:11:57.683] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:57.685] [local output] Rscript port: 24167 [07:11:57.685] [local output] Getting setup options for 1 cluster nodes ... done [07:11:57.686] [local output] - Parallel setup requested for some PSOCK nodes [07:11:57.686] [local output] Setting up PSOCK nodes in parallel [07:11:57.686] List of 36 [07:11:57.686] $ worker : chr "localhost" [07:11:57.686] ..- attr(*, "localhost")= logi TRUE [07:11:57.686] $ master : chr "localhost" [07:11:57.686] $ port : int 24167 [07:11:57.686] $ connectTimeout : num 120 [07:11:57.686] $ timeout : num 120 [07:11:57.686] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:57.686] $ homogeneous : logi TRUE [07:11:57.686] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:57.686] $ rscript_envs : NULL [07:11:57.686] $ rscript_libs : NULL [07:11:57.686] $ rscript_startup : NULL [07:11:57.686] $ rscript_sh : chr "cmd" [07:11:57.686] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:57.686] $ methods : logi TRUE [07:11:57.686] $ socketOptions : chr "no-delay" [07:11:57.686] $ useXDR : logi TRUE [07:11:57.686] $ outfile : chr "/dev/null" [07:11:57.686] $ renice : int NA [07:11:57.686] $ rshcmd : NULL [07:11:57.686] $ user : chr(0) [07:11:57.686] $ revtunnel : logi FALSE [07:11:57.686] $ rshlogfile : NULL [07:11:57.686] $ rshopts : chr(0) [07:11:57.686] $ rank : int 1 [07:11:57.686] $ manual : logi FALSE [07:11:57.686] $ dryrun : logi FALSE [07:11:57.686] $ quiet : logi FALSE [07:11:57.686] $ setup_strategy : chr "parallel" [07:11:57.686] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:57.686] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea181461373e.pid" [07:11:57.686] $ rshcmd_label : NULL [07:11:57.686] $ rsh_call : NULL [07:11:57.686] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:57.686] $ localMachine : logi TRUE [07:11:57.686] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:57.686] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:57.686] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:57.686] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:57.686] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:57.686] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:57.686] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:57.686] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:57.686] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:57.686] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:57.686] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:57.686] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:57.686] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:57.686] $ arguments :List of 28 [07:11:57.686] ..$ worker : chr "localhost" [07:11:57.686] ..$ master : NULL [07:11:57.686] ..$ port : int 24167 [07:11:57.686] ..$ connectTimeout : num 120 [07:11:57.686] ..$ timeout : num 120 [07:11:57.686] ..$ rscript : NULL [07:11:57.686] ..$ homogeneous : NULL [07:11:57.686] ..$ rscript_args : NULL [07:11:57.686] ..$ rscript_envs : NULL [07:11:57.686] ..$ rscript_libs : NULL [07:11:57.686] ..$ rscript_startup : NULL [07:11:57.686] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:57.686] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:57.686] ..$ methods : logi TRUE [07:11:57.686] ..$ socketOptions : chr "no-delay" [07:11:57.686] ..$ useXDR : logi TRUE [07:11:57.686] ..$ outfile : chr "/dev/null" [07:11:57.686] ..$ renice : int NA [07:11:57.686] ..$ rshcmd : NULL [07:11:57.686] ..$ user : NULL [07:11:57.686] ..$ revtunnel : logi NA [07:11:57.686] ..$ rshlogfile : NULL [07:11:57.686] ..$ rshopts : NULL [07:11:57.686] ..$ rank : int 1 [07:11:57.686] ..$ manual : logi FALSE [07:11:57.686] ..$ dryrun : logi FALSE [07:11:57.686] ..$ quiet : logi FALSE [07:11:57.686] ..$ setup_strategy : chr "parallel" [07:11:57.686] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:57.712] [local output] System call to launch all workers: [07:11:57.712] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea181461373e.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=24167 OUT=/dev/null TIMEOUT=120 XDR=TRUE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:57.712] [local output] Starting PSOCK main server [07:11:57.717] [local output] Workers launched [07:11:57.717] [local output] Waiting for workers to connect back [07:11:57.717] - [local output] 0 workers out of 1 ready [07:11:57.882] - [local output] 0 workers out of 1 ready [07:11:57.882] - [local output] 1 workers out of 1 ready [07:11:57.883] [local output] Launching of workers completed [07:11:57.883] [local output] Collecting session information from workers [07:11:57.884] [local output] - Worker #1 of 1 [07:11:57.884] [local output] makeClusterPSOCK() ... done [07:11:57.885] [local output] makeClusterPSOCK() ... [07:11:57.889] [local output] Workers: [n = 1] 'localhost' [07:11:57.892] [local output] Base port: 37426 [07:11:57.892] [local output] Getting setup options for 1 cluster nodes ... [07:11:57.892] [local output] - Node 1 of 1 ... [07:11:57.893] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:57.895] [local output] Rscript port: 37426 [07:11:57.895] [local output] Getting setup options for 1 cluster nodes ... done [07:11:57.896] [local output] - Parallel setup requested for some PSOCK nodes [07:11:57.896] [local output] Setting up PSOCK nodes in parallel [07:11:57.897] List of 36 [07:11:57.897] $ worker : chr "localhost" [07:11:57.897] ..- attr(*, "localhost")= logi TRUE [07:11:57.897] $ master : chr "localhost" [07:11:57.897] $ port : int 37426 [07:11:57.897] $ connectTimeout : num 120 [07:11:57.897] $ timeout : num 120 [07:11:57.897] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:57.897] $ homogeneous : logi TRUE [07:11:57.897] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:57.897] $ rscript_envs : NULL [07:11:57.897] $ rscript_libs : NULL [07:11:57.897] $ rscript_startup : NULL [07:11:57.897] $ rscript_sh : chr "cmd" [07:11:57.897] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:57.897] $ methods : logi TRUE [07:11:57.897] $ socketOptions : chr "no-delay" [07:11:57.897] $ useXDR : logi FALSE [07:11:57.897] $ outfile : chr "/dev/null" [07:11:57.897] $ renice : int NA [07:11:57.897] $ rshcmd : NULL [07:11:57.897] $ user : chr(0) [07:11:57.897] $ revtunnel : logi FALSE [07:11:57.897] $ rshlogfile : NULL [07:11:57.897] $ rshopts : chr(0) [07:11:57.897] $ rank : int 1 [07:11:57.897] $ manual : logi FALSE [07:11:57.897] $ dryrun : logi FALSE [07:11:57.897] $ quiet : logi FALSE [07:11:57.897] $ setup_strategy : chr "parallel" [07:11:57.897] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:57.897] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18181373f2.pid" [07:11:57.897] $ rshcmd_label : NULL [07:11:57.897] $ rsh_call : NULL [07:11:57.897] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:57.897] $ localMachine : logi TRUE [07:11:57.897] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:57.897] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:57.897] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:57.897] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:57.897] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:57.897] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:57.897] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:57.897] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:57.897] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:57.897] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:57.897] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:57.897] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:57.897] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:57.897] $ arguments :List of 28 [07:11:57.897] ..$ worker : chr "localhost" [07:11:57.897] ..$ master : NULL [07:11:57.897] ..$ port : int 37426 [07:11:57.897] ..$ connectTimeout : num 120 [07:11:57.897] ..$ timeout : num 120 [07:11:57.897] ..$ rscript : NULL [07:11:57.897] ..$ homogeneous : NULL [07:11:57.897] ..$ rscript_args : NULL [07:11:57.897] ..$ rscript_envs : NULL [07:11:57.897] ..$ rscript_libs : NULL [07:11:57.897] ..$ rscript_startup : NULL [07:11:57.897] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:57.897] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:57.897] ..$ methods : logi TRUE [07:11:57.897] ..$ socketOptions : chr "no-delay" [07:11:57.897] ..$ useXDR : logi FALSE [07:11:57.897] ..$ outfile : chr "/dev/null" [07:11:57.897] ..$ renice : int NA [07:11:57.897] ..$ rshcmd : NULL [07:11:57.897] ..$ user : NULL [07:11:57.897] ..$ revtunnel : logi NA [07:11:57.897] ..$ rshlogfile : NULL [07:11:57.897] ..$ rshopts : NULL [07:11:57.897] ..$ rank : int 1 [07:11:57.897] ..$ manual : logi FALSE [07:11:57.897] ..$ dryrun : logi FALSE [07:11:57.897] ..$ quiet : logi FALSE [07:11:57.897] ..$ setup_strategy : chr "parallel" [07:11:57.897] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:57.935] [local output] System call to launch all workers: [07:11:57.935] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18181373f2.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=37426 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:57.935] [local output] Starting PSOCK main server [07:11:57.939] [local output] Workers launched [07:11:57.940] [local output] Waiting for workers to connect back [07:11:57.940] - [local output] 0 workers out of 1 ready [07:11:58.106] - [local output] 0 workers out of 1 ready [07:11:58.107] - [local output] 1 workers out of 1 ready [07:11:58.107] [local output] Launching of workers completed [07:11:58.107] [local output] Collecting session information from workers [07:11:58.108] [local output] - Worker #1 of 1 [07:11:58.108] [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) + } [07:11:58.115] [local output] makeClusterPSOCK() ... [07:11:58.119] [local output] Workers: [n = 1] 'localhost' [07:11:58.122] [local output] Base port: 25668 [07:11:58.122] [local output] Getting setup options for 1 cluster nodes ... [07:11:58.122] [local output] - Node 1 of 1 ... [07:11:58.123] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:58.124] [local output] Rscript port: 25668 [07:11:58.125] [local output] Getting setup options for 1 cluster nodes ... done [07:11:58.125] [local output] - Parallel setup requested for some PSOCK nodes [07:11:58.126] [local output] Setting up PSOCK nodes in parallel [07:11:58.126] List of 36 [07:11:58.126] $ worker : chr "localhost" [07:11:58.126] ..- attr(*, "localhost")= logi TRUE [07:11:58.126] $ master : chr "localhost" [07:11:58.126] $ port : int 25668 [07:11:58.126] $ connectTimeout : num 120 [07:11:58.126] $ timeout : num 120 [07:11:58.126] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:58.126] $ homogeneous : logi TRUE [07:11:58.126] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:58.126] $ rscript_envs : NULL [07:11:58.126] $ rscript_libs : NULL [07:11:58.126] $ rscript_startup : NULL [07:11:58.126] $ rscript_sh : chr "cmd" [07:11:58.126] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.126] $ methods : logi TRUE [07:11:58.126] $ socketOptions : NULL [07:11:58.126] $ useXDR : logi FALSE [07:11:58.126] $ outfile : chr "/dev/null" [07:11:58.126] $ renice : int NA [07:11:58.126] $ rshcmd : NULL [07:11:58.126] $ user : chr(0) [07:11:58.126] $ revtunnel : logi FALSE [07:11:58.126] $ rshlogfile : NULL [07:11:58.126] $ rshopts : chr(0) [07:11:58.126] $ rank : int 1 [07:11:58.126] $ manual : logi FALSE [07:11:58.126] $ dryrun : logi FALSE [07:11:58.126] $ quiet : logi FALSE [07:11:58.126] $ setup_strategy : chr "parallel" [07:11:58.126] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.126] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185a44b42.pid" [07:11:58.126] $ rshcmd_label : NULL [07:11:58.126] $ rsh_call : NULL [07:11:58.126] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.126] $ localMachine : logi TRUE [07:11:58.126] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:58.126] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:58.126] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:58.126] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:58.126] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:58.126] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:58.126] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:58.126] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:58.126] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:58.126] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:58.126] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:58.126] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:58.126] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:58.126] $ arguments :List of 28 [07:11:58.126] ..$ worker : chr "localhost" [07:11:58.126] ..$ master : NULL [07:11:58.126] ..$ port : int 25668 [07:11:58.126] ..$ connectTimeout : num 120 [07:11:58.126] ..$ timeout : num 120 [07:11:58.126] ..$ rscript : NULL [07:11:58.126] ..$ homogeneous : NULL [07:11:58.126] ..$ rscript_args : NULL [07:11:58.126] ..$ rscript_envs : NULL [07:11:58.126] ..$ rscript_libs : NULL [07:11:58.126] ..$ rscript_startup : NULL [07:11:58.126] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:58.126] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.126] ..$ methods : logi TRUE [07:11:58.126] ..$ socketOptions : NULL [07:11:58.126] ..$ useXDR : logi FALSE [07:11:58.126] ..$ outfile : chr "/dev/null" [07:11:58.126] ..$ renice : int NA [07:11:58.126] ..$ rshcmd : NULL [07:11:58.126] ..$ user : NULL [07:11:58.126] ..$ revtunnel : logi NA [07:11:58.126] ..$ rshlogfile : NULL [07:11:58.126] ..$ rshopts : NULL [07:11:58.126] ..$ rank : int 1 [07:11:58.126] ..$ manual : logi FALSE [07:11:58.126] ..$ dryrun : logi FALSE [07:11:58.126] ..$ quiet : logi FALSE [07:11:58.126] ..$ setup_strategy : chr "parallel" [07:11:58.126] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:58.158] [local output] System call to launch all workers: [07:11:58.159] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185a44b42.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=25668 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:58.159] [local output] Starting PSOCK main server [07:11:58.163] [local output] Workers launched [07:11:58.163] [local output] Waiting for workers to connect back [07:11:58.163] - [local output] 0 workers out of 1 ready [07:11:58.328] - [local output] 0 workers out of 1 ready [07:11:58.329] - [local output] 1 workers out of 1 ready [07:11:58.329] [local output] Launching of workers completed [07:11:58.329] [local output] Collecting session information from workers [07:11:58.330] [local output] - Worker #1 of 1 [07:11:58.330] [local output] makeClusterPSOCK() ... done [07:11:58.331] [local output] makeClusterPSOCK() ... [07:11:58.334] [local output] Workers: [n = 1] 'localhost' [07:11:58.337] [local output] Base port: 20923 [07:11:58.337] [local output] Getting setup options for 1 cluster nodes ... [07:11:58.337] [local output] - Node 1 of 1 ... [07:11:58.338] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:58.339] [local output] Rscript port: 20923 [07:11:58.339] [local output] Getting setup options for 1 cluster nodes ... done [07:11:58.340] [local output] - Parallel setup requested for some PSOCK nodes [07:11:58.340] [local output] Setting up PSOCK nodes in parallel [07:11:58.340] List of 36 [07:11:58.340] $ worker : chr "localhost" [07:11:58.340] ..- attr(*, "localhost")= logi TRUE [07:11:58.340] $ master : chr "localhost" [07:11:58.340] $ port : int 20923 [07:11:58.340] $ connectTimeout : num 120 [07:11:58.340] $ timeout : num 120 [07:11:58.340] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:58.340] $ homogeneous : logi TRUE [07:11:58.340] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:58.340] $ rscript_envs : NULL [07:11:58.340] $ rscript_libs : NULL [07:11:58.340] $ rscript_startup : NULL [07:11:58.340] $ rscript_sh : chr "cmd" [07:11:58.340] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.340] $ methods : logi TRUE [07:11:58.340] $ socketOptions : NULL [07:11:58.340] $ useXDR : logi FALSE [07:11:58.340] $ outfile : chr "/dev/null" [07:11:58.340] $ renice : int NA [07:11:58.340] $ rshcmd : NULL [07:11:58.340] $ user : chr(0) [07:11:58.340] $ revtunnel : logi FALSE [07:11:58.340] $ rshlogfile : NULL [07:11:58.340] $ rshopts : chr(0) [07:11:58.340] $ rank : int 1 [07:11:58.340] $ manual : logi FALSE [07:11:58.340] $ dryrun : logi FALSE [07:11:58.340] $ quiet : logi FALSE [07:11:58.340] $ setup_strategy : chr "parallel" [07:11:58.340] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.340] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1852a23e54.pid" [07:11:58.340] $ rshcmd_label : NULL [07:11:58.340] $ rsh_call : NULL [07:11:58.340] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.340] $ localMachine : logi TRUE [07:11:58.340] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:58.340] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:58.340] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:58.340] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:58.340] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:58.340] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:58.340] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:58.340] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:58.340] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:58.340] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:58.340] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:58.340] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:58.340] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:58.340] $ arguments :List of 28 [07:11:58.340] ..$ worker : chr "localhost" [07:11:58.340] ..$ master : NULL [07:11:58.340] ..$ port : int 20923 [07:11:58.340] ..$ connectTimeout : num 120 [07:11:58.340] ..$ timeout : num 120 [07:11:58.340] ..$ rscript : NULL [07:11:58.340] ..$ homogeneous : NULL [07:11:58.340] ..$ rscript_args : NULL [07:11:58.340] ..$ rscript_envs : NULL [07:11:58.340] ..$ rscript_libs : NULL [07:11:58.340] ..$ rscript_startup : NULL [07:11:58.340] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:58.340] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.340] ..$ methods : logi TRUE [07:11:58.340] ..$ socketOptions : chr "NULL" [07:11:58.340] ..$ useXDR : logi FALSE [07:11:58.340] ..$ outfile : chr "/dev/null" [07:11:58.340] ..$ renice : int NA [07:11:58.340] ..$ rshcmd : NULL [07:11:58.340] ..$ user : NULL [07:11:58.340] ..$ revtunnel : logi NA [07:11:58.340] ..$ rshlogfile : NULL [07:11:58.340] ..$ rshopts : NULL [07:11:58.340] ..$ rank : int 1 [07:11:58.340] ..$ manual : logi FALSE [07:11:58.340] ..$ dryrun : logi FALSE [07:11:58.340] ..$ quiet : logi FALSE [07:11:58.340] ..$ setup_strategy : chr "parallel" [07:11:58.340] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:58.369] [local output] System call to launch all workers: [07:11:58.369] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1852a23e54.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20923 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:58.370] [local output] Starting PSOCK main server [07:11:58.373] [local output] Workers launched [07:11:58.374] [local output] Waiting for workers to connect back [07:11:58.374] - [local output] 0 workers out of 1 ready [07:11:58.572] - [local output] 0 workers out of 1 ready [07:11:58.572] - [local output] 1 workers out of 1 ready [07:11:58.572] [local output] Launching of workers completed [07:11:58.572] [local output] Collecting session information from workers [07:11:58.573] [local output] - Worker #1 of 1 [07:11:58.573] [local output] makeClusterPSOCK() ... done [07:11:58.574] [local output] makeClusterPSOCK() ... [07:11:58.577] [local output] Workers: [n = 1] 'localhost' [07:11:58.579] [local output] Base port: 20278 [07:11:58.579] [local output] Getting setup options for 1 cluster nodes ... [07:11:58.580] [local output] - Node 1 of 1 ... [07:11:58.580] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:58.581] [local output] Rscript port: 20278 [07:11:58.582] [local output] Getting setup options for 1 cluster nodes ... done [07:11:58.582] [local output] - Parallel setup requested for some PSOCK nodes [07:11:58.582] [local output] Setting up PSOCK nodes in parallel [07:11:58.583] List of 36 [07:11:58.583] $ worker : chr "localhost" [07:11:58.583] ..- attr(*, "localhost")= logi TRUE [07:11:58.583] $ master : chr "localhost" [07:11:58.583] $ port : int 20278 [07:11:58.583] $ connectTimeout : num 120 [07:11:58.583] $ timeout : num 120 [07:11:58.583] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:58.583] $ homogeneous : logi TRUE [07:11:58.583] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:58.583] $ rscript_envs : NULL [07:11:58.583] $ rscript_libs : NULL [07:11:58.583] $ rscript_startup : NULL [07:11:58.583] $ rscript_sh : chr "cmd" [07:11:58.583] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.583] $ methods : logi TRUE [07:11:58.583] $ socketOptions : chr "no-delay" [07:11:58.583] $ useXDR : logi FALSE [07:11:58.583] $ outfile : chr "/dev/null" [07:11:58.583] $ renice : int NA [07:11:58.583] $ rshcmd : NULL [07:11:58.583] $ user : chr(0) [07:11:58.583] $ revtunnel : logi FALSE [07:11:58.583] $ rshlogfile : NULL [07:11:58.583] $ rshopts : chr(0) [07:11:58.583] $ rank : int 1 [07:11:58.583] $ manual : logi FALSE [07:11:58.583] $ dryrun : logi FALSE [07:11:58.583] $ quiet : logi FALSE [07:11:58.583] $ setup_strategy : chr "parallel" [07:11:58.583] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.583] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea186d4b753e.pid" [07:11:58.583] $ rshcmd_label : NULL [07:11:58.583] $ rsh_call : NULL [07:11:58.583] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.583] $ localMachine : logi TRUE [07:11:58.583] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:58.583] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:58.583] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:58.583] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:58.583] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:58.583] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:58.583] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:58.583] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:58.583] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:58.583] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:58.583] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:58.583] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:58.583] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:58.583] $ arguments :List of 28 [07:11:58.583] ..$ worker : chr "localhost" [07:11:58.583] ..$ master : NULL [07:11:58.583] ..$ port : int 20278 [07:11:58.583] ..$ connectTimeout : num 120 [07:11:58.583] ..$ timeout : num 120 [07:11:58.583] ..$ rscript : NULL [07:11:58.583] ..$ homogeneous : NULL [07:11:58.583] ..$ rscript_args : NULL [07:11:58.583] ..$ rscript_envs : NULL [07:11:58.583] ..$ rscript_libs : NULL [07:11:58.583] ..$ rscript_startup : NULL [07:11:58.583] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:58.583] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.583] ..$ methods : logi TRUE [07:11:58.583] ..$ socketOptions : chr "no-delay" [07:11:58.583] ..$ useXDR : logi FALSE [07:11:58.583] ..$ outfile : chr "/dev/null" [07:11:58.583] ..$ renice : int NA [07:11:58.583] ..$ rshcmd : NULL [07:11:58.583] ..$ user : NULL [07:11:58.583] ..$ revtunnel : logi NA [07:11:58.583] ..$ rshlogfile : NULL [07:11:58.583] ..$ rshopts : NULL [07:11:58.583] ..$ rank : int 1 [07:11:58.583] ..$ manual : logi FALSE [07:11:58.583] ..$ dryrun : logi FALSE [07:11:58.583] ..$ quiet : logi FALSE [07:11:58.583] ..$ setup_strategy : chr "parallel" [07:11:58.583] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:58.605] [local output] System call to launch all workers: [07:11:58.606] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea186d4b753e.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20278 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:58.606] [local output] Starting PSOCK main server [07:11:58.610] [local output] Workers launched [07:11:58.610] [local output] Waiting for workers to connect back [07:11:58.610] - [local output] 0 workers out of 1 ready [07:11:58.783] - [local output] 0 workers out of 1 ready [07:11:58.783] - [local output] 1 workers out of 1 ready [07:11:58.783] [local output] Launching of workers completed [07:11:58.784] [local output] Collecting session information from workers [07:11:58.784] [local output] - Worker #1 of 1 [07:11:58.784] [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) + } [07:11:58.792] [local output] makeClusterPSOCK() ... [07:11:58.795] [local output] Workers: [n = 1] 'localhost' [07:11:58.797] [local output] Base port: 36371 [07:11:58.797] [local output] Getting setup options for 1 cluster nodes ... [07:11:58.798] [local output] - Node 1 of 1 ... [07:11:58.798] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:58.799] [local output] Rscript port: 36371 [07:11:58.800] [local output] Getting setup options for 1 cluster nodes ... done [07:11:58.800] [local output] - Parallel setup requested for some PSOCK nodes [07:11:58.800] [local output] Setting up PSOCK nodes in parallel [07:11:58.801] List of 36 [07:11:58.801] $ worker : chr "localhost" [07:11:58.801] ..- attr(*, "localhost")= logi TRUE [07:11:58.801] $ master : chr "localhost" [07:11:58.801] $ port : int 36371 [07:11:58.801] $ connectTimeout : num 120 [07:11:58.801] $ timeout : num 120 [07:11:58.801] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:58.801] $ homogeneous : logi TRUE [07:11:58.801] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:58.801] $ rscript_envs : NULL [07:11:58.801] $ rscript_libs : NULL [07:11:58.801] $ rscript_startup : NULL [07:11:58.801] $ rscript_sh : chr "cmd" [07:11:58.801] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.801] $ methods : logi TRUE [07:11:58.801] $ socketOptions : chr "no-delay" [07:11:58.801] $ useXDR : logi FALSE [07:11:58.801] $ outfile : chr "/dev/null" [07:11:58.801] $ renice : int NA [07:11:58.801] $ rshcmd : NULL [07:11:58.801] $ user : chr(0) [07:11:58.801] $ revtunnel : logi FALSE [07:11:58.801] $ rshlogfile : NULL [07:11:58.801] $ rshopts : chr(0) [07:11:58.801] $ rank : int 1 [07:11:58.801] $ manual : logi FALSE [07:11:58.801] $ dryrun : logi FALSE [07:11:58.801] $ quiet : logi FALSE [07:11:58.801] $ setup_strategy : chr "parallel" [07:11:58.801] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.801] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1847a36dc6.pid" [07:11:58.801] $ rshcmd_label : NULL [07:11:58.801] $ rsh_call : NULL [07:11:58.801] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:58.801] $ localMachine : logi TRUE [07:11:58.801] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:58.801] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:58.801] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:58.801] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:58.801] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:58.801] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:58.801] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:58.801] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:58.801] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:58.801] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:58.801] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:58.801] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:58.801] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:58.801] $ arguments :List of 28 [07:11:58.801] ..$ worker : chr "localhost" [07:11:58.801] ..$ master : NULL [07:11:58.801] ..$ port : int 36371 [07:11:58.801] ..$ connectTimeout : num 120 [07:11:58.801] ..$ timeout : num 120 [07:11:58.801] ..$ rscript : NULL [07:11:58.801] ..$ homogeneous : NULL [07:11:58.801] ..$ rscript_args : NULL [07:11:58.801] ..$ rscript_envs : NULL [07:11:58.801] ..$ rscript_libs : NULL [07:11:58.801] ..$ rscript_startup : NULL [07:11:58.801] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:58.801] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:58.801] ..$ methods : logi TRUE [07:11:58.801] ..$ socketOptions : chr "no-delay" [07:11:58.801] ..$ useXDR : logi FALSE [07:11:58.801] ..$ outfile : chr "/dev/null" [07:11:58.801] ..$ renice : int NA [07:11:58.801] ..$ rshcmd : NULL [07:11:58.801] ..$ user : NULL [07:11:58.801] ..$ revtunnel : logi NA [07:11:58.801] ..$ rshlogfile : NULL [07:11:58.801] ..$ rshopts : NULL [07:11:58.801] ..$ rank : int 1 [07:11:58.801] ..$ manual : logi FALSE [07:11:58.801] ..$ dryrun : logi FALSE [07:11:58.801] ..$ quiet : logi FALSE [07:11:58.801] ..$ setup_strategy : chr "parallel" [07:11:58.801] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:58.823] [local output] System call to launch all workers: [07:11:58.823] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1847a36dc6.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36371 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:58.823] [local output] Starting PSOCK main server [07:11:58.827] [local output] Workers launched [07:11:58.827] [local output] Waiting for workers to connect back [07:11:58.827] - [local output] 0 workers out of 1 ready [07:11:59.000] - [local output] 0 workers out of 1 ready [07:11:59.000] - [local output] 1 workers out of 1 ready [07:11:59.000] [local output] Launching of workers completed [07:11:59.000] [local output] Collecting session information from workers [07:11:59.001] [local output] - Worker #1 of 1 [07:11:59.001] [local output] makeClusterPSOCK() ... done [07:11:59.002] [local output] makeClusterPSOCK() ... [07:11:59.004] [local output] Workers: [n = 1] 'localhost' [07:11:59.007] [local output] Base port: 27260 [07:11:59.007] [local output] Getting setup options for 1 cluster nodes ... [07:11:59.007] [local output] - Node 1 of 1 ... [07:11:59.008] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:59.009] [local output] Rscript port: 27260 [07:11:59.010] [local output] Getting setup options for 1 cluster nodes ... done [07:11:59.010] [local output] - Parallel setup requested for some PSOCK nodes [07:11:59.010] [local output] Setting up PSOCK nodes in parallel [07:11:59.010] List of 36 [07:11:59.010] $ worker : chr "localhost" [07:11:59.010] ..- attr(*, "localhost")= logi TRUE [07:11:59.010] $ master : chr "localhost" [07:11:59.010] $ port : int 27260 [07:11:59.010] $ connectTimeout : num 120 [07:11:59.010] $ timeout : num 120 [07:11:59.010] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:59.010] $ homogeneous : logi TRUE [07:11:59.010] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:59.010] $ rscript_envs : NULL [07:11:59.010] $ rscript_libs : NULL [07:11:59.010] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [07:11:59.010] $ rscript_sh : chr "cmd" [07:11:59.010] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:59.010] $ methods : logi TRUE [07:11:59.010] $ socketOptions : chr "no-delay" [07:11:59.010] $ useXDR : logi FALSE [07:11:59.010] $ outfile : chr "/dev/null" [07:11:59.010] $ renice : int NA [07:11:59.010] $ rshcmd : NULL [07:11:59.010] $ user : chr(0) [07:11:59.010] $ revtunnel : logi FALSE [07:11:59.010] $ rshlogfile : NULL [07:11:59.010] $ rshopts : chr(0) [07:11:59.010] $ rank : int 1 [07:11:59.010] $ manual : logi FALSE [07:11:59.010] $ dryrun : logi FALSE [07:11:59.010] $ quiet : logi FALSE [07:11:59.010] $ setup_strategy : chr "parallel" [07:11:59.010] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:59.010] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1818c376b.pid" [07:11:59.010] $ rshcmd_label : NULL [07:11:59.010] $ rsh_call : NULL [07:11:59.010] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:59.010] $ localMachine : logi TRUE [07:11:59.010] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:59.010] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:59.010] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:59.010] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:59.010] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:59.010] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:59.010] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:59.010] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:59.010] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:59.010] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:59.010] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:59.010] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:59.010] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:59.010] $ arguments :List of 28 [07:11:59.010] ..$ worker : chr "localhost" [07:11:59.010] ..$ master : NULL [07:11:59.010] ..$ port : int 27260 [07:11:59.010] ..$ connectTimeout : num 120 [07:11:59.010] ..$ timeout : num 120 [07:11:59.010] ..$ rscript : NULL [07:11:59.010] ..$ homogeneous : NULL [07:11:59.010] ..$ rscript_args : NULL [07:11:59.010] ..$ rscript_envs : NULL [07:11:59.010] ..$ rscript_libs : NULL [07:11:59.010] ..$ rscript_startup : chr "options(abc = 42L)" [07:11:59.010] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:59.010] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:59.010] ..$ methods : logi TRUE [07:11:59.010] ..$ socketOptions : chr "no-delay" [07:11:59.010] ..$ useXDR : logi FALSE [07:11:59.010] ..$ outfile : chr "/dev/null" [07:11:59.010] ..$ renice : int NA [07:11:59.010] ..$ rshcmd : NULL [07:11:59.010] ..$ user : NULL [07:11:59.010] ..$ revtunnel : logi NA [07:11:59.010] ..$ rshlogfile : NULL [07:11:59.010] ..$ rshopts : NULL [07:11:59.010] ..$ rank : int 1 [07:11:59.010] ..$ manual : logi FALSE [07:11:59.010] ..$ dryrun : logi FALSE [07:11:59.010] ..$ quiet : logi FALSE [07:11:59.010] ..$ setup_strategy : chr "parallel" [07:11:59.010] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:59.033] [local output] System call to launch all workers: [07:11:59.033] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1818c376b.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=27260 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:59.034] [local output] Starting PSOCK main server [07:11:59.037] [local output] Workers launched [07:11:59.038] [local output] Waiting for workers to connect back [07:11:59.038] - [local output] 0 workers out of 1 ready [07:11:59.203] - [local output] 0 workers out of 1 ready [07:11:59.204] - [local output] 1 workers out of 1 ready [07:11:59.204] [local output] Launching of workers completed [07:11:59.204] [local output] Collecting session information from workers [07:11:59.205] [local output] - Worker #1 of 1 [07:11:59.205] [local output] makeClusterPSOCK() ... done [07:11:59.206] [local output] makeClusterPSOCK() ... [07:11:59.208] [local output] Workers: [n = 1] 'localhost' [07:11:59.211] [local output] Base port: 26989 [07:11:59.211] [local output] Getting setup options for 1 cluster nodes ... [07:11:59.211] [local output] - Node 1 of 1 ... [07:11:59.212] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:59.213] [local output] Rscript port: 26989 [07:11:59.214] [local output] Getting setup options for 1 cluster nodes ... done [07:11:59.214] [local output] - Parallel setup requested for some PSOCK nodes [07:11:59.214] [local output] Setting up PSOCK nodes in parallel [07:11:59.214] List of 36 [07:11:59.214] $ worker : chr "localhost" [07:11:59.214] ..- attr(*, "localhost")= logi TRUE [07:11:59.214] $ master : chr "localhost" [07:11:59.214] $ port : int 26989 [07:11:59.214] $ connectTimeout : num 120 [07:11:59.214] $ timeout : num 120 [07:11:59.214] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:59.214] $ homogeneous : logi TRUE [07:11:59.214] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:59.214] $ rscript_envs : NULL [07:11:59.214] $ rscript_libs : NULL [07:11:59.214] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [07:11:59.214] $ rscript_sh : chr "cmd" [07:11:59.214] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:59.214] $ methods : logi TRUE [07:11:59.214] $ socketOptions : chr "no-delay" [07:11:59.214] $ useXDR : logi FALSE [07:11:59.214] $ outfile : chr "/dev/null" [07:11:59.214] $ renice : int NA [07:11:59.214] $ rshcmd : NULL [07:11:59.214] $ user : chr(0) [07:11:59.214] $ revtunnel : logi FALSE [07:11:59.214] $ rshlogfile : NULL [07:11:59.214] $ rshopts : chr(0) [07:11:59.214] $ rank : int 1 [07:11:59.214] $ manual : logi FALSE [07:11:59.214] $ dryrun : logi FALSE [07:11:59.214] $ quiet : logi FALSE [07:11:59.214] $ setup_strategy : chr "parallel" [07:11:59.214] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:59.214] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18487410aa.pid" [07:11:59.214] $ rshcmd_label : NULL [07:11:59.214] $ rsh_call : NULL [07:11:59.214] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:59.214] $ localMachine : logi TRUE [07:11:59.214] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:59.214] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:59.214] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:59.214] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:59.214] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:59.214] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:59.214] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:59.214] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:59.214] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:59.214] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:59.214] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:59.214] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:59.214] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:59.214] $ arguments :List of 28 [07:11:59.214] ..$ worker : chr "localhost" [07:11:59.214] ..$ master : NULL [07:11:59.214] ..$ port : int 26989 [07:11:59.214] ..$ connectTimeout : num 120 [07:11:59.214] ..$ timeout : num 120 [07:11:59.214] ..$ rscript : NULL [07:11:59.214] ..$ homogeneous : NULL [07:11:59.214] ..$ rscript_args : NULL [07:11:59.214] ..$ rscript_envs : NULL [07:11:59.214] ..$ rscript_libs : NULL [07:11:59.214] ..$ rscript_startup : language options(abc = 42L) [07:11:59.214] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:59.214] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:59.214] ..$ methods : logi TRUE [07:11:59.214] ..$ socketOptions : chr "no-delay" [07:11:59.214] ..$ useXDR : logi FALSE [07:11:59.214] ..$ outfile : chr "/dev/null" [07:11:59.214] ..$ renice : int NA [07:11:59.214] ..$ rshcmd : NULL [07:11:59.214] ..$ user : NULL [07:11:59.214] ..$ revtunnel : logi NA [07:11:59.214] ..$ rshlogfile : NULL [07:11:59.214] ..$ rshopts : NULL [07:11:59.214] ..$ rank : int 1 [07:11:59.214] ..$ manual : logi FALSE [07:11:59.214] ..$ dryrun : logi FALSE [07:11:59.214] ..$ quiet : logi FALSE [07:11:59.214] ..$ setup_strategy : chr "parallel" [07:11:59.214] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:59.237] [local output] System call to launch all workers: [07:11:59.237] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18487410aa.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=26989 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:59.237] [local output] Starting PSOCK main server [07:11:59.241] [local output] Workers launched [07:11:59.241] [local output] Waiting for workers to connect back [07:11:59.242] - [local output] 0 workers out of 1 ready [07:11:59.409] - [local output] 0 workers out of 1 ready [07:11:59.409] - [local output] 1 workers out of 1 ready [07:11:59.409] [local output] Launching of workers completed [07:11:59.409] [local output] Collecting session information from workers [07:11:59.410] [local output] - Worker #1 of 1 [07:11:59.410] [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) + } [07:11:59.443] [local output] makeClusterPSOCK() ... [07:11:59.446] [local output] Workers: [n = 2] 'localhost', 'localhost' [07:11:59.449] [local output] Base port: 24703 [07:11:59.449] [local output] Getting setup options for 2 cluster nodes ... [07:11:59.449] [local output] - Node 1 of 2 ... [07:11:59.449] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:59.451] [local output] Rscript port: 24703 [07:11:59.451] [local output] - Node 2 of 2 ... [07:11:59.452] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:59.453] [local output] Rscript port: 24703 [07:11:59.453] [local output] Getting setup options for 2 cluster nodes ... done [07:11:59.453] [local output] Creating node 1 of 2 ... [07:11:59.454] [local output] - setting up node [07:11:59.454] [local output] - attempt #1 of 3 [07:11:59.454] [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:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1838fc397a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=24703 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [07:11:59.458] [local output] - Exit code of system() call: 0 [07:11:59.458] [local output] Waiting for worker #1 on 'localhost' to connect back [07:11:59.628] [local output] Connection with worker #1 on 'localhost' established [07:11:59.628] [local output] Creating node 1 of 2 ... done [07:11:59.628] [local output] Creating node 2 of 2 ... [07:11:59.629] [local output] - setting up node [07:11:59.629] [local output] - attempt #1 of 3 [07:11:59.629] [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:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=2.parallelly.parent=125464.1ea185d9f4947.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=24703 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [07:11:59.633] [local output] - Exit code of system() call: 0 [07:11:59.634] [local output] Waiting for worker #2 on 'localhost' to connect back [07:11:59.805] [local output] Connection with worker #2 on 'localhost' established [07:11:59.805] [local output] Creating node 2 of 2 ... done [07:11:59.805] [local output] Launching of workers completed [07:11:59.806] [local output] Collecting session information from workers [07:11:59.807] [local output] - Worker #1 of 2 [07:11:59.808] [local output] - Worker #2 of 2 [07:11:59.808] [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-28 r85999 ucrt), platform x86_64-w64-mingw32) [07:11:59.836] [local output] makeClusterPSOCK() ... [07:11:59.839] [local output] Workers: [n = 2] 'localhost', 'localhost' [07:11:59.842] [local output] Base port: 26930 [07:11:59.842] [local output] Getting setup options for 2 cluster nodes ... [07:11:59.842] [local output] - Node 1 of 2 ... [07:11:59.842] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:59.844] [local output] Rscript port: 26930 [07:11:59.844] [local output] - Node 2 of 2 ... [07:11:59.845] [local output] localMachine=TRUE => revtunnel=FALSE [07:11:59.846] [local output] Rscript port: 26930 [07:11:59.846] [local output] Getting setup options for 2 cluster nodes ... done [07:11:59.847] [local output] - Parallel setup requested for some PSOCK nodes [07:11:59.847] [local output] Setting up PSOCK nodes in parallel [07:11:59.847] List of 36 [07:11:59.847] $ worker : chr "localhost" [07:11:59.847] ..- attr(*, "localhost")= logi TRUE [07:11:59.847] $ master : chr "localhost" [07:11:59.847] $ port : int 26930 [07:11:59.847] $ connectTimeout : num 120 [07:11:59.847] $ timeout : num 120 [07:11:59.847] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:11:59.847] $ homogeneous : logi TRUE [07:11:59.847] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:11:59.847] $ rscript_envs : NULL [07:11:59.847] $ rscript_libs : NULL [07:11:59.847] $ rscript_startup : NULL [07:11:59.847] $ rscript_sh : chr "cmd" [07:11:59.847] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:59.847] $ methods : logi TRUE [07:11:59.847] $ socketOptions : chr "no-delay" [07:11:59.847] $ useXDR : logi FALSE [07:11:59.847] $ outfile : chr "/dev/null" [07:11:59.847] $ renice : int NA [07:11:59.847] $ rshcmd : NULL [07:11:59.847] $ user : chr(0) [07:11:59.847] $ revtunnel : logi FALSE [07:11:59.847] $ rshlogfile : NULL [07:11:59.847] $ rshopts : chr(0) [07:11:59.847] $ rank : int 1 [07:11:59.847] $ manual : logi FALSE [07:11:59.847] $ dryrun : logi FALSE [07:11:59.847] $ quiet : logi FALSE [07:11:59.847] $ setup_strategy : chr "parallel" [07:11:59.847] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:59.847] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1878eb650a.pid" [07:11:59.847] $ rshcmd_label : NULL [07:11:59.847] $ rsh_call : NULL [07:11:59.847] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:11:59.847] $ localMachine : logi TRUE [07:11:59.847] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:11:59.847] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:11:59.847] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:11:59.847] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:11:59.847] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:11:59.847] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:11:59.847] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:11:59.847] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:11:59.847] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:11:59.847] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:11:59.847] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:11:59.847] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:11:59.847] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:11:59.847] $ arguments :List of 28 [07:11:59.847] ..$ worker : chr "localhost" [07:11:59.847] ..$ master : NULL [07:11:59.847] ..$ port : int 26930 [07:11:59.847] ..$ connectTimeout : num 120 [07:11:59.847] ..$ timeout : num 120 [07:11:59.847] ..$ rscript : NULL [07:11:59.847] ..$ homogeneous : NULL [07:11:59.847] ..$ rscript_args : NULL [07:11:59.847] ..$ rscript_envs : NULL [07:11:59.847] ..$ rscript_libs : NULL [07:11:59.847] ..$ rscript_startup : NULL [07:11:59.847] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:11:59.847] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:11:59.847] ..$ methods : logi TRUE [07:11:59.847] ..$ socketOptions : chr "no-delay" [07:11:59.847] ..$ useXDR : logi FALSE [07:11:59.847] ..$ outfile : chr "/dev/null" [07:11:59.847] ..$ renice : int NA [07:11:59.847] ..$ rshcmd : NULL [07:11:59.847] ..$ user : NULL [07:11:59.847] ..$ revtunnel : logi NA [07:11:59.847] ..$ rshlogfile : NULL [07:11:59.847] ..$ rshopts : NULL [07:11:59.847] ..$ rank : int 1 [07:11:59.847] ..$ manual : logi FALSE [07:11:59.847] ..$ dryrun : logi FALSE [07:11:59.847] ..$ quiet : logi FALSE [07:11:59.847] ..$ setup_strategy : chr "parallel" [07:11:59.847] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:11:59.868] [local output] System call to launch all workers: [07:11:59.868] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1878eb650a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26930 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:11:59.868] [local output] Starting PSOCK main server [07:11:59.874] [local output] Workers launched [07:11:59.874] [local output] Waiting for workers to connect back [07:11:59.875] - [local output] 0 workers out of 2 ready [07:12:00.083] - [local output] 0 workers out of 2 ready [07:12:00.083] - [local output] 1 workers out of 2 ready [07:12:00.105] - [local output] 1 workers out of 2 ready [07:12:00.106] - [local output] 2 workers out of 2 ready [07:12:00.106] [local output] Launching of workers completed [07:12:00.106] [local output] Collecting session information from workers [07:12:00.107] [local output] - Worker #1 of 2 [07:12:00.107] [local output] - Worker #2 of 2 [07:12:00.108] [local output] makeClusterPSOCK() ... done user system elapsed 0.01 0.02 0.27 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-02-28 r85999 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 [07:12:00.110] [local output] makeClusterPSOCK() ... [07:12:00.113] [local output] Workers: [n = 1] 'localhost' [07:12:00.116] [local output] Base port: 28985 [07:12:00.116] [local output] Getting setup options for 1 cluster nodes ... [07:12:00.116] [local output] - Node 1 of 1 ... [07:12:00.117] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:00.118] [local output] Rscript port: 28985 [07:12:00.119] [local output] Getting setup options for 1 cluster nodes ... done [07:12:00.119] [local output] - Parallel setup requested for some PSOCK nodes [07:12:00.119] [local output] Setting up PSOCK nodes in parallel [07:12:00.119] List of 36 [07:12:00.119] $ worker : chr "localhost" [07:12:00.119] ..- attr(*, "localhost")= logi TRUE [07:12:00.119] $ master : chr "localhost" [07:12:00.119] $ port : int 28985 [07:12:00.119] $ connectTimeout : num 120 [07:12:00.119] $ timeout : num 120 [07:12:00.119] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:12:00.119] $ homogeneous : logi TRUE [07:12:00.119] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:12:00.119] $ rscript_envs : NULL [07:12:00.119] $ rscript_libs : NULL [07:12:00.119] $ rscript_startup : NULL [07:12:00.119] $ rscript_sh : chr "cmd" [07:12:00.119] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.119] $ methods : logi TRUE [07:12:00.119] $ socketOptions : chr "no-delay" [07:12:00.119] $ useXDR : logi FALSE [07:12:00.119] $ outfile : chr "/dev/null" [07:12:00.119] $ renice : int NA [07:12:00.119] $ rshcmd : NULL [07:12:00.119] $ user : chr(0) [07:12:00.119] $ revtunnel : logi FALSE [07:12:00.119] $ rshlogfile : NULL [07:12:00.119] $ rshopts : chr(0) [07:12:00.119] $ rank : int 1 [07:12:00.119] $ manual : logi FALSE [07:12:00.119] $ dryrun : logi FALSE [07:12:00.119] $ quiet : logi FALSE [07:12:00.119] $ setup_strategy : chr "parallel" [07:12:00.119] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.119] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1824091234.pid" [07:12:00.119] $ rshcmd_label : NULL [07:12:00.119] $ rsh_call : NULL [07:12:00.119] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.119] $ localMachine : logi TRUE [07:12:00.119] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:00.119] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:00.119] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:00.119] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:00.119] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:00.119] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:00.119] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:00.119] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:00.119] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:00.119] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:00.119] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:00.119] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:00.119] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:00.119] $ arguments :List of 28 [07:12:00.119] ..$ worker : chr "localhost" [07:12:00.119] ..$ master : NULL [07:12:00.119] ..$ port : int 28985 [07:12:00.119] ..$ connectTimeout : num 120 [07:12:00.119] ..$ timeout : num 120 [07:12:00.119] ..$ rscript : NULL [07:12:00.119] ..$ homogeneous : NULL [07:12:00.119] ..$ rscript_args : NULL [07:12:00.119] ..$ rscript_envs : NULL [07:12:00.119] ..$ rscript_libs : NULL [07:12:00.119] ..$ rscript_startup : NULL [07:12:00.119] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:00.119] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.119] ..$ methods : logi TRUE [07:12:00.119] ..$ socketOptions : chr "no-delay" [07:12:00.119] ..$ useXDR : logi FALSE [07:12:00.119] ..$ outfile : chr "/dev/null" [07:12:00.119] ..$ renice : int NA [07:12:00.119] ..$ rshcmd : NULL [07:12:00.119] ..$ user : NULL [07:12:00.119] ..$ revtunnel : logi NA [07:12:00.119] ..$ rshlogfile : NULL [07:12:00.119] ..$ rshopts : NULL [07:12:00.119] ..$ rank : int 1 [07:12:00.119] ..$ manual : logi FALSE [07:12:00.119] ..$ dryrun : logi FALSE [07:12:00.119] ..$ quiet : logi FALSE [07:12:00.119] ..$ setup_strategy : chr "parallel" [07:12:00.119] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:00.144] [local output] System call to launch all workers: [07:12:00.145] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1824091234.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=28985 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:00.145] [local output] Starting PSOCK main server [07:12:00.149] [local output] Workers launched [07:12:00.150] [local output] Waiting for workers to connect back [07:12:00.150] - [local output] 0 workers out of 1 ready [07:12:00.325] - [local output] 0 workers out of 1 ready [07:12:00.326] - [local output] 1 workers out of 1 ready [07:12:00.326] [local output] Launching of workers completed [07:12:00.326] [local output] Collecting session information from workers [07:12:00.327] [local output] - Worker #1 of 1 [07:12:00.327] [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) [07:12:00.328] [local output] makeClusterPSOCK() ... [07:12:00.331] [local output] Workers: [n = 1] 'localhost' [07:12:00.334] [local output] Base port: 38068 [07:12:00.334] [local output] Getting setup options for 1 cluster nodes ... [07:12:00.334] [local output] - Node 1 of 1 ... [07:12:00.335] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:00.336] [local output] Rscript port: 38068 [07:12:00.337] [local output] Getting setup options for 1 cluster nodes ... done [07:12:00.337] [local output] - Parallel setup requested for some PSOCK nodes [07:12:00.337] [local output] Setting up PSOCK nodes in parallel [07:12:00.338] List of 36 [07:12:00.338] $ worker : chr "localhost" [07:12:00.338] ..- attr(*, "localhost")= logi TRUE [07:12:00.338] $ master : chr "localhost" [07:12:00.338] $ port : int 38068 [07:12:00.338] $ connectTimeout : num 120 [07:12:00.338] $ timeout : num 120 [07:12:00.338] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:12:00.338] $ homogeneous : logi TRUE [07:12:00.338] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:12:00.338] $ rscript_envs : NULL [07:12:00.338] $ rscript_libs : NULL [07:12:00.338] $ rscript_startup : NULL [07:12:00.338] $ rscript_sh : chr "cmd" [07:12:00.338] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.338] $ methods : logi TRUE [07:12:00.338] $ socketOptions : chr "no-delay" [07:12:00.338] $ useXDR : logi FALSE [07:12:00.338] $ outfile : chr "/dev/null" [07:12:00.338] $ renice : int NA [07:12:00.338] $ rshcmd : NULL [07:12:00.338] $ user : chr(0) [07:12:00.338] $ revtunnel : logi FALSE [07:12:00.338] $ rshlogfile : NULL [07:12:00.338] $ rshopts : chr(0) [07:12:00.338] $ rank : int 1 [07:12:00.338] $ manual : logi FALSE [07:12:00.338] $ dryrun : logi FALSE [07:12:00.338] $ quiet : logi FALSE [07:12:00.338] $ setup_strategy : chr "parallel" [07:12:00.338] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.338] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1815f82a7c.pid" [07:12:00.338] $ rshcmd_label : NULL [07:12:00.338] $ rsh_call : NULL [07:12:00.338] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.338] $ localMachine : logi TRUE [07:12:00.338] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:00.338] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:00.338] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:00.338] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:00.338] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:00.338] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:00.338] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:00.338] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:00.338] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:00.338] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:00.338] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:00.338] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:00.338] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:00.338] $ arguments :List of 28 [07:12:00.338] ..$ worker : chr "localhost" [07:12:00.338] ..$ master : NULL [07:12:00.338] ..$ port : int 38068 [07:12:00.338] ..$ connectTimeout : num 120 [07:12:00.338] ..$ timeout : num 120 [07:12:00.338] ..$ rscript : NULL [07:12:00.338] ..$ homogeneous : NULL [07:12:00.338] ..$ rscript_args : NULL [07:12:00.338] ..$ rscript_envs : NULL [07:12:00.338] ..$ rscript_libs : NULL [07:12:00.338] ..$ rscript_startup : NULL [07:12:00.338] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:00.338] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.338] ..$ methods : logi TRUE [07:12:00.338] ..$ socketOptions : chr "no-delay" [07:12:00.338] ..$ useXDR : logi FALSE [07:12:00.338] ..$ outfile : chr "/dev/null" [07:12:00.338] ..$ renice : int NA [07:12:00.338] ..$ rshcmd : NULL [07:12:00.338] ..$ user : NULL [07:12:00.338] ..$ revtunnel : logi NA [07:12:00.338] ..$ rshlogfile : NULL [07:12:00.338] ..$ rshopts : NULL [07:12:00.338] ..$ rank : int 1 [07:12:00.338] ..$ manual : logi FALSE [07:12:00.338] ..$ dryrun : logi FALSE [07:12:00.338] ..$ quiet : logi FALSE [07:12:00.338] ..$ setup_strategy : chr "parallel" [07:12:00.338] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:00.362] [local output] System call to launch all workers: [07:12:00.362] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1815f82a7c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38068 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:00.362] [local output] Starting PSOCK main server [07:12:00.366] [local output] Workers launched [07:12:00.366] [local output] Waiting for workers to connect back [07:12:00.366] - [local output] 0 workers out of 1 ready [07:12:00.535] - [local output] 0 workers out of 1 ready [07:12:00.536] - [local output] 1 workers out of 1 ready [07:12:00.536] [local output] Launching of workers completed [07:12:00.536] [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 = "") [07:12:00.537] [local output] makeClusterPSOCK() ... [07:12:00.539] [local output] Workers: [n = 1] 'localhost' [07:12:00.542] [local output] Base port: 34747 [07:12:00.542] [local output] Getting setup options for 1 cluster nodes ... [07:12:00.542] [local output] - Node 1 of 1 ... [07:12:00.543] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:00.544] [local output] Rscript port: 34747 [07:12:00.545] [local output] Getting setup options for 1 cluster nodes ... done [07:12:00.545] [local output] - Parallel setup requested for some PSOCK nodes [07:12:00.545] [local output] Setting up PSOCK nodes in parallel [07:12:00.545] List of 36 [07:12:00.545] $ worker : chr "localhost" [07:12:00.545] ..- attr(*, "localhost")= logi TRUE [07:12:00.545] $ master : chr "localhost" [07:12:00.545] $ port : int 34747 [07:12:00.545] $ connectTimeout : num 120 [07:12:00.545] $ timeout : num 120 [07:12:00.545] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:12:00.545] $ homogeneous : logi TRUE [07:12:00.545] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:12:00.545] $ rscript_envs : NULL [07:12:00.545] $ rscript_libs : NULL [07:12:00.545] $ rscript_startup : NULL [07:12:00.545] $ rscript_sh : chr "cmd" [07:12:00.545] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.545] $ methods : logi TRUE [07:12:00.545] $ socketOptions : chr "no-delay" [07:12:00.545] $ useXDR : logi FALSE [07:12:00.545] $ outfile : chr "" [07:12:00.545] $ renice : int NA [07:12:00.545] $ rshcmd : NULL [07:12:00.545] $ user : chr(0) [07:12:00.545] $ revtunnel : logi FALSE [07:12:00.545] $ rshlogfile : NULL [07:12:00.545] $ rshopts : chr(0) [07:12:00.545] $ rank : int 1 [07:12:00.545] $ manual : logi FALSE [07:12:00.545] $ dryrun : logi FALSE [07:12:00.545] $ quiet : logi FALSE [07:12:00.545] $ setup_strategy : chr "parallel" [07:12:00.545] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.545] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185cd15400.pid" [07:12:00.545] $ rshcmd_label : NULL [07:12:00.545] $ rsh_call : NULL [07:12:00.545] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.545] $ localMachine : logi TRUE [07:12:00.545] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:00.545] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:00.545] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:00.545] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:00.545] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:00.545] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:00.545] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:00.545] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:00.545] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:00.545] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:00.545] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:00.545] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:00.545] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:00.545] $ arguments :List of 28 [07:12:00.545] ..$ worker : chr "localhost" [07:12:00.545] ..$ master : NULL [07:12:00.545] ..$ port : int 34747 [07:12:00.545] ..$ connectTimeout : num 120 [07:12:00.545] ..$ timeout : num 120 [07:12:00.545] ..$ rscript : NULL [07:12:00.545] ..$ homogeneous : NULL [07:12:00.545] ..$ rscript_args : NULL [07:12:00.545] ..$ rscript_envs : NULL [07:12:00.545] ..$ rscript_libs : NULL [07:12:00.545] ..$ rscript_startup : NULL [07:12:00.545] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:00.545] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.545] ..$ methods : logi TRUE [07:12:00.545] ..$ socketOptions : chr "no-delay" [07:12:00.545] ..$ useXDR : logi FALSE [07:12:00.545] ..$ outfile : chr "" [07:12:00.545] ..$ renice : int NA [07:12:00.545] ..$ rshcmd : NULL [07:12:00.545] ..$ user : NULL [07:12:00.545] ..$ revtunnel : logi NA [07:12:00.545] ..$ rshlogfile : NULL [07:12:00.545] ..$ rshopts : NULL [07:12:00.545] ..$ rank : int 1 [07:12:00.545] ..$ manual : logi FALSE [07:12:00.545] ..$ dryrun : logi FALSE [07:12:00.545] ..$ quiet : logi FALSE [07:12:00.545] ..$ setup_strategy : chr "parallel" [07:12:00.545] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:00.566] [local output] System call to launch all workers: [07:12:00.566] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185cd15400.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34747 OUT= TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:00.567] [local output] Starting PSOCK main server [07:12:00.570] [local output] Workers launched [07:12:00.571] [local output] Waiting for workers to connect back [07:12:00.571] - [local output] 0 workers out of 1 ready starting worker pid=12452 on localhost:34747 at 07:12:00.734 [07:12:00.743] - [local output] 0 workers out of 1 ready [07:12:00.743] - [local output] 1 workers out of 1 ready [07:12:00.744] [local output] Launching of workers completed [07:12:00.744] [local output] Collecting session information from workers [07:12:00.745] [local output] - Worker #1 of 1 [07:12:00.745] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-02-28 r85999 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) [07:12:00.747] [local output] makeClusterPSOCK() ... [07:12:00.749] [local output] Workers: [n = 1] 'localhost' [07:12:00.752] [local output] Base port: 31629 [07:12:00.752] [local output] Getting setup options for 1 cluster nodes ... [07:12:00.752] [local output] - Node 1 of 1 ... [07:12:00.753] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:00.754] [local output] Rscript port: 31629 [07:12:00.754] [local output] Getting setup options for 1 cluster nodes ... done [07:12:00.755] [local output] - Parallel setup requested for some PSOCK nodes [07:12:00.755] [local output] Setting up PSOCK nodes in parallel [07:12:00.755] List of 36 [07:12:00.755] $ worker : chr "localhost" [07:12:00.755] ..- attr(*, "localhost")= logi TRUE [07:12:00.755] $ master : chr "localhost" [07:12:00.755] $ port : int 31629 [07:12:00.755] $ connectTimeout : num 120 [07:12:00.755] $ timeout : num 120 [07:12:00.755] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:12:00.755] $ homogeneous : logi TRUE [07:12:00.755] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:12:00.755] $ rscript_envs : NULL [07:12:00.755] $ rscript_libs : NULL [07:12:00.755] $ rscript_startup : NULL [07:12:00.755] $ rscript_sh : chr "cmd" [07:12:00.755] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.755] $ methods : logi TRUE [07:12:00.755] $ socketOptions : chr "no-delay" [07:12:00.755] $ useXDR : logi FALSE [07:12:00.755] $ outfile : chr "/dev/null" [07:12:00.755] $ renice : int NA [07:12:00.755] $ rshcmd : NULL [07:12:00.755] $ user : chr(0) [07:12:00.755] $ revtunnel : logi FALSE [07:12:00.755] $ rshlogfile : NULL [07:12:00.755] $ rshopts : chr(0) [07:12:00.755] $ rank : int 1 [07:12:00.755] $ manual : logi FALSE [07:12:00.755] $ dryrun : logi FALSE [07:12:00.755] $ quiet : logi FALSE [07:12:00.755] $ setup_strategy : chr "parallel" [07:12:00.755] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.755] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185c8d30a4.pid" [07:12:00.755] $ rshcmd_label : NULL [07:12:00.755] $ rsh_call : NULL [07:12:00.755] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:00.755] $ localMachine : logi TRUE [07:12:00.755] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:00.755] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:00.755] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:00.755] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:00.755] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:00.755] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:00.755] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:00.755] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:00.755] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:00.755] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:00.755] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:00.755] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:00.755] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:00.755] $ arguments :List of 28 [07:12:00.755] ..$ worker : chr "localhost" [07:12:00.755] ..$ master : NULL [07:12:00.755] ..$ port : int 31629 [07:12:00.755] ..$ connectTimeout : num 120 [07:12:00.755] ..$ timeout : num 120 [07:12:00.755] ..$ rscript : NULL [07:12:00.755] ..$ homogeneous : NULL [07:12:00.755] ..$ rscript_args : NULL [07:12:00.755] ..$ rscript_envs : NULL [07:12:00.755] ..$ rscript_libs : NULL [07:12:00.755] ..$ rscript_startup : NULL [07:12:00.755] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:00.755] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:00.755] ..$ methods : logi TRUE [07:12:00.755] ..$ socketOptions : chr "no-delay" [07:12:00.755] ..$ useXDR : logi FALSE [07:12:00.755] ..$ outfile : chr "/dev/null" [07:12:00.755] ..$ renice : int NA [07:12:00.755] ..$ rshcmd : NULL [07:12:00.755] ..$ user : NULL [07:12:00.755] ..$ revtunnel : logi NA [07:12:00.755] ..$ rshlogfile : NULL [07:12:00.755] ..$ rshopts : NULL [07:12:00.755] ..$ rank : int 1 [07:12:00.755] ..$ manual : logi FALSE [07:12:00.755] ..$ dryrun : logi FALSE [07:12:00.755] ..$ quiet : logi FALSE [07:12:00.755] ..$ setup_strategy : chr "parallel" [07:12:00.755] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:00.778] [local output] System call to launch all workers: [07:12:00.778] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185c8d30a4.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=31629 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:00.778] [local output] Starting PSOCK main server [07:12:00.782] [local output] Workers launched [07:12:00.782] [local output] Waiting for workers to connect back [07:12:00.782] - [local output] 0 workers out of 1 ready [07:12:00.951] - [local output] 0 workers out of 1 ready [07:12:00.951] - [local output] 1 workers out of 1 ready [07:12:00.951] [local output] Launching of workers completed [07:12:00.952] [local output] Collecting session information from workers [07:12:00.952] [local output] - Worker #1 of 1 [07:12:00.952] [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' [07:12:00.959] [local output] makeClusterPSOCK() ... [07:12:00.961] [local output] Workers: [n = 1] 'localhost' [07:12:00.964] [local output] Base port: 29122 [07:12:00.964] [local output] Getting setup options for 1 cluster nodes ... [07:12:00.964] [local output] - Node 1 of 1 ... [07:12:00.965] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:00.966] 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/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18634674ec.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18634674ec.pid\")"' [07:12:01.289] - Possible to infer worker's PID: TRUE [07:12:01.290] [local output] Rscript port: 29122 [07:12:01.290] [local output] Getting setup options for 1 cluster nodes ... done [07:12:01.290] [local output] - Parallel setup requested for some PSOCK nodes [07:12:01.291] [local output] Setting up PSOCK nodes in parallel [07:12:01.291] List of 36 [07:12:01.291] $ worker : chr "localhost" [07:12:01.291] ..- attr(*, "localhost")= logi TRUE [07:12:01.291] $ master : chr "localhost" [07:12:01.291] $ port : int 29122 [07:12:01.291] $ connectTimeout : num 120 [07:12:01.291] $ timeout : num 120 [07:12:01.291] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [07:12:01.291] $ homogeneous : logi TRUE [07:12:01.291] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [07:12:01.291] $ rscript_envs : NULL [07:12:01.291] $ rscript_libs : NULL [07:12:01.291] $ rscript_startup : NULL [07:12:01.291] $ rscript_sh : chr "cmd" [07:12:01.291] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:01.291] $ methods : logi TRUE [07:12:01.291] $ socketOptions : chr "no-delay" [07:12:01.291] $ useXDR : logi FALSE [07:12:01.291] $ outfile : chr "/dev/null" [07:12:01.291] $ renice : int NA [07:12:01.291] $ rshcmd : NULL [07:12:01.291] $ user : chr(0) [07:12:01.291] $ revtunnel : logi FALSE [07:12:01.291] $ rshlogfile : NULL [07:12:01.291] $ rshopts : chr(0) [07:12:01.291] $ rank : int 1 [07:12:01.291] $ manual : logi FALSE [07:12:01.291] $ dryrun : logi FALSE [07:12:01.291] $ quiet : logi FALSE [07:12:01.291] $ setup_strategy : chr "parallel" [07:12:01.291] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [07:12:01.291] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18634674ec.pid" [07:12:01.291] $ rshcmd_label : NULL [07:12:01.291] $ rsh_call : NULL [07:12:01.291] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [07:12:01.291] $ localMachine : logi TRUE [07:12:01.291] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:01.291] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:01.291] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:01.291] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:01.291] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:01.291] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:01.291] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:01.291] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:01.291] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:01.291] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:01.291] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:01.291] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:01.291] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:01.291] $ arguments :List of 28 [07:12:01.291] ..$ worker : chr "localhost" [07:12:01.291] ..$ master : NULL [07:12:01.291] ..$ port : int 29122 [07:12:01.291] ..$ connectTimeout : num 120 [07:12:01.291] ..$ timeout : num 120 [07:12:01.291] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [07:12:01.291] ..$ homogeneous : NULL [07:12:01.291] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [07:12:01.291] ..$ rscript_envs : NULL [07:12:01.291] ..$ rscript_libs : NULL [07:12:01.291] ..$ rscript_startup : NULL [07:12:01.291] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:01.291] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:01.291] ..$ methods : logi TRUE [07:12:01.291] ..$ socketOptions : chr "no-delay" [07:12:01.291] ..$ useXDR : logi FALSE [07:12:01.291] ..$ outfile : chr "/dev/null" [07:12:01.291] ..$ renice : int NA [07:12:01.291] ..$ rshcmd : NULL [07:12:01.291] ..$ user : NULL [07:12:01.291] ..$ revtunnel : logi NA [07:12:01.291] ..$ rshlogfile : NULL [07:12:01.291] ..$ rshopts : NULL [07:12:01.291] ..$ rank : int 1 [07:12:01.291] ..$ manual : logi FALSE [07:12:01.291] ..$ dryrun : logi FALSE [07:12:01.291] ..$ quiet : logi FALSE [07:12:01.291] ..$ setup_strategy : chr "parallel" [07:12:01.291] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:01.312] [local output] System call to launch all workers: [07:12:01.312] [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:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18634674ec.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=29122 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:01.313] [local output] Starting PSOCK main server [07:12:01.317] [local output] Workers launched [07:12:01.317] [local output] Waiting for workers to connect back [07:12:01.317] - [local output] 0 workers out of 1 ready [07:12:01.517] - [local output] 0 workers out of 1 ready [07:12:01.517] - [local output] 1 workers out of 1 ready [07:12:01.518] [local output] Launching of workers completed [07:12:01.518] [local output] Collecting session information from workers [07:12:01.519] [local output] - Worker #1 of 1 [07:12:01.519] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [07:12:01.519] [local output] makeClusterPSOCK() ... [07:12:01.522] [local output] Workers: [n = 1] 'localhost' [07:12:01.524] [local output] Base port: 22289 [07:12:01.525] [local output] Getting setup options for 1 cluster nodes ... [07:12:01.525] [local output] - Node 1 of 1 ... [07:12:01.525] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:01.527] [local output] Rscript port: 22289 [07:12:01.527] [local output] Getting setup options for 1 cluster nodes ... done [07:12:01.527] [local output] - Parallel setup requested for some PSOCK nodes [07:12:01.528] [local output] Setting up PSOCK nodes in parallel [07:12:01.528] List of 36 [07:12:01.528] $ worker : chr "localhost" [07:12:01.528] ..- attr(*, "localhost")= logi TRUE [07:12:01.528] $ master : chr "localhost" [07:12:01.528] $ port : int 22289 [07:12:01.528] $ connectTimeout : num 120 [07:12:01.528] $ timeout : num 120 [07:12:01.528] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [07:12:01.528] $ homogeneous : logi TRUE [07:12:01.528] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [07:12:01.528] $ rscript_envs : NULL [07:12:01.528] $ rscript_libs : NULL [07:12:01.528] $ rscript_startup : NULL [07:12:01.528] $ rscript_sh : chr "cmd" [07:12:01.528] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:01.528] $ methods : logi TRUE [07:12:01.528] $ socketOptions : chr "no-delay" [07:12:01.528] $ useXDR : logi FALSE [07:12:01.528] $ outfile : chr "/dev/null" [07:12:01.528] $ renice : int NA [07:12:01.528] $ rshcmd : NULL [07:12:01.528] $ user : chr(0) [07:12:01.528] $ revtunnel : logi FALSE [07:12:01.528] $ rshlogfile : NULL [07:12:01.528] $ rshopts : chr(0) [07:12:01.528] $ rank : int 1 [07:12:01.528] $ manual : logi FALSE [07:12:01.528] $ dryrun : logi FALSE [07:12:01.528] $ quiet : logi FALSE [07:12:01.528] $ setup_strategy : chr "parallel" [07:12:01.528] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [07:12:01.528] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1827483dc0.pid" [07:12:01.528] $ rshcmd_label : NULL [07:12:01.528] $ rsh_call : NULL [07:12:01.528] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [07:12:01.528] $ localMachine : logi TRUE [07:12:01.528] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:01.528] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:01.528] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:01.528] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:01.528] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:01.528] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:01.528] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:01.528] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:01.528] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:01.528] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:01.528] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:01.528] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:01.528] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:01.528] $ arguments :List of 28 [07:12:01.528] ..$ worker : chr "localhost" [07:12:01.528] ..$ master : NULL [07:12:01.528] ..$ port : int 22289 [07:12:01.528] ..$ connectTimeout : num 120 [07:12:01.528] ..$ timeout : num 120 [07:12:01.528] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [07:12:01.528] ..$ homogeneous : NULL [07:12:01.528] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [07:12:01.528] ..$ rscript_envs : NULL [07:12:01.528] ..$ rscript_libs : NULL [07:12:01.528] ..$ rscript_startup : NULL [07:12:01.528] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:01.528] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:01.528] ..$ methods : logi TRUE [07:12:01.528] ..$ socketOptions : chr "no-delay" [07:12:01.528] ..$ useXDR : logi FALSE [07:12:01.528] ..$ outfile : chr "/dev/null" [07:12:01.528] ..$ renice : int NA [07:12:01.528] ..$ rshcmd : NULL [07:12:01.528] ..$ user : NULL [07:12:01.528] ..$ revtunnel : logi NA [07:12:01.528] ..$ rshlogfile : NULL [07:12:01.528] ..$ rshopts : NULL [07:12:01.528] ..$ rank : int 1 [07:12:01.528] ..$ manual : logi FALSE [07:12:01.528] ..$ dryrun : logi FALSE [07:12:01.528] ..$ quiet : logi FALSE [07:12:01.528] ..$ setup_strategy : chr "parallel" [07:12:01.528] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:01.549] [local output] System call to launch all workers: [07:12:01.549] [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:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea1827483dc0.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=22289 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:01.549] [local output] Starting PSOCK main server [07:12:01.553] [local output] Workers launched [07:12:01.554] [local output] Waiting for workers to connect back [07:12:01.554] - [local output] 0 workers out of 1 ready [07:12:01.766] - [local output] 0 workers out of 1 ready [07:12:01.766] - [local output] 1 workers out of 1 ready [07:12:01.767] [local output] Launching of workers completed [07:12:01.767] [local output] Collecting session information from workers [07:12:01.768] [local output] - Worker #1 of 1 [07:12:01.768] [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' [07:12:01.780] [local output] makeClusterPSOCK() ... [07:12:01.782] [local output] Workers: [n = 1] 'localhost' [07:12:01.785] [local output] Base port: 24746 [07:12:01.785] [local output] Getting setup options for 1 cluster nodes ... [07:12:01.785] [local output] - Node 1 of 1 ... [07:12:01.786] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:01.787] 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/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea186b6a736c.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea186b6a736c.pid\")"' [07:12:02.008] - Possible to infer worker's PID: TRUE [07:12:02.008] [local output] Rscript port: 24746 [07:12:02.009] [local output] Getting setup options for 1 cluster nodes ... done [07:12:02.009] [local output] - Parallel setup requested for some PSOCK nodes [07:12:02.009] [local output] Setting up PSOCK nodes in parallel [07:12:02.010] List of 36 [07:12:02.010] $ worker : chr "localhost" [07:12:02.010] ..- attr(*, "localhost")= logi TRUE [07:12:02.010] $ master : chr "localhost" [07:12:02.010] $ port : int 24746 [07:12:02.010] $ connectTimeout : num 120 [07:12:02.010] $ timeout : num 120 [07:12:02.010] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [07:12:02.010] $ homogeneous : logi TRUE [07:12:02.010] $ rscript_args : chr "--default-packages=utils,tools -e \"#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN\" -e \"try(suppressWarnings("| __truncated__ [07:12:02.010] $ rscript_envs : NULL [07:12:02.010] $ rscript_libs : NULL [07:12:02.010] $ rscript_startup : NULL [07:12:02.010] $ rscript_sh : chr "cmd" [07:12:02.010] $ default_packages: chr [1:2] "utils" "tools" [07:12:02.010] $ methods : logi TRUE [07:12:02.010] $ socketOptions : chr "no-delay" [07:12:02.010] $ useXDR : logi FALSE [07:12:02.010] $ outfile : chr "/dev/null" [07:12:02.010] $ renice : int NA [07:12:02.010] $ rshcmd : NULL [07:12:02.010] $ user : chr(0) [07:12:02.010] $ revtunnel : logi FALSE [07:12:02.010] $ rshlogfile : NULL [07:12:02.010] $ rshopts : chr(0) [07:12:02.010] $ rank : int 1 [07:12:02.010] $ manual : logi FALSE [07:12:02.010] $ dryrun : logi FALSE [07:12:02.010] $ quiet : logi FALSE [07:12:02.010] $ setup_strategy : chr "parallel" [07:12:02.010] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [07:12:02.010] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea186b6a736c.pid" [07:12:02.010] $ rshcmd_label : NULL [07:12:02.010] $ rsh_call : NULL [07:12:02.010] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [07:12:02.010] $ localMachine : logi TRUE [07:12:02.010] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:02.010] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:02.010] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:02.010] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:02.010] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:02.010] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:02.010] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:02.010] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:02.010] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:02.010] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:02.010] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:02.010] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:02.010] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:02.010] $ arguments :List of 28 [07:12:02.010] ..$ worker : chr "localhost" [07:12:02.010] ..$ master : NULL [07:12:02.010] ..$ port : int 24746 [07:12:02.010] ..$ connectTimeout : num 120 [07:12:02.010] ..$ timeout : num 120 [07:12:02.010] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [07:12:02.010] ..$ homogeneous : NULL [07:12:02.010] ..$ rscript_args : NULL [07:12:02.010] ..$ rscript_envs : NULL [07:12:02.010] ..$ rscript_libs : NULL [07:12:02.010] ..$ rscript_startup : NULL [07:12:02.010] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:02.010] ..$ default_packages: chr [1:2] "utils" "tools" [07:12:02.010] ..$ methods : logi TRUE [07:12:02.010] ..$ socketOptions : chr "no-delay" [07:12:02.010] ..$ useXDR : logi FALSE [07:12:02.010] ..$ outfile : chr "/dev/null" [07:12:02.010] ..$ renice : int NA [07:12:02.010] ..$ rshcmd : NULL [07:12:02.010] ..$ user : NULL [07:12:02.010] ..$ revtunnel : logi NA [07:12:02.010] ..$ rshlogfile : NULL [07:12:02.010] ..$ rshopts : NULL [07:12:02.010] ..$ rank : int 1 [07:12:02.010] ..$ manual : logi FALSE [07:12:02.010] ..$ dryrun : logi FALSE [07:12:02.010] ..$ quiet : logi FALSE [07:12:02.010] ..$ setup_strategy : chr "parallel" [07:12:02.010] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:02.030] [local output] System call to launch all workers: [07:12:02.031] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=utils,tools -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea186b6a736c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=24746 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:02.031] [local output] Starting PSOCK main server [07:12:02.034] [local output] Workers launched [07:12:02.035] [local output] Waiting for workers to connect back [07:12:02.035] - [local output] 0 workers out of 1 ready [07:12:02.129] - [local output] 0 workers out of 1 ready [07:12:02.129] - [local output] 1 workers out of 1 ready [07:12:02.130] [local output] Launching of workers completed [07:12:02.130] [local output] Collecting session information from workers [07:12:02.130] [local output] - Worker #1 of 1 [07:12:02.131] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [07:12:02.131] [local output] makeClusterPSOCK() ... [07:12:02.134] [local output] Workers: [n = 1] 'localhost' [07:12:02.136] [local output] Base port: 28744 [07:12:02.137] [local output] Getting setup options for 1 cluster nodes ... [07:12:02.137] [local output] - Node 1 of 1 ... [07:12:02.137] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:02.139] [local output] Rscript port: 28744 [07:12:02.139] [local output] Getting setup options for 1 cluster nodes ... done [07:12:02.139] [local output] - Parallel setup requested for some PSOCK nodes [07:12:02.140] [local output] Setting up PSOCK nodes in parallel [07:12:02.140] List of 36 [07:12:02.140] $ worker : chr "localhost" [07:12:02.140] ..- attr(*, "localhost")= logi TRUE [07:12:02.140] $ master : chr "localhost" [07:12:02.140] $ port : int 28744 [07:12:02.140] $ connectTimeout : num 120 [07:12:02.140] $ timeout : num 120 [07:12:02.140] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [07:12:02.140] $ homogeneous : logi TRUE [07:12:02.140] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN\" -e "| __truncated__ [07:12:02.140] $ rscript_envs : NULL [07:12:02.140] $ rscript_libs : NULL [07:12:02.140] $ rscript_startup : NULL [07:12:02.140] $ rscript_sh : chr "cmd" [07:12:02.140] $ default_packages: chr [1:2] "utils" "tools" [07:12:02.140] $ methods : logi TRUE [07:12:02.140] $ socketOptions : chr "no-delay" [07:12:02.140] $ useXDR : logi FALSE [07:12:02.140] $ outfile : chr "/dev/null" [07:12:02.140] $ renice : int NA [07:12:02.140] $ rshcmd : NULL [07:12:02.140] $ user : chr(0) [07:12:02.140] $ revtunnel : logi FALSE [07:12:02.140] $ rshlogfile : NULL [07:12:02.140] $ rshopts : chr(0) [07:12:02.140] $ rank : int 1 [07:12:02.140] $ manual : logi FALSE [07:12:02.140] $ dryrun : logi FALSE [07:12:02.140] $ quiet : logi FALSE [07:12:02.140] $ setup_strategy : chr "parallel" [07:12:02.140] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [07:12:02.140] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea183d9f5deb.pid" [07:12:02.140] $ rshcmd_label : NULL [07:12:02.140] $ rsh_call : NULL [07:12:02.140] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [07:12:02.140] $ localMachine : logi TRUE [07:12:02.140] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:02.140] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:02.140] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:02.140] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:02.140] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:02.140] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:02.140] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:02.140] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:02.140] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:02.140] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:02.140] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:02.140] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:02.140] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:02.140] $ arguments :List of 28 [07:12:02.140] ..$ worker : chr "localhost" [07:12:02.140] ..$ master : NULL [07:12:02.140] ..$ port : int 28744 [07:12:02.140] ..$ connectTimeout : num 120 [07:12:02.140] ..$ timeout : num 120 [07:12:02.140] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [07:12:02.140] ..$ homogeneous : NULL [07:12:02.140] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [07:12:02.140] ..$ rscript_envs : NULL [07:12:02.140] ..$ rscript_libs : NULL [07:12:02.140] ..$ rscript_startup : NULL [07:12:02.140] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:02.140] ..$ default_packages: chr [1:2] "utils" "tools" [07:12:02.140] ..$ methods : logi TRUE [07:12:02.140] ..$ socketOptions : chr "no-delay" [07:12:02.140] ..$ useXDR : logi FALSE [07:12:02.140] ..$ outfile : chr "/dev/null" [07:12:02.140] ..$ renice : int NA [07:12:02.140] ..$ rshcmd : NULL [07:12:02.140] ..$ user : NULL [07:12:02.140] ..$ revtunnel : logi NA [07:12:02.140] ..$ rshlogfile : NULL [07:12:02.140] ..$ rshopts : NULL [07:12:02.140] ..$ rank : int 1 [07:12:02.140] ..$ manual : logi FALSE [07:12:02.140] ..$ dryrun : logi FALSE [07:12:02.140] ..$ quiet : logi FALSE [07:12:02.140] ..$ setup_strategy : chr "parallel" [07:12:02.140] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:02.161] [local output] System call to launch all workers: [07:12:02.161] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea183d9f5deb.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=28744 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:02.161] [local output] Starting PSOCK main server [07:12:02.165] [local output] Workers launched [07:12:02.165] [local output] Waiting for workers to connect back [07:12:02.165] - [local output] 0 workers out of 1 ready [07:12:02.249] - [local output] 0 workers out of 1 ready [07:12:02.250] - [local output] 1 workers out of 1 ready [07:12:02.250] [local output] Launching of workers completed [07:12:02.250] [local output] Collecting session information from workers [07:12:02.251] [local output] - Worker #1 of 1 [07:12:02.251] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [07:12:02.252] [local output] makeClusterPSOCK() ... [07:12:02.254] [local output] Workers: [n = 1] 'localhost' [07:12:02.257] [local output] Base port: 25739 [07:12:02.257] [local output] Getting setup options for 1 cluster nodes ... [07:12:02.257] [local output] - Node 1 of 1 ... [07:12:02.258] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:02.259] [local output] Rscript port: 25739 [07:12:02.259] [local output] Getting setup options for 1 cluster nodes ... done [07:12:02.260] [local output] - Parallel setup requested for some PSOCK nodes [07:12:02.260] [local output] Setting up PSOCK nodes in parallel [07:12:02.260] List of 36 [07:12:02.260] $ worker : chr "localhost" [07:12:02.260] ..- attr(*, "localhost")= logi TRUE [07:12:02.260] $ master : chr "localhost" [07:12:02.260] $ port : int 25739 [07:12:02.260] $ connectTimeout : num 120 [07:12:02.260] $ timeout : num 120 [07:12:02.260] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [07:12:02.260] $ homogeneous : logi TRUE [07:12:02.260] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN\" -e "| __truncated__ [07:12:02.260] $ rscript_envs : NULL [07:12:02.260] $ rscript_libs : NULL [07:12:02.260] $ rscript_startup : NULL [07:12:02.260] $ rscript_sh : chr "cmd" [07:12:02.260] $ default_packages: chr [1:2] "utils" "tools" [07:12:02.260] $ methods : logi TRUE [07:12:02.260] $ socketOptions : chr "no-delay" [07:12:02.260] $ useXDR : logi FALSE [07:12:02.260] $ outfile : chr "/dev/null" [07:12:02.260] $ renice : int NA [07:12:02.260] $ rshcmd : NULL [07:12:02.260] $ user : chr(0) [07:12:02.260] $ revtunnel : logi FALSE [07:12:02.260] $ rshlogfile : NULL [07:12:02.260] $ rshopts : chr(0) [07:12:02.260] $ rank : int 1 [07:12:02.260] $ manual : logi FALSE [07:12:02.260] $ dryrun : logi FALSE [07:12:02.260] $ quiet : logi FALSE [07:12:02.260] $ setup_strategy : chr "parallel" [07:12:02.260] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [07:12:02.260] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea183c84e65.pid" [07:12:02.260] $ rshcmd_label : NULL [07:12:02.260] $ rsh_call : NULL [07:12:02.260] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [07:12:02.260] $ localMachine : logi TRUE [07:12:02.260] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:02.260] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:02.260] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:02.260] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:02.260] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:02.260] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:02.260] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:02.260] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:02.260] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:02.260] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:02.260] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:02.260] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:02.260] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:02.260] $ arguments :List of 28 [07:12:02.260] ..$ worker : chr "localhost" [07:12:02.260] ..$ master : NULL [07:12:02.260] ..$ port : int 25739 [07:12:02.260] ..$ connectTimeout : num 120 [07:12:02.260] ..$ timeout : num 120 [07:12:02.260] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [07:12:02.260] ..$ homogeneous : NULL [07:12:02.260] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [07:12:02.260] ..$ rscript_envs : NULL [07:12:02.260] ..$ rscript_libs : NULL [07:12:02.260] ..$ rscript_startup : NULL [07:12:02.260] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:02.260] ..$ default_packages: chr [1:2] "utils" "tools" [07:12:02.260] ..$ methods : logi TRUE [07:12:02.260] ..$ socketOptions : chr "no-delay" [07:12:02.260] ..$ useXDR : logi FALSE [07:12:02.260] ..$ outfile : chr "/dev/null" [07:12:02.260] ..$ renice : int NA [07:12:02.260] ..$ rshcmd : NULL [07:12:02.260] ..$ user : NULL [07:12:02.260] ..$ revtunnel : logi NA [07:12:02.260] ..$ rshlogfile : NULL [07:12:02.260] ..$ rshopts : NULL [07:12:02.260] ..$ rank : int 1 [07:12:02.260] ..$ manual : logi FALSE [07:12:02.260] ..$ dryrun : logi FALSE [07:12:02.260] ..$ quiet : logi FALSE [07:12:02.260] ..$ setup_strategy : chr "parallel" [07:12:02.260] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:02.282] [local output] System call to launch all workers: [07:12:02.283] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea183c84e65.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=25739 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:02.283] [local output] Starting PSOCK main server [07:12:02.286] [local output] Workers launched [07:12:02.287] [local output] Waiting for workers to connect back [07:12:02.287] - [local output] 0 workers out of 1 ready [07:12:02.370] - [local output] 0 workers out of 1 ready [07:12:02.370] - [local output] 1 workers out of 1 ready [07:12:02.370] [local output] Launching of workers completed [07:12:02.371] [local output] Collecting session information from workers [07:12:02.371] [local output] - Worker #1 of 1 [07:12:02.371] [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' [07:12:02.382] [local output] makeClusterPSOCK() ... [07:12:02.385] [local output] Workers: [n = 1] 'localhost' [07:12:02.387] [local output] Base port: 30233 [07:12:02.387] [local output] Getting setup options for 1 cluster nodes ... [07:12:02.388] [local output] - Node 1 of 1 ... [07:12:02.388] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:02.390] [local output] Rscript port: 30233 [07:12:02.390] [local output] Getting setup options for 1 cluster nodes ... done [07:12:02.390] [local output] - Parallel setup requested for some PSOCK nodes [07:12:02.391] [local output] Setting up PSOCK nodes in parallel [07:12:02.391] List of 36 [07:12:02.391] $ worker : chr "localhost" [07:12:02.391] ..- attr(*, "localhost")= logi TRUE [07:12:02.391] $ master : chr "localhost" [07:12:02.391] $ port : int 30233 [07:12:02.391] $ connectTimeout : num 120 [07:12:02.391] $ timeout : num 120 [07:12:02.391] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [07:12:02.391] $ homogeneous : logi TRUE [07:12:02.391] $ rscript_args : chr "--default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:12"| __truncated__ [07:12:02.391] $ rscript_envs : NULL [07:12:02.391] $ rscript_libs : NULL [07:12:02.391] $ rscript_startup : NULL [07:12:02.391] $ rscript_sh : chr "cmd" [07:12:02.391] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [07:12:02.391] $ methods : logi TRUE [07:12:02.391] $ socketOptions : chr "no-delay" [07:12:02.391] $ useXDR : logi FALSE [07:12:02.391] $ outfile : chr "/dev/null" [07:12:02.391] $ renice : int NA [07:12:02.391] $ rshcmd : NULL [07:12:02.391] $ user : chr(0) [07:12:02.391] $ revtunnel : logi FALSE [07:12:02.391] $ rshlogfile : NULL [07:12:02.391] $ rshopts : chr(0) [07:12:02.391] $ rank : int 1 [07:12:02.391] $ manual : logi FALSE [07:12:02.391] $ dryrun : logi FALSE [07:12:02.391] $ quiet : logi FALSE [07:12:02.391] $ setup_strategy : chr "parallel" [07:12:02.391] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [07:12:02.391] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea184acc1f6.pid" [07:12:02.391] $ rshcmd_label : NULL [07:12:02.391] $ rsh_call : NULL [07:12:02.391] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [07:12:02.391] $ localMachine : logi TRUE [07:12:02.391] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:02.391] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:02.391] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:02.391] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:02.391] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:02.391] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:02.391] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:02.391] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:02.391] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:02.391] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:02.391] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:02.391] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:02.391] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:02.391] $ arguments :List of 28 [07:12:02.391] ..$ worker : chr "localhost" [07:12:02.391] ..$ master : NULL [07:12:02.391] ..$ port : int 30233 [07:12:02.391] ..$ connectTimeout : num 120 [07:12:02.391] ..$ timeout : num 120 [07:12:02.391] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [07:12:02.391] ..$ homogeneous : NULL [07:12:02.391] ..$ rscript_args : NULL [07:12:02.391] ..$ rscript_envs : NULL [07:12:02.391] ..$ rscript_libs : NULL [07:12:02.391] ..$ rscript_startup : NULL [07:12:02.391] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:02.391] ..$ default_packages: chr [1:2] "parallelly" "*" [07:12:02.391] ..$ methods : logi TRUE [07:12:02.391] ..$ socketOptions : chr "no-delay" [07:12:02.391] ..$ useXDR : logi FALSE [07:12:02.391] ..$ outfile : chr "/dev/null" [07:12:02.391] ..$ renice : int NA [07:12:02.391] ..$ rshcmd : NULL [07:12:02.391] ..$ user : NULL [07:12:02.391] ..$ revtunnel : logi NA [07:12:02.391] ..$ rshlogfile : NULL [07:12:02.391] ..$ rshopts : NULL [07:12:02.391] ..$ rank : int 1 [07:12:02.391] ..$ manual : logi FALSE [07:12:02.391] ..$ dryrun : logi FALSE [07:12:02.391] ..$ quiet : logi FALSE [07:12:02.391] ..$ setup_strategy : chr "parallel" [07:12:02.391] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:02.411] [local output] System call to launch all workers: [07:12:02.412] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea184acc1f6.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30233 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:02.412] [local output] Starting PSOCK main server [07:12:02.416] [local output] Workers launched [07:12:02.416] [local output] Waiting for workers to connect back [07:12:02.416] - [local output] 0 workers out of 1 ready [07:12:02.616] - [local output] 0 workers out of 1 ready [07:12:02.617] - [local output] 1 workers out of 1 ready [07:12:02.617] [local output] Launching of workers completed [07:12:02.617] [local output] Collecting session information from workers [07:12:02.618] [local output] - Worker #1 of 1 [07:12:02.618] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [07:12:02.619] [local output] makeClusterPSOCK() ... [07:12:02.623] [local output] Workers: [n = 1] 'localhost' [07:12:02.626] [local output] Base port: 39295 [07:12:02.626] [local output] Getting setup options for 1 cluster nodes ... [07:12:02.626] [local output] - Node 1 of 1 ... [07:12:02.627] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:02.628] [local output] Rscript port: 39295 [07:12:02.629] [local output] Getting setup options for 1 cluster nodes ... done [07:12:02.629] [local output] - Parallel setup requested for some PSOCK nodes [07:12:02.629] [local output] Setting up PSOCK nodes in parallel [07:12:02.629] List of 36 [07:12:02.629] $ worker : chr "localhost" [07:12:02.629] ..- attr(*, "localhost")= logi TRUE [07:12:02.629] $ master : chr "localhost" [07:12:02.629] $ port : int 39295 [07:12:02.629] $ connectTimeout : num 120 [07:12:02.629] $ timeout : num 120 [07:12:02.629] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [07:12:02.629] $ homogeneous : logi TRUE [07:12:02.629] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [07:12:02.629] $ rscript_envs : NULL [07:12:02.629] $ rscript_libs : NULL [07:12:02.629] $ rscript_startup : NULL [07:12:02.629] $ rscript_sh : chr "cmd" [07:12:02.629] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [07:12:02.629] $ methods : logi TRUE [07:12:02.629] $ socketOptions : chr "no-delay" [07:12:02.629] $ useXDR : logi FALSE [07:12:02.629] $ outfile : chr "/dev/null" [07:12:02.629] $ renice : int NA [07:12:02.629] $ rshcmd : NULL [07:12:02.629] $ user : chr(0) [07:12:02.629] $ revtunnel : logi FALSE [07:12:02.629] $ rshlogfile : NULL [07:12:02.629] $ rshopts : chr(0) [07:12:02.629] $ rank : int 1 [07:12:02.629] $ manual : logi FALSE [07:12:02.629] $ dryrun : logi FALSE [07:12:02.629] $ quiet : logi FALSE [07:12:02.629] $ setup_strategy : chr "parallel" [07:12:02.629] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [07:12:02.629] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18beb21b1.pid" [07:12:02.629] $ rshcmd_label : NULL [07:12:02.629] $ rsh_call : NULL [07:12:02.629] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [07:12:02.629] $ localMachine : logi TRUE [07:12:02.629] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:02.629] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:02.629] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:02.629] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:02.629] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:02.629] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:02.629] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:02.629] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:02.629] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:02.629] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:02.629] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:02.629] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:02.629] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:02.629] $ arguments :List of 28 [07:12:02.629] ..$ worker : chr "localhost" [07:12:02.629] ..$ master : NULL [07:12:02.629] ..$ port : int 39295 [07:12:02.629] ..$ connectTimeout : num 120 [07:12:02.629] ..$ timeout : num 120 [07:12:02.629] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [07:12:02.629] ..$ homogeneous : NULL [07:12:02.629] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [07:12:02.629] ..$ rscript_envs : NULL [07:12:02.629] ..$ rscript_libs : NULL [07:12:02.629] ..$ rscript_startup : NULL [07:12:02.629] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:02.629] ..$ default_packages: chr [1:2] "parallelly" "*" [07:12:02.629] ..$ methods : logi TRUE [07:12:02.629] ..$ socketOptions : chr "no-delay" [07:12:02.629] ..$ useXDR : logi FALSE [07:12:02.629] ..$ outfile : chr "/dev/null" [07:12:02.629] ..$ renice : int NA [07:12:02.629] ..$ rshcmd : NULL [07:12:02.629] ..$ user : NULL [07:12:02.629] ..$ revtunnel : logi NA [07:12:02.629] ..$ rshlogfile : NULL [07:12:02.629] ..$ rshopts : NULL [07:12:02.629] ..$ rank : int 1 [07:12:02.629] ..$ manual : logi FALSE [07:12:02.629] ..$ dryrun : logi FALSE [07:12:02.629] ..$ quiet : logi FALSE [07:12:02.629] ..$ setup_strategy : chr "parallel" [07:12:02.629] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:02.652] [local output] System call to launch all workers: [07:12:02.653] [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:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea18beb21b1.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=39295 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:02.653] [local output] Starting PSOCK main server [07:12:02.656] [local output] Workers launched [07:12:02.657] [local output] Waiting for workers to connect back [07:12:02.657] - [local output] 0 workers out of 1 ready [07:12:02.858] - [local output] 0 workers out of 1 ready [07:12:02.858] - [local output] 1 workers out of 1 ready [07:12:02.858] [local output] Launching of workers completed [07:12:02.858] [local output] Collecting session information from workers [07:12:02.859] [local output] - Worker #1 of 1 [07:12:02.859] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [07:12:02.860] [local output] makeClusterPSOCK() ... [07:12:02.863] [local output] Workers: [n = 1] 'localhost' [07:12:02.865] [local output] Base port: 28796 [07:12:02.866] [local output] Getting setup options for 1 cluster nodes ... [07:12:02.866] [local output] - Node 1 of 1 ... [07:12:02.866] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:02.868] [local output] Rscript port: 28796 [07:12:02.868] [local output] Getting setup options for 1 cluster nodes ... done [07:12:02.868] [local output] - Parallel setup requested for some PSOCK nodes [07:12:02.869] [local output] Setting up PSOCK nodes in parallel [07:12:02.869] List of 36 [07:12:02.869] $ worker : chr "localhost" [07:12:02.869] ..- attr(*, "localhost")= logi TRUE [07:12:02.869] $ master : chr "localhost" [07:12:02.869] $ port : int 28796 [07:12:02.869] $ connectTimeout : num 120 [07:12:02.869] $ timeout : num 120 [07:12:02.869] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [07:12:02.869] $ homogeneous : logi TRUE [07:12:02.869] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [07:12:02.869] $ rscript_envs : NULL [07:12:02.869] $ rscript_libs : NULL [07:12:02.869] $ rscript_startup : NULL [07:12:02.869] $ rscript_sh : chr "cmd" [07:12:02.869] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [07:12:02.869] $ methods : logi TRUE [07:12:02.869] $ socketOptions : chr "no-delay" [07:12:02.869] $ useXDR : logi FALSE [07:12:02.869] $ outfile : chr "/dev/null" [07:12:02.869] $ renice : int NA [07:12:02.869] $ rshcmd : NULL [07:12:02.869] $ user : chr(0) [07:12:02.869] $ revtunnel : logi FALSE [07:12:02.869] $ rshlogfile : NULL [07:12:02.869] $ rshopts : chr(0) [07:12:02.869] $ rank : int 1 [07:12:02.869] $ manual : logi FALSE [07:12:02.869] $ dryrun : logi FALSE [07:12:02.869] $ quiet : logi FALSE [07:12:02.869] $ setup_strategy : chr "parallel" [07:12:02.869] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [07:12:02.869] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185c4f3e5.pid" [07:12:02.869] $ rshcmd_label : NULL [07:12:02.869] $ rsh_call : NULL [07:12:02.869] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [07:12:02.869] $ localMachine : logi TRUE [07:12:02.869] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:02.869] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:02.869] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:02.869] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:02.869] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:02.869] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:02.869] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:02.869] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:02.869] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:02.869] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:02.869] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:02.869] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:02.869] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:02.869] $ arguments :List of 28 [07:12:02.869] ..$ worker : chr "localhost" [07:12:02.869] ..$ master : NULL [07:12:02.869] ..$ port : int 28796 [07:12:02.869] ..$ connectTimeout : num 120 [07:12:02.869] ..$ timeout : num 120 [07:12:02.869] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [07:12:02.869] ..$ homogeneous : NULL [07:12:02.869] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [07:12:02.869] ..$ rscript_envs : NULL [07:12:02.869] ..$ rscript_libs : NULL [07:12:02.869] ..$ rscript_startup : NULL [07:12:02.869] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:02.869] ..$ default_packages: chr [1:2] "parallelly" "*" [07:12:02.869] ..$ methods : logi TRUE [07:12:02.869] ..$ socketOptions : chr "no-delay" [07:12:02.869] ..$ useXDR : logi FALSE [07:12:02.869] ..$ outfile : chr "/dev/null" [07:12:02.869] ..$ renice : int NA [07:12:02.869] ..$ rshcmd : NULL [07:12:02.869] ..$ user : NULL [07:12:02.869] ..$ revtunnel : logi NA [07:12:02.869] ..$ rshlogfile : NULL [07:12:02.869] ..$ rshopts : NULL [07:12:02.869] ..$ rank : int 1 [07:12:02.869] ..$ manual : logi FALSE [07:12:02.869] ..$ dryrun : logi FALSE [07:12:02.869] ..$ quiet : logi FALSE [07:12:02.869] ..$ setup_strategy : chr "parallel" [07:12:02.869] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:02.890] [local output] System call to launch all workers: [07:12:02.890] [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:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea185c4f3e5.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=28796 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [07:12:02.890] [local output] Starting PSOCK main server [07:12:02.894] [local output] Workers launched [07:12:02.894] [local output] Waiting for workers to connect back [07:12:02.894] - [local output] 0 workers out of 1 ready [07:12:03.096] - [local output] 0 workers out of 1 ready [07:12:03.096] - [local output] 1 workers out of 1 ready [07:12:03.096] [local output] Launching of workers completed [07:12:03.097] [local output] Collecting session information from workers [07:12:03.097] [local output] - Worker #1 of 1 [07:12:03.097] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > res <- tryCatch({ + cl <- makeClusterPSOCK(1:2) + }, error = identity) [07:12:03.098] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(0L) + }, error = identity) [07:12:03.099] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, rshcmd = character(0L)) + }, error = identity) [07:12:03.100] [local output] makeClusterPSOCK() ... [07:12:03.102] [local output] Workers: [n = 1] 'localhost' [07:12:03.105] [local output] Base port: 31075 [07:12:03.105] [local output] Getting setup options for 1 cluster nodes ... [07:12:03.105] [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) [07:12:03.106] [local output] makeClusterPSOCK() ... [07:12:03.108] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = NA_integer_) + }, error = identity) [07:12:03.109] [local output] makeClusterPSOCK() ... [07:12:03.111] [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) + } [07:12:03.114] [local output] makeClusterPSOCK() ... [07:12:03.116] [local output] Workers: [n = 1] 'localhost' [07:12:03.119] [local output] Base port: 35958 [07:12:03.119] [local output] Getting setup options for 1 cluster nodes ... [07:12:03.119] [local output] - Node 1 of 1 ... [07:12:03.119] [local output] localMachine=TRUE => revtunnel=FALSE [07:12:03.121] [local output] Rscript port: 35958 [07:12:03.121] [local output] Getting setup options for 1 cluster nodes ... done [07:12:03.122] [local output] - Parallel setup requested for some PSOCK nodes [07:12:03.122] [local output] Setting up PSOCK nodes in parallel [07:12:03.122] List of 36 [07:12:03.122] $ worker : chr "localhost" [07:12:03.122] ..- attr(*, "localhost")= logi TRUE [07:12:03.122] $ master : chr "localhost" [07:12:03.122] $ port : int 35958 [07:12:03.122] $ connectTimeout : num 0.1 [07:12:03.122] $ timeout : num 7 [07:12:03.122] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [07:12:03.122] $ homogeneous : logi TRUE [07:12:03.122] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:125464:CRANWI"| __truncated__ [07:12:03.122] $ rscript_envs : NULL [07:12:03.122] $ rscript_libs : NULL [07:12:03.122] $ rscript_startup : chr [1:2] "-e" "\"invisible({Sys.sleep(6)})\"" [07:12:03.122] $ rscript_sh : chr "cmd" [07:12:03.122] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:03.122] $ methods : logi TRUE [07:12:03.122] $ socketOptions : chr "no-delay" [07:12:03.122] $ useXDR : logi FALSE [07:12:03.122] $ outfile : chr "/dev/null" [07:12:03.122] $ renice : int NA [07:12:03.122] $ rshcmd : NULL [07:12:03.122] $ user : chr(0) [07:12:03.122] $ revtunnel : logi FALSE [07:12:03.122] $ rshlogfile : NULL [07:12:03.122] $ rshopts : chr(0) [07:12:03.122] $ rank : int 1 [07:12:03.122] $ manual : logi FALSE [07:12:03.122] $ dryrun : logi FALSE [07:12:03.122] $ quiet : logi FALSE [07:12:03.122] $ setup_strategy : chr "parallel" [07:12:03.122] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:03.122] $ pidfile : chr "D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea183ae4129e.pid" [07:12:03.122] $ rshcmd_label : NULL [07:12:03.122] $ rsh_call : NULL [07:12:03.122] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [07:12:03.122] $ localMachine : logi TRUE [07:12:03.122] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [07:12:03.122] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [07:12:03.122] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [07:12:03.122] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [07:12:03.122] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [07:12:03.122] "cmd", "sh"), default_packages = c("datasets", "utils", "grDevices", [07:12:03.122] "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [07:12:03.122] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [07:12:03.122] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [07:12:03.122] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [07:12:03.122] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [07:12:03.122] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [07:12:03.122] "parallel"), action = c("launch", "options"), verbose = FALSE) [07:12:03.122] $ arguments :List of 28 [07:12:03.122] ..$ worker : chr "localhost" [07:12:03.122] ..$ master : NULL [07:12:03.122] ..$ port : int 35958 [07:12:03.122] ..$ connectTimeout : num 0.1 [07:12:03.122] ..$ timeout : num 7 [07:12:03.122] ..$ rscript : NULL [07:12:03.122] ..$ homogeneous : NULL [07:12:03.122] ..$ rscript_args : NULL [07:12:03.122] ..$ rscript_envs : NULL [07:12:03.122] ..$ rscript_libs : NULL [07:12:03.122] ..$ rscript_startup : language Sys.sleep(6) [07:12:03.122] ..$ rscript_sh : chr [1:3] "auto" "cmd" "sh" [07:12:03.122] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [07:12:03.122] ..$ methods : logi TRUE [07:12:03.122] ..$ socketOptions : chr "no-delay" [07:12:03.122] ..$ useXDR : logi FALSE [07:12:03.122] ..$ outfile : chr "/dev/null" [07:12:03.122] ..$ renice : int NA [07:12:03.122] ..$ rshcmd : NULL [07:12:03.122] ..$ user : NULL [07:12:03.122] ..$ revtunnel : logi NA [07:12:03.122] ..$ rshlogfile : NULL [07:12:03.122] ..$ rshopts : NULL [07:12:03.122] ..$ rank : int 1 [07:12:03.122] ..$ manual : logi FALSE [07:12:03.122] ..$ dryrun : logi FALSE [07:12:03.122] ..$ quiet : logi FALSE [07:12:03.122] ..$ setup_strategy : chr "parallel" [07:12:03.122] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [07:12:03.145] [local output] System call to launch all workers: [07:12:03.145] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:125464:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmp2TfNYg/worker.rank=1.parallelly.parent=125464.1ea183ae4129e.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=35958 OUT=/dev/null TIMEOUT=7 XDR=FALSE SETUPTIMEOUT=0.1 SETUPSTRATEGY=parallel [07:12:03.145] [local output] Starting PSOCK main server [07:12:03.149] [local output] Workers launched [07:12:03.149] [local output] Waiting for workers to connect back [07:12:03.149] - [local output] 0 workers out of 1 ready [07:12:03.351] - [local output] 0 workers out of 1 ready [07:12:03.555] - [local output] 0 workers out of 1 ready [07:12:03.762] - [local output] 0 workers out of 1 ready [07:12:03.966] - [local output] 0 workers out of 1 ready [07:12:04.169] - [local output] 0 workers out of 1 ready [07:12:04.372] - [local output] 0 workers out of 1 ready [07:12:04.575] - [local output] 0 workers out of 1 ready [07:12:04.778] - [local output] 0 workers out of 1 ready [07:12:04.981] - [local output] 0 workers out of 1 ready [07:12:05.184] - [local output] 0 workers out of 1 ready [07:12:05.387] - [local output] 0 workers out of 1 ready [07:12:05.590] - [local output] 0 workers out of 1 ready [07:12:05.794] - [local output] 0 workers out of 1 ready [07:12:05.997] - [local output] 0 workers out of 1 ready [07:12:06.200] - [local output] 0 workers out of 1 ready [07:12:06.403] - [local output] 0 workers out of 1 ready [07:12:06.606] - [local output] 0 workers out of 1 ready [07:12:06.810] - [local output] 0 workers out of 1 ready [07:12:07.013] - [local output] 0 workers out of 1 ready [07:12:07.216] - [local output] 0 workers out of 1 ready [07:12:07.419] - [local output] 0 workers out of 1 ready [07:12:07.622] - [local output] 0 workers out of 1 ready [07:12:07.825] - [local output] 0 workers out of 1 ready [07:12:08.028] - [local output] 0 workers out of 1 ready [07:12:08.231] - [local output] 0 workers out of 1 ready [07:12:08.435] - [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.14 17.20