lease.go RawHistoryFolder

1package subagents
2
3import (
4	"errors"
5	"fmt"
6	"os"
7	"path/filepath"
8)
9
10// ErrAgentLeaseHeld means another supervisor currently owns an agent's
11// durable state. The lease is advisory; socket probing remains the fence for
12// workers that are still live.
13var ErrAgentLeaseHeld = errors.New("subagents: agent state is owned by another supervisor")
14
15type agentLease struct {
16	file *os.File
17}
18
19func openAgentLeaseFile(stateDir string) (*os.File, error) {
20	if err := os.MkdirAll(stateDir, 0o700); err != nil {
21		return nil, fmt.Errorf("subagents lease directory: %w", err)
22	}
23	path := filepath.Join(stateDir, "owner.lock")
24	file, err := os.OpenFile(path, os.O_CREATE|os.O_RDWR, 0o600)
25	if err != nil {
26		return nil, fmt.Errorf("subagents lease open: %w", err)
27	}
28	_ = file.Chmod(0o600)
29	return file, nil
30}