From 87ec0f89bff4e5ece18d3948527e017ee2e3ca86 Mon Sep 17 00:00:00 2001 From: Lantao Liu Date: Tue, 13 Jun 2017 17:47:29 +0000 Subject: [PATCH] Add the missing loop in event handler. Signed-off-by: Lantao Liu --- pkg/server/events.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/server/events.go b/pkg/server/events.go index ba83db384..80d221a45 100644 --- 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 + } } } }()