throw new NoSuchFieldException("Field " + fieldName + " not found");
    }

    private String readNullTerminatedString(byte[] buffer, int offset) {
        int end = offset;
        while (end < buffer.length && buffer[end] != 0) {
            end++;
        }
        return new String(buffer, offset, end - offset);
    }

        void testUnicodeStringEncodeNullBuffer() throws NdrException {
            // Given: A unicode string with null buffer
            rpc.unicode_string unicodeString = new rpc.unicode_string();
            unicodeString.length = (short) 0;
            unicodeString.maximum_length = (short) 0;
            unicodeString.buffer = null;

            when(mockSmbPipeHandleInternal.recv(buf, 0, buf.length)).thenAnswer(invocation -> {
                byte[] buffer = invocation.getArgument(0);
                buffer[0] = 5; // Valid PDU version
                buffer[1] = 0; // Valid PDU type
                Encdec.enc_uint16le((short) 50, buffer, 8); // Fragment length
                return 30; // Initial bytes received
            });

    @Test
    void testReadSetupWireFormat() {
        byte[] buffer = new byte[10];
        int result = response.readSetupWireFormat(buffer, 0, 10);
        assertEquals(0, result, "readSetupWireFormat should always return 0.");
    }

    /**
     * Tests the readParametersWireFormat method.
     */
    @Test
    void testReadParametersWireFormat() {
        byte[] buffer = new byte[10];

   * most [BufferedSource] instances, but not of [Buffer].
   */
  private fun responseBody(content: String): ResponseBody {
    val data = Buffer().writeUtf8(content)
    val source: Source =
      object : Source {
        var closed = false

        override fun close() {
          closed = true
        }

        override fun read(
          sink: Buffer,
          byteCount: Long,
        ): Long {

            bufferIndex += 2;
            bufferIndex += 2; // reserved
            writeInt2(dataLength, buffer, bufferIndex);
            bufferIndex += 2;
            writeInt2(dataOffset, buffer, bufferIndex);
        }

        @Test
        public void testReadParameterWordsWireFormat() {
            int bytesRead = response.readParameterWordsWireFormat(buffer, 0);

import java.nio.Buffer;

/**
 * Wrappers around {@link Buffer} methods that are covariantly overridden in Java 9+. See
 * https://github.com/google/guava/issues/3990
 */
@GwtIncompatible
final class Java8Compatibility {
  static void clear(Buffer b) {
    b.clear();
  }

  static void flip(Buffer b) {
    b.flip();
  }

  static void limit(Buffer b, int limit) {
    b.limit(limit);
  }

        SMBUtil.writeTime(testTime, buffer, 32); // changeTime
        SMBUtil.writeInt8(1024L, buffer, 40); // endOfFile
        SMBUtil.writeInt8(2048L, buffer, 48); // allocationSize
        SMBUtil.writeInt4(0x20, buffer, 56); // extFileAttributes
        SMBUtil.writeInt4(512, buffer, 64); // eaSize

        // Decode
        fileBothDirectoryInfo.decode(buffer, 0, buffer.length);

        SMBUtil.writeInt4(-1000, buffer, bufferIndex + 11);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 15);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 19);
        SMBUtil.writeInt4(-5000, buffer, bufferIndex + 23);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 27);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 31);
        buffer[bufferIndex + 35] = (byte) 0x80; // 128 as unsigned

	v := allTierStats{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeallTierStats(b *testing.B) {
	v := allTierStats{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))