🔨 Remove interrupt errors from responses

This commit is contained in:
Aykhan Shahsuvarov 2024-09-10 03:35:43 +04:00
parent 7296646428
commit 82bf31182f

View File

@ -210,18 +210,20 @@ func sendRequest(
} }
func() { func() {
defer func() { increase <- 1 }()
startTime := time.Now() startTime := time.Now()
response, err := clientDo(ctx, request) response, err := clientDo(ctx, request)
completedTime := time.Since(startTime) completedTime := time.Since(startTime)
if err != nil { if err != nil {
if err == customerrors.ErrInterrupt {
return
}
*responseData = append(*responseData, Response{ *responseData = append(*responseData, Response{
StatusCode: 0, StatusCode: 0,
Error: err, Error: err,
Time: completedTime, Time: completedTime,
}) })
increase <- 1
return return
} }
defer fasthttp.ReleaseResponse(response) defer fasthttp.ReleaseResponse(response)
@ -231,6 +233,7 @@ func sendRequest(
Error: nil, Error: nil,
Time: completedTime, Time: completedTime,
}) })
increase <- 1
}() }()
} }
} }