search for: recvdata

...ar and submitting a new portion; dynamic load balancing becomes much less efficient. - Adding local side effects to the function and detecting them while the parallel function is running in a child process (parabar). A clever hack, but much harder to extend to distributed clusters. With recvData and recvOneData becoming exported in R-4.4 [*], another approach becomes feasible: wrap the cluster object (and all nodes) into another class, attach the progress callback as an attribute, and let recvData / recvOneData call it. This makes it possible to give wrapped cluster objects to unchanged co...

...dynamic load balancing > becomes much less efficient. > > - Adding local side effects to the function and detecting them while > the parallel function is running in a child process (parabar). A > clever hack, but much harder to extend to distributed clusters. > > With recvData and recvOneData becoming exported in R-4.4 [*], another > approach becomes feasible: wrap the cluster object (and all nodes) into > another class, attach the progress callback as an attribute, and let > recvData / recvOneData call it. This makes it possible to give wrapped > cluster obj...

...achines makePSOCKcluster 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...

...ate 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("timeout") 60: old <- options(timeout = timeout); 61: on.exit(options(old)) 62: unserialize(node$con) 63: } --- R-2.5.0.orig/src/modules/internet/sockconn.c 2006-09-04 23:20:59.000000000 +0900...

...s=FALSE,port=11001) 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-...

...3.617 Warning in 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, :...

...t = 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("localh...

...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: >>>>...

...nnection(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, ser...

...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 s...