From c79f6110ed66374466f12a4a047493b8c02abed1 Mon Sep 17 00:00:00 2001 From: Ian Gulliver Date: Sat, 17 Jun 2023 15:09:33 -0700 Subject: [PATCH] Log voter/candidate start/stop --- candidate.go | 10 ++++++++++ voter.go | 10 ++++++++++ 2 files changed, 20 insertions(+) diff --git a/candidate.go b/candidate.go index cda1526..60d3536 100644 --- a/candidate.go +++ b/candidate.go @@ -289,6 +289,16 @@ func (c *Candidate) loop(ctx context.Context, ec *event.Client) { defer t.Stop() defer close(c.done) + defer func() { + c.log(ctx, ec, + "event", "stop", + ) + }() + + c.log(ctx, ec, + "event", "start", + ) + for { select { case <-c.stop: diff --git a/voter.go b/voter.go index 542d772..51cc4fb 100644 --- a/voter.go +++ b/voter.go @@ -72,6 +72,16 @@ func (v *Voter) Stop() { func (v *Voter) loop(ctx context.Context, ec *event.Client) { defer close(v.done) + defer func() { + v.log(ctx, ec, + "event", "stop", + ) + }() + + v.log(ctx, ec, + "event", "start", + ) + for { if !v.poll(ctx, ec) { break