Skip to content

Commit

Permalink
client: do not disable memory swappiness if kernel does not support it
Browse files Browse the repository at this point in the history
This PR adds a workaround for very old Linux kernels which do not support
the memory swappiness interface file. Normally we write a "0" to the file
to explicitly disable swap. In the case the kernel does not support it,
give libcontainer a nil value so it does not write anything.

Fixes #17448
  • Loading branch information
shoenig committed Jun 20, 2023
1 parent f73b454 commit 232a8ac
Show file tree
Hide file tree
Showing 3 changed files with 41 additions and 3 deletions.
30 changes: 30 additions & 0 deletions client/lib/cgutil/cgutil_linux.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"path/filepath"

"github.com/hashicorp/go-hclog"
"github.com/hashicorp/nomad/helper/pointer"
"github.com/hashicorp/nomad/helper/uuid"
"github.com/opencontainers/runc/libcontainer/cgroups"
lcc "github.com/opencontainers/runc/libcontainer/configs"
Expand Down Expand Up @@ -148,3 +149,32 @@ func CopyCpuset(source, destination string) error {

return nil
}

// MaybeDisableMemorySwappiness will disable memory swappiness, if that controller
// is available. Always the case for cgroups v2, but is not always the case on
// very old kernels with cgroups v1.
func MaybeDisableMemorySwappiness() *uint64 {
bypass := (*uint64)(nil)
zero := pointer.Of[uint64](0)

// cgroups v2 always set zero
if UseV2 {
return zero
}

// cgroups v1 find the cgroups mount path
dir, err := FindCgroupMountpointDir()
if err != nil {
return bypass
}

// e.g. in the standard mount path:
// /sys/fs/cgroup/memory/memory.swappiness
expectPath := filepath.Join(dir, "memory", "memory.swappiness")
_, err = os.Stat(expectPath)
if os.IsNotExist(err) {
return bypass
}

return zero
}
9 changes: 9 additions & 0 deletions client/lib/cgutil/cgutil_linux_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -130,3 +130,12 @@ func TestUtil_CopyCpuset(t *testing.T) {
require.Equal(t, "0-1", strings.TrimSpace(value))
})
}

func TestUtil_MaybeDisableMemorySwappiness(t *testing.T) {
ci.Parallel(t)

// will return 0 on any reasonable kernel (both cgroups v1 and v2)
value := MaybeDisableMemorySwappiness()
must.NotNil(t, value)
must.Eq(t, 0, *value)
}
5 changes: 2 additions & 3 deletions drivers/shared/executor/executor_linux.go
Original file line number Diff line number Diff line change
Expand Up @@ -689,9 +689,8 @@ func configureCgroups(cfg *lconfigs.Config, command *ExecCommand) error {
cfg.Cgroups.Resources.Memory = memHard * 1024 * 1024
cfg.Cgroups.Resources.MemoryReservation = memSoft * 1024 * 1024

// Disable swap to avoid issues on the machine
var memSwappiness uint64
cfg.Cgroups.Resources.MemorySwappiness = &memSwappiness
// Disable swap if possible, to avoid issues on the machine
cfg.Cgroups.Resources.MemorySwappiness = cgutil.MaybeDisableMemorySwappiness()
}

cpuShares := res.Cpu.CpuShares
Expand Down

0 comments on commit 232a8ac

Please sign in to comment.