Displaying 3 results from an estimated 3 matches for "n_slave".
Did you mean:
n_slaves
2008 Jul 16
1
Problem with mpi.close.Rslaves()
...to
# undertake tasks
mpi.bcast.cmd(foldslave())
# Create task list
tasks <- vector('list')
for (i in 1:10) {
tasks[[i]] <- list(foldNumber=i)
}
# Create data structure to store the results
rssresult = matrix(0,p,10)
junk <- 0
closed_slaves <- 0
n_slaves <- mpi.comm.size()-1
while (closed_slaves < n_slaves) {
# Receive a message from a slave
message <- mpi.recv.Robj(mpi.any.source(),mpi.any.tag())
message_info <- mpi.get.sourcetag()
slave_id <- message_info[1]
tag <- message_info[2]
if...
2008 Nov 07
1
Rmpi task-pull
...aves to get them ready to
# undertake tasks
mpi.bcast.cmd(foldslave())
# Create task list
tasks <- vector('list')
for (i in 1:10) {
tasks[[i]] <- list(foldNumber=i)
}
# Create data structure to store the results
rssresult = matrix(0,p,10)
junk <- 0
closed_slaves <- 0
n_slaves <- mpi.comm.size()-1
while (closed_slaves < n_slaves) {
# Receive a message from a slave
message <- mpi.recv.Robj(mpi.any.source(),mpi.any.tag())
message_info <- mpi.get.sourcetag()
slave_id <- message_info[1]
tag <- message_info[2]
if (tag == 1) {...
2009 Mar 25
0
Rmpi - send/receive multiple objects to slaves
...dify the
following to receive the task and the subset of matrix m:
task <- mpi.recv.Robj(mpi.any.source(),mpi.any.tag())
Once I have this figured out, I could then only send the upper/lower triangle,
to halve the data being passed around, but one step at a time!
Cheers,
Nathan
<code>
n_slaves <- mpi.comm.size()-1
slave <- function() {
# load my library in each slave
library(my_lib)
# Note the use of the tag for sent messages:
# 1=ready_for_task, 2=done_task, 3=exiting
# Note the use of the tag for received messages:
# 1=task, 2=done_tasks
ju...