Add compute_env() helper (#404)

* Add compute_env() helper

* Refresh readme

Author: shikokuchuo

R/daemons.R

@@ -368,9 +368,8 @@ with.miraiDaemons <- function(data, expr, ...) {
 #' @export
 #'
 status <- function(.compute = NULL) {
-  if (is.null(.compute)) .compute <- .[["cp"]]
   is.list(.compute) && return(status(attr(.compute, "id")))
-  envir <- ..[[.compute]]
+  envir <- compute_env(.compute)
   is.null(envir) && return(list(connections = 0L, daemons = 0L))
   is.null(envir[["dispatcher"]]) || return(dispatcher_status(envir))
   list(connections = as.integer(stat(envir[["sock"]], "pipes")), daemons = envir[["url"]])
@@ -393,10 +392,7 @@ status <- function(.compute = NULL) {
 #'
 #' @export
 #'
-daemons_set <- function(.compute = NULL) {
-  if (is.null(.compute)) .compute <- .[["cp"]]
-  !is.null(..[[.compute]])
-}
+daemons_set <- function(.compute = NULL) !is.null(compute_env(.compute))
 
 #' Require Daemons
 #'
@@ -552,6 +548,8 @@ register_serial <- function(class, sfunc, ufunc) {
 
 # internals --------------------------------------------------------------------
 
+compute_env <- function(x) ..[[if (is.null(x)) .[["cp"]] else x]]
+
 configure_tls <- function(url, tls, pass, envir, config = TRUE) {
   purl <- parse_url(url)
   sch <- purl[["scheme"]]

R/launchers.R

@@ -45,8 +45,7 @@
 #' @export
 #'
 launch_local <- function(n = 1L, ..., tls = NULL, .compute = NULL) {
-  if (is.null(.compute)) .compute <- .[["cp"]]
-  envir <- ..[[.compute]]
+  envir <- compute_env(.compute)
   is.null(envir) && stop(._[["daemons_unset"]])
   url <- envir[["url"]]
   write_args <- if (is.null(envir[["dispatcher"]])) args_daemon_direct else args_daemon_disp
@@ -83,13 +82,12 @@ launch_local <- function(n = 1L, ..., tls = NULL, .compute = NULL) {
 #' @export
 #'
 launch_remote <- function(n = 1L, remote = remote_config(), ..., tls = NULL, .compute = NULL) {
-  if (is.null(.compute)) .compute <- .[["cp"]]
   if (!is.numeric(n) && inherits(n, c("miraiCluster", "miraiNode"))) {
     .compute <- attr(n, "id")
     n <- max(length(n), 1L)
   }
   n <- as.integer(n)
-  envir <- ..[[.compute]]
+  envir <- compute_env(.compute)
   is.null(envir) && stop(._[["daemons_unset"]])
   url <- envir[["url"]]
   write_args <- if (is.null(envir[["dispatcher"]])) args_daemon_direct else args_daemon_disp

R/map.R

@@ -154,6 +154,7 @@
 #' @export
 #'
 mirai_map <- function(.x, .f, ..., .args = list(), .promise = NULL, .compute = NULL) {
+  if (is.null(.compute)) .compute <- .[["cp"]]
   require_daemons(.compute = .compute, call = environment())
   is.function(.f) || stop(sprintf(._[["function_required"]], typeof(.f)))
 

R/mirai.R

@@ -140,8 +140,7 @@
 #'
 mirai <- function(.expr, ..., .args = list(), .timeout = NULL, .compute = NULL) {
   missing(.expr) && stop(._[["missing_expression"]])
-  if (is.null(.compute)) .compute <- .[["cp"]]
-  envir <- ..[[.compute]]
+  envir <- compute_env(.compute)
 
   expr <- substitute(.expr)
   globals <- list(...)

README.Rmd

@@ -31,8 +31,6 @@ knitr::opts_chunk$set(
 Minimalist Async Evaluation Framework for R
 <br /><br />
 
-mirai is a comprehensive solution for performing computationally-intensive tasks efficiently.
-
 → Run R code in parallel in the background, without blocking your session
 
 → Distribute workloads across local or remote machines
@@ -117,13 +115,13 @@ mirai is designed from the ground up to provide a production-grade experience.
 
 → Error Handling: Robust error handling and reporting, with full stack traces for debugging.
 
-→ RNG Management: L'Ecuyer-CMRG RNG streams for reproducible random number generation in parallel execution.
+→ RNG Management: L'Ecuyer-CMRG RNG streams for reproducible parallel random number generation.
 
 ### Powering the Ecosystem
 
 mirai serves as a foundation for asynchronous and parallel computing in the R ecosystem:
 
-[<img alt="R parallel" src="https://www.r-project.org/logo/Rlogo.png" width="40" height="31" />](https://mirai.r-lib.org/articles/v04-parallel.html) &nbsp; Implements the first official alternative communications backend for R — the 'MIRAI' parallel cluster — fulfilling a feature request by R-Core at R Project Sprint 2023.
+[<img alt="R parallel" src="https://www.r-project.org/logo/Rlogo.png" width="40" height="31" />](https://mirai.r-lib.org/articles/v04-parallel.html) &nbsp; Implements the first official alternative communications backend for R, the 'MIRAI' parallel cluster, fulfilling a feature request by R-Core at R Project Sprint 2023.
 
 [<img alt="purrr" src="https://purrr.tidyverse.org/logo.png" width="40" height="46" />](https://purrr.tidyverse.org) &nbsp; Powers parallel map for the purrr functional programming toolkit, a core tidyverse package.
 

README.md

@@ -20,9 +20,6 @@ coverage](https://codecov.io/gh/r-lib/mirai/graph/badge.svg)](https://app.codeco
 <br /> みらい 未来 <br /><br /> Minimalist Async Evaluation Framework
 for R <br /><br />
 
-mirai is a comprehensive solution for performing
-computationally-intensive tasks efficiently.
-
 → Run R code in parallel in the background, without blocking your
 session
 
@@ -125,17 +122,17 @@ objects such as Arrow Tables, Polars DataFrames or torch tensors.
 → Error Handling: Robust error handling and reporting, with full stack
 traces for debugging.
 
-→ RNG Management: L’Ecuyer-CMRG RNG streams for reproducible random
-number generation in parallel execution.
+→ RNG Management: L’Ecuyer-CMRG RNG streams for reproducible parallel
+random number generation.
 
 ### Powering the Ecosystem
 
 mirai serves as a foundation for asynchronous and parallel computing in
 the R ecosystem:
 
 [<img alt="R parallel" src="https://www.r-project.org/logo/Rlogo.png" width="40" height="31" />](https://mirai.r-lib.org/articles/v04-parallel.html)
-  Implements the first official alternative communications backend for R
-— the ‘MIRAI’ parallel cluster — fulfilling a feature request by R-Core
+  Implements the first official alternative communications backend for
+R, the ‘MIRAI’ parallel cluster, fulfilling a feature request by R-Core
 at R Project Sprint 2023.
 
 [<img alt="purrr" src="https://purrr.tidyverse.org/logo.png" width="40" height="46" />](https://purrr.tidyverse.org)