mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-04 18:00:08 +00:00
Fix #14284: TestPersistentVolumeClaimBinder flake
This commit is contained in:
parent
2e5a3cfbc6
commit
cd56b041f3
@ -86,16 +86,18 @@ func TestPersistentVolumeClaimBinder(t *testing.T) {
|
|||||||
}
|
}
|
||||||
defer watch.Stop()
|
defer watch.Stop()
|
||||||
|
|
||||||
boundCount := 0
|
// Wait for claim01 and claim02 to become bound
|
||||||
expectedBoundCount := 2
|
claim01Pending := true
|
||||||
for {
|
claim02Pending := true
|
||||||
|
for claim01Pending || claim02Pending {
|
||||||
event := <-watch.ResultChan()
|
event := <-watch.ResultChan()
|
||||||
claim := event.Object.(*api.PersistentVolumeClaim)
|
claim := event.Object.(*api.PersistentVolumeClaim)
|
||||||
if claim.Spec.VolumeName != "" {
|
if claim.Spec.VolumeName != "" && claim.Status.Phase != "Bound" {
|
||||||
boundCount++
|
if claim.Name == "claim01" {
|
||||||
|
claim01Pending = false
|
||||||
|
} else if claim.Name == "claim02" {
|
||||||
|
claim02Pending = false
|
||||||
}
|
}
|
||||||
if boundCount == expectedBoundCount {
|
|
||||||
break
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user