fs.s3a.fast.upload.buffer=disk # Use disk as the buffer for uploads
fs.s3a.fast.upload=true # Turn on fast upload mode
fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks
fs.s3a.multipart.size=512M # Size of each multipart chunk
fs.s3a.multipart.threshold=512M # Size before using multipart uploads
fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint
fs.s3a.socket.send.buffer=65536 # Write socket buffer hint

    id("gradlebuild.jvm-compile")
}

extensions.create<IntegrationTestExtension>("integTest").apply {
    generateDefaultAutoTestedSamplesTest.convention(true)
    testJvmXmx.convention("512m")
}

val sourceSet = sourceSets.create("${TestType.INTEGRATION.prefix}Test")
jvmCompile {
    addCompilationFrom(sourceSet)
}
addDependenciesAndConfigurations(TestType.INTEGRATION.prefix)

    }

    def "matches daemon process with distribution full on Windows"() {

        assertTrue(response.getInfo() instanceof SmbInfoAllocation);

        SmbInfoAllocation info = (SmbInfoAllocation) response.getInfo();
        assertEquals(8L * 1000000L * 512L, info.getCapacity());
        assertEquals(8L * 500000L * 512L, info.getFree());
    }

    @Test
    void testReadDataWireFormat_FileFsSizeInformation() throws Exception {
        // Test reading FS_SIZE_INFO data

                    new Smb2Lock(512L, 512L, Smb2Lock.SMB2_LOCKFLAG_SHARED_LOCK), new Smb2Lock(1024L, 512L, Smb2Lock.SMB2_LOCKFLAG_UNLOCK),
                    new Smb2Lock(1536L, 512L, Smb2Lock.SMB2_LOCKFLAG_EXCLUSIVE_LOCK | Smb2Lock.SMB2_LOCKFLAG_FAIL_IMMEDIATELY),

	{"BETWEEN_64_MB_AND_128_MB", humanize.MiByte * 64, humanize.MiByte*128 - 1},
	{"BETWEEN_128_MB_AND_512_MB", humanize.MiByte * 128, humanize.MiByte*512 - 1},
	{"GREATER_THAN_512_MB", humanize.MiByte * 512, math.MaxInt64},
}

// ObjectsHistogramIntervals is the list of all intervals
// of object sizes to be included in objects histogram.

        // Simulate various RDMA operations
        stats.recordRdmaRead(1024, 1000000); // 1KB in 1ms
        stats.recordRdmaWrite(2048, 2000000); // 2KB in 2ms
        stats.recordRdmaSend(512, 500000); // 512B in 0.5ms
        stats.recordRdmaReceive(1536, 1500000); // 1.5KB in 1.5ms
        stats.recordError();

        // Verify counters
        assertEquals(1, stats.getRdmaReads(), "Should have 1 read operation");

            buffer.putLong(1048576L); // Total allocation units (1M)
            buffer.putLong(524288L); // Caller available allocation units (512K)
            buffer.putLong(524288L); // Actual free allocation units (512K)
            buffer.putInt(8); // Sectors per allocation unit
            buffer.putInt(512); // Bytes per sector
            byte[] bufferArray = buffer.array();

            // When

            buffer[16] = 0x00;
            buffer[17] = 0x02; // bytesPerSect = 512

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

            assertEquals(20, bytesDecoded);
            assertEquals(8L * 4096L * 512L, smbInfoAllocation.getCapacity());
            assertEquals(8L * 2048L * 512L, smbInfoAllocation.getFree());
        }

        @Test

        SID[] result = sidResolver.getGroupMemberSids(mockContext, testServerName, mockDomainSid, 512, 0);

        assertNotNull(result);
        assertArrayEquals(expectedMembers, result);
        verify(sidResolver, times(1)).getGroupMemberSids(mockContext, testServerName, mockDomainSid, 512, 0);
    }

    @Test
    void testGetGroupMemberSids_EmptyGroup() throws CIFSException {