edu.iu.dsc.tws.rsched.schedulers.standalone

Class MPIJobWorkerController

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.standalone.MPIJobWorkerController

All Implemented Interfaces:

IWorkerController

public class MPIJobWorkerController
extends java.lang.Object
implements IWorkerController

Constructor Summary

Constructors

Constructor and Description
MPIJobWorkerController(IWorkerController original)

Method Summary

Modifier and Type	Method and Description
void	add(java.lang.String name, java.lang.Object value)
java.util.List<JobMasterAPI.WorkerInfo>	getAllWorkers() get all workers in the job.
CheckpointingClient	getCheckpointingClient()
java.util.List<JobMasterAPI.WorkerInfo>	getJoinedWorkers() get all joined workers in this job, including the ones finished execution if there are some workers that have not joined yet, they may not be included in this list.
int	getNumberOfWorkers() return the number of all workers in this job, including non-started ones and finished ones
java.lang.Object	getRuntimeObject(java.lang.String name) Get object with a given name
JobMasterAPI.WorkerInfo	getWorkerInfo() return the WorkerInfo object for this worker
JobMasterAPI.WorkerInfo	getWorkerInfoForID(int id) return the WorkerInfo object for the given ID
void	waitOnBarrier() wait for all workers in the job to arrive at this barrier After waiting for the timeout specified in ControllerContext.maxWaitTimeOnBarrier if some workers still could not arrive at the barrier, throw an exception

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.resource.IWorkerController

getFailureListener

Constructor Detail

MPIJobWorkerController

public MPIJobWorkerController(IWorkerController original)

Method Detail

add

public void add(java.lang.String name,
                java.lang.Object value)

getWorkerInfo

public JobMasterAPI.WorkerInfo getWorkerInfo()

Description copied from interface: IWorkerController

return the WorkerInfo object for this worker

Specified by:

getWorkerInfo in interface IWorkerController

getWorkerInfoForID

public JobMasterAPI.WorkerInfo getWorkerInfoForID(int id)

Description copied from interface: IWorkerController

return the WorkerInfo object for the given ID

Specified by:

getWorkerInfoForID in interface IWorkerController

getNumberOfWorkers

public int getNumberOfWorkers()

Description copied from interface: IWorkerController

return the number of all workers in this job, including non-started ones and finished ones

Specified by:

getNumberOfWorkers in interface IWorkerController

getJoinedWorkers

public java.util.List<JobMasterAPI.WorkerInfo> getJoinedWorkers()

Description copied from interface: IWorkerController

get all joined workers in this job, including the ones finished execution if there are some workers that have not joined yet, they may not be included in this list. users can compare the total number of workers to the size of this list and understand whether there are non-joined workers

Specified by:

getJoinedWorkers in interface IWorkerController

getAllWorkers

public java.util.List<JobMasterAPI.WorkerInfo> getAllWorkers()
                                                      throws TimeoutException

Description copied from interface: IWorkerController

get all workers in the job. If some workers has not joined the job yet, wait for them. After waiting for the timeout specified in ControllerContext.maxWaitTimeForAllToJoin if some workers still could not join, throw an exception

return all workers in the job including the ones that have already left, if any

Specified by:

getAllWorkers in interface IWorkerController

Throws:

TimeoutException

waitOnBarrier

public void waitOnBarrier()
                   throws TimeoutException

Description copied from interface: IWorkerController

wait for all workers in the job to arrive at this barrier After waiting for the timeout specified in ControllerContext.maxWaitTimeOnBarrier if some workers still could not arrive at the barrier, throw an exception

Specified by:

waitOnBarrier in interface IWorkerController

Throws:

TimeoutException

getRuntimeObject

public java.lang.Object getRuntimeObject(java.lang.String name)

Description copied from interface: IWorkerController

Get object with a given name

Specified by:

getRuntimeObject in interface IWorkerController

Parameters:

name - name

Returns:

the object

getCheckpointingClient

public CheckpointingClient getCheckpointingClient()

Specified by:

getCheckpointingClient in interface IWorkerController