= Document = * [http://ace.acadiau.ca/math/ACMMaC/Rmpi/index.html Acadia Centre for Mathematical Modelling and Computation] * [http://ace.acadiau.ca/math/ACMMaC/Rmpi/Rmpi.pdf The Rmpi Package] = 基本結構 = * 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 會從呼叫它的 process 的 queue 中取得訊息,如果 queue 裡沒有資料,則 process 會一直等到接到訊息為止。 * info <- mpi.get.sourcetag() 當在 mpi.recv.Robj 後使用這個 function ,會回傳兩個整數,一個是訊息所傳送的 node 編號,一個是它的 tag 。 * mpi.bcast.cmd("R code") 讓所有的 slave processes 執行 R code , 這個 function 不會等待 slave 執行完畢。 * results <- mpi.remote.exec("R code") 讓所有的 slave processes 執行 R code ,並且回傳結果,這個 function 會等待所有的 slave 執行完畢後才回傳結果。