poll
Poll for process I/O or termination
Wait until one of the specified processes produce standard output or error, terminates, or a timeout occurs.
Usage
poll(processes, ms)Arguments
- processes
A list of
processobjects to wait on. If this is a named list, then the returned list will have the same names. This simplifies the identification of the processes. If an empty list, then the- ms
Integer scalar, a timeout for the polling, in milliseconds. Supply -1 for an infitite timeout, and 0 for not waiting at all.
Value
A list of character vectors of length two. There is one list
element for each process, in the same order as in the input list.
The character vectors' elements are named output and error and
their possible values are: nopipe, ready, timeout, closed,
silent. See details about these below.
Explanation of the return values
nopipemeans that the stdout or stderr from this process was not captured.readymeans that stdout or stderr from this process are ready to read from. Note that end-of-file on these outputs also triggersready.timeout`: the processes are not ready to read from and a timeout happened.
closed: the connection was already closed, before the polling started.silent: the connection is not ready to read from, but another connection was.
Known issues
You cannot wait on the termination of a process directly. It is only signalled through the closed stdout and stderr pipes. This means that if both stdout and stderr are ignored or closed for a process, then you will not be notified when it exits.
Examples
library(processx)
# NOT RUN {
## Different commands to run for windows and unix
# }
# NOT RUN {
cmd1 <- switch(
.Platform$OS.type,
"unix" = "sleep 1; ls",
"ping -n 2 127.0.0.1 && dir /b"
)
cmd2 <- switch(
.Platform$OS.type,
"unix" = "sleep 2; ls 1>&2",
"ping -n 2 127.0.0.1 && dir /b 1>&2"
)
## Run them. p1 writes to stdout, p2 to stderr, after some sleep
p1 <- process$new(commandline = cmd1, stdout = "|")
p2 <- process$new(commandline = cmd2, stderr = "|")
## Nothing to read initially
poll(list(p1 = p1, p2 = p2), 0)
## Wait until p1 finishes. Now p1 has some output
p1$wait()
poll(list(p1 = p1, p2 = p2), -1)
## Close p1's connection, p2 will have output on stderr, eventually
close(p1$get_output_connection())
poll(list(p1 = p1, p2 = p2), -1)
## Close p2's connection as well, no nothing to poll
close(p2$get_error_connection())
poll(list(p1 = p1, p2 = p2), 0)
# }