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

Merge pull request #105599 from jonyhy96/fix-pod-workers-test

Browse Source 
fix: pod workers test
This commit is contained in:
Kubernetes Prow Robot 2022-04-02 06:50:09 -07:00 committed by GitHub
commit e04a4e1c5b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/kubelet/pod_workers_test.go
View File

@ -398,7 +398,7 @@ func TestUpdatePod(t *testing.T) {
func TestUpdatePodWithTerminatedPod(t *testing.T) { func TestUpdatePodWithTerminatedPod(t *testing.T) {
podWorkers, _ := createPodWorkers() podWorkers, _ := createPodWorkers()
terminatedPod := newPodWithPhase("0000-0000-0000", "done-pod", v1.PodSucceeded) terminatedPod := newPodWithPhase("0000-0000-0000", "done-pod", v1.PodSucceeded)
runningPod := &kubecontainer.Pod{ID: "0000-0000-0001", Name: "done-pod"} orphanedPod := &kubecontainer.Pod{ID: "0000-0000-0001", Name: "orphaned-pod"}
pod := newPod("0000-0000-0002", "running-pod") pod := newPod("0000-0000-0002", "running-pod")
podWorkers.UpdatePod(UpdatePodOptions{ podWorkers.UpdatePod(UpdatePodOptions{
@ -411,17 +411,17 @@ func TestUpdatePodWithTerminatedPod(t *testing.T) {
}) })
podWorkers.UpdatePod(UpdatePodOptions{ podWorkers.UpdatePod(UpdatePodOptions{
UpdateType: kubetypes.SyncPodKill, UpdateType: kubetypes.SyncPodKill,
RunningPod: runningPod, RunningPod: orphanedPod,
}) })
drainAllWorkers(podWorkers)
if podWorkers.IsPodKnownTerminated(pod.UID) == true { if podWorkers.IsPodKnownTerminated(pod.UID) == true {
t.Errorf("podWorker state should not be terminated") t.Errorf("podWorker state should not be terminated")
} }
if podWorkers.IsPodKnownTerminated(terminatedPod.UID) == false { if podWorkers.IsPodKnownTerminated(terminatedPod.UID) == false {
t.Errorf("podWorker state should be terminated") t.Errorf("podWorker state should be terminated")
} }
if podWorkers.IsPodKnownTerminated(runningPod.ID) == true { if podWorkers.IsPodKnownTerminated(orphanedPod.ID) == false {
t.Errorf("podWorker state should not be marked terminated for a running pod") t.Errorf("podWorker state should be terminated for orphaned pod")
} }
} }