search for: socknode

Displaying 7 results from an estimated 7 matches for "socknode".

Did you mean: locknode
2011 Oct 13
1
Package snow: is there any way to check if a cluster is "acticve"
...lled .PBcluster > str(.PBcluster) List of 4 $ :List of 3 ..$ con :Classes 'sockconn', 'connection' atomic [1:1] 3 .. .. ..- attr(*, "conn_id")=<externalptr> ..$ host: chr "localhost" ..$ rank: int 1 ..- attr(*, "class")= chr "SOCKnode" $ :List of 3 .... Then I stop it with > stopCluster(.PBcluster) > .PBcluster [[1]] $con Error in summary.connection(x) : invalid connection > str(.PBcluster) List of 4 $ :List of 3 ..$ con :Classes 'sockconn', 'connection' atomic [1:1] 3 .. .. ..- attr(*, &q...
2007 Jun 24
1
There was a problem by the use of snow.
...id resize_buffer(membuf_t mb, int needed) { - int newsize = 2 * needed; + size_t newsize = 2 * needed; mb->buf = realloc(mb->buf, newsize); if (mb->buf == NULL) error(_("cannot allocate buffer")); The time-out of read and write was not set. 51:sendData.SOCKnode <- function(node, data) { 52: timeout <- getClusterOption("timeout") 53: old <- options(timeout = timeout); 54: on.exit(options(old)) 55: serialize(data, node$con) 56: } 57: 58:recvData.SOCKnode <- function(node) { 59: timeout <- getClusterOption("t...
2018 Mar 09
2
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...en = "a+b", timeout = timeout) }, 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, Henr...
2018 Mar 10
1
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...}, 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 >>...
2018 Mar 09
0
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...t = timeout) > }, 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. > >...
2018 Mar 09
2
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...: 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, first launch the background worker as: system('R --slave --no-restore -e "parallel:::.slaveRSOCK()" --args MASTER=localhost PORT=11000 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE', wait = FALSE) which...
2018 Mar 09
0
parallel:::newPSOCKnode(): background worker fails immediately if socket on master is not set up in time (BUG?)
...makeSOCKmaster <- function(master, 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)...