github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-07 03:03:59 +00:00
Code Issues Projects Releases Wiki Activity

do not recreate

Browse Source
This commit is contained in:
Nan Deng 2014-06-30 18:27:41 -07:00
parent 7b432eac5c
commit 101806cb5e
1 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/util/fake_etcd_client.go
View File

@ -123,13 +123,6 @@ func (f *FakeEtcdClient) Watch(prefix string, waitIndex uint64, recursive bool,
f.condWatchCompleted.Broadcast() f.condWatchCompleted.Broadcast()
f.condLock.Unlock() f.condLock.Unlock()
// After calling this function, the WatchStop channel will not be ready
defer func() {
f.condLock.Lock()
f.condWatchCompleted = sync.NewCond(&f.condLock)
f.condLock.Unlock()
}()
select { select {
case <-stop: case <-stop:
return nil, etcd.ErrWatchStoppedByUser return nil, etcd.ErrWatchStoppedByUser