natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Jonathan Ellis 2010-11-19 22:58:09 +00:00
parent 19879f0cbf
commit ec9f3d9c80
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java
View File

@ -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<InetAddress> 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);
}