Merge pull request #1152 from elandau/improve_logging

Improved logging
Netflix · Nov 12, 2018 · 44bf4ca · 44bf4ca
2 parents 12712a9 + 65567e4
commit 44bf4ca
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/eureka-client/src/main/java/com/netflix/discovery/TimedSupervisorTask.java b/eureka-client/src/main/java/com/netflix/discovery/TimedSupervisorTask.java
@@ -25,6 +25,7 @@
 public class TimedSupervisorTask extends TimerTask {
     private static final Logger logger = LoggerFactory.getLogger(TimedSupervisorTask.class);
 
+    private final Counter successCounter;
     private final Counter timeoutCounter;
     private final Counter rejectedCounter;
     private final Counter throwableCounter;
@@ -48,6 +49,7 @@ public TimedSupervisorTask(String name, ScheduledExecutorService scheduler, Thre
         this.maxDelay = timeoutMillis * expBackOffBound;
 
         // Initialize the counters and register.
+        successCounter = Monitors.newCounter("success");
         timeoutCounter = Monitors.newCounter("timeouts");
         rejectedCounter = Monitors.newCounter("rejectedExecutions");
         throwableCounter = Monitors.newCounter("throwables");
@@ -64,6 +66,7 @@ public void run() {
             future.get(timeoutMillis, TimeUnit.MILLISECONDS);  // block until done or timeout
             delay.set(timeoutMillis);
             threadPoolLevelGauge.set((long) executor.getActiveCount());
+            successCounter.increment();
         } catch (TimeoutException e) {
             logger.warn("task supervisor timed out", e);
             timeoutCounter.increment();

diff --git a/eureka-client/src/main/java/com/netflix/discovery/provider/DiscoveryJerseyProvider.java b/eureka-client/src/main/java/com/netflix/discovery/provider/DiscoveryJerseyProvider.java
@@ -104,10 +104,10 @@ public Object readFrom(Class serializableClass, Type type,
         } catch (Throwable e) {
             if (e instanceof Error) { // See issue: https://github.com/Netflix/eureka/issues/72 on why we catch Error here.
                 closeInputOnError(inputStream);
-                throw new WebApplicationException(createErrorReply(500, e, mediaType));
+                throw new WebApplicationException(e, createErrorReply(500, e, mediaType));
             }
             LOGGER.debug("Cannot parse request body", e);
-            throw new WebApplicationException(createErrorReply(400, "cannot parse request body", mediaType));
+            throw new WebApplicationException(e, createErrorReply(400, "cannot parse request body", mediaType));
         }
     }
 

diff --git a/...in/java/com/netflix/discovery/shared/transport/decorator/RedirectingEurekaHttpClient.java b/...in/java/com/netflix/discovery/shared/transport/decorator/RedirectingEurekaHttpClient.java
@@ -80,15 +80,15 @@ protected <R> EurekaHttpResponse<R> execute(RequestExecutor<R> requestExecutor)
                 TransportUtils.shutdown(delegateRef.getAndSet(currentEurekaClientRef.get()));
                 return response;
             } catch (Exception e) {
-                logger.error("Request execution error", e);
+                logger.error("Request execution error. endpoint={}", serviceEndpoint, e);
                 TransportUtils.shutdown(currentEurekaClientRef.get());
                 throw e;
             }
         } else {
             try {
                 return requestExecutor.execute(currentEurekaClient);
             } catch (Exception e) {
-                logger.error("Request execution error", e);
+                logger.error("Request execution error. endpoint={}", serviceEndpoint, e);
                 delegateRef.compareAndSet(currentEurekaClient, null);
                 currentEurekaClient.shutdown();
                 throw e;