diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-03-25 01:52:49 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-03-25 01:52:49 +0900 |
| commit | 5c4058d5ac7e7944973ca8216c258fc50c194e22 (patch) | |
| tree | c06597903233c75eca5a1edae8b06d93f0f81774 /internal/app/init0 | |
| parent | e732dca7629edb503df0c65df5f37a99600d567d (diff) | |
app: run in native sandbox
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/app/init0')
| -rw-r--r-- | internal/app/init0/early.go | 18 | ||||
| -rw-r--r-- | internal/app/init0/main.go | 165 | ||||
| -rw-r--r-- | internal/app/init0/payload.go | 13 |
3 files changed, 0 insertions, 196 deletions
diff --git a/internal/app/init0/early.go b/internal/app/init0/early.go deleted file mode 100644 index 0bcf094c..00000000 --- a/internal/app/init0/early.go +++ /dev/null @@ -1,18 +0,0 @@ -package init0 - -import ( - "os" - "path" - - "git.gensokyo.uk/security/fortify/internal" -) - -// used by the parent process - -// TryArgv0 calls [Main] if the last element of argv0 is "init0". -func TryArgv0() { - if len(os.Args) > 0 && path.Base(os.Args[0]) == "init0" { - Main() - internal.Exit(0) - } -} diff --git a/internal/app/init0/main.go b/internal/app/init0/main.go deleted file mode 100644 index 7b8d27c6..00000000 --- a/internal/app/init0/main.go +++ /dev/null @@ -1,165 +0,0 @@ -package init0 - -import ( - "errors" - "log" - "os" - "os/exec" - "os/signal" - "syscall" - "time" - - "git.gensokyo.uk/security/fortify/internal" - "git.gensokyo.uk/security/fortify/internal/fmsg" - "git.gensokyo.uk/security/fortify/sandbox" -) - -const ( - // time to wait for linger processes after death of initial process - residualProcessTimeout = 5 * time.Second -) - -// everything beyond this point runs within pid namespace -// proceed with caution! - -func Main() { - // sharing stdout with shim - // USE WITH CAUTION - fmsg.Prepare("init0") - - // setting this prevents ptrace - if err := sandbox.SetDumpable(sandbox.SUID_DUMP_DISABLE); err != nil { - log.Fatalf("cannot set SUID_DUMP_DISABLE: %s", err) - } - - if os.Getpid() != 1 { - log.Fatal("this process must run as pid 1") - } - - // receive setup payload - var ( - payload Payload - closeSetup func() error - ) - if f, err := sandbox.Receive(Env, &payload, nil); err != nil { - if errors.Is(err, sandbox.ErrInvalid) { - log.Fatal("invalid config descriptor") - } - if errors.Is(err, sandbox.ErrNotSet) { - log.Fatal("FORTIFY_INIT not set") - } - - log.Fatalf("cannot decode init setup payload: %v", err) - } else { - fmsg.Store(payload.Verbose) - closeSetup = f - - // child does not need to see this - if err = os.Unsetenv(Env); err != nil { - log.Printf("cannot unset %s: %v", Env, err) - // not fatal - } else { - fmsg.Verbose("received configuration") - } - } - - // die with parent - if err := sandbox.SetPdeathsig(syscall.SIGKILL); err != nil { - log.Fatalf("prctl(PR_SET_PDEATHSIG, SIGKILL): %v", err) - } - - cmd := exec.Command(payload.Argv0) - cmd.Stdin, cmd.Stdout, cmd.Stderr = os.Stdin, os.Stdout, os.Stderr - cmd.Args = payload.Argv - cmd.Env = os.Environ() - - if err := cmd.Start(); err != nil { - log.Fatalf("cannot start %q: %v", payload.Argv0, err) - } - fmsg.Suspend() - - // close setup pipe as setup is now complete - if err := closeSetup(); err != nil { - log.Println("cannot close setup pipe:", err) - // not fatal - } - - sig := make(chan os.Signal, 2) - signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM) - - type winfo struct { - wpid int - wstatus syscall.WaitStatus - } - info := make(chan winfo, 1) - done := make(chan struct{}) - - go func() { - var ( - err error - wpid = -2 - wstatus syscall.WaitStatus - ) - - // keep going until no child process is left - for wpid != -1 { - if err != nil { - break - } - - if wpid != -2 { - info <- winfo{wpid, wstatus} - } - - err = syscall.EINTR - for errors.Is(err, syscall.EINTR) { - wpid, err = syscall.Wait4(-1, &wstatus, 0, nil) - } - } - if !errors.Is(err, syscall.ECHILD) { - log.Println("unexpected wait4 response:", err) - } - - close(done) - }() - - // closed after residualProcessTimeout has elapsed after initial process death - timeout := make(chan struct{}) - - r := 2 - for { - select { - case s := <-sig: - if fmsg.Resume() { - fmsg.Verbosef("terminating on %s after process start", s.String()) - } else { - fmsg.Verbosef("terminating on %s", s.String()) - } - internal.Exit(0) - case w := <-info: - if w.wpid == cmd.Process.Pid { - // initial process exited, output is most likely available again - fmsg.Resume() - - switch { - case w.wstatus.Exited(): - r = w.wstatus.ExitStatus() - case w.wstatus.Signaled(): - r = 128 + int(w.wstatus.Signal()) - default: - r = 255 - } - - go func() { - time.Sleep(residualProcessTimeout) - close(timeout) - }() - } - case <-done: - internal.Exit(r) - case <-timeout: - log.Println("timeout exceeded waiting for lingering processes") - internal.Exit(r) - } - } -} diff --git a/internal/app/init0/payload.go b/internal/app/init0/payload.go deleted file mode 100644 index d1dc9ec3..00000000 --- a/internal/app/init0/payload.go +++ /dev/null @@ -1,13 +0,0 @@ -package init0 - -const Env = "FORTIFY_INIT" - -type Payload struct { - // target full exec path - Argv0 string - // child full argv - Argv []string - - // verbosity pass through - Verbose bool -} |
