From 4a4ebc70973148bfd93da53ceff976865e0b9298 Mon Sep 17 00:00:00 2001 From: wenjun93 Date: Fri, 25 Oct 2019 11:43:49 +0800 Subject: [PATCH] avoid log channel closed caused endless loop --- pkg/systemlogmonitor/log_monitor.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/systemlogmonitor/log_monitor.go b/pkg/systemlogmonitor/log_monitor.go index 777f7268..0ce2730c 100644 --- a/pkg/systemlogmonitor/log_monitor.go +++ b/pkg/systemlogmonitor/log_monitor.go @@ -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()