Add locking around partitionIDToState map accesses

[vprithvi]

Signed-off-by: Prithvi Raj [email protected]

Which problem is this PR solving?

• Prevents concurrent access of partitionIDToState map

Short description of the changes

• Add locks around partitionIDToState to prevent concurrent access

[yurishkuro]

this is not a great pattern - the Add() should be happening before this goroutine is started, otherwise the caller (or Close()) might have already called Wait() and exited. You can do Add(2) after creating the state

c.partitionIDToState[pc.Partition()] = &consumerState{partitionConsumer: pc}
c.partitionIDToState[pc.Partition()].Add(2)

[codecov]

Codecov Report

Merging #1239 into master will not change coverage.
The diff coverage is 100%.

@@          Coverage Diff           @@
##           master   #1239   +/-   ##
======================================
  Coverage     100%    100%           
======================================
  Files         159     159           
  Lines        7136    7145    +9     
======================================
+ Hits         7136    7145    +9

Impacted Files	Coverage Δ
cmd/ingester/app/consumer/consumer.go	100% <100%> (ø)	⬆️

---

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 6237e2f...812b46c. Read the comment docs.