status-im
/
nim-raft
mirror of https://github.com/status-im/nim-raft.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix

This commit is contained in:
Raycho Mukelov 2023-10-30 01:49:29 +02:00
parent 1e91d3f65a
commit c71b2210ed
2 changed files with 40 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
raft/consensus_state_machine.nim
View File

@ -30,7 +30,7 @@ type
# Define logical functions (conditions) computed from our NodeType etc. (Truth Table)
LogicalFunctionConditionValueType* = bool
LogicalFunctionCondition*[EventType, NodeTytpe, RaftMessageBase] = proc(e: EventType, n: NodeTytpe, msg: Option[RaftMessageBase]): bool
LogicalFunctionConditionsLUT*[EventType, NodeType, RaftMessageBase] = Table[(EventType, NodeType), LogicalFunctionCondition[EventType, NodeType, Option[RaftMessageBase]]]
LogicalFunctionConditionsLUT*[EventType, NodeType, RaftMessageBase] = Table[(EventType, NodeType), seq[LogicalFunctionCondition[EventType, NodeType, Option[RaftMessageBase]]]]
# Define Terminals as a tuple of a Event and a sequence of logical functions (conditions) and their respective values computed from NodeType, NodeTytpe and RaftMessageBase
# (kind of Truth Table)
@ -66,7 +66,7 @@ proc computeFSMLogicFunctionsPermutationValue[NonTerminalSymbol, NodeType, Event
var
logicFunctionsConds = fsm.logicalFunctionsLut[(e, NodeType)]
for f in nts[2]:
for f in logicFunctionsConds:
f = f(nts[1], e, msg)
rawInput[1] = logicFunctionsConds

38
raft/fsm.cpp Normal file
View File

@ -0,0 +1,38 @@
// no need to retry for timeout, network sends packets all the time and finally ends with an error time out, and next restart it.
fsm.addStateAction( bsrnchlConnecting, ConnectingSocketChannel::startConnecting, false );
fsm.add( bsrnchlConnecting, levsig_stop, bsrnchlStopped, ConnectingSocketChannel::closeSocket ); // close it
fsm.add( bsrnchlConnecting, levsig_start, bsrnchlConnecting, fsm.Empty );
fsm.add( bsrnchlConnecting, levsig_connected, bsrnchlConnected, fsm.Empty );
fsm.add( bsrnchlConnecting, levsig_accepted, bsrnchlConnected, fsm.Empty );
fsm.add( bsrnchlConnecting, levsig_failed, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlConnecting, levsig_disconnected, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlConnecting, levsig_timeout, bsrnchlConnecting, ConnectingSocketChannel::startRestartConnecting );
fsm.addStateAction( bsrnchlFailed, ConnectingSocketChannel::closeSocket, false );
fsm.add( bsrnchlFailed, levsig_stop, bsrnchlStopped, fsm.Empty ); // close it
fsm.add( bsrnchlFailed, levsig_start, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlFailed, levsig_connected, bsrnchlConnected, fsm.Empty ); // this is not expected
fsm.add( bsrnchlFailed, levsig_accepted, bsrnchlConnected, fsm.Empty ); // this is not expected
fsm.add( bsrnchlFailed, levsig_failed, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlFailed, levsig_disconnected, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlFailed, levsig_timeout, bsrnchlConnecting, fsm.Empty );
fsm.addStateAction( bsrnchlConnected, ConnectingSocketChannel::startProtocolCommunication, true );
fsm.add( bsrnchlConnected, levsig_stop, bsrnchlStoppingRequest, fsm.Empty ); // close it
fsm.add( bsrnchlConnected, levsig_start, bsrnchlConnected, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_connected, bsrnchlConnected, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_accepted, bsrnchlConnected, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_failed, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_disconnected, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_timeout, bsrnchlConnected, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_handshakeDone, bsrnchlEstablishedSuccess, fsm.Empty );
fsm.add( bsrnchlConnected, levsig_handshakeFailed, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_stop, bsrnchlStoppingRequest, fsm.Empty ); // close it
fsm.add( bsrnchlEstablishedSuccess, levsig_start, bsrnchlEstablishedSuccess, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_connected, bsrnchlEstablishedSuccess, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_accepted, bsrnchlEstablishedSuccess, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_failed, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_disconnected, bsrnchlFailed, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_timeout, bsrnchlEstablishedSuccess, fsm.Empty );
fsm.add( bsrnchlEstablishedSuccess, levsig_handshakeDone, bsrnchlEstablishedSuccess, fsm.Empty );