Commit d2e8ec93 authored by markturansky's avatar markturansky

merged recycler+deleter tests so they run serially

parent 6dca2a4e
...@@ -89,21 +89,10 @@ func TestPersistentVolumeRecycler(t *testing.T) { ...@@ -89,21 +89,10 @@ func TestPersistentVolumeRecycler(t *testing.T) {
waitForPersistentVolumePhase(watch, api.VolumeReleased) waitForPersistentVolumePhase(watch, api.VolumeReleased)
waitForPersistentVolumePhase(watch, api.VolumeAvailable) waitForPersistentVolumePhase(watch, api.VolumeAvailable)
}
func waitForPersistentVolumePhase(w watch.Interface, phase api.PersistentVolumePhase) { // end of Recycler test.
for { // Deleter test begins now.
event := <-w.ResultChan() // tests are serial because running masters concurrently that delete keys may cause similar tests to time out
volume := event.Object.(*api.PersistentVolume)
if volume.Status.Phase == phase {
break
}
}
}
func TestPersistentVolumeDeleter(t *testing.T) {
_, s := runAMaster(t)
defer s.Close()
deleteAllEtcdKeys() deleteAllEtcdKeys()
binderClient := client.NewOrDie(&client.Config{Host: s.URL, Version: testapi.Default.Version()}) binderClient := client.NewOrDie(&client.Config{Host: s.URL, Version: testapi.Default.Version()})
...@@ -160,3 +149,13 @@ func TestPersistentVolumeDeleter(t *testing.T) { ...@@ -160,3 +149,13 @@ func TestPersistentVolumeDeleter(t *testing.T) {
} }
} }
} }
func waitForPersistentVolumePhase(w watch.Interface, phase api.PersistentVolumePhase) {
for {
event := <-w.ResultChan()
volume := event.Object.(*api.PersistentVolume)
if volume.Status.Phase == phase {
break
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment