patchy/elect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Include IDs with events, ignore blank votes

Browse Source
This commit is contained in:
Ian Gulliver
2023-06-18 08:18:33 -07:00
parent e45d1931cf
commit 8318e90401
2 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
candidate.go
View File

@@ -250,9 +250,18 @@ func (c *Candidate) elect(ctx context.Context, ec *event.Client, v *vote) {
continue continue
} }
if vote.LastSeenCandidateID != c.resp.CandidateID { if vote.LastSeenCandidateID != "" && vote.LastSeenCandidateID != c.resp.CandidateID {
// Hard no; voted for someone else // Hard no; voted for someone else
no++ no++
if c.state == StateLeader {
c.log(ctx, ec,
"event", "noVoteWhileLeader",
"voterID", vote.VoterID,
"otherCandidateID", vote.LastSeenCandidateID,
"numPollsSincechange", vote.NumPollsSinceChange,
)
}
} }
if vote.NumPollsSinceChange < 10 { if vote.NumPollsSinceChange < 10 {
@@ -316,6 +325,7 @@ func (c *Candidate) log(ctx context.Context, ec *event.Client, vals ...any) {
ec.Log(ctx, append([]any{ ec.Log(ctx, append([]any{
"library", "elect", "library", "elect",
"subsystem", "candidate", "subsystem", "candidate",
"candidateID", c.resp.CandidateID,
}, vals...)...) }, vals...)...)
} }

1
voter.go
View File

@@ -198,5 +198,6 @@ func (v *Voter) log(ctx context.Context, ec *event.Client, vals ...any) {
ec.Log(ctx, append([]any{ ec.Log(ctx, append([]any{
"library", "elect", "library", "elect",
"subsystem", "voter", "subsystem", "voter",
"voterID", v.vote.VoterID,
}, vals...)...) }, vals...)...)
} }