Change RLock to a Lock in shouldKeep in sample node

influxdata · Mar 2, 2017 · 32d1502 · 32d1502
1 parent f97f8e4
commit 32d1502
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/sample.go b/sample.go
@@ -85,12 +85,10 @@ func (s *SampleNode) shouldKeep(group models.GroupID, t time.Time) bool {
 		keepTime := t.Truncate(s.duration)
 		return t.Equal(keepTime)
 	} else {
-		s.countsMu.RLock()
+		s.countsMu.Lock()
 		count := s.counts[group]
-		s.countsMu.RUnlock()
 		keep := count%s.s.N == 0
 		count++
-		s.countsMu.Lock()
 		s.counts[group] = count
 		s.countsMu.Unlock()
 		return keep