ClientBase.java 文件源码

/**
 * Return true if any of the states is achieved
 */
public static boolean waitForServerState(QuorumPeer qp, int timeout,
        String... serverStates) {
    long start = Time.currentElapsedTime();
    while (true) {
        try {
            Thread.sleep(250);
        } catch (InterruptedException e) {
            // ignore
        }
        for (String state : serverStates) {
            if (qp.getServerState().equals(state)) {
                return true;
            }
        }
        if (Time.currentElapsedTime() > start + timeout) {
            return false;
        }
    }
}