github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-11 06:02:18 +00:00
Code Issues Projects Releases Wiki Activity

pkg/watch: remove test hook

Browse Source
This commit is contained in:
Andrew M Bursavich
2014-09-15 18:47:16 -07:00
parent 9c25792dca
commit 4e7f8db3a0
2 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/watch/mux.go
View File

@@ -115,13 +115,10 @@ func (m *Mux) loop() {
m.closeAll()
}
var testHookMuxDistribute = func() {}
// distribute sends event to all watchers. Blocking.
func (m *Mux) distribute(event Event) {
m.lock.Lock()
defer m.lock.Unlock()
testHookMuxDistribute()
for _, w := range m.watchers {
select {
case w.result <- event: