Package: Rmpi 0.7-2

Hao Yu

Rmpi: Interface (Wrapper) to MPI (Message-Passing Interface)

An interface (wrapper) to MPI. It also provides interactive R manager and worker environment.

Authors:Hao Yu [aut]

Rmpi_0.7-2.tar.gz
Rmpi_0.7-2.tar.gz(r-4.5-noble)Rmpi_0.7-2.tar.gz(r-4.4-noble)
Rmpi.pdf |Rmpi.html
Rmpi/json (API)

# Install 'Rmpi' in R:
install.packages('Rmpi', repos = c('https://cran.r-universe.dev', 'https://cloud.r-project.org'))

Peer review:

Uses libs:
  • openmpi– High performance message passing library

This package does not link to any Github/Gitlab/R-forge repository. No issue tracker or development information is available.

121 exports 5 stars 3.64 score 0 dependencies 5 dependents 20 mentions 772 scripts 2.8k downloads

Last updated 9 months agofrom:0f7ca2f8b0. Checks:OK: 2. Indexed: yes.

TargetResultDate
Doc / VignettesOKAug 27 2024
R-4.5-linux-x86_64OKAug 27 2024

Exports:.docall.force.type.mpi.undefined.mpi.worker.apply.mpi.worker.applyLB.mpi.worker.exec.mpi.worker.sim.onUnload.simplify.splitIndices.typeindexlamhostsmpi.abortmpi.allgathermpi.allgather.Robjmpi.allgathervmpi.allreducempi.any.sourcempi.any.tagmpi.applympi.applyLBmpi.barriermpi.bcastmpi.bcast.cmdmpi.bcast.data2slavempi.bcast.Rfun2slavempi.bcast.Robjmpi.bcast.Robj2slavempi.cancelmpi.cart.coordsmpi.cart.creatempi.cart.getmpi.cart.rankmpi.cart.shiftmpi.cartdim.getmpi.close.Rslavesmpi.comm.c2fmpi.comm.disconnectmpi.comm.dupmpi.comm.freempi.comm.get.parentmpi.comm.is.nullmpi.comm.maxsizempi.comm.rankmpi.comm.remote.sizempi.comm.set.errhandlermpi.comm.sizempi.comm.spawnmpi.comm.test.intermpi.dims.creatempi.exitmpi.finalizempi.gathermpi.gather.Robjmpi.gathervmpi.get.countmpi.get.processor.namempi.get.sourcetagmpi.hostinfompi.iapplympi.iapplyLBmpi.info.creatempi.info.freempi.info.getmpi.info.setmpi.intercomm.mergempi.iparApplympi.iparCapplympi.iparLapplympi.iparMMmpi.iparRapplympi.iparReplicatempi.iparSapplympi.iprobempi.irecvmpi.is.mastermpi.isendmpi.isend.Robjmpi.parApplympi.parCapplympi.parLapplympi.parMMmpi.parRapplympi.parReplicatempi.parSapplympi.parSimmpi.probempi.proc.nullmpi.quitmpi.realloc.commmpi.realloc.requestmpi.realloc.statusmpi.recvmpi.recv.Robjmpi.reducempi.remote.execmpi.request.maxsizempi.scattermpi.scatter.Robjmpi.scatter.Robj2slavempi.scattervmpi.sendmpi.send.Robjmpi.sendrecvmpi.sendrecv.replacempi.setup.rngstreammpi.spawn.Rslavesmpi.status.maxsizempi.testmpi.test.cancelledmpi.testallmpi.testanympi.testsomempi.universe.sizempi.waitmpi.waitallmpi.waitanympi.waitsomeslave.hostinfostringtailslave.log

Dependencies:

Readme and manuals

Help Manual

Help pageTopics
Hosts Informationlamhosts mpi.hostinfo mpi.is.master slave.hostinfo
MPI_Abort APImpi.abort
MPI Constantsmpi.any.source mpi.any.tag mpi.proc.null
Scatter an array to slaves and then apply a FUNmpi.apply mpi.iapply
(Load balancing) parallel applympi.applyLB mpi.parApply mpi.parCapply mpi.parLapply mpi.parMM mpi.parRapply mpi.parReplicate mpi.parSapply
MPI_Barrier APImpi.barrier
MPI_Bcast APImpi.bcast
Extension of MPI_Bcast APImpi.bcast.cmd
Extensions of MPI_Bcast APImpi.bcast.data2slave mpi.bcast.Rfun2slave mpi.bcast.Robj mpi.bcast.Robj2slave
MPI_Cart_coordsmpi.cart.coords
MPI_Cart_creatempi.cart.create
MPI_Cart_getmpi.cart.get
MPI_Cart_rankmpi.cart.rank
MPI_Cart_shiftmpi.cart.shift
MPI_Cartdim_getmpi.cartdim.get
MPI_Comm_disconnect APImpi.comm.disconnect
MPI_Comm_free APImpi.comm.free
MPI_Comm_get_parent, MPI_Comm_remote_size, MPI_Comm_test_inter APIsmpi.comm.get.parent mpi.comm.remote.size mpi.comm.test.inter
MPI_Comm_set_errhandler APImpi.comm.set.errhandler
MPI_Comm_c2f, MPI_Comm_dup, MPI_Comm_rank, and MPI_Comm_size APIsmpi.comm.c2f mpi.comm.dup mpi.comm.rank mpi.comm.size
MPI_Comm_spawn APImpi.comm.spawn
MPI_Dims_creatempi.dims.create
Exit MPI Environmentmpi.exit mpi.quit
MPI_Finalize APImpi.finalize
MPI_Gather, MPI_Gatherv, MPI_Allgather, and MPI_Allgatherv APIsmpi.allgather mpi.allgatherv mpi.gather mpi.gatherv
Extentions of MPI_Gather and MPI_Allgather APIsmpi.allgather.Robj mpi.gather.Robj
MPI_Get_count APImpi.get.count
MPI_Get_processor_name APImpi.get.processor.name
Utility for finding the source and tag of a received messagempi.get.sourcetag
(Load balancing) parallel apply with nonblocking featuresmpi.iapplyLB mpi.iparApply mpi.iparCapply mpi.iparLapply mpi.iparMM mpi.iparRapply mpi.iparReplicate mpi.iparSapply
MPI_Info_create, MPI_Info_free, MPI_Info_get, MPI_Info_set APIsmpi.info.create mpi.info.free mpi.info.get mpi.info.set
MPI_Intercomm_merge APImpi.intercomm.merge
Parallel Monte Carlo Simulationmpi.parSim
MPI_Probe and MPI_Iprobe APIsmpi.iprobe mpi.probe
Find and increase the lengthes of MPI opaques comm, request, and statusmpi.comm.maxsize mpi.realloc.comm mpi.realloc.request mpi.realloc.status mpi.request.maxsize mpi.status.maxsize
MPI_Reduce and MPI_Allreduce APIsmpi.allreduce mpi.reduce
Remote Executions on R slavesmpi.remote.exec
MPI_Scatter and MPI_Scatterv APIsmpi.scatter mpi.scatterv
Extensions of MPI_ SCATTER and MPI_SCATTERVmpi.scatter.Robj mpi.scatter.Robj2slave
MPI_Send, MPI_Isend, MPI_Recv, and MPI_Irecv APIsmpi.irecv mpi.isend mpi.recv mpi.send
Extensions of MPI_Send and MPI_Recv APIsmpi.isend.Robj mpi.recv.Robj mpi.send.Robj
MPI_Sendrecv and MPI_Sendrecv_replace APIsmpi.sendrecv mpi.sendrecv.replace
Setup parallel RNG on all slavesmpi.setup.rngstream
Spawn and Close R Slavesmpi.close.Rslaves mpi.spawn.Rslaves tailslave.log
MPI_Universe_size APImpi.universe.size
Nonblocking completion operationsmpi.cancel mpi.test mpi.test.cancelled mpi.testall mpi.testany mpi.testsome mpi.wait mpi.waitall mpi.waitany mpi.waitsome
Internal functions.docall .force.type .mpi.undefined .mpi.worker.apply .mpi.worker.applyLB .mpi.worker.exec .mpi.worker.sim .onUnload .simplify .splitIndices .typeindex mpi.comm.is.null string