mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-23 08:08:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

#1741 add heartbeat message

Browse Source
This commit is contained in:
yanhuqing
2020-03-26 15:17:05 +08:00
parent a5fd07bb7d
commit af251b6434
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/heartbeat/MySQLHeartbeat.java
+3 -3
View File
@@ -153,7 +153,7 @@ public class MySQLHeartbeat {
private void setOk() {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("heartbeat setOK");
LOGGER.debug("heartbeat to [" + source.getConfig().getUrl() + "] setOK");
}
switch (status) {
case TIMEOUT_STATUS:
@@ -181,7 +181,7 @@ public class MySQLHeartbeat {
}
private void setError() {
LOGGER.warn("heartbeat setError");
LOGGER.warn("heartbeat to [" + source.getConfig().getUrl() + "] setError");
// should continues check error status
if (detector != null) {
detector.quit();
@@ -199,7 +199,7 @@ public class MySQLHeartbeat {
}
private void setTimeout() {
LOGGER.warn("heartbeat setTimeout");
LOGGER.warn("heartbeat to [" + source.getConfig().getUrl() + "] setTimeout");
this.isChecking.set(false);
status = TIMEOUT_STATUS;
}