bytes[byteIndex++] = (byte) (0xC0 | (c >> 6));
                bytes[byteIndex++] = (byte) (0x80 | (c & 0x3F));
            } else {
                bytes[byteIndex++] = (byte) (0xE0 | (c >> 12));
                bytes[byteIndex++] = (byte) (0x80 | ((c >> 6) & 0x3F));
                bytes[byteIndex++] = (byte) (0x80 | (c & 0x3F));
            }
        }

        return Arrays.copyOf(bytes, byteIndex);
    }

            SmbTreeHandleImpl sh = newTreeHandle(false); // force non-SMB2 path to avoid server-side branch
            SmbTreeHandleImpl dh = newTreeHandle(false);

            byte[][] buffers = new byte[][] { new byte[8], new byte[8] };

            when(src.toString()).thenReturn("smb://src");
            when(dest.toString()).thenReturn("smb://dest");

            // Act + Assert
            SmbException ex =

            // Given
            smbComTreeDisconnect = new SmbComTreeDisconnect(config);
            byte[] originalBuffer = new byte[100];
            for (int i = 0; i < originalBuffer.length; i++) {
                originalBuffer[i] = (byte) i;
            }
            byte[] bufferCopy = originalBuffer.clone();

            // When

    private static final byte[] SIGNCONTEXT_300 = toCBytes("SmbSign");
    private static final byte[] SIGNLABEL_300 = toCBytes("SMB2AESCMAC");
    private static final byte[] SIGNLABEL_311 = toCBytes("SMBSigningKey");

    private static final byte[] APPCONTEXT_300 = toCBytes("SmbRpc");
    private static final byte[] APPLABEL_300 = toCBytes("SMB2APP");
    private static final byte[] APPLABEL_311 = toCBytes("SMBAppKey");

        testBuffer = new byte[100];
        testBuffer[0] = (byte) 0xFF; // Non-zero = Deny
        testBuffer[1] = (byte) 0xFF; // All flags
        testBuffer[2] = (byte) 0xFF; // Size low byte
        testBuffer[3] = (byte) 0xFF; // Size high byte
        testBuffer[4] = (byte) 0xFF; // Access mask all bits
        testBuffer[5] = (byte) 0xFF;
        testBuffer[6] = (byte) 0xFF;
        testBuffer[7] = (byte) 0xFF;

        // Create a large byte array (1MB)
        byte[] data = new byte[1024 * 1024];
        for (int i = 0; i < data.length; i++) {
            data[i] = (byte) (i % 256);
        }

        ContentCache cache = new ContentCache(data);

        try (InputStream stream = cache.getInputStream()) {
            assertNotNull(stream);
            byte[] buffer = new byte[data.length];

	testCases := []struct {
		data           []byte
		expectedResult *FilterRule
		expectErr      bool
	}{
		{[]byte(`<FilterRule></FilterRule>`), nil, true},
		{[]byte(`<FilterRule><Name></Name></FilterRule>`), nil, true},
		{[]byte(`<FilterRule><Value></Value></FilterRule>`), nil, true},
		{[]byte(`<FilterRule><Name></Name><Value></Value></FilterRule>`), nil, true},

        String target = null;
        byte[] bytes = readSecurityBuffer(material, 12);
        if (bytes.length != 0) {
            target = new String(bytes, (flags & NTLMSSP_NEGOTIATE_UNICODE) != 0 ? UNI_ENCODING : getOEMEncoding());
        }
        setTarget(target);
        for (int i = 24; i < 32; i++) {
            if (material[i] != 0) {
                final byte[] challenge = new byte[8];

    }

    @Test
    @DisplayName("Test readParametersWireFormat ignores middle 2 bytes")
    void testReadParametersWireFormatIgnoresMiddleBytes() {
        // Arrange
        byte[] buffer = new byte[10];
        SMBUtil.writeInt2(200, buffer, 0);
        // These bytes should be ignored
        buffer[2] = (byte) 0xFF;
        buffer[3] = (byte) 0xFF;
        SMBUtil.writeInt2(TransPeekNamedPipeResponse.STATUS_LISTENING, buffer, 4);

    private static final byte[] CONTEXT_NAME_BYTES = CONTEXT_NAME.getBytes();
    private static final int STRUCTURE_SIZE = 16;

    private byte[] fileId; // 16-byte file ID from previous open

    /**
     * Create a new durable handle reconnect context
     * @param fileId the 16-byte file ID from the previous open
     */
    public DurableHandleReconnect(byte[] fileId) {
        if (fileId.length != 16) {