Skip to content

Commit

Permalink
cleanups
Browse files Browse the repository at this point in the history
  • Loading branch information
shikokuchuo committed Nov 29, 2024
1 parent 7bba855 commit 44f1ca6
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions R/daemons.R
Original file line number Diff line number Diff line change
Expand Up @@ -316,7 +316,7 @@ daemons <- function(n, url = NULL, remote = NULL, dispatcher = c("process", "nex
output <- attr(dots, "output")
urld <- local_url()
sock <- req_socket(urld)
res <- launch_sync_dispatcher(sock, sock, wa52(urld, dots, n, NULL, url), output, tls, pass)
res <- launch_sync_dispatcher(sock, sock, wa52(urld, dots, n, url), output, tls, pass)
is.object(res) && stop(._[["sync_dispatcher"]])
store_dispatcher(sock, res, cv, envir)
`[[<-`(envir, "msgid", 100L)
Expand Down Expand Up @@ -382,7 +382,7 @@ daemons <- function(n, url = NULL, remote = NULL, dispatcher = c("process", "nex
{
cv <- cv()
sock <- req_socket(urld)
res <- launch_sync_dispatcher(sock, sock, wa42(urld, dots, envir[["stream"]], n, NULL), output)
res <- launch_sync_dispatcher(sock, sock, wa42(urld, dots, envir[["stream"]], n), output)
is.object(res) && stop(._[["sync_dispatcher"]])
store_dispatcher(sock, res, cv, envir)
for (i in seq_len(n)) next_stream(envir)
Expand Down Expand Up @@ -658,13 +658,13 @@ wa32 <- function(url, dots, rs, tls = NULL)
wa4 <- function(urld, dots, rs, n, urlc)
shQuote(sprintf(".libPaths(c(\"%s\",.libPaths()));mirai::dispatcher(\"%s\",n=%d,rs=c(%s),monitor=\"%s\"%s)", libp(), urld, n, paste0(rs, collapse= ","), urlc, dots))

wa42 <- function(urld, dots, rs, n, urlc)
wa42 <- function(urld, dots, rs, n)
shQuote(sprintf(".libPaths(c(\"%s\",.libPaths()));mirai::dispatcher2(\"%s\",n=%d,rs=c(%s)%s)", libp(), urld, n, paste0(rs, collapse= ","), dots))

wa5 <- function(urld, dots, n, urlc, url)
shQuote(sprintf(".libPaths(c(\"%s\",.libPaths()));mirai::dispatcher(\"%s\",c(\"%s\"),n=%d,monitor=\"%s\"%s)", libp(), urld, paste0(url, collapse = "\",\""), n, urlc, dots))

wa52 <- function(urld, dots, n, urlc, url)
wa52 <- function(urld, dots, n, url)
shQuote(sprintf(".libPaths(c(\"%s\",.libPaths()));mirai::dispatcher2(\"%s\",c(\"%s\"),n=%d%s)", libp(), urld, paste0(url, collapse = "\",\""), n, dots))

launch_daemon <- function(args, output)
Expand Down

0 comments on commit 44f1ca6

Please sign in to comment.