assertEquals(-1, stream.read()); // Should indicate end of stream
        }
    }

    @Test
    public void testMemoryBasedCacheWithLargeData() throws IOException {
        // Create a large byte array (1MB)
        byte[] data = new byte[1024 * 1024];
        for (int i = 0; i < data.length; i++) {
            data[i] = (byte) (i % 256);
        }

        ContentCache cache = new ContentCache(data);

        // Create a file larger than MAX_BUF_SIZE (10MB)
        // Write 11MB of data
        try (FileOutputStream fos = new FileOutputStream(largeFile)) {
            final byte[] chunk = new byte[1024 * 1024]; // 1MB
            for (int i = 0; i < 11; i++) { // Write 11MB
                fos.write(chunk);
            }
        }

        try {
            FileUtil.readBytes(largeFile);

    // Configuration constants
    private static final int MIN_COMPRESSION_SIZE = 512; // 512 bytes minimum
    private static final int MAX_COMPRESSION_SIZE = 1024 * 1024; // 1MB maximum
    private static final int COMPRESSION_LEVEL = Deflater.DEFAULT_COMPRESSION;

    // Supported algorithms

labels.facet_contentLength_100kto500k=100KB - 500KB
labels.facet_contentLength_500kto1m=500KB - 1MB
labels.facet_contentLength_1m=1MB -  
labels.facet_contentLength_10kto50k=10KB - 50KB
labels.facet_contentLength_50kto100k=50KB - 100KB
labels.facet_contentLength_100kto250k=100KB - 250KB
labels.facet_contentLength_250kto500k=250KB - 500KB
labels.facet_contentLength_1mto5m=1MB - 5MB
labels.facet_contentLength_5m=5MB -  

//     methods like Instant Restore, File Level Recovery, and Database/Application restores. Veeam recommends that vendors
//     optimize the storage system for the default value of 1MB minus compression object sizes. The setting simultaneously
//     affects read from source, block, file, dedup, and object storage backup targets for a specific Veeam Job. When customers

    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
```java

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

labels.facet_contentLength_100kto500k=100KB - 500KB
labels.facet_contentLength_500kto1m=500KB - 1MB
labels.facet_contentLength_1m=1MB -  
labels.facet_contentLength_10kto50k=10KB - 50KB
labels.facet_contentLength_50kto100k=50KB - 100KB
labels.facet_contentLength_100kto250k=100KB - 250KB
labels.facet_contentLength_250kto500k=250KB - 500KB
labels.facet_contentLength_1mto5m=1MB - 5MB
labels.facet_contentLength_5m=5MB -  

 *
 * ESSourceReader reader = new ESSourceReader(client, settings, indexName);
 * reader.setScrollSize(1000); // Set the scroll size
 * reader.setLimitOfDocumentSize(1024 * 1024); // Limit document size to 1MB
 * reader.setQuery(QueryBuilders.termQuery("field", "value")); // Set a query
 *
 * Map<String, Object> document;
 * while ((document = reader.read()) != null) {
 *     // Process the document

    public void testValidMessageSize() throws Exception {
        validator.validateMessageSize(1024, false);
        validator.validateMessageSize(65535, true);
        validator.validateMessageSize(1048576, false); // 1MB for SMB2
    }

    @Test
    public void testMessageSizeTooSmall() throws Exception {
        assertThrows(SmbException.class, () -> {
            validator.validateMessageSize(20, false);
        });
    }