github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 19:01:49 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #108010 from endocrimes/dani/eviction-flake

Browse Source 
eviction: Deflake TestStart
This commit is contained in:
Kubernetes Prow Robot 2022-03-17 12:22:54 -07:00 committed by GitHub
commit 56062f7f4f
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/eviction/memory_threshold_notifier_test.go
View File

@ -174,8 +174,11 @@ func TestStart(t *testing.T) {
notifierFactory.EXPECT().NewCgroupNotifier(testCgroupPath, memoryUsageAttribute, int64(0)).Return(notifier, nil).Times(1) notifierFactory.EXPECT().NewCgroupNotifier(testCgroupPath, memoryUsageAttribute, int64(0)).Return(notifier, nil).Times(1)
var events chan<- struct{} = m.events var events chan<- struct{} = m.events
notifier.EXPECT().Start(events).Return() notifier.EXPECT().Start(events).DoAndReturn(func(events chan<- struct{}) {
notifier.EXPECT().Stop().Return().AnyTimes() for i := 0; i < 4; i++ {
events <- struct{}{}
}
})
err := m.UpdateThreshold(nodeSummary(noResources, noResources, noResources, isAllocatableEvictionThreshold(threshold))) err := m.UpdateThreshold(nodeSummary(noResources, noResources, noResources, isAllocatableEvictionThreshold(threshold)))
if err != nil { if err != nil {
@ -184,9 +187,6 @@ func TestStart(t *testing.T) {
go m.Start() go m.Start()
for i := 0; i < 4; i++ {
m.events <- struct{}{}
}
wg.Wait() wg.Wait()
} }