exit wait on cv instead

shikokuchuo · Sep 21, 2023 · ca2dced · ca2dced
1 parent 5630c7e
commit ca2dced
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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
     }