mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-01 07:47:56 +00:00
Fix panics in load test
This commit is contained in:
parent
a673d99731
commit
1583912dd0
@ -189,6 +189,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
|
|||||||
framework.Logf("Creating services")
|
framework.Logf("Creating services")
|
||||||
services := generateServicesForConfigs(configs)
|
services := generateServicesForConfigs(configs)
|
||||||
createService := func(i int) {
|
createService := func(i int) {
|
||||||
|
defer GinkgoRecover()
|
||||||
_, err := clientset.Core().Services(services[i].Namespace).Create(services[i])
|
_, err := clientset.Core().Services(services[i].Namespace).Create(services[i])
|
||||||
framework.ExpectNoError(err)
|
framework.ExpectNoError(err)
|
||||||
}
|
}
|
||||||
@ -197,6 +198,7 @@ var _ = framework.KubeDescribe("Load capacity", func() {
|
|||||||
defer func(services []*v1.Service) {
|
defer func(services []*v1.Service) {
|
||||||
framework.Logf("Starting to delete services...")
|
framework.Logf("Starting to delete services...")
|
||||||
deleteService := func(i int) {
|
deleteService := func(i int) {
|
||||||
|
defer GinkgoRecover()
|
||||||
err := clientset.Core().Services(services[i].Namespace).Delete(services[i].Name, nil)
|
err := clientset.Core().Services(services[i].Namespace).Delete(services[i].Name, nil)
|
||||||
framework.ExpectNoError(err)
|
framework.ExpectNoError(err)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user