sourcetag {pbdMPI} | R Documentation |
The functions extract MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_status.source and MPI_status.tag.
anysource() anytag() get.sourcetag(status = .pbd_env$SPMD.CT$status)
status |
a status number. |
These functions are for internal uses.
Corresponding status will be returned.
Wei-Chen Chen wccsnow@gmail.com, George Ostrouchov, Drew Schmidt, Pragneshkumar Patel, and Hao Yu.
Programming with Big Data in R Website: http://r-pbd.org/
## Not run: ### Save code in a file "demo.r" and run with 2 processors by ### SHELL> mpiexec -np 2 Rscript demo.r ### Initial. suppressMessages(library(pbdMPI, quietly = TRUE)) init() .comm.size <- comm.size() .comm.rank <- comm.rank() if(.comm.size < 2) comm.stop("At least two processors are requried.") ### Examples. if(.comm.rank != 0){ send(as.integer(.comm.rank * 10), rank.dest = 0L, tag = as.integer(.comm.rank + 10)) } if(.comm.rank == 0){ for(i in 1:(.comm.size - 1)){ ret <- recv(x.buffer = integer(1), rank.source = anysource(), tag = anytag()) sourcetag <- get.sourcetag() print(c(sourcetag, ret)) } } ### Finish. finalize() ## End(Not run)