lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-11-08 09:14:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix tests

Browse Source
This commit is contained in:
chrislu
2025-10-20 16:13:41 -07:00
parent ffd43218f6
commit c547cd7c18
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
weed/topology/volume_growth_reservation_test.go
View File

@@ -150,15 +150,17 @@ func TestVolumeGrowth_ConcurrentAllocationPreventsRaceCondition(t *testing.T) {
successCount.Add(1) successCount.Add(1)
t.Logf("Request %d succeeded, got reservation", requestId) t.Logf("Request %d succeeded, got reservation", requestId)
// Release the reservation to simulate completion // Simulate completion: increment volume count BEFORE releasing reservation
if reservation != nil { if reservation != nil {
reservation.releaseAllReservations() // First, increment the volume count to reflect the created volume
// Simulate volume creation by incrementing count
disk := dn.children[NodeId(types.HardDriveType.String())].(*Disk) disk := dn.children[NodeId(types.HardDriveType.String())].(*Disk)
deltaDiskUsage := &DiskUsageCounts{ deltaDiskUsage := &DiskUsageCounts{
volumeCount: 1, volumeCount: 1,
} }
disk.UpAdjustDiskUsageDelta(types.HardDriveType, deltaDiskUsage) disk.UpAdjustDiskUsageDelta(types.HardDriveType, deltaDiskUsage)
// Then release the reservation
reservation.releaseAllReservations()
} }
} }
}(i) }(i)