From 75f645e9cfad8b0be96bc4d1ff94ce42d9ccba2e Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Fri, 26 Jan 2024 23:49:05 +0800
Subject: [PATCH] CacheClusterAgent

---
 .../org/redkale/cluster/spi/CacheClusterAgent.java    | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/redkale/cluster/spi/CacheClusterAgent.java b/src/main/java/org/redkale/cluster/spi/CacheClusterAgent.java
index b83151021..c97a453d0 100644
--- a/src/main/java/org/redkale/cluster/spi/CacheClusterAgent.java
+++ b/src/main/java/org/redkale/cluster/spi/CacheClusterAgent.java
@@ -131,6 +131,7 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
     private Runnable newTask() {
         return () -> {
             try {
+                long s = System.currentTimeMillis();
                 localEntrys.values().stream()
                     .filter(e -> !e.canceled)
                     .forEach(this::checkLocalHealth);
@@ -140,8 +141,16 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
                 checkApplicationHealth();
                 checkHttpAddressHealth();
                 loadSncpAddressHealth();
+                long e = System.currentTimeMillis() - s;
+                if (e >= ttls * 9 / 10) {
+                    logger.log(Level.WARNING, getClass().getSimpleName() + ".schedule check-slower cost " + e + " ms");
+                } else if (e >= ttls / 2) {
+                    logger.log(Level.FINE, getClass().getSimpleName() + ".schedule check-slowly cost " + e + " ms");
+                } else {
+                    logger.log(Level.FINEST, getClass().getSimpleName() + ".schedule check cost " + e + " ms");
+                }
             } catch (Exception e) {
-                logger.log(Level.SEVERE, "scheduleAtFixedRate check error", e);
+                logger.log(Level.SEVERE, getClass().getSimpleName() + ".schedule check error", e);
             }
         };
     }