* @return this session's UID
     */
    public int getUid() {
        return this.uid;
    }

    /**
     * @return this session's expiration time
     */
    public Long getExpiration() {
        return this.expiration > 0 ? this.expiration : null;
    }

    /**
     * @return this session's credentials
     */
    public CredentialsInternal getCredentials() {

        // Create an expired handle
        HandleInfo expiredHandle = new HandleInfo("/test/file.txt", new HandleGuid(), new byte[16], HandleType.DURABLE_V2, 100, // 100ms timeout
                null);

        // Wait for expiration
        Thread.sleep(150);

        CompletableFuture<HandleInfo> future = reconnector.reconnectHandle(expiredHandle, new IOException("Network error"));

        assertThrows(ExecutionException.class, () -> {

 * modification checking, and integration with the Fess search engine backend.
 *
 * <p>Key features include:</p>
 * <ul>
 * <li>Incremental crawling support with last-modified timestamp checking</li>
 * <li>Document expiration handling</li>
 * <li>Child URL extraction and queueing</li>
 * <li>Integration with Fess configuration and permission systems</li>
 * <li>Client selection based on URL patterns</li>
 * </ul>
 *
 * @see CrawlerThread

     */
    public PopularWordHelper() {
        // Default constructor
    }

    /**
     * Initializes the PopularWordHelper after dependency injection.
     * Sets up the cache with configured size and expiration settings.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {
            logger.debug("Initializing {}", this.getClass().getSimpleName());
        }

        // Set a very short max age
        entry.setMaxAge(100); // 100ms

        assertFalse(entry.isExpired());
        assertFalse(entry.needsRefresh());

        // Wait for expiration
        try {
            Thread.sleep(150);
        } catch (InterruptedException e) {
            // Ignore
        }

        assertTrue(entry.isExpired());
        assertTrue(entry.needsRefresh());

    @Test
    public void testGetHandleForReconnectExpired() {
        manager.requestDurableHandle("/test/file.txt", HandleType.DURABLE_V2, 100, // 100ms timeout
                null);

        // Wait for expiration
        try {
            Thread.sleep(150);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

import jcifs.internal.smb2.lease.Smb2LeaseKey;

/**
 * Manager for persistent and durable SMB handles.
 *
 * This class provides:
 * - Handle lifecycle management
 * - Persistent storage for persistent handles
 * - Expiration tracking for durable handles
 * - Thread-safe access to handle information
 */
public class PersistentHandleManager {

    private static final Logger log = LoggerFactory.getLogger(PersistentHandleManager.class);

    public void setThumbnailTaskQueueSize(final int thumbnailTaskQueueSize) {
        this.thumbnailTaskQueueSize = thumbnailTaskQueueSize;
    }

    /**
     * Sets the expiration time for no-image placeholder files.
     *
     * @param noImageExpired the expiration time in milliseconds
     */
    public void setNoImageExpired(final long noImageExpired) {
        this.noImageExpired = noImageExpired;
    }

    /**

    private final UniAddress address;
    private final int port, localPort;
    private final InetAddress localAddr;

    SmbTransport transport = null;
    NtlmPasswordAuthentication auth;
    long expiration;
    String netbiosName = null;

    SmbSession(final UniAddress address, final int port, final InetAddress localAddr, final int localPort,
            final NtlmPasswordAuthentication auth) {

     */
    @Override
    public Long getExpiration() {
        return this.expiration;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.util.transport.Response#setExpiration(java.lang.Long)
     */
    @Override
    public void setExpiration(final Long exp) {
        this.expiration = exp;
    }

    /**
     * Gets the configuration object for this message block