mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 12:15:52 +00:00
Merge pull request #78298 from andyzhangx/azure-retry-issue
fix azure retry issue when return 2XX with error
This commit is contained in:
commit
fcc9f166fa
@ -596,8 +596,9 @@ func shouldRetryHTTPRequest(resp *http.Response, err error) bool {
|
||||
return false
|
||||
}
|
||||
|
||||
// processHTTPRetryResponse : return true means stop retry, false means continue retry
|
||||
func (az *Cloud) processHTTPRetryResponse(service *v1.Service, reason string, resp *http.Response, err error) (bool, error) {
|
||||
if resp != nil && isSuccessHTTPResponse(resp) {
|
||||
if err == nil && resp != nil && isSuccessHTTPResponse(resp) {
|
||||
// HTTP 2xx suggests a successful response
|
||||
return true, nil
|
||||
}
|
||||
@ -620,7 +621,7 @@ func (az *Cloud) processHTTPRetryResponse(service *v1.Service, reason string, re
|
||||
}
|
||||
|
||||
func (az *Cloud) processHTTPResponse(service *v1.Service, reason string, resp *http.Response, err error) error {
|
||||
if isSuccessHTTPResponse(resp) {
|
||||
if err == nil && isSuccessHTTPResponse(resp) {
|
||||
// HTTP 2xx suggests a successful response
|
||||
return nil
|
||||
}
|
||||
|
@ -119,6 +119,11 @@ func TestProcessRetryResponse(t *testing.T) {
|
||||
code: http.StatusOK,
|
||||
stop: true,
|
||||
},
|
||||
{
|
||||
code: http.StatusOK,
|
||||
err: fmt.Errorf("some error"),
|
||||
stop: false,
|
||||
},
|
||||
{
|
||||
code: 399,
|
||||
stop: true,
|
||||
|
Loading…
Reference in New Issue
Block a user