lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CacheClusterAgent

Browse Source
This commit is contained in:
redkale
2024-01-26 23:49:05 +08:00
parent 7bf75b69cd
commit 75f645e9cf
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/org/redkale/cluster/spi/CacheClusterAgent.java
View File

@@ -131,6 +131,7 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
private Runnable newTask() { private Runnable newTask() {
return () -> { return () -> {
try { try {
long s = System.currentTimeMillis();
localEntrys.values().stream() localEntrys.values().stream()
.filter(e -> !e.canceled) .filter(e -> !e.canceled)
.forEach(this::checkLocalHealth); .forEach(this::checkLocalHealth);
@@ -140,8 +141,16 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
checkApplicationHealth(); checkApplicationHealth();
checkHttpAddressHealth(); checkHttpAddressHealth();
loadSncpAddressHealth(); 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) { } catch (Exception e) {
logger.log(Level.SEVERE, "scheduleAtFixedRate check error", e); logger.log(Level.SEVERE, getClass().getSimpleName() + ".schedule check error", e);
} }
}; };
} }