runtime.go RawHistoryFolder

1package core
2
3import (
4	"fmt"
5	"sync"
6
7	portout "github.com/bnema/purego-pipewire/internal/ports/out"
8)
9
10type Runtime struct {
11	mu          sync.Mutex
12	capi        portout.CAPI
13	initialized bool
14}
15
16var (
17	pipewireMu     sync.Mutex
18	pipewireRefCnt int
19	pipewireCAPI   portout.CAPI
20)
21
22func NewRuntime(capi portout.CAPI) *Runtime {
23	return &Runtime{capi: capi}
24}
25
26func (r *Runtime) Init() error {
27	r.mu.Lock()
28	defer r.mu.Unlock()
29
30	if r.initialized {
31		return nil
32	}
33	if err := initPipeWire(r.capi); err != nil {
34		return err
35	}
36	r.initialized = true
37	return nil
38}
39
40// initPipeWire initializes the process-level PipeWire API once.
41func initPipeWire(capi portout.CAPI) error {
42	pipewireMu.Lock()
43	defer pipewireMu.Unlock()
44
45	if capi == nil {
46		return fmt.Errorf("runtime requires a non-nil CAPI implementation")
47	}
48
49	if pipewireRefCnt > 0 && pipewireCAPI != nil && capi != pipewireCAPI {
50		return fmt.Errorf("runtime already initialized with a different CAPI implementation")
51	}
52
53	if pipewireRefCnt == 0 {
54		pipewireCAPI = capi
55		capi.PWInit(nil, nil)
56	}
57	pipewireRefCnt++
58	return nil
59}
60
61func (r *Runtime) Deinit() {
62	r.mu.Lock()
63	defer r.mu.Unlock()
64
65	if !r.initialized {
66		return
67	}
68	r.initialized = false
69
70	pipewireMu.Lock()
71	defer pipewireMu.Unlock()
72
73	if pipewireRefCnt == 0 {
74		return
75	}
76
77	pipewireRefCnt--
78	if pipewireRefCnt == 0 {
79		pipewireCAPI.PWDeinit()
80		pipewireCAPI = nil
81	}
82}