-
Notifications
You must be signed in to change notification settings - Fork 448
Closed
Labels
area/metricsIssue related to metrics and monitoringIssue related to metrics and monitoringgood first issueGood for newcomersGood for newcomerskind/enhancementCategory issues or PRs related to enhancementCategory issues or PRs related to enhancement
Description
func (mb *MetricBucket) reset() { |
another question:
the minrt updating function is not thread safe.
func (mb *MetricBucket) AddRt(rt int64) {
mb.addCount(base.MetricEventRt, rt)
if rt < atomic.LoadInt64(&mb.minRt) { // here is not thread safe.
// Might not be accurate here.
atomic.StoreInt64(&mb.minRt, rt)
}
}
Metadata
Metadata
Assignees
Labels
area/metricsIssue related to metrics and monitoringIssue related to metrics and monitoringgood first issueGood for newcomersGood for newcomerskind/enhancementCategory issues or PRs related to enhancementCategory issues or PRs related to enhancement