Java 类org.apache.hadoop.hbase.zookeeper.ZooKeeperNodeTracker 实例源码

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 *
 * @param tracker znode tracker to use
 * @throws IOException          any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking if the region server
 * is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker) throws IOException,
    InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 *
 * @param tracker znode tracker to use
 * @throws IOException          any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
        throws IOException, InterruptedException {
    while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
        if (this.stopped) {
            throw new IOException("Received the shutdown message while waiting.");
        }
    }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  if (false == tracker.checkIfBaseNodeAvailable()) {
    String errorMsg = "Check the value configured in 'zookeeper.znode.parent'. "
        + "There could be a mismatch with the one configured in the master.";
    LOG.error(errorMsg);
    abort(errorMsg);
  }
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
    throws IOException, InterruptedException {
  while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
    if (this.stopped) {
      throw new IOException("Received the shutdown message while waiting.");
    }
  }
}