public void pingComplete(String name, int status, long time) { if (status == PingHelper.SUCCESS) { newState(name, stateOnSuccess); if (!isLocal(name)) { pingStats.enter(time); if (pingStats.getCount() == 10 || pingStats.getCount()%25 == 0) { setPingTimeout();
public void pingComplete(PingResult[] pingResults) {  String deadNodesFromModel[] = model.listEntries(model.NODE, DEAD); for (int i = 0; i < deadNodesFromModel.length; i++) { deadNodes.add(deadNodesFromModel[i]); } for (int i = 0; i < pingResults.length; i++) { if (pingResults[i].getStatus() == PingResult.FAIL) { deadNodes.add(pingResults[i].getName()); logger.info("Found new DEAD node during LoadBalance node check: " + pingResults[i].getName()); model.setCurrentState(pingResults[i].getName(), DEAD); } } List excludedNodes = new ArrayList(getExcludedNodes());  if (!newNodes.isEmpty()) { for (Iterator it = newNodes.iterator(); it.hasNext(); ) { String newNode = (String)it.next(); if (!isVacantNode(newNode) || excludedNodes.contains(newNode) || deadNodes.contains(newNode)) { it.remove();
      public void pingComplete(String name, int status, long time) {        if (status == PingHelper.SUCCESS) {          newState(name, stateOnSuccess);          if (!isLocal(name)) {            pingStats.enter(time);            if (pingStats.getCount() == 10 || pingStats.getCount()%25 == 0) {              setPingTimeout();            }          }        } else {          logger.info("Ping:" +                       " agent=" + name +                       " state=" + stateName(model.getCurrentState(name)) +                       " timeout=" + pingTimeout +                       " actual=" + time +                       " result=" + (status == PingHelper.SUCCESS ? "SUCCESS" : "FAIL") +                       (status == PingHelper.SUCCESS ? "" : " newState=" + stateName(stateOnFail)));          newState(name, stateOnFail);        }      }