diff --git a/pkg/kubelet/pleg/generic_test.go b/pkg/kubelet/pleg/generic_test.go index 860ff2934b8..9e648e9c13d 100644 --- a/pkg/kubelet/pleg/generic_test.go +++ b/pkg/kubelet/pleg/generic_test.go @@ -211,15 +211,17 @@ func TestEventChannelFull(t *testing.T) { }}, } pleg.relist() - // event channel is full, discard events - expected = []*PodLifecycleEvent{ + allEvents := []*PodLifecycleEvent{ {ID: "1234", Type: ContainerRemoved, Data: "c1"}, {ID: "1234", Type: ContainerDied, Data: "c2"}, {ID: "1234", Type: ContainerStarted, Data: "c3"}, {ID: "4567", Type: ContainerRemoved, Data: "c1"}, + {ID: "4567", Type: ContainerStarted, Data: "c4"}, } + // event channel is full, discard events actual = getEventsFromChannel(ch) - verifyEvents(t, expected, actual) + assert.True(t, len(actual) == 4, "channel length should be 4") + assert.Subsetf(t, allEvents, actual, "actual events should in all events") } func TestDetectingContainerDeaths(t *testing.T) {