assertFalse(init.getContextFlag(flag));

            // Set to true
            init.setContextFlag(flag, true);
            assertTrue(init.getContextFlag(flag));
            assertEquals(flag, init.getContextFlags());

            // Set to false
            init.setContextFlag(flag, false);
            assertFalse(init.getContextFlag(flag));
            assertEquals(0, init.getContextFlags());
        }

            int bytesRead = response.readBytesWireFormat(buffer, 0);

            assertEquals(16, bytesRead);
            assertEquals(-1, response.getCount()); // -1 as signed int represents max unsigned value
            assertEquals(-2, response.getRemaining());
        }

        private byte[] createValidWriteResponse(int count, int remaining) {
            byte[] buffer = new byte[64];

        void testEncodeVariousCipherCounts(int cipherCount) {
            int[] ciphers = new int[cipherCount];
            for (int i = 0; i < cipherCount; i++) {
                ciphers[i] = i + 1;
            }
            EncryptionNegotiateContext context = new EncryptionNegotiateContext(mockConfig, ciphers);

            int bytesWritten = context.encode(buffer, 0);

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

    @ParameterizedTest
    @ValueSource(ints = { TransPeekNamedPipeResponse.STATUS_DISCONNECTED, TransPeekNamedPipeResponse.STATUS_SERVER_END_CLOSED })
    @DisplayName("available() on SMB1 returns 0 and marks closed on disconnected statuses")
    void available_smb1_disconnectedStatuses(int status) throws Exception {

        // Test normal initialization
        converter.init();
        assertTrue(testConverter.isInitialized());
    }

    @Test
    public void testInitMultipleTimes() throws IOException {
        // Test multiple initialization calls
        converter.init();
        assertTrue(testConverter.isInitialized());

        // Call init again
        converter.init();
        assertTrue(testConverter.isInitialized());

         * @param p The process to monitor.
         * @param ist The input stream thread.
         * @param timeout The destruction timeout.
         */
        public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) {
            this.p = p;
            this.ist = ist;
            this.timeout = timeout;
        }

        /**

    private static final int FILE_NOTIFY_CHANGE_EA = 0x00000080;
    private static final int FILE_NOTIFY_CHANGE_SECURITY = 0x00000100;
    private static final int FILE_NOTIFY_CHANGE_STREAM_NAME = 0x00000200;
    private static final int FILE_NOTIFY_CHANGE_STREAM_SIZE = 0x00000400;
    private static final int FILE_NOTIFY_CHANGE_STREAM_WRITE = 0x00000800;

        assertEquals(response.getTreeId(), response.getTid());
    }

    /**
     * Helper method to create a valid response buffer
     */
    private byte[] createValidResponseBuffer(int shareType, int shareFlags, int capabilities, int maxAccess) {
        byte[] buffer = new byte[256];
        SMBUtil.writeInt2(16, buffer, 0);
        buffer[2] = (byte) shareType;
        buffer[3] = 0;

    }

    /**
     * Retrieves a setting value as an int.
     * @param key The key of the setting.
     * @param defaultValue The default value if the setting is not found.
     * @return The setting value as an int.
     */
    public int getAsInt(final String key, final int defaultValue) {
        final Object obj = get(key);

        final int value;
        if (obj == null) {
            value = defaultValue;

            int[] expectedSizes = { 16, 24, 32, 40, 48 };

            for (int i = 0; i < contexts.length; i++) {
                contexts[i] = new MockCreateContextRequest("CTX" + i, expectedSizes[i]);
            }

            // Calculate total size
            int totalSize = 0;
            for (int i = 0; i < contexts.length; i++) {