Skip to content

Commit 77aafea

Browse files
committed
Last two
1 parent 01ace92 commit 77aafea

File tree

2 files changed

+4
-7
lines changed

2 files changed

+4
-7
lines changed

cmd/standby_cleaner/main.go

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -52,12 +52,9 @@ func main() {
5252

5353
fmt.Printf("Pruning every %s...\n", deadMemberRemovalThreshold)
5454

55-
for {
56-
select {
57-
case <-ticker.C:
58-
if err := handleTick(ctx, flypgNode, seenAt, deadMemberRemovalThreshold); err != nil {
59-
fmt.Println(err)
60-
}
55+
for range ticker.C {
56+
if err := handleTick(ctx, flypgNode, seenAt, deadMemberRemovalThreshold); err != nil {
57+
fmt.Println(err)
6158
}
6259
}
6360
}

internal/supervisor/supervisor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ func (h *Supervisor) Stop() {
161161
}
162162

163163
func (h *Supervisor) StopOnSignal(sigs ...os.Signal) {
164-
sigch := make(chan os.Signal)
164+
sigch := make(chan os.Signal, 1)
165165
signal.Notify(sigch, sigs...)
166166

167167
go func() {

0 commit comments

Comments
 (0)