diff options
| -rw-r--r-- | weed/topology/volume_growth_reservation_test.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/weed/topology/volume_growth_reservation_test.go b/weed/topology/volume_growth_reservation_test.go index 7b06e626d..36b57a49c 100644 --- a/weed/topology/volume_growth_reservation_test.go +++ b/weed/topology/volume_growth_reservation_test.go @@ -150,15 +150,17 @@ func TestVolumeGrowth_ConcurrentAllocationPreventsRaceCondition(t *testing.T) { successCount.Add(1) 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 { - reservation.releaseAllReservations() - // Simulate volume creation by incrementing count + // First, increment the volume count to reflect the created volume disk := dn.children[NodeId(types.HardDriveType.String())].(*Disk) deltaDiskUsage := &DiskUsageCounts{ volumeCount: 1, } disk.UpAdjustDiskUsageDelta(types.HardDriveType, deltaDiskUsage) + + // Then release the reservation + reservation.releaseAllReservations() } } }(i) |