From de30886c9e65482b1940f583cced1cbb105f7ea1 Mon Sep 17 00:00:00 2001 From: Soam Vasani Date: Fri, 16 Dec 2016 00:43:45 -0800 Subject: [PATCH] compile error --- kubewatcher/kubewatcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kubewatcher/kubewatcher.go b/kubewatcher/kubewatcher.go index baf48d2e..be6def8e 100644 --- a/kubewatcher/kubewatcher.go +++ b/kubewatcher/kubewatcher.go @@ -205,7 +205,7 @@ func (ws *watchSubscription) eventDispatchLoop(poster *Poster) { // sends a different type when ev.Type == ERROR?) poster.Post(string(ev.Type), ws.Watch.ObjType, ws.Watch.Url, &buf) } - if !atomic.LoadInt32(ws.stopped) { + if atomic.LoadInt32(ws.stopped) != 0 { // TODO re-watch. What about resource version? log.Panicf("Watch channel closed unexpectedly") }