diff options
| author | chrislu <chris.lu@gmail.com> | 2025-10-20 16:13:41 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-10-20 16:13:48 -0700 |
| commit | c547cd7c18a39e3d157694e8a4891875c183db3c (patch) | |
| tree | 0d6de3ecde169c0d52b70c979e75a9fce43dd5d5 | |
| parent | ffd43218f62b024580bb2a70dc86c36ef5501e0f (diff) | |
| download | seaweedfs-c547cd7c18a39e3d157694e8a4891875c183db3c.tar.xz seaweedfs-c547cd7c18a39e3d157694e8a4891875c183db3c.zip | |
fix tests
| -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) |