public synchronized void close()

in modules/core/src/main/java/org/apache/fluo/core/impl/SharedResources.java [175:222]

44 lines of code
10 McCabe index (conditional complexity)


  public synchronized void close() {
    if (isClosed) {
      return;
    }

    isClosed = true;

    if (commitManager != null) {
      commitManager.close();
    }
    asyncCommitExecutor.shutdownNow();
    try {
      asyncCommitExecutor.awaitTermination(5, TimeUnit.SECONDS);
    } catch (InterruptedException e1) {
      throw new RuntimeException(e1);
    }

    syncCommitExecutor.shutdownNow();
    try {
      syncCommitExecutor.awaitTermination(5, TimeUnit.SECONDS);
    } catch (InterruptedException e1) {
      throw new RuntimeException(e1);
    }

    if (tnode != null) {
      tnode.close();
    }
    if (tsTracker != null) {
      tsTracker.close();
    }
    if (transactorCache != null) {
      transactorCache.close();
    }
    if (oracleClient != null) {
      oracleClient.close();
    }
    acw.close();
    cw.close();
    bulkAcw.close();
    bulkCw.close();
    sbw.close();
    try {
      bw.close();
    } catch (MutationsRejectedException e) {
      throw new RuntimeException(e);
    }
    curator.close();
  }