Function parseCompressionStats

bcachefs/get.go:211–262

(path string)

}

func parseCompressionStats(path string) (map[string]CompressionStats, error) {
	file, err := openIfExists(path)
	if err != nil {
		return nil, err
	}
	if file == nil {
		return map[string]CompressionStats{}, nil
	}
	defer file.Close()

	stats := make(map[string]CompressionStats)

	scanner := bufio.NewScanner(file)
	scanner.Buffer(make([]byte, 0, 64*1024), 1024*1024)
	lineNum := 0
	for scanner.Scan() {
		lineNum++
		line := scanner.Text()
		if lineNum == 1 {
			continue
		}
		fields := strings.Fields(line)
		if len(fields) < 3 {
			continue
		}
		algorithm := strings.TrimSuffix(fields[0], ":")
		compressed, err := parseHumanReadableBytes(fields[1])
		if err != nil {
			return nil, err
		}
		uncompressed, err := parseHumanReadableBytes(fields[2])
		if err != nil {
			return nil, err
		}
		var avgExtent uint64
		if len(fields) >= 4 {
			avgExtent, err = parseHumanReadableBytes(fields[3])
			if err != nil {
				return nil, err
			}
		}
		stats[algorithm] = CompressionStats{
			CompressedBytes:        compressed,
			UncompressedBytes:      uncompressed,
			AverageExtentSizeBytes: avgExtent,
		}
	}
	if err := scanner.Err(); err != nil {
		return nil, err
	}
	return stats, nil
}

func parseErrors(path string) (map[string]ErrorStats, error) {
	file, err := openIfExists(path)