spawn.go RawHistoryFolder

1package core
2
3import (
4	"context"
5
6	"github.com/bnema/neferwl/internal/ports"
7)
8
9// trySpawn is a bounded handoff, not execution admission. The launcher checks
10// Security again before exec: the gate may change after this owner's check.
11func (c *Core) trySpawn(ctx context.Context, req ports.SpawnRequest) bool {
12	if ctx.Err() != nil || c.protectionRequested() {
13		return false
14	}
15	req.Security = c.security
16	select {
17	case c.ch.Spawn <- req:
18		return true
19	default:
20		return false
21	}
22}
23
24// Startup has at most the configured number of pending commands. Initial
25// ready sends are bounded; Run selects the remainder alongside owner events.
26func (c *Core) pendingStartup() (chan<- ports.SpawnRequest, ports.SpawnRequest) {
27	if len(c.startup) == 0 || c.protectionRequested() {
28		return nil, ports.SpawnRequest{}
29	}
30	return c.ch.Spawn, ports.SpawnRequest{Security: c.security, Argv: c.startup[0]}
31}
32
33func (c *Core) spawnStartup(ctx context.Context) {
34	for len(c.startup) > 0 {
35		if !c.trySpawn(ctx, ports.SpawnRequest{Argv: c.startup[0]}) {
36			return
37		}
38		c.startup = c.startup[1:]
39	}
40}