edu.iu.dsc.tws.rsched.worker

Class MPIWorkerManager

java.lang.Object

edu.iu.dsc.tws.rsched.worker.MPIWorkerManager

All Implemented Interfaces:

IJobMasterFailureListener, IWorkerFailureListener

public class MPIWorkerManager
extends java.lang.Object
implements IWorkerFailureListener, IJobMasterFailureListener

Constructor Summary

Constructors

Constructor and Description
MPIWorkerManager()

Method Summary

Modifier and Type	Method and Description
boolean	execute(Config config, JobAPI.Job job, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume, IWorker managedWorker)
void	failed(int wID) let the listener know that a worker failed
void	jmFailed() informs when the job master fails.
void	jmRestarted(java.lang.String jobMasterAddress) informs when the job master rejoins after failure
void	restarted(JobMasterAPI.WorkerInfo workerInfo) let the listener know that previously failed worker rejoined the job

Methods inherited from class java.lang.Object

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

Constructor Detail

MPIWorkerManager

public MPIWorkerManager()

Method Detail

execute

public boolean execute(Config config,
                       JobAPI.Job job,
                       IWorkerController workerController,
                       IPersistentVolume persistentVolume,
                       IVolatileVolume volatileVolume,
                       IWorker managedWorker)

jmFailed

public void jmFailed()

Description copied from interface: IJobMasterFailureListener

informs when the job master fails.

Specified by:

jmFailed in interface IJobMasterFailureListener

jmRestarted

public void jmRestarted(java.lang.String jobMasterAddress)

Description copied from interface: IJobMasterFailureListener

informs when the job master rejoins after failure

Specified by:

jmRestarted in interface IJobMasterFailureListener

failed

public void failed(int wID)

Description copied from interface: IWorkerFailureListener

let the listener know that a worker failed

Specified by:

failed in interface IWorkerFailureListener

restarted

public void restarted(JobMasterAPI.WorkerInfo workerInfo)

Description copied from interface: IWorkerFailureListener

let the listener know that previously failed worker rejoined the job

Specified by:

restarted in interface IWorkerFailureListener