Commit 29edf627 authored by Ke Zhang's avatar Ke Zhang

change sourcesSeenLock to sync.RWMutex

parent 1c9332ab
...@@ -125,7 +125,7 @@ type podStorage struct { ...@@ -125,7 +125,7 @@ type podStorage struct {
updates chan<- kubetypes.PodUpdate updates chan<- kubetypes.PodUpdate
// contains the set of all sources that have sent at least one SET // contains the set of all sources that have sent at least one SET
sourcesSeenLock sync.Mutex sourcesSeenLock sync.RWMutex
sourcesSeen sets.String sourcesSeen sets.String
// the EventRecorder to use // the EventRecorder to use
...@@ -314,8 +314,8 @@ func (s *podStorage) markSourceSet(source string) { ...@@ -314,8 +314,8 @@ func (s *podStorage) markSourceSet(source string) {
} }
func (s *podStorage) seenSources(sources ...string) bool { func (s *podStorage) seenSources(sources ...string) bool {
s.sourcesSeenLock.Lock() s.sourcesSeenLock.RLock()
defer s.sourcesSeenLock.Unlock() defer s.sourcesSeenLock.RUnlock()
return s.sourcesSeen.HasAll(sources...) return s.sourcesSeen.HasAll(sources...)
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment