}

    @Override
    protected Parser createParser() {
        return new MavenParser();
    }

    @Test
    void defaultFs(
            @TempDir(cleanup = CleanupMode.ON_SUCCESS) Path cwd,
            @TempDir(cleanup = CleanupMode.ON_SUCCESS) Path userHome)
            throws Exception {
        invoke(cwd, userHome, List.of("verify"), List.of());
    }

     *
     * @param executorService the executor service for parallel processing
     * @param cleanup whether to run in cleanup mode
     * @return the number of tasks processed
     */
    public int generate(final ExecutorService executorService, final boolean cleanup) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final List<String> idList = new ArrayList<>();

exit_1() {
	cleanup

	for site in sitea siteb; do
		echo "$site server logs ========="
		cat "/tmp/${site}_1.log"
		echo "==========================="
		cat "/tmp/${site}_2.log"
	done

	exit 1
}

cleanup() {
	echo -n "Cleaning up instances of MinIO ..."
	pkill -9 minio || sudo pkill -9 minio
	rm -rf /tmp/sitea
	rm -rf /tmp/siteb
	echo "done"
}

cleanup

export MINIO_CI_CD=1

     * Note: Guava Cache handles expiration automatically, but this method
     * can be called to force immediate cleanup.
     */
    public void cleanup() {
        requestCounters.cleanUp();
        blockedIps.cleanUp();
        if (logger.isDebugEnabled()) {
            logger.debug("Cache cleanup completed: trackedIps={}, blockedIps={}", requestCounters.size(), blockedIps.size());
        }
    }

#!/bin/bash

trap 'cleanup $LINENO' ERR

# shellcheck disable=SC2120
cleanup() {
	MINIO_VERSION=dev /tmp/gopath/bin/docker-compose \
		-f "buildscripts/upgrade-tests/compose.yml" \
		down || true

	MINIO_VERSION=dev /tmp/gopath/bin/docker-compose \
		-f "buildscripts/upgrade-tests/compose.yml" \
		rm || true

	for volume in $(docker volume ls -q | grep upgrade); do
		docker volume rm ${volume} || true
	done

        assertTrue(true);
    }

    @Test
    public void test_process_cleanupMode() throws Exception {
        // Test process method in cleanup mode
        ThumbnailGenerator.Options options = new ThumbnailGenerator.Options();
        options.numOfThreads = 1;
        options.cleanup = true;

        setupMockComponents();

     * @param operationName the operation name used as the lock document ID.
     * @param data optional data to store with the operation document.
     * @param remainingRetries the number of remaining retry attempts for stale lock cleanup.
     * @return {@code true} if the lock was acquired.
     */
    protected boolean tryStartOperation(final String operationName, final String data, final int remainingRetries) {

        this.numOfThreads = numOfThreads;
        return this;
    }

    /**
     * Enables cleanup operations for this job.
     *
     * @return this job instance for method chaining
     */
    public GenerateThumbnailJob cleanup() {
        cleanup = true;
        return this;
    }

    @Override
    public String execute() {

        } finally {
            // Cleanup
            try {
                client.admin().indices().prepareDelete(suggester.getIndex() + "*").execute().actionGet();
            } catch (Exception cleanupError) {
                // Ignore cleanup errors
            }
            suggester.shutdown();
        }

        assertTrue(PreauthIntegrityService.getHashAlgorithmName(0xFF).startsWith("Unknown"));
    }

    @Test
    @DisplayName("Test service cleanup")
    public void testServiceCleanup() throws CIFSException {
        String sessionId1 = "cleanup-test-1";
        String sessionId2 = "cleanup-test-2";
        byte[] salt = preauthService.generatePreauthSalt();