github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-06-25 15:54:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

added panic catch on tests (#265)

Browse Source
This commit is contained in:
RoyUP9 2021-09-06 11:42:47 +03:00 committed by GitHub
parent 073b0b72d3
commit cf231538f4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
acceptanceTests/testsUtils.go
View File

@ -84,10 +84,10 @@ func getDefaultConfigCommandArgs() []string {
} }
func retriesExecute(retriesCount int, executeFunc func() error) error { func retriesExecute(retriesCount int, executeFunc func() error) error {
var lastError error var lastError interface{}
for i := 0; i < retriesCount; i++ { for i := 0; i < retriesCount; i++ {
if err := executeFunc(); err != nil { if err := tryExecuteFunc(executeFunc); err != nil {
lastError = err lastError = err
time.Sleep(1 * time.Second) time.Sleep(1 * time.Second)
@ -100,6 +100,16 @@ func retriesExecute(retriesCount int, executeFunc func() error) error {
return fmt.Errorf("reached max retries count, retries count: %v, last err: %v", retriesCount, lastError) return fmt.Errorf("reached max retries count, retries count: %v, last err: %v", retriesCount, lastError)
} }
func tryExecuteFunc(executeFunc func() error) (err interface{}) {
defer func() {
if panicErr := recover(); panicErr != nil {
err = panicErr
}
}()
return executeFunc()
}
func waitTapPodsReady(apiServerUrl string) error { func waitTapPodsReady(apiServerUrl string) error {
resolvingUrl := fmt.Sprintf("%v/status/tappersCount", apiServerUrl) resolvingUrl := fmt.Sprintf("%v/status/tappersCount", apiServerUrl)
tapPodsReadyFunc := func() error { tapPodsReadyFunc := func() error {