Method updateDisk

internal/nodes/node_status_executor.go:209–279

更新硬盘

(status *nodeconfigs.NodeStatus)

// 更新硬盘
func (this *NodeStatusExecutor) updateDisk(status *nodeconfigs.NodeStatus) {
	status.DiskWritingSpeedMB = int(fsutils.DiskSpeedMB)

	partitions, err := disk.Partitions(false)
	if err != nil {
		remotelogs.Error("NODE_STATUS", err.Error())
		return
	}
	lists.Sort(partitions, func(i int, j int) bool {
		p1 := partitions[i]
		p2 := partitions[j]
		return p1.Mountpoint > p2.Mountpoint
	})

	// 当前TeaWeb所在的fs
	var rootFS = ""
	var rootTotal = uint64(0)
	var totalUsed = uint64(0)
	if lists.ContainsString([]string{"darwin", "linux", "freebsd"}, runtime.GOOS) {
		for _, p := range partitions {
			if p.Mountpoint == "/" {
				rootFS = p.Fstype
				usage, _ := disk.Usage(p.Mountpoint)
				if usage != nil {
					rootTotal = usage.Total
					totalUsed = usage.Used
				}
				break
			}
		}
	}

	var total = rootTotal
	var maxUsage = float64(0)
	for _, partition := range partitions {
		if runtime.GOOS != "windows" && !strings.Contains(partition.Device, "/") && !strings.Contains(partition.Device, "\\") {
			continue
		}

		// 跳过不同fs的
		if len(rootFS) > 0 && rootFS != partition.Fstype {
			continue
		}

		usage, err := disk.Usage(partition.Mountpoint)
		if err != nil {
			continue
		}

		if partition.Mountpoint != "/" && (usage.Total != rootTotal || total == 0) {
			total += usage.Total
			totalUsed += usage.Used
			if usage.UsedPercent >= maxUsage {
				maxUsage = usage.UsedPercent
				status.DiskMaxUsagePartition = partition.Mountpoint
			}
		}
	}