R/Rhpc.R

In Rhpc: Permits *apply() Style Dispatch for 'HPC'

Rhpc_initialize <- function()
{
    invisible(.Call("Rhpc_mpi_initialize", PACKAGE="Rhpc"))
}

Rhpc_getHandle <- function(procs=NA)
{
    cl<-.Call("Rhpc_gethandle", as.integer(procs), PACKAGE="Rhpc")
    Rhpc_setupRNG(cl)
    invisible(cl)
}

Rhpc_finalize <- function()
{
    invisible(.Call("Rhpc_mpi_finalize", PACKAGE="Rhpc"))
}

Rhpc_numberOfWorker <- function(cl)
{
    .Call("Rhpc_number_of_worker", cl, PACKAGE="Rhpc")
}

Rhpc_Export <- function(cl, variableNames,
                        usequote=ifelse(is.logical(getOption("Rhpc.usequote")),getOption("Rhpc.usequote"),TRUE),
                        pos=1, envir=as.environment(pos)) {
    for(name in variableNames){
        args<-list(name, get(name, envir = envir))
        .Call("Rhpc_mpi_worker_call", cl, args, as.integer(2), usequote, PACKAGE="Rhpc")
    }
}

Rhpc_worker_call <- function(cl,FUN, ...,
                             usequote=ifelse(is.logical(getOption("Rhpc.usequote")),getOption("Rhpc.usequote"),TRUE))
{
    arg  <- list(...)
    args <- list(FUN,arg)
    .Call("Rhpc_mpi_worker_call", cl, args, as.integer(1), usequote, PACKAGE="Rhpc")
}


Rhpc_worker_shy <- function(cl,FUN, ...,
                            usequote=ifelse(is.logical(getOption("Rhpc.usequote")),getOption("Rhpc.usequote"),TRUE))
{
    arg  <- list(...)
    args <- list(FUN,arg)
    invisible(.Call("Rhpc_mpi_worker_call", cl, args, as.integer(0), usequote, PACKAGE="Rhpc"))
}

Rhpc_worker_noback <- function(cl,FUN, ...,
                               usequote=ifelse(is.logical(getOption("Rhpc.usequote")),getOption("Rhpc.usequote"),TRUE))
{
    arg  <- list(...)
    args <- list(FUN,arg)
    invisible(.Call("Rhpc_mpi_worker_call", cl, args, as.integer(0), usequote, PACKAGE="Rhpc"))
}


Rhpc_lapply <- function(cl, X, FUN, ...,
                        usequote=ifelse(is.logical(getOption("Rhpc.usequote")),getOption("Rhpc.usequote"),TRUE))
{
    X   <- as.list(X)
    arg <-list(...)
    args<- list(FUN,arg)
    .Call("Rhpc_mpi_lapply_seq", cl, X, args, usequote, PACKAGE="Rhpc")
}

Rhpc_lapplyLB <- function(cl, X, FUN, ...,
                          usequote=ifelse(is.logical(getOption("Rhpc.usequote")),getOption("Rhpc.usequote"),TRUE))
{
    X   <- as.list(X)
    arg <-list(...)
    args<- list(FUN,arg)
    .Call("Rhpc_mpi_lapply_LB", cl, X, args, usequote, PACKAGE="Rhpc")
}