From 0166833431633f7acc8b0d35c4451494eff8710a Mon Sep 17 00:00:00 2001 From: Ophestra Date: Sat, 23 Aug 2025 21:47:06 +0900 Subject: container/dispatcher: start goroutine in dispatcher This allows instrumentation of calls from goroutine without relying on finalizers. Signed-off-by: Ophestra --- container/init.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'container/init.go') diff --git a/container/init.go b/container/init.go index 6bb5a9e7..44e89c7a 100644 --- a/container/init.go +++ b/container/init.go @@ -178,6 +178,7 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV fmt.Sprintf("cannot prepare op at index %d:", i)) k.beforeExit() k.exit(1) + return } } @@ -218,6 +219,7 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV fmt.Sprintf("cannot apply op at index %d:", i)) k.beforeExit() k.exit(1) + return } } @@ -333,7 +335,7 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV info := make(chan winfo, 1) done := make(chan struct{}) - go func(k syscallDispatcher) { + k.new(func(k syscallDispatcher) { var ( err error wpid = -2 @@ -360,7 +362,7 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV } close(done) - }(k.new()) + }) // handle signals to dump withheld messages sig := make(chan os.Signal, 2) @@ -385,7 +387,9 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV } continue } + k.beforeExit() k.exit(0) + return case w := <-info: if w.wpid == cmd.Process.Pid { @@ -396,9 +400,11 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV case w.wstatus.Exited(): r = w.wstatus.ExitStatus() k.verbosef("initial process exited with code %d", w.wstatus.ExitStatus()) + case w.wstatus.Signaled(): r = 128 + int(w.wstatus.Signal()) k.verbosef("initial process exited with signal %s", w.wstatus.Signal()) + default: r = 255 k.verbosef("initial process exited with status %#x", w.wstatus) @@ -410,11 +416,13 @@ func initEntrypoint(k syscallDispatcher, prepareLogger func(prefix string), setV case <-done: k.beforeExit() k.exit(r) + return case <-timeout: k.printf("timeout exceeded waiting for lingering processes") k.beforeExit() k.exit(r) + return } } } -- cgit v1.3.1