ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
        EnumSet<RdmaAccess> access = EnumSet.of(RdmaAccess.LOCAL_READ, RdmaAccess.LOCAL_WRITE);

        RdmaMemoryRegion region = provider.registerMemory(buffer, access);
        assertNotNull(region, "Memory region should not be null");
        assertEquals(buffer, region.getBuffer(), "Buffer should match");

  ): Long {
    var byteCount = 0L
    val buffer: Buffer = if (countBytes) Buffer() else sink!!.buffer

    for (i in 0 until encodedNames.size) {
      if (i > 0) buffer.writeByte('&'.code)
      buffer.writeUtf8(encodedNames[i])
      buffer.writeByte('='.code)
      buffer.writeUtf8(encodedValues[i])
    }

    if (countBytes) {
      byteCount = buffer.size
      buffer.clear()
    }

    return byteCount
  }

    }

    /**
     * Encodes this NDR object into the specified buffer
     * @param dst the destination buffer for encoding
     * @throws NdrException if encoding fails
     */
    public abstract void encode(NdrBuffer dst) throws NdrException;

    /**
     * Decodes this NDR object from the specified buffer
     * @param src the source buffer for decoding
     * @throws NdrException if decoding fails
     */

    }

    /**
     * Encodes this NDR object into the specified buffer
     * @param dst the destination buffer for encoding
     * @throws NdrException if encoding fails
     */
    public abstract void encode(NdrBuffer dst) throws NdrException;

    /**
     * Decodes this NDR object from the specified buffer
     * @param src the source buffer for decoding
     * @throws NdrException if decoding fails
     */

    
    @Override
    public void encode(byte[] buffer, int offset) {
        // Context header
        int nameLen = getName().length();
        writeInt4(buffer, offset, 16);  // Next
        writeInt2(buffer, offset + 4, nameLen);  // NameOffset
        writeInt2(buffer, offset + 6, nameLen);  // NameLength
        writeInt2(buffer, offset + 8, 0);  // Reserved
        writeInt2(buffer, offset + 10, STRUCTURE_SIZE);  // DataOffset

    @Override
    public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {
        final int start = bufferIndex;
        this.chunksWritten = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;
        this.chunkBytesWritten = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;
        this.totalBytesWritten = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;

        final int zt = zterm ? 1 : 0;

        length = maximum_length = (short) ((len + zt) * 2);
        buffer = new short[len + zt];

        int i;
        for (i = 0; i < len; i++) {
            buffer[i] = (short) str.charAt(i);
        }
        if (zterm) {
            buffer[i] = (short) 0;
        }
    }

    @Override
    public String toString() {

        ByteBuffer buffer = bufferManager.allocateBuffer(2048);
        assertNotNull(buffer, "Buffer should not be null");
        assertTrue(buffer.capacity() >= 2048, "Buffer should be at least requested size");
        assertTrue(buffer.isDirect(), "Buffer should be direct");
    }

    @Test
    public void testReleaseBuffer() {
        ByteBuffer buffer = bufferManager.allocateBuffer(1024);

        /**
         * The buffer containing the Unicode characters.
         */
        public short[] buffer;

        @Override
        public void encode(NdrBuffer _dst) throws NdrException {
            _dst.align(4);
            _dst.enc_ndr_short(length);
            _dst.enc_ndr_short(maximum_length);
            _dst.enc_ndr_referent(buffer, 1);

            if (buffer != null) {

 * limitations under the License.
 */
package okhttp3

import java.io.IOException
import okhttp3.Interceptor.Chain
import okio.Buffer
import okio.BufferedSink
import okio.ForwardingSink
import okio.Sink
import okio.buffer

/** Rewrites the request body sent to the server to be all uppercase.  */
class UppercaseRequestInterceptor : Interceptor {
  @Throws(IOException::class)