resourceManager = ResourceManager.getInstance();
        // Configure with shorter intervals for testing
        resourceManager.configure(1000, 100, true, true);
    }

    /**
     * Test resource for tracking
     */
    static class TestResource implements AutoCloseable {
        private final AtomicBoolean closed = new AtomicBoolean(false);
        private final String name;

        TestResource(String name) {

        super.setUp();
        purgeLogJob = new PurgeLogJob();
    }

    // Test all services execute successfully
    public void test_execute_allSuccess() {
        // Setup tracking variables
        final boolean[] deleteCrawlingInfoCalled = { false };
        final boolean[] deleteSearchLogCalled = { false };
        final boolean[] deleteJobLogCalled = { false };

     */
    public static ResourceManager getInstance() {
        return INSTANCE;
    }

    /**
     * Register a resource for tracking
     *
     * @param resource the resource to track
     * @return resource ID for tracking
     */
    public String registerResource(AutoCloseable resource) {
        if (resource == null) {

    private final int maxAttemptsPerIp;
    private final int maxGlobalAttemptsPerMinute;
    private final Duration lockoutDuration;
    private final Duration cleanupInterval;

    // Tracking maps
    private final Map<String, AccountAttempts> accountAttempts = new ConcurrentHashMap<>();
    private final Map<String, IpAttempts> ipAttempts = new ConcurrentHashMap<>();

- [ ] Add lease context to Create request/response
- [ ] Implement lease break notification handling
- [ ] Modify SmbFile to support lease-based caching
- [ ] Add lease upgrade/downgrade logic
- [ ] Implement lease epoch tracking for v2 leases

#### 1.3 Integration Points
- Modify `Smb2CreateRequest` to include lease contexts
- Update `SmbFile` caching logic to use leases
- Add lease break handling in `SmbTransport`

---

        }

        return needsRotation;
    }

    /**
     * Reset key rotation tracking after new keys are established
     */
    public void resetKeyRotationTracking() {
        bytesEncrypted.set(0);
        encryptionStartTime = System.currentTimeMillis();
        log.debug("Key rotation tracking reset");
    }

    /**
     * Rotate encryption keys for enhanced security
     *

    // Proactive health monitoring
    private volatile boolean proactiveHealthCheckEnabled = true;
    private final long proactiveCheckInterval = DEFAULT_PROACTIVE_CHECK_INTERVAL;

    // Connection failure tracking
    private final Map<String, Long> lastFailureTimes = new ConcurrentHashMap<>();
    private final Map<String, AtomicInteger> consecutiveFailures = new ConcurrentHashMap<>();

        callback.store(new DataStoreParams(), new HashMap<>());
        assertEquals(1L, callback.getDocumentSize());
    }

    public void test_commit_behavior() {
        // Test commit behavior with state tracking
        final AtomicInteger commitCount = new AtomicInteger(0);
        final AtomicLong documentsBeforeCommit = new AtomicLong(0);

        IndexUpdateCallback callback = new IndexUpdateCallback() {

/**
 * File System Control Code (FSCC) structure for File Internal Information.
 * Provides access to the file's internal index number, which is a unique identifier
 * assigned by the file system for internal tracking and reference purposes.
 *
 * @author mbechler
 */
public class FileInternalInfo implements FileInformation {

    private long indexNumber;

    /**

        } catch (RuntimeException e) {
            assertEquals("Load failed", e.getMessage());
        }

        assertEquals(1, chain.loadCalls.size());
    }

    // Test implementation state tracking
    public void test_implementation_stateTracking() {
        TestAuthenticationChain chain = new TestAuthenticationChain();
        User user1 = createTestUser("user1", "User One");