[Amdatu-commits] SVN r604 - sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service

[subvers...@amdatu.org]

Author: ivol37 at gmail.com
Date: Wed Jan 12 15:47:24 2011
New Revision: 604

Log:


Modified:
   
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java

Modified: 
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
==============================================================================
--- 
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
      (original)
+++ 
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
      Wed Jan 12 15:47:24 2011
@@ -268,7 +268,7 @@
 
         Iface cs = m_daemon.getCassandraServer();
         cs.set_keyspace(keyspace);
-        List<KeySlice> keySlices = cs.get_range_slices(columnParent, p, range, 
ConsistencyLevel.ONE);
+        List<KeySlice> keySlices = cs.get_range_slices(columnParent, p, range, 
ConsistencyLevel.ALL);
 
         List<String> keys = new ArrayList<String>();
         for (KeySlice keySlice : keySlices) {
@@ -286,9 +286,9 @@
     private String inetAddressToString(InetAddress address) {
         String result = address.getHostAddress();
         if (!address.getCanonicalHostName().equals(address.getHostAddress())) {
-            result += "(" + address.getCanonicalHostName() + ")";
+            result += " (" + address.getCanonicalHostName() + ")";
         } else if (!address.getHostName().equals(address.getHostAddress())) {
-            result += "(" + address.getHostName() + ")";
+            result += " (" + address.getHostName() + ")";
         }
         return result;
     }