assertTrue(ex instanceof CIFSException, "Should be a CIFSException subtype");

        // Assert throwing/catching behavior with assertThrows
        SMBProtocolDecodingException thrown = assertThrows(SMBProtocolDecodingException.class, () -> {
            throw new SMBProtocolDecodingException();
        }, "Should be throwable via assertThrows");

    for (queue in TaskRunner.INSTANCE.activeQueues()) {
      // We wait at most 1 second, so we don't ever turn multiple lost threads into
      // a test timeout failure.
      val waitTime = (entryTime + 1_000_000_000L - System.nanoTime())
      if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) {
        TaskRunner.INSTANCE.withLock {
          TaskRunner.INSTANCE.cancelAll()
        }

  /**
   * Compares the specified object with this instance for equality. Returns {@code true} if the
   * given object is also a {@code MapDifference} and the values returned by the {@link
   * #entriesOnlyOnLeft()}, {@link #entriesOnlyOnRight()}, {@link #entriesInCommon()} and {@link
   * #entriesDiffering()} of the two instances are equal.
   */
  @Override
  boolean equals(@Nullable Object object);

  /**

     * @param index The index name.
     * @return This builder instance.
     */
    public SuggestRequestBuilder setIndex(final String index) {
        request.setIndex(index);
        return this;
    }

    /**
     * Sets the size of results for the request.
     * @param size The size.
     * @return This builder instance.
     */
    public SuggestRequestBuilder setSize(final int size) {

 * This class provides factory methods for creating instances of extensible enums
 * such as Language, PathScope, and ProjectScope.
 *
 * @since 4.0.0
 */
abstract class ExtensibleEnums {

    /**
     * Creates a new Language instance with the specified ID.
     *
     * @param id the identifier for the language
     * @return a new Language instance
     */
    static Language language(String id) {

be same across the federated deployment, i.e. all the MinIO instances within a federated deployment should use same
etcd back-end.

#### MINIO_DOMAIN

This is the top level domain name used for the federated setup. This domain name should ideally resolve to a load-balancer
running in front of all the federated MinIO instances. The domain name is used to create sub domain entries to etcd. For

            logger.debug("Initialize {}", this.getClass().getSimpleName());
        }
        load();
    }

    /**
     * Returns a list of available KeyMatch instances.
     *
     * @return A list of KeyMatch instances.
     */
    public List<KeyMatch> getAvailableKeyMatchList() {
        return ComponentUtil.getComponent(KeyMatchBhv.class).selectList(cb -> {
            cb.query().matchAll();

echo -n "Setup certs for MinIO instances ..."
wget -O certgen https://github.com/minio/certgen/releases/latest/download/certgen-linux-amd64 && chmod +x certgen
./certgen --host localhost
mkdir -p /tmp/certs
mv public.crt /tmp/certs || sudo mv public.crt /tmp/certs
mv private.key /tmp/certs || sudo mv private.key /tmp/certs
echo "done"

# Start MinIO instances
echo -n "Starting MinIO instances ..."

     * @return This builder instance.
     */
    public SuggesterBuilder settings(final SuggestSettings settings) {
        this.settings = settings;
        settingsBuilder = null;
        return this;
    }

    /**
     * Sets the suggest settings builder.
     * @param settingsBuilder The suggest settings builder.
     * @return This builder instance.
     */

        Collection<E> collection) {
      if (collection instanceof NavigableSet) {
        return Sets.unmodifiableNavigableSet((NavigableSet<E>) collection);
      } else if (collection instanceof SortedSet) {
        return Collections.unmodifiableSortedSet((SortedSet<E>) collection);
      } else if (collection instanceof Set) {
        return Collections.unmodifiableSet((Set<E>) collection);