}

    /**
     * Returns the contents read from the reader as a string.
     *
     * @param reader
     *            the reader
     * @param initialCapacity
     *            the initial buffer capacity
     * @return the string read from the reader
     */
    protected static String read(final Reader reader, final int initialCapacity) {
        int bufferSize;

        assertEquals("server.example.com", testImplementation.getServer());
    }

    @Test
    @DisplayName("Test resolve in DFS flag toggles")
    void testResolveInDfsToggle() {
        // Initial state should be false
        assertFalse(testImplementation.isResolveInDfs());

        // Toggle to true
        testImplementation.setResolveInDfs(true);
        assertTrue(testImplementation.isResolveInDfs());

            this.channelId = channelId;
            this.failureTime = System.currentTimeMillis();
            this.retryCount = 0;
            this.nextRetryTime = failureTime + 1000; // Initial 1 second delay
        }

        /**
         * Get channel ID
         *
         * @return channel identifier
         */
        public String getChannelId() {
            return channelId;

    //                                                                      Search Execute
    //                                                                      ==============
    /**
     * Displays the initial duplicate host management page.
     *
     * @param form the search form
     * @return HTML response for the duplicate host list page
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })

        assertTrue(it.hasNext());
        assertEquals("x", it.next().getName());
    }

    @Test
    @DisplayName("Empty initial results with end-of-search -> closes immediately")
    void emptyInitialResultsEndOfSearchCloses() throws Exception {

        // Act + Assert (no exception expected)
        assertDoesNotThrow(() -> SmbCopyUtil.copyFile(src, dest, buffers, 1, new WriterThread(), sh, dh));

        // Verify that server-side path engaged at least the initial opens
        verify(src, times(1)).openUnshared(anyInt(), anyInt(), anyInt(), anyInt(), anyInt());
        verify(dest, times(1)).openUnshared(anyInt(), anyInt(), anyInt(), anyInt(), anyInt());
    }

    }

    // Test source map modifications
    public void test_sourceMapModifications() {
        TestSearchLogEvent event = new TestSearchLogEvent("id", 1L, "type");

        // Initial empty map
        Map<String, Object> map1 = new HashMap<>();
        event.setSourceMap(map1);
        assertEquals(0, event.toSource().size());

        // Add elements to the map

        // Given
        Smb2EncryptionContext context = new Smb2EncryptionContext(EncryptionNegotiateContext.CIPHER_AES128_GCM, DialectVersion.SMB311,
                testEncryptionKey, testEncryptionKey);

        // Test initial encryption
        byte[] plaintext1 = "Before rotation".getBytes();
        byte[] encrypted1 = context.encryptMessage(plaintext1, 1L);
        byte[] decrypted1 = context.decryptMessage(encrypted1);

        }
    }

    @Test
    @DisplayName("ltime field is mutable")
    void testLtimeField() {
        TestLocking t = new TestLocking();

        // Initial value
        assertEquals(0L, t.ltime, "ltime should start at 0");

        // Set new value
        long currentTime = System.currentTimeMillis();
        t.ltime = currentTime;

    holderA.value = 3;
    assertTrue(map.entrySet().contains(immutableEntry("a", new IntHolder(3))));
    Map<String, Integer> intMap = ImmutableMap.of("a", 3, "b", 2);
    assertEquals(intMap.hashCode(), map.entrySet().hashCode());
    assertEquals(intMap.hashCode(), map.hashCode());
  }

  @J2ktIncompatible
  @GwtIncompatible // SerializableTester
  public void testViewSerialization() {