Free RLock prior to returning

2017-07-08 07:14:50 -07:00 · 2017-07-08 07:14:50 -07:00 · 2ccdda72a1
parent dba3ce1a42
commit 2ccdda72a1
1 changed files with 2 additions and 0 deletions
--- a/tsdb/index/inmem/meta.go
+++ b/tsdb/index/inmem/meta.go
@ -330,11 +330,13 @@ func (m *Measurement) TagSets(shardID uint64, opt influxql.IteratorOptions) ([]*
 		// Abort if the query was killed
 		select {
 		case <-opt.InterruptCh:
+			m.mu.RUnlock()
 			return nil, influxql.ErrQueryInterrupted
 		default:
 		}

 		if opt.MaxSeriesN > 0 && seriesN > opt.MaxSeriesN {
+			m.mu.RUnlock()
 			return nil, fmt.Errorf("max-select-series limit exceeded: (%d/%d)", seriesN, opt.MaxSeriesN)
 		}