diff --git a/storage/local/mapper.go b/storage/local/mapper.go index 97b58c923..9bc0e7d12 100644 --- a/storage/local/mapper.go +++ b/storage/local/mapper.go @@ -141,10 +141,10 @@ func (m *fpMapper) maybeAddMapping( // A new mapping has to be created. mappedFP = m.nextMappedFP() mappedFPs[ms] = mappedFP - m.mtx.RLock() + m.mtx.Lock() // Checkpoint mappings after each change. err := m.p.checkpointFPMappings(m.mappings) - m.mtx.RUnlock() + m.mtx.Unlock() log.Infof( "Collision detected for fingerprint %v, metric %v, mapping to new fingerprint %v.", fp, collidingMetric, mappedFP,