fix: concurrent map iteration and map write

blankbro · Aug 1, 2023 · dbee309 · dbee309
1 parent 146aed1
commit dbee309
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/storm/storm.go b/storm/storm.go
@@ -197,9 +197,11 @@ func (ms *MqttStorm) PubStorm(requestBodyBytes []byte) error {
 		return err
 	}
 
+	ms.Lock()
 	for _, client := range ms.MqttClientMap {
 		go ms.Mocker.Pub(client, requestBody)
 	}
+	ms.Unlock()
 
 	return nil
 }