mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-20 17:38:50 +00:00
remove lock for broadcast
This commit is contained in:
@@ -118,9 +118,7 @@ func (f *FakeEtcdClient) Watch(prefix string, waitIndex uint64, recursive bool,
|
||||
defer close(injectedError)
|
||||
f.WatchInjectError = injectedError
|
||||
|
||||
f.condLock.Lock()
|
||||
f.condWatchCompleted.Broadcast()
|
||||
f.condLock.Unlock()
|
||||
|
||||
select {
|
||||
case <-stop:
|
||||
|
Reference in New Issue
Block a user