68
}
69
70
>
func (c *sharedScopeCache) loadOrStoreHandler(key string, create func() *tallyMetricsHandler) *tallyMetricsHandler {
tally_metrics_handler.go
71
>
c.mu.RLock()
72
>
if h, ok := c.handlers[key]; ok {
73
c.mu.RUnlock()
74
return h
75
}
77
>
78
>
h := create()
79
>
80
>
c.mu.Lock()
81
>
defer c.mu.Unlock()
82
>
// Double-check: another goroutine may have inserted while we were creating.
83
>
if existing, ok := c.handlers[key]; ok {
84
return existing
85
}
87
clear(c.handlers)
88
}
90
>
return h
91
}
92