From 60cd8966028675d8327d833542635effb479cd06 Mon Sep 17 00:00:00 2001 From: jonyhy96 Date: Thu, 24 Feb 2022 16:35:33 +0800 Subject: [PATCH] fix: pod worker test Signed-off-by: jonyhy96 --- pkg/kubelet/pod_workers_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/kubelet/pod_workers_test.go b/pkg/kubelet/pod_workers_test.go index 91b36999593..d9112b2df93 100644 --- a/pkg/kubelet/pod_workers_test.go +++ b/pkg/kubelet/pod_workers_test.go @@ -288,7 +288,7 @@ func TestUpdatePod(t *testing.T) { func TestUpdatePodWithTerminatedPod(t *testing.T) { podWorkers, _ := createPodWorkers() 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") podWorkers.UpdatePod(UpdatePodOptions{ @@ -301,17 +301,17 @@ func TestUpdatePodWithTerminatedPod(t *testing.T) { }) podWorkers.UpdatePod(UpdatePodOptions{ UpdateType: kubetypes.SyncPodKill, - RunningPod: runningPod, + RunningPod: orphanedPod, }) - + drainAllWorkers(podWorkers) if podWorkers.IsPodKnownTerminated(pod.UID) == true { t.Errorf("podWorker state should not be terminated") } if podWorkers.IsPodKnownTerminated(terminatedPod.UID) == false { t.Errorf("podWorker state should be terminated") } - if podWorkers.IsPodKnownTerminated(runningPod.ID) == true { - t.Errorf("podWorker state should not be marked terminated for a running pod") + if podWorkers.IsPodKnownTerminated(orphanedPod.ID) == false { + t.Errorf("podWorker state should be terminated for orphaned pod") } }