if (getType() == TYPE_NAMED_PIPE) { // try opening the pipe for reading?
            return true;
        }
        return exists(); // try opening and catch sharing violation?
    }

    @Override
    public boolean canWrite() throws SmbException {
        if (getType() == TYPE_NAMED_PIPE) { // try opening the pipe for writing?
            return true;
        }

        }

        try {
            if (LogStream.level >= 3) {
                log.println("doConnect: " + addr);
            }

            tree.treeConnect(null, null);
        } catch (final SmbAuthException sae) {
            NtlmPasswordAuthentication a;
            SmbSession ssn;

            if (share == null) { // IPC$ - try "anonymous" credentials

     */
    public long getDocumentCount(final String indexName) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        try {
            client.admin().indices().prepareRefresh(indexName).execute().actionGet(fessConfig.getIndexIndicesTimeout());
            try (CurlResponse response = ComponentUtil.getCurlHelper().get("/" + indexName + "/_count").execute()) {
                if (response.getHttpStatusCode() == 200) {

        if (value == null) {
          misses++;
          keysToLoad.add(key);
        } else {
          hits++;
        }
      }
    }

    try {
      if (!keysToLoad.isEmpty()) {
        try {
          Map<K, V> newEntries = loadAll(unmodifiableSet(keysToLoad), defaultLoader);
          for (K key : keysToLoad) {
            V value = newEntries.get(key);

        if (value == null) {
          misses++;
          keysToLoad.add(key);
        } else {
          hits++;
        }
      }
    }

    try {
      if (!keysToLoad.isEmpty()) {
        try {
          Map<K, V> newEntries = loadAll(unmodifiableSet(keysToLoad), defaultLoader);
          for (K key : keysToLoad) {
            V value = newEntries.get(key);

   */
  @CanIgnoreReturnValue
  public boolean cancel(boolean mayInterruptIfRunning) {
    try {
      return state.cancel(mayInterruptIfRunning);
    } finally {
      reachabilityFence(this);
    }
  }

  private <U extends @Nullable Object> ClosingFuture<U> derive(FluentFuture<U> future) {
    try {
      ClosingFuture<U> derived = new ClosingFuture<>(future);

    CountDownLatch gotException = new CountDownLatch(1);
    AsyncFunction<String, String> function =
        unused -> {
          inFunction.countDown();
          try {
            shouldCompleteFunction.await();
          } catch (InterruptedException expected) {
            gotException.countDown();
            throw expected;
          }
          return immediateFuture("a");

    CountDownLatch gotException = new CountDownLatch(1);
    AsyncFunction<String, String> function =
        unused -> {
          inFunction.countDown();
          try {
            shouldCompleteFunction.await();
          } catch (InterruptedException expected) {
            gotException.countDown();
            throw expected;
          }
          return immediateFuture("a");

    new Thread() {
      @Override
      public void run() {
        try {
          map.get(one, loader);
        } catch (ExecutionException e) {
          throw new RuntimeException(e);
        }
        doneSignal.countDown();
      }
    }.start();

    try {
      computingSignal.await();
    } catch (InterruptedException e) {
      throw new RuntimeException(e);

    new Thread() {
      @Override
      public void run() {
        try {
          map.get(one, loader);
        } catch (ExecutionException e) {
          throw new RuntimeException(e);
        }
        doneSignal.countDown();
      }
    }.start();

    try {
      computingSignal.await();
    } catch (InterruptedException e) {
      throw new RuntimeException(e);