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

refactor: pleg/getContainersFromPods

Browse Source
This commit is contained in:
XuzhengChang 2022-04-01 17:36:07 +08:00
parent 885f14d162
commit 6266554b34
1 changed files with 13 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -325,29 +325,25 @@ func (g *GenericPLEG) relist() {
func getContainersFromPods(pods ...*kubecontainer.Pod) []*kubecontainer.Container { func getContainersFromPods(pods ...*kubecontainer.Pod) []*kubecontainer.Container {
cidSet := sets.NewString() cidSet := sets.NewString()
var containers []*kubecontainer.Container var containers []*kubecontainer.Container
fillCidSet := func(cs []*kubecontainer.Container) {
for _, c := range cs {
cid := c.ID.ID
if cidSet.Has(cid) {
continue
}
cidSet.Insert(cid)
containers = append(containers, c)
}
}
for _, p := range pods { for _, p := range pods {
if p == nil { if p == nil {
continue continue
} }
for _, c := range p.Containers { fillCidSet(p.Containers)
cid := string(c.ID.ID)
if cidSet.Has(cid) {
continue
}
cidSet.Insert(cid)
containers = append(containers, c)
}
// Update sandboxes as containers // Update sandboxes as containers
// TODO: keep track of sandboxes explicitly. // TODO: keep track of sandboxes explicitly.
for _, c := range p.Sandboxes { fillCidSet(p.Sandboxes)
cid := string(c.ID.ID)
if cidSet.Has(cid) {
continue
}
cidSet.Insert(cid)
containers = append(containers, c)
}
} }
return containers return containers
} }