diff options
| author | Paul Buetow <paul@buetow.org> | 2023-06-13 00:59:15 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2023-06-13 00:59:15 +0300 |
| commit | 93b32777632eb79393e4f6fe0b752665c8e511ff (patch) | |
| tree | db6e7b7f0fc003d3fd816eaf769bb66eb9f46dd3 /internal/quorum | |
| parent | a04fa17d3719e5435c35a599cf566630a08108a8 (diff) | |
lower vote expiry, send every expiry interval to partners my move anyway
Diffstat (limited to 'internal/quorum')
| -rw-r--r-- | internal/quorum/quorum.go | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/internal/quorum/quorum.go b/internal/quorum/quorum.go index e3f0eeb..52cf6ee 100644 --- a/internal/quorum/quorum.go +++ b/internal/quorum/quorum.go @@ -42,14 +42,12 @@ func (quo Quorum) Start(ctx context.Context) <-chan vote.Vote { for { select { case <-time.After(vote.Expiry): - if newVote, changed := quo.makeMyVote(); changed { - quo.score() - ch <- newVote - } - case vote := <-quo.voteCh: - quo.vote(vote) - if newVote, changed := quo.makeMyVote(); changed { - ch <- newVote + myVote, _ := quo.makeMyVote() + ch <- myVote + case v := <-quo.voteCh: + quo.vote(v) + if myVote, changed := quo.makeMyVote(); changed { + ch <- myVote } quo.score() case <-ctx.Done(): |
