vitalif
/
tinyraft
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: vitalif:713e10d22341fa25a4e031d4aa04ca28b1af33ba
Branches Tags
vitalif:master
vitalif:old-master
vitalif:de64
vitalif:prevote
...
compare: vitalif:a0b20be22c9b22e57de82d09e0a301da7d340e9e
Branches Tags
vitalif:master
vitalif:old-master
vitalif:de64
vitalif:prevote

No commits in common. "713e10d22341fa25a4e031d4aa04ca28b1af33ba" and "a0b20be22c9b22e57de82d09e0a301da7d340e9e" have entirely different histories.
713e10d223 ... a0b20be22c

1 changed files with 5 additions and 2 deletions
Show Stats Expand all files Collapse all files

3
tinyraft.js
View File

@ -209,10 +209,13 @@ class TinyRaft extends EventEmitter
this._nextTerm(this.leadershipTimeout > 0 ? this.leadershipTimeout : -1); this._nextTerm(this.leadershipTimeout > 0 ? this.leadershipTimeout : -1);
this.followers = this.votes[this.nodeId]; this.followers = this.votes[this.nodeId];
for (const follower of this.followers) for (const follower of this.followers)
{
if (follower != this.nodeId)
{ {
// Send a heartbeat to confirm leadership // Send a heartbeat to confirm leadership
this.send(follower, { type: PING, term: this.term }); this.send(follower, { type: PING, term: this.term });
} }
}
this.emit('change', { state: this.state, term: this.term, leader: this.nodeId, followers: this.votes[this.nodeId] }); this.emit('change', { state: this.state, term: this.term, leader: this.nodeId, followers: this.votes[this.nodeId] });
} }
else else