/**
     * List of listeners for connection events.
     */
    protected List<OnConnectListener> onConnectListenerList = new CopyOnWriteArrayList<>();

    /**
     * Flag indicating whether the client is connected.
     */
    private volatile boolean connected;

    /**
     * Scroll for delete operations.
     */

            relativePath = DEFAULT_PARENT_RELATIVE_PATH; // Maven default
        }

        // Only infer artifactId if relativePath is the default and we have multiple POMs
        // indicating this is likely a multi-module project
        return DEFAULT_PARENT_RELATIVE_PATH.equals(relativePath) && pomMap.size() > 1;
    }

    /**

    /**
     * AES-256-GCM cipher identifier for SMB3.1.1 encryption (future support)
     */
    public static final int CIPHER_AES_256_GCM = 0x0004;

    /**
     * Transform header flag indicating the message is encrypted
     */
    public static final int TRANSFORM_FLAG_ENCRYPTED = 0x0001;

    /**
     * Create encryption context
     *
     * @param cipherId

will be considered the “Licensor.” The text of the Creative Commons
public licenses is dedicated to the public domain under the CC0 Public
Domain Dedication. Except for the limited purpose of indicating that
material is shared under a Creative Commons public license or as
otherwise permitted by the Creative Commons policies published at
creativecommons.org/policies, Creative Commons does not authorize the

    /** Thread name for data store crawling process. */
    private static final String DATA_CRAWLING_PROCESS = "DataStoreCrawler";

    /** Atomic flag indicating whether the crawler is currently running. */
    private static AtomicBoolean running = new AtomicBoolean(false);

    /** Thread-safe queue for collecting error messages during crawling operations. */

 * @param <V> the type of mapped values used the maps under test
 * @author George van den Driessche
 */
// TODO: Descriptive assertion messages, with hints as to probable fixes.
// TODO: Add another constructor parameter indicating whether the class under test is ordered, and
// check the order if so.
// TODO: Refactor to share code with SetTestBuilder etc.
@GwtCompatible
@NullMarked

     * the parameter map, its value is used as a regular expression pattern to match against
     * the given URL. If the URL matches the exclusion pattern, the method returns {@code false},
     * indicating that the URL should not be crawled. Otherwise, it returns {@code true}.
     *
     * @param paramMap the parameter map containing potential exclusion patterns
     * @param url the URL to be checked for crawlability

    /** The password for authentication */
    String password;
    /** The ANSI password hash */
    byte[] ansiHash;
    /** The Unicode password hash */
    byte[] unicodeHash;
    /** Flag indicating if hashes are externally provided */
    boolean hashesExternal = false;
    /** The client challenge for NTLM authentication */
    byte[] clientChallenge = null;
    /** The server challenge for NTLM authentication */

		marker     string
		delimiter  string
		maxKeys    int
		versioned  bool
		// Expected output of ListObjects.
		resultL ListObjectsInfo
		resultV ListObjectVersionsInfo
		err     error
		// Flag indicating whether the test is expected to pass or not.
		shouldPass bool
	}{
		{testBuckets[0], "unique/", "", "/", 1000, false, resultCases[0], ListObjectVersionsInfo{}, nil, true},

		DistributionAlgo string `json:"distributionAlgo"`
	} `json:"xl"`
}

// formatErasureV3 struct is same as formatErasureV2 struct except that formatErasureV3.Erasure.Version is "3" indicating
// the simplified multipart backend which is a flat hierarchy now.
// In .minio.sys/multipart we have:
// sha256(bucket/object)/uploadID/[xl.meta, part.1, part.2 ....]
type formatErasureV3 struct {
	formatMetaV1