R Under development (unstable) (2024-07-26 r86926 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.6p1, OpenSSL 3.2.1 30 Jan 2024" $`putty-plink` plink "C:\\PROGRA~1\\PuTTY\\plink.exe" "-ssh" attr(,"type") [1] "putty-plink" attr(,"version") [1] "plink: Release 0.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) [12:31:40.899] [local output] makeClusterPSOCK() ... [12:31:40.946] [local output] Workers: [n = 1] '' [12:31:40.954] [local output] Base port: 34619 [12:31:40.954] [local output] Getting setup options for 1 cluster nodes ... [12:31:40.955] [local output] - Node #1 of 1 ... [12:31:40.958] [local output] Rscript port: 34619 [12:31:40.958] [local output] Using 'rshcmd': 'my_ssh' [type='', version=''] [12:31:40.959] [local output] Getting setup options for 1 cluster nodes ... done [12:31:40.959] [local output] Creating node #1 of 1 ... [12:31:40.959] [local output] - setting up node [12:31:40.960] [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:92884:CRANWIN3:CRAN' -e 'options(socketOptions = "no-delay")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=34619 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:92884:CRANWIN3:CRAN' -e 'options(socketOptions = \"no-delay\")' -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=CRANWIN3 PORT=34619 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential" [12:31:40.961] [local output] Creating node #1 of 1 ... done [12:31:40.961] [local output] Launching of 1 workers completed [12:31:40.962] [local output] Number of nodes in cluster: 1 [12:31:40.962] [local output] Collecting session information from 1 workers [12:31:40.962] [local output] - Worker #1 of 1 [12:31:40.963] [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) [12:31:40.966] [local output] makeClusterPSOCK() ... [12:31:40.970] [local output] Workers: [n = 1] 'localhost' [12:31:40.973] [local output] Base port: 37370 [12:31:40.973] [local output] Getting setup options for 1 cluster nodes ... [12:31:40.974] [local output] - Node #1 of 1 ... [12:31:40.974] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:40.975] [local output] Rscript port: 37370 [12:31:40.976] [local output] Getting setup options for 1 cluster nodes ... done [12:31:40.976] [local output] Creating node #1 of 1 ... [12:31:40.976] [local output] - setting up node [12:31:40.977] [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:92884:CRANWIN3:CRAN" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=37370 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [12:31:40.977] [local output] Creating node #1 of 1 ... done [12:31:40.977] [local output] Launching of 1 workers completed [12:31:40.978] [local output] Number of nodes in cluster: 1 [12:31:40.978] [local output] Collecting session information from 1 workers [12:31:40.978] [local output] - Worker #1 of 1 [12:31:40.979] [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) [12:31:40.981] [local output] makeClusterPSOCK() ... [12:31:40.985] [local output] Workers: [n = 1] 'localhost' [12:31:40.988] [local output] Base port: 20050 [12:31:40.988] [local output] Getting setup options for 1 cluster nodes ... [12:31:40.989] [local output] - Node #1 of 1 ... [12:31:40.989] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:40.991] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4412617eb.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4412617eb.pid\")"' [12:31:41.430] - Possible to infer worker's PID: TRUE [12:31:41.431] [local output] Rscript port: 20050 [12:31:41.431] [local output] Getting setup options for 1 cluster nodes ... done [12:31:41.432] [local output] - Parallel setup requested for some PSOCK nodes [12:31:41.433] [local output] Setting up PSOCK nodes in parallel [12:31:41.433] List of 36 [12:31:41.433] $ worker : chr "localhost" [12:31:41.433] ..- attr(*, "localhost")= logi TRUE [12:31:41.433] $ master : chr "localhost" [12:31:41.433] $ port : int 20050 [12:31:41.433] $ connectTimeout : num 120 [12:31:41.433] $ timeout : num 120 [12:31:41.433] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:41.433] $ homogeneous : logi TRUE [12:31:41.433] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:41.433] $ rscript_envs : NULL [12:31:41.433] $ rscript_libs : NULL [12:31:41.433] $ rscript_startup : NULL [12:31:41.433] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:41.433] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:41.433] $ methods : logi TRUE [12:31:41.433] $ socketOptions : chr "no-delay" [12:31:41.433] $ useXDR : logi FALSE [12:31:41.433] $ outfile : chr "/dev/null" [12:31:41.433] $ renice : int NA [12:31:41.433] $ rshcmd : NULL [12:31:41.433] $ user : chr(0) [12:31:41.433] $ revtunnel : logi FALSE [12:31:41.433] $ rshlogfile : NULL [12:31:41.433] $ rshopts : chr(0) [12:31:41.433] $ rank : int 1 [12:31:41.433] $ manual : logi FALSE [12:31:41.433] $ dryrun : logi FALSE [12:31:41.433] $ quiet : logi FALSE [12:31:41.433] $ setup_strategy : chr "parallel" [12:31:41.433] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:41.433] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4412617eb.pid" [12:31:41.433] $ rshcmd_label : NULL [12:31:41.433] $ rsh_call : NULL [12:31:41.433] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:41.433] $ localMachine : logi TRUE [12:31:41.433] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:41.433] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:41.433] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:41.433] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:41.433] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:41.433] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:41.433] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:41.433] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:41.433] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:41.433] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:41.433] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:41.433] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:41.433] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:41.433] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:41.433] $ arguments :List of 28 [12:31:41.433] ..$ worker : chr "localhost" [12:31:41.433] ..$ master : NULL [12:31:41.433] ..$ port : int 20050 [12:31:41.433] ..$ connectTimeout : num 120 [12:31:41.433] ..$ timeout : num 120 [12:31:41.433] ..$ rscript : NULL [12:31:41.433] ..$ homogeneous : NULL [12:31:41.433] ..$ rscript_args : NULL [12:31:41.433] ..$ rscript_envs : NULL [12:31:41.433] ..$ rscript_libs : NULL [12:31:41.433] ..$ rscript_startup : NULL [12:31:41.433] ..$ rscript_sh : chr "auto" [12:31:41.433] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:41.433] ..$ methods : logi TRUE [12:31:41.433] ..$ socketOptions : chr "no-delay" [12:31:41.433] ..$ useXDR : logi FALSE [12:31:41.433] ..$ outfile : chr "/dev/null" [12:31:41.433] ..$ renice : int NA [12:31:41.433] ..$ rshcmd : NULL [12:31:41.433] ..$ user : NULL [12:31:41.433] ..$ revtunnel : logi NA [12:31:41.433] ..$ rshlogfile : NULL [12:31:41.433] ..$ rshopts : NULL [12:31:41.433] ..$ rank : int 1 [12:31:41.433] ..$ manual : logi FALSE [12:31:41.433] ..$ dryrun : logi FALSE [12:31:41.433] ..$ quiet : logi FALSE [12:31:41.433] ..$ setup_strategy : chr "parallel" [12:31:41.433] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:41.470] [local output] System call to launch all workers: [12:31:41.470] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4412617eb.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20050 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:41.470] [local output] Starting PSOCK main server [12:31:41.476] [local output] Workers launched [12:31:41.477] [local output] Waiting for workers to connect back [12:31:41.477] - [local output] 0 workers out of 1 ready [12:31:41.748] - [local output] 0 workers out of 1 ready [12:31:41.749] - [local output] 1 workers out of 1 ready [12:31:41.749] [local output] Launching of 1 workers completed [12:31:41.749] [local output] Number of nodes in cluster: 1 [12:31:41.750] [local output] Collecting session information from 1 workers [12:31:41.751] [local output] - Worker #1 of 1 [12:31:41.751] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-07-26 r86926 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 "07" .. ..$ day : chr "26" .. ..$ svn rev : chr "86926" .. ..$ language : chr "R" .. ..$ version.string: chr "R Under development (unstable) (2024-07-26 r86926 ucrt)" .. ..$ nickname : chr "Unsuffered Consequences" .. ..$ os.type : chr "windows" ..$ system :List of 8 .. ..$ sysname : chr "Windows" .. ..$ release : chr "Server x64" .. ..$ version : chr "build 20348" .. ..$ nodename : chr "CRANWIN3" .. ..$ machine : chr "x86-64" .. ..$ login : chr "CRAN" .. ..$ user : chr "CRAN" .. ..$ effective_user: chr "CRAN" ..$ libs : chr [1:2] "D:/temp/RtmpIZlM8d/RLIBS_18f9814495723" "D:/RCompile/recent/R/library" ..$ pkgs : NULL ..$ pwd : chr "d:/RCompile/CRANincoming/R-devel/parallelly.Rcheck/tests" ..$ process:List of 1 .. ..$ pid: int 62296 - attr(*, "options")=List of 35 ..$ worker : chr "localhost" .. ..- attr(*, "localhost")= logi TRUE ..$ master : chr "localhost" ..$ port : int 20050 ..$ 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:92884: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 20050 .. ..$ 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) + } [12:31:41.827] [local output] makeClusterPSOCK() ... [12:31:41.831] [local output] Workers: [n = 1] 'localhost' [12:31:41.834] [local output] Base port: 36829 [12:31:41.835] [local output] Getting setup options for 1 cluster nodes ... [12:31:41.835] [local output] - Node #1 of 1 ... [12:31:41.836] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:41.838] [local output] Rscript port: 36829 [12:31:41.838] [local output] Getting setup options for 1 cluster nodes ... done [12:31:41.839] [local output] - Parallel setup requested for some PSOCK nodes [12:31:41.839] [local output] Setting up PSOCK nodes in parallel [12:31:41.839] List of 36 [12:31:41.839] $ worker : chr "localhost" [12:31:41.839] ..- attr(*, "localhost")= logi TRUE [12:31:41.839] $ master : chr "localhost" [12:31:41.839] $ port : int 36829 [12:31:41.839] $ connectTimeout : num 120 [12:31:41.839] $ timeout : num 120 [12:31:41.839] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:41.839] $ homogeneous : logi TRUE [12:31:41.839] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:41.839] $ rscript_envs : NULL [12:31:41.839] $ rscript_libs : NULL [12:31:41.839] $ rscript_startup : NULL [12:31:41.839] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:41.839] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:41.839] $ methods : logi TRUE [12:31:41.839] $ socketOptions : chr "no-delay" [12:31:41.839] $ useXDR : logi TRUE [12:31:41.839] $ outfile : chr "/dev/null" [12:31:41.839] $ renice : int NA [12:31:41.839] $ rshcmd : NULL [12:31:41.839] $ user : chr(0) [12:31:41.839] $ revtunnel : logi FALSE [12:31:41.839] $ rshlogfile : NULL [12:31:41.839] $ rshopts : chr(0) [12:31:41.839] $ rank : int 1 [12:31:41.839] $ manual : logi FALSE [12:31:41.839] $ dryrun : logi FALSE [12:31:41.839] $ quiet : logi FALSE [12:31:41.839] $ setup_strategy : chr "parallel" [12:31:41.839] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:41.839] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad42feb1d5.pid" [12:31:41.839] $ rshcmd_label : NULL [12:31:41.839] $ rsh_call : NULL [12:31:41.839] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:41.839] $ localMachine : logi TRUE [12:31:41.839] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:41.839] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:41.839] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:41.839] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:41.839] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:41.839] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:41.839] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:41.839] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:41.839] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:41.839] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:41.839] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:41.839] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:41.839] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:41.839] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:41.839] $ arguments :List of 28 [12:31:41.839] ..$ worker : chr "localhost" [12:31:41.839] ..$ master : NULL [12:31:41.839] ..$ port : int 36829 [12:31:41.839] ..$ connectTimeout : num 120 [12:31:41.839] ..$ timeout : num 120 [12:31:41.839] ..$ rscript : NULL [12:31:41.839] ..$ homogeneous : NULL [12:31:41.839] ..$ rscript_args : NULL [12:31:41.839] ..$ rscript_envs : NULL [12:31:41.839] ..$ rscript_libs : NULL [12:31:41.839] ..$ rscript_startup : NULL [12:31:41.839] ..$ rscript_sh : chr "auto" [12:31:41.839] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:41.839] ..$ methods : logi TRUE [12:31:41.839] ..$ socketOptions : chr "no-delay" [12:31:41.839] ..$ useXDR : logi TRUE [12:31:41.839] ..$ outfile : chr "/dev/null" [12:31:41.839] ..$ renice : int NA [12:31:41.839] ..$ rshcmd : NULL [12:31:41.839] ..$ user : NULL [12:31:41.839] ..$ revtunnel : logi NA [12:31:41.839] ..$ rshlogfile : NULL [12:31:41.839] ..$ rshopts : NULL [12:31:41.839] ..$ rank : int 1 [12:31:41.839] ..$ manual : logi FALSE [12:31:41.839] ..$ dryrun : logi FALSE [12:31:41.839] ..$ quiet : logi FALSE [12:31:41.839] ..$ setup_strategy : chr "parallel" [12:31:41.839] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:41.873] [local output] System call to launch all workers: [12:31:41.873] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad42feb1d5.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36829 OUT=/dev/null TIMEOUT=120 XDR=TRUE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:41.873] [local output] Starting PSOCK main server [12:31:41.879] [local output] Workers launched [12:31:41.880] [local output] Waiting for workers to connect back [12:31:41.880] - [local output] 0 workers out of 1 ready [12:31:42.103] - [local output] 0 workers out of 1 ready [12:31:42.104] - [local output] 1 workers out of 1 ready [12:31:42.104] [local output] Launching of 1 workers completed [12:31:42.104] [local output] Number of nodes in cluster: 1 [12:31:42.105] [local output] Collecting session information from 1 workers [12:31:42.106] [local output] - Worker #1 of 1 [12:31:42.106] [local output] makeClusterPSOCK() ... done [12:31:42.112] [local output] makeClusterPSOCK() ... [12:31:42.115] [local output] Workers: [n = 1] 'localhost' [12:31:42.119] [local output] Base port: 29061 [12:31:42.119] [local output] Getting setup options for 1 cluster nodes ... [12:31:42.119] [local output] - Node #1 of 1 ... [12:31:42.120] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:42.122] [local output] Rscript port: 29061 [12:31:42.123] [local output] Getting setup options for 1 cluster nodes ... done [12:31:42.123] [local output] - Parallel setup requested for some PSOCK nodes [12:31:42.124] [local output] Setting up PSOCK nodes in parallel [12:31:42.124] List of 36 [12:31:42.124] $ worker : chr "localhost" [12:31:42.124] ..- attr(*, "localhost")= logi TRUE [12:31:42.124] $ master : chr "localhost" [12:31:42.124] $ port : int 29061 [12:31:42.124] $ connectTimeout : num 120 [12:31:42.124] $ timeout : num 120 [12:31:42.124] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:42.124] $ homogeneous : logi TRUE [12:31:42.124] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:42.124] $ rscript_envs : NULL [12:31:42.124] $ rscript_libs : NULL [12:31:42.124] $ rscript_startup : NULL [12:31:42.124] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:42.124] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:42.124] $ methods : logi TRUE [12:31:42.124] $ socketOptions : chr "no-delay" [12:31:42.124] $ useXDR : logi FALSE [12:31:42.124] $ outfile : chr "/dev/null" [12:31:42.124] $ renice : int NA [12:31:42.124] $ rshcmd : NULL [12:31:42.124] $ user : chr(0) [12:31:42.124] $ revtunnel : logi FALSE [12:31:42.124] $ rshlogfile : NULL [12:31:42.124] $ rshopts : chr(0) [12:31:42.124] $ rank : int 1 [12:31:42.124] $ manual : logi FALSE [12:31:42.124] $ dryrun : logi FALSE [12:31:42.124] $ quiet : logi FALSE [12:31:42.124] $ setup_strategy : chr "parallel" [12:31:42.124] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:42.124] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4f9c23e5.pid" [12:31:42.124] $ rshcmd_label : NULL [12:31:42.124] $ rsh_call : NULL [12:31:42.124] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:42.124] $ localMachine : logi TRUE [12:31:42.124] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:42.124] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:42.124] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:42.124] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:42.124] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:42.124] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:42.124] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:42.124] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:42.124] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:42.124] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:42.124] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:42.124] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:42.124] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:42.124] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:42.124] $ arguments :List of 28 [12:31:42.124] ..$ worker : chr "localhost" [12:31:42.124] ..$ master : NULL [12:31:42.124] ..$ port : int 29061 [12:31:42.124] ..$ connectTimeout : num 120 [12:31:42.124] ..$ timeout : num 120 [12:31:42.124] ..$ rscript : NULL [12:31:42.124] ..$ homogeneous : NULL [12:31:42.124] ..$ rscript_args : NULL [12:31:42.124] ..$ rscript_envs : NULL [12:31:42.124] ..$ rscript_libs : NULL [12:31:42.124] ..$ rscript_startup : NULL [12:31:42.124] ..$ rscript_sh : chr "auto" [12:31:42.124] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:42.124] ..$ methods : logi TRUE [12:31:42.124] ..$ socketOptions : chr "no-delay" [12:31:42.124] ..$ useXDR : logi FALSE [12:31:42.124] ..$ outfile : chr "/dev/null" [12:31:42.124] ..$ renice : int NA [12:31:42.124] ..$ rshcmd : NULL [12:31:42.124] ..$ user : NULL [12:31:42.124] ..$ revtunnel : logi NA [12:31:42.124] ..$ rshlogfile : NULL [12:31:42.124] ..$ rshopts : NULL [12:31:42.124] ..$ rank : int 1 [12:31:42.124] ..$ manual : logi FALSE [12:31:42.124] ..$ dryrun : logi FALSE [12:31:42.124] ..$ quiet : logi FALSE [12:31:42.124] ..$ setup_strategy : chr "parallel" [12:31:42.124] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:42.159] [local output] System call to launch all workers: [12:31:42.159] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4f9c23e5.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=29061 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:42.160] [local output] Starting PSOCK main server [12:31:42.166] [local output] Workers launched [12:31:42.166] [local output] Waiting for workers to connect back [12:31:42.166] - [local output] 0 workers out of 1 ready [12:31:42.406] - [local output] 0 workers out of 1 ready [12:31:42.407] - [local output] 1 workers out of 1 ready [12:31:42.407] [local output] Launching of 1 workers completed [12:31:42.407] [local output] Number of nodes in cluster: 1 [12:31:42.408] [local output] Collecting session information from 1 workers [12:31:42.409] [local output] - Worker #1 of 1 [12:31:42.409] [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) + } [12:31:42.422] [local output] makeClusterPSOCK() ... [12:31:42.426] [local output] Workers: [n = 1] 'localhost' [12:31:42.429] [local output] Base port: 36699 [12:31:42.430] [local output] Getting setup options for 1 cluster nodes ... [12:31:42.430] [local output] - Node #1 of 1 ... [12:31:42.431] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:42.432] [local output] Rscript port: 36699 [12:31:42.433] [local output] Getting setup options for 1 cluster nodes ... done [12:31:42.433] [local output] - Parallel setup requested for some PSOCK nodes [12:31:42.433] [local output] Setting up PSOCK nodes in parallel [12:31:42.434] List of 36 [12:31:42.434] $ worker : chr "localhost" [12:31:42.434] ..- attr(*, "localhost")= logi TRUE [12:31:42.434] $ master : chr "localhost" [12:31:42.434] $ port : int 36699 [12:31:42.434] $ connectTimeout : num 120 [12:31:42.434] $ timeout : num 120 [12:31:42.434] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:42.434] $ homogeneous : logi TRUE [12:31:42.434] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:42.434] $ rscript_envs : NULL [12:31:42.434] $ rscript_libs : NULL [12:31:42.434] $ rscript_startup : NULL [12:31:42.434] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:42.434] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:42.434] $ methods : logi TRUE [12:31:42.434] $ socketOptions : NULL [12:31:42.434] $ useXDR : logi FALSE [12:31:42.434] $ outfile : chr "/dev/null" [12:31:42.434] $ renice : int NA [12:31:42.434] $ rshcmd : NULL [12:31:42.434] $ user : chr(0) [12:31:42.434] $ revtunnel : logi FALSE [12:31:42.434] $ rshlogfile : NULL [12:31:42.434] $ rshopts : chr(0) [12:31:42.434] $ rank : int 1 [12:31:42.434] $ manual : logi FALSE [12:31:42.434] $ dryrun : logi FALSE [12:31:42.434] $ quiet : logi FALSE [12:31:42.434] $ setup_strategy : chr "parallel" [12:31:42.434] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:42.434] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4279160e3.pid" [12:31:42.434] $ rshcmd_label : NULL [12:31:42.434] $ rsh_call : NULL [12:31:42.434] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:42.434] $ localMachine : logi TRUE [12:31:42.434] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:42.434] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:42.434] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:42.434] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:42.434] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:42.434] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:42.434] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:42.434] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:42.434] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:42.434] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:42.434] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:42.434] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:42.434] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:42.434] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:42.434] $ arguments :List of 28 [12:31:42.434] ..$ worker : chr "localhost" [12:31:42.434] ..$ master : NULL [12:31:42.434] ..$ port : int 36699 [12:31:42.434] ..$ connectTimeout : num 120 [12:31:42.434] ..$ timeout : num 120 [12:31:42.434] ..$ rscript : NULL [12:31:42.434] ..$ homogeneous : NULL [12:31:42.434] ..$ rscript_args : NULL [12:31:42.434] ..$ rscript_envs : NULL [12:31:42.434] ..$ rscript_libs : NULL [12:31:42.434] ..$ rscript_startup : NULL [12:31:42.434] ..$ rscript_sh : chr "auto" [12:31:42.434] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:42.434] ..$ methods : logi TRUE [12:31:42.434] ..$ socketOptions : NULL [12:31:42.434] ..$ useXDR : logi FALSE [12:31:42.434] ..$ outfile : chr "/dev/null" [12:31:42.434] ..$ renice : int NA [12:31:42.434] ..$ rshcmd : NULL [12:31:42.434] ..$ user : NULL [12:31:42.434] ..$ revtunnel : logi NA [12:31:42.434] ..$ rshlogfile : NULL [12:31:42.434] ..$ rshopts : NULL [12:31:42.434] ..$ rank : int 1 [12:31:42.434] ..$ manual : logi FALSE [12:31:42.434] ..$ dryrun : logi FALSE [12:31:42.434] ..$ quiet : logi FALSE [12:31:42.434] ..$ setup_strategy : chr "parallel" [12:31:42.434] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:42.459] [local output] System call to launch all workers: [12:31:42.459] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4279160e3.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=36699 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:42.460] [local output] Starting PSOCK main server [12:31:42.466] [local output] Workers launched [12:31:42.466] [local output] Waiting for workers to connect back [12:31:42.466] - [local output] 0 workers out of 1 ready [12:31:42.705] - [local output] 0 workers out of 1 ready [12:31:42.705] - [local output] 1 workers out of 1 ready [12:31:42.706] [local output] Launching of 1 workers completed [12:31:42.706] [local output] Number of nodes in cluster: 1 [12:31:42.706] [local output] Collecting session information from 1 workers [12:31:42.707] [local output] - Worker #1 of 1 [12:31:42.707] [local output] makeClusterPSOCK() ... done [12:31:42.712] [local output] makeClusterPSOCK() ... [12:31:42.716] [local output] Workers: [n = 1] 'localhost' [12:31:42.719] [local output] Base port: 22686 [12:31:42.719] [local output] Getting setup options for 1 cluster nodes ... [12:31:42.719] [local output] - Node #1 of 1 ... [12:31:42.720] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:42.722] [local output] Rscript port: 22686 [12:31:42.722] [local output] Getting setup options for 1 cluster nodes ... done [12:31:42.723] [local output] - Parallel setup requested for some PSOCK nodes [12:31:42.723] [local output] Setting up PSOCK nodes in parallel [12:31:42.724] List of 36 [12:31:42.724] $ worker : chr "localhost" [12:31:42.724] ..- attr(*, "localhost")= logi TRUE [12:31:42.724] $ master : chr "localhost" [12:31:42.724] $ port : int 22686 [12:31:42.724] $ connectTimeout : num 120 [12:31:42.724] $ timeout : num 120 [12:31:42.724] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:42.724] $ homogeneous : logi TRUE [12:31:42.724] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:42.724] $ rscript_envs : NULL [12:31:42.724] $ rscript_libs : NULL [12:31:42.724] $ rscript_startup : NULL [12:31:42.724] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:42.724] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:42.724] $ methods : logi TRUE [12:31:42.724] $ socketOptions : NULL [12:31:42.724] $ useXDR : logi FALSE [12:31:42.724] $ outfile : chr "/dev/null" [12:31:42.724] $ renice : int NA [12:31:42.724] $ rshcmd : NULL [12:31:42.724] $ user : chr(0) [12:31:42.724] $ revtunnel : logi FALSE [12:31:42.724] $ rshlogfile : NULL [12:31:42.724] $ rshopts : chr(0) [12:31:42.724] $ rank : int 1 [12:31:42.724] $ manual : logi FALSE [12:31:42.724] $ dryrun : logi FALSE [12:31:42.724] $ quiet : logi FALSE [12:31:42.724] $ setup_strategy : chr "parallel" [12:31:42.724] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:42.724] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad412dd6163.pid" [12:31:42.724] $ rshcmd_label : NULL [12:31:42.724] $ rsh_call : NULL [12:31:42.724] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:42.724] $ localMachine : logi TRUE [12:31:42.724] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:42.724] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:42.724] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:42.724] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:42.724] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:42.724] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:42.724] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:42.724] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:42.724] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:42.724] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:42.724] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:42.724] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:42.724] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:42.724] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:42.724] $ arguments :List of 28 [12:31:42.724] ..$ worker : chr "localhost" [12:31:42.724] ..$ master : NULL [12:31:42.724] ..$ port : int 22686 [12:31:42.724] ..$ connectTimeout : num 120 [12:31:42.724] ..$ timeout : num 120 [12:31:42.724] ..$ rscript : NULL [12:31:42.724] ..$ homogeneous : NULL [12:31:42.724] ..$ rscript_args : NULL [12:31:42.724] ..$ rscript_envs : NULL [12:31:42.724] ..$ rscript_libs : NULL [12:31:42.724] ..$ rscript_startup : NULL [12:31:42.724] ..$ rscript_sh : chr "auto" [12:31:42.724] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:42.724] ..$ methods : logi TRUE [12:31:42.724] ..$ socketOptions : chr "NULL" [12:31:42.724] ..$ useXDR : logi FALSE [12:31:42.724] ..$ outfile : chr "/dev/null" [12:31:42.724] ..$ renice : int NA [12:31:42.724] ..$ rshcmd : NULL [12:31:42.724] ..$ user : NULL [12:31:42.724] ..$ revtunnel : logi NA [12:31:42.724] ..$ rshlogfile : NULL [12:31:42.724] ..$ rshopts : NULL [12:31:42.724] ..$ rank : int 1 [12:31:42.724] ..$ manual : logi FALSE [12:31:42.724] ..$ dryrun : logi FALSE [12:31:42.724] ..$ quiet : logi FALSE [12:31:42.724] ..$ setup_strategy : chr "parallel" [12:31:42.724] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:42.749] [local output] System call to launch all workers: [12:31:42.749] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad412dd6163.pid\")), silent = TRUE)" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=22686 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:42.749] [local output] Starting PSOCK main server [12:31:42.754] [local output] Workers launched [12:31:42.755] [local output] Waiting for workers to connect back [12:31:42.755] - [local output] 0 workers out of 1 ready [12:31:42.991] - [local output] 0 workers out of 1 ready [12:31:42.992] - [local output] 1 workers out of 1 ready [12:31:42.992] [local output] Launching of 1 workers completed [12:31:42.993] [local output] Number of nodes in cluster: 1 [12:31:42.993] [local output] Collecting session information from 1 workers [12:31:42.994] [local output] - Worker #1 of 1 [12:31:42.994] [local output] makeClusterPSOCK() ... done [12:31:42.999] [local output] makeClusterPSOCK() ... [12:31:43.002] [local output] Workers: [n = 1] 'localhost' [12:31:43.005] [local output] Base port: 34918 [12:31:43.006] [local output] Getting setup options for 1 cluster nodes ... [12:31:43.006] [local output] - Node #1 of 1 ... [12:31:43.007] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:43.009] [local output] Rscript port: 34918 [12:31:43.009] [local output] Getting setup options for 1 cluster nodes ... done [12:31:43.009] [local output] - Parallel setup requested for some PSOCK nodes [12:31:43.010] [local output] Setting up PSOCK nodes in parallel [12:31:43.010] List of 36 [12:31:43.010] $ worker : chr "localhost" [12:31:43.010] ..- attr(*, "localhost")= logi TRUE [12:31:43.010] $ master : chr "localhost" [12:31:43.010] $ port : int 34918 [12:31:43.010] $ connectTimeout : num 120 [12:31:43.010] $ timeout : num 120 [12:31:43.010] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:43.010] $ homogeneous : logi TRUE [12:31:43.010] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:43.010] $ rscript_envs : NULL [12:31:43.010] $ rscript_libs : NULL [12:31:43.010] $ rscript_startup : NULL [12:31:43.010] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:43.010] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.010] $ methods : logi TRUE [12:31:43.010] $ socketOptions : chr "no-delay" [12:31:43.010] $ useXDR : logi FALSE [12:31:43.010] $ outfile : chr "/dev/null" [12:31:43.010] $ renice : int NA [12:31:43.010] $ rshcmd : NULL [12:31:43.010] $ user : chr(0) [12:31:43.010] $ revtunnel : logi FALSE [12:31:43.010] $ rshlogfile : NULL [12:31:43.010] $ rshopts : chr(0) [12:31:43.010] $ rank : int 1 [12:31:43.010] $ manual : logi FALSE [12:31:43.010] $ dryrun : logi FALSE [12:31:43.010] $ quiet : logi FALSE [12:31:43.010] $ setup_strategy : chr "parallel" [12:31:43.010] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.010] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad47f252747.pid" [12:31:43.010] $ rshcmd_label : NULL [12:31:43.010] $ rsh_call : NULL [12:31:43.010] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.010] $ localMachine : logi TRUE [12:31:43.010] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:43.010] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:43.010] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:43.010] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:43.010] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:43.010] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:43.010] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:43.010] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:43.010] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:43.010] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:43.010] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:43.010] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:43.010] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:43.010] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:43.010] $ arguments :List of 28 [12:31:43.010] ..$ worker : chr "localhost" [12:31:43.010] ..$ master : NULL [12:31:43.010] ..$ port : int 34918 [12:31:43.010] ..$ connectTimeout : num 120 [12:31:43.010] ..$ timeout : num 120 [12:31:43.010] ..$ rscript : NULL [12:31:43.010] ..$ homogeneous : NULL [12:31:43.010] ..$ rscript_args : NULL [12:31:43.010] ..$ rscript_envs : NULL [12:31:43.010] ..$ rscript_libs : NULL [12:31:43.010] ..$ rscript_startup : NULL [12:31:43.010] ..$ rscript_sh : chr "auto" [12:31:43.010] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.010] ..$ methods : logi TRUE [12:31:43.010] ..$ socketOptions : chr "no-delay" [12:31:43.010] ..$ useXDR : logi FALSE [12:31:43.010] ..$ outfile : chr "/dev/null" [12:31:43.010] ..$ renice : int NA [12:31:43.010] ..$ rshcmd : NULL [12:31:43.010] ..$ user : NULL [12:31:43.010] ..$ revtunnel : logi NA [12:31:43.010] ..$ rshlogfile : NULL [12:31:43.010] ..$ rshopts : NULL [12:31:43.010] ..$ rank : int 1 [12:31:43.010] ..$ manual : logi FALSE [12:31:43.010] ..$ dryrun : logi FALSE [12:31:43.010] ..$ quiet : logi FALSE [12:31:43.010] ..$ setup_strategy : chr "parallel" [12:31:43.010] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:43.042] [local output] System call to launch all workers: [12:31:43.042] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad47f252747.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34918 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:43.042] [local output] Starting PSOCK main server [12:31:43.049] [local output] Workers launched [12:31:43.049] [local output] Waiting for workers to connect back [12:31:43.049] - [local output] 0 workers out of 1 ready [12:31:43.304] - [local output] 0 workers out of 1 ready [12:31:43.304] - [local output] 1 workers out of 1 ready [12:31:43.305] [local output] Launching of 1 workers completed [12:31:43.305] [local output] Number of nodes in cluster: 1 [12:31:43.305] [local output] Collecting session information from 1 workers [12:31:43.307] [local output] - Worker #1 of 1 [12:31:43.307] [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) + } [12:31:43.323] [local output] makeClusterPSOCK() ... [12:31:43.326] [local output] Workers: [n = 1] 'localhost' [12:31:43.330] [local output] Base port: 33831 [12:31:43.330] [local output] Getting setup options for 1 cluster nodes ... [12:31:43.330] [local output] - Node #1 of 1 ... [12:31:43.331] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:43.333] [local output] Rscript port: 33831 [12:31:43.334] [local output] Getting setup options for 1 cluster nodes ... done [12:31:43.334] [local output] - Parallel setup requested for some PSOCK nodes [12:31:43.335] [local output] Setting up PSOCK nodes in parallel [12:31:43.335] List of 36 [12:31:43.335] $ worker : chr "localhost" [12:31:43.335] ..- attr(*, "localhost")= logi TRUE [12:31:43.335] $ master : chr "localhost" [12:31:43.335] $ port : int 33831 [12:31:43.335] $ connectTimeout : num 120 [12:31:43.335] $ timeout : num 120 [12:31:43.335] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:43.335] $ homogeneous : logi TRUE [12:31:43.335] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:43.335] $ rscript_envs : NULL [12:31:43.335] $ rscript_libs : NULL [12:31:43.335] $ rscript_startup : NULL [12:31:43.335] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:43.335] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.335] $ methods : logi TRUE [12:31:43.335] $ socketOptions : chr "no-delay" [12:31:43.335] $ useXDR : logi FALSE [12:31:43.335] $ outfile : chr "/dev/null" [12:31:43.335] $ renice : int NA [12:31:43.335] $ rshcmd : NULL [12:31:43.335] $ user : chr(0) [12:31:43.335] $ revtunnel : logi FALSE [12:31:43.335] $ rshlogfile : NULL [12:31:43.335] $ rshopts : chr(0) [12:31:43.335] $ rank : int 1 [12:31:43.335] $ manual : logi FALSE [12:31:43.335] $ dryrun : logi FALSE [12:31:43.335] $ quiet : logi FALSE [12:31:43.335] $ setup_strategy : chr "parallel" [12:31:43.335] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.335] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad44db37a85.pid" [12:31:43.335] $ rshcmd_label : NULL [12:31:43.335] $ rsh_call : NULL [12:31:43.335] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.335] $ localMachine : logi TRUE [12:31:43.335] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:43.335] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:43.335] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:43.335] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:43.335] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:43.335] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:43.335] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:43.335] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:43.335] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:43.335] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:43.335] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:43.335] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:43.335] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:43.335] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:43.335] $ arguments :List of 28 [12:31:43.335] ..$ worker : chr "localhost" [12:31:43.335] ..$ master : NULL [12:31:43.335] ..$ port : int 33831 [12:31:43.335] ..$ connectTimeout : num 120 [12:31:43.335] ..$ timeout : num 120 [12:31:43.335] ..$ rscript : NULL [12:31:43.335] ..$ homogeneous : NULL [12:31:43.335] ..$ rscript_args : NULL [12:31:43.335] ..$ rscript_envs : NULL [12:31:43.335] ..$ rscript_libs : NULL [12:31:43.335] ..$ rscript_startup : NULL [12:31:43.335] ..$ rscript_sh : chr "auto" [12:31:43.335] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.335] ..$ methods : logi TRUE [12:31:43.335] ..$ socketOptions : chr "no-delay" [12:31:43.335] ..$ useXDR : logi FALSE [12:31:43.335] ..$ outfile : chr "/dev/null" [12:31:43.335] ..$ renice : int NA [12:31:43.335] ..$ rshcmd : NULL [12:31:43.335] ..$ user : NULL [12:31:43.335] ..$ revtunnel : logi NA [12:31:43.335] ..$ rshlogfile : NULL [12:31:43.335] ..$ rshopts : NULL [12:31:43.335] ..$ rank : int 1 [12:31:43.335] ..$ manual : logi FALSE [12:31:43.335] ..$ dryrun : logi FALSE [12:31:43.335] ..$ quiet : logi FALSE [12:31:43.335] ..$ setup_strategy : chr "parallel" [12:31:43.335] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:43.365] [local output] System call to launch all workers: [12:31:43.365] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad44db37a85.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=33831 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:43.366] [local output] Starting PSOCK main server [12:31:43.376] [local output] Workers launched [12:31:43.376] [local output] Waiting for workers to connect back [12:31:43.377] - [local output] 0 workers out of 1 ready [12:31:43.618] - [local output] 0 workers out of 1 ready [12:31:43.619] - [local output] 1 workers out of 1 ready [12:31:43.619] [local output] Launching of 1 workers completed [12:31:43.620] [local output] Number of nodes in cluster: 1 [12:31:43.620] [local output] Collecting session information from 1 workers [12:31:43.621] [local output] - Worker #1 of 1 [12:31:43.621] [local output] makeClusterPSOCK() ... done [12:31:43.626] [local output] makeClusterPSOCK() ... [12:31:43.630] [local output] Workers: [n = 1] 'localhost' [12:31:43.633] [local output] Base port: 20224 [12:31:43.634] [local output] Getting setup options for 1 cluster nodes ... [12:31:43.634] [local output] - Node #1 of 1 ... [12:31:43.635] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:43.637] [local output] Rscript port: 20224 [12:31:43.637] [local output] Getting setup options for 1 cluster nodes ... done [12:31:43.638] [local output] - Parallel setup requested for some PSOCK nodes [12:31:43.638] [local output] Setting up PSOCK nodes in parallel [12:31:43.639] List of 36 [12:31:43.639] $ worker : chr "localhost" [12:31:43.639] ..- attr(*, "localhost")= logi TRUE [12:31:43.639] $ master : chr "localhost" [12:31:43.639] $ port : int 20224 [12:31:43.639] $ connectTimeout : num 120 [12:31:43.639] $ timeout : num 120 [12:31:43.639] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:43.639] $ homogeneous : logi TRUE [12:31:43.639] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:43.639] $ rscript_envs : NULL [12:31:43.639] $ rscript_libs : NULL [12:31:43.639] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [12:31:43.639] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:43.639] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.639] $ methods : logi TRUE [12:31:43.639] $ socketOptions : chr "no-delay" [12:31:43.639] $ useXDR : logi FALSE [12:31:43.639] $ outfile : chr "/dev/null" [12:31:43.639] $ renice : int NA [12:31:43.639] $ rshcmd : NULL [12:31:43.639] $ user : chr(0) [12:31:43.639] $ revtunnel : logi FALSE [12:31:43.639] $ rshlogfile : NULL [12:31:43.639] $ rshopts : chr(0) [12:31:43.639] $ rank : int 1 [12:31:43.639] $ manual : logi FALSE [12:31:43.639] $ dryrun : logi FALSE [12:31:43.639] $ quiet : logi FALSE [12:31:43.639] $ setup_strategy : chr "parallel" [12:31:43.639] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.639] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad44ac6132b.pid" [12:31:43.639] $ rshcmd_label : NULL [12:31:43.639] $ rsh_call : NULL [12:31:43.639] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.639] $ localMachine : logi TRUE [12:31:43.639] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:43.639] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:43.639] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:43.639] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:43.639] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:43.639] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:43.639] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:43.639] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:43.639] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:43.639] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:43.639] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:43.639] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:43.639] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:43.639] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:43.639] $ arguments :List of 28 [12:31:43.639] ..$ worker : chr "localhost" [12:31:43.639] ..$ master : NULL [12:31:43.639] ..$ port : int 20224 [12:31:43.639] ..$ connectTimeout : num 120 [12:31:43.639] ..$ timeout : num 120 [12:31:43.639] ..$ rscript : NULL [12:31:43.639] ..$ homogeneous : NULL [12:31:43.639] ..$ rscript_args : NULL [12:31:43.639] ..$ rscript_envs : NULL [12:31:43.639] ..$ rscript_libs : NULL [12:31:43.639] ..$ rscript_startup : chr "options(abc = 42L)" [12:31:43.639] ..$ rscript_sh : chr "auto" [12:31:43.639] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.639] ..$ methods : logi TRUE [12:31:43.639] ..$ socketOptions : chr "no-delay" [12:31:43.639] ..$ useXDR : logi FALSE [12:31:43.639] ..$ outfile : chr "/dev/null" [12:31:43.639] ..$ renice : int NA [12:31:43.639] ..$ rshcmd : NULL [12:31:43.639] ..$ user : NULL [12:31:43.639] ..$ revtunnel : logi NA [12:31:43.639] ..$ rshlogfile : NULL [12:31:43.639] ..$ rshopts : NULL [12:31:43.639] ..$ rank : int 1 [12:31:43.639] ..$ manual : logi FALSE [12:31:43.639] ..$ dryrun : logi FALSE [12:31:43.639] ..$ quiet : logi FALSE [12:31:43.639] ..$ setup_strategy : chr "parallel" [12:31:43.639] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:43.673] [local output] System call to launch all workers: [12:31:43.674] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad44ac6132b.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=20224 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:43.674] [local output] Starting PSOCK main server [12:31:43.680] [local output] Workers launched [12:31:43.680] [local output] Waiting for workers to connect back [12:31:43.680] - [local output] 0 workers out of 1 ready [12:31:43.934] - [local output] 0 workers out of 1 ready [12:31:43.946] - [local output] 1 workers out of 1 ready [12:31:43.946] [local output] Launching of 1 workers completed [12:31:43.947] [local output] Number of nodes in cluster: 1 [12:31:43.947] [local output] Collecting session information from 1 workers [12:31:43.948] [local output] - Worker #1 of 1 [12:31:43.948] [local output] makeClusterPSOCK() ... done [12:31:43.955] [local output] makeClusterPSOCK() ... [12:31:43.959] [local output] Workers: [n = 1] 'localhost' [12:31:43.963] [local output] Base port: 30838 [12:31:43.963] [local output] Getting setup options for 1 cluster nodes ... [12:31:43.964] [local output] - Node #1 of 1 ... [12:31:43.965] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:43.967] [local output] Rscript port: 30838 [12:31:43.967] [local output] Getting setup options for 1 cluster nodes ... done [12:31:43.967] [local output] - Parallel setup requested for some PSOCK nodes [12:31:43.968] [local output] Setting up PSOCK nodes in parallel [12:31:43.968] List of 36 [12:31:43.968] $ worker : chr "localhost" [12:31:43.968] ..- attr(*, "localhost")= logi TRUE [12:31:43.968] $ master : chr "localhost" [12:31:43.968] $ port : int 30838 [12:31:43.968] $ connectTimeout : num 120 [12:31:43.968] $ timeout : num 120 [12:31:43.968] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:43.968] $ homogeneous : logi TRUE [12:31:43.968] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:43.968] $ rscript_envs : NULL [12:31:43.968] $ rscript_libs : NULL [12:31:43.968] $ rscript_startup : chr [1:2] "-e" "\"invisible({options(abc = 42L)})\"" [12:31:43.968] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:43.968] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.968] $ methods : logi TRUE [12:31:43.968] $ socketOptions : chr "no-delay" [12:31:43.968] $ useXDR : logi FALSE [12:31:43.968] $ outfile : chr "/dev/null" [12:31:43.968] $ renice : int NA [12:31:43.968] $ rshcmd : NULL [12:31:43.968] $ user : chr(0) [12:31:43.968] $ revtunnel : logi FALSE [12:31:43.968] $ rshlogfile : NULL [12:31:43.968] $ rshopts : chr(0) [12:31:43.968] $ rank : int 1 [12:31:43.968] $ manual : logi FALSE [12:31:43.968] $ dryrun : logi FALSE [12:31:43.968] $ quiet : logi FALSE [12:31:43.968] $ setup_strategy : chr "parallel" [12:31:43.968] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.968] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad46f2c24a0.pid" [12:31:43.968] $ rshcmd_label : NULL [12:31:43.968] $ rsh_call : NULL [12:31:43.968] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:43.968] $ localMachine : logi TRUE [12:31:43.968] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:43.968] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:43.968] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:43.968] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:43.968] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:43.968] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:43.968] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:43.968] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:43.968] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:43.968] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:43.968] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:43.968] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:43.968] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:43.968] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:43.968] $ arguments :List of 28 [12:31:43.968] ..$ worker : chr "localhost" [12:31:43.968] ..$ master : NULL [12:31:43.968] ..$ port : int 30838 [12:31:43.968] ..$ connectTimeout : num 120 [12:31:43.968] ..$ timeout : num 120 [12:31:43.968] ..$ rscript : NULL [12:31:43.968] ..$ homogeneous : NULL [12:31:43.968] ..$ rscript_args : NULL [12:31:43.968] ..$ rscript_envs : NULL [12:31:43.968] ..$ rscript_libs : NULL [12:31:43.968] ..$ rscript_startup : language options(abc = 42L) [12:31:43.968] ..$ rscript_sh : chr "auto" [12:31:43.968] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:43.968] ..$ methods : logi TRUE [12:31:43.968] ..$ socketOptions : chr "no-delay" [12:31:43.968] ..$ useXDR : logi FALSE [12:31:43.968] ..$ outfile : chr "/dev/null" [12:31:43.968] ..$ renice : int NA [12:31:43.968] ..$ rshcmd : NULL [12:31:43.968] ..$ user : NULL [12:31:43.968] ..$ revtunnel : logi NA [12:31:43.968] ..$ rshlogfile : NULL [12:31:43.968] ..$ rshopts : NULL [12:31:43.968] ..$ rank : int 1 [12:31:43.968] ..$ manual : logi FALSE [12:31:43.968] ..$ dryrun : logi FALSE [12:31:43.968] ..$ quiet : logi FALSE [12:31:43.968] ..$ setup_strategy : chr "parallel" [12:31:43.968] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:44.007] [local output] System call to launch all workers: [12:31:44.007] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad46f2c24a0.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=30838 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:44.007] [local output] Starting PSOCK main server [12:31:44.013] [local output] Workers launched [12:31:44.014] [local output] Waiting for workers to connect back [12:31:44.014] - [local output] 0 workers out of 1 ready [12:31:44.264] - [local output] 0 workers out of 1 ready [12:31:44.265] - [local output] 1 workers out of 1 ready [12:31:44.265] [local output] Launching of 1 workers completed [12:31:44.265] [local output] Number of nodes in cluster: 1 [12:31:44.266] [local output] Collecting session information from 1 workers [12:31:44.267] [local output] - Worker #1 of 1 [12:31:44.267] [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) + } [12:31:44.318] [local output] makeClusterPSOCK() ... [12:31:44.322] [local output] Workers: [n = 2] 'localhost', 'localhost' [12:31:44.325] [local output] Base port: 26479 [12:31:44.326] [local output] Getting setup options for 2 cluster nodes ... [12:31:44.326] [local output] - Node #1 of 2 ... [12:31:44.327] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:44.328] [local output] Rscript port: 26479 [12:31:44.329] [local output] - Node #2 of 2 ... [12:31:44.330] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:44.331] [local output] Rscript port: 26479 [12:31:44.332] [local output] Getting setup options for 2 cluster nodes ... done [12:31:44.332] [local output] Creating node #1 of 2 ... [12:31:44.332] [local output] - setting up node [12:31:44.333] [local output] - attempt #1 of 3 [12:31:44.333] [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:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad460132e2c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26479 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [12:31:44.339] [local output] - Exit code of system() call: 0 [12:31:44.339] [local output] Waiting for worker #1 on 'localhost' to connect back [12:31:44.611] [local output] Connection with worker #1 on 'localhost' established [12:31:44.612] [local output] Creating node #1 of 2 ... done [12:31:44.613] [local output] Creating node #2 of 2 ... [12:31:44.613] [local output] - setting up node [12:31:44.613] [local output] - attempt #1 of 3 [12:31:44.614] [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:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=2.parallelly.parent=92884.16ad47fa228f2.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=26479 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=sequential [12:31:44.620] [local output] - Exit code of system() call: 0 [12:31:44.620] [local output] Waiting for worker #2 on 'localhost' to connect back [12:31:44.885] [local output] Connection with worker #2 on 'localhost' established [12:31:44.885] [local output] Creating node #2 of 2 ... done [12:31:44.886] [local output] Launching of 2 workers completed [12:31:44.886] [local output] Number of nodes in cluster: 2 [12:31:44.886] [local output] Collecting session information from 2 workers [12:31:44.888] [local output] - Worker #1 of 2 [12:31:44.889] [local output] - Worker #2 of 2 [12:31:44.890] [local output] makeClusterPSOCK() ... done user system elapsed 0.02 0.00 0.58 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-07-26 r86926 ucrt), platform x86_64-w64-mingw32) [12:31:44.940] [local output] makeClusterPSOCK() ... [12:31:44.944] [local output] Workers: [n = 2] 'localhost', 'localhost' [12:31:44.947] [local output] Base port: 20878 [12:31:44.948] [local output] Getting setup options for 2 cluster nodes ... [12:31:44.948] [local output] - Node #1 of 2 ... [12:31:44.949] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:44.951] [local output] Rscript port: 20878 [12:31:44.951] [local output] - Node #2 of 2 ... [12:31:44.952] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:44.954] [local output] Rscript port: 20878 [12:31:44.954] [local output] Getting setup options for 2 cluster nodes ... done [12:31:44.955] [local output] - Parallel setup requested for some PSOCK nodes [12:31:44.955] [local output] Setting up PSOCK nodes in parallel [12:31:44.956] List of 36 [12:31:44.956] $ worker : chr "localhost" [12:31:44.956] ..- attr(*, "localhost")= logi TRUE [12:31:44.956] $ master : chr "localhost" [12:31:44.956] $ port : int 20878 [12:31:44.956] $ connectTimeout : num 120 [12:31:44.956] $ timeout : num 120 [12:31:44.956] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:44.956] $ homogeneous : logi TRUE [12:31:44.956] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:44.956] $ rscript_envs : NULL [12:31:44.956] $ rscript_libs : NULL [12:31:44.956] $ rscript_startup : NULL [12:31:44.956] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:44.956] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:44.956] $ methods : logi TRUE [12:31:44.956] $ socketOptions : chr "no-delay" [12:31:44.956] $ useXDR : logi FALSE [12:31:44.956] $ outfile : chr "/dev/null" [12:31:44.956] $ renice : int NA [12:31:44.956] $ rshcmd : NULL [12:31:44.956] $ user : chr(0) [12:31:44.956] $ revtunnel : logi FALSE [12:31:44.956] $ rshlogfile : NULL [12:31:44.956] $ rshopts : chr(0) [12:31:44.956] $ rank : int 1 [12:31:44.956] $ manual : logi FALSE [12:31:44.956] $ dryrun : logi FALSE [12:31:44.956] $ quiet : logi FALSE [12:31:44.956] $ setup_strategy : chr "parallel" [12:31:44.956] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:44.956] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad42cb249dd.pid" [12:31:44.956] $ rshcmd_label : NULL [12:31:44.956] $ rsh_call : NULL [12:31:44.956] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:44.956] $ localMachine : logi TRUE [12:31:44.956] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:44.956] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:44.956] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:44.956] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:44.956] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:44.956] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:44.956] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:44.956] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:44.956] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:44.956] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:44.956] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:44.956] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:44.956] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:44.956] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:44.956] $ arguments :List of 28 [12:31:44.956] ..$ worker : chr "localhost" [12:31:44.956] ..$ master : NULL [12:31:44.956] ..$ port : int 20878 [12:31:44.956] ..$ connectTimeout : num 120 [12:31:44.956] ..$ timeout : num 120 [12:31:44.956] ..$ rscript : NULL [12:31:44.956] ..$ homogeneous : NULL [12:31:44.956] ..$ rscript_args : NULL [12:31:44.956] ..$ rscript_envs : NULL [12:31:44.956] ..$ rscript_libs : NULL [12:31:44.956] ..$ rscript_startup : NULL [12:31:44.956] ..$ rscript_sh : chr "auto" [12:31:44.956] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:44.956] ..$ methods : logi TRUE [12:31:44.956] ..$ socketOptions : chr "no-delay" [12:31:44.956] ..$ useXDR : logi FALSE [12:31:44.956] ..$ outfile : chr "/dev/null" [12:31:44.956] ..$ renice : int NA [12:31:44.956] ..$ rshcmd : NULL [12:31:44.956] ..$ user : NULL [12:31:44.956] ..$ revtunnel : logi NA [12:31:44.956] ..$ rshlogfile : NULL [12:31:44.956] ..$ rshopts : NULL [12:31:44.956] ..$ rank : int 1 [12:31:44.956] ..$ manual : logi FALSE [12:31:44.956] ..$ dryrun : logi FALSE [12:31:44.956] ..$ quiet : logi FALSE [12:31:44.956] ..$ setup_strategy : chr "parallel" [12:31:44.956] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:44.990] [local output] System call to launch all workers: [12:31:44.990] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad42cb249dd.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=20878 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:44.990] [local output] Starting PSOCK main server [12:31:44.999] [local output] Workers launched [12:31:45.000] [local output] Waiting for workers to connect back [12:31:45.000] - [local output] 0 workers out of 2 ready [12:31:45.240] - [local output] 0 workers out of 2 ready [12:31:45.241] - [local output] 1 workers out of 2 ready [12:31:45.272] - [local output] 1 workers out of 2 ready [12:31:45.272] - [local output] 2 workers out of 2 ready [12:31:45.273] [local output] Launching of 2 workers completed [12:31:45.273] [local output] Number of nodes in cluster: 2 [12:31:45.273] [local output] Collecting session information from 2 workers [12:31:45.274] [local output] - Worker #1 of 2 [12:31:45.275] [local output] - Worker #2 of 2 [12:31:45.275] [local output] makeClusterPSOCK() ... done user system elapsed 0.08 0.00 0.34 Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2024-07-26 r86926 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 [12:31:45.284] [local output] makeClusterPSOCK() ... [12:31:45.289] [local output] Workers: [n = 1] 'localhost' [12:31:45.293] [local output] Base port: 23949 [12:31:45.293] [local output] Getting setup options for 1 cluster nodes ... [12:31:45.293] [local output] - Node #1 of 1 ... [12:31:45.294] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:45.297] [local output] Rscript port: 23949 [12:31:45.297] [local output] Getting setup options for 1 cluster nodes ... done [12:31:45.298] [local output] - Parallel setup requested for some PSOCK nodes [12:31:45.298] [local output] Setting up PSOCK nodes in parallel [12:31:45.299] List of 36 [12:31:45.299] $ worker : chr "localhost" [12:31:45.299] ..- attr(*, "localhost")= logi TRUE [12:31:45.299] $ master : chr "localhost" [12:31:45.299] $ port : int 23949 [12:31:45.299] $ connectTimeout : num 120 [12:31:45.299] $ timeout : num 120 [12:31:45.299] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:45.299] $ homogeneous : logi TRUE [12:31:45.299] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:45.299] $ rscript_envs : NULL [12:31:45.299] $ rscript_libs : NULL [12:31:45.299] $ rscript_startup : NULL [12:31:45.299] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:45.299] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:45.299] $ methods : logi TRUE [12:31:45.299] $ socketOptions : chr "no-delay" [12:31:45.299] $ useXDR : logi FALSE [12:31:45.299] $ outfile : chr "/dev/null" [12:31:45.299] $ renice : int NA [12:31:45.299] $ rshcmd : NULL [12:31:45.299] $ user : chr(0) [12:31:45.299] $ revtunnel : logi FALSE [12:31:45.299] $ rshlogfile : NULL [12:31:45.299] $ rshopts : chr(0) [12:31:45.299] $ rank : int 1 [12:31:45.299] $ manual : logi FALSE [12:31:45.299] $ dryrun : logi FALSE [12:31:45.299] $ quiet : logi FALSE [12:31:45.299] $ setup_strategy : chr "parallel" [12:31:45.299] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:45.299] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad41ccb4c45.pid" [12:31:45.299] $ rshcmd_label : NULL [12:31:45.299] $ rsh_call : NULL [12:31:45.299] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:45.299] $ localMachine : logi TRUE [12:31:45.299] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:45.299] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:45.299] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:45.299] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:45.299] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:45.299] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:45.299] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:45.299] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:45.299] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:45.299] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:45.299] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:45.299] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:45.299] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:45.299] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:45.299] $ arguments :List of 28 [12:31:45.299] ..$ worker : chr "localhost" [12:31:45.299] ..$ master : NULL [12:31:45.299] ..$ port : int 23949 [12:31:45.299] ..$ connectTimeout : num 120 [12:31:45.299] ..$ timeout : num 120 [12:31:45.299] ..$ rscript : NULL [12:31:45.299] ..$ homogeneous : NULL [12:31:45.299] ..$ rscript_args : NULL [12:31:45.299] ..$ rscript_envs : NULL [12:31:45.299] ..$ rscript_libs : NULL [12:31:45.299] ..$ rscript_startup : NULL [12:31:45.299] ..$ rscript_sh : chr "auto" [12:31:45.299] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:45.299] ..$ methods : logi TRUE [12:31:45.299] ..$ socketOptions : chr "no-delay" [12:31:45.299] ..$ useXDR : logi FALSE [12:31:45.299] ..$ outfile : chr "/dev/null" [12:31:45.299] ..$ renice : int NA [12:31:45.299] ..$ rshcmd : NULL [12:31:45.299] ..$ user : NULL [12:31:45.299] ..$ revtunnel : logi NA [12:31:45.299] ..$ rshlogfile : NULL [12:31:45.299] ..$ rshopts : NULL [12:31:45.299] ..$ rank : int 1 [12:31:45.299] ..$ manual : logi FALSE [12:31:45.299] ..$ dryrun : logi FALSE [12:31:45.299] ..$ quiet : logi FALSE [12:31:45.299] ..$ setup_strategy : chr "parallel" [12:31:45.299] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:45.339] [local output] System call to launch all workers: [12:31:45.340] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad41ccb4c45.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=23949 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:45.340] [local output] Starting PSOCK main server [12:31:45.347] [local output] Workers launched [12:31:45.347] [local output] Waiting for workers to connect back [12:31:45.347] - [local output] 0 workers out of 1 ready [12:31:45.587] - [local output] 0 workers out of 1 ready [12:31:45.588] - [local output] 1 workers out of 1 ready [12:31:45.588] [local output] Launching of 1 workers completed [12:31:45.588] [local output] Number of nodes in cluster: 1 [12:31:45.589] [local output] Collecting session information from 1 workers [12:31:45.590] [local output] - Worker #1 of 1 [12:31:45.590] [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) [12:31:45.597] [local output] makeClusterPSOCK() ... [12:31:45.600] [local output] Workers: [n = 1] 'localhost' [12:31:45.603] [local output] Base port: 21298 [12:31:45.604] [local output] Getting setup options for 1 cluster nodes ... [12:31:45.604] [local output] - Node #1 of 1 ... [12:31:45.605] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:45.607] [local output] Rscript port: 21298 [12:31:45.607] [local output] Getting setup options for 1 cluster nodes ... done [12:31:45.608] [local output] - Parallel setup requested for some PSOCK nodes [12:31:45.608] [local output] Setting up PSOCK nodes in parallel [12:31:45.608] List of 36 [12:31:45.608] $ worker : chr "localhost" [12:31:45.608] ..- attr(*, "localhost")= logi TRUE [12:31:45.608] $ master : chr "localhost" [12:31:45.608] $ port : int 21298 [12:31:45.608] $ connectTimeout : num 120 [12:31:45.608] $ timeout : num 120 [12:31:45.608] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:45.608] $ homogeneous : logi TRUE [12:31:45.608] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:45.608] $ rscript_envs : NULL [12:31:45.608] $ rscript_libs : NULL [12:31:45.608] $ rscript_startup : NULL [12:31:45.608] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:45.608] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:45.608] $ methods : logi TRUE [12:31:45.608] $ socketOptions : chr "no-delay" [12:31:45.608] $ useXDR : logi FALSE [12:31:45.608] $ outfile : chr "/dev/null" [12:31:45.608] $ renice : int NA [12:31:45.608] $ rshcmd : NULL [12:31:45.608] $ user : chr(0) [12:31:45.608] $ revtunnel : logi FALSE [12:31:45.608] $ rshlogfile : NULL [12:31:45.608] $ rshopts : chr(0) [12:31:45.608] $ rank : int 1 [12:31:45.608] $ manual : logi FALSE [12:31:45.608] $ dryrun : logi FALSE [12:31:45.608] $ quiet : logi FALSE [12:31:45.608] $ setup_strategy : chr "parallel" [12:31:45.608] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:45.608] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4a7f2496.pid" [12:31:45.608] $ rshcmd_label : NULL [12:31:45.608] $ rsh_call : NULL [12:31:45.608] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:45.608] $ localMachine : logi TRUE [12:31:45.608] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:45.608] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:45.608] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:45.608] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:45.608] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:45.608] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:45.608] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:45.608] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:45.608] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:45.608] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:45.608] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:45.608] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:45.608] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:45.608] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:45.608] $ arguments :List of 28 [12:31:45.608] ..$ worker : chr "localhost" [12:31:45.608] ..$ master : NULL [12:31:45.608] ..$ port : int 21298 [12:31:45.608] ..$ connectTimeout : num 120 [12:31:45.608] ..$ timeout : num 120 [12:31:45.608] ..$ rscript : NULL [12:31:45.608] ..$ homogeneous : NULL [12:31:45.608] ..$ rscript_args : NULL [12:31:45.608] ..$ rscript_envs : NULL [12:31:45.608] ..$ rscript_libs : NULL [12:31:45.608] ..$ rscript_startup : NULL [12:31:45.608] ..$ rscript_sh : chr "auto" [12:31:45.608] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:45.608] ..$ methods : logi TRUE [12:31:45.608] ..$ socketOptions : chr "no-delay" [12:31:45.608] ..$ useXDR : logi FALSE [12:31:45.608] ..$ outfile : chr "/dev/null" [12:31:45.608] ..$ renice : int NA [12:31:45.608] ..$ rshcmd : NULL [12:31:45.608] ..$ user : NULL [12:31:45.608] ..$ revtunnel : logi NA [12:31:45.608] ..$ rshlogfile : NULL [12:31:45.608] ..$ rshopts : NULL [12:31:45.608] ..$ rank : int 1 [12:31:45.608] ..$ manual : logi FALSE [12:31:45.608] ..$ dryrun : logi FALSE [12:31:45.608] ..$ quiet : logi FALSE [12:31:45.608] ..$ setup_strategy : chr "parallel" [12:31:45.608] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:45.644] [local output] System call to launch all workers: [12:31:45.644] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4a7f2496.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=21298 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:45.645] [local output] Starting PSOCK main server [12:31:45.650] [local output] Workers launched [12:31:45.651] [local output] Waiting for workers to connect back [12:31:45.651] - [local output] 0 workers out of 1 ready [12:31:45.890] - [local output] 0 workers out of 1 ready [12:31:45.890] - [local output] 1 workers out of 1 ready [12:31:45.891] [local output] Launching of 1 workers completed [12:31:45.891] [local output] Number of nodes in cluster: 1 [12:31:45.891] [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 = "") [12:31:45.897] [local output] makeClusterPSOCK() ... [12:31:45.901] [local output] Workers: [n = 1] 'localhost' [12:31:45.905] [local output] Base port: 30682 [12:31:45.905] [local output] Getting setup options for 1 cluster nodes ... [12:31:45.905] [local output] - Node #1 of 1 ... [12:31:45.906] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:45.908] [local output] Rscript port: 30682 [12:31:45.909] [local output] Getting setup options for 1 cluster nodes ... done [12:31:45.909] [local output] - Parallel setup requested for some PSOCK nodes [12:31:45.909] [local output] Setting up PSOCK nodes in parallel [12:31:45.910] List of 36 [12:31:45.910] $ worker : chr "localhost" [12:31:45.910] ..- attr(*, "localhost")= logi TRUE [12:31:45.910] $ master : chr "localhost" [12:31:45.910] $ port : int 30682 [12:31:45.910] $ connectTimeout : num 120 [12:31:45.910] $ timeout : num 120 [12:31:45.910] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:45.910] $ homogeneous : logi TRUE [12:31:45.910] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:45.910] $ rscript_envs : NULL [12:31:45.910] $ rscript_libs : NULL [12:31:45.910] $ rscript_startup : NULL [12:31:45.910] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:45.910] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:45.910] $ methods : logi TRUE [12:31:45.910] $ socketOptions : chr "no-delay" [12:31:45.910] $ useXDR : logi FALSE [12:31:45.910] $ outfile : chr "" [12:31:45.910] $ renice : int NA [12:31:45.910] $ rshcmd : NULL [12:31:45.910] $ user : chr(0) [12:31:45.910] $ revtunnel : logi FALSE [12:31:45.910] $ rshlogfile : NULL [12:31:45.910] $ rshopts : chr(0) [12:31:45.910] $ rank : int 1 [12:31:45.910] $ manual : logi FALSE [12:31:45.910] $ dryrun : logi FALSE [12:31:45.910] $ quiet : logi FALSE [12:31:45.910] $ setup_strategy : chr "parallel" [12:31:45.910] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:45.910] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4118a4c5c.pid" [12:31:45.910] $ rshcmd_label : NULL [12:31:45.910] $ rsh_call : NULL [12:31:45.910] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:45.910] $ localMachine : logi TRUE [12:31:45.910] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:45.910] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:45.910] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:45.910] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:45.910] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:45.910] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:45.910] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:45.910] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:45.910] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:45.910] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:45.910] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:45.910] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:45.910] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:45.910] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:45.910] $ arguments :List of 28 [12:31:45.910] ..$ worker : chr "localhost" [12:31:45.910] ..$ master : NULL [12:31:45.910] ..$ port : int 30682 [12:31:45.910] ..$ connectTimeout : num 120 [12:31:45.910] ..$ timeout : num 120 [12:31:45.910] ..$ rscript : NULL [12:31:45.910] ..$ homogeneous : NULL [12:31:45.910] ..$ rscript_args : NULL [12:31:45.910] ..$ rscript_envs : NULL [12:31:45.910] ..$ rscript_libs : NULL [12:31:45.910] ..$ rscript_startup : NULL [12:31:45.910] ..$ rscript_sh : chr "auto" [12:31:45.910] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:45.910] ..$ methods : logi TRUE [12:31:45.910] ..$ socketOptions : chr "no-delay" [12:31:45.910] ..$ useXDR : logi FALSE [12:31:45.910] ..$ outfile : chr "" [12:31:45.910] ..$ renice : int NA [12:31:45.910] ..$ rshcmd : NULL [12:31:45.910] ..$ user : NULL [12:31:45.910] ..$ revtunnel : logi NA [12:31:45.910] ..$ rshlogfile : NULL [12:31:45.910] ..$ rshopts : NULL [12:31:45.910] ..$ rank : int 1 [12:31:45.910] ..$ manual : logi FALSE [12:31:45.910] ..$ dryrun : logi FALSE [12:31:45.910] ..$ quiet : logi FALSE [12:31:45.910] ..$ setup_strategy : chr "parallel" [12:31:45.910] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:45.943] [local output] System call to launch all workers: [12:31:45.944] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4118a4c5c.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30682 OUT= TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:45.944] [local output] Starting PSOCK main server [12:31:45.950] [local output] Workers launched [12:31:45.950] [local output] Waiting for workers to connect back [12:31:45.950] - [local output] 0 workers out of 1 ready starting worker pid=148952 on localhost:30682 at 12:31:46.172 [12:31:46.180] - [local output] 0 workers out of 1 ready [12:31:46.181] - [local output] 1 workers out of 1 ready [12:31:46.181] [local output] Launching of 1 workers completed [12:31:46.182] [local output] Number of nodes in cluster: 1 [12:31:46.182] [local output] Collecting session information from 1 workers [12:31:46.183] [local output] - Worker #1 of 1 [12:31:46.184] [local output] makeClusterPSOCK() ... done > print(cl) Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2024-07-26 r86926 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) [12:31:46.203] [local output] makeClusterPSOCK() ... [12:31:46.208] [local output] Workers: [n = 1] 'localhost' [12:31:46.211] [local output] Base port: 30767 [12:31:46.212] [local output] Getting setup options for 1 cluster nodes ... [12:31:46.212] [local output] - Node #1 of 1 ... [12:31:46.213] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:46.215] [local output] Rscript port: 30767 [12:31:46.215] [local output] Getting setup options for 1 cluster nodes ... done [12:31:46.216] [local output] - Parallel setup requested for some PSOCK nodes [12:31:46.216] [local output] Setting up PSOCK nodes in parallel [12:31:46.217] List of 36 [12:31:46.217] $ worker : chr "localhost" [12:31:46.217] ..- attr(*, "localhost")= logi TRUE [12:31:46.217] $ master : chr "localhost" [12:31:46.217] $ port : int 30767 [12:31:46.217] $ connectTimeout : num 120 [12:31:46.217] $ timeout : num 120 [12:31:46.217] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:46.217] $ homogeneous : logi TRUE [12:31:46.217] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:46.217] $ rscript_envs : NULL [12:31:46.217] $ rscript_libs : NULL [12:31:46.217] $ rscript_startup : NULL [12:31:46.217] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:46.217] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:46.217] $ methods : logi TRUE [12:31:46.217] $ socketOptions : chr "no-delay" [12:31:46.217] $ useXDR : logi FALSE [12:31:46.217] $ outfile : chr "/dev/null" [12:31:46.217] $ renice : int NA [12:31:46.217] $ rshcmd : NULL [12:31:46.217] $ user : chr(0) [12:31:46.217] $ revtunnel : logi FALSE [12:31:46.217] $ rshlogfile : NULL [12:31:46.217] $ rshopts : chr(0) [12:31:46.217] $ rank : int 1 [12:31:46.217] $ manual : logi FALSE [12:31:46.217] $ dryrun : logi FALSE [12:31:46.217] $ quiet : logi FALSE [12:31:46.217] $ setup_strategy : chr "parallel" [12:31:46.217] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:46.217] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad41deb656a.pid" [12:31:46.217] $ rshcmd_label : NULL [12:31:46.217] $ rsh_call : NULL [12:31:46.217] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:46.217] $ localMachine : logi TRUE [12:31:46.217] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:46.217] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:46.217] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:46.217] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:46.217] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:46.217] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:46.217] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:46.217] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:46.217] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:46.217] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:46.217] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:46.217] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:46.217] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:46.217] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:46.217] $ arguments :List of 28 [12:31:46.217] ..$ worker : chr "localhost" [12:31:46.217] ..$ master : NULL [12:31:46.217] ..$ port : int 30767 [12:31:46.217] ..$ connectTimeout : num 120 [12:31:46.217] ..$ timeout : num 120 [12:31:46.217] ..$ rscript : NULL [12:31:46.217] ..$ homogeneous : NULL [12:31:46.217] ..$ rscript_args : NULL [12:31:46.217] ..$ rscript_envs : NULL [12:31:46.217] ..$ rscript_libs : NULL [12:31:46.217] ..$ rscript_startup : NULL [12:31:46.217] ..$ rscript_sh : chr "auto" [12:31:46.217] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:46.217] ..$ methods : logi TRUE [12:31:46.217] ..$ socketOptions : chr "no-delay" [12:31:46.217] ..$ useXDR : logi FALSE [12:31:46.217] ..$ outfile : chr "/dev/null" [12:31:46.217] ..$ renice : int NA [12:31:46.217] ..$ rshcmd : NULL [12:31:46.217] ..$ user : NULL [12:31:46.217] ..$ revtunnel : logi NA [12:31:46.217] ..$ rshlogfile : NULL [12:31:46.217] ..$ rshopts : NULL [12:31:46.217] ..$ rank : int 1 [12:31:46.217] ..$ manual : logi FALSE [12:31:46.217] ..$ dryrun : logi FALSE [12:31:46.217] ..$ quiet : logi FALSE [12:31:46.217] ..$ setup_strategy : chr "parallel" [12:31:46.217] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:46.248] [local output] System call to launch all workers: [12:31:46.248] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad41deb656a.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=30767 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:46.248] [local output] Starting PSOCK main server [12:31:46.253] [local output] Workers launched [12:31:46.253] [local output] Waiting for workers to connect back [12:31:46.254] - [local output] 0 workers out of 1 ready [12:31:46.514] - [local output] 0 workers out of 1 ready [12:31:46.515] - [local output] 1 workers out of 1 ready [12:31:46.516] [local output] Launching of 1 workers completed [12:31:46.516] [local output] Number of nodes in cluster: 1 [12:31:46.516] [local output] Collecting session information from 1 workers [12:31:46.517] [local output] - Worker #1 of 1 [12:31:46.518] [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' [12:31:46.534] [local output] makeClusterPSOCK() ... [12:31:46.538] [local output] Workers: [n = 1] 'localhost' [12:31:46.541] [local output] Base port: 36493 [12:31:46.541] [local output] Getting setup options for 1 cluster nodes ... [12:31:46.541] [local output] - Node #1 of 1 ... [12:31:46.542] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:46.544] 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/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad467a17e92.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad467a17e92.pid\")"' [12:31:46.992] - Possible to infer worker's PID: TRUE [12:31:46.993] [local output] Rscript port: 36493 [12:31:46.994] [local output] Getting setup options for 1 cluster nodes ... done [12:31:46.994] [local output] - Parallel setup requested for some PSOCK nodes [12:31:46.995] [local output] Setting up PSOCK nodes in parallel [12:31:46.995] List of 36 [12:31:46.995] $ worker : chr "localhost" [12:31:46.995] ..- attr(*, "localhost")= logi TRUE [12:31:46.995] $ master : chr "localhost" [12:31:46.995] $ port : int 36493 [12:31:46.995] $ connectTimeout : num 120 [12:31:46.995] $ timeout : num 120 [12:31:46.995] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [12:31:46.995] $ homogeneous : logi TRUE [12:31:46.995] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [12:31:46.995] $ rscript_envs : NULL [12:31:46.995] $ rscript_libs : NULL [12:31:46.995] $ rscript_startup : NULL [12:31:46.995] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:46.995] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:46.995] $ methods : logi TRUE [12:31:46.995] $ socketOptions : chr "no-delay" [12:31:46.995] $ useXDR : logi FALSE [12:31:46.995] $ outfile : chr "/dev/null" [12:31:46.995] $ renice : int NA [12:31:46.995] $ rshcmd : NULL [12:31:46.995] $ user : chr(0) [12:31:46.995] $ revtunnel : logi FALSE [12:31:46.995] $ rshlogfile : NULL [12:31:46.995] $ rshopts : chr(0) [12:31:46.995] $ rank : int 1 [12:31:46.995] $ manual : logi FALSE [12:31:46.995] $ dryrun : logi FALSE [12:31:46.995] $ quiet : logi FALSE [12:31:46.995] $ setup_strategy : chr "parallel" [12:31:46.995] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [12:31:46.995] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad467a17e92.pid" [12:31:46.995] $ rshcmd_label : NULL [12:31:46.995] $ rsh_call : NULL [12:31:46.995] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [12:31:46.995] $ localMachine : logi TRUE [12:31:46.995] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:46.995] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:46.995] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:46.995] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:46.995] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:46.995] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:46.995] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:46.995] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:46.995] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:46.995] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:46.995] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:46.995] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:46.995] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:46.995] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:46.995] $ arguments :List of 28 [12:31:46.995] ..$ worker : chr "localhost" [12:31:46.995] ..$ master : NULL [12:31:46.995] ..$ port : int 36493 [12:31:46.995] ..$ connectTimeout : num 120 [12:31:46.995] ..$ timeout : num 120 [12:31:46.995] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [12:31:46.995] ..$ homogeneous : NULL [12:31:46.995] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [12:31:46.995] ..$ rscript_envs : NULL [12:31:46.995] ..$ rscript_libs : NULL [12:31:46.995] ..$ rscript_startup : NULL [12:31:46.995] ..$ rscript_sh : chr "auto" [12:31:46.995] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:46.995] ..$ methods : logi TRUE [12:31:46.995] ..$ socketOptions : chr "no-delay" [12:31:46.995] ..$ useXDR : logi FALSE [12:31:46.995] ..$ outfile : chr "/dev/null" [12:31:46.995] ..$ renice : int NA [12:31:46.995] ..$ rshcmd : NULL [12:31:46.995] ..$ user : NULL [12:31:46.995] ..$ revtunnel : logi NA [12:31:46.995] ..$ rshlogfile : NULL [12:31:46.995] ..$ rshopts : NULL [12:31:46.995] ..$ rank : int 1 [12:31:46.995] ..$ manual : logi FALSE [12:31:46.995] ..$ dryrun : logi FALSE [12:31:46.995] ..$ quiet : logi FALSE [12:31:46.995] ..$ setup_strategy : chr "parallel" [12:31:46.995] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:47.022] [local output] System call to launch all workers: [12:31:47.022] [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:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad467a17e92.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=36493 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:47.023] [local output] Starting PSOCK main server [12:31:47.028] [local output] Workers launched [12:31:47.028] [local output] Waiting for workers to connect back [12:31:47.029] - [local output] 0 workers out of 1 ready [12:31:47.268] - [local output] 0 workers out of 1 ready [12:31:47.268] - [local output] 1 workers out of 1 ready [12:31:47.268] [local output] Launching of 1 workers completed [12:31:47.269] [local output] Number of nodes in cluster: 1 [12:31:47.269] [local output] Collecting session information from 1 workers [12:31:47.270] [local output] - Worker #1 of 1 [12:31:47.270] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [12:31:47.275] [local output] makeClusterPSOCK() ... [12:31:47.280] [local output] Workers: [n = 1] 'localhost' [12:31:47.284] [local output] Base port: 24941 [12:31:47.284] [local output] Getting setup options for 1 cluster nodes ... [12:31:47.284] [local output] - Node #1 of 1 ... [12:31:47.285] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:47.288] [local output] Rscript port: 24941 [12:31:47.288] [local output] Getting setup options for 1 cluster nodes ... done [12:31:47.289] [local output] - Parallel setup requested for some PSOCK nodes [12:31:47.289] [local output] Setting up PSOCK nodes in parallel [12:31:47.290] List of 36 [12:31:47.290] $ worker : chr "localhost" [12:31:47.290] ..- attr(*, "localhost")= logi TRUE [12:31:47.290] $ master : chr "localhost" [12:31:47.290] $ port : int 24941 [12:31:47.290] $ connectTimeout : num 120 [12:31:47.290] $ timeout : num 120 [12:31:47.290] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [12:31:47.290] $ homogeneous : logi TRUE [12:31:47.290] $ rscript_args : chr "R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#label=makeClust"| __truncated__ [12:31:47.290] $ rscript_envs : NULL [12:31:47.290] $ rscript_libs : NULL [12:31:47.290] $ rscript_startup : NULL [12:31:47.290] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:47.290] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:47.290] $ methods : logi TRUE [12:31:47.290] $ socketOptions : chr "no-delay" [12:31:47.290] $ useXDR : logi FALSE [12:31:47.290] $ outfile : chr "/dev/null" [12:31:47.290] $ renice : int NA [12:31:47.290] $ rshcmd : NULL [12:31:47.290] $ user : chr(0) [12:31:47.290] $ revtunnel : logi FALSE [12:31:47.290] $ rshlogfile : NULL [12:31:47.290] $ rshopts : chr(0) [12:31:47.290] $ rank : int 1 [12:31:47.290] $ manual : logi FALSE [12:31:47.290] $ dryrun : logi FALSE [12:31:47.290] $ quiet : logi FALSE [12:31:47.290] $ setup_strategy : chr "parallel" [12:31:47.290] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [12:31:47.290] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad46c02768.pid" [12:31:47.290] $ rshcmd_label : NULL [12:31:47.290] $ rsh_call : NULL [12:31:47.290] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=datasets,utils,grDevices,graphics,stats,met"| __truncated__ [12:31:47.290] $ localMachine : logi TRUE [12:31:47.290] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:47.290] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:47.290] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:47.290] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:47.290] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:47.290] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:47.290] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:47.290] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:47.290] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:47.290] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:47.290] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:47.290] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:47.290] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:47.290] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:47.290] $ arguments :List of 28 [12:31:47.290] ..$ worker : chr "localhost" [12:31:47.290] ..$ master : NULL [12:31:47.290] ..$ port : int 24941 [12:31:47.290] ..$ connectTimeout : num 120 [12:31:47.290] ..$ timeout : num 120 [12:31:47.290] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [12:31:47.290] ..$ homogeneous : NULL [12:31:47.290] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [12:31:47.290] ..$ rscript_envs : NULL [12:31:47.290] ..$ rscript_libs : NULL [12:31:47.290] ..$ rscript_startup : NULL [12:31:47.290] ..$ rscript_sh : chr "auto" [12:31:47.290] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:47.290] ..$ methods : logi TRUE [12:31:47.290] ..$ socketOptions : chr "no-delay" [12:31:47.290] ..$ useXDR : logi FALSE [12:31:47.290] ..$ outfile : chr "/dev/null" [12:31:47.290] ..$ renice : int NA [12:31:47.290] ..$ rshcmd : NULL [12:31:47.290] ..$ user : NULL [12:31:47.290] ..$ revtunnel : logi NA [12:31:47.290] ..$ rshlogfile : NULL [12:31:47.290] ..$ rshopts : NULL [12:31:47.290] ..$ rank : int 1 [12:31:47.290] ..$ manual : logi FALSE [12:31:47.290] ..$ dryrun : logi FALSE [12:31:47.290] ..$ quiet : logi FALSE [12:31:47.290] ..$ setup_strategy : chr "parallel" [12:31:47.290] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:47.327] [local output] System call to launch all workers: [12:31:47.328] [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:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad46c02768.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=24941 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:47.328] [local output] Starting PSOCK main server [12:31:47.333] [local output] Workers launched [12:31:47.333] [local output] Waiting for workers to connect back [12:31:47.334] - [local output] 0 workers out of 1 ready [12:31:47.605] - [local output] 0 workers out of 1 ready [12:31:47.606] - [local output] 1 workers out of 1 ready [12:31:47.607] [local output] Launching of 1 workers completed [12:31:47.607] [local output] Number of nodes in cluster: 1 [12:31:47.607] [local output] Collecting session information from 1 workers [12:31:47.608] [local output] - Worker #1 of 1 [12:31:47.609] [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' [12:31:47.631] [local output] makeClusterPSOCK() ... [12:31:47.634] [local output] Workers: [n = 1] 'localhost' [12:31:47.639] [local output] Base port: 25328 [12:31:47.639] [local output] Getting setup options for 1 cluster nodes ... [12:31:47.639] [local output] - Node #1 of 1 ... [12:31:47.640] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:47.642] 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/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4dc37148.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4dc37148.pid\")"' [12:31:47.977] - Possible to infer worker's PID: TRUE [12:31:47.978] [local output] Rscript port: 25328 [12:31:47.979] [local output] Getting setup options for 1 cluster nodes ... done [12:31:47.979] [local output] - Parallel setup requested for some PSOCK nodes [12:31:47.979] [local output] Setting up PSOCK nodes in parallel [12:31:47.980] List of 36 [12:31:47.980] $ worker : chr "localhost" [12:31:47.980] ..- attr(*, "localhost")= logi TRUE [12:31:47.980] $ master : chr "localhost" [12:31:47.980] $ port : int 25328 [12:31:47.980] $ connectTimeout : num 120 [12:31:47.980] $ timeout : num 120 [12:31:47.980] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [12:31:47.980] $ homogeneous : logi TRUE [12:31:47.980] $ rscript_args : chr "--default-packages=utils,tools -e \"#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN\" -e \"try(suppressWarnings(c"| __truncated__ [12:31:47.980] $ rscript_envs : NULL [12:31:47.980] $ rscript_libs : NULL [12:31:47.980] $ rscript_startup : NULL [12:31:47.980] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:47.980] $ default_packages: chr [1:2] "utils" "tools" [12:31:47.980] $ methods : logi TRUE [12:31:47.980] $ socketOptions : chr "no-delay" [12:31:47.980] $ useXDR : logi FALSE [12:31:47.980] $ outfile : chr "/dev/null" [12:31:47.980] $ renice : int NA [12:31:47.980] $ rshcmd : NULL [12:31:47.980] $ user : chr(0) [12:31:47.980] $ revtunnel : logi FALSE [12:31:47.980] $ rshlogfile : NULL [12:31:47.980] $ rshopts : chr(0) [12:31:47.980] $ rank : int 1 [12:31:47.980] $ manual : logi FALSE [12:31:47.980] $ dryrun : logi FALSE [12:31:47.980] $ quiet : logi FALSE [12:31:47.980] $ setup_strategy : chr "parallel" [12:31:47.980] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [12:31:47.980] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4dc37148.pid" [12:31:47.980] $ rshcmd_label : NULL [12:31:47.980] $ rsh_call : NULL [12:31:47.980] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=utils,tools -e \"#label=makeClusterPSOCK."| __truncated__ [12:31:47.980] $ localMachine : logi TRUE [12:31:47.980] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:47.980] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:47.980] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:47.980] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:47.980] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:47.980] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:47.980] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:47.980] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:47.980] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:47.980] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:47.980] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:47.980] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:47.980] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:47.980] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:47.980] $ arguments :List of 28 [12:31:47.980] ..$ worker : chr "localhost" [12:31:47.980] ..$ master : NULL [12:31:47.980] ..$ port : int 25328 [12:31:47.980] ..$ connectTimeout : num 120 [12:31:47.980] ..$ timeout : num 120 [12:31:47.980] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [12:31:47.980] ..$ homogeneous : NULL [12:31:47.980] ..$ rscript_args : NULL [12:31:47.980] ..$ rscript_envs : NULL [12:31:47.980] ..$ rscript_libs : NULL [12:31:47.980] ..$ rscript_startup : NULL [12:31:47.980] ..$ rscript_sh : chr "auto" [12:31:47.980] ..$ default_packages: chr [1:2] "utils" "tools" [12:31:47.980] ..$ methods : logi TRUE [12:31:47.980] ..$ socketOptions : chr "no-delay" [12:31:47.980] ..$ useXDR : logi FALSE [12:31:47.980] ..$ outfile : chr "/dev/null" [12:31:47.980] ..$ renice : int NA [12:31:47.980] ..$ rshcmd : NULL [12:31:47.980] ..$ user : NULL [12:31:47.980] ..$ revtunnel : logi NA [12:31:47.980] ..$ rshlogfile : NULL [12:31:47.980] ..$ rshopts : NULL [12:31:47.980] ..$ rank : int 1 [12:31:47.980] ..$ manual : logi FALSE [12:31:47.980] ..$ dryrun : logi FALSE [12:31:47.980] ..$ quiet : logi FALSE [12:31:47.980] ..$ setup_strategy : chr "parallel" [12:31:47.980] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:48.002] [local output] System call to launch all workers: [12:31:48.002] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=utils,tools -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4dc37148.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=25328 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:48.002] [local output] Starting PSOCK main server [12:31:48.008] [local output] Workers launched [12:31:48.008] [local output] Waiting for workers to connect back [12:31:48.009] - [local output] 0 workers out of 1 ready [12:31:48.135] - [local output] 0 workers out of 1 ready [12:31:48.136] - [local output] 1 workers out of 1 ready [12:31:48.136] [local output] Launching of 1 workers completed [12:31:48.137] [local output] Number of nodes in cluster: 1 [12:31:48.137] [local output] Collecting session information from 1 workers [12:31:48.138] [local output] - Worker #1 of 1 [12:31:48.138] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [12:31:48.145] [local output] makeClusterPSOCK() ... [12:31:48.148] [local output] Workers: [n = 1] 'localhost' [12:31:48.151] [local output] Base port: 23210 [12:31:48.151] [local output] Getting setup options for 1 cluster nodes ... [12:31:48.152] [local output] - Node #1 of 1 ... [12:31:48.152] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:48.155] [local output] Rscript port: 23210 [12:31:48.155] [local output] Getting setup options for 1 cluster nodes ... done [12:31:48.156] [local output] - Parallel setup requested for some PSOCK nodes [12:31:48.156] [local output] Setting up PSOCK nodes in parallel [12:31:48.157] List of 36 [12:31:48.157] $ worker : chr "localhost" [12:31:48.157] ..- attr(*, "localhost")= logi TRUE [12:31:48.157] $ master : chr "localhost" [12:31:48.157] $ port : int 23210 [12:31:48.157] $ connectTimeout : num 120 [12:31:48.157] $ timeout : num 120 [12:31:48.157] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [12:31:48.157] $ homogeneous : logi TRUE [12:31:48.157] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN\" -e \"| __truncated__ [12:31:48.157] $ rscript_envs : NULL [12:31:48.157] $ rscript_libs : NULL [12:31:48.157] $ rscript_startup : NULL [12:31:48.157] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:48.157] $ default_packages: chr [1:2] "utils" "tools" [12:31:48.157] $ methods : logi TRUE [12:31:48.157] $ socketOptions : chr "no-delay" [12:31:48.157] $ useXDR : logi FALSE [12:31:48.157] $ outfile : chr "/dev/null" [12:31:48.157] $ renice : int NA [12:31:48.157] $ rshcmd : NULL [12:31:48.157] $ user : chr(0) [12:31:48.157] $ revtunnel : logi FALSE [12:31:48.157] $ rshlogfile : NULL [12:31:48.157] $ rshopts : chr(0) [12:31:48.157] $ rank : int 1 [12:31:48.157] $ manual : logi FALSE [12:31:48.157] $ dryrun : logi FALSE [12:31:48.157] $ quiet : logi FALSE [12:31:48.157] $ setup_strategy : chr "parallel" [12:31:48.157] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [12:31:48.157] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad41e2419b.pid" [12:31:48.157] $ rshcmd_label : NULL [12:31:48.157] $ rsh_call : NULL [12:31:48.157] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [12:31:48.157] $ localMachine : logi TRUE [12:31:48.157] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:48.157] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:48.157] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:48.157] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:48.157] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:48.157] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:48.157] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:48.157] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:48.157] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:48.157] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:48.157] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:48.157] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:48.157] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:48.157] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:48.157] $ arguments :List of 28 [12:31:48.157] ..$ worker : chr "localhost" [12:31:48.157] ..$ master : NULL [12:31:48.157] ..$ port : int 23210 [12:31:48.157] ..$ connectTimeout : num 120 [12:31:48.157] ..$ timeout : num 120 [12:31:48.157] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [12:31:48.157] ..$ homogeneous : NULL [12:31:48.157] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [12:31:48.157] ..$ rscript_envs : NULL [12:31:48.157] ..$ rscript_libs : NULL [12:31:48.157] ..$ rscript_startup : NULL [12:31:48.157] ..$ rscript_sh : chr "auto" [12:31:48.157] ..$ default_packages: chr [1:2] "utils" "tools" [12:31:48.157] ..$ methods : logi TRUE [12:31:48.157] ..$ socketOptions : chr "no-delay" [12:31:48.157] ..$ useXDR : logi FALSE [12:31:48.157] ..$ outfile : chr "/dev/null" [12:31:48.157] ..$ renice : int NA [12:31:48.157] ..$ rshcmd : NULL [12:31:48.157] ..$ user : NULL [12:31:48.157] ..$ revtunnel : logi NA [12:31:48.157] ..$ rshlogfile : NULL [12:31:48.157] ..$ rshopts : NULL [12:31:48.157] ..$ rank : int 1 [12:31:48.157] ..$ manual : logi FALSE [12:31:48.157] ..$ dryrun : logi FALSE [12:31:48.157] ..$ quiet : logi FALSE [12:31:48.157] ..$ setup_strategy : chr "parallel" [12:31:48.157] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:48.191] [local output] System call to launch all workers: [12:31:48.191] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad41e2419b.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=23210 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:48.191] [local output] Starting PSOCK main server [12:31:48.197] [local output] Workers launched [12:31:48.197] [local output] Waiting for workers to connect back [12:31:48.198] - [local output] 0 workers out of 1 ready [12:31:48.302] - [local output] 0 workers out of 1 ready [12:31:48.302] - [local output] 1 workers out of 1 ready [12:31:48.303] [local output] Launching of 1 workers completed [12:31:48.303] [local output] Number of nodes in cluster: 1 [12:31:48.303] [local output] Collecting session information from 1 workers [12:31:48.304] [local output] - Worker #1 of 1 [12:31:48.304] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [12:31:48.312] [local output] makeClusterPSOCK() ... [12:31:48.316] [local output] Workers: [n = 1] 'localhost' [12:31:48.320] [local output] Base port: 39280 [12:31:48.320] [local output] Getting setup options for 1 cluster nodes ... [12:31:48.320] [local output] - Node #1 of 1 ... [12:31:48.321] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:48.323] [local output] Rscript port: 39280 [12:31:48.324] [local output] Getting setup options for 1 cluster nodes ... done [12:31:48.324] [local output] - Parallel setup requested for some PSOCK nodes [12:31:48.325] [local output] Setting up PSOCK nodes in parallel [12:31:48.325] List of 36 [12:31:48.325] $ worker : chr "localhost" [12:31:48.325] ..- attr(*, "localhost")= logi TRUE [12:31:48.325] $ master : chr "localhost" [12:31:48.325] $ port : int 39280 [12:31:48.325] $ connectTimeout : num 120 [12:31:48.325] $ timeout : num 120 [12:31:48.325] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [12:31:48.325] $ homogeneous : logi TRUE [12:31:48.325] $ rscript_args : chr "R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN\" -e \"| __truncated__ [12:31:48.325] $ rscript_envs : NULL [12:31:48.325] $ rscript_libs : NULL [12:31:48.325] $ rscript_startup : NULL [12:31:48.325] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:48.325] $ default_packages: chr [1:2] "utils" "tools" [12:31:48.325] $ methods : logi TRUE [12:31:48.325] $ socketOptions : chr "no-delay" [12:31:48.325] $ useXDR : logi FALSE [12:31:48.325] $ outfile : chr "/dev/null" [12:31:48.325] $ renice : int NA [12:31:48.325] $ rshcmd : NULL [12:31:48.325] $ user : chr(0) [12:31:48.325] $ revtunnel : logi FALSE [12:31:48.325] $ rshlogfile : NULL [12:31:48.325] $ rshopts : chr(0) [12:31:48.325] $ rank : int 1 [12:31:48.325] $ manual : logi FALSE [12:31:48.325] $ dryrun : logi FALSE [12:31:48.325] $ quiet : logi FALSE [12:31:48.325] $ setup_strategy : chr "parallel" [12:31:48.325] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [12:31:48.325] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad42b2a1955.pid" [12:31:48.325] $ rshcmd_label : NULL [12:31:48.325] $ rsh_call : NULL [12:31:48.325] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e \"#la"| __truncated__ [12:31:48.325] $ localMachine : logi TRUE [12:31:48.325] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:48.325] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:48.325] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:48.325] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:48.325] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:48.325] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:48.325] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:48.325] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:48.325] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:48.325] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:48.325] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:48.325] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:48.325] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:48.325] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:48.325] $ arguments :List of 28 [12:31:48.325] ..$ worker : chr "localhost" [12:31:48.325] ..$ master : NULL [12:31:48.325] ..$ port : int 39280 [12:31:48.325] ..$ connectTimeout : num 120 [12:31:48.325] ..$ timeout : num 120 [12:31:48.325] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [12:31:48.325] ..$ homogeneous : NULL [12:31:48.325] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [12:31:48.325] ..$ rscript_envs : NULL [12:31:48.325] ..$ rscript_libs : NULL [12:31:48.325] ..$ rscript_startup : NULL [12:31:48.325] ..$ rscript_sh : chr "auto" [12:31:48.325] ..$ default_packages: chr [1:2] "utils" "tools" [12:31:48.325] ..$ methods : logi TRUE [12:31:48.325] ..$ socketOptions : chr "no-delay" [12:31:48.325] ..$ useXDR : logi FALSE [12:31:48.325] ..$ outfile : chr "/dev/null" [12:31:48.325] ..$ renice : int NA [12:31:48.325] ..$ rshcmd : NULL [12:31:48.325] ..$ user : NULL [12:31:48.325] ..$ revtunnel : logi NA [12:31:48.325] ..$ rshlogfile : NULL [12:31:48.325] ..$ rshopts : NULL [12:31:48.325] ..$ rank : int 1 [12:31:48.325] ..$ manual : logi FALSE [12:31:48.325] ..$ dryrun : logi FALSE [12:31:48.325] ..$ quiet : logi FALSE [12:31:48.325] ..$ setup_strategy : chr "parallel" [12:31:48.325] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:48.358] [local output] System call to launch all workers: [12:31:48.359] [local output] "D:\RCompile\recent\R\bin\x64\Rterm.exe" R_DEFAULT_PACKAGES=utils,tools --no-echo --no-restore -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad42b2a1955.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=39280 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:48.359] [local output] Starting PSOCK main server [12:31:48.365] [local output] Workers launched [12:31:48.366] [local output] Waiting for workers to connect back [12:31:48.366] - [local output] 0 workers out of 1 ready [12:31:48.495] - [local output] 0 workers out of 1 ready [12:31:48.495] - [local output] 1 workers out of 1 ready [12:31:48.496] [local output] Launching of 1 workers completed [12:31:48.496] [local output] Number of nodes in cluster: 1 [12:31:48.496] [local output] Collecting session information from 1 workers [12:31:48.497] [local output] - Worker #1 of 1 [12:31:48.498] [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' [12:31:48.522] [local output] makeClusterPSOCK() ... [12:31:48.525] [local output] Workers: [n = 1] 'localhost' [12:31:48.529] [local output] Base port: 34862 [12:31:48.529] [local output] Getting setup options for 1 cluster nodes ... [12:31:48.529] [local output] - Node #1 of 1 ... [12:31:48.530] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:48.532] [local output] Rscript port: 34862 [12:31:48.533] [local output] Getting setup options for 1 cluster nodes ... done [12:31:48.533] [local output] - Parallel setup requested for some PSOCK nodes [12:31:48.534] [local output] Setting up PSOCK nodes in parallel [12:31:48.534] List of 36 [12:31:48.534] $ worker : chr "localhost" [12:31:48.534] ..- attr(*, "localhost")= logi TRUE [12:31:48.534] $ master : chr "localhost" [12:31:48.534] $ port : int 34862 [12:31:48.534] $ connectTimeout : num 120 [12:31:48.534] $ timeout : num 120 [12:31:48.534] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\"" [12:31:48.534] $ homogeneous : logi TRUE [12:31:48.534] $ rscript_args : chr "--default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92"| __truncated__ [12:31:48.534] $ rscript_envs : NULL [12:31:48.534] $ rscript_libs : NULL [12:31:48.534] $ rscript_startup : NULL [12:31:48.534] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:48.534] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [12:31:48.534] $ methods : logi TRUE [12:31:48.534] $ socketOptions : chr "no-delay" [12:31:48.534] $ useXDR : logi FALSE [12:31:48.534] $ outfile : chr "/dev/null" [12:31:48.534] $ renice : int NA [12:31:48.534] $ rshcmd : NULL [12:31:48.534] $ user : chr(0) [12:31:48.534] $ revtunnel : logi FALSE [12:31:48.534] $ rshlogfile : NULL [12:31:48.534] $ rshopts : chr(0) [12:31:48.534] $ rank : int 1 [12:31:48.534] $ manual : logi FALSE [12:31:48.534] $ dryrun : logi FALSE [12:31:48.534] $ quiet : logi FALSE [12:31:48.534] $ setup_strategy : chr "parallel" [12:31:48.534] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [12:31:48.534] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad45f0335c2.pid" [12:31:48.534] $ rshcmd_label : NULL [12:31:48.534] $ rsh_call : NULL [12:31:48.534] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rscript.exe\" --default-packages=parallelly,datasets,utils,grDevices,graph"| __truncated__ [12:31:48.534] $ localMachine : logi TRUE [12:31:48.534] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:48.534] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:48.534] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:48.534] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:48.534] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:48.534] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:48.534] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:48.534] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:48.534] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:48.534] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:48.534] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:48.534] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:48.534] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:48.534] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:48.534] $ arguments :List of 28 [12:31:48.534] ..$ worker : chr "localhost" [12:31:48.534] ..$ master : NULL [12:31:48.534] ..$ port : int 34862 [12:31:48.534] ..$ connectTimeout : num 120 [12:31:48.534] ..$ timeout : num 120 [12:31:48.534] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rscript" [12:31:48.534] ..$ homogeneous : NULL [12:31:48.534] ..$ rscript_args : NULL [12:31:48.534] ..$ rscript_envs : NULL [12:31:48.534] ..$ rscript_libs : NULL [12:31:48.534] ..$ rscript_startup : NULL [12:31:48.534] ..$ rscript_sh : chr "auto" [12:31:48.534] ..$ default_packages: chr [1:2] "parallelly" "*" [12:31:48.534] ..$ methods : logi TRUE [12:31:48.534] ..$ socketOptions : chr "no-delay" [12:31:48.534] ..$ useXDR : logi FALSE [12:31:48.534] ..$ outfile : chr "/dev/null" [12:31:48.534] ..$ renice : int NA [12:31:48.534] ..$ rshcmd : NULL [12:31:48.534] ..$ user : NULL [12:31:48.534] ..$ revtunnel : logi NA [12:31:48.534] ..$ rshlogfile : NULL [12:31:48.534] ..$ rshopts : NULL [12:31:48.534] ..$ rank : int 1 [12:31:48.534] ..$ manual : logi FALSE [12:31:48.534] ..$ dryrun : logi FALSE [12:31:48.534] ..$ quiet : logi FALSE [12:31:48.534] ..$ setup_strategy : chr "parallel" [12:31:48.534] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:48.567] [local output] System call to launch all workers: [12:31:48.568] [local output] "D:\RCompile\recent\R\bin\x64\Rscript.exe" --default-packages=parallelly,datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad45f0335c2.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=34862 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:48.568] [local output] Starting PSOCK main server [12:31:48.574] [local output] Workers launched [12:31:48.574] [local output] Waiting for workers to connect back [12:31:48.574] - [local output] 0 workers out of 1 ready [12:31:48.903] - [local output] 0 workers out of 1 ready [12:31:48.903] - [local output] 1 workers out of 1 ready [12:31:48.904] [local output] Launching of 1 workers completed [12:31:48.904] [local output] Number of nodes in cluster: 1 [12:31:48.904] [local output] Collecting session information from 1 workers [12:31:48.905] [local output] - Worker #1 of 1 [12:31:48.905] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm' [12:31:48.911] [local output] makeClusterPSOCK() ... [12:31:48.914] [local output] Workers: [n = 1] 'localhost' [12:31:48.917] [local output] Base port: 23893 [12:31:48.918] [local output] Getting setup options for 1 cluster nodes ... [12:31:48.918] [local output] - Node #1 of 1 ... [12:31:48.919] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:48.921] [local output] Rscript port: 23893 [12:31:48.922] [local output] Getting setup options for 1 cluster nodes ... done [12:31:48.922] [local output] - Parallel setup requested for some PSOCK nodes [12:31:48.923] [local output] Setting up PSOCK nodes in parallel [12:31:48.923] List of 36 [12:31:48.923] $ worker : chr "localhost" [12:31:48.923] ..- attr(*, "localhost")= logi TRUE [12:31:48.923] $ master : chr "localhost" [12:31:48.923] $ port : int 23893 [12:31:48.923] $ connectTimeout : num 120 [12:31:48.923] $ timeout : num 120 [12:31:48.923] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [12:31:48.923] $ homogeneous : logi TRUE [12:31:48.923] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [12:31:48.923] $ rscript_envs : NULL [12:31:48.923] $ rscript_libs : NULL [12:31:48.923] $ rscript_startup : NULL [12:31:48.923] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:48.923] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [12:31:48.923] $ methods : logi TRUE [12:31:48.923] $ socketOptions : chr "no-delay" [12:31:48.923] $ useXDR : logi FALSE [12:31:48.923] $ outfile : chr "/dev/null" [12:31:48.923] $ renice : int NA [12:31:48.923] $ rshcmd : NULL [12:31:48.923] $ user : chr(0) [12:31:48.923] $ revtunnel : logi FALSE [12:31:48.923] $ rshlogfile : NULL [12:31:48.923] $ rshopts : chr(0) [12:31:48.923] $ rank : int 1 [12:31:48.923] $ manual : logi FALSE [12:31:48.923] $ dryrun : logi FALSE [12:31:48.923] $ quiet : logi FALSE [12:31:48.923] $ setup_strategy : chr "parallel" [12:31:48.923] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [12:31:48.923] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad456122e83.pid" [12:31:48.923] $ rshcmd_label : NULL [12:31:48.923] $ rsh_call : NULL [12:31:48.923] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [12:31:48.923] $ localMachine : logi TRUE [12:31:48.923] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:48.923] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:48.923] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:48.923] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:48.923] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:48.923] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:48.923] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:48.923] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:48.923] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:48.923] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:48.923] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:48.923] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:48.923] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:48.923] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:48.923] $ arguments :List of 28 [12:31:48.923] ..$ worker : chr "localhost" [12:31:48.923] ..$ master : NULL [12:31:48.923] ..$ port : int 23893 [12:31:48.923] ..$ connectTimeout : num 120 [12:31:48.923] ..$ timeout : num 120 [12:31:48.923] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm" [12:31:48.923] ..$ homogeneous : NULL [12:31:48.923] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [12:31:48.923] ..$ rscript_envs : NULL [12:31:48.923] ..$ rscript_libs : NULL [12:31:48.923] ..$ rscript_startup : NULL [12:31:48.923] ..$ rscript_sh : chr "auto" [12:31:48.923] ..$ default_packages: chr [1:2] "parallelly" "*" [12:31:48.923] ..$ methods : logi TRUE [12:31:48.923] ..$ socketOptions : chr "no-delay" [12:31:48.923] ..$ useXDR : logi FALSE [12:31:48.923] ..$ outfile : chr "/dev/null" [12:31:48.923] ..$ renice : int NA [12:31:48.923] ..$ rshcmd : NULL [12:31:48.923] ..$ user : NULL [12:31:48.923] ..$ revtunnel : logi NA [12:31:48.923] ..$ rshlogfile : NULL [12:31:48.923] ..$ rshopts : NULL [12:31:48.923] ..$ rank : int 1 [12:31:48.923] ..$ manual : logi FALSE [12:31:48.923] ..$ dryrun : logi FALSE [12:31:48.923] ..$ quiet : logi FALSE [12:31:48.923] ..$ setup_strategy : chr "parallel" [12:31:48.923] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:48.957] [local output] System call to launch all workers: [12:31:48.957] [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:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad456122e83.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=23893 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:48.957] [local output] Starting PSOCK main server [12:31:48.963] [local output] Workers launched [12:31:48.963] [local output] Waiting for workers to connect back [12:31:48.964] - [local output] 0 workers out of 1 ready [12:31:49.253] - [local output] 0 workers out of 1 ready [12:31:49.254] - [local output] 1 workers out of 1 ready [12:31:49.254] [local output] Launching of 1 workers completed [12:31:49.254] [local output] Number of nodes in cluster: 1 [12:31:49.254] [local output] Collecting session information from 1 workers [12:31:49.255] [local output] - Worker #1 of 1 [12:31:49.255] [local output] makeClusterPSOCK() ... done Launcher: 'D:/RCompile/recent/R/bin/x64/Rterm.exe' [12:31:49.261] [local output] makeClusterPSOCK() ... [12:31:49.265] [local output] Workers: [n = 1] 'localhost' [12:31:49.269] [local output] Base port: 29038 [12:31:49.269] [local output] Getting setup options for 1 cluster nodes ... [12:31:49.269] [local output] - Node #1 of 1 ... [12:31:49.270] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:49.273] [local output] Rscript port: 29038 [12:31:49.273] [local output] Getting setup options for 1 cluster nodes ... done [12:31:49.273] [local output] - Parallel setup requested for some PSOCK nodes [12:31:49.274] [local output] Setting up PSOCK nodes in parallel [12:31:49.274] List of 36 [12:31:49.274] $ worker : chr "localhost" [12:31:49.274] ..- attr(*, "localhost")= logi TRUE [12:31:49.274] $ master : chr "localhost" [12:31:49.274] $ port : int 29038 [12:31:49.274] $ connectTimeout : num 120 [12:31:49.274] $ timeout : num 120 [12:31:49.274] $ rscript : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\"" [12:31:49.274] $ homogeneous : logi TRUE [12:31:49.274] $ rscript_args : chr "R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphics,stats,methods --no-echo --no-restore -e \"#labe"| __truncated__ [12:31:49.274] $ rscript_envs : NULL [12:31:49.274] $ rscript_libs : NULL [12:31:49.274] $ rscript_startup : NULL [12:31:49.274] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:49.274] $ default_packages: chr [1:7] "parallelly" "datasets" "utils" "grDevices" ... [12:31:49.274] $ methods : logi TRUE [12:31:49.274] $ socketOptions : chr "no-delay" [12:31:49.274] $ useXDR : logi FALSE [12:31:49.274] $ outfile : chr "/dev/null" [12:31:49.274] $ renice : int NA [12:31:49.274] $ rshcmd : NULL [12:31:49.274] $ user : chr(0) [12:31:49.274] $ revtunnel : logi FALSE [12:31:49.274] $ rshlogfile : NULL [12:31:49.274] $ rshopts : chr(0) [12:31:49.274] $ rank : int 1 [12:31:49.274] $ manual : logi FALSE [12:31:49.274] $ dryrun : logi FALSE [12:31:49.274] $ quiet : logi FALSE [12:31:49.274] $ setup_strategy : chr "parallel" [12:31:49.274] $ local_cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [12:31:49.274] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4248a74d4.pid" [12:31:49.274] $ rshcmd_label : NULL [12:31:49.274] $ rsh_call : NULL [12:31:49.274] $ cmd : chr "\"D:\\RCompile\\recent\\R\\bin\\x64\\Rterm.exe\" R_DEFAULT_PACKAGES=parallelly,datasets,utils,grDevices,graphic"| __truncated__ [12:31:49.274] $ localMachine : logi TRUE [12:31:49.274] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:49.274] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:49.274] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:49.274] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:49.274] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:49.274] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:49.274] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:49.274] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:49.274] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:49.274] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:49.274] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:49.274] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:49.274] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:49.274] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:49.274] $ arguments :List of 28 [12:31:49.274] ..$ worker : chr "localhost" [12:31:49.274] ..$ master : NULL [12:31:49.274] ..$ port : int 29038 [12:31:49.274] ..$ connectTimeout : num 120 [12:31:49.274] ..$ timeout : num 120 [12:31:49.274] ..$ rscript : chr "D:/RCompile/recent/R/bin/x64/Rterm.exe" [12:31:49.274] ..$ homogeneous : NULL [12:31:49.274] ..$ rscript_args : chr [1:4] "--no-echo" "--no-restore" "*" "--args" [12:31:49.274] ..$ rscript_envs : NULL [12:31:49.274] ..$ rscript_libs : NULL [12:31:49.274] ..$ rscript_startup : NULL [12:31:49.274] ..$ rscript_sh : chr "auto" [12:31:49.274] ..$ default_packages: chr [1:2] "parallelly" "*" [12:31:49.274] ..$ methods : logi TRUE [12:31:49.274] ..$ socketOptions : chr "no-delay" [12:31:49.274] ..$ useXDR : logi FALSE [12:31:49.274] ..$ outfile : chr "/dev/null" [12:31:49.274] ..$ renice : int NA [12:31:49.274] ..$ rshcmd : NULL [12:31:49.274] ..$ user : NULL [12:31:49.274] ..$ revtunnel : logi NA [12:31:49.274] ..$ rshlogfile : NULL [12:31:49.274] ..$ rshopts : NULL [12:31:49.274] ..$ rank : int 1 [12:31:49.274] ..$ manual : logi FALSE [12:31:49.274] ..$ dryrun : logi FALSE [12:31:49.274] ..$ quiet : logi FALSE [12:31:49.274] ..$ setup_strategy : chr "parallel" [12:31:49.274] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:49.309] [local output] System call to launch all workers: [12:31:49.310] [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:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad4248a74d4.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" --args MASTER=localhost PORT=29038 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel [12:31:49.310] [local output] Starting PSOCK main server [12:31:49.316] [local output] Workers launched [12:31:49.316] [local output] Waiting for workers to connect back [12:31:49.317] - [local output] 0 workers out of 1 ready [12:31:49.628] - [local output] 0 workers out of 1 ready [12:31:49.629] - [local output] 1 workers out of 1 ready [12:31:49.629] [local output] Launching of 1 workers completed [12:31:49.630] [local output] Number of nodes in cluster: 1 [12:31:49.630] [local output] Collecting session information from 1 workers [12:31:49.631] [local output] - Worker #1 of 1 [12:31:49.632] [local output] makeClusterPSOCK() ... done > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > res <- tryCatch({ + cl <- makeClusterPSOCK(1:2) + }, error = identity) [12:31:49.638] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(0L) + }, error = identity) [12:31:49.639] [local output] makeClusterPSOCK() ... > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, rshcmd = character(0L)) + }, error = identity) [12:31:49.640] [local output] makeClusterPSOCK() ... [12:31:49.644] [local output] Workers: [n = 1] 'localhost' [12:31:49.648] [local output] Base port: 29563 [12:31:49.648] [local output] Getting setup options for 1 cluster nodes ... [12:31:49.648] [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) [12:31:49.650] [local output] makeClusterPSOCK() ... [12:31:49.652] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > res <- tryCatch({ + cl <- makeClusterPSOCK(1L, port = NA_integer_) + }, error = identity) [12:31:49.653] [local output] makeClusterPSOCK() ... [12:31:49.657] [local output] Workers: [n = 1] 'localhost' > print(res) > stopifnot(inherits(res, "error")) > > > message("- makeClusterPSOCK() - exceptions") - makeClusterPSOCK() - exceptions > > ## Non-existing hostname > res <- tryCatch({ + cl <- makeNodePSOCK("not.a.localhost.hostname", revtunnel = TRUE) + }, error = identity) > print(res) > stopifnot(inherits(res, "error")) > > ## Invalid port > res <- tryCatch({ + cl <- makeNodePSOCK("localhost", port = NA_integer_) + }, error = identity) > print(res) > stopifnot(inherits(res, "error")) > > ## Don't test on CRAN > if (fullTest || covr_testing) { + ## Occupied/blocked port + res <- tryCatch( + cl <- parallelly::makeClusterPSOCK("localhost", port = 80L, tries = 1L), + error = identity) + print(res) + ## Skip error assertion in case this actually works on some machine. + ## But where it fails, we are testing the port-failure exception code. + } > > > ## https://github.com/HenrikBengtsson/parallelly/issues/95 > if (getRversion() >= "4.0.0") { + res <- tryCatch({ + parallelly::makeClusterPSOCK(1L, rscript_startup = quote(Sys.sleep(6.0)), + connectTimeout = 0.1, timeout = 7.0) + }, error = identity) + print(res) + stopifnot( + inherits(res, "error"), + grepl("^Cluster setup failed", conditionMessage(res)) + ) + + ## Make sure to wait for background process to timeout before continuing, + ## when on MS Windows + if (.Platform$OS.type == "windows") Sys.sleep(5.0) + } [12:31:49.661] [local output] makeClusterPSOCK() ... [12:31:49.663] [local output] Workers: [n = 1] 'localhost' [12:31:49.666] [local output] Base port: 30159 [12:31:49.667] [local output] Getting setup options for 1 cluster nodes ... [12:31:49.667] [local output] - Node #1 of 1 ... [12:31:49.668] [local output] localMachine=TRUE => revtunnel=FALSE [12:31:49.670] [local output] Rscript port: 30159 [12:31:49.670] [local output] Getting setup options for 1 cluster nodes ... done [12:31:49.671] [local output] - Parallel setup requested for some PSOCK nodes [12:31:49.671] [local output] Setting up PSOCK nodes in parallel [12:31:49.672] List of 36 [12:31:49.672] $ worker : chr "localhost" [12:31:49.672] ..- attr(*, "localhost")= logi TRUE [12:31:49.672] $ master : chr "localhost" [12:31:49.672] $ port : int 30159 [12:31:49.672] $ connectTimeout : num 0.1 [12:31:49.672] $ timeout : num 7 [12:31:49.672] $ rscript : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\"" [12:31:49.672] $ homogeneous : logi TRUE [12:31:49.672] $ rscript_args : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=makeClusterPSOCK.R:92884:CRANWIN"| __truncated__ [12:31:49.672] $ rscript_envs : NULL [12:31:49.672] $ rscript_libs : NULL [12:31:49.672] $ rscript_startup : chr [1:2] "-e" "\"invisible({Sys.sleep(6)})\"" [12:31:49.672] $ rscript_sh : chr [1:2] "cmd" "cmd" [12:31:49.672] $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:49.672] $ methods : logi TRUE [12:31:49.672] $ socketOptions : chr "no-delay" [12:31:49.672] $ useXDR : logi FALSE [12:31:49.672] $ outfile : chr "/dev/null" [12:31:49.672] $ renice : int NA [12:31:49.672] $ rshcmd : NULL [12:31:49.672] $ user : chr(0) [12:31:49.672] $ revtunnel : logi FALSE [12:31:49.672] $ rshlogfile : NULL [12:31:49.672] $ rshopts : chr(0) [12:31:49.672] $ rank : int 1 [12:31:49.672] $ manual : logi FALSE [12:31:49.672] $ dryrun : logi FALSE [12:31:49.672] $ quiet : logi FALSE [12:31:49.672] $ setup_strategy : chr "parallel" [12:31:49.672] $ local_cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:49.672] $ pidfile : chr "D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad45a3c5810.pid" [12:31:49.672] $ rshcmd_label : NULL [12:31:49.672] $ rsh_call : NULL [12:31:49.672] $ cmd : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__ [12:31:49.672] $ localMachine : logi TRUE [12:31:49.672] $ make_fcn :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), [12:31:49.672] master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", [12:31:49.672] 2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", [12:31:49.672] 30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, [12:31:49.672] rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", [12:31:49.672] "cmd", "sh", "none"), default_packages = c("datasets", "utils", [12:31:49.672] "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, [12:31:49.672] socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", [12:31:49.672] "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", [12:31:49.672] FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", [12:31:49.672] NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", [12:31:49.672] NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, [12:31:49.672] setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", [12:31:49.672] "parallel"), action = c("launch", "options"), verbose = FALSE) [12:31:49.672] $ arguments :List of 28 [12:31:49.672] ..$ worker : chr "localhost" [12:31:49.672] ..$ master : NULL [12:31:49.672] ..$ port : int 30159 [12:31:49.672] ..$ connectTimeout : num 0.1 [12:31:49.672] ..$ timeout : num 7 [12:31:49.672] ..$ rscript : NULL [12:31:49.672] ..$ homogeneous : NULL [12:31:49.672] ..$ rscript_args : NULL [12:31:49.672] ..$ rscript_envs : NULL [12:31:49.672] ..$ rscript_libs : NULL [12:31:49.672] ..$ rscript_startup : language Sys.sleep(6) [12:31:49.672] ..$ rscript_sh : chr "auto" [12:31:49.672] ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ... [12:31:49.672] ..$ methods : logi TRUE [12:31:49.672] ..$ socketOptions : chr "no-delay" [12:31:49.672] ..$ useXDR : logi FALSE [12:31:49.672] ..$ outfile : chr "/dev/null" [12:31:49.672] ..$ renice : int NA [12:31:49.672] ..$ rshcmd : NULL [12:31:49.672] ..$ user : NULL [12:31:49.672] ..$ revtunnel : logi NA [12:31:49.672] ..$ rshlogfile : NULL [12:31:49.672] ..$ rshopts : NULL [12:31:49.672] ..$ rank : int 1 [12:31:49.672] ..$ manual : logi FALSE [12:31:49.672] ..$ dryrun : logi FALSE [12:31:49.672] ..$ quiet : logi FALSE [12:31:49.672] ..$ setup_strategy : chr "parallel" [12:31:49.672] - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions" [12:31:49.705] [local output] System call to launch all workers: [12:31:49.706] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=makeClusterPSOCK.R:92884:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/Rtmpw7jUI7/worker.rank=1.parallelly.parent=92884.16ad45a3c5810.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=30159 OUT=/dev/null TIMEOUT=7 XDR=FALSE SETUPTIMEOUT=0.1 SETUPSTRATEGY=parallel [12:31:49.706] [local output] Starting PSOCK main server [12:31:49.712] [local output] Workers launched [12:31:49.712] [local output] Waiting for workers to connect back [12:31:49.713] - [local output] 0 workers out of 1 ready [12:31:49.914] - [local output] 0 workers out of 1 ready [12:31:50.117] - [local output] 0 workers out of 1 ready [12:31:50.320] - [local output] 0 workers out of 1 ready [12:31:50.524] - [local output] 0 workers out of 1 ready [12:31:50.727] - [local output] 0 workers out of 1 ready [12:31:50.930] - [local output] 0 workers out of 1 ready [12:31:51.133] - [local output] 0 workers out of 1 ready [12:31:51.336] - [local output] 0 workers out of 1 ready [12:31:51.539] - [local output] 0 workers out of 1 ready [12:31:51.742] - [local output] 0 workers out of 1 ready [12:31:51.946] - [local output] 0 workers out of 1 ready [12:31:52.149] - [local output] 0 workers out of 1 ready [12:31:52.352] - [local output] 0 workers out of 1 ready [12:31:52.555] - [local output] 0 workers out of 1 ready [12:31:52.758] - [local output] 0 workers out of 1 ready [12:31:52.961] - [local output] 0 workers out of 1 ready [12:31:53.164] - [local output] 0 workers out of 1 ready [12:31:53.368] - [local output] 0 workers out of 1 ready [12:31:53.571] - [local output] 0 workers out of 1 ready [12:31:53.774] - [local output] 0 workers out of 1 ready [12:31:53.977] - [local output] 0 workers out of 1 ready [12:31:54.180] - [local output] 0 workers out of 1 ready [12:31:54.383] - [local output] 0 workers out of 1 ready [12:31:54.586] - [local output] 0 workers out of 1 ready [12:31:54.790] - [local output] 0 workers out of 1 ready [12:31:54.993] - [local output] 0 workers out of 1 ready > > message("*** makeClusterPSOCK() ... DONE") *** makeClusterPSOCK() ... DONE > > source("incl/end.R") > > proc.time() user system elapsed 1.68 0.15 19.98