@Resource
    protected FessConfig fessConfig;

    /**
     * Time interval in milliseconds after which jobs are considered expired.
     * Default is 2 hours (2 * 60 * 60 * 1000L).
     */
    protected long expiredJobInterval = 2 * 60 * 60 * 1000L; // 2hours

    /**
     * Retrieves a paginated list of job logs based on the provided pager configuration.
     *

        long[] testTimes = { 0L, 1000L, 1500000000000L };
        byte[] buffer = new byte[4];

        for (long time : testTimes) {
            SMBUtil.writeUTime(time, buffer, 0);
            long readTime = SMBUtil.readUTime(buffer, 0);

            // Account for precision loss (milliseconds to seconds conversion)
            assertEquals((time / 1000L) * 1000L, readTime);
        }
    }

    @Test

    void testSmbComQueryInformationResponseGetters() throws Exception {
        // The constructor is package‑private; use an anonymous subclass
        SmbComQueryInformationResponse resp = new SmbComQueryInformationResponse(1000L) {
        };
        java.lang.reflect.Field fileAttr = SmbComQueryInformationResponse.class.getDeclaredField("fileAttributes");
        fileAttr.setAccessible(true);
        fileAttr.setInt(resp, 0xABCD);

    }

    @ParameterizedTest
    @DisplayName("Test with various timeout values")
    @ValueSource(longs = { 0L, 1L, -1L, Long.MAX_VALUE, Long.MIN_VALUE, 1000L, -1000L })
    void testWithVariousTimeoutValues(long timeout) {
        // Setup
        String pipeName = "TestPipe";
        FsctlPipeWaitRequest request = new FsctlPipeWaitRequest(pipeName, timeout);

    protected List<String> commandList;

    /** Timeout for command execution in milliseconds. */
    protected long commandTimeout = 30 * 1000L;// 30sec

    /** Timeout for destroying processes in milliseconds. */
    protected long commandDestroyTimeout = 5 * 1000L;// 5sec

    /** Base directory for command execution. */
    protected File baseDir;

    /** Timer for managing process destruction. */

    /**
     * Default constructor.
     */
    public AbstractConfigHelper() {
        // Default constructor
    }

    /**
     * The interval for reloading.
     */
    protected long reloadInterval = 1000L;

    /**
     * Update the configuration.
     */
    public void update() {
        CommonPoolUtil.execute(this::load);
    }

    /**
     * Wait for the next reloading.
     */

        assertEquals(0, new BigDecimal("1.23E-10").compareTo(BigDecimalConversionUtil.toBigDecimal(Double.valueOf(0.000000000123))));

        assertEquals(0, new BigDecimal("100.00").compareTo(BigDecimalConversionUtil.toBigDecimal("100.00")));
        assertEquals(0, new BigDecimal("0.000000123").compareTo(BigDecimalConversionUtil.toBigDecimal("1.23E-7")));

    private int status = ACTIVE;

    TimeoutTask(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
        this.timeoutTarget = timeoutTarget;
        this.timeoutMillis = timeout * 1000L;
        this.permanent = permanent;
        this.startTime = System.currentTimeMillis();
    }

    /**
     * Returns whether the task has expired.
     *
     * @return whether the task has expired
     */

        // Test with a specific TTL
        long ttl = 600; // 10 minutes
        Dfs.CacheEntry cacheEntry = new Dfs.CacheEntry(ttl);
        long expectedExpiration = System.currentTimeMillis() + ttl * 1000L;
        assertTrue(cacheEntry.expiration >= expectedExpiration - 100 && cacheEntry.expiration <= expectedExpiration + 100);
        assertNotNull(cacheEntry.map);

        // Test with TTL = 0, should use default TTL

                for (final TimeoutTask task : getExpiredTask()) {
                    processTask(executorService, task);
                }
                Thread.sleep(1000L);
            }
        } catch (final InterruptedException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Interrupted.", e);
            }
        } finally {