bftsmart.statemanagement.strategy

Class BaseStateManager

java.lang.Object

bftsmart.statemanagement.strategy.BaseStateManager

All Implemented Interfaces:

StateManager

Direct Known Subclasses:

DurableStateManager, StandardStateManager

public abstract class BaseStateManager
extends java.lang.Object
implements StateManager

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	appStateOnly
protected DeliveryThread	dt
protected boolean	isInitializing
protected int	lastEid
protected java.util.HashMap<java.lang.Integer,java.lang.Integer>	senderLeaders
protected java.util.HashMap<java.lang.Integer,java.lang.Integer>	senderRegencies
protected java.util.HashMap<java.lang.Integer,ApplicationState>	senderStates
protected java.util.HashMap<java.lang.Integer,View>	senderViews
protected ApplicationState	state
protected ServerViewController	SVController
protected TOMLayer	tomLayer
protected int	waitingEid

Constructor Summary

Constructors

Constructor and Description
BaseStateManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	analyzeState(int eid)
void	askCurrentConsensusId()
void	currentConsensusIdAsked(int sender)
void	currentConsensusIdReceived(SMMessage smsg)
int	getLastEID()
protected int	getReplies()
abstract void	init(TOMLayer tomLayer, DeliveryThread dt)
boolean	isRetrievingState()
protected boolean	moreThan2F_Leaders(int leader)
protected boolean	moreThan2F_Regencies(int regency)
protected boolean	moreThan2F_Views(View view)
protected boolean	moreThanF_Replies()
java.util.Collection<ApplicationState>	receivedStates()
void	requestAppState(int eid)
protected abstract void	requestState()
protected void	reset() Clear the collections and state hold by this object.
void	setLastEID(int eid)
abstract void	SMReplyDeliver(SMMessage msg, boolean isBFT)
abstract void	SMRequestDeliver(SMMessage msg, boolean isBFT)
abstract void	stateTimeout()

Methods inherited from class java.lang.Object

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

Field Detail

tomLayer

protected TOMLayer tomLayer

SVController

protected ServerViewController SVController

dt

protected DeliveryThread dt

senderStates

protected java.util.HashMap<java.lang.Integer,ApplicationState> senderStates

senderViews

protected java.util.HashMap<java.lang.Integer,View> senderViews

senderRegencies

protected java.util.HashMap<java.lang.Integer,java.lang.Integer> senderRegencies

senderLeaders

protected java.util.HashMap<java.lang.Integer,java.lang.Integer> senderLeaders

appStateOnly

protected boolean appStateOnly

waitingEid

protected int waitingEid

lastEid

protected int lastEid

state

protected ApplicationState state

isInitializing

protected boolean isInitializing

Constructor Detail

BaseStateManager

public BaseStateManager()

Method Detail

getReplies

protected int getReplies()

moreThanF_Replies

protected boolean moreThanF_Replies()

moreThan2F_Regencies

protected boolean moreThan2F_Regencies(int regency)

moreThan2F_Leaders

protected boolean moreThan2F_Leaders(int leader)

moreThan2F_Views

protected boolean moreThan2F_Views(View view)

reset

protected void reset()

Clear the collections and state hold by this object. Calls clear() in the States, Leaders, Regenviews and Views collections. Sets the state to null;

receivedStates

public java.util.Collection<ApplicationState> receivedStates()

setLastEID

public void setLastEID(int eid)

Specified by:

setLastEID in interface StateManager

getLastEID

public int getLastEID()

Specified by:

getLastEID in interface StateManager

requestAppState

public void requestAppState(int eid)

Specified by:

requestAppState in interface StateManager

analyzeState

public void analyzeState(int eid)

Specified by:

analyzeState in interface StateManager

init

public abstract void init(TOMLayer tomLayer,
        DeliveryThread dt)

Specified by:

init in interface StateManager

isRetrievingState

public boolean isRetrievingState()

Specified by:

isRetrievingState in interface StateManager

askCurrentConsensusId

public void askCurrentConsensusId()

Specified by:

askCurrentConsensusId in interface StateManager

currentConsensusIdAsked

public void currentConsensusIdAsked(int sender)

Specified by:

currentConsensusIdAsked in interface StateManager

currentConsensusIdReceived

public void currentConsensusIdReceived(SMMessage smsg)

Specified by:

currentConsensusIdReceived in interface StateManager

requestState

protected abstract void requestState()

stateTimeout

public abstract void stateTimeout()

Specified by:

stateTimeout in interface StateManager

SMRequestDeliver

public abstract void SMRequestDeliver(SMMessage msg,
                    boolean isBFT)

Specified by:

SMRequestDeliver in interface StateManager

SMReplyDeliver

public abstract void SMReplyDeliver(SMMessage msg,
                  boolean isBFT)

Specified by:

SMReplyDeliver in interface StateManager