edu.iu.dsc.tws.master.server

Class WorkerHandler

java.lang.Object

edu.iu.dsc.tws.master.server.WorkerHandler

All Implemented Interfaces:

MessageHandler

public class WorkerHandler
extends java.lang.Object
implements MessageHandler

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
WorkerHandler(WorkerMonitor workerMonitor, RRServer rrServer, boolean zkUsed)

Method Summary

Modifier and Type	Method and Description
boolean	isAllConnected()
void	onMessage(RequestID id, int workerId, Message message) Handles a specific message type
void	sendWorkersJoinedMessage() send WorkersJoined message to all workers and the driver
void	unsetAllConnected() this is called after worker scale-up sets allConnected to false
void	workersScaledDown(int instancesRemoved) workerMonitor calls this method when job is scaled down and zk is not used
void	workersScaledUp(int instancesAdded) workerMonitor calls this method when the job is scaled up

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerHandler

public WorkerHandler(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

workersScaledDown

public void workersScaledDown(int instancesRemoved)

workerMonitor calls this method when job is scaled down and zk is not used

Parameters:

instancesRemoved -

workersScaledUp

public void workersScaledUp(int instancesAdded)

workerMonitor calls this method when the job is scaled up

Parameters:

instancesAdded -

sendWorkersJoinedMessage

public void sendWorkersJoinedMessage()

send WorkersJoined message to all workers and the driver

unsetAllConnected

public void unsetAllConnected()

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