Log voter/candidate start/stop
This commit is contained in:
10
candidate.go
10
candidate.go
@@ -289,6 +289,16 @@ func (c *Candidate) loop(ctx context.Context, ec *event.Client) {
|
|||||||
defer t.Stop()
|
defer t.Stop()
|
||||||
defer close(c.done)
|
defer close(c.done)
|
||||||
|
|
||||||
|
defer func() {
|
||||||
|
c.log(ctx, ec,
|
||||||
|
"event", "stop",
|
||||||
|
)
|
||||||
|
}()
|
||||||
|
|
||||||
|
c.log(ctx, ec,
|
||||||
|
"event", "start",
|
||||||
|
)
|
||||||
|
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case <-c.stop:
|
case <-c.stop:
|
||||||
|
|||||||
10
voter.go
10
voter.go
@@ -72,6 +72,16 @@ func (v *Voter) Stop() {
|
|||||||
func (v *Voter) loop(ctx context.Context, ec *event.Client) {
|
func (v *Voter) loop(ctx context.Context, ec *event.Client) {
|
||||||
defer close(v.done)
|
defer close(v.done)
|
||||||
|
|
||||||
|
defer func() {
|
||||||
|
v.log(ctx, ec,
|
||||||
|
"event", "stop",
|
||||||
|
)
|
||||||
|
}()
|
||||||
|
|
||||||
|
v.log(ctx, ec,
|
||||||
|
"event", "start",
|
||||||
|
)
|
||||||
|
|
||||||
for {
|
for {
|
||||||
if !v.poll(ctx, ec) {
|
if !v.poll(ctx, ec) {
|
||||||
break
|
break
|
||||||
|
|||||||
Reference in New Issue
Block a user