This repository has been archived by the owner on Apr 29, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: manage kernel versions explicitly
- Loading branch information
1 parent
f30909a
commit 9d408a0
Showing
9 changed files
with
276 additions
and
54 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,174 @@ | ||
| package kernel | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "io/fs" | ||
| "os/exec" | ||
| "path/filepath" | ||
| "strings" | ||
| "time" | ||
|
|
||
| "github.com/caos/orbos/internal/operator/common" | ||
| "github.com/caos/orbos/internal/operator/nodeagent" | ||
| "github.com/caos/orbos/internal/operator/nodeagent/dep" | ||
| "github.com/caos/orbos/internal/operator/nodeagent/dep/middleware" | ||
| ) | ||
|
|
||
| var _ Installer = (*kernelDep)(nil) | ||
|
|
||
| type Installer interface { | ||
| isKernel() | ||
| nodeagent.Installer | ||
| } | ||
|
|
||
| type kernelDep struct { | ||
| manager *dep.PackageManager | ||
| } | ||
|
|
||
| /* | ||
| New returns the kernel dependency | ||
| Node Agent uninstalls all kernels that don't have a corresponding initramfs file except for the currently | ||
| loaded kernel. If the currently loaded kernel doesn't have a corresponding initramfs file, Node Agent panics. | ||
| If ORBITER desires a specific kernel version, Node Agent installs and locks it, checks the initramfs file and reboots. | ||
| It is in the ORBITERS responsibility to ensure not all nodes are updated and rebooted simultaneously. | ||
| */ | ||
| func New(manager *dep.PackageManager) *kernelDep { | ||
| return &kernelDep{ | ||
| manager: manager, | ||
| } | ||
| } | ||
|
|
||
| func (kernelDep) isKernel() {} | ||
|
|
||
| func (kernelDep) Is(other nodeagent.Installer) bool { | ||
| _, ok := middleware.Unwrap(other).(Installer) | ||
| return ok | ||
| } | ||
|
|
||
| func (kernelDep) String() string { return "Kernel" } | ||
|
|
||
| func (*kernelDep) Equals(other nodeagent.Installer) bool { | ||
| _, ok := other.(*kernelDep) | ||
| return ok | ||
| } | ||
|
|
||
| func (k *kernelDep) Current() (pkg common.Package, err error) { | ||
| loaded, corrupted, err := k.kernelVersions() | ||
| if err != nil { | ||
| return pkg, err | ||
| } | ||
|
|
||
| pkg.Version = loaded | ||
|
|
||
| if len(corrupted) > 0 { | ||
| pkg.Config = map[string]string{"corrupted": strings.Join(corrupted, ",")} | ||
| } | ||
|
|
||
| return pkg, nil | ||
| } | ||
|
|
||
| func (k *kernelDep) Ensure(remove common.Package, ensure common.Package) error { | ||
|
|
||
| corruptedKernels := make([]*dep.Software, 0) | ||
| corruptedKernelsStr, ok := remove.Config["corrupted"] | ||
| if ok && corruptedKernelsStr != "" { | ||
| corruptedKernelsStrs := strings.Split(corruptedKernelsStr, ",") | ||
| for i := range corruptedKernelsStrs { | ||
| corruptedKernels = append(corruptedKernels, &dep.Software{ | ||
| Package: "kernel", | ||
| Version: corruptedKernelsStrs[i], | ||
| }) | ||
| } | ||
| } | ||
|
|
||
| if err := k.manager.Remove(corruptedKernels...); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if remove.Version == ensure.Version || ensure.Version == "" { | ||
| return nil | ||
| } | ||
|
|
||
| if err := k.manager.Install(&dep.Software{ | ||
| Package: "kernel", | ||
| Version: ensure.Version, | ||
| }); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| initramfsVersions, err := listInitramfsVersions() | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| var found bool | ||
| for i := range initramfsVersions { | ||
| if initramfsVersions[i] == ensure.Version { | ||
| fmt.Printf("initramfsVersions[i] == ensure.Version: %s == %s: %t\n", initramfsVersions[i], ensure.Version, initramfsVersions[i] == ensure.Version) | ||
| found = true | ||
| break | ||
| } | ||
| } | ||
| if !found { | ||
| return fmt.Errorf("couldn't find a corresponding initramfs file corresponding kernel version %s. Not rebooting", ensure.Version) | ||
| } | ||
|
|
||
| out, err := exec.Command("reboot").CombinedOutput() | ||
| if err != nil { | ||
| return fmt.Errorf("rebooting system failed: %s: %w", string(out), err) | ||
| } | ||
|
|
||
| // give os signal some time before doing anything | ||
| time.Sleep(5 * time.Second) | ||
| return nil | ||
| } | ||
|
|
||
| func (k *kernelDep) kernelVersions() (loadedKernel string, corruptedKernels []string, err error) { | ||
|
|
||
| loadedKernelBytes, err := exec.Command("uname", "-r").CombinedOutput() | ||
| if err != nil { | ||
| return loadedKernel, corruptedKernels, fmt.Errorf("getting loaded kernel failed: %s: %w", loadedKernel, err) | ||
| } | ||
|
|
||
| loadedKernel = string(loadedKernelBytes) | ||
|
|
||
| initramfsVersions, err := listInitramfsVersions() | ||
| if err != nil { | ||
| return loadedKernel, corruptedKernels, err | ||
| } | ||
|
|
||
| corruptedKernels = make([]string, 0) | ||
| kernels: | ||
| for _, installedKernel := range k.manager.CurrentVersions("kernel") { | ||
| for i := range initramfsVersions { | ||
| if initramfsVersions[i] == installedKernel.Version { | ||
| continue kernels | ||
| } | ||
| } | ||
| if installedKernel.Version == loadedKernel { | ||
| panic("The actively loaded kernel has no corresponding initramfs file. Pleases fix it manually so the machine survives the next reboot") | ||
| } | ||
| corruptedKernels = append(corruptedKernels, installedKernel.Version) | ||
| } | ||
|
|
||
| return loadedKernel, corruptedKernels, nil | ||
| } | ||
|
|
||
| func listInitramfsVersions() ([]string, error) { | ||
| initramfsdir := "/boot/" | ||
| var initramfsKernels []string | ||
| return initramfsKernels, filepath.WalkDir(initramfsdir, func(path string, d fs.DirEntry, err error) error { | ||
| if err != nil { | ||
| return err | ||
| } | ||
| if d.IsDir() { | ||
| return filepath.SkipDir | ||
| } | ||
| if strings.HasPrefix(path, initramfsdir+"initramfs-") && strings.HasSuffix(path, ".img") { | ||
| initramfsKernels = append(initramfsKernels, path[len(initramfsdir+"initramfs-"):strings.LastIndex(path, ".img")]) | ||
| } | ||
| return nil | ||
| }) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,40 @@ | ||
| package dep | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "fmt" | ||
| "os/exec" | ||
| "strings" | ||
| ) | ||
|
|
||
| func (p *PackageManager) rembasedRemove(remove ...*Software) error { | ||
|
|
||
| swStrs := make([]string, len(remove)) | ||
| for i, sw := range remove { | ||
| swStrs[i] = sw.Package | ||
| if sw.Version != "" { | ||
| swStrs[i] = fmt.Sprintf("%s-%s", sw.Package, sw.Version) | ||
| } | ||
| } | ||
|
|
||
| errBuf := new(bytes.Buffer) | ||
| defer errBuf.Reset() | ||
| outBuf := new(bytes.Buffer) | ||
| defer outBuf.Reset() | ||
|
|
||
| cmd := exec.Command("yum", append([]string{"--assumeyes", "remove"}, swStrs...)...) | ||
| cmd.Stderr = errBuf | ||
| cmd.Stdout = outBuf | ||
| err := cmd.Run() | ||
| errStr := errBuf.String() | ||
| outStr := outBuf.String() | ||
| p.monitor.WithFields(map[string]interface{}{ | ||
| "command": fmt.Sprintf("'%s'", strings.Join(cmd.Args, "' '")), | ||
| "stdout": outStr, | ||
| "stderr": errStr, | ||
| }).Debug("Executed yum remove") | ||
| if err != nil { | ||
| return fmt.Errorf("removing yum packages [%s] failed with stderr %s: %w", strings.Join(swStrs, ", "), errStr, err) | ||
| } | ||
| return nil | ||
| } |
Oops, something went wrong.