Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 16 additions & 7 deletions ring/ring.go
Original file line number Diff line number Diff line change
Expand Up @@ -198,7 +198,7 @@ type Ring struct {
totalTokensGauge prometheus.Gauge
numTokensGaugeVec *prometheus.GaugeVec
oldestTimestampGaugeVec *prometheus.GaugeVec
metricsUpdateTicker *time.Ticker
metricsUpdateCloser chan struct{}

logger log.Logger
}
Expand Down Expand Up @@ -284,11 +284,20 @@ func (r *Ring) starting(ctx context.Context) error {
r.updateRingState(value.(*Desc))
r.updateRingMetrics()

// Start metrics update ticker, and give it a function to update the ring metrics.
r.metricsUpdateTicker = time.NewTicker(10 * time.Second)
// Use this channel to close the go routine to prevent leaks.
r.metricsUpdateCloser = make(chan struct{})
go func() {
for range r.metricsUpdateTicker.C {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why the previous implementation wasn't good enough? I would expect the goroutine to end when the ticker channel is closed. However, I think the issue (which I believe persists even after this PR) is that the stopping() function isn't waiting until the goroutine is effectively terminated, so the goroutines leaker test may fail anyway.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Forgive the comment about the ticker. I just read the doc and learned ticker.Stop() doesn't close the channel. In case it's still leak the goroutine, then the 2nd part of my comment may be valid.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think there's also been a mistake: the previous version of this used a Ticker while this version uses a Timer. Was that the intention?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nope, this should be a ticker. 😞

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I opened #63 for this

r.updateRingMetrics()
// Start metrics update ticker to update the ring metrics.
ticker := time.NewTimer(10 * time.Second)
defer ticker.Stop()

for {
select {
case <-ticker.C:
r.updateRingMetrics()
case <-r.metricsUpdateCloser:
return
}
}
}()
return nil
Expand All @@ -309,8 +318,8 @@ func (r *Ring) loop(ctx context.Context) error {

func (r *Ring) stopping(_ error) error {
// Stop Metrics ticker.
if r.metricsUpdateTicker != nil {
r.metricsUpdateTicker.Stop()
if r.metricsUpdateCloser != nil {
close(r.metricsUpdateCloser)
}
return nil
}
Expand Down