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

fix: pod worker test

Browse Source 
Signed-off-by: jonyhy96 <hy352144278@gmail.com>
This commit is contained in:
jonyhy96 2022-02-24 16:35:33 +08:00
parent fb82a0d7eb
commit 60cd896602
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

@ -288,7 +288,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{
@ -301,17 +301,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")
} }
} }