R Under development (unstable) (2024-12-02 r87417 ucrt) -- "Unsuffered Consequences" Copyright (C) 2024 The R Foundation for Statistical Computing Platform: x86_64-w64-mingw32/x64 R is free software and comes with ABSOLUTELY NO WARRANTY. You are welcome to redistribute it under certain conditions. Type 'license()' or 'licence()' for distribution details. R is a collaborative project with many contributors. Type 'contributors()' for more information and 'citation()' on how to cite R or R packages in publications. Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for an HTML browser interface to help. Type 'q()' to quit R. > source("incl/start.R") > > is_fqdn <- parallelly:::is_fqdn > is_ip_number <- parallelly:::is_ip_number > is_localhost <- parallelly:::is_localhost > find_rshcmd <- parallelly:::find_rshcmd > > message("*** makeClusterPSOCK() ...") *** makeClusterPSOCK() ... > > message("- makeClusterPSOCK() - internal utility functions") - makeClusterPSOCK() - internal utility functions > > stopifnot( + is_fqdn("a.b"), + is_fqdn("a.b.c"), + !is_fqdn("a") + ) > > stopifnot( + is_ip_number("1.2.3.4"), + !is_ip_number("a"), + !is_ip_number("1.2.3"), + !is_ip_number("1.2.3.256"), + !is_ip_number("1.2.3.-1"), + !is_ip_number("1.2.3.a") + ) > > ## Reset internal cache > stopifnot(is.na(is_localhost(worker = NULL, hostname = NULL))) > stopifnot( + is_localhost("localhost"), + is_localhost("127.0.0.1"), + is_localhost(Sys.info()[["nodename"]]), + is_localhost(Sys.info()[["nodename"]]), ## cache hit + !is_localhost("not.a.localhost.hostname") + ) > > cmd <- find_rshcmd(must_work = FALSE) > print(cmd) $ssh ssh "d:\\rtools44\\usr\\bin\\ssh.exe" attr(,"type") [1] "ssh" attr(,"version") [1] "OpenSSH_9.9p1, OpenSSL 3.3.2 3 Sep 2024" $`putty-plink` plink "C:\\PROGRA~1\\PuTTY\\plink.exe" "-ssh" attr(,"type") [1] "putty-plink" attr(,"version") [1] "plink: Release 0.81; Build platform: 64-bit x86 Windows; Compiler: clang 14.0.0 , emulating Visual Studio 2022 (17.2), _MSC_VER=1932, _MSC_FULL_VER=193231329; Source commit: a8601a72a918dfc2a8e8536a77139d7f37700044" > > > message("- makeClusterPSOCK()") - makeClusterPSOCK() > > cl <- makeClusterPSOCK("", user = "johndoe", master = NULL, revtunnel = FALSE, rshcmd = "my_ssh", renice = TRUE, manual = TRUE, dryrun = TRUE) [05:01:54.577] [local output] makeClusterPSOCK() ... [05:01:54.618] [local output] Workers: [n = 1] '' [05:01:54.627] [local output] Base port: 37044 [05:01:54.628] [local output] Getting setup options for 1 cluster nodes ... [05:01:54.628] [local output] - Node #1 of 1 ... [05:01:54.632] [local output] Rscript port: 37044 [05:01:54.633] [local output] Using 'rshcmd': 'my_ssh' [type='', version=''] [05:01:54.633] [local output] Getting setup options for 1 cluster nodes ... done [05:01:54.634] [local output] Creating node #1 of 1 ... [05:01:54.634] [local output] - setting up node [05:01:54.634] [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:58828:CRANWIN3:CRAN' -e 'options(socketOptions = "no-delay")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=37044 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:58828:CRANWIN3:CRAN' -e 'options(socketOptions = \"no-delay\")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=37044 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential" [05:01:54.635] [local output] Creating node #1 of 1 ... done [05:01:54.635] [local output] Launching of 1 workers completed [05:01:54.636] [local output] Number of nodes in cluster: 1 [05:01:54.636] [local output] Collecting session information from 1 workers [05:01:54.636] [local output] - Worker #1 of 1 [05:01:54.637] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'NA' (R version and platform not queried) > > cl <- makeClusterPSOCK(1L, port = "random", dryrun = TRUE) [05:01:54.641] [local output] makeClusterPSOCK() ... [05:01:54.648] [local output] Workers: [n = 1] 'localhost' [05:01:54.651] [local output] Base port: 38818 [05:01:54.652] [local output] Getting setup options for 1 cluster nodes ... [05:01:54.652] [local output] - Node #1 of 1 ... [05:01:54.652] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:54.654] [local output] Rscript port: 38818 [05:01:54.654] [local output] Getting setup options for 1 cluster nodes ... done [05:01:54.655] [local output] Creating node #1 of 1 ... [05:01:54.655] [local output] - setting up node [05:01:54.655] [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:58828:CRANWIN3:CRAN" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38818 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [05:01:54.655] [local output] Creating node #1 of 1 ... done [05:01:54.656] [local output] Launching of 1 workers completed [05:01:54.656] [local output] Number of nodes in cluster: 1 [05:01:54.656] [local output] Collecting session information from 1 workers [05:01:54.656] [local output] - Worker #1 of 1 [05:01:54.657] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'NA' (R version and platform not queried) > > cl <- makeClusterPSOCK(1L) [05:01:54.658] [local output] makeClusterPSOCK() ... [05:01:54.661] [local output] Workers: [n = 1] 'localhost' [05:01:54.665] [local output] Base port: 35430 [05:01:54.666] [local output] Getting setup options for 1 cluster nodes ... [05:01:54.666] [local output] - Node #1 of 1 ... [05:01:54.667] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:54.669] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc7c7d7e4f.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc7c7d7e4f.pid\")"' [05:01:55.107] - Possible to infer worker's PID: TRUE [05:01:55.109] [local output] Rscript port: 35430 [05:01:55.109] [local output] Getting setup options for 1 cluster nodes ... done [05:01:55.110] [local output] - Parallel setup requested for some PSOCK nodes [05:01:55.111] [local output] Setting up PSOCK nodes in parallel [05:01:55.111] List of 36 [05:01:55.111] $ worker : chr "localhost" [05:01:55.111] ..- attr(*, "localhost")= logi TRUE [05:01:55.111] $ master : chr "localhost" [05:01:55.111] $ port : int 35430 [05:01:55.111] $ connectTimeout : num 120 [05:01:55.111] $ timeout : num 120 [05:01:55.111] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:55.111] $ homogeneous : logi TRUE [05:01:55.111] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:55.111] $ rscript_envs : NULL [05:01:55.111] $ rscript_libs : NULL [05:01:55.111] $ rscript_startup : NULL [05:01:55.111] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:55.111] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:55.111] $ methods : logi TRUE [05:01:55.111] $ socketOptions : chr "no-delay" [05:01:55.111] $ useXDR : logi FALSE [05:01:55.111] $ outfile : chr "/dev/null" [05:01:55.111] $ renice : int NA [05:01:55.111] $ rshcmd : NULL [05:01:55.111] $ user : chr(0) [05:01:55.111] $ revtunnel : logi FALSE [05:01:55.111] $ rshlogfile : NULL [05:01:55.111] $ rshopts : chr(0) [05:01:55.111] $ rank : int 1 [05:01:55.111] $ manual : logi FALSE [05:01:55.111] $ dryrun : logi FALSE [05:01:55.111] $ quiet : logi FALSE [05:01:55.111] $ setup_strategy : chr "parallel" [05:01:55.111] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:55.111] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc7c7d7e4f.pid" [05:01:55.111] $ rshcmd_label : NULL [05:01:55.111] $ rsh_call : NULL [05:01:55.111] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:55.111] $ localMachine : logi TRUE [05:01:55.111] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:55.111] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:55.111] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:55.111] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:55.111] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:55.111] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:55.111] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:55.111] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:55.111] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:55.111] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:55.111] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:55.111] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:55.111] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:55.111] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:55.111] $ arguments :List of 28 [05:01:55.111] ..$ worker : chr "localhost" [05:01:55.111] ..$ master : NULL [05:01:55.111] ..$ port : int 35430 [05:01:55.111] ..$ connectTimeout : num 120 [05:01:55.111] ..$ timeout : num 120 [05:01:55.111] ..$ rscript : NULL [05:01:55.111] ..$ homogeneous : NULL [05:01:55.111] ..$ rscript_args : NULL [05:01:55.111] ..$ rscript_envs : NULL [05:01:55.111] ..$ rscript_libs : NULL [05:01:55.111] ..$ rscript_startup : NULL [05:01:55.111] ..$ rscript_sh : chr "auto" [05:01:55.111] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:55.111] ..$ methods : logi TRUE [05:01:55.111] ..$ socketOptions : chr "no-delay" [05:01:55.111] ..$ useXDR : logi FALSE [05:01:55.111] ..$ outfile : chr "/dev/null" [05:01:55.111] ..$ renice : int NA [05:01:55.111] ..$ rshcmd : NULL [05:01:55.111] ..$ user : NULL [05:01:55.111] ..$ revtunnel : logi NA [05:01:55.111] ..$ rshlogfile : NULL [05:01:55.111] ..$ rshopts : NULL [05:01:55.111] ..$ rank : int 1 [05:01:55.111] ..$ manual : logi FALSE [05:01:55.111] ..$ dryrun : logi FALSE [05:01:55.111] ..$ quiet : logi FALSE [05:01:55.111] ..$ setup_strategy : chr "parallel" [05:01:55.111] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:55.153] [local output] System call to launch all workers: [05:01:55.153] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc7c7d7e4f.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=35430 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:55.153] [local output] Starting PSOCK main server [05:01:55.158] [local output] Workers launched [05:01:55.159] [local output] Waiting for workers to connect back [05:01:55.159] - [local output] 0 workers out of 1 ready [05:01:55.418] - [local output] 0 workers out of 1 ready [05:01:55.418] - [local output] 1 workers out of 1 ready [05:01:55.419] [local output] Launching of 1 workers completed [05:01:55.419] [local output] Number of nodes in cluster: 1 [05:01:55.419] [local output] Collecting session information from 1 workers [05:01:55.420] [local output] - Worker #1 of 1 [05:01:55.421] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-12-02 r87417 ucrt), platform x86_64-w64-mingw32) > node <- cl[[1]] > utils::str(node) List of 4 $ con : 'sockconn' int 4 ..- attr(*, "conn_id")= $ host : chr "localhost" ..- attr(*, "localhost")= logi TRUE $ rank : int 0 $ session_info:List of 6 ..$ r :List of 16 .. ..$ platform : chr "x86_64-w64-mingw32" .. ..$ arch : chr "x86_64" .. ..$ os : chr "mingw32" .. ..$ crt : chr "ucrt" .. ..$ system : chr "x86_64, mingw32" .. ..$ status : chr "Under development (unstable)" .. ..$ major : chr "4" .. ..$ minor : chr "5.0" .. ..$ year : chr "2024" .. ..$ month : chr "12" .. ..$ day : chr "02" .. ..$ svn rev : chr "87417" .. ..$ language : chr "R" .. ..$ version.string: chr "R Under development (unstable) (2024-12-02 r87417 ucrt)" .. ..$ nickname : chr "Unsuffered Consequences" .. ..$ os.type : chr "windows" ..$ system :List of 9 .. ..$ sysname : chr "Windows" .. ..$ release : chr "Server x64" .. ..$ version : chr "build 20348" .. ..$ nodename : chr "CRANWIN3" .. ..$ machine : chr "x86-64" .. ..$ login : chr "CRAN" .. ..$ user : chr "CRAN" .. ..$ effective_user: chr "CRAN" .. ..$ udomain : chr "CRANWIN3" ..$ libs : chr [1:2] "D:/temp/2024_12_03_04_25_01_4301/RtmpsXawjX/RLIBS_2603020557ef6" "D:/RCompile/recent/R/library" ..$ pkgs : NULL ..$ pwd : chr "d:/RCompile/CRANincoming/R-devel/parallelly.Rcheck/tests" ..$ process:List of 1 .. ..$ pid: int 55956 - attr(*, "options")=List of 35 ..$ worker : chr "localhost" .. ..- attr(*, "localhost")= logi TRUE ..$ master : chr "localhost" ..$ port : int 35430 ..$ 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:58828:CRANWIN"| __truncated__ ..$ rscript_envs : NULL ..$ rscript_libs : NULL ..$ rscript_startup : NULL ..$ rscript_sh : chr [1:2] "cmd" "cmd" ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... ..$ methods : logi TRUE ..$ socketOptions : chr "no-delay" ..$ useXDR : logi FALSE ..$ outfile : chr "/dev/null" ..$ renice : int NA ..$ rshcmd : NULL ..$ user : chr(0) ..$ revtunnel : logi FALSE ..$ rshlogfile : NULL ..$ rshopts : chr(0) ..$ rank : int 0 ..$ manual : logi FALSE ..$ dryrun : logi FALSE ..$ quiet : logi FALSE ..$ setup_strategy : chr "parallel" ..$ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ ..$ rshcmd_label : NULL ..$ rsh_call : NULL ..$ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ ..$ localMachine : logi TRUE ..$ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", "cmd", "sh", "none"), default_packages = c("datasets", "utils", "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", "parallel"), action = c("launch", "options"), verbose = FALSE) ..$ arguments :List of 28 .. ..$ worker : chr "localhost" .. ..$ master : NULL .. ..$ port : int 35430 .. ..$ connectTimeout : num 120 .. ..$ timeout : num 120 .. ..$ rscript : NULL .. ..$ homogeneous : NULL .. ..$ rscript_args : NULL .. ..$ rscript_envs : NULL .. ..$ rscript_libs : NULL .. ..$ rscript_startup : NULL .. ..$ rscript_sh : chr "auto" .. ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... .. ..$ methods : logi TRUE .. ..$ socketOptions : chr "no-delay" .. ..$ useXDR : logi FALSE .. ..$ outfile : chr "/dev/null" .. ..$ renice : int NA .. ..$ rshcmd : NULL .. ..$ user : NULL .. ..$ revtunnel : logi NA .. ..$ rshlogfile : NULL .. ..$ rshopts : NULL .. ..$ rank : int 1 .. ..$ manual : logi FALSE .. ..$ dryrun : logi FALSE .. ..$ quiet : logi FALSE .. ..$ setup_strategy : chr "parallel" ..- attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" - attr(*, "class")= chr [1:2] "RichSOCKnode" "SOCK0node" > stopifnot(isTRUE(attr(node[["host"]], "localhost"))) > parallel::stopCluster(cl) > > > message("- makeClusterPSOCK() - useXDR = TRUE/FALSE") - makeClusterPSOCK() - useXDR = TRUE/FALSE > > for (xdr in c(TRUE, FALSE)) { + cl <- makeClusterPSOCK(1L, useXDR = xdr) + node <- cl[[1]] + stopifnot( + is.list(node), + inherits(node, if (xdr) "SOCKnode" else "SOCK0node"), + "session_info" %in% names(node) + ) + si <- node[["session_info"]] + stopifnot(is.list(si)) + parallel::stopCluster(cl) + } [05:01:55.492] [local output] makeClusterPSOCK() ... [05:01:55.496] [local output] Workers: [n = 1] 'localhost' [05:01:55.500] [local output] Base port: 26396 [05:01:55.500] [local output] Getting setup options for 1 cluster nodes ... [05:01:55.501] [local output] - Node #1 of 1 ... [05:01:55.502] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:55.504] [local output] Rscript port: 26396 [05:01:55.505] [local output] Getting setup options for 1 cluster nodes ... done [05:01:55.506] [local output] - Parallel setup requested for some PSOCK nodes [05:01:55.506] [local output] Setting up PSOCK nodes in parallel [05:01:55.507] List of 36 [05:01:55.507] $ worker : chr "localhost" [05:01:55.507] ..- attr(*, "localhost")= logi TRUE [05:01:55.507] $ master : chr "localhost" [05:01:55.507] $ port : int 26396 [05:01:55.507] $ connectTimeout : num 120 [05:01:55.507] $ timeout : num 120 [05:01:55.507] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:55.507] $ homogeneous : logi TRUE [05:01:55.507] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:55.507] $ rscript_envs : NULL [05:01:55.507] $ rscript_libs : NULL [05:01:55.507] $ rscript_startup : NULL [05:01:55.507] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:55.507] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:55.507] $ methods : logi TRUE [05:01:55.507] $ socketOptions : chr "no-delay" [05:01:55.507] $ useXDR : logi TRUE [05:01:55.507] $ outfile : chr "/dev/null" [05:01:55.507] $ renice : int NA [05:01:55.507] $ rshcmd : NULL [05:01:55.507] $ user : chr(0) [05:01:55.507] $ revtunnel : logi FALSE [05:01:55.507] $ rshlogfile : NULL [05:01:55.507] $ rshopts : chr(0) [05:01:55.507] $ rank : int 1 [05:01:55.507] $ manual : logi FALSE [05:01:55.507] $ dryrun : logi FALSE [05:01:55.507] $ quiet : logi FALSE [05:01:55.507] $ setup_strategy : chr "parallel" [05:01:55.507] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:55.507] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc3a4d7b5c.pid" [05:01:55.507] $ rshcmd_label : NULL [05:01:55.507] $ rsh_call : NULL [05:01:55.507] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:55.507] $ localMachine : logi TRUE [05:01:55.507] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:55.507] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:55.507] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:55.507] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:55.507] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:55.507] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:55.507] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:55.507] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:55.507] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:55.507] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:55.507] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:55.507] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:55.507] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:55.507] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:55.507] $ arguments :List of 28 [05:01:55.507] ..$ worker : chr "localhost" [05:01:55.507] ..$ master : NULL [05:01:55.507] ..$ port : int 26396 [05:01:55.507] ..$ connectTimeout : num 120 [05:01:55.507] ..$ timeout : num 120 [05:01:55.507] ..$ rscript : NULL [05:01:55.507] ..$ homogeneous : NULL [05:01:55.507] ..$ rscript_args : NULL [05:01:55.507] ..$ rscript_envs : NULL [05:01:55.507] ..$ rscript_libs : NULL [05:01:55.507] ..$ rscript_startup : NULL [05:01:55.507] ..$ rscript_sh : chr "auto" [05:01:55.507] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:55.507] ..$ methods : logi TRUE [05:01:55.507] ..$ socketOptions : chr "no-delay" [05:01:55.507] ..$ useXDR : logi TRUE [05:01:55.507] ..$ outfile : chr "/dev/null" [05:01:55.507] ..$ renice : int NA [05:01:55.507] ..$ rshcmd : NULL [05:01:55.507] ..$ user : NULL [05:01:55.507] ..$ revtunnel : logi NA [05:01:55.507] ..$ rshlogfile : NULL [05:01:55.507] ..$ rshopts : NULL [05:01:55.507] ..$ rank : int 1 [05:01:55.507] ..$ manual : logi FALSE [05:01:55.507] ..$ dryrun : logi FALSE [05:01:55.507] ..$ quiet : logi FALSE [05:01:55.507] ..$ setup_strategy : chr "parallel" [05:01:55.507] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:55.550] [local output] System call to launch all workers: [05:01:55.550] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc3a4d7b5c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26396 OUT=/dev/null TIMEOUT=120 XDR=TRUE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:55.551] [local output] Starting PSOCK main server [05:01:55.556] [local output] Workers launched [05:01:55.557] [local output] Waiting for workers to connect back [05:01:55.557] - [local output] 0 workers out of 1 ready [05:01:55.801] - [local output] 0 workers out of 1 ready [05:01:55.801] - [local output] 1 workers out of 1 ready [05:01:55.802] [local output] Launching of 1 workers completed [05:01:55.802] [local output] Number of nodes in cluster: 1 [05:01:55.802] [local output] Collecting session information from 1 workers [05:01:55.803] [local output] - Worker #1 of 1 [05:01:55.803] [local output] makeClusterPSOCK() ... done [05:01:55.808] [local output] makeClusterPSOCK() ... [05:01:55.812] [local output] Workers: [n = 1] 'localhost' [05:01:55.816] [local output] Base port: 28422 [05:01:55.818] [local output] Getting setup options for 1 cluster nodes ... [05:01:55.818] [local output] - Node #1 of 1 ... [05:01:55.819] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:55.821] [local output] Rscript port: 28422 [05:01:55.821] [local output] Getting setup options for 1 cluster nodes ... done [05:01:55.821] [local output] - Parallel setup requested for some PSOCK nodes [05:01:55.822] [local output] Setting up PSOCK nodes in parallel [05:01:55.822] List of 36 [05:01:55.822] $ worker : chr "localhost" [05:01:55.822] ..- attr(*, "localhost")= logi TRUE [05:01:55.822] $ master : chr "localhost" [05:01:55.822] $ port : int 28422 [05:01:55.822] $ connectTimeout : num 120 [05:01:55.822] $ timeout : num 120 [05:01:55.822] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:55.822] $ homogeneous : logi TRUE [05:01:55.822] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:55.822] $ rscript_envs : NULL [05:01:55.822] $ rscript_libs : NULL [05:01:55.822] $ rscript_startup : NULL [05:01:55.822] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:55.822] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:55.822] $ methods : logi TRUE [05:01:55.822] $ socketOptions : chr "no-delay" [05:01:55.822] $ useXDR : logi FALSE [05:01:55.822] $ outfile : chr "/dev/null" [05:01:55.822] $ renice : int NA [05:01:55.822] $ rshcmd : NULL [05:01:55.822] $ user : chr(0) [05:01:55.822] $ revtunnel : logi FALSE [05:01:55.822] $ rshlogfile : NULL [05:01:55.822] $ rshopts : chr(0) [05:01:55.822] $ rank : int 1 [05:01:55.822] $ manual : logi FALSE [05:01:55.822] $ dryrun : logi FALSE [05:01:55.822] $ quiet : logi FALSE [05:01:55.822] $ setup_strategy : chr "parallel" [05:01:55.822] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:55.822] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc1e036aa4.pid" [05:01:55.822] $ rshcmd_label : NULL [05:01:55.822] $ rsh_call : NULL [05:01:55.822] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:55.822] $ localMachine : logi TRUE [05:01:55.822] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:55.822] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:55.822] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:55.822] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:55.822] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:55.822] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:55.822] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:55.822] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:55.822] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:55.822] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:55.822] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:55.822] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:55.822] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:55.822] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:55.822] $ arguments :List of 28 [05:01:55.822] ..$ worker : chr "localhost" [05:01:55.822] ..$ master : NULL [05:01:55.822] ..$ port : int 28422 [05:01:55.822] ..$ connectTimeout : num 120 [05:01:55.822] ..$ timeout : num 120 [05:01:55.822] ..$ rscript : NULL [05:01:55.822] ..$ homogeneous : NULL [05:01:55.822] ..$ rscript_args : NULL [05:01:55.822] ..$ rscript_envs : NULL [05:01:55.822] ..$ rscript_libs : NULL [05:01:55.822] ..$ rscript_startup : NULL [05:01:55.822] ..$ rscript_sh : chr "auto" [05:01:55.822] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:55.822] ..$ methods : logi TRUE [05:01:55.822] ..$ socketOptions : chr "no-delay" [05:01:55.822] ..$ useXDR : logi FALSE [05:01:55.822] ..$ outfile : chr "/dev/null" [05:01:55.822] ..$ renice : int NA [05:01:55.822] ..$ rshcmd : NULL [05:01:55.822] ..$ user : NULL [05:01:55.822] ..$ revtunnel : logi NA [05:01:55.822] ..$ rshlogfile : NULL [05:01:55.822] ..$ rshopts : NULL [05:01:55.822] ..$ rank : int 1 [05:01:55.822] ..$ manual : logi FALSE [05:01:55.822] ..$ dryrun : logi FALSE [05:01:55.822] ..$ quiet : logi FALSE [05:01:55.822] ..$ setup_strategy : chr "parallel" [05:01:55.822] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:55.844] [local output] System call to launch all workers: [05:01:55.844] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc1e036aa4.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=28422 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:55.845] [local output] Starting PSOCK main server [05:01:55.850] [local output] Workers launched [05:01:55.850] [local output] Waiting for workers to connect back [05:01:55.851] - [local output] 0 workers out of 1 ready [05:01:56.044] - [local output] 0 workers out of 1 ready [05:01:56.046] - [local output] 1 workers out of 1 ready [05:01:56.047] [local output] Launching of 1 workers completed [05:01:56.047] [local output] Number of nodes in cluster: 1 [05:01:56.047] [local output] Collecting session information from 1 workers [05:01:56.048] [local output] - Worker #1 of 1 [05:01:56.048] [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) + } [05:01:56.062] [local output] makeClusterPSOCK() ... [05:01:56.068] [local output] Workers: [n = 1] 'localhost' [05:01:56.073] [local output] Base port: 30390 [05:01:56.074] [local output] Getting setup options for 1 cluster nodes ... [05:01:56.074] [local output] - Node #1 of 1 ... [05:01:56.075] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:56.078] [local output] Rscript port: 30390 [05:01:56.078] [local output] Getting setup options for 1 cluster nodes ... done [05:01:56.079] [local output] - Parallel setup requested for some PSOCK nodes [05:01:56.080] [local output] Setting up PSOCK nodes in parallel [05:01:56.080] List of 36 [05:01:56.080] $ worker : chr "localhost" [05:01:56.080] ..- attr(*, "localhost")= logi TRUE [05:01:56.080] $ master : chr "localhost" [05:01:56.080] $ port : int 30390 [05:01:56.080] $ connectTimeout : num 120 [05:01:56.080] $ timeout : num 120 [05:01:56.080] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:56.080] $ homogeneous : logi TRUE [05:01:56.080] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:56.080] $ rscript_envs : NULL [05:01:56.080] $ rscript_libs : NULL [05:01:56.080] $ rscript_startup : NULL [05:01:56.080] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:56.080] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:56.080] $ methods : logi TRUE [05:01:56.080] $ socketOptions : NULL [05:01:56.080] $ useXDR : logi FALSE [05:01:56.080] $ outfile : chr "/dev/null" [05:01:56.080] $ renice : int NA [05:01:56.080] $ rshcmd : NULL [05:01:56.080] $ user : chr(0) [05:01:56.080] $ revtunnel : logi FALSE [05:01:56.080] $ rshlogfile : NULL [05:01:56.080] $ rshopts : chr(0) [05:01:56.080] $ rank : int 1 [05:01:56.080] $ manual : logi FALSE [05:01:56.080] $ dryrun : logi FALSE [05:01:56.080] $ quiet : logi FALSE [05:01:56.080] $ setup_strategy : chr "parallel" [05:01:56.080] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:56.080] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4f8b1e75.pid" [05:01:56.080] $ rshcmd_label : NULL [05:01:56.080] $ rsh_call : NULL [05:01:56.080] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:56.080] $ localMachine : logi TRUE [05:01:56.080] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:56.080] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:56.080] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:56.080] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:56.080] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:56.080] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:56.080] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:56.080] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:56.080] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:56.080] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:56.080] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:56.080] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:56.080] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:56.080] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:56.080] $ arguments :List of 28 [05:01:56.080] ..$ worker : chr "localhost" [05:01:56.080] ..$ master : NULL [05:01:56.080] ..$ port : int 30390 [05:01:56.080] ..$ connectTimeout : num 120 [05:01:56.080] ..$ timeout : num 120 [05:01:56.080] ..$ rscript : NULL [05:01:56.080] ..$ homogeneous : NULL [05:01:56.080] ..$ rscript_args : NULL [05:01:56.080] ..$ rscript_envs : NULL [05:01:56.080] ..$ rscript_libs : NULL [05:01:56.080] ..$ rscript_startup : NULL [05:01:56.080] ..$ rscript_sh : chr "auto" [05:01:56.080] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:56.080] ..$ methods : logi TRUE [05:01:56.080] ..$ socketOptions : NULL [05:01:56.080] ..$ useXDR : logi FALSE [05:01:56.080] ..$ outfile : chr "/dev/null" [05:01:56.080] ..$ renice : int NA [05:01:56.080] ..$ rshcmd : NULL [05:01:56.080] ..$ user : NULL [05:01:56.080] ..$ revtunnel : logi NA [05:01:56.080] ..$ rshlogfile : NULL [05:01:56.080] ..$ rshopts : NULL [05:01:56.080] ..$ rank : int 1 [05:01:56.080] ..$ manual : logi FALSE [05:01:56.080] ..$ dryrun : logi FALSE [05:01:56.080] ..$ quiet : logi FALSE [05:01:56.080] ..$ setup_strategy : chr "parallel" [05:01:56.080] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:56.110] [local output] System call to launch all workers: [05:01:56.110] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4f8b1e75.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30390 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:56.111] [local output] Starting PSOCK main server [05:01:56.115] [local output] Workers launched [05:01:56.115] [local output] Waiting for workers to connect back [05:01:56.116] - [local output] 0 workers out of 1 ready [05:01:56.337] - [local output] 0 workers out of 1 ready [05:01:56.338] - [local output] 1 workers out of 1 ready [05:01:56.339] [local output] Launching of 1 workers completed [05:01:56.339] [local output] Number of nodes in cluster: 1 [05:01:56.340] [local output] Collecting session information from 1 workers [05:01:56.341] [local output] - Worker #1 of 1 [05:01:56.341] [local output] makeClusterPSOCK() ... done [05:01:56.347] [local output] makeClusterPSOCK() ... [05:01:56.353] [local output] Workers: [n = 1] 'localhost' [05:01:56.359] [local output] Base port: 31457 [05:01:56.359] [local output] Getting setup options for 1 cluster nodes ... [05:01:56.359] [local output] - Node #1 of 1 ... [05:01:56.360] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:56.363] [local output] Rscript port: 31457 [05:01:56.364] [local output] Getting setup options for 1 cluster nodes ... done [05:01:56.364] [local output] - Parallel setup requested for some PSOCK nodes [05:01:56.365] [local output] Setting up PSOCK nodes in parallel [05:01:56.365] List of 36 [05:01:56.365] $ worker : chr "localhost" [05:01:56.365] ..- attr(*, "localhost")= logi TRUE [05:01:56.365] $ master : chr "localhost" [05:01:56.365] $ port : int 31457 [05:01:56.365] $ connectTimeout : num 120 [05:01:56.365] $ timeout : num 120 [05:01:56.365] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:56.365] $ homogeneous : logi TRUE [05:01:56.365] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:56.365] $ rscript_envs : NULL [05:01:56.365] $ rscript_libs : NULL [05:01:56.365] $ rscript_startup : NULL [05:01:56.365] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:56.365] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:56.365] $ methods : logi TRUE [05:01:56.365] $ socketOptions : NULL [05:01:56.365] $ useXDR : logi FALSE [05:01:56.365] $ outfile : chr "/dev/null" [05:01:56.365] $ renice : int NA [05:01:56.365] $ rshcmd : NULL [05:01:56.365] $ user : chr(0) [05:01:56.365] $ revtunnel : logi FALSE [05:01:56.365] $ rshlogfile : NULL [05:01:56.365] $ rshopts : chr(0) [05:01:56.365] $ rank : int 1 [05:01:56.365] $ manual : logi FALSE [05:01:56.365] $ dryrun : logi FALSE [05:01:56.365] $ quiet : logi FALSE [05:01:56.365] $ setup_strategy : chr "parallel" [05:01:56.365] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:56.365] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc31945dcd.pid" [05:01:56.365] $ rshcmd_label : NULL [05:01:56.365] $ rsh_call : NULL [05:01:56.365] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:56.365] $ localMachine : logi TRUE [05:01:56.365] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:56.365] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:56.365] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:56.365] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:56.365] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:56.365] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:56.365] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:56.365] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:56.365] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:56.365] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:56.365] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:56.365] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:56.365] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:56.365] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:56.365] $ arguments :List of 28 [05:01:56.365] ..$ worker : chr "localhost" [05:01:56.365] ..$ master : NULL [05:01:56.365] ..$ port : int 31457 [05:01:56.365] ..$ connectTimeout : num 120 [05:01:56.365] ..$ timeout : num 120 [05:01:56.365] ..$ rscript : NULL [05:01:56.365] ..$ homogeneous : NULL [05:01:56.365] ..$ rscript_args : NULL [05:01:56.365] ..$ rscript_envs : NULL [05:01:56.365] ..$ rscript_libs : NULL [05:01:56.365] ..$ rscript_startup : NULL [05:01:56.365] ..$ rscript_sh : chr "auto" [05:01:56.365] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:56.365] ..$ methods : logi TRUE [05:01:56.365] ..$ socketOptions : chr "NULL" [05:01:56.365] ..$ useXDR : logi FALSE [05:01:56.365] ..$ outfile : chr "/dev/null" [05:01:56.365] ..$ renice : int NA [05:01:56.365] ..$ rshcmd : NULL [05:01:56.365] ..$ user : NULL [05:01:56.365] ..$ revtunnel : logi NA [05:01:56.365] ..$ rshlogfile : NULL [05:01:56.365] ..$ rshopts : NULL [05:01:56.365] ..$ rank : int 1 [05:01:56.365] ..$ manual : logi FALSE [05:01:56.365] ..$ dryrun : logi FALSE [05:01:56.365] ..$ quiet : logi FALSE [05:01:56.365] ..$ setup_strategy : chr "parallel" [05:01:56.365] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:56.408] [local output] System call to launch all workers: [05:01:56.409] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc31945dcd.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=31457 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:56.409] [local output] Starting PSOCK main server [05:01:56.416] [local output] Workers launched [05:01:56.417] [local output] Waiting for workers to connect back [05:01:56.417] - [local output] 0 workers out of 1 ready [05:01:56.641] - [local output] 0 workers out of 1 ready [05:01:56.642] - [local output] 1 workers out of 1 ready [05:01:56.642] [local output] Launching of 1 workers completed [05:01:56.642] [local output] Number of nodes in cluster: 1 [05:01:56.642] [local output] Collecting session information from 1 workers [05:01:56.643] [local output] - Worker #1 of 1 [05:01:56.643] [local output] makeClusterPSOCK() ... done [05:01:56.648] [local output] makeClusterPSOCK() ... [05:01:56.655] [local output] Workers: [n = 1] 'localhost' [05:01:56.661] [local output] Base port: 30973 [05:01:56.661] [local output] Getting setup options for 1 cluster nodes ... [05:01:56.661] [local output] - Node #1 of 1 ... [05:01:56.662] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:56.665] [local output] Rscript port: 30973 [05:01:56.666] [local output] Getting setup options for 1 cluster nodes ... done [05:01:56.666] [local output] - Parallel setup requested for some PSOCK nodes [05:01:56.667] [local output] Setting up PSOCK nodes in parallel [05:01:56.668] List of 36 [05:01:56.668] $ worker : chr "localhost" [05:01:56.668] ..- attr(*, "localhost")= logi TRUE [05:01:56.668] $ master : chr "localhost" [05:01:56.668] $ port : int 30973 [05:01:56.668] $ connectTimeout : num 120 [05:01:56.668] $ timeout : num 120 [05:01:56.668] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:56.668] $ homogeneous : logi TRUE [05:01:56.668] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:56.668] $ rscript_envs : NULL [05:01:56.668] $ rscript_libs : NULL [05:01:56.668] $ rscript_startup : NULL [05:01:56.668] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:56.668] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:56.668] $ methods : logi TRUE [05:01:56.668] $ socketOptions : chr "no-delay" [05:01:56.668] $ useXDR : logi FALSE [05:01:56.668] $ outfile : chr "/dev/null" [05:01:56.668] $ renice : int NA [05:01:56.668] $ rshcmd : NULL [05:01:56.668] $ user : chr(0) [05:01:56.668] $ revtunnel : logi FALSE [05:01:56.668] $ rshlogfile : NULL [05:01:56.668] $ rshopts : chr(0) [05:01:56.668] $ rank : int 1 [05:01:56.668] $ manual : logi FALSE [05:01:56.668] $ dryrun : logi FALSE [05:01:56.668] $ quiet : logi FALSE [05:01:56.668] $ setup_strategy : chr "parallel" [05:01:56.668] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:56.668] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc23382f6f.pid" [05:01:56.668] $ rshcmd_label : NULL [05:01:56.668] $ rsh_call : NULL [05:01:56.668] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:56.668] $ localMachine : logi TRUE [05:01:56.668] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:56.668] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:56.668] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:56.668] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:56.668] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:56.668] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:56.668] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:56.668] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:56.668] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:56.668] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:56.668] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:56.668] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:56.668] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:56.668] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:56.668] $ arguments :List of 28 [05:01:56.668] ..$ worker : chr "localhost" [05:01:56.668] ..$ master : NULL [05:01:56.668] ..$ port : int 30973 [05:01:56.668] ..$ connectTimeout : num 120 [05:01:56.668] ..$ timeout : num 120 [05:01:56.668] ..$ rscript : NULL [05:01:56.668] ..$ homogeneous : NULL [05:01:56.668] ..$ rscript_args : NULL [05:01:56.668] ..$ rscript_envs : NULL [05:01:56.668] ..$ rscript_libs : NULL [05:01:56.668] ..$ rscript_startup : NULL [05:01:56.668] ..$ rscript_sh : chr "auto" [05:01:56.668] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:56.668] ..$ methods : logi TRUE [05:01:56.668] ..$ socketOptions : chr "no-delay" [05:01:56.668] ..$ useXDR : logi FALSE [05:01:56.668] ..$ outfile : chr "/dev/null" [05:01:56.668] ..$ renice : int NA [05:01:56.668] ..$ rshcmd : NULL [05:01:56.668] ..$ user : NULL [05:01:56.668] ..$ revtunnel : logi NA [05:01:56.668] ..$ rshlogfile : NULL [05:01:56.668] ..$ rshopts : NULL [05:01:56.668] ..$ rank : int 1 [05:01:56.668] ..$ manual : logi FALSE [05:01:56.668] ..$ dryrun : logi FALSE [05:01:56.668] ..$ quiet : logi FALSE [05:01:56.668] ..$ setup_strategy : chr "parallel" [05:01:56.668] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:56.712] [local output] System call to launch all workers: [05:01:56.712] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc23382f6f.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30973 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:56.712] [local output] Starting PSOCK main server [05:01:56.718] [local output] Workers launched [05:01:56.718] [local output] Waiting for workers to connect back [05:01:56.719] - [local output] 0 workers out of 1 ready [05:01:56.999] - [local output] 0 workers out of 1 ready [05:01:56.999] - [local output] 1 workers out of 1 ready [05:01:57.000] [local output] Launching of 1 workers completed [05:01:57.000] [local output] Number of nodes in cluster: 1 [05:01:57.000] [local output] Collecting session information from 1 workers [05:01:57.002] [local output] - Worker #1 of 1 [05:01:57.002] [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) + } [05:01:57.020] [local output] makeClusterPSOCK() ... [05:01:57.029] [local output] Workers: [n = 1] 'localhost' [05:01:57.034] [local output] Base port: 32089 [05:01:57.034] [local output] Getting setup options for 1 cluster nodes ... [05:01:57.034] [local output] - Node #1 of 1 ... [05:01:57.035] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:57.038] [local output] Rscript port: 32089 [05:01:57.038] [local output] Getting setup options for 1 cluster nodes ... done [05:01:57.039] [local output] - Parallel setup requested for some PSOCK nodes [05:01:57.039] [local output] Setting up PSOCK nodes in parallel [05:01:57.040] List of 36 [05:01:57.040] $ worker : chr "localhost" [05:01:57.040] ..- attr(*, "localhost")= logi TRUE [05:01:57.040] $ master : chr "localhost" [05:01:57.040] $ port : int 32089 [05:01:57.040] $ connectTimeout : num 120 [05:01:57.040] $ timeout : num 120 [05:01:57.040] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:57.040] $ homogeneous : logi TRUE [05:01:57.040] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:57.040] $ rscript_envs : NULL [05:01:57.040] $ rscript_libs : NULL [05:01:57.040] $ rscript_startup : NULL [05:01:57.040] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:57.040] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:57.040] $ methods : logi TRUE [05:01:57.040] $ socketOptions : chr "no-delay" [05:01:57.040] $ useXDR : logi FALSE [05:01:57.040] $ outfile : chr "/dev/null" [05:01:57.040] $ renice : int NA [05:01:57.040] $ rshcmd : NULL [05:01:57.040] $ user : chr(0) [05:01:57.040] $ revtunnel : logi FALSE [05:01:57.040] $ rshlogfile : NULL [05:01:57.040] $ rshopts : chr(0) [05:01:57.040] $ rank : int 1 [05:01:57.040] $ manual : logi FALSE [05:01:57.040] $ dryrun : logi FALSE [05:01:57.040] $ quiet : logi FALSE [05:01:57.040] $ setup_strategy : chr "parallel" [05:01:57.040] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:57.040] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4e05b36.pid" [05:01:57.040] $ rshcmd_label : NULL [05:01:57.040] $ rsh_call : NULL [05:01:57.040] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:57.040] $ localMachine : logi TRUE [05:01:57.040] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:57.040] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:57.040] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:57.040] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:57.040] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:57.040] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:57.040] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:57.040] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:57.040] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:57.040] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:57.040] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:57.040] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:57.040] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:57.040] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:57.040] $ arguments :List of 28 [05:01:57.040] ..$ worker : chr "localhost" [05:01:57.040] ..$ master : NULL [05:01:57.040] ..$ port : int 32089 [05:01:57.040] ..$ connectTimeout : num 120 [05:01:57.040] ..$ timeout : num 120 [05:01:57.040] ..$ rscript : NULL [05:01:57.040] ..$ homogeneous : NULL [05:01:57.040] ..$ rscript_args : NULL [05:01:57.040] ..$ rscript_envs : NULL [05:01:57.040] ..$ rscript_libs : NULL [05:01:57.040] ..$ rscript_startup : NULL [05:01:57.040] ..$ rscript_sh : chr "auto" [05:01:57.040] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:57.040] ..$ methods : logi TRUE [05:01:57.040] ..$ socketOptions : chr "no-delay" [05:01:57.040] ..$ useXDR : logi FALSE [05:01:57.040] ..$ outfile : chr "/dev/null" [05:01:57.040] ..$ renice : int NA [05:01:57.040] ..$ rshcmd : NULL [05:01:57.040] ..$ user : NULL [05:01:57.040] ..$ revtunnel : logi NA [05:01:57.040] ..$ rshlogfile : NULL [05:01:57.040] ..$ rshopts : NULL [05:01:57.040] ..$ rank : int 1 [05:01:57.040] ..$ manual : logi FALSE [05:01:57.040] ..$ dryrun : logi FALSE [05:01:57.040] ..$ quiet : logi FALSE [05:01:57.040] ..$ setup_strategy : chr "parallel" [05:01:57.040] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:57.071] [local output] System call to launch all workers: [05:01:57.071] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4e05b36.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=32089 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:57.071] [local output] Starting PSOCK main server [05:01:57.076] [local output] Workers launched [05:01:57.076] [local output] Waiting for workers to connect back [05:01:57.077] - [local output] 0 workers out of 1 ready [05:01:57.328] - [local output] 0 workers out of 1 ready [05:01:57.329] - [local output] 1 workers out of 1 ready [05:01:57.329] [local output] Launching of 1 workers completed [05:01:57.329] [local output] Number of nodes in cluster: 1 [05:01:57.329] [local output] Collecting session information from 1 workers [05:01:57.331] [local output] - Worker #1 of 1 [05:01:57.331] [local output] makeClusterPSOCK() ... done [05:01:57.336] [local output] makeClusterPSOCK() ... [05:01:57.340] [local output] Workers: [n = 1] 'localhost' [05:01:57.344] [local output] Base port: 38696 [05:01:57.344] [local output] Getting setup options for 1 cluster nodes ... [05:01:57.344] [local output] - Node #1 of 1 ... [05:01:57.345] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:57.347] [local output] Rscript port: 38696 [05:01:57.347] [local output] Getting setup options for 1 cluster nodes ... done [05:01:57.347] [local output] - Parallel setup requested for some PSOCK nodes [05:01:57.348] [local output] Setting up PSOCK nodes in parallel [05:01:57.348] List of 36 [05:01:57.348] $ worker : chr "localhost" [05:01:57.348] ..- attr(*, "localhost")= logi TRUE [05:01:57.348] $ master : chr "localhost" [05:01:57.348] $ port : int 38696 [05:01:57.348] $ connectTimeout : num 120 [05:01:57.348] $ timeout : num 120 [05:01:57.348] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:57.348] $ homogeneous : logi TRUE [05:01:57.348] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:57.348] $ rscript_envs : NULL [05:01:57.348] $ rscript_libs : NULL [05:01:57.348] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [05:01:57.348] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:57.348] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:57.348] $ methods : logi TRUE [05:01:57.348] $ socketOptions : chr "no-delay" [05:01:57.348] $ useXDR : logi FALSE [05:01:57.348] $ outfile : chr "/dev/null" [05:01:57.348] $ renice : int NA [05:01:57.348] $ rshcmd : NULL [05:01:57.348] $ user : chr(0) [05:01:57.348] $ revtunnel : logi FALSE [05:01:57.348] $ rshlogfile : NULL [05:01:57.348] $ rshopts : chr(0) [05:01:57.348] $ rank : int 1 [05:01:57.348] $ manual : logi FALSE [05:01:57.348] $ dryrun : logi FALSE [05:01:57.348] $ quiet : logi FALSE [05:01:57.348] $ setup_strategy : chr "parallel" [05:01:57.348] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:57.348] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc46215aa.pid" [05:01:57.348] $ rshcmd_label : NULL [05:01:57.348] $ rsh_call : NULL [05:01:57.348] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:57.348] $ localMachine : logi TRUE [05:01:57.348] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:57.348] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:57.348] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:57.348] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:57.348] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:57.348] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:57.348] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:57.348] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:57.348] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:57.348] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:57.348] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:57.348] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:57.348] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:57.348] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:57.348] $ arguments :List of 28 [05:01:57.348] ..$ worker : chr "localhost" [05:01:57.348] ..$ master : NULL [05:01:57.348] ..$ port : int 38696 [05:01:57.348] ..$ connectTimeout : num 120 [05:01:57.348] ..$ timeout : num 120 [05:01:57.348] ..$ rscript : NULL [05:01:57.348] ..$ homogeneous : NULL [05:01:57.348] ..$ rscript_args : NULL [05:01:57.348] ..$ rscript_envs : NULL [05:01:57.348] ..$ rscript_libs : NULL [05:01:57.348] ..$ rscript_startup : chr "options(abc = 42L)" [05:01:57.348] ..$ rscript_sh : chr "auto" [05:01:57.348] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:57.348] ..$ methods : logi TRUE [05:01:57.348] ..$ socketOptions : chr "no-delay" [05:01:57.348] ..$ useXDR : logi FALSE [05:01:57.348] ..$ outfile : chr "/dev/null" [05:01:57.348] ..$ renice : int NA [05:01:57.348] ..$ rshcmd : NULL [05:01:57.348] ..$ user : NULL [05:01:57.348] ..$ revtunnel : logi NA [05:01:57.348] ..$ rshlogfile : NULL [05:01:57.348] ..$ rshopts : NULL [05:01:57.348] ..$ rank : int 1 [05:01:57.348] ..$ manual : logi FALSE [05:01:57.348] ..$ dryrun : logi FALSE [05:01:57.348] ..$ quiet : logi FALSE [05:01:57.348] ..$ setup_strategy : chr "parallel" [05:01:57.348] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:57.371] [local output] System call to launch all workers: [05:01:57.372] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc46215aa.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=38696 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:57.372] [local output] Starting PSOCK main server [05:01:57.377] [local output] Workers launched [05:01:57.378] [local output] Waiting for workers to connect back [05:01:57.378] - [local output] 0 workers out of 1 ready [05:01:57.618] - [local output] 0 workers out of 1 ready [05:01:57.619] - [local output] 1 workers out of 1 ready [05:01:57.620] [local output] Launching of 1 workers completed [05:01:57.620] [local output] Number of nodes in cluster: 1 [05:01:57.620] [local output] Collecting session information from 1 workers [05:01:57.622] [local output] - Worker #1 of 1 [05:01:57.622] [local output] makeClusterPSOCK() ... done [05:01:57.629] [local output] makeClusterPSOCK() ... [05:01:57.635] [local output] Workers: [n = 1] 'localhost' [05:01:57.639] [local output] Base port: 39390 [05:01:57.639] [local output] Getting setup options for 1 cluster nodes ... [05:01:57.639] [local output] - Node #1 of 1 ... [05:01:57.640] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:57.642] [local output] Rscript port: 39390 [05:01:57.643] [local output] Getting setup options for 1 cluster nodes ... done [05:01:57.643] [local output] - Parallel setup requested for some PSOCK nodes [05:01:57.643] [local output] Setting up PSOCK nodes in parallel [05:01:57.643] List of 36 [05:01:57.643] $ worker : chr "localhost" [05:01:57.643] ..- attr(*, "localhost")= logi TRUE [05:01:57.643] $ master : chr "localhost" [05:01:57.643] $ port : int 39390 [05:01:57.643] $ connectTimeout : num 120 [05:01:57.643] $ timeout : num 120 [05:01:57.643] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:57.643] $ homogeneous : logi TRUE [05:01:57.643] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:57.643] $ rscript_envs : NULL [05:01:57.643] $ rscript_libs : NULL [05:01:57.643] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [05:01:57.643] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:57.643] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:57.643] $ methods : logi TRUE [05:01:57.643] $ socketOptions : chr "no-delay" [05:01:57.643] $ useXDR : logi FALSE [05:01:57.643] $ outfile : chr "/dev/null" [05:01:57.643] $ renice : int NA [05:01:57.643] $ rshcmd : NULL [05:01:57.643] $ user : chr(0) [05:01:57.643] $ revtunnel : logi FALSE [05:01:57.643] $ rshlogfile : NULL [05:01:57.643] $ rshopts : chr(0) [05:01:57.643] $ rank : int 1 [05:01:57.643] $ manual : logi FALSE [05:01:57.643] $ dryrun : logi FALSE [05:01:57.643] $ quiet : logi FALSE [05:01:57.643] $ setup_strategy : chr "parallel" [05:01:57.643] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:57.643] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc746d9d1.pid" [05:01:57.643] $ rshcmd_label : NULL [05:01:57.643] $ rsh_call : NULL [05:01:57.643] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:57.643] $ localMachine : logi TRUE [05:01:57.643] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:57.643] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:57.643] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:57.643] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:57.643] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:57.643] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:57.643] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:57.643] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:57.643] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:57.643] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:57.643] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:57.643] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:57.643] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:57.643] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:57.643] $ arguments :List of 28 [05:01:57.643] ..$ worker : chr "localhost" [05:01:57.643] ..$ master : NULL [05:01:57.643] ..$ port : int 39390 [05:01:57.643] ..$ connectTimeout : num 120 [05:01:57.643] ..$ timeout : num 120 [05:01:57.643] ..$ rscript : NULL [05:01:57.643] ..$ homogeneous : NULL [05:01:57.643] ..$ rscript_args : NULL [05:01:57.643] ..$ rscript_envs : NULL [05:01:57.643] ..$ rscript_libs : NULL [05:01:57.643] ..$ rscript_startup : language options(abc = 42L) [05:01:57.643] ..$ rscript_sh : chr "auto" [05:01:57.643] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:57.643] ..$ methods : logi TRUE [05:01:57.643] ..$ socketOptions : chr "no-delay" [05:01:57.643] ..$ useXDR : logi FALSE [05:01:57.643] ..$ outfile : chr "/dev/null" [05:01:57.643] ..$ renice : int NA [05:01:57.643] ..$ rshcmd : NULL [05:01:57.643] ..$ user : NULL [05:01:57.643] ..$ revtunnel : logi NA [05:01:57.643] ..$ rshlogfile : NULL [05:01:57.643] ..$ rshopts : NULL [05:01:57.643] ..$ rank : int 1 [05:01:57.643] ..$ manual : logi FALSE [05:01:57.643] ..$ dryrun : logi FALSE [05:01:57.643] ..$ quiet : logi FALSE [05:01:57.643] ..$ setup_strategy : chr "parallel" [05:01:57.643] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:57.683] [local output] System call to launch all workers: [05:01:57.683] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc746d9d1.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=39390 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:57.684] [local output] Starting PSOCK main server [05:01:57.690] [local output] Workers launched [05:01:57.691] [local output] Waiting for workers to connect back [05:01:57.691] - [local output] 0 workers out of 1 ready [05:01:57.952] - [local output] 0 workers out of 1 ready [05:01:57.953] - [local output] 1 workers out of 1 ready [05:01:57.954] [local output] Launching of 1 workers completed [05:01:57.954] [local output] Number of nodes in cluster: 1 [05:01:57.954] [local output] Collecting session information from 1 workers [05:01:57.956] [local output] - Worker #1 of 1 [05:01:57.957] [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) + } [05:01:58.016] [local output] makeClusterPSOCK() ... [05:01:58.022] [local output] Workers: [n = 2] 'localhost', 'localhost' [05:01:58.027] [local output] Base port: 35443 [05:01:58.027] [local output] Getting setup options for 2 cluster nodes ... [05:01:58.028] [local output] - Node #1 of 2 ... [05:01:58.029] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:58.031] [local output] Rscript port: 35443 [05:01:58.032] [local output] - Node #2 of 2 ... [05:01:58.032] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:58.034] [local output] Rscript port: 35443 [05:01:58.035] [local output] Getting setup options for 2 cluster nodes ... done [05:01:58.036] [local output] Creating node #1 of 2 ... [05:01:58.036] [local output] - setting up node [05:01:58.036] [local output] - attempt #1 of 3 [05:01:58.037] [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:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc33273548.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=35443 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [05:01:58.043] [local output] - Exit code of system() call: 0 [05:01:58.043] [local output] Waiting for worker #1 on 'localhost' to connect back [05:01:58.278] [local output] Connection with worker #1 on 'localhost' established [05:01:58.279] [local output] Creating node #1 of 2 ... done [05:01:58.279] [local output] Creating node #2 of 2 ... [05:01:58.280] [local output] - setting up node [05:01:58.280] [local output] - attempt #1 of 3 [05:01:58.280] [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:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=2.parallelly.parent=58828.e5cc29da69f7.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=35443 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [05:01:58.287] [local output] - Exit code of system() call: 0 [05:01:58.287] [local output] Waiting for worker #2 on 'localhost' to connect back [05:01:58.515] [local output] Connection with worker #2 on 'localhost' established [05:01:58.516] [local output] Creating node #2 of 2 ... done [05:01:58.516] [local output] Launching of 2 workers completed [05:01:58.516] [local output] Number of nodes in cluster: 2 [05:01:58.517] [local output] Collecting session information from 2 workers [05:01:58.518] [local output] - Worker #1 of 2 [05:01:58.520] [local output] - Worker #2 of 2 [05:01:58.520] [local output] makeClusterPSOCK() ... done user system elapsed 0.03 0.00 0.50 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-12-02 r87417 ucrt), platform x86_64-w64-mingw32) [05:01:58.564] [local output] makeClusterPSOCK() ... [05:01:58.567] [local output] Workers: [n = 2] 'localhost', 'localhost' [05:01:58.570] [local output] Base port: 38960 [05:01:58.571] [local output] Getting setup options for 2 cluster nodes ... [05:01:58.571] [local output] - Node #1 of 2 ... [05:01:58.571] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:58.573] [local output] Rscript port: 38960 [05:01:58.573] [local output] - Node #2 of 2 ... [05:01:58.574] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:58.575] [local output] Rscript port: 38960 [05:01:58.576] [local output] Getting setup options for 2 cluster nodes ... done [05:01:58.576] [local output] - Parallel setup requested for some PSOCK nodes [05:01:58.576] [local output] Setting up PSOCK nodes in parallel [05:01:58.577] List of 36 [05:01:58.577] $ worker : chr "localhost" [05:01:58.577] ..- attr(*, "localhost")= logi TRUE [05:01:58.577] $ master : chr "localhost" [05:01:58.577] $ port : int 38960 [05:01:58.577] $ connectTimeout : num 120 [05:01:58.577] $ timeout : num 120 [05:01:58.577] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:58.577] $ homogeneous : logi TRUE [05:01:58.577] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:58.577] $ rscript_envs : NULL [05:01:58.577] $ rscript_libs : NULL [05:01:58.577] $ rscript_startup : NULL [05:01:58.577] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:58.577] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:58.577] $ methods : logi TRUE [05:01:58.577] $ socketOptions : chr "no-delay" [05:01:58.577] $ useXDR : logi FALSE [05:01:58.577] $ outfile : chr "/dev/null" [05:01:58.577] $ renice : int NA [05:01:58.577] $ rshcmd : NULL [05:01:58.577] $ user : chr(0) [05:01:58.577] $ revtunnel : logi FALSE [05:01:58.577] $ rshlogfile : NULL [05:01:58.577] $ rshopts : chr(0) [05:01:58.577] $ rank : int 1 [05:01:58.577] $ manual : logi FALSE [05:01:58.577] $ dryrun : logi FALSE [05:01:58.577] $ quiet : logi FALSE [05:01:58.577] $ setup_strategy : chr "parallel" [05:01:58.577] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:58.577] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc13adaf.pid" [05:01:58.577] $ rshcmd_label : NULL [05:01:58.577] $ rsh_call : NULL [05:01:58.577] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:58.577] $ localMachine : logi TRUE [05:01:58.577] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:58.577] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:58.577] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:58.577] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:58.577] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:58.577] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:58.577] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:58.577] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:58.577] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:58.577] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:58.577] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:58.577] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:58.577] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:58.577] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:58.577] $ arguments :List of 28 [05:01:58.577] ..$ worker : chr "localhost" [05:01:58.577] ..$ master : NULL [05:01:58.577] ..$ port : int 38960 [05:01:58.577] ..$ connectTimeout : num 120 [05:01:58.577] ..$ timeout : num 120 [05:01:58.577] ..$ rscript : NULL [05:01:58.577] ..$ homogeneous : NULL [05:01:58.577] ..$ rscript_args : NULL [05:01:58.577] ..$ rscript_envs : NULL [05:01:58.577] ..$ rscript_libs : NULL [05:01:58.577] ..$ rscript_startup : NULL [05:01:58.577] ..$ rscript_sh : chr "auto" [05:01:58.577] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:58.577] ..$ methods : logi TRUE [05:01:58.577] ..$ socketOptions : chr "no-delay" [05:01:58.577] ..$ useXDR : logi FALSE [05:01:58.577] ..$ outfile : chr "/dev/null" [05:01:58.577] ..$ renice : int NA [05:01:58.577] ..$ rshcmd : NULL [05:01:58.577] ..$ user : NULL [05:01:58.577] ..$ revtunnel : logi NA [05:01:58.577] ..$ rshlogfile : NULL [05:01:58.577] ..$ rshopts : NULL [05:01:58.577] ..$ rank : int 1 [05:01:58.577] ..$ manual : logi FALSE [05:01:58.577] ..$ dryrun : logi FALSE [05:01:58.577] ..$ quiet : logi FALSE [05:01:58.577] ..$ setup_strategy : chr "parallel" [05:01:58.577] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:58.598] [local output] System call to launch all workers: [05:01:58.598] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc13adaf.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38960 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:58.598] [local output] Starting PSOCK main server [05:01:58.604] [local output] Workers launched [05:01:58.604] [local output] Waiting for workers to connect back [05:01:58.605] - [local output] 0 workers out of 2 ready [05:01:58.847] - [local output] 0 workers out of 2 ready [05:01:58.847] - [local output] 1 workers out of 2 ready [05:01:58.862] - [local output] 1 workers out of 2 ready [05:01:58.863] - [local output] 2 workers out of 2 ready [05:01:58.863] [local output] Launching of 2 workers completed [05:01:58.863] [local output] Number of nodes in cluster: 2 [05:01:58.863] [local output] Collecting session information from 2 workers [05:01:58.865] [local output] - Worker #1 of 2 [05:01:58.866] [local output] - Worker #2 of 2 [05:01:58.866] [local output] makeClusterPSOCK() ... done user system elapsed 0.03 0.00 0.30 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-12-02 r87417 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 [05:01:58.877] [local output] makeClusterPSOCK() ... [05:01:58.882] [local output] Workers: [n = 1] 'localhost' [05:01:58.885] [local output] Base port: 27192 [05:01:58.886] [local output] Getting setup options for 1 cluster nodes ... [05:01:58.886] [local output] - Node #1 of 1 ... [05:01:58.887] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:58.889] [local output] Rscript port: 27192 [05:01:58.890] [local output] Getting setup options for 1 cluster nodes ... done [05:01:58.890] [local output] - Parallel setup requested for some PSOCK nodes [05:01:58.891] [local output] Setting up PSOCK nodes in parallel [05:01:58.891] List of 36 [05:01:58.891] $ worker : chr "localhost" [05:01:58.891] ..- attr(*, "localhost")= logi TRUE [05:01:58.891] $ master : chr "localhost" [05:01:58.891] $ port : int 27192 [05:01:58.891] $ connectTimeout : num 120 [05:01:58.891] $ timeout : num 120 [05:01:58.891] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:58.891] $ homogeneous : logi TRUE [05:01:58.891] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:58.891] $ rscript_envs : NULL [05:01:58.891] $ rscript_libs : NULL [05:01:58.891] $ rscript_startup : NULL [05:01:58.891] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:58.891] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:58.891] $ methods : logi TRUE [05:01:58.891] $ socketOptions : chr "no-delay" [05:01:58.891] $ useXDR : logi FALSE [05:01:58.891] $ outfile : chr "/dev/null" [05:01:58.891] $ renice : int NA [05:01:58.891] $ rshcmd : NULL [05:01:58.891] $ user : chr(0) [05:01:58.891] $ revtunnel : logi FALSE [05:01:58.891] $ rshlogfile : NULL [05:01:58.891] $ rshopts : chr(0) [05:01:58.891] $ rank : int 1 [05:01:58.891] $ manual : logi FALSE [05:01:58.891] $ dryrun : logi FALSE [05:01:58.891] $ quiet : logi FALSE [05:01:58.891] $ setup_strategy : chr "parallel" [05:01:58.891] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:58.891] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4262680b.pid" [05:01:58.891] $ rshcmd_label : NULL [05:01:58.891] $ rsh_call : NULL [05:01:58.891] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:58.891] $ localMachine : logi TRUE [05:01:58.891] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:58.891] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:58.891] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:58.891] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:58.891] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:58.891] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:58.891] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:58.891] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:58.891] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:58.891] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:58.891] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:58.891] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:58.891] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:58.891] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:58.891] $ arguments :List of 28 [05:01:58.891] ..$ worker : chr "localhost" [05:01:58.891] ..$ master : NULL [05:01:58.891] ..$ port : int 27192 [05:01:58.891] ..$ connectTimeout : num 120 [05:01:58.891] ..$ timeout : num 120 [05:01:58.891] ..$ rscript : NULL [05:01:58.891] ..$ homogeneous : NULL [05:01:58.891] ..$ rscript_args : NULL [05:01:58.891] ..$ rscript_envs : NULL [05:01:58.891] ..$ rscript_libs : NULL [05:01:58.891] ..$ rscript_startup : NULL [05:01:58.891] ..$ rscript_sh : chr "auto" [05:01:58.891] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:58.891] ..$ methods : logi TRUE [05:01:58.891] ..$ socketOptions : chr "no-delay" [05:01:58.891] ..$ useXDR : logi FALSE [05:01:58.891] ..$ outfile : chr "/dev/null" [05:01:58.891] ..$ renice : int NA [05:01:58.891] ..$ rshcmd : NULL [05:01:58.891] ..$ user : NULL [05:01:58.891] ..$ revtunnel : logi NA [05:01:58.891] ..$ rshlogfile : NULL [05:01:58.891] ..$ rshopts : NULL [05:01:58.891] ..$ rank : int 1 [05:01:58.891] ..$ manual : logi FALSE [05:01:58.891] ..$ dryrun : logi FALSE [05:01:58.891] ..$ quiet : logi FALSE [05:01:58.891] ..$ setup_strategy : chr "parallel" [05:01:58.891] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:58.922] [local output] System call to launch all workers: [05:01:58.922] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4262680b.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=27192 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:58.922] [local output] Starting PSOCK main server [05:01:58.926] [local output] Workers launched [05:01:58.927] [local output] Waiting for workers to connect back [05:01:58.927] - [local output] 0 workers out of 1 ready [05:01:59.142] - [local output] 0 workers out of 1 ready [05:01:59.143] - [local output] 1 workers out of 1 ready [05:01:59.143] [local output] Launching of 1 workers completed [05:01:59.143] [local output] Number of nodes in cluster: 1 [05:01:59.144] [local output] Collecting session information from 1 workers [05:01:59.145] [local output] - Worker #1 of 1 [05:01:59.146] [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) [05:01:59.152] [local output] makeClusterPSOCK() ... [05:01:59.158] [local output] Workers: [n = 1] 'localhost' [05:01:59.163] [local output] Base port: 39432 [05:01:59.164] [local output] Getting setup options for 1 cluster nodes ... [05:01:59.164] [local output] - Node #1 of 1 ... [05:01:59.164] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:59.166] [local output] Rscript port: 39432 [05:01:59.167] [local output] Getting setup options for 1 cluster nodes ... done [05:01:59.167] [local output] - Parallel setup requested for some PSOCK nodes [05:01:59.167] [local output] Setting up PSOCK nodes in parallel [05:01:59.168] List of 36 [05:01:59.168] $ worker : chr "localhost" [05:01:59.168] ..- attr(*, "localhost")= logi TRUE [05:01:59.168] $ master : chr "localhost" [05:01:59.168] $ port : int 39432 [05:01:59.168] $ connectTimeout : num 120 [05:01:59.168] $ timeout : num 120 [05:01:59.168] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:59.168] $ homogeneous : logi TRUE [05:01:59.168] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:59.168] $ rscript_envs : NULL [05:01:59.168] $ rscript_libs : NULL [05:01:59.168] $ rscript_startup : NULL [05:01:59.168] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:59.168] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:59.168] $ methods : logi TRUE [05:01:59.168] $ socketOptions : chr "no-delay" [05:01:59.168] $ useXDR : logi FALSE [05:01:59.168] $ outfile : chr "/dev/null" [05:01:59.168] $ renice : int NA [05:01:59.168] $ rshcmd : NULL [05:01:59.168] $ user : chr(0) [05:01:59.168] $ revtunnel : logi FALSE [05:01:59.168] $ rshlogfile : NULL [05:01:59.168] $ rshopts : chr(0) [05:01:59.168] $ rank : int 1 [05:01:59.168] $ manual : logi FALSE [05:01:59.168] $ dryrun : logi FALSE [05:01:59.168] $ quiet : logi FALSE [05:01:59.168] $ setup_strategy : chr "parallel" [05:01:59.168] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:59.168] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc7ab91f6a.pid" [05:01:59.168] $ rshcmd_label : NULL [05:01:59.168] $ rsh_call : NULL [05:01:59.168] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:59.168] $ localMachine : logi TRUE [05:01:59.168] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:59.168] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:59.168] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:59.168] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:59.168] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:59.168] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:59.168] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:59.168] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:59.168] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:59.168] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:59.168] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:59.168] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:59.168] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:59.168] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:59.168] $ arguments :List of 28 [05:01:59.168] ..$ worker : chr "localhost" [05:01:59.168] ..$ master : NULL [05:01:59.168] ..$ port : int 39432 [05:01:59.168] ..$ connectTimeout : num 120 [05:01:59.168] ..$ timeout : num 120 [05:01:59.168] ..$ rscript : NULL [05:01:59.168] ..$ homogeneous : NULL [05:01:59.168] ..$ rscript_args : NULL [05:01:59.168] ..$ rscript_envs : NULL [05:01:59.168] ..$ rscript_libs : NULL [05:01:59.168] ..$ rscript_startup : NULL [05:01:59.168] ..$ rscript_sh : chr "auto" [05:01:59.168] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:59.168] ..$ methods : logi TRUE [05:01:59.168] ..$ socketOptions : chr "no-delay" [05:01:59.168] ..$ useXDR : logi FALSE [05:01:59.168] ..$ outfile : chr "/dev/null" [05:01:59.168] ..$ renice : int NA [05:01:59.168] ..$ rshcmd : NULL [05:01:59.168] ..$ user : NULL [05:01:59.168] ..$ revtunnel : logi NA [05:01:59.168] ..$ rshlogfile : NULL [05:01:59.168] ..$ rshopts : NULL [05:01:59.168] ..$ rank : int 1 [05:01:59.168] ..$ manual : logi FALSE [05:01:59.168] ..$ dryrun : logi FALSE [05:01:59.168] ..$ quiet : logi FALSE [05:01:59.168] ..$ setup_strategy : chr "parallel" [05:01:59.168] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:59.208] [local output] System call to launch all workers: [05:01:59.208] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc7ab91f6a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=39432 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:59.209] [local output] Starting PSOCK main server [05:01:59.214] [local output] Workers launched [05:01:59.215] [local output] Waiting for workers to connect back [05:01:59.215] - [local output] 0 workers out of 1 ready [05:01:59.446] - [local output] 0 workers out of 1 ready [05:01:59.447] - [local output] 1 workers out of 1 ready [05:01:59.447] [local output] Launching of 1 workers completed [05:01:59.448] [local output] Number of nodes in cluster: 1 [05:01:59.448] [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 = "") [05:01:59.455] [local output] makeClusterPSOCK() ... [05:01:59.461] [local output] Workers: [n = 1] 'localhost' [05:01:59.465] [local output] Base port: 38540 [05:01:59.466] [local output] Getting setup options for 1 cluster nodes ... [05:01:59.466] [local output] - Node #1 of 1 ... [05:01:59.467] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:59.470] [local output] Rscript port: 38540 [05:01:59.470] [local output] Getting setup options for 1 cluster nodes ... done [05:01:59.471] [local output] - Parallel setup requested for some PSOCK nodes [05:01:59.471] [local output] Setting up PSOCK nodes in parallel [05:01:59.472] List of 36 [05:01:59.472] $ worker : chr "localhost" [05:01:59.472] ..- attr(*, "localhost")= logi TRUE [05:01:59.472] $ master : chr "localhost" [05:01:59.472] $ port : int 38540 [05:01:59.472] $ connectTimeout : num 120 [05:01:59.472] $ timeout : num 120 [05:01:59.472] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:59.472] $ homogeneous : logi TRUE [05:01:59.472] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:59.472] $ rscript_envs : NULL [05:01:59.472] $ rscript_libs : NULL [05:01:59.472] $ rscript_startup : NULL [05:01:59.472] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:59.472] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:59.472] $ methods : logi TRUE [05:01:59.472] $ socketOptions : chr "no-delay" [05:01:59.472] $ useXDR : logi FALSE [05:01:59.472] $ outfile : chr "" [05:01:59.472] $ renice : int NA [05:01:59.472] $ rshcmd : NULL [05:01:59.472] $ user : chr(0) [05:01:59.472] $ revtunnel : logi FALSE [05:01:59.472] $ rshlogfile : NULL [05:01:59.472] $ rshopts : chr(0) [05:01:59.472] $ rank : int 1 [05:01:59.472] $ manual : logi FALSE [05:01:59.472] $ dryrun : logi FALSE [05:01:59.472] $ quiet : logi FALSE [05:01:59.472] $ setup_strategy : chr "parallel" [05:01:59.472] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:59.472] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cccfb15c9.pid" [05:01:59.472] $ rshcmd_label : NULL [05:01:59.472] $ rsh_call : NULL [05:01:59.472] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:59.472] $ localMachine : logi TRUE [05:01:59.472] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:59.472] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:59.472] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:59.472] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:59.472] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:59.472] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:59.472] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:59.472] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:59.472] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:59.472] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:59.472] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:59.472] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:59.472] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:59.472] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:59.472] $ arguments :List of 28 [05:01:59.472] ..$ worker : chr "localhost" [05:01:59.472] ..$ master : NULL [05:01:59.472] ..$ port : int 38540 [05:01:59.472] ..$ connectTimeout : num 120 [05:01:59.472] ..$ timeout : num 120 [05:01:59.472] ..$ rscript : NULL [05:01:59.472] ..$ homogeneous : NULL [05:01:59.472] ..$ rscript_args : NULL [05:01:59.472] ..$ rscript_envs : NULL [05:01:59.472] ..$ rscript_libs : NULL [05:01:59.472] ..$ rscript_startup : NULL [05:01:59.472] ..$ rscript_sh : chr "auto" [05:01:59.472] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:59.472] ..$ methods : logi TRUE [05:01:59.472] ..$ socketOptions : chr "no-delay" [05:01:59.472] ..$ useXDR : logi FALSE [05:01:59.472] ..$ outfile : chr "" [05:01:59.472] ..$ renice : int NA [05:01:59.472] ..$ rshcmd : NULL [05:01:59.472] ..$ user : NULL [05:01:59.472] ..$ revtunnel : logi NA [05:01:59.472] ..$ rshlogfile : NULL [05:01:59.472] ..$ rshopts : NULL [05:01:59.472] ..$ rank : int 1 [05:01:59.472] ..$ manual : logi FALSE [05:01:59.472] ..$ dryrun : logi FALSE [05:01:59.472] ..$ quiet : logi FALSE [05:01:59.472] ..$ setup_strategy : chr "parallel" [05:01:59.472] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:59.509] [local output] System call to launch all workers: [05:01:59.510] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cccfb15c9.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=38540 OUT= TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:59.510] [local output] Starting PSOCK main server [05:01:59.516] [local output] Workers launched [05:01:59.516] [local output] Waiting for workers to connect back [05:01:59.516] - [local output] 0 workers out of 1 ready starting worker pid=177936 on localhost:38540 at 05:01:59.725 [05:01:59.736] - [local output] 0 workers out of 1 ready [05:01:59.737] - [local output] 1 workers out of 1 ready [05:01:59.737] [local output] Launching of 1 workers completed [05:01:59.738] [local output] Number of nodes in cluster: 1 [05:01:59.738] [local output] Collecting session information from 1 workers [05:01:59.740] [local output] - Worker #1 of 1 [05:01:59.741] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-12-02 r87417 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) [05:01:59.753] [local output] makeClusterPSOCK() ... [05:01:59.757] [local output] Workers: [n = 1] 'localhost' [05:01:59.761] [local output] Base port: 21271 [05:01:59.761] [local output] Getting setup options for 1 cluster nodes ... [05:01:59.762] [local output] - Node #1 of 1 ... [05:01:59.762] [local output] localMachine=TRUE => revtunnel=FALSE [05:01:59.764] [local output] Rscript port: 21271 [05:01:59.765] [local output] Getting setup options for 1 cluster nodes ... done [05:01:59.765] [local output] - Parallel setup requested for some PSOCK nodes [05:01:59.766] [local output] Setting up PSOCK nodes in parallel [05:01:59.766] List of 36 [05:01:59.766] $ worker : chr "localhost" [05:01:59.766] ..- attr(*, "localhost")= logi TRUE [05:01:59.766] $ master : chr "localhost" [05:01:59.766] $ port : int 21271 [05:01:59.766] $ connectTimeout : num 120 [05:01:59.766] $ timeout : num 120 [05:01:59.766] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:01:59.766] $ homogeneous : logi TRUE [05:01:59.766] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:01:59.766] $ rscript_envs : NULL [05:01:59.766] $ rscript_libs : NULL [05:01:59.766] $ rscript_startup : NULL [05:01:59.766] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:01:59.766] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:59.766] $ methods : logi TRUE [05:01:59.766] $ socketOptions : chr "no-delay" [05:01:59.766] $ useXDR : logi FALSE [05:01:59.766] $ outfile : chr "/dev/null" [05:01:59.766] $ renice : int NA [05:01:59.766] $ rshcmd : NULL [05:01:59.766] $ user : chr(0) [05:01:59.766] $ revtunnel : logi FALSE [05:01:59.766] $ rshlogfile : NULL [05:01:59.766] $ rshopts : chr(0) [05:01:59.766] $ rank : int 1 [05:01:59.766] $ manual : logi FALSE [05:01:59.766] $ dryrun : logi FALSE [05:01:59.766] $ quiet : logi FALSE [05:01:59.766] $ setup_strategy : chr "parallel" [05:01:59.766] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:59.766] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc2a8e4200.pid" [05:01:59.766] $ rshcmd_label : NULL [05:01:59.766] $ rsh_call : NULL [05:01:59.766] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:01:59.766] $ localMachine : logi TRUE [05:01:59.766] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:01:59.766] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:01:59.766] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:01:59.766] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:01:59.766] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:01:59.766] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:01:59.766] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:01:59.766] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:01:59.766] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:01:59.766] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:01:59.766] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:01:59.766] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:01:59.766] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:01:59.766] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:01:59.766] $ arguments :List of 28 [05:01:59.766] ..$ worker : chr "localhost" [05:01:59.766] ..$ master : NULL [05:01:59.766] ..$ port : int 21271 [05:01:59.766] ..$ connectTimeout : num 120 [05:01:59.766] ..$ timeout : num 120 [05:01:59.766] ..$ rscript : NULL [05:01:59.766] ..$ homogeneous : NULL [05:01:59.766] ..$ rscript_args : NULL [05:01:59.766] ..$ rscript_envs : NULL [05:01:59.766] ..$ rscript_libs : NULL [05:01:59.766] ..$ rscript_startup : NULL [05:01:59.766] ..$ rscript_sh : chr "auto" [05:01:59.766] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:01:59.766] ..$ methods : logi TRUE [05:01:59.766] ..$ socketOptions : chr "no-delay" [05:01:59.766] ..$ useXDR : logi FALSE [05:01:59.766] ..$ outfile : chr "/dev/null" [05:01:59.766] ..$ renice : int NA [05:01:59.766] ..$ rshcmd : NULL [05:01:59.766] ..$ user : NULL [05:01:59.766] ..$ revtunnel : logi NA [05:01:59.766] ..$ rshlogfile : NULL [05:01:59.766] ..$ rshopts : NULL [05:01:59.766] ..$ rank : int 1 [05:01:59.766] ..$ manual : logi FALSE [05:01:59.766] ..$ dryrun : logi FALSE [05:01:59.766] ..$ quiet : logi FALSE [05:01:59.766] ..$ setup_strategy : chr "parallel" [05:01:59.766] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:01:59.797] [local output] System call to launch all workers: [05:01:59.797] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc2a8e4200.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=21271 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:01:59.797] [local output] Starting PSOCK main server [05:01:59.804] [local output] Workers launched [05:01:59.804] [local output] Waiting for workers to connect back [05:01:59.804] - [local output] 0 workers out of 1 ready [05:02:00.057] - [local output] 0 workers out of 1 ready [05:02:00.057] - [local output] 1 workers out of 1 ready [05:02:00.058] [local output] Launching of 1 workers completed [05:02:00.058] [local output] Number of nodes in cluster: 1 [05:02:00.058] [local output] Collecting session information from 1 workers [05:02:00.060] [local output] - Worker #1 of 1 [05:02:00.060] [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' [05:02:00.073] [local output] makeClusterPSOCK() ... [05:02:00.077] [local output] Workers: [n = 1] 'localhost' [05:02:00.081] [local output] Base port: 21766 [05:02:00.082] [local output] Getting setup options for 1 cluster nodes ... [05:02:00.082] [local output] - Node #1 of 1 ... [05:02:00.083] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:00.084] Testing if worker's PID can be inferred: '"D:\RCompile\recent\R\bin\x64\Rterm.exe" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4a733f1d.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4a733f1d.pid\")"' [05:02:00.420] - Possible to infer worker's PID: TRUE [05:02:00.421] [local output] Rscript port: 21766 [05:02:00.422] [local output] Getting setup options for 1 cluster nodes ... done [05:02:00.422] [local output] - Parallel setup requested for some PSOCK nodes [05:02:00.423] [local output] Setting up PSOCK nodes in parallel [05:02:00.424] List of 36 [05:02:00.424] $ worker : chr "localhost" [05:02:00.424] ..- attr(*, "localhost")= logi TRUE [05:02:00.424] $ master : chr "localhost" [05:02:00.424] $ port : int 21766 [05:02:00.424] $ connectTimeout : num 120 [05:02:00.424] $ timeout : num 120 [05:02:00.424] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [05:02:00.424] $ homogeneous : logi TRUE [05:02:00.424] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [05:02:00.424] $ rscript_envs : NULL [05:02:00.424] $ rscript_libs : NULL [05:02:00.424] $ rscript_startup : NULL [05:02:00.424] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:00.424] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:02:00.424] $ methods : logi TRUE [05:02:00.424] $ socketOptions : chr "no-delay" [05:02:00.424] $ useXDR : logi FALSE [05:02:00.424] $ outfile : chr "/dev/null" [05:02:00.424] $ renice : int NA [05:02:00.424] $ rshcmd : NULL [05:02:00.424] $ user : chr(0) [05:02:00.424] $ revtunnel : logi FALSE [05:02:00.424] $ rshlogfile : NULL [05:02:00.424] $ rshopts : chr(0) [05:02:00.424] $ rank : int 1 [05:02:00.424] $ manual : logi FALSE [05:02:00.424] $ dryrun : logi FALSE [05:02:00.424] $ quiet : logi FALSE [05:02:00.424] $ setup_strategy : chr "parallel" [05:02:00.424] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [05:02:00.424] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4a733f1d.pid" [05:02:00.424] $ rshcmd_label : NULL [05:02:00.424] $ rsh_call : NULL [05:02:00.424] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [05:02:00.424] $ localMachine : logi TRUE [05:02:00.424] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:00.424] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:00.424] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:00.424] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:00.424] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:00.424] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:00.424] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:00.424] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:00.424] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:00.424] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:00.424] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:00.424] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:00.424] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:00.424] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:00.424] $ arguments :List of 28 [05:02:00.424] ..$ worker : chr "localhost" [05:02:00.424] ..$ master : NULL [05:02:00.424] ..$ port : int 21766 [05:02:00.424] ..$ connectTimeout : num 120 [05:02:00.424] ..$ timeout : num 120 [05:02:00.424] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [05:02:00.424] ..$ homogeneous : NULL [05:02:00.424] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [05:02:00.424] ..$ rscript_envs : NULL [05:02:00.424] ..$ rscript_libs : NULL [05:02:00.424] ..$ rscript_startup : NULL [05:02:00.424] ..$ rscript_sh : chr "auto" [05:02:00.424] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:02:00.424] ..$ methods : logi TRUE [05:02:00.424] ..$ socketOptions : chr "no-delay" [05:02:00.424] ..$ useXDR : logi FALSE [05:02:00.424] ..$ outfile : chr "/dev/null" [05:02:00.424] ..$ renice : int NA [05:02:00.424] ..$ rshcmd : NULL [05:02:00.424] ..$ user : NULL [05:02:00.424] ..$ revtunnel : logi NA [05:02:00.424] ..$ rshlogfile : NULL [05:02:00.424] ..$ rshopts : NULL [05:02:00.424] ..$ rank : int 1 [05:02:00.424] ..$ manual : logi FALSE [05:02:00.424] ..$ dryrun : logi FALSE [05:02:00.424] ..$ quiet : logi FALSE [05:02:00.424] ..$ setup_strategy : chr "parallel" [05:02:00.424] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:00.460] [local output] System call to launch all workers: [05:02:00.460] [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:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4a733f1d.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=21766 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:00.460] [local output] Starting PSOCK main server [05:02:00.466] [local output] Workers launched [05:02:00.466] [local output] Waiting for workers to connect back [05:02:00.467] - [local output] 0 workers out of 1 ready [05:02:00.692] - [local output] 0 workers out of 1 ready [05:02:00.693] - [local output] 1 workers out of 1 ready [05:02:00.693] [local output] Launching of 1 workers completed [05:02:00.693] [local output] Number of nodes in cluster: 1 [05:02:00.694] [local output] Collecting session information from 1 workers [05:02:00.695] [local output] - Worker #1 of 1 [05:02:00.695] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [05:02:00.700] [local output] makeClusterPSOCK() ... [05:02:00.706] [local output] Workers: [n = 1] 'localhost' [05:02:00.710] [local output] Base port: 23516 [05:02:00.711] [local output] Getting setup options for 1 cluster nodes ... [05:02:00.711] [local output] - Node #1 of 1 ... [05:02:00.712] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:00.715] [local output] Rscript port: 23516 [05:02:00.715] [local output] Getting setup options for 1 cluster nodes ... done [05:02:00.715] [local output] - Parallel setup requested for some PSOCK nodes [05:02:00.716] [local output] Setting up PSOCK nodes in parallel [05:02:00.716] List of 36 [05:02:00.716] $ worker : chr "localhost" [05:02:00.716] ..- attr(*, "localhost")= logi TRUE [05:02:00.716] $ master : chr "localhost" [05:02:00.716] $ port : int 23516 [05:02:00.716] $ connectTimeout : num 120 [05:02:00.716] $ timeout : num 120 [05:02:00.716] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [05:02:00.716] $ homogeneous : logi TRUE [05:02:00.716] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [05:02:00.716] $ rscript_envs : NULL [05:02:00.716] $ rscript_libs : NULL [05:02:00.716] $ rscript_startup : NULL [05:02:00.716] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:00.716] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:02:00.716] $ methods : logi TRUE [05:02:00.716] $ socketOptions : chr "no-delay" [05:02:00.716] $ useXDR : logi FALSE [05:02:00.716] $ outfile : chr "/dev/null" [05:02:00.716] $ renice : int NA [05:02:00.716] $ rshcmd : NULL [05:02:00.716] $ user : chr(0) [05:02:00.716] $ revtunnel : logi FALSE [05:02:00.716] $ rshlogfile : NULL [05:02:00.716] $ rshopts : chr(0) [05:02:00.716] $ rank : int 1 [05:02:00.716] $ manual : logi FALSE [05:02:00.716] $ dryrun : logi FALSE [05:02:00.716] $ quiet : logi FALSE [05:02:00.716] $ setup_strategy : chr "parallel" [05:02:00.716] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [05:02:00.716] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5ccd2830b6.pid" [05:02:00.716] $ rshcmd_label : NULL [05:02:00.716] $ rsh_call : NULL [05:02:00.716] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [05:02:00.716] $ localMachine : logi TRUE [05:02:00.716] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:00.716] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:00.716] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:00.716] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:00.716] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:00.716] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:00.716] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:00.716] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:00.716] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:00.716] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:00.716] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:00.716] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:00.716] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:00.716] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:00.716] $ arguments :List of 28 [05:02:00.716] ..$ worker : chr "localhost" [05:02:00.716] ..$ master : NULL [05:02:00.716] ..$ port : int 23516 [05:02:00.716] ..$ connectTimeout : num 120 [05:02:00.716] ..$ timeout : num 120 [05:02:00.716] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [05:02:00.716] ..$ homogeneous : NULL [05:02:00.716] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [05:02:00.716] ..$ rscript_envs : NULL [05:02:00.716] ..$ rscript_libs : NULL [05:02:00.716] ..$ rscript_startup : NULL [05:02:00.716] ..$ rscript_sh : chr "auto" [05:02:00.716] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:02:00.716] ..$ methods : logi TRUE [05:02:00.716] ..$ socketOptions : chr "no-delay" [05:02:00.716] ..$ useXDR : logi FALSE [05:02:00.716] ..$ outfile : chr "/dev/null" [05:02:00.716] ..$ renice : int NA [05:02:00.716] ..$ rshcmd : NULL [05:02:00.716] ..$ user : NULL [05:02:00.716] ..$ revtunnel : logi NA [05:02:00.716] ..$ rshlogfile : NULL [05:02:00.716] ..$ rshopts : NULL [05:02:00.716] ..$ rank : int 1 [05:02:00.716] ..$ manual : logi FALSE [05:02:00.716] ..$ dryrun : logi FALSE [05:02:00.716] ..$ quiet : logi FALSE [05:02:00.716] ..$ setup_strategy : chr "parallel" [05:02:00.716] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:00.751] [local output] System call to launch all workers: [05:02:00.751] [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:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5ccd2830b6.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=23516 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:00.751] [local output] Starting PSOCK main server [05:02:00.757] [local output] Workers launched [05:02:00.757] [local output] Waiting for workers to connect back [05:02:00.757] - [local output] 0 workers out of 1 ready [05:02:01.000] - [local output] 0 workers out of 1 ready [05:02:01.001] - [local output] 1 workers out of 1 ready [05:02:01.001] [local output] Launching of 1 workers completed [05:02:01.002] [local output] Number of nodes in cluster: 1 [05:02:01.002] [local output] Collecting session information from 1 workers [05:02:01.004] [local output] - Worker #1 of 1 [05:02:01.004] [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' [05:02:01.032] [local output] makeClusterPSOCK() ... [05:02:01.038] [local output] Workers: [n = 1] 'localhost' [05:02:01.043] [local output] Base port: 26081 [05:02:01.043] [local output] Getting setup options for 1 cluster nodes ... [05:02:01.043] [local output] - Node #1 of 1 ... [05:02:01.044] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:01.046] Testing if worker's PID can be inferred: '"D:\RCompile\recent\R\bin\x64\Rscript.exe" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc17cd417e.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc17cd417e.pid\")"' [05:02:01.373] - Possible to infer worker's PID: TRUE [05:02:01.374] [local output] Rscript port: 26081 [05:02:01.375] [local output] Getting setup options for 1 cluster nodes ... done [05:02:01.375] [local output] - Parallel setup requested for some PSOCK nodes [05:02:01.376] [local output] Setting up PSOCK nodes in parallel [05:02:01.376] List of 36 [05:02:01.376] $ worker : chr "localhost" [05:02:01.376] ..- attr(*, "localhost")= logi TRUE [05:02:01.376] $ master : chr "localhost" [05:02:01.376] $ port : int 26081 [05:02:01.376] $ connectTimeout : num 120 [05:02:01.376] $ timeout : num 120 [05:02:01.376] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [05:02:01.376] $ homogeneous : logi TRUE [05:02:01.376] $ rscript_args : chr "--default-packages=utils,tools -e \"#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN\" -e \"try(suppressWarnings(c"| __truncated__ [05:02:01.376] $ rscript_envs : NULL [05:02:01.376] $ rscript_libs : NULL [05:02:01.376] $ rscript_startup : NULL [05:02:01.376] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:01.376] $ default_packages: chr [1:2] "utils" "tools" [05:02:01.376] $ methods : logi TRUE [05:02:01.376] $ socketOptions : chr "no-delay" [05:02:01.376] $ useXDR : logi FALSE [05:02:01.376] $ outfile : chr "/dev/null" [05:02:01.376] $ renice : int NA [05:02:01.376] $ rshcmd : NULL [05:02:01.376] $ user : chr(0) [05:02:01.376] $ revtunnel : logi FALSE [05:02:01.376] $ rshlogfile : NULL [05:02:01.376] $ rshopts : chr(0) [05:02:01.376] $ rank : int 1 [05:02:01.376] $ manual : logi FALSE [05:02:01.376] $ dryrun : logi FALSE [05:02:01.376] $ quiet : logi FALSE [05:02:01.376] $ setup_strategy : chr "parallel" [05:02:01.376] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [05:02:01.376] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc17cd417e.pid" [05:02:01.376] $ rshcmd_label : NULL [05:02:01.376] $ rsh_call : NULL [05:02:01.376] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [05:02:01.376] $ localMachine : logi TRUE [05:02:01.376] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:01.376] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:01.376] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:01.376] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:01.376] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:01.376] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:01.376] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:01.376] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:01.376] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:01.376] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:01.376] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:01.376] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:01.376] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:01.376] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:01.376] $ arguments :List of 28 [05:02:01.376] ..$ worker : chr "localhost" [05:02:01.376] ..$ master : NULL [05:02:01.376] ..$ port : int 26081 [05:02:01.376] ..$ connectTimeout : num 120 [05:02:01.376] ..$ timeout : num 120 [05:02:01.376] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [05:02:01.376] ..$ homogeneous : NULL [05:02:01.376] ..$ rscript_args : NULL [05:02:01.376] ..$ rscript_envs : NULL [05:02:01.376] ..$ rscript_libs : NULL [05:02:01.376] ..$ rscript_startup : NULL [05:02:01.376] ..$ rscript_sh : chr "auto" [05:02:01.376] ..$ default_packages: chr [1:2] "utils" "tools" [05:02:01.376] ..$ methods : logi TRUE [05:02:01.376] ..$ socketOptions : chr "no-delay" [05:02:01.376] ..$ useXDR : logi FALSE [05:02:01.376] ..$ outfile : chr "/dev/null" [05:02:01.376] ..$ renice : int NA [05:02:01.376] ..$ rshcmd : NULL [05:02:01.376] ..$ user : NULL [05:02:01.376] ..$ revtunnel : logi NA [05:02:01.376] ..$ rshlogfile : NULL [05:02:01.376] ..$ rshopts : NULL [05:02:01.376] ..$ rank : int 1 [05:02:01.376] ..$ manual : logi FALSE [05:02:01.376] ..$ dryrun : logi FALSE [05:02:01.376] ..$ quiet : logi FALSE [05:02:01.376] ..$ setup_strategy : chr "parallel" [05:02:01.376] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:01.408] [local output] System call to launch all workers: [05:02:01.408] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=utils,tools -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc17cd417e.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26081 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:01.408] [local output] Starting PSOCK main server [05:02:01.414] [local output] Workers launched [05:02:01.415] [local output] Waiting for workers to connect back [05:02:01.415] - [local output] 0 workers out of 1 ready [05:02:01.549] - [local output] 0 workers out of 1 ready [05:02:01.550] - [local output] 1 workers out of 1 ready [05:02:01.550] [local output] Launching of 1 workers completed [05:02:01.550] [local output] Number of nodes in cluster: 1 [05:02:01.551] [local output] Collecting session information from 1 workers [05:02:01.552] [local output] - Worker #1 of 1 [05:02:01.552] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [05:02:01.559] [local output] makeClusterPSOCK() ... [05:02:01.564] [local output] Workers: [n = 1] 'localhost' [05:02:01.567] [local output] Base port: 26298 [05:02:01.568] [local output] Getting setup options for 1 cluster nodes ... [05:02:01.568] [local output] - Node #1 of 1 ... [05:02:01.569] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:01.571] [local output] Rscript port: 26298 [05:02:01.571] [local output] Getting setup options for 1 cluster nodes ... done [05:02:01.571] [local output] - Parallel setup requested for some PSOCK nodes [05:02:01.572] [local output] Setting up PSOCK nodes in parallel [05:02:01.572] List of 36 [05:02:01.572] $ worker : chr "localhost" [05:02:01.572] ..- attr(*, "localhost")= logi TRUE [05:02:01.572] $ master : chr "localhost" [05:02:01.572] $ port : int 26298 [05:02:01.572] $ connectTimeout : num 120 [05:02:01.572] $ timeout : num 120 [05:02:01.572] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [05:02:01.572] $ homogeneous : logi TRUE [05:02:01.572] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN\" -e \"| __truncated__ [05:02:01.572] $ rscript_envs : NULL [05:02:01.572] $ rscript_libs : NULL [05:02:01.572] $ rscript_startup : NULL [05:02:01.572] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:01.572] $ default_packages: chr [1:2] "utils" "tools" [05:02:01.572] $ methods : logi TRUE [05:02:01.572] $ socketOptions : chr "no-delay" [05:02:01.572] $ useXDR : logi FALSE [05:02:01.572] $ outfile : chr "/dev/null" [05:02:01.572] $ renice : int NA [05:02:01.572] $ rshcmd : NULL [05:02:01.572] $ user : chr(0) [05:02:01.572] $ revtunnel : logi FALSE [05:02:01.572] $ rshlogfile : NULL [05:02:01.572] $ rshopts : chr(0) [05:02:01.572] $ rank : int 1 [05:02:01.572] $ manual : logi FALSE [05:02:01.572] $ dryrun : logi FALSE [05:02:01.572] $ quiet : logi FALSE [05:02:01.572] $ setup_strategy : chr "parallel" [05:02:01.572] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [05:02:01.572] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc2a877015.pid" [05:02:01.572] $ rshcmd_label : NULL [05:02:01.572] $ rsh_call : NULL [05:02:01.572] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [05:02:01.572] $ localMachine : logi TRUE [05:02:01.572] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:01.572] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:01.572] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:01.572] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:01.572] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:01.572] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:01.572] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:01.572] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:01.572] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:01.572] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:01.572] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:01.572] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:01.572] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:01.572] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:01.572] $ arguments :List of 28 [05:02:01.572] ..$ worker : chr "localhost" [05:02:01.572] ..$ master : NULL [05:02:01.572] ..$ port : int 26298 [05:02:01.572] ..$ connectTimeout : num 120 [05:02:01.572] ..$ timeout : num 120 [05:02:01.572] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [05:02:01.572] ..$ homogeneous : NULL [05:02:01.572] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [05:02:01.572] ..$ rscript_envs : NULL [05:02:01.572] ..$ rscript_libs : NULL [05:02:01.572] ..$ rscript_startup : NULL [05:02:01.572] ..$ rscript_sh : chr "auto" [05:02:01.572] ..$ default_packages: chr [1:2] "utils" "tools" [05:02:01.572] ..$ methods : logi TRUE [05:02:01.572] ..$ socketOptions : chr "no-delay" [05:02:01.572] ..$ useXDR : logi FALSE [05:02:01.572] ..$ outfile : chr "/dev/null" [05:02:01.572] ..$ renice : int NA [05:02:01.572] ..$ rshcmd : NULL [05:02:01.572] ..$ user : NULL [05:02:01.572] ..$ revtunnel : logi NA [05:02:01.572] ..$ rshlogfile : NULL [05:02:01.572] ..$ rshopts : NULL [05:02:01.572] ..$ rank : int 1 [05:02:01.572] ..$ manual : logi FALSE [05:02:01.572] ..$ dryrun : logi FALSE [05:02:01.572] ..$ quiet : logi FALSE [05:02:01.572] ..$ setup_strategy : chr "parallel" [05:02:01.572] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:01.598] [local output] System call to launch all workers: [05:02:01.598] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc2a877015.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=26298 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:01.598] [local output] Starting PSOCK main server [05:02:01.604] [local output] Workers launched [05:02:01.605] [local output] Waiting for workers to connect back [05:02:01.605] - [local output] 0 workers out of 1 ready [05:02:01.720] - [local output] 0 workers out of 1 ready [05:02:01.721] - [local output] 1 workers out of 1 ready [05:02:01.721] [local output] Launching of 1 workers completed [05:02:01.722] [local output] Number of nodes in cluster: 1 [05:02:01.722] [local output] Collecting session information from 1 workers [05:02:01.723] [local output] - Worker #1 of 1 [05:02:01.723] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [05:02:01.729] [local output] makeClusterPSOCK() ... [05:02:01.737] [local output] Workers: [n = 1] 'localhost' [05:02:01.741] [local output] Base port: 29653 [05:02:01.741] [local output] Getting setup options for 1 cluster nodes ... [05:02:01.742] [local output] - Node #1 of 1 ... [05:02:01.743] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:01.745] [local output] Rscript port: 29653 [05:02:01.746] [local output] Getting setup options for 1 cluster nodes ... done [05:02:01.746] [local output] - Parallel setup requested for some PSOCK nodes [05:02:01.747] [local output] Setting up PSOCK nodes in parallel [05:02:01.747] List of 36 [05:02:01.747] $ worker : chr "localhost" [05:02:01.747] ..- attr(*, "localhost")= logi TRUE [05:02:01.747] $ master : chr "localhost" [05:02:01.747] $ port : int 29653 [05:02:01.747] $ connectTimeout : num 120 [05:02:01.747] $ timeout : num 120 [05:02:01.747] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [05:02:01.747] $ homogeneous : logi TRUE [05:02:01.747] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN\" -e \"| __truncated__ [05:02:01.747] $ rscript_envs : NULL [05:02:01.747] $ rscript_libs : NULL [05:02:01.747] $ rscript_startup : NULL [05:02:01.747] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:01.747] $ default_packages: chr [1:2] "utils" "tools" [05:02:01.747] $ methods : logi TRUE [05:02:01.747] $ socketOptions : chr "no-delay" [05:02:01.747] $ useXDR : logi FALSE [05:02:01.747] $ outfile : chr "/dev/null" [05:02:01.747] $ renice : int NA [05:02:01.747] $ rshcmd : NULL [05:02:01.747] $ user : chr(0) [05:02:01.747] $ revtunnel : logi FALSE [05:02:01.747] $ rshlogfile : NULL [05:02:01.747] $ rshopts : chr(0) [05:02:01.747] $ rank : int 1 [05:02:01.747] $ manual : logi FALSE [05:02:01.747] $ dryrun : logi FALSE [05:02:01.747] $ quiet : logi FALSE [05:02:01.747] $ setup_strategy : chr "parallel" [05:02:01.747] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [05:02:01.747] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc76221e25.pid" [05:02:01.747] $ rshcmd_label : NULL [05:02:01.747] $ rsh_call : NULL [05:02:01.747] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [05:02:01.747] $ localMachine : logi TRUE [05:02:01.747] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:01.747] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:01.747] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:01.747] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:01.747] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:01.747] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:01.747] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:01.747] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:01.747] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:01.747] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:01.747] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:01.747] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:01.747] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:01.747] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:01.747] $ arguments :List of 28 [05:02:01.747] ..$ worker : chr "localhost" [05:02:01.747] ..$ master : NULL [05:02:01.747] ..$ port : int 29653 [05:02:01.747] ..$ connectTimeout : num 120 [05:02:01.747] ..$ timeout : num 120 [05:02:01.747] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [05:02:01.747] ..$ homogeneous : NULL [05:02:01.747] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [05:02:01.747] ..$ rscript_envs : NULL [05:02:01.747] ..$ rscript_libs : NULL [05:02:01.747] ..$ rscript_startup : NULL [05:02:01.747] ..$ rscript_sh : chr "auto" [05:02:01.747] ..$ default_packages: chr [1:2] "utils" "tools" [05:02:01.747] ..$ methods : logi TRUE [05:02:01.747] ..$ socketOptions : chr "no-delay" [05:02:01.747] ..$ useXDR : logi FALSE [05:02:01.747] ..$ outfile : chr "/dev/null" [05:02:01.747] ..$ renice : int NA [05:02:01.747] ..$ rshcmd : NULL [05:02:01.747] ..$ user : NULL [05:02:01.747] ..$ revtunnel : logi NA [05:02:01.747] ..$ rshlogfile : NULL [05:02:01.747] ..$ rshopts : NULL [05:02:01.747] ..$ rank : int 1 [05:02:01.747] ..$ manual : logi FALSE [05:02:01.747] ..$ dryrun : logi FALSE [05:02:01.747] ..$ quiet : logi FALSE [05:02:01.747] ..$ setup_strategy : chr "parallel" [05:02:01.747] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:01.777] [local output] System call to launch all workers: [05:02:01.778] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc76221e25.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=29653 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:01.778] [local output] Starting PSOCK main server [05:02:01.783] [local output] Workers launched [05:02:01.784] [local output] Waiting for workers to connect back [05:02:01.784] - [local output] 0 workers out of 1 ready [05:02:01.892] - [local output] 0 workers out of 1 ready [05:02:01.893] - [local output] 1 workers out of 1 ready [05:02:01.894] [local output] Launching of 1 workers completed [05:02:01.894] [local output] Number of nodes in cluster: 1 [05:02:01.894] [local output] Collecting session information from 1 workers [05:02:01.896] [local output] - Worker #1 of 1 [05:02:01.896] [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' [05:02:01.923] [local output] makeClusterPSOCK() ... [05:02:01.930] [local output] Workers: [n = 1] 'localhost' [05:02:01.935] [local output] Base port: 36726 [05:02:01.936] [local output] Getting setup options for 1 cluster nodes ... [05:02:01.936] [local output] - Node #1 of 1 ... [05:02:01.937] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:01.940] [local output] Rscript port: 36726 [05:02:01.941] [local output] Getting setup options for 1 cluster nodes ... done [05:02:01.941] [local output] - Parallel setup requested for some PSOCK nodes [05:02:01.942] [local output] Setting up PSOCK nodes in parallel [05:02:01.942] List of 36 [05:02:01.942] $ worker : chr "localhost" [05:02:01.942] ..- attr(*, "localhost")= logi TRUE [05:02:01.942] $ master : chr "localhost" [05:02:01.942] $ port : int 36726 [05:02:01.942] $ connectTimeout : num 120 [05:02:01.942] $ timeout : num 120 [05:02:01.942] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [05:02:01.942] $ homogeneous : logi TRUE [05:02:01.942] $ rscript_args : chr "--default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58"| __truncated__ [05:02:01.942] $ rscript_envs : NULL [05:02:01.942] $ rscript_libs : NULL [05:02:01.942] $ rscript_startup : NULL [05:02:01.942] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:01.942] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [05:02:01.942] $ methods : logi TRUE [05:02:01.942] $ socketOptions : chr "no-delay" [05:02:01.942] $ useXDR : logi FALSE [05:02:01.942] $ outfile : chr "/dev/null" [05:02:01.942] $ renice : int NA [05:02:01.942] $ rshcmd : NULL [05:02:01.942] $ user : chr(0) [05:02:01.942] $ revtunnel : logi FALSE [05:02:01.942] $ rshlogfile : NULL [05:02:01.942] $ rshopts : chr(0) [05:02:01.942] $ rank : int 1 [05:02:01.942] $ manual : logi FALSE [05:02:01.942] $ dryrun : logi FALSE [05:02:01.942] $ quiet : logi FALSE [05:02:01.942] $ setup_strategy : chr "parallel" [05:02:01.942] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [05:02:01.942] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc74fa15aa.pid" [05:02:01.942] $ rshcmd_label : NULL [05:02:01.942] $ rsh_call : NULL [05:02:01.942] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [05:02:01.942] $ localMachine : logi TRUE [05:02:01.942] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:01.942] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:01.942] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:01.942] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:01.942] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:01.942] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:01.942] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:01.942] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:01.942] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:01.942] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:01.942] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:01.942] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:01.942] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:01.942] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:01.942] $ arguments :List of 28 [05:02:01.942] ..$ worker : chr "localhost" [05:02:01.942] ..$ master : NULL [05:02:01.942] ..$ port : int 36726 [05:02:01.942] ..$ connectTimeout : num 120 [05:02:01.942] ..$ timeout : num 120 [05:02:01.942] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [05:02:01.942] ..$ homogeneous : NULL [05:02:01.942] ..$ rscript_args : NULL [05:02:01.942] ..$ rscript_envs : NULL [05:02:01.942] ..$ rscript_libs : NULL [05:02:01.942] ..$ rscript_startup : NULL [05:02:01.942] ..$ rscript_sh : chr "auto" [05:02:01.942] ..$ default_packages: chr [1:2] "parallelly" "*" [05:02:01.942] ..$ methods : logi TRUE [05:02:01.942] ..$ socketOptions : chr "no-delay" [05:02:01.942] ..$ useXDR : logi FALSE [05:02:01.942] ..$ outfile : chr "/dev/null" [05:02:01.942] ..$ renice : int NA [05:02:01.942] ..$ rshcmd : NULL [05:02:01.942] ..$ user : NULL [05:02:01.942] ..$ revtunnel : logi NA [05:02:01.942] ..$ rshlogfile : NULL [05:02:01.942] ..$ rshopts : NULL [05:02:01.942] ..$ rank : int 1 [05:02:01.942] ..$ manual : logi FALSE [05:02:01.942] ..$ dryrun : logi FALSE [05:02:01.942] ..$ quiet : logi FALSE [05:02:01.942] ..$ setup_strategy : chr "parallel" [05:02:01.942] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:01.983] [local output] System call to launch all workers: [05:02:01.983] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc74fa15aa.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36726 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:01.983] [local output] Starting PSOCK main server [05:02:01.989] [local output] Workers launched [05:02:01.989] [local output] Waiting for workers to connect back [05:02:01.990] - [local output] 0 workers out of 1 ready [05:02:02.316] - [local output] 0 workers out of 1 ready [05:02:02.317] - [local output] 1 workers out of 1 ready [05:02:02.317] [local output] Launching of 1 workers completed [05:02:02.317] [local output] Number of nodes in cluster: 1 [05:02:02.318] [local output] Collecting session information from 1 workers [05:02:02.318] [local output] - Worker #1 of 1 [05:02:02.319] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [05:02:02.324] [local output] makeClusterPSOCK() ... [05:02:02.330] [local output] Workers: [n = 1] 'localhost' [05:02:02.338] [local output] Base port: 38255 [05:02:02.338] [local output] Getting setup options for 1 cluster nodes ... [05:02:02.339] [local output] - Node #1 of 1 ... [05:02:02.340] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:02.343] [local output] Rscript port: 38255 [05:02:02.344] [local output] Getting setup options for 1 cluster nodes ... done [05:02:02.344] [local output] - Parallel setup requested for some PSOCK nodes [05:02:02.345] [local output] Setting up PSOCK nodes in parallel [05:02:02.345] List of 36 [05:02:02.345] $ worker : chr "localhost" [05:02:02.345] ..- attr(*, "localhost")= logi TRUE [05:02:02.345] $ master : chr "localhost" [05:02:02.345] $ port : int 38255 [05:02:02.345] $ connectTimeout : num 120 [05:02:02.345] $ timeout : num 120 [05:02:02.345] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [05:02:02.345] $ homogeneous : logi TRUE [05:02:02.345] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [05:02:02.345] $ rscript_envs : NULL [05:02:02.345] $ rscript_libs : NULL [05:02:02.345] $ rscript_startup : NULL [05:02:02.345] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:02.345] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [05:02:02.345] $ methods : logi TRUE [05:02:02.345] $ socketOptions : chr "no-delay" [05:02:02.345] $ useXDR : logi FALSE [05:02:02.345] $ outfile : chr "/dev/null" [05:02:02.345] $ renice : int NA [05:02:02.345] $ rshcmd : NULL [05:02:02.345] $ user : chr(0) [05:02:02.345] $ revtunnel : logi FALSE [05:02:02.345] $ rshlogfile : NULL [05:02:02.345] $ rshopts : chr(0) [05:02:02.345] $ rank : int 1 [05:02:02.345] $ manual : logi FALSE [05:02:02.345] $ dryrun : logi FALSE [05:02:02.345] $ quiet : logi FALSE [05:02:02.345] $ setup_strategy : chr "parallel" [05:02:02.345] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [05:02:02.345] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4b1b7891.pid" [05:02:02.345] $ rshcmd_label : NULL [05:02:02.345] $ rsh_call : NULL [05:02:02.345] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [05:02:02.345] $ localMachine : logi TRUE [05:02:02.345] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:02.345] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:02.345] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:02.345] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:02.345] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:02.345] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:02.345] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:02.345] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:02.345] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:02.345] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:02.345] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:02.345] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:02.345] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:02.345] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:02.345] $ arguments :List of 28 [05:02:02.345] ..$ worker : chr "localhost" [05:02:02.345] ..$ master : NULL [05:02:02.345] ..$ port : int 38255 [05:02:02.345] ..$ connectTimeout : num 120 [05:02:02.345] ..$ timeout : num 120 [05:02:02.345] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [05:02:02.345] ..$ homogeneous : NULL [05:02:02.345] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [05:02:02.345] ..$ rscript_envs : NULL [05:02:02.345] ..$ rscript_libs : NULL [05:02:02.345] ..$ rscript_startup : NULL [05:02:02.345] ..$ rscript_sh : chr "auto" [05:02:02.345] ..$ default_packages: chr [1:2] "parallelly" "*" [05:02:02.345] ..$ methods : logi TRUE [05:02:02.345] ..$ socketOptions : chr "no-delay" [05:02:02.345] ..$ useXDR : logi FALSE [05:02:02.345] ..$ outfile : chr "/dev/null" [05:02:02.345] ..$ renice : int NA [05:02:02.345] ..$ rshcmd : NULL [05:02:02.345] ..$ user : NULL [05:02:02.345] ..$ revtunnel : logi NA [05:02:02.345] ..$ rshlogfile : NULL [05:02:02.345] ..$ rshopts : NULL [05:02:02.345] ..$ rank : int 1 [05:02:02.345] ..$ manual : logi FALSE [05:02:02.345] ..$ dryrun : logi FALSE [05:02:02.345] ..$ quiet : logi FALSE [05:02:02.345] ..$ setup_strategy : chr "parallel" [05:02:02.345] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:02.383] [local output] System call to launch all workers: [05:02:02.384] [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:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc4b1b7891.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=38255 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:02.384] [local output] Starting PSOCK main server [05:02:02.390] [local output] Workers launched [05:02:02.390] [local output] Waiting for workers to connect back [05:02:02.390] - [local output] 0 workers out of 1 ready [05:02:02.691] - [local output] 0 workers out of 1 ready [05:02:02.691] - [local output] 1 workers out of 1 ready [05:02:02.692] [local output] Launching of 1 workers completed [05:02:02.692] [local output] Number of nodes in cluster: 1 [05:02:02.692] [local output] Collecting session information from 1 workers [05:02:02.694] [local output] - Worker #1 of 1 [05:02:02.694] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [05:02:02.701] [local output] makeClusterPSOCK() ... [05:02:02.707] [local output] Workers: [n = 1] 'localhost' [05:02:02.712] [local output] Base port: 31241 [05:02:02.713] [local output] Getting setup options for 1 cluster nodes ... [05:02:02.713] [local output] - Node #1 of 1 ... [05:02:02.714] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:02.717] [local output] Rscript port: 31241 [05:02:02.717] [local output] Getting setup options for 1 cluster nodes ... done [05:02:02.718] [local output] - Parallel setup requested for some PSOCK nodes [05:02:02.718] [local output] Setting up PSOCK nodes in parallel [05:02:02.719] List of 36 [05:02:02.719] $ worker : chr "localhost" [05:02:02.719] ..- attr(*, "localhost")= logi TRUE [05:02:02.719] $ master : chr "localhost" [05:02:02.719] $ port : int 31241 [05:02:02.719] $ connectTimeout : num 120 [05:02:02.719] $ timeout : num 120 [05:02:02.719] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [05:02:02.719] $ homogeneous : logi TRUE [05:02:02.719] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [05:02:02.719] $ rscript_envs : NULL [05:02:02.719] $ rscript_libs : NULL [05:02:02.719] $ rscript_startup : NULL [05:02:02.719] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:02.719] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [05:02:02.719] $ methods : logi TRUE [05:02:02.719] $ socketOptions : chr "no-delay" [05:02:02.719] $ useXDR : logi FALSE [05:02:02.719] $ outfile : chr "/dev/null" [05:02:02.719] $ renice : int NA [05:02:02.719] $ rshcmd : NULL [05:02:02.719] $ user : chr(0) [05:02:02.719] $ revtunnel : logi FALSE [05:02:02.719] $ rshlogfile : NULL [05:02:02.719] $ rshopts : chr(0) [05:02:02.719] $ rank : int 1 [05:02:02.719] $ manual : logi FALSE [05:02:02.719] $ dryrun : logi FALSE [05:02:02.719] $ quiet : logi FALSE [05:02:02.719] $ setup_strategy : chr "parallel" [05:02:02.719] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [05:02:02.719] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc71a74e85.pid" [05:02:02.719] $ rshcmd_label : NULL [05:02:02.719] $ rsh_call : NULL [05:02:02.719] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [05:02:02.719] $ localMachine : logi TRUE [05:02:02.719] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:02.719] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:02.719] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:02.719] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:02.719] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:02.719] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:02.719] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:02.719] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:02.719] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:02.719] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:02.719] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:02.719] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:02.719] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:02.719] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:02.719] $ arguments :List of 28 [05:02:02.719] ..$ worker : chr "localhost" [05:02:02.719] ..$ master : NULL [05:02:02.719] ..$ port : int 31241 [05:02:02.719] ..$ connectTimeout : num 120 [05:02:02.719] ..$ timeout : num 120 [05:02:02.719] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [05:02:02.719] ..$ homogeneous : NULL [05:02:02.719] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [05:02:02.719] ..$ rscript_envs : NULL [05:02:02.719] ..$ rscript_libs : NULL [05:02:02.719] ..$ rscript_startup : NULL [05:02:02.719] ..$ rscript_sh : chr "auto" [05:02:02.719] ..$ default_packages: chr [1:2] "parallelly" "*" [05:02:02.719] ..$ methods : logi TRUE [05:02:02.719] ..$ socketOptions : chr "no-delay" [05:02:02.719] ..$ useXDR : logi FALSE [05:02:02.719] ..$ outfile : chr "/dev/null" [05:02:02.719] ..$ renice : int NA [05:02:02.719] ..$ rshcmd : NULL [05:02:02.719] ..$ user : NULL [05:02:02.719] ..$ revtunnel : logi NA [05:02:02.719] ..$ rshlogfile : NULL [05:02:02.719] ..$ rshopts : NULL [05:02:02.719] ..$ rank : int 1 [05:02:02.719] ..$ manual : logi FALSE [05:02:02.719] ..$ dryrun : logi FALSE [05:02:02.719] ..$ quiet : logi FALSE [05:02:02.719] ..$ setup_strategy : chr "parallel" [05:02:02.719] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:02.758] [local output] System call to launch all workers: [05:02:02.759] [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:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc71a74e85.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=31241 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [05:02:02.759] [local output] Starting PSOCK main server [05:02:02.764] [local output] Workers launched [05:02:02.765] [local output] Waiting for workers to connect back [05:02:02.765] - [local output] 0 workers out of 1 ready [05:02:03.036] - [local output] 0 workers out of 1 ready [05:02:03.037] - [local output] 1 workers out of 1 ready [05:02:03.037] [local output] Launching of 1 workers completed [05:02:03.038] [local output] Number of nodes in cluster: 1 [05:02:03.038] [local output] Collecting session information from 1 workers [05:02:03.040] [local output] - Worker #1 of 1 [05:02:03.040] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > res <- tryCatch({ + cl <- makeClusterPSOCK(1:2) + }, error = identity) [05:02:03.047] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(0L) + }, error = identity) [05:02:03.048] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, rshcmd = character(0L)) + }, error = identity) [05:02:03.049] [local output] makeClusterPSOCK() ... [05:02:03.055] [local output] Workers: [n = 1] 'localhost' [05:02:03.060] [local output] Base port: 37769 [05:02:03.060] [local output] Getting setup options for 1 cluster nodes ... [05:02:03.061] [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) [05:02:03.062] [local output] makeClusterPSOCK() ... [05:02:03.068] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = NA_integer_) + }, error = identity) [05:02:03.069] [local output] makeClusterPSOCK() ... [05:02:03.075] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > ## Non-existing hostname > res <- tryCatch({ + cl <- makeNodePSOCK("not.a.localhost.hostname", revtunnel = TRUE) + }, error = identity) > print(res) > stopifnot(inherits(res, "error")) > > ## Invalid port > res <- tryCatch({ + cl <- makeNodePSOCK("localhost", port = NA_integer_) + }, error = identity) > print(res) > stopifnot(inherits(res, "error")) > > ## Don't test on CRAN > if (fullTest || covr_testing) { + ## Occupied/blocked port + res <- tryCatch( + cl <- parallelly::makeClusterPSOCK("localhost", port = 80L, tries = 1L), + error = identity) + print(res) + ## Skip error assertion in case this actually works on some machine. + ## But where it fails, we are testing the port-failure exception code. + } > > > ## https://github.com/futureverse/parallelly/issues/95 > if (getRversion() >= "4.0.0") { + res <- tryCatch({ + parallelly::makeClusterPSOCK(1L, rscript_startup = quote(Sys.sleep(6.0)), + connectTimeout = 0.1, timeout = 7.0) + }, error = identity) + print(res) + stopifnot( + inherits(res, "error"), + grepl("^Cluster setup failed", conditionMessage(res)) + ) + + ## Make sure to wait for background process to timeout before continuing, + ## when on MS Windows + if (.Platform$OS.type == "windows") Sys.sleep(5.0) + } [05:02:03.080] [local output] makeClusterPSOCK() ... [05:02:03.085] [local output] Workers: [n = 1] 'localhost' [05:02:03.090] [local output] Base port: 25818 [05:02:03.091] [local output] Getting setup options for 1 cluster nodes ... [05:02:03.091] [local output] - Node #1 of 1 ... [05:02:03.092] [local output] localMachine=TRUE => revtunnel=FALSE [05:02:03.095] [local output] Rscript port: 25818 [05:02:03.095] [local output] Getting setup options for 1 cluster nodes ... done [05:02:03.096] [local output] - Parallel setup requested for some PSOCK nodes [05:02:03.097] [local output] Setting up PSOCK nodes in parallel [05:02:03.097] List of 36 [05:02:03.097] $ worker : chr "localhost" [05:02:03.097] ..- attr(*, "localhost")= logi TRUE [05:02:03.097] $ master : chr "localhost" [05:02:03.097] $ port : int 25818 [05:02:03.097] $ connectTimeout : num 0.1 [05:02:03.097] $ timeout : num 7 [05:02:03.097] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [05:02:03.097] $ homogeneous : logi TRUE [05:02:03.097] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:58828:CRANWIN"| __truncated__ [05:02:03.097] $ rscript_envs : NULL [05:02:03.097] $ rscript_libs : NULL [05:02:03.097] $ rscript_startup : chr [1:2] "-e" "\"invisible({Sys.sleep(6)})\"" [05:02:03.097] $ rscript_sh : chr [1:2] "cmd" "cmd" [05:02:03.097] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:02:03.097] $ methods : logi TRUE [05:02:03.097] $ socketOptions : chr "no-delay" [05:02:03.097] $ useXDR : logi FALSE [05:02:03.097] $ outfile : chr "/dev/null" [05:02:03.097] $ renice : int NA [05:02:03.097] $ rshcmd : NULL [05:02:03.097] $ user : chr(0) [05:02:03.097] $ revtunnel : logi FALSE [05:02:03.097] $ rshlogfile : NULL [05:02:03.097] $ rshopts : chr(0) [05:02:03.097] $ rank : int 1 [05:02:03.097] $ manual : logi FALSE [05:02:03.097] $ dryrun : logi FALSE [05:02:03.097] $ quiet : logi FALSE [05:02:03.097] $ setup_strategy : chr "parallel" [05:02:03.097] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:02:03.097] $ pidfile : chr "D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc31782506.pid" [05:02:03.097] $ rshcmd_label : NULL [05:02:03.097] $ rsh_call : NULL [05:02:03.097] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [05:02:03.097] $ localMachine : logi TRUE [05:02:03.097] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [05:02:03.097] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [05:02:03.097] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [05:02:03.097] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [05:02:03.097] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [05:02:03.097] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [05:02:03.097] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [05:02:03.097] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [05:02:03.097] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [05:02:03.097] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [05:02:03.097] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [05:02:03.097] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [05:02:03.097] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [05:02:03.097] "parallel"), action = c("launch", "options"), verbose = FALSE) [05:02:03.097] $ arguments :List of 28 [05:02:03.097] ..$ worker : chr "localhost" [05:02:03.097] ..$ master : NULL [05:02:03.097] ..$ port : int 25818 [05:02:03.097] ..$ connectTimeout : num 0.1 [05:02:03.097] ..$ timeout : num 7 [05:02:03.097] ..$ rscript : NULL [05:02:03.097] ..$ homogeneous : NULL [05:02:03.097] ..$ rscript_args : NULL [05:02:03.097] ..$ rscript_envs : NULL [05:02:03.097] ..$ rscript_libs : NULL [05:02:03.097] ..$ rscript_startup : language Sys.sleep(6) [05:02:03.097] ..$ rscript_sh : chr "auto" [05:02:03.097] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [05:02:03.097] ..$ methods : logi TRUE [05:02:03.097] ..$ socketOptions : chr "no-delay" [05:02:03.097] ..$ useXDR : logi FALSE [05:02:03.097] ..$ outfile : chr "/dev/null" [05:02:03.097] ..$ renice : int NA [05:02:03.097] ..$ rshcmd : NULL [05:02:03.097] ..$ user : NULL [05:02:03.097] ..$ revtunnel : logi NA [05:02:03.097] ..$ rshlogfile : NULL [05:02:03.097] ..$ rshopts : NULL [05:02:03.097] ..$ rank : int 1 [05:02:03.097] ..$ manual : logi FALSE [05:02:03.097] ..$ dryrun : logi FALSE [05:02:03.097] ..$ quiet : logi FALSE [05:02:03.097] ..$ setup_strategy : chr "parallel" [05:02:03.097] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [05:02:03.135] [local output] System call to launch all workers: [05:02:03.136] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:58828:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2024_12_03_04_25_01_4301/RtmpAPXgde/worker.rank=1.parallelly.parent=58828.e5cc31782506.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=25818 OUT=/dev/null TIMEOUT=7 XDR=FALSE SETUPTIMEOUT=0.1 SETUPSTRATEGY=parallel [05:02:03.136] [local output] Starting PSOCK main server [05:02:03.142] [local output] Workers launched [05:02:03.142] [local output] Waiting for workers to connect back [05:02:03.143] - [local output] 0 workers out of 1 ready [05:02:03.341] - [local output] 0 workers out of 1 ready [05:02:03.544] - [local output] 0 workers out of 1 ready [05:02:03.748] - [local output] 0 workers out of 1 ready [05:02:03.951] - [local output] 0 workers out of 1 ready [05:02:04.154] - [local output] 0 workers out of 1 ready [05:02:04.357] - [local output] 0 workers out of 1 ready [05:02:04.560] - [local output] 0 workers out of 1 ready [05:02:04.763] - [local output] 0 workers out of 1 ready [05:02:04.966] - [local output] 0 workers out of 1 ready [05:02:05.169] - [local output] 0 workers out of 1 ready [05:02:05.373] - [local output] 0 workers out of 1 ready [05:02:05.576] - [local output] 0 workers out of 1 ready [05:02:05.779] - [local output] 0 workers out of 1 ready [05:02:05.982] - [local output] 0 workers out of 1 ready [05:02:06.185] - [local output] 0 workers out of 1 ready [05:02:06.388] - [local output] 0 workers out of 1 ready [05:02:06.591] - [local output] 0 workers out of 1 ready [05:02:06.794] - [local output] 0 workers out of 1 ready [05:02:06.998] - [local output] 0 workers out of 1 ready [05:02:07.201] - [local output] 0 workers out of 1 ready [05:02:07.404] - [local output] 0 workers out of 1 ready [05:02:07.607] - [local output] 0 workers out of 1 ready [05:02:07.810] - [local output] 0 workers out of 1 ready [05:02:08.013] - [local output] 0 workers out of 1 ready [05:02:08.216] - [local output] 0 workers out of 1 ready [05:02:08.419] - [local output] 0 workers out of 1 ready > > message("*** makeClusterPSOCK() ... DONE") *** makeClusterPSOCK() ... DONE > > source("incl/end.R") > > proc.time() user system elapsed 1.81 0.26 19.76