added back some attribs to CassandraClientMonitor

hector-client · Nov 15, 2010 · e8ddfc1 · e8ddfc1
1 parent d1a699d
commit e8ddfc1
Showing 1 changed file with 5 additions and 20 deletions.
diff --git a/src/main/java/me/prettyprint/cassandra/service/CassandraClientMonitor.java b/src/main/java/me/prettyprint/cassandra/service/CassandraClientMonitor.java
@@ -89,12 +89,7 @@ public long getWriteFail() {
 
   public void updateKnownHosts() throws HectorTransportException {
    log.info("Updating all known cassandra hosts on all clients");
-   /*
-    TODO is this a noop given retry service?
-   for (ConcurrentHClientPool pool: pools) {
-     pool.updateKnownHosts();
-   }
-   */
+
   }
 
 
@@ -105,7 +100,7 @@ public long getNumPoolExhaustedEventCount() {
 
   public Set<String> getExhaustedPoolNames() {
     Set<String> ret = new HashSet<String>();
-    // TODO connectionManager...
+
     return ret;
   }
 
@@ -139,9 +134,7 @@ public int getNumIdleConnections() {
 
 
   public int getNumPools() {
-    int ret = 0;
-    // TODO connectionManager....
-    return ret;
+    return connectionManager.getHosts().size();
   }
 
 
@@ -153,9 +146,7 @@ public Set<String> getPoolNames() {
 
 
   public Set<CassandraHost> getKnownHosts() {
-    Set<CassandraHost> ret = new HashSet<CassandraHost>();
-    // TODO connectionManager...
-    return ret;
+    return connectionManager.getHosts();
   }
 
 
@@ -167,13 +158,7 @@ public long getRecoverableTransportExceptionCount() {
   public long getRecoverableErrorCount() {
     return getRecoverableTimedOutCount() + getRecoverableTransportExceptionCount() +
         getRecoverableUnavailableCount() + getRecoverableLoadBalancedConnectErrors();
-  }
-
-  /*
-  public void addPool(CassandraClientPool pool) {
-    // TODO no longer germain?
-  }
-  */
+  }  
 
 
   public long getRecoverableLoadBalancedConnectErrors() {