Fix data race on hcr.channels

Signed-off-by: Anton Litvinov <[email protected]>
mysteriumnetwork · Mar 4, 2024 · 4ffa546 · 4ffa546
1 parent d6e4124
commit 4ffa546
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/session/pingpong/hermes_channel_repository.go b/session/pingpong/hermes_channel_repository.go
@@ -249,6 +249,10 @@ func (hcr *HermesChannelRepository) Subscribe(bus eventbus.Subscriber) error {
 }
 
 func (hcr *HermesChannelRepository) handleHermesPromiseReceived(payload pingEvent.AppEventHermesPromise) {
+	// protect hcr.channels: handleHermesPromiseReceived->updateChannelWithLatestPromise->updateChannel
+	hcr.lock.RLock()
+	defer hcr.lock.RUnlock()
+
 	channelID, err := crypto.GenerateProviderChannelID(payload.ProviderID.Address, payload.HermesID.Hex())
 	if err != nil {
 		log.Err(err).Msg("could not generate provider channel id")