search for: makesockmast

A solution is to have parallel:::.slaveRSOCK() attempt to connect multiple times before failing, e.g. makeSOCKmaster <- function(master, port, timeout, useXDR, maxTries = 10L, interval = 1.0) { port <- as.integer(port) for (i in seq_len(maxTries)) { con <- tryCatch({ socketConnection(master, port = port, blocking = TRUE, open = &...

...n socketConnection(master, port = port, blocking = TRUE, open = "a+b", : localhost:11000 cannot be opened Error in socketConnection(master, port = port, blocking = TRUE, open = "a+b", : cannot open the connection Calls: <Anonymous> ... doTryCatch -> recvData -> makeSOCKmaster -> socketConnection will produce an *instant* error on the worker, and before master opens the server socket. Eventually, master will produce the originally observed error: Error in socketConnection("localhost", port = 11000, server = TRUE, blocking = TRUE, : cannot open the co...

...master > died, and then you want the workers to die as well. > > Best, > > luke > > > On Fri, 9 Mar 2018, Henrik Bengtsson wrote: > >> A solution is to have parallel:::.slaveRSOCK() attempt to connect >> multiple times before failing, e.g. >> >> makeSOCKmaster <- function(master, port, timeout, useXDR, maxTries >> = 10L, interval = 1.0) { >> port <- as.integer(port) >> for (i in seq_len(maxTries)) { >> con <- tryCatch({ >> socketConnection(master, port = port, blocking = TRUE, &gt...

...nitely since the connection could be failing because the master died, and then you want the workers to die as well. Best, luke On Fri, 9 Mar 2018, Henrik Bengtsson wrote: > A solution is to have parallel:::.slaveRSOCK() attempt to connect > multiple times before failing, e.g. > > makeSOCKmaster <- function(master, port, timeout, useXDR, maxTries > = 10L, interval = 1.0) { > port <- as.integer(port) > for (i in seq_len(maxTries)) { > con <- tryCatch({ > socketConnection(master, port = port, blocking = TRUE, >...

I just noticed that parallel:::.slaveRSOCK() passes 'timeout' to socketConnection() as a character, i.e. there's a missing timeout <- as.integer(timeout), cf. port <- as.integer(port) and useXDR <- as.logical(value): > parallel:::.slaveRSOCK function () { 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&quo...

...d tail -f outfile, I got following: [... some R msgs ...] Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for a HTML browser interface to help. Type 'q()' to quit R. > > #library(serialize) > library(snow) > > slaveLoop(makeSOCKmaster()) Error in unserialize(node$con) : error reading from connection Execution halted after makeCluster() returns, the outfile hangs around the empty lines above, about 1 minute later, all msg shows up, also it dies. This is reproducible on my machine. Also, one of my friends also got th...

...CKcluster does not produce the cluster. If I run the function with outfile="" option, I obtain this message Error in socketConnection(master, port = port, blocking = TRUE, open = "a+b", : cannot open the connection Calls: <Anonymous> ... doTryCatch -> recvData -> makeSOCKmaster -> socketConnection In addition: Warning message: In socketConnection(master, port = port, blocking = TRUE, open = "a+b", : ip-10-158-31-12:11883 cannot be opened Execution halted Can you help me? Best regards Anna Longari [[alternative HTML version deleted]]

...001) soumen at 10.10.2.32's password: starting worker pid=2324 on soumen-HP-ProBook-440-G2:11001 at 12:11:59.349 Error in socketConnection(master, port = port, blocking = TRUE, open = "a+b",? : ? cannot open the connection Calls: <Anonymous> ... doTryCatch -> recvData -> makeSOCKmaster -> socketConnection In addition: Warning message: In socketConnection(master, port = port, blocking = TRUE, open = "a+b",? : ? soumen-HP-ProBook-440-G2:11001 cannot be opened Execution halted My sessionInfo() is as follwos sessionInfo() R version 3.2.1 (2015-06-18) Platform: x86_6...

...UPTIMEOUT=120 TIMEOUT=2 592000 XDR=TRUE This process will keep running for 'TIMEOUT=2592000' seconds (= 30 days). The reason for this is that it is currently in the state where it attempts to set up a connection to the main R process: > parallel:::.slaveRSOCK function () { makeSOCKmaster <- function(master, port, setup_timeout, timeout, useXDR) { ... repeat { con <- tryCatch({ socketConnection(master, port = port, blocking = TRUE, open = "a+b", timeout = timeout) }, error = id...

...t; This process will keep running for 'TIMEOUT=2592000' seconds (= 30 > days). The reason for this is that it is currently in the state where > it attempts to set up a connection to the main R process: > > > parallel:::.slaveRSOCK > function () > { > makeSOCKmaster <- function(master, port, setup_timeout, timeout, > useXDR) { > ... > repeat { > con <- tryCatch({ > socketConnection(master, port = port, blocking = TRUE, > open = "a+b", timeout =...