Merge pull request #74 from Random-Liu/fix-event-handler

Add the missing loop in event handler.
containerd · Jun 13, 2017 · b83270d · b83270d
2 parents 479e8c3 + 87ec0f8
commit b83270d
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/pkg/server/events.go b/pkg/server/events.go
@@ -58,10 +58,11 @@ func (c *criContainerdService) startEventMonitor() {
 			b.Reset()
 			// TODO(random-liu): Relist to recover state, should prevent other operations
 			// until state is fully recovered.
-			if err := c.handleEventStream(events); err != nil {
-				glog.Errorf("Failed to handle event stream: %v", err)
-				time.Sleep(b.Duration())
-				continue
+			for {
+				if err := c.handleEventStream(events); err != nil {
+					glog.Errorf("Failed to handle event stream: %v", err)
+					break
+				}
 			}
 		}
 	}()