Displaying 5 results from an estimated 5 matches for "sinkworkeroutput".
2018 Mar 09
2
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
..., OUT = {
> outfile <- value
> }, TIMEOUT = {
> timeout <- value
> }, XDR = {
> useXDR <- as.logical(value)
> })
> }
> if (is.na(port))
> stop("PORT must be specified")
> sinkWorkerOutput(outfile)
> msg <- sprintf("starting worker pid=%d on %s at %s\n", Sys.getpid(),
> paste(master, port, sep = ":"), format(Sys.time(), "%H:%M:%OS3"))
> cat(msg)
> slaveLoop(makeSOCKmaster(master, port, timeout, useXDR))
> }
> <...
2018 Mar 09
2
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
BACKGROUND:
While troubleshooting random, occasionally occurring, errors from
parallel::makePSOCKcluster("localhost", port = 11000);
Error in socketConnection("localhost", port = port, server = TRUE,
blocking = TRUE, :
cannot open the connection
I had another look at parallel:::newPSOCKnode(), which is used
internally to set up each background worker. It is designed to,
2018 Mar 10
1
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...IMEOUT = {
>>> timeout <- value
>>> }, XDR = {
>>> useXDR <- as.logical(value)
>>> })
>>> }
>>> if (is.na(port))
>>> stop("PORT must be specified")
>>> sinkWorkerOutput(outfile)
>>> msg <- sprintf("starting worker pid=%d on %s at %s\n", Sys.getpid(),
>>> paste(master, port, sep = ":"), format(Sys.time(), "%H:%M:%OS3"))
>>> cat(msg)
>>> slaveLoop(makeSOCKmaster(master, port, ti...
2018 Mar 09
0
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...}, PORT = {
port <- value
}, OUT = {
outfile <- value
}, TIMEOUT = {
timeout <- value
}, XDR = {
useXDR <- as.logical(value)
})
}
if (is.na(port))
stop("PORT must be specified")
sinkWorkerOutput(outfile)
msg <- sprintf("starting worker pid=%d on %s at %s\n", Sys.getpid(),
paste(master, port, sep = ":"), format(Sys.time(), "%H:%M:%OS3"))
cat(msg)
slaveLoop(makeSOCKmaster(master, port, timeout, useXDR))
}
<bytecode: 0x4bd4b58>
<en...
2018 Mar 09
0
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...lt;- value
>> }, TIMEOUT = {
>> timeout <- value
>> }, XDR = {
>> useXDR <- as.logical(value)
>> })
>> }
>> if (is.na(port))
>> stop("PORT must be specified")
>> sinkWorkerOutput(outfile)
>> msg <- sprintf("starting worker pid=%d on %s at %s\n", Sys.getpid(),
>> paste(master, port, sep = ":"), format(Sys.time(), "%H:%M:%OS3"))
>> cat(msg)
>> slaveLoop(makeSOCKmaster(master, port, timeout, useXDR))...