inst/examples/test_cs/simple.client.r

In pbdMPI: R Interface to MPI for HPC Clusters (Programming with Big Data Project)

### See ``http://www.mpi-forum.org/docs/mpi-20-html/node106.htm'' for details.

args<-commandArgs(TRUE)
port.name <- args[1]
print(port.name)

### Initialize MPI.
suppressMessages(library(pbdMPI, quietly = TRUE))
.pbd_env$SPMD.CT$check.type <- FALSE
server.comm <- .pbd_env$SPMD.CT$newcomm

### Connection start.
comm.connect(port.name, newcomm = server.comm)

### Communicate 1.
buffer <- as.integer(1:5)
spmd.send.integer(buffer, rank.dest = 0L, tag = 2L, comm = server.comm)

### Communicate 2.
ret <- spmd.allgather.integer(buffer, rep(buffer, 2), comm = server.comm)
print(ret)

### Connection stop.
comm.disconnect(comm = server.comm)

### Finish.
finalize()