Adds debug logs

Netflix · Apr 18, 2023 · 85b00d5 · 85b00d5
1 parent 0552980
commit 85b00d5
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/...-core/src/main/java/com/netflix/dyno/connectionpool/impl/lb/AbstractTokenMapSupplier.java b/...-core/src/main/java/com/netflix/dyno/connectionpool/impl/lb/AbstractTokenMapSupplier.java
@@ -141,7 +141,7 @@ public List<HostToken> getTokens(Set<Host> activeHosts) {
         // hence trying them all
         Set<HostToken> allTokens = new HashSet<HostToken>();
         Set<Host> remainingHosts = new HashSet<>(activeHosts);
-
+        Logger.info("[DynoConnectDebug] Number of active hosts = " + activeHosts.size());
         for (Host host : activeHosts) {
             try {
                 List<HostToken> hostTokens = parseTokenListFromJson(getTopologyJsonPayload((host.getHostAddress())));

diff --git a/.../main/java/com/netflix/dyno/connectionpool/impl/lb/HttpEndpointBasedTokenMapSupplier.java b/.../main/java/com/netflix/dyno/connectionpool/impl/lb/HttpEndpointBasedTokenMapSupplier.java
@@ -70,6 +70,7 @@ public HttpEndpointBasedTokenMapSupplier(String url, int port) {
     @Override
     public String getTopologyJsonPayload(String hostname) {
         try {
+            Logger.info("[DynoConnectDebug] Hostname is = " + hostname);
             return getResponseViaHttp(hostname);
         } catch (Exception e) {
             throw new RuntimeException(e);

diff --git a/dyno-jedis/src/main/java/com/netflix/dyno/jedis/DynoJedisUtils.java b/dyno-jedis/src/main/java/com/netflix/dyno/jedis/DynoJedisUtils.java
@@ -119,6 +119,7 @@ private static void setHashtagConnectionPool(HostSupplier hostSupplier, Connecti
         List<Host> hosts = (List<Host>) hostSupplier.getHosts();
         Collections.sort(hosts);
 
+        logger.info("[DynoConnectDebug] Got number of hosts = " + hosts.size());
         // Take the token map supplier (aka the token topology from
         // Dynomite)
         TokenMapSupplier tokenMapSupplier = config.getTokenSupplier();