Merge pull request #74 from Random-Liu/fix-event-handler
Add the missing loop in event handler.
This commit is contained in:
		@@ -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
 | 
			
		||||
				}
 | 
			
		||||
			}
 | 
			
		||||
		}
 | 
			
		||||
	}()
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user