fix callcomplete: reset consecutiveErrors when 4xx

EMCECS · Sep 15, 2022 · 71434dc · 71434dc
1 parent a5ccbf2
commit 71434dc
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 14 deletions.
diff --git a/smart-client-core/src/main/java/com/emc/rest/smart/SmartClientException.java b/smart-client-core/src/main/java/com/emc/rest/smart/SmartClientException.java
@@ -2,20 +2,15 @@
 
 public class SmartClientException extends RuntimeException {
 
+    private ErrorType errorType = ErrorType.Unknown;
+
     public SmartClientException(String message) {
         super(message);
     }
 
     public SmartClientException(String message, Throwable cause) {
         super(message, cause);
     }
-
-    public enum ErrorType {
-        Client, // 4xx
-        Service, // 5xx
-        Unknown
-    }
-
     public ErrorType getErrorType() {
         return errorType;
     }
@@ -24,6 +19,14 @@ public void setErrorType(ErrorType errorType) {
         this.errorType = errorType;
     }
 
-    private ErrorType errorType = ErrorType.Unknown;
+    public enum ErrorType {
+        Client, // 4xx
+        Service, // 5xx
+        Unknown
+    }
+
+    public boolean isServerError() {
+        return this.getErrorType().equals(SmartClientException.ErrorType.Service);
+    }
 
 }
diff --git a/smart-client-jersey/src/main/java/com/emc/rest/smart/jersey/SmartFilter.java b/smart-client-jersey/src/main/java/com/emc/rest/smart/jersey/SmartFilter.java
@@ -75,12 +75,10 @@ public ClientResponse handle(ClientRequest request) throws ClientHandlerExceptio
 
             return response;
         } catch (RuntimeException e) {
-
-            if (e instanceof SmartClientException && !((SmartClientException)e).getErrorType().equals(SmartClientException.ErrorType.Client)) {
-                // capture requests stats (error)
-                host.callComplete(true);
-                host.connectionClosed();
-            }
+            // capture requests stats (error)
+            boolean isServerError = e instanceof SmartClientException && ((SmartClientException) e).isServerError();
+            host.callComplete(isServerError);
+            host.connectionClosed();
 
             throw e;
         }