修复节点缓存磁盘容量设置不生效的问题

This commit is contained in:
刘祥超
2023-09-16 09:36:04 +08:00
parent 99670e46a5
commit 8a4373e984

View File

@@ -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
}