Skip to content
This repository has been archived by the owner on Feb 27, 2023. It is now read-only.

Commit

Permalink
reset to the results of adding the pool to the connection manager. Th…
Browse files Browse the repository at this point in the history
…is could cause a pretty ugly issue where the host would just disappear if there was a failure adding it back after the successful test
  • Loading branch information
zznate committed May 20, 2011
1 parent 9251230 commit 7f42416
Showing 1 changed file with 1 addition and 5 deletions.
Expand Up @@ -96,8 +96,7 @@ public void run() {
boolean reconnected = verifyConnection(cassandraHost);
log.info("Downed Host retry status {} with host: {}", reconnected, cassandraHost.getName());
if ( reconnected ) {
//cassandraClientPool.getCluster().addHost(cassandraHost, true);
connectionManager.addCassandraHost(cassandraHost);
reconnected = connectionManager.addCassandraHost(cassandraHost);
}
if ( !reconnected && cassandraHost != null ) {
downedHostQueue.add(cassandraHost);
Expand Down Expand Up @@ -128,7 +127,4 @@ private boolean verifyConnection(CassandraHost cassandraHost) {

}

// TODO create callable to handle checking

// perhaps wrap CassandraHost and add a lastRetryTime?
}

0 comments on commit 7f42416

Please sign in to comment.