edu.iu.dsc.tws.master.worker

Class JMWorkerStatusUpdater

java.lang.Object

edu.iu.dsc.tws.master.worker.JMWorkerStatusUpdater

All Implemented Interfaces:

MessageHandler, IWorkerStatusUpdater

public class JMWorkerStatusUpdater
extends java.lang.Object
implements IWorkerStatusUpdater, MessageHandler

Constructor Summary

Constructors

Constructor and Description
JMWorkerStatusUpdater(RRClient rrClient, int workerID, Config config)

Method Summary

Modifier and Type	Method and Description
boolean	addWorkerFailureListener(IWorkerFailureListener workerFailureListener1) only one IWorkerFailureListener can be added if the second IWorkerFailureListener tried to be added, returns false
JobMasterAPI.WorkerState	getWorkerStatusForID(int id) return the status of any worker in the job
void	onMessage(RequestID id, int workerId, Message message) Handles a specific message type
boolean	updateWorkerStatus(JobMasterAPI.WorkerState newState) update the status of this worker in the job each worker reports its status changes with this method Dashboard, JobMaster and other workers get worker status updates if status update is unsuccessful, return false

Methods inherited from class java.lang.Object

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

Constructor Detail

JMWorkerStatusUpdater

public JMWorkerStatusUpdater(RRClient rrClient,
                             int workerID,
                             Config config)

Method Detail

updateWorkerStatus

public boolean updateWorkerStatus(JobMasterAPI.WorkerState newState)

Description copied from interface: IWorkerStatusUpdater

update the status of this worker in the job each worker reports its status changes with this method Dashboard, JobMaster and other workers get worker status updates if status update is unsuccessful, return false

Specified by:

updateWorkerStatus in interface IWorkerStatusUpdater

Returns:

addWorkerFailureListener

public boolean addWorkerFailureListener(IWorkerFailureListener workerFailureListener1)

only one IWorkerFailureListener can be added if the second IWorkerFailureListener tried to be added, returns false

getWorkerStatusForID

public JobMasterAPI.WorkerState getWorkerStatusForID(int id)

Description copied from interface: IWorkerStatusUpdater

return the status of any worker in the job

Specified by:

getWorkerStatusForID in interface IWorkerStatusUpdater

Returns:

onMessage

public void onMessage(RequestID id,
                      int workerId,
                      Message message)

Description copied from interface: MessageHandler

Handles a specific message type

Specified by:

onMessage in interface MessageHandler

Parameters:

id - request id

workerId - worker id

message - protbuf message