Displaying 3 results from an estimated 3 matches for "done_task".
Did you mean:
done_tasks
2008 Jul 16
1
Problem with mpi.close.Rslaves()
...# Initialize MPI
library("Rmpi")
# Function the slaves will call to perform a validation on the
# fold equal to their slave number.
# Assumes: thedata,fold,foldNumber,p
foldslave <- function() {
# 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
junk <- 0
done <- 0
while (done != 1) {
# Signal being ready to receive a new task
mpi.send.Robj(junk,0,1)
# Receive a task
task &l...
2008 Nov 07
1
Rmpi task-pull
...quot;)
.Call("mpi_finalize")
}
}
# Function the slaves will call to perform a validation on the
# fold equal to their slave number.
# Assumes: thedata,fold,foldNumber,p
foldslave <- function() {
# 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
junk <- 0
done <- 0
while (done != 1) {
# Signal being ready to receive a new task
mpi.send.Robj(junk,0,1)
# Receive a task
task <- mpi.recv.Robj(mpi...
2009 Mar 25
0
Rmpi - send/receive multiple objects to slaves
...iangle,
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
junk <- 0
done <- 0
while (done != 1) {
# Signal being ready to receive a new task
mpi.send.Robj(junk,0,1)
# Receive a task
task <- mpi.recv.Robj(mpi.any.sour...