snow-internal: Internal SNOW Objects

In snow: Simple Network of Workstations

Description

Internal functions for the snow package.

Usage

## Default S3 method:
stopCluster(cl)
## S3 method for class 'MPIcluster'
stopCluster(cl)
## S3 method for class 'spawnedMPIcluster'
stopCluster(cl)

defaultClusterOptions
addClusterOptions(options, new)
initDefaultClusterOptions(libname)

docall(fun, args)
workLoop(master)
sinkWorkerOutput(outfile)

newSOCKnode(machine = "localhost", ..., options = defaultClusterOptions, rank)
makeSOCKmaster(master = Sys.getenv("MASTER"), port = Sys.getenv("PORT"))
## S3 method for class 'SOCKnode'
closeNode(node)
## S3 method for class 'SOCKnode'
sendData(node, data)
## S3 method for class 'SOCKnode'
recvData(node)






setMPIcluster(new)
runMPIworker()
newMPInode(rank, comm)
makeMPImaster(comm)
## S3 method for class 'MPInode'
sendData(node, data)
## S3 method for class 'MPInode'
recvData(node)

closeNode(node)
## Default S3 method:
closeNode(node)
sendData(node, data)
recvData(node)

postNode(con, type, value = NULL, tag = NULL)
stopNode(n)

sendCall(con, fun, args, return = TRUE, tag = NULL)
recvResult(con)


initRNGstreamNode(stream)

splitIndices(nx, ncl)
splitList(x, ncl)
splitRows(x, ncl)
splitCols(x, ncl)

findRecvOneTag(cl, anytag)
recvOneData(cl)
recvOneResult(cl)
## S3 method for class 'MPIcluster'
recvOneData(cl)

## S3 method for class 'SOCKcluster'
recvOneData(cl)

getClusterOption(name, options = defaultClusterOptions)

checkCluster(cl)
checkForRemoteErrors(val)
staticClusterApply(cl, fun, n, argfun)
dynamicClusterApply(cl, fun, n, argfun)

shQuoteIfNeeded(p)

Details

These are not to be called by the user.

snow documentation built on Oct. 27, 2021, 5:08 p.m.