search for: sock0node

Displaying 5 results from an estimated 5 matches for "sock0node".

Did you mean: locknode
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 a...
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. >> >> /He...
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 a...
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 -...