private boolean isClusterStateDone(String state,boolean isVersioned,String svcName) throws Exception {
  if (clusterNodeCount == 0) {
    throw new IllegalStateException("node count not set");
  }
  List<Configuration> configs=coordinator.queryAllConfiguration(coordinator.getSiteId(),coordinator.getVersionedDbConfigPath(svcName,getDbsvcVersion(isVersioned)));
  List<Configuration> leftoverConfig=coordinator.queryAllConfiguration(coordinator.getVersionedDbConfigPath(svcName,getDbsvcVersion(isVersioned)));
  configs.addAll(leftoverConfig);
  Set<String> qualifiedConfigs=new HashSet<String>();
  for (int i=0; i < configs.size(); i++) {
    Configuration config=configs.get(i);
    String value=config.getConfig(state);
    if (value != null && Boolean.parseBoolean(value)) {
      qualifiedConfigs.add(config.getId());
    }
  }
  return (qualifiedConfigs.size() == clusterNodeCount);
}

private boolean isClusterStateDone ( String state , boolean isVersioned , String svcName ) throws Exception { if ( clusterNodeCount == 0 ) { throw new IllegalStateException ( "node count not set" ) ; } List < Configuration > configs = coordinator . queryAllConfiguration ( coordinator . getSiteId ( ) , coordinator . getVersionedDbConfigPath ( svcName , getDbsvcVersion ( isVersioned ) ) ) ; List < Configuration > leftoverConfig = coordinator . queryAllConfiguration ( coordinator . getVersionedDbConfigPath ( svcName , getDbsvcVersion ( isVersioned ) ) ) ; configs . addAll ( leftoverConfig ) ; Set < String > qualifiedConfigs = new HashSet < String > ( ) ; for ( int i = 0 ; i < configs . size ( ) ; i ++ ) { Configuration config = configs . get ( i ) ; String value = config . getConfig ( state ) ; if ( value != null && Boolean . parseBoolean ( value ) ) { qualifiedConfigs . add ( config . getId ( ) ) ; } } return ( qualifiedConfigs . size ( ) == clusterNodeCount ) ; }
checks to see if the cassandra cluster finished entering a certain state
