diff --git a/DESCRIPTION b/DESCRIPTION index f56830a96..c4d0ef23a 100644 --- a/DESCRIPTION +++ b/DESCRIPTION @@ -1,7 +1,7 @@ Package: mirai Type: Package Title: Minimalist Async Evaluation Framework for R -Version: 0.10.0.9005 +Version: 0.10.0.9006 Description: Lightweight parallel code execution and distributed computing. Designed for simplicity, a 'mirai' evaluates an R expression asynchronously, on local or network resources, resolving automatically upon completion. diff --git a/NEWS.md b/NEWS.md index 0a22b10e9..82610e529 100644 --- a/NEWS.md +++ b/NEWS.md @@ -1,4 +1,4 @@ -# mirai 0.10.0.9005 (development) +# mirai 0.10.0.9006 (development) * `daemon()` argument 'exitlinger' retired as daemons now synchronise with the host/dispatcher and exit as soon as possible. * Optimises scheduling at dispatcher: tasks are no longer assigned to a daemon if it is exiting due to specified time/task-outs. diff --git a/R/mirai.R b/R/mirai.R index 20c496cf6..7ad996acc 100644 --- a/R/mirai.R +++ b/R/mirai.R @@ -121,7 +121,8 @@ daemon <- function(url, asyncdial = FALSE, maxtasks = Inf, idletime = Inf, (count >= maxtasks || count > timerstart && mclock() - start >= walltime) && { send(ctx, data = data, mode = 0L) - recv(sock, mode = 8L, block = .timelimit) + data <- recv_aio_signal(sock, cv = cv, mode = 8L) + wait(cv) break }