mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-02-02 08:31:11 -08:00
Code Issues Actions 55 Packages Projects Releases Wiki Activity

Merge pull request #4066 from krasi-georgiev/race-DiscoveredLabels

Browse source 
add mutex for DiscoveredLabels
This commit is contained in:
Björn Rabenstein 2018-04-10 15:36:56 +02:00 committed by GitHub
parent e65fc8591a dc29dd1c6f
commit f8dcf9b272
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
scrape/target.go
View file

@ -110,6 +110,8 @@ func (t *Target) Labels() labels.Labels {
// DiscoveredLabels returns a copy of the target's labels before any processing. // DiscoveredLabels returns a copy of the target's labels before any processing.
func (t *Target) DiscoveredLabels() labels.Labels { func (t *Target) DiscoveredLabels() labels.Labels {
t.mtx.Lock()
defer t.mtx.Unlock()
lset := make(labels.Labels, len(t.discoveredLabels)) lset := make(labels.Labels, len(t.discoveredLabels))
copy(lset, t.discoveredLabels) copy(lset, t.discoveredLabels)
return lset return lset
@ -117,6 +119,8 @@ func (t *Target) DiscoveredLabels() labels.Labels {
// SetDiscoveredLabels sets new DiscoveredLabels // SetDiscoveredLabels sets new DiscoveredLabels
func (t *Target) SetDiscoveredLabels(l labels.Labels) { func (t *Target) SetDiscoveredLabels(l labels.Labels) {
t.mtx.Lock()
defer t.mtx.Unlock()
t.discoveredLabels = l t.discoveredLabels = l
} }