verify(tree, times(1)).release();
    }

    @Test
    @DisplayName("release() decrements usage; closes only when count reaches zero")
    void release_decrementsAndClosesOnZero() throws CIFSException {
        when(cfg.isTraceResourceUsage()).thenReturn(false);
        stubValidTree(8L, true, true);

        RuntimeCIFSException ex = assertThrows(RuntimeCIFSException.class, () -> handle.release());
        assertTrue(ex.getMessage().contains("below zero"));
        verify(treeConnection, times(1)).release(); // still only once
    }

    @Test
    @DisplayName("acquire after release reacquires underlying tree connection")
    void acquireAfterReleaseReacquires() {

    //                                               Details
    //                                               -------
    /**
     * Display detailed view of a specific stemmer override item.
     * Shows read-only details of the selected item.
     *
     * @param dictId The dictionary ID
     * @param crudMode The CRUD mode (should be DETAILS)
     * @param id The ID of the stemmer override item to display

     * returned (e.g. MYDOM\alice or MYDOM\Domain Users).
     * If the SID has been resolved but it is is a domain SID,
     * only the domain name will be returned (e.g. MYDOM).
     * If the SID has been resolved but it is a builtin account,
     * only the name component will be returned (e.g. SYSTEM).
     * If the sid cannot be resolved the numeric representation from
     * toString() is returned.
     */

        assertEquals("mybucket", getField(storageConn, "bucketName"));
        assertEquals("path/to/object.txt", getField(storageConn, "objectName"));
    }

    /**
     * Test URL parsing with bucket only (no object path).
     */
    public void test_urlParsing_bucketOnly() throws Exception {
        URL url = new URL("storage://mybucket");
        Handler handler = new Handler();

     */
    @Override
    public void delete(final String sessionId) {
        deleteBySessionId(sessionId);
    }

    /**
     * Offers multiple URL queue entries for the specified session.
     * Only URLs that don't already exist will be added.
     *
     * @param sessionId The session ID.
     * @param urlQueueList The list of URL queue entries to offer.
     */
    @Override

            System.arraycopy(fileId, 0, buffer, 8, 16);

            int bytesRead = notification.readBytesWireFormat(buffer, 0);
            assertEquals(24, bytesRead);

            // Verify only the necessary bytes were read
            Field fileIdField = Smb2OplockBreakNotification.class.getDeclaredField("fileId");
            fileIdField.setAccessible(true);

    }

    @Nested
    @DisplayName("Constructor Tests")
    class ConstructorTests {

        @Test
        @DisplayName("Should construct with config only")
        void testConstructorWithConfig() {
            TestServerMessageBlock2Response resp = new TestServerMessageBlock2Response(mockConfig);
            assertNotNull(resp);

        assertNotNull(tokens);
        assertTrue(tokens.isEmpty());
    }

    @Test
    public void testAnalyzeWithWhitespaceOnly() {
        // Test analyze with whitespace only
        String text = "   ";
        String field = "content";
        String lang = "en";

        List<AnalyzeToken> tokens = analyzer.analyze(text, field, lang);

        assertNotNull(tokens);

                                blockedAttempts.incrementAndGet();
                                continue;
                            }

                            // Only record failure/success if the attempt was allowed
                            if (j % 2 == 0) {
                                concurrentLimiter.recordFailure("user" + threadId, "192.168.2." + threadId);