edu.iu.dsc.tws.master.server

Class JMWorkerHandler

java.lang.Object

edu.iu.dsc.tws.master.server.JMWorkerHandler

All Implemented Interfaces:

MessageHandler, IWorkerEventSender

public class JMWorkerHandler
extends java.lang.Object
implements MessageHandler, IWorkerEventSender

Handles JobMaster to worker messaging It handles following message types: JobMasterAPI.RegisterWorker JobMasterAPI.WorkerStateChange JobMasterAPI.ListWorkersRequest

It gets request messages from workers and talks to WorkerMonitor It sends response messages back to workers

Constructor Summary

Constructors

Constructor and Description
JMWorkerHandler(WorkerMonitor workerMonitor, RRServer rrServer, boolean zkUsed)

Method Summary

Modifier and Type	Method and Description
void	allJoined() all workers joined the job
boolean	isAllConnected()
void	jobScaled(int change, int numberOfWorkers) job scaled up or down
void	onMessage(RequestID id, int workerId, Message message) Handles a specific message type
void	unsetAllConnected() this is called after worker scale-up sets allConnected to false
void	workerFailed(int workerID) the worker with the provided workerID failed
void	workerRestarted(JobMasterAPI.WorkerInfo workerInfo) the worker with the provided workerInfo restarted

Methods inherited from class java.lang.Object

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

Constructor Detail

JMWorkerHandler

public JMWorkerHandler(WorkerMonitor workerMonitor,
                       RRServer rrServer,
                       boolean zkUsed)

Method Detail

isAllConnected

public boolean isAllConnected()

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

unsetAllConnected

public void unsetAllConnected()

this is called after worker scale-up sets allConnected to false

workerFailed

public void workerFailed(int workerID)

Description copied from interface: IWorkerEventSender

the worker with the provided workerID failed

Specified by:

workerFailed in interface IWorkerEventSender

workerRestarted

public void workerRestarted(JobMasterAPI.WorkerInfo workerInfo)

Description copied from interface: IWorkerEventSender

the worker with the provided workerInfo restarted

Specified by:

workerRestarted in interface IWorkerEventSender

allJoined

public void allJoined()

Description copied from interface: IWorkerEventSender

all workers joined the job

Specified by:

allJoined in interface IWorkerEventSender

jobScaled

public void jobScaled(int change,
                      int numberOfWorkers)

Description copied from interface: IWorkerEventSender

job scaled up or down

Specified by:

jobScaled in interface IWorkerEventSender