github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 05:57:25 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #99880 from Dragoncell/pleg-log

Browse Source 
Add exit code log when container died
This commit is contained in:
Kubernetes Prow Robot 2021-04-22 13:18:01 -07:00 committed by GitHub
commit 27e23967f4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
pkg/kubelet/pleg/generic.go
View File

@ -264,6 +264,10 @@ func (g *GenericPLEG) relist() {
} }
// Update the internal storage and send out the events. // Update the internal storage and send out the events.
g.podRecords.update(pid) g.podRecords.update(pid)
// Map from containerId to exit code; used as a temporary cache for lookup
containerExitCode := make(map[string]int)
for i := range events { for i := range events {
// Filter out events that are not reliable and no other components use yet. // Filter out events that are not reliable and no other components use yet.
if events[i].Type == ContainerChanged { if events[i].Type == ContainerChanged {
@ -275,6 +279,24 @@ func (g *GenericPLEG) relist() {
metrics.PLEGDiscardEvents.Inc() metrics.PLEGDiscardEvents.Inc()
klog.ErrorS(nil, "Event channel is full, discard this relist() cycle event") klog.ErrorS(nil, "Event channel is full, discard this relist() cycle event")
} }
// Log exit code of containers when they finished in a particular event
if events[i].Type == ContainerDied {
// Fill up containerExitCode map for ContainerDied event when first time appeared
if len(containerExitCode) == 0 && pod != nil && g.cache != nil {
// Get updated podStatus
status, err := g.cache.Get(pod.ID)
if err == nil {
for _, containerStatus := range status.ContainerStatuses {
containerExitCode[containerStatus.ID.ID] = containerStatus.ExitCode
}
}
}
if containerID, ok := events[i].Data.(string); ok {
if exitCode, ok := containerExitCode[containerID]; ok {
klog.V(2).InfoS("Generic (PLEG): container finished", "podID", pod.ID, "containerID", containerID, "exitCode", exitCode)
}
}
}
} }
} }