diff --git a/core/src/main/java/com/qq/tars/client/cluster/ServantInvokerAliveStat.java b/core/src/main/java/com/qq/tars/client/cluster/ServantInvokerAliveStat.java index c9aee4ec..020fa68e 100644 --- a/core/src/main/java/com/qq/tars/client/cluster/ServantInvokerAliveStat.java +++ b/core/src/main/java/com/qq/tars/client/cluster/ServantInvokerAliveStat.java @@ -90,6 +90,7 @@ public synchronized void onCallFinished(int ret, ServantProxyConfig config) { double radio = div(timeoutCount, totalCount, 2); if (radio > config.getFrequenceFailRadio()) { alive = false; + lastRetryTime = System.currentTimeMillis(); ClientLogger.getLogger().info(identity + "|alive=false|radio=" + radio + "|" + toString()); } } @@ -97,6 +98,7 @@ public synchronized void onCallFinished(int ret, ServantProxyConfig config) { if (alive) { if (frequenceFailInvoke >= config.getFrequenceFailInvoke() && (frequenceFailInvoke_startTime + 5000) > System.currentTimeMillis()) { alive = false; + lastRetryTime = System.currentTimeMillis(); ClientLogger.getLogger().info(identity + "|alive=false|frequenceFailInvoke=" + frequenceFailInvoke + "|" + toString()); } } @@ -104,6 +106,7 @@ public synchronized void onCallFinished(int ret, ServantProxyConfig config) { if (alive) { if (netConnectTimeout) { alive = false; + lastRetryTime = System.currentTimeMillis(); ClientLogger.getLogger().info(identity + "|alive=false|netConnectTimeout" + "|" + toString()); } }