Displaying 5 results from an estimated 5 matches for "sock0nod".
Did you mean:
sock0node
2018 Mar 09
2
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...meout)
}, error = identity)
if (inherits(con, "connection")) break
Sys.sleep(interval)
}
if (inherits(con, "error")) stop(con)
structure(list(con = con), class = if (useXDR)
"SOCKnode"
else "SOCK0node")
}
One could set 'maxTries' and 'interval' via commandArgs() like what is
done for the other arguments.
I'm happy to submit an SVN patch if R core thinks this is an
acceptable solution.
/Henrik
On Thu, Mar 8, 2018 at 7:36 PM, Henrik Bengtsson
<henrik.bengtsson...
2018 Mar 10
1
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...if (inherits(con, "connection")) break
>> Sys.sleep(interval)
>> }
>> if (inherits(con, "error")) stop(con)
>> structure(list(con = con), class = if (useXDR)
>> "SOCKnode"
>> else "SOCK0node")
>> }
>>
>> One could set 'maxTries' and 'interval' via commandArgs() like what is
>> done for the other arguments.
>>
>> I'm happy to submit an SVN patch if R core thinks this is an
>> acceptable solution.
>>
>> /H...
2018 Mar 09
0
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...identity)
> if (inherits(con, "connection")) break
> Sys.sleep(interval)
> }
> if (inherits(con, "error")) stop(con)
> structure(list(con = con), class = if (useXDR)
> "SOCKnode"
> else "SOCK0node")
> }
>
> One could set 'maxTries' and 'interval' via commandArgs() like what is
> done for the other arguments.
>
> I'm happy to submit an SVN patch if R core thinks this is an
> acceptable solution.
>
> /Henrik
>
> On Thu, Mar 8, 2018...
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 09
0
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...er, port, timeout, useXDR) {
port <- as.integer(port)
con <- socketConnection(master, port = port, blocking = TRUE,
open = "a+b", timeout = timeout)
structure(list(con = con), class = if (useXDR)
"SOCKnode"
else "SOCK0node")
}
master <- "localhost"
port <- NA_integer_
outfile <- Sys.getenv("R_SNOW_OUTFILE")
methods <- TRUE
useXDR <- TRUE
for (a in commandArgs(TRUE)) {
pos <- regexpr("=", a)
name <- substr(a, 1L, pos -...