Thread.sleep(500);
                } else {
                    // If delete fails, at least verify copy succeeded
                    log.warn("Could not delete source after copy, but continuing");
                    deleted = true; // Proceed anyway
                }
            }
        }

        // Verify results with fresh context
        CIFSContext checkContext = createFreshContext();

   * @return an immutable set containing those elements, minus duplicates
   */
  public static <E extends Enum<E>> ImmutableSet<E> immutableEnumSet(
      E anElement, E... otherElements) {
    return ImmutableEnumSet.asImmutable(EnumSet.of(anElement, otherElements));
  }

  /**
   * Returns an immutable set instance containing the given enum elements. Internally, the returned

  }

  /**
   * Divides an iterator into unmodifiable sublists of the given size (the final list may be
   * smaller). For example, partitioning an iterator containing {@code [a, b, c, d, e]} with a
   * partition size of 3 yields {@code [[a, b, c], [d, e]]} -- an outer iterator containing two
   * inner lists of three and two elements, all in the original order.
   *
   * <p>The returned lists implement {@link java.util.RandomAccess}.
   *

     *
     * @param username the username for authentication
     * @param password the password for authentication
     * @return an optional containing the authenticated user if successful, empty otherwise
     */
    public OptionalEntity<FessUser> login(final String username, final String password) {

    private static final int UTF8_BOM_SIZE = 3;

    /** Flag indicating whether content should be pruned */
    public boolean prunedContent = true;

    /** Map containing URL conversion rules (regex patterns to replacement strings) */
    protected Map<String, String> convertUrlMap = new LinkedHashMap<>();

    /** Fess configuration instance */
    protected FessConfig fessConfig;

            return buf.toString();
        }).orElse(value);
    }

    /**
     * Gets the set of highlight queries from the current request.
     *
     * @return OptionalThing containing the query set
     */
    protected OptionalThing<Set<String>> getQuerySet() {
        return LaRequestUtil.getOptionalRequest()
                .map(req -> ((Set<String>) req.getAttribute(Constants.HIGHLIGHT_QUERIES)))

// Kernel definition information.

// Returns a serialized KernelList protocol buffer containing KernelDefs for all
// registered kernels.
TF_CAPI_EXPORT extern TF_Buffer* TF_GetAllRegisteredKernels(TF_Status* status);

// Returns a serialized KernelList protocol buffer containing KernelDefs for all
// kernels registered for the operation named `name`.

          throw new ExecutionException(t);
        }
      }
    };
  }

  /**
   * Creates a new {@code ListenableFuture} whose value is a list containing the values of all its
   * input futures, if all succeed.
   *
   * <p>The list of results is in the same order as the input list.
   *

      return multimap.containsKey(key);
    }

    @Override
    public void clear() {
      multimap.clear();
    }
  }

  /**
   * Returns a multimap containing the mappings in {@code unfiltered} whose keys satisfy a
   * predicate. The returned multimap is a live view of {@code unfiltered}; changes to one affect
   * the other.
   *

      return multimap.containsKey(key);
    }

    @Override
    public void clear() {
      multimap.clear();
    }
  }

  /**
   * Returns a multimap containing the mappings in {@code unfiltered} whose keys satisfy a
   * predicate. The returned multimap is a live view of {@code unfiltered}; changes to one affect
   * the other.
   *