mirror of
https://github.com/kubernetes/node-problem-detector.git
synced 2026-05-06 09:17:10 +00:00
Merge pull request #1260 from hakman/kmsg-stop-parser
fix(logwatchers/kmsg): don't close parser from Stop()
This commit is contained in:
@@ -80,11 +80,8 @@ func (k *kernelLogWatcher) Watch() (<-chan *logtypes.Log, error) {
|
||||
return k.logCh, nil
|
||||
}
|
||||
|
||||
// Stop closes the kmsgparser
|
||||
// Stop signals the watch loop to stop.
|
||||
func (k *kernelLogWatcher) Stop() {
|
||||
if err := k.kmsgParser.Close(); err != nil {
|
||||
klog.Errorf("Failed to close kmsg parser: %v", err)
|
||||
}
|
||||
k.tomb.Stop()
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user