search for: mpi_fin

...umbers from all C slave processes*/ /* Using randarray doesn't make sense since this should correspond to the rdata vector in the R master process */ MPI_GAther(&rand, 1, 1, MPI_DOUBLE, randarray, 1, MPI_DOUBLE, 0, all_processes); /*All done*/ MPI_Comm_free(&all_processes); MPI_Finalize(); exit(0); }

...- function(){ if (is.loaded("mpi_initialize")){ if (mpi.comm.size(1) > 0){ print("Please use mpi.close.Rslaves() to close slaves.") mpi.close.Rslaves() } print("Please use mpi.quit() to quit R") .Call("mpi_finalize") } } # Function the slaves will call to perform a validation on the # fold equal to their slave number. # Assumes: thedata,fold,foldNumber,p foldslave <- function() { # Note the use of the tag for sent messages: # 1=ready_for_task, 2=done_task, 3=exiting # Note th...

...uot;mpi_initialize")) { if (mpi.comm.size(1) > 0) { print("Please use mpi.close.Rslaves() to close slaves.") mpi.close.Rslaves() } print("Please use mpi.quit() to quit R") .Call("mpi_finalize") } } # Define the base directory basedir <- "/home/user/directory/" fcnfishtest <- function() { wrout = paste(basedir, paste("processor",my_rank, sep=""), sep="") write(my_rank, wrout, append=TRUE) }...

...ion(){ if (is.loaded("mpi_initialize")){ if (mpi.comm.size(1) > 0){ print("Please use mpi.close.Rslaves() to close slaves.") mpi.close.Rslaves() } print("Please use mpi.quit() to quit R") .Call("mpi_finalize") } } # Tell all slaves to return a message identifying themselves mpi.remote.exec(paste("I am",mpi.comm.rank(),"of",mpi.comm.size())) # Tell all slaves to close down, and exit the program mpi.close.Rslaves() mpi.quit() Mark Lyman, Statistician AT...

...ading required package: utils Library Rmpi loaded. snowfall 1.70 initialized: parallel execution on 3 CPUs. Error in unserialize(obj) : unknown input format Calls: sfExport ... mpi.recv.Robj -> .mpi.unserialize -> unserialize -> .Call Execution halted MPI Application rank 0 exited before MPI_Finalize() with status 1 /users/mvalle/snow/snow/inst/RMPISNOW: line 40: 15028 Terminated R --no-save $* /users/mvalle/snow/snow/inst/RMPISNOW: line 40: 23906 Terminated R --no-save $* /users/mvalle/snow/snow/inst/RMPISNOW: line 40: 22094 Terminated R --no-save...

...oading required package: utils Library Rmpi loaded. snowfall 1.70 initialized: parallel execution on 3 CPUs. Error in unserialize(obj) : unknown input format Calls: sfExport ... mpi.recv.Robj -> .mpi.unserialize -> unserialize -> .Call Execution halted MPI Application rank 0 exited before MPI_Finalize() with status 1 /users/mvalle/snow/snow/inst/RMPISNOW: line 40: 15028 Terminated R --no-save $* /users/mvalle/snow/snow/inst/RMPISNOW: line 40: 23906 Terminated R --no-save $* /users/mvalle/snow/snow/inst/RMPISNOW: line 40: 22094 Terminated R --no-save $*...

I'm fairly astute at C and R but new to parallelization. Would someone be willing to provide help in the form of a simple example that parallelizes an R function from the inside of a C routine? If so, write me back at izmirlig at mail.nih.gov Thanks!

Hi list, It appears there is a problem with the OpenMPI I/O library on CentOS 6.2 & 6.3 (package openmpi-1.5.4-1.el6.x86_64). When I compile the attached program it ends up in the error path since MPI_File_open returns 16. The corresponding (unhelpful) message is: MPI_ERR_OTHER: known error not in list I couldn't find any pointers on the net and the same program works with OpenMPI

...p by Rmpi (slaves, memory, etc...) .Last <- function(){ if (is.loaded("mpi_initialize")){ if (mpi.comm.size(1) > 0){ print("Please use mpi.close.Rslaves() to close slaves.") mpi.close.Rslaves() } print("Please use mpi.quit() to quit R") .Call("mpi_finalize") } } # Tell all slaves to return a message identifying themselves mpi.remote.exec(paste("I am",mpi.comm.rank(),"of",mpi.comm.size())) # Tell all slaves to close down, and exit the program mpi.close.Rslaves() mpi.quit() My output is as follows; > source("./t...

...ed expression before ')' token Rmpi.c:88: error: expected ';' before 'R_chk_calloc' Rmpi.c:89: error: 'MPI_REQUEST_NULL' undeclared (first use in this function) Rmpi.c:91: error: 'MPI_COMM_NULL' undeclared (first use in this function) Rmpi.c: In function 'mpi_finalize': Rmpi.c:98: warning: implicit declaration of function 'MPI_Finalize' Rmpi.c:99: error: 'comm' undeclared (first use in this function) Rmpi.c:100: error: 'status' undeclared (first use in this function) Rmpi.c:101: error: 'request' undeclared (first use in t...