Merge pull request #6323 from jepio/jepio/fix-cgroupv2-oom-event
This commit is contained in:
commit
e7cba85e1c
@ -71,15 +71,15 @@ func (w *watcher) Run(ctx context.Context) {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
lastOOM := lastOOMMap[i.id]
|
lastOOM := lastOOMMap[i.id]
|
||||||
if i.ev.OOM > lastOOM {
|
if i.ev.OOMKill > lastOOM {
|
||||||
if err := w.publisher.Publish(ctx, runtime.TaskOOMEventTopic, &eventstypes.TaskOOM{
|
if err := w.publisher.Publish(ctx, runtime.TaskOOMEventTopic, &eventstypes.TaskOOM{
|
||||||
ContainerID: i.id,
|
ContainerID: i.id,
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
logrus.WithError(err).Error("publish OOM event")
|
logrus.WithError(err).Error("publish OOM event")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if i.ev.OOM > 0 {
|
if i.ev.OOMKill > 0 {
|
||||||
lastOOMMap[i.id] = i.ev.OOM
|
lastOOMMap[i.id] = i.ev.OOMKill
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user