Displaying 3 results from an estimated 3 matches for "slave_id".
Did you mean:
slave_fd
2009 Mar 25
0
Rmpi - send/receive multiple objects to slaves
...ubset of the
matrix to each slave. How do I do this?
For example, rather than broadcasting the whole of matrix m to all slaves:
mpi.bcast.Robj2slave(m)
Can I send a subset of the matrix (depending on what the tasks is) at the same
time I send the task to the slaves e.g.:
mpi.send.Robj(tasks[[1]], slave_id, 1)
idx <- c(tasks[[1]]$start:tasks[[1]]$end)
mpi.send.Robj(m[idx,idx], slave_id, 1)
If so, how do I receive the two objects in the slave? i.e. How do I modify 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 thi...
2008 Jul 16
1
Problem with mpi.close.Rslaves()
...sresult = 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) {
# slave is ready for a task. Give it the next task, or tell it
tasks
# are done if there are none.
if (length(tasks) > 0) {
# Send a task, and then remove it from the task l...
2008 Nov 07
1
Rmpi task-pull
...tore 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) {
# slave is ready for a task. Give it the next task, or tell it tasks
# are done if there are none.
if (length(tasks) > 0) {
# Send a task, and then remove it from the task list...