fix infinite loop

moycat · Jan 29, 2022 · c0ffde5 · c0ffde5
1 parent ee7398e
commit c0ffde5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/app/shiba.go b/app/shiba.go
@@ -79,6 +79,7 @@ func NewShiba(client kubernetes.Interface, nodeName, cniConfigPath string, optio
 func (shiba *Shiba) Run(stopCh <-chan struct{}) error {
 	go shiba.execute(stopCh)
 	go shiba.periodicFire(stopCh)
+watchLoop:
 	for {
 		watcher, err := shiba.client.CoreV1().Nodes().Watch(context.Background(), metav1.ListOptions{})
 		if err != nil {
@@ -94,7 +95,7 @@ func (shiba *Shiba) Run(stopCh <-chan struct{}) error {
 			case event, ok := <-watcherCh:
 				if !ok {
 					log.Info("watch channel closed")
-					break
+					continue watchLoop
 				}
 				shiba.processEvent(event)
 			}