From 990595a5401f482527899d5fffe6c4f05f3fc4a3 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Fri, 15 Nov 2019 12:07:09 +0300
Subject: [PATCH] added logging to DNSMonitor class

---
 .../java/org/redisson/connection/DNSMonitor.java     | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/connection/DNSMonitor.java b/redisson/src/main/java/org/redisson/connection/DNSMonitor.java
index fe5236522..2560d1833 100644
--- a/redisson/src/main/java/org/redisson/connection/DNSMonitor.java
+++ b/redisson/src/main/java/org/redisson/connection/DNSMonitor.java
@@ -98,6 +98,8 @@ public class DNSMonitor {
 
     private void monitorMasters(AtomicInteger counter) {
         for (Entry<RedisURI, InetSocketAddress> entry : masters.entrySet()) {
+            log.debug("Request sent to resolve ip address for master host: {}", entry.getKey().getHost());
+
             Future<InetSocketAddress> resolveFuture = resolver.resolve(InetSocketAddress.createUnresolved(entry.getKey().getHost(), entry.getKey().getPort()));
             resolveFuture.addListener(new FutureListener<InetSocketAddress>() {
                 @Override
@@ -110,7 +112,9 @@ public class DNSMonitor {
                         log.error("Unable to resolve " + entry.getKey().getHost(), future.cause());
                         return;
                     }
-                    
+
+                    log.debug("Resolved ip: {} for master host: {}", future.getNow().getAddress(), entry.getKey().getHost());
+
                     InetSocketAddress currentMasterAddr = entry.getValue();
                     InetSocketAddress newMasterAddr = future.getNow();
                     if (!newMasterAddr.getAddress().equals(currentMasterAddr.getAddress())) {
@@ -135,6 +139,8 @@ public class DNSMonitor {
 
     private void monitorSlaves(AtomicInteger counter) {
         for (Entry<RedisURI, InetSocketAddress> entry : slaves.entrySet()) {
+            log.debug("Request sent to resolve ip address for slave host: {}", entry.getKey().getHost());
+
             Future<InetSocketAddress> resolveFuture = resolver.resolve(InetSocketAddress.createUnresolved(entry.getKey().getHost(), entry.getKey().getPort()));
             resolveFuture.addListener(new FutureListener<InetSocketAddress>() {
                 @Override
@@ -147,7 +153,9 @@ public class DNSMonitor {
                         log.error("Unable to resolve " + entry.getKey().getHost(), future.cause());
                         return;
                     }
-                    
+
+                    log.debug("Resolved ip: {} for slave host: {}", future.getNow().getAddress(), entry.getKey().getHost());
+
                     InetSocketAddress currentSlaveAddr = entry.getValue();
                     InetSocketAddress newSlaveAddr = future.getNow();
                     if (!newSlaveAddr.getAddress().equals(currentSlaveAddr.getAddress())) {