2d49080056
Commit 6a516acb2e moved the MemInfo type and
ReadMemInfo() function into the pkg/sysinfo package. In an attempt to assist
consumers of these to migrate to the new location, an alias was added.
Unfortunately, the side effect of this alias is that pkg/system now depends
on pkg/sysinfo, which means that consumers of this (such as docker/cli) now
get all (indirect) dependencies of that package as dependency, which includes
many dependencies that should only be needed for the daemon / runtime;
- github.com/cilium/ebpf
- github.com/containerd/cgroups
- github.com/coreos/go-systemd/v22
- github.com/godbus/dbus/v5
- github.com/moby/sys/mountinfo
- github.com/opencontainers/runtime-spec
This patch moves the MemInfo related code to its own package. As the previous move
was not yet part of a release, we're not adding new aliases in pkg/sysinfo.
Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
69 lines
1.4 KiB
Go
69 lines
1.4 KiB
Go
package meminfo
|
|
|
|
import (
|
|
"bufio"
|
|
"io"
|
|
"os"
|
|
"strconv"
|
|
"strings"
|
|
)
|
|
|
|
// readMemInfo retrieves memory statistics of the host system and returns a
|
|
// Memory type.
|
|
func readMemInfo() (*Memory, error) {
|
|
file, err := os.Open("/proc/meminfo")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer file.Close()
|
|
return parseMemInfo(file)
|
|
}
|
|
|
|
// parseMemInfo parses the /proc/meminfo file into
|
|
// a Memory object given an io.Reader to the file.
|
|
// Throws error if there are problems reading from the file
|
|
func parseMemInfo(reader io.Reader) (*Memory, error) {
|
|
meminfo := &Memory{}
|
|
scanner := bufio.NewScanner(reader)
|
|
memAvailable := int64(-1)
|
|
for scanner.Scan() {
|
|
// Expected format: ["MemTotal:", "1234", "kB"]
|
|
parts := strings.Fields(scanner.Text())
|
|
|
|
// Sanity checks: Skip malformed entries.
|
|
if len(parts) < 3 || parts[2] != "kB" {
|
|
continue
|
|
}
|
|
|
|
// Convert to bytes.
|
|
size, err := strconv.Atoi(parts[1])
|
|
if err != nil {
|
|
continue
|
|
}
|
|
// Convert to KiB
|
|
bytes := int64(size) * 1024
|
|
|
|
switch parts[0] {
|
|
case "MemTotal:":
|
|
meminfo.MemTotal = bytes
|
|
case "MemFree:":
|
|
meminfo.MemFree = bytes
|
|
case "MemAvailable:":
|
|
memAvailable = bytes
|
|
case "SwapTotal:":
|
|
meminfo.SwapTotal = bytes
|
|
case "SwapFree:":
|
|
meminfo.SwapFree = bytes
|
|
}
|
|
}
|
|
if memAvailable != -1 {
|
|
meminfo.MemFree = memAvailable
|
|
}
|
|
|
|
// Handle errors that may have occurred during the reading of the file.
|
|
if err := scanner.Err(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return meminfo, nil
|
|
}
|