From ec9f3d9c80f5d4ed7dc13a6deb2e63d6119ae6ed Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Fri, 19 Nov 2010 22:58:09 +0000 Subject: [PATCH] add NTS debug logging patch by jbellis; git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@1037076 13f79535-47bb-0310-9956-ffa450edef68 --- .../cassandra/locator/NetworkTopologyStrategy.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java b/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java index 9ac7ca4538..f345cd41ec 100644 --- a/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java +++ b/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java @@ -29,10 +29,13 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.google.common.collect.Multimap; +import org.apache.commons.lang.StringUtils; + import org.apache.cassandra.config.ConfigurationException; import org.apache.cassandra.dht.Token; import org.apache.cassandra.service.*; import org.apache.cassandra.thrift.ConsistencyLevel; +import org.apache.cassandra.utils.FBUtilities; /** * This Replication Strategy takes a property file that gives the intended @@ -62,12 +65,11 @@ public class NetworkTopologyStrategy extends AbstractReplicationStrategy if (configOptions != null) { for (Entry entry : configOptions.entrySet()) - { newDatacenters.put((String) entry.getKey(), Integer.parseInt((String) entry.getValue())); - } } datacenters = Collections.unmodifiableMap(newDatacenters); + logger.debug("Configured datacenter replicas are {}", FBUtilities.toString(datacenters)); } public List calculateNaturalEndpoints(Token searchToken, TokenMetadata tokenMetadata) @@ -116,6 +118,9 @@ public class NetworkTopologyStrategy extends AbstractReplicationStrategy if (dcEndpoints.size() < dcReplicas) throw new IllegalStateException(String.format("datacenter (%s) has no more endpoints, (%s) replicas still needed", dcName, dcReplicas - dcEndpoints.size())); + if (logger.isDebugEnabled()) + logger.debug("{} endpoints in datacenter {} for token {} ", + new Object[] { StringUtils.join(dcEndpoints, ","), dcName, searchToken}); endpoints.addAll(dcEndpoints); }