Displaying 7 results from an estimated 7 matches for "socknod".
Did you mean:
socknode
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(*, &...
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("...
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, Hen...
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)
whic...
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)...