var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

    public static final int DEFAULT_RDMA_READ_WRITE_SIZE = 1048576;  // 1MB
    public static final int DEFAULT_RECEIVE_CREDIT_MAX = 255;
    public static final int DEFAULT_SEND_CREDIT_TARGET = 32;
    public static final int DEFAULT_MAX_RECEIVE_SIZE = 8192;
    public static final int DEFAULT_MAX_FRAGMENTED_SIZE = 131072;    // 128KB
    public static final int DEFAULT_MAX_READ_WRITE_SIZE = 1048576;   // 1MB
}
```

### 3.2 RDMA Provider Interface

	xlMeta.Format = xlMetaFormat
	xlMeta.Minio.Release = "test"
	xlMeta.Erasure = ErasureInfo{
		Algorithm:    "klauspost/reedsolomon/vandermonde",
		DataBlocks:   5,
		ParityBlocks: 5,
		BlockSize:    10485760,
		Index:        10,
		Distribution: []int{9, 10, 1, 2, 3, 4, 5, 6, 7, 8},
	}
	xlMeta.Stat = StatInfo{
		Size:    int64(20),
		ModTime: UTCNow(),
	}
	// Set meta data.
	xlMeta.Meta = make(map[string]string)

        if (message instanceof Smb2ReadRequest) {
            return ((Smb2ReadRequest)message).getLength() > 1048576;  // 1MB
        }
        if (message instanceof Smb2WriteRequest) {
            return ((Smb2WriteRequest)message).getLength() > 1048576;
        }
        return false;
    }
    
    private boolean isMetadataOperation(SMBMessage message) {

	const legacyJSON = `{"version":"1.0.1","format":"xl","stat":{"size":2016,"modTime":"2021-10-11T23:40:34.914361617Z"},"erasure":{"algorithm":"klauspost/reedsolomon/vandermonde","data":2,"parity":2,"blockSize":10485760,"index":2,"distribution":[2,3,4,1],"checksum":[{"name":"part.1","algorithm":"highwayhash256S"}]},"minio":{"release":"RELEASE.2019-12-30T05-45-39Z"},"meta":{"X-Minio-Internal-Server-Side-Encryption-Iv":"kInsJB/0yxyz/40ZI+lmQYJfZacDYqZsGh2wEiv+N50...

    }

    @Override
    public void tearDown() throws Exception {
        super.tearDown();
    }

    public void test_init() {
        // Test initialization
        assertEquals(1048576L, indexUpdateCallback.maxDocumentRequestSize);
        assertEquals(10000, indexUpdateCallback.maxDocumentCacheSize);
    }

    public void test_store_withValidData() {
        // Prepare test data

                    1048576, // 1MB per chunk
                    16777216 // 16MB total
            );

            int bytesDecoded = response.decode(buffer, 0, buffer.length);

            assertEquals(12, bytesDecoded);
            assertEquals(16, response.getChunksWritten());
            assertEquals(1048576, response.getChunkBytesWritten());

{

        setResponseAsReceived(response);
        setPrivateField(response, "dialectRevision", 0x0300);
        setPrivateField(response, "maxReadSize", 1048576);
        setPrivateField(response, "maxWriteSize", 1048576);
        setPrivateField(response, "maxTransactSize", 1048576);

        when(mockConfig.getTransactionBufferSize()).thenReturn(65536);
        when(mockConfig.getReceiveBufferSize()).thenReturn(32768);

     */
    public static final int SMB_DIRECT_RESPONSE_REQUESTED = 0x00000001;

    /**
     * Default maximum size for RDMA read/write operations (1MB)
     */
    public static final int DEFAULT_RDMA_READ_WRITE_SIZE = 1048576; // 1MB

    /**
     * Default maximum number of receive credits
     */
    public static final int DEFAULT_RECEIVE_CREDIT_MAX = 255;

    /**
     * Default target number of send credits
     */