private void waitForCuratorToConnect()

in hbase-oss/src/main/java/org/apache/hadoop/hbase/oss/sync/ZKTreeLockManager.java [112:122]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  private void waitForCuratorToConnect() {
    try {
      if (!requireNonNull(curator).blockUntilConnected(30, TimeUnit.SECONDS)) {
        throw new RuntimeException("Failed to connect to ZooKeeper");
      }
    } catch (InterruptedException e) {
      LOG.warn("Interrupted waiting to connect to ZooKeeper", e);
      Thread.currentThread().interrupt();
      return;
    }
  }