R Under development (unstable) (2025-01-29 r87668 ucrt) -- "Unsuffered Consequences"
Copyright (C) 2025 The R Foundation for Statistical Computing
Platform: x86_64-w64-mingw32/x64

R is free software and comes with ABSOLUTELY NO WARRANTY.
You are welcome to redistribute it under certain conditions.
Type 'license()' or 'licence()' for distribution details.

R is a collaborative project with many contributors.
Type 'contributors()' for more information and
'citation()' on how to cite R or R packages in publications.

Type 'demo()' for some demos, 'help()' for on-line help, or
'help.start()' for an HTML browser interface to help.
Type 'q()' to quit R.

> source("incl/start.R")
> stopCluster <- parallel::stopCluster
> 
> message("*** cluster operations ...")
*** cluster operations ...
> 
> local({
+   cl0 <- makeClusterPSOCK(1L)
+   on.exit(stopCluster(cl0))
+   cl <- cl0
+   print(cl)
+ 
+   message("*** cluster operations - as.cluster() ...")
+   cl1 <- as.cluster(cl)
+   print(cl1)
+   stopifnot(inherits(cl1, "cluster"), identical(cl1, cl))
+ 
+   node <- cl[[1]]
+   print(node)
+   cl2 <- as.cluster(node)
+   stopifnot(inherits(cl2, "cluster"), length(cl2) == 1L,
+             identical(cl2[[1]], node))
+ 
+   node <- cl[[1]]
+   print(node)
+   stopifnot(inherits(node, if (useXDR) "SOCKnode" else "SOCK0node"))
+   nodes <- list(node, node)
+   cl3 <- as.cluster(node)
+   print(cl3)
+   stopifnot(inherits(cl3, "cluster"), length(cl3) == 1L,
+             identical(cl3[[1]], node))
+ 
+   cl4 <- as.cluster(nodes)
+   print(cl4)
+   stopifnot(inherits(cl4, "cluster"), length(cl4) == 2L,
+             identical(cl4[[1]], node), identical(cl4[[2]], node))
+   
+   message("*** cluster operations - as.cluster() ... DONE")
+ 
+   message("*** cluster operations - c(...) ...")
+   cl2 <- makeClusterPSOCK("localhost")
+   on.exit(stopCluster(cl2), add = TRUE)
+   print(cl2)
+   
+   cl <- c(cl1, cl2)
+   print(cl)
+ 
+   stopifnot(inherits(cl, "cluster"), length(cl) == 2L)
+   stopifnot(identical(cl[1], cl1),
+             identical(cl[2], cl2[1]))
+   message("*** cluster operations - c(...) ... DONE")
+ })
[16:45:05.326] [local output] makeClusterPSOCK() ...
[16:45:05.391] [local output] Workers: [n = 1] 'localhost'
[16:45:05.405] [local output] Base port: 24719
[16:45:05.405] [local output] Getting setup options for 1 cluster nodes ...
[16:45:05.406] [local output]  - Node #1 of 1 ...
[16:45:05.407] [local output] localMachine=TRUE => revtunnel=FALSE

[16:45:05.409] Testing if worker's PID can be inferred: '"D:/RCompile/recent/R/bin/x64/Rscript" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpqY74vA/worker.rank=1.parallelly.parent=153256.256a83a0f64fb.pid\")), silent = TRUE)" -e "file.exists(\"D:/temp/2025_01_30_16_40_16_30529/RtmpqY74vA/worker.rank=1.parallelly.parent=153256.256a83a0f64fb.pid\")"'
[16:45:05.850] - Possible to infer worker's PID: TRUE
[16:45:05.852] [local output] Rscript port: 24719

[16:45:05.852] [local output] Getting setup options for 1 cluster nodes ... done
[16:45:05.853] [local output]  - Parallel setup requested for some PSOCK nodes
[16:45:05.854] [local output] Setting up PSOCK nodes in parallel
[16:45:05.854] List of 36
[16:45:05.854]  $ worker          : chr "localhost"
[16:45:05.854]   ..- attr(*, "localhost")= logi TRUE
[16:45:05.854]  $ master          : chr "localhost"
[16:45:05.854]  $ port            : int 24719
[16:45:05.854]  $ connectTimeout  : num 120
[16:45:05.854]  $ timeout         : num 120
[16:45:05.854]  $ rscript         : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\""
[16:45:05.854]  $ homogeneous     : logi TRUE
[16:45:05.854]  $ rscript_args    : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=as.cluster.R:153256:CRANWIN3:CRA"| __truncated__
[16:45:05.854]  $ rscript_envs    : NULL
[16:45:05.854]  $ rscript_libs    : NULL
[16:45:05.854]  $ rscript_startup : NULL
[16:45:05.854]  $ rscript_sh      : chr [1:2] "cmd" "cmd"
[16:45:05.854]  $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ...
[16:45:05.854]  $ methods         : logi TRUE
[16:45:05.854]  $ socketOptions   : chr "no-delay"
[16:45:05.854]  $ useXDR          : logi FALSE
[16:45:05.854]  $ outfile         : chr "/dev/null"
[16:45:05.854]  $ renice          : int NA
[16:45:05.854]  $ rshcmd          : NULL
[16:45:05.854]  $ user            : chr(0) 
[16:45:05.854]  $ revtunnel       : logi FALSE
[16:45:05.854]  $ rshlogfile      : NULL
[16:45:05.854]  $ rshopts         : chr(0) 
[16:45:05.854]  $ rank            : int 1
[16:45:05.854]  $ manual          : logi FALSE
[16:45:05.854]  $ dryrun          : logi FALSE
[16:45:05.854]  $ quiet           : logi FALSE
[16:45:05.854]  $ setup_strategy  : chr "parallel"
[16:45:05.854]  $ local_cmd       : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__
[16:45:05.854]  $ pidfile         : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpqY74vA/worker.rank=1.parallelly.parent=153256.256a83a0f64fb.pid"
[16:45:05.854]  $ rshcmd_label    : NULL
[16:45:05.854]  $ rsh_call        : NULL
[16:45:05.854]  $ cmd             : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__
[16:45:05.854]  $ localMachine    : logi TRUE
[16:45:05.854]  $ make_fcn        :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), 
[16:45:05.854]     master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", 
[16:45:05.854]         2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", 
[16:45:05.854]         30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, 
[16:45:05.854]     rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", 
[16:45:05.854]         "cmd", "sh", "none"), default_packages = c("datasets", "utils", 
[16:45:05.854]         "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, 
[16:45:05.854]     socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", 
[16:45:05.854]         "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", 
[16:45:05.854]         FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", 
[16:45:05.854]         NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", 
[16:45:05.854]         NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, 
[16:45:05.854]     setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", 
[16:45:05.854]         "parallel"), action = c("launch", "options"), verbose = FALSE)  
[16:45:05.854]  $ arguments       :List of 28
[16:45:05.854]   ..$ worker          : chr "localhost"
[16:45:05.854]   ..$ master          : NULL
[16:45:05.854]   ..$ port            : int 24719
[16:45:05.854]   ..$ connectTimeout  : num 120
[16:45:05.854]   ..$ timeout         : num 120
[16:45:05.854]   ..$ rscript         : NULL
[16:45:05.854]   ..$ homogeneous     : NULL
[16:45:05.854]   ..$ rscript_args    : NULL
[16:45:05.854]   ..$ rscript_envs    : NULL
[16:45:05.854]   ..$ rscript_libs    : NULL
[16:45:05.854]   ..$ rscript_startup : NULL
[16:45:05.854]   ..$ rscript_sh      : chr "auto"
[16:45:05.854]   ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ...
[16:45:05.854]   ..$ methods         : logi TRUE
[16:45:05.854]   ..$ socketOptions   : chr "no-delay"
[16:45:05.854]   ..$ useXDR          : logi FALSE
[16:45:05.854]   ..$ outfile         : chr "/dev/null"
[16:45:05.854]   ..$ renice          : int NA
[16:45:05.854]   ..$ rshcmd          : NULL
[16:45:05.854]   ..$ user            : NULL
[16:45:05.854]   ..$ revtunnel       : logi NA
[16:45:05.854]   ..$ rshlogfile      : NULL
[16:45:05.854]   ..$ rshopts         : NULL
[16:45:05.854]   ..$ rank            : int 1
[16:45:05.854]   ..$ manual          : logi FALSE
[16:45:05.854]   ..$ dryrun          : logi FALSE
[16:45:05.854]   ..$ quiet           : logi FALSE
[16:45:05.854]   ..$ setup_strategy  : chr "parallel"
[16:45:05.854]  - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions"
[16:45:05.890] [local output] System call to launch all workers:
[16:45:05.890] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=as.cluster.R:153256:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpqY74vA/worker.rank=1.parallelly.parent=153256.256a83a0f64fb.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=24719 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel
[16:45:05.890] [local output] Starting PSOCK main server
[16:45:05.894] [local output] Workers launched
[16:45:05.894] [local output] Waiting for workers to connect back
[16:45:05.895]  - [local output] 0 workers out of 1 ready
[16:45:06.158]  - [local output] 0 workers out of 1 ready
[16:45:06.158]  - [local output] 1 workers out of 1 ready
[16:45:06.159] [local output] Launching of 1 workers completed
[16:45:06.159] [local output] Number of nodes in cluster: 1
[16:45:06.159] [local output] Collecting session information from 1 workers
[16:45:06.161] [local output]  - Worker #1 of 1
[16:45:06.161] [local output] makeClusterPSOCK() ... done
Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32)
*** cluster operations - as.cluster() ...
Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32)
RichSOCKnode of a socket cluster on local host 'localhost' with pid 143128 (R Under development (unstable) (2025-01-29 r87668 ucrt), x86_64-w64-mingw32) using socket connection #4 ('<-CRANwin3.fb05.statistik.uni-dortmund.de:24719')
RichSOCKnode of a socket cluster on local host 'localhost' with pid 143128 (R Under development (unstable) (2025-01-29 r87668 ucrt), x86_64-w64-mingw32) using socket connection #4 ('<-CRANwin3.fb05.statistik.uni-dortmund.de:24719')
Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32)
Warning: The combined cluster contains 1 duplicated nodes
Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32)
*** cluster operations - as.cluster() ... DONE
*** cluster operations - c(...) ...
[16:45:06.178] [local output] makeClusterPSOCK() ...
[16:45:06.178] [local output] Workers: [n = 1] 'localhost'
[16:45:06.183] [local output] Base port: 29220
[16:45:06.183] [local output] Getting setup options for 1 cluster nodes ...
[16:45:06.183] [local output]  - Node #1 of 1 ...
[16:45:06.184] [local output] localMachine=TRUE => revtunnel=FALSE

[16:45:06.186] [local output] Rscript port: 29220

[16:45:06.187] [local output] Getting setup options for 1 cluster nodes ... done
[16:45:06.187] [local output]  - Parallel setup requested for some PSOCK nodes
[16:45:06.188] [local output] Setting up PSOCK nodes in parallel
[16:45:06.188] List of 36
[16:45:06.188]  $ worker          : chr "localhost"
[16:45:06.188]   ..- attr(*, "localhost")= logi TRUE
[16:45:06.188]  $ master          : chr "localhost"
[16:45:06.188]  $ port            : int 29220
[16:45:06.188]  $ connectTimeout  : num 120
[16:45:06.188]  $ timeout         : num 120
[16:45:06.188]  $ rscript         : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\""
[16:45:06.188]  $ homogeneous     : logi TRUE
[16:45:06.188]  $ rscript_args    : chr "--default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"#label=as.cluster.R:153256:CRANWIN3:CRA"| __truncated__
[16:45:06.188]  $ rscript_envs    : NULL
[16:45:06.188]  $ rscript_libs    : NULL
[16:45:06.188]  $ rscript_startup : NULL
[16:45:06.188]  $ rscript_sh      : chr [1:2] "cmd" "cmd"
[16:45:06.188]  $ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ...
[16:45:06.188]  $ methods         : logi TRUE
[16:45:06.188]  $ socketOptions   : chr "no-delay"
[16:45:06.188]  $ useXDR          : logi FALSE
[16:45:06.188]  $ outfile         : chr "/dev/null"
[16:45:06.188]  $ renice          : int NA
[16:45:06.188]  $ rshcmd          : NULL
[16:45:06.188]  $ user            : chr(0) 
[16:45:06.188]  $ revtunnel       : logi FALSE
[16:45:06.188]  $ rshlogfile      : NULL
[16:45:06.188]  $ rshopts         : chr(0) 
[16:45:06.188]  $ rank            : int 1
[16:45:06.188]  $ manual          : logi FALSE
[16:45:06.188]  $ dryrun          : logi FALSE
[16:45:06.188]  $ quiet           : logi FALSE
[16:45:06.188]  $ setup_strategy  : chr "parallel"
[16:45:06.188]  $ local_cmd       : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__
[16:45:06.188]  $ pidfile         : chr "D:/temp/2025_01_30_16_40_16_30529/RtmpqY74vA/worker.rank=1.parallelly.parent=153256.256a85dd53407.pid"
[16:45:06.188]  $ rshcmd_label    : NULL
[16:45:06.188]  $ rsh_call        : NULL
[16:45:06.188]  $ cmd             : chr "\"D:/RCompile/recent/R/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "| __truncated__
[16:45:06.188]  $ localMachine    : logi TRUE
[16:45:06.188]  $ make_fcn        :function (worker = getOption2("parallelly.localhost.hostname", "localhost"), 
[16:45:06.188]     master = NULL, port, connectTimeout = getOption2("parallelly.makeNodePSOCK.connectTimeout", 
[16:45:06.188]         2 * 60), timeout = getOption2("parallelly.makeNodePSOCK.timeout", 
[16:45:06.188]         30 * 24 * 60 * 60), rscript = NULL, homogeneous = NULL, rscript_args = NULL, 
[16:45:06.188]     rscript_envs = NULL, rscript_libs = NULL, rscript_startup = NULL, rscript_sh = c("auto", 
[16:45:06.188]         "cmd", "sh", "none"), default_packages = c("datasets", "utils", 
[16:45:06.188]         "grDevices", "graphics", "stats", if (methods) "methods"), methods = TRUE, 
[16:45:06.188]     socketOptions = getOption2("parallelly.makeNodePSOCK.socketOptions", 
[16:45:06.188]         "no-delay"), useXDR = getOption2("parallelly.makeNodePSOCK.useXDR", 
[16:45:06.188]         FALSE), outfile = "/dev/null", renice = NA_integer_, rshcmd = getOption2("parallelly.makeNodePSOCK.rshcmd", 
[16:45:06.188]         NULL), user = NULL, revtunnel = NA, rshlogfile = NULL, rshopts = getOption2("parallelly.makeNodePSOCK.rshopts", 
[16:45:06.188]         NULL), rank = 1L, manual = FALSE, dryrun = FALSE, quiet = FALSE, 
[16:45:06.188]     setup_strategy = getOption2("parallelly.makeNodePSOCK.setup_strategy", 
[16:45:06.188]         "parallel"), action = c("launch", "options"), verbose = FALSE)  
[16:45:06.188]  $ arguments       :List of 28
[16:45:06.188]   ..$ worker          : chr "localhost"
[16:45:06.188]   ..$ master          : NULL
[16:45:06.188]   ..$ port            : int 29220
[16:45:06.188]   ..$ connectTimeout  : num 120
[16:45:06.188]   ..$ timeout         : num 120
[16:45:06.188]   ..$ rscript         : NULL
[16:45:06.188]   ..$ homogeneous     : NULL
[16:45:06.188]   ..$ rscript_args    : NULL
[16:45:06.188]   ..$ rscript_envs    : NULL
[16:45:06.188]   ..$ rscript_libs    : NULL
[16:45:06.188]   ..$ rscript_startup : NULL
[16:45:06.188]   ..$ rscript_sh      : chr "auto"
[16:45:06.188]   ..$ default_packages: chr [1:6] "datasets" "utils" "grDevices" "graphics" ...
[16:45:06.188]   ..$ methods         : logi TRUE
[16:45:06.188]   ..$ socketOptions   : chr "no-delay"
[16:45:06.188]   ..$ useXDR          : logi FALSE
[16:45:06.188]   ..$ outfile         : chr "/dev/null"
[16:45:06.188]   ..$ renice          : int NA
[16:45:06.188]   ..$ rshcmd          : NULL
[16:45:06.188]   ..$ user            : NULL
[16:45:06.188]   ..$ revtunnel       : logi NA
[16:45:06.188]   ..$ rshlogfile      : NULL
[16:45:06.188]   ..$ rshopts         : NULL
[16:45:06.188]   ..$ rank            : int 1
[16:45:06.188]   ..$ manual          : logi FALSE
[16:45:06.188]   ..$ dryrun          : logi FALSE
[16:45:06.188]   ..$ quiet           : logi FALSE
[16:45:06.188]   ..$ setup_strategy  : chr "parallel"
[16:45:06.188]  - attr(*, "class")= chr [1:2] "makeNodePSOCKOptions" "makeNodeOptions"
[16:45:06.221] [local output] System call to launch all workers:
[16:45:06.221] [local output] "D:/RCompile/recent/R/bin/x64/Rscript" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e "#label=as.cluster.R:153256:CRANWIN3:CRAN" -e "try(suppressWarnings(cat(Sys.getpid(),file=\"D:/temp/2025_01_30_16_40_16_30529/RtmpqY74vA/worker.rank=1.parallelly.parent=153256.256a85dd53407.pid\")), silent = TRUE)" -e "options(socketOptions = \"no-delay\")" -e "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()" MASTER=localhost PORT=29220 OUT=/dev/null TIMEOUT=120 XDR=FALSE SETUPTIMEOUT=120 SETUPSTRATEGY=parallel
[16:45:06.221] [local output] Starting PSOCK main server
[16:45:06.227] [local output] Workers launched
[16:45:06.228] [local output] Waiting for workers to connect back
[16:45:06.228]  - [local output] 0 workers out of 1 ready
[16:45:06.488]  - [local output] 0 workers out of 1 ready
[16:45:06.488]  - [local output] 1 workers out of 1 ready
[16:45:06.488] [local output] Launching of 1 workers completed
[16:45:06.489] [local output] Number of nodes in cluster: 1
[16:45:06.489] [local output] Collecting session information from 1 workers
[16:45:06.490] [local output]  - Worker #1 of 1
[16:45:06.490] [local output] makeClusterPSOCK() ... done
Socket cluster with 1 nodes where 1 node is on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32)
Socket cluster with 2 nodes where 2 nodes are on host 'localhost' (R Under development (unstable) (2025-01-29 r87668 ucrt), platform x86_64-w64-mingw32)
*** cluster operations - c(...) ... DONE
> 
> 
> message("*** cluster operations - makeClusterPSOCK(remotes) ...")
*** cluster operations - makeClusterPSOCK(remotes) ...
> 
> remotes <- Sys.getenv("R_PARALLELLY_TESTS_REMOTES", "")
> remotes <- gsub(" ", "", unlist(strsplit(remotes, split = ",")))
> remotes <- remotes[nzchar(remotes)]
> if (length(remotes) > 0) {
+   message("Remotes: ", paste(sQuote(remotes), collapse = ", "))
+   local({
+     cl <- makeClusterPSOCK(remotes, verbose = TRUE)
+     on.exit(stopCluster(cl))
+     print(cl)
+   })
+ }
> 
> message("*** cluster operations - makeClusterPSOCK(remotes) ... DONE")
*** cluster operations - makeClusterPSOCK(remotes) ... DONE
> 
> message("*** cluster operations ... DONE")
*** cluster operations ... DONE
> 
> source("incl/end.R")
> 
> proc.time()
   user  system elapsed 
   0.45    0.15    1.54