mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
Print running containers in infra container oom score test.
This commit is contained in:
parent
b88b31cff4
commit
1226c5794a
@ -92,50 +92,61 @@ var _ = framework.KubeDescribe("Kubelet Container Manager [Serial]", func() {
|
|||||||
return validateOOMScoreAdjSetting(kubeletPids[0], -999)
|
return validateOOMScoreAdjSetting(kubeletPids[0], -999)
|
||||||
}, 5*time.Minute, 30*time.Second).Should(BeNil())
|
}, 5*time.Minute, 30*time.Second).Should(BeNil())
|
||||||
})
|
})
|
||||||
It("pod infra containers oom-score-adj should be -998 and best effort container's should be 1000", func() {
|
Context("", func() {
|
||||||
var err error
|
It("pod infra containers oom-score-adj should be -998 and best effort container's should be 1000", func() {
|
||||||
podClient := f.PodClient()
|
var err error
|
||||||
podName := "besteffort" + string(uuid.NewUUID())
|
podClient := f.PodClient()
|
||||||
podClient.Create(&v1.Pod{
|
podName := "besteffort" + string(uuid.NewUUID())
|
||||||
ObjectMeta: metav1.ObjectMeta{
|
podClient.Create(&v1.Pod{
|
||||||
Name: podName,
|
ObjectMeta: metav1.ObjectMeta{
|
||||||
},
|
Name: podName,
|
||||||
Spec: v1.PodSpec{
|
},
|
||||||
Containers: []v1.Container{
|
Spec: v1.PodSpec{
|
||||||
{
|
Containers: []v1.Container{
|
||||||
Image: "gcr.io/google_containers/serve_hostname:v1.4",
|
{
|
||||||
Name: podName,
|
Image: "gcr.io/google_containers/serve_hostname:v1.4",
|
||||||
|
Name: podName,
|
||||||
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
})
|
||||||
})
|
var pausePids []int
|
||||||
var pausePids []int
|
By("checking infra container's oom-score-adj")
|
||||||
By("checking infra container's oom-score-adj")
|
Eventually(func() error {
|
||||||
Eventually(func() error {
|
pausePids, err = getPidsForProcess("pause", "")
|
||||||
pausePids, err = getPidsForProcess("pause", "")
|
if err != nil {
|
||||||
if err != nil {
|
return fmt.Errorf("failed to get list of pause pids: %v", err)
|
||||||
return fmt.Errorf("failed to get list of pause pids: %v", err)
|
|
||||||
}
|
|
||||||
for _, pid := range pausePids {
|
|
||||||
if err := validateOOMScoreAdjSetting(pid, -998); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
}
|
||||||
|
for _, pid := range pausePids {
|
||||||
|
if err := validateOOMScoreAdjSetting(pid, -998); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}, 2*time.Minute, time.Second*4).Should(BeNil())
|
||||||
|
var shPids []int
|
||||||
|
By("checking besteffort container's oom-score-adj")
|
||||||
|
Eventually(func() error {
|
||||||
|
shPids, err = getPidsForProcess("serve_hostname", "")
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to get list of serve hostname process pids: %v", err)
|
||||||
|
}
|
||||||
|
if len(shPids) != 1 {
|
||||||
|
return fmt.Errorf("expected only one serve_hostname process; found %d", len(shPids))
|
||||||
|
}
|
||||||
|
return validateOOMScoreAdjSetting(shPids[0], 1000)
|
||||||
|
}, 2*time.Minute, time.Second*4).Should(BeNil())
|
||||||
|
})
|
||||||
|
// Log the running containers here to help debugging. Use `docker ps`
|
||||||
|
// directly for now because the test is already docker specific.
|
||||||
|
AfterEach(func() {
|
||||||
|
if CurrentGinkgoTestDescription().Failed {
|
||||||
|
By("Dump all running docker containers")
|
||||||
|
output, err := exec.Command("docker", "ps").CombinedOutput()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
framework.Logf("Running docker containers:\n%s", string(output))
|
||||||
}
|
}
|
||||||
return nil
|
})
|
||||||
}, 2*time.Minute, time.Second*4).Should(BeNil())
|
|
||||||
var shPids []int
|
|
||||||
By("checking besteffort container's oom-score-adj")
|
|
||||||
Eventually(func() error {
|
|
||||||
shPids, err = getPidsForProcess("serve_hostname", "")
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("failed to get list of serve hostname process pids: %v", err)
|
|
||||||
}
|
|
||||||
if len(shPids) != 1 {
|
|
||||||
return fmt.Errorf("expected only one serve_hostname process; found %d", len(shPids))
|
|
||||||
}
|
|
||||||
return validateOOMScoreAdjSetting(shPids[0], 1000)
|
|
||||||
}, 2*time.Minute, time.Second*4).Should(BeNil())
|
|
||||||
|
|
||||||
})
|
})
|
||||||
It("guaranteed container's oom-score-adj should be -998", func() {
|
It("guaranteed container's oom-score-adj should be -998", func() {
|
||||||
podClient := f.PodClient()
|
podClient := f.PodClient()
|
||||||
|
Loading…
Reference in New Issue
Block a user