Skip to content

Commit 939da5e

Browse files
authored
Merge pull request kubernetes#86078 from feiskyer/peni/fix-err-message
Make error message and service event message more clear
2 parents 30a5db1 + 96084a5 commit 939da5e

File tree

1 file changed

+15
-11
lines changed

1 file changed

+15
-11
lines changed

staging/src/k8s.io/legacy-cloud-providers/azure/azure_backoff.go

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -747,13 +747,15 @@ func (az *Cloud) processHTTPRetryResponse(service *v1.Service, reason string, re
747747
}
748748

749749
if shouldRetryHTTPRequest(resp, err) {
750+
message := "processHTTPRetryResponse: backoff failure, will retry"
751+
if resp != nil {
752+
message = fmt.Sprintf("%s, HTTP response: %d", message, resp.StatusCode)
753+
}
750754
if err != nil {
751-
az.Event(service, v1.EventTypeWarning, reason, err.Error())
752-
klog.Errorf("processHTTPRetryResponse: backoff failure, will retry, err=%v", err)
753-
} else {
754-
az.Event(service, v1.EventTypeWarning, reason, fmt.Sprintf("Azure HTTP response %d", resp.StatusCode))
755-
klog.Errorf("processHTTPRetryResponse: backoff failure, will retry, HTTP response=%d", resp.StatusCode)
755+
message = fmt.Sprintf("%s, error: %v", message, err)
756756
}
757+
az.Event(service, v1.EventTypeWarning, reason, message)
758+
klog.Error(message)
757759

758760
// suppress the error object so that backoff process continues
759761
return false, nil
@@ -769,15 +771,17 @@ func (az *Cloud) processHTTPResponse(service *v1.Service, reason string, resp *h
769771
return nil
770772
}
771773

774+
message := "processHTTPResponse failed"
775+
if resp != nil {
776+
message = fmt.Sprintf("%s, HTTP response: %d", message, resp.StatusCode)
777+
}
772778
if err != nil {
773-
az.Event(service, v1.EventTypeWarning, reason, err.Error())
774-
klog.Errorf("processHTTPRetryResponse failure with err: %v", err)
775-
} else if resp != nil {
776-
az.Event(service, v1.EventTypeWarning, reason, fmt.Sprintf("Azure HTTP response %d", resp.StatusCode))
777-
klog.Errorf("processHTTPRetryResponse failure with HTTP response %q", resp.Status)
779+
message = fmt.Sprintf("%s, error: %v", message, err)
778780
}
781+
az.Event(service, v1.EventTypeWarning, reason, message)
782+
klog.Error(message)
779783

780-
return err
784+
return fmt.Errorf(message)
781785
}
782786

783787
func (cfg *Config) shouldOmitCloudProviderBackoff() bool {

0 commit comments

Comments
 (0)