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 typoes

This commit is contained in:
Marto 2024-02-13 19:08:35 +02:00
parent 68afc77666
commit c99a576b72
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/raft/consensus_state_machine.nim
View File

@ -185,7 +185,6 @@ func replicateTo*(sm: var RaftStateMachine, follower: RaftFollowerProgressTracke
entries: @[sm.log.getEntryByIndex(follower.nextIndex)]) entries: @[sm.log.getEntryByIndex(follower.nextIndex)])
follower.nextIndex += 1 follower.nextIndex += 1
sm.sendTo(follower.id, request) sm.sendTo(follower.id, request)
sm.debug "exit" & $follower[]
func replicate*(sm: var RaftStateMachine) = func replicate*(sm: var RaftStateMachine) =
if sm.state.isLeader: if sm.state.isLeader:
@ -222,8 +221,10 @@ func becomeLeader*(sm: var RaftStateMachine) =
return return
sm.output.stateChange = true sm.output.stateChange = true
# Because we will add new entry on the next line
sm.state = initLeader(sm.config, sm.log.lastIndex + 1, sm.timeNow)
sm.addEntry(Empty()) sm.addEntry(Empty())
sm.state = initLeader(sm.config, sm.log.lastIndex, sm.timeNow)
sm.pingLeader = false sm.pingLeader = false
#TODO: Update last election time #TODO: Update last election time
return return
@ -240,7 +241,7 @@ func becomeCandidate*(sm: var RaftStateMachine) =
sm.term += 1 sm.term += 1
for nodeId in sm.candidate.votes.voters: for nodeId in sm.candidate.votes.voters:
if nodeId == sm.myId: if nodeId == sm.myId:
sm.debug "reguster vote for it self " sm.debug "register vote for it self "
discard sm.candidate.votes.registerVote(nodeId, true) discard sm.candidate.votes.registerVote(nodeId, true)
sm.votedFor = nodeId sm.votedFor = nodeId
continue continue
@ -253,8 +254,9 @@ func becomeCandidate*(sm: var RaftStateMachine) =
return return
func hearthbeat(sm: var RaftStateMachine, follower: var RaftFollowerProgressTracker) = func heartbeat(sm: var RaftStateMachine, follower: var RaftFollowerProgressTracker) =
sm.debug "hearthbear" & $follower.nextIndex sm.debug "heartbeat" & $follower.nextIndex
# TODO: we should just send empty array instead adding new empty entries on each heartbeat
sm.addEntry(Empty()) sm.addEntry(Empty())
func tickLeader*(sm: var RaftStateMachine, now: times.DateTime) = func tickLeader*(sm: var RaftStateMachine, now: times.DateTime) =
@ -278,7 +280,7 @@ func tickLeader*(sm: var RaftStateMachine, now: times.DateTime) =
#sm.debug $(now - follower.lastMessageAt) #sm.debug $(now - follower.lastMessageAt)
if now - follower.lastMessageAt > sm.heartbeatTime: if now - follower.lastMessageAt > sm.heartbeatTime:
sm.debug "heartbeat" sm.debug "heartbeat"
sm.hearthbeat(follower) sm.heartbeat(follower)
# TODO: implement step down logic # TODO: implement step down logic
func tick*(sm: var RaftStateMachine, now: times.DateTime) = func tick*(sm: var RaftStateMachine, now: times.DateTime) =