Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| cac5b9c86e | |||
| b5d04ef045 | |||
| fcd64438ea | |||
| 0e39e7d960 | |||
|
|
58d6da0e4f |
@@ -64,6 +64,8 @@ func run(args []string, stdout, stderr io.Writer) (exitCode int) {
|
|||||||
return runExport(args[1:], stdout, stderr)
|
return runExport(args[1:], stdout, stderr)
|
||||||
case "preflight":
|
case "preflight":
|
||||||
return runPreflight(args[1:], stdout, stderr)
|
return runPreflight(args[1:], stdout, stderr)
|
||||||
|
case "install-to-ram":
|
||||||
|
return runInstallToRAM(args[1:], stdout, stderr)
|
||||||
case "support-bundle":
|
case "support-bundle":
|
||||||
return runSupportBundle(args[1:], stdout, stderr)
|
return runSupportBundle(args[1:], stdout, stderr)
|
||||||
case "web":
|
case "web":
|
||||||
@@ -90,6 +92,7 @@ func printRootUsage(w io.Writer) {
|
|||||||
fmt.Fprintln(w, `bee commands:
|
fmt.Fprintln(w, `bee commands:
|
||||||
bee audit --runtime auto|local|livecd --output stdout|file:<path>
|
bee audit --runtime auto|local|livecd --output stdout|file:<path>
|
||||||
bee preflight --output stdout|file:<path>
|
bee preflight --output stdout|file:<path>
|
||||||
|
bee install-to-ram
|
||||||
bee export --target <device>
|
bee export --target <device>
|
||||||
bee support-bundle --output stdout|file:<path>
|
bee support-bundle --output stdout|file:<path>
|
||||||
bee web --listen :80 [--audit-path `+app.DefaultAuditJSONPath+`]
|
bee web --listen :80 [--audit-path `+app.DefaultAuditJSONPath+`]
|
||||||
@@ -109,6 +112,8 @@ func runHelp(args []string, stdout, stderr io.Writer) int {
|
|||||||
return runExport([]string{"--help"}, stdout, stdout)
|
return runExport([]string{"--help"}, stdout, stdout)
|
||||||
case "preflight":
|
case "preflight":
|
||||||
return runPreflight([]string{"--help"}, stdout, stdout)
|
return runPreflight([]string{"--help"}, stdout, stdout)
|
||||||
|
case "install-to-ram":
|
||||||
|
return runInstallToRAM([]string{"--help"}, stdout, stdout)
|
||||||
case "support-bundle":
|
case "support-bundle":
|
||||||
return runSupportBundle([]string{"--help"}, stdout, stdout)
|
return runSupportBundle([]string{"--help"}, stdout, stdout)
|
||||||
case "web":
|
case "web":
|
||||||
@@ -252,6 +257,32 @@ func runPreflight(args []string, stdout, stderr io.Writer) int {
|
|||||||
return 0
|
return 0
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func runInstallToRAM(args []string, stdout, stderr io.Writer) int {
|
||||||
|
fs := flag.NewFlagSet("install-to-ram", flag.ContinueOnError)
|
||||||
|
fs.SetOutput(stderr)
|
||||||
|
fs.Usage = func() {
|
||||||
|
fmt.Fprintln(stderr, "usage: bee install-to-ram")
|
||||||
|
}
|
||||||
|
if err := fs.Parse(args); err != nil {
|
||||||
|
if err == flag.ErrHelp {
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
return 2
|
||||||
|
}
|
||||||
|
if fs.NArg() != 0 {
|
||||||
|
fs.Usage()
|
||||||
|
return 2
|
||||||
|
}
|
||||||
|
|
||||||
|
application := app.New(platform.New())
|
||||||
|
logLine := func(s string) { fmt.Fprintln(stdout, s) }
|
||||||
|
if err := application.RunInstallToRAM(context.Background(), logLine); err != nil {
|
||||||
|
slog.Error("run install-to-ram", "err", err)
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|
||||||
func runSupportBundle(args []string, stdout, stderr io.Writer) int {
|
func runSupportBundle(args []string, stdout, stderr io.Writer) int {
|
||||||
fs := flag.NewFlagSet("support-bundle", flag.ContinueOnError)
|
fs := flag.NewFlagSet("support-bundle", flag.ContinueOnError)
|
||||||
fs.SetOutput(stderr)
|
fs.SetOutput(stderr)
|
||||||
|
|||||||
@@ -14,6 +14,22 @@ import (
|
|||||||
const installToRAMDir = "/dev/shm/bee-live"
|
const installToRAMDir = "/dev/shm/bee-live"
|
||||||
const copyProgressLogStep int64 = 100 * 1024 * 1024
|
const copyProgressLogStep int64 = 100 * 1024 * 1024
|
||||||
|
|
||||||
|
var liveMediumSquashfsGlob = func() ([]string, error) {
|
||||||
|
return filepath.Glob("/run/live/medium/live/*.squashfs")
|
||||||
|
}
|
||||||
|
|
||||||
|
var runRemountMedium = func() ([]byte, error) {
|
||||||
|
return exec.Command("bee-remount-medium").CombinedOutput()
|
||||||
|
}
|
||||||
|
|
||||||
|
var umountLiveMedium = func() error {
|
||||||
|
return exec.Command("umount", "/run/live/medium").Run()
|
||||||
|
}
|
||||||
|
|
||||||
|
var ejectDevice = func(device string) error {
|
||||||
|
return exec.Command("eject", device).Run()
|
||||||
|
}
|
||||||
|
|
||||||
func (s *System) IsLiveMediaInRAM() bool {
|
func (s *System) IsLiveMediaInRAM() bool {
|
||||||
return s.LiveMediaRAMState().InRAM
|
return s.LiveMediaRAMState().InRAM
|
||||||
}
|
}
|
||||||
@@ -140,8 +156,7 @@ func (s *System) RunInstallToRAM(ctx context.Context, logFunc func(string)) (ret
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
squashfsFiles, err := filepath.Glob("/run/live/medium/live/*.squashfs")
|
squashfsFiles, sourceAvailable := ensureLiveMediumAvailable(log)
|
||||||
sourceAvailable := err == nil && len(squashfsFiles) > 0
|
|
||||||
|
|
||||||
dstDir := installToRAMDir
|
dstDir := installToRAMDir
|
||||||
|
|
||||||
@@ -171,7 +186,7 @@ func (s *System) RunInstallToRAM(ctx context.Context, logFunc func(string)) (ret
|
|||||||
}
|
}
|
||||||
goto bindMedium
|
goto bindMedium
|
||||||
}
|
}
|
||||||
return fmt.Errorf("no squashfs files found in /run/live/medium/live/ and no prior RAM copy in %s — reconnect the installation medium and retry", dstDir)
|
return fmt.Errorf("no squashfs files found in /run/live/medium/live/ and no prior RAM copy in %s — reconnect the installation medium and retry (or run bee-remount-medium as root)", dstDir)
|
||||||
}
|
}
|
||||||
|
|
||||||
{
|
{
|
||||||
@@ -254,10 +269,83 @@ bindMedium:
|
|||||||
if status.InRAM {
|
if status.InRAM {
|
||||||
log(fmt.Sprintf("Verification passed: live medium now served from %s.", describeLiveBootSource(status)))
|
log(fmt.Sprintf("Verification passed: live medium now served from %s.", describeLiveBootSource(status)))
|
||||||
}
|
}
|
||||||
log("Done. Squashfs files are in RAM. Installation media can be safely disconnected.")
|
detachInstallMedium(status, log)
|
||||||
|
log("Done. Squashfs files are in RAM. Installation media has been detached when possible.")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func tryRemountLiveMedium(log func(string)) error {
|
||||||
|
output, err := runRemountMedium()
|
||||||
|
trimmed := strings.TrimSpace(string(output))
|
||||||
|
if err != nil {
|
||||||
|
if trimmed != "" && log != nil {
|
||||||
|
for _, line := range strings.Split(trimmed, "\n") {
|
||||||
|
log("bee-remount-medium: " + line)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if trimmed != "" && log != nil {
|
||||||
|
for _, line := range strings.Split(trimmed, "\n") {
|
||||||
|
log("bee-remount-medium: " + line)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func ensureLiveMediumAvailable(log func(string)) ([]string, bool) {
|
||||||
|
squashfsFiles, err := liveMediumSquashfsGlob()
|
||||||
|
sourceAvailable := err == nil && len(squashfsFiles) > 0
|
||||||
|
if sourceAvailable {
|
||||||
|
return squashfsFiles, true
|
||||||
|
}
|
||||||
|
|
||||||
|
if log != nil {
|
||||||
|
log("Live medium not mounted at /run/live/medium — attempting automatic remount scan...")
|
||||||
|
}
|
||||||
|
if remountErr := tryRemountLiveMedium(log); remountErr != nil {
|
||||||
|
if log != nil {
|
||||||
|
log(fmt.Sprintf("Automatic remount did not restore the live medium: %v", remountErr))
|
||||||
|
}
|
||||||
|
return squashfsFiles, false
|
||||||
|
}
|
||||||
|
|
||||||
|
squashfsFiles, err = liveMediumSquashfsGlob()
|
||||||
|
sourceAvailable = err == nil && len(squashfsFiles) > 0
|
||||||
|
if sourceAvailable && log != nil {
|
||||||
|
log("Live medium restored after remount scan.")
|
||||||
|
}
|
||||||
|
return squashfsFiles, sourceAvailable
|
||||||
|
}
|
||||||
|
|
||||||
|
func detachInstallMedium(status LiveBootSource, log func(string)) {
|
||||||
|
if log == nil {
|
||||||
|
log = func(string) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
log("Detaching original installation medium...")
|
||||||
|
if err := umountLiveMedium(); err != nil {
|
||||||
|
log(fmt.Sprintf("Warning: could not unmount /run/live/medium: %v", err))
|
||||||
|
} else {
|
||||||
|
log("Unmounted /run/live/medium.")
|
||||||
|
}
|
||||||
|
|
||||||
|
device := strings.TrimSpace(status.Device)
|
||||||
|
if device == "" {
|
||||||
|
device = strings.TrimSpace(status.Source)
|
||||||
|
}
|
||||||
|
if device == "" || !strings.HasPrefix(device, "/dev/") {
|
||||||
|
log("No block device identified for eject; skipping media eject.")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if err := ejectDevice(device); err != nil {
|
||||||
|
log(fmt.Sprintf("Warning: could not eject %s: %v", device, err))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
log(fmt.Sprintf("Ejected %s.", device))
|
||||||
|
}
|
||||||
|
|
||||||
func verifyInstallToRAMStatus(status LiveBootSource, dstDir string, mediumRebound bool, log func(string)) error {
|
func verifyInstallToRAMStatus(status LiveBootSource, dstDir string, mediumRebound bool, log func(string)) error {
|
||||||
if status.InRAM {
|
if status.InRAM {
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
@@ -1,6 +1,9 @@
|
|||||||
package platform
|
package platform
|
||||||
|
|
||||||
import "testing"
|
import (
|
||||||
|
"fmt"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
func TestInferLiveBootKind(t *testing.T) {
|
func TestInferLiveBootKind(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
@@ -124,3 +127,156 @@ func TestShouldLogCopyProgress(t *testing.T) {
|
|||||||
t.Fatal("expected final completion log")
|
t.Fatal("expected final completion log")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestTryRemountLiveMedium(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
orig := runRemountMedium
|
||||||
|
t.Cleanup(func() {
|
||||||
|
runRemountMedium = orig
|
||||||
|
})
|
||||||
|
|
||||||
|
t.Run("success", func(t *testing.T) {
|
||||||
|
runRemountMedium = func() ([]byte, error) {
|
||||||
|
return []byte("[10:57:31] Mounted /dev/sr1 on /run/live/medium\n"), nil
|
||||||
|
}
|
||||||
|
var logs []string
|
||||||
|
if err := tryRemountLiveMedium(func(msg string) { logs = append(logs, msg) }); err != nil {
|
||||||
|
t.Fatalf("tryRemountLiveMedium() error = %v", err)
|
||||||
|
}
|
||||||
|
if len(logs) != 1 || logs[0] != "bee-remount-medium: [10:57:31] Mounted /dev/sr1 on /run/live/medium" {
|
||||||
|
t.Fatalf("logs=%v", logs)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
t.Run("failure", func(t *testing.T) {
|
||||||
|
runRemountMedium = func() ([]byte, error) {
|
||||||
|
return []byte("must be run as root\n"), fmt.Errorf("exit status 1")
|
||||||
|
}
|
||||||
|
var logs []string
|
||||||
|
err := tryRemountLiveMedium(func(msg string) { logs = append(logs, msg) })
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error")
|
||||||
|
}
|
||||||
|
if len(logs) != 1 || logs[0] != "bee-remount-medium: must be run as root" {
|
||||||
|
t.Fatalf("logs=%v", logs)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestEnsureLiveMediumAvailableRemountsSource(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
origGlob := liveMediumSquashfsGlob
|
||||||
|
origRemount := runRemountMedium
|
||||||
|
t.Cleanup(func() {
|
||||||
|
liveMediumSquashfsGlob = origGlob
|
||||||
|
runRemountMedium = origRemount
|
||||||
|
})
|
||||||
|
|
||||||
|
callCount := 0
|
||||||
|
liveMediumSquashfsGlob = func() ([]string, error) {
|
||||||
|
callCount++
|
||||||
|
if callCount == 1 {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
return []string{"/run/live/medium/live/filesystem.squashfs"}, nil
|
||||||
|
}
|
||||||
|
runRemountMedium = func() ([]byte, error) {
|
||||||
|
return []byte("Mounted /dev/sr1 on /run/live/medium\n"), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
var logs []string
|
||||||
|
files, ok := ensureLiveMediumAvailable(func(msg string) { logs = append(logs, msg) })
|
||||||
|
if !ok {
|
||||||
|
t.Fatal("expected live medium to become available after remount")
|
||||||
|
}
|
||||||
|
if callCount < 2 {
|
||||||
|
t.Fatalf("liveMediumSquashfsGlob called %d times, want at least 2", callCount)
|
||||||
|
}
|
||||||
|
if len(files) != 1 || files[0] != "/run/live/medium/live/filesystem.squashfs" {
|
||||||
|
t.Fatalf("files=%v", files)
|
||||||
|
}
|
||||||
|
found := false
|
||||||
|
for _, msg := range logs {
|
||||||
|
if msg == "Live medium restored after remount scan." {
|
||||||
|
found = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !found {
|
||||||
|
t.Fatalf("expected remount success log, logs=%v", logs)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestDetachInstallMedium(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
origUmount := umountLiveMedium
|
||||||
|
origEject := ejectDevice
|
||||||
|
t.Cleanup(func() {
|
||||||
|
umountLiveMedium = origUmount
|
||||||
|
ejectDevice = origEject
|
||||||
|
})
|
||||||
|
|
||||||
|
t.Run("success", func(t *testing.T) {
|
||||||
|
var umountCalled bool
|
||||||
|
var ejected string
|
||||||
|
umountLiveMedium = func() error {
|
||||||
|
umountCalled = true
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
ejectDevice = func(device string) error {
|
||||||
|
ejected = device
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
var logs []string
|
||||||
|
detachInstallMedium(LiveBootSource{Kind: "cdrom", Device: "/dev/sr1"}, func(msg string) { logs = append(logs, msg) })
|
||||||
|
if !umountCalled {
|
||||||
|
t.Fatal("expected umountLiveMedium to be called")
|
||||||
|
}
|
||||||
|
if ejected != "/dev/sr1" {
|
||||||
|
t.Fatalf("ejected=%q want /dev/sr1", ejected)
|
||||||
|
}
|
||||||
|
if len(logs) < 3 {
|
||||||
|
t.Fatalf("logs=%v", logs)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
t.Run("no device", func(t *testing.T) {
|
||||||
|
umountLiveMedium = func() error { return nil }
|
||||||
|
ejectDevice = func(device string) error {
|
||||||
|
t.Fatalf("unexpected eject for %q", device)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
var logs []string
|
||||||
|
detachInstallMedium(LiveBootSource{Kind: "ram", Source: "tmpfs"}, func(msg string) { logs = append(logs, msg) })
|
||||||
|
found := false
|
||||||
|
for _, msg := range logs {
|
||||||
|
if msg == "No block device identified for eject; skipping media eject." {
|
||||||
|
found = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !found {
|
||||||
|
t.Fatalf("logs=%v", logs)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
t.Run("eject failure is warning only", func(t *testing.T) {
|
||||||
|
umountLiveMedium = func() error { return nil }
|
||||||
|
ejectDevice = func(device string) error { return fmt.Errorf("exit status 1") }
|
||||||
|
var logs []string
|
||||||
|
detachInstallMedium(LiveBootSource{Kind: "usb", Device: "/dev/sdb1"}, func(msg string) { logs = append(logs, msg) })
|
||||||
|
found := false
|
||||||
|
for _, msg := range logs {
|
||||||
|
if msg == "Warning: could not eject /dev/sdb1: exit status 1" {
|
||||||
|
found = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !found {
|
||||||
|
t.Fatalf("logs=%v", logs)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|||||||
@@ -91,6 +91,7 @@ func (j *jobState) writeLogLineLocked(line string) {
|
|||||||
j.logBuf = bufio.NewWriterSize(f, 64*1024)
|
j.logBuf = bufio.NewWriterSize(f, 64*1024)
|
||||||
}
|
}
|
||||||
_, _ = j.logBuf.WriteString(line + "\n")
|
_, _ = j.logBuf.WriteString(line + "\n")
|
||||||
|
_ = j.logBuf.Flush()
|
||||||
}
|
}
|
||||||
|
|
||||||
// closeLog flushes and closes the log file. Called after all task output is done.
|
// closeLog flushes and closes the log file. Called after all task output is done.
|
||||||
|
|||||||
@@ -431,7 +431,7 @@ fetch('/api/system/ram-status').then(r=>r.json()).then(d=>{
|
|||||||
else if (kind === 'disk') label = 'disk (' + source + ')';
|
else if (kind === 'disk') label = 'disk (' + source + ')';
|
||||||
else label = source;
|
else label = source;
|
||||||
boot.textContent = 'Current boot source: ' + label + '.';
|
boot.textContent = 'Current boot source: ' + label + '.';
|
||||||
txt.textContent = d.message || 'Checking...';
|
txt.textContent = d.blocked_reason || d.message || 'Checking...';
|
||||||
if (d.status === 'ok' || d.in_ram) {
|
if (d.status === 'ok' || d.in_ram) {
|
||||||
txt.style.color = 'var(--ok, green)';
|
txt.style.color = 'var(--ok, green)';
|
||||||
} else if (d.status === 'failed') {
|
} else if (d.status === 'failed') {
|
||||||
|
|||||||
@@ -600,6 +600,17 @@ func (q *taskQueue) startRecoveredTaskMonitorLocked(t *Task, j *jobState) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (q *taskQueue) runTaskExternal(t *Task, j *jobState) {
|
func (q *taskQueue) runTaskExternal(t *Task, j *jobState) {
|
||||||
|
startedKmsgWatch := false
|
||||||
|
if q.kmsgWatcher != nil && isSATTarget(t.Target) {
|
||||||
|
q.kmsgWatcher.NotifyTaskStarted(t.ID, t.Target)
|
||||||
|
startedKmsgWatch = true
|
||||||
|
}
|
||||||
|
defer func() {
|
||||||
|
if startedKmsgWatch && q.kmsgWatcher != nil {
|
||||||
|
q.kmsgWatcher.NotifyTaskFinished(t.ID)
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
stopTail := make(chan struct{})
|
stopTail := make(chan struct{})
|
||||||
doneTail := make(chan struct{})
|
doneTail := make(chan struct{})
|
||||||
defer func() {
|
defer func() {
|
||||||
|
|||||||
@@ -126,6 +126,23 @@ func TestNewTaskJobStateLoadsExistingLog(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestJobAppendFlushesTaskLogImmediately(t *testing.T) {
|
||||||
|
dir := t.TempDir()
|
||||||
|
path := filepath.Join(dir, "task.log")
|
||||||
|
j := newTaskJobState(path)
|
||||||
|
|
||||||
|
j.append("live-line")
|
||||||
|
|
||||||
|
data, err := os.ReadFile(path)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if string(data) != "live-line\n" {
|
||||||
|
t.Fatalf("log=%q want live-line newline", string(data))
|
||||||
|
}
|
||||||
|
j.closeLog()
|
||||||
|
}
|
||||||
|
|
||||||
func TestTaskQueueSnapshotSortsNewestFirst(t *testing.T) {
|
func TestTaskQueueSnapshotSortsNewestFirst(t *testing.T) {
|
||||||
now := time.Date(2026, 4, 2, 12, 0, 0, 0, time.UTC)
|
now := time.Date(2026, 4, 2, 12, 0, 0, 0, time.UTC)
|
||||||
q := &taskQueue{
|
q := &taskQueue{
|
||||||
@@ -849,3 +866,82 @@ func TestExecuteTaskMarksPanicsAsFailedAndClosesKmsgWindow(t *testing.T) {
|
|||||||
t.Fatalf("expected kmsg window to be cleared, got %+v", window)
|
t.Fatalf("expected kmsg window to be cleared, got %+v", window)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestRunTaskExternalOpensAndClosesKmsgWindow(t *testing.T) {
|
||||||
|
dir := t.TempDir()
|
||||||
|
releasePath := filepath.Join(dir, "release")
|
||||||
|
readyPath := filepath.Join(dir, "ready")
|
||||||
|
q := &taskQueue{
|
||||||
|
opts: &HandlerOptions{ExportDir: dir},
|
||||||
|
logsDir: filepath.Join(dir, "tasks"),
|
||||||
|
kmsgWatcher: newKmsgWatcher(nil),
|
||||||
|
trigger: make(chan struct{}, 1),
|
||||||
|
}
|
||||||
|
if err := os.MkdirAll(q.logsDir, 0755); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
tk := &Task{
|
||||||
|
ID: "cpu-external-1",
|
||||||
|
Name: "CPU SAT",
|
||||||
|
Target: "cpu",
|
||||||
|
Status: TaskRunning,
|
||||||
|
CreatedAt: time.Now(),
|
||||||
|
}
|
||||||
|
q.assignTaskLogPathLocked(tk)
|
||||||
|
j := newTaskJobState(tk.LogPath)
|
||||||
|
|
||||||
|
orig := externalTaskRunnerCommand
|
||||||
|
externalTaskRunnerCommand = func(exportDir, taskID string) (*exec.Cmd, error) {
|
||||||
|
script := "printf ready > \"$1\"; while [ ! -f \"$2\" ]; do sleep 0.05; done"
|
||||||
|
return exec.Command("sh", "-c", script, "sh", readyPath, releasePath), nil
|
||||||
|
}
|
||||||
|
defer func() { externalTaskRunnerCommand = orig }()
|
||||||
|
|
||||||
|
done := make(chan struct{})
|
||||||
|
go func() {
|
||||||
|
q.runTaskExternal(tk, j)
|
||||||
|
close(done)
|
||||||
|
}()
|
||||||
|
|
||||||
|
deadline := time.Now().Add(2 * time.Second)
|
||||||
|
for time.Now().Before(deadline) {
|
||||||
|
if _, err := os.Stat(readyPath); err == nil {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
time.Sleep(20 * time.Millisecond)
|
||||||
|
}
|
||||||
|
if _, err := os.Stat(readyPath); err != nil {
|
||||||
|
t.Fatalf("external runner did not start: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
q.kmsgWatcher.mu.Lock()
|
||||||
|
activeCount := q.kmsgWatcher.activeCount
|
||||||
|
window := q.kmsgWatcher.window
|
||||||
|
q.kmsgWatcher.mu.Unlock()
|
||||||
|
if activeCount != 1 {
|
||||||
|
t.Fatalf("activeCount while running=%d want 1", activeCount)
|
||||||
|
}
|
||||||
|
if window == nil || len(window.targets) != 1 || window.targets[0] != "cpu" {
|
||||||
|
t.Fatalf("window while running=%+v", window)
|
||||||
|
}
|
||||||
|
|
||||||
|
if err := os.WriteFile(releasePath, []byte("1\n"), 0644); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
select {
|
||||||
|
case <-done:
|
||||||
|
case <-time.After(2 * time.Second):
|
||||||
|
t.Fatal("runTaskExternal did not return")
|
||||||
|
}
|
||||||
|
|
||||||
|
q.kmsgWatcher.mu.Lock()
|
||||||
|
activeCount = q.kmsgWatcher.activeCount
|
||||||
|
window = q.kmsgWatcher.window
|
||||||
|
q.kmsgWatcher.mu.Unlock()
|
||||||
|
if activeCount != 0 {
|
||||||
|
t.Fatalf("activeCount after finish=%d want 0", activeCount)
|
||||||
|
}
|
||||||
|
if window != nil {
|
||||||
|
t.Fatalf("expected kmsg window to be cleared, got %+v", window)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
2
bible
2
bible
Submodule bible updated: d2600f1279...1d89a4918e
Submodule internal/chart updated: 2a15bc87f1...ac8120c8ab
@@ -69,12 +69,27 @@ mkdir -p "${CACHE_ROOT}"
|
|||||||
: "${GOMODCACHE:=${CACHE_ROOT}/go-mod}"
|
: "${GOMODCACHE:=${CACHE_ROOT}/go-mod}"
|
||||||
export GOCACHE GOMODCACHE
|
export GOCACHE GOMODCACHE
|
||||||
|
|
||||||
resolve_audit_version() {
|
resolve_project_version() {
|
||||||
|
if [ -n "${BEE_VERSION:-}" ]; then
|
||||||
|
echo "${BEE_VERSION}"
|
||||||
|
return 0
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [ -n "${BEE_AUDIT_VERSION:-}" ] && [ -n "${BEE_ISO_VERSION:-}" ] && [ "${BEE_AUDIT_VERSION}" != "${BEE_ISO_VERSION}" ]; then
|
||||||
|
echo "ERROR: BEE_AUDIT_VERSION (${BEE_AUDIT_VERSION}) and BEE_ISO_VERSION (${BEE_ISO_VERSION}) differ; versioning must stay synchronized" >&2
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
if [ -n "${BEE_AUDIT_VERSION:-}" ]; then
|
if [ -n "${BEE_AUDIT_VERSION:-}" ]; then
|
||||||
echo "${BEE_AUDIT_VERSION}"
|
echo "${BEE_AUDIT_VERSION}"
|
||||||
return 0
|
return 0
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
if [ -n "${BEE_ISO_VERSION:-}" ]; then
|
||||||
|
echo "${BEE_ISO_VERSION}"
|
||||||
|
return 0
|
||||||
|
fi
|
||||||
|
|
||||||
tag="$(git -C "${REPO_ROOT}" describe --tags --match 'v[0-9]*' --abbrev=7 --dirty 2>/dev/null || true)"
|
tag="$(git -C "${REPO_ROOT}" describe --tags --match 'v[0-9]*' --abbrev=7 --dirty 2>/dev/null || true)"
|
||||||
case "${tag}" in
|
case "${tag}" in
|
||||||
v*)
|
v*)
|
||||||
@@ -97,35 +112,6 @@ resolve_audit_version() {
|
|||||||
date +%Y%m%d
|
date +%Y%m%d
|
||||||
}
|
}
|
||||||
|
|
||||||
# ISO image versioned separately from the audit binary (iso/v* tags).
|
|
||||||
resolve_iso_version() {
|
|
||||||
if [ -n "${BEE_ISO_VERSION:-}" ]; then
|
|
||||||
echo "${BEE_ISO_VERSION}"
|
|
||||||
return 0
|
|
||||||
fi
|
|
||||||
|
|
||||||
# Plain v* tags (e.g. v2.7) take priority — this is the current tagging scheme
|
|
||||||
tag="$(git -C "${REPO_ROOT}" describe --tags --match 'v[0-9]*' --abbrev=7 --dirty 2>/dev/null || true)"
|
|
||||||
case "${tag}" in
|
|
||||||
v*)
|
|
||||||
echo "${tag#v}"
|
|
||||||
return 0
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
|
|
||||||
# Legacy iso/v* tags fallback
|
|
||||||
tag="$(git -C "${REPO_ROOT}" describe --tags --match 'iso/v*' --abbrev=7 --dirty 2>/dev/null || true)"
|
|
||||||
case "${tag}" in
|
|
||||||
iso/v*)
|
|
||||||
echo "${tag#iso/v}"
|
|
||||||
return 0
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
|
|
||||||
# Fall back to audit version so the name is still meaningful
|
|
||||||
resolve_audit_version
|
|
||||||
}
|
|
||||||
|
|
||||||
sync_builder_workdir() {
|
sync_builder_workdir() {
|
||||||
src_dir="$1"
|
src_dir="$1"
|
||||||
dst_dir="$2"
|
dst_dir="$2"
|
||||||
@@ -566,6 +552,42 @@ validate_iso_live_boot_entries() {
|
|||||||
echo "=== live boot validation OK ==="
|
echo "=== live boot validation OK ==="
|
||||||
}
|
}
|
||||||
|
|
||||||
|
validate_iso_grub_theme_assets() {
|
||||||
|
iso_path="$1"
|
||||||
|
echo "=== validating GRUB theme assets in ISO ==="
|
||||||
|
|
||||||
|
[ -f "$iso_path" ] || {
|
||||||
|
echo "ERROR: ISO not found for GRUB theme validation: $iso_path" >&2
|
||||||
|
exit 1
|
||||||
|
}
|
||||||
|
require_iso_reader "$iso_path" >/dev/null 2>&1 || {
|
||||||
|
echo "ERROR: ISO reader unavailable for GRUB theme validation" >&2
|
||||||
|
exit 1
|
||||||
|
}
|
||||||
|
|
||||||
|
iso_files="$(mktemp)"
|
||||||
|
list_iso_files "$iso_path" > "$iso_files" || {
|
||||||
|
echo "ERROR: failed to list ISO files for GRUB theme validation" >&2
|
||||||
|
rm -f "$iso_files"
|
||||||
|
exit 1
|
||||||
|
}
|
||||||
|
|
||||||
|
for required in \
|
||||||
|
boot/grub/config.cfg \
|
||||||
|
boot/grub/theme.cfg \
|
||||||
|
boot/grub/live-theme/theme.txt \
|
||||||
|
boot/grub/live-theme/bee-logo.tga; do
|
||||||
|
grep -q "^${required}$" "$iso_files" || {
|
||||||
|
echo "ERROR: missing GRUB theme asset in ISO: ${required}" >&2
|
||||||
|
rm -f "$iso_files"
|
||||||
|
exit 1
|
||||||
|
}
|
||||||
|
done
|
||||||
|
|
||||||
|
rm -f "$iso_files"
|
||||||
|
echo "=== GRUB theme validation OK ==="
|
||||||
|
}
|
||||||
|
|
||||||
validate_iso_nvidia_runtime() {
|
validate_iso_nvidia_runtime() {
|
||||||
iso_path="$1"
|
iso_path="$1"
|
||||||
[ "$BEE_GPU_VENDOR" = "nvidia" ] || return 0
|
[ "$BEE_GPU_VENDOR" = "nvidia" ] || return 0
|
||||||
@@ -698,16 +720,6 @@ write_canonical_grub_cfg() {
|
|||||||
cat > "$cfg" <<EOF
|
cat > "$cfg" <<EOF
|
||||||
source /boot/grub/config.cfg
|
source /boot/grub/config.cfg
|
||||||
|
|
||||||
echo ""
|
|
||||||
echo " ███████╗ █████╗ ███████╗██╗ ██╗ ██████╗ ███████╗███████╗"
|
|
||||||
echo " ██╔════╝██╔══██╗██╔════╝╚██╗ ██╔╝ ██╔══██╗██╔════╝██╔════╝"
|
|
||||||
echo " █████╗ ███████║███████╗ ╚████╔╝ █████╗██████╔╝█████╗ █████╗"
|
|
||||||
echo " ██╔══╝ ██╔══██║╚════██║ ╚██╔╝ ╚════╝██╔══██╗██╔══╝ ██╔══╝"
|
|
||||||
echo " ███████╗██║ ██║███████║ ██║ ██████╔╝███████╗███████╗"
|
|
||||||
echo " ╚══════╝╚═╝ ╚═╝╚══════╝ ╚═╝ ╚═════╝ ╚══════╝╚══════╝"
|
|
||||||
echo " Hardware Audit LiveCD"
|
|
||||||
echo ""
|
|
||||||
|
|
||||||
menuentry "EASY-BEE" {
|
menuentry "EASY-BEE" {
|
||||||
linux ${kernel} ${append_live} bee.display=kms bee.nvidia.mode=normal pci=realloc net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
linux ${kernel} ${append_live} bee.display=kms bee.nvidia.mode=normal pci=realloc net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
||||||
initrd ${initrd}
|
initrd ${initrd}
|
||||||
@@ -746,13 +758,13 @@ write_canonical_isolinux_cfg() {
|
|||||||
cat > "$cfg" <<EOF
|
cat > "$cfg" <<EOF
|
||||||
label live-@FLAVOUR@-normal
|
label live-@FLAVOUR@-normal
|
||||||
menu label ^EASY-BEE
|
menu label ^EASY-BEE
|
||||||
menu default
|
|
||||||
linux ${kernel}
|
linux ${kernel}
|
||||||
initrd ${initrd}
|
initrd ${initrd}
|
||||||
append ${append_live} nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
append ${append_live} nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
||||||
|
|
||||||
label live-@FLAVOUR@-toram
|
label live-@FLAVOUR@-toram
|
||||||
menu label EASY-BEE (^load to RAM)
|
menu label EASY-BEE (^load to RAM)
|
||||||
|
menu default
|
||||||
linux ${kernel}
|
linux ${kernel}
|
||||||
initrd ${initrd}
|
initrd ${initrd}
|
||||||
append ${append_live} toram nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
append ${append_live} toram nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
||||||
@@ -992,11 +1004,10 @@ recover_iso_memtest() {
|
|||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|
||||||
AUDIT_VERSION_EFFECTIVE="$(resolve_audit_version)"
|
PROJECT_VERSION_EFFECTIVE="$(resolve_project_version)"
|
||||||
ISO_VERSION_EFFECTIVE="$(resolve_iso_version)"
|
ISO_BASENAME="easy-bee-${BUILD_VARIANT}-v${PROJECT_VERSION_EFFECTIVE}-amd64"
|
||||||
ISO_BASENAME="easy-bee-${BUILD_VARIANT}-v${ISO_VERSION_EFFECTIVE}-amd64"
|
|
||||||
# Versioned output directory: dist/easy-bee-v4.1/ — all final artefacts live here.
|
# Versioned output directory: dist/easy-bee-v4.1/ — all final artefacts live here.
|
||||||
OUT_DIR="${DIST_DIR}/easy-bee-v${ISO_VERSION_EFFECTIVE}"
|
OUT_DIR="${DIST_DIR}/easy-bee-v${PROJECT_VERSION_EFFECTIVE}"
|
||||||
mkdir -p "${OUT_DIR}"
|
mkdir -p "${OUT_DIR}"
|
||||||
LOG_DIR="${OUT_DIR}/${ISO_BASENAME}.logs"
|
LOG_DIR="${OUT_DIR}/${ISO_BASENAME}.logs"
|
||||||
LOG_ARCHIVE="${OUT_DIR}/${ISO_BASENAME}.logs.tar.gz"
|
LOG_ARCHIVE="${OUT_DIR}/${ISO_BASENAME}.logs.tar.gz"
|
||||||
@@ -1172,7 +1183,7 @@ fi
|
|||||||
|
|
||||||
echo "=== bee ISO build (variant: ${BUILD_VARIANT}) ==="
|
echo "=== bee ISO build (variant: ${BUILD_VARIANT}) ==="
|
||||||
echo "Debian: ${DEBIAN_VERSION}, Kernel ABI: ${DEBIAN_KERNEL_ABI}, Go: ${GO_VERSION}"
|
echo "Debian: ${DEBIAN_VERSION}, Kernel ABI: ${DEBIAN_KERNEL_ABI}, Go: ${GO_VERSION}"
|
||||||
echo "Audit version: ${AUDIT_VERSION_EFFECTIVE}, ISO version: ${ISO_VERSION_EFFECTIVE}"
|
echo "Project version: ${PROJECT_VERSION_EFFECTIVE}"
|
||||||
echo ""
|
echo ""
|
||||||
|
|
||||||
run_step "sync git submodules" "05-git-submodules" \
|
run_step "sync git submodules" "05-git-submodules" \
|
||||||
@@ -1192,7 +1203,7 @@ if [ "$NEED_BUILD" = "1" ]; then
|
|||||||
"cd '${REPO_ROOT}/audit' && \
|
"cd '${REPO_ROOT}/audit' && \
|
||||||
env GOOS=linux GOARCH=amd64 CGO_ENABLED=0 \
|
env GOOS=linux GOARCH=amd64 CGO_ENABLED=0 \
|
||||||
go build \
|
go build \
|
||||||
-ldflags '-s -w -X main.Version=${AUDIT_VERSION_EFFECTIVE}' \
|
-ldflags '-s -w -X main.Version=${PROJECT_VERSION_EFFECTIVE}' \
|
||||||
-o '${BEE_BIN}' \
|
-o '${BEE_BIN}' \
|
||||||
./cmd/bee"
|
./cmd/bee"
|
||||||
echo "binary: $BEE_BIN"
|
echo "binary: $BEE_BIN"
|
||||||
@@ -1467,8 +1478,10 @@ else
|
|||||||
fi
|
fi
|
||||||
|
|
||||||
cat > "${OVERLAY_STAGE_DIR}/etc/bee-release" <<EOF
|
cat > "${OVERLAY_STAGE_DIR}/etc/bee-release" <<EOF
|
||||||
BEE_ISO_VERSION=${ISO_VERSION_EFFECTIVE}
|
BEE_VERSION=${PROJECT_VERSION_EFFECTIVE}
|
||||||
BEE_AUDIT_VERSION=${AUDIT_VERSION_EFFECTIVE}
|
export BEE_VERSION
|
||||||
|
BEE_ISO_VERSION=${PROJECT_VERSION_EFFECTIVE}
|
||||||
|
BEE_AUDIT_VERSION=${PROJECT_VERSION_EFFECTIVE}
|
||||||
BEE_BUILD_VARIANT=${BUILD_VARIANT}
|
BEE_BUILD_VARIANT=${BUILD_VARIANT}
|
||||||
BEE_GPU_VENDOR=${BEE_GPU_VENDOR}
|
BEE_GPU_VENDOR=${BEE_GPU_VENDOR}
|
||||||
BUILD_DATE=${BUILD_DATE}
|
BUILD_DATE=${BUILD_DATE}
|
||||||
@@ -1561,6 +1574,7 @@ if ! needs_full_build; then
|
|||||||
fast_path_rebuild_iso
|
fast_path_rebuild_iso
|
||||||
ISO_RAW="${LB_DIR}/live-image-amd64.hybrid.iso"
|
ISO_RAW="${LB_DIR}/live-image-amd64.hybrid.iso"
|
||||||
validate_iso_live_boot_entries "$ISO_RAW"
|
validate_iso_live_boot_entries "$ISO_RAW"
|
||||||
|
validate_iso_grub_theme_assets "$ISO_RAW"
|
||||||
validate_iso_nvidia_runtime "$ISO_RAW"
|
validate_iso_nvidia_runtime "$ISO_RAW"
|
||||||
cp "$ISO_RAW" "$ISO_OUT"
|
cp "$ISO_RAW" "$ISO_OUT"
|
||||||
echo ""
|
echo ""
|
||||||
@@ -1615,6 +1629,7 @@ if [ -f "$ISO_RAW" ]; then
|
|||||||
fi
|
fi
|
||||||
validate_iso_memtest "$ISO_RAW"
|
validate_iso_memtest "$ISO_RAW"
|
||||||
validate_iso_live_boot_entries "$ISO_RAW"
|
validate_iso_live_boot_entries "$ISO_RAW"
|
||||||
|
validate_iso_grub_theme_assets "$ISO_RAW"
|
||||||
validate_iso_nvidia_runtime "$ISO_RAW"
|
validate_iso_nvidia_runtime "$ISO_RAW"
|
||||||
cp "$ISO_RAW" "$ISO_OUT"
|
cp "$ISO_RAW" "$ISO_OUT"
|
||||||
touch "${FULL_BUILD_MARKER}"
|
touch "${FULL_BUILD_MARKER}"
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
set default=0
|
set default=1
|
||||||
set timeout=5
|
set timeout=10
|
||||||
|
|
||||||
if [ x$feature_default_font_path = xy ] ; then
|
if [ x$feature_default_font_path = xy ] ; then
|
||||||
font=unicode
|
font=unicode
|
||||||
|
|||||||
@@ -1,12 +1,12 @@
|
|||||||
label live-@FLAVOUR@-normal
|
label live-@FLAVOUR@-normal
|
||||||
menu label ^EASY-BEE
|
menu label ^EASY-BEE
|
||||||
menu default
|
|
||||||
linux @LINUX@
|
linux @LINUX@
|
||||||
initrd @INITRD@
|
initrd @INITRD@
|
||||||
append @APPEND_LIVE@ nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
append @APPEND_LIVE@ nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
||||||
|
|
||||||
label live-@FLAVOUR@-toram
|
label live-@FLAVOUR@-toram
|
||||||
menu label EASY-BEE (^load to RAM)
|
menu label EASY-BEE (^load to RAM)
|
||||||
|
menu default
|
||||||
linux @LINUX@
|
linux @LINUX@
|
||||||
initrd @INITRD@
|
initrd @INITRD@
|
||||||
append @APPEND_LIVE@ toram nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
append @APPEND_LIVE@ toram nomodeset bee.nvidia.mode=normal net.ifnames=0 biosdevname=0 mitigations=off transparent_hugepage=always numa_balancing=disable pcie_aspm=off intel_idle.max_cstate=1 processor.max_cstate=1 nowatchdog nosoftlockup
|
||||||
|
|||||||
@@ -28,6 +28,10 @@ done
|
|||||||
log() { echo "[$(date +%H:%M:%S)] $*"; }
|
log() { echo "[$(date +%H:%M:%S)] $*"; }
|
||||||
die() { log "ERROR: $*" >&2; exit 1; }
|
die() { log "ERROR: $*" >&2; exit 1; }
|
||||||
|
|
||||||
|
if [ "$(id -u)" -ne 0 ]; then
|
||||||
|
die "bee-remount-medium must be run as root (use sudo or a root shell)"
|
||||||
|
fi
|
||||||
|
|
||||||
# Return all candidate block devices (optical + removable USB mass storage)
|
# Return all candidate block devices (optical + removable USB mass storage)
|
||||||
find_candidates() {
|
find_candidates() {
|
||||||
# CD/DVD drives
|
# CD/DVD drives
|
||||||
|
|||||||
Reference in New Issue
Block a user