summaryrefslogtreecommitdiff
path: root/internal/quorum
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2023-06-13 00:59:15 +0300
committerPaul Buetow <paul@buetow.org>2023-06-13 00:59:15 +0300
commit93b32777632eb79393e4f6fe0b752665c8e511ff (patch)
treedb6e7b7f0fc003d3fd816eaf769bb66eb9f46dd3 /internal/quorum
parenta04fa17d3719e5435c35a599cf566630a08108a8 (diff)
lower vote expiry, send every expiry interval to partners my move anyway
Diffstat (limited to 'internal/quorum')
-rw-r--r--internal/quorum/quorum.go14
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():