Merge pull request #339 from wenjun93/logmonitor

avoid log channel closed caused endless loop
This commit is contained in:
Kubernetes Prow Robot
2019-10-25 11:27:39 -07:00
committed by GitHub

View File

@@ -129,7 +129,11 @@ func (l *logMonitor) monitorLoop() {
l.initializeStatus()
for {
select {
case log := <-l.logCh:
case log, ok := <-l.logCh:
if !ok {
glog.Errorf("Log channel closed")
return
}
l.parseLog(log)
case <-l.tomb.Stopping():
l.watcher.Stop()