github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modify random failure

Browse Source
This commit is contained in:
changyaowei
2019-04-27 08:04:58 +08:00
parent 123d1a925f
commit 850f4bbd36
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/kubelet/pleg/generic_test.go
View File

@@ -211,23 +211,17 @@ func TestEventChannelFull(t *testing.T) {
}}, }},
} }
pleg.relist() pleg.relist()
// event channel is full, discard events allEvents := []*PodLifecycleEvent{
expected = []*PodLifecycleEvent{
{ID: "1234", Type: ContainerRemoved, Data: "c1"}, {ID: "1234", Type: ContainerRemoved, Data: "c1"},
{ID: "1234", Type: ContainerDied, Data: "c2"}, {ID: "1234", Type: ContainerDied, Data: "c2"},
{ID: "1234", Type: ContainerStarted, Data: "c3"}, {ID: "1234", Type: ContainerStarted, Data: "c3"},
{ID: "4567", Type: ContainerRemoved, Data: "c1"}, {ID: "4567", Type: ContainerRemoved, Data: "c1"},
{ID: "4567", Type: ContainerStarted, Data: "c4"}, {ID: "4567", Type: ContainerStarted, Data: "c4"},
} }
// event channel is full, discard events
actual = getEventsFromChannel(ch) actual = getEventsFromChannel(ch)
assert.True(t, len(actual) == 4, "channel length should be 4") assert.True(t, len(actual) == 4, "channel length should be 4")
for _, actualEvent := range actual { assert.Subsetf(t, allEvents, actual, "actual events should in all events")
for _, expectedEvent := range expected {
if actualEvent.ID == expectedEvent.ID && actualEvent.Data == expectedEvent.Data {
assert.True(t, actualEvent.Type == expectedEvent.Type, "event type should be equal")
}
}
}
} }
func TestDetectingContainerDeaths(t *testing.T) { func TestDetectingContainerDeaths(t *testing.T) {