// Write to buffer
        SMBUtil.writeInt4(testCapabilities, buffer, bufferIndex);
        System.arraycopy(testGuid, 0, buffer, bufferIndex + 4, 16);
        SMBUtil.writeInt2(testSecurityMode, buffer, bufferIndex + 20);
        SMBUtil.writeInt2(testDialect, buffer, bufferIndex + 22);

        // Execute decode
        int bytesDecoded = response.decode(buffer, bufferIndex, 24);

        // Verify results

    if (readBuffer.remaining() <= buffer.remaining()) {
      buffer.put(readBuffer);
      munchIfFull();
      return this;
    }

    // First add just enough to fill buffer size, and munch that
    int bytesToCopy = bufferSize - buffer.position();
    for (int i = 0; i < bytesToCopy; i++) {
      buffer.put(readBuffer.get());
    }
    munch(); // buffer becomes empty here, since chunkSize divides bufferSize

        Object obj;
    }

    /**
     * The underlying byte buffer containing the NDR data.
     */
    public byte[] buf;

    /**
     * The starting position in the buffer.
     */
    public int start;

    /**
     * The current position in the buffer.
     */
    public int index;

    /**
     * The length of data in the buffer.
     */
    public int length;

    /**

    @DisplayName("Test decode method with valid buffer")
    void testDecodeWithValidBuffer() throws SMBProtocolDecodingException {
        // Given
        byte[] buffer = new byte[256];
        int bufferIndex = 0;
        int expectedLength = 100;

        when(messageBlock.decode(buffer, bufferIndex)).thenReturn(expectedLength);

        // When
        int actualLength = messageBlock.decode(buffer, bufferIndex);

        // Then

import okhttp3.logging.internal.isProbablyUtf8
import okio.Buffer
import org.junit.jupiter.api.Test

class IsProbablyUtf8Test {
  @Test fun isProbablyUtf8() {
    assertThat(Buffer().isProbablyUtf8()).isTrue()
    assertThat(Buffer().writeUtf8("abc").isProbablyUtf8()).isTrue()
    assertThat(Buffer().writeUtf8("new\r\nlines").isProbablyUtf8()).isTrue()
    assertThat(Buffer().writeUtf8("white\t space").isProbablyUtf8()).isTrue()

            // Encode
            byte[] buffer = new byte[1024];
            int encodedSize = original.encode(buffer, 0);

            // Decode
            PreauthIntegrityNegotiateContext decoded = new PreauthIntegrityNegotiateContext();
            int decodedSize = decoded.decode(buffer, 0, encodedSize);

            // Verify
            assertEquals(encodedSize, decodedSize);

  private fun String.map(): String {
    val buffer = Buffer()
    for (codePoint in codePoints()) {
      require(table.map(codePoint, buffer))
    }
    return buffer.readUtf8()
  }

  private fun String.mapExpectingErrors(): String {
    val buffer = Buffer()
    var errorCount = 0
    for (codePoint in codePoints()) {
      if (!table.map(codePoint, buffer)) errorCount++
    }

        byte[] buffer = new byte[100];

        // Define behavior
        when(mockFileInfo.decode(buffer, 0, 100)).thenReturn(8);

        // Test decode
        int decoded = mockFileInfo.decode(buffer, 0, 100);
        assertEquals(8, decoded);

        // Verify interaction
        verify(mockFileInfo).decode(buffer, 0, 100);
    }

    /**

    }

    @Test
    void testReadSetupWireFormat() {
        byte[] buffer = new byte[100];
        int result = response.readSetupWireFormat(buffer, 0, 100);
        assertEquals(0, result);
    }

    @Test
    void testReadParametersWireFormat() {
        byte[] buffer = new byte[100];
        int result = response.readParametersWireFormat(buffer, 0, 100);
        assertEquals(0, result);
    }

    @Test

    Callable {
      val buffer = Buffer()
      while (source!!.read(buffer, 16384) != -1L) {
      }
      source.close()
      buffer.readByteString()
    }

  private fun assertFile(
    prefix: ByteString,
    upstreamSize: Long,
    metadataSize: Int,
    upstream: String?,
    metadata: ByteString?,
  ) {
    val source = file.source().buffer()