Add GinkgoRecover in goroutines
This commit is contained in:
parent
b5f644f605
commit
4ad97afdb3
3 changed files with 4 additions and 0 deletions
|
@ -61,6 +61,7 @@ var _ = framework.DescribeAnnotation("Annotation - limit-connections", func() {
|
|||
|
||||
worker := func(wg *sync.WaitGroup) {
|
||||
defer wg.Done()
|
||||
defer ginkgo.GinkgoRecover()
|
||||
|
||||
resp := f.HTTPTestClient().
|
||||
GET("/sleep/10").
|
||||
|
|
|
@ -115,6 +115,7 @@ func (f *Framework) BeforeEach() {
|
|||
func (f *Framework) AfterEach() {
|
||||
defer func(kubeClient kubernetes.Interface, ns string) {
|
||||
go func() {
|
||||
defer ginkgo.GinkgoRecover()
|
||||
err := deleteKubeNamespace(kubeClient, ns)
|
||||
assert.Nil(ginkgo.GinkgoT(), err, "deleting namespace %v", f.Namespace)
|
||||
}()
|
||||
|
|
|
@ -88,6 +88,7 @@ var _ = framework.IngressNginxDescribe("[Shutdown] ingress controller", func() {
|
|||
|
||||
result := make(chan int)
|
||||
go func() {
|
||||
defer ginkgo.GinkgoRecover()
|
||||
resp := f.HTTPTestClient().
|
||||
GET("/sleep/70").
|
||||
WithHeader("Host", host).
|
||||
|
@ -133,6 +134,7 @@ var _ = framework.IngressNginxDescribe("[Shutdown] ingress controller", func() {
|
|||
|
||||
result := make(chan int)
|
||||
go func() {
|
||||
defer ginkgo.GinkgoRecover()
|
||||
resp := f.HTTPTestClient().
|
||||
GET("/sleep/150").
|
||||
WithHeader("Host", host).
|
||||
|
|
Loading…
Reference in a new issue