edu.iu.dsc.tws.master.server

Class BarrierHandler

java.lang.Object

edu.iu.dsc.tws.master.server.BarrierHandler

All Implemented Interfaces:

MessageHandler

public class BarrierHandler
extends java.lang.Object
implements MessageHandler

all workers in a job may wait on a barrier point BarrierHandler will get barrier requests from all workers It will send response message to all workers, when it gets the request from the last worker in a job

Constructor Summary

Constructors

Constructor and Description
BarrierHandler(WorkerMonitor workerMonitor, RRServer rrServer)

Method Summary

Modifier and Type	Method and Description
void	onMessage(RequestID requestID, int workerId, Message message) Handles a specific message type

Methods inherited from class java.lang.Object

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

Constructor Detail

BarrierHandler

public BarrierHandler(WorkerMonitor workerMonitor,
                      RRServer rrServer)

Method Detail

onMessage

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

Description copied from interface: MessageHandler

Handles a specific message type

Specified by:

onMessage in interface MessageHandler

Parameters:

requestID - request id

workerId - worker id

message - protbuf message