io.openmessaging.storage.dledger.statemachine

Class StateMachineCaller

java.lang.Object

org.apache.rocketmq.remoting.common.ServiceThread

io.openmessaging.storage.dledger.statemachine.StateMachineCaller

All Implemented Interfaces:

Runnable

public class StateMachineCaller
extends org.apache.rocketmq.remoting.common.ServiceThread

Finite state machine caller Through a task queue, all tasks that modify the state of the state machine are guaranteed to be executed sequentially.

Field Summary

Fields inherited from class org.apache.rocketmq.remoting.common.ServiceThread

hasNotified, stopped, thread

Constructor Summary

Constructors

Constructor and Description
StateMachineCaller(DLedgerStore dLedgerStore, StateMachine statemachine, DLedgerEntryPusher entryPusher)

Method Summary

Modifier and Type	Method and Description
DLedgerStore	getdLedgerStore()
Long	getLastAppliedIndex()
long	getLastAppliedTerm()
String	getServiceName()
SnapshotManager	getSnapshotManager()
StateMachine	getStateMachine()
boolean	onCommitted(long committedIndex)
boolean	onSnapshotLoad(LoadSnapshotHook loadSnapshotAfter)
boolean	onSnapshotSave(SaveSnapshotHook saveSnapshotAfter)
void	registerSnapshotManager(SnapshotManager snapshotManager)
void	run()
void	setError(DLedgerServer server, DLedgerException error)
void	shutdown()

Methods inherited from class org.apache.rocketmq.remoting.common.ServiceThread

getJointime, isStopped, shutdown, start

Methods inherited from class java.lang.Object

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

Constructor Detail

StateMachineCaller

public StateMachineCaller(DLedgerStore dLedgerStore,
                          StateMachine statemachine,
                          DLedgerEntryPusher entryPusher)

Method Detail

getStateMachine

public StateMachine getStateMachine()

onCommitted

public boolean onCommitted(long committedIndex)

onSnapshotLoad

public boolean onSnapshotLoad(LoadSnapshotHook loadSnapshotAfter)

onSnapshotSave

public boolean onSnapshotSave(SaveSnapshotHook saveSnapshotAfter)

shutdown

public void shutdown()

Overrides:

shutdown in class org.apache.rocketmq.remoting.common.ServiceThread

run

public void run()

setError

public void setError(DLedgerServer server,
                     DLedgerException error)

getServiceName

public String getServiceName()

Specified by:

getServiceName in class org.apache.rocketmq.remoting.common.ServiceThread

getLastAppliedIndex

public Long getLastAppliedIndex()

getLastAppliedTerm

public long getLastAppliedTerm()

registerSnapshotManager

public void registerSnapshotManager(SnapshotManager snapshotManager)

getSnapshotManager

public SnapshotManager getSnapshotManager()

getdLedgerStore

public DLedgerStore getdLedgerStore()