summaryrefslogtreecommitdiff
path: root/vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go
diff options
context:
space:
mode:
authorLibravatar dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>2023-05-01 11:01:36 +0200
committerLibravatar GitHub <noreply@github.com>2023-05-01 11:01:36 +0200
commitab7f518f5732fe5ac71d806858340b0d86ccc004 (patch)
tree4cfe513f79649731edf908fa3ff5fc005c0bd661 /vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go
parent[chore]: Bump github.com/miekg/dns from 1.1.53 to 1.1.54 (#1727) (diff)
downloadgotosocial-ab7f518f5732fe5ac71d806858340b0d86ccc004.tar.xz
[chore]: Bump github.com/KimMachineGun/automemlimit from 0.2.5 to 0.2.6 (#1723)
Bumps [github.com/KimMachineGun/automemlimit](https://github.com/KimMachineGun/automemlimit) from 0.2.5 to 0.2.6. - [Release notes](https://github.com/KimMachineGun/automemlimit/releases) - [Commits](https://github.com/KimMachineGun/automemlimit/compare/v0.2.5...v0.2.6) --- updated-dependencies: - dependency-name: github.com/KimMachineGun/automemlimit dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Diffstat (limited to 'vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go')
-rw-r--r--vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go42
1 files changed, 34 insertions, 8 deletions
diff --git a/vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go b/vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go
index 2fee2a40a..a5c22de32 100644
--- a/vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go
+++ b/vendor/github.com/KimMachineGun/automemlimit/memlimit/cgroups.go
@@ -4,6 +4,8 @@
package memlimit
import (
+ "path/filepath"
+
"github.com/containerd/cgroups/v3"
"github.com/containerd/cgroups/v3/cgroup1"
"github.com/containerd/cgroups/v3/cgroup2"
@@ -18,7 +20,9 @@ func FromCgroup() (uint64, error) {
switch cgroups.Mode() {
case cgroups.Legacy:
return FromCgroupV1()
- case cgroups.Hybrid, cgroups.Unified:
+ case cgroups.Hybrid:
+ return fromCgroupHybrid()
+ case cgroups.Unified:
return FromCgroupV2()
}
return 0, ErrNoCgroup
@@ -36,21 +40,41 @@ func FromCgroupV1() (uint64, error) {
metrics, err := cg.Stat(cgroup1.IgnoreNotExist)
if err != nil {
return 0, err
- } else if metrics.Memory == nil {
- return 0, ErrNoLimit
}
- return metrics.Memory.HierarchicalMemoryLimit, nil
+ if limit := metrics.GetMemory().GetHierarchicalMemoryLimit(); limit != 0 {
+ return limit, nil
+ }
+
+ return 0, ErrNoLimit
+}
+
+// fromCgroupHybrid returns the memory limit from the cgroup v1 or v2.
+// It checks the cgroup v2 first, and if it fails, it falls back to cgroup v1.
+// TODO: make this function public in the next minor version.
+func fromCgroupHybrid() (uint64, error) {
+ limit, err := fromCgroupV2(filepath.Join(cgroupMountPoint, "unified"))
+ if err == nil {
+ return limit, nil
+ } else if err != ErrNoLimit {
+ return 0, err
+ }
+
+ return FromCgroupV1()
}
// FromCgroupV2 returns the memory limit from the cgroup v2.
func FromCgroupV2() (uint64, error) {
+ return fromCgroupV2(cgroupMountPoint)
+}
+
+func fromCgroupV2(mountPoint string) (uint64, error) {
path, err := cgroup2.NestedGroupPath("")
if err != nil {
return 0, err
}
- m, err := cgroup2.Load(path, cgroup2.WithMountpoint(cgroupMountPoint))
+ m, err := cgroup2.Load(path, cgroup2.WithMountpoint(mountPoint))
if err != nil {
return 0, err
}
@@ -58,9 +82,11 @@ func FromCgroupV2() (uint64, error) {
stats, err := m.Stat()
if err != nil {
return 0, err
- } else if stats.Memory == nil {
- return 0, ErrNoLimit
}
- return stats.Memory.UsageLimit, nil
+ if limit := stats.GetMemory().GetUsageLimit(); limit != 0 {
+ return limit, nil
+ }
+
+ return 0, ErrNoLimit
}