diff --git a/pkg/util/fake_etcd_client.go b/pkg/util/fake_etcd_client.go index f21a5c17e1e..df6ac54c767 100644 --- a/pkg/util/fake_etcd_client.go +++ b/pkg/util/fake_etcd_client.go @@ -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: