Add the missing loop in event handler.

Signed-off-by: Lantao Liu <lantaol@google.com>
This commit is contained in:
Lantao Liu 2017-06-13 17:47:29 +00:00
parent 479e8c3045
commit 87ec0f89bf

View File

@ -58,10 +58,11 @@ func (c *criContainerdService) startEventMonitor() {
b.Reset() b.Reset()
// TODO(random-liu): Relist to recover state, should prevent other operations // TODO(random-liu): Relist to recover state, should prevent other operations
// until state is fully recovered. // until state is fully recovered.
if err := c.handleEventStream(events); err != nil { for {
glog.Errorf("Failed to handle event stream: %v", err) if err := c.handleEventStream(events); err != nil {
time.Sleep(b.Duration()) glog.Errorf("Failed to handle event stream: %v", err)
continue break
}
} }
} }
}() }()