edu.iu.dsc.tws.master.barrier

Class BarrierMonitor

java.lang.Object

edu.iu.dsc.tws.master.barrier.BarrierMonitor

All Implemented Interfaces:

JobFaultListener

public class BarrierMonitor
extends java.lang.Object
implements JobFaultListener

implements barrier logic

Constructor Summary

Constructors

Constructor and Description
BarrierMonitor(WorkerMonitor workerMonitor, InitBarrierListener barrierListener)

Method Summary

Modifier and Type	Method and Description
void	arrivedAtDefault(int workerID, long timeout) a worker arrived at the default barrier
void	arrivedAtInit(int workerID, long timeout) a worker arrived at the init barrier
void	checkBarrierFailure() this method is called periodically by Job Master to check for the barrier failure barriers fail for two reasons: the barrier times out: barrier failure message should be broadcasted to all waiting workers job becomes faulty: default barrier fails in this case only
void	faultOccurred() this is called when a worker failed in the job it is also called when a worker is restarted before its failure message received
void	faultRestored() this is called when all workers restored and they all come to a barrier after the barrier
void	initDefaultAfterRestart(java.util.Set<java.lang.Integer> initialWorkers, long timeout, int expectedWorkers)
void	initInitAfterRestart(java.util.Set<java.lang.Integer> initialWorkers, long timeout, int expectedWorkers) this method is invoked when JM restarts it gets previous status from ZK
boolean	isFirstInitProceeded()
void	removedFromDefault(int workerID) a worker is removed from the default barrier we expect it to come back later on remove it from the list
void	removedFromInit(int workerID) a worker is removed from the init barrier we expect it to come back later on remove it from the list
void	setBarrierResponder(BarrierResponder barrierResponder)

Methods inherited from class java.lang.Object

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

Constructor Detail

BarrierMonitor

public BarrierMonitor(WorkerMonitor workerMonitor,
                      InitBarrierListener barrierListener)

Method Detail

setBarrierResponder

public void setBarrierResponder(BarrierResponder barrierResponder)

initDefaultAfterRestart

public void initDefaultAfterRestart(java.util.Set<java.lang.Integer> initialWorkers,
                                    long timeout,
                                    int expectedWorkers)

initInitAfterRestart

public void initInitAfterRestart(java.util.Set<java.lang.Integer> initialWorkers,
                                 long timeout,
                                 int expectedWorkers)

this method is invoked when JM restarts it gets previous status from ZK

Parameters:

initialWorkers -

timeout -

expectedWorkers -

isFirstInitProceeded

public boolean isFirstInitProceeded()

faultOccurred

public void faultOccurred()

Description copied from interface: JobFaultListener

this is called when a worker failed in the job it is also called when a worker is restarted before its failure message received

Specified by:

faultOccurred in interface JobFaultListener

faultRestored

public void faultRestored()

Description copied from interface: JobFaultListener

this is called when all workers restored and they all come to a barrier after the barrier

Specified by:

faultRestored in interface JobFaultListener

arrivedAtDefault

public void arrivedAtDefault(int workerID,
                             long timeout)

a worker arrived at the default barrier

Parameters:

workerID -

timeout -

arrivedAtInit

public void arrivedAtInit(int workerID,
                          long timeout)

a worker arrived at the init barrier

Parameters:

workerID -

timeout -

checkBarrierFailure

public void checkBarrierFailure()

this method is called periodically by Job Master to check for the barrier failure barriers fail for two reasons: the barrier times out: barrier failure message should be broadcasted to all waiting workers job becomes faulty: default barrier fails in this case only

removedFromDefault

public void removedFromDefault(int workerID)

a worker is removed from the default barrier we expect it to come back later on remove it from the list

removedFromInit

public void removedFromInit(int workerID)

a worker is removed from the init barrier we expect it to come back later on remove it from the list