private InterProcessReadWriteLock get()

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

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

  private InterProcessReadWriteLock get(Path path) {
    return lockCache.computeIfAbsent(path, s -> {
      String zkPath = new Path(path, LOCK_SUB_ZNODE).toString();
      try {
        ZKPaths.mkdirs(curator.getZookeeperClient().getZooKeeper(), zkPath,
            true);
      } catch (KeeperException.NodeExistsException e) {
        // Ignore
      } catch (Exception e) {
        throw new RuntimeException(e);
      }
      return new InterProcessReadWriteLock(curator, zkPath);
    });
  }