Calls can be made in parallel or consecutively, the function waits until all calls have finished and returns call results. In consecutive mode the output on the workers can also be shown on the master during computation.
Please read and understand the comments for argument dir
.
Note that this function should only be used for short administrative
tasks or information gathering on the workers, the true work horse for
real computation is submitJobs
.
In makeSSHWorker
various options for load
management are possible. Note that these will be
ignored for the current call to execute it immediatly.
callFunctionOnSSHWorkers(
nodenames,
fun,
...,
consecutive = FALSE,
show.output = consecutive,
simplify = TRUE,
use.names = TRUE,
dir = getwd()
)
[character
]
Nodenames of workers to call function on.
Only workers which were specified in your
makeClusterFunctionsSSH
configuration can be used.
[function
]
Function to call on workers.
[any]
Arguments for fun
.
[logical(1)
]
Do calls consecutively and always wait until each worker is done.
Default is FALSE
.
[logical(1)
]
Show output of workers on master during call.
Can be useful to see what is happening.
Can only be used in consecutive mode.
Default is consecutive
.
[logical(1)
]
Should the result be simplified? See sapply
.
Default is TRUE
.
[logical(1)
]
Name results by nodenames
.
Default is TRUE
.
[character(1)
]
Directory under which a temporary registry will be
created in a subdirectory for communication.
This has to be somewhere on the shared
filesystem. The created subdirectory will be cleaned up on exit.
Default is current working directory.
Results of function calls, either a list or simplified.