}

    int writeHeaderWireFormat(final byte[] dst, int dstIndex) {
        dst[dstIndex] = (byte) this.type;
        dstIndex++;
        if (this.length > 0x0000FFFF) {
            dst[dstIndex] = (byte) 0x01;
        }
        dstIndex++;
        writeInt2(this.length, dst, dstIndex);
        return HEADER_LENGTH;
    }

    void testFaultCodeValueRanges() {
        // Standard fault codes (0x00000000 - 0x0000FFFF range)
        assertTrue(DcerpcError.DCERPC_FAULT_OTHER >= 0 && DcerpcError.DCERPC_FAULT_OTHER <= 0x0000FFFF,
                "DCERPC_FAULT_OTHER should be in standard range");
        assertTrue(DcerpcError.DCERPC_FAULT_ACCESS_DENIED >= 0 && DcerpcError.DCERPC_FAULT_ACCESS_DENIED <= 0x0000FFFF,
                "DCERPC_FAULT_ACCESS_DENIED should be in standard range");

            // File access constants should fit in lower 16 bits (0x0000FFFF)
            assertTrue(ACE.FILE_READ_DATA <= 0x0000FFFF, "FILE_READ_DATA should fit in lower 16 bits");
            assertTrue(ACE.FILE_WRITE_DATA <= 0x0000FFFF, "FILE_WRITE_DATA should fit in lower 16 bits");
            assertTrue(ACE.FILE_WRITE_ATTRIBUTES <= 0x0000FFFF, "FILE_WRITE_ATTRIBUTES should fit in lower 16 bits");

package okhttp3.internal.ws

import java.io.Closeable
import java.io.IOException
import java.util.zip.Inflater
import okio.Buffer
import okio.InflaterSource

private const val OCTETS_TO_ADD_BEFORE_INFLATION = 0x0000ffff

class MessageInflater(
  private val noContextTakeover: Boolean,
) : Closeable {
  private val deflatedBytes = Buffer()

  // Lazily-created.
  private var inflater: Inflater? = null

    @Test
    @DisplayName("Should maintain correct wire format structure")
    void testWireFormatStructure() {
        // Given
        request.setNotifyFlags(0x0001);
        request.setCompletionFilter(0x00000FFF);

        // When
        byte[] buffer = new byte[512];
        int written = request.writeBytesWireFormat(buffer, 0);

        // Then
        assertEquals(32, written);

        leftt = inInts[0];
        right = inInts[1];

        work = (leftt >>> 4 ^ right) & 0x0f0f0f0f;
        right ^= work;
        leftt ^= work << 4;

        work = (leftt >>> 16 ^ right) & 0x0000ffff;
        right ^= work;
        leftt ^= work << 16;

        work = (right >>> 2 ^ leftt) & 0x33333333;
        leftt ^= work;
        right ^= work << 2;

    @DisplayName("Should convert integer to hex string with padding")
    void testIntToHexString() {
        // Test various integer values
        assertEquals("00000000", Hexdump.toHexString(0, 8));
        assertEquals("000000FF", Hexdump.toHexString(255, 8));
        assertEquals("00001000", Hexdump.toHexString(4096, 8));
        assertEquals("FFFFFFFF", Hexdump.toHexString(-1, 8));

        // Test different sizes

                    | FileNotifyInformation.FILE_NOTIFY_CHANGE_STREAM_SIZE | FileNotifyInformation.FILE_NOTIFY_CHANGE_STREAM_WRITE;

            // Expected value when all flags are combined
            assertEquals(0x00000FFF, allFlags);
        }

        @Test
        @DisplayName("Test removing specific filter flag")
        void testRemovingFilterFlag() {

        assertEquals(0x84, SessionServicePacket.SESSION_RETARGET_RESPONSE);
        assertEquals(0x85, SessionServicePacket.SESSION_KEEP_ALIVE);
        assertEquals(0x0001FFFF, SessionServicePacket.MAX_MESSAGE_SIZE);
        assertEquals(4, SessionServicePacket.HEADER_LENGTH);
    }

    @ParameterizedTest
    @MethodSource("provideRoundTripTestData")

    private static final int FILE_NOTIFY_CHANGE_STREAM_SIZE = 0x00000400;
    private static final int FILE_NOTIFY_CHANGE_STREAM_WRITE = 0x00000800;
    private static final int FILE_NOTIFY_CHANGE_ALL = 0x00000FFF;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        when(mockConfig.getNotifyBufferSize()).thenReturn(4096);
        when(mockConfig.getTransactionBufferSize()).thenReturn(65535);