snow (version 0.4-4)

snow-internal: Internal SNOW Objects

Description

Internal functions for the snow package.

Usage

# S3 method for default
stopCluster(cl)
# S3 method for MPIcluster
stopCluster(cl)
# S3 method for 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 SOCKnode
closeNode(node)
# S3 method for SOCKnode
sendData(node, data)
# S3 method for SOCKnode
recvData(node)



setMPIcluster(new)
runMPIworker()
newMPInode(rank, comm)
makeMPImaster(comm)
# S3 method for MPInode
sendData(node, data)
# S3 method for MPInode
recvData(node)
closeNode(node)
# S3 method for default
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 MPIcluster
recvOneData(cl)

# S3 method for 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.