From f43f48f33f8cf770e657f72a70c644e255eaf077 Mon Sep 17 00:00:00 2001 From: Nikita Date: Sat, 30 Jan 2016 13:15:38 +0300 Subject: [PATCH] logging fixed --- .../connection/SentinelConnectionManager.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/src/main/java/org/redisson/connection/SentinelConnectionManager.java index b25d19f4c..5e9c0c6cb 100755 --- a/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -99,13 +99,12 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { c.addSlaveAddress(host); slaves.put(host, true); log.debug("slave {} state: {}", host, map); + log.info("slave: {} added", host); if (flags.contains("s_down") || flags.contains("disconnected")) { URI url = URIBuilder.create(host); disconnectedSlaves.add(url); - log.info("slave: {} down", host); - } else { - log.info("slave: {} added", host); + log.warn("slave: {} is down", host); } } break; @@ -265,7 +264,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { RedisClient sentinel = sentinels.remove(addr); if (sentinel != null) { sentinel.shutdownAsync(); - log.info("sentinel: {} has down", addr); + log.warn("sentinel: {} has down", addr); } } else if ("master".equals(parts[0])) { String ip = parts[2]; @@ -275,7 +274,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { if (entry.getFreezeReason() != FreezeReason.MANAGER) { entry.freeze(); String addr = ip + ":" + port; - log.info("master: {} has down", addr); + log.warn("master: {} has down", addr); } } } else { @@ -288,7 +287,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager { slaveDown(singleSlotRange, ip, Integer.valueOf(port), FreezeReason.MANAGER); } - log.info("slave: {}:{} has down", ip, port); + log.warn("slave: {}:{} has down", ip, port); } private void onNodeUp(URI addr, String msg) {