int bytesWritten = context.encode(buffer, 0);

            assertEquals(12, bytesWritten);
            assertEquals(3, SMBUtil.readInt2(buffer, 0));
            assertEquals(2, SMBUtil.readInt2(buffer, 2));
            assertEquals(0x01, SMBUtil.readInt2(buffer, 4));
            assertEquals(0x02, SMBUtil.readInt2(buffer, 6));
            assertEquals(0x03, SMBUtil.readInt2(buffer, 8));

import okhttp3.internal.http2.Header
import okhttp3.internal.http2.Http2Connection
import okhttp3.internal.http2.Http2Stream
import okhttp3.internal.platform.Platform
import okhttp3.tls.internal.TlsUtil.localhost
import okio.buffer
import okio.source

/** A basic HTTP/2 server that serves the contents of a local directory.  */
class Http2Server(
  private val baseDirectory: File,
  private val sslSocketFactory: SSLSocketFactory,

    @DisplayName("Should encode lease key to buffer")
    void testEncode() {
        byte[] testBytes = new byte[] { 0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, (byte) 0x88, (byte) 0x99, (byte) 0xAA, (byte) 0xBB,
                (byte) 0xCC, (byte) 0xDD, (byte) 0xEE, (byte) 0xFF, 0x00 };

        Smb2LeaseKey key = new Smb2LeaseKey(testBytes);
        byte[] buffer = new byte[20];

        key.encode(buffer, 2);

            assertEquals(0, echoResponse.writeBytesWireFormat(buffer, 100));
            assertEquals(0, echoResponse.writeBytesWireFormat(buffer, 500));
        }

        @Test
        @DisplayName("Should not modify buffer")
        void testWriteBytesWireFormatNoModification() {
            byte[] buffer = new byte[1024];
            byte[] originalBuffer = buffer.clone();

    /**
     * Register memory region for RDMA operations
     *
     * @param buffer memory buffer to register
     * @param access access permissions for the memory region
     * @return registered memory region
     * @throws IOException if memory registration fails
     */
    RdmaMemoryRegion registerMemory(ByteBuffer buffer, EnumSet<RdmaAccess> access) throws IOException;

    /**

            e.name = readString(buffer, bufferIndex, 16, false);
            bufferIndex += 16;
            e.versionMajor = buffer[bufferIndex] & 0xFF;
            bufferIndex++;
            e.versionMinor = buffer[bufferIndex++] & 0xFF;
            e.type = readInt4(buffer, bufferIndex);
            bufferIndex += 4;
            int off = readInt4(buffer, bufferIndex);
            bufferIndex += 4;

    public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {
        final int start = bufferIndex;

        this.capabilities = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;

        System.arraycopy(buffer, bufferIndex, this.serverGuid, 0, 16);
        bufferIndex += 16;

        this.securityMode = SMBUtil.readInt2(buffer, bufferIndex);

        this.maxDataCount = maxDataCount;
    }

    /**
     * Sets the transaction buffer
     * @param buffer
     *            the transaction buffer to use
     */
    public void setBuffer(final byte[] buffer) {
        this.txn_buf = buffer;
    }

    /**
     * Releases and returns the transaction buffer
     * @return the txn_buf
     */
    public byte[] releaseBuffer() {

        byte[] buffer = new byte[10];

        // Act
        int bytesWritten = transPeekNamedPipe.writeSetupWireFormat(buffer, 0);

        // Assert
        assertEquals(4, bytesWritten);
        assertEquals(SmbComTransaction.TRANS_PEEK_NAMED_PIPE, buffer[0]);
        assertEquals((byte) 0x00, buffer[1]);
        assertEquals((byte) 0x00, buffer[2]);
        assertEquals((byte) 0x00, buffer[3]);

     *
     * @param buffer the buffer containing the message data
     * @param bufferIndex the starting offset in the buffer
     * @return the number of bytes read
     */
    protected int readHeaderWireFormat(final byte[] buffer, final int bufferIndex) {
        this.command = buffer[bufferIndex + SmbConstants.CMD_OFFSET];
        this.errorCode = SMBUtil.readInt4(buffer, bufferIndex + SmbConstants.ERROR_CODE_OFFSET);