瀏覽代碼

modify logic for closing informer

Alexander Belanger 5 年之前
父節點
當前提交
e49db2a0e3
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      internal/kubernetes/agent.go

+ 1 - 1
internal/kubernetes/agent.go

@@ -612,7 +612,7 @@ func (a *Agent) StreamControllerStatus(conn *websocket.Conn, kind string, select
 		for {
 		for {
 			if _, _, err := conn.ReadMessage(); err != nil {
 			if _, _, err := conn.ReadMessage(); err != nil {
 				defer conn.Close()
 				defer conn.Close()
-				defer close(stopper)
+				close(stopper)
 				errorchan <- nil
 				errorchan <- nil
 				return
 				return
 			}
 			}