void testEncodeIdempotency() {
            String path = "\\\\server\\share";
            buffer = new DfsReferralRequestBuffer(path, 3);

            byte[] dst1 = new byte[buffer.size()];
            byte[] dst2 = new byte[buffer.size()];

            int bytesEncoded1 = buffer.encode(dst1, 0);
            int bytesEncoded2 = buffer.encode(dst2, 0);

            assertEquals(bytesEncoded1, bytesEncoded2);

    int readParameterWordsWireFormat(final byte[] buffer, int bufferIndex) {
        final int start = bufferIndex;

        fid = readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        fileAttributes = readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        lastWriteTime = readUTime(buffer, bufferIndex);
        bufferIndex += 4;
        dataSize = readInt4(buffer, bufferIndex);
        bufferIndex += 4;

        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        // Create buffer for encoding - initially allocate some space
        byte[] encodeBuffer = new byte[1024];
        NdrBuffer dst = new NdrBuffer(encodeBuffer, 0);
        info1.encode(dst);

        ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray());
        // Use the encoded buffer for decoding
        NdrBuffer src = new NdrBuffer(encodeBuffer, 0);

	select {
	case b = <-bp.c:
		// reuse existing buffer
	default:
		// create new aligned buffer
		b = reedsolomon.AllocAligned(1, bp.wcap)[0][:bp.w]
	}
	return b
}

// Put returns the given Buffer to the BytePool.
func (bp *BytePoolCap) Put(b []byte) {
	if bp == nil {
		return
	}

	if cap(b) != bp.wcap {
		// someone tried to put back buffer which is not part of this buffer pool

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

    host: String,
    type: Int,
  ): ByteString =
    Buffer()
      .apply {
        writeShort(0) // query id
        writeShort(256) // flags with recursion
        writeShort(1) // question count
        writeShort(0) // answerCount
        writeShort(0) // authorityResourceCount
        writeShort(0) // additional

        val nameBuf = Buffer()
        val labels = host.split('.').dropLastWhile { it.isEmpty() }

        byte[] buffer = new byte[256];
        int written = trans2FindNext2.writeParametersWireFormat(buffer, 0);

        assertEquals(0, SMBUtil.readInt2(buffer, 0)); // sid
        assertEquals(0, SMBUtil.readInt2(buffer, 2)); // maxItems
        assertEquals(0, SMBUtil.readInt4(buffer, 6)); // resumeKey
    }

    // Helper method to read string from buffer

 * limitations under the License.
 */
package okhttp3.tls.internal.der

import java.math.BigInteger
import okio.Buffer
import okio.BufferedSink
import okio.ByteString

internal class DerWriter(
  sink: BufferedSink,
) {
  /** A stack of buffers that will be concatenated once we know the length of each. */
  private val stack = mutableListOf(sink)

        byte[] buffer = new byte[256];

        // Perform multiple operations
        for (int i = 0; i < 5; i++) {
            trans2QueryFSInfo.writeSetupWireFormat(buffer, 0);
            trans2QueryFSInfo.writeParametersWireFormat(buffer, 0);
            trans2QueryFSInfo.writeDataWireFormat(buffer, 0);
            trans2QueryFSInfo.readSetupWireFormat(buffer, 0, buffer.length);

                // Simulate header reading
                return 33;
            }
        };
        byte[] buffer = new byte[1024];

        // Setup buffer after header
        buffer[33] = 4; // wordCount
        buffer[34] = (byte) 0xFF; // andxCommand
        buffer[36] = 0; // andxOffset low
        buffer[37] = 0; // andxOffset high