Fix data race b/c of lacking lock protection for "data" slice

Signed-off-by: Anton Litvinov <[email protected]>
mysteriumnetwork · Mar 26, 2024 · c73dec3 · c73dec3
1 parent 453bb8b
commit c73dec3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/session/pingpong/consumer_totals_storage.go b/session/pingpong/consumer_totals_storage.go
@@ -94,6 +94,9 @@ func (cts *ConsumerTotalsStorage) Store(chainID int64, id identity.Identity, her
 // Get fetches the amount as promised for the given channel.
 func (cts *ConsumerTotalsStorage) Get(chainID int64, id identity.Identity, hermesID common.Address) (*big.Int, error) {
 	key := cts.makeKey(chainID, id, hermesID)
+	cts.createLock.Lock()
+	defer cts.createLock.Unlock()
+
 	element, ok := cts.data[key]
 	if !ok {
 		return nil, ErrNotFound