data race fixing.

pydio · Mar 25, 2024 · 8a34d99 · 8a34d99
1 parent fbef850
commit 8a34d99
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/common/broker/grpcpubsub/client.go b/common/broker/grpcpubsub/client.go
@@ -75,7 +75,9 @@ func (s *sharedSubscriber) Unsubscribe(subId string) {
 	delete(s.out, subId)
 	if len(s.out) == 0 && s.cancel != nil {
 		s.cancel()
+		subLock.Lock()
 		delete(subscribers, s.sharedKey)
+		subLock.Unlock()
 	}
 }