edu.iu.dsc.tws.master.barrier

Class JMBarrierHandler

java.lang.Object

edu.iu.dsc.tws.master.barrier.JMBarrierHandler

All Implemented Interfaces:

MessageHandler, BarrierResponder

public class JMBarrierHandler
extends java.lang.Object
implements MessageHandler, BarrierResponder

Constructor Summary

Constructors

Constructor and Description
JMBarrierHandler(RRServer rrServer, BarrierMonitor barrierMonitor)

Method Summary

Modifier and Type	Method and Description
void	allArrived(JobMasterAPI.BarrierType barrierType) this method is invoked when all workers arrived at the barrier all workers shall be released from the barrier
void	barrierFailed(JobMasterAPI.BarrierType barrierType, JobMasterAPI.BarrierResult result) this method is called when the barrier failed all waiting workers shall be released with a failure message
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

JMBarrierHandler

public JMBarrierHandler(RRServer rrServer,
                        BarrierMonitor barrierMonitor)

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

allArrived

public void allArrived(JobMasterAPI.BarrierType barrierType)

Description copied from interface: BarrierResponder

this method is invoked when all workers arrived at the barrier all workers shall be released from the barrier

Specified by:

allArrived in interface BarrierResponder

barrierFailed

public void barrierFailed(JobMasterAPI.BarrierType barrierType,
                          JobMasterAPI.BarrierResult result)

Description copied from interface: BarrierResponder

this method is called when the barrier failed all waiting workers shall be released with a failure message

Specified by:

barrierFailed in interface BarrierResponder