add expiry log

1 files changed, 5 insertions, 2 deletions

diff --git a/internal/quorum/quorum.go b/internal/quorum/quorum.go
index 25852b2..d33db56 100644
--- a/internal/quorum/quorum.go
+++ b/internal/quorum/quorum.go
@@ -42,6 +42,7 @@ func (quo Quorum) Start(ctx context.Context) <-chan vote.Vote {
 
 	interval := time.Second * time.Duration(quo.conf.LoopIntervalS)
 	if vote.Expiry <= interval {
+		// TODO: When to use log.Fatal and when to use panic?
 		log.Fatal("quorum: LoopIntervalS ", quo.conf.LoopIntervalS,
 			" should be less than the vote expiry of ", vote.Expiry)
 	}
@@ -64,7 +65,7 @@ func (quo Quorum) Start(ctx context.Context) <-chan vote.Vote {
 			case <-ctx.Done():
 				return
 			}
-			if err := quo.persistScores(); err != nil {
+			if err := quo.persist(); err != nil {
 				log.Println("quorum:", err)
 			}
 		}
@@ -108,7 +109,7 @@ func (quo Quorum) scores() (scores []Score) {
 	return
 }
 
-func (quo *Quorum) persistScores() error {
+func (quo *Quorum) persist() error {
 	scores := quo.scores()
 	log.Println("quorum scores:", scores)
 
@@ -121,6 +122,7 @@ func (quo *Quorum) persistScores() error {
 	stateFile := fmt.Sprintf("%s/scores", quo.conf.StateDir)
 	stateTmpFile := fmt.Sprintf("%s.tmp", stateFile)
 
+	// TODO: Also create a "is_leader" marker file in the fs!
 	fd, err := os.Create(stateTmpFile)
 	if err != nil {
 		return err
@@ -179,6 +181,7 @@ func (quo Quorum) pruneVotes() (vote.Vote, error) {
 
 	for fromNode, vote := range quo.votes {
 		if vote.Expired() {
+			log.Println("quorum: vote", vote, "from node", fromNode, "expired!")
 			expired = append(expired, fromNode)
 			continue
 		}