From 8a4373e984f332ed6a7ef5ec05c7f29a8ceda840 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Sat, 16 Sep 2023 09:36:04 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=8A=82=E7=82=B9=E7=BC=93?= =?UTF-8?q?=E5=AD=98=E7=A3=81=E7=9B=98=E5=AE=B9=E9=87=8F=E8=AE=BE=E7=BD=AE?= =?UTF-8?q?=E4=B8=8D=E7=94=9F=E6=95=88=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/caches/storage_file.go | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/internal/caches/storage_file.go b/internal/caches/storage_file.go index d481f3e..328703a 100644 --- a/internal/caches/storage_file.go +++ b/internal/caches/storage_file.go @@ -1457,10 +1457,19 @@ func (this *FileStorage) checkDiskSpace() { if err == nil { this.mainDiskIsFull = stat.FreeSize() < minFreeSize - // check capacity (only on main directory) - var policy = this.policy // copy - if !this.mainDiskIsFull && policy != nil { - var capacityBytes = policy.CapacityBytes() // copy + // check capacity (only on main directory) when node capacity had not been set + if !this.mainDiskIsFull { + var capacityBytes int64 + var maxDiskCapacity = SharedManager.MaxDiskCapacity // copy + if maxDiskCapacity != nil && maxDiskCapacity.Bytes() > 0 { + capacityBytes = SharedManager.MaxDiskCapacity.Bytes() + } else { + var policy = this.policy // copy + if policy != nil { + capacityBytes = policy.CapacityBytes() // copy + } + } + if capacityBytes > 0 && stat.UsedSize() >= uint64(capacityBytes) { this.mainDiskIsFull = true }