}

        // Check total memory allocation
        long totalSize = (long) size * (long) elementSize;
        long maxAllocation = 100 * 1024 * 1024; // 100MB max

        if (totalSize > maxAllocation) {
            failedValidations.incrementAndGet();
            log.warn("Array allocation too large: {} bytes", totalSize);

}

// BenchmarkPutObjectPart10MbFS - Benchmark FS.PutObjectPart() for object size of 10MB.
func BenchmarkPutObjectPart10MbFS(b *testing.B) {
	benchmarkPutObjectPart(b, "FS", 10*humanize.MiByte)
}

// BenchmarkPutObjectPart10MbErasure - Benchmark Erasure.PutObjectPart() for object size of 10MB.
func BenchmarkPutObjectPart10MbErasure(b *testing.B) {
	benchmarkPutObjectPart(b, "Erasure", 10*humanize.MiByte)

        void shouldHandleTypicalNTFSConfiguration() throws SMBProtocolDecodingException {
            // Given - typical NTFS: 4KB clusters (8 sectors * 512 bytes)
            long totalClusters = 26214400L; // 100GB / 4KB
            long freeClusters = 13107200L; // 50GB / 4KB

            ByteBuffer buffer = ByteBuffer.allocate(32);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
            buffer.putLong(totalClusters);

        void shouldHandleTypicalNTFSConfiguration() throws SMBProtocolDecodingException {
            // Given - typical NTFS: 4KB clusters (8 sectors * 512 bytes)
            long totalClusters = 26214400L; // 100GB / 4KB
            long freeClusters = 13107200L; // 50GB / 4KB

            ByteBuffer buffer = ByteBuffer.allocate(24);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
            buffer.putLong(totalClusters);

labels.facet_contentLength_10k=  - 10KB
labels.facet_contentLength_10kto100k=10KB - 100KB
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

    }

    @Test
    public void testHandleInfoExpiration() {
        // Test durable handle expiration
        HandleInfo durableInfo = new HandleInfo("/test/file.txt", testGuid, testFileId, HandleType.DURABLE_V2, 100, // 100ms timeout
                null);

        assertFalse(durableInfo.isExpired());

        // Wait for expiration
        try {
            Thread.sleep(150);
        } catch (InterruptedException e) {

labels.facet_contentLength_10k=  - 10KB
labels.facet_contentLength_10kto100k=10KB - 100KB
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

		}
	}
	b.Run("1KB", func(b *testing.B) { benchmarkEncrypt(1*1024, b) })
	b.Run("512KB", func(b *testing.B) { benchmarkEncrypt(512*1024, b) })
	b.Run("1MB", func(b *testing.B) { benchmarkEncrypt(1024*1024, b) })
	b.Run("10MB", func(b *testing.B) { benchmarkEncrypt(10*1024*1024, b) })

        try (RankFusionProcessor processor = new RankFusionProcessor()) {
            processor.setSearcher(new TestSearcher(100));
            processor.register(new SlowSearcher(100)); // 100ms delay
            processor.init();

            // Should complete even with slow searcher
            final long startTime = System.currentTimeMillis();

streaming compression due to its stability and performance.

This algorithm is specifically optimized for machine generated content.
Write throughput is typically at least 500MB/s per CPU core,
and scales with the number of available CPU cores.
Decompression speed is typically at least 1GB/s.

This means that in cases where raw IO is below these numbers