(byte) 0xFF, 0x01, 0x1F, 0x00 // MaximalAccess
        };

        // When
        int bytesRead = response.readBytesWireFormat(wireData, 0);

        // Then
        assertEquals(16, bytesRead);
        assertEquals(wireData.length, bytesRead);
        assertEquals((byte) 0x01, response.getShareType());
        assertEquals(0x00000001, response.getShareFlags());

        // When
        int bytesRead = testResponse.readBytesWireFormat(buffer, bufferIndex);

        // Then
        assertTrue(testResponse.errorResponseCalled);
        assertEquals(8, bytesRead); // Error response is 8 bytes
    }

    @DisplayName("Should throw exception for invalid structure size")
    @ParameterizedTest

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

        // The count should be read from the buffer.
        assertEquals(10L, response.count);
        // The method should return the number of bytes read.
        assertEquals(8, bytesRead);
    }

    /**
     * Test the writeParameterWordsWireFormat method.
     */

        Trans2QueryPathInformation trans = new Trans2QueryPathInformation("anyfile.txt", 0);
        byte[] buffer = new byte[10];

        // When
        int bytesRead = trans.readSetupWireFormat(buffer, 0, 10);

        // Then
        assertEquals(0, bytesRead, "Should read 0 bytes.");
    }

    /**
     * Tests the readParametersWireFormat method.
     */
    @Test
    void testReadParametersWireFormat() {

type countUpReader struct {
	reader    io.Reader
	bytesRead int64
}

// Max bzip2 concurrency across calls. 50% of GOMAXPROCS.
var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2)

func (r *countUpReader) Read(p []byte) (n int, err error) {
	n, err = r.reader.Read(p)
	atomic.AddInt64(&r.bytesRead, int64(n))
	return n, err
}

func (r *countUpReader) BytesRead() int64 {
	if r == nil {
		return 0
	}

            SMBUtil.writeInt2(0, buffer, bufferIndex + 2); // Reserved field

            // When
            int bytesRead = response.readBytesWireFormat(buffer, bufferIndex);

            // Then
            assertEquals(4, bytesRead);
        }

        @Test
        @DisplayName("Should throw exception for invalid structure size")

        byte[] buffer = new byte[10];

        // When
        int bytesRead = transCallNamedPipe.readSetupWireFormat(buffer, 0, buffer.length);

        // Then
        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("Test writeParametersWireFormat returns 0")
    void testWriteParametersWireFormat() {
        // Given

    val totalBytesToRead = inflater.bytesRead + deflatedBytes.size

    // We cannot read all, as the source does not close.
    // Instead, we ensure that all bytes from source have been processed by inflater.
    do {
      inflaterSource.readOrInflate(buffer, Long.MAX_VALUE)
    } while (inflater.bytesRead < totalBytesToRead && !inflater.finished())

	buf bytes.Buffer
	// total bytes read including header size
	bytesRead int
}

// Close is a no operation closer
func (r *RequestRecorder) Close() error {
	// no-op
	return nil
}

// Read reads from the internal reader and counts/save the body in the memory
func (r *RequestRecorder) Read(p []byte) (n int, err error) {
	n, err = r.Reader.Read(p)
	r.bytesRead += n

	if r.LogBody {
		r.buf.Write(p[:n])
	}

        bufferIndex += 4;
        // setupCount = 0 (1 byte + 1 padding byte)
        buffer[bufferIndex] = 0;
        buffer[bufferIndex + 1] = 0; // padding byte

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

        assertEquals(37, bytesRead); // 3 reserved + 32 (8*4) + 2 for setupCount
        assertEquals(10, response.totalParameterCount);