| Version 3 (modified by wade, 17 years ago) (diff) |
|---|
Document
基本結構
- library("Rmpi")
將 Rmpi 的 package 載入，讓我們可以使用 MPI 的 function。所以在使用任何 MPI functions 前必須先執行這個指令。
- mpi.spawn.Rslaves(nslaves=#)
會產生出 # 個 processes，如果沒有任何參數，則會產出這個 MPI 環境中最大數量的 nodes。
- mpi.close.Rslaves()
將所有的 slaves 關閉，建議在結束程式前必須執行此程式。
- mpi.quit([saving=yes/no])
將 Rmpi 所分配的資源清除，並且呼叫 R 的 quit function，我們必須使用這個 function 離開程式。
- mpi.comm.size()
回傳 processes 的個數，一般來說這個數目是 slaves 個數加上 1 個 master。
- mpi.comm.rank()
回傳每個 process 所代表的數字。
- mpi.bcast.Robj2slave(object)
將一個 R object(number, string or list) 或是 function 送給所有的 slaves 。
- mpi.send.Robj(object,destination,tag)
將一個 R object(number, string or list) 送給 destination ， destination 是就是 nodes 的 rank 。舉例來說， mpi.send.Robj(object,0,tag) ，會送到 master ， mpi.send.Robj(object,10,tag) 會送到 rank = 10 的 slave 。
- object <- mpi.recv.Robj(mpi.any.source(),mpi.any.tag())
使用這個 function 的 process 會從
