search for: intercomm

...ave = system.file("Rslaves.sh", package = "Rmpi"), : MPI_Error_string: error spawning process > traceback() 3: .Call("mpi_comm_spawn", as.character(slave), as.character(slavearg), as.integer(nslaves), as.integer(info), as.integer(root), as.integer(intercomm), PACKAGE = "Rmpi") 2: mpi.comm.spawn(slave = system.file("Rslaves.sh", package = "Rmpi"), slavearg = arg, nslaves = nslaves, info = 0, root = root, intercomm = intercomm) 1: mpi.spawn.Rslaves(nslaves = 5) There are no logfiles! What was changed in the...

....bat", package="Rmpi"), slavearg=arg, nslaves=count) } else{ # for unix count <- mpi.comm.spawn(slave = "/usr/bin/env", slavearg = args, nslaves = count, intercomm = intercomm) } Doing some work, there should be a better and nicer solution with directly using mpi.spawn.Rslaves. Best Markus -- Dipl.-Tech. Math. Markus Schmidberger Ludwig-Maximilians-Universit?t M?nchen IBE - Institut f?r medizinische Informationsverarbeitung, Biometrie und Epidemiologie...

...pi.spawn.Rslaves(nslaves=1) *** caught segfault *** address 0x2df0c9f, cause 'memory not mapped' Traceback: 1: .Call("mpi_comm_spawn", as.character(slave), as.character(slavearg), as.integer(nslaves), as.integer(info), as.integer(root), as.integer(intercomm), PACKAGE = "npRmpi") 2: mpi.comm.spawn(slave = system.file("Rslaves.sh", package = "npRmpi"), slavearg = arg, nslaves = nslaves, info = 0, root = root, intercomm = intercomm) 3: mpi.spawn.Rslaves(nslaves = 1) Possible actions: 1: abort...

...***************************************** rand.R ************************************************************************* library(Rmpi) rand <- function () { if (mpi.comm.size(1) > 1) stop ("It seems some slaves running on comm 1.") mpi.comm.spawn("./rand") mpi.intercomm.merge(2,0,1) mpi.init.sprng() free.sprng() #does this function exist here? rdata <- double(sum(mpi.comm.size(1))) out <- mpi.gather(0, 2, rdata) ##this isn't right mpi.comm.free() out } ************************************************************************* rand.c *******...

...ple mpi.get.count text html latex mpi.get.processor.name text html latex mpi.get.sourcetag text html latex mpi.info text html latex mpi.init.sprng text html latex mpi.intercomm.merge text html latex mpi.parSim text html latex mpi.parapply text html latex example mpi.probe text html latex mpi.realloc text html latex mpi.reduce...

Hi I am trying to utilize my dual core processor (and later a High-performance clusters (HPC) ) by using the Rmpi, snow, snowfall, ... packages, but I am struggling at the beginning, i.e. to initialise the "cluster" on my dual core computer. Whenever I try to initialize it (via sfInit(parallel=TRUE, cpus=2) or mpi.spawn.Rslaves(nslaves=2) ), I get an error message: >

...ple mpi.get.count text html latex mpi.get.processor.name text html latex mpi.get.sourcetag text html latex mpi.info text html latex mpi.init.sprng text html latex mpi.intercomm.merge text html latex mpi.parSim text html latex mpi.parapply text html latex example mpi.probe text html latex mpi.realloc text html latex mpi.reduce...

...mpi.get.count text html latex mpi.get.processor.name text html latex mpi.get.sourcetag text html latex mpi.info text html latex mpi.init.sprng text html latex mpi.intercomm.merge text html latex mpi.parallel.sim text html latex mpi.probe text html latex mpi.reduce text html latex mpi.remote.exec text html latex mpi.scatter...

....Rslaves(nslaves = 2) : >> You cannot use MPI_Comm_spawn API > > This error comes from Rmpi, > >> head(mpi.spawn.Rslaves, 6) > > 1 function (Rscript = system.file("slavedaemon.R", package = "Rmpi"), > 2 nslaves = mpi.universe.size(), root = 0, intercomm = 2, comm = 1, > 3 hosts = NULL, needlog = TRUE, mapdrive = TRUE) > 4 { > 5 if (!is.loaded("mpi_comm_spawn")) > 6 stop("You cannot use MPI_Comm_spawn API") > > and occurs when the compiler variable MPI2 is undefined when your > package is in...