Use atomic.LoadInt32() when reading back numChunks

pracucci · pracucci · commit 4d68aaa621dd · 2020-07-14T09:44:30.000+02:00
Signed-off-by: Marco Pracucci &lt;marco@pracucci.com&gt;
diff --git a/pkg/querier/blocks_store_queryable.go b/pkg/querier/blocks_store_queryable.go
@@ -552,7 +552,7 @@ func (q *blocksStoreQuerier) fetchSeriesFromStores(
 		return nil, nil, nil, 0, err
 	}
 
-	return seriesSets, queriedBlocks, warnings, int(numChunks), nil
+	return seriesSets, queriedBlocks, warnings, int(atomic.LoadInt32(&numChunks)), nil
 }
 
 func createSeriesRequest(minT, maxT int64, matchers []storepb.LabelMatcher, blockIDs []ulid.ULID) (*storepb.SeriesRequest, error) {

Original file line number	Diff line number	Diff line change
`@@ -552,7 +552,7 @@ func (q *blocksStoreQuerier) fetchSeriesFromStores(`
`552`	`552`	`return nil, nil, nil, 0, err`
`553`	`553`	`}`
`554`	`554`
`555`		`- return seriesSets, queriedBlocks, warnings, int(numChunks), nil`
	`555`	`+ return seriesSets, queriedBlocks, warnings, int(atomic.LoadInt32(&numChunks)), nil`
`556`	`556`	`}`
`557`	`557`
`558`	`558`	`func createSeriesRequest(minT, maxT int64, matchers []storepb.LabelMatcher, blockIDs []ulid.ULID) (*storepb.SeriesRequest, error) {`