Internal SNOW Objects

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)
## S3 method for class 'NWScluster':
stopCluster(cl)
defaultClusterOptions
addClusterOptions(options, new)
initDefaultClusterOptions()

enquote(x)
docall(fun, args)
slaveLoop(master)
sinkWorkerOutput(outfile)

newSOCKnode(machine = "localhost", ..., options = defaultClusterOptions)
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)

newPVMnode(where = "", options = defaultClusterOptions)
makePVMmaster()
## S3 method for class 'PVMnode':
sendData(node, data)
## S3 method for class 'PVMnode':
recvData(node)

setMPIcluster(new)
runMPIslave()
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)

initSprngNode(streamno, nstream, seed, kind, para) 
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 'PVMcluster':
recvOneData(cl)
## S3 method for class 'SOCKcluster':
recvOneData(cl)
## S3 method for class 'NWScluster':
recvOneData(cl)
getClusterOption(name, options = defaultClusterOptions)

checkCluster(cl)
checkForRemoteErrors(val)
staticClusterApply(cl, fun, n, argfun)
dynamicClusterApply(cl, fun, n, argfun)
## S3 method for class 'cluster':
cl[...]

Details

These are not to be called by the user.