@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

            byte[] buffer = new byte[256];
            byte[] name = "BOUNDARY".getBytes(StandardCharsets.UTF_8);
            TestCreateContextRequest request = new TestCreateContextRequest(name);

            // Test at buffer start
            int result1 = request.encode(buffer, 0);
            assertTrue(result1 > 0);

            // Test at buffer middle

        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);
    }

    /**

  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++
    }

            // Create a buffer with sample data
            byte[] buffer = new byte[100];
            // Fill with some test data
            for (int i = 0; i < buffer.length; i++) {
                buffer[i] = (byte) (i % 256);
            }

            int result = resp.readDataWireFormat(buffer, 0, 40);
            assertNotNull(resp.info);

            // 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);

        val read = delegate.read(buffer, byteCount)
        if (read != -1L) {
          sink.write(buffer.readByteString().toAsciiUppercase())
        }
        return read
      }
    }
  }

        this.server.smaxMpxCount = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        this.server.maxNumberVcs = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        this.server.maxBufferSize = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;
        this.server.maxRawSize = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;

}

// pickRelevantGoroutines returns all goroutines we care about for the purpose
// of leak checking. It excludes testing or runtime ones.
func pickRelevantGoroutines() (gs []string) {
	// get runtime stack buffer.
	buf := debug.Stack()
	// runtime stack of go routines will be listed with 2 blank spaces between each of them, so split on "\n\n" .
	for g := range strings.SplitSeq(string(buf), "\n\n") {

    protected final ByteBuffer buffer;
    protected final EnumSet<RdmaAccess> accessFlags;
    protected final int localKey;
    protected final int remoteKey;
    protected final long address;
    protected volatile boolean valid;
    
    public RdmaMemoryRegion(ByteBuffer buffer, EnumSet<RdmaAccess> access) {
        this.buffer = buffer;
        this.accessFlags = access;