edu.iu.dsc.tws.checkpointing.master

Class CheckpointManager

java.lang.Object

edu.iu.dsc.tws.checkpointing.master.CheckpointManager

All Implemented Interfaces:

JobFaultListener, MessageHandler

public class CheckpointManager
extends java.lang.Object
implements MessageHandler, JobFaultListener

Constructor Summary

Constructors

Constructor and Description
CheckpointManager(RRServer rrServer, StateStore stateStore, java.lang.String jobId)

Method Summary

Modifier and Type	Method and Description
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	init()
void	onMessage(RequestID id, 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

CheckpointManager

public CheckpointManager(RRServer rrServer,
                         StateStore stateStore,
                         java.lang.String jobId)

Method Detail

init

public void init()

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

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