status-im/nim-raft
2
0
Fork 0
mirror of https://github.com/status-im/nim-raft.git synced 2025-02-26 03:45:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added addFSMTransition proc etc.

Browse Source
This commit is contained in:
Raycho Mukelov 2023-11-05 06:42:19 +02:00
parent ddb58f7063
commit 30ba492caf
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
raft/consensus_state_machine.nim
View File

@ -59,19 +59,22 @@ type
proc new*[RaftNodeState, EventType, NodeType, RaftNodeStates]( proc new*[RaftNodeState, EventType, NodeType, RaftNodeStates](
T: type ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase], startSymbol: RaftNodeState): T = T: type ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase], startSymbol: RaftNodeState): T =
result = new(ConsensusFSM[NodeType, EventType, RaftNodeStates]) result = (ConsensusFSM[NodeType, EventType, RaftNodeStates])
result = ConsensusFSM[NodeType, EventType, RaftNodeStates].new
initRLock(result.mtx) initRLock(result.mtx)
result.state = startSymbol result.state = startSymbol
debug "new: ", fsm=repr(result) debug "new: ", fsm=repr(result)
proc addNewFsmTransition*[RaftNodeState, EventType, NodeType, RaftMessageBase]( proc addFSMTransition*[RaftNodeState, EventType, NodeType, RaftMessageBase](
fsm: ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase], fsm: ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase],
fromState: RaftNodeState, fromState: RaftNodeState,
toState: RaftNodeState) = termSymb: TerminalSymbol[EventType, NodeType, RaftMessageBase],
toState: RaftNodeState,
action: Option[ConsensusFSMTransActionType]) =
fsm.stateTransitionsLUT[fromState.state] = (toState, none) fsm.stateTransitionsLUT[(fromState.state, termSymb)] = (toState, action)
proc computeFSMLogicFunctionsPermutationValue[RaftNodeState, NodeType, EventType, RaftMessageBase]( proc computeFSMLogicFunctionsPermutationValu*[RaftNodeState, NodeType, EventType, RaftMessageBase](
fsm: ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase], fsm: ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase],
nts: RaftNodeState, nts: RaftNodeState,
termSymb: TerminalSymbol, termSymb: TerminalSymbol,
@ -96,7 +99,7 @@ proc computeFSMLogicFunctionsPermutationValue[RaftNodeState, NodeType, EventType
termSymb[1] = logicFunctionsConds termSymb[1] = logicFunctionsConds
result = termSymb result = termSymb
proc consensusFSMAdvance[RaftNodeState, EventType, NodeType, RaftMessageBase]( proc consensusFSMAdvance*[RaftNodeState, EventType, NodeType, RaftMessageBase](
fsm: ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase], fsm: ConsensusFSM[RaftNodeState, EventType, NodeType, RaftMessageBase],
node: NodeType, node: NodeType,
event: EventType, event: EventType,

4
tests/test_consensus_state_machine.nim
View File

@ -12,4 +12,6 @@ import ../raft/consensus_state_machine
suite "Create and test Consensus State Machine": suite "Create and test Consensus State Machine":
test test "Create Consensus State Machine":
let csm = ConsensusStateMachine.new()
check csm != nil