Function parseDevices

bcachefs/get.go:410–467

(fsPath string)

}

func parseDevices(fsPath string) (map[string]*DeviceStats, error) {
	entries, err := os.ReadDir(fsPath)
	if err != nil {
		return nil, err
	}

	devices := make(map[string]*DeviceStats)
	for _, entry := range entries {
		if !entry.IsDir() || !strings.HasPrefix(entry.Name(), "dev-") {
			continue
		}
		device := strings.TrimPrefix(entry.Name(), "dev-")
		devPath := filepath.Join(fsPath, entry.Name())

		stats := &DeviceStats{
			Label:    readSysfsFile(filepath.Join(devPath, "label")),
			State:    readSysfsFile(filepath.Join(devPath, "state")),
			IODone:   make(map[string]map[string]uint64),
			IOErrors: make(map[string]uint64),
		}

		if bucketSizeRaw := readSysfsFile(filepath.Join(devPath, "bucket_size")); bucketSizeRaw != "" {
			bucketSize, err := parseHumanReadableBytes(bucketSizeRaw)
			if err != nil {
				return nil, err
			}
			stats.BucketSizeBytes = bucketSize
		}

		nbuckets, err := readUintFile(filepath.Join(devPath, "nbuckets"))
		if err != nil {
			return nil, err
		}
		stats.Buckets = nbuckets

		durability, err := readUintFile(filepath.Join(devPath, "durability"))
		if err != nil {
			return nil, err
		}
		stats.Durability = durability

		ioDone, err := parseDeviceIODone(filepath.Join(devPath, "io_done"))
		if err != nil {
			return nil, err
		}
		stats.IODone = ioDone

		ioErrors, err := parseDeviceIOErrors(filepath.Join(devPath, "io_errors"))
		if err != nil {
			return nil, err
		}
		stats.IOErrors = ioErrors

		devices[device] = stats
	}

	return devices, nil
}